(unfinished) messages

oasisprotocol · Dec 30, 2023 · 6fad4ad · 6fad4ad
1 parent 074327e
commit 6fad4ad
Show file tree

Hide file tree

Showing 2 changed files with 18 additions and 0 deletions.
diff --git a/storage/oasis/nodeapi/cobalt/convert.go b/storage/oasis/nodeapi/cobalt/convert.go
@@ -1,6 +1,7 @@
 package cobalt
 
 import (
+	"encoding/json"
 	"strings"
 
 	"github.com/oasisprotocol/oasis-core/go/common/cbor"
@@ -327,6 +328,18 @@ func convertEvent(e txResultsCobalt.Event) nodeapi.Event {
 					"err", err,
 				)
 			}
+			messagesRaw := make([]json.RawMessage, len(computeBody.Messages))
+			for i, message := range computeBody.Messages {
+				messageJSON, err := json.Marshal(message)
+				if err != nil {
+					logger.Error("convert event: roothash executor committed: compute body message error marshaling",
+						"event", e,
+						"message_index", i,
+						"err", err,
+					)
+				}
+				messagesRaw[i] = messageJSON
+			}
 			ret = nodeapi.Event{
 				RoothashExecutorCommitted: &nodeapi.ExecutorCommittedEvent{
 					RuntimeID: e.RootHash.RuntimeID,

diff --git a/storage/oasis/nodeapi/eden/convert.go b/storage/oasis/nodeapi/eden/convert.go
@@ -1,6 +1,7 @@
 package eden
 
 import (
+	"encoding/json"
 	"strings"
 
 	"github.com/oasisprotocol/oasis-core/go/common/cbor"
@@ -399,6 +400,10 @@ func convertEvent(e txResultsEden.Event) nodeapi.Event {
 	case e.RootHash != nil:
 		switch {
 		case e.RootHash.ExecutorCommitted != nil:
+			messagesRaw := make([]json.RawMessage, len(e.RootHash.ExecutorCommitted.Commit.Messages))
+			for i, message := range e.RootHash.ExecutorCommitted.Commit.Messages {
+				messagesRaw[i] = common.TryAsJSON(message)
+			}
 			ret = nodeapi.Event{
 				RoothashExecutorCommitted: &nodeapi.ExecutorCommittedEvent{
 					RuntimeID: e.RootHash.RuntimeID,