jonathan/combine.fm
jonathan/combine.fm
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages 1 Wiki Activity Actions

Add more debug output to worker

Browse source
This commit is contained in:
Jonathan Cremin 2017-11-11 19:51:39 +00:00
parent 82fa61f5d5
commit 46142d12de
2 changed files with 9 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

3
routes/search.js
View file

@ -54,7 +54,8 @@ export default function* () {
this.body = share; this.body = share;
} catch (e) { } catch (e) {
this.throw(400, { error: { message: 'Unexpected error looking up music. Please try again later.' } }); debug(e);
this.throw(500, { error: { message: 'Unexpected error looking up music. Please try again later.' } });
throw e; throw e;
} }
} }

9
worker.js
View file

@ -1,10 +1,13 @@
import co from 'co'; import co from 'co';
import kue from 'kue'; import kue from 'kue';
import raven from 'raven'; import raven from 'raven';
import debuglog from 'debug';
import models from './models'; import models from './models';
import services from './lib/services'; import services from './lib/services';
const debug = debuglog('combine.fm:worker');
raven.config(process.env.SENTRY_DSN).install(); raven.config(process.env.SENTRY_DSN).install();
const queue = kue.createQueue({ const queue = kue.createQueue({
@ -14,7 +17,7 @@ const queue = kue.createQueue({
function search(data, done) { function search(data, done) {
const share = data.share; const share = data.share;
const service = services.find(item => data.service.id === item.id); const service = services.find(item => data.service.id === item.id);
console.log(service); debug(`Searching on: ${service}`);
co(function* gen() { // eslint-disable-line no-loop-func co(function* gen() { // eslint-disable-line no-loop-func
try { try {
const match = yield service.search(share); const match = yield service.search(share);
@ -49,7 +52,9 @@ function search(data, done) {
return done(err); return done(err);
} }
}).catch((err) => { }).catch((err) => {
console.log(err); debug(`Error searching on: ${service}`);
debug(share);
debug(err);
raven.captureException(err); raven.captureException(err);
return done(); return done();
}); });