Invoking Observable Actor in background with dynamic context

[kennetpostigo]

Hi, I have a machine that uses urql and fromObservable on the urql subscription that I want to invoke in the background of my machine that will emit events for my machine to handle.

I need the following:

1. The invocation to run in the backgroun and emit events to my machine
2. I only want the invocation to begin once the user has been set in context, otherwise the graphql query will err.
3. If the user changes I want to be able update the input for the invoked actor.

Does anyone know how to do this? At the moment the observable actor runs but doesn't wait for user to be set so it simply fails.

export const machine = setup({
  types: {
    context: {user: undefined, data: []} as {user: any, data: any[]},
    events: {} as
      | { type: 'INITIAL_DATA'; params: { user } }
      | { type: 'TICK'; data: any }
  },
  actions: {
    handleInitialData: assign(({ context, event }, params) => {
      return { user: event.params.user };
    }),
    handleTick: assign(({ context: ctx, event }, params) => {
      ...
    }),
  },
  guards: {
    isValidInitialData: ({ event }, params) => event.params.user != null,
  },
  actors: {
    userDataSubscription: fromObservable(({ input }) => {
      return pipe(
        client.subscription(UserDataSubscription, {
          input: {
            userId: input.userId,
            username: input?.username,
          },
        }),
        subscribe((result) => {
          if (result?.data?.userDataList) {
            return { type: 'TICK', data: result?.data?.userDataList };
          }
        }),
      );
    }),
  },
}).createMachine({
  id: 'my-machine',
  context: {
    user: undefined, 
    data: []
  },
  initial: 'waiting',
  invoke: {
    src: 'userDataSubscription',
    input: ({ context }) => ({
      userId: context.user?.id,
      username: context.user?.username,
    }),
  },
  states: {
    waiting: {
      on: {
        INITIAL_DATA: [
          {
            guard: { type: 'isValidInitialData' },
            target: 'active',
            actions: { type: 'handleInitialData' },
          },
          {
            target: 'waiting',
          },
        ],
      },
    },
    active: {
      on: {
        TICK: {
          target: 'active',
          actions: { type: 'handleTick' },
        },
      },
    },
  },
});