Merge feature to support basic message for a multi-tenant agent

src/controllers/multi-tenancy/MultiTenancyController.ts

@@ -389,7 +389,7 @@
   private async handleKey(createDidOptions: DidCreate, tenantId: string) {
     let didResponse
     let did: string
     let didDocument: any
 
     await this.agent.modules.tenants.withTenantAgent({ tenantId }, async (tenantAgent) => {
       if (!createDidOptions.seed) {
@@ -444,7 +444,7 @@
 
   private async handleDidPeer(createDidOptions: DidCreate, tenantId: string) {
     let didResponse
     let did: any
 
     if (!createDidOptions.keyType) {
       throw Error('keyType is required')
@@ -478,7 +478,7 @@
 
   private async handleWeb(createDidOptions: DidCreate, tenantId: string) {
     let did
     let didDocument: any
 
     if (!createDidOptions.domain) {
       throw Error('For web method domain is required')
@@ -833,7 +833,7 @@
         outOfBandRecords = await tenantAgent.oob.getAll()
 
         if (invitationId)
           outOfBandRecords = outOfBandRecords.filter((o: any) => o.outOfBandInvitation.id === invitationId)
         outOfBandRecordsRes = outOfBandRecords.map((c: any) => c.toJSON())
       })
 
@@ -1007,7 +1007,7 @@
           schema,
         })
       })
-      
+
       if (schemaResponse.schemaState?.state === 'failed') {
         const reason = schemaResponse.schemaState?.reason?.toLowerCase()
         if (reason && reason.includes('insufficient') && reason.includes('funds')) {
@@ -2013,4 +2013,35 @@
 
     return questionAnswerRecord
   }
+
+  /**
+   * Send a question to a connection
+   *
+   * @param tenantId Tenant identifier
+   * @param connectionId Connection identifier
+   * @param content The content of the message
+   */
+  @Security('apiKey')
+  @Post('/basic-message/:connectionId/:tenantId')
+  public async sendBasicMessage(
+    @Path('connectionId') connectionId: RecordId,
+    @Path('tenantId') tenantId: string,
+    @Body() request: Record<'content', string>,
+    @Res() notFoundError: TsoaResponse<404, { reason: string }>,
+    @Res() internalServerError: TsoaResponse<500, { message: string }>
+  ) {
+    try {
+      let basicMessageRecord
+      await this.agent.modules.tenants.withTenantAgent({ tenantId }, async (tenantAgent) => {
+        basicMessageRecord = await tenantAgent.basicMessages.sendMessage(connectionId, request.content)
+        basicMessageRecord = basicMessageRecord?.toJSON()
+      })
+      return basicMessageRecord
+    } catch (error) {
+      if (error instanceof RecordNotFoundError) {
+        return notFoundError(404, { reason: `connection with connection id "${connectionId}" not found.` })
+      }
+      return internalServerError(500, { message: `something went wrong: ${error}` })
+    }
+  }
 }