Function runTestsForSyncMode

packages/db-collection-e2e/src/suites/moves.suite.ts:140–749

(syncMode: SyncMode)

    // Helper function to run all tests for a given sync mode
    function runTestsForSyncMode(syncMode: SyncMode) {
      describe(`${syncMode} mode`, () => {
        it(`Initial snapshot contains only posts from active users`, async () => {
          // Create collection on posts with WHERE clause: userId IN (SELECT id FROM users WHERE isActive = true)
          const collection = createPostsByActiveUsersCollection(syncMode)

          if (!config.mutations) {
            throw new Error(`Mutations not configured`)
          }

          // Insert 2 active users and 1 inactive user
          const userId1 = randomUUID()
          const userId2 = randomUUID()
          const userId3 = randomUUID()

          await config.mutations.insertUser({
            id: userId1,
            name: `Active User 1`,
            email: `user1@test.com`,
            age: 25,
            isActive: true,
            createdAt: new Date(),
            metadata: null,
            deletedAt: null,
          })

          await config.mutations.insertUser({
            id: userId2,
            name: `Active User 2`,
            email: `user2@test.com`,
            age: 30,
            isActive: true,
            createdAt: new Date(),
            metadata: null,
            deletedAt: null,
          })

          await config.mutations.insertUser({
            id: userId3,
            name: `Inactive User`,
            email: `user3@test.com`,
            age: 42,
            isActive: false,
            createdAt: new Date(),
            metadata: null,
            deletedAt: null,
          })

          // Wait for all 3 users to be synced to Electric before inserting posts
          // This ensures the subquery in the WHERE clause can properly evaluate
          await waitForUsersSynced([userId1, userId2, userId3])

          // Insert posts for these users
          const postId1 = randomUUID()
          const postId2 = randomUUID()
          const postId3 = randomUUID()

          await config.mutations.insertPost({