Fix internal signaling

Signed-off-by: Joas Schilling <coding@schilljs.com>
This commit is contained in:
Joas Schilling 2021-10-20 12:44:13 +02:00
parent 85f04900e8
commit 9be9d846b7
No known key found for this signature in database
GPG key ID: 7076EA9751AACDDA

View file

@ -133,11 +133,11 @@ class Messages {
}
$result->closeCursor();
$query = $this->db->getQueryBuilder();
$query->delete('talk_internalsignaling')
->where($query->expr()->eq('recipient', $query->createNamedParameter($sessionId)))
->andWhere($query->expr()->lte('timestamp', $query->createNamedParameter($time)));
$query->executeQuery();
$delete = $this->db->getQueryBuilder();
$delete->delete('talk_internalsignaling')
->where($delete->expr()->eq('recipient', $delete->createNamedParameter($sessionId)))
->andWhere($delete->expr()->lte('timestamp', $delete->createNamedParameter($time)));
$delete->executeStatement();
return $messages;
}