git/metabuilder
1
0
Fork 0
mirror of https://github.com/johndoe6345789/metabuilder.git synced 2026-04-24 13:54:57 +00:00
Code Issues Packages Projects Releases Wiki Activity

docs: production,dbal,txt (2 files)

Browse Source
This commit is contained in:
Richard Ward
2025-12-30 22:32:00 +00:00
parent 6d47884ba4
commit ce650fe83e
2 changed files with 69 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
dbal/production/build-config/CMakeLists.txt
View File

@@ -44,6 +44,7 @@ add_executable(dbal_daemon
${DBAL_SRC_DIR}/daemon/server_helpers/serialization.cpp
${DBAL_SRC_DIR}/daemon/server_helpers/response.cpp
${DBAL_SRC_DIR}/daemon/rpc_user_actions.cpp
${DBAL_SRC_DIR}/daemon/rpc_schema_actions.cpp
${DBAL_SRC_DIR}/daemon/security.cpp
)

68
dbal/production/src/daemon/server_routes.cpp
View File

@@ -147,6 +147,74 @@ void Server::registerRoutes() {
drogon::app().registerHandler("/api/status", status_handler, {drogon::HttpMethod::Get});
drogon::app().registerHandler("/api/dbal", rpc_handler, {drogon::HttpMethod::Post});
// Schema management routes
auto schema_handler = [](const drogon::HttpRequestPtr& request,
std::function<void(const drogon::HttpResponsePtr&)>&& callback) {
// Get paths from environment or use defaults
const char* env_registry = std::getenv("DBAL_SCHEMA_REGISTRY_PATH");
const char* env_packages = std::getenv("DBAL_PACKAGES_PATH");
const char* env_output = std::getenv("DBAL_PRISMA_OUTPUT_PATH");
const std::string registry_path = env_registry ? env_registry : "/app/prisma/schema-registry.json";
const std::string packages_path = env_packages ? env_packages : "/app/packages";
const std::string output_path = env_output ? env_output : "/app/prisma/generated-from-packages.prisma";
auto send_success = [&callback](const Json::Value& data) {
callback(build_json_response(data));
};
auto send_error = [&callback](const std::string& message, int status) {
Json::Value body;
body["success"] = false;
body["error"] = message;
auto response = drogon::HttpResponse::newHttpJsonResponse(body);
response->setStatusCode(static_cast<drogon::HttpStatusCode>(status));
callback(response);
};
// Handle GET - list/status
if (request->method() == drogon::HttpMethod::Get) {
rpc::handle_schema_list(registry_path, send_success, send_error);
return;
}
// Handle POST - actions
std::istringstream stream(request->getBody());
Json::CharReaderBuilder reader_builder;
Json::Value body;
JSONCPP_STRING errs;
if (!Json::parseFromStream(reader_builder, stream, &body, &errs)) {
send_error("Invalid JSON payload", 400);
return;
}
const std::string action = body.get("action", "").asString();
const std::string id = body.get("id", "").asString();
if (action == "scan") {
rpc::handle_schema_scan(registry_path, packages_path, send_success, send_error);
} else if (action == "approve") {
if (id.empty()) {
send_error("Migration ID required", 400);
return;
}
rpc::handle_schema_approve(registry_path, id, send_success, send_error);
} else if (action == "reject") {
if (id.empty()) {
send_error("Migration ID required", 400);
return;
}
rpc::handle_schema_reject(registry_path, id, send_success, send_error);
} else if (action == "generate") {
rpc::handle_schema_generate(registry_path, output_path, send_success, send_error);
} else {
send_error("Unknown action: " + action, 400);
}
};
drogon::app().registerHandler("/api/dbal/schema", schema_handler,
{drogon::HttpMethod::Get, drogon::HttpMethod::Post});
routes_registered_ = true;
}