feat: new cronjobs for fees, mempool and block stats

src/domain/bot/bot.service.ts

@@ -17,15 +17,25 @@ export class BotService {
     // cronjob list
     const cronjobList = [
       {
-        webhook: `${this.webhookUrl}/new-price`,
-        interval: '*/20 * * * * *',
-        type: 'price',
+        webhook: `${this.webhookUrl}/new-fees`,
+        interval: '0 * * * * *',
+        type: 'fees',
       },
       {
         webhook: `${this.webhookUrl}/new-block`,
-        interval: '* * * * * *',
+        interval: '15 * * * * *',
         type: 'block',
       },
+      {
+        webhook: `${this.webhookUrl}/new-price`,
+        interval: '30 * * * * *',
+        type: 'price',
+      },
+      {
+        webhook: `${this.webhookUrl}/new-mempool`,
+        interval: '45 * * * * *',
+        type: 'mempool',
+      },
     ]
 
     // add cronjob list

src/domain/webhooks/dto/fees.dto.ts

@@ -0,0 +1,7 @@
+export interface FeesBodyDto {
+  fastestFee: number
+  halfHourFee: number
+  hourFee: number
+  economyFee: number
+  minimumFee: number
+}

src/domain/webhooks/dto/index.ts

@@ -4,3 +4,5 @@ export * from './alert-tx.dto'
 export * from './block.dto'
 export * from './price.dto'
 export * from './message.dto'
+export * from './fees.dto'
+export * from './mempool.dto'

src/domain/webhooks/dto/mempool.dto.ts

@@ -0,0 +1,4 @@
+export interface MempoolBodyDto {
+  count: number
+  vsize: number
+}

src/domain/webhooks/webhooks.controller.ts

@@ -7,6 +7,8 @@ import {
   PriceBodyDto,
   MessageParamsDto,
   MessageResponseDto,
+  FeesBodyDto,
+  MempoolBodyDto,
 } from './dto'
 import { WebhooksService } from './webhooks.service'
 
@@ -44,6 +46,16 @@ export class WebhooksController {
     return { message: 'NOK' }
   }
 
+  @Post('/new-fees')
+  updateNewFees(@Body() feesDto: FeesBodyDto) {
+    this.webhooksService.updateNewFees(feesDto)
+  }
+
+  @Post('/new-mempool')
+  updateNewMempool(@Body() mempoolDto: MempoolBodyDto) {
+    this.webhooksService.updateNewMempool(mempoolDto)
+  }
+
   @Post('/new-block')
   updateNewBlock(@Body() blockDto: BlockBodyDto) {
     this.webhooksService.updateNewBlock(blockDto)

src/domain/webhooks/webhooks.service.ts

@@ -1,10 +1,10 @@
 import { InjectDiscordClient } from '@discord-nestjs/core'
 import { Injectable, Logger } from '@nestjs/common'
-import { Client, EmbedBuilder } from 'discord.js'
+import { ActivityType, Client, EmbedBuilder } from 'discord.js'
 import { progressBar } from 'src/utils'
 import { createResponse } from 'src/utils/default-response'
 import { NumbersService } from 'src/utils/numbers/numbers.service'
-import { PriceBodyDto, BlockBodyDto, MessageResponseDto } from './dto'
+import { PriceBodyDto, BlockBodyDto, MessageResponseDto, FeesBodyDto, MempoolBodyDto } from './dto'
 
 @Injectable()
 export class WebhooksService {
@@ -67,14 +67,41 @@ export class WebhooksService {
     }
   }
 
+  async updateNewMempool(mempool: MempoolBodyDto) {
+    try {
+      if (mempool && mempool.count) {
+        this.client.user.setActivity(` ${mempool.count} txs unconfirmed`, {
+          type: ActivityType.Watching,
+        })
+        this.logger.debug(`NEW WEBHOOK - mempool txs: ${mempool.count}`)
+      }
+    } catch (error) {
+      this.logger.error(`NEW WEBHOOK - mempool txs: ${error}`)
+    }
+  }
   async updateNewBlock(block: BlockBodyDto) {
     try {
       if (block && block.height) {
-        this.client.user.setActivity(`New Block: ${block.height}`)
-        this.logger.debug(`NEW WEBHOOK - New Block: ${block.height}`)
+        this.client.user.setActivity(`${block.height} block height`, {
+          type: ActivityType.Watching,
+        })
+        this.logger.debug(`NEW WEBHOOK - Block: ${block.height}`)
+      }
+    } catch (error) {
+      this.logger.error(`NEW WEBHOOK - Block: ${error}`)
+    }
+  }
+
+  async updateNewFees(fees: FeesBodyDto) {
+    try {
+      if (fees.fastestFee) {
+        this.client.user.setActivity(`${fees.fastestFee} sats/vByte`, {
+          type: ActivityType.Watching,
+        })
+        this.logger.debug(`NEW WEBHOOK - New Fees: ${fees.fastestFee} sats/vByte`)
       }
     } catch (error) {
-      this.logger.error(`NEW WEBHOOK - New Block: ${error}`)
+      this.logger.error(`NEW WEBHOOK - New Fees: ${error}`)
     }
   }
 
@@ -86,7 +113,9 @@ export class WebhooksService {
       const status = tickers.usd.priceChangePercent <= 0 ? 'dnd' : 'online'
 
       this.client.user.setStatus(status)
-      this.client.user.setActivity(msg)
+      this.client.user.setActivity(msg, {
+        type: ActivityType.Playing,
+      })
       this.logger.debug(`NEW WEBHOOK - New Price: ${msg}`)
     } catch (error) {
       this.logger.error(`NEW WEBHOOK - New Price: ${error}`)