Initial commit

.devcontainer/devcontainer.json

@@ -0,0 +1,4 @@
+{
+  "name": "Anythink Development Container",
+  "image": "public.ecr.aws/v0a2l7y2/wilco/anythink-devcontainer:latest"
+}

.github/workflows/wilco-actions.yml

@@ -0,0 +1,34 @@
+on:
+  pull_request:
+    branches:
+      - main
+
+jobs:
+  wilco:
+    runs-on: ubuntu-20.04
+    timeout-minutes: 10
+    name: Pr checks
+
+    steps:
+      - name: Check out project
+        uses: actions/checkout@v2
+
+      - name: Use Node.js
+        uses: actions/setup-node@v3
+        with:
+          node-version: "16"
+
+      - name: Start MongoDB
+        uses: supercharge/mongodb-github-action@1.6.0
+        with:
+          mongodb-version: "4.4"
+
+      - uses: oNaiPs/secrets-to-env-action@v1
+        with:
+          secrets: ${{ toJSON(secrets) }}
+
+      - name: Wilco checks
+        id: Wilco
+        uses: trywilco/actions@main
+        with:
+          engine: ${{ secrets.WILCO_ENGINE_URL }}

backend/.gitignore

@@ -0,0 +1,37 @@
+# Logs
+logs
+*.log
+.DS_Store
+
+npm-debug.log*
+
+# Runtime data
+pids
+*.pid
+*.seed
+
+# Directory for instrumented libs generated by jscoverage/JSCover
+lib-cov
+
+# Coverage directory used by tools like istanbul
+coverage
+
+# Grunt intermediate storage (http://gruntjs.com/creating-plugins#storing-task-files)
+.grunt
+
+# node-waf configuration
+.lock-wscript
+
+# Compiled binary addons (http://nodejs.org/api/addons.html)
+build/Release
+
+# Dependency directory
+node_modules
+
+# Optional npm cache directory
+.npm
+
+# Optional REPL history
+.node_repl_history
+
+.idea

backend/Dockerfile

@@ -0,0 +1 @@
+FROM public.ecr.aws/v0a2l7y2/wilco/anythink-backend-node:latest

backend/Dockerfile.aws

@@ -0,0 +1,10 @@
+FROM node:16
+
+WORKDIR /usr/src
+COPY backend ./backend
+COPY .wilco ./.wilco
+
+# Pre-install npm packages
+WORKDIR /usr/src/backend
+RUN yarn install
+

backend/README.md

@@ -0,0 +1,22 @@
+# Anythink Market Backend
+
+The Anythink Market backend is Node web app written with [Express](https://expressjs.com/)
+
+## Dependencies
+
+- [jsonwebtoken](https://github.com/auth0/node-jsonwebtoken) - For generating JWTs used by authentication
+- [mongoose](https://github.com/Automattic/mongoose) - For modeling and mapping MongoDB data to javascript
+- [mongoose-unique-validator](https://github.com/blakehaswell/mongoose-unique-validator) - For handling unique validation errors in Mongoose. Mongoose only handles validation at the document level, so a unique index across a collection will throw an exception at the driver level. The `mongoose-unique-validator` plugin helps us by formatting the error like a normal mongoose `ValidationError`.
+- [passport](https://github.com/jaredhanson/passport) - For handling user authentication
+- [slug](https://github.com/dodo/node-slug) - For encoding titles into a URL-friendly format
+
+## Application Structure
+
+- `app.js` - The entry point to our application. This file defines our express server and connects it to MongoDB using mongoose. It also requires the routes and models we'll be using in the application.
+- `config/` - This folder contains configuration for passport as well as a central location for configuration/environment variables.
+- `routes/` - This folder contains the route definitions for our API.
+- `models/` - This folder contains the schema definitions for our Mongoose models.
+
+## Error Handling
+
+In `routes/api/index.js`, we define a error-handling middleware for handling Mongoose's `ValidationError`. This middleware will respond with a 422 status code and format the response to have [error messages the clients can understand](https://github.com/gothinkster/realworld/blob/master/API.md#errors-and-status-codes)

backend/app.js

@@ -0,0 +1,89 @@
+require("dotenv").config();
+var http = require("http"),
+  path = require("path"),
+  methods = require("methods"),
+  express = require("express"),
+  bodyParser = require("body-parser"),
+  session = require("express-session"),
+  cors = require("cors"),
+  passport = require("passport"),
+  errorhandler = require("errorhandler"),
+  mongoose = require("mongoose");
+
+var isProduction = process.env.NODE_ENV === "production";
+
+// Create global app object
+var app = express();
+
+app.use(cors());
+
+// Normal express config defaults
+app.use(require("morgan")("dev"));
+app.use(bodyParser.urlencoded({ extended: false }));
+app.use(bodyParser.json());
+
+app.use(require("method-override")());
+app.use(express.static(__dirname + "/public"));
+
+app.use(
+  session({
+    secret: "secret",
+    cookie: { maxAge: 60000 },
+    resave: false,
+    saveUninitialized: false
+  })
+);
+
+if (!isProduction) {
+  app.use(errorhandler());
+}
+
+if (!process.env.MONGODB_URI) {
+  console.warn("Missing MONGODB_URI in env, please add it to your .env file");
+}
+
+mongoose.connect(process.env.MONGODB_URI);
+if (isProduction) {
+} else {
+  mongoose.set("debug", true);
+}
+
+require("./models/User");
+require("./models/Item");
+require("./models/Comment");
+require("./config/passport");
+
+app.use(require("./routes"));
+
+/// catch 404 and forward to error handler
+app.use(function (req, res, next) {
+  if (req.url === "/favicon.ico") {
+    res.writeHead(200, { "Content-Type": "image/x-icon" });
+    res.end();
+  } else {
+    const err = new Error("Not Found");
+    err.status = 404;
+    next(err);
+  }
+});
+
+/// error handler
+app.use(function(err, req, res, next) {
+  console.log(err.stack);
+  if (isProduction) {
+    res.sendStatus(err.status || 500)
+  } else {
+    res.status(err.status || 500);
+    res.json({
+      errors: {
+        message: err.message,
+        error: err
+      }
+    });
+  }
+});
+
+// finally, let's start our server...
+var server = app.listen(process.env.PORT || 3000, function() {
+  console.log("Listening on port " + server.address().port);
+});

backend/config/index.js

@@ -0,0 +1,3 @@
+module.exports = {
+  secret: process.env.NODE_ENV === 'production' ? process.env.SECRET : 'secret'
+};

backend/config/passport.js

@@ -0,0 +1,18 @@
+var passport = require('passport');
+var LocalStrategy = require('passport-local').Strategy;
+var mongoose = require('mongoose');
+var User = mongoose.model('User');
+
+passport.use(new LocalStrategy({
+  usernameField: 'user[email]',
+  passwordField: 'user[password]'
+}, function(email, password, done) {
+  User.findOne({email: email}).then(function(user){
+    if(!user || !user.validPassword(password)){
+      return done(null, false, {errors: {'email or password': 'is invalid'}});
+    }
+
+    return done(null, user);
+  }).catch(done);
+}));
+

backend/lib/event.js

@@ -0,0 +1,25 @@
+const axiosLib = require("axios");
+const fs = require("fs");
+
+const WILCO_ID = process.env.WILCO_ID || fs.readFileSync('../.wilco', 'utf8')
+const baseURL = process.env.ENGINE_BASE_URL || "https://engine.wilco.gg"
+
+const axios = axiosLib.create({
+  baseURL: baseURL,
+  headers: {
+    'Content-type': 'application/json',
+  },
+});
+
+async function sendEvent(event, metadata) {
+    try {
+        const result = await axios.post(`/users/${WILCO_ID}/event`, JSON.stringify({event, metadata}));
+        return result.data;
+    } catch (error) {
+        console.error(`failed to send event ${event} to Wilco engine`)
+    }
+}
+
+module.exports = {
+  sendEvent,
+}

backend/models/Comment.js

@@ -0,0 +1,22 @@
+var mongoose = require("mongoose");
+
+var CommentSchema = new mongoose.Schema(
+  {
+    body: String,
+    seller: { type: mongoose.Schema.Types.ObjectId, ref: "User" },
+    item: { type: mongoose.Schema.Types.ObjectId, ref: "Item" }
+  },
+  { timestamps: true }
+);
+
+// Requires population of seller
+CommentSchema.methods.toJSONFor = function(user) {
+  return {
+    id: this._id,
+    body: this.body,
+    createdAt: this.createdAt,
+    seller: this.seller.toProfileJSONFor(user)
+  };
+};
+
+mongoose.model("Comment", CommentSchema);

backend/models/Item.js

@@ -0,0 +1,62 @@
+var mongoose = require("mongoose");
+var uniqueValidator = require("mongoose-unique-validator");
+var slug = require("slug");
+var User = mongoose.model("User");
+
+var ItemSchema = new mongoose.Schema(
+  {
+    slug: { type: String, lowercase: true, unique: true },
+    title: {type: String, required: [true, "can't be blank"]},
+    description: {type: String, required: [true, "can't be blank"]},
+    image: String,
+    favoritesCount: { type: Number, default: 0 },
+    comments: [{ type: mongoose.Schema.Types.ObjectId, ref: "Comment" }],
+    tagList: [{ type: String }],
+    seller: { type: mongoose.Schema.Types.ObjectId, ref: "User" }
+  },
+  { timestamps: true }
+);
+
+ItemSchema.plugin(uniqueValidator, { message: "is already taken" });
+
+ItemSchema.pre("validate", function(next) {
+  if (!this.slug) {
+    this.slugify();
+  }
+
+  next();
+});
+
+ItemSchema.methods.slugify = function() {
+  this.slug =
+    slug(this.title) +
+    "-" +
+    ((Math.random() * Math.pow(36, 6)) | 0).toString(36);
+};
+
+ItemSchema.methods.updateFavoriteCount = function() {
+  var item = this;
+
+  return User.count({ favorites: { $in: [item._id] } }).then(function(count) {
+    item.favoritesCount = count;
+
+    return item.save();
+  });
+};
+
+ItemSchema.methods.toJSONFor = function(user) {
+  return {
+    slug: this.slug,
+    title: this.title,
+    description: this.description,
+    image: this.image,
+    createdAt: this.createdAt,
+    updatedAt: this.updatedAt,
+    tagList: this.tagList,
+    favorited: user ? user.isFavorite(this._id) : false,
+    favoritesCount: this.favoritesCount,
+    seller: this.seller.toProfileJSONFor(user)
+  };
+};
+
+mongoose.model("Item", ItemSchema);