From 7a2001907aa072448e254845df549510e8450613 Mon Sep 17 00:00:00 2001
From: Elias Arruda <eliasdarruda@gmail.com>
Date: Fri, 24 Jan 2025 17:57:58 -0300
Subject: [PATCH] forward and pipe with register ref fix

---
 lib/actors/actor/entity/invocation.ex | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/lib/actors/actor/entity/invocation.ex b/lib/actors/actor/entity/invocation.ex
index 896d6401..f31cba96 100644
--- a/lib/actors/actor/entity/invocation.ex
+++ b/lib/actors/actor/entity/invocation.ex
@@ -705,7 +705,7 @@ defmodule Actors.Actor.Entity.Invocation do
            payload: payload,
            workflow:
              %Workflow{
-               routing: {:pipe, %Pipe{actor: actor_name, action_name: cmd} = _pipe} = _workflow
+               routing: {:pipe, %Pipe{actor: actor_name, action_name: cmd} = pipe} = _workflow
              } = response
          },
          opts
@@ -717,6 +717,7 @@ defmodule Actors.Actor.Entity.Invocation do
         invocation = %InvocationRequest{
           system: %ActorSystem{name: system_name},
           actor: %Actor{id: %ActorId{name: actor_name, system: system_name}},
+          register_ref: pipe.register_ref,
           action_name: cmd,
           metadata: metadata,
           payload: payload,
@@ -755,7 +756,7 @@ defmodule Actors.Actor.Entity.Invocation do
            workflow:
              %Workflow{
                routing:
-                 {:forward, %Forward{actor: actor_name, action_name: cmd} = _pipe} = _workflow
+                 {:forward, %Forward{actor: actor_name, action_name: cmd} = forward} = _workflow
              } = response
          },
          opts
@@ -767,6 +768,7 @@ defmodule Actors.Actor.Entity.Invocation do
         invocation = %InvocationRequest{
           system: %ActorSystem{name: system_name},
           actor: %Actor{id: %ActorId{name: actor_name, system: system_name}},
+          register_ref: forward.register_ref,
           action_name: cmd,
           metadata: metadata,
           payload: payload,