module hunt.http.codec.websocket.model.extension.identity.IdentityExtension;

import hunt.http.codec.websocket.frame.Frame;
import hunt.http.codec.websocket.model.ExtensionConfig;
import hunt.http.codec.websocket.model.extension.AbstractExtension;

// import hunt.http.utils.lang.QuotedStringTokenizer;

import hunt.lang.exception;
import hunt.util.functional;
import hunt.string;

import std.conv;

/**
*/
class IdentityExtension : AbstractExtension {
    private string id;

    this() {
        start();
    }

    string getParam(string key) {
        return getConfig().getParameter(key, "?");
    }

    override string getName() {
        return "identity";
    }

    override void incomingError(Exception e) {
        // pass through
        nextIncomingError(e);
    }

    // override
    void incomingFrame(Frame frame) {
        // pass through
        nextIncomingFrame(frame);
    }

    // override
    void outgoingFrame(Frame frame, Callback callback) {
        // pass through
        nextOutgoingFrame(frame, callback);
    }

    override void setConfig(ExtensionConfig config) {
        super.setConfig(config);
        StringBuilder s = new StringBuilder();
        s.append(config.getName());
        s.append("@").append(to!string(toHash(), 16));
        // s.append("@").append(Integer.toHexString(hashCode()));
        s.append("[");
        bool delim = false;
        foreach (string param; config.getParameterKeys()) {
            if (delim) {
                s.append(';');
            }
            string str = QuotedStringTokenizer.quoteIfNeeded(config.getParameter(param, ""), ";=");
            s.append(param).append('=').append(str);
            delim = true;
        }
        s.append("]");
        id = s.toString();
    }

    override string toString() {
        return id;
    }

    override protected void initialize() {

    }

    override protected void destroy() {

    }
}