refactor: reorganize tests into unit and e2e directories

pkgs/client/__tests__/FlowRun.test.ts → pkgs/client/__tests__/unit/FlowRun.test.ts

@@ -1,22 +1,22 @@
 import { describe, test, expect, vi } from 'vitest';
-import { FlowRun } from '../src/lib/FlowRun';
-import { FlowStep } from '../src/lib/FlowStep';
-import { FlowRunStatus, FlowStepStatus } from '../src/lib/types';
-import { toTypedRunEvent, toTypedStepEvent } from '../src/lib/eventAdapters';
+import { FlowRun } from '../../src/lib/FlowRun';
+import { FlowStep } from '../../src/lib/FlowStep';
+import { FlowRunStatus, FlowStepStatus } from '../../src/lib/types';
+import { toTypedRunEvent, toTypedStepEvent } from '../../src/lib/eventAdapters';
 import {
   setupTestEnvironment,
   advanceTimersAndFlush,
   createEventTracker,
-} from './helpers/test-utils';
+} from '../helpers/test-utils';
 import {
   createRunStartedEvent,
   createRunCompletedEvent,
   createRunFailedEvent,
   createStepStartedEvent,
-} from './helpers/event-factories';
-import { createFlowRun } from './helpers/state-factories';
+} from '../helpers/event-factories';
+import { createFlowRun } from '../helpers/state-factories';
 // Test scenarios have been inlined for clarity
-import { RUN_ID, FLOW_SLUG, STEP_SLUG, ANOTHER_STEP_SLUG } from './fixtures';
+import { RUN_ID, FLOW_SLUG, STEP_SLUG, ANOTHER_STEP_SLUG } from '../fixtures';
 
 describe('FlowRun', () => {
   setupTestEnvironment();

pkgs/client/__tests__/FlowStep.test.ts → pkgs/client/__tests__/unit/FlowStep.test.ts

@@ -1,19 +1,19 @@
 import { describe, test, expect, vi } from 'vitest';
-import { FlowStep } from '../src/lib/FlowStep';
-import { FlowStepStatus } from '../src/lib/types';
+import { FlowStep } from '../../src/lib/FlowStep';
+import { FlowStepStatus } from '../../src/lib/types';
 import {
   setupTestEnvironment,
   advanceTimersAndFlush,
   createEventTracker,
-} from './helpers/test-utils';
+} from '../helpers/test-utils';
 import {
   createStepStartedEvent,
   createStepCompletedEvent,
   createStepFailedEvent,
-} from './helpers/event-factories';
-import { createFlowStep } from './helpers/state-factories';
+} from '../helpers/event-factories';
+import { createFlowStep } from '../helpers/state-factories';
 // Test scenarios have been inlined for clarity
-import { RUN_ID, STEP_SLUG, ANOTHER_STEP_SLUG } from './fixtures';
+import { RUN_ID, STEP_SLUG, ANOTHER_STEP_SLUG } from '../fixtures';
 
 describe('FlowStep', () => {
   setupTestEnvironment();

pkgs/client/__tests__/PgflowClient.test.ts → pkgs/client/__tests__/unit/PgflowClient.test.ts

@@ -1,19 +1,19 @@
 import { describe, test, expect, vi } from 'vitest';
-import { PgflowClient } from '../src/lib/PgflowClient';
-import { FlowRunStatus, FlowStepStatus } from '../src/lib/types';
+import { PgflowClient } from '../../src/lib/PgflowClient';
+import { FlowRunStatus, FlowStepStatus } from '../../src/lib/types';
 import {
   setupTestEnvironment,
   createMockClient,
   createRunResponse,
   mockRpcCall,
   emitBroadcastEvent,
   createSyncSchedule,
-} from './helpers/test-utils';
+} from '../helpers/test-utils';
 import {
   createRunCompletedEvent,
   createStepStartedEvent,
-} from './helpers/event-factories';
-import { RUN_ID, FLOW_SLUG } from './fixtures';
+} from '../helpers/event-factories';
+import { RUN_ID, FLOW_SLUG } from '../fixtures';
 
 // Mock uuid.v4 to return a predictable run ID for testing
 vi.mock('uuid', () => ({

pkgs/client/__tests__/SupabaseBroadcastAdapter.simple.test.ts → pkgs/client/__tests__/unit/SupabaseBroadcastAdapter.simple.test.ts

@@ -1,22 +1,22 @@
 import { describe, test, expect, vi } from 'vitest';
-import { SupabaseBroadcastAdapter } from '../src/lib/SupabaseBroadcastAdapter';
+import { SupabaseBroadcastAdapter } from '../../src/lib/SupabaseBroadcastAdapter';
 import {
   setupTestEnvironment,
   createMockClient,
   emitBroadcastEvent,
-} from './helpers/test-utils';
+} from '../helpers/test-utils';
 import {
   createRunStartedEvent,
   createStepStartedEvent,
-} from './helpers/event-factories';
+} from '../helpers/event-factories';
 import {
   RUN_ID,
   FLOW_SLUG,
   STEP_SLUG,
   startedRunSnapshot,
   startedStepState,
-} from './fixtures';
-import { mockChannelSubscription } from './mocks';
+} from '../fixtures';
+import { mockChannelSubscription } from '../mocks';
 
 /**
  * This is a simplified test that focuses on the core functionality

pkgs/client/__tests__/SupabaseBroadcastAdapter.stabilization-delay.test.ts → pkgs/client/__tests__/unit/SupabaseBroadcastAdapter.stabilization-delay.test.ts

@@ -1,10 +1,10 @@
 import { describe, test, expect, vi, beforeEach, afterEach } from 'vitest';
-import { SupabaseBroadcastAdapter } from '../src/lib/SupabaseBroadcastAdapter';
+import { SupabaseBroadcastAdapter } from '../../src/lib/SupabaseBroadcastAdapter';
 import {
   createMockClient,
-} from './helpers/test-utils';
-import { RUN_ID } from './fixtures';
-import { mockChannelSubscription } from './mocks';
+} from '../helpers/test-utils';
+import { RUN_ID } from '../fixtures';
+import { mockChannelSubscription } from '../mocks';
 
 /**
  * Tests for configurable stabilization delay

pkgs/client/__tests__/SupabaseBroadcastAdapter.test.ts → pkgs/client/__tests__/unit/SupabaseBroadcastAdapter.test.ts

@@ -1,30 +1,30 @@
 import { describe, test, expect, vi } from 'vitest';
-import { SupabaseBroadcastAdapter } from '../src/lib/SupabaseBroadcastAdapter';
+import { SupabaseBroadcastAdapter } from '../../src/lib/SupabaseBroadcastAdapter';
 import {
   setupTestEnvironment,
   createMockClient,
   emitBroadcastEvent,
   createEventTracker,
   createEventRoutingTest,
   createSyncSchedule,
-} from './helpers/test-utils';
+} from '../helpers/test-utils';
 import {
   createRunStartedEvent,
   createRunCompletedEvent,
   createRunFailedEvent,
   createStepStartedEvent,
   createStepCompletedEvent,
   createStepFailedEvent,
-} from './helpers/event-factories';
-import { mockChannelSubscription } from './mocks';
+} from '../helpers/event-factories';
+import { mockChannelSubscription } from '../mocks';
 import { 
   RUN_ID, 
   FLOW_SLUG, 
   startedRunSnapshot,
   startedStepState,
   sampleFlowDefinition,
   sampleStepsDefinition,
-} from './fixtures';
+} from '../fixtures';
 
 describe('SupabaseBroadcastAdapter', () => {
   setupTestEnvironment();

pkgs/client/__tests__/browser.test.ts → pkgs/client/__tests__/unit/browser.test.ts

@@ -1,5 +1,5 @@
 import { describe, it, expect, vi } from 'vitest';
-import { createClient, PgflowClient } from '../src/browser';
+import { createClient, PgflowClient } from '../../src/browser';
 import type { SupabaseClient } from '@supabase/supabase-js';
 
 describe('browser entry point', () => {

pkgs/client/__tests__/concurrent-operations.test.ts → pkgs/client/__tests__/unit/concurrent-operations.test.ts

@@ -1,6 +1,6 @@
 import { describe, it, expect, vi } from 'vitest';
-import { PgflowClient } from '../src/lib/PgflowClient';
-import { FlowRunStatus, FlowStepStatus } from '../src/lib/types';
+import { PgflowClient } from '../../src/lib/PgflowClient';
+import { FlowRunStatus, FlowStepStatus } from '../../src/lib/types';
 import { Flow } from '@pgflow/dsl';
 import {
   setupTestEnvironment,
@@ -12,13 +12,13 @@ import {
   setupConcurrentOperations,
   createEventTracker,
   createSyncSchedule,
-} from './helpers/test-utils';
+} from '../helpers/test-utils';
 import {
   createStepStartedEvent,
   createStepCompletedEvent,
   createRunCompletedEvent,
-} from './helpers/event-factories';
-import { RUN_ID, FLOW_SLUG, STEP_SLUG, startedRunSnapshot, stepStatesSample } from './fixtures';
+} from '../helpers/event-factories';
+import { RUN_ID, FLOW_SLUG, STEP_SLUG, startedRunSnapshot, stepStatesSample } from '../fixtures';
 
 // Create a test flow for proper typing
 const TestFlow = new Flow<{ test: string }>({ slug: 'test_flow' }).step(

pkgs/client/__tests__/data-validation.test.ts → pkgs/client/__tests__/unit/data-validation.test.ts

@@ -1,9 +1,9 @@
 import { describe, it, expect, vi } from 'vitest';
-import { PgflowClient } from '../src/lib/PgflowClient';
-import { FlowRun } from '../src/lib/FlowRun';
-import { FlowStep } from '../src/lib/FlowStep';
-import { FlowRunStatus, FlowStepStatus } from '../src/lib/types';
-import { toTypedRunEvent, toTypedStepEvent } from '../src/lib/eventAdapters';
+import { PgflowClient } from '../../src/lib/PgflowClient';
+import { FlowRun } from '../../src/lib/FlowRun';
+import { FlowStep } from '../../src/lib/FlowStep';
+import { FlowRunStatus, FlowStepStatus } from '../../src/lib/types';
+import { toTypedRunEvent, toTypedStepEvent } from '../../src/lib/eventAdapters';
 import {
   setupTestEnvironment,
   createMockClient,
@@ -12,21 +12,21 @@ import {
   emitBroadcastEvent,
   advanceTimersAndFlush,
   createSyncSchedule,
-} from './helpers/test-utils';
+} from '../helpers/test-utils';
 import {
   createRunStartedEvent,
   createRunCompletedEvent,
   createStepStartedEvent,
   createStepCompletedEvent,
-} from './helpers/event-factories';
-import { mockChannelSubscription } from './mocks';
+} from '../helpers/event-factories';
+import { mockChannelSubscription } from '../mocks';
 import {
   RUN_ID,
   FLOW_SLUG,
   STEP_SLUG,
   startedRunSnapshot,
   stepStatesSample,
-} from './fixtures';
+} from '../fixtures';
 
 // Mock uuid.v4 to return predictable run ID for testing
 vi.mock('uuid', () => ({

pkgs/client/__tests__/error-recovery.test.ts → pkgs/client/__tests__/unit/error-recovery.test.ts

@@ -1,21 +1,21 @@
 import { describe, it, expect, vi } from 'vitest';
-import { PgflowClient } from '../src/lib/PgflowClient';
-import { FlowRunStatus } from '../src/lib/types';
+import { PgflowClient } from '../../src/lib/PgflowClient';
+import { FlowRunStatus } from '../../src/lib/types';
 import {
   setupTestEnvironment,
   createMockClient,
   mockRpcCall,
   createRunResponse,
   advanceTimersAndFlush,
   createSyncSchedule,
-} from './helpers/test-utils';
-import { mockChannelSubscription } from './mocks';
+} from '../helpers/test-utils';
+import { mockChannelSubscription } from '../mocks';
 import {
   RUN_ID,
   FLOW_SLUG,
   startedRunSnapshot,
   stepStatesSample,
-} from './fixtures';
+} from '../fixtures';
 
 // Mock uuid.v4 to return predictable run ID for testing
 vi.mock('uuid', () => ({

pkgs/client/__tests__/event-matchers.test.ts → pkgs/client/__tests__/unit/event-matchers.test.ts

@@ -1,6 +1,6 @@
 import { describe, test, expect } from 'vitest';
-import { createEventTracker } from './helpers/test-utils';
-import type { BroadcastRunEvent, BroadcastStepEvent } from '../src/lib/types';
+import { createEventTracker } from '../helpers/test-utils';
+import type { BroadcastRunEvent, BroadcastStepEvent } from '../../src/lib/types';
 
 /**
  * Tests demonstrating the new event matcher patterns

pkgs/client/__tests__/json-parsing.test.ts → pkgs/client/__tests__/unit/json-parsing.test.ts

@@ -1,13 +1,13 @@
 import { describe, it, expect, vi } from 'vitest';
-import { SupabaseBroadcastAdapter } from '../src/lib/SupabaseBroadcastAdapter';
-import type { BroadcastStepEvent, BroadcastRunEvent } from '../src/lib/types';
+import { SupabaseBroadcastAdapter } from '../../src/lib/SupabaseBroadcastAdapter';
+import type { BroadcastStepEvent, BroadcastRunEvent } from '../../src/lib/types';
 import {
   setupTestEnvironment,
   createMockClient,
   emitBroadcastEvent,
   createSyncSchedule,
-} from './helpers/test-utils';
-import { mockChannelSubscription } from './mocks';
+} from '../helpers/test-utils';
+import { mockChannelSubscription } from '../mocks';
 
 describe('JSON Parsing in Broadcasts', () => {
   setupTestEnvironment();

pkgs/client/__tests__/reconnection.test.ts → pkgs/client/__tests__/unit/reconnection.test.ts

@@ -1,16 +1,16 @@
 import { describe, it, expect, vi } from 'vitest';
-import { SupabaseBroadcastAdapter } from '../src/lib/SupabaseBroadcastAdapter';
+import { SupabaseBroadcastAdapter } from '../../src/lib/SupabaseBroadcastAdapter';
 import {
   setupTestEnvironment,
   createMockClient,
   mockRpcCall,
   createRunResponse,
   createSyncSchedule,
-} from './helpers/test-utils';
+} from '../helpers/test-utils';
 import {
   createMockSchedule,
-} from './mocks';
-import { RUN_ID, startedRunSnapshot, stepStatesSample } from './fixtures';
+} from '../mocks';
+import { RUN_ID, startedRunSnapshot, stepStatesSample } from '../fixtures';
 
 describe('Reconnection Logic', () => {
   setupTestEnvironment();

pkgs/client/__tests__/type-guards.test.ts → pkgs/client/__tests__/unit/type-guards.test.ts

@@ -9,19 +9,19 @@ import {
   FlowStepStatus,
   type BroadcastRunStartedEvent,
   type BroadcastStepStartedEvent,
-} from '../src/lib/types';
+} from '../../src/lib/types';
 import {
   createRunStartedEvent,
   createRunCompletedEvent,
   createRunFailedEvent,
   createStepStartedEvent,
   createStepCompletedEvent,
   createStepFailedEvent,
-} from './helpers/event-factories';
+} from '../helpers/event-factories';
 import {
   RUN_ID,
   STEP_SLUG,
-} from './fixtures';
+} from '../fixtures';
 
 // Create test events
 const broadcastRunStarted = createRunStartedEvent({ run_id: RUN_ID });

pkgs/client/project.json

@@ -149,7 +149,7 @@
         "commands": [
           "../../scripts/supabase-start-locked.sh .",
           "psql 'postgresql://postgres:postgres@localhost:50522/postgres' -c 'SELECT pgflow_tests.reset_db()'",
-          "vitest run __tests__/integration/ --poolOptions.threads.singleThread"
+          "vitest run __tests__/e2e/ --config vitest.e2e.config.ts --poolOptions.threads.singleThread"
         ],
         "parallel": false
       }
@@ -160,7 +160,7 @@
       "inputs": ["default", "^production"],
       "options": {
         "cwd": "{projectRoot}",
-        "commands": ["vitest run __tests__/ --exclude __tests__/integration/"],
+        "commands": ["vitest run __tests__/unit/"],
         "parallel": false
       }
     },
@@ -174,7 +174,7 @@
         "commands": [
           "../../scripts/supabase-start-locked.sh .",
           "psql 'postgresql://postgres:postgres@localhost:50522/postgres' -c 'SELECT pgflow_tests.reset_db()'",
-          "vitest run __tests__/ --poolOptions.threads.singleThread"
+          "vitest run __tests__/ --config vitest.e2e.config.ts --poolOptions.threads.singleThread"
         ],
         "parallel": false
       }

pkgs/client/vite.config.ts

@@ -55,7 +55,6 @@ export default defineConfig({
       '__tests__/**/*.{test,spec}.{js,mjs,cjs,ts,mts,cts,jsx,tsx}'
     ],
     setupFiles: ['__tests__/setup.ts'],
-    globalSetup: './vitest.global-setup.ts',
     reporters: ['default'],
     coverage: {
       reportsDirectory: '../../coverage/pkgs/client',

pkgs/client/vitest.e2e.config.ts

@@ -0,0 +1,12 @@
+/// <reference types='vitest' />
+import { defineConfig, mergeConfig } from 'vitest/config';
+import baseConfig from './vite.config';
+
+export default mergeConfig(
+  baseConfig,
+  defineConfig({
+    test: {
+      globalSetup: './vitest.e2e.global-setup.ts',
+    },
+  })
+);