test(project): 🧪 echo integration

greataped/test/api_local_test.go

@@ -0,0 +1,7 @@
+package test
+
+import "testing"
+
+func Test_Local_Echo(t *testing.T) {
+	Run(t, apiLocal, echo)
+}

greataped/test/api_remote_test.go

@@ -0,0 +1,7 @@
+package test
+
+import "testing"
+
+func Test_Remote_Echo(t *testing.T) {
+	Run(t, apiRemote, echo)
+}

greataped/test/echo_test.go

@@ -0,0 +1,31 @@
+package test
+
+import (
+	"errors"
+
+	. "rail.town/infrastructure/components/api/protobuf"
+	. "rail.town/infrastructure/components/contracts"
+)
+
+func echo(api IApi) error {
+
+	// Echo
+	{
+		input := &EchoRequest{
+			Document: &Document{
+				Content: "{}",
+			},
+		}
+
+		output, err := api.Echo(input)
+		if err != nil {
+			return err
+		}
+
+		if output.Document.Content != input.Document.Content {
+			return errors.New("echo_failed")
+		}
+	}
+
+	return nil
+}

greataped/test/init_test.go

@@ -0,0 +1,72 @@
+package test
+
+import (
+	"os"
+	"testing"
+	"time"
+
+	"github.com/xeronith/diamante/analytics"
+	"github.com/xeronith/diamante/logging"
+	"github.com/xeronith/diamante/server"
+	"github.com/xeronith/diamante/settings"
+	"rail.town/infrastructure/components/api/handlers"
+	"rail.town/infrastructure/components/api/operations"
+	. "rail.town/infrastructure/components/constants"
+	. "rail.town/infrastructure/components/contracts"
+	"rail.town/infrastructure/components/core"
+	"rail.town/infrastructure/components/model/repository"
+	"rail.town/infrastructure/providers/outbound/email"
+	"rail.town/infrastructure/providers/outbound/sms"
+)
+
+var (
+	apiLocal, apiRemote IApi
+	remoteEndpoint      = "https://greatape.social"
+)
+
+func TestMain(main *testing.M) {
+	logger := logging.NewLogger(false)
+	logger.SetLevel(logging.LEVEL_SUPPRESS_SYS_COMP)
+	configuration := settings.NewTestConfiguration()
+	operationsFactory := operations.NewFactory()
+	handlersFactory := handlers.NewFactory()
+	measurementsProvider := analytics.NewInfluxDbProvider(configuration, logger)
+	emailProvider := email.NewProvider(logger)
+	smsProvider := sms.NewProvider(logger)
+
+	if testServer, err := server.New(configuration, operationsFactory, handlersFactory, OPCODES); err != nil {
+		logger.Fatal(err)
+	} else {
+		if err := repository.Initialize(configuration, logger); err != nil {
+			logger.Fatal(err)
+		}
+
+		if err := core.Initialize(configuration, logger); err != nil {
+			logger.Fatal(err)
+		}
+
+		testServer.Localizer().Register(Errors)
+		testServer.SetSecurityHandler(core.Conductor.IdentityManager())
+		testServer.SetMeasurementsProvider(measurementsProvider)
+		testServer.SetEmailProvider(emailProvider)
+		testServer.SetSMSProvider(smsProvider)
+
+		go testServer.Start()
+
+		apiLocal = core.NewApi(testServer.PassiveEndpoint(), logger)
+		apiRemote = core.NewApi(remoteEndpoint, logger)
+
+		os.Exit(main.Run())
+	}
+}
+
+func Run(t *testing.T, api IApi, f func(IApi) error) {
+	defer func() {
+		delay := time.Millisecond * 50
+		time.Sleep(repository.AUTO_FLUSH_DURATION + delay)
+	}()
+
+	if err := f(api); err != nil {
+		t.Fatal(err)
+	}
+}