-removed comma on last column of query.
-removed useless console log. -added more understandable logging for which claims are pushed to elastic search.
This commit is contained in:
parent
b1c7f8b8ca
commit
c6893991c3
1 changed files with 2 additions and 3 deletions
|
@ -59,7 +59,6 @@ export async function claimSync () {
|
||||||
weight: 30,
|
weight: 30,
|
||||||
};
|
};
|
||||||
}
|
}
|
||||||
console.log('Push claim to elastic search: ' + claim);
|
|
||||||
pushElastic(claim);
|
pushElastic(claim);
|
||||||
}
|
}
|
||||||
winston.log('info', '[Importer] Removing blocked claims from search!');
|
winston.log('info', '[Importer] Removing blocked claims from search!');
|
||||||
|
@ -97,7 +96,7 @@ export function getStats () {
|
||||||
}
|
}
|
||||||
|
|
||||||
async function pushElastic (claim) {
|
async function pushElastic (claim) {
|
||||||
console.log('_id:' + claim.claimId);
|
console.log('Pushing To Elastic Search claimId:' + claim.claimId);
|
||||||
return new Promise(async(resolve, reject) => {
|
return new Promise(async(resolve, reject) => {
|
||||||
queue.push({
|
queue.push({
|
||||||
index: 'claims',
|
index: 'claims',
|
||||||
|
@ -155,7 +154,7 @@ function getClaimsSince (time) {
|
||||||
`value_as_json as value, ` +
|
`value_as_json as value, ` +
|
||||||
`bid_state, ` +
|
`bid_state, ` +
|
||||||
`effective_amount, ` +
|
`effective_amount, ` +
|
||||||
`claim_id as claimId, ` +
|
`claim_id as claimId ` +
|
||||||
// `transaction_by_hash_id, ` + // txhash and vout needed to leverage old format for comparison.
|
// `transaction_by_hash_id, ` + // txhash and vout needed to leverage old format for comparison.
|
||||||
// `vout ` +
|
// `vout ` +
|
||||||
`FROM claim ` +
|
`FROM claim ` +
|
||||||
|
|
Loading…
Add table
Reference in a new issue