Job examples

Author: manobi

examples/async.js

@@ -0,0 +1,14 @@
+const fetch = require('node-fetch'),
+    { worker, createTask } = require('..')(),
+    manobi = worker('manobi');
+
+const manobi = worker('manobi');
+manobi.addJob('compress', async (ctx, done) => {
+    setTimeout(() => {
+        done(null, 'acabou');
+    }, 3000);
+});
+(async () => {
+    const res = await createTask({date: new Date().toISOString()});
+    console.log(res);
+})();

examples/config.js

@@ -0,0 +1,19 @@
+const fetch = require('node-fetch');
+const dlay = require('../')({database: 'dlay_tasks'}),
+    { worker, createTask } = dlay;
+
+const manobi = worker('manobi');
+manobi.addJob('compress', async (ctx, done) => {
+    //fast exec
+    //done(null, {sucesso: 'muleque'});
+
+    // Async exec
+    const deps = await ctx.deps();
+    console.log(deps);
+    const res = await fetch('https://dog.ceo/api/breeds/image/random');
+    return res.json();
+});
+(async () => {
+    const res = await createTask({date: new Date().toISOString()});
+    console.log(res);
+})();

examples/deps.js

@@ -0,0 +1,17 @@
+const fetch = require('node-fetch'),
+    { worker, createTask } = require('..')(),
+    manobi = worker('manobi');
+    
+manobi.addJob('compress', async (ctx, done) => {
+    // Async exec
+    const deps = await ctx.deps();
+    if(deps.length){
+        //do something
+        done();
+    }
+});
+
+(async () => {
+    const res = await createTask({date: new Date().toISOString()});
+    console.log(res);
+})();

examples/failed.js

@@ -0,0 +1,12 @@
+const fetch = require('node-fetch'),
+    { worker, createTask } = require('..')(),
+    manobi = worker('manobi');
+    
+manobi.addJob('compress', async (ctx, done) => {
+    done({message: 'Something very wrong have happened'});
+});
+
+(async () => {
+    const res = await createTask({date: new Date().toISOString()});
+    console.log(res);
+})();

examples/fast.js

@@ -0,0 +1,11 @@
+const fetch = require('node-fetch'),
+    { worker, createTask } = require('..')(),
+    manobi = worker('manobi');
+    
+manobi.addJob('compress', async (ctx, done) => {
+    done(null, {sucesso: 'muleque'});
+});
+(async () => {
+    const res = await createTask({date: new Date().toISOString()});
+    console.log(res);
+})();

examples/index.js

@@ -0,0 +1,14 @@
+const fetch = require('node-fetch'),
+    { worker, createTask } = require('..')(),
+    manobi = worker('manobi');
+    
+manobi.addJob('compress', async (ctx, done) => {
+    // Async exec
+    const res = await fetch('https://dog.ceo/api/breeds/image/random');
+    return res.json();
+});
+
+(async () => {
+    const res = await createTask({date: new Date().toISOString()});
+    console.log(res);
+})();

examples/promise.js

@@ -0,0 +1,14 @@
+const fetch = require('node-fetch');
+const dlay = require('../')({database: 'dlay_tasks'}),
+    { worker, createTask } = dlay;
+
+const manobi = worker('manobi');
+manobi.addJob('compress', async (ctx, done) => {
+    // never calls done will reach the task timeout
+    setTimeout(() => {
+        console.log(this.tasks);
+    }, 50000);
+});
+(async () => {
+    const res = await createTask({date: new Date().toISOString()});
+})();