wip

.vscode/launch.json

@@ -0,0 +1,21 @@
+{
+    // Use IntelliSense to learn about possible attributes.
+    // Hover to view descriptions of existing attributes.
+    // For more information, visit: https://go.microsoft.com/fwlink/?linkid=830387
+    "version": "0.2.0",
+    "configurations": [
+
+      {
+        "name": "Lunch Kraken",
+        "type": "node",
+        "request": "launch",
+        "runtimeExecutable": "${workspaceFolder}/node_modules/@nestjs/cli/bin/nest.js",
+        "runtimeArgs": ["start", "--watch"],
+        "cwd": "${workspaceRoot}",
+        "console": "integratedTerminal",
+        "restart": true,
+        "autoAttachChildProcesses": true
+      }
+    ]
+  }
+

src/app.module.ts

@@ -2,6 +2,7 @@ import { Module } from '@nestjs/common';
 import { ConfigModule } from '@nestjs/config';
 
 import AuthModule from './modules/auth/auth.module';
+import { ServicesConfigModule } from './modules/config/config.module';
 import HealthModule from './modules/health/health.module';
 import ServiceRegistryModule from './modules/service-registry/service-registry.module';
 import { UserModule } from './modules/users/user.module';
@@ -17,6 +18,7 @@ import { SharedModule } from './shared/shared.module';
     UserModule,
     HealthModule,
     ServiceRegistryModule,
+    ServicesConfigModule,
   ],
   controllers: [],
   providers: [],

src/common/abstract.entity.ts

@@ -1,5 +1,5 @@
 /* eslint-disable max-classes-per-file */
-import { CreateDateColumn, ObjectId, ObjectIdColumn, UpdateDateColumn } from 'typeorm';
+import { CreateDateColumn, ObjectId, ObjectIdColumn, PrimaryGeneratedColumn, UpdateDateColumn } from 'typeorm';
 
 import type { Constructor } from '../types';
 import type { AbstractDto } from './dto/abstract.dto';
@@ -13,7 +13,7 @@ import type { AbstractDto } from './dto/abstract.dto';
  * otherwise just delete and use your own entity.
  */
 export interface IAbstractEntity<DTO extends AbstractDto, O = never> {
-  id: ObjectId;
+  _id: ObjectId;
   createdAt: Date;
   updatedAt: Date;
 
@@ -23,8 +23,9 @@ export interface IAbstractEntity<DTO extends AbstractDto, O = never> {
 export abstract class AbstractEntity<DTO extends AbstractDto = AbstractDto, O = never>
   implements IAbstractEntity<DTO, O>
 {
-  @ObjectIdColumn() // MongoDB ObjectId
-  id: ObjectId;
+  @PrimaryGeneratedColumn()
+  @ObjectIdColumn()
+  _id: ObjectId;
 
   @CreateDateColumn({
     type: 'timestamp',
@@ -61,10 +62,10 @@ export abstract class AbstractEntity<DTO extends AbstractDto = AbstractDto, O =
   }
 
   assign(item: Partial<AbstractEntity>) {
-    const { id, createdAt, updatedAt } = item;
+    const { _id: id, createdAt, updatedAt } = item;
 
     if (id) {
-      this.id = id;
+      this._id = id;
     }
 
     this.createdAt = createdAt ? new Date(createdAt) : this.createdAt;

src/common/dto/abstract.dto.ts

@@ -14,7 +14,7 @@ export class AbstractDto {
 
   constructor(entity: AbstractEntity, options?: { excludeFields?: boolean }) {
     if (!options?.excludeFields) {
-      this.id = entity.id.toString();
+      this.id = entity._id.toString();
       this.createdAt = entity.createdAt;
       this.updatedAt = entity.updatedAt;
     }

src/common/dto/page-options.dto.ts

@@ -1,12 +1,9 @@
-import { Order } from '../../constants';
-import {
-  EnumFieldOptional,
-  NumberFieldOptional,
-  StringFieldOptional,
-} from '../../decorators';
+import { Order } from '../../../src/constant/constants';
+import { EnumFieldOptional, NumberFieldOptional, StringFieldOptional } from '../../decorators';
 
 export class PageOptionsDto {
   @EnumFieldOptional(() => Order, {
+    // eslint-disable-next-line @typescript-eslint/no-unsafe-assignment
     default: Order.ASC,
   })
   readonly order: Order = Order.ASC;

src/constant/constants.ts

@@ -0,0 +1,3 @@
+export enum Order {
+  ASC = 'ASC',
+}

src/main.ts

@@ -1,3 +1,4 @@
+import { ReflectionService } from '@grpc/reflection';
 import { ClassSerializerInterceptor, HttpStatus, UnprocessableEntityException, ValidationPipe } from '@nestjs/common';
 import { NestFactory, Reflector } from '@nestjs/core';
 import type { MicroserviceOptions } from '@nestjs/microservices';
@@ -6,7 +7,6 @@ import type { NestExpressApplication } from '@nestjs/platform-express';
 import { ExpressAdapter } from '@nestjs/platform-express';
 import compression from 'compression';
 import morgan from 'morgan';
-import { ReflectionService } from '@grpc/reflection';
 
 import { AppModule } from './app.module';
 import { setupSwagger } from './setup-swagger';

src/modules/auth/auth.service.ts

@@ -31,7 +31,7 @@ export default class AuthService {
 
     if (isPasswordOk) {
       return {
-        id: user.id.toString(),
+        id: user._id.toString(),
         email: user.email,
       };
     }

src/modules/auth/strategies/jwt.strategy.ts

@@ -18,7 +18,7 @@ export default class JwtStrategy extends PassportStrategy(Strategy) {
 
   validate(payload: UserEntity): IJwtStrategyValidate {
     return {
-      id: payload.id.toString(),
+      id: payload._id.toString(),
       email: payload.email,
     };
   }

src/modules/config/config.module.ts

@@ -0,0 +1,16 @@
+import { Module } from '@nestjs/common';
+import { TypeOrmModule } from '@nestjs/typeorm';
+
+import { ConfigRepository } from './config.repository';
+import { ConfigService } from './config.service';
+import { ServiceConfigController } from './controllers/config.controller';
+import { ConfigGrpcController } from './controllers/config-grpc.controller';
+import { ConfigEntity } from './entities/config.entity';
+
+@Module({
+  imports: [TypeOrmModule.forFeature([ConfigEntity])],
+  providers: [ConfigService, ConfigRepository],
+  controllers: [ServiceConfigController, ConfigGrpcController],
+  exports: [ConfigService],
+})
+export class ServicesConfigModule {}

src/modules/config/config.repository.ts

@@ -0,0 +1,30 @@
+import { Injectable } from '@nestjs/common';
+import { InjectRepository } from '@nestjs/typeorm';
+import type { DeepPartial, FindManyOptions, FindOneOptions } from 'typeorm';
+import { MongoRepository } from 'typeorm';
+
+import { ConfigEntity } from './entities/config.entity';
+
+@Injectable()
+export class ConfigRepository {
+  constructor(
+    @InjectRepository(ConfigEntity)
+    private repository: MongoRepository<ConfigEntity>,
+  ) {}
+
+  async findAll(options?: FindManyOptions<ConfigEntity> | undefined) {
+    return this.repository.find({ ...options });
+  }
+
+  async findOne(options?: FindOneOptions<ConfigEntity>) {
+    return this.repository.findOne({ ...options });
+  }
+
+  async save(data: ConfigEntity) {
+    return this.repository.save(data);
+  }
+
+  create(entityLike: DeepPartial<ConfigEntity>) {
+    return this.repository.create(entityLike);
+  }
+}

src/modules/config/config.service.ts

@@ -0,0 +1,30 @@
+import { Injectable } from '@nestjs/common';
+
+import { ConfigRepository } from './config.repository';
+import type { UpdateConfigDto } from './dto/update-config.dto';
+
+@Injectable()
+export class ConfigService {
+  constructor(private readonly configRepo: ConfigRepository) {}
+
+  async getConfig() {
+    return this.configRepo.findOne();
+  }
+
+  async update(props: UpdateConfigDto) {
+    let config = await this.getConfig();
+    console.log('AAAAA');
+    if (!config) {
+      config = this.configRepo.create(props);
+    }
+
+    console.log('BBBBBBB');
+
+
+    config.assign(props);
+    console.log('CCCCCC');
+
+
+    return this.configRepo.save(config);
+  }
+}

src/modules/config/controllers/config-grpc.controller.ts

@@ -0,0 +1,17 @@
+import { Controller } from '@nestjs/common';
+
+import type { getConfigResponse } from '../../../../src/modules/grpc/gen/ts/kraken';
+import { KrakenConfigServiceControllerMethods } from '../../../../src/modules/grpc/gen/ts/kraken';
+import { ConfigService } from '../config.service';
+
+@Controller()
+@KrakenConfigServiceControllerMethods()
+export class ConfigGrpcController {
+  constructor(private readonly configService: ConfigService) {}
+
+  async getConfig(): Promise<getConfigResponse> {
+    const config = await this.configService.getConfig();
+
+    return config?.toDto() as getConfigResponse;
+  }
+}

src/modules/config/controllers/config.controller.ts

@@ -0,0 +1,23 @@
+import { Body, Controller, Get, Patch } from '@nestjs/common';
+import { ApiTags } from '@nestjs/swagger';
+
+import { ConfigService } from '../config.service';
+import { UpdateConfigDto } from '../dto/update-config.dto';
+
+@Controller('service-config')
+@ApiTags('Service config')
+export class ServiceConfigController {
+  constructor(private readonly configService: ConfigService) {}
+
+  @Patch()
+  async update(@Body() props: UpdateConfigDto) {
+    return this.configService.update(props);
+  }
+
+  @Get()
+  async get() {
+    const config = await this.configService.getConfig();
+
+    return config?.toDto();
+  }
+}

src/modules/config/dto/config.dto.ts

@@ -0,0 +1,101 @@
+import { ApiProperty } from '@nestjs/swagger';
+import { IsArray, IsOptional, IsString } from 'class-validator';
+
+import { AbstractDto } from '../../../common/dto/abstract.dto';
+import type { ConfigEntity } from '../entities/config.entity';
+import { Retention } from './retention.dto';
+
+export class ConfigDto extends AbstractDto {
+  @ApiProperty()
+  @IsString()
+  name: string;
+
+  @ApiProperty()
+  @IsString()
+  description: string;
+
+  @ApiProperty()
+  @IsString()
+  pubkey: string;
+
+  @ApiProperty()
+  @IsString()
+  contact: string;
+
+  @ApiProperty()
+  @IsString()
+  software: string;
+
+  @ApiProperty({ type: [Number] })
+  @IsArray()
+  supportedNips: number[];
+
+  @ApiProperty()
+  @IsString()
+  version: string;
+
+  @ApiProperty({ type: [String] })
+  @IsArray()
+  relayCountries: string[];
+
+  @ApiProperty({ type: [String] })
+  @IsArray()
+  languageTags: string[];
+
+  @ApiProperty({ type: [String] })
+  @IsArray()
+  tags: string[];
+
+  @ApiProperty({ required: false })
+  @IsOptional()
+  @IsString()
+  postingPolicy?: string;
+
+  @ApiProperty({ required: false })
+  @IsOptional()
+  @IsString()
+  paymentsUrl?: string;
+
+  @ApiProperty({ required: false })
+  @IsOptional()
+  @IsString()
+  icon?: string;
+
+  @ApiProperty({ required: false })
+  @IsOptional()
+  @IsString()
+  url?: string;
+
+  @ApiProperty({ type: () => Retention, required: false })
+  @IsOptional()
+  retention?: Retention;
+
+  // @ApiProperty({ type: () => FeesClass, required: false })
+  // @IsOptional()
+  // fees?: FeesClass;
+
+  constructor(e: ConfigEntity) {
+    super(e);
+
+    this.name = e.name;
+    this.description = e.description;
+    this.pubkey = e.pubkey;
+    this.contact = e.contact;
+    this.software = e.software;
+    this.supportedNips = e.supportedNips;
+    this.version = e.version;
+    this.relayCountries = e.relayCountries;
+    this.languageTags = e.languageTags;
+    this.tags = e.tags;
+    this.postingPolicy = e.postingPolicy;
+    this.paymentsUrl = e.paymentsUrl;
+    this.icon = e.icon;
+    this.url = e.url;
+    this.retention = {
+      count: e.retention?.count,
+      kinds: e.retention?.kinds,
+      time: e.retention?.time,
+    };
+    // this.fees = e.fees;
+  }
+}

src/modules/config/dto/fees.dto.ts

@@ -0,0 +1,29 @@
+export interface ISubscription {
+  amount: number;
+
+  unit: string;
+
+  period: number;
+}
+
+export interface IPublication {
+  kinds: number[];
+
+  amount: number;
+
+  unit: string;
+}
+
+export interface IAdmission {
+  amount: number;
+
+  unit: number;
+}
+
+export interface IFees {
+  subscription: ISubscription[];
+
+  publication: IPublication[];
+
+  admission: IAdmission[];
+}