almost completed

src/backend/feed/worker.js

@@ -1,7 +1,8 @@
 const feedQueue = require('./queue');
 const feedParser = require('./parser');
 const extractUrls = require('../utils/extract-urls');
-const logger = require('./../utils/logger');
+const storage = require('../utils/storage');
+// const logger = require('./../utils/logger');
 
 exports.workerCallback = async function(job) {
   const { url } = job.data;
@@ -23,11 +24,8 @@ exports.workerCallback = async function(job) {
       });
       return processedPosts;
     }
-<<<<<<< HEAD
     return processedPosts;
-=======
     // return processedPosts;
->>>>>>> still working
   } catch (err) {
     return err;
   }
@@ -36,8 +34,15 @@ exports.workerCallback = async function(job) {
 // eslint-disable-next-line prettier/prettier
 exports.start = function() {
   // Start processing jobs from the feed queue...
-  feedQueue.process(this.workerCallback);
-  feedQueue.on('completed', (job, result) => {
-    console.log(`Job ${job.id} completed! Result: ${result.processedPosts[0].author}`);
+  feedQueue.process(exports.workerCallback);
+  feedQueue.on('completed', (job, results) => {
+    if (results.length > 0) {
+      results.forEach(result => {
+        console.log(`Result: ${result.title}`);
+        // We have an issure here, addPost is an async function. Should we make the start
+        // function an async one too..?
+        storage.addPost(result);
+      });
+    }
   });
 };