feat: create intent API endpoints and intent template mapping APIs (#1547)

* feat: create intent APIs

Signed-off-by: pranalidhanavade <pranali.dhanavade@ayanworks.com>

* feat: create intent mapping and create intent APIs

Signed-off-by: pranalidhanavade <pranali.dhanavade@ayanworks.com>

* fix: sonarlint issues

Signed-off-by: pranalidhanavade <pranali.dhanavade@ayanworks.com>

* refactor: move validations from ecosystem repository to ecosystem service

Signed-off-by: pranalidhanavade <pranali.dhanavade@ayanworks.com>

* fix: sonarlint issues

Signed-off-by: pranalidhanavade <pranali.dhanavade@ayanworks.com>

* fix: sonarlint issues

Signed-off-by: pranalidhanavade <pranali.dhanavade@ayanworks.com>

* fix: sonarlint issues

Signed-off-by: pranalidhanavade <pranali.dhanavade@ayanworks.com>

* fix: coderabbit suggestions

Signed-off-by: pranalidhanavade <pranali.dhanavade@ayanworks.com>

* fix: comments on PR

Signed-off-by: pranalidhanavade <pranali.dhanavade@ayanworks.com>

---------

Signed-off-by: pranalidhanavade <pranali.dhanavade@ayanworks.com>

Author: pranalidhanavade

apps/api-gateway/src/ecosystem/ecosystem.controller.ts

@@ -6,12 +6,17 @@ import {
   IEcosystem,
   IEcosystemDashboard,
   IEcosystemInvitation,
-  IEcosystemInvitations,
   IEcosystemMemberInvitations
 } from 'apps/ecosystem/interfaces/ecosystem.interfaces';
 import { CreateEcosystemDto } from 'apps/ecosystem/dtos/create-ecosystem-dto';
 // eslint-disable-next-line camelcase
 import { ecosystem_orgs, user } from '@prisma/client';
+import { IUserRequest } from '@credebl/user-request/user-request.interface';
+import { CreateIntentDto } from 'apps/ecosystem/dtos/create-intent.dto';
+import { UpdateIntentDto } from 'apps/ecosystem/dtos/update-intent.dto';
+import { CreateIntentTemplateDto, UpdateIntentTemplateDto } from '../utilities/dtos/intent-template.dto';
+import { GetAllIntentTemplatesDto } from '../utilities/dtos/get-all-intent-templates.dto';
+import { IIntentTemplateList } from '@credebl/common/interfaces/intents-template.interface';
 
 @Injectable()
 export class EcosystemService {
@@ -20,26 +25,6 @@ export class EcosystemService {
     private readonly natsClient: NATSClient
   ) {}
 
-  /**
-   *
-   * @param createEcosystemInvitationDto
-   * @returns Ecosystem creation success
-   */
-  async inviteUserToCreateEcosystem(email: string, platformAdminId: string): Promise<IEcosystemInvitations> {
-    return this.natsClient.sendNatsMessage(this.serviceProxy, 'invite-user-for-ecosystem-creation', {
-      email,
-      platformAdminId
-    });
-  }
-  /**
-   *
-   * @param userId
-   * @returns Get invitations
-   */
-  async getInvitationsByUserId(userId: string): Promise<IEcosystemInvitations[]> {
-    return this.natsClient.sendNatsMessage(this.serviceProxy, 'get-ecosystem-invitations-by-user', { userId });
-  }
-
   /**
    *
    * @param createEcosystemDto
@@ -123,4 +108,102 @@ export class EcosystemService {
       ecosystemId
     });
   }
+
+  // Intent Template CRUD operations
+  async createIntentTemplate(createIntentTemplateDto: CreateIntentTemplateDto, user: IUserRequest): Promise<object> {
+    const payload = { ...createIntentTemplateDto, user: { id: user.userId } };
+    return this.natsClient.sendNatsMessage(this.serviceProxy, 'create-intent-template', payload);
+  }
+
+  async getIntentTemplateById(id: string): Promise<object> {
+    return this.natsClient.sendNatsMessage(this.serviceProxy, 'get-intent-template-by-id', id);
+  }
+
+  async getIntentTemplatesByIntentId(intentId: string): Promise<object[]> {
+    return this.natsClient.sendNatsMessage(this.serviceProxy, 'get-intent-templates-by-intent-id', { intentId });
+  }
+
+  async updateIntentTemplate(
+    id: string,
+    updateIntentTemplateDto: UpdateIntentTemplateDto,
+    user: IUserRequest
+  ): Promise<object> {
+    const payload = { id, ...updateIntentTemplateDto, user: { id: user.userId } };
+    return this.natsClient.sendNatsMessage(this.serviceProxy, 'update-intent-template', payload);
+  }
+
+  async deleteIntentTemplate(id: string): Promise<object> {
+    return this.natsClient.sendNatsMessage(this.serviceProxy, 'delete-intent-template', { id });
+  }
+
+  async getIntentTemplatesByOrgId(orgId: string): Promise<object[]> {
+    return this.natsClient.sendNatsMessage(this.serviceProxy, 'get-intent-templates-by-org-id', { orgId });
+  }
+  // Intent CRUD operations
+
+  /**
+   * Create a new intent
+   * @param createIntentDto Intent details
+   * @param user Logged-in user
+   * @returns Created intent
+   */
+  async createIntent(createIntentDto: CreateIntentDto): Promise<object> {
+    const payload = { createIntentDto };
+
+    return this.natsClient.sendNatsMessage(this.serviceProxy, 'create-intent', payload);
+  }
+
+  /**
+   * Get all intents
+   * @returns List of intents
+   */
+  async getIntents(ecosystemId: string, intentId?: string): Promise<object[]> {
+    return this.natsClient.sendNatsMessage(this.serviceProxy, 'get-intents', { ecosystemId, intentId });
+  }
+
+  async getVerificationTemplates(orgId: string): Promise<object[]> {
+    return this.natsClient.sendNatsMessage(this.serviceProxy, 'get-verification-templates-by-org-id', { orgId });
+  }
+
+  async getIntentTemplateByIntentAndOrg(intentName: string, verifierOrgId: string): Promise<object | null> {
+    const payload = { intentName, verifierOrgId };
+    return this.natsClient.sendNatsMessage(this.serviceProxy, 'get-intent-template-by-intent-and-org', payload);
+  }
+
+  async getAllIntentTemplatesByQuery(
+    intentTemplateSearchCriteria: GetAllIntentTemplatesDto
+  ): Promise<IIntentTemplateList> {
+    const payload = {
+      intentTemplateSearchCriteria
+    };
+    return this.natsClient.sendNatsMessage(this.serviceProxy, 'get-all-intent-templates-by-query', payload);
+  }
+
+  /**
+   * Update an intent
+   * @param id Intent ID
+   * @param updateIntentDto Updated intent details
+   * @param user Logged-in user
+   * @returns Updated intent
+   */
+  async updateIntent(updateIntentDto: UpdateIntentDto): Promise<object> {
+    const payload = {
+      updateIntentDto
+    };
+
+    return this.natsClient.sendNatsMessage(this.serviceProxy, 'update-intent', payload);
+  }
+
+  /**
+   * Delete an intent
+   * @param id Intent ID
+   * @returns Deleted intent
+   */
+  async deleteIntent(ecosystemId: string, intentId: string, user: IUserRequest): Promise<object> {
+    return this.natsClient.sendNatsMessage(this.serviceProxy, 'delete-intent', {
+      ecosystemId,
+      intentId,
+      user: { id: user.userId }
+    });
+  }
 }