LBRYCommunity/lighthouse.js
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

Chainquery #73

Merged
tiger5226 merged 2 commits from chainquery into master 2018-05-15 16:17:04 +02:00
Conversation 1 Commits 2 Files changed 1 +6 -6
1 changed files with 6 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
server/utils/chainquery/index.js
View file

@ -11,6 +11,7 @@ import rp from 'request-promise';
import appRoot from 'app-root-path'; import appRoot from 'app-root-path';
import fs from 'fs'; import fs from 'fs';
import fileExists from 'file-exists'; import fileExists from 'file-exists';
import * as util from '../../utils/importer/util';
const loggerStream = winstonStream(winston, 'info'); const loggerStream = winstonStream(winston, 'info');
const eclient = new elasticsearch.Client({ const eclient = new elasticsearch.Client({
@ -59,11 +60,10 @@ export async function claimSync () {
weight: 30, weight: 30,
}; };
} }
console.log('Push claim to elastic search: ' + claim);
pushElastic(claim); pushElastic(claim);
} }
winston.log('info', '[Importer] Pushed ' + claims.length + ' claims to elastic search');
winston.log('info', '[Importer] Removing blocked claims from search!'); winston.log('info', '[Importer] Removing blocked claims from search!');
let util = require('./util.js');
let blockedOutputsResponse = await getBlockedOutpoints(); let blockedOutputsResponse = await getBlockedOutpoints();
let outpointlist = JSON.parse(blockedOutputsResponse); let outpointlist = JSON.parse(blockedOutputsResponse);
for (let outpoint of outpointlist.data.outpoints) { for (let outpoint of outpointlist.data.outpoints) {
@ -97,7 +97,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',
@ -137,7 +137,7 @@ function sleep (ms) {
function getBlockedOutpoints () { function getBlockedOutpoints () {
return new Promise((resolve, reject) => { return new Promise((resolve, reject) => {
rp(`http://api.lbry.io/file/list_blocked`) rp(`https://api.lbry.io/file/list_blocked`)
.then(function (htmlString) { .then(function (htmlString) {
resolve(htmlString); resolve(htmlString);
}) })
@ -155,8 +155,8 @@ 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 ` +
`WHERE modified >='` + time + `'`; `WHERE modified >='` + time + `'`;