feat: implement StorX credential management and service integration

Author: neuralarchitects

backend/src/modules/device/controllers/storx.controller.ts

@@ -1,6 +1,24 @@
-import { Controller, Get, HttpCode, Post, Query } from '@nestjs/common';
-import { ApiOperation, ApiQuery, ApiTags } from '@nestjs/swagger';
+import {
+  Body,
+  Controller,
+  Get,
+  HttpCode,
+  Post,
+  Query,
+  Request,
+  Res,
+  UseGuards,
+} from '@nestjs/common';
+import {
+  ApiBearerAuth,
+  ApiOperation,
+  ApiQuery,
+  ApiTags,
+} from '@nestjs/swagger';
 import { StorxService } from '../services/storx.service';
+import { Response } from 'express';
+import { InsertStorxDto } from '../data-transfer-objects/insert-storx.dto';
+import { JwtAuthGuard } from 'src/modules/authentication/guard/jwt-auth.guard';
 
 @ApiTags('StorX')
 @Controller('app')
@@ -19,12 +37,27 @@ export class StorXController {
     };
   }
 
-  @Get('v1/storx/callback')
+  @Post('v1/storx/credentials')
   @HttpCode(200)
-  async callback(@Query('access_grant') accessGrant: string) {
-    await this.storxService.handleCallback(accessGrant);
-    return {
-      message: 'Callback received',
-    };
+  @ApiOperation({
+    summary: 'Save StorX Credentials',
+    description: 'Save StorX Credentials',
+  })
+  @UseGuards(JwtAuthGuard)
+  @ApiBearerAuth()
+  async saveCredentials(@Body() body: InsertStorxDto, @Request() request) {
+    return this.storxService.saveCredentials(body, request.user.userId);
+  }
+
+  @Get('v1/storx/credentials')
+  @HttpCode(200)
+  @ApiOperation({
+    summary: 'Get StorX Credentials',
+    description: 'Get StorX Credentials',
+  })
+  @UseGuards(JwtAuthGuard)
+  @ApiBearerAuth()
+  async getCredentials(@Request() request) {
+    return this.storxService.getCredentials(request.user.userId);
   }
 }

backend/src/modules/device/data-transfer-objects/insert-storx.dto.ts

@@ -0,0 +1,8 @@
+import { ApiProperty } from '@nestjs/swagger';
+import { IsString } from 'class-validator';
+
+export class InsertStorxDto {
+  @IsString({ message: 'accessGrant must be string.' })
+  @ApiProperty({ required: true })
+  accessGrant: string;
+}

backend/src/modules/device/device.module.ts

@@ -22,15 +22,18 @@ import { BuildingModule } from '../building/building.module';
 import { StorxService } from './services/storx.service';
 import { StorXController } from './controllers/storx.controller';
 import { JwtModule } from '@nestjs/jwt';
+import { storxFeature } from './features/storx.feature';
+import { StorxRepository } from './repositories/storx.repository';
 
 @Module({
   imports: [
     JwtModule.register({
-      secret: '$2a$10$4THkK2FfT2Y7AIbU0pBFPOpmKeTfrzs8On2Qe8L362D4DR8VI52gO',
+      secret: process.env.STORX_CLIENT_SECRET,
     }),
     MongooseModule.forFeature(deviceFeature),
     MongooseModule.forFeature(deviceLogFeature),
     MongooseModule.forFeature(deviceTypeFeature),
+    MongooseModule.forFeature(storxFeature),
     forwardRef(() => UserModule),
     forwardRef(() => NotificationModule),
     forwardRef(() => ServiceModule),
@@ -47,6 +50,7 @@ import { JwtModule } from '@nestjs/jwt';
     DeviceTypeService,
     DeviceTypeRepository,
     StorxService,
+    StorxRepository,
   ],
   controllers: [
     DeviceController,

backend/src/modules/device/features/storx.feature.ts

@@ -0,0 +1,3 @@
+import { storxSchema } from '../schemas/storx.schema';
+
+export const storxFeature = [{ name: 'storx', schema: storxSchema }];

backend/src/modules/device/interfaces/storx.interface.ts

@@ -0,0 +1,5 @@
+import { Document } from 'mongoose';
+
+export interface Storx extends Document {
+  accessGrant: string;
+}

backend/src/modules/device/models/storx.model.ts

@@ -0,0 +1,6 @@
+import { Model } from 'mongoose';
+import { Storx } from '../interfaces/storx.interface';
+
+export interface StorxModel extends Model<Storx> {
+  [x: string]: any;
+}

backend/src/modules/device/repositories/storx.repository.ts

@@ -0,0 +1,19 @@
+import { InjectModel } from '@nestjs/mongoose';
+import { StorxModel } from '../models/storx.model';
+import { Injectable } from '@nestjs/common';
+
+@Injectable()
+export class StorxRepository {
+  constructor(
+    @InjectModel('storx')
+    private readonly storxModel: StorxModel,
+  ) {}
+
+  async insertStorx(data) {
+    return await this.storxModel.create(data);
+  }
+
+  async getStorxByUserId(userId: string) {
+    return await this.storxModel.findOne().where('userId').equals(userId);
+  }
+}

backend/src/modules/device/schemas/storx.schema.ts

@@ -0,0 +1,11 @@
+import { Schema } from 'mongoose';
+
+const storxSchema = new Schema({
+  userId: { type: String, required: true },
+  accessGrant: { type: String, required: true },
+  accessKeyId: { type: String },
+  secretKey: { type: String },
+  endpoint: { type: String },
+});
+
+export { storxSchema };