/*
 * @file SMSRecord.cpp
 * @author Mateusz Piesta (mateusz.piesta@mudita.com)
 * @date 29.05.19
 * @brief
 * @copyright Copyright (C) 2019 mudita.com
 * @details
 */


#include "SMSRecord.hpp"
#include "ContactRecord.hpp"
#include "ThreadRecord.hpp"
#include <log/log.hpp>

SMSRecord::SMSRecord(const SMSTableRow &w, const UTF8 &num)
{
    ID = w.ID;
    date = w.date;
    dateSent = w.dateSent;
    errorCode = w.errorCode;
    number = num;
    body = w.body;
    isRead = w.isRead;
    type = w.type;
    threadID = w.threadID;
    contactID = w.contactID;
}

SMSRecordInterface::SMSRecordInterface(SmsDB* smsDb,ContactsDB* contactsDb): smsDB(smsDb),contactsDB(contactsDb) {

}

SMSRecordInterface::~SMSRecordInterface() {

}

bool SMSRecordInterface::Add(const SMSRecord &rec) {

    uint32_t contactID = 0;

    ContactRecordInterface contactInterface(contactsDB);
    auto contactRec = contactInterface.GetLimitOffsetByField(0, 1, ContactRecordField::NumberE164, rec.number.c_str());

    // Contact not found, create one
    if (contactRec->size() == 0) {
        contactInterface.Add(ContactRecord{
        		.primaryName = rec.number,
                .contactType=ContactType::TEMPORARY,
                .numbers=std::vector<ContactRecord::Number>{ContactRecord::Number(
                    rec.number.c_str(),
                    rec.number.c_str())
                },
                });

        contactRec = contactInterface.GetLimitOffsetByField(0, 1, ContactRecordField::NumberE164,
                                                                 rec.number.c_str());
    }
    contactID = (*contactRec)[0].dbID;



    // Search for a thread with specified contactID
    uint32_t threadID =0;
    ThreadRecordInterface threadInterface(smsDB,contactsDB);
    auto threadRec = threadInterface.GetLimitOffsetByField(0, 1, ThreadRecordField::ContactID,
                                                           std::to_string(contactID).c_str());

    // Thread not found, create one
    if (threadRec->size() == 0) {

        ThreadRecord re;
        re.contactID = contactID;
        threadInterface.Add(re);

        threadRec = threadInterface.GetLimitOffsetByField(0,1,ThreadRecordField::ContactID,std::to_string(contactID).c_str());

    }
    threadID = (*threadRec)[0].dbID;

    // Create SMS
    smsDB->sms.Add(SMSTableRow{
            .threadID = threadID,
            .contactID=contactID,
            .date=rec.date,
            .dateSent=rec.dateSent,
            .errorCode=rec.errorCode,
            .body=rec.body,
            .isRead=rec.isRead,
            .type=rec.type

    });

    //TODO: error check

    // Update thread
    auto thread = (*threadRec)[0];
    thread.snippet = rec.body.substr(0,rec.body.length() >= snippetLength ? snippetLength : rec.body.length());
    thread.date = rec.date;
    thread.type = rec.type;
    thread.msgCount++;
    if(rec.type == SMSType::INBOX){
        thread.msgRead++;
    }

    threadInterface.Update(thread);


    return true;
}
uint32_t SMSRecordInterface::GetCount(SMSState state)
{
    return smsDB->sms.GetCount(state);
}

uint32_t SMSRecordInterface::GetCount() {
    return GetCount(SMSState::ALL);
}

uint32_t SMSRecordInterface::GetLastID(void)
{
	return smsDB->GetLastInsertRowID();

}
std::unique_ptr<std::vector<SMSRecord>> SMSRecordInterface::GetLimitOffsetByField(uint32_t offset, uint32_t limit,
                                                                                  SMSRecordField field,
                                                                                  const char *str) {
    auto records = std::make_unique<std::vector<SMSRecord>>();

    std::vector<SMSTableRow> smses;

    switch(field){
        case SMSRecordField ::ContactID:
            smses = smsDB->sms.GetLimitOffsetByField(offset,limit,SMSTableFields::ContactID,str);
            break;

        case SMSRecordField ::ThreadID:
            smses = smsDB->sms.GetLimitOffsetByField(offset,limit,SMSTableFields::ThreadID,str);
            break;

        default:
            LOG_ERROR("SMS thread get - wrong selection: %d", field);
            return records;
    }

    LOG_INFO("Get: %d SMS by selection: %d", smses.size(), field);

    ContactRecordInterface contactInterface(contactsDB);
    for(const auto &w : smses){

        auto contactRec = contactInterface.GetByID(w.contactID);
        // TODO: or numberUser? or other number?
        records->push_back({w, contactRec.numbers[0].numberE164});
    }

    return records;
}


std::unique_ptr<std::vector<SMSRecord>> SMSRecordInterface::GetLimitOffset(uint32_t offset, uint32_t limit) {
    auto smses = smsDB->sms.GetLimitOffset(offset,limit);

    auto records = std::make_unique<std::vector<SMSRecord>>();

    ContactRecordInterface contactInterface(contactsDB);
    for(const auto &w : smses){

        auto contactRec = contactInterface.GetByID(w.contactID);
        // TODO: or numberUser? or other number
        records->push_back({w, contactRec.numbers[0].numberE164});
    }

    return records;
}

bool SMSRecordInterface::Update(const SMSRecord &rec) {

    auto sms = smsDB->sms.GetByID(rec.ID);
    if(sms.ID == 0){
        return false;
    }

    smsDB->sms.Update(SMSTableRow{.ID = rec.ID,
                                  .threadID = sms.threadID,
                                  .contactID = sms.contactID,
                                  .date = rec.date,
                                  .dateSent = rec.dateSent,
                                  .errorCode = rec.errorCode,
                                  .body = rec.body,
                                  .isRead = rec.isRead,
                                  .type = rec.type});

    // Update messages read count if necessary
    if(!sms.isRead && rec.isRead){
        ThreadRecordInterface threadInterface(smsDB,contactsDB);
        auto threadRec =   threadInterface.GetByID(sms.threadID);
        threadRec.msgRead--;
        threadInterface.Update(threadRec);

    }

    return true;
}

bool SMSRecordInterface::RemoveByID(uint32_t id) {

    auto sms = smsDB->sms.GetByID(id);
    if(sms.ID == 0){
        return false;
    }

    ThreadRecordInterface threadInterface(smsDB,contactsDB);
    auto threadRec = threadInterface.GetByID(sms.threadID);

    // If thread not found
    if(threadRec.dbID == 0){
        if(smsDB->sms.RemoveByID(id) == false){
            return false;
        }

        return false;
    }

    // If thread contains only one message remove it
    if(threadRec.msgCount == 1){
        threadInterface.RemoveByID(sms.threadID);
    }
    else{
        // Update msg count
        threadRec.msgCount--;
        threadInterface.Update(threadRec);
    }

    // Remove SMS
    if(smsDB->sms.RemoveByID(id) == false){
        return false;
    }

    return true;
}

bool SMSRecordInterface::RemoveByField(SMSRecordField field, const char *str) {

    switch(field){
        case SMSRecordField ::ContactID:
            return smsDB->sms.RemoveByField(SMSTableFields::ContactID,str);

        case SMSRecordField ::ThreadID:
            return smsDB->sms.RemoveByField(SMSTableFields::ThreadID,str);

        case SMSRecordField ::Number:
            return false;

        default:
            return false;

    }

}

SMSRecord SMSRecordInterface::GetByID(uint32_t id) {
    auto sms = smsDB->sms.GetByID(id);


    ContactRecordInterface contactInterface(contactsDB);
    auto contactRec = contactInterface.GetByID(sms.contactID);
    // TODO: or numberUser?
    return SMSRecord{sms, contactRec.numbers[0].numberE164};
}