update

cmd/cart/pool-server.go

@@ -768,6 +768,17 @@ func (s *PoolServer) AdyenSessionHandler(w http.ResponseWriter, r *http.Request,
 
 }
 
+func (s *PoolServer) GetAnywhere(ctx context.Context, cartId cart.CartId) (*cart.CartGrain, error) {
+	id := uint64(cartId)
+	if host, isOnOtherHost := s.OwnerHost(id); isOnOtherHost {
+		grain := &cart.CartGrain{}
+
+		err := host.Get(ctx, id, grain)
+		return grain, err
+	}
+	return s.Get(ctx, id)
+}
+
 func (s *PoolServer) ApplyAnywhere(ctx context.Context, cartId cart.CartId, msgs ...proto.Message) error {
 	id := uint64(cartId)
 	if host, isOnOtherHost := s.OwnerHost(id); isOnOtherHost {

pkg/actor/grain_pool.go

@@ -37,6 +37,7 @@ type Host interface {
 	Name() string
 	Proxy(id uint64, w http.ResponseWriter, r *http.Request, customBody io.Reader) (bool, error)
 	Apply(ctx context.Context, id uint64, mutation ...proto.Message) (bool, error)
+	Get(ctx context.Context, id uint64, grain any) error
 	GetActorIds() []uint64
 	Close() error
 	Ping() bool

pkg/proxy/remotehost.go

@@ -131,7 +131,7 @@ func (h *RemoteHost[V]) Ping() bool {
 	return true
 }
 
-func (h *RemoteHost[V]) Get(ctx context.Context, id uint64, grain *V) error {
+func (h *RemoteHost[V]) Get(ctx context.Context, id uint64, grain any) error {
 	ctx, cancel := context.WithTimeout(ctx, 5*time.Second)
 	defer cancel()
 	reply, error := h.controlClient.Get(ctx, &messages.GetRequest{Id: id})