Fix server queries prefetch (#39)

* fix: update query cache finding for server queries to use proper key

* bump version

package.json

@@ -1,6 +1,6 @@
 {
 	"name": "trpc-svelte-query-adapter",
-	"version": "2.3.1",
+	"version": "2.3.2",
 	"description": "A simple adapter to use `@tanstack/svelte-query` with trpc, similar to `@trpc/react-query`.",
 	"keywords": [
 		"trpc",

src/index.ts

@@ -45,6 +45,7 @@ type HasMutate = { mutate: (...args: any[]) => any }
 type HasSubscribe = { subscribe: (...args: any[]) => any }
 type OnlyQueries<TClient> = Without<TClient, HasMutate | HasSubscribe>
 
+
 // createUtils
 const UtilsProcedureNames = {
 	client: 'client',
@@ -157,6 +158,7 @@ type CreateQueries<TClient, TError> = <TOpts extends CreateQueryOptionsForCreate
 	queriesCallback: (t: CreateQueriesRecord<OnlyQueries<TClient>, TError>) => readonly [...TOpts]
 ) => CreateQueriesResult<TOpts>
 
+
 // createServerQueries
 type CreateQueryOptionsForCreateServerQueries<TOutput, TError, TData> = CreateQueryOptionsForCreateQueries<TOutput, TError, TData> & {
 	ssr?: boolean
@@ -174,6 +176,7 @@ type CreateServerQueries<TClient, TError> = <TOpts extends CreateQueryOptionsFor
 	queriesCallback: (t: CreateServerQueriesRecord<OnlyQueries<TClient>, TError>) => readonly [...TOpts]
 ) => Promise<(queriesCallback?: (t: CreateQueriesRecord<OnlyQueries<TClient>, TError>, old: readonly [...TOpts]) => readonly [...TOpts]) => CreateQueriesResult<TOpts>>
 
+
 // Procedures
 const ProcedureNames = {
 	query: 'createQuery',
@@ -260,6 +263,8 @@ type AddQueryPropTypes<TClient, TError> = TClient extends Record<any, any> ? {
 	: TClient[K] extends HasSubscribe ? CreateSubscriptionProcedure<Parameters<TClient[K]['subscribe']>[0], GetSubscriptionOutput<Parameters<TClient[K]['subscribe']>[1]>, TError>
 	: GetQueryKey & AddQueryPropTypes<TClient[K], TError>
 } : TClient;
+
+
 // Implementation
 function createQueriesProxy(client: any) {
 	return new DeepProxy({}, {
@@ -592,7 +597,7 @@ const procedures: Record<PropertyKey,
 			return async (input: (...args: any[]) => any) => {
 				const queries = await Promise.all(
 					input(proxy).map(async (query: any) => {
-						const cache = queryClient.getQueryCache().find(query.queryKey);
+						const cache = queryClient.getQueryCache().find({ queryKey: query.queryKey });
 						const cacheNotFound = !cache?.state?.data;
 
 						if (query.ssr !== false && cacheNotFound) {
@@ -625,6 +630,7 @@ const procedures: Record<PropertyKey,
 		},
 	};
 
+
 // getQueryKey
 type QueryType = 'query' | 'infinite' | 'any';
 
@@ -669,7 +675,6 @@ type GetQueryKey<TInput = undefined> = [TInput] extends [undefined | void]
 	} & {}
 
 
-
 export function svelteQueryWrapper<TRouter extends AnyRouter>({
 	client,
 	queryClient,