adding status endpoint for devices

Author: CropWatchDevelopment

src/devices/devices.controller.ts

@@ -70,6 +70,21 @@ export class DevicesController {
     return this.devicesService.findAll(req.user, req.headers.authorization, skip, take);
   }
 
+  @Get('status')
+  @UseGuards(JwtAuthGuard)
+  @ApiOperation({
+    summary: 'Returns online vs offline devices for the authenticated user',
+    description: `
+    Returns the online vs offline status of all devices for the authenticated user.`,
+  })
+  findAllDeviceStatus(@Req() req) {
+    const parsedSkip = parseInt(req.query.skip, 10);
+    const parsedTake = parseInt(req.query.take, 10);
+    const skip = Number.isNaN(parsedSkip) ? 0 : parsedSkip;
+    const take = Number.isNaN(parsedTake) ? undefined : parsedTake;
+    return this.devicesService.findAllStatus(req.user, req.headers.authorization);
+  }
+
   @Get('latest-primary-data')
   @UseGuards(JwtAuthGuard)
   @ApiParam({ name: 'skip (0)', description: 'Number of records to skip for pagination', required: false })

src/devices/devices.service.ts

@@ -100,6 +100,45 @@ export class DevicesService {
     return data;
   }
 
+  public async findAllStatus(jwtPayload: any, authHeader: string): Promise<{ online: number; offline: number }> {
+    const accessToken = this.getAccessToken(authHeader);
+    const client = this.supabaseService.getClient(accessToken);
+    const userId = this.getUserId(jwtPayload);
+
+    const { data: devices, error: devicesError } = await client
+      .from('cw_devices')
+      .select('last_data_updated_at, upload_interval, cw_device_type(default_upload_interval)')
+      .eq('user_id', userId);
+
+    if (devicesError) {
+      throw new InternalServerErrorException('Failed to fetch devices');
+    }
+
+    if (!devices || devices.length === 0) {
+      throw new NotFoundException('No devices found');
+    }
+
+    const now = new Date();
+
+    let onlineCount = 0;
+    let offlineCount = 0;
+
+    devices.forEach((device) => {
+      const lastUpdated = new Date(device.last_data_updated_at);
+      const minutesSinceLastUpdate = (now.getTime() - lastUpdated.getTime()) / (1000 * 60);
+      const deviceType = Array.isArray(device.cw_device_type)
+        ? device.cw_device_type[0]
+        : device.cw_device_type;
+      if (minutesSinceLastUpdate <= (device.upload_interval ? device.upload_interval : (deviceType?.default_upload_interval as number))) {
+        onlineCount++;
+      } else {
+        offlineCount++;
+      }
+    });
+
+    return { online: onlineCount, offline: offlineCount };
+  }
+
   public async findData(
     jwtPayload: any,
     devEui: string,

src/payments/dto/create-checkout-session.dto.ts

@@ -54,17 +54,23 @@ export class CreateCheckoutSessionDto {
 
   @ApiPropertyOptional({
     type: 'object',
-    additionalProperties: true,
+    additionalProperties: {
+      oneOf: [{ type: 'string' }, { type: 'number' }, { type: 'boolean' }],
+    },
     description: 'Metadata copied to order/subscription.',
+    example: { plan: 'pro', seats: 5, trial: true },
   })
-  metadata?: Record<string, unknown>;
+  metadata?: Record<string, string | number | boolean>;
 
   @ApiPropertyOptional({
     type: 'object',
-    additionalProperties: true,
+    additionalProperties: {
+      oneOf: [{ type: 'string' }, { type: 'number' }, { type: 'boolean' }],
+    },
     description: 'Metadata copied to customer when created.',
+    example: { source: 'dashboard', region: 'us-east-1' },
   })
-  customer_metadata?: Record<string, unknown>;
+  customer_metadata?: Record<string, string | number | boolean>;
 
   @ApiPropertyOptional({ default: true })
   allow_discount_codes?: boolean;

src/payments/payments.service.ts

@@ -10,6 +10,8 @@ import { ConfigService } from '@nestjs/config';
 import { CreateCheckoutSessionDto } from './dto/create-checkout-session.dto';
 import { CreateCustomerPortalSessionDto } from './dto/create-customer-portal-session.dto';
 
+type CheckoutMetadataValue = string | number | boolean;
+
 @Injectable()
 export class PaymentsService {
   constructor(private readonly configService: ConfigService) {}
@@ -60,10 +62,12 @@ export class PaymentsService {
     if (createCheckoutSessionDto.customer_billing_address) {
       payload.customer_billing_address = createCheckoutSessionDto.customer_billing_address;
     }
-    if (createCheckoutSessionDto.metadata) {
+    if (createCheckoutSessionDto.metadata !== undefined) {
+      this.assertCheckoutMetadata('metadata', createCheckoutSessionDto.metadata);
       payload.metadata = createCheckoutSessionDto.metadata;
     }
-    if (createCheckoutSessionDto.customer_metadata) {
+    if (createCheckoutSessionDto.customer_metadata !== undefined) {
+      this.assertCheckoutMetadata('customer_metadata', createCheckoutSessionDto.customer_metadata);
       payload.customer_metadata = createCheckoutSessionDto.customer_metadata;
     }
     if (typeof createCheckoutSessionDto.allow_discount_codes === 'boolean') {
@@ -184,6 +188,32 @@ export class PaymentsService {
     return token;
   }
 
+  private assertCheckoutMetadata(fieldName: string, value: unknown): void {
+    if (!value || typeof value !== 'object' || Array.isArray(value)) {
+      throw new BadRequestException(
+        `${fieldName} must be an object with string, number, or boolean values`,
+      );
+    }
+
+    for (const [key, entryValue] of Object.entries(value)) {
+      if (!this.isValidCheckoutMetadataValue(entryValue)) {
+        throw new BadRequestException(
+          `${fieldName}.${key} must be a string, number, or boolean`,
+        );
+      }
+    }
+  }
+
+  private isValidCheckoutMetadataValue(value: unknown): value is CheckoutMetadataValue {
+    if (typeof value === 'string' || typeof value === 'boolean') {
+      return true;
+    }
+    if (typeof value === 'number') {
+      return Number.isFinite(value);
+    }
+    return false;
+  }
+
   private getPolarApiBaseUrl(): string {
     const configuredBaseUrl = this.configService.get<string>('POLAR_API_URL')?.trim();
     const baseUrl =