Dwinzo-Beta/Dwinzo-Backend-V0.0
4
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

clear the testing commits

Browse Source
This commit is contained in:
sabarinathan
2025-06-03 14:54:00 +05:30
parent f9083175da
commit 118f65d688
44 changed files with 479 additions and 852 deletions
Download Patch File Download Diff File Expand all files Collapse all files

95
src/socket-server/controllers/builderController/asset-Controller.ts
View File

@@ -2,6 +2,7 @@ import { Socket, Server } from "socket.io";
import { EVENTS } from "../../socket/events.ts";
import { emitToSenderAndAdmins } from "../../utils/emitEventResponse.ts";
import { deleteAssetModel, replaceEventDatas, setAssetModel } from "../../../shared/services/builder/assetService.ts";
import { ErrorResponse, FinalResponse, validateFields } from "../../utils/socketfunctionHelpers.ts";
export const setAssetHandleEvent = async (
event: string,
socket: Socket,
@@ -23,18 +24,11 @@ export const setAssetHandleEvent = async (
"userId",
"organization",
];
const missingFields = requiredFields.filter(field => !data?.[field]);
const missingFields = validateFields(data, requiredFields);
if (missingFields.length > 0) {
const response = {
success: false,
message: `Missing required field(s): ${missingFields.join(", ")}`,
status: "MissingFields",
socketId: socket.id,
organization: data?.organization ?? "unknown",
};
emitToSenderAndAdmins(io, socket, data.organization, EVENTS.asset_v1UpdateResponse, response, connectedUsersByOrg)
emitToSenderAndAdmins(io, socket, data.organization, EVENTS.asset_v1UpdateResponse,
ErrorResponse(missingFields, socket, data.organization), connectedUsersByOrg);
return;
}
const result = await setAssetModel(data);
@@ -54,24 +48,12 @@ export const setAssetHandleEvent = async (
status === "Success" && result?.data
? {
// widget: {
// id: result.data.widgetID,
// type: result.data.projectName,
// position: result.data.position,
// },
// Data: result.data.Data,
// zoneId: result.data.zoneId,
}
: undefined;
const response = {
success: status === "Success",
message: msg.message,
status,
socketId: socket.id,
organization: data.organization,
...(Asset_Datas ? { data: Asset_Datas } : {}),
};
const response = FinalResponse(status, socket, data.organization, messages, Asset_Datas);
emitToSenderAndAdmins(io, socket, data.organization, EVENTS.asset_v1UpdateResponse, response, connectedUsersByOrg)
@@ -91,18 +73,11 @@ export const deleteAssetHandleEvent = async (
"userId",
"organization",
];
const missingFields = requiredFields.filter(field => !data?.[field]);
const missingFields = validateFields(data, requiredFields);
if (missingFields.length > 0) {
const response = {
success: false,
message: `Missing required field(s): ${missingFields.join(", ")}`,
status: "MissingFields",
socketId: socket.id,
organization: data?.organization ?? "unknown",
};
emitToSenderAndAdmins(io, socket, data.organization, EVENTS.asset_v1DeleteResponse, response, connectedUsersByOrg)
emitToSenderAndAdmins(io, socket, data.organization, EVENTS.asset_v1DeleteResponse,
ErrorResponse(missingFields, socket, data.organization), connectedUsersByOrg);
return;
}
const result = await deleteAssetModel(data);
@@ -123,24 +98,10 @@ export const deleteAssetHandleEvent = async (
status === "Success" && result?.data
? {
// widget: {
// id: result.data.widgetID,
// type: result.data.projectName,
// position: result.data.position,
// },
// Data: result.data.Data,
// zoneId: result.data.zoneId,
}
: undefined;
const response = {
success: status === "Success",
message: msg.message,
status,
socketId: socket.id,
organization: data.organization,
...(Asset_Datas ? { data: Asset_Datas } : {}),
};
const response = FinalResponse(status, socket, data.organization, messages, Asset_Datas);
emitToSenderAndAdmins(io, socket, data.organization, EVENTS.asset_v1DeleteResponse, response, connectedUsersByOrg)
@@ -160,18 +121,10 @@ export const replaceEventDatasHandleEvent = async (
"userId",
"organization",
];
const missingFields = requiredFields.filter(field => !data?.[field]);
const missingFields = validateFields(data, requiredFields);
if (missingFields.length > 0) {
const response = {
success: false,
message: `Missing required field(s): ${missingFields.join(", ")}`,
status: "MissingFields",
socketId: socket.id,
organization: data?.organization ?? "unknown",
};
emitToSenderAndAdmins(io, socket, data.organization, EVENTS.asset_v1EventDataResponse, response, connectedUsersByOrg)
emitToSenderAndAdmins(io, socket, data.organization, EVENTS.asset_v1EventDataResponse,
ErrorResponse(missingFields, socket, data.organization), connectedUsersByOrg);
return;
}
const result = await replaceEventDatas(data);
@@ -192,25 +145,11 @@ export const replaceEventDatasHandleEvent = async (
status === "Success" && result?.data
? {
// widget: {
// id: result.data.widgetID,
// type: result.data.projectName,
// position: result.data.position,
// },
// Data: result.data.Data,
// zoneId: result.data.zoneId,
}
: undefined;
const response = {
success: status === "Success",
message: msg.message,
status,
socketId: socket.id,
organization: data.organization,
...(Asset_Datas ? { data: Asset_Datas } : {}),
};
const response = FinalResponse(status, socket, data.organization, messages, Asset_Datas);
emitToSenderAndAdmins(io, socket, data.organization, EVENTS.asset_v1EventDataResponse, response, connectedUsersByOrg)
}