nctalkconversation.js

class TalkConversation {

    constructor(talkclient, nchttp, capabilities, roominfo) {
        this.nchttp = nchttp;
        this.capabilities = capabilities;
        this.roominfo = roominfo;

        this.talkclient = talkclient;

        this.lastmsgid = roominfo.lastReadMessage;
        this.listenactive = false;    // We start with active listing off
        this.waitmsgongoing = false;

        // Build url based on capabilities
        let conversation_feature = capabilities.CheckFeature("chat-v");

        if (conversation_feature == "chat-v2") {
            this.chatVersion = 2;
        }
        else {
            this.chatVersion = 1;
        }

        // So far only url API Version 1 exists...
        //   this.url = `/ocs/v2.php/apps/spreed/api/v1/chat/${this.roominfo.token}?lookIntoFuture=1&includeLastKnown=0&format=json&lastKnownMessageId=${this.lastmsgid}&setReadMarker=1`;

    }

    _geturl(func, param1) {
        switch (func) {
            case "SendMessage":
                return `/ocs/v2.php/apps/spreed/api/v1/chat/${this.roominfo.token}?format=json`;
            case "WaitNewMessages":
                // https://nextcloud-talk.readthedocs.io/en/latest/chat/ - chat version chat-v2 doesn't impact url it added support for rich object strings
                return `/ocs/v2.php/apps/spreed/api/v1/chat/${this.roominfo.token}?lookIntoFuture=1&setReadMarker=1&format=json&lastKnownMessageId=${this.lastmsgid}`;
            case "ShareFile":
                return `/ocs/v2.php/apps/files_sharing/api/v1/shares?shareType=10&shareWith=${this.roominfo.token}&path=${param1}`;


        }
    }

    SendMessage(comment, Callback) {

        let message = JSON.stringify({ message: comment, replyTo: 0 });
        this.nchttp.RequestfromHost("POST", this._geturl("SendMessage"), message, (retcode, res) => {
            switch (retcode) {
                case "OK":
                    Callback();
                    break;
                case "ERROR":
                    break;
            }
        });

    }

    ShareFile(filename, Callback) {
        this.nchttp.RequestfromHost("POST", this._geturl("ShareFile", filename), null, (retcode, res) => {
            switch (retcode) {
                case "OK":
                    Callback();
                    break;
                case "ERROR":
                    break;
            }
        });
    }

    SetListenMode(active) {
        this.listenactive = active;
    }

    WaitNewMessages(Callback) {
        if ((this.listenactive == true) && (this.waitmsgongoing == false)) {
            this.waitmsgongoing = true;  // Only one WaitNewMessages per conversation
            this.talkclient.DebugLog("WaitNewMessages IN " + this.roominfo.token);
            this.nchttp.RequestfromHost("GET", this._geturl("WaitNewMessages"), null, (retcode, res) => {

                if (this.waitmsgongoing == false) {
                    this.talkclient.ErrorLog("Callback called with waitmsgongoing = false!", this.roominfo.token, retcode, res);
                    Callback("STOP", res);
                }
                else {
                    this.talkclient.DebugLog("WaitNewMessages OUT " + this.roominfo.token + " " + this.waitmsgongoing);

                    // WaitNewMessages is done - do this before any callbacks are called in case the trigger a new WaitNewMessage
                    this.waitmsgongoing = false;

                    // https://nextcloud-talk.readthedocs.io/en/latest/chat/#receive-chat-messages-of-a-conversation
                    switch (retcode) {
                        case "OK":
                            let messages = undefined;

                            this.talkclient.DebugLog(res);

                            if (res.statusCode == 200) {
                                // 200 OK
                                try {
                                    messages = JSON.parse(res.body).ocs.data;
                                    this.lastmsgid = res.headers["x-chat-last-given"];
                                    Callback("OK", messages);
                                }
                                catch {
                                    Callback("ERROR", `ERROR reply string is not a JSON ${res.body}`);
                                }
                            } else if (res.statusCode == 304) {
                                // 304 Not Modified When there were no older/newer messages
                                Callback("NOMSG", "WaitNewMessages - Talk timeout empty reply after no new message was received");
                            } else if (res.statusCode == 404) {
                                // 404 Not Found When the conversation could not be found for the participant
                                Callback("ERROR", "Error http statusCode - 404 Not Found When the conversation could not be found for the participant");
                            }
                            else if (res.statusCode == 412) {
                                // 412 Precondition Failed When the lobby is active and the user is not a moderator
                                Callback("ERROR", "Error http statusCode - 412 Precondition Failed When the lobby is active and the user is not a moderator");
                            }
                            else {
                                Callback("ERROR", `Error unknown http statusCode - ${res.statusCode}`);
                            }
                            break;
                        case "ERROR":
                            Callback("ERROR", res);
                            break;
                    }
                }
            });
        }
    }
}

module.exports = TalkConversation;