Add broadcast support

Author: sleipnir

example/joe.py

@@ -17,6 +17,11 @@
 @actor.timer_action(every=1000)
 def hi(ctx: Context) -> Value:
     new_state = None
+    broadcast = Broadcast()
+    broadcast.channel = "test"
+    broadcast.action_name = "setLanguage"
+    broadcast.value = Request()
+
     if not ctx.state:
         new_state = JoeState()
         new_state.languages.append("portuguese")
@@ -25,6 +30,7 @@ def hi(ctx: Context) -> Value:
 
     return Value()\
         .of("test")\
+        .broadcast(broadcast)\
         .state(new_state)\
         .reply()
 
@@ -33,7 +39,7 @@ def hi(ctx: Context) -> Value:
 def set_language(request: Request, ctx: Context) -> Value:
     return Value()\
         .of("test")\
-        .broadcast(Broadcast())\
+        .broadcast()\
         .effect(Effect())\
         .metada(Metadata())\
         .state({})\

spawn/eigr/functions/actors/api/workflows/broadcast.py

@@ -1,4 +1,9 @@
 
+from dataclasses import dataclass
+
+
+@dataclass
 class Broadcast:
-    def __init__(self):
-        pass
+    channel: str = None
+    action_name: str = None
+    value: any = None

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

@@ -36,6 +36,7 @@
     Noop,
     RegistrationRequest,
     ServiceInfo,
+    Broadcast
 )
 
 from google.protobuf import symbol_database as _symbol_database
@@ -100,9 +101,28 @@ def handle_response(system, actor_name, result):
     elif result.get_reply_kind == ReplyKind.REPLY:
         actor_invocation_response.value = pack(result.get_response())
 
+    if result.get_broadcast() != None:
+        value_broadcast = result.get_broadcast()
+        broadcast = handle_broadcast(value_broadcast)
+        actor_invocation_response.workflow.broadcast.CopyFrom(broadcast)
+
     return actor_invocation_response
 
 
+def handle_broadcast(value_broadcast):
+    broadcast = Broadcast()
+    broadcast.channel_group = value_broadcast.channel
+    broadcast.action_name = value_broadcast.action_name
+
+    if value_broadcast.value == None:
+        broadcast.noop = Noop()
+    else:
+        value = pack(value_broadcast.value)
+        broadcast.value.CopyFrom(value)
+
+    return broadcast
+
+
 class ActorController:
     _instance = None