36 lines
1.3 KiB
JavaScript
36 lines
1.3 KiB
JavaScript
const chainquery = require('chainquery').default;
|
|
const logger = require('winston');
|
|
const getClaimData = require('server/utils/getClaimData');
|
|
const { returnPaginatedChannelClaims } = require('./channelPagination.js');
|
|
|
|
const getChannelClaims = async (channelName, channelLongId, page) => {
|
|
logger.debug(`getChannelClaims: ${channelName}, ${channelLongId}, ${page}`);
|
|
let channelShortId = await chainquery.claim.queries.getShortClaimIdFromLongClaimId(
|
|
channelLongId,
|
|
channelName
|
|
);
|
|
let channelClaims;
|
|
if (channelLongId) {
|
|
channelClaims = await chainquery.claim.queries.getAllChannelClaims(channelLongId);
|
|
}
|
|
/*
|
|
Put mempool unconfirmed claims at the beginning
|
|
*/
|
|
const split = channelClaims.reduce(
|
|
(acc, val) =>
|
|
val.dataValues.height === 0
|
|
? { ...acc, zero: acc.zero.concat(val) }
|
|
: { ...acc, nonzero: acc.nonzero.concat(val) },
|
|
{ zero: [], nonzero: [] }
|
|
);
|
|
channelClaims = split.zero.concat(split.nonzero);
|
|
|
|
const processingChannelClaims = channelClaims
|
|
? channelClaims.map(claim => getClaimData(claim, channelName, channelShortId))
|
|
: [];
|
|
const processedChannelClaims = await Promise.all(processingChannelClaims);
|
|
|
|
return returnPaginatedChannelClaims(channelName, channelShortId, processedChannelClaims, page);
|
|
};
|
|
|
|
module.exports = getChannelClaims;
|