Use protobuf marshal/unmarshal in execution database

database/execution_db.go

@@ -1,10 +1,10 @@
 package database
 
 import (
-	"encoding/json"
 	"errors"
 	"io"
 
+	"github.com/gogo/protobuf/proto"
 	"github.com/mesg-foundation/engine/execution"
 	"github.com/mesg-foundation/engine/hash"
 	"github.com/syndtr/goleveldb/leveldb"
@@ -100,7 +100,7 @@ func executionFind(db leveldbTxDB, executionHash hash.Hash) (*execution.Executio
 		return nil, err
 	}
 	var execution execution.Execution
-	if err := json.Unmarshal(data, &execution); err != nil {
+	if err := proto.Unmarshal(data, &execution); err != nil {
 		return nil, err
 	}
 	return &execution, nil
@@ -112,7 +112,7 @@ func executionSave(db leveldbTxDB, execution *execution.Execution) error {
 	if len(execution.Hash) == 0 {
 		return errors.New("database: can't save execution without hash")
 	}
-	data, err := json.Marshal(execution)
+	data, err := proto.Marshal(execution)
 	if err != nil {
 		return err
 	}

protobuf/types/execution.proto

@@ -7,6 +7,7 @@ package types;
 option go_package = "github.com/mesg-foundation/engine/execution";
 
 option (gogoproto.goproto_getters_all) = false;
+option (gogoproto.equal_all) = true;
 
 // Status represents the status of a single execution.
 // Note that a valid execution must have only one status

sdk/execution/execution_test.go

@@ -100,7 +100,7 @@ func TestGet(t *testing.T) {
 	require.NoError(t, sdk.execDB.Save(exec))
 	got, err := sdk.Get(exec.Hash)
 	require.NoError(t, err)
-	require.Equal(t, exec, got)
+	require.True(t, exec.Equal(got))
 }
 
 func TestGetStream(t *testing.T) {

server/grpc/api/execution_test.go

@@ -28,7 +28,7 @@ func TestGet(t *testing.T) {
 
 	got, err := s.Get(context.Background(), &api.GetExecutionRequest{Hash: exec.Hash})
 	require.NoError(t, err)
-	require.Equal(t, got, exec)
+	require.True(t, got.Equal(exec))
 }
 
 func TestUpdate(t *testing.T) {