 			message.cache_has_attachments,
 			message.expressive_send_style_id,
 			message.associated_message_type,
-			message.associated_message_guid, message.guid
-			FROM message INNER JOIN handle
+			message.associated_message_guid, message.guid, destination_caller_id
+			FROM message LEFT JOIN handle
 			ON message.handle_id = handle.ROWID
 			WHERE message.ROWID > ? ORDER BY message.ROWID ASC
 	"""

        }
        
        var People = [Person]()
        
        while sqlite3_step(statement) == SQLITE_ROW {
            guard let idcString = sqlite3_column_text(statement, 0) else {
                break
            }
            let handle = String(cString: idcString)
            let contact = ContactHelper.RetreiveContact(handle: handle)
            
            People.append(Person(givenName: contact?.givenName, handle: handle, isMe: false))
        }
        
        return Group(name: "", handle: handle, participants: People)
    }
    
    private func unwrapStringColumn(for sqlStatement: OpaquePointer?, at column: Int32) -> String? {

    private func queryNewRecords() -> Double {
        let start = Date()
        defer { statement = nil }
        querySinceID = "225925"
        
        if sqlite3_prepare_v2(db, DatabaseHandler.newRecordquery, -1, &statement, nil) != SQLITE_OK {
            let errmsg = String(cString: sqlite3_errmsg(db)!)
