24 lines
1.2 KiB
JavaScript
24 lines
1.2 KiB
JavaScript
import WebSocket from 'ws';
|
|
const headers = { 'apikey': 'eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJzdWIiOiJhbm9uIiwicm9sZSI6ImFub24iLCJpc3MiOiJtYWRiYXNlIiwiaWF0IjoxNzczNjk0OTEwLCJleHAiOjE3NzQyOTk3MTB9.kiDrLssL7YrvQdiOvhbH6qsvcO_O2cc4v6i5s2zN3wM' };
|
|
const ws = new WebSocket('ws://localhost:8002/realtime/v1/websocket', { headers });
|
|
ws.on('open', () => {
|
|
console.log('WebSocket connected');
|
|
ws.send(JSON.stringify(['1', '1', 'realtime:public:todos', 'phx_join', { config: { access_token: 'eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJzdWIiOiJhbm9uIiwicm9sZSI6ImFub24iLCJpc3MiOiJtYWRiYXNlIiwiaWF0IjoxNzczNjk0OTEwLCJleHAiOjE3NzQyOTk3MTB9.kiDrLssL7YrvQdiOvhbH6qsvcO_O2cc4v6i5s2zN3wM', postgres_changes: [{ schema: 'public', table: 'todos' }] } }]));
|
|
});
|
|
ws.on('message', (data) => {
|
|
console.log('Received message:', data.toString());
|
|
});
|
|
ws.on('error', (error) => {
|
|
console.error('WebSocket error:', error);
|
|
});
|
|
ws.on('close', (code, reason) => {
|
|
console.log('WebSocket closed:', code, reason.toString());
|
|
});
|
|
setTimeout(() => {
|
|
if (ws.readyState === WebSocket.OPEN) {
|
|
ws.close();
|
|
} else {
|
|
console.error('WebSocket did not connect within 5 seconds');
|
|
process.exit(1);
|
|
}
|
|
}, 5000); |