Release NodeJS+GraphQL example (using apolloServer)

Author: flyingcop

Diff for: .eslintrc.json

@@ -0,0 +1,13 @@
+{
+    "env": {
+        "browser": true,
+        "es2021": true
+    },
+    "extends": "eslint:recommended",
+    "parserOptions": {
+        "ecmaVersion": "latest",
+        "sourceType": "module"
+    },
+    "rules": {
+    }
+}

Diff for: .gitignore

@@ -0,0 +1,21 @@
+**/.terraform/*
+*.tfstate
+*.tfstate.*
+crash.log
+**/node_modules/*
+**/.idea/*
+*.map
+*.tfvars
+package-lock.json
+**/.serverless/*
+dump.rdb
+userAuth.zip
+serverless.yml
+**/.vscode/*
+**/.nyc_output/*
+**/coverage/*
+env.bat
+./serverless_dev_pokers/*
+serverless_dev_pokers/
+sls_pokers.sh
+**/.DS_Store

Diff for: package.json

@@ -0,0 +1,55 @@
+{
+  "name": "example-nodejs-graphql",
+  "version": "1.0.0",
+  "description": "",
+  "main": "index.js",
+  "scripts": {
+    "dev": "ts-node-dev --inspect --watch -- ./src/index.ts",
+    "compile": "tsc",
+    "bundle": "esbuild ./src/index.ts --platform=node --bundle --outfile=./dist/index.js",
+    "build": "tsc && esbuild ./src/index.ts --platform=node --bundle --outfile=./dist/index.js",
+    "start": "node --es-module-specifier-resolution=node ./dist/index.js"
+  },
+  "author": "pokers",
+  "license": "ISC",
+  "dependencies": {
+    "@graphql-tools/schema": "^8.3.11",
+    "@graphql-tools/utils": "^8.6.10",
+    "apollo-server-express": "^3.7.0",
+    "body-parser-graphql": "^1.1.0",
+    "compression": "^1.7.4",
+    "cors": "^2.8.5",
+    "dotenv": "^16.0.1",
+    "express": "^4.18.1",
+    "graphql": "^16.5.0",
+    "lodash": "^4.17.21",
+    "morgan": "^1.10.0",
+    "promise-mysql": "^5.2.0"
+  },
+  "devDependencies": {
+    "@types/compression": "^1.7.2",
+    "@types/cors": "^2.8.12",
+    "@types/express": "^4.17.13",
+    "@types/graphql": "^14.5.0",
+    "@types/http-errors": "^1.8.2",
+    "@types/jest": "^27.5.1",
+    "@types/knex": "^0.16.1",
+    "@types/lodash": "^4.14.182",
+    "@types/morgan": "^1.9.3",
+    "@types/node": "^17.0.33",
+    "@types/supertest": "^2.0.12",
+    "@typescript-eslint/eslint-plugin": "^5.23.0",
+    "@typescript-eslint/parser": "^5.23.0",
+    "concurrently": "^7.2.0",
+    "eslint": "^8.15.0",
+    "eslint-config-prettier": "^8.5.0",
+    "eslint-plugin-import": "^2.26.0",
+    "eslint-plugin-prettier": "^4.0.0",
+    "graphql-import": "^1.0.2",
+    "graphql-import-node": "0.0.5",
+    "nodemon": "^2.0.16",
+    "prettier": "^2.6.2",
+    "supertest": "^6.2.3",
+    "ts-jest": "^28.0.2"
+  }
+}

Diff for: src/config/index.ts

@@ -0,0 +1,13 @@
+import { MySqlConfig } from "../types"
+const config = {
+    port: 8080
+}
+export default config
+
+export const MySql:MySqlConfig = {
+    host: process.env.GO_MYSQL_URL,
+    port: Number(process.env.DB_RDS_PORT),
+    user: process.env.DB_RDS_USER,
+    password: process.env.DB_RDS_PASS,
+    database: process.env.DB_RDS_DATABASE,
+}

Diff for: src/controller/index.ts

@@ -0,0 +1,3 @@
+import { UserController } from './user'
+
+export { UserController }

Diff for: src/controller/user/UserController.ts

@@ -0,0 +1,50 @@
+import {Request, Response} from 'express'
+import { UserQuerySet } from '../../service/mysql'
+
+const getUserList = async (req:Request, res:Response) => {
+    try{
+        const result = await UserQuerySet.getUserList(10, 225)
+        console.log('Query result : ', result)
+
+        res.status(200).send({
+            success: true,
+            data: result
+        })
+    }catch(e){
+        console.error(e)
+        res.status(500).send({message : 'Failed to get user list'})
+    }
+}
+
+const getUser = async (req:Request, res:Response)=>{
+    try{
+        const userId:number = parseInt(req.params.id)
+        const result = await UserQuerySet.getUser(userId)
+        console.log('Query result : ', result)
+
+        res.status(200).send({
+            success: true,
+            data: result[0]
+        })
+    }catch(e){
+        console.error(e)
+        res.status(500).send({message : 'Failed to get user'})
+    }
+}
+
+const postUser = async (req:Request, res:Response)=>{
+    try{
+        res.status(201).send({message: "success"})
+    }catch(e){
+        console.error(e)
+        res.status(500).send({message : 'Failed to get user'})
+    }
+}
+
+
+
+export const UserController = {
+    getUserList,
+    getUser,
+    postUser,
+}

Diff for: src/controller/user/index.ts

@@ -0,0 +1,3 @@
+import { UserController } from "./UserController";
+
+export { UserController}

Diff for: src/gqlschema/index.ts

@@ -0,0 +1,14 @@
+import 'graphql-import-node'
+import { merge } from 'lodash'
+import * as userTypeDefs from './user.graphql'
+import * as orderTypeDefs from './ordering.graphql'
+import { makeExecutableSchema } from '@graphql-tools/schema'
+import { UserResolver, OrderingResolver } from '../resolver/'
+import { GraphQLSchema } from 'graphql'
+
+const schema: GraphQLSchema = makeExecutableSchema({
+  typeDefs: [userTypeDefs, orderTypeDefs],
+  resolvers : merge(UserResolver, OrderingResolver),
+});
+
+export default schema;

Diff for: src/gqlschema/ordering.graphql

@@ -0,0 +1,31 @@
+"""
+'id','int(11) unsigned','NO','PRI',NULL,'auto_increment'
+'status_id','int(11) unsigned','NO','MUL',NULL,''
+'user_id','int(11) unsigned','NO','MUL',NULL,''
+'scooter_id','varchar(20)','NO','MUL',NULL,''
+'billing_info_id','int(11) unsigned','NO','',NULL,''
+'voucher_id','int(11) unsigned','YES','',NULL,''
+'reservation_id','int(11) unsigned','YES','MUL',NULL,''
+'start_time','datetime','YES','MUL',NULL,''
+'end_time','datetime','YES','MUL',NULL,''
+'price','decimal(10,2)','YES','',NULL,''
+'description','varchar(255)','YES','',NULL,''
+"""
+
+type Ordering {
+    id: Int
+    status_id: Int
+    user_id: Int
+    scooter_id: String
+    billing_info_id: Int
+    voucher_id: Int
+    reservation_id: Int
+    start_time: String
+    end_time: String
+    price: Float
+    description: String
+}
+
+type Query {
+    ordering(userId:Int!, count:Int, startDt:String): [ Ordering ]
+}

Diff for: src/gqlschema/user.graphql

@@ -0,0 +1,42 @@
+"""
+'id','int(11) unsigned','NO','PRI',NULL,'auto_increment'
+'cognito_username','varchar(255)','NO','MUL',NULL,''
+'username','varchar(100)','NO','UNI',NULL,''
+'password','varchar(255)','YES','',NULL,''
+'name','varchar(30)','YES','',NULL,''
+'market','varchar(10)','YES','',NULL,''
+'email','varchar(100)','YES','',NULL,''
+'birthday','date','YES','',NULL,''
+'gender','enum(\'F\',\'M\')','YES','',NULL,''
+'phone_number','varchar(50)','NO','MUL',NULL,''
+'used_count','int(11)','YES','',NULL,''
+'status_id','int(11) unsigned','NO','MUL',NULL,''
+'ordering_id','int(11) unsigned','YES','MUL',NULL,''
+'description','varchar(255)','YES','',NULL,''
+"""
+type User {
+    id: Int!
+    cognito_username: String!
+    username: String
+    password: String
+    name: String
+    market: String
+    email: String
+    birthday: String
+    gender: String
+    phone_number: String!
+    used_count: Int
+    status_id: Int
+    ordering_id: Int
+    description: String
+    ordering: [Ordering]
+}
+
+type Query {
+    users(count:Int, offset: Int): [ User ]
+    user(userId:Int!, count: Int, startDt: String): User
+}
+
+type Mutation {
+    addUser(cognito_username: String): Boolean
+}

Diff for: src/handler

@@ -0,0 +1,32 @@
+import express, { Express } from 'express'
+import morgan from 'morgan'
+import cors from 'cors'
+import bodyParser from 'body-parser'
+import config from './config'
+import {initRoutes} from './route'
+import { bodyParserGraphQL } from 'body-parser-graphql'
+import compression from 'compression'
+
+
+const app:Express = express()
+
+app.set('port', config.port)
+
+const corsOptions = {
+    origin: '*',
+}
+app.use(cors(corsOptions))
+
+app.use(morgan('dev'))
+
+app.use(bodyParser.json())
+app.use(bodyParser.urlencoded({extended: true}))
+app.use(bodyParserGraphQL())
+app.use(compression())
+
+initRoutes(app)
+
+app.listen(config.port, () =>{
+    console.log("Start server...\n")
+})
+

Diff for: src/index.ts

@@ -0,0 +1,4 @@
+import { UserResolver } from "./user"
+import { OrderingResolver } from "./ordering"
+
+export { UserResolver, OrderingResolver}

Diff for: src/resolver/index.ts

@@ -0,0 +1,3 @@
+import { OrderingResolver } from "./orderingResolver"
+
+export { OrderingResolver }

Diff for: src/resolver/ordering/index.ts

@@ -0,0 +1,40 @@
+
+import { GraphQLResolveInfo, ObjectTypeDefinitionNode } from 'graphql'
+import { IResolvers } from '@graphql-tools/utils'
+import { UserQuerySet, OrderingQuerySet } from '../../service/mysql'
+
+
+let getDateBefore = (days: number):string=>{
+    function pad(n:number) { return n<10 ? "0"+n : n }
+    const now = new Date()
+    now.setTime(now.getTime() + (9*60*60*1000))
+    now.setTime(now.getTime() - (days * 24 * 60*60*1000))
+    return now.getFullYear()+"-"+ 
+    pad(now.getMonth()+1)+"-"+ 
+    pad(now.getDate())+" "+ 
+    pad(now.getHours())+":"+ 
+    pad(now.getMinutes())+":"+ 
+    pad(now.getSeconds())
+}
+
+let queryOrdering = async (parent:any, args:any, context:any, info:GraphQLResolveInfo) => {
+    try{
+        // console.log('Params : ', parent, JSON.stringify(args), JSON.stringify(context), JSON.stringify(info))
+        console.log('Args : ', JSON.stringify(args))
+        const count:number = (args || ({} as any)).count? args.count:10
+        const startDt:string = (args || ({} as any)).startDt? args.startDt:getDateBefore(10)
+        const result:Array<any> = await OrderingQuerySet.getOrderingByUser(args.userId, count, startDt, "DESC")
+        return result
+    }catch(e){
+        console.log(e)
+        throw e
+    }
+}
+
+const OrderingResolver:IResolvers = {
+    Query: {
+        ordering: queryOrdering
+    }
+}
+
+export { OrderingResolver }

Diff for: src/resolver/ordering/orderingResolver.ts

@@ -0,0 +1,3 @@
+import { UserResolver } from "./userResolver"
+
+export { UserResolver }