mirror of
https://onedev.site.tesses.net/tesses-framework
synced 2026-02-09 00:05:46 +00:00
Compare commits
12 Commits
7dc4ad9b08
...
master
| Author | SHA1 | Date | |
|---|---|---|---|
| adf11bd144 | |||
| f53bacb18b | |||
| 94eb56aad6 | |||
| 4efd654941 | |||
| 34b484f633 | |||
| 96ba20d65c | |||
| f825c2616a | |||
| 67874eba30 | |||
| 8eb7e050c0 | |||
| e96b359bb8 | |||
| 848fca7f36 | |||
| 2f5271f7c3 |
44
.gitea/workflows/tag.yaml
Normal file
44
.gitea/workflows/tag.yaml
Normal file
@@ -0,0 +1,44 @@
|
|||||||
|
name: Build and Deploy on Tag
|
||||||
|
on:
|
||||||
|
push:
|
||||||
|
tags:
|
||||||
|
- 'v*'
|
||||||
|
|
||||||
|
env:
|
||||||
|
GITEA_AUTH: ${{ secrets.MY_GITEA_AUTH }}
|
||||||
|
|
||||||
|
jobs:
|
||||||
|
build-arch:
|
||||||
|
runs-on: arch-builder
|
||||||
|
steps:
|
||||||
|
- run: pacman --noconfirm -Sy nodejs npm
|
||||||
|
- uses: actions/checkout@v4
|
||||||
|
- run: pacman --noconfirm -Sy mbedtls curl
|
||||||
|
- run: pacman --config /opt/cross/ppc/pacman.conf --noconfirm -Sy mbedtls
|
||||||
|
- run: cp Packaging/Linux/PKGBUILD /home/build/PKGBUILD
|
||||||
|
- run: cp Packaging/Linux/build-arch.sh /home/build/build-arch.sh
|
||||||
|
- run: chmod 755 /home/build/build-arch.sh
|
||||||
|
- run: chown build:build /home/build/PKGBUILD
|
||||||
|
- run: chown build:build /home/build/build-arch.sh
|
||||||
|
- run: su build -c /home/build/build-arch.sh
|
||||||
|
build-jammy:
|
||||||
|
runs-on: deb-builder-jammy
|
||||||
|
steps:
|
||||||
|
- uses: actions/checkout@v4
|
||||||
|
- name: Build for jammy, noble
|
||||||
|
run: |
|
||||||
|
bash build-ubuntu-jammy.sh
|
||||||
|
bash push-ubuntu-jammy.sh
|
||||||
|
working-directory: ./Packaging/Linux
|
||||||
|
build-plucky:
|
||||||
|
runs-on: deb-builder-plucky
|
||||||
|
steps:
|
||||||
|
- uses: actions/checkout@v4
|
||||||
|
- name: Build for plucky, resolute
|
||||||
|
run: |
|
||||||
|
bash build-ubuntu-plucky.sh
|
||||||
|
bash push-ubuntu-plucky.sh
|
||||||
|
working-directory: ./Packaging/Linux
|
||||||
|
- uses: akkuman/gitea-release-action@v1
|
||||||
|
env:
|
||||||
|
NODE_OPTIONS: '--experimental-fetch' # if nodejs < 18
|
||||||
@@ -1,18 +1,21 @@
|
|||||||
version: 39
|
version: 43
|
||||||
jobs:
|
jobs:
|
||||||
- name: Build for x86_64
|
- name: Build for x86_64
|
||||||
steps:
|
steps:
|
||||||
- !CheckoutStep
|
- type: CheckoutStep
|
||||||
name: Checkout
|
name: Checkout
|
||||||
cloneCredential: !DefaultCredential {}
|
cloneCredential:
|
||||||
|
type: DefaultCredential
|
||||||
withLfs: true
|
withLfs: true
|
||||||
withSubmodules: false
|
withSubmodules: false
|
||||||
condition: ALL_PREVIOUS_STEPS_WERE_SUCCESSFUL
|
condition: SUCCESSFUL
|
||||||
- !CommandStep
|
optional: false
|
||||||
|
- type: CommandStep
|
||||||
name: Execute build
|
name: Execute build
|
||||||
runInContainer: true
|
runInContainer: true
|
||||||
image: onedev.site.tesses.net/dependencies/dependencies:latest
|
image: onedev.site.tesses.net/dependencies/dependencies:latest
|
||||||
interpreter: !DefaultInterpreter
|
interpreter:
|
||||||
|
type: DefaultInterpreter
|
||||||
commands: |
|
commands: |
|
||||||
mkdir build
|
mkdir build
|
||||||
cd build
|
cd build
|
||||||
@@ -20,72 +23,28 @@ jobs:
|
|||||||
make -j12
|
make -j12
|
||||||
make install DESTDIR=out
|
make install DESTDIR=out
|
||||||
useTTY: true
|
useTTY: true
|
||||||
condition: ALL_PREVIOUS_STEPS_WERE_SUCCESSFUL
|
condition: SUCCESSFUL
|
||||||
- !BuildImageStep
|
optional: false
|
||||||
|
- type: BuildImageStep
|
||||||
name: Build Docker Image
|
name: Build Docker Image
|
||||||
dockerfile: Dockerfile.run
|
dockerfile: Dockerfile.run
|
||||||
output: !RegistryOutput
|
output:
|
||||||
tags: onedev.site.tesses.net/tesses-framework/tesses-framework:latest onedev.site.tesses.net/tesses-framework/tesses-framework:@commit_hash@
|
type: RegistryOutput
|
||||||
|
tags: onedev.site.tesses.net/tesses-framework/tesses-framework:latest onedev.site.tesses.net/tesses-framework/tesses-framework:@commit_hash@ git.tesseslanguage.com/tesses50/tesses-framework:latest git.tesseslanguage.com/tesses50/tesses-framework:@commit_hash@
|
||||||
registryLogins:
|
registryLogins:
|
||||||
- registryUrl: '@server_url@'
|
- registryUrl: '@server_url@'
|
||||||
userName: '@job_token@'
|
userName: '@job_token@'
|
||||||
passwordSecret: dockersecret
|
passwordSecret: dockersecret
|
||||||
|
- registryUrl: git.tesseslanguage.com
|
||||||
|
userName: tesses50
|
||||||
|
passwordSecret: GITEA_AUTH
|
||||||
platforms: linux/amd64
|
platforms: linux/amd64
|
||||||
condition: ALL_PREVIOUS_STEPS_WERE_SUCCESSFUL
|
condition: SUCCESSFUL
|
||||||
- !CommandStep
|
optional: false
|
||||||
name: Build archlinux
|
|
||||||
runInContainer: true
|
|
||||||
image: git.tesseslanguage.com/tesses50/arch-builds:2025-11-11
|
|
||||||
interpreter: !DefaultInterpreter
|
|
||||||
commands: |
|
|
||||||
pacman --noconfirm -Sy mbedtls curl
|
|
||||||
pacman --config /opt/cross/ppc/pacman.conf --noconfirm -Sy mbedtls
|
|
||||||
cp Packaging/Linux/PKGBUILD /home/build/PKGBUILD
|
|
||||||
cp Packaging/Linux/build-arch.sh /home/build/build-arch.sh
|
|
||||||
chmod 755 /home/build/build-arch.sh
|
|
||||||
chown build:build /home/build/PKGBUILD
|
|
||||||
chown build:build /home/build/build-arch.sh
|
|
||||||
su build -c /home/build/build-arch.sh
|
|
||||||
envVars:
|
|
||||||
- name: GITEA_AUTH
|
|
||||||
value: '@secret:GITEA_AUTH@'
|
|
||||||
useTTY: true
|
|
||||||
condition: ALL_PREVIOUS_STEPS_WERE_SUCCESSFUL
|
|
||||||
- !CommandStep
|
|
||||||
name: Build and Publish Deb Package
|
|
||||||
runInContainer: true
|
|
||||||
image: onedev.site.tesses.net/dependencies/debbuilder/jammy:latest
|
|
||||||
interpreter: !DefaultInterpreter
|
|
||||||
commands: |
|
|
||||||
cd Packaging/Linux
|
|
||||||
bash build-ubuntu-jammy.sh
|
|
||||||
bash push-ubuntu-jammy.sh
|
|
||||||
envVars:
|
|
||||||
- name: GITEA_AUTH
|
|
||||||
value: '@secret:GITEA_AUTH@'
|
|
||||||
- name: BUILD_NO
|
|
||||||
value: '@build_number@'
|
|
||||||
useTTY: true
|
|
||||||
condition: ALL_PREVIOUS_STEPS_WERE_SUCCESSFUL
|
|
||||||
- !CommandStep
|
|
||||||
name: Build and Publish Deb Package (Plucky)
|
|
||||||
runInContainer: true
|
|
||||||
image: onedev.site.tesses.net/dependencies/debbuilder/plucky:latest
|
|
||||||
interpreter: !DefaultInterpreter
|
|
||||||
commands: |
|
|
||||||
cd Packaging/Linux
|
|
||||||
bash build-ubuntu-plucky.sh
|
|
||||||
bash push-ubuntu-plucky.sh
|
|
||||||
envVars:
|
|
||||||
- name: GITEA_AUTH
|
|
||||||
value: '@secret:GITEA_AUTH@'
|
|
||||||
- name: BUILD_NO
|
|
||||||
value: '@build_number@'
|
|
||||||
useTTY: true
|
|
||||||
condition: ALL_PREVIOUS_STEPS_WERE_SUCCESSFUL
|
|
||||||
triggers:
|
triggers:
|
||||||
- !BranchUpdateTrigger
|
- type: BranchUpdateTrigger
|
||||||
branches: master
|
branches: master
|
||||||
|
userMatch: anyone
|
||||||
projects: tesses-framework
|
projects: tesses-framework
|
||||||
retryCondition: never
|
retryCondition: never
|
||||||
maxRetries: 3
|
maxRetries: 3
|
||||||
|
|||||||
@@ -1,6 +1,10 @@
|
|||||||
cmake_minimum_required(VERSION 3.16)
|
cmake_minimum_required(VERSION 3.16)
|
||||||
|
|
||||||
project(TessesFramework VERSION 1.0.0)
|
set(TESSESFRAMEWORK_MAJOR_VERSION 0)
|
||||||
|
set(TESSESFRAMEWORK_MINOR_VERSION 0)
|
||||||
|
set(TESSESFRAMEWORK_PATCH_VERSION 1)
|
||||||
|
|
||||||
|
project(TessesFramework VERSION ${TESSESFRAMEWORK_MAJOR_VERSION}.${TESSESFRAMEWORK_MINOR_VERSION}.${TESSESFRAMEWORK_PATCH_VERSION})
|
||||||
|
|
||||||
set(CMAKE_CXX_STANDARD 17)
|
set(CMAKE_CXX_STANDARD 17)
|
||||||
|
|
||||||
@@ -9,6 +13,7 @@ src/Random.cpp
|
|||||||
src/Date/Date.cpp
|
src/Date/Date.cpp
|
||||||
src/Http/FileServer.cpp
|
src/Http/FileServer.cpp
|
||||||
src/Http/MountableServer.cpp
|
src/Http/MountableServer.cpp
|
||||||
|
src/Http/RouteServer.cpp
|
||||||
src/Http/CallbackServer.cpp
|
src/Http/CallbackServer.cpp
|
||||||
src/Http/HttpServer.cpp
|
src/Http/HttpServer.cpp
|
||||||
src/Http/HttpUtils.cpp
|
src/Http/HttpUtils.cpp
|
||||||
@@ -408,6 +413,11 @@ add_executable(trng apps/trng.cpp)
|
|||||||
|
|
||||||
target_link_libraries(trng PUBLIC tessesframework)
|
target_link_libraries(trng PUBLIC tessesframework)
|
||||||
install(TARGETS trng DESTINATION "${CMAKE_INSTALL_BINDIR}")
|
install(TARGETS trng DESTINATION "${CMAKE_INSTALL_BINDIR}")
|
||||||
|
|
||||||
|
add_executable(twatch apps/twatch.cpp)
|
||||||
|
|
||||||
|
target_link_libraries(twatch PUBLIC tessesframework)
|
||||||
|
install(TARGETS twatch DESTINATION "${CMAKE_INSTALL_BINDIR}")
|
||||||
endif()
|
endif()
|
||||||
|
|
||||||
include(InstallRequiredSystemLibraries)
|
include(InstallRequiredSystemLibraries)
|
||||||
|
|||||||
7
Dockerfile.portable-json-creator
Normal file
7
Dockerfile.portable-json-creator
Normal file
@@ -0,0 +1,7 @@
|
|||||||
|
FROM onedev.site.tesses.net/tesses-framework/tesses-framework:latest
|
||||||
|
|
||||||
|
COPY ./portable-json-creator /wwwroot
|
||||||
|
|
||||||
|
EXPOSE 4999
|
||||||
|
|
||||||
|
ENTRYPOINT ["tfileserver","--port","4999","/wwwroot"]
|
||||||
@@ -1,6 +1,6 @@
|
|||||||
# Maintainer: Mike Nolan <tesses@tesses.net>
|
# Maintainer: Mike Nolan <tesses@tesses.net>
|
||||||
pkgname=tesses-framework # '-bzr', '-git', '-hg' or '-svn'
|
pkgname=tesses-framework # '-bzr', '-git', '-hg' or '-svn'
|
||||||
pkgver=1.0.0
|
pkgver=0.0.1
|
||||||
pkgrel=1
|
pkgrel=1
|
||||||
pkgdesc=""
|
pkgdesc=""
|
||||||
arch=('x86_64' 'powerpc')
|
arch=('x86_64' 'powerpc')
|
||||||
@@ -18,21 +18,7 @@ options=(!strip)
|
|||||||
else
|
else
|
||||||
options=(!buildflags !strip)
|
options=(!buildflags !strip)
|
||||||
fi
|
fi
|
||||||
# Please refer to the 'USING VCS SOURCES' section of the PKGBUILD man page for
|
|
||||||
# a description of each element in the source array.
|
|
||||||
|
|
||||||
pkgver() {
|
|
||||||
cd "$srcdir/${pkgname}"
|
|
||||||
|
|
||||||
# The examples below are not absolute and need to be adapted to each repo. The
|
|
||||||
# primary goal is to generate version numbers that will increase according to
|
|
||||||
# pacman's version comparisons with later commits to the repo. The format
|
|
||||||
# VERSION='VER_NUM.rREV_NUM.HASH', or a relevant subset in case VER_NUM or HASH
|
|
||||||
# are not available, is recommended.
|
|
||||||
|
|
||||||
# Git, no tags available
|
|
||||||
printf "r%s.%s" "$(git rev-list --count HEAD)" "$(git rev-parse --short HEAD)"
|
|
||||||
}
|
|
||||||
|
|
||||||
prepare() {
|
prepare() {
|
||||||
cd "$srcdir/${pkgname}"
|
cd "$srcdir/${pkgname}"
|
||||||
|
|||||||
@@ -1,2 +1 @@
|
|||||||
export BUILD=$(($BUILD_NO-163))
|
export DEB_VERSION=0.0.1
|
||||||
export DEB_VERSION=1.0.0-$BUILD
|
|
||||||
@@ -1,6 +1,11 @@
|
|||||||
#pragma once
|
#pragma once
|
||||||
#define TESSES_FRAMEWORK_FLAG_OFF 0
|
#define TESSES_FRAMEWORK_FLAG_OFF 0
|
||||||
#define TESSES_FRAMEWORK_FLAG_ON 1
|
#define TESSES_FRAMEWORK_FLAG_ON 1
|
||||||
|
|
||||||
|
#define TESSES_FRAMEWORK_MAJOR @TESSESFRAMEWORK_MAJOR_VERSION@
|
||||||
|
#define TESSES_FRAMEWORK_MINOR @TESSESFRAMEWORK_MINOR_VERSION@
|
||||||
|
#define TESSES_FRAMEWORK_PATCH @TESSESFRAMEWORK_PATCH_VERSION@
|
||||||
|
|
||||||
#if defined(TESSES_FRAMEWORK_FLAG_@TESSESFRAMEWORK_ENABLE_SQLITE@) && !defined(TESSESFRAMEWORK_ENABLE_SQLITE)
|
#if defined(TESSES_FRAMEWORK_FLAG_@TESSESFRAMEWORK_ENABLE_SQLITE@) && !defined(TESSESFRAMEWORK_ENABLE_SQLITE)
|
||||||
#define TESSESFRAMEWORK_ENABLE_SQLITE
|
#define TESSESFRAMEWORK_ENABLE_SQLITE
|
||||||
#endif
|
#endif
|
||||||
|
|||||||
24
apps/twatch.cpp
Normal file
24
apps/twatch.cpp
Normal file
@@ -0,0 +1,24 @@
|
|||||||
|
#include <TessesFramework/TessesFramework.hpp>
|
||||||
|
|
||||||
|
using namespace Tesses::Framework;
|
||||||
|
using namespace Tesses::Framework::Filesystem;
|
||||||
|
using namespace Tesses::Framework::Filesystem::Literals;
|
||||||
|
|
||||||
|
int main(int argc, char** argv)
|
||||||
|
{
|
||||||
|
TF_Init();
|
||||||
|
if(argc<2)
|
||||||
|
{
|
||||||
|
std::cout << "USAGE " << argv[0] << " <file|dir>" << std::endl;
|
||||||
|
return 1;
|
||||||
|
}
|
||||||
|
|
||||||
|
auto watcher=FSWatcher::Create(LocalFS,VFSPath{argv[1]});
|
||||||
|
watcher->events = FSWatcherEventType::All;
|
||||||
|
watcher->event = [](FSWatcherEvent& evt)->void{
|
||||||
|
std::cout << evt.ToString() << std::endl;
|
||||||
|
};
|
||||||
|
watcher->SetEnabled(true);
|
||||||
|
TF_RunEventLoop();
|
||||||
|
return 0;
|
||||||
|
}
|
||||||
5
docker-compose/portable-json-creator/docker-compose.yml
Normal file
5
docker-compose/portable-json-creator/docker-compose.yml
Normal file
@@ -0,0 +1,5 @@
|
|||||||
|
services:
|
||||||
|
portable-json:
|
||||||
|
image: onedev.site.tesses.net/tesses-framework/portable-json-creator:latest
|
||||||
|
ports:
|
||||||
|
- "4999:4999"
|
||||||
@@ -139,11 +139,35 @@ class MyOtherWebServer : public IHttpServer
|
|||||||
int main(int argc, char** argv)
|
int main(int argc, char** argv)
|
||||||
{
|
{
|
||||||
TF_InitWithConsole();
|
TF_InitWithConsole();
|
||||||
|
std::shared_ptr<RouteServer> routeSvr = std::make_shared<RouteServer>();
|
||||||
|
routeSvr->Get("/name/{name}/greeting",[](ServerContext& ctx)->bool{
|
||||||
|
std::string name;
|
||||||
|
if(ctx.pathArguments.TryGetFirst("name",name))
|
||||||
|
{
|
||||||
|
ctx.WithMimeType("text/plain").SendText("Hello " + name);
|
||||||
|
}
|
||||||
|
else {
|
||||||
|
ctx.WithMimeType("text/plain").SendText("Please provide a name");
|
||||||
|
}
|
||||||
|
return true;
|
||||||
|
});
|
||||||
|
routeSvr->Get("/name/{name}/length",[](ServerContext& ctx)->bool{
|
||||||
|
std::string name;
|
||||||
|
if(ctx.pathArguments.TryGetFirst("name",name))
|
||||||
|
{
|
||||||
|
ctx.WithMimeType("text/plain").SendText("The length of the name is " + std::to_string(name.size()));
|
||||||
|
}
|
||||||
|
else {
|
||||||
|
ctx.WithMimeType("text/plain").SendText("Please provide a name");
|
||||||
|
}
|
||||||
|
return true;
|
||||||
|
});
|
||||||
std::shared_ptr<MyOtherWebServer> myo = std::make_shared<MyOtherWebServer>();
|
std::shared_ptr<MyOtherWebServer> myo = std::make_shared<MyOtherWebServer>();
|
||||||
std::shared_ptr<MyWebServer> mws = std::make_shared<MyWebServer>();
|
std::shared_ptr<MyWebServer> mws = std::make_shared<MyWebServer>();
|
||||||
|
|
||||||
std::shared_ptr<MountableServer> mountable = std::make_shared<MountableServer>(myo);
|
std::shared_ptr<MountableServer> mountable = std::make_shared<MountableServer>(myo);
|
||||||
mountable->Mount("/mymount/",mws);
|
mountable->Mount("/mymount/",mws);
|
||||||
|
mountable->Mount("/routeSvr/", routeSvr);
|
||||||
HttpServer server(10001,mountable);
|
HttpServer server(10001,mountable);
|
||||||
server.StartAccepting();
|
server.StartAccepting();
|
||||||
TF_RunEventLoop();
|
TF_RunEventLoop();
|
||||||
|
|||||||
@@ -10,9 +10,11 @@
|
|||||||
#include <functional>
|
#include <functional>
|
||||||
#include "Threading/Mutex.hpp"
|
#include "Threading/Mutex.hpp"
|
||||||
#include <optional>
|
#include <optional>
|
||||||
|
#include <atomic>
|
||||||
|
|
||||||
namespace Tesses::Framework
|
namespace Tesses::Framework
|
||||||
{
|
{
|
||||||
|
|
||||||
template<typename...TArgs>
|
template<typename...TArgs>
|
||||||
class Event {
|
class Event {
|
||||||
public:
|
public:
|
||||||
@@ -90,6 +92,7 @@ namespace Tesses::Framework
|
|||||||
|
|
||||||
extern EventList<uint64_t> OnItteraton;
|
extern EventList<uint64_t> OnItteraton;
|
||||||
std::optional<std::string> TF_GetCommandName();
|
std::optional<std::string> TF_GetCommandName();
|
||||||
|
|
||||||
void TF_Init();
|
void TF_Init();
|
||||||
void TF_InitWithConsole();
|
void TF_InitWithConsole();
|
||||||
void TF_AllowPortable(std::string argv0);
|
void TF_AllowPortable(std::string argv0);
|
||||||
|
|||||||
@@ -42,6 +42,9 @@ namespace Tesses::Framework::Filesystem
|
|||||||
void Lock(VFSPath path);
|
void Lock(VFSPath path);
|
||||||
void Unlock(VFSPath path);
|
void Unlock(VFSPath path);
|
||||||
|
|
||||||
|
protected:
|
||||||
|
std::shared_ptr<FSWatcher> CreateWatcher(std::shared_ptr<VFS> vfs, VFSPath path);
|
||||||
|
|
||||||
};
|
};
|
||||||
extern std::shared_ptr<LocalFilesystem> LocalFS;
|
extern std::shared_ptr<LocalFilesystem> LocalFS;
|
||||||
}
|
}
|
||||||
@@ -8,6 +8,7 @@
|
|||||||
|
|
||||||
namespace Tesses::Framework::Filesystem
|
namespace Tesses::Framework::Filesystem
|
||||||
{
|
{
|
||||||
|
|
||||||
class StatVFSData {
|
class StatVFSData {
|
||||||
public:
|
public:
|
||||||
uint64_t BlockSize;
|
uint64_t BlockSize;
|
||||||
@@ -29,13 +30,15 @@ namespace Tesses::Framework::Filesystem
|
|||||||
static std::vector<std::string> SplitPath(std::string path);
|
static std::vector<std::string> SplitPath(std::string path);
|
||||||
std::vector<std::string> path;
|
std::vector<std::string> path;
|
||||||
VFSPath();
|
VFSPath();
|
||||||
|
explicit VFSPath(const char* path) : VFSPath(std::string(path))
|
||||||
|
{}
|
||||||
VFSPath(std::vector<std::string> path);
|
VFSPath(std::vector<std::string> path);
|
||||||
VFSPath(std::string path);
|
VFSPath(std::string path);
|
||||||
VFSPath(VFSPath p, std::string subent);
|
VFSPath(VFSPath p, std::string subent);
|
||||||
VFSPath(VFSPath p, VFSPath p2);
|
VFSPath(VFSPath p, VFSPath p2);
|
||||||
|
|
||||||
|
//does not check for ?
|
||||||
|
static VFSPath ParseUriPath(std::string path);
|
||||||
|
|
||||||
VFSPath GetParent() const;
|
VFSPath GetParent() const;
|
||||||
VFSPath CollapseRelativeParents() const;
|
VFSPath CollapseRelativeParents() const;
|
||||||
@@ -117,7 +120,74 @@ namespace Tesses::Framework::Filesystem
|
|||||||
|
|
||||||
VFSPathEnumeratorItterator end();
|
VFSPathEnumeratorItterator end();
|
||||||
};
|
};
|
||||||
|
enum class FSWatcherEventType {
|
||||||
|
|
||||||
|
None = 0,
|
||||||
|
//IN_ACCESS
|
||||||
|
Accessed=1,
|
||||||
|
//IN_ATTRIB
|
||||||
|
AttributeChanged =2,
|
||||||
|
//IN_CLOSE_WRITE
|
||||||
|
Writen = 4,
|
||||||
|
//IN_CLOSE_NOWRITE
|
||||||
|
Read = 8,
|
||||||
|
//IN_CREATE
|
||||||
|
Created = 16,
|
||||||
|
//IN_DELETE
|
||||||
|
Deleted = 32,
|
||||||
|
//IN_DELETE_SELF
|
||||||
|
WatchEntryDeleted = 64,
|
||||||
|
//IN_MODIFY
|
||||||
|
Modified = 128,
|
||||||
|
//IN_MOVE_SELF
|
||||||
|
WatchEntryMoved = 256,
|
||||||
|
//IN_MOVED_FROM
|
||||||
|
MoveOld = 512,
|
||||||
|
//IN_MOVED_TO
|
||||||
|
MoveNew = 1024,
|
||||||
|
//IN_OPEN
|
||||||
|
Opened = 2048,
|
||||||
|
//IN_CLOSE
|
||||||
|
Closed = Writen | Read,
|
||||||
|
//IN_MOVE
|
||||||
|
Moved = MoveOld | MoveNew,
|
||||||
|
//IN_ALL_EVENTS
|
||||||
|
All = Accessed | AttributeChanged | Created | Deleted | WatchEntryDeleted | Modified | WatchEntryMoved | Opened | Closed | Moved
|
||||||
|
};
|
||||||
|
struct FSWatcherEvent {
|
||||||
|
//the file or source on move
|
||||||
|
VFSPath src;
|
||||||
|
//the dest when moving
|
||||||
|
VFSPath dest;
|
||||||
|
FSWatcherEventType type;
|
||||||
|
bool isDir;
|
||||||
|
|
||||||
|
bool IsEvent(FSWatcherEventType e);
|
||||||
|
|
||||||
|
std::string ToString();
|
||||||
|
};
|
||||||
|
class VFS;
|
||||||
|
|
||||||
|
class FSWatcher {
|
||||||
|
private:
|
||||||
|
std::shared_ptr<VFS> vfs;
|
||||||
|
VFSPath path;
|
||||||
|
protected:
|
||||||
|
|
||||||
|
std::atomic<bool> enabled=false;
|
||||||
|
virtual void SetEnabledImpl(bool enabled);
|
||||||
|
public:
|
||||||
|
FSWatcher(std::shared_ptr<VFS> vfs, VFSPath path);
|
||||||
|
std::function<void(FSWatcherEvent&)> event;
|
||||||
|
FSWatcherEventType events = FSWatcherEventType::All;
|
||||||
|
bool GetEnabled();
|
||||||
|
void SetEnabled(bool val);
|
||||||
|
std::shared_ptr<VFS> GetFilesystem();
|
||||||
|
const VFSPath& GetPath();
|
||||||
|
virtual ~FSWatcher() = default;
|
||||||
|
|
||||||
|
static std::shared_ptr<FSWatcher> Create(std::shared_ptr<VFS> vfs, VFSPath path);
|
||||||
|
};
|
||||||
|
|
||||||
class VFS {
|
class VFS {
|
||||||
public:
|
public:
|
||||||
@@ -156,8 +226,24 @@ namespace Tesses::Framework::Filesystem
|
|||||||
virtual void Lock(VFSPath path);
|
virtual void Lock(VFSPath path);
|
||||||
virtual void Unlock(VFSPath path);
|
virtual void Unlock(VFSPath path);
|
||||||
|
|
||||||
|
|
||||||
virtual ~VFS();
|
virtual ~VFS();
|
||||||
|
|
||||||
virtual void Close();
|
virtual void Close();
|
||||||
|
|
||||||
|
protected:
|
||||||
|
virtual std::shared_ptr<FSWatcher> CreateWatcher(std::shared_ptr<VFS> vfs, VFSPath path);
|
||||||
|
friend class FSWatcher;
|
||||||
};
|
};
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
namespace Literals
|
||||||
|
{
|
||||||
|
inline VFSPath operator""_tpath(const char* path)
|
||||||
|
{
|
||||||
|
return VFSPath(path);
|
||||||
|
}
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -23,6 +23,8 @@ namespace Tesses::Framework::Http
|
|||||||
HttpDictionary requestHeaders;
|
HttpDictionary requestHeaders;
|
||||||
HttpDictionary responseHeaders;
|
HttpDictionary responseHeaders;
|
||||||
HttpDictionary queryParams;
|
HttpDictionary queryParams;
|
||||||
|
//used by path
|
||||||
|
HttpDictionary pathArguments;
|
||||||
std::string path;
|
std::string path;
|
||||||
std::string originalPath;
|
std::string originalPath;
|
||||||
std::string method;
|
std::string method;
|
||||||
|
|||||||
@@ -25,6 +25,7 @@ namespace Tesses::Framework::Http
|
|||||||
int64_t GetPosition();
|
int64_t GetPosition();
|
||||||
size_t Read(uint8_t* buffer, size_t len);
|
size_t Read(uint8_t* buffer, size_t len);
|
||||||
size_t Write(const uint8_t* buffer, size_t len);
|
size_t Write(const uint8_t* buffer, size_t len);
|
||||||
|
void Close();
|
||||||
~HttpStream();
|
~HttpStream();
|
||||||
};
|
};
|
||||||
}
|
}
|
||||||
41
include/TessesFramework/Http/RouteServer.hpp
Normal file
41
include/TessesFramework/Http/RouteServer.hpp
Normal file
@@ -0,0 +1,41 @@
|
|||||||
|
#pragma once
|
||||||
|
#include "HttpServer.hpp"
|
||||||
|
#include "../Filesystem/VFSFix.hpp"
|
||||||
|
#include "../Filesystem/VFS.hpp"
|
||||||
|
|
||||||
|
namespace Tesses::Framework::Http
|
||||||
|
{
|
||||||
|
using ServerRequestHandler = std::function<bool(ServerContext&)>;
|
||||||
|
|
||||||
|
|
||||||
|
class RouteServer : public IHttpServer
|
||||||
|
{
|
||||||
|
class RouteServerRoute {
|
||||||
|
public:
|
||||||
|
std::vector<std::pair<std::string,bool>> parts;
|
||||||
|
std::string method;
|
||||||
|
ServerRequestHandler handler;
|
||||||
|
|
||||||
|
RouteServerRoute() = default;
|
||||||
|
RouteServerRoute(std::string route, std::string method, ServerRequestHandler handler);
|
||||||
|
bool Equals(Tesses::Framework::Filesystem::VFSPath& path, HttpDictionary& args);
|
||||||
|
};
|
||||||
|
std::vector<RouteServerRoute> routes;
|
||||||
|
std::shared_ptr<IHttpServer> root;
|
||||||
|
public:
|
||||||
|
RouteServer() = default;
|
||||||
|
RouteServer(std::shared_ptr<IHttpServer> root);
|
||||||
|
void Get(std::string pattern, ServerRequestHandler handler);
|
||||||
|
void Post(std::string pattern, ServerRequestHandler handler);
|
||||||
|
void Put(std::string pattern, ServerRequestHandler handler);
|
||||||
|
void Patch(std::string pattern, ServerRequestHandler handler);
|
||||||
|
|
||||||
|
void Delete(std::string pattern, ServerRequestHandler handler);
|
||||||
|
|
||||||
|
void Trace(std::string pattern, ServerRequestHandler handler);
|
||||||
|
void Options(std::string pattern, ServerRequestHandler handler);
|
||||||
|
void Add(std::string method, std::string pattern, ServerRequestHandler handler);
|
||||||
|
bool Handle(ServerContext& ctx);
|
||||||
|
|
||||||
|
};
|
||||||
|
}
|
||||||
@@ -6,7 +6,23 @@ namespace Tesses::Framework::Platform::Environment
|
|||||||
{
|
{
|
||||||
extern const char EnvPathSeperator;
|
extern const char EnvPathSeperator;
|
||||||
|
|
||||||
|
struct PortableAppConfig {
|
||||||
|
|
||||||
|
std::optional<Tesses::Framework::Filesystem::VFSPath> desktop;
|
||||||
|
std::optional<Tesses::Framework::Filesystem::VFSPath> documents;
|
||||||
|
std::optional<Tesses::Framework::Filesystem::VFSPath> music;
|
||||||
|
std::optional<Tesses::Framework::Filesystem::VFSPath> pictures;
|
||||||
|
std::optional<Tesses::Framework::Filesystem::VFSPath> videos;
|
||||||
|
std::optional<Tesses::Framework::Filesystem::VFSPath> downloads;
|
||||||
|
std::optional<Tesses::Framework::Filesystem::VFSPath> user;
|
||||||
|
std::optional<Tesses::Framework::Filesystem::VFSPath> config;
|
||||||
|
std::optional<Tesses::Framework::Filesystem::VFSPath> state;
|
||||||
|
std::optional<Tesses::Framework::Filesystem::VFSPath> data;
|
||||||
|
std::optional<Tesses::Framework::Filesystem::VFSPath> cache;
|
||||||
|
std::optional<Tesses::Framework::Filesystem::VFSPath> temp;
|
||||||
|
};
|
||||||
|
|
||||||
|
extern PortableAppConfig portable_config;
|
||||||
|
|
||||||
namespace SpecialFolders {
|
namespace SpecialFolders {
|
||||||
Tesses::Framework::Filesystem::VFSPath GetTemp();
|
Tesses::Framework::Filesystem::VFSPath GetTemp();
|
||||||
|
|||||||
@@ -9,6 +9,7 @@
|
|||||||
#include "Http/ChangeableServer.hpp"
|
#include "Http/ChangeableServer.hpp"
|
||||||
#include "Http/CGIServer.hpp"
|
#include "Http/CGIServer.hpp"
|
||||||
#include "Http/BasicAuthServer.hpp"
|
#include "Http/BasicAuthServer.hpp"
|
||||||
|
#include "Http/RouteServer.hpp"
|
||||||
#include "Streams/FileStream.hpp"
|
#include "Streams/FileStream.hpp"
|
||||||
#include "Streams/MemoryStream.hpp"
|
#include "Streams/MemoryStream.hpp"
|
||||||
#include "Streams/NetworkStream.hpp"
|
#include "Streams/NetworkStream.hpp"
|
||||||
|
|||||||
25
portable-json-creator/index.html
Normal file
25
portable-json-creator/index.html
Normal file
@@ -0,0 +1,25 @@
|
|||||||
|
<!DOCTYPE html>
|
||||||
|
<html lang="en">
|
||||||
|
<head>
|
||||||
|
<meta charset="UTF-8">
|
||||||
|
<meta name="viewport" content="width=device-width, initial-scale=1.0">
|
||||||
|
<title>TessesFramework portable.json creator</title>
|
||||||
|
</head>
|
||||||
|
<body>
|
||||||
|
<h1>TessesFramework portable.json creator</h1>
|
||||||
|
|
||||||
|
Choose the way you want your app to be portable
|
||||||
|
<ul>
|
||||||
|
<li>
|
||||||
|
<a href="./portableapps/">
|
||||||
|
PortableApps.com
|
||||||
|
</a>
|
||||||
|
</li>
|
||||||
|
<li>
|
||||||
|
<a href="./relative/">
|
||||||
|
Relative To Application
|
||||||
|
</a>
|
||||||
|
</li>
|
||||||
|
</ul>
|
||||||
|
</body>
|
||||||
|
</html>
|
||||||
98
portable-json-creator/portableapps/index.html
Normal file
98
portable-json-creator/portableapps/index.html
Normal file
@@ -0,0 +1,98 @@
|
|||||||
|
<!DOCTYPE html>
|
||||||
|
<html lang="en">
|
||||||
|
<head>
|
||||||
|
<meta charset="UTF-8">
|
||||||
|
<meta name="viewport" content="width=device-width, initial-scale=1.0">
|
||||||
|
<title>TessesFramework portable.json creator</title>
|
||||||
|
</head>
|
||||||
|
<body>
|
||||||
|
<h1>TessesFramework portable.json creator</h1>
|
||||||
|
Don't want PortableApps.com click <a href="../relative/">here</a> for just having directories relative to application
|
||||||
|
|
||||||
|
<fieldset>
|
||||||
|
<legend>Configuration</legend>
|
||||||
|
|
||||||
|
<label for="user">TF_User: </label>
|
||||||
|
<select id="user">
|
||||||
|
<option value="system">System's %USERPROFILE%</option>
|
||||||
|
<option value="app">MyApp\Data\TF_User (tied to app)</option>
|
||||||
|
<option value="documents" selected>PAF\Documents\TF_User (shared between all tessesframework portable apps)</option>
|
||||||
|
</select>
|
||||||
|
|
||||||
|
<br>
|
||||||
|
<label for="desktop">Desktop: </label>
|
||||||
|
<select id="desktop">
|
||||||
|
<option value="system">System's</option>
|
||||||
|
<option value="tf_user">TF_User\Desktop</option>
|
||||||
|
<option value="documents" selected>PAF\Documents\Desktop</option>
|
||||||
|
</select>
|
||||||
|
<br>
|
||||||
|
<label for="downloads">Downloads: </label>
|
||||||
|
<select id="downloads">
|
||||||
|
<option value="system">System's</option>
|
||||||
|
<option value="tf_user">TF_User\Downloads</option>
|
||||||
|
<option value="documents" selected>PAF\Documents\Downloads</option>
|
||||||
|
</select>
|
||||||
|
<br>
|
||||||
|
<input type="checkbox" id="system_documents">
|
||||||
|
<label for="system_documents">Use System's Documents Folder</label>
|
||||||
|
<br>
|
||||||
|
<input type="checkbox" id="system_pictures">
|
||||||
|
<label for="system_pictures">Use System's Pictures Folder</label>
|
||||||
|
<br>
|
||||||
|
<input type="checkbox" id="system_videos">
|
||||||
|
<label for="system_videos">Use System's Videos Folder</label>
|
||||||
|
<br>
|
||||||
|
<input type="checkbox" id="system_music">
|
||||||
|
<label for="system_music">Use System's Music Folder</label>
|
||||||
|
<br>
|
||||||
|
<input type="checkbox" id="system_config">
|
||||||
|
<label for="system_config">Use System's Config Folder</label>
|
||||||
|
<br>
|
||||||
|
<input type="checkbox" id="system_cache">
|
||||||
|
<label for="system_cache">Use System's Cache Folder</label>
|
||||||
|
<br>
|
||||||
|
<input type="checkbox" id="system_data">
|
||||||
|
<label for="system_data">Use System's Data Folder</label>
|
||||||
|
<br>
|
||||||
|
<input type="checkbox" id="system_state">
|
||||||
|
<label for="system_state">Use System's State Folder</label>
|
||||||
|
|
||||||
|
<br>
|
||||||
|
<input type="checkbox" id="system_temp" checked>
|
||||||
|
<label for="system_temp">Use System's Temp Folder</label>
|
||||||
|
|
||||||
|
</fieldset>
|
||||||
|
<button id="saveBtn">Save</button>
|
||||||
|
<script>
|
||||||
|
(function(){
|
||||||
|
saveBtn.onclick = ()=>{
|
||||||
|
const dict = {
|
||||||
|
portable_type: "PortableApps.com",
|
||||||
|
portable_data: {
|
||||||
|
user: user.value,
|
||||||
|
desktop: desktop.value,
|
||||||
|
downloads: downloads.value,
|
||||||
|
|
||||||
|
system_documents: system_documents.checked,
|
||||||
|
system_pictures: system_pictures.checked,
|
||||||
|
system_videos: system_videos.checked,
|
||||||
|
system_music: system_music.checked,
|
||||||
|
system_config: system_config.checked,
|
||||||
|
system_cache: system_cache.checked,
|
||||||
|
system_data: system_data.checked,
|
||||||
|
system_state: system_state.checked,
|
||||||
|
system_temp: system_temp.checked
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
|
const json = JSON.stringify(dict,null,'\t');
|
||||||
|
const a = document.createElement('a');
|
||||||
|
a.href = `data:text/json;charset=utf-8,${encodeURIComponent(json)}`;
|
||||||
|
a.download="portable.json";
|
||||||
|
a.click();
|
||||||
|
};
|
||||||
|
})();
|
||||||
|
</script>
|
||||||
|
</body>
|
||||||
|
</html>
|
||||||
157
portable-json-creator/relative/index.html
Normal file
157
portable-json-creator/relative/index.html
Normal file
@@ -0,0 +1,157 @@
|
|||||||
|
<!DOCTYPE html>
|
||||||
|
<html lang="en">
|
||||||
|
<head>
|
||||||
|
<meta charset="UTF-8">
|
||||||
|
<meta name="viewport" content="width=device-width, initial-scale=1.0">
|
||||||
|
<title>TessesFramework portable.json creator</title>
|
||||||
|
</head>
|
||||||
|
<body>
|
||||||
|
<h1>TessesFramework portable.json creator</h1>
|
||||||
|
Want PortableApps.com click <a href="../portableapps/">here</a>
|
||||||
|
<br>system: don't make this folder portable, default: the default value (not portable if TF_User directory is "system", otherwise it's a subdirectory in the TF_User directory), anything else is relative to executable directory (for all of these)
|
||||||
|
<br>Please use "/" and not "\" even if on Windows
|
||||||
|
<fieldset>
|
||||||
|
<legend>Configuration</legend>
|
||||||
|
<label for="user">TF_User: </label>
|
||||||
|
<datalist id="user_datalist">
|
||||||
|
<option>system</option>
|
||||||
|
<option>../TF_User</option>
|
||||||
|
</datalist>
|
||||||
|
<input type="text" id="user" value="../TF_User" list="user_datalist">
|
||||||
|
|
||||||
|
<br>
|
||||||
|
<label for="documents">Documents: </label>
|
||||||
|
<datalist id="documents_datalist">
|
||||||
|
<option>system</option>
|
||||||
|
<option>default</option>
|
||||||
|
<option>../TF_User/Documents</option>
|
||||||
|
</datalist>
|
||||||
|
<input type="text" id="documents" value="default" list="documents_datalist">
|
||||||
|
|
||||||
|
<br>
|
||||||
|
<label for="downloads">Downloads: </label>
|
||||||
|
<datalist id="downloads_datalist">
|
||||||
|
<option>system</option>
|
||||||
|
<option>default</option>
|
||||||
|
<option>../TF_User/Downloads</option>
|
||||||
|
</datalist>
|
||||||
|
<input type="text" id="downloads" value="default" list="downloads_datalist">
|
||||||
|
|
||||||
|
<br>
|
||||||
|
<label for="desktop">Desktop: </label>
|
||||||
|
<datalist id="desktop_datalist">
|
||||||
|
<option>system</option>
|
||||||
|
<option>default</option>
|
||||||
|
<option>../TF_User/Desktop</option>
|
||||||
|
</datalist>
|
||||||
|
<input type="text" id="desktop" value="default" list="desktop_datalist">
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
<br>
|
||||||
|
<label for="pictures">Pictures: </label>
|
||||||
|
<datalist id="pictures_datalist">
|
||||||
|
<option>system</option>
|
||||||
|
<option>default</option>
|
||||||
|
<option>../TF_User/Pictures</option>
|
||||||
|
</datalist>
|
||||||
|
<input type="text" id="pictures" value="default" list="pictures_datalist">
|
||||||
|
|
||||||
|
<br>
|
||||||
|
<label for="videos">Videos: </label>
|
||||||
|
<datalist id="videos_datalist">
|
||||||
|
<option>system</option>
|
||||||
|
<option>default</option>
|
||||||
|
<option>../TF_User/Videos</option>
|
||||||
|
</datalist>
|
||||||
|
<input type="text" id="videos" value="default" list="videos_datalist">
|
||||||
|
|
||||||
|
<br>
|
||||||
|
<label for="music">Music: </label>
|
||||||
|
<datalist id="music_datalist">
|
||||||
|
<option>system</option>
|
||||||
|
<option>default</option>
|
||||||
|
<option>../TF_User/Music</option>
|
||||||
|
</datalist>
|
||||||
|
<input type="text" id="music" value="default" list="music_datalist">
|
||||||
|
|
||||||
|
<br>
|
||||||
|
<label for="config">Config: </label>
|
||||||
|
<datalist id="config_datalist">
|
||||||
|
<option>system</option>
|
||||||
|
<option>default</option>
|
||||||
|
<option>../TF_User/Config</option>
|
||||||
|
</datalist>
|
||||||
|
<input type="text" id="config" value="default" list="config_datalist">
|
||||||
|
|
||||||
|
<br>
|
||||||
|
<label for="cache">Cache: </label>
|
||||||
|
<datalist id="cache_datalist">
|
||||||
|
<option>system</option>
|
||||||
|
<option>default</option>
|
||||||
|
<option>../TF_User/Cache</option>
|
||||||
|
</datalist>
|
||||||
|
<input type="text" id="cache" value="default" list="cache_datalist">
|
||||||
|
|
||||||
|
<br>
|
||||||
|
<label for="data">Data: </label>
|
||||||
|
<datalist id="data_datalist">
|
||||||
|
<option>system</option>
|
||||||
|
<option>default</option>
|
||||||
|
<option>../TF_User/Data</option>
|
||||||
|
</datalist>
|
||||||
|
<input type="text" id="data" value="default" list="data_datalist">
|
||||||
|
|
||||||
|
<br>
|
||||||
|
<label for="state">State: </label>
|
||||||
|
<datalist id="state_datalist">
|
||||||
|
<option>system</option>
|
||||||
|
<option>default</option>
|
||||||
|
<option>../TF_User/State</option>
|
||||||
|
</datalist>
|
||||||
|
<input type="text" id="state" value="default" list="state_datalist">
|
||||||
|
|
||||||
|
<br>
|
||||||
|
<label for="temp">Temp: </label>
|
||||||
|
<datalist id="temp_datalist">
|
||||||
|
<option>system</option>
|
||||||
|
<option>default</option>
|
||||||
|
<option>../TF_User/Temp</option>
|
||||||
|
</datalist>
|
||||||
|
<input type="text" id="temp" value="system" list="temp_datalist">
|
||||||
|
</fieldset>
|
||||||
|
|
||||||
|
|
||||||
|
<button id="saveBtn">Save</button>
|
||||||
|
<script>
|
||||||
|
(function(){
|
||||||
|
saveBtn.onclick = ()=>{
|
||||||
|
const dict = {
|
||||||
|
portable_type: "relative",
|
||||||
|
portable_data: {
|
||||||
|
user: user.value,
|
||||||
|
documents: documents.value,
|
||||||
|
downloads: downloads.value,
|
||||||
|
desktop: desktop.value,
|
||||||
|
pictures: pictures.value,
|
||||||
|
videos: videos.value,
|
||||||
|
music: music.value,
|
||||||
|
config: config.value,
|
||||||
|
cache: cache.value,
|
||||||
|
data: data.value,
|
||||||
|
state: state.value,
|
||||||
|
temp: temp.value
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
|
const json = JSON.stringify(dict,null,'\t');
|
||||||
|
const a = document.createElement('a');
|
||||||
|
a.href = `data:text/json;charset=utf-8,${encodeURIComponent(json)}`;
|
||||||
|
a.download="portable.json";
|
||||||
|
a.click();
|
||||||
|
};
|
||||||
|
})();
|
||||||
|
</script>
|
||||||
|
|
||||||
|
</body>
|
||||||
|
</html>
|
||||||
@@ -10,6 +10,13 @@
|
|||||||
#include <utime.h>
|
#include <utime.h>
|
||||||
#include <sys/statvfs.h>
|
#include <sys/statvfs.h>
|
||||||
#endif
|
#endif
|
||||||
|
|
||||||
|
#include "TessesFramework/Threading/Thread.hpp"
|
||||||
|
#if defined(__linux__)
|
||||||
|
#include <poll.h>
|
||||||
|
#include <sys/inotify.h>
|
||||||
|
#include <unistd.h>
|
||||||
|
#endif
|
||||||
namespace Tesses::Framework::Filesystem
|
namespace Tesses::Framework::Filesystem
|
||||||
{
|
{
|
||||||
#if defined(_WIN32)
|
#if defined(_WIN32)
|
||||||
@@ -249,8 +256,184 @@ namespace Tesses::Framework::Filesystem
|
|||||||
std::error_code error;
|
std::error_code error;
|
||||||
std::filesystem::remove(VFSPathToSystem(path),error);
|
std::filesystem::remove(VFSPathToSystem(path),error);
|
||||||
}
|
}
|
||||||
|
#if defined(__linux__)
|
||||||
|
|
||||||
|
class INotifyWatcher : public FSWatcher {
|
||||||
|
std::shared_ptr<Threading::Thread> thrd;
|
||||||
|
static uint32_t to_linux_mask(FSWatcherEventType flags)
|
||||||
|
{
|
||||||
|
uint32_t lflags = 0;
|
||||||
|
lflags |= (((uint32_t)flags & (uint32_t)FSWatcherEventType::Accessed) != 0) ? IN_ACCESS : 0;
|
||||||
|
lflags |= (((uint32_t)flags & (uint32_t)FSWatcherEventType::AttributeChanged) != 0) ? IN_ATTRIB : 0;
|
||||||
|
lflags |= (((uint32_t)flags & (uint32_t)FSWatcherEventType::Writen) != 0) ? IN_CLOSE_WRITE : 0;
|
||||||
|
lflags |= (((uint32_t)flags & (uint32_t)FSWatcherEventType::Read) != 0) ? IN_CLOSE_NOWRITE : 0;
|
||||||
|
lflags |= (((uint32_t)flags & (uint32_t)FSWatcherEventType::Created) != 0) ? IN_CREATE : 0;
|
||||||
|
lflags |= (((uint32_t)flags & (uint32_t)FSWatcherEventType::Deleted) != 0) ? IN_DELETE : 0;
|
||||||
|
lflags |= (((uint32_t)flags & (uint32_t)FSWatcherEventType::WatchEntryDeleted) != 0) ? IN_DELETE_SELF : 0;
|
||||||
|
lflags |= (((uint32_t)flags & (uint32_t)FSWatcherEventType::Modified) != 0) ? IN_MODIFY : 0;
|
||||||
|
lflags |= (((uint32_t)flags & (uint32_t)FSWatcherEventType::WatchEntryMoved) != 0) ? IN_MOVE_SELF : 0;
|
||||||
|
lflags |= (((uint32_t)flags & (uint32_t)FSWatcherEventType::MoveOld) != 0) ? IN_MOVED_FROM : 0;
|
||||||
|
lflags |= (((uint32_t)flags & (uint32_t)FSWatcherEventType::MoveNew) != 0) ? IN_MOVED_TO : 0;
|
||||||
|
lflags |= (((uint32_t)flags & (uint32_t)FSWatcherEventType::Opened) != 0) ? IN_OPEN : 0;
|
||||||
|
|
||||||
|
return lflags;
|
||||||
|
}
|
||||||
|
static FSWatcherEventType from_linux_mask(uint32_t lflags)
|
||||||
|
{
|
||||||
|
uint32_t flags = 0;
|
||||||
|
flags |= ((lflags & IN_ACCESS) != 0) ? (uint32_t)FSWatcherEventType::Accessed : 0;
|
||||||
|
flags |= ((lflags & IN_ATTRIB) != 0) ? (uint32_t)FSWatcherEventType::AttributeChanged : 0;
|
||||||
|
flags |= ((lflags & IN_CLOSE_WRITE) != 0) ? (uint32_t)FSWatcherEventType::Writen : 0;
|
||||||
|
flags |= ((lflags & IN_CLOSE_NOWRITE) != 0) ? (uint32_t)FSWatcherEventType::Read : 0;
|
||||||
|
flags |= ((lflags & IN_CREATE) != 0) ? (uint32_t)FSWatcherEventType::Created : 0;
|
||||||
|
flags |= ((lflags & IN_DELETE) != 0) ? (uint32_t)FSWatcherEventType::Deleted : 0;
|
||||||
|
flags |= ((lflags & IN_DELETE_SELF) != 0) ? (uint32_t)FSWatcherEventType::WatchEntryDeleted : 0;
|
||||||
|
flags |= ((lflags & IN_MODIFY) != 0) ? (uint32_t)FSWatcherEventType::Modified : 0;
|
||||||
|
flags |= ((lflags & IN_MOVE_SELF) != 0) ? (uint32_t)FSWatcherEventType::WatchEntryMoved : 0;
|
||||||
|
flags |= ((lflags & IN_MOVED_FROM) != 0) ? (uint32_t)FSWatcherEventType::MoveOld : 0;
|
||||||
|
flags |= ((lflags & IN_MOVED_TO) != 0) ? (uint32_t)FSWatcherEventType::MoveNew : 0;
|
||||||
|
flags |= ((lflags & IN_OPEN) != 0) ? (uint32_t)FSWatcherEventType::Opened : 0;
|
||||||
|
|
||||||
|
return (FSWatcherEventType)flags;
|
||||||
|
}
|
||||||
|
public:
|
||||||
|
INotifyWatcher(std::shared_ptr<VFS> vfs, VFSPath path) : FSWatcher(vfs,path)
|
||||||
|
{
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
protected:
|
||||||
|
|
||||||
|
void SetEnabledImpl(bool enabled)
|
||||||
|
{
|
||||||
|
if(enabled)
|
||||||
|
{
|
||||||
|
int fd = inotify_init1(IN_NONBLOCK | IN_CLOEXEC);
|
||||||
|
if (fd == -1)
|
||||||
|
{
|
||||||
|
throw std::runtime_error("Cannot init inotify");
|
||||||
|
}
|
||||||
|
auto str = this->GetFilesystem()->VFSPathToSystem(this->GetPath());
|
||||||
|
|
||||||
|
int watch = inotify_add_watch(fd, str.c_str(),to_linux_mask(this->events));
|
||||||
|
|
||||||
|
thrd = std::make_shared<Threading::Thread>([this,watch,fd]()-> void {
|
||||||
|
int cnt = 0;
|
||||||
|
struct pollfd pfd = {.fd = fd, .events = POLLIN};
|
||||||
|
std::vector<std::pair<VFSPath,uint32_t>> mvFroms;
|
||||||
|
char buf[4096]
|
||||||
|
__attribute__ ((aligned(__alignof__(struct inotify_event))));
|
||||||
|
const struct inotify_event *event;
|
||||||
|
ssize_t size;
|
||||||
|
|
||||||
|
bool fail=false;
|
||||||
|
|
||||||
|
FSWatcherEvent evt;
|
||||||
|
evt.dest = this->GetPath();
|
||||||
|
while(!fail && this->enabled)
|
||||||
|
{
|
||||||
|
cnt = poll(&pfd,1,-1);
|
||||||
|
if(cnt == -1) break;
|
||||||
|
|
||||||
|
if(cnt > 0)
|
||||||
|
{
|
||||||
|
if(pfd.revents & POLLIN)
|
||||||
|
{
|
||||||
|
for (;;) {
|
||||||
|
size = read(fd, buf, sizeof(buf));
|
||||||
|
if (size == -1 && errno != EAGAIN) {
|
||||||
|
fail=true;
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
|
||||||
|
if (size <= 0)
|
||||||
|
break;
|
||||||
|
|
||||||
|
for (char *ptr = buf; ptr < buf + size;
|
||||||
|
ptr += sizeof(struct inotify_event) + event->len) {
|
||||||
|
|
||||||
|
event = (const struct inotify_event *) ptr;
|
||||||
|
VFSPath path = this->GetPath();
|
||||||
|
|
||||||
|
if(event->len)
|
||||||
|
path = path / std::string(event->name, (size_t)event->len);
|
||||||
|
|
||||||
|
if(((uint32_t)this->events & (uint32_t)FSWatcherEventType::Moved) == (uint32_t)FSWatcherEventType::Moved && event->mask & IN_MOVED_FROM)
|
||||||
|
{
|
||||||
|
mvFroms.emplace_back(path,event->cookie);
|
||||||
|
}
|
||||||
|
else if(((uint32_t)this->events & (uint32_t)FSWatcherEventType::Moved) == (uint32_t)FSWatcherEventType::Moved && event->mask & IN_MOVED_TO)
|
||||||
|
{
|
||||||
|
for(auto ittr = mvFroms.begin(); ittr != mvFroms.end(); ittr++)
|
||||||
|
{
|
||||||
|
if(ittr->second == event->cookie)
|
||||||
|
{
|
||||||
|
evt.src = ittr->first;
|
||||||
|
mvFroms.erase(ittr);
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
evt.isDir = (event->mask & IN_ISDIR);
|
||||||
|
evt.dest = path;
|
||||||
|
evt.type = FSWatcherEventType::Moved;
|
||||||
|
if(this->event)
|
||||||
|
this->event(evt);
|
||||||
|
}
|
||||||
|
else {
|
||||||
|
|
||||||
|
evt.isDir = (event->mask & IN_ISDIR);
|
||||||
|
evt.src = path;
|
||||||
|
evt.type = from_linux_mask(event->mask);;
|
||||||
|
if(this->event)
|
||||||
|
this->event(evt);
|
||||||
|
}
|
||||||
|
if(event->mask & IN_MOVE_SELF)
|
||||||
|
{
|
||||||
|
close(fd);
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
if(event->mask & IN_DELETE_SELF)
|
||||||
|
{
|
||||||
|
close(fd);
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
close(fd);
|
||||||
|
});
|
||||||
|
|
||||||
|
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
thrd = nullptr;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
public:
|
||||||
|
~INotifyWatcher()
|
||||||
|
{
|
||||||
|
this->enabled = false;
|
||||||
|
}
|
||||||
|
};
|
||||||
|
#endif
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
std::shared_ptr<FSWatcher> LocalFilesystem::CreateWatcher(std::shared_ptr<VFS> vfs, VFSPath path)
|
||||||
|
{
|
||||||
|
#if defined(__linux__)
|
||||||
|
return std::make_shared<INotifyWatcher>(vfs, path);
|
||||||
|
#endif
|
||||||
|
return VFS::CreateWatcher(vfs,path);
|
||||||
|
}
|
||||||
|
|
||||||
std::shared_ptr<LocalFilesystem> LocalFS = std::make_shared<LocalFilesystem>();
|
std::shared_ptr<LocalFilesystem> LocalFS = std::make_shared<LocalFilesystem>();
|
||||||
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// C:/Users/Jim/Joel
|
// C:/Users/Jim/Joel
|
||||||
|
|||||||
@@ -210,7 +210,13 @@ namespace Tesses::Framework::Filesystem {
|
|||||||
}
|
}
|
||||||
TempFS::~TempFS()
|
TempFS::~TempFS()
|
||||||
{
|
{
|
||||||
Close();
|
VFSPath p;
|
||||||
|
p.relative = false;
|
||||||
|
p.path.push_back(this->tmp_str);
|
||||||
|
this->vfs = nullptr;
|
||||||
|
if(this->deleteOnDestroy && this->parent->DirectoryExists(p))
|
||||||
|
this->parent->DeleteDirectoryRecurse(p);
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
@@ -232,7 +232,8 @@ namespace Tesses::Framework::Filesystem
|
|||||||
|
|
||||||
if(i == this->path.size()-1 && i == toMakeRelativeTo.path.size()-1)
|
if(i == this->path.size()-1 && i == toMakeRelativeTo.path.size()-1)
|
||||||
{
|
{
|
||||||
VFSPath path({this->path[this->path.size()-1]});
|
std::vector<std::string> paths{this->path[this->path.size()-1]};
|
||||||
|
VFSPath path(paths);
|
||||||
path.relative = true;
|
path.relative = true;
|
||||||
return path;
|
return path;
|
||||||
}
|
}
|
||||||
@@ -330,6 +331,35 @@ namespace Tesses::Framework::Filesystem
|
|||||||
this->path = p;
|
this->path = p;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
VFSPath VFSPath::ParseUriPath(std::string path)
|
||||||
|
{
|
||||||
|
std::string builder = {};
|
||||||
|
VFSPath vpath;
|
||||||
|
vpath.relative=true;
|
||||||
|
|
||||||
|
if(!path.empty() && path[0] == '/') vpath.relative=false;
|
||||||
|
|
||||||
|
for(auto item : path)
|
||||||
|
{
|
||||||
|
if(item == '/')
|
||||||
|
{
|
||||||
|
if(!builder.empty())
|
||||||
|
{
|
||||||
|
vpath.path.push_back(builder);
|
||||||
|
builder.clear();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
else {
|
||||||
|
builder.push_back(item);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if(!builder.empty())
|
||||||
|
{
|
||||||
|
vpath.path.push_back(builder);
|
||||||
|
}
|
||||||
|
return vpath;
|
||||||
|
}
|
||||||
|
|
||||||
bool VFSPath::HasExtension() const
|
bool VFSPath::HasExtension() const
|
||||||
{
|
{
|
||||||
if(this->path.empty()) return false;
|
if(this->path.empty()) return false;
|
||||||
@@ -358,7 +388,8 @@ namespace Tesses::Framework::Filesystem
|
|||||||
if(ext.empty()) return;
|
if(ext.empty()) return;
|
||||||
if(ext[0] != '.')
|
if(ext[0] != '.')
|
||||||
{
|
{
|
||||||
str += '.' + ext;
|
str += '.';
|
||||||
|
str += ext;
|
||||||
}
|
}
|
||||||
else
|
else
|
||||||
{
|
{
|
||||||
@@ -377,6 +408,9 @@ namespace Tesses::Framework::Filesystem
|
|||||||
if(!str.empty())
|
if(!str.empty())
|
||||||
{
|
{
|
||||||
if(str.front() == '/') this->relative=false;
|
if(str.front() == '/') this->relative=false;
|
||||||
|
#if defined(_WIN32)
|
||||||
|
if(str.front() == '\\') this->relative=false;
|
||||||
|
#endif
|
||||||
if(!this->path.empty())
|
if(!this->path.empty())
|
||||||
{
|
{
|
||||||
auto firstPartPath = this->path.front();
|
auto firstPartPath = this->path.front();
|
||||||
@@ -528,4 +562,113 @@ namespace Tesses::Framework::Filesystem
|
|||||||
{
|
{
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
std::shared_ptr<FSWatcher> VFS::CreateWatcher(std::shared_ptr<VFS> vfs,VFSPath path)
|
||||||
|
{
|
||||||
|
return std::make_shared<FSWatcher>(vfs,path);
|
||||||
|
}
|
||||||
|
void FSWatcher::SetEnabled(bool enabled)
|
||||||
|
{
|
||||||
|
if(this->enabled == enabled) return;
|
||||||
|
this->enabled = enabled;
|
||||||
|
this->SetEnabledImpl(enabled);
|
||||||
|
}
|
||||||
|
|
||||||
|
bool FSWatcher::GetEnabled()
|
||||||
|
{
|
||||||
|
return this->enabled;
|
||||||
|
}
|
||||||
|
|
||||||
|
void FSWatcher::SetEnabledImpl(bool enabled)
|
||||||
|
{
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
std::shared_ptr<VFS> FSWatcher::GetFilesystem()
|
||||||
|
{
|
||||||
|
return this->vfs;
|
||||||
|
}
|
||||||
|
const VFSPath& FSWatcher::GetPath()
|
||||||
|
{
|
||||||
|
return this->path;
|
||||||
|
}
|
||||||
|
|
||||||
|
FSWatcher::FSWatcher(std::shared_ptr<VFS> vfs, VFSPath path): vfs(vfs), path(path)
|
||||||
|
{
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
std::shared_ptr<FSWatcher> FSWatcher::Create(std::shared_ptr<VFS> vfs, VFSPath path)
|
||||||
|
{
|
||||||
|
return vfs->CreateWatcher(vfs,path);
|
||||||
|
}
|
||||||
|
|
||||||
|
bool FSWatcherEvent::IsEvent(FSWatcherEventType e)
|
||||||
|
{
|
||||||
|
if(e == FSWatcherEventType::All) return this->type != FSWatcherEventType::None;
|
||||||
|
if(e == FSWatcherEventType::Moved) return ((uint32_t)this->type & (uint32_t)FSWatcherEventType::Moved) == (uint32_t)FSWatcherEventType::Moved;
|
||||||
|
if(e == FSWatcherEventType::Closed) return ((uint32_t)this->type & (uint32_t)FSWatcherEventType::Closed) != 0;
|
||||||
|
return (uint32_t)this->type & (uint32_t)e;
|
||||||
|
}
|
||||||
|
|
||||||
|
std::string FSWatcherEvent::ToString()
|
||||||
|
{
|
||||||
|
if(IsEvent(FSWatcherEventType::Moved))
|
||||||
|
{
|
||||||
|
return (this->isDir ? "Moved directory " : "Moved file ") + this->src.ToString() + " -> " + this->dest.ToString();
|
||||||
|
}
|
||||||
|
else if(IsEvent(FSWatcherEventType::MoveOld))
|
||||||
|
{
|
||||||
|
return (this->isDir ? "Move source directory " : "Move source file ") + this->src.ToString();
|
||||||
|
}
|
||||||
|
else if(IsEvent(FSWatcherEventType::MoveNew))
|
||||||
|
{
|
||||||
|
return (this->isDir ? "Move destination directory " : "Move destination file ") + this->src.ToString();
|
||||||
|
}
|
||||||
|
else if(IsEvent(FSWatcherEventType::Accessed))
|
||||||
|
{
|
||||||
|
return (this->isDir ? "Accessed directory " : "Accessed file ") + this->src.ToString();
|
||||||
|
}
|
||||||
|
else if(IsEvent(FSWatcherEventType::AttributeChanged))
|
||||||
|
{
|
||||||
|
return (this->isDir ? "Changed attr on directory " : "Changed attr on file ") + this->src.ToString();
|
||||||
|
}
|
||||||
|
else if(IsEvent(FSWatcherEventType::Writen))
|
||||||
|
{
|
||||||
|
return (this->isDir ? "Finished changing directory " : "Finished writing to file ") + this->src.ToString();
|
||||||
|
}
|
||||||
|
else if(IsEvent(FSWatcherEventType::Read))
|
||||||
|
{
|
||||||
|
return (this->isDir ? "Finished reading directory " : "Finished reading from file ") + this->src.ToString();
|
||||||
|
}
|
||||||
|
else if(IsEvent(FSWatcherEventType::Created))
|
||||||
|
{
|
||||||
|
return (this->isDir ? "Created directory " : "Created file ") + this->src.ToString();
|
||||||
|
}
|
||||||
|
else if(IsEvent(FSWatcherEventType::Deleted))
|
||||||
|
{
|
||||||
|
return (this->isDir ? "Deleted directory " : "Deleted file ") + this->src.ToString();
|
||||||
|
}
|
||||||
|
else if(IsEvent(FSWatcherEventType::WatchEntryDeleted))
|
||||||
|
{
|
||||||
|
|
||||||
|
return (this->isDir ? "Deleted watched directory " : "Deleted watched file ") + this->src.ToString();
|
||||||
|
}
|
||||||
|
else if(IsEvent(FSWatcherEventType::Modified))
|
||||||
|
{
|
||||||
|
return (this->isDir ? "Modified directory " : "Modified file ") + this->src.ToString();
|
||||||
|
}
|
||||||
|
else if(IsEvent(FSWatcherEventType::WatchEntryMoved))
|
||||||
|
{
|
||||||
|
return (this->isDir ? "Moved watched directory " : "Moved watched file ") + this->src.ToString();
|
||||||
|
}
|
||||||
|
else if(IsEvent(FSWatcherEventType::Opened))
|
||||||
|
{
|
||||||
|
return (this->isDir ? "Opened directory " : "Opened file ") + this->src.ToString();
|
||||||
|
}
|
||||||
|
|
||||||
|
return "";
|
||||||
|
}
|
||||||
}
|
}
|
||||||
@@ -389,11 +389,8 @@ namespace Tesses::Framework::Http
|
|||||||
static bool parseUntillBoundaryEnd(std::shared_ptr<Tesses::Framework::Streams::Stream> src, std::shared_ptr<Tesses::Framework::Streams::Stream> dest, std::string boundary)
|
static bool parseUntillBoundaryEnd(std::shared_ptr<Tesses::Framework::Streams::Stream> src, std::shared_ptr<Tesses::Framework::Streams::Stream> dest, std::string boundary)
|
||||||
{
|
{
|
||||||
bool hasMore=true;
|
bool hasMore=true;
|
||||||
#if defined(_WIN32)
|
|
||||||
uint8_t* checkBuffer = new uint8_t[boundary.size()];
|
uint8_t* checkBuffer = new uint8_t[boundary.size()];
|
||||||
#else
|
|
||||||
uint8_t checkBuffer[boundary.size()];
|
|
||||||
#endif
|
|
||||||
int b;
|
int b;
|
||||||
size_t i = 0;
|
size_t i = 0;
|
||||||
size_t i2 = 0;
|
size_t i2 = 0;
|
||||||
@@ -457,9 +454,8 @@ namespace Tesses::Framework::Http
|
|||||||
{
|
{
|
||||||
dest->Write(buffer,offsetInMem);
|
dest->Write(buffer,offsetInMem);
|
||||||
}
|
}
|
||||||
#if defined(_WIN32)
|
delete[] checkBuffer;
|
||||||
delete checkBuffer;
|
|
||||||
#endif
|
|
||||||
return hasMore;
|
return hasMore;
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -566,7 +562,12 @@ namespace Tesses::Framework::Http
|
|||||||
this->responseHeaders.SetValue("Transfer-Encoding","chunked");
|
this->responseHeaders.SetValue("Transfer-Encoding","chunked");
|
||||||
|
|
||||||
this->WriteHeaders();
|
this->WriteHeaders();
|
||||||
return std::make_shared<HttpStream>(this->strm,length,false,version == "HTTP/1.1");
|
auto strm = std::make_shared<HttpStream>(this->strm,length,false,version == "HTTP/1.1");
|
||||||
|
if(method == "HEAD")
|
||||||
|
{
|
||||||
|
strm->Close();
|
||||||
|
}
|
||||||
|
return strm;
|
||||||
}
|
}
|
||||||
std::shared_ptr<Stream> ServerContext::OpenRequestStream()
|
std::shared_ptr<Stream> ServerContext::OpenRequestStream()
|
||||||
{
|
{
|
||||||
@@ -788,23 +789,26 @@ namespace Tesses::Framework::Http
|
|||||||
this->WithSingleHeader("Content-Range","bytes " + std::to_string(begin) + "-" + std::to_string(end) + "/" + std::to_string(len));
|
this->WithSingleHeader("Content-Range","bytes " + std::to_string(begin) + "-" + std::to_string(end) + "/" + std::to_string(len));
|
||||||
this->statusCode = PartialContent;
|
this->statusCode = PartialContent;
|
||||||
this->WriteHeaders();
|
this->WriteHeaders();
|
||||||
strm->Seek(begin,SeekOrigin::Begin);
|
if(this->method != "HEAD")
|
||||||
|
{
|
||||||
|
strm->Seek(begin,SeekOrigin::Begin);
|
||||||
|
|
||||||
uint8_t buffer[1024];
|
uint8_t buffer[1024];
|
||||||
|
|
||||||
size_t read=0;
|
size_t read=0;
|
||||||
do {
|
|
||||||
read = sizeof(buffer);
|
|
||||||
myLen = (end - begin)+1;
|
|
||||||
if(myLen < read) read = (size_t)myLen;
|
|
||||||
if(read == 0) break;
|
|
||||||
read = strm->Read(buffer,read);
|
|
||||||
if(read == 0) break;
|
|
||||||
this->strm->WriteBlock(buffer,read);
|
|
||||||
|
|
||||||
begin += read;
|
do {
|
||||||
} while(read > 0 && !this->strm->EndOfStream());
|
read = sizeof(buffer);
|
||||||
|
myLen = (end - begin)+1;
|
||||||
|
if(myLen < read) read = (size_t)myLen;
|
||||||
|
if(read == 0) break;
|
||||||
|
read = strm->Read(buffer,read);
|
||||||
|
if(read == 0) break;
|
||||||
|
this->strm->WriteBlock(buffer,read);
|
||||||
|
|
||||||
|
begin += read;
|
||||||
|
} while(read > 0 && !this->strm->EndOfStream());
|
||||||
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
else
|
else
|
||||||
@@ -821,6 +825,7 @@ namespace Tesses::Framework::Http
|
|||||||
this->WithSingleHeader("Accept-Range","bytes");
|
this->WithSingleHeader("Accept-Range","bytes");
|
||||||
this->WithSingleHeader("Content-Length",std::to_string(len));
|
this->WithSingleHeader("Content-Length",std::to_string(len));
|
||||||
this->WriteHeaders();
|
this->WriteHeaders();
|
||||||
|
if(this->method != "HEAD")
|
||||||
strm->CopyTo(this->strm);
|
strm->CopyTo(this->strm);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -828,8 +833,10 @@ namespace Tesses::Framework::Http
|
|||||||
}
|
}
|
||||||
else
|
else
|
||||||
{
|
{
|
||||||
|
|
||||||
auto chunkedStream = this->OpenResponseStream();
|
auto chunkedStream = this->OpenResponseStream();
|
||||||
|
|
||||||
|
if(method != "HEAD")
|
||||||
strm->CopyTo(chunkedStream);
|
strm->CopyTo(chunkedStream);
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
@@ -27,6 +27,7 @@ namespace Tesses::Framework::Http
|
|||||||
}
|
}
|
||||||
bool HttpStream::CanWrite()
|
bool HttpStream::CanWrite()
|
||||||
{
|
{
|
||||||
|
if(this->done) return false;
|
||||||
if(this->recv) return false;
|
if(this->recv) return false;
|
||||||
return this->strm->CanWrite();
|
return this->strm->CanWrite();
|
||||||
}
|
}
|
||||||
@@ -118,6 +119,7 @@ namespace Tesses::Framework::Http
|
|||||||
}
|
}
|
||||||
size_t HttpStream::Write(const uint8_t* buff, size_t len)
|
size_t HttpStream::Write(const uint8_t* buff, size_t len)
|
||||||
{
|
{
|
||||||
|
if(this->done) return 0;
|
||||||
if(this->recv) return 0;
|
if(this->recv) return 0;
|
||||||
if(this->length == 0) return 0;
|
if(this->length == 0) return 0;
|
||||||
if(this->length > 0)
|
if(this->length > 0)
|
||||||
@@ -153,9 +155,20 @@ namespace Tesses::Framework::Http
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
void HttpStream::Close()
|
||||||
|
{
|
||||||
|
if(this->length == -1 && this->http1_1 && !done && !this->recv)
|
||||||
|
{
|
||||||
|
this->done=true;
|
||||||
|
StreamWriter writer(this->strm);
|
||||||
|
writer.newline = "\r\n";
|
||||||
|
writer.WriteLine("0");
|
||||||
|
writer.WriteLine();
|
||||||
|
}
|
||||||
|
}
|
||||||
HttpStream::~HttpStream()
|
HttpStream::~HttpStream()
|
||||||
{
|
{
|
||||||
if(this->length == -1 && this->http1_1)
|
if(this->length == -1 && this->http1_1 && !done && !this->recv)
|
||||||
{
|
{
|
||||||
StreamWriter writer(this->strm);
|
StreamWriter writer(this->strm);
|
||||||
writer.newline = "\r\n";
|
writer.newline = "\r\n";
|
||||||
|
|||||||
97
src/Http/RouteServer.cpp
Normal file
97
src/Http/RouteServer.cpp
Normal file
@@ -0,0 +1,97 @@
|
|||||||
|
#include "TessesFramework/Http/RouteServer.hpp"
|
||||||
|
|
||||||
|
namespace Tesses::Framework::Http
|
||||||
|
{
|
||||||
|
|
||||||
|
RouteServer::RouteServerRoute::RouteServerRoute(std::string route, std::string method, ServerRequestHandler handler) : method(method), handler(handler)
|
||||||
|
{
|
||||||
|
auto path = Tesses::Framework::Filesystem::VFSPath::ParseUriPath(route);
|
||||||
|
for(auto item : path.path)
|
||||||
|
{
|
||||||
|
if(item.size() > 2 && item[0] == '{' && item[item.size()-1] == '}')
|
||||||
|
{
|
||||||
|
this->parts.emplace_back( item.substr(1,item.size()-2),true);
|
||||||
|
}
|
||||||
|
else {
|
||||||
|
this->parts.emplace_back(item,false);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
bool RouteServer::RouteServerRoute::Equals(Tesses::Framework::Filesystem::VFSPath& path, HttpDictionary& args)
|
||||||
|
{
|
||||||
|
if(path.path.size() != this->parts.size()) return false;
|
||||||
|
|
||||||
|
|
||||||
|
for(size_t i = 0; i < this->parts.size(); i++)
|
||||||
|
{
|
||||||
|
auto& part = this->parts[i];
|
||||||
|
if(part.second)
|
||||||
|
args.SetValue(part.first, Tesses::Framework::Http::HttpUtils::UrlPathDecode(path.path[i]));
|
||||||
|
else if(part.first != path.path[i]) return false;
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
|
||||||
|
RouteServer::RouteServer(std::shared_ptr<IHttpServer> root) : root(root)
|
||||||
|
{
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
void RouteServer::Add(std::string method, std::string pattern, ServerRequestHandler handler)
|
||||||
|
{
|
||||||
|
this->routes.emplace_back(pattern,method,handler);
|
||||||
|
}
|
||||||
|
|
||||||
|
bool RouteServer::Handle(ServerContext& ctx)
|
||||||
|
{
|
||||||
|
auto pathArgs = ctx.pathArguments;
|
||||||
|
auto path = Tesses::Framework::Filesystem::VFSPath::ParseUriPath(ctx.path);
|
||||||
|
for(auto& svr : this->routes)
|
||||||
|
{
|
||||||
|
if(svr.method != ctx.method && !((svr.method == "GET" && ctx.method == "HEAD") || (svr.method == "HEAD" && ctx.method == "GET"))) continue;
|
||||||
|
ctx.pathArguments = pathArgs;
|
||||||
|
if(svr.Equals(path, ctx.pathArguments) && svr.handler && svr.handler(ctx))
|
||||||
|
return true;
|
||||||
|
|
||||||
|
}
|
||||||
|
ctx.pathArguments = pathArgs;
|
||||||
|
|
||||||
|
if(this->root)
|
||||||
|
return this->root->Handle(ctx);
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
|
||||||
|
void RouteServer::Get(std::string pattern, ServerRequestHandler handler)
|
||||||
|
{
|
||||||
|
Add("GET",pattern,handler);
|
||||||
|
}
|
||||||
|
void RouteServer::Post(std::string pattern, ServerRequestHandler handler)
|
||||||
|
{
|
||||||
|
Add("POST",pattern,handler);
|
||||||
|
}
|
||||||
|
void RouteServer::Put(std::string pattern, ServerRequestHandler handler)
|
||||||
|
{
|
||||||
|
Add("PUT",pattern,handler);
|
||||||
|
}
|
||||||
|
void RouteServer::Patch(std::string pattern, ServerRequestHandler handler)
|
||||||
|
{
|
||||||
|
Add("PATCH",pattern,handler);
|
||||||
|
}
|
||||||
|
|
||||||
|
void RouteServer::Delete(std::string pattern, ServerRequestHandler handler)
|
||||||
|
{
|
||||||
|
Add("DELETE",pattern,handler);
|
||||||
|
}
|
||||||
|
|
||||||
|
void RouteServer::Trace(std::string pattern, ServerRequestHandler handler)
|
||||||
|
{
|
||||||
|
Add("TRACE",pattern,handler);
|
||||||
|
}
|
||||||
|
void RouteServer::Options(std::string pattern, ServerRequestHandler handler)
|
||||||
|
{
|
||||||
|
Add("OPTIONS",pattern,handler);
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -22,15 +22,23 @@ namespace Tesses::Framework::Platform::Environment
|
|||||||
#else
|
#else
|
||||||
const char EnvPathSeperator=':';
|
const char EnvPathSeperator=':';
|
||||||
#endif
|
#endif
|
||||||
|
PortableAppConfig portable_config;
|
||||||
|
|
||||||
namespace SpecialFolders
|
namespace SpecialFolders
|
||||||
{
|
{
|
||||||
VFSPath GetTemp()
|
VFSPath GetTemp()
|
||||||
{
|
{
|
||||||
|
|
||||||
|
if(portable_config.temp)
|
||||||
|
return *portable_config.temp;
|
||||||
return std::filesystem::temp_directory_path().string();
|
return std::filesystem::temp_directory_path().string();
|
||||||
}
|
}
|
||||||
VFSPath GetHomeFolder()
|
VFSPath GetHomeFolder()
|
||||||
{
|
{
|
||||||
|
|
||||||
|
if(portable_config.user)
|
||||||
|
return *portable_config.user;
|
||||||
|
|
||||||
#if defined(TESSESFRAMEWORK_ENABLE_PLATFORMFOLDERS) && !defined(SAGO_DISABLE)
|
#if defined(TESSESFRAMEWORK_ENABLE_PLATFORMFOLDERS) && !defined(SAGO_DISABLE)
|
||||||
return sago::getHomeDir();
|
return sago::getHomeDir();
|
||||||
#elif defined(__EMSCRIPTEN__)
|
#elif defined(__EMSCRIPTEN__)
|
||||||
@@ -43,6 +51,9 @@ namespace Tesses::Framework::Platform::Environment
|
|||||||
}
|
}
|
||||||
VFSPath GetDownloads()
|
VFSPath GetDownloads()
|
||||||
{
|
{
|
||||||
|
if(portable_config.downloads)
|
||||||
|
return *portable_config.downloads;
|
||||||
|
|
||||||
#if defined(TESSESFRAMEWORK_ENABLE_PLATFORMFOLDERS) && !defined(SAGO_DISABLE)
|
#if defined(TESSESFRAMEWORK_ENABLE_PLATFORMFOLDERS) && !defined(SAGO_DISABLE)
|
||||||
return sago::getDownloadFolder();
|
return sago::getDownloadFolder();
|
||||||
#elif defined(__ANDROID__)
|
#elif defined(__ANDROID__)
|
||||||
@@ -53,6 +64,9 @@ namespace Tesses::Framework::Platform::Environment
|
|||||||
}
|
}
|
||||||
VFSPath GetMusic()
|
VFSPath GetMusic()
|
||||||
{
|
{
|
||||||
|
|
||||||
|
if(portable_config.music)
|
||||||
|
return *portable_config.music;
|
||||||
#if defined(TESSESFRAMEWORK_ENABLE_PLATFORMFOLDERS) && !defined(SAGO_DISABLE)
|
#if defined(TESSESFRAMEWORK_ENABLE_PLATFORMFOLDERS) && !defined(SAGO_DISABLE)
|
||||||
return sago::getMusicFolder();
|
return sago::getMusicFolder();
|
||||||
#elif defined(__ANDROID__)
|
#elif defined(__ANDROID__)
|
||||||
@@ -63,6 +77,9 @@ namespace Tesses::Framework::Platform::Environment
|
|||||||
}
|
}
|
||||||
VFSPath GetPictures()
|
VFSPath GetPictures()
|
||||||
{
|
{
|
||||||
|
|
||||||
|
if(portable_config.pictures)
|
||||||
|
return *portable_config.pictures;
|
||||||
#if defined(TESSESFRAMEWORK_ENABLE_PLATFORMFOLDERS) && !defined(SAGO_DISABLE)
|
#if defined(TESSESFRAMEWORK_ENABLE_PLATFORMFOLDERS) && !defined(SAGO_DISABLE)
|
||||||
return sago::getPicturesFolder();
|
return sago::getPicturesFolder();
|
||||||
#elif defined(__ANDROID__)
|
#elif defined(__ANDROID__)
|
||||||
@@ -73,6 +90,8 @@ namespace Tesses::Framework::Platform::Environment
|
|||||||
}
|
}
|
||||||
VFSPath GetVideos()
|
VFSPath GetVideos()
|
||||||
{
|
{
|
||||||
|
if(portable_config.videos)
|
||||||
|
return *portable_config.videos;
|
||||||
#if defined(TESSESFRAMEWORK_ENABLE_PLATFORMFOLDERS) && !defined(SAGO_DISABLE)
|
#if defined(TESSESFRAMEWORK_ENABLE_PLATFORMFOLDERS) && !defined(SAGO_DISABLE)
|
||||||
return sago::getVideoFolder();
|
return sago::getVideoFolder();
|
||||||
#elif defined(__ANDROID__)
|
#elif defined(__ANDROID__)
|
||||||
@@ -83,6 +102,9 @@ namespace Tesses::Framework::Platform::Environment
|
|||||||
}
|
}
|
||||||
VFSPath GetDocuments()
|
VFSPath GetDocuments()
|
||||||
{
|
{
|
||||||
|
|
||||||
|
if(portable_config.documents)
|
||||||
|
return *portable_config.documents;
|
||||||
#if defined(TESSESFRAMEWORK_ENABLE_PLATFORMFOLDERS) && !defined(SAGO_DISABLE)
|
#if defined(TESSESFRAMEWORK_ENABLE_PLATFORMFOLDERS) && !defined(SAGO_DISABLE)
|
||||||
return sago::getDocumentsFolder();
|
return sago::getDocumentsFolder();
|
||||||
#elif defined(__ANDROID__)
|
#elif defined(__ANDROID__)
|
||||||
@@ -93,6 +115,9 @@ namespace Tesses::Framework::Platform::Environment
|
|||||||
}
|
}
|
||||||
VFSPath GetConfig()
|
VFSPath GetConfig()
|
||||||
{
|
{
|
||||||
|
|
||||||
|
if(portable_config.config)
|
||||||
|
return *portable_config.config;
|
||||||
#if defined(TESSESFRAMEWORK_ENABLE_PLATFORMFOLDERS) && !defined(SAGO_DISABLE)
|
#if defined(TESSESFRAMEWORK_ENABLE_PLATFORMFOLDERS) && !defined(SAGO_DISABLE)
|
||||||
return sago::getConfigHome();
|
return sago::getConfigHome();
|
||||||
#else
|
#else
|
||||||
@@ -101,6 +126,8 @@ namespace Tesses::Framework::Platform::Environment
|
|||||||
}
|
}
|
||||||
VFSPath GetDesktop()
|
VFSPath GetDesktop()
|
||||||
{
|
{
|
||||||
|
if(portable_config.desktop)
|
||||||
|
return *portable_config.desktop;
|
||||||
#if defined(TESSESFRAMEWORK_ENABLE_PLATFORMFOLDERS) && !defined(SAGO_DISABLE)
|
#if defined(TESSESFRAMEWORK_ENABLE_PLATFORMFOLDERS) && !defined(SAGO_DISABLE)
|
||||||
return sago::getDesktopFolder();
|
return sago::getDesktopFolder();
|
||||||
#else
|
#else
|
||||||
@@ -109,6 +136,9 @@ namespace Tesses::Framework::Platform::Environment
|
|||||||
}
|
}
|
||||||
VFSPath GetState()
|
VFSPath GetState()
|
||||||
{
|
{
|
||||||
|
|
||||||
|
if(portable_config.state)
|
||||||
|
return *portable_config.state;
|
||||||
#if defined(TESSESFRAMEWORK_ENABLE_PLATFORMFOLDERS) && !defined(SAGO_DISABLE)
|
#if defined(TESSESFRAMEWORK_ENABLE_PLATFORMFOLDERS) && !defined(SAGO_DISABLE)
|
||||||
return sago::getStateDir();
|
return sago::getStateDir();
|
||||||
#else
|
#else
|
||||||
@@ -117,6 +147,9 @@ namespace Tesses::Framework::Platform::Environment
|
|||||||
}
|
}
|
||||||
VFSPath GetCache()
|
VFSPath GetCache()
|
||||||
{
|
{
|
||||||
|
|
||||||
|
if(portable_config.cache)
|
||||||
|
return *portable_config.cache;
|
||||||
#if defined(TESSESFRAMEWORK_ENABLE_PLATFORMFOLDERS) && !defined(SAGO_DISABLE)
|
#if defined(TESSESFRAMEWORK_ENABLE_PLATFORMFOLDERS) && !defined(SAGO_DISABLE)
|
||||||
return sago::getCacheDir();
|
return sago::getCacheDir();
|
||||||
#else
|
#else
|
||||||
@@ -125,6 +158,9 @@ namespace Tesses::Framework::Platform::Environment
|
|||||||
}
|
}
|
||||||
VFSPath GetData()
|
VFSPath GetData()
|
||||||
{
|
{
|
||||||
|
|
||||||
|
if(portable_config.data)
|
||||||
|
return *portable_config.data;
|
||||||
#if defined(TESSESFRAMEWORK_ENABLE_PLATFORMFOLDERS) && !defined(SAGO_DISABLE)
|
#if defined(TESSESFRAMEWORK_ENABLE_PLATFORMFOLDERS) && !defined(SAGO_DISABLE)
|
||||||
return sago::getDataHome();
|
return sago::getDataHome();
|
||||||
#else
|
#else
|
||||||
|
|||||||
@@ -104,7 +104,12 @@ namespace Tesses::Framework::Streams
|
|||||||
}
|
}
|
||||||
FileStream::~FileStream()
|
FileStream::~FileStream()
|
||||||
{
|
{
|
||||||
Close();
|
if(!f) return;
|
||||||
|
if(this->owns)
|
||||||
|
{
|
||||||
|
fclose(this->f);
|
||||||
|
f=NULL;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
void FileStream::Close()
|
void FileStream::Close()
|
||||||
{
|
{
|
||||||
|
|||||||
@@ -47,7 +47,7 @@ extern "C" {
|
|||||||
#if defined(AF_UNIX) && !defined(GEKKO) && !defined(__SWITCH__) && !defined(__PS2__)
|
#if defined(AF_UNIX) && !defined(GEKKO) && !defined(__SWITCH__) && !defined(__PS2__)
|
||||||
#include <sys/un.h>
|
#include <sys/un.h>
|
||||||
#endif
|
#endif
|
||||||
#include <sys/poll.h>
|
#include <poll.h>
|
||||||
}
|
}
|
||||||
#endif
|
#endif
|
||||||
#if defined(GEKKO)
|
#if defined(GEKKO)
|
||||||
@@ -538,7 +538,10 @@ namespace Tesses::Framework::Streams {
|
|||||||
TcpServer::~TcpServer()
|
TcpServer::~TcpServer()
|
||||||
{
|
{
|
||||||
if(this->valid && this->owns)
|
if(this->valid && this->owns)
|
||||||
Close();
|
{
|
||||||
|
NETWORK_CLOSE(this->sock);
|
||||||
|
}
|
||||||
|
this->valid=false;
|
||||||
}
|
}
|
||||||
void TcpServer::Close()
|
void TcpServer::Close()
|
||||||
{
|
{
|
||||||
@@ -818,7 +821,9 @@ namespace Tesses::Framework::Streams {
|
|||||||
}
|
}
|
||||||
NetworkStream::~NetworkStream()
|
NetworkStream::~NetworkStream()
|
||||||
{
|
{
|
||||||
Close();
|
if(this->owns && this->success)
|
||||||
|
NETWORK_CLOSE(this->sock);
|
||||||
|
this->success=0;
|
||||||
}
|
}
|
||||||
void NetworkStream::SetNoDelay(bool noDelay)
|
void NetworkStream::SetNoDelay(bool noDelay)
|
||||||
{
|
{
|
||||||
@@ -945,5 +950,8 @@ uint16_t TcpServer::GetPort()
|
|||||||
{
|
{
|
||||||
return 0;
|
return 0;
|
||||||
}
|
}
|
||||||
|
bool NetworkStream::DataAvailable(int to){
|
||||||
|
return false;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
#endif
|
#endif
|
||||||
|
|||||||
@@ -126,7 +126,13 @@ namespace Tesses::Framework::Streams {
|
|||||||
}
|
}
|
||||||
PtyStream::~PtyStream()
|
PtyStream::~PtyStream()
|
||||||
{
|
{
|
||||||
Close();
|
if(this->eos) return;
|
||||||
|
this->eos=true;
|
||||||
|
#if !defined(GEKKO) && !defined(__APPLE__) && !defined(__PS2__) && !defined(_WIN32) && !defined(__SWITCH__) && !defined(__FreeBSD__) && defined(TESSESFRAMEWORK_ENABLE_PROCESS)
|
||||||
|
close(this->socket);
|
||||||
|
|
||||||
|
kill((pid_t)this->pid,SIGHUP);
|
||||||
|
#endif
|
||||||
}
|
}
|
||||||
void PtyStream::Close()
|
void PtyStream::Close()
|
||||||
{
|
{
|
||||||
|
|||||||
@@ -48,8 +48,13 @@ namespace Tesses::Framework::Streams {
|
|||||||
if(len < 1024)
|
if(len < 1024)
|
||||||
read = len;
|
read = len;
|
||||||
if(read > 0)
|
if(read > 0)
|
||||||
|
{
|
||||||
read=this->Write(buffer,read);
|
read=this->Write(buffer,read);
|
||||||
|
if(read == 0)
|
||||||
|
{
|
||||||
|
throw std::out_of_range("Failed to write!");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
buffer += read;
|
buffer += read;
|
||||||
@@ -109,7 +114,6 @@ namespace Tesses::Framework::Streams {
|
|||||||
read = (size_t)std::min(len-offset,(uint64_t)buffSize);
|
read = (size_t)std::min(len-offset,(uint64_t)buffSize);
|
||||||
|
|
||||||
read = this->Read(buffer,read);
|
read = this->Read(buffer,read);
|
||||||
|
|
||||||
strm->WriteBlock(buffer, read);
|
strm->WriteBlock(buffer, read);
|
||||||
|
|
||||||
offset += read;
|
offset += read;
|
||||||
|
|||||||
621
src/TF_Init.cpp
621
src/TF_Init.cpp
@@ -2,6 +2,9 @@
|
|||||||
#include "TessesFramework/Streams/NetworkStream.hpp"
|
#include "TessesFramework/Streams/NetworkStream.hpp"
|
||||||
#include "TessesFramework/Lazy.hpp"
|
#include "TessesFramework/Lazy.hpp"
|
||||||
#include "TessesFramework/Filesystem/LocalFS.hpp"
|
#include "TessesFramework/Filesystem/LocalFS.hpp"
|
||||||
|
#include "TessesFramework/Platform/Environment.hpp"
|
||||||
|
#include "TessesFramework/Filesystem/FSHelpers.hpp"
|
||||||
|
#include "TessesFramework/Serialization/Json.hpp"
|
||||||
#include <atomic>
|
#include <atomic>
|
||||||
#include <csignal>
|
#include <csignal>
|
||||||
#include <iostream>
|
#include <iostream>
|
||||||
@@ -330,9 +333,627 @@ if (iResult != 0) {
|
|||||||
|
|
||||||
std::optional<std::string> _argv0=std::nullopt;
|
std::optional<std::string> _argv0=std::nullopt;
|
||||||
|
|
||||||
|
|
||||||
void TF_AllowPortable(std::string argv0)
|
void TF_AllowPortable(std::string argv0)
|
||||||
{
|
{
|
||||||
|
using namespace Tesses::Framework::Serialization::Json;
|
||||||
|
using namespace Tesses::Framework::Platform::Environment;
|
||||||
|
using namespace Tesses::Framework::Filesystem;
|
||||||
_argv0 = argv0;
|
_argv0 = argv0;
|
||||||
|
VFSPath path(argv0);
|
||||||
|
auto realPath=path.MakeAbsolute();
|
||||||
|
auto dir = realPath.GetParent();
|
||||||
|
auto portable=dir / "portable.json";
|
||||||
|
if(LocalFS->FileExists(portable))
|
||||||
|
{
|
||||||
|
|
||||||
|
std::string portable_str;
|
||||||
|
Helpers::ReadAllText(LocalFS,portable, portable_str);
|
||||||
|
auto jsonObj=Json::Decode(portable_str);
|
||||||
|
JObject dict;
|
||||||
|
JObject dict2;
|
||||||
|
if(TryGetJToken(jsonObj,dict) && dict.TryGetValueAsType("portable_data",dict2))
|
||||||
|
{
|
||||||
|
|
||||||
|
if(dict.TryGetValueAsType("portable_type", portable_str))
|
||||||
|
{
|
||||||
|
if(portable_str == "PortableApps.com")
|
||||||
|
{
|
||||||
|
//do the special stuffs for PortableApps.com based apps
|
||||||
|
auto paf_documents = GetVariable("PortableApps.comDocuments");
|
||||||
|
auto paf_music = GetVariable("PortableApps.comMusic");
|
||||||
|
auto paf_pictures = GetVariable("PortableApps.comPictures");
|
||||||
|
auto paf_videos = GetVariable("PortableApps.comVideos");
|
||||||
|
auto paf_data = GetVariable("PAL:DataDir");
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
bool bV=false;
|
||||||
|
if(!dict2.TryGetValueAsType("system_documents",bV) || !bV)
|
||||||
|
{
|
||||||
|
if(paf_documents)
|
||||||
|
{
|
||||||
|
portable_config.documents = LocalFS->SystemToVFSPath(*paf_documents);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if(!dict2.TryGetValueAsType("system_pictures",bV) || !bV)
|
||||||
|
{
|
||||||
|
if(paf_pictures)
|
||||||
|
{
|
||||||
|
portable_config.pictures = LocalFS->SystemToVFSPath(*paf_pictures);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if(!dict2.TryGetValueAsType("system_videos",bV) || !bV)
|
||||||
|
{
|
||||||
|
if(paf_videos)
|
||||||
|
{
|
||||||
|
portable_config.videos = LocalFS->SystemToVFSPath(*paf_videos);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if(!dict2.TryGetValueAsType("system_music",bV) || !bV)
|
||||||
|
{
|
||||||
|
if(paf_music)
|
||||||
|
{
|
||||||
|
portable_config.music = LocalFS->SystemToVFSPath(*paf_music);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if(dict2.TryGetValueAsType("user",portable_str))
|
||||||
|
{
|
||||||
|
if(portable_str == "app")
|
||||||
|
{
|
||||||
|
if(paf_data)
|
||||||
|
portable_config.user = LocalFS->SystemToVFSPath(*paf_data) / "TF_User";
|
||||||
|
}
|
||||||
|
else if(portable_str == "documents")
|
||||||
|
{
|
||||||
|
if(paf_documents)
|
||||||
|
portable_config.user = LocalFS->SystemToVFSPath(*paf_documents) / "TF_User";
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if(dict2.TryGetValueAsType("desktop",portable_str))
|
||||||
|
{
|
||||||
|
if(portable_str == "tf_user")
|
||||||
|
{
|
||||||
|
if(portable_config.user)
|
||||||
|
portable_config.desktop = *(portable_config.user) / "Desktop";
|
||||||
|
}
|
||||||
|
else if(portable_str == "documents")
|
||||||
|
{
|
||||||
|
if(paf_documents)
|
||||||
|
portable_config.desktop = LocalFS->SystemToVFSPath(*paf_documents) / "Desktop";
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if(dict2.TryGetValueAsType("downloads",portable_str))
|
||||||
|
{
|
||||||
|
if(portable_str == "tf_user")
|
||||||
|
{
|
||||||
|
if(portable_config.user)
|
||||||
|
portable_config.downloads = *(portable_config.user) / "Downloads";
|
||||||
|
}
|
||||||
|
else if(portable_str == "documents")
|
||||||
|
{
|
||||||
|
if(paf_documents)
|
||||||
|
portable_config.downloads = LocalFS->SystemToVFSPath(*paf_documents) / "Downloads";
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if(!dict2.TryGetValueAsType("system_config",bV) || !bV)
|
||||||
|
{
|
||||||
|
if(portable_config.user)
|
||||||
|
portable_config.config = *(portable_config.user) / "Config";
|
||||||
|
}
|
||||||
|
if(!dict2.TryGetValueAsType("system_cache",bV) || !bV)
|
||||||
|
{
|
||||||
|
if(portable_config.user)
|
||||||
|
portable_config.cache = *(portable_config.user) / "Cache";
|
||||||
|
}
|
||||||
|
if(!dict2.TryGetValueAsType("system_data",bV) || !bV)
|
||||||
|
{
|
||||||
|
if(portable_config.user)
|
||||||
|
portable_config.data = *(portable_config.user) / "Data";
|
||||||
|
}
|
||||||
|
if(!dict2.TryGetValueAsType("system_state",bV) || !bV)
|
||||||
|
{
|
||||||
|
if(portable_config.user)
|
||||||
|
portable_config.state = *(portable_config.user) / "State";
|
||||||
|
}
|
||||||
|
if(!dict2.TryGetValueAsType("system_temp",bV) || !bV)
|
||||||
|
{
|
||||||
|
if(portable_config.user)
|
||||||
|
portable_config.temp = *(portable_config.user) / "Temp";
|
||||||
|
}
|
||||||
|
}
|
||||||
|
else if(portable_str == "relative")
|
||||||
|
{
|
||||||
|
if(dict2.TryGetValueAsType("user",portable_str))
|
||||||
|
{
|
||||||
|
if(portable_str != "system")
|
||||||
|
{
|
||||||
|
auto userDir = dir / portable_str;
|
||||||
|
portable_config.user = userDir.CollapseRelativeParents();
|
||||||
|
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
if(dict2.TryGetValueAsType("documents", portable_str))
|
||||||
|
{
|
||||||
|
|
||||||
|
if(portable_str != "system")
|
||||||
|
{
|
||||||
|
if(portable_str == "default")
|
||||||
|
{
|
||||||
|
if(portable_config.user)
|
||||||
|
{
|
||||||
|
portable_config.documents = *(portable_config.user) / "Documents";
|
||||||
|
}
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
auto userDir = dir / portable_str;
|
||||||
|
portable_config.documents = userDir.CollapseRelativeParents();
|
||||||
|
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if(dict2.TryGetValueAsType("downloads", portable_str))
|
||||||
|
{
|
||||||
|
|
||||||
|
if(portable_str != "system")
|
||||||
|
{
|
||||||
|
if(portable_str == "default")
|
||||||
|
{
|
||||||
|
if(portable_config.user)
|
||||||
|
{
|
||||||
|
portable_config.downloads = *(portable_config.user) / "Downloads";
|
||||||
|
}
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
auto userDir = dir / portable_str;
|
||||||
|
portable_config.downloads = userDir.CollapseRelativeParents();
|
||||||
|
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if(dict2.TryGetValueAsType("desktop", portable_str))
|
||||||
|
{
|
||||||
|
|
||||||
|
if(portable_str != "system")
|
||||||
|
{
|
||||||
|
if(portable_str == "default")
|
||||||
|
{
|
||||||
|
if(portable_config.user)
|
||||||
|
{
|
||||||
|
portable_config.desktop = *(portable_config.user) / "Desktop";
|
||||||
|
}
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
auto userDir = dir / portable_str;
|
||||||
|
portable_config.desktop = userDir.CollapseRelativeParents();
|
||||||
|
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if(dict2.TryGetValueAsType("pictures", portable_str))
|
||||||
|
{
|
||||||
|
|
||||||
|
if(portable_str != "system")
|
||||||
|
{
|
||||||
|
if(portable_str == "default")
|
||||||
|
{
|
||||||
|
if(portable_config.user)
|
||||||
|
{
|
||||||
|
portable_config.pictures = *(portable_config.user) / "Pictures";
|
||||||
|
}
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
auto userDir = dir / portable_str;
|
||||||
|
portable_config.pictures = userDir.CollapseRelativeParents();
|
||||||
|
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if(dict2.TryGetValueAsType("videos", portable_str))
|
||||||
|
{
|
||||||
|
|
||||||
|
if(portable_str != "system")
|
||||||
|
{
|
||||||
|
if(portable_str == "default")
|
||||||
|
{
|
||||||
|
if(portable_config.user)
|
||||||
|
{
|
||||||
|
portable_config.videos = *(portable_config.user) / "Videos";
|
||||||
|
}
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
auto userDir = dir / portable_str;
|
||||||
|
portable_config.videos = userDir.CollapseRelativeParents();
|
||||||
|
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if(dict2.TryGetValueAsType("music", portable_str))
|
||||||
|
{
|
||||||
|
|
||||||
|
if(portable_str != "system")
|
||||||
|
{
|
||||||
|
if(portable_str == "default")
|
||||||
|
{
|
||||||
|
if(portable_config.user)
|
||||||
|
{
|
||||||
|
portable_config.music = *(portable_config.user) / "Music";
|
||||||
|
}
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
auto userDir = dir / portable_str;
|
||||||
|
portable_config.music = userDir.CollapseRelativeParents();
|
||||||
|
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if(dict2.TryGetValueAsType("config", portable_str))
|
||||||
|
{
|
||||||
|
|
||||||
|
if(portable_str != "system")
|
||||||
|
{
|
||||||
|
if(portable_str == "default")
|
||||||
|
{
|
||||||
|
if(portable_config.user)
|
||||||
|
{
|
||||||
|
portable_config.config = *(portable_config.user) / "Config";
|
||||||
|
}
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
auto userDir = dir / portable_str;
|
||||||
|
portable_config.config = userDir.CollapseRelativeParents();
|
||||||
|
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if(dict2.TryGetValueAsType("cache", portable_str))
|
||||||
|
{
|
||||||
|
|
||||||
|
if(portable_str != "system")
|
||||||
|
{
|
||||||
|
if(portable_str == "default")
|
||||||
|
{
|
||||||
|
if(portable_config.user)
|
||||||
|
{
|
||||||
|
portable_config.cache = *(portable_config.user) / "Cache";
|
||||||
|
}
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
auto userDir = dir / portable_str;
|
||||||
|
portable_config.cache = userDir.CollapseRelativeParents();
|
||||||
|
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if(dict2.TryGetValueAsType("data", portable_str))
|
||||||
|
{
|
||||||
|
|
||||||
|
if(portable_str != "system")
|
||||||
|
{
|
||||||
|
if(portable_str == "default")
|
||||||
|
{
|
||||||
|
if(portable_config.user)
|
||||||
|
{
|
||||||
|
portable_config.data = *(portable_config.user) / "Data";
|
||||||
|
}
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
auto userDir = dir / portable_str;
|
||||||
|
portable_config.data = userDir.CollapseRelativeParents();
|
||||||
|
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if(dict2.TryGetValueAsType("state", portable_str))
|
||||||
|
{
|
||||||
|
|
||||||
|
if(portable_str != "system")
|
||||||
|
{
|
||||||
|
if(portable_str == "default")
|
||||||
|
{
|
||||||
|
if(portable_config.user)
|
||||||
|
{
|
||||||
|
portable_config.state = *(portable_config.user) / "State";
|
||||||
|
}
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
auto userDir = dir / portable_str;
|
||||||
|
portable_config.state = userDir.CollapseRelativeParents();
|
||||||
|
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if(dict2.TryGetValueAsType("temp", portable_str))
|
||||||
|
{
|
||||||
|
|
||||||
|
if(portable_str != "system")
|
||||||
|
{
|
||||||
|
if(portable_str == "default")
|
||||||
|
{
|
||||||
|
if(portable_config.user)
|
||||||
|
{
|
||||||
|
portable_config.temp = *(portable_config.user) / "Temp";
|
||||||
|
}
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
auto userDir = dir / portable_str;
|
||||||
|
portable_config.temp = userDir.CollapseRelativeParents();
|
||||||
|
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
}
|
||||||
|
else if(portable_str == "absolute")
|
||||||
|
{
|
||||||
|
if(dict2.TryGetValueAsType("user",portable_str))
|
||||||
|
{
|
||||||
|
if(portable_str != "system")
|
||||||
|
{
|
||||||
|
VFSPath userDir = portable_str;
|
||||||
|
portable_config.user = userDir.CollapseRelativeParents();
|
||||||
|
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
if(dict2.TryGetValueAsType("documents", portable_str))
|
||||||
|
{
|
||||||
|
|
||||||
|
if(portable_str != "system")
|
||||||
|
{
|
||||||
|
if(portable_str == "default")
|
||||||
|
{
|
||||||
|
if(portable_config.user)
|
||||||
|
{
|
||||||
|
portable_config.documents = *(portable_config.user) / "Documents";
|
||||||
|
}
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
VFSPath userDir = portable_str;
|
||||||
|
portable_config.documents = userDir.CollapseRelativeParents();
|
||||||
|
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if(dict2.TryGetValueAsType("downloads", portable_str))
|
||||||
|
{
|
||||||
|
|
||||||
|
if(portable_str != "system")
|
||||||
|
{
|
||||||
|
if(portable_str == "default")
|
||||||
|
{
|
||||||
|
if(portable_config.user)
|
||||||
|
{
|
||||||
|
portable_config.downloads = *(portable_config.user) / "Downloads";
|
||||||
|
}
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
VFSPath userDir = portable_str;
|
||||||
|
portable_config.downloads = userDir.CollapseRelativeParents();
|
||||||
|
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if(dict2.TryGetValueAsType("desktop", portable_str))
|
||||||
|
{
|
||||||
|
|
||||||
|
if(portable_str != "system")
|
||||||
|
{
|
||||||
|
if(portable_str == "default")
|
||||||
|
{
|
||||||
|
if(portable_config.user)
|
||||||
|
{
|
||||||
|
portable_config.desktop = *(portable_config.user) / "Desktop";
|
||||||
|
}
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
VFSPath userDir = portable_str;
|
||||||
|
portable_config.desktop = userDir.CollapseRelativeParents();
|
||||||
|
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if(dict2.TryGetValueAsType("pictures", portable_str))
|
||||||
|
{
|
||||||
|
|
||||||
|
if(portable_str != "system")
|
||||||
|
{
|
||||||
|
if(portable_str == "default")
|
||||||
|
{
|
||||||
|
if(portable_config.user)
|
||||||
|
{
|
||||||
|
portable_config.pictures = *(portable_config.user) / "Pictures";
|
||||||
|
}
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
VFSPath userDir = portable_str;
|
||||||
|
portable_config.pictures = userDir.CollapseRelativeParents();
|
||||||
|
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if(dict2.TryGetValueAsType("videos", portable_str))
|
||||||
|
{
|
||||||
|
|
||||||
|
if(portable_str != "system")
|
||||||
|
{
|
||||||
|
if(portable_str == "default")
|
||||||
|
{
|
||||||
|
if(portable_config.user)
|
||||||
|
{
|
||||||
|
portable_config.videos = *(portable_config.user) / "Videos";
|
||||||
|
}
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
VFSPath userDir = portable_str;
|
||||||
|
portable_config.videos = userDir.CollapseRelativeParents();
|
||||||
|
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if(dict2.TryGetValueAsType("music", portable_str))
|
||||||
|
{
|
||||||
|
|
||||||
|
if(portable_str != "system")
|
||||||
|
{
|
||||||
|
if(portable_str == "default")
|
||||||
|
{
|
||||||
|
if(portable_config.user)
|
||||||
|
{
|
||||||
|
portable_config.music = *(portable_config.user) / "Music";
|
||||||
|
}
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
VFSPath userDir = portable_str;
|
||||||
|
portable_config.music = userDir.CollapseRelativeParents();
|
||||||
|
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if(dict2.TryGetValueAsType("config", portable_str))
|
||||||
|
{
|
||||||
|
|
||||||
|
if(portable_str != "system")
|
||||||
|
{
|
||||||
|
if(portable_str == "default")
|
||||||
|
{
|
||||||
|
if(portable_config.user)
|
||||||
|
{
|
||||||
|
portable_config.config = *(portable_config.user) / "Config";
|
||||||
|
}
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
VFSPath userDir = portable_str;
|
||||||
|
portable_config.config = userDir.CollapseRelativeParents();
|
||||||
|
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if(dict2.TryGetValueAsType("cache", portable_str))
|
||||||
|
{
|
||||||
|
|
||||||
|
if(portable_str != "system")
|
||||||
|
{
|
||||||
|
if(portable_str == "default")
|
||||||
|
{
|
||||||
|
if(portable_config.user)
|
||||||
|
{
|
||||||
|
portable_config.cache = *(portable_config.user) / "Cache";
|
||||||
|
}
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
VFSPath userDir = portable_str;
|
||||||
|
portable_config.cache = userDir.CollapseRelativeParents();
|
||||||
|
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if(dict2.TryGetValueAsType("data", portable_str))
|
||||||
|
{
|
||||||
|
|
||||||
|
if(portable_str != "system")
|
||||||
|
{
|
||||||
|
if(portable_str == "default")
|
||||||
|
{
|
||||||
|
if(portable_config.user)
|
||||||
|
{
|
||||||
|
portable_config.data = *(portable_config.user) / "Data";
|
||||||
|
}
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
VFSPath userDir = portable_str;
|
||||||
|
portable_config.data = userDir.CollapseRelativeParents();
|
||||||
|
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if(dict2.TryGetValueAsType("state", portable_str))
|
||||||
|
{
|
||||||
|
|
||||||
|
if(portable_str != "system")
|
||||||
|
{
|
||||||
|
if(portable_str == "default")
|
||||||
|
{
|
||||||
|
if(portable_config.user)
|
||||||
|
{
|
||||||
|
portable_config.state = *(portable_config.user) / "State";
|
||||||
|
}
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
VFSPath userDir = portable_str;
|
||||||
|
portable_config.state = userDir.CollapseRelativeParents();
|
||||||
|
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if(dict2.TryGetValueAsType("temp", portable_str))
|
||||||
|
{
|
||||||
|
|
||||||
|
if(portable_str != "system")
|
||||||
|
{
|
||||||
|
if(portable_str == "default")
|
||||||
|
{
|
||||||
|
if(portable_config.user)
|
||||||
|
{
|
||||||
|
portable_config.temp = *(portable_config.user) / "Temp";
|
||||||
|
}
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
VFSPath userDir = portable_str;
|
||||||
|
portable_config.temp = userDir.CollapseRelativeParents();
|
||||||
|
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
std::optional<std::string> TF_GetCommandName()
|
std::optional<std::string> TF_GetCommandName()
|
||||||
|
|||||||
Reference in New Issue
Block a user