refactor: tweak log

Author: fengkx

source/index.ts

@@ -276,8 +276,8 @@ async function startFetchProcess(restartTime: number): Promise<void> {
     });
 
     child.on('exit', function (code, signal) {
-        logger.error(`child process exit`);
         logger.error({
+            message: `child process exit`,
             code,
             signal
         });

source/utils/errors.ts

@@ -1,13 +1,18 @@
 import i18n from '../i18n';
-import logger from './logger';
+import logger, { logDBError } from './logger';
 import { config } from '../config';
 
 export class ControllableError extends Error {
     code: string;
-    constructor(err: string) {
+    constructor(err: string, code: string) {
         super(err);
+        this.code = code;
         if (err) {
-            logger.error(err);
+            if (code === 'DB_ERROR') {
+                logDBError(err);
+            } else {
+                logger.error(err);
+            }
         }
     }
 
@@ -20,15 +25,14 @@ export class ControllableError extends Error {
 }
 
 export function newCtrlErr(code: string, e?: any) {
-    const err = new ControllableError(e);
     if (e && e.response) {
         switch (e.response.statusCode) {
             case 404:
             case 403:
-                this.code = e.response.statusCode;
+                code = e.response.statusCode;
         }
     }
-    err.code = code;
+    const err = new ControllableError(e, code);
     return err;
 }
 

source/utils/fetch.ts

@@ -3,7 +3,7 @@ import Parser from 'rss-parser';
 import pMap from 'p-map';
 import hashFeed from './hash-feed';
 import { RecurrenceRule, scheduleJob } from 'node-schedule';
-import logger from './logger';
+import logger, { logHttpError } from './logger';
 import { findFeed } from './feed';
 import { config } from '../config';
 import { Feed, FeedItem } from '../types/feed';
@@ -73,7 +73,7 @@ async function fetch(feedModal: Feed): Promise<Option<FeedItem[]>> {
             })
         );
     } catch (e) {
-        logger.error(`${feedUrl} ${e.stack || e.message}`);
+        logHttpError(feedUrl, e);
         await failAttempt(feedUrl);
         const feed = await getFeedByUrl(feedUrl);
         if (isSome(feed)) {

source/utils/logger.ts

@@ -39,4 +39,10 @@ logger.add(
         )
     })
 );
+export function logHttpError(url: string, error: any) {
+    logger.error({ type: 'http', url, error });
+}
+export function logDBError(error: any) {
+    logger.error({ type: 'db', error });
+}
 export default logger;