implementando...

Author: markleymsm

server/bin/send_email.js

@@ -0,0 +1,32 @@
+const connection = require('../src/db/connection');
+// const sender = require('../src/email/sender');
+const campaignModel = require('../src/models/campaign');
+const leadModel = require('../src/models/lead');
+const tracker = require('../src/email/tracker');
+
+async function send() {
+    const now = new Date();
+    const campaigns = await campaignModel.find({start: {$lt: now}, status: null});
+
+    for (let i = 0; i < campaigns.length; i++) {
+        console.log('send campaign')
+        let lists = campaigns[i].lists;
+
+        let leads = await leadModel.find({ lists: {$in: lists}});
+
+        leads.map((lead) => {
+            console.log('send lead')
+            let mailBody = tracker(campaigns[i].body, campaigns[i]._id, lead._id);
+            console.log(lead.email, campaigns[i].title, mailBody);
+            sender(lead.email, campaigns[i].title, mailBody); //envia o email
+        });
+
+        campaigns[i].status = 'enviado';
+        campaigns[i].save();
+
+
+        console.log('end')
+    }
+}
+
+module.exports = send;

server/bin/send_email_service.js

@@ -0,0 +1,15 @@
+const send = require('./send_email');
+
+async function init() {
+    send();
+
+    let time = 1000 * 3;
+
+    setTimeout(() => {
+        init();
+    }, time);
+}
+
+console.log('start send email');
+
+init();

server/bin/send_email_tasks.js

@@ -0,0 +1,3 @@
+const send = require('./send_email');
+
+send();

server/docker-compose.yml

@@ -16,4 +16,15 @@ services:
       - ./:/home/node/app
     ports:
       - "3000:3000"
-    command: "node_modules/.bin/nodemon -L --exec npm start"
+    command: "node_modules/.bin/nodemon -L --exec npm start"
+  sendemail:
+    image: "node:10.18.0"
+    user: "node"
+    working_dir: /home/node/app
+    environment:
+      - NODE_ENV=development
+    volumes:
+      - ./:/home/node/app
+    ports:
+      - "3000:3000"
+    command: "node bin/send_email.js"

server/src/controllers/tracking.js

@@ -26,7 +26,7 @@ module.exports = function () {
             let actions = lead.actions;
             actions.push({
                 campaign: campaignId,
-                actions: [{
+                action: [{
                     typeAction: 'open',
                     link: '',
                     date: new Date()
@@ -43,13 +43,51 @@ module.exports = function () {
     };
 
     let click = function (req, res) {
+        if (!req.query.link) {
+            return res.status(404).send('Not Found');
+        }
+
         let campaignId = req.params.id;
         let leadId = req.params.leadid;
+
+        campaignModel.findById(campaignId, function (err, campaign) {
+            if (err) {
+                return err;
+            }
+            campaign.clicks += 1;
+            campaign.save();
+        });
+
+        leadModel.findById(leadId, function (err, lead) {
+            if (err) {
+                return err;
+            }
+
+            if (!lead) {
+                return;
+            }
+
+            let actions = lead.actions;
+            actions.push({
+                campaign: campaignId,
+                action: [{
+                    typeAction: 'click',
+                    link: req.query.link,
+                    date: new Date()
+                }]
+            });
+
+            lead.actions = actions;
+            lead.save();
+        });
+
+        res.writeHead(302, {'Location': req.query.link});
+        res.end();
     };
 
     let controller = {
-        open: open(),
-        click: click()
+        open: open,
+        click: click
     };
 
     return controller;

server/src/db/connection.js

@@ -1,5 +1,6 @@
 let mongoose = require('mongoose');
 
+mongoose.Promise = global.Promise;
 mongoose.connect('mongodb://mongo:27017/email_marketing', { useMongoClient: true }, function (err) {
 // mongoose.connect(MONGODB_URL, { useNewUrlParser: true, useUnifiedTopology: true, }, function (err) {
     if (err) {

server/src/email/tracker.js

@@ -0,0 +1,7 @@
+module.exports = function (body, campaignId, leadId) {
+    let img = '<img src="/campaigns/tracking/open/' + campaignId + '/' + leadId + '">';
+    let ulr_tracking = '/campaigns/tracking/click/' + campaignId + '/' + leadId + '?link=';
+    let regex = /<a href="(.*?)"/g;
+
+    return body.replace(regex, "/<a href=\"" + ulr_tracking + "$1\"") + img;
+}

server/src/models/lead.js

@@ -14,7 +14,7 @@ const Lead = mongoose.Schema({
     {
       campaign: {
         type: ObjectId,
-        ref: "List"
+        ref: "Campaign"
       },
       action: [
         {

server/src/routes/index.js

@@ -4,6 +4,7 @@ let auth = require("./auth");
 let campaigns = require("./campaigns");
 let leads = require("./leads");
 let lists = require("./lists");
+let tracking = require("./tracking");
 
 module.exports = app => {
   app.get("/", function(req, res) {
@@ -16,4 +17,5 @@ module.exports = app => {
   campaigns(app);
   leads(app);
   lists(app);
+  tracking(app);
 };

server/src/routes/tracking.js

@@ -1,6 +1,7 @@
 module.exports = function (app) {
-    let controller = require('../controllers/trackin')();
+    let controller = require('../controllers/tracking')();
 
-    app.get('/campaigns/tracking/open/:', controller.index);
+    app.get('/campaigns/tracking/open/:id/:leadid', controller.open);
+    app.get('/campaigns/tracking/open/:id/:leadid', controller.click);
 
 }