feat: find bitsacco shares transaction using id

apps/api/src/shares/shares.controller.ts

@@ -74,4 +74,19 @@ export class SharesController {
       userId,
     });
   }
+
+  @Get('transactions/find/:sharesId')
+  @ApiOperation({
+    summary: 'Find Bitsacco shares transaction with given ID',
+  })
+  @ApiParam({
+    name: 'sharesId',
+    type: 'string',
+    description: 'Share Transaction ID',
+  })
+  findSharesTransaction(@Param('sharesId') sharesId: string) {
+    return this.sharesService.findSharesTransaction({
+      sharesId,
+    });
+  }
 }

apps/api/src/shares/shares.service.ts

@@ -7,6 +7,7 @@ import {
   TransferSharesDto,
   UserSharesDto,
   UpdateSharesDto,
+  FindSharesTxDto,
 } from '@bitsacco/common';
 import { Inject, Injectable, OnModuleInit } from '@nestjs/common';
 import { type ClientGrpc } from '@nestjs/microservices';
@@ -49,4 +50,8 @@ export class SharesService implements OnModuleInit {
   allSharesTransactions(req: Empty) {
     return this.client.allSharesTransactions(req);
   }
+
+  findSharesTransaction(req: FindSharesTxDto) {
+    return this.client.findSharesTransaction(req);
+  }
 }

apps/shares/src/shares.controller.ts

@@ -2,6 +2,7 @@ import { Controller } from '@nestjs/common';
 import { GrpcMethod } from '@nestjs/microservices';
 import {
   type Empty,
+  FindSharesTxDto,
   OfferSharesDto,
   SharesServiceControllerMethods,
   SubscribeSharesDto,
@@ -50,4 +51,9 @@ export class SharesController {
   allSharesTransactions(_: Empty) {
     return this.sharesService.allSharesTransactions();
   }
+
+  @GrpcMethod()
+  findSharesTransaction(request: FindSharesTxDto) {
+    return this.sharesService.findSharesTransaction(request);
+  }
 }

apps/shares/src/shares.service.ts

@@ -2,8 +2,10 @@ import { Injectable, Logger } from '@nestjs/common';
 import {
   AllSharesOffers,
   AllSharesTxsResponse,
+  FindSharesTxDto,
   OfferSharesDto,
   SharesOffer,
+  SharesTx,
   SharesTxStatus,
   SubscribeSharesDto,
   TransferSharesDto,
@@ -129,11 +131,13 @@ export class SharesService {
     const originShares = await this.shares.findOne({ _id: sharesId });
     const { quantity, status, transfer, offerId } = updates;
 
+    this.logger.log(`Updates : ${JSON.stringify(updates)}`);
+
     let { userId } = await this.shares.findOneAndUpdate(
       { _id: sharesId },
       {
-        quantity: quantity ?? originShares.quantity,
-        status: status ?? originShares.status,
+        quantity: quantity !== undefined ? quantity : originShares.quantity,
+        status: status !== undefined ? status : originShares.status,
         transfer: transfer ?? originShares.transfer,
         offerId: offerId ?? originShares.offerId,
         updatedAt: Date.now(),
@@ -177,4 +181,16 @@ export class SharesService {
       offers,
     };
   }
+
+  async findSharesTransaction({
+    sharesId,
+  }: FindSharesTxDto): Promise<SharesTx> {
+    const shares = toSharesTx(await this.shares.findOne({ _id: sharesId }));
+
+    if (!shares) {
+      throw new Error('Shares transaction not found');
+    }
+
+    return shares;
+  }
 }

libs/common/src/dto/shares.dto.ts

@@ -11,6 +11,7 @@ import {
   IsNotEmptyObject,
 } from 'class-validator';
 import {
+  FindShareTxRequest,
   OfferSharesRequest,
   SharesTxStatus,
   type SharesTxTransferMeta,
@@ -161,3 +162,11 @@ export class UserSharesDto implements UserSharesTxsRequest {
   @ApiProperty({ example: '7b158dfd-cb98-40b1-9ed2-a13006a9f670' })
   userId: string;
 }
+
+export class FindSharesTxDto implements FindShareTxRequest {
+  @IsNotEmpty()
+  @IsString()
+  @Type(() => String)
+  @ApiProperty({ example: '3e158dfd-cb98-40b1-9ed2-a13006a9f430' })
+  sharesId: string;
+}

proto/shares.proto

@@ -12,6 +12,7 @@ service SharesService {
   rpc UpdateShares(UpdateSharesRequest) returns (UserShareTxsResponse);
   rpc UserSharesTransactions(UserSharesTxsRequest) returns (UserShareTxsResponse);
   rpc AllSharesTransactions(lib.Empty) returns (AllSharesTxsResponse);
+  rpc FindSharesTransaction(FindShareTxRequest) returns (SharesTx);
 }
 
 message OfferSharesRequest {
@@ -132,3 +133,7 @@ message AllSharesTxsResponse {
   repeated SharesTx shares = 1;
   AllSharesOffers offers = 2;
 }
+
+message FindShareTxRequest {
+  string shares_id = 1;
+}