dap_chain_cs_dag_pos.c

@@ -26,6 +26,7 @@
 #include "dap_common.h"
 #include "dap_string.h"
 #include "dap_strfuncs.h"
+#include "dap_chain_net.h"
 #include "dap_chain_cs.h"
 #include "dap_chain_cs_dag.h"
 #include "dap_chain_cs_dag_pos.h"
@@ -36,6 +37,7 @@
 
 typedef struct dap_chain_cs_dag_pos_pvt
 {
+    dap_chain_cert_t * events_sign_cert;
     char ** tokens_hold;
     uint64_t * tokens_hold_value;
     size_t tokens_hold_size;
@@ -45,7 +47,10 @@ typedef struct dap_chain_cs_dag_pos_pvt
 
 static void s_callback_delete(dap_chain_cs_dag_t * a_dag);
 static int s_callback_new(dap_chain_t * a_chain, dap_config_t * a_chain_cfg);
+static int s_callback_created(dap_chain_t * a_chain, dap_config_t *a_chain_cfg);
 static int s_callback_event_verify(dap_chain_cs_dag_t * a_dag, dap_chain_cs_dag_event_t * a_dag_event);
+static dap_chain_cs_dag_event_t * s_callback_event_create(dap_chain_cs_dag_t * a_dag, dap_chain_datum_t * a_datum,
+                                                          dap_chain_hash_fast_t * a_hashes, size_t a_hashes_count);
 
 /**
  * @brief dap_chain_cs_dag_pos_init
@@ -78,6 +83,7 @@ static int s_callback_new(dap_chain_t * a_chain, dap_config_t * a_chain_cfg)
     l_dag->_inheritor = l_pos;
     l_dag->callback_delete = s_callback_delete;
     l_dag->callback_cs_verify = s_callback_event_verify;
+    l_dag->callback_cs_event_create = s_callback_event_create;
     l_pos->_pvt = DAP_NEW_Z ( dap_chain_cs_dag_pos_pvt_t );
 
     dap_chain_cs_dag_pos_pvt_t * l_pos_pvt = PVT ( l_pos );
@@ -110,7 +116,7 @@ static int s_callback_new(dap_chain_t * a_chain, dap_config_t * a_chain_cfg)
              goto lb_err;
         }
     }
-
+    l_dag->chain->callback_created = s_callback_created;
     return 0;
 
 lb_err:
@@ -127,6 +133,30 @@ lb_err:
 
 }
 
+/**
+ * @brief s_callback_created
+ * @param a_chain
+ * @param a_chain_cfg
+ * @return
+ */
+static int s_callback_created(dap_chain_t * a_chain, dap_config_t *a_chain_net_cfg)
+{
+    dap_chain_cs_dag_t * l_dag = DAP_CHAIN_CS_DAG ( a_chain );
+    dap_chain_cs_dag_pos_t * l_pos = DAP_CHAIN_CS_DAG_POS( l_dag );
+
+    const char * l_events_sign_wallet = NULL;
+    if ( ( l_events_sign_wallet = dap_config_get_item_str(a_chain_net_cfg,"dag-pos","events-sign-wallet") ) != NULL ) {
+
+        if ( ( PVT(l_pos)->events_sign_cert = dap_chain_cert_find_by_name(l_events_sign_wallet)) == NULL ){
+            log_it(L_ERROR,"Can't load events sign certificate, name \"%s\" is wrong",l_events_sign_wallet);
+        }else
+            log_it(L_NOTICE,"Loaded \"%s\" certificate to sign pos event", l_events_sign_wallet);
+
+    }
+    return 0;
+}
+
+
 /**
  * @brief s_chain_cs_dag_callback_delete
  * @param a_dag
@@ -145,6 +175,33 @@ static void s_callback_delete(dap_chain_cs_dag_t * a_dag)
     }
 }
 
+/**
+ * @brief s_callback_event_create
+ * @param a_dag
+ * @param a_datum
+ * @param a_hashes
+ * @param a_hashes_count
+ * @return
+ */
+static dap_chain_cs_dag_event_t * s_callback_event_create(dap_chain_cs_dag_t * a_dag, dap_chain_datum_t * a_datum,
+                                                          dap_chain_hash_fast_t * a_hashes, size_t a_hashes_count)
+{
+    dap_return_val_if_fail(a_dag && a_dag->chain && DAP_CHAIN_CS_DAG_POS(a_dag) && a_datum, NULL);
+    dap_chain_net_t * l_net = dap_chain_net_by_name( a_dag->chain->net_name );
+    dap_chain_cs_dag_pos_t * l_pos = DAP_CHAIN_CS_DAG_POS(a_dag);
+
+    if( PVT(l_pos)->events_sign_cert == NULL) {
+        log_it(L_ERROR, "Can't sign event with events_sign_cert in [dag-poa] section");
+        return NULL;
+    }
+    if(a_datum || (a_hashes && a_hashes_count)) {
+        dap_chain_cs_dag_event_t * l_event = dap_chain_cs_dag_event_new(a_dag->chain->id, l_net->pub.cell_id, a_datum,
+        PVT(l_pos)->events_sign_cert->enc_key, a_hashes, a_hashes_count);
+        return l_event;
+    } else
+        return NULL;
+}
+
 /**
  * @brief s_callback_event_verify
  * @param a_dag
@@ -160,13 +217,29 @@ static int s_callback_event_verify(dap_chain_cs_dag_t * a_dag, dap_chain_cs_dag_
         return -3;
 
     if ( a_dag_event->header.signs_count == 1 ){
-        dap_chain_addr_t l_addr;
+        dap_chain_addr_t l_addr = { 0 };
         dap_chain_sign_t * l_sign = dap_chain_cs_dag_event_get_sign(a_dag_event,0);
         dap_enc_key_t * l_key = dap_chain_sign_to_enc_key( l_sign);
 
         dap_chain_addr_fill (&l_addr,l_key,&a_dag->chain->net_id );
         dap_enc_key_delete (l_key); // TODO cache all this operations to prevent useless memory copy ops
 
+        dap_chain_datum_t *l_datum = dap_chain_cs_dag_event_get_datum(a_dag_event);
+        // transaction include emission?
+        bool l_is_emit = false;
+        if(l_datum && l_datum->header.type_id == DAP_CHAIN_DATUM_TX) {
+            // transaction
+            dap_chain_datum_tx_t *l_tx = (dap_chain_datum_tx_t*) l_datum->data;
+            // find Token items
+            dap_list_t *l_list_tx_token = dap_chain_datum_tx_items_get(l_tx, TX_ITEM_TYPE_TOKEN, NULL);
+            if(l_list_tx_token)
+                l_is_emit = true;
+            dap_list_free(l_list_tx_token);
+        }
+        // if emission then the wallet can be with zero balance
+        if(l_is_emit)
+            return 0;
+
         for (size_t i =0; i <l_pos_pvt->tokens_hold_size; i++){
             if ( dap_chain_ledger_calc_balance ( a_dag->chain->ledger , &l_addr, l_pos_pvt->tokens_hold[i] ) >= l_pos_pvt->tokens_hold_value[i]  )
                 return 0;
@@ -175,5 +248,3 @@ static int s_callback_event_verify(dap_chain_cs_dag_t * a_dag, dap_chain_cs_dag_
     }else
        return -2; // Wrong signatures number
 }
-
-