Add queries & mutations

Author: davidnguyen11

.npm-scripts/migration.sh .npm-scripts/seed.sh

@@ -1,4 +1,4 @@
 #!/bin/bash
 
 echo "Filling data to `todo_list` table"
-node ./scripts/migration/todo-list/index.ts
+node ./scripts/seed/todo-list/index.ts

README.md

@@ -1,10 +1,70 @@
-# Bookzone API
+# Todo API
 
-## Table content
+# Getting started
 
-- [Getting started](/docs/getting-started.md)
-- [Development](/docs/development.md)
+## Database
+
+Make sure you have [Docker](https://www.docker.com/) installed
+
+### Setting up
+
+**Commands**
+
+To install the database management, run:
+
+```bash
+docker-compose up -d
+```
+
+To create database, run:
+
+```bash
+docker exec -it todo psql -U postgres -c "create database todo"
+```
+
+**.env file**
+
+1. Create the `.env` file
+2. Copy and parse the `connection information` below:
+
+```bash
+DB_USER=postgres
+DB_HOST=localhost
+DB_DATABASE=todo
+DB_PORT=54320
+```
+
+## Create tables
+
+Open and run the `database/sql/database.sql` by postgres tools (i.e. [pgAdmin](https://www.pgadmin.org/))
+
+## Seeding data
+
+**dump data**
+
+To initialize the dump data for `todo` database, run:
+
+```bash
+npm run seed
+```
+
+## Development
+
+To run development environment
+
+```bash
+npm run dev
+```
+
+## Production
+
+To run production environment
+
+```bash
+npm start
+```
 
 # References
 
 - [node-postgres](https://node-postgres.com/)
+- [pgAdmin](https://www.pgadmin.org/)

docs/development.md

@@ -11,7 +11,7 @@
     "dev": "./.npm-scripts/watch.sh",
     "serve": "node dist/server.js",
     "build": "tsc",
-    "migrate": "./.npm-scripts/migration.sh"
+    "seed": "./.npm-scripts/seed.sh"
   },
   "keywords": [
     "typescript",

docs/getting-started.md

@@ -1,4 +1,4 @@
-const { connect } = require('../../../scripts/migration/db/connect.ts');
+const { connect } = require('../../../scripts/seed/db/connect.ts');
 const pool = connect();
 
 const db = {

package.json

@@ -1,6 +1,6 @@
 var fs = require('fs');
-var { db } = require('../../../scripts/migration/db/index.ts');
-const data = require('../../../scripts/migration/todo-list/data.json')
+var { db } = require('../../../scripts/seed/db/index.ts');
+const data = require('../../../scripts/seed/todo-list/data.json');
 
 const todoListItems = [];
 

scripts/migration/db/connect.ts scripts/seed/db/connect.ts

@@ -7,14 +7,27 @@ type Resolver = {
 
 export function getResolver() {
   let resolver: Resolver = {};
-  // Register resolvers
-  const files = readdirSync('./src/graphql/resolvers');
 
-  files.forEach(name => {
-    const fileName = `${path.resolve(__dirname, 'resolvers')}/${name}`;
+  // Register Query to resolvers
+  const queries = readdirSync('./src/graphql/resolvers/queries');
+  queries.forEach(name => {
+    const fileName = `${path.resolve(__dirname, 'resolvers/queries')}/${name}`;
     const module = require(fileName);
-    resolver.Query = (module.default && module.default.Query) ? { ...resolver.Query, ...module.default.Query } : {};
-    resolver.Mutation = (module.default && module.default.Mutation) ? { ...resolver.Mutation, ...module.default.Mutation } : {};
+    resolver.Query = {
+      ...resolver.Query,
+      ...module,
+    };
+  });
+
+  // Register Mutation to resolvers
+  const mutations = readdirSync('./src/graphql/resolvers/mutations');
+  mutations.forEach(name => {
+    const fileName = `${path.resolve(__dirname, 'resolvers/mutations')}/${name}`;
+    const module = require(fileName);
+    resolver.Mutation = {
+      ...resolver.Mutation,
+      ...module,
+    };
   });
 
   // Register scalar types

scripts/migration/db/index.ts scripts/seed/db/index.ts

@@ -0,0 +1,37 @@
+import { DB, QueryConfig, APIResponse } from '../../../types';
+import { TodoListItem } from '../../../models';
+
+export async function createTodoItem(db: DB, args: any) {
+  const {
+    item: { content },
+  } = args;
+
+  const query: QueryConfig = {
+    text: `INSERT INTO todo_list(content) VALUES($1) RETURNING *`,
+    values: [content],
+  };
+
+  const result = await db.query(query);
+  const response: APIResponse<TodoListItem> = {
+    status: 'fetching',
+  };
+
+  try {
+    if (result.rowCount > 0) {
+      const data = result.rows.map((item: TodoListItem) => {
+        return {
+          id: item.id,
+          content: item.content,
+          createdAt: item.created_at,
+          updatedAt: item.updated_at,
+        };
+      });
+      response.status = 'success';
+      response.data = data;
+    }
+  } catch (e) {
+    response.status = 'error';
+  }
+
+  return response;
+}

scripts/migration/todo-list/data.json scripts/seed/todo-list/data.json

@@ -0,0 +1,38 @@
+import { DB, QueryConfig, APIResponse } from '../../../types';
+import { TodoListItem } from '../../../models';
+
+export async function deleteTodoItem(db: DB, args: any) {
+  const { id } = args;
+
+  const query: QueryConfig = {
+    text: `DELETE FROM todo_list WHERE id = $1 RETURNING *`,
+    values: [id],
+  };
+
+  const result = await db.query(query);
+  const response: APIResponse<TodoListItem> = {
+    status: 'fetching',
+  };
+
+  try {
+    if (result.rowCount > 0) {
+      const data = result.rows.map((item: TodoListItem) => {
+        return {
+          id: item.id,
+          content: item.content,
+          createdAt: item.created_at,
+          updatedAt: item.updated_at,
+        };
+      });
+      response.status = 'success';
+      response.data = data;
+    } else {
+      response.status = 'error';
+      response.message = 'Record is not found';
+    }
+  } catch (e) {
+    response.status = 'error';
+  }
+
+  return response;
+}

scripts/migration/todo-list/index.ts scripts/seed/todo-list/index.ts

@@ -0,0 +1,38 @@
+import { DB, QueryConfig, APIResponse } from '../../../types';
+import { TodoListItem } from '../../../models';
+
+export async function updateTodoItem(db: DB, args: any) {
+  const {
+    id,
+    item: { content },
+  } = args;
+
+  const query: QueryConfig = {
+    text: `UPDATE todo_list SET content = $2 WHERE id = $1 RETURNING *`,
+    values: [id, content],
+  };
+
+  const result = await db.query(query);
+  const response: APIResponse<TodoListItem> = {
+    status: 'fetching',
+  };
+
+  try {
+    if (result.rowCount > 0) {
+      const data = result.rows.map((item: TodoListItem) => {
+        return {
+          id: item.id,
+          content: item.content,
+          createdAt: item.created_at,
+          updatedAt: item.updated_at,
+        };
+      });
+      response.status = 'success';
+      response.data = data;
+    }
+  } catch (e) {
+    response.status = 'error';
+  }
+
+  return response;
+}

src/graphql/resolver.ts

@@ -0,0 +1,38 @@
+import { DB, QueryConfig, APIResponse } from '../../../types';
+import { TodoListItem } from '../../../models';
+
+export async function todoListItems(db: DB, args: any) {
+  let query: QueryConfig = { text: 'SELECT * FROM todo_list' };
+
+  if (args && args.keyword) {
+    query = {
+      text: `SELECT * FROM todo_list WHERE content LIKE '%' || $1 || '%'`,
+      values: [args.keyword],
+    };
+  }
+
+  const result = await db.query(query);
+
+  const response: APIResponse<TodoListItem[]> = {
+    status: 'fetching',
+  };
+
+  try {
+    if (result.rowCount > 0) {
+      const data = result.rows.map((item: TodoListItem) => {
+        return {
+          id: item.id,
+          content: item.content,
+          createdAt: item.created_at,
+          updatedAt: item.updated_at,
+        };
+      });
+      response.status = 'success';
+      response.data = data;
+    }
+  } catch (e) {
+    response.status = 'error';
+  }
+
+  return response;
+}