BUR-61 Изменил чтение поля value в ingest.controller

Reviewed-on: #5

migrations/0001_camera.sql

@@ -0,0 +1,8 @@
+CREATE TABLE IF NOT EXISTS camera (
+  edge varchar NOT NULL,
+  protocol varchar NOT NULL,
+  source varchar NOT NULL,
+  PRIMARY KEY (edge, protocol, source)
+);
+
+CREATE INDEX IF NOT EXISTS camera_edge_idx ON camera (edge);

migrations/0002_current_value_nullable.sql

@@ -0,0 +1,2 @@
+ALTER TABLE current
+  ALTER COLUMN value DROP NOT NULL;

src/app.module.ts

@@ -1,4 +1,5 @@
 import { Module } from '@nestjs/common';
+import { CameraModule } from './camera/camera.module';
 import { CurrentModule } from './current/current.module';
 import { DbModule } from './db/db.module';
 import { EdgeModule } from './edge/edge.module';
@@ -10,6 +11,7 @@ import { TagModule } from './tag/tag.module';
 @Module({
   imports: [
     DbModule,
+    CameraModule,
     IngestModule,
     EdgeModule,
     CurrentModule,

src/camera/camera.controller.ts

@@ -0,0 +1,16 @@
+import { Controller, Get, Header, Query } from '@nestjs/common';
+import { CameraService } from './camera.service';
+import { GetCamerasDto } from './dto/get-cameras.dto';
+
+@Controller('camera')
+export class CameraController {
+  constructor(private readonly camera: CameraService) {}
+
+  @Get()
+  @Header('Cache-Control', 'no-store')
+  @Header('Pragma', 'no-cache')
+  @Header('Expires', '0')
+  findByEdge(@Query() query: GetCamerasDto) {
+    return this.camera.findByEdge(query);
+  }
+}

src/camera/camera.mapper.ts

@@ -0,0 +1,12 @@
+import { CameraResponseDto } from './dto/camera-response.dto';
+import { CameraRow } from './camera.types';
+
+export function createCameraResponse(edge: string, rows: CameraRow[]): CameraResponseDto {
+  return {
+    edge,
+    items: rows.map((row) => ({
+      protocol: row.protocol,
+      source: row.source,
+    })),
+  };
+}

src/camera/camera.module.ts

@@ -0,0 +1,10 @@
+import { Module } from '@nestjs/common';
+import { CameraController } from './camera.controller';
+import { CameraRepository } from './camera.repository';
+import { CameraService } from './camera.service';
+
+@Module({
+  controllers: [CameraController],
+  providers: [CameraService, CameraRepository],
+})
+export class CameraModule {}

src/camera/camera.repository.ts

@@ -0,0 +1,22 @@
+import { Injectable } from '@nestjs/common';
+import { DbService } from '../db/db.service';
+import { CameraRow } from './camera.types';
+
+@Injectable()
+export class CameraRepository {
+  constructor(private readonly db: DbService) {}
+
+  async findByEdge(edge: string): Promise<CameraRow[]> {
+    const result = await this.db.query<CameraRow>(
+      `
+        SELECT protocol, source
+        FROM camera
+        WHERE edge = $1
+        ORDER BY source ASC
+      `,
+      [edge],
+    );
+
+    return result.rows;
+  }
+}

src/camera/camera.service.ts

@@ -0,0 +1,15 @@
+import { Injectable } from '@nestjs/common';
+import { CameraResponseDto } from './dto/camera-response.dto';
+import { GetCamerasDto } from './dto/get-cameras.dto';
+import { createCameraResponse } from './camera.mapper';
+import { CameraRepository } from './camera.repository';
+
+@Injectable()
+export class CameraService {
+  constructor(private readonly repository: CameraRepository) {}
+
+  async findByEdge(query: GetCamerasDto): Promise<CameraResponseDto> {
+    const rows = await this.repository.findByEdge(query.edge);
+    return createCameraResponse(query.edge, rows);
+  }
+}

src/camera/camera.types.ts

@@ -0,0 +1,4 @@
+export type CameraRow = {
+  protocol: string;
+  source: string;
+};

src/camera/dto/camera-response.dto.ts

@@ -0,0 +1,9 @@
+export type CameraItemDto = {
+  protocol: string;
+  source: string;
+};
+
+export type CameraResponseDto = {
+  edge: string;
+  items: CameraItemDto[];
+};

src/camera/dto/get-cameras.dto.ts

@@ -0,0 +1,7 @@
+import { IsNotEmpty, IsString } from 'class-validator';
+
+export class GetCamerasDto {
+  @IsNotEmpty()
+  @IsString()
+  edge!: string;
+}

src/common/is-nullable-number.decorator.ts

@@ -0,0 +1,11 @@
+import { applyDecorators } from '@nestjs/common';
+import { Transform } from 'class-transformer';
+import { IsNumber, ValidateIf, ValidationOptions } from 'class-validator';
+
+export function IsNullableNumber(options?: ValidationOptions): PropertyDecorator {
+  return applyDecorators(
+    Transform(({ value }) => (value === null ? null : Number(value))),
+    ValidateIf((_, value) => value !== null),
+    IsNumber({}, options),
+  );
+}

src/current/current.types.ts

@@ -1,7 +1,7 @@
 export type CurrentRow = {
   edge: string;
   tag: string;
-  value: number;
+  value: number | null;
   createdAt: Date;
   updatedAt: Date;
   name: string | null;

src/current/dto/current-response.dto.ts

@@ -1,7 +1,7 @@
 export type CurrentItemDto = {
   edge: string;
   tag: string;
-  value: number;
+  value: number | null;
   createdAt: Date;
   updatedAt: Date;
   time: Date;

src/ingest/dto/ingest-edge-values.dto.ts

@@ -5,5 +5,5 @@ export class IngestEdgeValuesDto {
   timestamp!: string;
 
   @IsObject()
-  values!: Record<string, number>;
+  values!: Record<string, number | null>;
 }

src/ingest/dto/ingest-point.dto.ts

@@ -1,5 +1,5 @@
-import { Type } from 'class-transformer';
+import { IsDateString, IsNotEmpty, IsString } from 'class-validator';
-import { IsDateString, IsNotEmpty, IsNumber, IsString } from 'class-validator';
+import { IsNullableNumber } from '../../common/is-nullable-number.decorator';
 
 export class IngestPointDto {
   @IsNotEmpty()
@@ -13,7 +13,6 @@ export class IngestPointDto {
   @IsDateString()
   timestamp!: string;
 
-  @Type(() => Number)
+  @IsNullableNumber()
-  @IsNumber()
+  value!: number | null;
-  value!: number;
 }

src/ingest/ingest.controller.ts

@@ -22,7 +22,7 @@ export class IngestController {
     const points = Object.entries(body.values).map(([tag, value]) => ({
       edge,
       tag,
-      value: Number(value),
+      value,
       timestamp: body.timestamp,
     }));
 

src/ingest/ingest.service.ts

@@ -10,15 +10,17 @@ type IngestResult = {
 export class IngestService {
   constructor(private readonly db: DbService) {}
 
-  /** Пишет одну входящую точку в history и обновляет текущий снимок current для UI/SSE. */
+  /** Пишет числовую точку в history и всегда обновляет текущий снимок current для UI/SSE. */
   async ingestPoint(point: IngestPointDto): Promise<IngestResult> {
-    await this.db.query(
+    if (point.value !== null) {
-      `
+      await this.db.query(
-        INSERT INTO history (timestamp, edge, tag, value)
+        `
-        VALUES ($1, $2, $3, $4)
+          INSERT INTO history (timestamp, edge, tag, value)
-      `,
+          VALUES ($1, $2, $3, $4)
-      [point.timestamp, point.edge, point.tag, point.value],
+        `,
-    );
+        [point.timestamp, point.edge, point.tag, point.value],
+      );
+    }
 
     await this.db.query(
       `