[+] shard id for pkt hdr

dap_stream_ch_chain.c

@@ -49,7 +49,6 @@ typedef enum dap_stream_ch_chain_state{
 
 typedef struct dap_stream_ch_chain {
     pthread_mutex_t mutex;
-    dap_chain_net_id_t net_id;
     dap_chain_hash_t block_id;
 
 } dap_stream_ch_chain_t;
@@ -115,7 +114,8 @@ void s_stream_ch_packet_in(dap_stream_ch_t* a_ch , void* a_arg)
         dap_stream_ch_pkt_t * l_ch_pkt = (dap_stream_ch_pkt_t *) a_arg;
         dap_stream_ch_chain_pkt_t * l_chain_pkt =(dap_stream_ch_chain_pkt_t *) l_ch_pkt->data;
         if( l_chain_pkt ){
-            dap_chain_t * l_chain = dap_chain_find_by_id(l_ch_chain->net_id,  l_chain_pkt->hdr.chain_id);
+            dap_chain_t * l_chain = dap_chain_find_by_id(l_chain_pkt->hdr.net_id,  l_chain_pkt->hdr.chain_id,
+                                                         l_chain_pkt->hdr.shard_id);
             if ( l_chain ) {
                 switch ( l_chain_pkt->hdr.type ) {
                     case STREAM_CH_CHAIN_PKT_TYPE_REQUEST:{

dap_stream_ch_chain_pkt.h

@@ -25,6 +25,7 @@
 
 #include <stdint.h>
 #include <stddef.h>
+#include "dap_common.h"
 #include "dap_chain_common.h"
 #include "dap_chain_datum.h"
 #include "dap_chain_block.h"
@@ -46,6 +47,8 @@ typedef union dap_stream_ch_chain_request{
 
 typedef struct dap_stream_ch_chain_pkt_hdr{
     dap_chain_id_t chain_id;
+    dap_chain_net_id_t net_id;
+    dap_chain_shard_id_t shard_id;
     uint8_t type;
     uint8_t padding1[3];
     union{