@@ -5,51 +5,51 @@ const TelegramBot = require("node-telegram-bot-api")
55const chatId = process . env . CHAT_ID
66
77const bot = new TelegramBot ( process . env . BOT_TOKEN , {
8- polling : chatId === undefined ,
8+ polling : chatId === undefined || chatId === "" ,
99} )
1010
11- if ( chatId === undefined ) {
11+ if ( chatId === undefined || chatId === "" ) {
1212 bot . onText ( / \/ g e t _ c h a t _ i d / , ( msg , _match ) => {
1313 bot . sendMessage ( msg . chat . id , msg . chat . id )
1414 } )
15- }
16-
17- // Send messages in queue every minute
18- sendMessagesInQueue ( )
19- scheduleJob ( )
15+ } else {
16+ // Send messages in queue every minute
17+ sendMessagesInQueue ( )
18+ scheduleJob ( )
2019
21- function sendMessagesInQueue ( ) {
22- const db = new loki ( "./db/notifybot.db" )
23- db . loadDatabase ( { } , ( ) => {
24- const messages =
25- db . getCollection ( "messages" ) || db . addCollection ( "messages" )
26- messages . findAndUpdate (
27- {
28- sent : false ,
29- schedule : {
30- $lte : new Date ( Date . now ( ) + 58 * 1000 ) . toISOString ( ) ,
20+ function sendMessagesInQueue ( ) {
21+ const db = new loki ( "./db/notifybot.db" )
22+ db . loadDatabase ( { } , ( ) => {
23+ const messages =
24+ db . getCollection ( "messages" ) || db . addCollection ( "messages" )
25+ messages . findAndUpdate (
26+ {
27+ sent : false ,
28+ schedule : {
29+ $lte : new Date ( Date . now ( ) + 58 * 1000 ) . toISOString ( ) ,
30+ } ,
3131 } ,
32- } ,
33- ( obj ) => {
34- try {
35- bot . sendMessage ( chatId , obj . message )
36- obj . sent = true
37- return obj
38- } catch ( e ) {
39- console . log ( "Couldn't send message" )
40- console . log ( e )
41- obj . sent = false
42- return obj
32+ ( obj ) => {
33+ try {
34+ bot . sendMessage ( chatId , obj . message )
35+ obj . sent = true
36+ return obj
37+ } catch ( e ) {
38+ console . log ( "Couldn't send message" )
39+ console . log ( e )
40+ obj . sent = false
41+ return obj
42+ }
4343 }
44- }
45- )
46- db . save ( )
47- } )
48- }
44+ )
45+ db . save ( )
46+ } )
47+ }
4948
50- function scheduleJob ( ) {
51- schedule . scheduleJob ( "* * * * *" , async ( ) => {
52- console . log ( "HELLO AT " , new Date ( ) )
53- sendMessagesInQueue ( )
54- } )
49+ function scheduleJob ( ) {
50+ schedule . scheduleJob ( "* * * * *" , async ( ) => {
51+ console . log ( "HELLO AT " , new Date ( ) )
52+ sendMessagesInQueue ( )
53+ } )
54+ }
5555}
0 commit comments