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

added slack integration

Browse source
This commit is contained in:
Mark Beamer Jr 2018-10-28 02:28:24 -04:00
parent 36db99ddca
commit 965746b9d2
No known key found for this signature in database
GPG key ID: 1C314FB89AD76973
6 changed files with 155 additions and 15 deletions
server/utils/chainquery
index.js

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

@ -12,6 +12,7 @@ import appRoot from 'app-root-path';
import fs from 'fs';
import fileExists from 'file-exists';
import * as util from '../../utils/importer/util';
import {logErrorToSlack} from '../../index';
const elasticsearchloglevel = 'info';
const loggerStream = winstonStream(winston, elasticsearchloglevel);
@ -68,7 +69,7 @@ export async function claimSync () {
await sleep(600000);
claimSync();
} catch (err) {
winston.log(err);
logErrorToSlack(err);
status.err = err;
await sleep(600000);
claimSync();
@ -116,6 +117,7 @@ function getJSON (path) {
return new Promise((resolve, reject) => {
jsonfile.readFile(path, function (err, jsoncontent) {
if (err) {
logErrorToSlack(err);
reject(err);
} else {
resolve(jsoncontent);
@ -127,6 +129,7 @@ function saveJSON (path, obj) {
return new Promise((resolve, reject) => {
jsonfile.writeFile(path, obj, function (err, jsoncontent) {
if (err) {
logErrorToSlack(err);
reject(err);
} else {
resolve();
@ -146,7 +149,7 @@ function getBlockedOutpoints () {
resolve(htmlString);
})
.catch(function (err) {
winston.log('error', '[Importer] Error getting blocked outpoints. ' + err);
logErrorToSlack('[Importer] Error getting blocked outpoints. ' + err);
reject(err);
});
});
@ -174,7 +177,7 @@ function getClaimsSince (time) {
resolve(htmlString);
})
.catch(function (err) {
winston.log('error', '[Importer] Error getting updated claims. ' + err);
logErrorToSlack('[Importer] Error getting updated claims. ' + err);
reject(err);
});
});