261 lines
9.3 KiB
C
261 lines
9.3 KiB
C
#include "rpc_i.h"
|
|
#include <m-string.h>
|
|
|
|
static size_t rpc_debug_print_file_msg(
|
|
string_t str,
|
|
const char* prefix,
|
|
const PB_Storage_File* msg_file,
|
|
size_t msg_files_size) {
|
|
size_t cnt = 0;
|
|
|
|
for(size_t i = 0; i < msg_files_size; ++i, ++msg_file) {
|
|
string_cat_printf(
|
|
str,
|
|
"%s[%c] size: %5ld",
|
|
prefix,
|
|
msg_file->type == PB_Storage_File_FileType_DIR ? 'd' : 'f',
|
|
msg_file->size);
|
|
|
|
if(msg_file->name) {
|
|
string_cat_printf(str, " \'%s\'", msg_file->name);
|
|
}
|
|
|
|
if(msg_file->data && msg_file->data->size) {
|
|
string_cat_printf(
|
|
str,
|
|
" (%d):\'%.*s%s\'",
|
|
msg_file->data->size,
|
|
MIN(msg_file->data->size, 30),
|
|
msg_file->data->bytes,
|
|
msg_file->data->size > 30 ? "..." : "");
|
|
}
|
|
|
|
string_cat_printf(str, "\r\n");
|
|
}
|
|
|
|
return cnt;
|
|
}
|
|
|
|
void rpc_debug_print_data(const char* prefix, uint8_t* buffer, size_t size) {
|
|
string_t str;
|
|
string_init(str);
|
|
string_reserve(str, 100 + size * 5);
|
|
|
|
string_cat_printf(str, "\r\n%s DEC(%d): {", prefix, size);
|
|
for(size_t i = 0; i < size; ++i) {
|
|
string_cat_printf(str, "%d, ", buffer[i]);
|
|
}
|
|
string_cat_printf(str, "}\r\n");
|
|
|
|
printf("%s", string_get_cstr(str));
|
|
string_reset(str);
|
|
string_reserve(str, 100 + size * 3);
|
|
|
|
string_cat_printf(str, "%s HEX(%d): {", prefix, size);
|
|
for(size_t i = 0; i < size; ++i) {
|
|
string_cat_printf(str, "%02X", buffer[i]);
|
|
}
|
|
string_cat_printf(str, "}\r\n\r\n");
|
|
|
|
printf("%s", string_get_cstr(str));
|
|
string_clear(str);
|
|
}
|
|
|
|
void rpc_debug_print_message(const PB_Main* message) {
|
|
string_t str;
|
|
string_init(str);
|
|
|
|
string_cat_printf(
|
|
str,
|
|
"PB_Main: {\r\n\tresult: %d cmd_id: %ld (%s)\r\n",
|
|
message->command_status,
|
|
message->command_id,
|
|
message->has_next ? "has_next" : "last");
|
|
switch(message->which_content) {
|
|
default:
|
|
/* not implemented yet */
|
|
string_cat_printf(str, "\tNOT_IMPLEMENTED (%d) {\r\n", message->which_content);
|
|
break;
|
|
case PB_Main_stop_session_tag:
|
|
string_cat_printf(str, "\tstop_session {\r\n");
|
|
break;
|
|
case PB_Main_app_start_request_tag: {
|
|
string_cat_printf(str, "\tapp_start {\r\n");
|
|
const char* name = message->content.app_start_request.name;
|
|
const char* args = message->content.app_start_request.args;
|
|
if(name) {
|
|
string_cat_printf(str, "\t\tname: %s\r\n", name);
|
|
}
|
|
if(args) {
|
|
string_cat_printf(str, "\t\targs: %s\r\n", args);
|
|
}
|
|
break;
|
|
}
|
|
case PB_Main_app_lock_status_request_tag: {
|
|
string_cat_printf(str, "\tapp_lock_status_request {\r\n");
|
|
break;
|
|
}
|
|
case PB_Main_app_lock_status_response_tag: {
|
|
string_cat_printf(str, "\tapp_lock_status_response {\r\n");
|
|
bool lock_status = message->content.app_lock_status_response.locked;
|
|
string_cat_printf(str, "\t\tlocked: %s\r\n", lock_status ? "true" : "false");
|
|
break;
|
|
}
|
|
case PB_Main_storage_md5sum_request_tag: {
|
|
string_cat_printf(str, "\tmd5sum_request {\r\n");
|
|
const char* path = message->content.storage_md5sum_request.path;
|
|
if(path) {
|
|
string_cat_printf(str, "\t\tpath: %s\r\n", path);
|
|
}
|
|
break;
|
|
}
|
|
case PB_Main_storage_md5sum_response_tag: {
|
|
string_cat_printf(str, "\tmd5sum_response {\r\n");
|
|
const char* path = message->content.storage_md5sum_response.md5sum;
|
|
if(path) {
|
|
string_cat_printf(str, "\t\tmd5sum: %s\r\n", path);
|
|
}
|
|
break;
|
|
}
|
|
case PB_Main_system_ping_request_tag:
|
|
string_cat_printf(str, "\tping_request {\r\n");
|
|
break;
|
|
case PB_Main_system_ping_response_tag:
|
|
string_cat_printf(str, "\tping_response {\r\n");
|
|
break;
|
|
case PB_Main_system_device_info_request_tag:
|
|
string_cat_printf(str, "\tdevice_info_request {\r\n");
|
|
break;
|
|
case PB_Main_system_device_info_response_tag:
|
|
string_cat_printf(str, "\tdevice_info_response {\r\n");
|
|
string_cat_printf(
|
|
str,
|
|
"\t\t%s: %s\r\n",
|
|
message->content.system_device_info_response.key,
|
|
message->content.system_device_info_response.value);
|
|
break;
|
|
case PB_Main_storage_mkdir_request_tag:
|
|
string_cat_printf(str, "\tmkdir {\r\n");
|
|
break;
|
|
case PB_Main_storage_delete_request_tag: {
|
|
string_cat_printf(str, "\tdelete {\r\n");
|
|
const char* path = message->content.storage_delete_request.path;
|
|
if(path) {
|
|
string_cat_printf(str, "\t\tpath: %s\r\n", path);
|
|
}
|
|
break;
|
|
}
|
|
case PB_Main_empty_tag:
|
|
string_cat_printf(str, "\tempty {\r\n");
|
|
break;
|
|
case PB_Main_storage_info_request_tag: {
|
|
string_cat_printf(str, "\tinfo_request {\r\n");
|
|
const char* path = message->content.storage_info_request.path;
|
|
if(path) {
|
|
string_cat_printf(str, "\t\tpath: %s\r\n", path);
|
|
}
|
|
break;
|
|
}
|
|
case PB_Main_storage_info_response_tag: {
|
|
string_cat_printf(str, "\tinfo_response {\r\n");
|
|
string_cat_printf(
|
|
str, "\t\ttotal_space: %lu\r\n", message->content.storage_info_response.total_space);
|
|
string_cat_printf(
|
|
str, "\t\tfree_space: %lu\r\n", message->content.storage_info_response.free_space);
|
|
break;
|
|
}
|
|
case PB_Main_storage_stat_request_tag: {
|
|
string_cat_printf(str, "\tstat_request {\r\n");
|
|
const char* path = message->content.storage_stat_request.path;
|
|
if(path) {
|
|
string_cat_printf(str, "\t\tpath: %s\r\n", path);
|
|
}
|
|
break;
|
|
}
|
|
case PB_Main_storage_stat_response_tag: {
|
|
string_cat_printf(str, "\tstat_response {\r\n");
|
|
if(message->content.storage_stat_response.has_file) {
|
|
const PB_Storage_File* msg_file = &message->content.storage_stat_response.file;
|
|
rpc_debug_print_file_msg(str, "\t\t\t", msg_file, 1);
|
|
}
|
|
break;
|
|
}
|
|
case PB_Main_storage_list_request_tag: {
|
|
string_cat_printf(str, "\tlist_request {\r\n");
|
|
const char* path = message->content.storage_list_request.path;
|
|
if(path) {
|
|
string_cat_printf(str, "\t\tpath: %s\r\n", path);
|
|
}
|
|
break;
|
|
}
|
|
case PB_Main_storage_read_request_tag: {
|
|
string_cat_printf(str, "\tread_request {\r\n");
|
|
const char* path = message->content.storage_read_request.path;
|
|
if(path) {
|
|
string_cat_printf(str, "\t\tpath: %s\r\n", path);
|
|
}
|
|
break;
|
|
}
|
|
case PB_Main_storage_write_request_tag: {
|
|
string_cat_printf(str, "\twrite_request {\r\n");
|
|
const char* path = message->content.storage_write_request.path;
|
|
if(path) {
|
|
string_cat_printf(str, "\t\tpath: %s\r\n", path);
|
|
}
|
|
if(message->content.storage_write_request.has_file) {
|
|
const PB_Storage_File* msg_file = &message->content.storage_write_request.file;
|
|
rpc_debug_print_file_msg(str, "\t\t\t", msg_file, 1);
|
|
}
|
|
break;
|
|
}
|
|
case PB_Main_storage_read_response_tag:
|
|
string_cat_printf(str, "\tread_response {\r\n");
|
|
if(message->content.storage_read_response.has_file) {
|
|
const PB_Storage_File* msg_file = &message->content.storage_read_response.file;
|
|
rpc_debug_print_file_msg(str, "\t\t\t", msg_file, 1);
|
|
}
|
|
break;
|
|
case PB_Main_storage_list_response_tag: {
|
|
const PB_Storage_File* msg_file = message->content.storage_list_response.file;
|
|
size_t msg_file_count = message->content.storage_list_response.file_count;
|
|
string_cat_printf(str, "\tlist_response {\r\n");
|
|
rpc_debug_print_file_msg(str, "\t\t", msg_file, msg_file_count);
|
|
break;
|
|
}
|
|
case PB_Main_storage_rename_request_tag: {
|
|
string_cat_printf(str, "\trename_request {\r\n");
|
|
string_cat_printf(
|
|
str, "\t\told_path: %s\r\n", message->content.storage_rename_request.old_path);
|
|
string_cat_printf(
|
|
str, "\t\tnew_path: %s\r\n", message->content.storage_rename_request.new_path);
|
|
break;
|
|
}
|
|
case PB_Main_gui_start_screen_stream_request_tag:
|
|
string_cat_printf(str, "\tstart_screen_stream {\r\n");
|
|
break;
|
|
case PB_Main_gui_stop_screen_stream_request_tag:
|
|
string_cat_printf(str, "\tstop_screen_stream {\r\n");
|
|
break;
|
|
case PB_Main_gui_screen_frame_tag:
|
|
string_cat_printf(str, "\tscreen_frame {\r\n");
|
|
break;
|
|
case PB_Main_gui_send_input_event_request_tag:
|
|
string_cat_printf(str, "\tsend_input_event {\r\n");
|
|
string_cat_printf(
|
|
str, "\t\tkey: %d\r\n", message->content.gui_send_input_event_request.key);
|
|
string_cat_printf(
|
|
str, "\t\type: %d\r\n", message->content.gui_send_input_event_request.type);
|
|
break;
|
|
case PB_Main_gui_start_virtual_display_request_tag:
|
|
string_cat_printf(str, "\tstart_virtual_display {\r\n");
|
|
break;
|
|
case PB_Main_gui_stop_virtual_display_request_tag:
|
|
string_cat_printf(str, "\tstop_virtual_display {\r\n");
|
|
break;
|
|
}
|
|
string_cat_printf(str, "\t}\r\n}\r\n");
|
|
printf("%s", string_get_cstr(str));
|
|
|
|
string_clear(str);
|
|
}
|