Function makeClient

packages/vue/src/makeClient.ts:727–1277

(
  // global, but only accessible after startup has completed
  getBaseMrt: () => ManagedRuntime.ManagedRuntime<RT_ | Mix, never>,
  clientFor_: ReturnType<typeof ApiClientFactory["makeFor"]>,
  rtHooks: Layer.Layer<RTHooks, never, Mix>,
  options?: MakeClientOptions
)

      invalidateSoft(keys).pipe(
        Effect.provideService(Reactivity.Reactivity, getReactivity())
      )
  }
}

export const makeClient = <RT_, RTHooks>(
  // global, but only accessible after startup has completed
  getBaseMrt: () => ManagedRuntime.ManagedRuntime<RT_ | Mix, never>,
  clientFor_: ReturnType<typeof ApiClientFactory["makeFor"]>,
  rtHooks: Layer.Layer<RTHooks, never, Mix>,
  options?: MakeClientOptions
) => {
  type RT = RT_ | Mix
  const getBaseRt = () => managedRuntimeRt(getBaseMrt())
  const makeCommand = makeUseCommand<RT, RTHooks>(rtHooks)
  let cmd: Effect.Success<typeof makeCommand>
  const useCommand = () => cmd ??= getBaseMrt().runSync(makeCommand)

  // one AtomRuntime for the query engine, built lazily from the live app context;
  // shares the ManagedRuntime memoMap so layers + Reactivity are the same instances.
  let atomRt: AtomClientRuntime | undefined
  const getAtomRt =
    () => (atomRt ??= makeAtomClientRuntime(() => Layer.succeedContext(getBaseRt()), getBaseMrt().memoMap))

  const legacyQueryEngine = options?.legacyQueryEngine ?? "tanstack"
  let tanstackQueryClient: ReturnType<typeof makeTanstackQueryClient> | undefined
  const getTanstackQueryClient = () => tanstackQueryClient ??= makeTanstackQueryClient()
  const atomInvalidator = makeResolvedAtomQueryInvalidator(getBaseRt)
  const queryInvalidator = legacyQueryEngine === "tanstack"
    ? combineQueryInvalidators(atomInvalidator, makeTanstackQueryInvalidator(getTanstackQueryClient()))
    : atomInvalidator
  setQueryCacheUpdater(
    legacyQueryEngine === "tanstack"
      ? combineQueryCacheUpdaters(
        makeTanstackQueryCacheUpdater(getTanstackQueryClient()),
        optionalAtomQueryCacheUpdater
      )
      : atomQueryCacheUpdater
  )

  let m: ReturnType<typeof useMutationInt>
  const useMutation = () => m ??= useMutationInt(queryInvalidator)

  let sm2: ReturnType<typeof makeStreamMutation2>
  const useStreamMutation2 = () => sm2 ??= makeStreamMutation2(queryInvalidator)

  const legacyUseQuery = legacyQueryEngine === "tanstack"
    ? makeTanstackQuery(getBaseRt, getTanstackQueryClient())
    : undefined
  const query = new QueryImpl(getBaseRt, getAtomRt, legacyUseQuery)
  const useQuery = query.useQuery
  const useQueryNew = query.useQueryNew
  const useQueryAtom = query.useQueryAtom
  const useQueryFamily = query.useQueryFamily
  const useSuspenseQuery = query.useSuspenseQuery
  const useSuspenseQueryNew = query.useSuspenseQueryNew
  const useStreamQuery = query.useStreamQuery
  const useStreamQueryFamily = query.useStreamQueryFamily
  const useStreamQueryAtom = query.useStreamQueryAtom