Function trackMutation

packages/core/src/threads.ts:1251–1292

(
    dispatchAction:
      | ReturnType<typeof threadAdapterEvents.renameRequested>
      | ReturnType<typeof threadAdapterEvents.archiveRequested>
      | ReturnType<typeof threadAdapterEvents.unarchiveRequested>
      | ReturnType<typeof threadAdapterEvents.deleteRequested>,
  )

  });

  function trackMutation(
    dispatchAction:
      | ReturnType<typeof threadAdapterEvents.renameRequested>
      | ReturnType<typeof threadAdapterEvents.archiveRequested>
      | ReturnType<typeof threadAdapterEvents.unarchiveRequested>
      | ReturnType<typeof threadAdapterEvents.deleteRequested>,
  ): Promise<void> {
    const completion$ = merge(
      store.actions$.pipe(
        ofType(threadRestEvents.mutationFinished),
        filter(
          (action) => action.outcome.requestId === dispatchAction.requestId,
        ),
        map((action) => action.outcome),
      ),
      store.actions$.pipe(
        ofType(threadAdapterEvents.stopped),
        map(
          () =>
            ({
              requestId: dispatchAction.requestId,
              sessionId: store.getState().sessionId,
              ok: false,
              error: new Error(
                "Thread store stopped before mutation completed",
              ),
            }) satisfies MutationOutcome,
        ),
      ),
    ).pipe(take(1));

    const resultPromise = firstValueFrom(completion$).then((outcome) => {
      if (outcome.ok) {
        return;
      }

      throw outcome.error;
    });

    store.dispatch(dispatchAction);
    return resultPromise;
  }

  // Surface mutation rejections to the optional environment callback. The
  // reducer has already applied any delete rollback by the time this fires