feat: update solowallet transaction

apps/api/src/solowallet/solowallet.controller.ts

@@ -1,5 +1,6 @@
 import {
   DepositFundsRequestDto,
+  UpdateTxDto,
   UserTxsRequestDto,
   WithdrawFundsRequestDto,
 } from '@bitsacco/common';
@@ -41,4 +42,13 @@ export class SolowalletController {
   userTransactions(@Body() req: UserTxsRequestDto) {
     return this.walletService.userTransactions(req);
   }
+
+  @Post('update')
+  @ApiOperation({ summary: 'Update Solowallet transaction' })
+  @ApiBody({
+    type: UpdateTxDto,
+  })
+  updateShares(@Body() req: UpdateTxDto) {
+    return this.walletService.updateTransaction(req);
+  }
 }

apps/api/src/solowallet/solowallet.service.ts

@@ -4,6 +4,7 @@ import {
   SOLOWALLET_SERVICE_NAME,
   SolowalletServiceClient,
   WithdrawFundsRequestDto,
+  UpdateTxDto,
 } from '@bitsacco/common';
 import { Inject, Injectable, OnModuleInit } from '@nestjs/common';
 import { type ClientGrpc } from '@nestjs/microservices';
@@ -33,4 +34,8 @@ export class SolowalletService implements OnModuleInit {
   withdrawFunds(req: WithdrawFundsRequestDto) {
     return this.client.withdrawFunds(req);
   }
+
+  updateTransaction(req: UpdateTxDto) {
+    return this.client.updateTransaction(req);
+  }
 }

apps/solowallet/src/solowallet.controller.ts

@@ -5,6 +5,7 @@ import {
   DepositFundsRequestDto,
   UserTxsRequestDto,
   WithdrawFundsRequestDto,
+  UpdateTxDto,
 } from '@bitsacco/common';
 import { SolowalletService } from './solowallet.service';
 
@@ -27,4 +28,9 @@ export class SolowalletController {
   withdrawFunds(request: WithdrawFundsRequestDto) {
     return this.solowalletService.withdrawFunds(request);
   }
+
+  @GrpcMethod()
+  updateTransaction(request: UpdateTxDto) {
+    return this.solowalletService.updateTransaction(request);
+  }
 }

apps/solowallet/src/solowallet.service.ts

@@ -25,6 +25,7 @@ import {
   TransactionType,
   WithdrawFundsRequestDto,
   CreateOfframpSwapDto,
+  UpdateTxDto,
 } from '@bitsacco/common';
 import { type ClientGrpc } from '@nestjs/microservices';
 import { catchError, firstValueFrom, map, of, tap } from 'rxjs';
@@ -482,6 +483,33 @@ export class SolowalletService {
     };
   }
 
+  async updateTransaction({ txId, updates }: UpdateTxDto) {
+    const originTx = await this.wallet.findOne({ _id: txId });
+    const { status, lightning, reference } = updates;
+
+    let { userId } = await this.wallet.findOneAndUpdate(
+      { _id: txId },
+      {
+        status: status !== undefined ? status : originTx.status,
+        lightning: lightning !== undefined ? lightning : originTx.lightning,
+        reference: reference ?? originTx.reference,
+      },
+    );
+
+    const ledger = await this.getPaginatedUserTxLedger({
+      userId,
+      pagination: { page: 0, size: 10 },
+    });
+    const meta = await this.getWalletMeta(userId);
+
+    return {
+      txId: originTx._id,
+      ledger,
+      meta,
+      userId,
+    };
+  }
+
   @OnEvent(fedimint_receive_success)
   private async handleSuccessfulReceive({
     context,

libs/common/src/dto/solowallet.dto.ts

@@ -1,7 +1,10 @@
 import { Type } from 'class-transformer';
 import {
+  IsEnum,
   IsNotEmpty,
+  IsNotEmptyObject,
   IsNumber,
+  IsOptional,
   IsString,
   Min,
   ValidateNested,
@@ -16,6 +19,9 @@ import {
   DepositFundsRequest,
   WithdrawFundsRequest,
   UserTxsRequest,
+  UpdateTxRequest,
+  SolowalletTxUpdates,
+  TransactionStatus,
 } from '../types';
 import { PaginatedRequestDto } from './lib.dto';
 
@@ -86,3 +92,36 @@ export class UserTxsRequestDto implements UserTxsRequest {
   @ApiProperty({ type: PaginatedRequestDto })
   pagination: PaginatedRequestDto;
 }
+
+class SolowalletTxUpdatesDto implements SolowalletTxUpdates {
+  @IsOptional()
+  @IsEnum(TransactionStatus)
+  @ApiProperty({ enum: TransactionStatus })
+  status?: TransactionStatus;
+
+  @IsOptional()
+  @ValidateNested()
+  @Type(() => Bolt11InvoiceDto)
+  @ApiProperty({ type: Bolt11InvoiceDto })
+  lightning?: Bolt11InvoiceDto;
+
+  @IsOptional()
+  @IsString()
+  @Type(() => String)
+  @ApiProperty()
+  reference: string;
+}
+
+export class UpdateTxDto implements UpdateTxRequest {
+  @IsNotEmpty()
+  @IsString()
+  @Type(() => String)
+  @ApiProperty({ example: '4a4b4c4d-cb98-40b1-9ed2-a13006a9f670' })
+  txId: string;
+
+  @IsNotEmptyObject()
+  @ValidateNested()
+  @Type(() => SolowalletTxUpdatesDto)
+  @ApiProperty({ type: SolowalletTxUpdatesDto })
+  updates: SolowalletTxUpdatesDto;
+}

proto/solowallet.proto

@@ -12,6 +12,8 @@ service SolowalletService {
   rpc WithdrawFunds(WithdrawFundsRequest) returns (UserTxsResponse){}
 
   rpc UserTransactions(UserTxsRequest) returns (UserTxsResponse){}
+
+  rpc UpdateTransaction(UpdateTxRequest) returns (UserTxsResponse) {}
 }
 
 message DepositFundsRequest {
@@ -97,3 +99,14 @@ message WalletMeta {
   float total_withdrawals = 2;
   int32 current_balance = 3;
 }
+
+message UpdateTxRequest {
+  string tx_id = 1;
+  SolowalletTxUpdates updates = 2;
+}
+
+message SolowalletTxUpdates {
+  optional lib.TransactionStatus status = 1;
+  optional lightning.Bolt11 lightning = 2;
+  optional string reference = 3;
+}