Feat. Added sync invocation support

Author: sleipnir

example/domain/domain_pb2.py

@@ -2,7 +2,7 @@
 Copyright 2022 Eigr.
 Licensed under the Apache License, Version 2.0.
 """
-from domain.domain_pb2 import JoeState, Request, Reply
+from domain.domain_pb2 import State, Request, Reply
 from spawn.eigr.functions.actors.api.actor import Actor
 from spawn.eigr.functions.actors.api.settings import ActorSettings
 from spawn.eigr.functions.actors.api.context import Context
@@ -24,7 +24,7 @@ def hi(ctx: Context) -> Value:
     broadcast.value = request
 
     if not ctx.state:
-        new_state = JoeState()
+        new_state = State()
         new_state.languages.append("python")
     else:
         new_state = ctx.state
@@ -39,4 +39,7 @@ def hi(ctx: Context) -> Value:
 def set_language(request: Request, ctx: Context) -> Value:
     reply = Reply()
     reply.response = "erlang"
-    return Value().of(reply, ctx.state).reply()
+    print("Current State -> " + str(ctx.state))
+    new_state = State()
+    new_state.languages.append("python")
+    return Value().value(reply).state(new_state).reply()

example/joe.py

@@ -0,0 +1,15 @@
+syntax = "proto3";
+
+package domain;
+
+message State {
+  repeated string languages = 1;
+}
+
+message Request {
+  string language = 1;
+}
+
+message Reply {
+  string response = 1;
+}

example/protobuf/domain/domain.proto

@@ -4,6 +4,7 @@
 """
 from spawn.eigr.functions.actors.api.reference import ActorRef
 from spawn.eigr.functions.actors.api.sdk import Spawn
+
 from example.joe import actor as joe_actor
 from example.unnamed_actor import abstract
 from example.domain.domain_pb2 import Request
@@ -20,8 +21,9 @@
     mike_actor: ActorRef = Spawn.create_actor_ref(
         system="spawn-system",
         actor_name="mike",
-        parent="abs_actor",
-        state_revision=1
+        parent="abs_actor"
     )
 
-    # mike_actor.invoke(request)
+    (status, result) = mike_actor.invoke("setLanguage", request)
+    print("Invocation Result Status: " + status)
+    print("Invocation Result Value:  " + str(result.response))

example/protobuf/example/domain/domain.proto

@@ -2,7 +2,7 @@
 Copyright 2022 Eigr.
 Licensed under the Apache License, Version 2.0.
 """
-from domain.domain_pb2 import Request, Reply
+from domain.domain_pb2 import State, Request, Reply
 from spawn.eigr.functions.actors.api.actor import Actor
 from spawn.eigr.functions.actors.api.settings import ActorSettings, Kind
 from spawn.eigr.functions.actors.api.context import Context
@@ -16,4 +16,7 @@
 def set_language(request: Request, ctx: Context) -> Value:
     reply = Reply()
     reply.response = "erlang"
-    return Value().of(reply, ctx.state).reply()
+    print("Current State -> " + str(ctx.state))
+    new_state = State()
+    new_state.languages.append("python")
+    return Value().value(reply).state(new_state).reply()

example/spawn_example.py

@@ -5,7 +5,7 @@ set -o errexit
 set -o pipefail
 
 # follow the basic steps here: https://grpc.io/docs/tutorials/basic/python/
-protoc -I ../protobuf/ --python_out=../spawn eigr/functions/protocol/actors/actor.proto
-protoc -I ../protobuf/ --python_out=../spawn eigr/functions/protocol/actors/protocol.proto
+#protoc -I ../protobuf/ --python_out=../spawn eigr/functions/protocol/actors/actor.proto
+#protoc -I ../protobuf/ --python_out=../spawn eigr/functions/protocol/actors/protocol.proto
 
-#protoc -I ../example/protobuf/ --python_out=../example ../example/protobuf/domain/domain.proto
+protoc -I ../example/protobuf/ --python_out=../example ../example/protobuf/domain/domain.proto

example/unnamed_actor.py

@@ -1,29 +1,20 @@
 
 from spawn.eigr.functions.actors.internal.client import SpawnClient
+from spawn.eigr.functions.actors.internal.controller import pack, get_payload
 
 from spawn.eigr.functions.protocol.actors.actor_pb2 import (
     Actor,
     ActorId,
-    ActorState,
-    Metadata,
-    ActorSettings,
-    Action,
-    FixedTimerAction,
-    ActorSnapshotStrategy,
-    ActorDeactivationStrategy,
-    ActorSystem,
-    Kind,
-    Registry,
-    TimeoutStrategy,
+    ActorSystem
 )
 
 from spawn.eigr.functions.protocol.actors.protocol_pb2 import (
     SpawnRequest,
     SpawnResponse,
     InvocationRequest,
     InvocationResponse,
-    RegistrationRequest,
-    RegistrationResponse
+    RequestStatus,
+    Status
 )
 
 
@@ -52,5 +43,43 @@ def __init__(self, client: SpawnClient, system: str, actor: str, parent: str = N
             spawn(self.__spawn_client, self.actor_system,
                   self.actor_name, self.actor_parent, self.revision)
 
-    def invoke(self, request: any):
-        pass
+    def invoke(self, action: str, request: any = None):
+        req: InvocationRequest = self.__build_request(action, request)
+        resp: InvocationResponse = self.__spawn_client.invoke(
+            self.actor_system, self.actor_name, req)
+
+        return self.__build_result(resp)
+
+    def __build_request(self, action: str, request: any):
+        req: InvocationRequest = InvocationRequest()
+        system = ActorSystem()
+        system.name = self.actor_system
+
+        actor_id = ActorId()
+        actor_id.name = self.actor_name
+        actor_id.system = self.actor_system
+
+        actor = Actor()
+        actor.id.CopyFrom(actor_id)
+
+        req.system.CopyFrom(system)
+        req.actor.CopyFrom(actor)
+        req.action_name = action
+
+        if request != None:
+            req.value.CopyFrom(pack(request))
+
+        return req
+
+    def __build_result(self, resp: InvocationResponse) -> any:
+        sts: RequestStatus = resp.status
+
+        if sts.status == Status.OK:
+            output = None if resp.WhichOneof(
+                "payload") == "noop" else get_payload(resp.value)
+
+            return "ok", output
+        elif sts.status == Status.ACTOR_NOT_FOUND:
+            return "actor_not_found", None
+        else:
+            return "error", None

scripts/compile-pb.sh

@@ -26,7 +26,6 @@ def create_app(controller: ActorController):
 
     @app.route('/api/v1/actors/actions', methods=["POST"])
     def action():
-        print(request)
         data = request.data
 
         actor_invocation_response = controller.handle_invoke(data)

spawn/eigr/functions/actors/api/reference.py

@@ -88,6 +88,7 @@ def pipe(self, pipe: Pipe):
         return self
 
     def reply(self):
+        self.__reply_kind = ReplyKind.REPLY
         return self
 
     def noreply(self):