first commit

Author: tomanagle

.env

@@ -0,0 +1,2 @@
+PRIVATE_KEY=LS0tLS1CRUdJTiBSU0EgUFJJVkFURSBLRVktLS0tLQpNSUlDWFFJQkFBS0JnUUNrWndLTlMzU0V5RUhRNElLamh4UjF5alFrTkNPSVl6K3BNTHdud1hlSHkreWR5VGF1Cm5MMlBtTUVPSXc0bkRCSkpySGNGVWI3R3pjSVdGd0dNSHk2aWxRSFdaWnFSUkFmdklJVHE1TkNVSXFVMzNUcEoKajlDbElNNDEyL255V1Z5R2YrYml3eWErSWpKdUJEaHEwMDJyeHhVWGFtUzgzNWZtVEs3NkxkWVFmUUlEQVFBQgpBb0dCQUlNdno5R0FESktJV2p5YmFxT2kvcWlmbWN2cDd4QytZZVpZaFV3VURaWEhIQ0VzbHYzdkJUUzQ2QlNuCjFIdEVIck83YzU1REJNRVBIM2tSRXFNRm51ZS9IWHRBS1J6U3BGQm9HUldXelp2aytndDJDM0lPdy9hRTJCQ08KaVFUK3l0QUM0b0pnNU8zVU1FVWVsVWJRR0I1ZDlqZGRDWnhxa09iaVR1NXBlT1lCQWtFQS9GRUg1VHRuREhHRQorUG9UNDZwYkVMdW5UclpqdnJBV3FzN1J3a3lFZlo5YjVpbVhYQ0FvaWRFUWIreFdGRVpJNUtvYTNyVXBLeW5mCnkvME9jbnIxRVFKQkFLYk5iQm1EQXp1ZG13RzBjTjhRSDE0RGZOR2F4SVRGaE5LOVRINGVsdEtKY0kzNmhJWFAKYVdwVjRuL3IzNTNkTjNhcFlsbWg1d1U3eGhyc3FPdUhOSzBDUUZJanN2Vk9ORXJadmRjcjJrTzRWck1JMC91TQo1c1hTSDE3MXUxV01nV2svOHJQb0FFMU9ic1FHMmxvRlR6U0VlUUJ2M0JWNlZtK2x6eVJpT2t6TWVIRUNRSGdICkE4MkwxK3l6S1pKZGZJY1crK3RUeVNLdkl0Q0RyV05UOGxJaXd0YjNMWFlOR2dXTHpjaEZ5dm5RQ3BaM1UremcKVURROWE1YjVmMEZxb05ieThQVUNRUURNQzdGcFFsbG5jUGU5L2hDenVXTXg5QnoyLzVTU3R0NFFPRmF5alJscgplNUlzdU9xWkN4RE5qei9uM3JVclZXOGlYeTdhSnAwWEF5anJzVFcrejRSMQotLS0tLUVORCBSU0EgUFJJVkFURSBLRVktLS0tLQ
+PUBLIC_KEY=LS0tLS1CRUdJTiBQVUJMSUMgS0VZLS0tLS0KTUlHZk1BMEdDU3FHU0liM0RRRUJBUVVBQTRHTkFEQ0JpUUtCZ1FDa1p3S05TM1NFeUVIUTRJS2poeFIxeWpRawpOQ09JWXorcE1Md253WGVIeSt5ZHlUYXVuTDJQbU1FT0l3NG5EQkpKckhjRlViN0d6Y0lXRndHTUh5NmlsUUhXClpacVJSQWZ2SUlUcTVOQ1VJcVUzM1RwSmo5Q2xJTTQxMi9ueVdWeUdmK2Jpd3lhK0lqSnVCRGhxMDAycnh4VVgKYW1TODM1Zm1USzc2TGRZUWZRSURBUUFCCi0tLS0tRU5EIFBVQkxJQyBLRVktLS0tLQ

.gitignore

@@ -0,0 +1 @@
+node_modules

config/custom-environment-variables.ts

@@ -0,0 +1,4 @@
+export default {
+  publicKey: "PUBLIC_KEY",
+  privateKey: "PRIVATE_KEY",
+};

config/default.ts

@@ -0,0 +1,3 @@
+export default {
+  dbUri: "mongodb://localhost:27017/graphql-api-tutorial",
+};

config/development.ts

@@ -0,0 +1 @@
+export default {};

config/production.ts

@@ -0,0 +1 @@
+export default {};

config/test.ts

@@ -0,0 +1 @@
+export default {};

package.json

@@ -0,0 +1,33 @@
+{
+  "name": "typegraphql-tutorial",
+  "version": "1.0.0",
+  "main": "index.js",
+  "author": "Tom Nagle",
+  "license": "MIT",
+  "scripts": {
+    "dev": "ts-node-dev --respawn --transpile-only src/index.ts"
+  },
+  "dependencies": {
+    "@typegoose/typegoose": "^9.2.0",
+    "apollo-server": "^3.5.0",
+    "bcrypt": "^5.0.1",
+    "class-validator": "^0.13.2",
+    "config": "^3.3.6",
+    "cookie-parser": "^1.4.6",
+    "dotenv": "^10.0.0",
+    "graphql": "15.x",
+    "jsonwebtoken": "^8.5.1",
+    "mongoose": "^6.0.13",
+    "nanoid": "^3.1.30",
+    "reflect-metadata": "^0.1.13",
+    "type-graphql": "^1.1.1"
+  },
+  "devDependencies": {
+    "@types/bcrypt": "^5.0.0",
+    "@types/config": "^0.0.40",
+    "@types/cookie-parser": "^1.4.2",
+    "@types/jsonwebtoken": "^8.5.6",
+    "ts-node-dev": "^1.1.8",
+    "typescript": "^4.5.2"
+  }
+}

src/index.ts

@@ -0,0 +1,63 @@
+import dotenv from "dotenv";
+dotenv.config();
+import "reflect-metadata";
+import express from "express";
+import { buildSchema } from "type-graphql";
+import cookieParser from "cookie-parser";
+import { ApolloServer } from "apollo-server-express";
+import {
+  ApolloServerPluginLandingPageGraphQLPlayground,
+  ApolloServerPluginLandingPageProductionDefault,
+} from "apollo-server-core";
+import { resolvers } from "./resolvers";
+import { connectToMongo } from "./utils/mongo";
+import { verifyJwt } from "./utils/jwt";
+import { User } from "./schema/user.schema";
+import Context from "./types/context";
+import authChecker from "./utils/authChecker";
+
+async function bootstrap() {
+  // Build the schema
+
+  const schema = await buildSchema({
+    resolvers,
+    authChecker,
+  });
+
+  // Init express
+  const app = express();
+
+  app.use(cookieParser());
+
+  // Create the apollo server
+  const server = new ApolloServer({
+    schema,
+    context: (ctx: Context) => {
+      const context = ctx;
+
+      if (ctx.req.cookies.accessToken) {
+        const user = verifyJwt<User>(ctx.req.cookies.accessToken);
+        context.user = user;
+      }
+      return context;
+    },
+    plugins: [
+      process.env.NODE_ENV === "production"
+        ? ApolloServerPluginLandingPageProductionDefault()
+        : ApolloServerPluginLandingPageGraphQLPlayground(),
+    ],
+  });
+
+  await server.start();
+  // apply middleware to server
+
+  server.applyMiddleware({ app });
+
+  // app.listen on express server
+  app.listen({ port: 4000 }, () => {
+    console.log("App is listening on http://localhost:4000");
+  });
+  connectToMongo();
+}
+
+bootstrap();

src/resolvers/index.ts

@@ -0,0 +1,4 @@
+import UserResolver from "./user.resolver";
+import ProductResolver from "./product.resolver";
+
+export const resolvers = [UserResolver, ProductResolver] as const;

src/resolvers/product.resolver.ts

@@ -0,0 +1,35 @@
+import { Arg, Authorized, Ctx, Mutation, Query, Resolver } from "type-graphql";
+import {
+  CreateProductInput,
+  GetProductInput,
+  Product,
+} from "../schema/product.schema";
+import ProductService from "../service/product.service";
+import Context from "../types/context";
+
+@Resolver()
+export default class ProductResolver {
+  constructor(private productService: ProductService) {
+    this.productService = new ProductService();
+  }
+
+  @Authorized()
+  @Mutation(() => Product)
+  createProduct(
+    @Arg("input") input: CreateProductInput,
+    @Ctx() context: Context
+  ) {
+    const user = context.user!;
+    return this.productService.createProduct({ ...input, user: user?._id });
+  }
+
+  @Query(() => [Product])
+  products() {
+    return this.productService.findProducts();
+  }
+
+  @Query(() => Product)
+  product(@Arg("input") input: GetProductInput) {
+    return this.productService.findSingleProduct(input);
+  }
+}

src/resolvers/user.resolver.ts

@@ -0,0 +1,26 @@
+import { Arg, Ctx, Mutation, Query, Resolver } from "type-graphql";
+import { CreateUserInput, LoginInput, User } from "../schema/user.schema";
+import UserService from "../service/user.service";
+import Context from "../types/context";
+
+@Resolver()
+export default class UserResolver {
+  constructor(private userService: UserService) {
+    this.userService = new UserService();
+  }
+
+  @Mutation(() => User)
+  createUser(@Arg("input") input: CreateUserInput) {
+    return this.userService.createUser(input);
+  }
+
+  @Mutation(() => String) // Returns the JWT
+  login(@Arg("input") input: LoginInput, @Ctx() context: Context) {
+    return this.userService.login(input, context);
+  }
+
+  @Query(() => User, { nullable: true })
+  me(@Ctx() context: Context) {
+    return context.user;
+  }
+}

src/schema/product.schema.ts

@@ -0,0 +1,62 @@
+import { getModelForClass, index, prop, Ref } from "@typegoose/typegoose";
+import { Field, InputType, ObjectType } from "type-graphql";
+import { customAlphabet } from "nanoid";
+import { User } from "./user.schema";
+import { IsNumber, MaxLength, Min, MinLength } from "class-validator";
+
+const nanoid = customAlphabet("abcdefghijklmnopqrstuvwxyz123456789", 10);
+
+@ObjectType()
+@index({ productId: 1 })
+export class Product {
+  @Field(() => String)
+  _id: string;
+
+  @Field(() => String)
+  @prop({ required: true, ref: () => User })
+  user: Ref<User>;
+
+  @Field(() => String)
+  @prop({ required: true })
+  name: string;
+
+  @Field(() => String)
+  @prop({ required: true })
+  description: string;
+
+  @Field(() => String)
+  @prop({ required: true })
+  price: string;
+
+  @Field(() => String)
+  @prop({ required: true, default: () => `product_${nanoid()}, unique: true}` })
+  productId: string;
+}
+
+export const ProductModel = getModelForClass<typeof Product>(Product);
+
+@InputType()
+export class CreateProductInput {
+  @Field()
+  name: string;
+
+  @MinLength(50, {
+    message: "Description must be at least 50 characters",
+  })
+  @MaxLength(1000, {
+    message: "Description must not be more than 1000 characters",
+  })
+  @Field()
+  description: string;
+
+  @IsNumber()
+  @Min(1)
+  @Field()
+  price: number;
+}
+
+@InputType()
+export class GetProductInput {
+  @Field()
+  productId: string;
+}

src/schema/user.schema.ts

@@ -0,0 +1,84 @@
+import {
+  getModelForClass,
+  prop,
+  pre,
+  ReturnModelType,
+  queryMethod,
+  index,
+} from "@typegoose/typegoose";
+import { AsQueryMethod } from "@typegoose/typegoose/lib/types";
+import bcrypt from "bcrypt";
+import { IsEmail, MaxLength, MinLength } from "class-validator";
+import { Field, InputType, ObjectType } from "type-graphql";
+
+function findByEmail(
+  this: ReturnModelType<typeof User, QueryHelpers>,
+  email: User["email"]
+) {
+  return this.findOne({ email });
+}
+
+interface QueryHelpers {
+  findByEmail: AsQueryMethod<typeof findByEmail>;
+}
+
+@pre<User>("save", async function () {
+  // Check that the password is being modified
+  if (!this.isModified("password")) {
+    return;
+  }
+
+  const salt = await bcrypt.genSalt(10);
+
+  const hash = await bcrypt.hashSync(this.password, salt);
+
+  this.password = hash;
+})
+@index({ email: 1 })
+@queryMethod(findByEmail)
+@ObjectType()
+export class User {
+  @Field(() => String)
+  _id: string;
+
+  @Field(() => String)
+  @prop({ required: true })
+  name: string;
+
+  @Field(() => String)
+  @prop({ required: true })
+  email: string;
+
+  @prop({ required: true })
+  password: string;
+}
+
+export const UserModel = getModelForClass<typeof User, QueryHelpers>(User);
+
+@InputType()
+export class CreateUserInput {
+  @Field(() => String)
+  name: string;
+
+  @IsEmail()
+  @Field(() => String)
+  email: string;
+
+  @MinLength(6, {
+    message: "password must be at least 6 characters long",
+  })
+  @MaxLength(50, {
+    message: "password must not be longer than 50 characters",
+  })
+  @Field(() => String)
+  password: string;
+}
+
+@InputType()
+export class LoginInput {
+  @Field(() => String)
+  email: string;
+
+  @Field(() => String)
+  password: string;
+}

src/service/product.service.ts

@@ -0,0 +1,23 @@
+import {
+  CreateProductInput,
+  GetProductInput,
+  ProductModel,
+} from "../schema/product.schema";
+import { User } from "../schema/user.schema";
+
+class ProductService {
+  async createProduct(input: CreateProductInput & { user: User["_id"] }) {
+    return ProductModel.create(input);
+  }
+
+  async findProducts() {
+    // Pagination login
+    return ProductModel.find().lean();
+  }
+
+  async findSingleProduct(input: GetProductInput) {
+    return ProductModel.findOne(input).lean();
+  }
+}
+
+export default ProductService;