redrockjs/request-bot
1
0
Fork 0
Code Issues 1 Pull Requests Actions Packages Projects Releases Wiki Activity

fix: update dockerfile, gh workflow

Browse Source
This commit is contained in:
Valery Grunenko
2024-05-17 08:53:42 +03:00
parent f0f4d9479c
commit 8f7929d2d6
4 changed files with 68 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files

36
build/index.js
View File

@@ -1,3 +1,4 @@
"use strict";
var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
return new (P || (P = Promise))(function (resolve, reject) {
@@ -41,11 +42,12 @@ var __asyncValues = (this && this.__asyncValues) || function (o) {
function verb(n) { i[n] = o[n] && function (v) { return new Promise(function (resolve, reject) { v = o[n](v), settle(resolve, reject, v.done, v.value); }); }; }
function settle(resolve, reject, d, v) { Promise.resolve(v).then(function(v) { resolve({ value: v, done: d }); }, reject); }
};
var _this = this;
Object.defineProperty(exports, "__esModule", { value: true });
var chalk = require('chalk');
var ImapFlow = require('imapflow').ImapFlow;
var simpleParser = require('mailparser').simpleParser;
var Telegraf = require('telegraf').Telegraf;
var lib_1 = require("./lib");
require('dotenv').config();
var bot = new Telegraf(process.env.TELEGRAM_BOT_TOKEN);
var POLLING_TIMEOUT = process.env.POLLING_TIMEOUT;
@@ -59,7 +61,7 @@ var clientConfig = {
pass: process.env.EMAIL_PASSWORD,
}
};
var main = function () { return __awaiter(_this, void 0, void 0, function () {
var main = function () { return __awaiter(void 0, void 0, void 0, function () {
var client, lock, listSeenMsgId, _loop_1, _a, _b, _c, e_1_1, e_2;
var _d, e_1, _e, _f;
return __generator(this, function (_g) {
@@ -83,28 +85,36 @@ var main = function () { return __awaiter(_this, void 0, void 0, function () {
case 5:
_g.trys.push([5, 11, 12, 17]);
_loop_1 = function () {
var message, email, parsed;
return __generator(this, function (_h) {
switch (_h.label) {
var message, email, parsed, _h, title, groupName, subject, user, estimatedDate, estimatedTime, preparedMessage;
return __generator(this, function (_j) {
switch (_j.label) {
case 0:
_f = _c.value;
_a = false;
message = _f;
if (!message.envelope.subject.includes(MARK_STRING)) return [3 /*break*/, 2];
if (!(message.envelope.subject && message.envelope.subject.includes(MARK_STRING))) return [3 /*break*/, 2];
email = Buffer.from(message.source).toString();
return [4 /*yield*/, simpleParser(email)];
return [4 /*yield*/, simpleParser(email)
//console.log('📌', chalk.cyan('Message:'), chalk.yellow(parsed.text));
];
case 1:
parsed = _h.sent();
console.log('📌', chalk.cyan('Message:'), chalk.yellow(parsed.text));
if (parsed.text) {
bot.telegram.sendMessage(process.env.TELEGRAM_GROUP_ID, parsed.text)
parsed = _j.sent();
_h = (0, lib_1.parseMessage)(parsed.text), title = _h.title, groupName = _h.groupName, subject = _h.subject, user = _h.user, estimatedDate = _h.estimatedDate, estimatedTime = _h.estimatedTime;
console.log("\uD83D\uDCCC \u041D\u043E\u0432\u043E\u0435 \u043E\u0431\u0440\u0430\u0449\u0435\u043D\u0438\u0435: ".concat(title), '\n', "\u0413\u0440\u0443\u043F\u043F\u0430: ".concat(groupName), '\n', "".concat(user), '\n', "".concat(subject), '\n', "\u0412\u0440\u0435\u043C\u044F \u0432\u044B\u043F\u043E\u043B\u043D\u0435\u043D\u0438\u044F: ".concat(estimatedDate, " ").concat(estimatedTime), '\n');
preparedMessage = "\uD83D\uDCCC \u041D\u043E\u0432\u043E\u0435 \u043E\u0431\u0440\u0430\u0449\u0435\u043D\u0438\u0435: ".concat(title, "\n") +
"\u0413\u0440\u0443\u043F\u043F\u0430: ".concat(groupName, "\n") +
"".concat(user, "\n") +
"".concat(subject, "\n") +
"\u0412\u0440\u0435\u043C\u044F \u0432\u044B\u043F\u043E\u043B\u043D\u0435\u043D\u0438\u044F: ".concat(estimatedDate, " ").concat(estimatedTime, "\n");
if (preparedMessage) {
bot.telegram.sendMessage(process.env.TELEGRAM_GROUP_ID, preparedMessage)
.then()
.catch(console.error);
}
client.messageFlagsAdd(message.seq.toString(), ['\\Seen'])
.then(function (result) { return console.log('📌', chalk.cyan("Set seen flag for id-".concat(message.seq)), result); })
.catch(console.error);
_h.label = 2;
_j.label = 2;
case 2: return [2 /*return*/];
}
});
@@ -158,7 +168,7 @@ var main = function () { return __awaiter(_this, void 0, void 0, function () {
});
}); };
//main().then().catch(err => console.error(err)); // start once for development
setInterval(function () { return __awaiter(_this, void 0, void 0, function () {
setInterval(function () { return __awaiter(void 0, void 0, void 0, function () {
return __generator(this, function (_a) {
main().then().catch(console.error);
return [2 /*return*/];