#include "GenericFileSystemMessage.h"

#include "../objectmanager/ObjectManager.h"
#include "../storagemanager/StorageManagerIF.h"

void GenericFileSystemMessage::setCreateFileCommand(CommandMessage* message,
        store_address_t storeId) {
    message->setCommand(CMD_CREATE_FILE);
    message->setParameter2(storeId.raw);
}

void GenericFileSystemMessage::setDeleteFileCommand(
        CommandMessage* message, store_address_t storeId) {
    message->setCommand(CMD_DELETE_FILE);
    message->setParameter2(storeId.raw);
}

void GenericFileSystemMessage::setCreateDirectoryCommand(
        CommandMessage* message, store_address_t storeId) {
    message->setCommand(CMD_CREATE_DIRECTORY);
    message->setParameter2(storeId.raw);
}

void GenericFileSystemMessage::setReportFileAttributesCommand(CommandMessage *message,
        store_address_t storeId) {
    message->setCommand(CMD_REPORT_FILE_ATTRIBUTES);
    message->setParameter2(storeId.raw);
}

void GenericFileSystemMessage::setReportFileAttributesReply(CommandMessage *message,
        store_address_t storeId) {
    message->setCommand(REPLY_REPORT_FILE_ATTRIBUTES);
    message->setParameter2(storeId.raw);
}

void GenericFileSystemMessage::setDeleteDirectoryCommand(CommandMessage* message,
        store_address_t storeId) {
    message->setCommand(CMD_DELETE_DIRECTORY);
    message->setParameter2(storeId.raw);
}

void GenericFileSystemMessage::setLockFileCommand(CommandMessage *message,
        store_address_t storeId) {
    message->setCommand(CMD_LOCK_FILE);
    message->setParameter2(storeId.raw);
}

void GenericFileSystemMessage::setUnlockFileCommand(CommandMessage *message,
        store_address_t storeId) {
    message->setCommand(CMD_UNLOCK_FILE);
    message->setParameter2(storeId.raw);
}

void GenericFileSystemMessage::setSuccessReply(CommandMessage *message) {
    message->setCommand(COMPLETION_SUCCESS);
}

void GenericFileSystemMessage::setFailureReply(CommandMessage *message,
        ReturnValue_t errorCode, uint32_t errorParam) {
    message->setCommand(COMPLETION_FAILED);
    message->setParameter(errorCode);
    message->setParameter2(errorParam);
}

store_address_t GenericFileSystemMessage::getStoreId(const CommandMessage* message) {
    store_address_t temp;
    temp.raw = message->getParameter2();
    return temp;
}

ReturnValue_t GenericFileSystemMessage::getFailureReply(
        const CommandMessage *message, uint32_t* errorParam) {
    if(errorParam != nullptr) {
        *errorParam = message->getParameter2();
    }
    return message->getParameter();
}

void GenericFileSystemMessage::setFinishStopWriteCommand(CommandMessage *message,
        store_address_t storeId) {
    message->setCommand(CMD_FINISH_APPEND_TO_FILE);
    message->setParameter2(storeId.raw);
}

void GenericFileSystemMessage::setFinishStopWriteReply(CommandMessage *message,
        store_address_t storeId) {
    message->setCommand(REPLY_FINISH_APPEND);
    message->setParameter2(storeId.raw);
}

void GenericFileSystemMessage::setCopyCommand(CommandMessage* message,
        store_address_t storeId) {
    message->setCommand(CMD_COPY_FILE);
    message->setParameter2(storeId.raw);
}

void GenericFileSystemMessage::setWriteCommand(CommandMessage* message,
        store_address_t storeId) {
    message->setCommand(CMD_APPEND_TO_FILE);
    message->setParameter2(storeId.raw);
}

void GenericFileSystemMessage::setReadCommand(CommandMessage* message,
        store_address_t storeId) {
    message->setCommand(CMD_READ_FROM_FILE);
    message->setParameter2(storeId.raw);
}

void GenericFileSystemMessage::setFinishAppendReply(CommandMessage* message,
        store_address_t storageID) {
    message->setCommand(REPLY_FINISH_APPEND);
    message->setParameter2(storageID.raw);
}

void GenericFileSystemMessage::setReadReply(CommandMessage* message,
        bool readFinished, store_address_t storeId) {
    message->setCommand(REPLY_READ_FROM_FILE);
    message->setParameter(readFinished);
    message->setParameter2(storeId.raw);
}

void GenericFileSystemMessage::setReadFinishedReply(CommandMessage *message,
        store_address_t storeId) {
    message->setCommand(REPLY_READ_FINISHED_STOP);
    message->setParameter2(storeId.raw);
}

bool GenericFileSystemMessage::getReadReply(const CommandMessage *message,
        store_address_t *storeId) {
    if(storeId != nullptr) {
        (*storeId).raw = message->getParameter2();
    }
    return message->getParameter();
}

ReturnValue_t GenericFileSystemMessage::clear(CommandMessage* message) {
    switch(message->getCommand()) {
    case(CMD_CREATE_FILE):
    case(CMD_DELETE_FILE):
    case(CMD_CREATE_DIRECTORY):
    case(CMD_REPORT_FILE_ATTRIBUTES):
    case(REPLY_REPORT_FILE_ATTRIBUTES):
    case(CMD_LOCK_FILE):
    case(CMD_UNLOCK_FILE):
    case(CMD_COPY_FILE):
    case(REPLY_READ_FROM_FILE):
    case(CMD_READ_FROM_FILE):
    case(CMD_APPEND_TO_FILE):
    case(CMD_FINISH_APPEND_TO_FILE):
    case(REPLY_READ_FINISHED_STOP):
    case(REPLY_FINISH_APPEND): {
        store_address_t storeId = GenericFileSystemMessage::getStoreId(message);
        auto ipcStore = ObjectManager::instance()->get<StorageManagerIF>(objects::IPC_STORE);
        if(ipcStore == nullptr) {
            return HasReturnvaluesIF::RETURN_FAILED;
        }
        return ipcStore->deleteData(storeId);
    }
    }
    return HasReturnvaluesIF::RETURN_OK;
}