Initial
This commit is contained in:
SathishKannaa-HexrFactory
421
src/socket-server/socket/socketManager.ts
Normal file
421
src/socket-server/socket/socketManager.ts
Normal file
@@ -0,0 +1,421 @@
|
||||
import { Server, Socket } from 'socket.io';
|
||||
import { EVENTS } from './events';
|
||||
import { createCamera } from '../services/camera/camera-Controller';
|
||||
import { setEnvironment } from '../services/environments/environments-controller';
|
||||
import { deleteFloorItems, setFloorItems } from '../services/assets/flooritem-Controller';
|
||||
import { deleteWallItems, setWallItems } from '../services/assets/wallitem-Controller';
|
||||
import { deleteLineItems, deleteLinPoiteItems, updateLineItems ,createLineItems, deleteLayer} from '../services/lines/line-Controller';
|
||||
import { activeUserOffline, activeUsers } from '../services/users/user-controller';
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
const cameraHandleEvent =async (event: string, socket: Socket, data: any,io:any) => {
|
||||
switch (event) {
|
||||
|
||||
case EVENTS.setCamera:
|
||||
const result = await createCamera(data,);
|
||||
// console.log('result: ', result);
|
||||
if (result.success) {
|
||||
// console.log('result.success: ', result.success);
|
||||
// if (result.message === 'Camera updated') {
|
||||
// Emit update response
|
||||
|
||||
io.emit(EVENTS.cameraUpdateResponse, {
|
||||
success: true,
|
||||
message: result.message,
|
||||
data: result.data,
|
||||
socketId: socket.id,
|
||||
organization:result.organization
|
||||
});
|
||||
} else if (result.message === 'Camera created') {
|
||||
// Emit create response
|
||||
io.emit(EVENTS.cameraCreateResponse, {
|
||||
success: true,
|
||||
message: result.message,
|
||||
data: result.data,
|
||||
socketId: socket.id,
|
||||
organization:result.organization
|
||||
});
|
||||
// }
|
||||
} else {
|
||||
// Emit error response
|
||||
socket.emit(EVENTS.cameraError, {
|
||||
success: false,
|
||||
message: result.message,
|
||||
error: result.error,
|
||||
socketId: socket.id,
|
||||
organization:result.organization
|
||||
});
|
||||
}
|
||||
break;
|
||||
// case EVENTS.updataControlle_iot:
|
||||
// updateControlle(data);
|
||||
break;
|
||||
// case EVENTS.deleteControlle_iot:
|
||||
// deleteControlle(data);
|
||||
break;
|
||||
|
||||
|
||||
default:
|
||||
// console.error(`Unhandled event type: ${event}`);
|
||||
}
|
||||
}
|
||||
const EnvironmentHandleEvent =async (event: string, socket: Socket, data: any,io:any) => {
|
||||
switch (event) {
|
||||
|
||||
case EVENTS.setenvironment:
|
||||
const result = await setEnvironment(data,);
|
||||
// console.log('result: ', result);
|
||||
if (result.success) {
|
||||
// if (result.message === 'Camera updated') {
|
||||
// Emit update response
|
||||
|
||||
io.emit(EVENTS.EnvironmentUpdateResponse, {
|
||||
success: true,
|
||||
message: result.message,
|
||||
data: result.data,
|
||||
socketId: socket.id,
|
||||
organization:result.organization
|
||||
});
|
||||
// } else if (result.message === 'evironments created') {
|
||||
// // Emit create response
|
||||
// io.emit(EVENTS.cameraCreateResponse, {
|
||||
// success: true,
|
||||
// message: result.message,
|
||||
// data: result.data,
|
||||
// });
|
||||
// }
|
||||
} else {
|
||||
// Emit error response
|
||||
socket.emit(EVENTS.cameraError, {
|
||||
success: false,
|
||||
message: result.message,
|
||||
error: result.error,
|
||||
socketId: socket.id,
|
||||
organization:result.organization
|
||||
});
|
||||
}
|
||||
break;
|
||||
// case EVENTS.updataControlle_iot:
|
||||
// updateControlle(data);
|
||||
break;
|
||||
// case EVENTS.deleteControlle_iot:
|
||||
// deleteControlle(data);
|
||||
break;
|
||||
|
||||
|
||||
default:
|
||||
// console.error(`Unhandled event type: ${event}`);
|
||||
}
|
||||
}
|
||||
const floorItemsHandleEvent =async (event: string, socket: Socket, data: any,io:any) => {
|
||||
switch (event) {
|
||||
|
||||
case EVENTS.setFloorItems:{
|
||||
const result = await setFloorItems(data);
|
||||
// console.log('result: ', result);
|
||||
if (result.success) {
|
||||
io.emit(EVENTS.FloorItemsUpdateResponse, {
|
||||
success: true || false,
|
||||
message: result.message,
|
||||
data: result.data,
|
||||
socketId: socket.id,
|
||||
organization:result.organization
|
||||
|
||||
});
|
||||
|
||||
} else {
|
||||
// Emit error response
|
||||
socket.emit(EVENTS.floorItemError, {
|
||||
success: false,
|
||||
message: result.message,
|
||||
error: result.error,
|
||||
socketId: socket.id,
|
||||
organization:result.organization
|
||||
});
|
||||
}
|
||||
break;}
|
||||
case EVENTS.deleteFloorItems:{
|
||||
const result = await deleteFloorItems(data);
|
||||
// console.log('result: ', result);
|
||||
if (result.success) {
|
||||
|
||||
|
||||
io.emit(EVENTS.FloorItemsDeleteResponse, {
|
||||
success: true || false,
|
||||
message: result.message,
|
||||
data: result.data,
|
||||
socketId: socket.id,
|
||||
organization:result.organization
|
||||
|
||||
});
|
||||
|
||||
} else {
|
||||
// Emit error response
|
||||
socket.emit(EVENTS.floorItemError, {
|
||||
success: false,
|
||||
message: result.message,
|
||||
error: result.error,
|
||||
socketId: socket.id,
|
||||
organization:result.organization
|
||||
});
|
||||
}
|
||||
break;}
|
||||
|
||||
default:
|
||||
// console.error(`Unhandled event type: ${event}`);
|
||||
}
|
||||
}
|
||||
const wallItemsHandleEvent =async (event: string, socket: Socket, data: any,io:any) => {
|
||||
switch (event) {
|
||||
|
||||
case EVENTS.setWallItems:{
|
||||
const result = await setWallItems(data);
|
||||
// console.log('result: ', result);
|
||||
if (result.success) {
|
||||
io.emit(EVENTS.wallItemsUpdateResponse, {
|
||||
success: true,
|
||||
message: result.message,
|
||||
data: result.data,
|
||||
socketId: socket.id,
|
||||
organization:result.organization
|
||||
|
||||
});
|
||||
|
||||
} else {
|
||||
// Emit error response
|
||||
socket.emit(EVENTS.wallItemError, {
|
||||
success: false,
|
||||
message: result.message,
|
||||
error: result.error,
|
||||
});
|
||||
}
|
||||
break;
|
||||
}
|
||||
case EVENTS.deleteWallItems:{
|
||||
const result = await deleteWallItems(data);
|
||||
// console.log('result: ', result);
|
||||
if (result.success) {
|
||||
|
||||
|
||||
io.emit(EVENTS.wallItemsDeleteResponse, {
|
||||
success: true || false,
|
||||
message: result.message,
|
||||
data: result.data,
|
||||
socketId: socket.id,
|
||||
organization:result.organization
|
||||
|
||||
});
|
||||
|
||||
} else {
|
||||
// Emit error response
|
||||
socket.emit(EVENTS.wallItemError, {
|
||||
success: false,
|
||||
message: result.message,
|
||||
error: result.error,
|
||||
});
|
||||
}
|
||||
break;
|
||||
}
|
||||
|
||||
default:
|
||||
// console.error(`Unhandled event type: ${event}`);
|
||||
}
|
||||
}
|
||||
const lineHandleEvent =async (event: string, socket: Socket, data: any,io:any) => {
|
||||
switch (event) {
|
||||
case EVENTS.createLine:{
|
||||
const result = await createLineItems(data);
|
||||
// console.log('result: ', result);
|
||||
if (result.success) {
|
||||
|
||||
|
||||
io.emit(EVENTS.createLineResponse, {
|
||||
success: true || false,
|
||||
message: result.message,
|
||||
data: result.data,
|
||||
socketId: socket.id,
|
||||
organization:result.organization
|
||||
|
||||
});
|
||||
|
||||
} else {
|
||||
// Emit error response
|
||||
// socket.emit(EVENTS.wallItemError, {
|
||||
// success: false,
|
||||
// message: result.message,
|
||||
// error: result.error,
|
||||
// });
|
||||
}
|
||||
break;
|
||||
}
|
||||
case EVENTS.updateLine: {
|
||||
const result = await updateLineItems(data);
|
||||
// console.log('result: ', result);
|
||||
if (result.success) {
|
||||
|
||||
|
||||
io.emit(EVENTS.updateLineResponse, {
|
||||
success: true || false,
|
||||
message: result.message,
|
||||
data: result.data,
|
||||
socketId: socket.id,
|
||||
organization: result.organization
|
||||
|
||||
});
|
||||
|
||||
}
|
||||
break;
|
||||
}
|
||||
case EVENTS.deleteLine:{
|
||||
const result = await deleteLineItems(data);
|
||||
// console.log('result: ', result);
|
||||
if (result.success) {
|
||||
|
||||
|
||||
io.emit(EVENTS.deleteLineResponse, {
|
||||
success: true || false,
|
||||
message: result.message,
|
||||
data: result.data,
|
||||
socketId: socket.id,
|
||||
organization:result.organization
|
||||
|
||||
});
|
||||
|
||||
} else {
|
||||
// Emit error response
|
||||
// socket.emit(EVENTS.wallItemError, {
|
||||
// success: false,
|
||||
// message: result.message,
|
||||
// error: result.error,
|
||||
// });
|
||||
}
|
||||
break;
|
||||
}
|
||||
case EVENTS.deletePoint:{
|
||||
const result = await deleteLinPoiteItems(data);
|
||||
// console.log('result: ', result);
|
||||
if (result.success) {
|
||||
|
||||
io.emit(EVENTS.deletePointResponse, {
|
||||
success: true || false,
|
||||
message: result.message,
|
||||
data: result.data,
|
||||
socketId: socket.id,
|
||||
organization:result.organization
|
||||
|
||||
});
|
||||
|
||||
} else {
|
||||
// Emit error response
|
||||
// socket.emit(EVENTS.wallItemError, {
|
||||
// success: false,
|
||||
// message: result.message,
|
||||
// error: result.error,
|
||||
// });
|
||||
}
|
||||
break;
|
||||
}
|
||||
case EVENTS.deleteLineLayer:{
|
||||
const result = await deleteLayer(data);
|
||||
// console.log('result: ', result);
|
||||
if (result.success) {
|
||||
|
||||
io.emit(EVENTS.deleteLineLayerResponse, {
|
||||
success: true || false,
|
||||
message: result.message,
|
||||
data: result.data,
|
||||
socketId: socket.id,
|
||||
organization:result.organization
|
||||
|
||||
});
|
||||
|
||||
} else {
|
||||
// Emit error response
|
||||
// socket.emit(EVENTS.wallItemError, {
|
||||
// success: false,
|
||||
// message: result.message,
|
||||
// error: result.error,
|
||||
// });
|
||||
}
|
||||
break;
|
||||
}
|
||||
|
||||
default:
|
||||
// console.error(`Unhandled event type: ${event}`);
|
||||
}
|
||||
}
|
||||
const userStatus =async (event: string, socket: Socket, data: any,io:any) => {
|
||||
switch (event) {
|
||||
case EVENTS.connection: {
|
||||
// console.log('EVENTS.connection: ', EVENTS.connection);
|
||||
// console.log('event: ', event);
|
||||
const result = await activeUsers(data);
|
||||
if (result?.success) {
|
||||
// console.log('result.success: ', result.success)
|
||||
|
||||
io.emit(EVENTS.userConnect, {
|
||||
success: true || false,
|
||||
message: result.message,
|
||||
data: result.data,
|
||||
socketId: socket.id,
|
||||
organization:result.organization
|
||||
|
||||
});}
|
||||
break;
|
||||
}
|
||||
case EVENTS.disconnect: {
|
||||
// console.log('EVENTS.disconnect: ', EVENTS.connection);
|
||||
// console.log('event: ', event);
|
||||
const result = await activeUserOffline(data);
|
||||
if (result?.success) {
|
||||
// console.log('result.success: ', result.success)
|
||||
|
||||
io.emit(EVENTS.userDisConnect, {
|
||||
success: true || false,
|
||||
message: result.message,
|
||||
data: result.data,
|
||||
socketId: socket.id,
|
||||
organization:result.organization
|
||||
|
||||
});}
|
||||
break;
|
||||
}
|
||||
}
|
||||
}
|
||||
export const initSocketServer = (httpServer: any) => {
|
||||
const io = new Server(httpServer, {
|
||||
cors: {
|
||||
origin: '*', // Allow CORS for all origins (adjust in production)
|
||||
methods: ['GET', 'POST'],
|
||||
},
|
||||
});
|
||||
|
||||
// Listen for new connections
|
||||
io.on(EVENTS.connection, (socket: Socket) => {
|
||||
// console.log(`New client connected: ${socket.id}`);
|
||||
// console.log(socket.handshake.auth);
|
||||
userStatus(EVENTS.connection, socket, socket.handshake.auth,io);
|
||||
|
||||
// Handle all incoming events with the handleEvent function
|
||||
socket.onAny((event: string, data: any,) => {
|
||||
cameraHandleEvent(event, socket, data,io);
|
||||
EnvironmentHandleEvent(event, socket, data,io);
|
||||
floorItemsHandleEvent(event, socket, data,io);
|
||||
wallItemsHandleEvent(event, socket, data,io);
|
||||
lineHandleEvent(event, socket, data,io);
|
||||
|
||||
|
||||
});
|
||||
socket.on(EVENTS.disconnect, (reason: string) => {
|
||||
// console.log(`Client disconnected: ${socket.id}, Reason: ${reason}`);
|
||||
// console.log(socket.handshake.auth);
|
||||
userStatus(EVENTS.disconnect, socket, socket.handshake.auth,io);
|
||||
// Perform cleanup or other necessary actions
|
||||
});
|
||||
});
|
||||
|
||||
return io;
|
||||
};
|
||||
Reference in New Issue
Block a user