mirror of
https://github.com/falk-werner/webfuse
synced 2024-10-27 20:34:10 +00:00
87f34fa768
* moves server into session * renames jsonrpc server to jsonrpc proxy * moves server into session * renames jsonrpc server to jsonrpc proxy * adds json rpc server * removes obsolete proxy from protocol * changes interface of jsonrpc_proxy_onresult to accept previously parsed messages * adds infrastructure to process incoming requests; fixes invalid read of ill formatted responses * adds description of authentication request * adds authentication request * adds userdb for authentication purposes * removes debug code: console.log() * fixes cmake build error (missing openssl symbols) * fixes typo * replaces ASCII art by UML diagram * renames BAD_NOACCESS to BAD_ACCESS_DENIED * fixes style * adds docu of authentication * ignored false positives of flawfinder * fixes style issues * fixes javascript style issues
101 lines
2.6 KiB
C
101 lines
2.6 KiB
C
#include "webfuse/adapter/impl/operations.h"
|
|
|
|
#include <errno.h>
|
|
#include <string.h>
|
|
|
|
#include <sys/types.h>
|
|
#include <sys/stat.h>
|
|
#include <unistd.h>
|
|
|
|
#include "webfuse/adapter/impl/jsonrpc/proxy.h"
|
|
#include "webfuse/adapter/impl/jsonrpc/util.h"
|
|
#include "webfuse/core/util.h"
|
|
|
|
struct wf_impl_operation_getattr_context
|
|
{
|
|
fuse_req_t request;
|
|
double timeout;
|
|
uid_t uid;
|
|
gid_t gid;
|
|
};
|
|
|
|
static void wf_impl_operation_getattr_finished(
|
|
void * user_data,
|
|
wf_status status,
|
|
json_t const * data)
|
|
{
|
|
struct wf_impl_operation_getattr_context * context = user_data;
|
|
|
|
struct stat buffer;
|
|
if (NULL != data)
|
|
{
|
|
json_t * mode_holder = json_object_get(data, "mode");
|
|
json_t * type_holder = json_object_get(data, "type");
|
|
if ((NULL != mode_holder) && (json_is_integer(mode_holder)) &&
|
|
(NULL != type_holder) && (json_is_string(type_holder)))
|
|
{
|
|
memset(&buffer, 0, sizeof(struct stat));
|
|
|
|
buffer.st_mode = json_integer_value(mode_holder) & 0555;
|
|
char const * type = json_string_value(type_holder);
|
|
if (0 == strcmp("file", type))
|
|
{
|
|
buffer.st_mode |= S_IFREG;
|
|
}
|
|
else if (0 == strcmp("dir", type))
|
|
{
|
|
buffer.st_mode |= S_IFDIR;
|
|
}
|
|
|
|
buffer.st_uid = context->uid;
|
|
buffer.st_gid = context->gid;
|
|
buffer.st_nlink = 1;
|
|
buffer.st_size = wf_impl_json_get_int(data, "size", 0);
|
|
buffer.st_atime = wf_impl_json_get_int(data, "atime", 0);
|
|
buffer.st_mtime = wf_impl_json_get_int(data, "mtime", 0);
|
|
buffer.st_ctime = wf_impl_json_get_int(data, "ctime", 0);
|
|
|
|
}
|
|
else
|
|
{
|
|
status = WF_BAD_FORMAT;
|
|
}
|
|
}
|
|
|
|
if (WF_GOOD == status)
|
|
{
|
|
fuse_reply_attr(context->request, &buffer, context->timeout);
|
|
}
|
|
else
|
|
{
|
|
fuse_reply_err(context->request, ENOENT);
|
|
}
|
|
|
|
free(context);
|
|
}
|
|
|
|
void wf_impl_operation_getattr (
|
|
fuse_req_t request,
|
|
fuse_ino_t inode,
|
|
struct fuse_file_info * WF_UNUSED_PARAM(file_info))
|
|
{
|
|
struct fuse_ctx const * context = fuse_req_ctx(request);
|
|
struct wf_impl_operations_context * user_data = fuse_req_userdata(request);
|
|
struct wf_impl_jsonrpc_proxy * rpc = wf_impl_operations_context_get_proxy(user_data, inode);
|
|
|
|
if (NULL != rpc)
|
|
{
|
|
struct wf_impl_operation_getattr_context * getattr_context = malloc(sizeof(struct wf_impl_operation_getattr_context));
|
|
getattr_context->request = request;
|
|
getattr_context->uid = context->uid;
|
|
getattr_context->gid = context->gid;
|
|
getattr_context->timeout = user_data->timeout;
|
|
|
|
wf_impl_jsonrpc_proxy_invoke(rpc, &wf_impl_operation_getattr_finished, getattr_context, "getattr", "i", inode);
|
|
}
|
|
else
|
|
{
|
|
fuse_reply_err(request, ENOENT);
|
|
}
|
|
}
|