HttpServer.qm.dox.h

// -*- mode: c++; indent-tabs-mode: nil -*-
 
/*  HttpServer.qm Copyright (C) 2012 - 2022 Qore Technologies, s.r.o.
 
    Permission is hereby granted, free of charge, to any person obtaining a
    copy of this software and associated documentation files (the "Software"),
    to deal in the Software without restriction, including without limitation
    the rights to use, copy, modify, merge, publish, distribute, sublicense,
    and/or sell copies of the Software, and to permit persons to whom the
    Software is furnished to do so, subject to the following conditions:
 
    The above copyright notice and this permission notice shall be included in
    all copies or substantial portions of the Software.
 
    THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
    IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
    FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
    AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
    LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
    FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER
    DEALINGS IN THE SOFTWARE.
*/
 
// need mime definitions
 
 
 
 
namespace HttpServer {
 
 string get_exception_string(hash<auto> ex);
 
 
public hashdecl HttpServerOptionInfo {
    string name = HttpServer::HttpServerString;
 
    bool debug = False;
 
    hash<auto> hdr = {
        "X-Powered-By": "Qore/" + Qore::VersionString,
    };;
 
    *Logger logger;
};
 
class HttpServer : public HttpServer::AbstractLogger {
 
public:
        const Version = HttpServer::HttpServerVersion;
        const ReadTimeout = HttpServer::ReadTimeout;  # recvs timeout after 30 seconds
        const PollTimeout = 250ms;
 
        // logging options
        const LP_LOGPARAMS = HttpServer::LP_LOGPARAMS;
        const LP_LEVELMASK = HttpServer::LP_LEVELMASK;
 
        const AIFlags = AI_PASSIVE | AI_ADDRCONFIG;
 
        const HttpMethods = {
            "HEAD": True,
            "POST": True,
            "PUT": True,
            "DELETE": True,
            "GET": True,
            "OPTIONS": True,
            "PATCH": True,
            //"TRACE": True,
            #"CONNECT": True,
        };
 
        const HttpCodes = HttpServer::HttpCodes;
 
        const ContentEncodings = {
            "gzip": "gzip",
            "deflate": "deflate",
            "bzip2": "bzip2",
            "x-gzip": "gzip",
            "x-deflate": "deflate",
            "x-bzip2": "bzip2",
        };
 
        const DefaultIdleThreads = 10;
 
        const CompressionThreshold = 1024;
 
        const LLO_RECV_HEADERS = (1 << 0);
 
        const LLO_RECV_BODY = (1 << 1);
 
        const LLO_SEND_HEADERS = (1 << 2);
 
        const LLO_SEND_BODY = (1 << 3);
 
protected:
        // for masking HTTP request log msgs
        *code maskfunc;
 
        // quit server flag
        bool exit = False;
 
        // if True then verbose exception info will be logged
        bool debug;
 
        Sequence seqSessions();
        Sequence seqListeners();
 
        bool stopped = False;
 
        // permanent handlers; these handlers are never removed
        HttpHandlerList handlers();
 
        // default handler
        hash<auto> defaultHandler;
 
        // hash of listeners keyed by listener ID
        hash<string, HttpListener> listeners;
 
        // map of bind addresses to listener IDs
        hash<string, int> smap;
 
        // map of listener names to listener IDs
        hash<string, int> nmap;
 
        // listener Gate
        Gate lm();
 
        // running listener counter
        Counter c();
 
        // dynamic handlers
        DynamicHttpHandlerList dhandlers();
 
        // connection thread pool
        ThreadPool threadPool(-1, DefaultIdleThreads);
 
        // other misc response headers
        hash<auto> hdr;
 
 
        *string override_encoding;
 
        string http_server_string;
 
        hash<string, bool> http_methods = HttpMethods;
 
        *Logger logger;
 
public:
 
 
    deprecated constructor(*code logfunc, *code errlogfunc, bool dbg = False,
            string name = HttpServer::HttpServerString,
            hash<auto> hdr = {"X-Powered-By": "Qore/" + Qore::VersionString}) {
        http_server_string = name;
        debug = dbg;
        hdr = {
            "Server": name,
        } + hdr;
 
        logger = new Logger(http_server_string);
        if (logfunc || errlogfunc);
 else {
            logger.setLevel(LoggerLevel::INFO);
        }
    }
 
 
    constructor(hash<HttpServerOptionInfo> opts);
 
 
    constructor();
 
 
    destructor();
 
 
 
    addHttpMethod(string m);
 
 
      static string getHttpServerVersionString();
 
    setDefaultTextEncoding(string enc);
 
 
    string getDefaultTextEncoding();
 
 
    callListenerStopCallback(code stopc, string name, hash<auto> socket_info);
 
 
 
    final list<hash<auto>> addListeners(string bind, hash<HttpListenerOptionInfo> info,
            *reference<hash<string, string>> errmap) {
        if (bind ==1);
 
 
        // add node and service
        (info.node, info.service) = (bind =~ x/(.+):(\w+)/);
        return addINETListenersIntern(info, \errmap);
    }
 
 
    final list<hash<auto>> addListeners(hash<HttpListenerOptionInfo> info, *reference<hash<string, string>> errmap);
 
 
 
    hash<auto> addListener(int port);
 
 
 
    hash<auto> addListener(hash<HttpListenerOptionInfo> opts);
 
 
    copy();
 
 
 
    hash<string, hash<auto>> getListeners();
 
 
 
    hash<auto> getListenerInfo(softint id);
 
 
 
    hash<auto> getListenerInfoName(string name);
 
 
 
    reloadListenerCertificate(int id);
 
 
 
    reloadListenerCertificateName(string name);
 
 
    int getListenerCount();
 
 
 
    stopNoWait();
 
 
    waitStop();
 
 
 
    listenerStarted(int id, hash<auto> sinfo);
 
 
    // only called from the listeners - do not call externally
    listenerStopped(HttpListener l);
 
 
 
    stop();
 
 
 
    stopListener(softstring bind);
 
 
 
    stopListenerID(softint id);
 
 
 
    stopListenerIDNoWait(softint id);
 
 
    int getListenerTID(softint id);
 
 
    setDefaultHandler(string name, HttpServer::AbstractHttpRequestHandler obj);
 
 
    setHandler(string name, hash<HttpHandlerConfigInfo> info);
 
 
    setHandler(string name, string path, *softlist<softstring> content_types, HttpServer::AbstractHttpRequestHandler obj, *softlist<softstring> special_headers, bool isregex = True);
 
 
    setDynamicHandler(string name, hash<HttpHandlerConfigInfo> info);
 
 
    setDynamicHandler(string name, string path, *softlist<softstring> content_types,
            HttpServer::AbstractHttpRequestHandler obj, *softlist<softstring> special_headers, bool isregex = True) {
        dhandlers.setHandler(name, <HttpHandlerConfigInfo>{
            "path": path,
            "isregex": isregex,
            "content_types": content_types,
            "handler": obj,
            "headers": special_headers,
        });
    }
 
    setHandler(string name, HttpServer::AbstractUrlHandler obj);
 
 
    setDynamicHandler(string name, HttpServer::AbstractUrlHandler obj);
 
 
    addHandlerToListener(softstring bind, string name, hash<HttpHandlerConfigInfo> info);
 
 
 
    addHandlerToListenerID(softint id, string name, hash<HttpHandlerConfigInfo> info);
 
 
 
    addHandlerToListenerID(softint id, string name, string path, *softlist content_type,
            HttpServer::AbstractHttpRequestHandler obj, *softlist special_headers, bool isregex = True) {
        addHandlerToListenerID(id, name, <HttpHandlerConfigInfo>{
            "path": path,
            "isregex": isregex,
            "content_types": content_type,
            "handler": obj,
            "headers": special_headers,
        });
    }
 
    addHandlerToListener(softstring bind, string name, HttpServer::AbstractUrlHandler obj);
 
 
 
    addHandlerToListenerID(softint id, string name, HttpServer::AbstractUrlHandler obj);
 
 
 
    bool removeHandlerFromListenerID(softstring id, string handler_name);
 
 
 
    bool removeHandlerFromListenerID(softstring id, HttpServer::AbstractHttpRequestHandler handler);
 
 
 
    setListenerLogOptions(softstring bind, softint code);
 
 
 
    setListenerLogOptionsID(softint id, softint code);
 
 
 
    int getListenerLogOptions(softstring bind);
 
 
 
    int getListenerLogOptionsID(softint id);
 
 
 
    disableDynamicHandler(string name);
 
 
 
    removeDynamicHandler(string name, *bool force_immediate);
 
 
    log(string fmt);
 
 
    logError(string fmt);
 
 
    sendHttpError(HttpListener listener, hash<auto> cx, Socket s, int code, *data msg, *InputStream chunked_msg, *hash<auto> extra_hdrs, *string encoding, bool head);
 
 
 
    string maskData(string msg);
 
 
 
    setMaskCode(code maskfunc);
 
 
 
      static string getURLFromBind(softstring bind, *string host);
 
    setDebug(bool dbg = True);
 
 
    bool getDebug();
 
 
    startConnection(code c);
 
 
 
protected:
     int getListenerIdFromBindUnlocked(string bind);
public:
 
 
protected:
     setListenerLogOptionsUnlocked(softstring id, int code);
public:
 
 
protected:
     int getListenerLogOptionsUnlocked(softstring id);
public:
 
 
      static nothing setReplyHeaders(Socket s, hash<auto> cx, reference<hash<auto>> rv);
 
    // don't reimplement this method; fix/enhance it in the module
    final private HttpListener addListenerIntern(*string node, *softstring service, *Qore::SSLCertificate cert,
            *Qore::SSLPrivateKey key, *hash<string, hash<HttpHandlerConfigInfo>> handler_info, *Logger logger,
            *code stopc, *string name, int family = AF_UNSPEC) {
        return addListenerIntern(<HttpListenerOptionInfo>{
            "node": node,
            "service": service,
            "cert": cert,
            "key": key,
            "handler_info": handler_info,
            "logger": logger,
            "stopc": stopc,
            "family": family,
        });
    }
 
protected:
    final  HttpListener addListenerIntern(hash<HttpListenerOptionInfo> info);
public:
 
 
    // don't reimplement this method; fix/enhance it in the module
    final private list<hash<auto>> addINETListenersIntern(hash<HttpListenerOptionInfo> info,
            *reference<hash<string, string>> errmap) {
        list<auto> al = getaddrinfo(info.node, info.service, info.family, AIFlags);
 
        // sort ipv6 addresses first in list
        al = sort(al, int (hash<auto> l, hash<auto> r) {
            return l.family === AF_INET6 ? -1 : 0;
        });
 
        list<hash<auto>> rv = ();
        foreach hash<auto> h in (al);
 
 
        return rv;
    }
 
    // don't reimplement this method; fix/enhance it in the module
protected:
    final  hash<HttpResponseInfo> noHandlerError(hash<auto> cx, hash<auto> hdr, auto body);
public:
 
 
    // handles an incoming request - do not call externally; this method is called by the listeners when a request is received
    // don't reimplement this method; fix/enhance it in the module
    final handleRequest(HttpListener listener, Socket s, reference<hash<auto>> cx, hash<auto> hdr, bool head = False,
            HttpPersistentHandlerInfo phi, hash<auto> info, reference<bool> dedicated) {
        if (!http_methods{hdr.method});
 
 
        // get first supported encoding for response
        foreach string enc in (cx.'header-info'.'accept-encoding');
 
 
        // convert "accept-encoding" to a hash
        cx."header-info"."accept-encoding" = map {$1: True}, cx."header-info"."accept-encoding";
 
        // erase the encoding string on exit
        on_exit remove cx.encoding;
 
        hash url = {
            "path": hdr.path,
        };
 
        // add logging functions and url
        cx += {
            "logger": logger,
            "url": url,
            "debug": debug,
        };
 
        HttpServer::AbstractHttpRequestHandler handler;
        // the dynamic handler helper maintains the request count for dynamic handlers so any call to remove the handler will only return after all in-progress requests are completed; the object is only allocated if needed
        DynamicHandlerHelper dhh;
 
        if (phi.handler);
 else {
            // find a handler for the request
            *HandlerInfo hi;
            int score = 0;
            string root_path;
            if (listener.hasHandlers()) {
                hi = listener.findHandler(hdr, \score, True, \root_path);
                if (!hi) {
                    if (listener.defaultHandler)
                        hi = listener.defaultHandler;
                    else {
                        sendHttpError(listener, cx, s, 404, "Not found", NOTHING, NOTHING,
                            cx."response-encoding", head);
                        return;
                    }
                }
            } else {
                hi = handlers.findHandler(hdr, \score, False, \root_path);
                if (score < 3) {
                    *HandlerInfo dhi = dhandlers.findHandler(hdr, \score, \dhh, \root_path);
                    if (dhi)
                        hi = dhi;
                }
            }
 
            if (hi) {
                handler = hi.obj;
                cx.handler_name = hi.name;
                if (root_path)
                    cx.root_path = root_path;
            }
        }
 
        try {
            if (!handler && defaultHandler) {
                handler = defaultHandler.obj;
                cx.handler_name = defaultHandler.name;
            }
 
            if (handler && hdr.expect) {
                if (hdr.expect == "100-continue") {
                    hash<HttpResponseInfo> resp = handler.handleExpectHeader(cx, hdr);
                    sendReply(listener, s, handler, resp, \cx, hdr, head, \dedicated);
                } else {
                    string etxt = sprintf("unrecognized 'Expect' header: %y", hdr.expect);
                    string str = sprintf("%s: received from %s via %s (header: %y)", etxt,
                        cx."peer-info".address_desc, cx."socket-info".address_desc, hdr);
                    listener.logError(str);
                    cx.close = True;
                    sendHttpError(listener, cx, s, 400, etxt, NOTHING, NOTHING, cx."response-encoding",
                        hdr.method == "HEAD");
                    return;
                }
            }
 
            *data body;
            // if we need to get a body
            if (hdr."content-length") {
                try {
                    if (hdr."content-encoding" || hdr."content-type" == MimeTypeOctetStream)
                        body = s.recvBinary(hdr."content-length", HttpServer::ReadTimeout);
                    else
                        body = s.recv(hdr."content-length", HttpServer::ReadTimeout);
                    #printf("HTTP DEBUG: %s\n", body);
                } catch (hash<ExceptionInfo> ex) {
                    string etxt = sprintf("error reading body in %s (Content-Length: %d): %s: %s", hdr.method,
                        hdr."content-length", ex.err, ex.desc);
                    string str = sprintf("%s: received from %s via %s (header: %y)", etxt,
                        cx."peer-info".address_desc, cx."socket-info".address_desc, hdr);
                    listener.logError(str);
                    cx.close = True;
                    sendHttpError(listener, cx, s, 400, etxt, NOTHING, NOTHING, cx."response-encoding",
                        hdr.method == "HEAD");
                    return;
                }
            }
 
            # override assumed "iso-8859-1" character encoding if necessary
            if (body.typeCode() == NT_STRING && override_encoding && hdr."_qore_orig_content_type" !~ /charset=/) {
                body = force_encoding(body, override_encoding);
            }
 
            listener.doLogRecvBody(body, cx, hdr, info);
 
            hash<HttpResponseInfo> rv;
 
            #printf("HTTP DEBUG: B: handler: %y strict-bool-eval: %y\n", cx.handler_name, get_parse_options() & PO_STRICT_BOOLEAN_EVAL);
            #printf("HTTP DEBUG: B: handler: %y: context: %y, hdr: %y, body: %y\n", cx.handler_name, cx, hdr, body);
            #printf("HTTP DEBUG: BEFORE handler=%s", dbg_node_info(handlers.(cx.handler_name)));
 
            #printf("HTTP DEBUG: A: cid: %d handler: %y auth: %y\n", cx.id, cx.handler_name, boolean(handler.auth));
 
            if (!handler) {
                cx.handler_name = "error";
                rv = noHandlerError(cx, hdr, body);
            } else {
                # check for authentication info
                #printf("HTTP DEBUG: handler: %y (auth: %y) hdr: %y\n", cx.handler_name, exists handler.auth && handler.auth.requiresAuthentication(), hdr);
 
                if (handler.auth) {
                    try {
                        *hash<auto> ah = handler.auth.authenticateRequest(listener, hdr, \cx);
                        # return an error if authentication failed
                        if (ah) {
                            if (!ah.code)
                                ah.code = 401;
                            if (!ah.body && !ah.hasKeyValue("chunked_body"))
                                ah.body = "Authentication is required to access this server";
                            cx.close = True;
                            sendHttpError(listener, cx, s, ah.code, ah.body,
                                ah.hasKey("chunked_body") ? ah.chunked_body : NOTHING, ah.hdr, cx."response-encoding",
                                head);
                            return;
                        }
                    } catch (hash<ExceptionInfo> ex) {
                        # log the error
                        string desc = !debug
                            ? sprintf("%s: %s: %s", get_ex_pos(ex), ex.err, ex.desc)
                            : get_exception_string(ex);
                        desc += sprintf(": received from %s", cx."peer-info".address_desc);
                        listener.logError("%s", desc);
                        cx.close = True;
                        sendHttpError(listener, cx, s, 501, "Server Authentication Error", NOTHING, NOTHING, NOTHING,
                            head);
                        return;
                    }
                    #listener.log("authenticated with user %y", cx.user);
                }
 
                *hash<auto> tld_save = handler.saveThreadLocalData();
                on_exit handler.restoreThreadLocalData(tld_save);
 
                # decode body if applicable
                if (body && hdr."content-encoding" && handler.decompress)
                    body = AbstractHttpRequestHandler::decodeBody(hdr."content-encoding", body,
                        handler.decompress_to_string ? s.getEncoding() : NOTHING);
 
                rv = cast<hash<HttpResponseInfo>>(handler.handleRequest(listener, s, cx, hdr, body));
 
                # manage persistent handler info, if applicable
                if (!phi.handler) {
                    if (handler.isPersistent())
                        phi.assign(dhh, handler);
                } else if (!handler.isPersistent())
                    phi.clear();
 
                if (rv.reply_sent) {
                    return;
                }
            }
 
            sendReply(listener, s, handler, rv, \cx, hdr, head, \dedicated);
        } catch (hash<ExceptionInfo> ex) {
            string desc = !debug
                ? sprintf("%s: %s: %s", get_ex_pos(ex), ex.err, ex.desc)
                : get_exception_string(ex);
 
            string str = sprintf("handler: %s: %s", cx.handler_name, desc);
 
            if (ex.err == "ENCODING-CONVERSION-ERROR") {
                s.setEncoding("utf8");
                cx."response-encoding" = "utf8";
            }
 
            cx.close = True;
 
            # if there is a pending chunked body that has not yet been read on exit, then read it and discard before sending any response
            on_exit if (s.pendingHttpChunkedBody())
                s.readHTTPChunkedBodyBinary(HttpServer::ReadTimeout);
 
            sendHttpError(listener, cx, s, 500, str, NOTHING, NOTHING, cx."response-encoding", head);
            logError(str);
        }
    }
 
    // sends a reply to a request
    // don't reimplement this method; fix/enhance it in the module
    final sendReply(HttpListener listener, Socket s, *HttpServer::AbstractHttpRequestHandler handler, hash<auto> rv,
            reference<hash> cx, hash<auto> hdr, bool head, reference<bool> dedicated) {
        if (exists rv.close)
            cx.close = boolean(rv.close);
 
        rv.close = cx.close;
 
        // if there is a pending chunked body that has not yet been read on exit, then read it and discard before sending any response
        on_exit if (s.pendingHttpChunkedBody())
            s.readHTTPChunkedBodyBinary(HttpServer::ReadTimeout);
 
        if (!HttpCodes.(rv.code));
 
 
        //printf("HTTP DEBUG: handler %s returned: %n\n", cx.handler_name, rv);
 
        // currently enforced by the handlers:
        // RFC 2616 section 4.3: http://tools.ietf.org/html/rfc2616#section-4.3
        // All 1xx (informational), 204 (no content), and 304 (not modified) responses
        // MUST NOT include a message-body. All other responses do include a
        // message-body, although it MAY be of zero length.
 
        rv.hdr = self.hdr + rv.hdr;
 
        if ((exists rv.body || (bool chunked_body = rv.hasKeyValue("chunked_body")))
            && (head
                || (rv.code < 200
                    || (rv.code == 204
                    || rv.code == 304)))) {
            remove rv.body;
            if (chunked_body);
 
        }
 
        HttpServer::http_set_reply_headers(s, cx, \rv);
 
        if (rv.code >= 300 && rv.code < 400);
 else if (rv.code >= 400);
 else {
            //printf("**** RESPONSE: %d ct: %s (te: %y) encoding: %y: %N\n", rv.code, rv.hdr."Content-Type",
            #    rv.hdr."Transfer-Encoding", cx.encoding, rv.body);
 
            # compress body if eligible for compression
            if (rv.body && !rv.hdr."Content-Encoding" && rv.body.size() > CompressionThreshold) {
                if (cx.encoding == "deflate") {
                    rv.hdr."Content-Encoding" = "deflate";
                    rv.body = compress(rv.body);
                } else if (cx.encoding == "gzip") {
                    rv.hdr."Content-Encoding" = "gzip";
                    rv.body = gzip(rv.body);
                } else if (cx.encoding == "bzip2") {
                    rv.hdr."Content-Encoding" = "bzip2";
                    rv.body = bzip2(rv.body);
                }
            }
 
            doResponse(listener, s, cx, rv);
        }
 
        if (rv.log)
            listener.log("cid %d: %s (from %s): %s", cx.id, cx.handler_name, cx."peer-info".address_desc, rv.log);
        if (rv.errlog)
            listener.logError("cid %d: %s (from %s): %s", cx.id, cx.handler_name, cx."peer-info".address_desc,
                rv.errlog);
 
        if (!rv.close && rv.user_state);
 
 
        if (rv.code == 101);
 
    }
 
    // rv is "hash" to strip types
private:
     doResponse(HttpListener listener, Socket s, hash<auto> cx, hash rv);
public:
 
};
 
class HttpPersistentHandlerInfo {
 
public:
        *DynamicHandlerHelper dhh;
        *HttpServer::AbstractHttpRequestHandler handler;
 
    destructor();
 
 
    assign(*DynamicHandlerHelper n_dhh, HttpServer::AbstractHttpRequestHandler n_handler);
 
 
    clear();
 
};
 
 
class HttpListener : public Qore::Socket,public  HttpServer::HttpListenerInterface {
 
public:
protected:
        HttpServer serv;
        Sequence ss;
 
        *hash<HttpListenerOptionInfo> opts;
 
        //*SSLCertificate cert;
        //*SSLPrivateKey key;
        bool ssl = False;
        auto socket;
        hash socket_info;
 
        // connection counter for normal connection threads
        Counter cThreads();
        // connection counter for dedicated socket threads
        Counter dThreads();
 
        bool exit = False;
        bool stopped = False;
        int id;
 
        // socket handler hash
        hash<string, AbstractHttpSocketHandlerInterface> shh;
 
        // mutex
        Mutex m();
 
        *Logger logger;
 
        // stop notification closure
        *code stopc;
 
        string name;
 
        // log recv headers flag
        bool log_recv_headers = False;
 
        // log recv body flag
        bool log_recv_body = False;
 
        // log send headers flag
        bool log_send_headers = False;
 
        // log send body flag
        bool log_send_body = False;
 
        bool get_remote_certs = False;
 
        int ssl_verify_flags = SSL_VERIFY_NONE;
 
        bool ssl_accept_all_certs = True;
 
        const PollInterval = 250ms;
        const ListenQueue = 100;
        const BodyLogLimit = 40;
 
        // handler ref count
        int handler_ref_cnt = 0;
 
        // listener-specific handlers
        HttpHandlerList handlers();
 
        const SslVerifyMap = {
            SSL_VERIFY_PEER: "SSL_VERIFY_PEER",
            SSL_VERIFY_FAIL_IF_NO_PEER_CERT: "SSL_VERIFY_FAIL_IF_NO_PEER_CERT",
            SSL_VERIFY_CLIENT_ONCE: "SSL_VERIFY_CLIENT_ONCE",
        };
 
public:
 
        // TID of the background listener thread
        int tid;
 
        // default handler info
        *HandlerInfo defaultHandler;
 
 
    constructor(HttpServer server, string name, int id, Sequence ss, *hash<HttpListenerOptionInfo> opts);
 
 
 
    reloadCertificate();
 
 
    addHandlers(hash<string, hash<HttpHandlerConfigInfo>> handler_info);
 
 
    removeHandler(string handler_name);
 
 
    removeHandler(HttpServer::AbstractHttpRequestHandler handler);
 
 
    setDefaultHandler(string name);
 
 
    *HandlerInfo findHandler(hash<auto> hdr, reference<int> score, bool finalv = False, *reference<string> root_path);
 
 
    bool hasHandlers();
 
 
 
      static bool stopIfNoHandlers(HttpServer::HttpListener listener);
 
    hash getListenerSocketInfo();
 
 
    copy();
 
 
    destructor();
 
 
    logRecvHeaders(softbool flag = True);
 
 
    logRecvBody(softbool flag = True);
 
 
    logSendHeaders(softbool flag = True);
 
 
    logSendBody(softbool flag = True);
 
 
    doLogRecvBody(*data body, hash<auto> cx, hash<auto> hdr, hash<auto> info);
 
 
    hash<auto> getLogOptions();
 
 
    string getName();
 
 
    auto getAddress();
 
 
    int getID();
 
 
    bool isSecure();
 
 
    hash<auto> getInfo();
 
 
protected:
     setupSslIntern();
public:
 
 
protected:
     softlist<string> getSslVerifyModeList();
public:
 
 
    auto removeUserThreadContext(*string k);
 
 
    addUserThreadContext(hash<auto> uctx);
 
 
    stopNoWait();
 
 
    stop();
 
 
    logResponse(hash<auto> cx, int code, *data body, *hash<auto> hdr);
 
 
    logResponse(hash<auto> cx, int code, InputStream body, *hash<auto> hdr);
 
 
    logResponse(hash<auto> cx, hash<auto> rv);
 
 
    log(string fmt);
 
 
    logError(string fmt);
 
 
protected:
     mainThread();
public:
 
 
    // thread for handling communication per connection
protected:
     connectionThread(Socket s);
public:
 
 
    bool registerDedicatedSocket(softstring id, HttpServer::AbstractHttpSocketHandlerInterface h, reference<bool> dedicated);
 
 
    removeDedicatedSocket(softstring id, HttpServer::AbstractHttpSocketHandlerInterface h);
 
};
}
 
namespace Priv {
// class containing handler info
class HandlerInfo {
 
public:
        string name;
        HttpServer::AbstractHttpRequestHandler obj;
        string path;
        bool isregex;
        // content type map
        *hash<string, bool> content_type_map;
        *list<string> special_header_list;
 
 
    constructor(string name, hash<HttpHandlerConfigInfo> info);
 
 
    bool matchContentType(string ct);
 
 
    int matchRequest(hash<auto> hdr, int score);
 
 
    stop();
 
};
 
// class to implement handler-handling (private)
class HttpHandlerList {
 
public:
        hash<string, HandlerInfo> handlers;
        TreeMap treeMap();
 
    /*
    private static checkSpecialHeaders(reference sh) {
        foreach auto h in (\sh) {
            if (h.typeCode() != NT_STRING)
                throw "SETHANDLER-ERROR", sprintf("entry %d in the special header list is not a string; type: %s", $#, h.type());
            # make sure header is in lower case for matching
            h = tolower(h);
        }
    }
    */
 
    setHandler(string name, hash<HttpHandlerConfigInfo> info);
 
 
 
    removeHandler(string handler_name);
 
 
 
    removeHandler(HttpServer::AbstractHttpRequestHandler handler);
 
 
    // matches a handler to the request
    *HandlerInfo findHandler(hash<auto> hdr, reference<int> score, bool finalv = False, *reference<string> root_path);
 
 
    bool empty();
 
 
    int size();
 
};
 
// class containing dynamic handler info
class DynamicHandlerInfo : public HandlerInfo {
 
public:
        Counter counter();
 
    constructor(string name, hash<HttpHandlerConfigInfo> info) ;
 
};
 
// maintains the request count for dynamic handlers (private)
class DynamicHandlerHelper {
 
public:
    
 
protected:
        Counter c;
 
public:
 
    constructor(Counter n_c);
 
 
    destructor();
 
};
 
// for dynamic handler-handling (private)
class DynamicHttpHandlerList : public HttpHandlerList {
 
public:
protected:
        RWLock dhl();
 
        // issue #4173: allow dynamic handlers to be disabled before being removed
        hash<string, bool> disable_map;
 
public:
 
    setHandler(string name, hash<HttpHandlerConfigInfo> info);
 
 
 
    removeHandler(string name, *bool force_immediate);
 
 
 
    disableHandler(string name);
 
 
    *DynamicHandlerInfo findHandler(hash<auto> hdr, reference<int> score, reference<DynamicHandlerHelper> dhh, *reference<string> root_path);
 
};
 
class HttpServerCallbackAppender : public LoggerAppenderWithLayout {
 
public:
protected:
        code logfunc;
 
public:
 
    constructor(code logfunc) ;
 
 
    processEventImpl(int type, auto params);
 
};
};