get backend from TezosLink

This commit is contained in:
Hugo Lextrait 2023-03-02 16:53:14 +01:00
parent 6ec76544e2
commit ad4f692732
29 changed files with 143 additions and 120 deletions

View File

@ -61,3 +61,4 @@ export default class ProjectController extends ApiController {
this.httpCreated(res, await this.projectService.create(projectEntity));
}
}

View File

@ -2,7 +2,7 @@ import { Container } from "typedi";
import ProjectController from "./ProjectController";
export default {
start: () => {
Container.get(ProjectController);
},
};
start: () => {
Container.get(ProjectController);
}
}

View File

@ -10,7 +10,7 @@ export default function errorHandler(error: any, req: Request, response: Respons
if (error instanceof SyntaxError && errorStatus === 400 && "body" in error) {
response.status(HttpCodes.BAD_REQUEST).send({
body: error["body"],
type: error as any["type"],
type: error as any ["type"],
});
return;
}
@ -22,3 +22,4 @@ export default function errorHandler(error: any, req: Request, response: Respons
next(error);
}

View File

@ -1,4 +1,4 @@
export default interface IDatabaseConfig {
name: string;
url?: string;
}
export default interface IDatabaseConfig {
name: string;
url?: string;
}

View File

@ -26,3 +26,4 @@ export default class TezosLink {
return name;
}
}

View File

@ -1,7 +1,7 @@
import { plainToClassFromExist } from "class-transformer";
export default abstract class ObjectHydrate {
public static hydrate<T = { [key: string]: any }>(object: { [key: string]: any }, from: { [key: string]: any }): T {
return plainToClassFromExist(object, from) as T;
}
}
import { plainToClassFromExist } from "class-transformer";
export default abstract class ObjectHydrate {
public static hydrate<T = { [key: string]: any }>(object: { [key: string]: any }, from: { [key: string]: any }): T {
return plainToClassFromExist(object, from) as T;
}
}

View File

@ -64,7 +64,7 @@ export default class MetricRepository {
const data = { ...metricEntity };
const result: MetricEntity[] = [];
this.instanceDb.$transaction(async (transaction: Prisma.TransactionClient) => {
this.instanceDb.$transaction(async(transaction: Prisma.TransactionClient) => {
for (const item of data) {
if (!item) continue;
result.push(
@ -135,7 +135,7 @@ export default class MetricRepository {
const response = this.model.groupBy({
by: ["date_requested"],
_count: {
date_requested: true,
date_requested: true,
},
where: {
projectId: projectId,
@ -187,3 +187,4 @@ export default class MetricRepository {
}
}
}

View File

@ -24,13 +24,14 @@ export default class ProjectRepository {
const data = { ...projectEntity };
return this.model.findUnique({
where: data,
include: {
// Include metrics & count
Metrics: true,
_count: {
select: { Metrics: true },
},
},
},
});
} catch (error) {
@ -58,3 +59,4 @@ export default class ProjectRepository {
}
}
}

View File

@ -4,28 +4,28 @@ import ProjectEntity from "./ProjectEntity";
export default class MetricEntity {
@IsNotEmpty()
public id!: number;
@IsNotEmpty({ groups: ["create"] })
@IsNotEmpty(({groups: ["create"]}))
public path!: string;
@IsNotEmpty({ groups: ["create"] })
@IsNotEmpty(({groups: ["create"]}))
public uuid!: string;
@IsNotEmpty({ groups: ["create"] })
@IsNotEmpty(({groups: ["create"]}))
public remote_address!: string;
@IsNotEmpty({ groups: ["create"] })
@IsNotEmpty(({groups: ["create"]}))
public date_requested!: Date;
@IsNotEmpty({ groups: ["create"] })
@IsNotEmpty(({groups: ["create"]}))
public projectId!: number;
@IsNotEmpty({ groups: ["create"] })
@IsNotEmpty(({groups: ["create"]}))
public project!: ProjectEntity;
@IsDate()
public createdAt?: Date;
@IsDate()
@IsDate()
public updatedAt?: Date;
}

View File

@ -5,21 +5,21 @@ export default class ProjectEntity {
@IsNotEmpty()
public id!: number;
@IsNotEmpty({ groups: ["create"] })
@IsNotEmpty({groups: ["create"]})
public title!: string;
@IsNotEmpty()
@IsNotEmpty()
public uuid!: string;
@IsDate()
public createdAt!: Date;
@IsDate()
@IsDate()
public updatedAt!: Date;
@IsNotEmpty({ groups: ["create"] })
@IsNotEmpty({groups: ["create"]})
public network!: string;
@IsOptional()
public metrics?: MetricEntity[];
}
}

View File

@ -1,4 +1,4 @@
import ProjectEntity from "./ProjectEntity";
import MetricEntity from "./MetricEntity";
export { ProjectEntity, MetricEntity };
import ProjectEntity from "./ProjectEntity";
import MetricEntity from "./MetricEntity";
export { ProjectEntity, MetricEntity};

View File

@ -1 +1,2 @@
export default class BaseService {}

View File

@ -35,18 +35,18 @@ export default class MetricService {
}
/**
*
* @throws {Error} If metric is undefined
* @returns
*/
public async getCountRpcPath(metricEntity: Partial<MetricEntity>, from: Date, to: Date) {
const pathsCount = await this.metricRepository.countRpcPathUsage(metricEntity.projectId!, from, to);
if (!pathsCount) return null;
return pathsCount;
}
*
* @throws {Error} If metric is undefined
* @returns
*/
public async getCountRpcPath(metricEntity: Partial<MetricEntity>, from: Date, to: Date) {
const pathsCount = await this.metricRepository.countRpcPathUsage(metricEntity.projectId!,from,to);
if (!pathsCount) return null;
return pathsCount;
}
/**
*
* @throws {Error} If metric is undefined
*
* @throws {Error} If metric is undefined
* @returns
*/
public async getCountAllMetrics(metricEntity: Partial<MetricEntity>) {
@ -56,27 +56,27 @@ export default class MetricService {
}
/**
*
*
* @throws {Error} If metric is undefined
* @returns
*/
public async getLastMetrics(metricEntity: Partial<MetricEntity>, limit: number) {
const lastMetric = await this.metricRepository.findLastRequests(metricEntity.projectId!, limit);
public async getLastMetrics(metricEntity: Partial<MetricEntity>, limit: number){
const lastMetric = await this.metricRepository.findLastRequests(metricEntity.projectId!,limit);
return ObjectHydrate.hydrate<Partial<MetricEntity>>(new MetricEntity(), lastMetric);
}
/**
*
*
* @throws {Error} If metric is undefined
* @returns
*/
public async getRequestsByDay(metricEntity: Partial<MetricEntity>, from: Date, to: Date) {
const requestByDay = await this.metricRepository.findRequestsByDay(metricEntity.projectId!, from, to);
public async getRequestsByDay(metricEntity: Partial<MetricEntity>, from: Date, to: Date){
const requestByDay = await this.metricRepository.findRequestsByDay(metricEntity.projectId!,from,to);
return ObjectHydrate.hydrate<Partial<MetricEntity>>(new MetricEntity(), requestByDay);
}
/**
*
*
* @throws {Error} If metric is undefined
* @returns
*/
@ -85,3 +85,4 @@ export default class MetricService {
await this.metricRepository.removeOldMetricsBymonths(months);
}
}

View File

@ -4,6 +4,8 @@ import { ProjectEntity } from "@Common/ressources";
import { type processFindManyQuery } from "prisma-query";
import { Service } from "typedi";
@Service()
export default class ProjectService {
constructor(private projectRepository: ProjectRepository) {}
@ -15,7 +17,7 @@ export default class ProjectService {
const projects = await this.projectRepository.findMany(query);
return ObjectHydrate.hydrate<Partial<ProjectEntity>>(new ProjectEntity(), projects);
}
/**
/**
* @throws {Error} If project is undefined
*/
public async getByUUID(projectEntity: Partial<ProjectEntity>) {
@ -23,14 +25,15 @@ export default class ProjectService {
if (!project) return null;
return ObjectHydrate.hydrate<Partial<ProjectEntity>>(new ProjectEntity(), project);
}
/**
*
* @throws {Error} If project cannot be created
* @returns
*/
/**
*
* @throws {Error} If project cannot be created
* @returns
*/
public async create(projectEntity: Partial<ProjectEntity>) {
const project = await this.projectRepository.create(projectEntity);
if (!project) return null;
return ObjectHydrate.hydrate<Partial<ProjectEntity>>(new ProjectEntity(), project);
}
}

View File

@ -31,3 +31,4 @@ export default class ExpressServer implements ServerInterface {
return this;
}
}

View File

@ -14,3 +14,4 @@ export default interface ServerInterface {
init(config: IConfig): this;
}

View File

@ -6,3 +6,4 @@ import HttpCodes from "@Common/system/controller-pattern/HttpCodes";
export default abstract class ApiController extends BaseController {}
export { HttpCodes as ResponseStatusCodes };

View File

@ -2,8 +2,10 @@ import { StRoute } from "./StRoute";
import { Response } from "express";
import HttpCodes from "@Common/system/controller-pattern/HttpCodes";
type IResponseData = {} | string | number | boolean | null | unknown;
export default abstract class BaseController {
public expressRoutes!: StRoute[];
public httpCode: typeof HttpCodes = HttpCodes;

View File

@ -34,3 +34,4 @@ function createRoute(controller: any, route: StRoute) {
}
export default Controller;

View File

@ -12,3 +12,4 @@ export default class ErrorCatch {
next(args[args.length - 1] ?? "Unknown Error");
}
}

View File

@ -1,10 +1,10 @@
enum HttpCodes {
SUCCESS = 200,
CREATED = 201,
BAD_REQUEST = 400,
INTERNAL_ERROR = 500,
UNKNOWN_ERROR = 520,
NOT_IMPLEMENTED = 501,
NOT_FOUND = 404,
}
export default HttpCodes;
enum HttpCodes {
SUCCESS = 200,
CREATED = 201,
BAD_REQUEST = 400,
INTERNAL_ERROR = 500,
UNKNOWN_ERROR = 520,
NOT_IMPLEMENTED = 501,
NOT_FOUND = 404,
}
export default HttpCodes;

View File

@ -1,12 +1,7 @@
import BaseController from "./BaseController";
import { StRoute } from "./StRoute";
function MethodsAny(
type: StRoute["type"],
path: string,
frontMiddlewares: StRoute["frontMiddlewares"] = [],
backMiddlewares: StRoute["backMiddlewares"] = [],
) {
function MethodsAny(type: StRoute["type"], path: string, frontMiddlewares: StRoute["frontMiddlewares"] = [], backMiddlewares: StRoute["backMiddlewares"] = []) {
return (target: any, memberName: string, propertyDescriptor: PropertyDescriptor) => {
const func = propertyDescriptor.value;
const constructor: typeof BaseController = target.constructor;
@ -34,3 +29,4 @@ export const Delete = MethodsAny.bind(null, "delete");
* @description Decorator Method PUT
*/
export const Put = MethodsAny.bind(null, "put");

View File

@ -7,3 +7,4 @@ export interface StRoute {
frontMiddlewares: ((requests: Request, response: Response, next: NextFunction) => void)[];
backMiddlewares: ((requests: Request, response: Response, next: NextFunction) => void)[];
}

View File

@ -1,7 +1,7 @@
import HttpCodes from "../HttpCodes";
export default class HttpException extends Error {
constructor(message: string, public httpCode: HttpCodes = HttpCodes.UNKNOWN_ERROR) {
super(message);
}
}
import HttpCodes from "../HttpCodes";
export default class HttpException extends Error {
constructor(message: string, public httpCode: HttpCodes = HttpCodes.UNKNOWN_ERROR) {
super(message);
}
}

View File

@ -1,31 +1,32 @@
import dotenv from "dotenv";
import { PrismaClient } from "@prisma/client";
import IDatabaseConfig from "../../config/IDatabaseConfig";
dotenv.config();
export default class DbProvider {
protected client = new PrismaClient({
datasources: {
db: {
url: `postgres://${process.env["DATABASE_USER"]}:${process.env["DATABASE_PASSWORD"]}@${process.env["DATABASE_HOSTNAME"]}:${process.env["DATABASE_PORT"]}/${process.env["DATABASE_NAME"]}`,
},
},
});
constructor(protected config: IDatabaseConfig) {}
public async connect(): Promise<void> {
await this.client.$connect();
console.info(`⚡️[Prisma]: Connected to ${this.config.name}`); // A Logger middleware is to be added here
}
public getClient() {
return this.client;
}
public async disconnect(): Promise<void> {
await this.client.$disconnect();
console.info(`⚡️[Prisma]: Disconnected from ${this.config.name}`); // A Logger middleware is to be added here
}
}
import dotenv from "dotenv";
import { PrismaClient } from "@prisma/client";
import IDatabaseConfig from "../../config/IDatabaseConfig";
dotenv.config();
export default class DbProvider {
protected client = new PrismaClient({
datasources: {
db: {
url: `postgres://${process.env["DATABASE_USER"]}:${process.env["DATABASE_PASSWORD"]}@${process.env["DATABASE_HOSTNAME"]}:${process.env["DATABASE_PORT"]}/${process.env["DATABASE_NAME"]}`,
},
},
});
constructor(protected config: IDatabaseConfig) {
}
public async connect(): Promise<void> {
await this.client.$connect();
console.info(`⚡️[Prisma]: Connected to ${this.config.name}`);// A Logger middleware is to be added here
}
public getClient() {
return this.client;
}
public async disconnect(): Promise<void> {
await this.client.$disconnect();
console.info(`⚡️[Prisma]: Disconnected from ${this.config.name}`); // A Logger middleware is to be added here
}
}

View File

@ -2,4 +2,4 @@ export class ORMBadQueryError extends Error {
constructor(message: string, public error: Error) {
super(message);
}
}
}

View File

@ -2,4 +2,4 @@ import IDatabaseConfig from "@Common/config/IDatabaseConfig";
import DbProvider from "./DbProvider";
export type { IDatabaseConfig };
export default DbProvider;
export default DbProvider;

View File

@ -22,8 +22,15 @@ Container.get(ExpressServer).init({
label,
port: parseInt(port),
rootUrl,
middlwares: [cors({ origin: "*" }), bodyParser.urlencoded({ extended: true }), bodyParser.json()],
middlwares: [
cors({ origin: "*" }),
bodyParser.urlencoded({ extended: true }),
bodyParser.json(),
],
errorHandler,
});
routes.start();

View File

@ -15,7 +15,7 @@ if (!rootUrl) throw new Error(`process.env RootUrl is undefined`);
Container.get(NextServer).init({
label,
isDev: process.env.NODE_ENV !== "production",
isDev: process.env.NODE_ENV !== 'production',
port: parseInt(port),
rootUrl,
});
});