crtxcr/qswiki
1
0
Fork 0
Code Issues 21 Pull Requests 1 Releases Activity

qswiki: Add background worker, currently to clean old sessions mainly

Browse Source
This commit is contained in:
Albert S. 2023-02-01 18:55:13 +01:00
parent f160ac8102
commit af1734e7bf
1 changed files with 31 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
qswiki.cpp
View File

@ -31,8 +31,8 @@ SOFTWARE.
#include "handlers/handlerfactory.h" #include "handlers/handlerfactory.h"
#include "database/databasefactory.h" #include "database/databasefactory.h"
#include "config.h" #include "config.h"
#include "template.h"
#include "session.h" #include "session.h"
#include "template.h"
#include "logger.h" #include "logger.h"
#include "urlprovider.h" #include "urlprovider.h"
#include "requestworker.h" #include "requestworker.h"
@ -74,6 +74,33 @@ std::unique_ptr<ICache> createCache(const ConfigVariableResolver &resolver)
return std::make_unique<FsCache>(path); return std::make_unique<FsCache>(path);
} }
std::thread background_worker;
void start_background_worker(Database &database, Config &config)
{
background_worker = std::thread(
[&database, &config]()
{
while(true)
{
Logger::log() << "Executing background worker";
auto sessionDao = database.createSessionDao();
auto sessionList = sessionDao->fetch();
time_t now = time(NULL);
for(Session &sess : sessionList)
{
if(now - sess.creation_time > config.session_max_lifetime)
{
sessionDao->deleteSession(sess.token);
}
}
std::this_thread::sleep_for(std::chrono::hours(1));
}
});
}
int main(int argc, char **argv) int main(int argc, char **argv)
{ {
@ -136,6 +163,7 @@ int main(int argc, char **argv)
Logger::setStream(&logstream); Logger::setStream(&logstream);
auto database = createDatabase(config); auto database = createDatabase(config);
std::string socketPath = config.configVarResolver.getConfig("socketpath"); std::string socketPath = config.configVarResolver.getConfig("socketpath");
CLIHandler cliHandler(config, *database); CLIHandler cliHandler(config, *database);
@ -158,6 +186,8 @@ int main(int argc, char **argv)
exit(EXIT_FAILURE); exit(EXIT_FAILURE);
} }
start_background_worker(*database.get(), config);
CLIServer cliServer{cliHandler}; CLIServer cliServer{cliHandler};
if(!cliServer.detachServer(socketPath)) if(!cliServer.detachServer(socketPath))
{ {