Skip to content
Snippets Groups Projects
Commit 6de0c334 authored by akwizgran's avatar akwizgran
Browse files

Missed a method when replacing private messages with private groups.

Unit tests would've caught this.
parent caec26e9
No related branches found
No related tags found
No related merge requests found
...@@ -1673,25 +1673,7 @@ abstract class JdbcDatabase implements Database<Connection> { ...@@ -1673,25 +1673,7 @@ abstract class JdbcDatabase implements Database<Connection> {
PreparedStatement ps = null; PreparedStatement ps = null;
ResultSet rs = null; ResultSet rs = null;
try { try {
// Do we have any sendable private messages?
String sql = "SELECT m.messageId FROM messages AS m" String sql = "SELECT m.messageId FROM messages AS m"
+ " JOIN statuses AS s"
+ " ON m.messageId = s.messageId"
+ " WHERE m.contactId = ? AND seen = FALSE AND expiry < ?"
+ " ORDER BY timestamp DESC LIMIT ?";
ps = txn.prepareStatement(sql);
ps.setInt(1, c.getInt());
ps.setLong(2, now);
ps.setInt(3, maxMessages);
rs = ps.executeQuery();
List<MessageId> ids = new ArrayList<MessageId>();
while(rs.next()) ids.add(new MessageId(rs.getBytes(1)));
rs.close();
ps.close();
if(ids.size() == maxMessages)
return Collections.unmodifiableList(ids);
// Do we have any sendable group messages?
sql = "SELECT m.messageId FROM messages AS m"
+ " JOIN contactGroups AS cg" + " JOIN contactGroups AS cg"
+ " ON m.groupId = cg.groupId" + " ON m.groupId = cg.groupId"
+ " JOIN groupVisibilities AS gv" + " JOIN groupVisibilities AS gv"
...@@ -1709,8 +1691,9 @@ abstract class JdbcDatabase implements Database<Connection> { ...@@ -1709,8 +1691,9 @@ abstract class JdbcDatabase implements Database<Connection> {
ps = txn.prepareStatement(sql); ps = txn.prepareStatement(sql);
ps.setInt(1, c.getInt()); ps.setInt(1, c.getInt());
ps.setLong(2, now); ps.setLong(2, now);
ps.setInt(3, maxMessages - ids.size()); ps.setInt(3, maxMessages);
rs = ps.executeQuery(); rs = ps.executeQuery();
List<MessageId> ids = new ArrayList<MessageId>();
while(rs.next()) ids.add(new MessageId(rs.getBytes(1))); while(rs.next()) ids.add(new MessageId(rs.getBytes(1)));
rs.close(); rs.close();
ps.close(); ps.close();
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment