Add express server from module and updated the server and config
Some checks failed
continuous-integration/drone/push Build is failing

This commit is contained in:
Sambo Chea 2021-09-16 18:14:49 +07:00
parent c41002a96b
commit 03458fe00c
Signed by: sombochea
GPG Key ID: 3C7CF22A05D95490
13 changed files with 48 additions and 148 deletions

3
.gitmodules vendored
View File

@ -1,3 +1,6 @@
[submodule "packages/ts-common"]
path = packages/ts-common
url = https://git.cubetiqs.com/CUBETIQ/ts-common.git
[submodule "packages/cubetiq-express-server"]
path = packages/cubetiq-express-server
url = https://git.cubetiqs.com/CUBETIQ/cubetiq-express-server.git

View File

@ -18,7 +18,8 @@
},
"keywords": [
"Express",
"Nodejs"
"Nodejs",
"Typescript"
],
"author": "Sambo Chea <sombochea@cubetiqs.com>",
"license": "ISC",
@ -41,8 +42,8 @@
},
"dependencies": {
"@cubetiq/ts-common": "1.0.0",
"express": "^4.17.1",
"reflect-metadata": "^0.1.13"
"@cubetiq/express-server": "1.0.0",
"express": "^4.17.1"
},
"lint-staged": {
"**/*": "prettier --write --ignore-unknown"

@ -0,0 +1 @@
Subproject commit 558626d0e4d955d0b702365b507d2697ef83196d

@ -1 +1 @@
Subproject commit c42964407eaa35f0beea28926d234f74678b6cfc
Subproject commit d011f4547ebe4f1b36dc12fbb06b626e7345dc65

View File

@ -1,8 +1,28 @@
// app config
import "./dotenv"
// reflection metadata for decorator
import "reflect-metadata"
import { createServer } from "http"
import { SERVER_PORT } from "./app.config"
import { info } from "@cubetiq/ts-common/dist/log"
import application from "./server"
// core app
import "./server"
// get current host id
const hostId = `${require("os").hostname()}#${process.pid}`
const startedAt = new Date()
const app = application.instance
const httpServer = createServer(app)
info(
`Application server running on: ${hostId} at port: ${SERVER_PORT} and started at: ${startedAt}`
)
httpServer.listen(SERVER_PORT)
app.get("/info", (req, res) => {
res.type("json")
res.send({
startedAt,
message: `Instance id: ${hostId}`,
status: "OK",
})
})

View File

@ -1,54 +0,0 @@
import express, { Application as ExpressApp, Handler } from "express"
import { controllers } from "./controller"
import { RouteHandler } from "./decorators/handlers.decorator"
import { MetadataKeys } from "./constants/metadata.keys"
class Application {
private readonly _instance: ExpressApp
get instance(): ExpressApp {
return this._instance
}
constructor() {
this._instance = express()
this._instance.use(express.json())
this._instance.use(express.urlencoded({ extended: false }))
this.registerRoutes()
}
private registerRoutes(): void {
const info: Array<{ api: string; handler: string }> = []
controllers.forEach((controller) => {
const controllerInstance: { [handlerName: string]: Handler } =
new controller() as any
const basePath: string = Reflect.getMetadata(
MetadataKeys.BASE_PATH,
controller
)
const routers: RouteHandler[] = Reflect.getMetadata(
MetadataKeys.ROUTERS,
controller
)
const exRouter = express.Router()
routers.forEach(({ method, path, handlerName }) => {
exRouter[method](
path,
controllerInstance[String(handlerName)]
).bind(controllerInstance)
info.push({
api: `${method.toLocaleUpperCase()} ${basePath + path}`,
handler: `${controller.name}.${String(handlerName)}`,
})
})
this._instance.use(basePath, exRouter)
})
console.table(info)
}
}
export default new Application()

View File

@ -1,4 +0,0 @@
export enum MetadataKeys {
BASE_PATH = "base_path",
ROUTERS = "routers",
}

View File

@ -1,5 +1,5 @@
import { Request, Response } from "express"
import { Controller, Get } from "../decorators"
import { Controller, Get } from "@cubetiq/express-server/dist/decorators"
@Controller("/hello")
export default class IndexController {

View File

@ -1,5 +1,10 @@
import { Request, Response } from "express"
import { Controller, Delete, Get, Post } from "../decorators"
import {
Controller,
Delete,
Get,
Post,
} from "@cubetiq/express-server/dist/decorators"
const persons: Array<any> = [
{

View File

@ -1,7 +0,0 @@
import { MetadataKeys } from "../constants/metadata.keys"
export const Controller = (basePath: string): ClassDecorator => {
return (target: any) => {
Reflect.defineMetadata(MetadataKeys.BASE_PATH, basePath, target)
}
}

View File

@ -1,47 +0,0 @@
import { MetadataKeys } from "../constants/metadata.keys"
export enum Method {
GET = "get",
POST = "post",
PUT = "put",
DELETE = "delete",
PATCH = "patch",
}
export interface RouteHandler {
method: Method
path: string
handlerName: string | symbol
}
const methodDecoratorFactory = (method: Method) => {
return (path: string = ""): MethodDecorator => {
return (target: any, propertyKey: string | symbol): void => {
const controllerClass = target.constructor
const routers: RouteHandler[] = Reflect.hasMetadata(
MetadataKeys.ROUTERS,
controllerClass
)
? Reflect.getMetadata(MetadataKeys.ROUTERS, controllerClass)
: []
routers.push({
method,
path,
handlerName: propertyKey,
})
Reflect.defineMetadata(
MetadataKeys.ROUTERS,
routers,
controllerClass
)
}
}
}
export const Get = methodDecoratorFactory(Method.GET)
export const Post = methodDecoratorFactory(Method.POST)
export const Put = methodDecoratorFactory(Method.PUT)
export const Delete = methodDecoratorFactory(Method.DELETE)
export const Patch = methodDecoratorFactory(Method.PATCH)

View File

@ -1,2 +0,0 @@
export * from "./controller.decorator"
export * from "./handlers.decorator"

View File

@ -1,25 +1,9 @@
import { createServer } from "http"
import { SERVER_PORT } from "./app.config"
import { info } from "@cubetiq/ts-common/dist/log"
import application from "./application"
import Application from "@cubetiq/express-server/dist"
import { controllers as AllControllers } from "./controller"
class Server extends Application {
get controllers(): any[] {
return AllControllers
}
}
// get current host id
const hostId = `${require("os").hostname()}#${process.pid}`
const startedAt = new Date()
const app = application.instance
const httpServer = createServer(app)
info(
`Application server running on: ${hostId} at port: ${SERVER_PORT} and started at: ${startedAt}`
)
httpServer.listen(SERVER_PORT)
app.get("/info", (req, res) => {
res.type("json")
res.send({
startedAt,
message: `Instance id: ${hostId}`,
status: "OK",
})
})
export default new Server()