fix: local collection manual transactions

Signed-off-by: Marc MacLeod <marbemac+gh@gmail.com>

Author: marbemac

.changeset/metal-results-float.md

@@ -0,0 +1,5 @@
+---
+"@tanstack/db": patch
+---
+
+Fixed local collection manual transactions

packages/db/src/local-only.ts

@@ -179,7 +179,12 @@ export function localOnlyCollectionOptions<
 ): LocalOnlyCollectionOptionsResult<T, TKey, TSchema> & {
   schema?: StandardSchemaV1
 } {
-  const { initialData, onInsert, onUpdate, onDelete, ...restConfig } = config
+  const { initialData, onInsert, onUpdate, onDelete, id, ...restConfig } =
+    config
+
+  // Generate a stable collection ID for filtering mutations
+  // If not provided, generate a unique ID that will be used by the collection
+  const collectionId = id ?? `local-only:${crypto.randomUUID()}`
 
   // Create the sync configuration with transaction confirmation capability
   const syncResult = createLocalOnlySync<T, TKey>(initialData)
@@ -245,11 +250,9 @@ export function localOnlyCollectionOptions<
   const acceptMutations = (transaction: {
     mutations: Array<PendingMutation<Record<string, unknown>>>
   }) => {
-    // Filter mutations that belong to this collection
+    // Filter mutations that belong to this collection by collection ID
     const collectionMutations = transaction.mutations.filter(
-      (m) =>
-        // eslint-disable-next-line @typescript-eslint/no-unnecessary-condition
-        m.collection === syncResult.collection
+      (m) => m.collection.id === collectionId
     )
 
     if (collectionMutations.length === 0) {
@@ -264,6 +267,7 @@ export function localOnlyCollectionOptions<
 
   return {
     ...restConfig,
+    id: collectionId,
     sync: syncResult.sync,
     onInsert: wrappedOnInsert,
     onUpdate: wrappedOnUpdate,

packages/db/tests/local-only.test.ts

@@ -481,7 +481,7 @@ describe(`LocalOnly Collection`, () => {
   })
 
   describe(`Manual transactions with acceptMutations`, () => {
-    it(`should accept and persist mutations from manual transactions`, () => {
+    it(`should accept and persist mutations from manual transactions`, async () => {
       const tx = createTransaction({
         mutationFn: async ({ transaction }: any) => {
           // Simulate API call success
@@ -510,6 +510,39 @@ describe(`LocalOnly Collection`, () => {
         id: 101,
         name: `Manual Tx Insert 2`,
       })
+
+      // Verify that the item is still present after async operations complete
+      await new Promise((resolve) => setTimeout(resolve, 1))
+      expect(collection.get(100)).toEqual({ id: 100, name: `Manual Tx Insert` })
+    })
+
+    it(`should work without explicit collection ID`, async () => {
+      // Create a collection without an explicit ID
+      const noIdCollection = createCollection<
+        TestItem,
+        number,
+        LocalOnlyCollectionUtils
+      >(
+        localOnlyCollectionOptions({
+          getKey: (item) => item.id,
+        })
+      )
+
+      const tx = createTransaction({
+        mutationFn: async ({ transaction }: any) => {
+          noIdCollection.utils.acceptMutations(transaction)
+        },
+        autoCommit: false,
+      })
+
+      tx.mutate(() => {
+        noIdCollection.insert({ id: 999, name: `No ID Test` })
+      })
+
+      await tx.commit()
+
+      // Data should persist even without explicit ID
+      expect(noIdCollection.get(999)).toEqual({ id: 999, name: `No ID Test` })
     })
 
     it(`should only accept mutations for the specific collection`, () => {