yakbak

const http = require('http'); const path = require('path'); const fs = require('fs'); const yakbak = require('yakbak'); // Ensure the tapes directory exists const tapesDir = path.join(__dirname, 'tapes'); if (!fs.existsSync(tapesDir)) { fs.mkdirSync(tapesDir, { recursive: true }); } // Create a yakbak handler for a dummy API endpoint // We'll proxy to httpbin.org for demonstration const handler = yakbak('https://httpbin.org', { dirname: tapesDir }); // Create an HTTP server that uses the yakbak handler const proxyServer = http.createServer((req, res) => { console.log(`Proxying request for: ${req.url}`); handler(req, res); // Yakbak handles the request (record or playback) }); const PORT = 3000; proxyServer.listen(PORT, () => { console.log(`Yakbak proxy server listening on http://localhost:${PORT}`); // Example client request to the yakbak proxy // This request will either be recorded or played back http.get(`http://localhost:${PORT}/get?foo=bar`, (response) => { let data = ''; response.on('data', (chunk) => (data += chunk)); response.on('end', () => { console.log('\n--- Client received response from Yakbak proxy ---'); console.log(`Status: ${response.statusCode}`); console.log('Body:', JSON.parse(data)); proxyServer.close(() => { console.log('Proxy server closed.'); // Clean up tapes for repeated runs, if not desired to persist fs.rmdirSync(tapesDir, { recursive: true }); }); }); }).on('error', (err) => { console.error('Client request error:', err); proxyServer.close(); fs.rmdirSync(tapesDir, { recursive: true }); }); });