/* Copyright 2011 Yorba Foundation
 *
 * This software is licensed under the GNU Lesser General Public License
 * (version 2.1 or later).  See the COPYING file in this distribution. 
 */

public class Geary.Sqlite.MessageTable : Geary.Sqlite.Table {
    // This *must* match the column order in the database
    public enum Column {
        ID,
        
        DATE_FIELD,
        DATE_INT64,
        
        FROM_FIELD,
        SENDER,
        REPLY_TO,
        
        TO_FIELD,
        CC,
        BCC,
        
        MESSAGE_ID,
        IN_REPLY_TO,
        
        SUBJECT,
        
        HEADER,
        
        BODY;
    }
    
    internal MessageTable(Geary.Sqlite.Database gdb, SQLHeavy.Table table) {
        base (gdb, table);
    }
    
    public async int64 create_async(MessageRow row, Cancellable? cancellable) throws Error {
        SQLHeavy.Query query = db.prepare(
            "INSERT INTO MessageTable "
            + "(date_field, date_time_t, from_field, sender, reply_to, to_field, cc, bcc, message_id, in_reply_to, subject, header, body) "
            + "VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)");
        query.bind_string(0, row.date);
        query.bind_int64(1, row.date_time_t);
        query.bind_string(2, row.from);
        query.bind_string(3, row.sender);
        query.bind_string(4, row.reply_to);
        query.bind_string(5, row.to);
        query.bind_string(6, row.cc);
        query.bind_string(7, row.bcc);
        query.bind_string(8, row.message_id);
        query.bind_string(9, row.in_reply_to);
        query.bind_string(10, row.subject);
        query.bind_string(11, row.header);
        query.bind_string(12, row.body);
        
        return yield query.execute_insert_async(cancellable);
    }
    
    public async Gee.List<MessageRow>? list_by_message_id_async(Geary.RFC822.MessageID message_id,
        Geary.Email.Field fields, Cancellable? cancellable) throws Error {
        assert(fields != Geary.Email.Field.NONE);
        
        SQLHeavy.Query query = db.prepare(
            "SELECT %s FROM MessageTable WHERE message_id = ?".printf(fields_to_columns(fields)));
        query.bind_string(0, message_id.value);
        
        SQLHeavy.QueryResult results = yield query.execute_async(cancellable);
        if (results.finished)
            return null;
        
        Gee.List<MessageRow> list = new Gee.ArrayList<MessageRow>();
        do {
            list.add(new MessageRow.from_query_result(this, fields, results));
            yield results.next_async(cancellable);
        } while (!results.finished);
        
        return (list.size > 0) ? list : null;
    }
    
    public async MessageRow? fetch_async(int64 id, Geary.Email.Field fields,
        Cancellable? cancellable = null) throws Error {
        assert(fields != Geary.Email.Field.NONE);
        
        SQLHeavy.Query query = db.prepare(
            "SELECT %s FROM MessageTable WHERE id = ?".printf(fields_to_columns(fields)));
        query.bind_int64(0, id);
        
        SQLHeavy.QueryResult results = yield query.execute_async(cancellable);
        if (results.finished)
            return null;
        
        MessageRow row = new MessageRow.from_query_result(this, fields, results);
        row.id = id;
        
        return row;
    }
    
    private static string fields_to_columns(Geary.Email.Field fields) {
        StringBuilder builder = new StringBuilder();
        foreach (Geary.Email.Field field in Geary.Email.Field.all()) {
            string? append = null;
            switch (field) {
                case Geary.Email.Field.DATE:
                    append = "date_field, date_time_t";
                break;
                
                case Geary.Email.Field.ORIGINATORS:
                    append = "from_field, sender, reply_to";
                break;
                
                case Geary.Email.Field.RECEIVERS:
                    append = "to_field, cc, bcc";
                break;
                
                case Geary.Email.Field.REFERENCES:
                    append = "message_id, in_reply_to";
                break;
                
                case Geary.Email.Field.SUBJECT:
                    append = "subject";
                break;
                
                case Geary.Email.Field.HEADER:
                    append = "header";
                break;
                
                case Geary.Email.Field.BODY:
                    append = "body";
                break;
            }
            
            if (append != null) {
                if (!String.is_empty(builder.str))
                    builder.append(", ");
                
                builder.append(append);
            }
        }
        
        return builder.str;
    }
}