1
2

yum install nodejs	# 安装node.js
yum install npm		# 安装npm

1

tsc init

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34

{
  "compilerOptions": {
    /* Language and Environment */
    "target": "ES2022", /* Set the JavaScript language version for emitted JavaScript and include compatible library declarations. */
    /* Modules */
    "module": "commonjs", /* Specify what module code is generated. */
    /* Emit */
    "outDir": "publish", /* Specify an output folder for all emitted files. */
    "removeComments": true, /* Disable emitting comments. */
    "noEmitHelpers": true, /* Disable generating custom helper functions like '__extends' in compiled output. */
    "noEmitOnError": true, /* Disable emitting files if any type checking errors are reported. */
    /* Interop Constraints */
    "esModuleInterop": false, /* Emit additional JavaScript to ease support for importing CommonJS modules. This enables 'allowSyntheticDefaultImports' for type compatibility. */
    "forceConsistentCasingInFileNames": true, /* Ensure that casing is correct in imports. */
    /* Type Checking */
    "strict": true, /* Enable all strict type-checking options. */
    "noImplicitAny": true, /* Enable error reporting for expressions and declarations with an implied 'any' type. */
    "strictNullChecks": false, /* When type checking, take into account 'null' and 'undefined'. */
    "strictFunctionTypes": true, /* When assigning functions, check to ensure parameters and the return values are subtype-compatible. */
    "strictBindCallApply": true, /* Check that the arguments for 'bind', 'call', and 'apply' methods match the original function. */
    "strictPropertyInitialization": false, /* Check for class properties that are declared but not set in the constructor. */
    "noImplicitThis": true, /* Enable error reporting when 'this' is given the type 'any'. */
    "alwaysStrict": true, /* Ensure 'use strict' is always emitted. */
    "noImplicitReturns": true, /* Enable error reporting for codepaths that do not explicitly return in a function. */
    "skipLibCheck": true /* Skip type checking all .d.ts files. */
  },
  "exclude": [
    "node_modules"
  ],
  "include": [
    "src/*",
    "src/**/*"
  ]
}

1

npm init

1
2
3
4
5
6
7
8
9

npm install typescript --save	# 安装ts
npm install ts-node  --save		# 可选，安装ts运行工具，可以跳过编译生成js，直接运行ts

# tg机器人库
npm install node-telegram-bot-api  --save
npm install @types/node-telegram-bot-api  --save-dev

# log
npm install log4js --save

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83

import { Configuration, Logger, configure, shutdown } from "log4js";

export const enum ELogLevel {
    ALL = 'ALL',
    MARK = 'MARK',
    TRACE = 'TRACE',
    DEBUG = 'DEBUG',
    INFO = 'INFO',
    WARN = 'WARN',
    ERROR = 'ERROR',
    FATAL = 'FATAL',
    OFF = 'OFF'
}

export class Log {
    private static _instance: Log;
    private _log: Logger;

    public static get instance(): Log {
        if (!this._instance) {
            this._instance = new Log();
        }
        return this._instance;
    }

    public init(filename: string, level: ELogLevel): void {
        let cfg: Configuration = {
            appenders: {
                console: {
                    type: 'console'
                },
                dailyFile: {
                    type: 'dateFile',
                    filename: filename,
                    pattern: 'yyyy-MM-dd.log',
                    alwaysIncludePattern: true,
                    maxLogSize: 10 * 1024 * 1024, // 100M
                    backups: 10, // Number of backup files
                },
                // network: {   // 网络日志
                //     type: 'log4js-logstash',
                //     host: 'your-logstash-server',
                //     port: 5000,
                //     fields: {
                //         // 添加额外的字段，如项目名称
                //         appName: filename,
                //     },
                // },
            },

            categories: {
                default: { appenders: ['dailyFile'], level: level },
            }
        }

        const log4 = configure(cfg);
        this._log = log4.getLogger("default");
    }

    public debug(message: any, ...args: any[]): void {
        this._log.debug(message, ...args);
    }

    public info(message: any, ...args: any[]): void {
        this._log.info(message, ...args);
    }

    public warn(message: any, ...args: any[]): void {
        this._log.warn(message, ...args);
    }

    public error(message: any, ...args: any[]): void {
        this._log.error(message, ...args, new Error().stack);
    }

    public fatal(message: any, ...args: any[]): void {
        this._log.fatal(message, ...args, new Error().stack);
    }

    public shutdown(cb?: (error: Error) => void): void {
        shutdown(cb);
    }
}

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94

import * as TelegramBot from "node-telegram-bot-api"
import { ELogLevel, Log } from "../common/log";

class Main {
    private static _instance = new Main();
    private readonly _token: string;
    private _bot: TelegramBot;

    constructor() {
        this._token = "your_token";
    }

    public static get instance() {
        return this._instance;
    }

    /** 开启机器人连接 */
    private startTelegramBot(): void {
        // 创建一个 Telegram Bot 实例
        this._bot = new TelegramBot(this._token, { polling: true });

        // 监听所有命令，命令格式'/start'
        this._bot.onText(/\/(.+)/, (msg, match) => {
            const chatId = msg.chat.id;
            const command = match[1]; // 提取命令部分

            Log.instance.info("recv command: ", command);

            // 根据不同命令进行响应
            switch (command) {
                case 'start':
                    this._bot.sendMessage(chatId, 'Hello! I am your Telegram bot.');
                    break;
                case 'help':
                    this._bot.sendMessage(chatId, 'This is the help message.');
                    break;
                // 添加其他命令响应
                default:
                    this._bot.sendMessage(chatId, 'Error: Unknown command.');
            }
        });

        Log.instance.debug("startTelegramBot success");
    }

    /** 初始化日志 */
    private initLog(): void {
        const workpath = `${__dirname}/../../`;
        const packageJson = require(`${workpath}/package.json`); // 根据 package.json 的实际路径进行调整
        const filename = `${workpath}/log/${packageJson.name}`;
        // console.log("filename", filename)
        Log.instance.init(filename, ELogLevel.DEBUG);

        Log.instance.debug("initLog success");
    }

    /** 错误捕获 */
    private initErrorCatch(): void {
        const signals: Array<NodeJS.Signals> = [
            "SIGINT",
            'SIGTERM'
        ];

        for (const signal of signals) {
            process.on(signal, (signal: NodeJS.Signals): void => {
                Log.instance.warn("service exit because signal!");

                Log.instance.shutdown();
                process.exit(0);
            });
        }

        process.on("uncaughtException", (error: Error, origin: "uncaughtException") => {
            Log.instance.error(error);
        });
        process.on("unhandledRejection", (error: Error, promise: Promise<Error>) => {
            Log.instance.error(error);
        });

        Log.instance.debug("initErrorCatch success");
    }

    public startNetwork(): void {
        this.initLog();
        this.initErrorCatch();
        this.startTelegramBot();

        if (global.gc) {
            global.gc();
        }
    }
}

Main.instance.startNetwork();

1
2

tsc
node publish/main/main.js