Dwinzo-Backend-V0.0/src/socket-server/controllers/builderController/asset-Controller.ts

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,
    io: Server,
    data: any,
    connectedUsersByOrg: { [org: string]: { socketId: string; userId: string; role: string }[] },
) => {
    if (event !== EVENTS.setAssetModel_v1 || !data?.organization) return;
    const requiredFields = [
        "modelUuid",
        "modelName",
        "position",
        "rotation",
        "eventData",
        "modelfileID",
        "isLocked",
        "isVisible",
        "projectId",
        "userId",
        "organization",
    ];
    const missingFields = validateFields(data, requiredFields);

    if (missingFields.length > 0) {
        emitToSenderAndAdmins(io, socket, data.organization, EVENTS.asset_v1UpdateResponse,
            ErrorResponse(missingFields, socket, data.organization), connectedUsersByOrg);
        return;
    }
    const result = await setAssetModel(data);
    const status = typeof result?.status === "string" ? result.status : "unknown";

    const messages: Record<string, { message: string }> = {
        Success: { message: "Model created successfully" },
        "User not found": { message: "User not found" },
        "Project not found": { message: "Project not found" },
        "Updated successfully": { message: "Updated successfully" },


    };

    const msg = messages[status] || { message: "Internal server error" };
    const Asset_Datas =
        status === "Success" && result?.data

            ? {

            }
            : undefined;


    const response = FinalResponse(status, socket, data.organization, messages, Asset_Datas);


    emitToSenderAndAdmins(io, socket, data.organization, EVENTS.asset_v1UpdateResponse, response, connectedUsersByOrg)
}
export const deleteAssetHandleEvent = async (
    event: string,
    socket: Socket,
    io: Server,
    data: any,
    connectedUsersByOrg: { [org: string]: { socketId: string; userId: string; role: string }[] },
) => {
    if (event !== EVENTS.delete_v1AssetModel || !data?.organization) return;
    const requiredFields = [
        "modelUuid",
        "modelName",
        "projectId",
        "userId",
        "organization",
    ];
    const missingFields = validateFields(data, requiredFields);

    if (missingFields.length > 0) {
        emitToSenderAndAdmins(io, socket, data.organization, EVENTS.asset_v1DeleteResponse,
            ErrorResponse(missingFields, socket, data.organization), connectedUsersByOrg);
        return;
    }
    const result = await deleteAssetModel(data);
    const status = typeof result?.status === "string" ? result.status : "unknown";

    const messages: Record<string, { message: string }> = {
        Success: { message: "Model deleted successfully" },
        "User not found": { message: "User not found" },
        "Project not found": { message: "Project not found" },
        "model not found": { message: "model not found" },
        "Failed to archive asset": { message: "Failed to archive asset" },


    };

    const msg = messages[status] || { message: "Internal server error" };
    const Asset_Datas =
        status === "Success" && result?.data

            ? {

            }
            : undefined;
    const response = FinalResponse(status, socket, data.organization, messages, Asset_Datas);


    emitToSenderAndAdmins(io, socket, data.organization, EVENTS.asset_v1DeleteResponse, response, connectedUsersByOrg)
}
export const replaceEventDatasHandleEvent = async (
    event: string,
    socket: Socket,
    io: Server,
    data: any,
    connectedUsersByOrg: { [org: string]: { socketId: string; userId: string; role: string }[] },
) => {
    if (event !== EVENTS.asset_v1EventData || !data?.organization) return;
    const requiredFields = [
        "modelUuid",
        "eventData",
        "projectId",
        "userId",
        "organization",
    ];
    const missingFields = validateFields(data, requiredFields);
    if (missingFields.length > 0) {
        emitToSenderAndAdmins(io, socket, data.organization, EVENTS.asset_v1EventDataResponse,
            ErrorResponse(missingFields, socket, data.organization), connectedUsersByOrg);
        return;
    }
    const result = await replaceEventDatas(data);
    const status = typeof result?.status === "string" ? result.status : "unknown";

    const messages: Record<string, { message: string }> = {
        Success: { message: "Data updated successfully" },
        "User not found": { message: "User not found" },
        "Project not found": { message: "Project not found" },
        "Model not for this UUID": { message: "Model not for this UUID" },
        "Failed to archive asset": { message: "Failed to archive asset" },


    };

    const msg = messages[status] || { message: "Internal server error" };
    const Asset_Datas =
        status === "Success" && result?.data

            ? {

            }
            : undefined;

    const response = FinalResponse(status, socket, data.organization, messages, Asset_Datas);

    emitToSenderAndAdmins(io, socket, data.organization, EVENTS.asset_v1EventDataResponse, response, connectedUsersByOrg)
}