Feat. Use ctx.state

Author: sleipnir

example/joe.py

@@ -3,7 +3,6 @@
 Licensed under the Apache License, Version 2.0.
 """
 from domain.domain_pb2 import JoeState, 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
@@ -12,15 +11,18 @@
 from spawn.eigr.functions.actors.api.workflows.broadcast import Broadcast
 from spawn.eigr.functions.actors.api.workflows.effect import Effect
 
-
 actor = Actor(settings=ActorSettings(name="joe", stateful=True))
 
 
 @actor.timer_action(every=1000)
 def hi(ctx: Context) -> Value:
-    print("Context {}".format(ctx))
-    new_state = JoeState()
-    new_state.languages.append("portuguese")
+    new_state = None
+    if not ctx.state:
+        new_state = JoeState()
+        new_state.languages.append("portuguese")
+    else:
+        new_state = ctx.state
+
     return Value()\
         .of("test")\
         .state(new_state)\

example/spawn_example.py

@@ -13,4 +13,3 @@
     spawn = Spawn()
     spawn.port(8091).proxy_port(9003).actor_system(
         "spawn-system").add_actor(joe_actor).start()
-#    spawn.invoke("vijay", "setLanguage", request, Reply)

spawn/eigr/functions/actors/internal/controller.py

@@ -58,13 +58,14 @@
 
 
 def get_payload(input):
-    input_type: str = input.payload.type_url
+    print(input)
+    input_type: str = input.type_url
     if input_type.startswith(TYPE_URL_PREFIX):
         input_type = input_type[len(TYPE_URL_PREFIX):]
     input_class = _sym_db.GetSymbol(input_type)
-    input = input_class()
-    input.ParseFromString(input.payload.value)
-    return input
+    result = input_class()
+    result.ParseFromString(input.value)
+    return result
 
 
 def pack(input):
@@ -135,10 +136,13 @@ def handle_invoke(self, data) -> ActorInvocationResponse:
         handler = ActorHandler(entity)
         current_context = actor_invocation.current_context
 
+        state = None if current_context.state == None else get_payload(
+            current_context.state)
+
         input = None if actor_invocation.WhichOneof(
             "payload") == "noop" else get_payload(actor_invocation.value)
 
-        ctx = ActorContext(state=None, caller=actor_invocation.caller.name,
+        ctx = ActorContext(state=state, caller=actor_invocation.caller.name,
                            metadata=current_context.metadata, tags=current_context.tags)
 
         result = handler.handle_action(