Merge pull request #1443 from mesg-foundation/feature/e2e-event-test

e2e event test

e2e/api_test.go

@@ -57,5 +57,6 @@ func TestAPI(t *testing.T) {
 	t.Run("service", testService)
 	t.Run("ownership", testOwnership)
 	t.Run("instance", testInstance)
+	t.Run("event", testEvent)
 	t.Run("instance/delete", testDeleteInstance)
 }

e2e/event_test.go

@@ -0,0 +1,42 @@
+package main
+
+import (
+	"context"
+	"testing"
+
+	"github.com/mesg-foundation/engine/protobuf/acknowledgement"
+	pb "github.com/mesg-foundation/engine/protobuf/api"
+	"github.com/mesg-foundation/engine/protobuf/types"
+	"github.com/stretchr/testify/require"
+)
+
+func testEvent(t *testing.T) {
+	stream, err := client.EventClient.Stream(context.Background(), &pb.StreamEventRequest{
+		Filter: &pb.StreamEventRequest_Filter{},
+	})
+	require.NoError(t, err)
+	acknowledgement.WaitForStreamToBeReady(stream)
+
+	resp, err := client.EventClient.Create(context.Background(), &pb.CreateEventRequest{
+		InstanceHash: testInstanceHash,
+		Key:          "ping_ok",
+		Data: &types.Struct{
+			Fields: map[string]*types.Value{
+				"msg": {
+					Kind: &types.Value_StringValue{
+						StringValue: "foo",
+					},
+				},
+			},
+		},
+	})
+	require.NoError(t, err)
+
+	event, err := stream.Recv()
+	require.NoError(t, err)
+
+	require.Equal(t, resp.Hash, event.Hash)
+	require.Equal(t, testInstanceHash, event.InstanceHash)
+	require.Equal(t, "ping_ok", event.Key)
+	require.Equal(t, "foo", event.Data.Fields["msg"].GetStringValue())
+}