creating tasks

Author: manobi

examples/index.js

@@ -0,0 +1,34 @@
+const fetch = require('node-fetch');
+
+/*
+const dlay = require('dlay')({database: 'dlay_tasks'}),
+    {worker} = dlay;
+*/
+const { worker, createTask } = require('../')();
+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();
+    
+    // failed
+    //done({deu: 'ruim'});
+
+    // Success msg
+    //done(null, {deu: 'certo'});
+
+    //long run
+    
+    // setTimeout(() => {
+    //     console.log('long exec');
+    //     done(null, 'acabou');
+    // }, 200000000);
+    
+});
+
+createTask({date: new Date().toISOString()});

index.js

@@ -1,31 +1,14 @@
-const fetch = require('node-fetch');
 const Worker = require('./lib/worker');
-const worker = new Worker({
-    name: 'manobi',
-    database: 'dlay_tasks'
-});
-
-worker.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();
-    
-    // failed
-    //done({deu: 'ruim'});
-
-    // Success msg
-    //done(null, {deu: 'certo'});
-
-    //long run
-    
-    // setTimeout(() => {
-    //     console.log('long exec');
-    //     done(null, 'acabou');
-    // }, 200000000);
-    
-});
+const Task = require('./lib/task');
+const CouchdbAdaptor = require('./lib/couchdb-adaptor');
+
+module.exports = (connection = {}, Adaptor = CouchdbAdaptor) => {
+    return {
+        worker(name, options = connection, Adaptor = CouchdbAdaptor){
+            return  new Worker({ ...options, name }, Adaptor);
+        },
+        createTask(info, options = connection, Adaptor = CouchdbAdaptor){
+            return new Task(info, options, Adaptor).save();
+        }
+    }
+}

lib/couchdb-adaptor.js

@@ -24,28 +24,23 @@ module.exports = class Adaptor {
      * @param {Object} options 
      */
     createConnection(options){
-        let merged = {...STD, ...options};
-        const url = new URL(`${merged.protocol}://${merged.hostname}`);
-        url.port = merged.port;
-        url.username = merged.username;
-        url.password = merged.password;
+        
+        const url = new URL(`${options.protocol}://${options.hostname}`);
+        url.port = options.port;
+        url.username = options.username;
+        url.password = options.password;
         this.connection = nano(url.toString());
     }
 
     /**
      * @method connect
      * @param {Object} options 
      */
-    async connect(options){
-        this.createConnection(options);
-        const {database} = options;
+    connect(options){
+        let merged = {...STD, ...options};
+        this.createConnection(merged);
+        const {database} = merged;
         this.db = this.connection.db.use(database);
-        this.subscribe(options.seq);
-        // for cold start
-        const docs = await this.looseTasks(); 
-        docs.forEach((doc) => {
-            this.onChange(this.formatDoc(doc));
-        });
     }
 
     /**
@@ -72,9 +67,14 @@ module.exports = class Adaptor {
 
     /**
     * @method subscribe
-    * @param {Number} seq
     */
-    subscribe(seq){
+    async subscribe(){
+         // for cold start
+         const docs = await this.looseTasks(); 
+         docs.forEach((doc) => {
+             this.onChange(this.formatDoc(doc));
+         });
+
         const name = this.name;
         this.feed = this.db.follow({
             include_docs: true,
@@ -115,6 +115,10 @@ module.exports = class Adaptor {
         return docs;
     }
 
+    create(task){
+        return this.db.insert(task);
+    }
+
     /**
     * @method update
     * @param {Object} task

lib/task.js

@@ -0,0 +1,11 @@
+module.exports = class Task {
+    constructor(info = {}, connection = {}, Adaptor){
+        this.storage = new Adaptor();
+        this.storage.connect(connection);
+        this.info = info;
+    }
+    
+    save(){
+        return this.storage.create(this.info);
+    }
+}

lib/worker.js

@@ -1,5 +1,4 @@
 const Scheduler = require('./scheduler');
-const CouchdbAdaptor = require('./couchdb-adaptor');
 const Context = require('./context');
 const queue = require('queue');
 
@@ -8,7 +7,7 @@ const queue = require('queue');
  * @extends Scheduler
  */
 module.exports = class Worker extends Scheduler {
-    constructor(options, Adaptor = CouchdbAdaptor){
+    constructor(options, Adaptor){
         // Can't create a worker without name
         if(!options || !options.name) throw new Error('The attribute "name" is required to construct Workers');
 
@@ -24,6 +23,7 @@ module.exports = class Worker extends Scheduler {
         this.storage.name = this.name;
         this.storage.onChange = (change) => this.changeHandler.call(this, change);
         this.storage.connect(options);
+        this.storage.subscribe();
     }
 
     enqueue(id, fn){