feat(datastores): allow listenQuery to have separate listen and fetch…

… queries

Listeners go into a mode where if the expression cannot be parsed to an optimizible filter,
it will emit events for every document. This can cause quite significantly more refetches
to be performed compared to the intended listener that was set up

packages/sanity/src/datastores/document/document-store.ts

@@ -31,7 +31,11 @@ function getIdPairFromPublished(publishedId: string): IdPair {
 export interface DocumentStore {
   checkoutPair: (idPair: IdPair) => Pair
   initialValue: (opts: InitialValueOptions) => Observable<InitialValueMsg>
-  listenQuery: (query: string, params: QueryParams, options: ListenQueryOptions) => Observable<any>
+  listenQuery: (
+    query: string | {fetch: string; listen: string},
+    params: QueryParams,
+    options: ListenQueryOptions
+  ) => Observable<any>
   resolveTypeForDocument: (id: string, specifiedType?: string) => Observable<string>
 
   pair: {

packages/sanity/src/datastores/document/listenQuery.ts

@@ -51,13 +51,16 @@ function isWelcomeEvent(
 // todo: optimize by patching collection in-place
 export const listenQuery = (
   client: SanityClient,
-  query: string,
+  query: string | {fetch: string; listen: string},
   params: ListenQueryParams = {},
   options: ListenQueryOptions = {}
 ) => {
-  const fetchOnce$ = fetch(client, query, params, options)
+  const fetchQuery = typeof query === 'string' ? query : query.fetch
+  const listenerQuery = typeof query === 'string' ? query : query.listen
+
+  const fetchOnce$ = fetch(client, fetchQuery, params, options)
 
-  const events$ = listen(client, query, params, options).pipe(
+  const events$ = listen(client, listenerQuery, params, options).pipe(
     mergeMap((ev, i) => {
       const isFirst = i === 0
       if (isFirst && !isWelcomeEvent(ev)) {