lorenz.stechauner/sesimos
1
1
Fork 0
Code Issues Pull Requests Projects Releases Activity

Add more utils

Browse Source
This commit is contained in:
Lorenz Stechauner
2023-01-11 11:06:36 +01:00
parent 7699583c5f
commit 764b754a6f
15 changed files with 133 additions and 100 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
src/cache_handler.c
View File

@ -25,7 +25,6 @@
#define CACHE_BUF_SIZE 16 #define CACHE_BUF_SIZE 16
static magic_t magic; static magic_t magic;
static pthread_t thread; static pthread_t thread;
static sem_t sem_free, sem_used, sem_lock; static sem_t sem_free, sem_used, sem_lock;
@ -69,7 +68,7 @@ static cache_entry_t *cache_get_entry(cache_t *cache, const char *filename) {
for (int i = 0; i < CACHE_ENTRIES; i++) { for (int i = 0; i < CACHE_ENTRIES; i++) {
entry = &cache->entries[i]; entry = &cache->entries[i];
if (entry->filename[0] == 0) break; if (entry->filename[0] == 0) break;
if (strcmp(entry->filename, filename) == 0) { if (streq(entry->filename, filename)) {
// found // found
return entry; return entry;
} }
@ -344,9 +343,7 @@ static void cache_mark_entry_dirty(cache_entry_t *entry) {
} }
static void cache_update_entry(cache_entry_t *entry, const char *filename, const char *webroot) { static void cache_update_entry(cache_entry_t *entry, const char *filename, const char *webroot) {
struct stat statbuf; entry->meta.mtime = stat_mtime(filename);
stat(filename, &statbuf);
memcpy(&entry->meta.stat, &statbuf, sizeof(statbuf));
entry->webroot_len = (unsigned char) strlen(webroot); entry->webroot_len = (unsigned char) strlen(webroot);
strcpy(entry->filename, filename); strcpy(entry->filename, filename);
@ -355,10 +352,10 @@ static void cache_update_entry(cache_entry_t *entry, const char *filename, const
const char *type = magic_file(magic, filename); const char *type = magic_file(magic, filename);
char type_new[URI_TYPE_SIZE]; char type_new[URI_TYPE_SIZE];
sprintf(type_new, "%s", type); sprintf(type_new, "%s", type);
if (strncmp(type, "text/", 5) == 0) { if (strstarts(type, "text/")) {
if (strcmp(filename + strlen(filename) - 4, ".css") == 0) { if (strends(filename, ".css")) {
sprintf(type_new, "text/css"); sprintf(type_new, "text/css");
} else if (strcmp(filename + strlen(filename) - 3, ".js") == 0) { } else if (strends(filename, ".js")) {
sprintf(type_new, "application/javascript"); sprintf(type_new, "application/javascript");
} }
} }
@ -394,9 +391,7 @@ void cache_init_uri(cache_t *cache, http_uri *uri) {
return; return;
// check, if file has changed // check, if file has changed
struct stat statbuf; if (uri->meta->mtime != stat_mtime(uri->filename)) {
stat(uri->filename, &statbuf);
if (memcmp(&uri->meta->stat.st_mtime, &statbuf.st_mtime, sizeof(statbuf.st_mtime)) != 0) {
// modify time has changed // modify time has changed
cache_update_entry(entry, uri->filename, uri->webroot); cache_update_entry(entry, uri->filename, uri->webroot);
} }

15
src/lib/config.c
View File

@ -8,6 +8,7 @@
#include "../logger.h" #include "../logger.h"
#include "config.h" #include "config.h"
#include "utils.h"
#include <stdio.h> #include <stdio.h>
#include <string.h> #include <string.h>
@ -133,7 +134,7 @@ int config_load(const char *filename) {
} else { } else {
hc->type = CONFIG_TYPE_REVERSE_PROXY; hc->type = CONFIG_TYPE_REVERSE_PROXY;
} }
} else if (strcmp(ptr, "http") == 0) { } else if (streq(ptr, "http")) {
if (hc->type != 0 && hc->type != CONFIG_TYPE_REVERSE_PROXY) { if (hc->type != 0 && hc->type != CONFIG_TYPE_REVERSE_PROXY) {
goto err; goto err;
} else { } else {
@ -141,7 +142,7 @@ int config_load(const char *filename) {
hc->proxy.enc = 0; hc->proxy.enc = 0;
} }
continue; continue;
} else if (strcmp(ptr, "https") == 0) { } else if (streq(ptr, "https")) {
if (hc->type != 0 && hc->type != CONFIG_TYPE_REVERSE_PROXY) { if (hc->type != 0 && hc->type != CONFIG_TYPE_REVERSE_PROXY) {
goto err; goto err;
} else { } else {
@ -166,11 +167,11 @@ int config_load(const char *filename) {
if (target != NULL) { if (target != NULL) {
strcpy(target, source); strcpy(target, source);
} else if (mode == 1) { } else if (mode == 1) {
if (strcmp(source, "forbidden") == 0) { if (streq(source, "forbidden")) {
config.hosts[i - 1].local.dir_mode = URI_DIR_MODE_FORBIDDEN; config.hosts[i - 1].local.dir_mode = URI_DIR_MODE_FORBIDDEN;
} else if (strcmp(source, "info") == 0) { } else if (streq(source, "info")) {
config.hosts[i - 1].local.dir_mode = URI_DIR_MODE_INFO; config.hosts[i - 1].local.dir_mode = URI_DIR_MODE_INFO;
} else if (strcmp(source, "list") == 0) { } else if (streq(source, "list")) {
config.hosts[i - 1].local.dir_mode = URI_DIR_MODE_LIST; config.hosts[i - 1].local.dir_mode = URI_DIR_MODE_LIST;
} else { } else {
goto err; goto err;
@ -193,7 +194,7 @@ int config_load(const char *filename) {
if (hc->cert_name[0] == 0) goto err2; if (hc->cert_name[0] == 0) goto err2;
int found = 0; int found = 0;
for (int m = 0; m < j; m++) { for (int m = 0; m < j; m++) {
if (strcmp(config.certs[m].name, hc->cert_name) == 0) { if (streq(config.certs[m].name, hc->cert_name)) {
hc->cert = m; hc->cert = m;
found = 1; found = 1;
break; break;
@ -213,7 +214,7 @@ host_config_t *get_host_config(const char *host) {
for (int i = 0; i < CONFIG_MAX_HOST_CONFIG; i++) { for (int i = 0; i < CONFIG_MAX_HOST_CONFIG; i++) {
host_config_t *hc = &config.hosts[i]; host_config_t *hc = &config.hosts[i];
if (hc->type == CONFIG_TYPE_UNSET) break; if (hc->type == CONFIG_TYPE_UNSET) break;
if (strcmp(hc->name, host) == 0) return hc; if (streq(hc->name, host)) return hc;
if (hc->name[0] == '*' && hc->name[1] == '.') { if (hc->name[0] == '*' && hc->name[1] == '.') {
const char *pos = strstr(host, hc->name + 1); const char *pos = strstr(host, hc->name + 1);
if (pos != NULL && strlen(pos) == strlen(hc->name + 1)) return hc; if (pos != NULL && strlen(pos) == strlen(hc->name + 1)) return hc;

8
src/lib/fastcgi.c
View File

@ -236,16 +236,16 @@ int fastcgi_php_error(const fastcgi_cnx_t *conn, const char *msg, int msg_len, c
goto next; goto next;
} }
if (len >= 14 && strncmp(ptr0, "PHP Warning: ", 14) == 0) { if (len >= 14 && strstarts(ptr0, "PHP Warning: ")) {
msg_type = LOG_WARNING; msg_type = LOG_WARNING;
msg_pre_len = 14; msg_pre_len = 14;
} else if (len >= 18 && strncmp(ptr0, "PHP Fatal error: ", 18) == 0) { } else if (len >= 18 && strstarts(ptr0, "PHP Fatal error: ")) {
msg_type = LOG_ERROR; msg_type = LOG_ERROR;
msg_pre_len = 18; msg_pre_len = 18;
} else if (len >= 18 && strncmp(ptr0, "PHP Parse error: ", 18) == 0) { } else if (len >= 18 && strstarts(ptr0, "PHP Parse error: ")) {
msg_type = LOG_ERROR; msg_type = LOG_ERROR;
msg_pre_len = 18; msg_pre_len = 18;
} else if (len >= 18 && strncmp(ptr0, "PHP Notice: ", 13) == 0) { } else if (len >= 18 && strstarts(ptr0, "PHP Notice: ")) {
msg_type = LOG_NOTICE; msg_type = LOG_NOTICE;
msg_pre_len = 13; msg_pre_len = 13;
} }

3
src/lib/geoip.c
View File

@ -9,6 +9,7 @@
#include "geoip.h" #include "geoip.h"
#include "../logger.h" #include "../logger.h"
#include "error.h" #include "error.h"
#include "utils.h"
#include <memory.h> #include <memory.h>
#include <dirent.h> #include <dirent.h>
@ -91,7 +92,7 @@ int geoip_init(const char *directory) {
struct dirent *entry; struct dirent *entry;
int i = 0, status; int i = 0, status;
while ((entry = readdir(geoip_dir)) != NULL) { while ((entry = readdir(geoip_dir)) != NULL) {
if (strcmp(entry->d_name + strlen(entry->d_name) - 5, ".mmdb") != 0) if (!strends(entry->d_name, ".mmdb"))
continue; continue;
if (i >= GEOIP_MAX_MMDB) { if (i >= GEOIP_MAX_MMDB) {

14
src/lib/http.c
View File

@ -390,15 +390,15 @@ const char *http_get_status_color(const http_status *status) {
} }
char *http_format_date(time_t time, char *buf, size_t size) { char *http_format_date(time_t time, char *buf, size_t size) {
struct tm timeinfo; struct tm time_info;
strftime(buf, size, "%a, %d %b %Y %H:%M:%S GMT", gmtime_r(&time, &timeinfo)); strftime(buf, size, "%a, %d %b %Y %H:%M:%S GMT", gmtime_r(&time, &time_info));
return buf; return buf;
} }
char *http_get_date(char *buf, size_t size) { char *http_get_date(char *buf, size_t size) {
time_t rawtime; time_t raw_time;
time(&rawtime); time(&raw_time);
return http_format_date(rawtime, buf, size); return http_format_date(raw_time, buf, size);
} }
const http_doc_info *http_get_status_info(const http_status *status) { const http_doc_info *http_get_status_info(const http_status *status) {
@ -426,9 +426,9 @@ int http_get_compression(const http_req *req, const http_res *res) {
const char *content_type = http_get_header_field(&res->hdr, "Content-Type"); const char *content_type = http_get_header_field(&res->hdr, "Content-Type");
const char *content_encoding = http_get_header_field(&res->hdr, "Content-Encoding"); const char *content_encoding = http_get_header_field(&res->hdr, "Content-Encoding");
if (mime_is_compressible(content_type) && content_encoding == NULL && accept_encoding != NULL) { if (mime_is_compressible(content_type) && content_encoding == NULL && accept_encoding != NULL) {
if (strstr(accept_encoding, "br") != NULL) { if (strcontains(accept_encoding, "br")) {
return COMPRESS_BR; return COMPRESS_BR;
} else if (strstr(accept_encoding, "gzip") != NULL) { } else if (strcontains(accept_encoding, "gzip")) {
return COMPRESS_GZ; return COMPRESS_GZ;
} }
} }

8
src/lib/proxy.c
View File

@ -398,10 +398,10 @@ int proxy_init(proxy_ctx_t **proxy_ptr, http_req *req, http_res *res, http_statu
proxy: proxy:
connection = http_get_header_field(&req->hdr, "Connection"); connection = http_get_header_field(&req->hdr, "Connection");
if (connection != NULL && (strstr(connection, "upgrade") != NULL || strstr(connection, "Upgrade") != NULL)) { if (strcontains(connection, "upgrade") || strcontains(connection, "Upgrade")) {
upgrade = http_get_header_field(&req->hdr, "Upgrade"); upgrade = http_get_header_field(&req->hdr, "Upgrade");
ws_version = http_get_header_field(&req->hdr, "Sec-WebSocket-Version"); ws_version = http_get_header_field(&req->hdr, "Sec-WebSocket-Version");
if (upgrade != NULL && ws_version != NULL && strcmp(upgrade, "websocket") == 0 && strcmp(ws_version, "13") == 0) { if (streq(upgrade, "websocket") && streq(ws_version, "13")) {
ctx->ws_key = http_get_header_field(&req->hdr, "Sec-WebSocket-Key"); ctx->ws_key = http_get_header_field(&req->hdr, "Sec-WebSocket-Key");
} else { } else {
res->status = http_get_status(501); res->status = http_get_status(501);
@ -437,7 +437,7 @@ int proxy_init(proxy_ctx_t **proxy_ptr, http_req *req, http_res *res, http_statu
ret = 0; ret = 0;
if (content_len > 0) { if (content_len > 0) {
ret = sock_splice(&proxy->proxy, client, buffer, sizeof(buffer), content_len); ret = sock_splice(&proxy->proxy, client, buffer, sizeof(buffer), content_len);
} else if (transfer_encoding != NULL && strstr(transfer_encoding, "chunked") != NULL) { } else if (strcontains(transfer_encoding, "chunked")) {
ret = sock_splice_chunked(&proxy->proxy, client, buffer, sizeof(buffer)); ret = sock_splice_chunked(&proxy->proxy, client, buffer, sizeof(buffer));
} }
@ -510,7 +510,7 @@ int proxy_init(proxy_ctx_t **proxy_ptr, http_req *req, http_res *res, http_statu
goto proxy_err; goto proxy_err;
} }
if (ptr == buf) { if (ptr == buf) {
if (strncmp(ptr, "HTTP/", 5) != 0) { if (!strstarts(ptr, "HTTP/")) {
res->status = http_get_status(502); res->status = http_get_status(502);
ctx->origin = SERVER_RES; ctx->origin = SERVER_RES;
error("Unable to parse header: Invalid header format"); error("Unable to parse header: Invalid header format");

14
src/lib/uri.c
View File

@ -78,7 +78,7 @@ int uri_init(http_uri *uri, const char *webroot, const char *uri_str, int dir_mo
if (query != NULL) { if (query != NULL) {
query[-1] = '?'; query[-1] = '?';
} }
if (strstr(uri->req_path, "/../") != NULL || strstr(uri->req_path, "/./") != NULL) { if (strcontains(uri->req_path, "/../") || strcontains(uri->req_path, "/./")) {
return 2; return 2;
} }
@ -145,10 +145,10 @@ int uri_init(http_uri *uri, const char *webroot, const char *uri_str, int dir_mo
uri->filename = malloc(strlen(buf0) + 1); uri->filename = malloc(strlen(buf0) + 1);
strcpy(uri->filename, buf0); strcpy(uri->filename, buf0);
long len = (long) strlen(uri->path); long len = (long) strlen(uri->path);
if (strcmp(uri->path + len - 4, ".ncr") == 0 || strcmp(uri->path + len - 4, ".php") == 0) { if (strends(uri->path, ".ncr") || strends(uri->path, ".php")) {
uri->path[len - 4] = 0; uri->path[len - 4] = 0;
uri->is_static = 0; uri->is_static = 0;
} else if (strcmp(uri->path + len - 5, ".html") == 0) { } else if (strends(uri->path, ".html")) {
uri->path[len - 5] = 0; uri->path[len - 5] = 0;
} }
} else if (path_is_file(buf1)) { } else if (path_is_file(buf1)) {
@ -195,12 +195,12 @@ int uri_init(http_uri *uri, const char *webroot, const char *uri_str, int dir_mo
} }
} }
if (strcmp(uri->path + strlen(uri->path) - 5, "index") == 0) { if (strends(uri->path + strlen(uri->path), "index")) {
uri->path[strlen(uri->path) - 5] = 0; uri->path[strlen(uri->path) - 5] = 0;
} }
if (strcmp(uri->pathinfo, "index.ncr") == 0 || if (streq(uri->pathinfo, "index.ncr") ||
strcmp(uri->pathinfo, "index.php") == 0 || streq(uri->pathinfo, "index.php") ||
strcmp(uri->pathinfo, "index.html") == 0) { streq(uri->pathinfo, "index.html")) {
uri->pathinfo[0] = 0; uri->pathinfo[0] = 0;
} }

2
src/lib/uri.h
View File

@ -26,7 +26,7 @@ typedef struct {
char charset[URI_CHARSET_SIZE]; char charset[URI_CHARSET_SIZE];
char filename_comp_gz[256]; char filename_comp_gz[256];
char filename_comp_br[256]; char filename_comp_br[256];
struct stat stat; long mtime;
} metadata_t; } metadata_t;
typedef struct { typedef struct {

70
src/lib/utils.c
View File

@ -124,27 +124,27 @@ int mime_is_compressible(const char *type) {
char *pos = strchr(type_parsed, ';'); char *pos = strchr(type_parsed, ';');
if (pos != NULL) pos[0] = 0; if (pos != NULL) pos[0] = 0;
return return
strncmp(type_parsed, "text/", 5) == 0 || strstarts(type_parsed, "text/") ||
strncmp(type_parsed, "message/", 7) == 0 || strstarts(type_parsed, "message/") ||
strstr(type_parsed, "+xml") != NULL || strends(type_parsed, "+xml") ||
strstr(type_parsed, "+json") != NULL || strends(type_parsed, "+json") ||
strcmp(type_parsed, "application/javascript") == 0 || streq(type_parsed, "application/javascript") ||
strcmp(type_parsed, "application/json") == 0 || streq(type_parsed, "application/json") ||
strcmp(type_parsed, "application/xml") == 0 || streq(type_parsed, "application/xml") ||
strcmp(type_parsed, "application/x-www-form-urlencoded") == 0 || streq(type_parsed, "application/x-www-form-urlencoded") ||
strcmp(type_parsed, "application/x-tex") == 0 || streq(type_parsed, "application/x-tex") ||
strcmp(type_parsed, "application/x-httpd-php") == 0 || streq(type_parsed, "application/x-httpd-php") ||
strcmp(type_parsed, "application/x-latex") == 0 || streq(type_parsed, "application/x-latex") ||
strcmp(type_parsed, "application/vnd.ms-fontobject") == 0 || streq(type_parsed, "application/vnd.ms-fontobject") ||
strcmp(type_parsed, "application/x-font-ttf") == 0 || streq(type_parsed, "application/x-font-ttf") ||
strcmp(type_parsed, "application/x-javascript") == 0 || streq(type_parsed, "application/x-javascript") ||
strcmp(type_parsed, "font/eot") == 0 || streq(type_parsed, "font/eot") ||
strcmp(type_parsed, "font/opentype") == 0 || streq(type_parsed, "font/opentype") ||
strcmp(type_parsed, "image/bmp") == 0 || streq(type_parsed, "image/bmp") ||
strcmp(type_parsed, "image/gif") == 0 || streq(type_parsed, "image/gif") ||
strcmp(type_parsed, "image/vnd.microsoft.icon") == 0 || streq(type_parsed, "image/vnd.microsoft.icon") ||
strcmp(type_parsed, "image/vnd.microsoft.iconbinary") == 0 || streq(type_parsed, "image/vnd.microsoft.iconbinary") ||
strcmp(type_parsed, "image/x-icon") == 0; streq(type_parsed, "image/x-icon");
} }
int strcpy_rem_webroot(char *dst, const char *src, long len, const char *webroot) { int strcpy_rem_webroot(char *dst, const char *src, long len, const char *webroot) {
@ -187,6 +187,26 @@ int str_trim_lws(char **start, char **end) {
return 0; return 0;
} }
int streq(const char *restrict str1, const char *restrict str2) {
return str1 != NULL && str2 != NULL && strcmp(str1, str2) == 0;
}
int strcontains(const char *restrict haystack, const char *restrict needle) {
return haystack != NULL && needle != NULL && strstr(haystack, needle) != NULL;
}
int strstarts(const char *restrict str, const char *restrict prefix) {
if (str == NULL || prefix == NULL) return 0;
unsigned long l1 = strlen(str), l2 = strlen(prefix);
return l2 <= l1 && strncmp(str, prefix, l2) == 0;
}
int strends(const char *restrict str, const char *restrict suffix) {
if (str == NULL || suffix == NULL) return 0;
unsigned long l1 = strlen(str), l2 = strlen(suffix);
return l2 <= l1 && strcmp(str + l1 - l2, suffix) == 0;
}
int base64_encode(void *data, unsigned long data_len, char *output, unsigned long *output_len) { int base64_encode(void *data, unsigned long data_len, char *output, unsigned long *output_len) {
unsigned long out_len = 4 * ((data_len + 2) / 3); unsigned long out_len = 4 * ((data_len + 2) / 3);
if (output_len != NULL) *output_len = out_len; if (output_len != NULL) *output_len = out_len;
@ -221,6 +241,12 @@ long clock_cpu(void) {
return time.tv_sec * 1000000000 + time.tv_nsec; return time.tv_sec * 1000000000 + time.tv_nsec;
} }
long stat_mtime(const char *filename) {
struct stat stat_buf;
stat(filename, &stat_buf);
return stat_buf.st_mtime;
}
int rm_rf(const char *path) { int rm_rf(const char *path) {
struct stat stat_buf; struct stat stat_buf;
if (lstat(path, &stat_buf) != 0) if (lstat(path, &stat_buf) != 0)
@ -243,7 +269,7 @@ int rm_rf(const char *path) {
// read directory // read directory
for (struct dirent *ent; (ent = readdir(dir)) != NULL;) { for (struct dirent *ent; (ent = readdir(dir)) != NULL;) {
if (strcmp(ent->d_name, ".") == 0 || strcmp(ent->d_name, "..") == 0) if (streq(ent->d_name, ".") || streq(ent->d_name, ".."))
continue; continue;
snprintf(buf, sizeof(buf), "%s/%s", path, ent->d_name); snprintf(buf, sizeof(buf), "%s/%s", path, ent->d_name);

10
src/lib/utils.h
View File

@ -35,12 +35,22 @@ int str_trim(char **start, char **end);
int str_trim_lws(char **start, char **end); int str_trim_lws(char **start, char **end);
int streq(const char *restrict str1, const char *restrict str2);
int strcontains(const char *restrict haystack, const char *restrict needle);
int strstarts(const char *restrict str, const char *restrict prefix);
int strends(const char *restrict str, const char *restrict suffix);
int base64_encode(void *data, unsigned long data_len, char *output, unsigned long *output_len); int base64_encode(void *data, unsigned long data_len, char *output, unsigned long *output_len);
long clock_micros(void); long clock_micros(void);
long clock_cpu(void); long clock_cpu(void);
long stat_mtime(const char *filename);
int rm_rf(const char *path); int rm_rf(const char *path);
#endif //SESIMOS_UTILS_H #endif //SESIMOS_UTILS_H

10
src/worker/fastcgi_handler.c
View File

@ -46,9 +46,9 @@ static int fastcgi_handler_1(client_ctx_t *ctx, fastcgi_cnx_t *fcgi_cnx) {
char buf[1024]; char buf[1024];
int mode, ret; int mode, ret;
if (strcmp(uri->filename + strlen(uri->filename) - 4, ".ncr") == 0) { if (strends(uri->filename, ".ncr")) {
mode = FASTCGI_SESIMOS; mode = FASTCGI_SESIMOS;
} else if (strcmp(uri->filename + strlen(uri->filename) - 4, ".php") == 0) { } else if (strends(uri->filename, ".php")) {
mode = FASTCGI_PHP; mode = FASTCGI_PHP;
} else { } else {
res->status = http_get_status(500); res->status = http_get_status(500);
@ -73,7 +73,7 @@ static int fastcgi_handler_1(client_ctx_t *ctx, fastcgi_cnx_t *fcgi_cnx) {
if (client_content_length != NULL) { if (client_content_length != NULL) {
unsigned long client_content_len = strtoul(client_content_length, NULL, 10); unsigned long client_content_len = strtoul(client_content_length, NULL, 10);
ret = fastcgi_receive(fcgi_cnx, client, client_content_len); ret = fastcgi_receive(fcgi_cnx, client, client_content_len);
} else if (client_transfer_encoding != NULL && strstr(client_transfer_encoding, "chunked") != NULL) { } else if (strcontains(client_transfer_encoding, "chunked")) {
ret = fastcgi_receive_chunked(fcgi_cnx, client); ret = fastcgi_receive_chunked(fcgi_cnx, client);
} else { } else {
ret = 0; ret = 0;
@ -118,7 +118,7 @@ static int fastcgi_handler_1(client_ctx_t *ctx, fastcgi_cnx_t *fcgi_cnx) {
const char *content_encoding = http_get_header_field(&res->hdr, "Content-Encoding"); const char *content_encoding = http_get_header_field(&res->hdr, "Content-Encoding");
if (content_encoding == NULL && if (content_encoding == NULL &&
content_type != NULL && content_type != NULL &&
strncmp(content_type, "text/html", 9) == 0 && strstarts(content_type, "text/html") &&
ctx->content_length != -1 && ctx->content_length != -1 &&
ctx->content_length <= sizeof(ctx->msg_content) - 1) ctx->content_length <= sizeof(ctx->msg_content) - 1)
{ {
@ -157,7 +157,7 @@ static int fastcgi_handler_1(client_ctx_t *ctx, fastcgi_cnx_t *fcgi_cnx) {
static int fastcgi_handler_2(client_ctx_t *ctx, fastcgi_cnx_t *fcgi_cnx) { static int fastcgi_handler_2(client_ctx_t *ctx, fastcgi_cnx_t *fcgi_cnx) {
const char *transfer_encoding = http_get_header_field(&ctx->res.hdr, "Transfer-Encoding"); const char *transfer_encoding = http_get_header_field(&ctx->res.hdr, "Transfer-Encoding");
int chunked = (transfer_encoding != NULL && strstr(transfer_encoding, "chunked") != NULL); int chunked = strcontains(transfer_encoding, "chunked");
int flags = (chunked ? FASTCGI_CHUNKED : 0) | (ctx->use_fastcgi & (FASTCGI_COMPRESS | FASTCGI_COMPRESS_HOLD)); int flags = (chunked ? FASTCGI_CHUNKED : 0) | (ctx->use_fastcgi & (FASTCGI_COMPRESS | FASTCGI_COMPRESS_HOLD));
int ret = fastcgi_send(fcgi_cnx, &ctx->socket, flags); int ret = fastcgi_send(fcgi_cnx, &ctx->socket, flags);

22
src/worker/local_handler.c
View File

@ -45,7 +45,7 @@ static int local_handler(client_ctx_t *ctx) {
char buf1[1024], buf2[1024]; char buf1[1024], buf2[1024];
int accept_if_modified_since = 0; int accept_if_modified_since = 0;
if (strcmp(req->method, "TRACE") == 0) { if (streq(req->method, "TRACE")) {
res->status = http_get_status(200); res->status = http_get_status(200);
http_add_header_field(&res->hdr, "Content-Type", "message/http"); http_add_header_field(&res->hdr, "Content-Type", "message/http");
@ -60,11 +60,11 @@ static int local_handler(client_ctx_t *ctx) {
return 0; return 0;
} }
if (strncmp(uri->req_path, "/.well-known/", 13) == 0) { if (strstarts(uri->req_path, "/.well-known/")) {
http_add_header_field(&res->hdr, "Access-Control-Allow-Origin", "*"); http_add_header_field(&res->hdr, "Access-Control-Allow-Origin", "*");
} }
if (strncmp(uri->req_path, "/.well-known/", 13) != 0 && strstr(uri->path, "/.") != NULL) { if (!strstarts(uri->req_path, "/.well-known/") && strcontains(uri->path, "/.")) {
res->status = http_get_status(403); res->status = http_get_status(403);
sprintf(err_msg, "Parts of this URI are hidden."); sprintf(err_msg, "Parts of this URI are hidden.");
return 0; return 0;
@ -88,7 +88,7 @@ static int local_handler(client_ctx_t *ctx) {
if (uri->is_static) { if (uri->is_static) {
res->status = http_get_status(200); res->status = http_get_status(200);
http_add_header_field(&res->hdr, "Accept-Ranges", "bytes"); http_add_header_field(&res->hdr, "Accept-Ranges", "bytes");
if (strcmp(req->method, "GET") != 0 && strcmp(req->method, "HEAD") != 0) { if (!streq(req->method, "GET") && !streq(req->method, "HEAD")) {
res->status = http_get_status(405); res->status = http_get_status(405);
return 0; return 0;
} }
@ -101,7 +101,7 @@ static int local_handler(client_ctx_t *ctx) {
cache_init_uri(ctx->conf->cache, uri); cache_init_uri(ctx->conf->cache, uri);
const char *last_modified = http_format_date(uri->meta->stat.st_mtime, buf1, sizeof(buf1)); const char *last_modified = http_format_date(uri->meta->mtime, buf1, sizeof(buf1));
http_add_header_field(&res->hdr, "Last-Modified", last_modified); http_add_header_field(&res->hdr, "Last-Modified", last_modified);
sprintf(buf2, "%s; charset=%s", uri->meta->type, uri->meta->charset); sprintf(buf2, "%s; charset=%s", uri->meta->type, uri->meta->charset);
http_add_header_field(&res->hdr, "Content-Type", buf2); http_add_header_field(&res->hdr, "Content-Type", buf2);
@ -110,7 +110,7 @@ static int local_handler(client_ctx_t *ctx) {
const char *accept_encoding = http_get_header_field(&req->hdr, "Accept-Encoding"); const char *accept_encoding = http_get_header_field(&req->hdr, "Accept-Encoding");
int enc = 0; int enc = 0;
if (accept_encoding != NULL) { if (accept_encoding != NULL) {
if (uri->meta->filename_comp_br[0] != 0 && strstr(accept_encoding, "br") != NULL) { if (uri->meta->filename_comp_br[0] != 0 && strcontains(accept_encoding, "br")) {
ctx->file = fopen(uri->meta->filename_comp_br, "rb"); ctx->file = fopen(uri->meta->filename_comp_br, "rb");
if (ctx->file == NULL) { if (ctx->file == NULL) {
cache_mark_dirty(ctx->conf->cache, uri->filename); cache_mark_dirty(ctx->conf->cache, uri->filename);
@ -119,7 +119,7 @@ static int local_handler(client_ctx_t *ctx) {
http_add_header_field(&res->hdr, "Content-Encoding", "br"); http_add_header_field(&res->hdr, "Content-Encoding", "br");
enc = COMPRESS_BR; enc = COMPRESS_BR;
} }
} else if (uri->meta->filename_comp_gz[0] != 0 && strstr(accept_encoding, "gzip") != NULL) { } else if (uri->meta->filename_comp_gz[0] != 0 && strcontains(accept_encoding, "gzip")) {
ctx->file = fopen(uri->meta->filename_comp_gz, "rb"); ctx->file = fopen(uri->meta->filename_comp_gz, "rb");
if (ctx->file == NULL) { if (ctx->file == NULL) {
cache_mark_dirty(ctx->conf->cache, uri->filename); cache_mark_dirty(ctx->conf->cache, uri->filename);
@ -143,7 +143,7 @@ static int local_handler(client_ctx_t *ctx) {
} }
} }
if (strncmp(uri->meta->type, "text/", 5) == 0) { if (strstarts(uri->meta->type, "text/")) {
http_add_header_field(&res->hdr, "Cache-Control", "public, max-age=3600"); http_add_header_field(&res->hdr, "Cache-Control", "public, max-age=3600");
} else { } else {
http_add_header_field(&res->hdr, "Cache-Control", "public, max-age=86400"); http_add_header_field(&res->hdr, "Cache-Control", "public, max-age=86400");
@ -151,8 +151,8 @@ static int local_handler(client_ctx_t *ctx) {
const char *if_modified_since = http_get_header_field(&req->hdr, "If-Modified-Since"); const char *if_modified_since = http_get_header_field(&req->hdr, "If-Modified-Since");
const char *if_none_match = http_get_header_field(&req->hdr, "If-None-Match"); const char *if_none_match = http_get_header_field(&req->hdr, "If-None-Match");
if ((if_none_match != NULL && strstr(if_none_match, uri->meta->etag) == NULL) || if ((if_none_match != NULL && !strcontains(if_none_match, uri->meta->etag)) ||
(accept_if_modified_since && if_modified_since != NULL && strcmp(if_modified_since, last_modified) == 0)) (accept_if_modified_since && streq(if_modified_since, last_modified)))
{ {
res->status = http_get_status(304); res->status = http_get_status(304);
return 0; return 0;
@ -160,7 +160,7 @@ static int local_handler(client_ctx_t *ctx) {
const char *range = http_get_header_field(&req->hdr, "Range"); const char *range = http_get_header_field(&req->hdr, "Range");
if (range != NULL) { if (range != NULL) {
if (strlen(range) <= 6 || strncmp(range, "bytes=", 6) != 0) { if (!strstarts(range, "bytes=")) {
res->status = http_get_status(416); res->status = http_get_status(416);
http_remove_header_field(&res->hdr, "Content-Type", HTTP_REMOVE_ALL); http_remove_header_field(&res->hdr, "Content-Type", HTTP_REMOVE_ALL);
http_remove_header_field(&res->hdr, "Last-Modified", HTTP_REMOVE_ALL); http_remove_header_field(&res->hdr, "Last-Modified", HTTP_REMOVE_ALL);

18
src/worker/proxy_handler.c
View File

@ -63,12 +63,12 @@ static int proxy_handler_1(client_ctx_t *ctx) {
const char *connection = http_get_header_field(&res->hdr, "Connection"); const char *connection = http_get_header_field(&res->hdr, "Connection");
const char *upgrade = http_get_header_field(&res->hdr, "Upgrade"); const char *upgrade = http_get_header_field(&res->hdr, "Upgrade");
if (connection != NULL && upgrade != NULL && if (connection != NULL && upgrade != NULL &&
(strstr(connection, "upgrade") != NULL || strstr(connection, "Upgrade") != NULL) && (strcontains(connection, "upgrade") || strcontains(connection, "Upgrade")) &&
strcmp(upgrade, "websocket") == 0) streq(upgrade, "websocket"))
{ {
const char *ws_accept = http_get_header_field(&res->hdr, "Sec-WebSocket-Accept"); const char *ws_accept = http_get_header_field(&res->hdr, "Sec-WebSocket-Accept");
if (ws_calc_accept_key(status->ws_key, buf) == 0) { if (ws_calc_accept_key(status->ws_key, buf) == 0) {
ctx->use_proxy = (strcmp(buf, ws_accept) == 0) ? 2 : 1; ctx->use_proxy = streq(buf, ws_accept) ? 2 : 1;
} }
} else { } else {
status->status = 101; status->status = 101;
@ -84,10 +84,10 @@ static int proxy_handler_1(client_ctx_t *ctx) {
const char *content_encoding = http_get_header_field(&res->hdr, "Content-Encoding"); const char *content_encoding = http_get_header_field(&res->hdr, "Content-Encoding");
if (content_encoding == NULL && ( if (content_encoding == NULL && (
content_length_f == NULL || content_length_f == NULL ||
(content_length_f != NULL && strcmp(content_length_f, "0") == 0) || streq(content_length_f, "0") ||
(content_type != NULL && content_length_f != NULL && strncmp(content_type, "text/html", 9) == 0))) (content_length_f != NULL && strstarts(content_type, "text/html"))))
{ {
long content_len = (strcmp(ctx->req.method, "HEAD") != 0 && content_length_f != NULL) ? strtol(content_length_f, NULL, 10) : 0; long content_len = (!streq(ctx->req.method, "HEAD") && content_length_f != NULL) ? strtol(content_length_f, NULL, 10) : 0;
if (content_len <= sizeof(ctx->msg_content) - 1) { if (content_len <= sizeof(ctx->msg_content) - 1) {
if (status->status != 101) { if (status->status != 101) {
status->status = res->status->code; status->status = res->status->code;
@ -103,7 +103,7 @@ static int proxy_handler_1(client_ctx_t *ctx) {
} }
} }
if (strcmp(ctx->req.method, "HEAD") == 0) { if (streq(ctx->req.method, "HEAD")) {
return 1; return 1;
} }
@ -119,7 +119,7 @@ static int proxy_handler_1(client_ctx_t *ctx) {
} }
char *transfer_encoding = http_get_header_field(&res->hdr, "Transfer-Encoding"); char *transfer_encoding = http_get_header_field(&res->hdr, "Transfer-Encoding");
int chunked = transfer_encoding != NULL && strcmp(transfer_encoding, "chunked") == 0; int chunked = transfer_encoding != NULL && streq(transfer_encoding, "chunked");
http_remove_header_field(&res->hdr, "Transfer-Encoding", HTTP_REMOVE_ALL); http_remove_header_field(&res->hdr, "Transfer-Encoding", HTTP_REMOVE_ALL);
ret = sprintf(buf, "%s%s%s", ret = sprintf(buf, "%s%s%s",
(use_proxy & PROXY_COMPRESS_BR) ? "br" : (use_proxy & PROXY_COMPRESS_BR) ? "br" :
@ -136,7 +136,7 @@ static int proxy_handler_1(client_ctx_t *ctx) {
static int proxy_handler_2(client_ctx_t *ctx) { static int proxy_handler_2(client_ctx_t *ctx) {
const char *transfer_encoding = http_get_header_field(&ctx->res.hdr, "Transfer-Encoding"); const char *transfer_encoding = http_get_header_field(&ctx->res.hdr, "Transfer-Encoding");
int chunked = transfer_encoding != NULL && strstr(transfer_encoding, "chunked") != NULL; int chunked = strcontains(transfer_encoding, "chunked");
const char *content_len = http_get_header_field(&ctx->res.hdr, "Content-Length"); const char *content_len = http_get_header_field(&ctx->res.hdr, "Content-Length");
unsigned long len_to_send = 0; unsigned long len_to_send = 0;

18
src/worker/request_handler.c
View File

@ -108,7 +108,7 @@ static int request_handler(client_ctx_t *ctx) {
} }
const char *hdr_connection = http_get_header_field(&req->hdr, "Connection"); const char *hdr_connection = http_get_header_field(&req->hdr, "Connection");
ctx->c_keep_alive = (hdr_connection != NULL && (strstr(hdr_connection, "keep-alive") != NULL || strstr(hdr_connection, "Keep-Alive") != NULL)); ctx->c_keep_alive = (strcontains(hdr_connection, "keep-alive") || strcontains(hdr_connection, "Keep-Alive"));
const char *host_ptr = http_get_header_field(&req->hdr, "Host"); const char *host_ptr = http_get_header_field(&req->hdr, "Host");
if (host_ptr != NULL && strlen(host_ptr) > 255) { if (host_ptr != NULL && strlen(host_ptr) > 255) {
ctx->req_host[0] = 0; ctx->req_host[0] = 0;
@ -131,8 +131,8 @@ static int request_handler(client_ctx_t *ctx) {
logger_set_prefix("[%s%*s%s]%s", BLD_STR, INET6_ADDRSTRLEN, ctx->req_host, CLR_STR, ctx->log_prefix); logger_set_prefix("[%s%*s%s]%s", BLD_STR, INET6_ADDRSTRLEN, ctx->req_host, CLR_STR, ctx->log_prefix);
info(BLD_STR "%s %s", req->method, req->uri); info(BLD_STR "%s %s", req->method, req->uri);
if (strncmp(req->uri, "/.sesimos/res/", 14) == 0) { if (strstarts(req->uri, "/.sesimos/res/")) {
if (strcmp(req->method, "GET") != 0 && strcmp(req->method, "HEAD") != 0) { if (!streq(req->method, "GET") && !streq(req->method, "HEAD")) {
res->status = http_get_status(405); res->status = http_get_status(405);
http_add_header_field(&res->hdr, "Allow", "GET, HEAD"); http_add_header_field(&res->hdr, "Allow", "GET, HEAD");
return 0; return 0;
@ -150,7 +150,7 @@ static int request_handler(client_ctx_t *ctx) {
res->status = http_get_status(404); res->status = http_get_status(404);
for (int i = 0; i < sizeof(resources) / sizeof(res_t); i++) { for (int i = 0; i < sizeof(resources) / sizeof(res_t); i++) {
const res_t *r = &resources[i]; const res_t *r = &resources[i];
if (strcmp(req->uri + 14, r->name) == 0) { if (streq(req->uri + 14, r->name)) {
res->status = http_get_status(203); res->status = http_get_status(203);
http_add_header_field(&res->hdr, "Content-Type", r->type); http_add_header_field(&res->hdr, "Content-Type", r->type);
http_add_header_field(&res->hdr, "Cache-Control", "public, max-age=86400"); http_add_header_field(&res->hdr, "Cache-Control", "public, max-age=86400");
@ -189,13 +189,13 @@ static int request_handler(client_ctx_t *ctx) {
return 0; return 0;
} }
if (ctx->conf->type == CONFIG_TYPE_LOCAL && strcmp(req->method, "TRACE") == 0) { if (ctx->conf->type == CONFIG_TYPE_LOCAL && streq(req->method, "TRACE")) {
return 1; return 1;
} else if (dir_mode != URI_DIR_MODE_NO_VALIDATION) { } else if (dir_mode != URI_DIR_MODE_NO_VALIDATION) {
ssize_t size = sizeof(buf0); ssize_t size = sizeof(buf0);
url_decode(req->uri, buf0, &size); url_decode(req->uri, buf0, &size);
int change_proto = (!client->enc && strncmp(uri->uri, "/.well-known/", 13) != 0); int change_proto = (!client->enc && !strstarts(uri->uri, "/.well-known/"));
if (strcmp(uri->uri, buf0) != 0 || change_proto) { if (!streq(uri->uri, buf0) || change_proto) {
res->status = http_get_status(308); res->status = http_get_status(308);
size = url_encode(uri->uri, strlen(uri->uri), buf0, sizeof(buf0)); size = url_encode(uri->uri, strlen(uri->uri), buf0, sizeof(buf0));
if (change_proto) { if (change_proto) {
@ -271,7 +271,7 @@ int respond(client_ctx_t *ctx) {
snprintf(ctx->msg_content, sizeof(ctx->msg_content), " <ul>\n <li><a href=\"%s\">%s</a></li>\n </ul>\n", location, location); snprintf(ctx->msg_content, sizeof(ctx->msg_content), " <ul>\n <li><a href=\"%s\">%s</a></li>\n </ul>\n", location, location);
} }
} }
} else if (strncmp(ctx->msg_content, "<!DOCTYPE html>", 15) == 0 || strncmp(ctx->msg_content, "<html", 5) == 0) { } else if (strstarts(ctx->msg_content, "<!DOCTYPE html>") || strstarts(ctx->msg_content, "<html")) {
ctx->msg_content[0] = 0; ctx->msg_content[0] = 0;
// TODO let relevant information pass? // TODO let relevant information pass?
} }
@ -340,7 +340,7 @@ int respond(client_ctx_t *ctx) {
if (ctx->use_proxy) { if (ctx->use_proxy) {
// reverse proxy // reverse proxy
return 3; return 3;
} else if (strcmp(req->method, "HEAD") != 0) { } else if (!streq(req->method, "HEAD")) {
// default response // default response
if (ctx->msg_buf != NULL) { if (ctx->msg_buf != NULL) {
ret = sock_send(client, ctx->msg_buf, ctx->content_length, 0); ret = sock_send(client, ctx->msg_buf, ctx->content_length, 0);

4
src/worker/tcp_acceptor.c
View File

@ -33,7 +33,7 @@ static int tcp_acceptor(client_ctx_t *ctx) {
struct sockaddr_in6 server_addr; struct sockaddr_in6 server_addr;
inet_ntop(ctx->socket._addr.ipv6.sin6_family, &ctx->socket._addr.ipv6.sin6_addr, ctx->_c_addr, sizeof(ctx->_c_addr)); inet_ntop(ctx->socket._addr.ipv6.sin6_family, &ctx->socket._addr.ipv6.sin6_addr, ctx->_c_addr, sizeof(ctx->_c_addr));
if (strncmp(ctx->_c_addr, "::ffff:", 7) == 0) { if (strstarts(ctx->_c_addr, "::ffff:")) {
ctx->socket.addr = ctx->_c_addr + 7; ctx->socket.addr = ctx->_c_addr + 7;
} else { } else {
ctx->socket.addr = ctx->_c_addr; ctx->socket.addr = ctx->_c_addr;
@ -42,7 +42,7 @@ static int tcp_acceptor(client_ctx_t *ctx) {
socklen_t len = sizeof(server_addr); socklen_t len = sizeof(server_addr);
getsockname(ctx->socket.socket, (struct sockaddr *) &server_addr, &len); getsockname(ctx->socket.socket, (struct sockaddr *) &server_addr, &len);
inet_ntop(server_addr.sin6_family, (void *) &server_addr.sin6_addr, ctx->_s_addr, sizeof(ctx->_s_addr)); inet_ntop(server_addr.sin6_family, (void *) &server_addr.sin6_addr, ctx->_s_addr, sizeof(ctx->_s_addr));
if (strncmp(ctx->_s_addr, "::ffff:", 7) == 0) { if (strstarts(ctx->_s_addr, "::ffff:")) {
ctx->socket.s_addr = ctx->_s_addr + 7; ctx->socket.s_addr = ctx->_s_addr + 7;
} else { } else {
ctx->socket.s_addr = ctx->_s_addr; ctx->socket.s_addr = ctx->_s_addr;