[*] Some renames, added static ragne request structure

dap_stream_ch_chain.c

@@ -61,11 +61,12 @@ static void s_stream_ch_packet_out(dap_stream_ch_t* a_ch , void* a_arg);
 int dap_stream_ch_chain_init()
 {
     log_it(L_NOTICE,"Chain blocks and datums exchange channel initialized");
-    dap_stream_ch_proc_add('C',s_stream_ch_new,s_stream_ch_delete,s_stream_ch_packet_in,s_stream_ch_packet_out);
+    dap_stream_ch_proc_add(dap_stream_ch_chain_get_id(),s_stream_ch_new,s_stream_ch_delete,s_stream_ch_packet_in,s_stream_ch_packet_out);
 
     return 0;
 }
 
+
 /**
  * @brief dap_stream_ch_chain_deinit
  */
@@ -112,7 +113,7 @@ void s_stream_ch_packet_in(dap_stream_ch_t* a_ch , void* a_arg)
             dap_chain_t * l_chain = dap_chain_find_by_id(l_chain_pkt->hdr.net_id,  l_chain_pkt->hdr.chain_id);
             if ( l_chain ) {
                 switch ( l_chain_pkt->hdr.type ) {
-                    case STREAM_CH_CHAIN_PKT_TYPE_REQUEST:{
+                    case STREAM_CH_CHAIN_PKT_TYPE_SYNC_CHAINS_REQUEST:{
                     }break;
                     case STREAM_CH_CHAIN_PKT_TYPE_DATUM:{
                     }break;

dap_stream_ch_chain.h

@@ -24,6 +24,8 @@
 
 #pragma once
 
-int dap_stream_ch_chain_init();
-void dap_stream_ch_chain_deinit();
+#include <stdint.h>
+int dap_stream_ch_chain_init(void);
+void dap_stream_ch_chain_deinit(void);
 
+inline static uint8_t dap_stream_ch_chain_get_id(void) { return (uint8_t) 'C'; }

dap_stream_ch_chain_pkt.h

@@ -30,25 +30,22 @@
 #include "dap_chain_datum.h"
 #include "dap_chain_cs.h"
 
-#define STREAM_CH_CHAIN_PKT_TYPE_REQUEST       0x00
-#define STREAM_CH_CHAIN_PKT_TYPE_BLOCK         0x11
-#define STREAM_CH_CHAIN_PKT_TYPE_DATUM         0x12
-#define STREAM_CH_CHAIN_PKT_TYPE_GLOVAL_DB     0x13
+#define STREAM_CH_CHAIN_PKT_TYPE_SYNC_CHAINS_REQUEST       0x00
+#define STREAM_CH_CHAIN_PKT_TYPE_BLOCK                     0x11
+#define STREAM_CH_CHAIN_PKT_TYPE_DATUM                     0x12
+#define STREAM_CH_CHAIN_PKT_TYPE_GLOVAL_DB                 0x13
 
 typedef union dap_stream_ch_chain_request{
-    enum {
-            CHAIN_REQUEST_CHAIN_BLOCKS_RANGE_HASH,
-            CHAIN_REQUEST_CHAIN_BLOCKS_RANGE_DATE,
-            CHAIN_REQUEST_CHAIN_DATUM_RANGE_HASH,
-            CHAIN_REQUEST_CHAIN_DATUM_RANGE_DATE,
-         } enums:16;
-    uint16_t u16;
+    dap_chain_hash_fast_t hash_from;
+    dap_chain_hash_fast_t hash_to;
+    uint64_t ts_from;
+    uint64_t ts_to;
 } dap_stream_ch_chain_request_t;
 
 typedef struct dap_stream_ch_chain_pkt_hdr{
-    dap_chain_id_t chain_id;
     dap_chain_net_id_t net_id;
-    dap_chain_cell_id_t shard_id;
+    dap_chain_id_t chain_id;
+    dap_chain_cell_id_t cell_id;
     uint8_t type;
     uint8_t padding1[3];
     uint64_t tid;