Merge pull request #381 from psteinroe/fix/return-input-from-mutations

fix/return input from mutations

.changeset/strong-sheep-laugh.md

@@ -0,0 +1,5 @@
+---
+"@supabase-cache-helpers/postgrest-core": patch
+---
+
+fix: return input from mutations without query so that cache updates still work

packages/postgrest-core/__tests__/insert-fetcher.spec.ts

@@ -76,7 +76,14 @@ describe('insert', () => {
         { username: `${testRunPrefix}-username-1` },
         { username: `${testRunPrefix}-username-2` },
       ]),
-    ).resolves.toEqual(null);
+    ).resolves.toEqual([
+      {
+        normalizedData: { username: `${testRunPrefix}-username-1` },
+      },
+      {
+        normalizedData: { username: `${testRunPrefix}-username-2` },
+      },
+    ]);
   });
 
   it('should support passing a query', async () => {

packages/postgrest-core/__tests__/update-fetcher.spec.ts

@@ -47,7 +47,12 @@ describe('update', () => {
       id: contact?.id,
       username: `${testRunPrefix}-username-2`,
     });
-    expect(updatedContact).toEqual(null);
+    expect(updatedContact).toEqual({
+      normalizedData: {
+        id: expect.anything(),
+        username: `${testRunPrefix}-username-2`,
+      },
+    });
     const { data } = await client
       .from('contact')
       .select('*')

packages/postgrest-core/__tests__/upsert-fetcher.spec.ts

@@ -27,7 +27,14 @@ describe('upsert', () => {
           { username: `${testRunPrefix}-username-2` },
         ],
       ),
-    ).resolves.toEqual(null);
+    ).resolves.toEqual([
+      {
+        normalizedData: { username: `${testRunPrefix}-username-1` },
+      },
+      {
+        normalizedData: { username: `${testRunPrefix}-username-2` },
+      },
+    ]);
   });
 
   it('should support passing a query', async () => {

packages/postgrest-core/src/insert-fetcher.ts

@@ -49,7 +49,7 @@ function buildInsertFetcher<
       );
     }
     await qb.insert(input as any).throwOnError();
-    return null;
+    return input.map((d) => ({ normalizedData: d as R }));
   };
 }
 

packages/postgrest-core/src/update-fetcher.ts

@@ -57,5 +57,5 @@ export const buildUpdateFetcher =
       return buildMutationFetcherResponse(data as R, { userQueryPaths, paths });
     }
     await filterBuilder.throwOnError().single();
-    return null;
+    return { normalizedData: input as R };
   };

packages/postgrest-core/src/upsert-fetcher.ts

@@ -51,5 +51,7 @@ export const buildUpsertFetcher =
     await qb
       .upsert(input as any) // todo fix type
       .throwOnError();
-    return null;
+    return input.map((d) => ({
+      normalizedData: d as R,
+    }));
   };

packages/postgrest-swr/__tests__/mutate/use-update-mutation.integration.spec.tsx

@@ -194,7 +194,7 @@ describe('useUpdateMutation', () => {
       const { trigger: update } = useUpdateMutation(
         client.from('contact'),
         ['id'],
-        'id',
+        null,
         {
           revalidateTables: [{ schema: 'public', table: 'contact_note' }],
           onSuccess: () => setSuccess(true),