Move deno demo GraphQL server into project.

Author: jdillick

server/.gitignore

@@ -0,0 +1 @@
+.env

server/Data/Db.ts

@@ -0,0 +1,12 @@
+import { config } from 'dotenv.ts';
+import {
+  MongoClient,
+} from "mongo.ts";
+
+
+const { parsed: env } = config();
+
+if (typeof env === 'undefined') throw new Error('No .env file found');
+
+const client = new MongoClient();
+export const db = await client.connect(env.MONGODB_URI);

server/Post/Post.ts

@@ -0,0 +1,49 @@
+import { db } from "../Data/Db.ts";
+import { ObjectId } from "mongo.ts";
+
+type PostRecord = {
+  _id?: ObjectId;
+  title: string;
+  body: string;
+  published?: boolean;
+};
+
+export class Post {
+  constructor({ _id, title, body, published = true }: PostRecord) {
+    this.id = _id;
+    this.title = title;
+    this.body = body;
+    this.published = published;
+  }
+
+  id?: ObjectId;
+  title: string;
+  body: string;
+  published?: boolean;
+
+  static collection = db.collection("Post");
+
+  async save() {
+    let rec;
+    if (this.id) {
+      rec = await Post.collection.updateOne({ _id: this.id }, { $set: this });
+    } else {
+      rec = await Post.collection.insertOne(this);
+    }
+
+    const saved = new Post({ ...this, ...rec });
+    Object.assign(this, saved);
+    return saved;
+  }
+
+  static async find(query?: any) {
+    const records = await Post.collection.find(query).toArray();
+    return records.map((record) => new Post(record as PostRecord));
+  }
+
+  static async load(_id: string) {
+    const record = await Post.collection.findOne({ _id: new ObjectId(_id) });
+    if (typeof record == "undefined") return null;
+    return new Post(record as PostRecord);
+  }
+}

server/User/User.ts

@@ -0,0 +1,53 @@
+import { db } from "../Data/Db.ts";
+import { ObjectId } from "mongo.ts";
+
+type UserRecord = {
+  _id?: ObjectId;
+  name: string;
+  email: string;
+  age?: number;
+};
+
+export class User {
+  constructor({ _id, name, email, age }: UserRecord) {
+    this.id = _id;
+    this.name = name;
+    this.email = email;
+    this.age = age;
+  }
+
+  id?: ObjectId;
+  name: string;
+  email: string;
+  age?: number;
+
+  static collection = db.collection("User");
+
+  async save() {
+    let rec;
+    if (this.id) {
+      rec = await User.collection.updateOne({ _id: this.id }, { $set: this });
+    } else {
+      rec = await User.collection.insertOne(this);
+    }
+
+    const saved = new User({ ...this, ...rec });
+    Object.assign(this, saved);
+    return saved;
+  }
+
+  static async find(query?: any) {
+    const records = await User.collection.find(query).toArray();
+    return records.map((record) => new User(record as UserRecord));
+  }
+
+  static async load(_id: string) {
+    const record = await User.collection.findOne({ _id: new ObjectId(_id) });
+    if (typeof record == "undefined") return null;
+    return new User(record as UserRecord);
+  }
+
+  static async delete(_id: string) {
+    return await User.collection.deleteOne({ _id: new ObjectId(_id) });
+  }
+}

server/app.ts

@@ -0,0 +1,189 @@
+import { Application, Router } from 'oak.ts';
+import { applyGraphQL, gql, GQLError } from 'oak_graphql.ts';
+import { User } from './User/User.ts';
+import { Post } from './Post/Post.ts';
+import _ from 'underscore.ts';
+
+const app = new Application();
+
+app.use(async (ctx, next) => {
+  await next();
+  const rt = ctx.response.headers.get('X-Response-Time');
+  console.log(`${ctx.request.method} ${ctx.request.url} - ${rt}`);
+});
+
+app.use(async (ctx, next) => {
+  const start = Date.now();
+  await next();
+  const ms = Date.now() - start;
+  ctx.response.headers.set('X-Response-Time', `${ms}ms`);
+});
+
+const typeDefs = gql`
+  input CreateUserInput {
+    name: String!
+    email: String!
+    age: Int
+  }
+
+  type User {
+    id: ID!
+    name: String!
+    email: String!
+    age: Int
+  }
+
+  type Post {
+    id: ID!
+    title: String!
+    body: String!
+    published: Boolean!
+    author: User
+  }
+
+  type SuccessOrError {
+    success: Boolean!
+    message: String
+  }
+
+  type Query {
+    testInput(input: CreateUserInput!): User
+    me: User!
+    user(id: ID!): User
+    users: [User]!
+    post(id: ID!): Post
+    posts(query: String): [Post!]!
+    grades: [Int!]!
+    add(nums: [Int!]!): Int!
+  }
+
+  type Mutation {
+    createUser(name: String!, email: String!, age: Int): User!
+    deleteUser(id: ID!): SuccessOrError!
+    createPost(title: String!, body: String!, published: Boolean!): Post!
+  }
+`;
+
+// console.log(JSON.stringify(typeDefs, null, 2));
+
+const resolvers = {
+  Query: {
+    testInput: async (
+      parent: any,
+      { input }: { input: { name: string; email: string; age?: number } },
+      context: any,
+      info: any
+    ) => {
+      return { id: 'wtf', ...input };
+    },
+    grades: async (parent: any, args: any, context: any, info: any) => {
+      return [1, 2, 3, 4, 5];
+    },
+    add: async (
+      parent: any,
+      { nums }: { nums: number[] },
+      context: any,
+      info: any
+    ) => {
+      return nums.reduce((a, b) => a + b, 0);
+    },
+    me: async (parent: any, args: any, context: any, info: any) => {
+      return {
+        id: 'jdillick',
+        name: 'John',
+        email: 'john@dillick.us',
+      };
+    },
+
+    user: async (parent: any, { id }: any, context: any, info: any) => {
+      const user = await User.load(id);
+      return user;
+    },
+
+    users: async (parent: any, args: any, context: any, info: any) => {
+      // await new Promise((resolve) => setTimeout(resolve, 5000));
+      const users = User.find();
+      return users;
+    },
+
+    post: async (
+      parent: any,
+      { id }: { id: number },
+      context: any,
+      info: any
+    ) => {
+      console.log({ id });
+      return {
+        id: 123,
+        title: 'Hello World',
+        body: 'This is a post.',
+        published: true,
+      };
+    },
+
+    posts: async (parent: any, { query }: any, context: any, info: any) => {
+      if (query) {
+        return Post.find({ title: { $regex: query, $options: 'i' } });
+      }
+      return Post.find();
+    },
+  },
+  Mutation: {
+    createUser: async (
+      parent: any,
+      { name, email, age }: { name: string; email: string; age?: number },
+      context: any,
+      info: any
+    ) => {
+      const user = new User({ name, email, age });
+      await user.save();
+      return user;
+    },
+    deleteUser: async (
+      parent: any,
+      { id }: { id: string },
+      context: any,
+      info: any
+    ) => {
+      try {
+        const user = await User.delete(id);
+        return { success: true };
+      } catch (e) {
+        return { success: false, message: e.message };
+      }
+    },
+    createPost: async (
+      parent: any,
+      {
+        title,
+        body,
+        published,
+      }: {
+        title: string;
+        body: string;
+        published: boolean;
+      },
+      context: any,
+      info: any
+    ) => {
+      const post = new Post({ title, body, published });
+      await post.save();
+      return post;
+    },
+  },
+};
+
+const GraphQLService = await applyGraphQL<Router>({
+  Router,
+  typeDefs,
+  resolvers,
+  context: (ctx) => {
+    // this line is for passing a user context for the auth
+    return { user: 'Boo' };
+  },
+});
+
+app.use(GraphQLService.routes(), GraphQLService.allowedMethods());
+
+console.log('Server start at http://localhost:4000');
+await app.listen({ port: 4000 });

server/db/.gitkeep

@@ -0,0 +1,2 @@
+{"title":"Hello World","body":"This is a new post.","published":true,"_id":"d138638a-90d0-4b24-b4fc-fb0bba78e075"}
+{"title":"My first post","body":"I'm writing to say: graphql is pretty cool.","published":true,"_id":"e580cd90-5f6c-4771-ac2c-dde327ce0908"}

server/db/posts.json.db

@@ -0,0 +1,3 @@
+{"name":"john","email":"john@dillick.us","_id":"f3ddef83-0534-4f0a-b334-8128140477e7"}
+{"name":"john","email":"john@dillick.us","_id":"bd972d6f-898d-421a-91d0-a28d3229d817"}
+{"name":"john","email":"john@dillick.us","_id":"b6a6c5ab-3232-4cf4-9b1f-a04abf025f68"}

server/db/users.json.db

@@ -0,0 +1,36 @@
+{
+  "unstable": [
+    "bare-node-builtins",
+    "byonm",
+    "unsafe-proto",
+    "webgpu",
+    "broadcast-channel",
+    "worker-options",
+    "cron",
+    "kv",
+    "ffi",
+    "fs",
+    "net"
+  ],
+  "imports": {
+    "/": "./",
+    "./": "./",
+    "archisaurus.ts": "https://deno.land/x/archisaurus@v0.0.1/mod.ts",
+    "tilia/": "https://deno.land/x/tilia@0.1.2/src/",
+    "oak.ts": "https://deno.land/x/oak@v10.0.0/mod.ts",
+    "oak_graphql.ts": "https://deno.land/x/oak_graphql/mod.ts",
+    "mongoose.ts": "https://deno.land/x/mongoose@8.5.2/mod.ts",
+    "reactium-core-sdk.ts": "https://esm.sh/@atomic-reactor/reactium-sdk-core@2.2.0/core?bundle-deps",
+    "underscore.ts": "https://esm.sh/underscore@1.12.1",
+    "mongo.ts": "https://deno.land/x/mongo@v0.33.0/mod.ts",
+    "dotenv.ts": "https://deno.land/x/dot_env@0.2.0/mod.ts"
+  },
+  "lint": {
+    "rules": {
+      "tags": ["recommended"],
+      "rules": {
+        "no-explicit-any": false
+      }
+    }
+  }
+}