added wtf command

src/api/telegram/index.ts

@@ -15,6 +15,8 @@ export class TelegramApi {
     this.telegram.bot.command("ping", TelegramApi.ping);
     this.telegram.bot.command("config", this.dumpConfig);
     this.telegram.bot.command("pop", this.pop);
+    this.telegram.bot.command("wtf", this.wtf);
+
     return;
   }
 
@@ -76,6 +78,32 @@ export class TelegramApi {
     return next();
   };
 
+  /**
+   * Sends recent logs
+   */
+  private wtf = async (ctx, next) => {
+    const username = ctx?.update?.message?.from?.username;
+
+    if (!username || !this.telegram.isOwner(`@${username}`)) {
+      return;
+    }
+
+    const logs = await this.db.popLogs();
+    if (!logs || !logs.length) {
+      await ctx.reply(`sorry, no logged errors yet`);
+      return next();
+    }
+
+    const source = JSON.stringify(logs, null, 2);
+
+    await ctx.replyWithDocument({
+      source: Readable.from(source),
+      filename: `logs-${new Date().toISOString()}.txt`,
+    });
+
+    return next();
+  };
+
   /**
    * Probes webhook url and falls back to polling mode on error
    */

src/index.ts

@@ -5,6 +5,7 @@ import { VkService } from "./service/vk";
 import { TelegramApi } from "./api/telegram";
 import { HttpApi } from "./api/http";
 import { PostgresDB } from "./service/db/postgres";
+import { PgTransport } from "./service/db/postgres/loggerTransport";
 
 async function main() {
   try {
@@ -13,6 +14,8 @@ async function main() {
     const db = new PostgresDB(config.postgres, config.logger);
     await db.connect();
 
+    logger.add(new PgTransport(db, { level: "warn" }));
+
     const telegram = new TelegramService(config.telegram);
     const vkService = new VkService(config.vk, telegram, config.templates, db);
 

src/service/db/postgres/entities/Log.ts

@@ -0,0 +1,23 @@
+import {
+  Column,
+  CreateDateColumn,
+  Entity,
+  PrimaryGeneratedColumn,
+  UpdateDateColumn,
+} from "typeorm";
+
+@Entity()
+export class Log {
+  @PrimaryGeneratedColumn()
+  id!: number;
+  @Column()
+  level!: string;
+  @Column({ type: "text" })
+  message!: string;
+  @Column("simple-json", { default: {}, nullable: false })
+  body!: Record<any, any>;
+  @CreateDateColumn()
+  createdAt!: Date;
+  @UpdateDateColumn()
+  updatedAt!: Date;
+}

src/service/db/postgres/index.ts

@@ -9,6 +9,7 @@ import { Event } from "./entities/Event";
 import { Post } from "./entities/Post";
 import { LoggerConfig } from "../../logger/types";
 import { Request } from "./entities/Request";
+import { Log } from "./entities/Log";
 
 const entities = [path.join(__dirname, "./entities/*")];
 
@@ -18,6 +19,7 @@ export class PostgresDB implements Storage {
   private likes!: Repository<Like>;
   private posts!: Repository<Post>;
   private requests!: Repository<Request>;
+  private logs!: Repository<Log>;
 
   constructor(
     private config: PostgresConfig,
@@ -41,6 +43,7 @@ export class PostgresDB implements Storage {
     this.likes = this.connection.getRepository(Like);
     this.posts = this.connection.getRepository(Post);
     this.requests = this.connection.getRepository(Request);
+    this.logs = this.connection.getRepository(Log);
 
     logger.info(`db connected to ${this.config.uri}`);
   };
@@ -151,6 +154,27 @@ export class PostgresDB implements Storage {
     return requests[0];
   };
 
+  insertLog = async (
+    level: string,
+    message: string,
+    body: Record<any, any>
+  ) => {
+    return this.logs.save({ message, level, body });
+  };
+
+  /**
+   * Returns last request with shift
+   */
+  popLogs = async (take: number = 20, skip: number = 0) => {
+    const requests = await this.logs.find({
+      order: { createdAt: "DESC" },
+      take,
+      skip,
+    });
+
+    return requests.reverse();
+  };
+
   healthcheck = async () => {
     try {
       await this.connection.query("SELECT 1");

src/service/db/postgres/loggerTransport.ts

@@ -0,0 +1,21 @@
+import Transport, { TransportStreamOptions } from "winston-transport";
+import { PostgresDB } from "./index";
+import safeJson from "safe-json-stringify";
+
+export class PgTransport extends Transport {
+  constructor(private db: PostgresDB, private props: TransportStreamOptions) {
+    super(props);
+  }
+
+  log = async (info, callback) => {
+    try {
+      await this.db.insertLog(info.level, info.message, info);
+    } catch (e) {
+      await this.db.insertLog(info.level, info.message, {
+        dump: safeJson(info),
+      });
+    }
+
+    callback();
+  };
+}