422 lines
12 KiB
TypeScript
422 lines
12 KiB
TypeScript
|
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;
|
||
|
|
};
|