Add wasm printMem and other debug functions

Signed-off-by: Sean Young <[email protected]>

Author: seanyoung

deploy/jobs/jobs_contracts.go

@@ -574,14 +574,17 @@ func deployFinalize(client *def.Client, tx payload.Payload, logger *logging.Logg
 }
 
 func logEvents(txe *exec.TxExecution, client *def.Client, logger *logging.Logger) {
-	if client.AllSpecs == nil {
-		return
-	}
-
 	for _, event := range txe.Events {
+		print := event.GetPrint()
+
+		if print != nil {
+			logger.InfoMsg("print", "address", print.Address.String(), "msg", string(print.Data))
+			continue
+		}
+
 		eventLog := event.GetLog()
 
-		if eventLog == nil {
+		if eventLog == nil || client.AllSpecs == nil {
 			continue
 		}
 

deploy/jobs/jobs_test_jobs.go

@@ -69,6 +69,8 @@ func QueryContractJob(query *def.QueryContract, do *def.DeployArgs, script *def.
 		return "", nil, err
 	}
 
+	logEvents(txe, client, logger)
+
 	result2 := util.GetReturnValue(query.Variables, logger)
 	// Finalize
 	if result2 != "" {

execution/exec/event.go

@@ -24,6 +24,7 @@ const (
 	TypeEnvelope
 	TypeEndTx
 	TypeEndBlock
+	TypePrint
 )
 
 var nameFromType = map[EventType]string{

execution/exec/event_sink.go

@@ -7,6 +7,7 @@ import (
 type EventSink interface {
 	Call(call *CallEvent, exception *errors.Exception) error
 	Log(log *LogEvent) error
+	Print(print *PrintEvent) error
 }
 
 type noopEventSink struct {
@@ -24,6 +25,10 @@ func (es *noopEventSink) Log(log *LogEvent) error {
 	return nil
 }
 
+func (es *noopEventSink) Print(print *PrintEvent) error {
+	return nil
+}
+
 type logFreeEventSink struct {
 	EventSink
 }

execution/exec/events.go

@@ -44,6 +44,17 @@ func (evs *Events) Log(log *LogEvent) error {
 	return nil
 }
 
+func (evs *Events) Print(print *PrintEvent) error {
+	evs.Append(&Event{
+		Header: &Header{
+			EventType: TypePrint,
+			EventID:   EventStringLogEvent(print.Address),
+		},
+		Print: print,
+	})
+	return nil
+}
+
 func (evs Events) CallTrace() string {
 	var calls []string
 	for _, ev := range evs {

execution/exec/exec.pb.go

@@ -35,6 +35,8 @@ func (ev *StreamEvent) EventType() EventType {
 		return TypeEndTx
 	case ev.EndBlock != nil:
 		return TypeEndBlock
+	case ev.Event.Print != nil:
+		return TypePrint
 	}
 	return TypeUnknown
 }

execution/exec/stream_event.go

@@ -128,6 +128,14 @@ func (txe *TxExecution) GovernAccount(governAccount *GovernAccountEvent, excepti
 	})
 }
 
+func (txe *TxExecution) Print(print *PrintEvent) error {
+	txe.Append(&Event{
+		Header: txe.Header(TypePrint, EventStringLogEvent(print.Address), nil),
+		Print:  print,
+	})
+	return nil
+}
+
 // Errors pushed to TxExecutions end up in merkle state so it is essential that they are deterministic and independent
 // of the code path taken to execution (e.g. replay takes a different path to that of normal consensus reactor so stack
 // traces may differ - as they may across architectures)

execution/exec/tx_execution.go

@@ -48,4 +48,8 @@ contract ewasm is E {
 	function test_events() public {
 		emit L(102, "Hello from wasm", true);
 	}
+
+	function test_print(int64 arg1, string arg2) public {
+		print("arg1:{} arg2:{}".format(arg1, arg2));
+	}
 }