@@ -24,25 +24,25 @@ module.exports = function (RED) {
2424 this . phoneNumber = this . credentials . phonenumber || '' ;
2525 }
2626
27- this . createTelegramClient = async function ( apiId , apiHash , session , phonenumber , logLevel , done ) {
27+ this . createTelegramClient = async function createTelegramClient ( apiId , apiHash , session , phonenumber , logLevel ) {
2828 let client ;
2929 if ( apiId !== undefined && apiId !== '' ) {
3030 const stringSession = new StringSession ( session ) ;
3131 const ID = Number ( apiId ) ;
3232 client = new TelegramClient ( stringSession , ID , apiHash , {
3333 connectionRetries : 5 ,
3434 } ) ;
35-
35+
3636 client . setLogLevel ( logLevel ) ;
37-
37+
3838 await client . start ( {
3939 phoneNumber : phonenumber , // TODO: check if we need this
4040 onError : ( err ) => console . log ( err ) ,
4141 } ) ;
4242 }
4343
4444 return client ;
45- }
45+ } ;
4646
4747 // Activates the client or returns the already activated bot.
4848 this . getTelegramClient = async function ( ) {
@@ -52,7 +52,7 @@ module.exports = function (RED) {
5252
5353 return this . client ;
5454 } ;
55-
55+
5656 this . onStarted = function ( ) { } ;
5757 RED . events . on ( 'flows:started' , this . onStarted ) ;
5858
@@ -78,8 +78,22 @@ module.exports = function (RED) {
7878 this . bot = config . bot ;
7979 this . config = RED . nodes . getNode ( this . bot ) ;
8080
81- const start = async ( ) =>
82- {
81+ const eventHandler = async function ( event ) {
82+ const message = event . message ;
83+ const sender = await message . getSender ( ) ;
84+ const chat = await message . getChat ( ) ;
85+ let msg = {
86+ payload : {
87+ sender : sender ,
88+ chat : chat ,
89+ message : message ,
90+ originalUpdate : event . originalUpdate ,
91+ } ,
92+ } ;
93+ node . send ( msg ) ;
94+ } ;
95+
96+ const start = async ( ) => {
8397 let client = await node . config . getTelegramClient ( ) ;
8498 if ( client ) {
8599 node . status ( {
@@ -88,20 +102,6 @@ module.exports = function (RED) {
88102 text : 'connected' ,
89103 } ) ;
90104
91- async function eventHandler ( event ) {
92- const message = event . message ;
93- const sender = await message . getSender ( ) ;
94- const chat = await message . getChat ( ) ;
95- let msg = {
96- payload : {
97- sender : sender ,
98- chat : chat ,
99- message : message ,
100- originalUpdate : event . originalUpdate
101- } ,
102- }
103- node . send ( msg ) ;
104- }
105105 client . addEventHandler ( eventHandler , new NewMessage ( { } ) ) ;
106106
107107 // client.addEventHandler((update) => {
@@ -129,4 +129,4 @@ module.exports = function (RED) {
129129// message: `hi your id is ${message.senderId}`,
130130//});
131131// const entity = await client.getEntity('Windhose');
132- // await client.sendMessage(entity, { message: 'Hello!' });
132+ // await client.sendMessage(entity, { message: 'Hello!' });
0 commit comments