32 lines
735 B
JavaScript
32 lines
735 B
JavaScript
const express = require('express');
|
|
const { WebSocketServer } = require('ws');
|
|
const path = require('path');
|
|
const { subscribeToSomething, setWsClient } = require('./subscriptionClient');
|
|
|
|
const app = express();
|
|
const PORT = 4000;
|
|
|
|
// Serve the HTML file
|
|
app.get('/', (req, res) => {
|
|
res.sendFile(path.join(__dirname, 'index.html'));
|
|
});
|
|
|
|
const server = app.listen(PORT, () => {
|
|
console.log(`Server is running on http://localhost:${PORT}`);
|
|
});
|
|
|
|
// Create WebSocket server
|
|
const wss = new WebSocketServer({ server });
|
|
|
|
wss.on('connection', (ws) => {
|
|
console.log('Client connected');
|
|
setWsClient(ws);
|
|
|
|
ws.on('close', () => {
|
|
console.log('Client disconnected');
|
|
});
|
|
});
|
|
|
|
// Start the subscription
|
|
subscribeToSomething();
|