Function runInvalidationMatrix

packages/vue/test/dependencyInvalidation.test.ts:287–349

(engine: string, makeHarness: (repo: DataDependencies.DataDependency) => EngineHarness)

  const self = { id: "MatrixTs.List", handler: () => DataDependencies.read(queryRepo).pipe(Effect.as(++runs)) }
  const ctx = makeTanstackContext(queryClient)
  const [, , , handle] = ctx.run(() => useQuery(self as any)(ref(undefined) as any, {} as any)) as any
  return {
    queryFullKey: [...makeQueryKey(self), undefined],
    serverInvalidationKey: makeQueryKey(self),
    fetchInitial: () => Effect.runPromise(handle.refetch()),
    runs: () => runs,
    runCommand: (options, command) =>
      Effect.runPromise(invalidateQueries({ id: "MatrixTs.Save" }, options, invalidator)(command, { id: "x" })),
    dispose: () => ctx.dispose()
  }
}

const makeAtomHarness = (queryRepo: DataDependencies.DataDependency): EngineHarness => {
  const mrt = ManagedRuntime.make(Reactivity.layer)
  const baseContext = mrt.runSync(Effect.context<Reactivity.Reactivity>())
  const reactivity = Context.get(baseContext, Reactivity.Reactivity)
  const rt = makeAtomClientRuntime(
    () => Layer.succeedContext(baseContext) as Layer.Layer<any, never, never>,
    mrt.memoMap
  )
  const invalidator = {
    invalidateAndAwait: (keys: ReadonlyArray<ReadonlyArray<unknown>>) =>
      invalidateAndAwait(keys).pipe(Effect.provideService(Reactivity.Reactivity, reactivity))
  }
  let runs = 0
  const self = { id: "MatrixAtom.List", handler: () => DataDependencies.read(queryRepo).pipe(Effect.as(++runs)) }
  const atom = buildQueryFamily(rt as any, self as any)(undefined)
  const unmount = defaultRegistry.mount(atom)
  return {
    queryFullKey: [...makeQueryKey(self), undefined],
    serverInvalidationKey: makeQueryKey(self),
    fetchInitial: () => Effect.runPromise(awaitAtomResult(defaultRegistry, atom)),
    runs: () => runs,
    runCommand: (options, command) =>
      Effect.runPromise(
        invalidateQueries({ id: "MatrixAtom.Save" }, options, invalidator)(command, { id: "x" })
          .pipe(Effect.andThen(awaitAtomResult(defaultRegistry, atom).pipe(Effect.exit)))
      ),
    dispose: () => {
      unmount()
      clearQueryReadDependencies([...makeQueryKey(self), undefined])
    }
  }
}

const runInvalidationMatrix = (engine: string, makeHarness: (repo: DataDependencies.DataDependency) => EngineHarness) =>
  it(`${engine} engine e2e: invalidation source matrix`, async () => {
    const queryRepo = DataDependencies.repo(`${engine}MatrixRepo`)
    const otherRepo = DataDependencies.repo(`${engine}MatrixOther`)
    const h = makeHarness(queryRepo)
    const noop = Effect.succeed(undefined)

    const expectRefetch = async <A, E>(
      label: string,
      options: MutationOptionsBase | undefined,
      command: Effect.Effect<A, E>
    ) => {
      const before = h.runs()