Skip to content

Commit

Permalink
feat: removed getcount param for transfers
Browse files Browse the repository at this point in the history
  • Loading branch information
pranavkparti committed Aug 10, 2023
1 parent 2aa9127 commit c459281
Show file tree
Hide file tree
Showing 4 changed files with 17 additions and 15 deletions.
9 changes: 8 additions & 1 deletion server/handlers/transferHandler/index.js
Original file line number Diff line number Diff line change
Expand Up @@ -95,7 +95,14 @@ const transferIdGet = async (req, res) => {
req.params.transfer_id,
req.wallet_id,
);
res.json(result);

const modifiedTransfer = {
...result,
token_count:
+result.parameters?.bundle?.bundleSize || +result.parameters?.tokens?.length,
}

res.json(modifiedTransfer);
};

const transferIdTokenGet = async (req, res) => {
Expand Down
11 changes: 5 additions & 6 deletions server/models/Transfer.js
Original file line number Diff line number Diff line change
Expand Up @@ -26,20 +26,20 @@ class Transfer {
return transferObjectCopy;
}

async getByFilter(filter, limitOptions, getCount) {
const {count, result} = await this._transferRepository.getByFilter(
async getByFilter(filter, limitOptions) {
const {result, count} = await this._transferRepository.getByFilter(
filter,
limitOptions,
getCount
);


const transfers = result.map((t) => this.constructor.removeWalletIds(t));

return { transfers, count }
}

async getById({ transferId, walletLoginId }) {
const transfers = await this.getTransfers({ walletLoginId, transferId });
const {transfers} = await this.getTransfers({ walletLoginId, transferId });
return transfers[0];
}

Expand All @@ -65,7 +65,6 @@ class Transfer {
transferId,
before,
after,
getCount
}) {
const filter = {
and: [],
Expand Down Expand Up @@ -98,7 +97,7 @@ class Transfer {
if (after) {
filter.and.push({ after: { 'transfer.created_at': after } });
}
return this.getByFilter(filter, { offset, limit }, getCount);
return this.getByFilter(filter, { offset, limit });
}

/*
Expand Down
7 changes: 2 additions & 5 deletions server/repositories/TransferRepository.js
Original file line number Diff line number Diff line change
Expand Up @@ -93,7 +93,7 @@ class TransferRepository extends BaseRepository {
return transfer;
}

async getByFilter(filter, limitOptions, getCount) {
async getByFilter(filter, limitOptions) {
let promise = this._session
.getDB()
.select(
Expand Down Expand Up @@ -136,10 +136,7 @@ class TransferRepository extends BaseRepository {
const result = await promise;
Joi.assert(result, Joi.array().required());

if (getCount)
return { result, count: +count[0].count };

return result;
return { result, count: +count[0].count };
}

async getPendingTransfers(wallet_id) {
Expand Down
5 changes: 2 additions & 3 deletions server/services/TransferService.js
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@ class TransferService {
}

async getByFilter(query, walletLoginId) {
const { state, wallet, limit, offset, before, after, getCount = true } = query;
const { state, wallet, limit, offset, before, after } = query;

let walletId;

Expand All @@ -29,8 +29,7 @@ class TransferService {
limit,
walletLoginId,
before,
after,
getCount
after
});


Expand Down

0 comments on commit c459281

Please sign in to comment.