GeneralBots/botserver
2
1
Fork 0
Code Issues Pull requests 1 Projects Releases 323 Packages Wiki Activity Actions

Update WhatsappDirectLine.ts

Browse source
This commit is contained in:
Rodrigo Rodriguez 2019-06-23 07:24:35 -03:00 • committed by GitHub
parent 013ad665d7
commit a7de845164
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
packages/whatsapp.gblib/services/WhatsappDirectLine.ts
View file

@ -50,7 +50,6 @@ export class WhatsappDirectLine extends GBService {
public whatsappServiceNumber: string; public whatsappServiceNumber: string;
public whatsappServiceUrl: string; public whatsappServiceUrl: string;
public botId: string; public botId: string;
public watermark: string;
public conversationIds = {}; public conversationIds = {};
@ -173,19 +172,21 @@ export class WhatsappDirectLine extends GBService {
public pollMessages(client, conversationId, from, fromName) { public pollMessages(client, conversationId, from, fromName) {
GBLog.info(`GBWhatsapp: Starting message polling(${from}, ${conversationId}).`); GBLog.info(`GBWhatsapp: Starting message polling(${from}, ${conversationId}).`);
let watermark: any;
const worker = async () => { const worker = async () => {
try { try {
const response = client.Conversations.Conversations_GetActivities({ const response = await client.Conversations.Conversations_GetActivities({
conversationId: conversationId, conversationId: conversationId,
watermark: this.watermark watermark: watermark
}); });
watermark = response.obj.watermark;
await this.printMessages(response.obj.activities, conversationId, from, fromName); await this.printMessages(response.obj.activities, conversationId, from, fromName);
} catch (err) { } catch (err) {
GBLog.error(`Error calling printMessages on Whatsapp channel ${err.data}`); GBLog.error(`Error calling printMessages on Whatsapp channel ${err.data}`);
} }
setInterval(worker, this.pollInterval);
}; };
setInterval(worker, this.pollInterval);
} }
public async printMessages(activities, conversationId, from, fromName) { public async printMessages(activities, conversationId, from, fromName) {