add bundle
This commit is contained in:
parent
a4b02b9f4b
commit
74d9c6ac36
1 changed files with 19 additions and 9 deletions
|
@ -864,19 +864,29 @@ var claimQueries = (db, table, sequelize) => ({
|
||||||
});
|
});
|
||||||
},
|
},
|
||||||
|
|
||||||
getAllChannelClaims: async (channelClaimId) => {
|
getAllChannelClaims: async (channelClaimId, bidState) => {
|
||||||
logger$1.debug(`claim.getAllChannelClaims for ${channelClaimId}`);
|
logger$1.debug(`claim.getAllChannelClaims for ${channelClaimId}`);
|
||||||
|
const whereClause = bidState || {
|
||||||
|
[sequelize.Op.or]: [
|
||||||
|
{ bid_state: 'Controlling' },
|
||||||
|
{ bid_state: 'Active' },
|
||||||
|
{ bid_state: 'Accepted' },
|
||||||
|
],
|
||||||
|
};
|
||||||
|
const selectWhere = {
|
||||||
|
...whereClause,
|
||||||
|
publisher_id: channelClaimId,
|
||||||
|
};
|
||||||
return await table.findAll({
|
return await table.findAll({
|
||||||
where: { publisher_id: channelClaimId },
|
where: selectWhere,
|
||||||
order: [['height', 'DESC']],
|
order: [['height', 'DESC']],
|
||||||
})
|
})
|
||||||
.then(channelClaimsArray => {
|
.then(channelClaimsArray => {
|
||||||
if(channelClaimsArray.length === 0) {
|
if (channelClaimsArray.length === 0) {
|
||||||
return null;
|
return null;
|
||||||
}
|
}
|
||||||
|
return channelClaimsArray;
|
||||||
return channelClaimsArray;
|
});
|
||||||
})
|
|
||||||
},
|
},
|
||||||
|
|
||||||
getClaimIdByLongChannelId: async (channelClaimId, claimName) => {
|
getClaimIdByLongChannelId: async (channelClaimId, claimName) => {
|
||||||
|
|
Loading…
Reference in a new issue