Function buildInvalidateCache

packages/vue/src/mutate.ts:265–345

(
  self: { id: string; options?: ClientForOptions; disableQueryInvalidation?: boolean },
  queryInvalidation: MutationOptionsBase["queryInvalidation"] | undefined,
  queryInvalidator: QueryInvalidator<RInvalidator>
)

              })
            )
          )
        )
      )

  const act = (...args: Args) => runStream(handler(...args))

  return tuple(computed(() => state.value), act)
}

const buildInvalidateCache = <RInvalidator>(
  self: { id: string; options?: ClientForOptions; disableQueryInvalidation?: boolean },
  queryInvalidation: MutationOptionsBase["queryInvalidation"] | undefined,
  queryInvalidator: QueryInvalidator<RInvalidator>
) => {
  // Concrete reactivity keys to invalidate: a raw query key, one derived from an `{ id }`
  // entry, or a compatibility `{ filters: { queryKey } }` entry.
  // Predicate-only `{ filters }` entries have no exact-key reactivity equivalent and throw.
  const getClientInvalidationKeys = (
    input: unknown,
    output: Exit.Exit<unknown, unknown>
  ): ReadonlyArray<ReadonlyArray<unknown>> => {
    const queryKey = getQueryKey(self)

    if (queryInvalidation) {
      const keys: Array<ReadonlyArray<unknown>> = []
      for (const entry of queryInvalidation(queryKey, self.id, input, output)) {
        if (isQueryKey(entry)) {
          keys.push(entry)
          continue
        }
        if ("id" in entry) {
          keys.push(makeQueryKey(entry.options ? { id: entry.id, options: entry.options } : { id: entry.id }))
          continue
        }
        const filterQueryKey = queryKeyFromFilters(entry)
        if (filterQueryKey !== undefined) {
          keys.push(filterQueryKey)
          continue
        }
        throw new Error("Unsupported query invalidation filter: only filters.queryKey is supported")
      }
      return keys
    }

    // No manual `invalidatesQueries`: contribute nothing. Invalidation rides entirely on the
    // repository-derived write-dependencies (plus any server-provided keys) — there is no default
    // namespace invalidation of the command's own resource.
    return []
  }

  const invalidateCache = (
    input: unknown,
    output: Exit.Exit<unknown, unknown>,
    serverKeys: ReadonlyArray<InvalidationKey>,
    writeDependencies: DataDependencies.DataDependencies = DataDependencies.empty()
  ) =>
    Effect.suspend(() => {
      if (self.disableQueryInvalidation) return Effect.void