Add initial node support TCK implementation (cloudstateio#503)

.travis.yml

@@ -63,7 +63,7 @@ jobs:
     before_script:
     - sbt update
     - cd node-support && nvm install && nvm use && npm install && cd -
-    - cd samples/js-shopping-cart && nvm install && nvm use && npm install && cd -
+    - cd node-support/tck && nvm install && nvm use && npm install && cd -
     script:
     - sbt 'set concurrentRestrictions in Global += Tags.limitAll(1)' tck/it:test
 

cloudstate-operator/cmd/main.go

@@ -16,6 +16,7 @@ package main
 
 import (
 	"flag"
+	"github.com/cloudstateio/cloudstate/cloudstate-operator/pkg/listeners"
 	"os"
 	"time"
 
@@ -150,6 +151,7 @@ func main() {
 		ReconcileTimeout: reconcileTimeout,
 		OperatorConfig:   cfg,
 		Stores:           store,
+		Listener:         &listeners.NullStatefulServiceListener{},
 	}).SetupWithManager(mgr); err != nil {
 		setupLog.Error(err, "unable to create controller", "controller", "StatefulService")
 		os.Exit(1)

cloudstate-operator/pkg/controllers/statefulservice_controller.go

@@ -18,6 +18,7 @@ import (
 	"context"
 	"errors"
 	"fmt"
+	"github.com/cloudstateio/cloudstate/cloudstate-operator/pkg/listeners"
 	"time"
 
 	"github.com/cloudstateio/cloudstate/cloudstate-operator/pkg/config"
@@ -58,6 +59,7 @@ type StatefulServiceReconciler struct {
 	ReconcileTimeout time.Duration
 	OperatorConfig   *config.OperatorConfig
 	Stores           stores.Stores
+	Listener         listeners.StatefulServiceListener
 }
 
 // +kubebuilder:rbac:groups=cloudstate.io,resources=statefulservices,verbs=get;list;watch;create;update;patch;delete
@@ -144,6 +146,9 @@ func (r *StatefulServiceReconciler) Reconcile(req ctrl.Request) (ctrl.Result, er
 			log.Error(err, "Unable to create deployment")
 			return ctrl.Result{}, err
 		}
+		if err := r.Listener.DeploymentCreated(ctx, &service, desired); err != nil {
+			return ctrl.Result{}, err
+		}
 		log.Info("Created deployment")
 		return ctrl.Result{}, nil
 	}
@@ -159,6 +164,10 @@ func (r *StatefulServiceReconciler) Reconcile(req ctrl.Request) (ctrl.Result, er
 		return ctrl.Result{}, err
 	}
 
+	if err := r.Listener.DeploymentUpdated(ctx, &service, actual, desired); err != nil {
+		return ctrl.Result{}, err
+	}
+
 	log.Info("Updated deployment")
 	return ctrl.Result{}, nil
 }

cloudstate-operator/pkg/controllers/suite_test.go

@@ -17,6 +17,7 @@ package controllers
 import (
 	"context"
 	"fmt"
+	"github.com/cloudstateio/cloudstate/cloudstate-operator/pkg/listeners"
 	"path/filepath"
 	"testing"
 	"time"
@@ -166,6 +167,7 @@ func runController(ctx context.Context) chan struct{} {
 		ReconcileTimeout: 10 * time.Second,
 		OperatorConfig:   operatorConfig,
 		Stores:           multistore,
+		Listener:         &listeners.NullStatefulServiceListener{},
 	}).SetupWithManager(mgr)
 	Expect(err).ToNot(HaveOccurred(), "failed to setup statefulservice controller")
 

cloudstate-operator/pkg/listeners/statefulservice_listener.go

@@ -0,0 +1,25 @@
+package listeners
+
+import (
+	"context"
+	cloudstate "github.com/cloudstateio/cloudstate/cloudstate-operator/pkg/apis/v1alpha1"
+	appsv1 "k8s.io/api/apps/v1"
+)
+
+type StatefulServiceListener interface {
+	DeploymentCreated(ctx context.Context, service *cloudstate.StatefulService, created *appsv1.Deployment) error
+	DeploymentUpdated(ctx context.Context, service *cloudstate.StatefulService, old *appsv1.Deployment, new *appsv1.Deployment) error
+}
+
+type NullStatefulServiceListener struct {
+}
+
+var _ StatefulServiceListener = (*NullStatefulServiceListener)(nil)
+
+func (n *NullStatefulServiceListener) DeploymentCreated(ctx context.Context, service *cloudstate.StatefulService, created *appsv1.Deployment) error {
+	return nil
+}
+
+func (n *NullStatefulServiceListener) DeploymentUpdated(ctx context.Context, service *cloudstate.StatefulService, old *appsv1.Deployment, new *appsv1.Deployment) error {
+	return nil
+}

node-support/src/cloudstate.js

@@ -210,7 +210,9 @@ class CloudState {
         serviceVersion: this.options.serviceVersion,
         serviceRuntime: process.title + " " + process.version,
         supportLibraryName: packageInfo.name,
-        supportLibraryVersion: packageInfo.version
+        supportLibraryVersion: packageInfo.version,
+        protocolMajorVersion: 0,
+        protocolMinorVersion: 2
       }
     });
   }

node-support/tck/.gitignore

@@ -0,0 +1,3 @@
+/node_modules/
+/proto/
+/user-function.desc

node-support/tck/.npmrc

@@ -0,0 +1 @@
+engine-strict=true

node-support/tck/.nvmrc

@@ -0,0 +1 @@
+v12

node-support/tck/eventsourced.js

@@ -0,0 +1,87 @@
+/*
+ * Copyright 2019 Lightbend Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+const EventSourced = require("cloudstate").EventSourced;
+
+const tckModel = new EventSourced(
+  ["proto/eventsourced.proto"],
+  "cloudstate.tck.model.EventSourcedTckModel",
+  {
+    persistenceId: "event-sourced-tck-model",
+    snapshotEvery: 5
+  }
+);
+
+const Response = tckModel.lookupType("cloudstate.tck.model.Response")
+const Persisted = tckModel.lookupType("cloudstate.tck.model.Persisted")
+
+tckModel.initial = entityId => Persisted.create({ value: "" });
+
+tckModel.behavior = state => {
+  return {
+    commandHandlers: {
+      Process: process
+    },
+    eventHandlers: {
+      Persisted: persisted
+    }
+  };
+};
+
+function process(request, state, context) {
+  request.actions.forEach(action => {
+    if (action.emit) {
+      const event = Persisted.create({ value: action.emit.value });
+      context.emit(event);
+      // FIXME: events are not emitted immediately, so we also update the function local state directly for responses
+      state = persisted(event, state);
+    } else if (action.forward) {
+      context.thenForward(two.service.methods.Call, { id: action.forward.id });
+    } else if (action.effect) {
+      context.effect(two.service.methods.Call, { id: action.effect.id }, action.effect.synchronous);
+    } else if (action.fail) {
+      context.fail(action.fail.message);
+    }
+  });
+  return Response.create(state.value ? { message: state.value } : {});
+}
+
+function persisted(event, state) {
+  state.value += event.value;
+  return state;
+}
+
+const two = new EventSourced(
+  ["proto/eventsourced.proto"],
+  "cloudstate.tck.model.EventSourcedTwo"
+);
+
+two.initial = entityId => Persisted.create({ value: "" });
+
+two.behavior = state => {
+  return {
+    commandHandlers: {
+      Call: call
+    }
+  };
+};
+
+function call(request) {
+  return Response.create({});
+}
+
+module.exports.tckModel = tckModel;
+module.exports.two = two;

node-support/tck/index.js

@@ -0,0 +1,22 @@
+/*
+ * Copyright 2019 Lightbend Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+const CloudState = require("cloudstate").CloudState;
+const server = new CloudState();
+const eventSourced = require("./eventsourced.js");
+server.addEntity(eventSourced.tckModel);
+server.addEntity(eventSourced.two);
+server.start();