return false;
}
-static int copyNCreateTacSymlink(std::string binPath, std::string tacVersionDir, std::string nugetPackage, bool isCreateTacDir)
+static int copyAssemblyCreateSymlink(std::string binPath, std::string tacVersionDir, std::string nugetPackage, bool isCreateTacDir)
{
std::string tac_dir = concatPath(binPath, TAC_SYMLINK_SUB_DIR);
if (!createDir(tac_dir)) {
return 0;
}
-static void copyNCreateTlcSymlink(const char* pkgId, std::vector<std::string> LibrariesInfo, std::string tlcDir)
+static void copyLibraryCreateSymlink(const char* pkgId, std::vector<std::string> LibrariesInfo, std::string tlcDir)
{
if (LibrariesInfo.empty()) {
_INFO("Not exist data for TLC in %s", pkgId);
bf::create_symlink(concatPath(tlcDir, fileSha), library);
char *sql = sqlite3_mprintf("INSERT INTO TLC (PKGID, LIBRARY) VALUES (%Q, %Q);", pkgId, fileSha.c_str());
- if (!dbInsert(tlc_db, sql)) {
+ if (!insertDB(tlc_db, sql)) {
_ERR("Sqlite insert error");
sqlite3_free(sql);
copyFile(concatPath(tlcDir, fileSha), library);
}
}
-static void depsJsonCheck(std::string rootPath, std::string binPath, std::string execName)
+static void checkDepsJson(std::string rootPath, std::string binPath, std::string execName)
{
for (auto& npAssembly : depsJsonParser(rootPath, execName)) {
std::string nuget_package = npAssembly.substr(0, npAssembly.rfind(':'));
return 0;
}
if (metaValue == METADATA_VALUE) {
- depsJsonCheck(rootPath, binPath, execName);
+ checkDepsJson(rootPath, binPath, execName);
}
status = "install";
- tac_db = dbCreate(TAC_APP_LIST_DB, CREATE_TAC_DB_TABLE);
+ tac_db = createDB(TAC_APP_LIST_DB, CREATE_TAC_DB_TABLE);
if (!tac_db) {
_ERR("Sqlite create error. So restore the database.");
- if (restoreTACDB() != TAC_ERROR_NONE) {
+ if (tac_restoreDB() != TAC_ERROR_NONE) {
_ERR("Sqlite create error");
return 0;
}
- tac_db = dbCreate(TAC_APP_LIST_DB, CREATE_TAC_DB_TABLE);
+ tac_db = createDB(TAC_APP_LIST_DB, CREATE_TAC_DB_TABLE);
if (!tac_db) {
_ERR("Sqlite create error");
return 0;
return -1;
}
- if (copyNCreateTacSymlink(binPath, tac_version_dir, np, true) < 0) {
+ if (copyAssemblyCreateSymlink(binPath, tac_version_dir, np, true) < 0) {
_ERR("Failed to create symlink");
return -1;
}
char *sql = sqlite3_mprintf(
"INSERT INTO TAC (PKGID, NUGET, NAME, VERSION) " \
"VALUES (%Q, %Q, %Q, %Q);", pkgId, np.c_str(), tac_name.c_str(), tac_version.c_str());
- dbInsert(tac_db, sql);
+ insertDB(tac_db, sql);
sqlite3_free(sql);
} else {
_INFO("Exists tac_version_dir [%s]", tac_version_dir.c_str());
if (!bf::is_symlink(sha256_info)) {
if (compareSHA256Info(sha256_info, np)) {
- if (copyNCreateTacSymlink(binPath, tac_version_dir, np, false) < 0) {
+ if (copyAssemblyCreateSymlink(binPath, tac_version_dir, np, false) < 0) {
_ERR("Failed to create symlink");
return -1;
}
char *sql = sqlite3_mprintf(
"INSERT INTO TAC (PKGID, NUGET, NAME, VERSION) " \
"VALUES (%Q, %Q, %Q, %Q);", pkgId, np.c_str(), tac_name.c_str(), tac_version.c_str());
- dbInsert(tac_db, sql);
+ insertDB(tac_db, sql);
sqlite3_free(sql);
} else {
_INFO("Different nuget : %s", np.c_str());
return 0;
}
- tlc_db = dbCreate(TLC_APP_LIST_DB, CREATE_TLC_DB_TABLE);
+ tlc_db = createDB(TLC_APP_LIST_DB, CREATE_TLC_DB_TABLE);
if (!tlc_db) {
_ERR("Sqlite create error. So restore the database.");
- if (restoreTLCDB() != TAC_ERROR_NONE) {
+ if (tlc_restoreDB() != TAC_ERROR_NONE) {
_ERR("Sqlite create error");
return 0;
}
- tlc_db = dbCreate(TLC_APP_LIST_DB, CREATE_TLC_DB_TABLE);
+ tlc_db = createDB(TLC_APP_LIST_DB, CREATE_TLC_DB_TABLE);
if (!tlc_db) {
_ERR("Sqlite create error");
return 0;
}
sqlite3_exec(tlc_db, "BEGIN;", NULL, NULL, NULL);
- copyNCreateTlcSymlink(pkgId, getLibrariesInfo(rootPath), tlcDir);
+ copyLibraryCreateSymlink(pkgId, getLibrariesInfo(rootPath), tlcDir);
return 0;
}
return 0;
}
-static int updateTacDB(sqlite3 *sqlite)
+static int tac_updateDB(sqlite3 *sqlite)
{
for (auto& unp : updateTac) {
int count = -1;
return 0;
}
-static void updateTlcDB(sqlite3 *sqlite, std::vector<std::string> updateTlc, std::string tlcDir)
+static void tlc_updateDB(sqlite3 *sqlite, std::vector<std::string> updateTlc, std::string tlcDir)
{
for (auto& ulp : updateTlc) {
int count = -1;
return 0;
}
if (metaValue == METADATA_VALUE) {
- depsJsonCheck(rootPath, binPath, execName);
+ checkDepsJson(rootPath, binPath, execName);
}
}
status = "update";
- tac_db = dbCreate(TAC_APP_LIST_DB, CREATE_TAC_DB_TABLE);
+ tac_db = createDB(TAC_APP_LIST_DB, CREATE_TAC_DB_TABLE);
if (!tac_db) {
_ERR("Sqlite create error. So restore the database.");
- if (restoreTACDB() != TAC_ERROR_NONE) {
+ if (tac_restoreDB() != TAC_ERROR_NONE) {
_ERR("Sqlite create error");
return 0;
}
- tac_db = dbCreate(TAC_APP_LIST_DB, CREATE_TAC_DB_TABLE);
+ tac_db = createDB(TAC_APP_LIST_DB, CREATE_TAC_DB_TABLE);
if (!tac_db) {
_ERR("Sqlite create error");
return 0;
sqlite3_exec(tac_db, "BEGIN;", NULL, NULL, NULL);
char *sql = sqlite3_mprintf("SELECT * FROM TAC WHERE PKGID = %Q;", pkgId);
- updateTac = dbSelect(tac_db, sql);
+ updateTac = selectDB(tac_db, sql);
sqlite3_free(sql);
bool skipTLC = false;
if (tacDB.empty()) {
sql = sqlite3_mprintf("DELETE FROM TAC WHERE PKGID = %Q;", pkgId);
- dbDelete(tac_db, sql);
+ deleteDB(tac_db, sql);
sqlite3_free(sql);
- if (updateTacDB(tac_db) < 0) {
+ if (tac_updateDB(tac_db) < 0) {
return -1;
}
skipTLC = true;
return -1;
}
- if (copyNCreateTacSymlink(binPath, tac_version_dir, np, true) < 0) {
+ if (copyAssemblyCreateSymlink(binPath, tac_version_dir, np, true) < 0) {
_ERR("Failed to create symlink");
return -1;
}
sql = sqlite3_mprintf(
"UPDATE TAC SET NAME = %Q, VERSION = %Q, NUGET = %Q WHERE PKGID = %Q AND NAME = %Q;",
tac_name.c_str(), tac_version.c_str(), np.c_str(), pkgId, tac_name.c_str());
- dbUpdate(tac_db, sql);
+ updateDB(tac_db, sql);
sqlite3_free(sql);
} else if (count == 0) {
sql = sqlite3_mprintf(
"INSERT INTO TAC (PKGID, NUGET, NAME, VERSION) " \
"VALUES (%Q, %Q, %Q, %Q);", pkgId, np.c_str(), tac_name.c_str(), tac_version.c_str());
- dbInsert(tac_db, sql);
+ insertDB(tac_db, sql);
sqlite3_free(sql);
}
} else {
_INFO("Exists tac_version_dir [%s]", tac_version_dir.c_str());
if (!bf::is_symlink(sha256_info)) {
if (compareSHA256Info(sha256_info, np)) {
- if (copyNCreateTacSymlink(binPath, tac_version_dir, np, false) < 0) {
+ if (copyAssemblyCreateSymlink(binPath, tac_version_dir, np, false) < 0) {
_ERR("Failed to create symlink");
return -1;
}
sql = sqlite3_mprintf(
"UPDATE TAC SET NAME = %Q, VERSION = %Q, NUGET = %Q WHERE PKGID = %Q AND NAME = %Q;",
tac_name.c_str(), tac_version.c_str(), np.c_str(), pkgId, tac_name.c_str());
- dbUpdate(tac_db, sql);
+ updateDB(tac_db, sql);
sqlite3_free(sql);
} else if (count == 0) {
sql = sqlite3_mprintf(
"INSERT INTO TAC (PKGID, NUGET, NAME, VERSION) " \
"VALUES (%Q, %Q, %Q, %Q);", pkgId, np.c_str(), tac_name.c_str(), tac_version.c_str());
- dbInsert(tac_db, sql);
+ insertDB(tac_db, sql);
sqlite3_free(sql);
}
} else {
}
if (!isExits) {
char *sql = sqlite3_mprintf("DELETE FROM TAC WHERE PKGID = %Q AND NUGET = %Q;", pkgId, unp.c_str());
- dbDelete(tac_db, sql);
+ deleteDB(tac_db, sql);
sqlite3_free(sql);
}
}
- if (updateTacDB(tac_db) < 0) {
+ if (tac_updateDB(tac_db) < 0) {
return -1;
}
}
return 0;
}
- tlc_db = dbCreate(TLC_APP_LIST_DB, CREATE_TLC_DB_TABLE);
+ tlc_db = createDB(TLC_APP_LIST_DB, CREATE_TLC_DB_TABLE);
if (!tlc_db) {
_ERR("Sqlite create error. So restore the database.");
- if (restoreTLCDB() != TAC_ERROR_NONE) {
+ if (tlc_restoreDB() != TAC_ERROR_NONE) {
_ERR("Sqlite create error");
return 0;
}
- tlc_db = dbCreate(TLC_APP_LIST_DB, CREATE_TLC_DB_TABLE);
+ tlc_db = createDB(TLC_APP_LIST_DB, CREATE_TLC_DB_TABLE);
if (!tlc_db) {
_ERR("Sqlite create error");
return 0;
sqlite3_exec(tlc_db, "BEGIN;", NULL, NULL, NULL);
sql = sqlite3_mprintf("SELECT * FROM TLC WHERE PKGID = %Q;", pkgId);
- std::vector<std::string> updateTlc = dbSelect(tlc_db, sql);
+ std::vector<std::string> updateTlc = selectDB(tlc_db, sql);
sqlite3_free(sql);
sql = sqlite3_mprintf("DELETE FROM TLC WHERE PKGID = %Q;", pkgId);
- dbDelete(tlc_db, sql);
+ deleteDB(tlc_db, sql);
sqlite3_free(sql);
std::vector<std::string> librariesInfo = getLibrariesInfo(rootPath);
librariesInfo.clear();
}
- copyNCreateTlcSymlink(pkgId, librariesInfo, tlcDir);
+ copyLibraryCreateSymlink(pkgId, librariesInfo, tlcDir);
- updateTlcDB(tlc_db, updateTlc, tlcDir);
+ tlc_updateDB(tlc_db, updateTlc, tlcDir);
return 0;
}
tacPluginInstalled = true;
status = "uninstall";
- tac_db = dbOpen(TAC_APP_LIST_DB);
+ tac_db = openDB(TAC_APP_LIST_DB);
if (!tac_db) {
_ERR("Sqlite open error. So restore the database.");
- if (restoreTACDB() != TAC_ERROR_NONE) {
+ if (tac_restoreDB() != TAC_ERROR_NONE) {
_ERR("Sqlite open error");
return 0;
}
- tac_db = dbOpen(TAC_APP_LIST_DB);
+ tac_db = openDB(TAC_APP_LIST_DB);
if (!tac_db) {
_ERR("Sqlite open error");
return 0;
sqlite3_exec(tac_db, "BEGIN;", NULL, NULL, NULL);
char *sql = sqlite3_mprintf("SELECT * FROM TAC WHERE PKGID = %Q;", pkgId);
- updateTac = dbSelect(tac_db, sql);
+ updateTac = selectDB(tac_db, sql);
sqlite3_free(sql);
sql = sqlite3_mprintf("DELETE FROM TAC WHERE PKGID = %Q;", pkgId);
- dbDelete(tac_db, sql);
+ deleteDB(tac_db, sql);
sqlite3_free(sql);
- if (updateTacDB(tac_db) < 0) {
+ if (tac_updateDB(tac_db) < 0) {
return -1;
}
///// TLC /////
- tlc_db = dbOpen(TLC_APP_LIST_DB);
+ tlc_db = openDB(TLC_APP_LIST_DB);
if (!tlc_db) {
_ERR("Sqlite open error. So restore the database.");
- if (restoreTLCDB() != TAC_ERROR_NONE) {
+ if (tlc_restoreDB() != TAC_ERROR_NONE) {
_ERR("Sqlite open error");
return 0;
}
- tlc_db = dbOpen(TLC_APP_LIST_DB);
+ tlc_db = openDB(TLC_APP_LIST_DB);
if (!tlc_db) {
_ERR("Sqlite open error");
return 0;
sqlite3_exec(tlc_db, "BEGIN;", NULL, NULL, NULL);
sql = sqlite3_mprintf("SELECT * FROM TLC WHERE PKGID = %Q;", pkgId);
- std::vector<std::string> updateTlc = dbSelect(tlc_db, sql);
+ std::vector<std::string> updateTlc = selectDB(tlc_db, sql);
sqlite3_free(sql);
sql = sqlite3_mprintf("DELETE FROM TLC WHERE PKGID = %Q;", pkgId);
- dbDelete(tlc_db, sql);
+ deleteDB(tlc_db, sql);
sqlite3_free(sql);
- updateTlcDB(tlc_db, updateTlc, concatPath(__DOTNET_DIR, TLC_LIBRARIES_DIR));
+ tlc_updateDB(tlc_db, updateTlc, concatPath(__DOTNET_DIR, TLC_LIBRARIES_DIR));
return 0;
}
}
if (tac_db) {
- dbClose(tac_db);
+ closeDB(tac_db);
tac_db = NULL;
}
if (tlc_db) {
- dbClose(tlc_db);
+ closeDB(tlc_db);
tlc_db = NULL;
}
}
if (tac_db) {
- dbRollback(tac_db);
+ rollbackDB(tac_db);
tac_db = NULL;
}
if (tlc_db) {
- dbRollback(tlc_db);
+ rollbackDB(tlc_db);
tlc_db = NULL;
}
return 0;
-}
\ No newline at end of file
+}
}
// callback function of "pkgmgrinfo_appinfo_metadata_filter_foreach"
-static int restoreTACDBCb(pkgmgrinfo_appinfo_h handle, void *userData)
+static int tac_restoreDBCb(pkgmgrinfo_appinfo_h handle, void *userData)
{
char *pkgId = NULL;
char *root = NULL;
char *sql = sqlite3_mprintf(
"INSERT INTO TAC (PKGID, NUGET, NAME, VERSION) " \
"VALUES (%Q, %Q, %Q, %Q);", pkgId, nuget.c_str(), name.c_str(), version.c_str());
- dbInsert(tac_db, sql);
+ insertDB(tac_db, sql);
restore_nuget.push_back(concatPath(__DOTNET_DIR, nuget));
sqlite3_free(sql);
}
return 0;
}
-tac_error_e restoreTACDB()
+tac_error_e tac_restoreDB()
{
if (!removeFile(TAC_APP_LIST_RESTORE_DB)) {
fprintf(stderr, "Failed to remove of %s\n", TAC_APP_LIST_RESTORE_DB);
return TAC_ERROR_UNKNOWN;
}
- tac_db = dbCreate(TAC_APP_LIST_RESTORE_DB, CREATE_TAC_DB_TABLE);
+ tac_db = createDB(TAC_APP_LIST_RESTORE_DB, CREATE_TAC_DB_TABLE);
if (!tac_db) {
fprintf(stderr, "Sqlite create error\n");
return TAC_ERROR_UNKNOWN;
return TAC_ERROR_UNKNOWN;
}
- ret = pkgmgrinfo_appinfo_metadata_filter_foreach(handle, restoreTACDBCb, NULL);
+ ret = pkgmgrinfo_appinfo_metadata_filter_foreach(handle, tac_restoreDBCb, NULL);
if (ret != PMINFO_R_OK) {
fprintf(stderr, "Failed pkgmgrinfo_appinfo_metadata_filter_foreach\n");
pkgmgrinfo_appinfo_metadata_filter_destroy(handle);
pkgmgrinfo_appinfo_metadata_filter_destroy(handle);
if (tac_db) {
- dbClose(tac_db);
+ closeDB(tac_db);
tac_db = NULL;
}
}
// callback function of "pkgmgrinfo_appinfo_metadata_filter_foreach"
-static int restoreTLCDBCb(pkgmgrinfo_appinfo_h handle, void *userData)
+static int tlc_restoreDBCb(pkgmgrinfo_appinfo_h handle, void *userData)
{
char *pkgId = NULL;
char *root = NULL;
if (bf::exists(library)) {
std::string fileSha = library.substr(library.rfind('/') + 1) + ".." + librarySha.substr(librarySha.find(':') + 1);
char *sql = sqlite3_mprintf("INSERT INTO TLC (PKGID, LIBRARY) VALUES (%Q, %Q);", pkgId, fileSha.c_str());
- dbInsert(tlc_db, sql);
+ insertDB(tlc_db, sql);
restore_library.push_back(fileSha);
sqlite3_free(sql);
}
return 0;
}
-tac_error_e restoreTLCDB()
+tac_error_e tlc_restoreDB()
{
if (!removeFile(TLC_APP_LIST_RESTORE_DB)) {
fprintf(stderr, "Failed to remove of %s\n", TLC_APP_LIST_RESTORE_DB);
return TAC_ERROR_UNKNOWN;
}
- tlc_db = dbCreate(TLC_APP_LIST_RESTORE_DB, CREATE_TLC_DB_TABLE);
+ tlc_db = createDB(TLC_APP_LIST_RESTORE_DB, CREATE_TLC_DB_TABLE);
if (!tlc_db) {
fprintf(stderr, "Sqlite create error\n");
return TAC_ERROR_UNKNOWN;
return TAC_ERROR_UNKNOWN;
}
- ret = pkgmgrinfo_appinfo_metadata_filter_foreach(handle, restoreTLCDBCb, NULL);
+ ret = pkgmgrinfo_appinfo_metadata_filter_foreach(handle, tlc_restoreDBCb, NULL);
if (ret != PMINFO_R_OK) {
fprintf(stderr, "Failed pkgmgrinfo_appinfo_metadata_filter_foreach\n");
pkgmgrinfo_appinfo_metadata_filter_destroy(handle);
pkgmgrinfo_appinfo_metadata_filter_destroy(handle);
if (tlc_db) {
- dbClose(tlc_db);
+ closeDB(tlc_db);
tlc_db = NULL;
}
#endif
#define LOG_TAG "DOTNET_INSTALLER_PLUGIN"
-static int dbIntegrityCheckCb(void *user_data, int argc, char **argv, char **not_used)
+static int checkIntegrityDBCb(void *user_data, int argc, char **argv, char **not_used)
{
bool* is_db_corrupted = static_cast<bool*>(user_data);
std::string result_DB_check = argv[0];
return 0;
}
-sqlite3* dbCreate(std::string path, std::string query)
+sqlite3* createDB(std::string path, std::string query)
{
sqlite3 *sqlite = NULL;
bool is_db_corrupted = false;
sqlite = NULL;
return sqlite;
}
- ret = sqlite3_exec(sqlite, "PRAGMA integrity_check", dbIntegrityCheckCb, &is_db_corrupted, NULL);
+ ret = sqlite3_exec(sqlite, "PRAGMA integrity_check", checkIntegrityDBCb, &is_db_corrupted, NULL);
if (ret == SQLITE_CORRUPT || is_db_corrupted) {
_INFO("DB file is corrupted, start to recover corrupted db");
sqlite3_close(sqlite);
return sqlite;
}
-sqlite3* dbOpen(std::string path)
+sqlite3* openDB(std::string path)
{
sqlite3 *sqlite = NULL;
bool is_db_corrupted = false;
_INFO("DB file is corrupted, start to recover corrupted db");
return sqlite;
}
- ret = sqlite3_exec(sqlite, "PRAGMA integrity_check", dbIntegrityCheckCb, &is_db_corrupted, NULL);
+ ret = sqlite3_exec(sqlite, "PRAGMA integrity_check", checkIntegrityDBCb, &is_db_corrupted, NULL);
if (ret == SQLITE_CORRUPT || is_db_corrupted) {
_INFO("DB file is corrupted, start to recover corrupted db");
sqlite3_close(sqlite);
return sqlite;
}
-void dbFinalize(sqlite3_stmt *stmt)
+void finalizeDB(sqlite3_stmt *stmt)
{
if (stmt) {
sqlite3_finalize(stmt);
}
}
-void dbClose(sqlite3 *sqlite)
+void closeDB(sqlite3 *sqlite)
{
if (sqlite) {
sqlite3_exec(sqlite, "COMMIT;", NULL, NULL, NULL);
}
}
-void dbRollback(sqlite3 *sqlite)
+void rollbackDB(sqlite3 *sqlite)
{
if (sqlite) {
sqlite3_exec(sqlite, "ROLLBACK;", NULL, NULL, NULL);
}
}
-static bool dbExec(sqlite3 *sqlite, std::string query)
+static bool execDB(sqlite3 *sqlite, std::string query)
{
int ret = sqlite3_exec(sqlite, query.c_str(), NULL, NULL, NULL);
if (ret != SQLITE_OK) {
return true;
}
-bool dbUpdate(sqlite3 *sqlite, std::string query)
+bool updateDB(sqlite3 *sqlite, std::string query)
{
- return dbExec(sqlite, query);
+ return execDB(sqlite, query);
}
-bool dbInsert(sqlite3 *sqlite, std::string query)
+bool insertDB(sqlite3 *sqlite, std::string query)
{
- return dbExec(sqlite, query);
+ return execDB(sqlite, query);
}
-bool dbDelete(sqlite3 *sqlite, std::string query)
+bool deleteDB(sqlite3 *sqlite, std::string query)
{
- return dbExec(sqlite, query);
+ return execDB(sqlite, query);
}
-std::vector<std::string> dbSelect(sqlite3 *sqlite, std::string query)
+std::vector<std::string> selectDB(sqlite3 *sqlite, std::string query)
{
std::vector<std::string> selectData;
sqlite3_stmt* stmt = NULL;
str = (const char *) sqlite3_column_text(stmt, 2);
selectData.push_back((!str || !strlen(str)) ? NULL : strdup(str));
}
- dbFinalize(stmt);
+ finalizeDB(stmt);
return selectData;
}