declare var Promise;
import Util from './../util/util';

export default
class Chat {
    private util:any;
    private boom:any;

    constructor(private db:any, private LISTS:any) {
        this.util = new Util(db);
        this.boom = require('boom')
    }

    /**
     * Returns a list of conversations by userid.
     * @param userid
     */
    getConversationsByUserId = (userid:string) => {
        return this.util.retrieveAllValues(this.LISTS.LIST_CHAT_CONVERSATIONS, {userId: userid});
    };

    /**
     * Checks if a conversation of two users does not exist
     * @param userid
     * @param userid2
     */
    conversationDoesNotExist = (userid:string, userid2:string) => {
        return new Promise((resolve, reject) => {

            this.db.list(this.LISTS.LIST_CHAT_CONVERSATIONS_BY_TWO_USER, {
                userId: userid,
                userId2: userid2
            }, (err, result) => {
                if (err) {
                    return reject(this.boom.badRequest(err))
                }

                if (!result.length || result[0].delete) {
                    return resolve();
                }

                reject(result[0]);
            });
        });
    };

    /**
     * Update a conversation object with new value
     * @param conversationid
     * @param value
     */
    updateConversation = (conversationid:string, value:any) => {

        return new Promise((resolve, reject) => {
            this.db.get(conversationid, (err, res) => {

                if (err) {
                    return reject(this.boom.badRequest(err))
                }

                if (value.trip && res.trip && value.trip === res.trip) {
                    res.duplicateTrip = true;
                    return resolve(res)
                }

                this.db.merge(conversationid, value, (err, res) => {

                    if (err) {
                        reject(this.boom.badRequest(err))
                    }
                    resolve(res);
                });

            })
        })
    };

    /**
     * Create a new conversation.
     *
     * @param conversation:any
     */
    createConversation = (conversation:any) => {
        return this.util.createDocument(conversation);
    };

    /**
     * Get conversation by conversationId
     *
     * @param conversationId:string
     */
    getConversationById = (conversationId:string) => {
        return this.util.retrieveSingleValue(this.LISTS.LIST_CHAT_CONVERSATIONBYID, conversationId);
    };

    /**
     * Get messages by conversationId
     *
     * @param conversationId:string
     */
    getMessagesByConversionId = (conversationId:string, query:any)=> {
        var options:any = {};
        if (query && query.elements) {
            options = {
                startkey: [conversationId, {}],
                endkey: [conversationId],
                include_docs: true,
                descending: true,
                limit: query.elements,
                skip: query.elements * query.page
            };
        } else {
            options = {
                endkey: [conversationId, {}],
                startkey: [conversationId],
                include_docs: true,
            };
        }


        return new Promise((resolve, reject) => {
            this.db.view('chat/messagesByConversationIdPage', options, (err, res) => {

                if (err) {
                    return reject(this.boom.badRequest(err));
                }

                resolve(this.reduceData(res));
            })

        })
    }
        ;

    /**
     * Check if user is part of the conversation
     * @param userid
     * @param conversationid
     * @returns {any}
     */
    iAmPartOfThisConversation = (userid:string, conversationid:string) => {
        return new Promise((resolve, reject) => {
            this.db.get(conversationid, (err, res) => {

                if (err) {
                    return reject(this.boom.badRequest(err))
                }

                if (userid != res.user_1 && userid != res.user_2) {
                    return reject(this.boom.forbidden('you are not a fellow of this conversation'))
                }

                return resolve();
            })

        })
    };

    /**
     * Save new message
     *
     * @param messageObj
     */
    saveMessage = (messageObj) => {
        return this.util.createDocument(messageObj);
    };

    reduceData = (data:any) => {
        var r = [];

        data.forEach(function (value) {
            r.push(value)
        });

        return r
    }
}