Initial commit

.editorconfig

@@ -0,0 +1,9 @@
+root = true
+
+[*]
+charset = utf-8
+indent_style = space
+indent_size = 2
+end_of_line = lf
+insert_final_newline = true
+trim_trailing_whitespace = true

.env.example

@@ -0,0 +1,2 @@
+RABBITMQ_URL=amqp://user:password@host
+BOT_TOKEN=bot_token

.eslintrc.json

@@ -0,0 +1,17 @@
+{
+    "env": {
+        "commonjs": true,
+        "es6": true,
+        "node": true
+    },
+    "extends": "airbnb",
+    "globals": {
+        "Atomics": "readonly",
+        "SharedArrayBuffer": "readonly"
+    },
+    "parserOptions": {
+        "ecmaVersion": 2018
+    },
+    "rules": {
+    }
+}

.gitignore

@@ -0,0 +1,9 @@
+.DS_Store
+node_modules/
+*.log*
+coverage
+*.swp
+data/*
+!data/.gitkeep
+.env
+!.env.example

Dockerfile

@@ -0,0 +1,14 @@
+FROM node:dubnium-alpine
+
+WORKDIR /app
+
+RUN apk update && apk add --no-cache bash
+
+COPY package.json /app
+COPY package-lock.json /app
+
+RUN npm install
+
+COPY . /app
+
+CMD ["npm", "start"]

README.md

@@ -0,0 +1,11 @@
+# Klick Telegram Service
+
+## Dependencies to run in development environment
+
+- docker
+- docker-compose
+
+## Running service
+
+Copy `.env.example` to `.env` and update the environment variables.
+Run `docker-compose up -d` to build and run service.

app.js

@@ -0,0 +1,5 @@
+const consumers = require('./app/consumers');
+const bot = require('./app/services/bot');
+
+consumers.load();
+bot.launch();

app/broker.js

@@ -0,0 +1,9 @@
+const Broker = require('roger-rabbit');
+
+module.exports = Broker({
+  host: process.env.RABBITMQ_URL,
+  exchange: {
+    type: 'direct',
+    name: 'klick.account',
+  },
+});

app/business/send_message.js

@@ -0,0 +1,12 @@
+const UserRepository = require('../repositories/user');
+const bot = require('../services/bot');
+
+module.exports = ({ identifier, title, content }) => {
+  const model = new UserRepository();
+  const user = model.find(identifier);
+
+  return bot.sendMessage({
+    chatId: user.telegramId,
+    message: `${title}\n${content}`,
+  });
+};

app/business/user_register.js

@@ -0,0 +1,13 @@
+const UserRepository = require('../repositories/user');
+const bot = require('../services/bot');
+
+module.exports = (data) => {
+  const model = new UserRepository();
+
+  model.create(data);
+
+  return bot.sendMessage({
+    chatId: data.telegramId,
+    message: 'Hey! You have been registered!',
+  });
+};

app/consumers/index.js

@@ -0,0 +1,14 @@
+const fs = require('fs');
+const path = require('path');
+
+module.exports = {
+  load() {
+    const consumerFileRegex = /_consumer.js$/;
+
+    fs.readdirSync(path.join(__dirname))
+      .filter(consumerPath => consumerFileRegex.test(consumerPath))
+      /* eslint-disable global-require, import/no-dynamic-require */
+      .map(consumerPath => require(`./${consumerPath}`));
+    /* eslint-enable global-require, import/no-dynamic-require */
+  },
+};

app/consumers/telegram_notification_send_consumer.js

@@ -0,0 +1,13 @@
+const broker = require('../broker');
+const sendMessage = require('../business/send_message');
+
+const queue = {
+  name: 'telegram.notification.send',
+  options: {
+    durable: true,
+  },
+};
+
+const routingKey = 'notification.send';
+
+broker.consume({ queue, routingKey }, data => sendMessage(data));

app/consumers/telegram_user_sync_consumer.js

@@ -0,0 +1,13 @@
+const broker = require('../broker');
+const userRegister = require('../business/user_register');
+
+const queue = {
+  name: 'telegram.user.sync',
+  options: {
+    durable: true,
+  },
+};
+
+const routingKey = 'user.sync';
+
+broker.consume({ queue, routingKey }, user => userRegister(user));

app/db.js

@@ -0,0 +1,10 @@
+const low = require('lowdb');
+const FileSync = require('lowdb/adapters/FileSync');
+
+const adapter = new FileSync('./data/db.json');
+const db = low(adapter);
+
+db.defaults({ users: [] })
+  .write();
+
+module.exports = db;

app/repositories/user.js

@@ -0,0 +1,25 @@
+const db = require('../db');
+
+module.exports = class UserRepository {
+  constructor() {
+    this.table = db.get('users');
+  }
+
+  create({ identifier, telegramId }) {
+    const user = this.find(identifier);
+
+    if (user) {
+      return user;
+    }
+
+    this.table
+      .push({ identifier, telegramId })
+      .write();
+
+    return this.find(telegramId);
+  }
+
+  find(identifier) {
+    return this.table.find({ identifier }).value();
+  }
+};

app/services/bot.js

@@ -0,0 +1,31 @@
+const Telegraf = require('telegraf');
+const Telegram = require('telegraf/telegram');
+const broker = require('../broker');
+
+const bot = new Telegraf(process.env.BOT_TOKEN);
+const telegram = new Telegram(process.env.BOT_TOKEN);
+
+module.exports = {
+  launch() {
+    bot.start((ctx) => {
+      ctx.reply('Hey! Register your email using /register [email protected]');
+    });
+
+    bot.command('register', (ctx) => {
+      const { from, text } = ctx.message;
+      const telegramId = from.id;
+      const name = `${from.first_name} ${from.last_name}`;
+      const email = text.split(' ')[1];
+
+      if (email) {
+        broker.publish('user.register', { email, name, telegramId });
+      }
+    });
+
+
+    bot.launch();
+  },
+  sendMessage({ chatId, message }) {
+    telegram.sendMessage(chatId, message, { parse_mode: 'Markdown' });
+  },
+};

docker-compose.yml

@@ -0,0 +1,12 @@
+version: '3'
+services:
+  telegram-service.local:
+    tty: true
+    stdin_open: true
+    container_name: telegram-service
+    build:
+      context: .
+    env_file:
+      - ./.env
+    volumes:
+      - .:/app