Skip to content
Snippets Groups Projects

Compare revisions

Changes are shown as if the source revision was being merged into the target revision. Learn more about comparing revisions.

Source

Select target project
No results found

Target

Select target project
  • cellframe/python-cellframe
1 result
Show changes
Commits on Source (775)
675 additional commits have been omitted to prevent performance issues.
Expand all Hide whitespace changes
Inline Side-by-side
Showing
with 814 additions and 607 deletions
.gitmodules
View file @ b6468582
[submodule "cellframe-sdk"]
path = cellframe-sdk
url = https://gitlab.demlabs.net/cellframe/cellframe-sdk
url = ../cellframe-sdk
branch = master
[submodule "dists/python-modules/pycfhelpers"]
path = dists/python-modules/pycfhelpers
url = https://gitlab.demlabs.net/cellframe/python-cellframe-modules/pycfhelpers.git
[submodule "dists/python-modules/pycftools"]
path = dists/python-modules/pycftools
url = https://gitlab.demlabs.net/cellframe/python-cellframe-modules/pycftools.git
CMakeLists.txt
View file @ b6468582
cmake_minimum_required(VERSION 2.8)
cmake_minimum_required(VERSION 3.0)
project(CellFrame C)
if (SUPPORT_PYTHON_PLUGINS)
project(API_CellFrame C)
else()
project(CellFrame C)
endif()
set(CMAKE_VERBOSE_MAKEFILE ON)
set(CMAKE_COLOR_MAKEFILE ON)
set(CMAKE_C_STANDARD 11)
set(Python_ADDITIONAL_VERSIONS 3.9 3.8 3.7 3.6 3.5 3.4)
find_package (PythonLibs REQUIRED)
include_directories(${PYTHON_INCLUDE_DIR} include/)
#set(Python_ADDITIONAL_VERSIONS 3.9 3.8 3.7 3.6 3.5 3.4)
#find_package (PythonLibs REQUIRED)
file(GLOB PYTHON_CELLFRAME_SRCS CellFrame/*.c)
file(GLOB PYTHON_CELLFRAME_HEADERS include/*.h)
set(SUBMODULES_NO_BUILD ON)
if (SUPPORT_PYTHON_PLUGINS)
file (GLOB APP_CONTEXT_HEADER
modules/plugins/include/dap_plugins_python_app_context.h)
add_definitions("-fpic")
add_definitions("-DDAP_SUPPORT_PYTHON_PLUGINS")
add_library(${PROJECT_NAME} STATIC ${PYTHON_CELLFRAME_SRCS} ${APP_CONTEXT_HEADER} ${PYTHON_CELLFRAME_HEADERS})
target_include_directories(${PROJECT_NAME} INTERFACE include/)
include_directories(${PYTHON_INCLUDE_DIR})
else()
SET( CPACK_GENERATOR "DEB")
SET( CPACK_PACKAGE_NAME "${PROJECT_NAME}")
SET( CPACK_PACKAGE_VERSION_MAJOR 3)
SET( CPACK_PACKAGE_VERSION_MINOR 0)
SET( CPACK_PACKAGE_VERSION_PATCH 0)
add_definitions("-DDAP_VERSION_MAJOR=\"${CPACK_PACKAGE_VERSION_MAJOR}\"")
add_definitions("-DDAP_VERSION_MINOR=\"${CPACK_PACKAGE_VERSION_MINOR}\"")
add_definitions("-DDAP_VERSION_PATCH=\"${CPACK_PACKAGE_VERSION_PATCH}\"")
add_definitions("-DDAP_VERSION=\"${CPACK_PACKAGE_VERSION_MAJOR}.${CPACK_PACKAGE_VERSION_MINOR}-${CPACK_PACKAGE_VERSION_PATCH}\"")
set(SUBMODULES_NO_BUILD ON)
#if (SKBUILD)
message(STATUS "Make python extension")
#find_package(PythonExtensions REQUIRED)
add_library(CellFrame MODULE ${PYTHON_CELLFRAME_SRCS} ${PYTHON_CELLFRAME_HEADERS})
add_library(python_static STATIC IMPORTED GLOBAL)
target_include_directories(CellFrame INTERFACE include/)
install(TARGETS ${PROJECT_NAME} LIBRARY DESTINATION ${PROJECT_NAME})
install(FILES CellFrame/__init__.py DESTINATION ${PROJECT_NAME})
install(FILES CellFrame/PublicNetworks/* DESTINATION ${PROJECT_NAME})
endif()
if (NOT (SUPPORT_PYTHON_PLUGINS))
if (NOT(WIN32))
set(CELLFRAME_MODULES "core chains mining network srv cs-dag-poa cs-dag-pos cs-none srv-app srv-app-db srv-datum srv-vpn srv-stake")
set(CELLFRAME_MODULES "core chains network cs-none srv srv-emit-delegate")
else()
set(CELLFRAME_MODULES "core chains mining network srv cs-dag-poa cs-dag-pos cs-none srv-app srv-app-db srv-datum srv-stake")
set(CELLFRAME_MODULES "core chains network cs-none srv srv-emit-delegate")
endif()
include(cellframe-sdk/cmake/OS_Detection.cmake)
include(dap-sdk/cmake/OS_Detection.cmake)
add_subdirectory(dap-sdk)
add_subdirectory(cellframe-sdk)
else()
add_subdirectory(modules/plugins)
target_compile_options(dap_plugins_python PRIVATE "-fpic")
endif()
include_directories(${CMAKE_CURRENT_SOURCE_DIR}/include)
add_subdirectory(modules/dap-sdk/core)
add_subdirectory(modules/dap-sdk/crypto)
add_subdirectory(modules/dap-sdk/net/core)
add_subdirectory(modules/dap-sdk/io)
add_subdirectory(modules/dap-sdk/net/client)
add_subdirectory(modules/dap-sdk/net/server/enc)
add_subdirectory(modules/dap-sdk/net/server/http)
add_subdirectory(modules/dap-sdk/net/server/json_rpc)
add_subdirectory(modules/dap-sdk/net/stream/stream)
add_subdirectory(modules/dap-sdk/global-db)
add_subdirectory(modules/cellframe-sdk/common)
add_subdirectory(modules/cellframe-sdk/mempool)
add_subdirectory(modules/cellframe-sdk/net)
add_subdirectory(modules/cellframe-sdk/gdb)
add_subdirectory(modules/cellframe-sdk/net/srv)
add_subdirectory(modules/cellframe-sdk/chain)
add_subdirectory(modules/cellframe-sdk/app-cli)
add_subdirectory(modules/cellframe-sdk/wallet)
add_subdirectory(modules/cellframe-sdk/type/dag)
add_subdirectory(modules/cellframe-sdk/type/blocks)
add_subdirectory(modules/cellframe-sdk/consensus/dag_poa)
add_subdirectory(modules/cellframe-sdk/services/pos_delegate)
add_subdirectory(modules/cellframe-sdk/services/xchange)
add_subdirectory(modules/cellframe-sdk/services/vote)
add_subdirectory(modules/cellframe-sdk/channel/chain-net)
target_compile_options(dap_chain_common_python_module PRIVATE "-fpic")
target_compile_options(dap_python_module PRIVATE "-fpic" )
target_compile_options(dap_crypto_python_module PRIVATE "-fpic" )
target_compile_options(dap_chain_net_python_module PRIVATE "-fpic")
target_compile_options(dap_chain_gdb_python_module PRIVATE "-fpic")
target_compile_options(dap_chain_net_srv_python_module PRIVATE "-fpic")
target_compile_options(dap_chain_python_module PRIVATE "-fpic")
target_compile_options(dap_app_cli_python_module PRIVATE "-fpic")
target_compile_options(dap_client_python_module PRIVATE "-fpic")
......@@ -54,78 +107,39 @@ add_subdirectory(modules/cellframe-sdk/wallet)
target_compile_options(dap_core PRIVATE "-fpic")
if (NOT WIN32)
target_compile_options(dap_core_unix PRIVATE "-fpic")
endif()
target_compile_options(dap_app_cli PRIVATE "-fpic")
target_compile_options(dap_crypto PRIVATE "-fpic")
target_compile_options(dap_chain PRIVATE "-fpic")
target_compile_options(dap_chain_common PRIVATE "-fpic")
target_compile_options(dap_chain_wallet PRIVATE "-fpic" )
target_compile_options(dap_chain_crypto PRIVATE "-fpic" )
target_compile_options(dap_chain_mempool PRIVATE "-fpic" )
#target_compile_options(dap_chain_crypto PRIVATE "-fpic" )
#target_compile_options(dap_chain_mempool PRIVATE "-fpic" )
target_compile_options(dap_chain_net PRIVATE "-fpic" )
target_compile_options(dap_server_core PRIVATE "-fpic" )
target_compile_options(dap_chain_global_db PRIVATE "-fpic" )
target_compile_options(dap_io PRIVATE "-fpic" )
target_compile_options(dap_global_db PRIVATE "-fpic" )
target_compile_options(dap_client PRIVATE "-fpic" )
#target_compile_options(libdap-server PRIVATE "-fpic" )
target_compile_options(dap_stream PRIVATE "-fpic" )
target_compile_options(dap_stream_ch PRIVATE "-fpic" )
target_compile_options(dap_stream_ch_chain_net PRIVATE "-fpic" )
target_compile_options(dap_stream_ch_chain PRIVATE "-fpic" )
target_compile_options(dap_chain_net_srv PRIVATE "-fpic" )
#target_compile_options(dap_chain_net_srv PRIVATE "-fpic" )
if(NOT WIN32)
target_compile_options(dap_chain_net_srv_vpn PRIVATE "-fpic" )
# target_compile_options(dap_chain_net_srv_vpn PRIVATE "-fpic" )
endif()
target_compile_options(dap_chain_cs_none PRIVATE "-fpic" )
#target_compile_options(dap_chain_cs_none PRIVATE "-fpic" )
target_compile_options(dap_enc_server PRIVATE "-fpic")
target_compile_options(dap_http_server PRIVATE "-fpic")
target_compile_options(dap_session PRIVATE "-fpic")
target_compile_options(dap_stream_ch_chain_net_srv PRIVATE "-fpic")
target_compile_options(dap_chain_cs_dag PRIVATE "-fpic")
target_compile_options(dap_chain_cs_dag_poa PRIVATE "-fpic")
target_compile_options(dap_chain_cs_dag_pos PRIVATE "-fpic")
if (SUPPORT_PYTHON_PLUGINS)
add_definitions("-fpic")
add_definitions("-DDAP_SUPPORT_PYTHON_PLUGINS")
add_library(${PROJECT_NAME} STATIC ${PYTHON_CELLFRAME_SRCS} ${PYTHON_CELLFRAME_HEADERS})
#target_compile_options(dap_chain_cs_dag PRIVATE "-fpic")
#target_compile_options(dap_chain_cs_dag_poa PRIVATE "-fpic")
#target_compile_options(dap_chain_cs_dag_pos PRIVATE "-fpic")
else()
SET( CPACK_GENERATOR "DEB")
SET( CPACK_PACKAGE_NAME "${PROJECT_NAME}")
SET( CPACK_PACKAGE_VERSION_MAJOR 0)
SET( CPACK_PACKAGE_VERSION_MINOR 9)
SET( CPACK_PACKAGE_VERSION_PATCH 15)
add_definitions("-DDAP_VERSION_MAJOR=\"${CPACK_PACKAGE_VERSION_MAJOR}\"")
add_definitions("-DDAP_VERSION_MINOR=\"${CPACK_PACKAGE_VERSION_MINOR}\"")
add_definitions("-DDAP_VERSION_PATCH=\"${CPACK_PACKAGE_VERSION_PATCH}\"")
add_definitions("-DDAP_VERSION=\"${CPACK_PACKAGE_VERSION_MAJOR}.${CPACK_PACKAGE_VERSION_MINOR}-${CPACK_PACKAGE_VERSION_PATCH}\"")
set(SUBMODULES_NO_BUILD ON)
#if (SKBUILD)
message(STATUS "Make python extension")
#find_package(PythonExtensions REQUIRED)
add_library(CellFrame MODULE ${PYTHON_CELLFRAME_SRCS} ${PYTHON_CELLFRAME_HEADERS})
#python_extension_module(${PROJECT_NAME})
#python_extension_module(${PROJECT_NAME} LINKED_MODULES_VAR dap_python_module)
#python_extension_module(${PROJECT_NAME} LINKED_MODULES_VAR dap_crypto_python_module)
#python_extension_module(${PROJECT_NAME} LINKED_MODULES_VAR DapServerCore)
install(TARGETS ${PROJECT_NAME} LIBRARY DESTINATION ${PROJECT_NAME})
install(FILES CellFrame/__init__.py DESTINATION ${PROJECT_NAME})
install(FILES CellFrame/PublicNetworks/* DESTINATION ${PROJECT_NAME})
# install(FILES ${CMAKE_CURRENT_BINARY_DIR}/libdap-python/libdap_python_module.so DESTINATION CellFrame/lib)
# install(TARGETS dap_python_module LIBRARY DESTINATION CellFrame)
# install(TARGETS dap_crypto_python_module LIBRARY DESTINATION CellFrame)
# install(TARGETS DapServerCore LIBRARY DESTINATION CellFrame)
#else()
# add_library(${PROJECT_NAME} SHARED ${PYTHON_CELLFRAME_SRCS} ${PYTHON_CELLFRAME_HEADERS})
#endif()
endif()
target_compile_options(dap_core PRIVATE "-fpic")
target_compile_options(dap_app_cli PRIVATE "-fpic")
......@@ -133,29 +147,29 @@ target_compile_options(dap_crypto PRIVATE "-fpic")
target_compile_options(dap_chain PRIVATE "-fpic")
target_compile_options(dap_chain_common PRIVATE "-fpic")
target_compile_options(dap_chain_wallet PRIVATE "-fpic" )
target_compile_options(dap_chain_crypto PRIVATE "-fpic" )
target_compile_options(dap_chain_mempool PRIVATE "-fpic" )
#target_compile_options(dap_chain_crypto PRIVATE "-fpic" )
#target_compile_options(dap_chain_mempool PRIVATE "-fpic" )
target_compile_options(dap_chain_net PRIVATE "-fpic" )
target_compile_options(dap_server_core PRIVATE "-fpic" )
target_compile_options(dap_chain_global_db PRIVATE "-fpic" )
target_compile_options(dap_io PRIVATE "-fpic" )
target_compile_options(dap_global_db PRIVATE "-fpic" )
target_compile_options(dap_client PRIVATE "-fpic" )
#target_compile_options(libdap-server PRIVATE "-fpic" )
target_compile_options(dap_stream PRIVATE "-fpic" )
target_compile_options(dap_stream_ch PRIVATE "-fpic" )
target_compile_options(dap_stream_ch_chain_net PRIVATE "-fpic" )
target_compile_options(dap_stream_ch_chain PRIVATE "-fpic" )
target_compile_options(dap_chain_net_srv PRIVATE "-fpic" )
#target_compile_options(dap_chain_net_srv PRIVATE "-fpic" )
if (NOT WIN32)
target_compile_options(dap_chain_net_srv_vpn PRIVATE "-fpic" )
#target_compile_options(dap_chain_net_srv_vpn PRIVATE "-fpic" )
endif()
target_compile_options(dap_chain_cs_none PRIVATE "-fpic" )
#target_compile_options(dap_chain_cs_none PRIVATE "-fpic" )
target_compile_options(dap_enc_server PRIVATE "-fpic")
target_compile_options(dap_http_server PRIVATE "-fpic")
target_compile_options(dap_session PRIVATE "-fpic")
target_compile_options(dap_stream_ch_chain_net_srv PRIVATE "-fpic")
target_compile_options(dap_chain_cs_dag PRIVATE "-fpic")
target_compile_options(dap_chain_cs_dag_poa PRIVATE "-fpic")
target_compile_options(dap_chain_cs_dag_pos PRIVATE "-fpic")
#target_compile_options(dap_chain_cs_dag PRIVATE "-fpic")
#target_compile_options(dap_chain_cs_dag_poa PRIVATE "-fpic")
#target_compile_options(dap_chain_cs_dag_pos PRIVATE "-fpic")
target_compile_options(dap_io_python_module PRIVATE "-fpic")
if (WIN32)
......@@ -165,13 +179,24 @@ endif()
target_link_libraries(${PROJECT_NAME} cellframe-sdk dap_python_module
dap_crypto_python_module
dap_server_core_python_module
dap_io_python_module
dap_enc_server_python_module
dap_server_http_python_module
dap_stream_python_module
dap_chain_python_module
dap_chain_net_python_module
dap_chain_gdb_python_module
dap_chain_net_srv_python_module
dap_mempool_python_module
dap_app_cli_python_module
dap_chain_wallet_python_module
dap_server_json_rpc_python_module
dap_chain_cs_dag_poa_python_module
dap_chain_cs_blocks_python_module
dap_global_db_python_module
dap_chain_net_srv_stake_pos_delegate_python_module
wrapping_dap_chain_net_srv_xchange
dap_chain_net_srv_vote_python
dap_stream_ch_chain_net_python_module
${PYTHON_LIBRARIES}
)
target_include_directories(${PROJECT_NAME} INTERFACE include/)
CellFrame/generator_config_file.c deleted 100644 → 0
View file @ 59f68881
#include "generator_config_file.h"
#define LOG_TAG "generator_config_file"
static void writeGroupInFile(FILE *file, const char *group){
fputs("[", file);
fputs(group, file);
fputs("]\n", file);
}
static void writeKeyAndValueInFile(FILE *file, const char *key, const char *value){
fputs(key, file);
fputs("=", file);
fputs(value, file);
fputs("\n", file);
}
char* getCharFromPyObject(PyObject *obj){
char *res = "NULL\0";
if (PyUnicode_Check(obj)){
res = strdup(PyUnicode_AsUTF8(obj));
}
if (PyLong_Check(obj)){
int i = _PyLong_AsInt(obj);
res = dap_itoa(i);
}
if (PyBool_Check(obj)){
res = (obj == Py_True) ? "true\0" : "false\0";
}
if (PyBytes_Check(obj)){
size_t size_bytes = (size_t)PyBytes_Size(obj);
res = calloc(size_bytes+1, sizeof(char));
memcpy(res, PyBytes_AsString(obj), size_bytes);
res[size_bytes+1] = '\0';
}
if (PyList_Check(obj)){
dap_string_t *str = dap_string_new("[");
Py_ssize_t size_list = PyList_Size(obj);
for (Py_ssize_t i = 0; i < size_list;i++){
char *d = getCharFromPyObject(PyList_GetItem(obj, i));
str = dap_string_append(str, d);
if (i != size_list - 1){
str = dap_string_append(str, ",");
}
}
str = dap_string_append(str, "]");
res = strdup(str->str);
dap_string_free(str, true);
}
return res;
}
void writeContectSectorToFile(FILE *file, PyObject *sector){
PyGILState_STATE state;
state = PyGILState_Ensure();
PyObject *list_keys = PyDict_Keys(sector);
PyGILState_Release(state);
Py_ssize_t count_keys = PyList_Size(list_keys);
char *key;
PyObject *obj_value;
char *value;
for (Py_ssize_t i = 0; i < count_keys; i++){
key = getCharFromPyObject(PyList_GetItem(list_keys, i));
obj_value = PyDict_GetItemString(sector, key);
value = getCharFromPyObject(obj_value);
writeKeyAndValueInFile(file, key, value);
}
}
void writeSectorsToFile(FILE *file, PyObject *sectors, int count, ...){
log_it(L_DEBUG, "Write_sector start");
if (!PyDict_Check(sectors)){
log_it(L_ERROR, "input object don't have sector");
return;
}
PyObject *list_sectors = PyDict_Keys(sectors);
log_it(L_DEBUG, "WSTF1");
Py_ssize_t count_sectors = PyList_Size(list_sectors);
char *name_sector = NULL;
bool _this_obj_not_processes = false;
PyObject *sector;
for (Py_ssize_t i = 0; i < count_sectors; i++){
name_sector = getCharFromPyObject(PyList_GetItem(list_sectors, i));
va_list args;
va_start(args, count);
for (int l=0; l < count; l++){
if (strcmp(name_sector, va_arg(args, char*)) == 0){
_this_obj_not_processes = true;
}
}
if (!_this_obj_not_processes){
sector = PyDict_GetItemString(sectors, name_sector);
writeGroupInFile(file, name_sector);
writeContectSectorToFile(file, sector);
}
DAP_FREE(name_sector);
}
}
void writeChainFiles(char *base_path, PyObject *chains_conf){
PyObject *list_names = PyDict_GetItemString(chains_conf, "name_cfg_files");
PyObject *dict_conf = PyDict_GetItemString(chains_conf, "conf_files");
for (Py_ssize_t i=0; i < PyList_Size(list_names); i++){
char *name = dap_strdup(PyUnicode_AsUTF8(PyList_GetItem(list_names, i)));
PyObject *cfg = PyDict_GetItemString(dict_conf, name);
FILE *file_chain;
char *path_file = dap_strjoin(NULL, base_path, name, ".cfg", NULL);
if ((file_chain = fopen(path_file, "w")) == NULL){
log_it(L_WARNING,"Can't create file \"%s\"", path_file);
break;
}
writeSectorsToFile(file_chain, cfg, 0);
fclose(file_chain);
}
}
void createConfNetworks(char *base_path, PyObject *nets){
log_it(L_DEBUG, "Create network settings");
PyObject *name_nets = PyDict_Keys(nets);
Py_ssize_t count_nets = PyList_Size(name_nets);
char *name_net_dir;
char *name_net_cfg;
char *name_net_cfg_tmp;
char *value = NULL;
for (Py_ssize_t i =0; i < count_nets; i++){
value = getCharFromPyObject(PyList_GetItem(name_nets, i));
log_it(L_DEBUG, "net: %s", value);
name_net_cfg_tmp = dap_strjoin(NULL, base_path, "/", value, NULL);
name_net_dir = dap_strjoin(NULL, name_net_cfg_tmp, "/", NULL);
name_net_cfg = dap_strjoin(NULL, name_net_cfg_tmp, ".cfg", NULL);
DAP_FREE(name_net_cfg_tmp);
if (!dap_valid_ascii_symbols(name_net_cfg)){
break;
}
dap_mkdir_with_parents(name_net_dir);
FILE *cfg_file_net;
if ((cfg_file_net = fopen(name_net_cfg, "w")) == NULL){
log_it(L_WARNING,"Can't create file \"%s\"", name_net_cfg);
break;
}
DAP_FREE(name_net_cfg);
PyObject *conf = PyDict_GetItemString(nets, value);
writeSectorsToFile(cfg_file_net, conf, 2, "name_cfg_files", "conf_files");
fclose(cfg_file_net);
writeChainFiles(name_net_dir, conf);
DAP_FREE(name_net_dir);
DAP_FREE(value);
}
}
int gen_config_files(const char *cfgDir, const char *app_name, PyObject *cfg_JSON){
if (!dap_valid_ascii_symbols(cfgDir)){
return -1;
}
char *network_dir = dap_strjoin(NULL, cfgDir, "/network", NULL);
dap_mkdir_with_parents(network_dir);
char *main_config_files = dap_strjoin(NULL, cfgDir, "//", app_name, ".cfg", NULL);
FILE *main_file;
if ((main_file = fopen(main_config_files, "w")) == NULL){
log_it(L_WARNING, "Can't open file %s", main_config_files);
return -3;
}
writeSectorsToFile(main_file, cfg_JSON, 1, "networks");
fclose(main_file);
createConfNetworks(network_dir, PyDict_GetItemString(cfg_JSON, "networks"));
DAP_FREE(main_config_files);
DAP_FREE(network_dir);
return 0;
}
CellFrame/python-cellframe.c
View file @ b6468582
This diff is collapsed.
CellFrame/python-cellframe_common.c 0 → 100644
View file @ b6468582
#include <Python.h>
#if PY_MAJOR_VERSION > 3 || (PY_MAJOR_VERSION == 3 && PY_MINOR_VERSION > 11)
#include <pytypedefs.h>
#endif
#include <patchlevel.h>
#include <frameobject.h>
#include "python-cellframe_common.h"
void _PyErr_logIt(const dap_log_level_t a_level, const char *a_tag, const char *a_msg){
_log_it("\0", 0, a_tag, a_level, "%s", a_msg);
}
char* _PyErr_get_stacktrace(PyObject *a_obj){
if (!a_obj){
return "No stack trace";
}
PyTracebackObject *l_traceback = (PyTracebackObject*)a_obj;
char *s = "\tStack trace:\n";
size_t cnt = 0;
while (l_traceback != NULL) {
const char *l_name, *l_file;
#if PY_MAJOR_VERSION == 3 && PY_MINOR_VERSION < 10
l_name = l_file = "unknown";
#else
PyCodeObject *l_code = PyFrame_GetCode(l_traceback->tb_frame);
l_name = PyUnicode_AsUTF8(l_code->co_name);
l_file = PyUnicode_AsUTF8(l_code->co_filename);
#endif
int l_lineo = l_traceback->tb_lineno;
s = dap_strdup_printf("%s\t\t(%zu) File \"%s\", line %d, in %s\n", s, cnt, l_file, l_lineo, l_name);
l_traceback = l_traceback->tb_next;
cnt++;
}
return s;
}
void python_error_in_log_it(const char *a_tag){
PyObject *type, *value, *trackback;
PyErr_Fetch(&type, &value, &trackback);
PyErr_NormalizeException(&type, &value, &trackback);
PyObject* str_exc_value = PyObject_Repr(value);
PyObject* exect_value_str = PyUnicode_AsEncodedString(str_exc_value, "utf-8", "strict");
const char *l_str_value = PyBytes_AS_STRING(exect_value_str);
char *l_str = dap_strdup_printf(
"An exception occurred while executing a Python script.\n"
"\t%s\n%s", l_str_value ? l_str_value : "(null)",
trackback ? _PyErr_get_stacktrace(trackback) : "(null)"
);
_PyErr_logIt(L_ERROR, a_tag, l_str);
DAP_DELETE(l_str);
PyErr_Restore(type, value, trackback);
}
PyObject *python_get_config_item(dap_config_t* a_config, const char *a_section, const char *a_key, PyObject *obj_default) {
dap_config_item_type_t l_type_item = dap_config_get_item_type(
a_config, a_section, a_key);
switch (l_type_item) {
case DAP_CONFIG_ITEM_UNKNOWN: {
if (obj_default != NULL) {
return obj_default;
}
PyErr_SetString(PyExc_ValueError, "Value can't be obtained. Either no such section or a key is missing in section");
return NULL;
}
case DAP_CONFIG_ITEM_ARRAY: {
uint16_t l_values_count = 0;
const char **l_values = dap_config_get_array_str(a_config, a_section, a_key, &l_values_count);
PyObject *obj_list = PyList_New(l_values_count);
for (uint16_t i = 0; i < l_values_count; i++) {
const char *l_value = l_values[i];
PyObject *obj_unicode = PyUnicode_FromString(l_value);
PyList_SetItem(obj_list, i, obj_unicode);
}
return obj_list;
}
case DAP_CONFIG_ITEM_BOOL: {
if (dap_config_get_item_bool(a_config, a_section, a_key))
Py_RETURN_TRUE;
else
Py_RETURN_FALSE;
}
case DAP_CONFIG_ITEM_DECIMAL: {
int64_t res = dap_config_get_item_int64(a_config, a_section, a_key);
return Py_BuildValue("L", res);
}
case DAP_CONFIG_ITEM_STRING: {
const char *res = dap_config_get_item_str(a_config, a_section, a_key);
return Py_BuildValue("s", res);
}
default:;
}
Py_RETURN_NONE;
}
CellFrame/wrapping_dap_enc_http.c deleted 100644 → 0
View file @ 59f68881
#include "wrapping_dap_enc_http.h"
PyObject *enc_http_add_proc_py(PyObject *self, PyObject *args){
PyObject *obj_server;
const char *HTTP_URL;
if (!PyArg_ParseTuple(args, "O|s", &obj_server, &HTTP_URL))
return NULL;
enc_http_add_proc(DAP_HTTP(((PyDapServerObject*)obj_server)->t_server), HTTP_URL);
return PyLong_FromLong(0);
}
CellFrame/wrapping_dap_http_folder.c deleted 100644 → 0
View file @ 59f68881
#include "wrapping_dap_http_folder.h"
PyObject *dap_http_folder_add_py(PyObject *self, PyObject *args){
PyObject *obj_server;
const char *url_path;
const char *local_path;
if (!PyArg_ParseTuple(args, "O|s|s", &obj_server, &url_path, &local_path))
return NULL;
int res = dap_http_folder_add(DAP_HTTP(((PyDapServerObject*)obj_server)->t_server), url_path, local_path);
return PyLong_FromLong(res);
}
CellFrame/wrapping_dap_mempool.c deleted 100644 → 0
View file @ 59f68881
#include "wrapping_dap_mempool.h"
PyObject *dap_chain_mempool_add_proc_py(PyObject *self, PyObject *args){
PyObject *obj_server;
const char *MEMPOOL_URL;
if (!PyArg_ParseTuple(args, "O|s", &obj_server, &MEMPOOL_URL))
return NULL;
dap_chain_mempool_add_proc(DAP_HTTP(((PyDapServerObject*)obj_server)->t_server), MEMPOOL_URL);
return PyLong_FromLong(0);
}
\ No newline at end of file
CellFrame/wrapping_dap_stream.c deleted 100644 → 0
View file @ 59f68881
#include "wrapping_dap_stream.h"
PyObject *dap_stream_add_proc_http_py(PyObject *self, PyObject *args){
PyObject *obj_server;
const char *STREAM_URL;
if (!PyArg_ParseTuple(args, "O|s", &obj_server, &STREAM_URL))
return NULL;
dap_stream_add_proc_http(DAP_HTTP(((PyDapServerObject*)obj_server)->t_server), STREAM_URL);
return PyLong_FromLong(0);
}
CellFrame/wrapping_dap_stream_ctl.c deleted 100644 → 0
View file @ 59f68881
#include "wrapping_dap_stream_ctl.h"
PyObject *dap_stream_ctl_add_proc_py(PyObject *self, PyObject *args){
PyObject *obj_server;
const char *STREAM_CTL_URL;
if (!PyArg_ParseTuple(args, "O|s", &obj_server, &STREAM_CTL_URL))
return NULL;
dap_stream_ctl_add_proc(DAP_HTTP(((PyDapServerObject*)obj_server)->t_server), STREAM_CTL_URL);
return PyLong_FromLong(0);
}
int dap_stream_ctl_init_py(uint32_t size){
return dap_stream_ctl_init(size);
}
CellFrame/wrapping_http.c deleted 100644 → 0
View file @ 59f68881
#include "wrapping_http.h"
PyObject *dap_http_new_py(PyObject *self, PyObject *args){
PyObject *obj_server;
const char * name;
if (!PyArg_ParseTuple(args, "O|s", &obj_server, &name))
return NULL;
int res = dap_http_new(((PyDapServerObject*)obj_server)->t_server, name);
return PyLong_FromLong(res);
}
README.md
View file @ b6468582
......@@ -9,7 +9,7 @@ Use the following command to fix it
dpkg-statoverride --remove /etc/exim4/passwd.client
Now repeat sudo apt-get install pip3
## Build and Run tests:
## Build:
```
git clone https://gitlab.demlabs.net/cellframe/python-cellframe.git
cd python-cellframe
......@@ -18,7 +18,6 @@ cd cellframe-sdk
git submodule update --init
cd ..
sudo python3.7 setup.py install
python3.7 test/main_test.py
```
## How to package
......
cellframe-sdk @ 0f244621
Subproject commit 21886ef54e5b6d00c605221271530f83201b1574
Subproject commit 0f24462136e52cb6ed566e3f5bc5e4c9399e4f6e
dists/examples/0.Beginning/var/lib/ca/.keep-it deleted 100644 → 0
View file @ 59f68881
dists/examples/1.Authority/var/lib/ca/.keep-it deleted 100644 → 0
View file @ 59f68881
dists/examples/1.Authority/var/lib/wallet/.keep-it deleted 100644 → 0
View file @ 59f68881
dists/examples/1.Authority/var/log/.keep-it deleted 100644 → 0
View file @ 59f68881
dists/examples/plugins/customDatum/customDatum.py 0 → 100644
View file @ b6468582
from DAP.Core import logIt
from CellFrame.Common import CustomDatum
from CellFrame.Network import Net
from CellFrame import AppCliServer
def datumCMD(argv, indexStrReply):
if (len(argv) == 3 or len(argv) == 5):
if (argv[1] == 'create'):
net = Net.byName(argv[2])
chain = net.getChainByName(argv[3])
res = CustomDatum.create(chain, argv[4].encode('utf-8'))
AppCliServer.setReplyText("Return hash datum: "+str(res), indexStrReply)
elif(argv[1] == 'load'):
data = CustomDatum.read(argv[2])
AppCliServer.setReplyText("Return data: "+str(data), indexStrReply)
else:
logIt.notice("This command can take three or four arguments.")
def init():
logIt.notice("Start plugin customDatum")
AppCliServer.cmdItemCreate("pyDatum", datumCMD, "Command for creation datum", """
Command for created and get info from custom datum:
create <net name> <chain name> <date in datum>
load <path for file>
""")
return 0
dists/examples/plugins/customDatum/manifest.json 0 → 100644
View file @ b6468582
{
"name": "customDatum",
"version": "1.0",
"author": "DEMLABS (C) 2021",
"dependencies": [],
"description": "This plugin does the work of the backend for the blockchain explorer."
}
dists/examples/plugins/demoCustomCMD/demoCustomCMD.py 0 → 100644
View file @ b6468582
from DAP.Core import logIt
from CellFrame import AppCliServer
"""
This function takes two arguments
argv is an array of incoming arguments
indexStrReply is an internal index that correlates what is needed
to fill the desired buffer with the data that will be passed to the CLI.
"""
def cmdDemo(argv, indexStrReply):
reply = "Arguments :\n"
for i in range(len(argv)):
reply += "arg["+str(i)+"]: "+argv[i]+"\n"
AppCliServer.setReplyText(reply, indexStrReply)
def cmdDemo2(argv, indexStrReply):
AppCliServer.setReplyText("I simple demo command", indexStrReply)
def init():
logIt.notice("Running plugin order")
"""
The cmdItemCreate function creates a CLI command.
This function takes four arguments.
Command name, command handler function, short description of
of the command, full description of the command.
"""
AppCliServer.cmdItemCreate("demo", cmdDemo, "Command demo",
"""
This command is intended to demonstrate the work of custom command in the CellFrame API for Python.
""")
AppCliServer.cmdItemCreate("demo2", cmdDemo2, "Second command demo",
"""
This is demo and testing
""")
return 0