added actions, routes, and socketio bun engine
This commit is contained in:
@@ -1,9 +1,53 @@
|
||||
import { Hono } from 'hono'
|
||||
import { cors } from 'hono/cors'
|
||||
import { Server as Engine } from '@socket.io/bun-engine'
|
||||
import { Server } from 'socket.io'
|
||||
import routes from './routes/index'
|
||||
|
||||
//initialize socket.io server
|
||||
const io = new Server()
|
||||
|
||||
//initialize bun engine
|
||||
//then bind to socket.io server
|
||||
const engine = new Engine()
|
||||
io.bind(engine)
|
||||
|
||||
io.on('connection', (socket) => {
|
||||
|
||||
//get userId and clientId from query params
|
||||
const userId = socket.handshake.query.userId;
|
||||
const clientId = socket.handshake.query.clientId;
|
||||
if(!userId || Array.isArray(userId)){
|
||||
socket.disconnect();
|
||||
throw new Error('Invalid user ID');
|
||||
}
|
||||
|
||||
if(!clientId || Array.isArray(clientId)){
|
||||
socket.disconnect()
|
||||
throw new Error('Invalid client ID')
|
||||
}
|
||||
|
||||
socket.join(userId)
|
||||
console.log(`User ${userId} connected. Client ID ${clientId} on socket ${socket.id}`);
|
||||
|
||||
socket.on('disconnect', () => {
|
||||
console.log(`User ${userId} disconnected from socket ${socket.id}`);
|
||||
});
|
||||
});
|
||||
|
||||
const app = new Hono()
|
||||
|
||||
app.get('/', (c) => {
|
||||
return c.text('Hello Hono!')
|
||||
})
|
||||
app.use('*', cors({
|
||||
origin: 'http://localhost:5173',
|
||||
allowHeaders: ['Content-Type', 'Authorization'],
|
||||
allowMethods: ['GET', 'POST', 'PUT', 'DELETE', 'OPTIONS'],
|
||||
credentials: true
|
||||
}))
|
||||
app.use(routes)
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
export default app
|
||||
|
||||
Reference in New Issue
Block a user