proffesor-for-testing__agentic-qe/tests/manual/test-5-streaming-simple.ts

/**
 * Manual Test 5: Streaming Progress (Simplified)
 * Tests async generator pattern for streaming
 */

// Simple async generator to demonstrate streaming
async function* simpleStreamingExample() {
  console.log('📊 Starting stream...\n');

  // Emit progress updates
  yield { type: 'progress', percent: 0, message: 'Initializing...' };
  await new Promise(resolve => setTimeout(resolve, 100));

  yield { type: 'progress', percent: 25, message: 'Analyzing code...' };
  await new Promise(resolve => setTimeout(resolve, 100));

  yield { type: 'progress', percent: 50, message: 'Generating tests...' };
  await new Promise(resolve => setTimeout(resolve, 100));

  yield { type: 'progress', percent: 75, message: 'Running validation...' };
  await new Promise(resolve => setTimeout(resolve, 100));

  yield { type: 'progress', percent: 100, message: 'Complete!' };

  // Emit final result
  return {
    type: 'result',
    data: {
      testsGenerated: 10,
      coverage: 95,
      duration: 400
    }
  };
}

async function testStreaming() {
  console.log('🧪 Test 5: Streaming Progress Updates (Simplified)\n');

  try {
    let progressCount = 0;
    let hasResult = false;

    // Use for-await-of to consume the stream
    for await (const event of simpleStreamingExample()) {
      if (event.type === 'progress') {
        progressCount++;
        console.log(`  ${event.percent}% - ${event.message}`);
      }
    }

    console.log('\n═'.repeat(50));
    console.log('📈 Stream Statistics:');
    console.log(`  Progress updates: ${progressCount}`);

    if (progressCount >= 5) {
      console.log('  ✅ Multiple progress updates received');
    }

    // Verify async generator protocol
    const stream = simpleStreamingExample();
    console.log('\n🔍 Verifying Async Iterator Protocol:');
    console.log(`  Has Symbol.asyncIterator: ${Symbol.asyncIterator in stream}`);
    console.log(`  Is async function: ${typeof stream[Symbol.asyncIterator] === 'function'}`);

    if (Symbol.asyncIterator in stream) {
      console.log('  ✅ Async iteration protocol supported');
    }

    console.log('\n🎉 TEST 5 PASSED: Streaming pattern functional');
    console.log('\nKey Features Demonstrated:');
    console.log('  ✓ AsyncGenerator pattern works');
    console.log('  ✓ Progress updates emit correctly');
    console.log('  ✓ for-await-of loop consumes stream');
    console.log('  ✓ Symbol.asyncIterator protocol supported');

    process.exit(0);

  } catch (error) {
    console.error('\n❌ TEST 5 FAILED:', error);
    process.exit(1);
  }
}

testStreaming();