- Updated Sentry integration

.env.example

@@ -13,4 +13,4 @@ API_KEY=API_KEY
 TELEGRAM_BOT_TOKEN=TELEGRAM_BOT_TOKEN
 SOLANA_AMOUNT_PER_TOKEN=10000000
 
-SENTRY_DNS=SENTRY_DNS
+SENTRY_DSN=SENTRY_DNS

src/app.module.ts

@@ -26,10 +26,10 @@ const sessions = new LocalSession({
 @Module({
   imports: [
     SentryModule.forRoot(),
+    ConfigModule.forRoot(),
     ScheduleModule.forRoot(),
     TickerFetcherModule,
     TickerModule,
-    ConfigModule.forRoot(),
     TypeOrmModule.forRoot({
       type: 'postgres',
       host: process.env.PG_HOST,

src/main.ts

@@ -3,6 +3,13 @@ import { AppModule } from './app.module';
 import * as Sentry from '@sentry/node';
 import { nodeProfilingIntegration } from '@sentry/profiling-node';
 
+async function bootstrap() {
+  initSentry();
+
+  const app = await NestFactory.create(AppModule);
+  await app.listen(process.env.PORT || 3000);
+}
+
 const initSentry = () => {
   Sentry.init({
     dsn: process.env.SENTRY_DSN,
@@ -14,11 +21,4 @@ const initSentry = () => {
   });
 };
 
-async function bootstrap() {
-  initSentry();
-
-  const app = await NestFactory.create(AppModule);
-  await app.listen(process.env.PORT || 3000);
-}
-
 bootstrap();

src/position-processor/position-processor.service.ts

@@ -6,6 +6,7 @@ import { TelegramBotService } from '../telegram-bot/telegram-bot.service';
 import { UsersService } from '../user';
 import { SolanaAmmClientService } from '../solana-client/solana-amm-client.service';
 import { User } from '../user/user.entity';
+import * as Sentry from '@sentry/node';
 
 @Injectable()
 export class PositionProcessorService {
@@ -51,6 +52,7 @@ export class PositionProcessorService {
           `Purchased the token: ${position.raydiumPool}`,
         );
       } catch (e) {
+        Sentry.captureException(e);
         this.logger.error(`Something is wrong: ${e.message}`);
       }
     }
@@ -87,6 +89,7 @@ export class PositionProcessorService {
           `Sold the token: ${position.raydiumPool}`,
         );
       } catch (e) {
+        Sentry.captureException(e);
         this.logger.error(`Something is wrong: ${e.message}`);
       }
     }

src/telegram-bot/telegram-bot.service.ts

@@ -109,6 +109,8 @@ export class TelegramBotService {
 
     const positions = await this.positionService.getAll();
 
+    await ctx.reply(`Positions:`);
+
     for (const position of positions) {
       await ctx.reply(
         `ID: ${position.id}, Status: ${position.status}, Pool: ${position.raydiumPool} `,

src/ticker-fetcher/ticker-fetcher.service.ts

@@ -2,6 +2,7 @@ import { Injectable, Logger } from '@nestjs/common';
 import { PumpFunClientService } from '../pump-fun-client/pump-fun-client.service';
 import { TickerService } from '../ticker/ticker.service';
 import { Cron } from '@nestjs/schedule';
+import * as Sentry from '@sentry/node';
 
 const HISTORY_TIME_RANGE_SECONDS = 3600;
 
@@ -36,6 +37,7 @@ export class TickerFetcherService {
 
       await this.tickerService.bulkAdd(coins);
     } catch (e) {
+      Sentry.captureException(e);
       this.logger.error(`Something went wrong. Error: ${e.message}`);
     }
 

src/token-watcher/token-watcher.service.ts

@@ -3,6 +3,7 @@ import { Cron } from '@nestjs/schedule';
 import { TickerService } from '../ticker/ticker.service';
 import { PositionService } from '../position/position.service';
 import { SolanaAmmClientService } from '../solana-client/solana-amm-client.service';
+import * as Sentry from '@sentry/node';
 
 @Injectable()
 export class TokenWatcherService {
@@ -78,6 +79,7 @@ export class TokenWatcherService {
         }
       }
     } catch (e) {
+      Sentry.captureException(e);
       this.logger.error(`Something went wrong. Error: ${e.message}`);
     }