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

fix(basic.gblib): update ChatServices.ts #420

Closed
eltociear wants to merge 2540 commits from patch-1 into main
pull from: patch-1
merge into: GeneralBots:main
Conversation 1 Commits 2540 Files changed 292 +11 -24
1 changed files with 11 additions and 24 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files
Showing only changes of commit 013ad665d7 - Show all commits

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

@ -171,34 +171,21 @@ export class WhatsappDirectLine extends GBService {
}
public pollMessages(client, conversationId, from, fromName) {
GBLog.info(`GBWhatsapp: Starting polling message for conversationId:
${conversationId}.`);
GBLog.info(`GBWhatsapp: Starting message polling(${from}, ${conversationId}).`);
let task: NodeJS.Timer;
const worker = () => {
clearInterval(task);
client.Conversations.Conversations_GetActivities({
conversationId: conversationId,
watermark: this.watermark
})
.then(response => {
this.watermark = response.obj.watermark;
return response.obj.activities;
})
.catch(err => {
GBLog.error(`Error calling Conversations_GetActivities on Whatsapp channel ${err.data}`);
})
.then(async activities => {
await this.printMessages(activities, conversationId, from, fromName);
})
.catch(err => {
GBLog.error(`Error calling printMessages on Whatsapp channel ${err.data}`);
const worker = async () => {
try {
const response = client.Conversations.Conversations_GetActivities({
conversationId: conversationId,
watermark: this.watermark
});
task = setInterval(worker, this.pollInterval);
await this.printMessages(response.obj.activities, conversationId, from, fromName);
} catch (err) {
GBLog.error(`Error calling printMessages on Whatsapp channel ${err.data}`);
}
};
task = setInterval(worker, this.pollInterval);
setInterval(worker, this.pollInterval);
}
public async printMessages(activities, conversationId, from, fromName) {