Add Custom Telegram filter

valamicorp · Nov 8, 2021 · c601417 · c601417
1 parent a80e991
commit c601417
Show file tree

Hide file tree

Showing 4 changed files with 35 additions and 2 deletions.
diff --git a/assets/index.html b/assets/index.html
@@ -203,6 +203,10 @@ <h5 class="modal-title" id="settingModalLabel">Settings</h5>
                   <label for="settingTelegramChannel" class="form-label">TelegramChannelName</label>
                   <input type="text" class="form-control" id="settingTelegramChannel">
                 </div>
+                <div class="mb-3">
+                  <label for="settingTelegramFilter" class="form-label">CustomFilterWord</label>
+                  <input type="text" placeholder="BNB" class="form-control" id="settingTelegramFilter">
+                </div>
                 <div class="mb-3">
                   <label for="settingTelegramAPI" class="form-label">TelegramAPI ID</label>
                   <input type="text" class="form-control" id="settingTelegramAPI">

diff --git a/assets/renderer.js b/assets/renderer.js
@@ -49,6 +49,9 @@ window.onload = (event) => {
   if (store.has('telegramAPI')) {
     document.getElementById('settingTelegramAPI').value = store.get('telegramAPI');
   }
+  if (store.has('telegramFilter')) {
+    document.getElementById('settingTelegramFilter').value = store.get('telegramFilter');
+  }
   if (store.has('telegramAPIHASH')) {
     document.getElementById('settingTelegramAPIHASH').value = store.get('telegramAPIHASH');
   }
@@ -157,6 +160,9 @@ const readSetting = () => {
   const telegramChannel = document.getElementById('settingTelegramChannel').value;
   const telegramAPI = document.getElementById('settingTelegramAPI').value;
   const telegramAPIHASH = document.getElementById('settingTelegramAPIHASH').value;
+  const telegramFilter = document.getElementById('settingTelegramFilter').value;
+
+
 
   const coinmarketcapAPI = document.getElementById('coinmarketcapAPI').value;
 
@@ -175,6 +181,7 @@ const readSetting = () => {
     store.set('telegramAPI', telegramAPI.trim());
     store.set('telegramAPIHASH', telegramAPIHASH.trim());
     store.set('telegramSession', telegramSession.trim());
+    store.set('telegramFilter', telegramFilter.trim());
   }
 
 

diff --git a/src/main.ts b/src/main.ts
@@ -180,9 +180,10 @@ const start = async (broker: ElectronBroker) => {
         hash: store.get('telegramAPIHASH'),
         session: store.get('telegramSession'),
         channel: store.get('telegramChannel'),
+        filter: store.get('telegramFilter') || '',
       };
 
-      const telegramSignaler = new TelegramScrapper(tgOption.api, tgOption.hash, tgOption.session, tgOption.channel);
+      const telegramSignaler = new TelegramScrapper(tgOption.api, tgOption.hash, tgOption.session, tgOption.channel, tgOption.filter);
       telegramSignaler.on('newSignal', async (address: string) => {
         try {
           if (store.has('signalHistoryTg')) {

diff --git a/src/plugins/telegram/telegram.ts b/src/plugins/telegram/telegram.ts
@@ -23,9 +23,11 @@ export class TelegramScrapper extends EventEmitter {
   private listener?: NodeJS.Timer;
   private client?: TelegramClient;
 
+  private customFilter?: string;
+
   private lastProcessed = 0;
 
-  constructor(apiId: string, apiHash: string, session: string, channelName: string) {
+  constructor(apiId: string, apiHash: string, session: string, channelName: string, customFilter?: string) {
     super();
     this.apiId = Number(apiId);
     this.apiHash = apiHash;
@@ -109,6 +111,25 @@ export class TelegramScrapper extends EventEmitter {
           break;
         }
 
+        // Custom Signal Filter
+        if(this?.customFilter && this?.customFilter !== "") {
+              if (content && content.includes(this.customFilter)) {
+
+                Logger.log('Telegram address found!', content, new Date());
+
+                const regex = /0x[a-fA-F0-9]{40}/;
+                const almostAddress = content.match(regex);
+
+                if (almostAddress[0] && this.lastSignal !== almostAddress[0]) {
+                  this.lastSignal = almostAddress[0];
+                  this.emit('newSignal', almostAddress[0]);
+                  return;
+                }
+              }
+
+            return;
+        }
+
         // CMC list signals
         if (content && content.includes('first pump') && content.includes('BNB')) {