202 node reciepts collection

.golangci.yml

@@ -39,6 +39,9 @@ linters-settings:
   goimports:
     local-prefixes: github.com/zoobc/zoobc-core
   gocritic:
+    settings: 
+      hugeParam:
+        sizeThreshold: 512
     enabled-tags:
       - performance
       - style

ZooBC.postman_collection.json

@@ -1,90 +1,90 @@
 {
-	"info": {
-		"_postman_id": "e8cb55b1-5c13-4894-8106-52f4bf019eee",
-		"name": "ZooBC",
-		"schema": "https://schema.getpostman.com/json/collection/v2.1.0/collection.json"
-	},
-	"item": [
-		{
-			"name": "blocks",
-			"item": [
-				{
-					"name": "GetBlocks",
-					"request": {
-						"method": "GET",
-						"header": [],
-						"body": {
-							"mode": "raw",
-							"raw": ""
-						},
-						"url": {
-							"raw": "{{host}}/v1/block/GetBlocks?Limit=10&Height=0&Chaintype=0",
-							"host": [
-								"{{host}}"
-							],
-							"path": [
-								"v1",
-								"block",
-								"GetBlocks"
-							],
-							"query": [
-								{
-									"key": "Limit",
-									"value": "10"
-								},
-								{
-									"key": "Height",
-									"value": "0"
-								},
-								{
-									"key": "Chaintype",
-									"value": "0"
-								}
-							]
-						}
-					},
-					"response": []
-				},
-				{
-					"name": "GetBlock",
-					"request": {
-						"method": "GET",
-						"header": [],
-						"body": {
-							"mode": "raw",
-							"raw": ""
-						},
-						"url": {
-							"raw": "{{host}}/v1/block/GetBlock?ID=-8826204794314169398",
-							"host": [
-								"{{host}}"
-							],
-							"path": [
-								"v1",
-								"block",
-								"GetBlock"
-							],
-							"query": [
-								{
-									"key": "ID",
-									"value": "-8826204794314169398"
-								},
-								{
-									"key": "Height",
-									"value": "20",
-									"disabled": true
-								},
-								{
-									"key": "Chaintype",
-									"value": "0",
-									"disabled": true
-								}
-							]
-						}
-					},
-					"response": []
-				}
-			]
-		}
-	]
+  "info": {
+    "_postman_id": "e8cb55b1-5c13-4894-8106-52f4bf019eee",
+    "name": "ZooBC",
+    "schema": "https://schema.getpostman.com/json/collection/v2.1.0/collection.json"
+  },
+  "item": [
+    {
+      "name": "blocks",
+      "item": [
+        {
+          "name": "GetBlocks",
+          "request": {
+            "method": "GET",
+            "header": [],
+            "body": {
+              "mode": "raw",
+              "raw": ""
+            },
+            "url": {
+              "raw": "{{host}}/v1/block/GetBlocks?Limit=10&Height=0&Chaintype=0",
+              "host": [
+                "{{host}}"
+              ],
+              "path": [
+                "v1",
+                "block",
+                "GetBlocks"
+              ],
+              "query": [
+                {
+                  "key": "Limit",
+                  "value": "10"
+                },
+                {
+                  "key": "Height",
+                  "value": "0"
+                },
+                {
+                  "key": "Chaintype",
+                  "value": "0"
+                }
+              ]
+            }
+          },
+          "response": []
+        },
+        {
+          "name": "GetBlock",
+          "request": {
+            "method": "GET",
+            "header": [],
+            "body": {
+              "mode": "raw",
+              "raw": ""
+            },
+            "url": {
+              "raw": "{{host}}/v1/block/GetBlock?ID=-8826204794314169398",
+              "host": [
+                "{{host}}"
+              ],
+              "path": [
+                "v1",
+                "block",
+                "GetBlock"
+              ],
+              "query": [
+                {
+                  "key": "ID",
+                  "value": "-8826204794314169398"
+                },
+                {
+                  "key": "Height",
+                  "value": "20",
+                  "disabled": true
+                },
+                {
+                  "key": "Chaintype",
+                  "value": "0",
+                  "disabled": true
+                }
+              ]
+            }
+          },
+          "response": []
+        }
+      ]
+    }
+  ]
 }

api/handler/nodeHardwareHandler.go

@@ -2,7 +2,6 @@ package handler
 
 import (
 	"io"
-
 	"time"
 
 	"github.com/zoobc/zoobc-core/api/service"

common/constant/participationScore.go

@@ -3,9 +3,9 @@ package constant
 const (
 	// ScalarReceiptScore the converter score to avoid calculation in float number
 	ScalarReceiptScore float32 = 1000000
-	// LinkedReceiptScore the score for each receipt that proved have relation with prevoius published receipt via merkle root
+	// LinkedReceiptScore the score for each receipt that proved have relation with previous published receipt via merkle root
 	LinkedReceiptScore float32 = 2
-	// LinkedReceiptScore the score for each receipt that can't proved have relation with prevoius published receipt via merkle root
+	// LinkedReceiptScore the score for each receipt that can't proved have relation with previous published receipt via merkle root
 	UnlinkedReceiptScore float32 = 0.5
 	// MaxScoreChange the maximum score that node wll get
 	MaxScoreChange int64 = 10 * int64(ScalarReceiptScore)

common/constant/receipt.go

@@ -3,4 +3,5 @@ package constant
 const (
 	ReceiptDatumTypeBlock       = uint32(1)
 	ReceiptDatumTypeTransaction = uint32(2)
+	ReceiptBatchMaximum         = uint32(8) // 256 in production
 )

common/database/migration.go

@@ -3,7 +3,6 @@ package database
 import (
 	"fmt"
 
-	log "github.com/sirupsen/logrus"
 	"github.com/zoobc/zoobc-core/common/query"
 )
 
@@ -27,11 +26,9 @@ and initialize versions
 func (m *Migration) Init() error {
 
 	if m.Query != nil {
-		rows, _ := m.Query.ExecuteSelect("SELECT version FROM migration;", false)
-		if rows != nil {
-			defer rows.Close()
-			var version int
-			_ = rows.Scan(&version)
+		var version int
+		err := m.Query.ExecuteSelectRow("SELECT version FROM migration;").Scan(&version)
+		if err == nil {
 			m.CurrentVersion = &version
 		}
 
@@ -135,16 +132,36 @@ func (m *Migration) Init() error {
 			);`,
 			`
 			CREATE TABLE IF NOT EXISTS "node_receipt" (
-				"sender_public_key" BLOB, 
+				"sender_public_key" BLOB,
 				"recipient_public_key" BLOB,
 				"datum_type" INTEGER,
 				"datum_hash" BLOB,
 				"reference_block_height" INTEGER,
 				"reference_block_hash" BLOB,
-				"receipt_merkle_root" BLOB,
+				"rmr_linked" BLOB,
+				"recipient_signature" BLOB,
+				"rmr" BLOB,
+				"rmr_index" INTEGER
+			)
+			`,
+			`
+			CREATE TABLE IF NOT EXISTS "batch_receipt" (
+				"sender_public_key" BLOB,
+				"recipient_public_key" BLOB,
+				"datum_type" INTEGER,
+				"datum_hash" BLOB,
+				"reference_block_height" INTEGER,
+				"reference_block_hash" BLOB,
+				"rmr_linked" BLOB,
 				"recipient_signature" BLOB
 			)
 			`,
+			`
+			CREATE TABLE IF NOT EXISTS "merkle_tree" (
+				"id" BLOB,
+				"tree" BLOB
+			)
+			`,
 		}
 		return nil
 	}
@@ -160,29 +177,25 @@ func (m *Migration) Apply() error {
 
 	var (
 		migrations = m.Versions
+		err        error
 	)
 
 	if m.CurrentVersion != nil {
-		migrations = m.Versions[*m.CurrentVersion:]
+		migrations = m.Versions[*m.CurrentVersion+1:]
 	}
 
-	for version, query := range migrations {
-		var err error
-		version := version
-		err = m.Query.BeginTx()
-		if err != nil {
-			log.Warn(err)
-		}
+	for v, query := range migrations {
+		version := v
+		_ = m.Query.BeginTx()
 		err = m.Query.ExecuteTransaction(query)
 		if err != nil {
-			log.Warn(err)
+			return err
 		}
-
 		if m.CurrentVersion != nil {
 			err = m.Query.ExecuteTransaction(`UPDATE "migration"
-				SET "version" = ?, "created_date" = datetime('now');`, *m.CurrentVersion)
+				SET "version" = ?, "created_date" = datetime('now');`, *m.CurrentVersion+1)
 			if err != nil {
-				log.Warn(err)
+				return err
 			}
 		} else {
 			err = m.Query.ExecuteTransaction(`
@@ -194,13 +207,14 @@ func (m *Migration) Apply() error {
 					0,
 					datetime('now')
 				);
-				`)
+			`)
 			if err != nil {
-				log.Warn(err)
+				return err
 			}
 		}
-		err = m.Query.CommitTx()
+
 		m.CurrentVersion = &version
+		err := m.Query.CommitTx()
 		if err != nil {
 			return err
 		}