feat(awm): fix comments

Author: cpatino-intive

src/__tests__/api/master/consolidateUnspents.test.ts

@@ -236,6 +236,58 @@ describe('POST /api/:coin/wallet/:walletId/consolidateunspents', () => {
     sinon.assert.calledOnce(consolidateUnspentsStub);
   });
 
+  it('should fail when consolidateUnspents returns array with more than one element', async () => {
+    const walletGetNock = nock(bitgoApiUrl)
+      .get(`/api/v2/${coin}/wallet/${walletId}`)
+      .matchHeader('authorization', `Bearer ${accessToken}`)
+      .reply(200, mockWalletData);
+
+    const keychainGetNock = nock(bitgoApiUrl)
+      .get(`/api/v2/${coin}/key/user-key-id`)
+      .matchHeader('authorization', `Bearer ${accessToken}`)
+      .reply(200, mockUserKeychain);
+
+    const mockArrayResult = [
+      {
+        txid: 'first-tx-id',
+        tx: '01000000000102first...',
+        status: 'signed',
+      },
+      {
+        txid: 'second-tx-id',
+        tx: '01000000000102second...',
+        status: 'signed',
+      },
+    ];
+
+    const consolidateUnspentsStub = sinon
+      .stub(Wallet.prototype, 'consolidateUnspents')
+      .resolves(mockArrayResult);
+
+    const requestPayload = {
+      pubkey: mockUserKeychain.pub,
+      source: 'user' as const,
+      feeRate: 1000,
+    };
+
+    const response = await agent
+      .post(`/api/${coin}/wallet/${walletId}/consolidateunspents`)
+      .set('Authorization', `Bearer ${accessToken}`)
+      .send(requestPayload);
+
+    response.status.should.equal(500);
+    response.body.should.have.property('error', 'Internal Server Error');
+    response.body.should.have.property('name', 'Error');
+    response.body.should.have.property(
+      'details',
+      'Expected single consolidation result, but received 2 results',
+    );
+
+    walletGetNock.done();
+    keychainGetNock.done();
+    sinon.assert.calledOnce(consolidateUnspentsStub);
+  });
+
   it('should succeed in consolidating unspents with all optional parameters', async () => {
     const walletGetNock = nock(bitgoApiUrl)
       .get(`/api/v2/${coin}/wallet/${walletId}`)

src/masterBitgoExpress/handlers/handleConsolidateUnspents.ts

@@ -40,8 +40,14 @@ export async function handleConsolidateUnspents(
     // Send consolidate unspents
     let result = await wallet.consolidateUnspents(consolidationParams);
 
-    if (Array.isArray(result) && result.length > 0) {
-      result = result[0];
+    if (Array.isArray(result)) {
+      if (result.length === 1) {
+        result = result[0];
+      } else if (result.length > 1) {
+        throw new Error(
+          `Expected single consolidation result, but received ${result.length} results`,
+        );
+      }
     }
 
     return result;