Merge branch 'main' into dependabot/npm_and_yarn/vite-6.3.6

Author: DTCurrie

.changeset/cold-beans-sin.md

@@ -0,0 +1,5 @@
+---
+'@viamrobotics/svelte-sdk': patch
+---
+
+Export streamQueryKey factory to help with query management

.changeset/polite-candies-watch.md

@@ -0,0 +1,5 @@
+---
+'@viamrobotics/svelte-sdk': patch
+---
+
+Fix create-resource-stream params"

src/lib/hooks/create-resource-stream.svelte.ts

@@ -22,12 +22,27 @@ export type StreamItemType<T> = T extends (
 interface QueryOptions {
   // enabled defaults to true if unspecified
   enabled?: boolean;
+  // refetchMode defaults to 'reset' if unspecified
   refetchMode?: 'append' | 'reset' | 'replace';
-  maxChunks?: number;
 }
 
 type QueryResult<U> = QueryObserverResult<U[], Error>;
 
+export const streamQueryKey = (
+  partID: string,
+  name: string | undefined,
+  methodName: string,
+  args?: QueryOptions | unknown
+) => [
+  'viam-svelte-sdk',
+  'partID',
+  partID,
+  'resource',
+  name,
+  methodName,
+  ...(args ? [args] : []),
+];
+
 export const createResourceStream = <T extends Resource, K extends keyof T>(
   client: { current: T | undefined },
   method: K,
@@ -54,15 +69,9 @@ export const createResourceStream = <T extends Resource, K extends keyof T>(
   const _args = $derived(typeof args === 'function' ? args() : args);
   const name = $derived(client.current?.name);
   const methodName = $derived(String(method));
-  const queryKey = $derived([
-    'viam-svelte-sdk',
-    'partID',
-    (client.current as T & { partID: string })?.partID,
-    'resource',
-    name,
-    methodName,
-    ...(_args ? [_args] : []),
-  ]);
+  const refetchMode = $derived(_options?.refetchMode ?? 'reset');
+  const partID = $derived((client.current as T & { partID: string })?.partID);
+  const queryKey = $derived(streamQueryKey(partID, name, methodName, _args));
 
   function processStream() {
     const clientFunc = client.current?.[method];
@@ -97,7 +106,7 @@ export const createResourceStream = <T extends Resource, K extends keyof T>(
       enabled: client.current !== undefined && _options?.enabled !== false,
       queryFn: streamedQuery<StreamItemType<T[K]>>({
         streamFn: processStream,
-        ..._options,
+        refetchMode,
       }),
     })
   );

src/lib/index.ts

@@ -16,7 +16,10 @@ export { createRobotMutation } from './hooks/create-robot-mutation.svelte';
 export { createResourceClient } from './hooks/create-resource-client.svelte';
 export { createResourceQuery } from './hooks/create-resource-query.svelte';
 export { createResourceMutation } from './hooks/create-resource-mutation.svelte';
-export { createResourceStream } from './hooks/create-resource-stream.svelte';
+export {
+  createResourceStream,
+  streamQueryKey,
+} from './hooks/create-resource-stream.svelte';
 export { createStreamClient } from './hooks/create-stream-client.svelte';
 
 export { useMachineStatus } from './hooks/machine-status.svelte';