added telegram service connector

src/config/index.ts

@@ -15,6 +15,6 @@ const config = userConfig && mergeRight(defaultConfig, userConfig) || defaultCon
 
 export default function prepareConfig() {
   validateConfig(config)
-  logger.debug('config is ok:', config)
+  logger.debug('config is ok: ', config)
   return config
 }

src/index.ts

@@ -5,7 +5,7 @@ import { VkService } from './service/vk';
 
 try {
   const config = prepareConfig()
-  const telegramService = new TelegramService(config.telegram)
+  const telegramService = new TelegramService(config.telegram).start()
   const vkService = new VkService(config.vk)
 
 } catch (e) {

src/service/telegram/index.ts

@@ -1,9 +1,39 @@
 import { TelegramConfig } from './types';
+import { Telegraf } from 'telegraf';
+import logger from '../logger';
+
+// import SocksProxyAgent from 'socks-proxy-agent';
 
 export class TelegramService {
+  bot: Telegraf
+
   constructor(private props: TelegramConfig) {
     if (!props.key) {
       throw new Error('Telegram api key not found. Get it from bot father')
     }
+
+    // const agent = (CONFIG.PROXY && new SocksProxyAgent(CONFIG.PROXY)) || null;
+    const options = {
+      channelMode: true,
+      telegram: {
+        // agent, // TODO: add proxy support
+        webhookReply: !!props.webhookUrl,
+      },
+    };
+
+    this.bot = new Telegraf(props.key, options);
+
+    process.once('SIGINT', () => this.bot.stop('SIGINT'))
+    process.once('SIGTERM', () => this.bot.stop('SIGTERM'))
+
+    logger.info('Telegram service started')
+  }
+
+  start() {
+    if (!this.bot) {
+      throw new Error('Not initialized')
+    }
+
+    return this.bot.launch()
   }
 }