rgutierrez/resq
1
0
Fork 0
Code Issues 126 Pull requests 49 Projects Releases 4 Packages Wiki Activity Actions

Make sure we only send to unique channels when sending user app events #162

Browse source
This commit is contained in:
Kendrick Chan 2018-08-15 09:14:18 +08:00
parent e0b98d00fe
commit 4bb2374d66
1 changed files with 11 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
src/Service/MQTTClient.php
View file

@ -57,14 +57,23 @@ class MQTTClient
return;
}
$channels = [];
// send to every customer session
foreach ($sessions as $sess)
{
$phone_num = $sess->getPhoneNumber();
$channel = self::PREFIX . $phone_num;
$this->publish($channel, json_encode($payload));
error_log('sent to ' . $channel);
// gather channels, so we only send once
$channels[$channel] = json_encode($payload);
}
foreach ($channels as $channel => $json_payload)
{
$this->publish($channel, $json_payload);
// error_log('sent to ' . $channel);
}
}