self-healing: finalize verify->commit flow and hash assertions

Author: j-rafique

gen/supernode/self_healing.pb.go

@@ -45,6 +45,27 @@
         }
       }
     },
+    "supernodeCommitSelfHealingResponse": {
+      "type": "object",
+      "properties": {
+        "challengeId": {
+          "type": "string"
+        },
+        "epochId": {
+          "type": "string",
+          "format": "uint64"
+        },
+        "recipientId": {
+          "type": "string"
+        },
+        "stored": {
+          "type": "boolean"
+        },
+        "error": {
+          "type": "string"
+        }
+      }
+    },
     "supernodeRequestSelfHealingResponse": {
       "type": "object",
       "properties": {

gen/supernode/self_healing.swagger.json

@@ -7,6 +7,7 @@ option go_package = "github.com/LumeraProtocol/supernode/v2/gen/supernode";
 service SelfHealingService {
   rpc RequestSelfHealing(RequestSelfHealingRequest) returns (RequestSelfHealingResponse) {}
   rpc VerifySelfHealing(VerifySelfHealingRequest) returns (VerifySelfHealingResponse) {}
+  rpc CommitSelfHealing(CommitSelfHealingRequest) returns (CommitSelfHealingResponse) {}
 }
 
 message RequestSelfHealingRequest {
@@ -17,6 +18,7 @@ message RequestSelfHealingRequest {
   string challenger_id = 4;
   string recipient_id = 5;
   repeated string observer_ids = 6;
+  string action_id = 7;
 }
 
 message RequestSelfHealingResponse {
@@ -38,6 +40,7 @@ message VerifySelfHealingRequest {
   string recipient_id = 4;
   string reconstructed_hash_hex = 5;
   string observer_id = 6;
+  string action_id = 7;
 }
 
 message VerifySelfHealingResponse {
@@ -47,3 +50,21 @@ message VerifySelfHealingResponse {
   bool ok = 4;
   string error = 5;
 }
+
+message CommitSelfHealingRequest {
+  string challenge_id = 1;
+  uint64 epoch_id = 2;
+
+  string file_key = 3;
+  string action_id = 4;
+  string challenger_id = 5;
+  string recipient_id = 6;
+}
+
+message CommitSelfHealingResponse {
+  string challenge_id = 1;
+  uint64 epoch_id = 2;
+  string recipient_id = 3;
+  bool stored = 4;
+  string error = 5;
+}

gen/supernode/self_healing_grpc.pb.go

@@ -2,6 +2,7 @@ package cascade
 
 import (
 	"context"
+	"encoding/hex"
 	"fmt"
 	"sort"
 	"strings"
@@ -13,14 +14,16 @@ import (
 )
 
 type RecoveryReseedRequest struct {
-	ActionID string
+	ActionID         string
+	PersistArtifacts *bool
 }
 
 type RecoveryReseedResult struct {
 	ActionID             string
 	DownloadEvents       int
 	DownloadLastEvent    string
 	DecodeCleanupError   string
+	ReconstructedHashHex string
 	RQIC                 uint64
 	RQMax                uint64
 	DataHashVerified     bool
@@ -114,8 +117,13 @@ func (task *CascadeRegistrationTask) RecoveryReseed(ctx context.Context, req *Re
 	if err := cascadekit.VerifyB64DataHash(fileHash, meta.DataHash); err != nil {
 		return result, task.wrapErr(ctx, "decoded file hash does not match action metadata", err, fields)
 	}
+	result.ReconstructedHashHex = hex.EncodeToString(fileHash)
 	result.DataHashVerified = true
 
+	if !shouldPersistArtifacts(req) {
+		return result, nil
+	}
+
 	encodeResult, err := task.encodeInput(ctx, actionID, decodeFilePath, fields)
 	if err != nil {
 		return result, err
@@ -143,6 +151,13 @@ func (task *CascadeRegistrationTask) RecoveryReseed(ctx context.Context, req *Re
 	return result, nil
 }
 
+func shouldPersistArtifacts(req *RecoveryReseedRequest) bool {
+	if req == nil || req.PersistArtifacts == nil {
+		return true
+	}
+	return *req.PersistArtifacts
+}
+
 func symbolIDsFromLayout(layout codec.Layout) []string {
 	seen := make(map[string]struct{}, 1024)
 	for _, block := range layout.Blocks {