SmartPDCode/f407/applications/web.c

#include "web.h"
#include "mongoose.h"
#include "thread.h"
#include "cfg.h"

typedef void (*http_fn_t)(void *arg);


#ifdef USE_MG714
typedef struct mg_tls_opts mg_tls_t;
#else
typedef struct mg_serve_http_opts mg_opts_t;
#define MG_PATH_MAX  128
#endif

typedef struct {
    struct mg_connection *c;
    int     ev;
    void    *ev_data;
}mg_stream_t;

typedef struct {
    pthread_t       tid;

#ifdef USE_MG714
    mg_tls_t        tls;
#else
    mg_opts_t       opts;
#endif
    
    char            rootDir[MG_PATH_MAX];
}web_handle_t;
static web_handle_t webHandle={0};


static void http_fn(struct mg_connection *c, int ev, void *ev_data)
{
    int i,j,flag=0;
    web_handle_t *h=&webHandle;
    mg_stream_t s={c,ev,ev_data};

#ifdef USE_MG714
    if (ev == MG_EV_HTTP_MSG) {
        struct mg_http_serve_opts opts = {.root_dir = h->rootDir};
        mg_http_serve_dir(c, ev_data, &opts);
    }
    else if(ev == MG_EV_ACCEPT) {
        if (c->fn_data) {
            mg_tls_init(c, &h->tls);
        }
    }
#else
    if (ev == MG_EV_HTTP_REQUEST) {
        mg_serve_http(c, (struct http_message *)ev_data, h->opts);
    }
#endif
}
static void *web_thread(void *arg)
{
    thread_handle_t *th=(thread_handle_t*)arg;
    
    struct mg_mgr mgr;
    struct mg_connection *nc;
    const char *http_addr="http://[::]:80";
    const char *https_addr="https://[::]:443";
    web_handle_t *h=&webHandle;

#ifdef USE_MG714
    //mg_log_set(MG_LL_DEBUG);
    mg_mgr_init(&mgr);

    //sys_get_path(mh->rootDir, WEB_ROOT);
    strcpy(h->rootDir, "/web");

    if (mg_http_listen(&mgr, http_addr, http_fn, NULL) == NULL) {
        MG_ERROR(("cannot listen on %s\n", http_addr));
        return NULL;
    }

    if (mg_http_listen(&mgr, https_addr, http_fn, (void*)1) == NULL) {
        MG_ERROR(("cannot listen on %s\n", https_addr));
        return NULL;
    }
    
    //mh->tls.cert = mg_str(file_load2("/root/run/app/cert/server.crt",0));
    //mh->tls.key = mg_str(file_load2("/root/run/app/cert/server.key",0));
    //mh->tls.name = mg_url_host(https_addr);
#else
    mg_mgr_init(&mgr, NULL);
    nc = mg_bind(&mgr, "80", http_fn);

    strcpy(h->rootDir, "/web");
    
    mg_set_protocol_http_websocket(nc);
    h->opts.document_root = h->rootDir;
    h->opts.enable_directory_listing = "yes";


#endif
    while(th->quit==0) {
        mg_mgr_poll(&mgr, 200);
    }
    mg_mgr_free(&mgr);
    
    pthread_exit(NULL);
}


int web_init(void)
{
    thread_start(THREAD_ID_WEB, web_thread, NULL);
    return 0;
}