Update multiple threads example

Author: tshemsedinov

JavaScript/3-multithread/actors/mailer.js

@@ -6,24 +6,27 @@ 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
-    });
-  }
+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}`);
-    });
-  }
+    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}`);
+      });
+    }
 
-  exit() {
-    this.transport.close();
-    console.log('Stop actor: Mailer');
-  }
-});
+    exit() {
+      this.transport.close();
+      console.log('Stop actor: Mailer');
+    }
+  },
+);

JavaScript/3-multithread/actors/monitoring.js

@@ -6,35 +6,39 @@ const http = require('node: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);
-  }
+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 });
-    });
-  }
+    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 });
+    notify({ url, success, status }) {
+      if (this.prevSuccess !== success) {
+        this.prevSuccess = success;
+        ActorSystem.send('Renderer', { url, success, status });
+      }
     }
-  }
 
-  message() {}
+    message() {}
 
-  exit() {
-    clearInterval(this.timer);
-    console.log('Stop actor: Monitoring');
-  }
-});
+    exit() {
+      clearInterval(this.timer);
+      console.log('Stop actor: Monitoring');
+    }
+  },
+);

JavaScript/3-multithread/actors/renderer.js

@@ -2,22 +2,24 @@
 
 const ActorSystem = require('../system');
 
-ActorSystem.register(class Renderer {
-  constructor() {
-    console.log('Start actor: Renderer');
-  }
+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 });
-  }
+    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 });
+    }
 
-  exit() {
-    console.log('Stop actor: Renderer');
-  }
-});
+    exit() {
+      console.log('Stop actor: Renderer');
+    }
+  },
+);

JavaScript/3-multithread/actors/root.js

@@ -2,20 +2,22 @@
 
 const ActorSystem = require('../system');
 
-ActorSystem.register(class Root {
-  constructor() {
-    console.log('Start actor: Root');
-    ActorSystem.start('Monitoring');
-    ActorSystem.start('Renderer');
-    ActorSystem.start('Mailer', 3);
-  }
+ActorSystem.register(
+  class Root {
+    constructor() {
+      console.log('Start actor: Root');
+      ActorSystem.start('Monitoring');
+      ActorSystem.start('Renderer');
+      ActorSystem.start('Mailer', 3);
+    }
 
-  message() {}
+    message() {}
 
-  exit() {
-    ActorSystem.stop('Monitoring');
-    ActorSystem.stop('Renderer');
-    ActorSystem.stop('Mailer');
-    console.log('Stop actor: Root');
-  }
-});
+    exit() {
+      ActorSystem.stop('Monitoring');
+      ActorSystem.stop('Renderer');
+      ActorSystem.stop('Mailer');
+      console.log('Stop actor: Root');
+    }
+  },
+);

JavaScript/3-multithread/eslint.config.js

@@ -0,0 +1,7 @@
+'use strict';
+
+const init = require('eslint-config-metarhia');
+
+init[0].rules['class-methods-use-this'] = 'off';
+
+module.exports = init;