builtin/client_data

This commit is contained in:
Perttu Ahola 2014-09-19 15:47:21 +03:00
parent acbce6c19f
commit 3176478881
4 changed files with 105 additions and 7 deletions

View File

@ -0,0 +1,104 @@
#include "core/log.h"
#include "interface/module.h"
#include "interface/server.h"
#include "interface/event.h"
#include "interface/fs.h"
#include "client_file/include/api.h"
#include "network/include/api.h"
#include <cereal/archives/binary.hpp>
#include <cereal/types/string.hpp>
#include <fstream>
#include <streambuf>
using interface::Event;
namespace client_data {
struct Module: public interface::Module
{
interface::Server *m_server;
Module(interface::Server *server):
m_server(server),
interface::Module("client_data")
{
log_v(MODULE, "client_data construct");
}
~Module()
{
log_v(MODULE, "client_data destruct");
}
void init()
{
log_v(MODULE, "client_data init");
m_server->sub_event(this, Event::t("core:start"));
m_server->sub_event(this, Event::t("core:module_loaded"));
m_server->sub_event(this, Event::t("core:module_unloaded"));
m_server->sub_event(this, Event::t("network:new_client"));
}
void event(const Event::Type &type, const Event::Private *p)
{
EVENT_VOIDN("core:start", on_start)
EVENT_TYPEN("core:module_loaded", on_module_loaded,
interface::ModuleLoadedEvent)
EVENT_TYPEN("core:module_unloaded", on_module_unloaded,
interface::ModuleUnloadedEvent)
EVENT_TYPEN("network:new_client", on_new_client, network::NewClient)
}
void on_start()
{
}
void on_module_loaded(const interface::ModuleLoadedEvent &event)
{
log_v(MODULE, "on_module_loaded(): %s", cs(event.name));
ss_ module_name = event.name;
ss_ module_path = m_server->get_module_path(module_name);
ss_ client_data_path = module_path+"/client_data";
auto list = interface::getGlobalFilesystem()
->list_directory(client_data_path);
sv_<ss_> log_list;
for(const interface::Filesystem::Node &n : list){
if(n.is_directory)
continue;
log_list.push_back(n.name);
}
log_i(MODULE, "client_data: %s: %s", cs(module_name), cs(dump(log_list)));
for(const interface::Filesystem::Node &n : list){
if(n.is_directory)
continue;
const ss_ &file_name = n.name;
std::ifstream f(client_data_path+"/"+file_name);
std::string file_content((std::istreambuf_iterator<char>(f)),
std::istreambuf_iterator<char>());
const ss_ &public_file_name = module_name+"/"+n.name;
client_file::access(m_server, [&](client_file::Interface * i){
i->add_file_content(public_file_name, file_content);
});
}
}
void on_module_unloaded(const interface::ModuleUnloadedEvent &event)
{
log_v(MODULE, "on_module_unloaded(): %s", cs(event.name));
// TODO
}
void on_new_client(const network::NewClient &new_client)
{
}
};
extern "C" {
EXPORT void* createModule_client_data(interface::Server *server){
return (void*)(new Module(server));
}
}
}

View File

@ -4,7 +4,6 @@
#include "interface/event.h"
#include "interface/fs.h"
#include "client_file/include/api.h"
#include "client_lua/include/api.h"
#include "network/include/api.h"
#include <cereal/archives/binary.hpp>
#include <cereal/types/string.hpp>

View File

@ -1,6 +0,0 @@
#pragma once
#include "interface/event.h"
namespace client_lua
{
}

View File

@ -44,6 +44,7 @@ struct Module: public interface::Module
m_server->load_module("network", builtin+"/network");
m_server->load_module("client_file", builtin+"/client_file");
m_server->load_module("client_lua", builtin+"/client_lua");
m_server->load_module("client_data", builtin+"/client_data");
sv_<ss_> load_list = {
"test1",