Skip to content

Add Web Admin Dashboard, JSON API, and Basic Auth #22

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
NangenX wants to merge 4 commits into
base: master
Choose a base branch
from
Open

Add Web Admin Dashboard, JSON API, and Basic Auth #22

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
4 commits
Select commit Hold shift + click to select a range
e5d303b
添加 JSON 统计信息支持，更新 CMake 文件以包含新源文件
Dec 14, 2025
8f2f926
移除未使用的头文件，并优化管理员页面内存显示布局
Dec 14, 2025
7eacd19
添加对 unistd.h 的包含以支持系统调用
Dec 14, 2025
d5d2947
添加基本认证支持以保护管理员页面和统计信息接口
Dec 14, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 1 addition & 0 deletions src/CMakeLists.txt
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,6 +1,7 @@

set(MSD_LITE_BIN msd_lite.c
msd_lite_stat_text.c
msd_lite_stat_json.c
stream_sys.c
liblcb/src/net/socket.c
liblcb/src/net/socket_address.c
Expand Down
117 changes: 117 additions & 0 deletions src/msd_lite.c
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -71,6 +71,7 @@
#include "utils/cmd_line_daemon.h"
#include "utils/sys_res_limits_xml.h"
#include "msd_lite_stat_text.h"
#include "msd_lite_stat_json.h"



Expand All @@ -97,6 +98,9 @@ struct prog_settings {
str_src_conn_params_t src_conn_params; /* Stream hub source connection params. */

uintptr_t log_fd; // log file descriptor

uint8_t *admin_auth_basic; /* Base64 encoded "user:pass" */
size_t admin_auth_basic_size;
};
static struct prog_settings g_data;

Expand Down Expand Up @@ -272,6 +276,30 @@ msd_src_conn_profile_load(const uint8_t *data, size_t data_size, void *conn) {
return (0);
}

static void
base64_encode(const uint8_t *src, size_t len, uint8_t *dst) {
Copy link
Owner

@rozhuk-im rozhuk-im Dec 14, 2025 •
edited
Loading

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

There is base64 encoder/decoder in liblcb: /include/utils/base64.h

static const char b64[] = "ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/";
while (len >= 3) {
*dst++ = b64[src[0] >> 2];
*dst++ = b64[((src[0] & 0x03) << 4) | (src[1] >> 4)];
*dst++ = b64[((src[1] & 0x0F) << 2) | (src[2] >> 6)];
*dst++ = b64[src[2] & 0x3F];
src += 3; len -= 3;
}
if (len > 0) {
*dst++ = b64[src[0] >> 2];
if (len == 1) {
*dst++ = b64[(src[0] & 0x03) << 4];
*dst++ = '=';
} else {
*dst++ = b64[((src[0] & 0x03) << 4) | (src[1] >> 4)];
*dst++ = b64[(src[1] & 0x0F) << 2];
}
*dst++ = '=';
}
*dst = 0;
}



int
Expand Down Expand Up @@ -396,6 +424,36 @@ main(int argc, char *argv[]) {
msd_src_profile_load(data, data_size, &g_data.src_params);
msd_src_conn_profile_load(data, data_size, &g_data.src_conn_params);
}

/* Admin Auth Settings */
{
const uint8_t *adm_user = NULL, *adm_pass = NULL;
size_t adm_user_len = 0, adm_pass_len = 0;

MSD_CFG_GET_VAL_DATA(NULL, &adm_user, &adm_user_len, "admin", "user", NULL);
MSD_CFG_GET_VAL_DATA(NULL, &adm_pass, &adm_pass_len, "admin", "password", NULL);

if (adm_user && adm_pass && adm_user_len > 0 && adm_pass_len > 0) {
size_t up_len = adm_user_len + 1 + adm_pass_len;
uint8_t *up_buf = malloc(up_len + 1);
if (up_buf) {
memcpy(up_buf, adm_user, adm_user_len);
up_buf[adm_user_len] = ':';
memcpy(up_buf + adm_user_len + 1, adm_pass, adm_pass_len);
up_buf[up_len] = 0;

size_t b64_len = ((up_len + 2) / 3) * 4;
g_data.admin_auth_basic = malloc(b64_len + 1);
if (g_data.admin_auth_basic) {
base64_encode(up_buf, up_len, g_data.admin_auth_basic);
g_data.admin_auth_basic_size = b64_len;
syslog(LOG_NOTICE, "Admin Basic Auth enabled.");
}
free(up_buf);
}
}
}

error = str_hubs_bckt_create(tp, PACKAGE_NAME"/"PACKAGE_VERSION, &g_data.hub_params,
&g_data.src_params, &g_data.shbskt);
if (0 != error) {
Expand Down Expand Up @@ -600,6 +658,7 @@ msd_http_srv_on_req_rcv_cb(http_srv_cli_p cli, void *udata __unused,
str_src_conn_params_t src_conn_params;
static const char *cttype = "Content-Type: text/plain\r\n"
"Pragma: no-cache";
static const char *auth_fail_hdrs = "WWW-Authenticate: Basic realm=\"MSD Lite Admin\"\r\n";

SYSLOGD_EX(LOG_DEBUG, "...");

Expand Down Expand Up @@ -643,6 +702,64 @@ msd_http_srv_on_req_rcv_cb(http_srv_cli_p cli, void *udata __unused,
return (HTTP_SRV_CB_NONE);
}

/* JSON Statistic request. */
if (HTTP_REQ_METHOD_GET == req->line.method_code &&
0 == mem_cmpin_cstr("/api/stats", req->line.abs_path, req->line.abs_path_size)) {

/* Auth Check */
if (g_data.admin_auth_basic) {
const uint8_t *val;
size_t val_len;
if (0 != http_hdr_val_get(req->hdr, req->hdr_size, (const uint8_t*)"Authorization", 13, &val, &val_len) ||
val_len < 6 ||
0 != memcmp(val, "Basic ", 6) ||
val_len - 6 != g_data.admin_auth_basic_size ||
0 != memcmp(val + 6, g_data.admin_auth_basic, g_data.admin_auth_basic_size)) {
resp->status_code = 401;
resp->hdrs_count = 1;
resp->hdrs[0].iov_base = MK_RW_PTR(auth_fail_hdrs);
resp->hdrs[0].iov_len = 46;
return (HTTP_SRV_CB_CONTINUE);
}
}

error = gen_hub_stat_json_send_async(g_data.shbskt, cli);
if (0 != error) {
resp->status_code = 500;
return (HTTP_SRV_CB_CONTINUE);
}
/* Will send reply later... */
return (HTTP_SRV_CB_NONE);
}

/* Admin page request. */
if (HTTP_REQ_METHOD_GET == req->line.method_code &&
0 == mem_cmpin_cstr("/admin", req->line.abs_path, req->line.abs_path_size)) {

/* Auth Check */
if (g_data.admin_auth_basic) {
const uint8_t *val;
size_t val_len;
if (0 != http_hdr_val_get(req->hdr, req->hdr_size, (const uint8_t*)"Authorization", 13, &val, &val_len) ||
val_len < 6 ||
0 != memcmp(val, "Basic ", 6) ||
val_len - 6 != g_data.admin_auth_basic_size ||
0 != memcmp(val + 6, g_data.admin_auth_basic, g_data.admin_auth_basic_size)) {
resp->status_code = 401;
resp->hdrs_count = 1;
resp->hdrs[0].iov_base = MK_RW_PTR(auth_fail_hdrs);
resp->hdrs[0].iov_len = 46;
return (HTTP_SRV_CB_CONTINUE);
}
}

error = gen_admin_page(cli);
if (0 != error) {
resp->status_code = 500;
}
return (HTTP_SRV_CB_CONTINUE);
}

if (12 < req->line.abs_path_size &&
(0 == memcmp(req->line.abs_path, "/udp/", 5) ||
0 == memcmp(req->line.abs_path, "/rtp/", 5))) {
Expand Down
Loading