1
0
mirror of https://github.com/falk-werner/webfused synced 2024-10-27 20:44:08 +00:00

switches daemon to config file

This commit is contained in:
Falk Werner 2020-03-17 22:53:38 +01:00
parent b62e9fc67b
commit 5a58025e4a
6 changed files with 129 additions and 98 deletions

View File

@ -59,6 +59,7 @@ add_library(webfused-static STATIC
src/webfused/auth/factory.c src/webfused/auth/factory.c
src/webfused/auth/file_authenticator.c src/webfused/auth/file_authenticator.c
src/webfused/log/logger.c src/webfused/log/logger.c
src/webfused/log/stderr_logger.c
) )
add_executable(webfused add_executable(webfused

View File

@ -4,6 +4,7 @@
#include "webfuse/adapter/credentials.h" #include "webfuse/adapter/credentials.h"
#include "userdb/userdb.h" #include "userdb/userdb.h"
#include "webfused/log/log.h"
#include <stdlib.h> #include <stdlib.h>
#include <string.h> #include <string.h>
@ -45,6 +46,10 @@ wfd_file_authenticator_authenticate(
userdb_dispose(db); userdb_dispose(db);
} }
WFD_INFO("authenticate user \'%s\': %s",
(NULL != username) ? username : "<unknown>",
result ? "success" : "failure");
return result; return result;
} }

View File

@ -11,14 +11,17 @@
#include <getopt.h> #include <getopt.h>
#include <webfuse_adapter.h> #include <webfuse_adapter.h>
#include <userdb/userdb.h> #include "webfused/config/config.h"
#include "webfused/config/factory.h"
#include "webfused/log/stderr_logger.h"
#include "webfused/log/log.h"
#define SERVICE_TIMEOUT (1 * 1000) #define WFD_SERVICE_TIMEOUT (1 * 1000)
#define WFD_DEFAULT_CONFIG_FILE ("/etc/webfuse.conf")
struct args struct args
{ {
struct wf_server_config * config; char * config_file;
char * passwd_path;
bool show_help; bool show_help;
}; };
@ -27,67 +30,35 @@ static bool shutdown_requested = false;
static void show_help(void) static void show_help(void)
{ {
printf( printf(
"webfused, Copyright (c) 2019, webfused authors <https://github.com/falk-werner/webfused>\n" "webfused, Copyright (c) 2019-2020, webfused authors <https://github.com/falk-werner/webfused>\n"
"Websocket file system daemon\n" "Websocket file system daemon\n"
"\n" "\n"
"Usage: webfused [m <mount_point>] [-d <document_root] [-n <vhost_name>] [-p <port>]\n" "Usage: webfused [-f <config file>] | -h\n"
" [-c <server_cert_path>] [-k <server_key_path>] [-P <passwd_path>]\n"
"\n" "\n"
"Options:\n" "Options:\n"
"\t-m, --mount_point Path of mount point (required)\n" "\t-f, --config-file Path to config file (default: /etc/webfuse.conf)\n"
"\t-d, --document_root Path of www directory (default: not set, www disabled)\n" "\t-h, --help Print this message and terminate\n"
"\t-c, --server_cert_path Path of servers own certificate (default: not set, TLS disabled)\n"
"\t-k, --server_key_path Path of servers private key (default: not set, TLS disabled)\n"
"\t-n, --vhost_name Name of virtual host (default: \"localhost\")\n"
"\t-p, --port Number of servers port (default: 8080)\n"
"\t-P, --passwd_path Path to password file (default: not set, authentication disabled)\n"
"\n"); "\n");
} }
static bool authenticate(struct wf_credentials * creds, void * user_data)
{
bool result = false;
struct args * args = user_data;
char const * username = wf_credentials_get(creds, "username");
char const * password = wf_credentials_get(creds, "password");
if ((NULL != username) && (NULL != password))
{
struct userdb * db = userdb_create("");
result = userdb_load(db, args->passwd_path);
if (result)
{
result = userdb_check(db, username, password);
}
userdb_dispose(db);
}
return result;
}
static int parse_arguments(int argc, char * argv[], struct args * args) static int parse_arguments(int argc, char * argv[], struct args * args)
{ {
static struct option const options[] = static struct option const options[] =
{ {
{"mount_point", required_argument, NULL, 'm'}, {"config-file", required_argument, NULL, 'f'},
{"document_root", required_argument, NULL, 'd'},
{"server_cert_path", required_argument, NULL, 'c'},
{"server_key_path", required_argument, NULL, 'k'},
{"vhost_name", required_argument, NULL, 'n'},
{"port", required_argument, NULL, 'p'},
{"passwd_path", required_argument, NULL, 'P'},
{"help", no_argument, NULL, 'h'}, {"help", no_argument, NULL, 'h'},
{NULL, 0, NULL, 0} {NULL, 0, NULL, 0}
}; };
args->config_file = strdup(WFD_DEFAULT_CONFIG_FILE);
args->show_help = false;
bool result = EXIT_SUCCESS; bool result = EXIT_SUCCESS;
bool finished = false; bool finished = false;
bool has_mountpoint = false;
while ((!finished) && (EXIT_SUCCESS == result)) while ((!finished) && (EXIT_SUCCESS == result))
{ {
int option_index = 0; int option_index = 0;
int const c = getopt_long(argc, argv, "m:d:c:k:n:p:P:h", options, &option_index); int const c = getopt_long(argc, argv, "f:h", options, &option_index);
switch (c) switch (c)
{ {
@ -98,32 +69,9 @@ static int parse_arguments(int argc, char * argv[], struct args * args)
args->show_help = true; args->show_help = true;
finished = true; finished = true;
break; break;
case 'm': case 'f':
wf_server_config_set_mountpoint(args->config, optarg); free(args->config_file);
has_mountpoint = true; args->config_file = strdup(optarg);
break;
case 'd':
wf_server_config_set_documentroot(args->config, optarg);
break;
case 'c':
wf_server_config_set_certpath(args->config, optarg);
break;
case 'k':
wf_server_config_set_keypath(args->config, optarg);
break;
case 'n':
wf_server_config_set_vhostname(args->config, optarg);
break;
case 'p':
wf_server_config_set_port(args->config, atoi(optarg));
break;
case 'P':
free(args->passwd_path);
args->passwd_path = strdup(optarg);
wf_server_config_add_authenticator(args->config,
"username",
&authenticate,
args);
break; break;
default: default:
fprintf(stderr, "error: unknown argument\n"); fprintf(stderr, "error: unknown argument\n");
@ -132,15 +80,6 @@ static int parse_arguments(int argc, char * argv[], struct args * args)
} }
} }
if ((EXIT_SUCCESS == result) && (!args->show_help))
{
if (!has_mountpoint)
{
fprintf(stderr, "error: missing mount point\n");
result = EXIT_FAILURE;
}
}
if (EXIT_SUCCESS != result) if (EXIT_SUCCESS != result)
{ {
args->show_help = true; args->show_help = true;
@ -158,24 +97,27 @@ static void on_interrupt(int signal_id)
int wfd_daemon_run(int argc, char * argv[]) int wfd_daemon_run(int argc, char * argv[])
{ {
struct args args; wfd_stderr_logger_init(WFD_LOGLEVEL_ALL);
args.config = wf_server_config_create();
wf_server_config_set_vhostname(args.config, "localhost");
wf_server_config_set_port(args.config, 8080);
args.passwd_path = NULL;
args.show_help = false;
struct args args;
int result = parse_arguments(argc, argv, &args); int result = parse_arguments(argc, argv, &args);
if (!args.show_help) if (!args.show_help)
{ {
signal(SIGINT, on_interrupt); signal(SIGINT, on_interrupt);
struct wf_server * server = wf_server_create(args.config);
struct wfd_config * config = wfd_config_create();
struct wfd_config_builder builder = wfd_config_get_builder(config);
bool success = wfd_config_load_file(builder, args.config_file);
if (success)
{
struct wf_server_config * server_config = wfd_config_get_server_config(config);
struct wf_server * server = wf_server_create(server_config);
if (NULL != server) if (NULL != server)
{ {
while (!shutdown_requested) while (!shutdown_requested)
{ {
wf_server_service(server, SERVICE_TIMEOUT); wf_server_service(server, WFD_SERVICE_TIMEOUT);
} }
wf_server_dispose(server); wf_server_dispose(server);
@ -187,12 +129,19 @@ int wfd_daemon_run(int argc, char * argv[])
} }
} }
else else
{
fprintf(stderr, "fatal: failed to load server config\n");
result = EXIT_FAILURE;
}
wfd_config_dispose(config);
}
else
{ {
show_help(); show_help();
} }
free(args.passwd_path); free(args.config_file);
wf_server_config_dispose(args.config);
return result; return result;
} }

View File

@ -0,0 +1,40 @@
#include "webfused/log/stderr_logger.h"
#include "webfused/log/logger.h"
#include "webfused/log/log.h"
#include <stdio.h>
#include <stdlib.h>
static const char *
wfd_stderr_logger_level_str(int level)
{
switch (level)
{
case WFD_LOGLEVEL_FATAL: return "fatal";
case WFD_LOGLEVEL_ERROR: return "error";
case WFD_LOGLEVEL_WARN: return "warn";
case WFD_LOGLEVEL_INFO: return "info";
case WFD_LOGLEVEL_DEBUG: return "debug";
default: return "notice";
}
}
void
wfd_stderr_logger_log(
void * user_data,
int level,
char const * format,
va_list args)
{
fprintf(stderr, "%s: ", wfd_stderr_logger_level_str(level));
vfprintf(stderr, format, args);
fprintf(stderr, "\n");
}
void
wfd_stderr_logger_init(
int level)
{
wfd_logger_init(level, &wfd_stderr_logger_log, NULL, NULL);
}

View File

@ -0,0 +1,31 @@
#ifndef WFD_LOG_STDERR_LOGGER_H
#define WFD_LOG_STDERR_LOGGER_H
#ifndef __cplusplus
#include <stdarg.h>
#else
#include <cstdarg>
#endif
#ifdef __cplusplus
extern "C"
{
#endif
extern void
wfd_stderr_logger_log(
void * user_data,
int level,
char const * format,
va_list args);
extern void
wfd_stderr_logger_init(
int level);
#ifdef __cplusplus
}
#endif
#endif

View File

@ -141,5 +141,10 @@ wfd_mountpoint_factory_create_mountpoint(
wf_mountpoint_set_userdata(result, wf_mountpoint_set_userdata(result,
&fs->in_use, &wfd_mountpoint_factory_release_mountpoint); &fs->in_use, &wfd_mountpoint_factory_release_mountpoint);
WFD_INFO("create mountpoint \'%s\' at path \'%s\': %s",
filesystem,
fs->mount_point,
result ? "success" : "failure");
return result; return result;
} }