Merge pull request #21 from Libertech-FR/14-api-feature

WIP implements mails

Author: tacxou

app/src/public/favicon.ico

@@ -37,8 +37,10 @@
     "cookie-parser": "^1.4.6",
     "dayjs": "^1.11.9",
     "deepmerge": "^4.3.1",
+    "hbs": "^4.2.0",
     "helmet": "^7.0.0",
     "ioredis": "^5.3.2",
+    "mailparser": "^3.6.5",
     "mongoose": "^7.5.0",
     "mongoose-unique-validator": "^4.0.0",
     "nestjs-i18n": "^10.3.1",
@@ -59,6 +61,7 @@
     "@types/cookie-parser": "^1.4.3",
     "@types/express": "^4.17.13",
     "@types/jest": "29.5.0",
+    "@types/mailparser": "^3.4.0",
     "@types/multer": "^1.4.7",
     "@types/node": "18.16.0",
     "@types/passport": "^1.0.12",

service/package.json

@@ -1,6 +1,7 @@
 import { ModuleRef } from '@nestjs/core'
 import { ApiExtraModels } from '@nestjs/swagger'
 import { PaginatedResponseDto } from '~/_common/dto/paginated-response.dto'
+import { Logger } from '@nestjs/common'
 
 export interface AbstractControllerContext {
   [key: string | number]: any
@@ -10,10 +11,12 @@ export interface AbstractControllerContext {
 
 @ApiExtraModels(PaginatedResponseDto)
 export abstract class AbstractController {
+  protected logger: Logger
   protected moduleRef?: ModuleRef
 
   protected constructor(context?: AbstractControllerContext) {
     this.moduleRef = context?.moduleRef
+    this.logger = new Logger(this.controllerName)
   }
 
   public get controllerName(): string {

service/public/favicon.ico

@@ -2,7 +2,7 @@ import { Injectable, NotFoundException } from '@nestjs/common'
 import { AbstractSchema } from './schemas/abstract.schema'
 import {
   Document,
-  FilterQuery,
+  FilterQuery, HydratedDocument,
   Model,
   ModifyResult,
   ProjectionType,
@@ -15,6 +15,7 @@ import {
 import { AbstractService, AbstractServiceContext } from './abstract.service'
 import { ServiceSchemaInterface } from './interfaces/service.schema.interface'
 import { EventEmitterSeparator } from '~/_common/constants/event-emitter.constant'
+import { Filestorage } from '~/core/filestorage/_schemas/filestorage.schema'
 
 @Injectable()
 export abstract class AbstractServiceSchema extends AbstractService implements ServiceSchemaInterface {
@@ -161,7 +162,7 @@ export abstract class AbstractServiceSchema extends AbstractService implements S
         session: typeof arguments[1] === 'object' && 'session' in arguments[1] ? 'session' : undefined,
       },
     })
-    this.logger.debug(['create', JSON.stringify(Object.values(arguments))].join(' '))
+    this.logger.debug(['create', JSON.stringify(logInfos)].join(' '))
     if (this.eventEmitter) {
       const beforeEvents = await this.eventEmitter?.emitAsync([
         this.moduleName.toLowerCase(),
@@ -177,13 +178,13 @@ export abstract class AbstractServiceSchema extends AbstractService implements S
     }
     console.log('this.request?.user', this.request?.user)
     const document: Document<T, any, T> = new this._model({
-      ...data,
       metadata: {
         createdBy: this.request?.user?.username || 'anonymous',
         createdAt: new Date(),
         lastUpdatedBy: this.request?.user?.username || 'anonymous',
         lastUpdatedAt: new Date(),
       },
+      ...data,
     })
     let created = document.save(options)
     if (this.eventEmitter) {

service/src/_common/abstracts/abstract.controller.ts

@@ -4,5 +4,5 @@ export class CustomFieldsDto {
   @IsObject()
   @IsOptional()
   @ValidateNested()
-  public customFields?: { [key: string]: any }[]
+  public customFields?: { [key: string]: any }
 }

service/src/_common/abstracts/abstract.service.schema.ts

@@ -1,5 +1,17 @@
-import { Document, FilterQuery, ModifyResult, ProjectionType, Query, QueryOptions, SaveOptions, Types, UpdateQuery } from 'mongoose'
+import {
+  Document,
+  FilterQuery,
+  HydratedDocument,
+  ModifyResult,
+  ProjectionType,
+  Query,
+  QueryOptions,
+  SaveOptions,
+  Types,
+  UpdateQuery,
+} from 'mongoose'
 import { AbstractSchema } from '../schemas/abstract.schema'
+import { Filestorage } from '~/core/filestorage/_schemas/filestorage.schema'
 
 export interface ServiceSchemaInterface {
   find<T extends AbstractSchema | Document>(

service/src/_common/abstracts/dto/custom-fields.dto.ts

@@ -1,10 +1,11 @@
 import { IsMongoId, IsNotEmpty, IsString } from 'class-validator'
 import { ApiProperty } from '@nestjs/swagger'
+import { Types } from 'mongoose'
 
 export class IdnamePartDto {
   @IsMongoId({ message: 'Id invalide' })
   @ApiProperty()
-  public id: string
+  public id: Types.ObjectId
 
   @IsString()
   @IsNotEmpty()

service/src/_common/abstracts/interfaces/service.schema.interface.ts

@@ -0,0 +1,20 @@
+import { IsMongoId, IsNotEmpty, IsOptional, IsString } from 'class-validator'
+import { ApiProperty } from '@nestjs/swagger'
+import { Types } from 'mongoose'
+
+export class MailaddressPartDto {
+  @IsString()
+  @IsNotEmpty()
+  @ApiProperty()
+  public address: string
+
+  @IsString()
+  @IsOptional()
+  @ApiProperty()
+  public name: string
+
+  @IsMongoId({ message: 'Id invalide' })
+  @IsOptional()
+  @ApiProperty()
+  public entityId?: Types.ObjectId
+}

service/src/_common/dto/parts/idname.part.dto.ts

@@ -0,0 +1,46 @@
+import { CallHandler, ExecutionContext, Inject, mixin, NestInterceptor, Optional, Type } from '@nestjs/common'
+import { Observable } from 'rxjs'
+import * as multer from 'multer'
+import { MULTER_MODULE_OPTIONS } from '@nestjs/platform-express/multer/files.constants'
+import { MulterModuleOptions } from '@nestjs/platform-express'
+import { transformException } from '@nestjs/platform-express/multer/multer/multer.utils'
+import { Request } from 'express'
+
+export function FileRawBodyInterceptor(fieldName: string, localOptions?: any): Type<NestInterceptor> {
+  class MixinInterceptor implements NestInterceptor {
+    protected multer: any
+
+    public constructor(
+      @Optional()
+      @Inject(MULTER_MODULE_OPTIONS) options: MulterModuleOptions = {},
+    ) {
+      this.multer = (multer as any)({
+        ...options,
+        ...localOptions,
+      })
+    }
+
+    public async intercept(context: ExecutionContext, next: CallHandler): Promise<Observable<any>> {
+      const ctx = context.switchToHttp()
+      await new Promise<void>((resolve, reject) => {
+          const request = ctx.getRequest<Request & { rawBody: string }>()
+          request.rawBody = ''
+          request.prependListener('data', (chunk) => request.rawBody += chunk.toString())
+          this.multer.single(fieldName)(
+            request,
+            ctx.getResponse(),
+            (err: any) => {
+              if (err) {
+                const error = transformException(err)
+                return reject(error)
+              }
+              resolve()
+            },
+          )
+        },
+      )
+      return next.handle()
+    }
+  }
+  return mixin(MixinInterceptor)
+}