Singlethreaded implementation

Author: tshemsedinov

JavaScript/1-singletrhead/actors/mailer.js

@@ -0,0 +1,29 @@
+'use strict';
+
+const ActorSystem = require('../system');
+const nodemailer = require('nodemailer');
+const auth = require('../config');
+
+const FROM = 'nodeua.com@gmail.com';
+
+ActorSystem.register(class Mailer {
+  constructor() {
+    console.log('Start actor: Mailer');
+    this.transport = nodemailer.createTransport({
+      service: 'gmail', auth
+    });
+  }
+
+  message({ to, subject, message }) {
+    const mail = { from: FROM, to, subject, text: message };
+    this.transport.sendMail(mail, (error, data) => {
+      if (error) console.log(error);
+      else console.log(`Email sent: ${data.response}`);
+    });
+  }
+
+  async exit() {
+    this.transport.close();
+    console.log('Stop actor: Mailer');
+  }
+});

JavaScript/1-singletrhead/actors/monitoring.js

@@ -0,0 +1,40 @@
+'use strict';
+
+const ActorSystem = require('../system');
+const http = require('http');
+
+const URL = 'http://localhost:8000/';
+const INTERVAL = 2000;
+
+ActorSystem.register(class Monitoring {
+  constructor() {
+    console.log('Start actor: Monitoring');
+    this.prevSuccess = true;
+    this.timer = setInterval(() => {
+      this.attempt(URL);
+    }, INTERVAL);
+  }
+
+  attempt(url) {
+    http.get(url, res => {
+      const success = res.statusCode === 200;
+      this.notify({ url, success, status: res.statusCode });
+    }).on('error', error => {
+      this.notify({ url, success: false, status: error.message });
+    });
+  }
+
+  notify({ url, success, status }) {
+    if (this.prevSuccess !== success) {
+      this.prevSuccess = success;
+      ActorSystem.send('Renderer', { url, success, status });
+    }
+  }
+
+  message() {}
+
+  async exit() {
+    clearInterval(this.timer);
+    console.log('Stop actor: Monitoring');
+  }
+});

JavaScript/1-singletrhead/actors/renderer.js

@@ -0,0 +1,23 @@
+'use strict';
+
+const ActorSystem = require('../system');
+
+ActorSystem.register(class Renderer {
+  constructor() {
+    console.log('Start actor: Renderer');
+  }
+
+  message({ url, success, status }) {
+    const to = 'nodeua.com@gmail.com';
+    const msg = success ? 'is available again' : 'is not available';
+    const date = new Date().toUTCString();
+    const reason = (success ? 'Status code: ' : 'Error code: ') + status;
+    const message = `Resource ${url} ${msg} (${date})\n${reason}`;
+    const subject = 'Server Monitoring';
+    ActorSystem.send('Mailer', { to, subject, message });
+  }
+
+  async exit() {
+    console.log('Stop actor: Renderer');
+  }
+});

JavaScript/1-singletrhead/actors/root.js

@@ -0,0 +1,27 @@
+'use strict';
+
+const ActorSystem = require('../system');
+
+ActorSystem.register(class Root {
+  constructor() {
+    console.log('Start actor: Root');
+    ActorSystem.start('Monitoring');
+    ActorSystem.start('Renderer');
+    ActorSystem.start('Mailer');
+  }
+
+  message() {}
+
+  async exit() {
+    setTimeout(() => {
+      console.log('Abnormal termination');
+      process.exit(1);
+    }, 10000);
+    await ActorSystem.stop('Monitoring');
+    await ActorSystem.stop('Renderer');
+    await ActorSystem.stop('Mailer');
+    console.log('Stop actor: Root');
+    console.log('Graceful shutdown');
+    process.exit(0);
+  }
+});

JavaScript/1-singletrhead/config.js

@@ -0,0 +1,6 @@
+'use strict';
+
+module.exports = {
+  user: 'account-name@gmail.com',
+  pass: 'your-password',
+};

JavaScript/1-singletrhead/main.js

@@ -0,0 +1,10 @@
+'use strict';
+
+const ActorSystem = require('./system.js');
+
+ActorSystem.start('Root');
+
+process.on('SIGINT', () => {
+  console.log();
+  ActorSystem.stop('Root');
+});

JavaScript/1-singletrhead/package-lock.json

@@ -0,0 +1,19 @@
+{
+  "name": "server-monitoring",
+  "version": "1.0.0",
+  "description": "Actor Model example application",
+  "main": "main.js",
+  "repository": {
+    "type": "git",
+    "url": "git+https://github.com/HowProgrammingWorks/ActorModel.git"
+  },
+  "author": "Timur Shemsedinov <timur.shemsedinov@gmail.com>",
+  "license": "MIT",
+  "bugs": {
+    "url": "https://github.com/HowProgrammingWorks/ActorModel/issues"
+  },
+  "homepage": "https://github.com/HowProgrammingWorks/ActorModel#readme",
+  "dependencies": {
+    "nodemailer": "^6.1.1"
+  }
+}

JavaScript/1-singletrhead/package.json

@@ -0,0 +1,40 @@
+'use strict';
+
+const actors = new Map();
+
+class ActorSystem {
+  static register(actor) {
+    const instances = [];
+    const next = 0;
+    actors.set(actor.name, { actor, instances, next });
+  }
+
+  static start(name) {
+    require('./actors/' + name.toLowerCase() + '.js');
+    const record = actors.get(name);
+    if (record) {
+      const ActorClass = record.actor;
+      const { instances } = record;
+      const instance = new ActorClass();
+      instances.push(instance);
+    }
+  }
+
+  static async stop(name) {
+    const record = actors.get(name);
+    if (record) {
+      const { instances } = record;
+      await Promise.all(instances.map(instance => instance.exit()));
+    }
+  }
+
+  static send(name, data) {
+    const record = actors.get(name);
+    if (record) {
+      const { instances } = record;
+      instances[0].message(data);
+    }
+  }
+}
+
+module.exports = ActorSystem;