Completed User Endpoint Setup

Author: ioedeveloper

ormconfig.json

@@ -30,6 +30,7 @@
   },
   "homepage": "https://github.com/ioedeveloper/Shadow-Backend#readme",
   "dependencies": {
+    "body-parser": "^1.19.0",
     "chai": "^4.2.0",
     "express": "^4.17.1",
     "mocha": "^6.1.4",
@@ -42,6 +43,7 @@
     "@types/chai": "^4.1.7",
     "@types/express": "^4.17.0",
     "@types/mocha": "^5.2.7",
+    "@types/mongodb": "^3.1.28",
     "@types/node": "^12.0.7",
     "nodemon": "^1.19.1",
     "tslint": "^5.17.0"

package-lock.json

@@ -22,3 +22,5 @@ router.post('/signup', async function(req: Request, res: Response) {
     }
 
 });
+
+export { router };

package.json

@@ -1,5 +1,6 @@
+import { ObjectID } from 'typeorm';
 interface IUser {
-    id: number;
+    _id: ObjectID;
     email: string;
     extensionId: string;
     deleted: boolean;

src/api/user.ts

@@ -1,16 +1,16 @@
-import { Entity, PrimaryGeneratedColumn, Column } from 'typeorm';
+import { Entity, ObjectID, ObjectIdColumn, Column } from 'typeorm';
 
 @Entity()
 export class UserModel {
-    @PrimaryGeneratedColumn
-    id: number;
+    @ObjectIdColumn()
+    _id: ObjectID
 
-    @Column
+    @Column()
     email: string;
 
-    @Column
+    @Column()
     extensionId: string;
 
-    @Column
+    @Column()
     deleted: boolean = false;
 }

src/config/types/user.ts

@@ -2,31 +2,42 @@
 import { Request, Response } from 'express';
 import express = require('express');
 import {createConnection} from 'typeorm';
+import bodyParser = require('body-parser');
+import * as UserEndpoint from './api/user';
 
 // establish database connection.
-createConnection().then(() => {
-    // tslint:disable-next-line:no-console
-    console.log('Database Connection Established...');
+(async () => {
+    try {
+        const connection = await createConnection();
+        // tslint:disable-next-line:no-console
+        console.log('Database Connection Established...');
 
-    // create a new express application instance
-    const app: express.Application = express();
+        // create a new express application instance
+        const app: express.Application = express();
 
         // the port the express app will listen on
-    const port: any = process.env.PORT || 2002;
+        const port: any = process.env.PORT || 2002;
 
-    app.get('/', (req: Request, res: Response) => {
-        res.setHeader('Content-Type', 'application/json');
-        res.send(JSON.stringify({
-            status: 200,
-            message: 'Service is up!',
-        }));
-    });
+        app.use(bodyParser.json());
+        app.use(bodyParser.urlencoded({ extended: false }));
 
-    // serve the application at the given port
-    app.listen(port, () => {
-        // tslint:disable-next-line:no-console
-        console.log(`Listening at http://localhost:${port}/`);
-    });
+        app.use('/user', UserEndpoint.router);
 
-// tslint:disable-next-line:no-console
-}).catch((error) => console.log(`Error: ${error}`));
+        app.get('/', (req: Request, res: Response) => {
+            res.setHeader('Content-Type', 'application/json');
+            res.send(JSON.stringify({
+                status: 200,
+                message: 'Service is up!',
+            }));
+        });
+
+        // serve the application at the given port
+        app.listen(port, () => {
+            // tslint:disable-next-line:no-console
+            console.log(`Listening at http://localhost:${port}/`);
+        });
+    } catch (error) {
+        // tslint:disable-next-line:no-console
+        console.log(`Error: ${error}`);
+    }
+})();

src/model/user.ts

@@ -1,19 +1,15 @@
-import { MongoRepository, getConnection, UpdateWriteOpResult } from 'typeorm';
+import { MongoRepository, getMongoRepository, UpdateWriteOpResult } from 'typeorm';
 import { UserModel } from '../model/user';
 
 export class UserDataService {
     private _db: MongoRepository<UserModel>;
 
-    constructor() {
-        this._db = getConnection().getMongoRepository(UserModel);
-    }
-
     public async create(newUser: UserModel): Promise<UserModel> {
         const userModel: UserModel = new UserModel();
-        userModel.id = newUser.id;
         userModel.email = newUser.email;
         userModel.extensionId = newUser.extensionId;
         try {
+            if (!this._db) await this._init();
             const user = await this._db.save(userModel);
             return user;
         } catch (error) {
@@ -26,6 +22,7 @@ export class UserDataService {
         if (!take) take = 10;
         query.deleted = false;
         try {
+            if (!this._db) await this._init();
             const users: UserModel[] = await this._db.find({
                 where: query,
                 skip,
@@ -40,6 +37,7 @@ export class UserDataService {
     public async findOneBy(query: UserModel): Promise<UserModel | undefined> {
         query.deleted = false;
         try {
+            if (!this._db) await this._init();
             const user: UserModel | undefined = await this._db.findOne(query);
             return user;
         } catch (error) {
@@ -48,8 +46,9 @@ export class UserDataService {
     }
 
     public async update(user: UserModel): Promise<UserModel> {
-        if (!user.id) {
+        if (!user._id) {
             try {
+                if (!this._db) await this._init();
                 const newUser = this.create(user);
                 return newUser;
             } catch (error) {
@@ -58,7 +57,8 @@ export class UserDataService {
         } else {
             user.deleted = false;
             try {
-                await this._db.findOneAndUpdate({id: user.id}, {
+                if (!this._db) await this._init();
+                await this._db.findOneAndUpdate({id: user._id}, {
                     $set: {
                         email: user.email,
                         extensionId: user.extensionId,
@@ -74,6 +74,7 @@ export class UserDataService {
     public async countBy(query: UserModel): Promise<number> {
         query.deleted = false;
         try {
+            if (!this._db) await this._init();
             const count = await this._db.count(query);
             return count;
         } catch (error) {
@@ -84,6 +85,7 @@ export class UserDataService {
     public async deleteBy(query: UserModel, userId: number): Promise<UpdateWriteOpResult> {
         query.deleted = false;
         try {
+            if (!this._db) await this._init();
             const result: UpdateWriteOpResult = await this._db.updateMany(query, {
                 $set: {
                     deleted: true,
@@ -95,4 +97,8 @@ export class UserDataService {
             throw error;
         }
     }
+
+    private async _init() {
+        this._db = getMongoRepository(UserModel);
+    }
 }

src/server.ts

@@ -26,7 +26,7 @@
     // "strictNullChecks": true,              /* Enable strict null checks. */
     // "strictFunctionTypes": true,           /* Enable strict checking of function types. */
     // "strictBindCallApply": true,           /* Enable strict 'bind', 'call', and 'apply' methods on functions. */
-    // "strictPropertyInitialization": true,  /* Enable strict checking of property initialization in classes. */
+    "strictPropertyInitialization": false,  /* Enable strict checking of property initialization in classes. */
     // "noImplicitThis": true,                /* Raise error on 'this' expressions with an implied 'any' type. */
     // "alwaysStrict": true,                  /* Parse in strict mode and emit "use strict" for each source file. */
 

src/service/userDataService.ts

@@ -3,7 +3,8 @@
     "linterOptions": {
         "exclude": [
             "build",
-            "node_modules"
+            "node_modules",
+            "src/model/*.ts"
         ]
     },
     "rules": {