Compare commits

...

13 Commits

Author SHA1 Message Date
feeaab1ebe pull = fetch/merge 2024-04-15 16:58:00 +02:00
7aed1eed11 changed parameters 2024-04-15 16:44:42 +02:00
d8de4e070e PullRepository(): call fetch and merge 2024-04-15 16:41:11 +02:00
fe46da5417 format code 2024-04-05 12:44:34 +02:00
a3cbb20a53 at least it compiles 2024-04-05 12:13:27 +02:00
1d119cb63e continued merge 2024-04-05 11:41:26 +02:00
a336b507fb forglobal defines 2024-04-05 11:10:12 +02:00
84c422ee38 just safe again 2024-04-03 16:40:46 +02:00
4ab36ec64f just safe 2024-04-03 16:29:58 +02:00
7ba9cb8147 ostern ... 2024-03-28 16:45:46 +01:00
5338c30e79 saving ... 2024-03-27 08:40:16 +01:00
2d8a947cb4 Adapt to new atb-units 2024-03-25 16:13:26 +01:00
f3680754ec save for the weekend 2024-03-22 13:46:54 +01:00
8 changed files with 1307 additions and 606 deletions

View File

@@ -28,14 +28,17 @@ CONFIG += c++20 console
SOURCES += \ SOURCES += \
calculator_c_interface_lib.cpp \ calculator_c_interface_lib.cpp \
git_library.cpp \
tariff_calculator.cpp \ tariff_calculator.cpp \
local_git_repository.cpp local_git_repository.cpp
HEADERS += \ HEADERS += \
calculator_c_interface_lib.h \ calculator_c_interface_lib.h \
calculator_c_interface_lib_global.h \ calculator_c_interface_lib_global.h \
git_library.h \
tariff_calculator.h \ tariff_calculator.h \
local_git_repository.h local_git_repository.h \
global_defines.h
# Default rules for deployment. # Default rules for deployment.
unix { unix {

View File

@@ -1,4 +1,6 @@
#include "calculator_c_interface_lib.h" #include "calculator_c_interface_lib.h"
#include "local_git_repository.h"
#include "git_library.h"
//#include <git2/common.h> //#include <git2/common.h>
@@ -17,10 +19,8 @@
#include <stdint.h> #include <stdint.h>
#include <algorithm> #include <algorithm>
static QMap<QString, git_repository *> customerRepoMap; //static QMap<QString, git_repository *> customerRepoMap;
static std::mutex m; //static std::mutex m;
static char const *user = NULL;
static char const *pass = NULL;
#ifndef _WIN32 #ifndef _WIN32
# include <unistd.h> # include <unistd.h>
@@ -31,241 +31,6 @@ static char const *pass = NULL;
extern "C" { extern "C" {
#endif #endif
// see https://libgit2.org/libgit2/ex/HEAD/checkout.html
/* Define t/he printf format specifier to use for size_t output */
#if defined(_MSC_VER) || defined(__MINGW32__)
# define PRIuZ "Illu"
# define PRIxZ "Illx"
# define PRIdZ "Illd"
#else
# define PRIuZ "zu"
# define PRIxZ "zx"
# define PRIdZ "zd"
#endif
typedef struct {
unsigned int force : 1;
unsigned int progress : 1;
unsigned int perf : 1;
} checkout_options;
int cred_acquire_cb(git_credential **out,
const char *url,
const char *username_from_url,
unsigned int allowed_types,
void *payload)
{
char const *username = user, *password = pass;
fprintf(stderr, "%s:%d: opened repository %s %s\n", __func__, __LINE__, username, password);
Q_UNUSED(url);
Q_UNUSED(username_from_url);
Q_UNUSED(payload);
int error = -1;
if (allowed_types & GIT_CREDENTIAL_USERPASS_PLAINTEXT) {
error = git_credential_userpass_plaintext_new(out, username, password);
} else {
fprintf(stderr, "GIT_CREDENTIAL_USERPASS_PLAINTEXT not supported by protocol (allowed_types=%08x)\n", allowed_types);
}
return error;
}
static bool check(int error, const char *message, const char *extra) {
const git_error *lg2err;
const char *lg2msg = "", *lg2spacer = "";
if (!error) {
return true;
}
if ((lg2err = git_error_last()) != NULL && lg2err->message != NULL) {
lg2msg = lg2err->message;
lg2spacer = " - ";
}
if (extra)
fprintf(stderr, "%s '%s' [%d]%s%s\n",
message, extra, error, lg2spacer, lg2msg);
else
fprintf(stderr, "%s [%d]%s%s\n",
message, error, lg2spacer, lg2msg);
// exit(1);
return false;
}
static void print_checkout_progress(const char *path, size_t completed_steps, size_t total_steps, void *payload) {
(void)payload;
if (path == NULL) {
printf("checkout started: %" PRIuZ " steps\n", total_steps);
} else {
printf("checkout: %s %" PRIuZ "/%" PRIuZ "\n", path, completed_steps, total_steps);
}
}
static void print_perf_data(const git_checkout_perfdata *perfdata, void *payload) {
(void)payload;
printf("perf: stat: %" PRIuZ " mkdir: %" PRIuZ " chmod: %" PRIuZ "\n",
perfdata->stat_calls, perfdata->mkdir_calls, perfdata->chmod_calls);
}
static int resolve_refish(git_annotated_commit **commit, git_repository *repo, const char *refish)
{
git_reference *ref;
git_object *obj;
int err = 0;
assert(commit != NULL);
err = git_reference_dwim(&ref, repo, refish);
if (err == GIT_OK) {
git_annotated_commit_from_ref(commit, repo, ref);
git_reference_free(ref);
return 0;
}
err = git_revparse_single(&obj, repo, refish);
if (err == GIT_OK) {
err = git_annotated_commit_lookup(commit, repo, git_object_id(obj));
git_object_free(obj);
}
return err;
}
static int perform_checkout_ref(git_repository *repo,
git_annotated_commit *target,
const char *target_ref, checkout_options *opts) {
git_checkout_options checkout_opts;
git_reference *ref = NULL, *branch = NULL;
git_commit *target_commit = NULL;
int err;
if ((err = git_checkout_options_init(&checkout_opts, GIT_CHECKOUT_OPTIONS_VERSION)) < 0) {
fprintf(stderr, "error checkout options init %s\n", git_error_last()->message);
return err;
}
// Setup our checkout options from the parsed options
checkout_opts.checkout_strategy = GIT_CHECKOUT_SAFE;
// if (opts->force)
// checkout_opts.checkout_strategy = GIT_CHECKOUT_FORCE;
// if (opts->progress)
// checkout_opts.progress_cb = print_checkout_progress;
// if (opts->perf)
// checkout_opts.perfdata_cb = print_perf_data;
// Grab the commit we're interested to move to
err = git_commit_lookup(&target_commit, repo, git_annotated_commit_id(target));
if (err != 0) {
fprintf(stderr, "failed to lookup commit: %s\n", git_error_last()->message);
goto cleanup;
}
// Perform the checkout so the workdir corresponds to what target_commit contains.
// Note that it's okay to pass a git_commit here, because it will be peeled to a tree.
err = git_checkout_tree(repo, (const git_object *)target_commit, &checkout_opts);
if (err != 0) {
fprintf(stderr, "failed to checkout tree: %s\n", git_error_last()->message);
goto cleanup;
}
// Now that the checkout has completed, we have to update HEAD.
// Depending on the "origin" of target (ie. it's an OID or a branch name), we might need to detach HEAD.
if (git_annotated_commit_ref(target)) {
const char *target_head;
if ((err = git_reference_lookup(&ref, repo, git_annotated_commit_ref(target))) < 0)
goto error;
if (git_reference_is_remote(ref)) {
if ((err = git_branch_create_from_annotated(&branch, repo, target_ref, target, 0)) < 0)
goto error;
target_head = git_reference_name(branch);
} else {
target_head = git_annotated_commit_ref(target);
}
err = git_repository_set_head(repo, target_head);
} else {
err = git_repository_set_head_detached_from_annotated(repo, target);
}
error:
if (err != 0) {
fprintf(stderr, "failed to update HEAD reference: %s\n", git_error_last()->message);
goto cleanup;
}
cleanup:
git_commit_free(target_commit);
git_reference_free(branch);
git_reference_free(ref);
return err;
}
static int guess_refish(git_annotated_commit **out, git_repository *repo, const char *ref) {
git_strarray remotes = { NULL, 0 };
git_reference *remote_ref = NULL;
int error;
size_t i;
if ((error = git_remote_list(&remotes, repo)) < 0) {
fprintf(stderr, "error git_remote_list %s\n", git_error_last()->message);
goto out;
}
for (i = 0; i < remotes.count; i++) {
char *refname = NULL;
size_t reflen;
reflen = snprintf(refname, 0, "refs/remotes/%s/%s", remotes.strings[i], ref);
if ((refname = (char *)malloc(reflen + 1)) == NULL) {
error = -1;
fprintf(stderr, "%s:%d malloc failed\n", __func__, __LINE__);
goto next;
}
snprintf(refname, reflen + 1, "refs/remotes/%s/%s", remotes.strings[i], ref);
if ((error = git_reference_lookup(&remote_ref, repo, refname)) < 0) {
fprintf(stderr, "git reference lookup %s\n", git_error_last()->message);
goto next;
}
break;
next:
free(refname);
refname = NULL;
if (error < 0 && error != GIT_ENOTFOUND) {
break;
}
}
if (!remote_ref) {
error = GIT_ENOTFOUND;
goto out;
}
if ((error = git_annotated_commit_from_ref(out, repo, remote_ref)) < 0)
goto out;
out:
git_reference_free(remote_ref);
git_strarray_dispose(&remotes);
return error;
}
TariffCalculatorHandle NewTariffCalculator(void) { TariffCalculatorHandle NewTariffCalculator(void) {
return new TariffCalculator(); return new TariffCalculator();
@@ -275,356 +40,74 @@ void DeleteTariffCalculator(TariffCalculatorHandle handle) {
delete handle; delete handle;
} }
int InitGitLibrary(void) { int InitGitLibraryInternal(void) {
return git_libgit2_init(); return GitLibrary::Init();
} }
int ShutdownGitLibrary(void) { int ShutdownGitLibraryInternal(void) {
LocalGitRepository::DestroyAllRepositories();
for (auto key : customerRepoMap.keys()) { return GitLibrary::Shutdown();
git_repository_free(customerRepoMap.value(key));
}
customerRepoMap.clear();
return git_libgit2_shutdown();
} }
int CloneRepository(char const *url, char const *local_path) { int CloneRepositoryInternal(char const *url, char const *local_path) {
return GitLibrary::CloneRepository(url, local_path);
QString localRepoPath(QDir::cleanPath(QString(local_path) + QDir::separator() + ".git"));
QDir localRepoDir(localRepoPath);
if (localRepoDir.exists()) {
fprintf(stderr, "local repository path %s already exists\n",
localRepoPath.toUtf8().constData());
return -1;
} }
git_repository *out; int CheckoutRepositoryInternal(char const *url, char const *localRepoName, char const *branchName) {
git_clone_options opts; return GitLibrary::CheckoutRepository(url, localRepoName, branchName);
int res = 0;
if ((res = git_clone_options_init(&opts, GIT_CLONE_OPTIONS_VERSION)) == 0) {
opts.checkout_branch = "master";
fprintf(stderr, "%s:%d %s %s\n", __func__, __LINE__, url, local_path);
if ((res = git_clone(&out, url, local_path, &opts)) < 0) {
git_error const *error = git_error_last();
fprintf(stderr, "%s:%d error: %s\n", __func__, __LINE__, error->message);
} else {
QString localRepoPath = QDir::cleanPath(QString(local_path) + QDir::separator() + ".git");
customerRepoMap.insert(localRepoPath, out);
}
} else {
git_error const *error = git_error_last();
fprintf(stderr, "%s:%d error: %s\n", __func__, __LINE__, error->message);
}
return res;
} }
int CheckoutLocalBranch(char const *local_path, char const *branch_name) { int CommitFileInternal(char const *localRepoName, char const *branchName,
int err = 0; char const *fName, char const *commitMessage) {
checkout_options opts; return GitLibrary::CommitFile(localRepoName, branchName, fName, commitMessage);
git_repository_state_t state = GIT_REPOSITORY_STATE_NONE;
git_annotated_commit *checkout_target = NULL;
git_repository *repo = NULL;
git_reference *branch_ref = NULL;
QString localRepoPath(QDir::cleanPath(QString(local_path) + QDir::separator() + ".git"));
QDir localRepoDir(localRepoPath);
if (!localRepoDir.exists()) {
fprintf(stderr, "local repository path %s does not exist\n",
localRepoPath.toUtf8().constData());
return -1;
} }
if (!customerRepoMap.contains(localRepoPath)) { int PushRepositoryInternal(char const *localRepoName, char const *branchName,
if ((err = git_repository_open(&repo, localRepoPath.toUtf8().constData())) != 0) { char const *userName, char const *userPassword) {
fprintf(stderr, "repository %s cannot be opened: %s\n", return GitLibrary::PushRepository(localRepoName, branchName, userName, userPassword);
localRepoPath.toUtf8().constData(), git_error_last()->message);
return -1;
}
customerRepoMap.insert(localRepoPath, repo);
} }
if (customerRepoMap.contains(localRepoPath)) { int PullRepositoryInternal(char const *localRepoName, char const *remoteRepoName) {
repo = customerRepoMap[localRepoPath]; return GitLibrary::PullRepository(localRepoName, remoteRepoName);
// Make sure we're not about to checkout while something else is going on
if ((state = (git_repository_state_t)git_repository_state(repo)) != GIT_REPOSITORY_STATE_NONE) {
fprintf(stderr, "repository %s is in unexpected state %d\n",
localRepoPath.toUtf8().constData(), state);
err = -1;
} else {
fprintf(stderr, "repository %s is in state %d\n",
localRepoPath.toUtf8().constData(), state);
if ((err = resolve_refish(&checkout_target, repo, branch_name)) < 0 &&
(err = guess_refish(&checkout_target, repo, branch_name)) < 0) {
fprintf(stderr, "failed to resolve %s: %s\n", branch_name, git_error_last()->message);
} else {
if ((err = perform_checkout_ref(repo, checkout_target, branch_name, &opts)) == 0) {
fprintf(stderr, "%s:%d checkout ok\n", __func__, __LINE__);
if ((err = git_branch_lookup(&branch_ref, repo, branch_name, GIT_BRANCH_LOCAL)) != 0) {
if (err == GIT_ENOTFOUND) {
fprintf(stderr, "local branch %s not found\n", branch_name);
} else {
fprintf(stderr, "local branch %s not found: %s\n",
branch_name, git_error_last()->message);
}
}
}
}
}
}
if (branch_ref) {
git_reference_free(branch_ref);
}
if (checkout_target) {
git_annotated_commit_free(checkout_target);
}
return err;
}
int CommitFile(char const *local_path, char const *branch_name,
char const *file_name, char const *comment) {
assert(local_path != NULL);
assert(branch_name != NULL);
assert(file_name != NULL);
assert(comment != NULL);
fprintf(stderr, "%s %s %s %s\n",
local_path, branch_name, file_name, comment);
QString const currentWD = QDir::currentPath();
QString localPath(local_path);
if (!QDir(localPath).exists()) {
fprintf(stderr, "local path %s for file %s does not exist\n",
localPath.toUtf8().constData(), file_name);
QDir::setCurrent(currentWD);
return -1;
}
if (!QDir::setCurrent(localPath)) {
fprintf(stderr, "can not set cwd path %s\n", localPath.toUtf8().constData());
QDir::setCurrent(currentWD);
return -1;
}
fprintf(stderr, "cwd %s\n", QDir::current().absolutePath().toUtf8().constData());
git_repository *repo = NULL;
int error = 0;
QString localRepoPath(QDir::cleanPath(QString(local_path) + QDir::separator() + ".git"));
QDir localRepoDir(localRepoPath);
if (!localRepoDir.exists()) {
fprintf(stderr, "local repository path %s does not exist\n",
localRepoPath.toUtf8().constData());
QDir::setCurrent(currentWD);
return -1;
}
if (!customerRepoMap.contains(localRepoPath)) {
if ((error = git_repository_open(&repo, localRepoPath.toUtf8().constData())) != 0) {
fprintf(stderr, "repository %s cannot be opened: %s\n",
localRepoPath.toUtf8().constData(), git_error_last()->message);
QDir::setCurrent(currentWD);
return -1;
}
customerRepoMap.insert(localRepoPath, repo);
}
git_oid commit_oid,tree_oid;
git_tree *tree = NULL;
git_index *index = NULL;
git_object *parent = NULL;
git_reference *ref = NULL;
git_signature *signature = NULL;
git_repository_state_t state = GIT_REPOSITORY_STATE_NONE;
if (customerRepoMap.contains(localRepoPath)) {
repo = customerRepoMap[localRepoPath];
if (git_repository_head_unborn(repo) == 1) {
fprintf(stderr, "HEAD unborn. Create first commit\n");
return -1;
}
// Make sure we're not about to checkout while something else is going on
if ((state = (git_repository_state_t)git_repository_state(repo)) != GIT_REPOSITORY_STATE_NONE) {
fprintf(stderr, "repository %s is in unexpected state %d\n",
localRepoPath.toUtf8().constData(), state);
error = -1;
} else {
error = git_revparse_ext(&parent, &ref, repo, "HEAD");
if (error == GIT_ENOTFOUND) {
fprintf(stderr, "HEAD not found. Creating first commit\n");
error = 0;
} else if (error != 0) {
const git_error *err = git_error_last();
if (err) {
fprintf(stderr, "ERROR %d: %s\n", err->klass, err->message);
} else {
fprintf(stderr, "ERROR %d: no detailed info\n", error);
}
}
if (error == 0) {
if (check(git_repository_index(&index, repo), "Could not open repository index", NULL) &&
check(git_index_write_tree(&tree_oid, index), "Could not write tree", NULL) &&
check(git_index_write(index), "Could not write index", NULL) &&
check(git_tree_lookup(&tree, repo, &tree_oid), "Error looking up tree", NULL) &&
check(git_signature_default(&signature, repo), "Error creating signature", NULL) &&
check(git_commit_create_v(&commit_oid, repo, "HEAD", signature, signature,
NULL, comment, tree, parent ? 1 : 0, parent),
"Error creating commit", NULL)) {
fprintf(stderr, "%s %s %s %s\n",
local_path, branch_name, file_name, comment);
fprintf(stderr, "git commit ok\n");
}
if (index) {
git_index_free(index);
}
if (signature) {
git_signature_free(signature);
}
if (tree) {
git_tree_free(tree);
}
if (parent) {
git_object_free(parent);
}
if (ref) {
git_reference_free(ref);
}
}
}
}
QDir::setCurrent(currentWD);
return error;
}
int PushLocalRepository(char const *local_path, char const *branch_name, char const *username, char const *password) {
git_repository *repo = NULL;
int error = -1;
fprintf(stderr, "%s:%d: %s %s\n", __func__, __LINE__, local_path, branch_name);
QString const currentWD = QDir::currentPath();
QString localRepoPath(QDir::cleanPath(QString(local_path) + QDir::separator() + ".git"));
QDir localRepoDir(localRepoPath);
if (!localRepoDir.exists()) {
fprintf(stderr, "local repository path %s does not exist\n",
localRepoPath.toUtf8().constData());
QDir::setCurrent(currentWD);
return -1;
}
if (!customerRepoMap.contains(localRepoPath)) {
if ((error = git_repository_open(&repo, localRepoPath.toUtf8().constData())) != 0) {
fprintf(stderr, "repository %s cannot be opened: %s\n",
localRepoPath.toUtf8().constData(), git_error_last()->message);
QDir::setCurrent(currentWD);
return -1;
}
customerRepoMap.insert(localRepoPath, repo);
}
fprintf(stderr, "%s:%d: opened repository\n", __func__, __LINE__);
git_repository_state_t state = GIT_REPOSITORY_STATE_NONE;
git_push_options options;
git_remote_callbacks callbacks;
git_remote* remote = NULL;
char refspec_[] = "refs/heads/master";
char *refspec = refspec_;
const git_strarray refspecs = {
&refspec,
1
};
std::lock_guard<std::mutex> lock(m);
user = username;
pass = password;
fprintf(stderr, "%s:%d: opened repository %s %s\n", __func__, __LINE__, user, pass);
if (customerRepoMap.contains(localRepoPath)) {
repo = customerRepoMap[localRepoPath];
// Make sure we're not about to checkout while something else is going on
if ((state = (git_repository_state_t)git_repository_state(repo)) != GIT_REPOSITORY_STATE_NONE) {
fprintf(stderr, "repository %s is in unexpected state %d\n",
localRepoPath.toUtf8().constData(), state);
} else {
if (check(git_remote_lookup(&remote, repo, "origin" ), "Unable to lookup remote", NULL)) {
if (check(git_remote_init_callbacks(&callbacks, GIT_REMOTE_CALLBACKS_VERSION),
"Error initializing remote callbacks", NULL)) {
callbacks.credentials = cred_acquire_cb;
if (check(git_push_options_init(&options, GIT_PUSH_OPTIONS_VERSION ),
"Error initializing push", NULL)) {
options.callbacks = callbacks;
if (check(git_remote_push(remote, &refspecs, &options), "Error pushing", NULL)) {
fprintf(stderr, "%s:%d: pushed %s (branch: %s)\n", __func__, __LINE__, local_path, branch_name);
error = 0;
}
}
}
}
}
}
if (remote) {
git_remote_free(remote);
}
QDir::setCurrent(currentWD);
return error;
} }
#include <local_git_repository.h> #include <local_git_repository.h>
static QMap<QString, LocalGitRepository *> localGitRepos;
int32_t GetFileMenuSize(char const *localGitRepo) { void SetReposRootDirectoryInternal(char const *p) {
if (localGitRepos.count(localGitRepo) == 0) { LocalGitRepository::SetReposRootDirectory(QString::fromUtf8(p));
localGitRepos.insert(localGitRepo,
new LocalGitRepository(localGitRepo));
}
return localGitRepos[localGitRepo]->GetFileMenuSize();
} }
char const *GetFileMenu(const char *localGitRepo) { char const *GetReposRootDirectoryInternal() {
static char j[] = "{}"; return (char const *)LocalGitRepository::GetReposRootDirectory().constData();
char *json = j; }
int const len = GetFileMenuSize(localGitRepo);
char const *GetLocalRepositoryPathInternal(char const *localGitRepo) {
return (char const *)LocalGitRepository::GetInstance(localGitRepo)->localRepositoryPath().constData();
}
int32_t GetFileMenuSizeInternal(char const *localGitRepo) {
return LocalGitRepository::GetInstance(localGitRepo)->GetFileMenuSizeInternal();
}
char const *GetFileMenuInternal(const char *localGitRepo) {
QByteArray const &a = LocalGitRepository::GetInstance(localGitRepo)->GetFileMenuInternal().constData();
if (a.isValidUtf8()) {
int const len = GetFileMenuSizeInternal(localGitRepo);
if (len > 0) { if (len > 0) {
json = new char [len+1]; char *json = new char [len+1];
// fprintf(stderr, "allocate pointer %p\n", json); // fprintf(stderr, "allocate pointer %p\n", json);
memset(json, 0x00, len+1); memset(json, 0x00, len+1);
QByteArray const &a = localGitRepos[localGitRepo]->GetFileMenu().constData();
if (a.isValidUtf8()) {
memcpy(json, a.constData(), std::min(len, (int)a.size())); memcpy(json, a.constData(), std::min(len, (int)a.size()));
}
}
return json; return json;
} }
}
return nullptr;
}
char const *GetFileName(char const *localGitRepo, char const *fileId) { char const *GetFileNameInternal(char const *localGitRepo, char const *fileId) {
QByteArray const &a = localGitRepos[localGitRepo]->GetFileName(fileId); QByteArray const &a = LocalGitRepository::GetInstance(localGitRepo)->GetFileNameInternal(fileId);
if (a.isValidUtf8()) { if (a.isValidUtf8()) {
char *c = new char[a.size() + 1]; char *c = new char[a.size() + 1];
memset(c, 0x00, a.size() + 1); memset(c, 0x00, a.size() + 1);
@@ -635,11 +118,11 @@ char const *GetFileName(char const *localGitRepo, char const *fileId) {
} }
int32_t GetFileSize(char const *localGitRepo, char const *fileId) { int32_t GetFileSize(char const *localGitRepo, char const *fileId) {
return localGitRepos[localGitRepo]->GetFileSize(fileId); return LocalGitRepository::GetInstance(localGitRepo)->GetFileSize(fileId);
} }
char const *GetFile(char const *localGitRepo, char const *fileId) { char const *GetFileInternal(char const *localGitRepo, char const *fileId) {
QByteArray const &a = localGitRepos[localGitRepo]->GetFile(fileId); QByteArray const &a = LocalGitRepository::GetInstance(localGitRepo)->GetFileInternal(fileId);
if (a.isValidUtf8()) { if (a.isValidUtf8()) {
char *c = new char[a.size() + 1]; char *c = new char[a.size() + 1];
memset(c, 0x00, a.size() + 1); memset(c, 0x00, a.size() + 1);
@@ -649,6 +132,10 @@ char const *GetFile(char const *localGitRepo, char const *fileId) {
return nullptr; return nullptr;
} }
bool SetFileInternal(char const *localGitRepo, char const *fileId, char const *json, int size) {
return LocalGitRepository::GetInstance(localGitRepo)->SetFileInternal(QString(fileId), QByteArray(json, size));
}
void DeleteMem(char *p) { void DeleteMem(char *p) {
if (p) { if (p) {
// fprintf(stderr, "delete pointer %p\n", p); // fprintf(stderr, "delete pointer %p\n", p);

View File

@@ -10,25 +10,30 @@ extern "C" {
#endif #endif
void DeleteMem(char *p) CALCULATOR_C_INTERFACE_LIB_EXPORT; void DeleteMem(char *p) CALCULATOR_C_INTERFACE_LIB_EXPORT;
void SetReposRootDirectoryInternal(char const *p) CALCULATOR_C_INTERFACE_LIB_EXPORT;
char const *GetReposRootDirectoryInternal() CALCULATOR_C_INTERFACE_LIB_EXPORT;
char const *GetLocalRepositoryPathInternal(char const *localRepo) CALCULATOR_C_INTERFACE_LIB_EXPORT;
// interface for menu of webpage // interface for menu of webpage
char const *GetFileMenu(char const *localRepo) CALCULATOR_C_INTERFACE_LIB_EXPORT; char const *GetFileMenuInternal(char const *localRepo) CALCULATOR_C_INTERFACE_LIB_EXPORT;
int32_t GetFileMenuSize(char const *localRepo) CALCULATOR_C_INTERFACE_LIB_EXPORT; int32_t GetFileMenuSizeInternal(char const *localRepo) CALCULATOR_C_INTERFACE_LIB_EXPORT;
char const *GetFileName(char const *localRepo, char const *fileId) CALCULATOR_C_INTERFACE_LIB_EXPORT;
char const *GetFileNameInternal(char const *localRepo, char const *fileId) CALCULATOR_C_INTERFACE_LIB_EXPORT;
int32_t GetFileSize(char const *localRepo, char const *fileId) CALCULATOR_C_INTERFACE_LIB_EXPORT; int32_t GetFileSize(char const *localRepo, char const *fileId) CALCULATOR_C_INTERFACE_LIB_EXPORT;
char const *GetFile(char const *localRepo, char const *fileId) CALCULATOR_C_INTERFACE_LIB_EXPORT; char const *GetFileInternal(char const *localRepo, char const *fileId) CALCULATOR_C_INTERFACE_LIB_EXPORT;
bool SetFile(char const *localRepo, char const *fileId, char const *json) CALCULATOR_C_INTERFACE_LIB_EXPORT; bool SetFileInternal(char const *localRepo, char const *fileId, char const *json, int size) CALCULATOR_C_INTERFACE_LIB_EXPORT;
TariffCalculatorHandle NewTariffCalculator(void) CALCULATOR_C_INTERFACE_LIB_EXPORT; TariffCalculatorHandle NewTariffCalculator(void) CALCULATOR_C_INTERFACE_LIB_EXPORT;
void DeleteTariffCalculator(TariffCalculatorHandle handle) CALCULATOR_C_INTERFACE_LIB_EXPORT; void DeleteTariffCalculator(TariffCalculatorHandle handle) CALCULATOR_C_INTERFACE_LIB_EXPORT;
// libgit2 // libgit2
int InitGitLibrary(void) CALCULATOR_C_INTERFACE_LIB_EXPORT; int InitGitLibraryInternal(void) CALCULATOR_C_INTERFACE_LIB_EXPORT;
int ShutdownGitLibrary(void) CALCULATOR_C_INTERFACE_LIB_EXPORT; int ShutdownGitLibraryInternal(void) CALCULATOR_C_INTERFACE_LIB_EXPORT;
int CloneRepository(char const *url, char const *local_path) CALCULATOR_C_INTERFACE_LIB_EXPORT; int CloneRepositoryInternal(char const *url, char const *local_path) CALCULATOR_C_INTERFACE_LIB_EXPORT;
int CheckoutLocalBranch(char const *local_path, char const *branch) CALCULATOR_C_INTERFACE_LIB_EXPORT; int CheckoutRepositoryInternal(char const *url, char const *localRepoName, char const *branchName) CALCULATOR_C_INTERFACE_LIB_EXPORT;
int CommitFile(char const *local_path, char const *branch_name, char const *file_name, char const *commit_message) CALCULATOR_C_INTERFACE_LIB_EXPORT; int CommitFileInternal(char const *local_path, char const *branch_name, char const *file_name, char const *commit_message) CALCULATOR_C_INTERFACE_LIB_EXPORT;
int PushLocalRepository(char const *local_path, char const *branch_name, char const *user, char const *password) CALCULATOR_C_INTERFACE_LIB_EXPORT; int PushRepositoryInternal(char const *local_path, char const *branch_name, char const *user, char const *password) CALCULATOR_C_INTERFACE_LIB_EXPORT;
int PullRepositoryInternal(char const *localRepoName, char const *remoteRepoName) CALCULATOR_C_INTERFACE_LIB_EXPORT;
#ifdef __cplusplus #ifdef __cplusplus
} }

File diff suppressed because it is too large Load Diff

View File

@@ -0,0 +1,47 @@
#ifndef GIT_LIBRARY_H_INCLUDED
#define GIT_LIBRARY_H_INCLUDED
#include <QByteArray>
#include <QString>
#include <QJsonDocument>
#include <QJsonArray>
#include <QJsonObject>
#include <QDir>
#include <git2.h>
class CWD {
QDir m_prev;
QDir m_localRepoDir;
QDir m_localRepoGitDir;
bool m_valid;
public:
CWD(QString const &localRepoName);
~CWD();
QDir const &localRepoDir() const { return m_localRepoDir; }
QDir &localRepoDir() { return m_localRepoDir; }
QDir const &localRepoGitDir() const { return m_localRepoGitDir; }
QDir &localRepoGitDir() { return m_localRepoGitDir; }
};
class GitLibrary {
static QString m_userName;
static QString m_userPassword;
public:
static QString &userName() { return m_userName; }
static QString &userPassword() { return m_userPassword; }
static int Init();
static int Shutdown();
static int CloneRepository(char const *url, char const *localRepoName);
static int CheckoutRepository(char const *url, char const *localRepoName, char const *branchName);
static int CommitRepository(char const *localRepoName, char const *branchName, char const *commitMessage);
static int CommitFile(char const *localRepoName, char const *branchName, char const *fName, char const *commitMessage);
static int PushRepository(char const *localRepoName, char const *branchName, char const *userName, char const *userPassword);
static int PullRepository(char const *localRepoName, char const *remoteRepoName);
// explicit GitLibrary();
// ~GitLibrary();
};
#endif // #define GIT_LIBRARY_H_INCLUDED

View File

@@ -0,0 +1,7 @@
#ifndef GLOBAL_DEFINES_H_INCLUDED
#define GLOBAL_DEFINES_H_INCLUDED
#define HEADER __func__ << "(" << __LINE__ << ")"
#endif // GLOBAL_DEFINES_H_INCLUDED

View File

@@ -1,5 +1,7 @@
#include "local_git_repository.h" #include "local_git_repository.h"
#include "git_library.h"
#include <QDebug>
#include <QDir> #include <QDir>
#include <QFile> #include <QFile>
#include <QTextStream> #include <QTextStream>
@@ -9,22 +11,118 @@
#include <QRegularExpressionMatch> #include <QRegularExpressionMatch>
#include <QFile> #include <QFile>
QString LocalGitRepository::repoRootDirectory = "";
QMap<QString, LocalGitRepository *> LocalGitRepository::localGitRepos;
QMap<QString, LocalGitRepository *> &LocalGitRepository::GetLocalGitRepos() {
return localGitRepos;
}
void LocalGitRepository::SetReposRootDirectory(QString s) {
if (repoRootDirectory.isEmpty()) {
repoRootDirectory = s;
return;
}
qCritical() << __func__ << ":" << __LINE__
<< "ERROR git-repository-root-directory already set"
<< repoRootDirectory;
}
QString LocalGitRepository::GetReposRootDirectory() {
return repoRootDirectory;
}
LocalGitRepository::LocalGitRepository(QString const &localRepository) LocalGitRepository::LocalGitRepository(QString const &localRepository)
: m_localRepository(localRepository) : m_localRepository(localRepository)
, m_fileMenu("{}") , m_fileMenu("{}")
, m_fileMenuSize(-1) { , m_fileMenuSize(-1)
, m_git_repository(nullptr) {
} }
int32_t LocalGitRepository::GetFileMenuSize() const { LocalGitRepository::~LocalGitRepository() {
if (m_fileMenuSize == -1) {
GetFileMenu();
} }
void LocalGitRepository::SetGitRepository(git_repository *git_repo) {
m_git_repository = git_repo;
}
git_repository const *LocalGitRepository::GetGitRepository() const {
return m_git_repository;
}
git_repository *LocalGitRepository::GetGitRepository() {
return m_git_repository;
}
QString LocalGitRepository::localRepositoryName() const { // e.g. customer_999
return m_localRepository;
}
QString LocalGitRepository::localRepositoryPath() const {
if (!repoRootDirectory.isEmpty()) {
return QDir::cleanPath(repoRootDirectory + QDir::separator() + m_localRepository);
}
qCritical() << __func__ << ":" << __LINE__
<< "ERROR git-repository-root-directory not set";
return "";
}
QString LocalGitRepository::localRepositoryPath(QString const &localRepository) {
if (!repoRootDirectory.isEmpty()) {
return QDir::cleanPath(repoRootDirectory + QDir::separator() + localRepository);
}
qCritical() << __func__ << ":" << __LINE__
<< "ERROR git-repository-root-directory not set";
return "";
}
LocalGitRepository *LocalGitRepository::GetInstance(QString const& localRepository) {
LocalGitRepository *repo = nullptr;
if (GetLocalGitRepos().count(localRepository) > 0) {
repo = GetLocalGitRepos()[localRepository];
} else {
repo = new LocalGitRepository(localRepository);
qCritical() << "created local git-repository" << localRepository;
GetLocalGitRepos().insert(localRepository, repo);
}
if (repo == nullptr) {
qCritical() << __func__ << ":" << __LINE__
<< "ERROR: could not find local git-repository" << localRepository;
}
return repo;
}
bool LocalGitRepository::DestroyInstance(QString const &localRepository) {
if (GetLocalGitRepos().count(localRepository) > 0) {
LocalGitRepository *repo = GetLocalGitRepos().take(localRepository);
delete repo;
qCritical() << "deleted local git-repository" << localRepository;
return true;
}
qCritical() << __func__ << ":" << __LINE__
<< "ERROR: could not find local git-repository" << localRepository;
return false;
}
void LocalGitRepository::DestroyAllRepositories() {
for (auto it = GetLocalGitRepos().keyValueBegin(); it != GetLocalGitRepos().keyValueEnd(); ++it) {
QString const &key = it->first;
LocalGitRepository *repo = GetLocalGitRepos()[key];
delete repo;
qCritical() << "deleted local git-repository" << key;
}
GetLocalGitRepos().clear();
}
int32_t LocalGitRepository::GetFileMenuSizeInternal() const {
return m_fileMenuSize; return m_fileMenuSize;
} }
QByteArray const &LocalGitRepository::GetFileMenu() const { QByteArray LocalGitRepository::GetFileMenuInternal() {
if (m_fileMenu.toStdString() == "{}") { if (m_fileMenuSize == -1) {
QFile f(QDir::cleanPath(QString(baseDir) + m_localRepository + QDir::separator() QFile f(QDir::cleanPath(repoRootDirectory + QDir::separator()
+ m_localRepository + QDir::separator()
+ "etc/psa_webinterface/menu_config.json")); + "etc/psa_webinterface/menu_config.json"));
if (f.exists()) { if (f.exists()) {
if (f.open(QIODevice::ReadOnly | QIODevice::Text)) { if (f.open(QIODevice::ReadOnly | QIODevice::Text)) {
@@ -40,7 +138,7 @@ QByteArray const &LocalGitRepository::GetFileMenu() const {
return m_fileMenu; return m_fileMenu;
} }
QByteArray LocalGitRepository::GetFileName(QString const &fId) { QByteArray LocalGitRepository::GetFileNameInternal(QString const &fId) {
QRegularExpressionMatch match; QRegularExpressionMatch match;
static const QRegularExpression re("(master|[0-9]+)"); static const QRegularExpression re("(master|[0-9]+)");
if (fId.lastIndexOf(re, -1, &match) != -1) { if (fId.lastIndexOf(re, -1, &match) != -1) {
@@ -54,7 +152,7 @@ QByteArray LocalGitRepository::GetFileName(QString const &fId) {
if (s != "master") { if (s != "master") {
if (fId.contains("psa_tariff")) { if (fId.contains("psa_tariff")) {
QString fn(QDir::cleanPath( QString fn(QDir::cleanPath(
QString(baseDir) + QDir::separator() + repoRootDirectory + QDir::separator() +
QString(m_localRepository) + QDir::separator() QString(m_localRepository) + QDir::separator()
+ path + QDir::separator() + path + QDir::separator()
+ QString("tariff%1.json").arg(s.toUInt(), 2, 10, QChar('0')))); + QString("tariff%1.json").arg(s.toUInt(), 2, 10, QChar('0'))));
@@ -67,8 +165,8 @@ QByteArray LocalGitRepository::GetFileName(QString const &fId) {
return QByteArray(); return QByteArray();
} }
QByteArray LocalGitRepository::GetFile(QString const &fId) { QByteArray LocalGitRepository::GetFileInternal(QString const &fId) {
QByteArray a = GetFileName(fId); QByteArray a = GetFileNameInternal(fId);
if (a.isValidUtf8()) { if (a.isValidUtf8()) {
QFile fn(a); QFile fn(a);
if (fn.exists()) { if (fn.exists()) {
@@ -82,7 +180,7 @@ QByteArray LocalGitRepository::GetFile(QString const &fId) {
} }
int32_t LocalGitRepository::GetFileSize(QString const &fId) { int32_t LocalGitRepository::GetFileSize(QString const &fId) {
QByteArray a = GetFileName(fId); QByteArray a = GetFileNameInternal(fId);
if (a.isValidUtf8()) { if (a.isValidUtf8()) {
QFile fn(a); QFile fn(a);
if (fn.exists()) { if (fn.exists()) {
@@ -92,18 +190,19 @@ int32_t LocalGitRepository::GetFileSize(QString const &fId) {
return -1; return -1;
} }
bool LocalGitRepository::SetFile(QString const &fId, QByteArray const &json) { bool LocalGitRepository::SetFileInternal(QString const &fId, QByteArray const &json) {
QByteArray a = GetFileName(fId); QByteArray a = GetFileNameInternal(fId);
if (a.isValidUtf8()) { if (a.isValidUtf8()) {
QFile fn(a); QFile fn(a);
if (fn.exists()) { if (fn.exists()) {
if (fn.open(QIODevice::WriteOnly)) { if (fn.open(QIODevice::WriteOnly)) {
quint64 bytesWritten = 0; qint64 bytesWritten = 0;
qint64 bytesToWrite = a.size(); qint64 bytesToWrite = json.size();
while (bytesToWrite > 0 && while (bytesToWrite > 0 &&
(bytesWritten = fn.write(json.constData(), bytesToWrite)) != -1) { (bytesWritten = fn.write(json.constData(), bytesToWrite)) != -1) {
bytesToWrite -= bytesWritten; bytesToWrite -= bytesWritten;
} }
fn.flush();
return (bytesToWrite == 0); return (bytesToWrite == 0);
} }
} }

View File

@@ -3,28 +3,56 @@
#include <QByteArray> #include <QByteArray>
#include <QString> #include <QString>
#include <QJsonDocument> #include <QJsonDocument>
#include <QJsonArray> #include <QJsonArray>
#include <QJsonObject> #include <QJsonObject>
#include <QDir>
#include <QMap>
#include <git2.h>
class GitLibrary;
class LocalGitRepository { class LocalGitRepository {
friend class GitLibrary;
QString m_localRepository; QString m_localRepository;
mutable QByteArray m_fileMenu; mutable QByteArray m_fileMenu;
mutable int32_t m_fileMenuSize; mutable int32_t m_fileMenuSize;
public: git_repository *m_git_repository;
static QString repoRootDirectory;
static QMap<QString, LocalGitRepository *> localGitRepos;
protected: // force heap-based objects
LocalGitRepository(QString const &localRepository); LocalGitRepository(QString const &localRepository);
~LocalGitRepository();
static char const constexpr *baseDir = "H:\\"; public:
QString gitRepository() const { return m_localRepository; } static void SetReposRootDirectory(QString s);
static QString GetReposRootDirectory();
QByteArray const &GetFileMenu() const; static LocalGitRepository *GetInstance(QString const &localRepository);
int32_t GetFileMenuSize() const; static bool DestroyInstance(QString const &localRepository);
QByteArray GetFileName(QString const &fileId); static void DestroyAllRepositories();
static QMap<QString, LocalGitRepository *> &GetLocalGitRepos();
QString localRepositoryName() const;
QString localRepositoryPath() const;
void SetGitRepository(git_repository *git_repo);
git_repository const *GetGitRepository() const;
git_repository *GetGitRepository();
static QString localRepositoryPath(QString const &localRepository);
QByteArray GetFileMenuInternal();
int32_t GetFileMenuSizeInternal() const;
QByteArray GetFileNameInternal(QString const &fileId);
int32_t GetFileSize(QString const &fileId); int32_t GetFileSize(QString const &fileId);
QByteArray GetFile(QString const &fileId); QByteArray GetFileInternal(QString const &fileId);
bool SetFile(QString const &fileId, QByteArray const &json); bool SetFileInternal(QString const &fileId, QByteArray const &json);
}; };
#endif // LOCAL_GIT_REPOSITORY_H_INCLUDED #endif // LOCAL_GIT_REPOSITORY_H_INCLUDED