support multi hash algorithm (#761)

Author: huangzhiran

service/apinode/api/http.go

@@ -3,6 +3,7 @@ package api
 import (
 	"bytes"
 	"crypto/ecdsa"
+	"crypto/sha256"
 	"encoding/json"
 	"fmt"
 	"io"
@@ -32,11 +33,12 @@ func newErrResp(err error) *errResp {
 }
 
 type CreateTaskReq struct {
-	Nonce          uint64   `json:"nonce"                      binding:"required"`
-	ProjectID      uint64   `json:"projectID"                  binding:"required"`
-	ProjectVersion string   `json:"projectVersion"`
-	Payloads       []string `json:"payloads"                   binding:"required"`
-	Signature      string   `json:"signature,omitempty"        binding:"required"`
+	Nonce          uint64   `json:"nonce"                        binding:"required"`
+	ProjectID      uint64   `json:"projectID"                    binding:"required"`
+	ProjectVersion string   `json:"projectVersion,omitempty"`
+	Payloads       []string `json:"payloads"                     binding:"required"`
+	HashAlgorithm  string   `json:"hashAlgorithm,omitempty"`
+	Signature      string   `json:"signature,omitempty"          binding:"required"`
 }
 
 type CreateTaskResp struct {
@@ -79,7 +81,7 @@ func (s *httpServer) createTask(c *gin.Context) {
 		c.JSON(http.StatusBadRequest, newErrResp(errors.Wrap(err, "failed to decode signature from hex format")))
 		return
 	}
-	pubKey, err := recoverPubkey(*req, sig)
+	pubKey, hashAlg, err := recoverPubkey(*req, sig)
 	if err != nil {
 		slog.Error("failed to recover public key", "error", err)
 		c.JSON(http.StatusBadRequest, newErrResp(errors.Wrap(err, "invalid signature; could not recover public key")))
@@ -126,6 +128,7 @@ func (s *httpServer) createTask(c *gin.Context) {
 			ProjectVersion: req.ProjectVersion,
 			Payloads:       payloadsJ,
 			Signature:      sig,
+			HashAlgorithm:  hashAlg,
 		},
 	); err != nil {
 		slog.Error("failed to create task to persistence layer", "error", err)
@@ -164,19 +167,32 @@ func (s *httpServer) createTask(c *gin.Context) {
 	})
 }
 
-func recoverPubkey(req CreateTaskReq, sig []byte) (*ecdsa.PublicKey, error) {
+func recoverPubkey(req CreateTaskReq, sig []byte) (*ecdsa.PublicKey, string, error) {
 	req.Signature = ""
 	reqJson, err := json.Marshal(req)
 	if err != nil {
-		return nil, errors.Wrap(err, "failed to marshal request into json format")
+		return nil, "", errors.Wrap(err, "failed to marshal request into json format")
 	}
 
-	h := crypto.Keccak256Hash(reqJson)
-	sigpk, err := crypto.SigToPub(h.Bytes(), sig)
+	var alg string
+	var h []byte
+
+	switch req.HashAlgorithm {
+	case "sha256":
+		hash := sha256.New()
+		hash.Write(reqJson)
+		h = hash.Sum(nil)
+		alg = "sha256"
+	default:
+		h = crypto.Keccak256Hash(reqJson).Bytes()
+		alg = "keccak256"
+	}
+
+	sigpk, err := crypto.SigToPub(h, sig)
 	if err != nil {
-		return nil, errors.Wrap(err, "failed to recover public key from signature")
+		return nil, "", errors.Wrap(err, "failed to recover public key from signature")
 	}
-	return sigpk, nil
+	return sigpk, alg, nil
 }
 
 func (s *httpServer) getProverTaskState(taskID string) (*StateLog, error) {

service/apinode/db/clickhouse.go

@@ -19,6 +19,7 @@ type Task struct {
 	ProjectVersion string    `ch:"project_version"`
 	Payloads       []byte    `ch:"payloads"`
 	Signature      []byte    `ch:"signature"`
+	HashAlgorithm  string    `ch:"hash_algorithm"`
 	CreatedAt      time.Time `ch:"create_at"`
 }
 
@@ -44,21 +45,22 @@ func (p *DB) FetchTask(taskID common.Hash) (*Task, error) {
 
 func migrateCH(conn driver.Conn) error {
 	err := conn.Exec(context.Background(), `
-CREATE TABLE IF NOT EXISTS w3bstream_tasks
-(
-    task_id Array(UInt8) NOT NULL,
-    device_id Array(UInt8) NOT NULL,
-    nonce UInt64 NOT NULL,
-    project_id UInt64 NOT NULL,
-    project_version String NOT NULL,
-    payloads Array(UInt8) NOT NULL,
-    signature Array(UInt8) NOT NULL,
-	create_at DateTime NOT NULL
-)
-ENGINE = ReplacingMergeTree()
-PRIMARY KEY task_id
-ORDER BY task_id
-`)
+        CREATE TABLE IF NOT EXISTS w3bstream_tasks
+        (
+            task_id Array(UInt8) NOT NULL,
+            device_id Array(UInt8) NOT NULL,
+            nonce UInt64 NOT NULL,
+            project_id UInt64 NOT NULL,
+            project_version String NOT NULL,
+            payloads Array(UInt8) NOT NULL,
+            signature Array(UInt8) NOT NULL,
+        	hash_algorithm String NOT NULL,
+        	create_at DateTime NOT NULL
+        )
+        ENGINE = ReplacingMergeTree()
+        PRIMARY KEY task_id
+        ORDER BY task_id`,
+	)
 	return errors.Wrap(err, "failed to create clickhouse table")
 }