fix: i18n of error message

Author: fengkx

source/index.ts

@@ -280,7 +280,7 @@ async function startFetchProcess(restartTime: number): Promise<void> {
                 const { feed, err } = message;
                 send(
                     bot,
-                    `${feed.feed_title}: <a href="${feed.url}">${feed.url}</a> ${i18n[lang]['ERROR_MANY_TIME']} ${err.message}`,
+                    `${feed.feed_title}: <a href="${feed.url}">${feed.url}</a> <%=i18n['ERROR_MANY_TIME']%> ${err.message}`,
                     feed
                 );
             }
@@ -290,11 +290,11 @@ async function startFetchProcess(restartTime: number): Promise<void> {
                 builder.push(
                     `${feed.feed_title}: <a href="${encodeUrl(
                         feed.url
-                    )}"></a> ${i18n[lang]['ERROR_MANY_TIME']}`
+                    )}"></a> <%=i18n['ERROR_MANY_TIME']%>`
                 ); // feed is from database which not urlencoded
-                builder.push(`<b>${i18n[lang]['FOUND_FEEDS']}</b>:`);
+                builder.push(`<b><%=i18n['FOUND_FEEDS']%></b>:`);
                 builder.push(...new_feed);
-                builder.push(`${i18n[lang]['FEED_CHANGE_TO']} ${new_feed[0]}`);
+                builder.push(`<%=i18n['FEED_CHANGE_TO']%> ${new_feed[0]}`);
                 send(bot, builder.join('\n'), feed);
             }
         }
@@ -316,3 +316,4 @@ logger.info(`Database is located in ${db_path}`);
 logger.info(`Using Default language is ${lang}`);
 logger.info(`send the latest ${item_num} items for each feed`);
 logger.info('NodeRSSBot is ready');
+process.on('uncaughtException', logger.error);

source/utils/send.ts

@@ -8,7 +8,9 @@ import { config } from '../config';
 import Telegraf, { Context } from 'telegraf';
 import { Feed, FeedItem } from '../types/feed';
 import { getUserById, migrateUser } from '../proxies/users';
-import { isNone } from '../types/option';
+import { isNone, isSome } from '../types/option';
+import * as ejs from 'ejs';
+import i18n from '../i18n';
 
 /**
  * handle send error log or delete user or migrate user
@@ -47,9 +49,16 @@ const send = async (
 ): Promise<void> => {
     const subscribers = await getSubscribersByFeedId(feed.feed_id);
     if (typeof toSend === 'string') {
+        const tpl = toSend;
         subscribers.map(async (subscribe) => {
             const userId = subscribe.user_id;
             try {
+                const user = await getUserById(userId);
+                let lang = config.lang;
+                if (isSome(user)) {
+                    lang = user.value.lang;
+                }
+                toSend = ejs.render(tpl, { i18n: i18n[lang] });
                 await bot.telegram.sendMessage(userId, toSend, {
                     parse_mode: 'HTML',
                     disable_web_page_preview: true
@@ -59,10 +68,11 @@ const send = async (
             }
         });
     } else {
+        const feedItems = toSend;
         subscribers.map(async (subscribe) => {
             const userId = subscribe.user_id;
             let text = `<b>${sanitize(feed.feed_title)}</b>`;
-            toSend.forEach(function (item) {
+            feedItems.forEach(function (item) {
                 text += `\n<a href="${item.link.trim()}">${sanitize(
                     item.title
                 )}</a>`;