decline -> reject endpoint, CM through auth

apps/authentication/src/auth/auth.controller.ts

@@ -1,16 +1,41 @@
 import { HttpService } from '@nestjs/axios';
-import { Body, Controller, Post, UseGuards } from '@nestjs/common';
+import { Body, Controller, Get, Param, Patch, Post, UseGuards } from '@nestjs/common';
 import { JwtAuthGuard } from './auth-jwt.guard';
 import { AuthService } from './auth.service';
 import { AuthDto } from './dto/auth.dto';
+import { CA } from './dto/ca.dto';
 
 @Controller('auth')
 export class AuthController {
   constructor(private readonly authService: AuthService) { }
 
-  @Post()
+  @Post('/verify')
   @UseGuards(JwtAuthGuard)
   hadleAuth(@Body() body: AuthDto) {
     return this.authService.handleAuth(body);
   }
+
+  @Post('/register')
+  @UseGuards(JwtAuthGuard)
+  handleRegister(@Body() ca: CA) {
+    return this.authService.handleRegister(ca);
+  }
+
+  @Patch('/:caId/accept')
+  @UseGuards(JwtAuthGuard)
+  handleAccept(@Param('caId') caId: string) {
+    return this.authService.handleConsent(caId, 'accept');
+  }
+
+  @Patch('/:caId/reject')
+  @UseGuards(JwtAuthGuard)
+  handleReject(@Param('caId') caId: string) {
+    return this.authService.handleConsent(caId, 'reject');
+  }
+
+  @Patch('/:caId/revoke')
+  @UseGuards(JwtAuthGuard)
+  handleRevoke(@Param('caId') caId: string) {
+    return this.authService.handleConsent(caId, 'revoke');
+  }
 }

apps/authentication/src/auth/auth.service.ts

@@ -2,6 +2,7 @@ import { HttpService } from '@nestjs/axios';
 import { Injectable, InternalServerErrorException } from '@nestjs/common';
 import { lastValueFrom, map } from 'rxjs';
 import { AuthDto } from './dto/auth.dto';
+import { CA } from './dto/ca.dto';
 
 @Injectable()
 export class AuthService {
@@ -126,4 +127,53 @@ export class AuthService {
       throw new InternalServerErrorException();
     }
   }
+
+  handleRegister = async (data: CA) => {
+    try {
+      let ca = data.consentArtifact
+      const caRes = await lastValueFrom(
+        this.httpService
+          .post(
+            `${process.env.CONSENT_MANAGER_URI}/register`,
+            { ca }
+          )
+          .pipe(map((response) => response.data)),
+      );
+      if (!caRes.caId) {
+        return "An error occured while creating Consent Artifact";
+      }
+
+      return caRes;
+
+    } catch (err) {
+      console.log('err: ', err);
+      if (err?.response?.data)
+        return err?.response?.data;
+      throw new InternalServerErrorException();
+    }
+  }
+
+  handleConsent = async (caId: string, type: string) => {
+    try {
+      const caRes = await lastValueFrom(
+        this.httpService
+          .patch(
+            `${process.env.CONSENT_MANAGER_URI}/${caId}/${type}`
+          )
+          .pipe(map((response) => response.data)),
+      );
+
+      if (!caRes.caId) {
+        return "An error occured while performing the requested action";
+      }
+
+      return caRes;
+
+    } catch (err) {
+      console.log('err: ', err);
+      if (err?.response?.data)
+        return err?.response?.data;
+      throw new InternalServerErrorException();
+    }
+  }
 }

apps/authentication/src/auth/dto/ca.dto.ts

@@ -0,0 +1,3 @@
+export class CA {
+  consentArtifact: JSON
+}

apps/consent-manager/src/app.controller.ts

@@ -10,6 +10,7 @@ import { CAObject, CAStates, ConsentAction, GetCAResponse, RequestBody, WebhookR
 import { AppService } from './app.service';
 import { ConsentArtifact, TheProofSchema } from './types/consentArtifact';
 import { CARequests } from '@prisma/client';
+import { RegisterCA } from './types/RegisterCA';
 
 @Controller()
 export class AppController {
@@ -117,9 +118,9 @@ export class AppController {
     return updatedCARequest;
   }
 
-  @ApiOperation({ summary: 'Decline CA' })
+  @ApiOperation({ summary: 'Reject CA' })
   @ApiResponse({ type: ConsentAction, status: 200, description: 'Reject a CA Request' })
-  @Patch('/:caId/decline')
+  @Patch('/:caId/reject')
   async rejectCA(@Param('caId') caId: string): Promise<CARequests> {
     const caRequest = await this.appService.updateCaStatus(caId, CAStates.DECLINE);
     return caRequest;
@@ -128,7 +129,7 @@ export class AppController {
   @ApiOperation({ summary: 'Register CA' })
   @ApiResponse({ type: CAObject, status: 200, description: 'Create a new CA Request entry' })
   @Post('/register')
-  register(@Body() ca: ConsentArtifact): Promise<CARequests> {
-    return this.appService.register(ca, ca.user.id, ca.consumer.url);
+  register(@Body() body: RegisterCA): Promise<CARequests> {
+    return this.appService.register(body.ca, body.ca.user.id, body.ca.consumer.url);
   }
 }

apps/consent-manager/src/types/RegisterCA.ts

@@ -0,0 +1,5 @@
+import { ConsentArtifact } from "./consentArtifact"
+
+export type RegisterCA = {
+    ca: ConsentArtifact
+}