import {db} from "../../../../database/dbclient.js";
import {ocmeData} from "../../../../database/schema/ocme.js";
import {createSSCC} from "../../../globalUtils/createSSCC.js";
import {createLog} from "../../logger/logger.js";
import {query} from "../../sqlServer/prodSqlServer.js";
import {labelData} from "../../sqlServer/querys/materialHelpers/labelInfo.js";

export const postLabelData = async (data: any) => {
    // if we have sscc we will do everything here and ignore the rn even it its sent over
    if (data.sscc && !data.runningNr) {
        data.runningNr = data.sscc.slice(10, -1);
    }

    if (!data.sscc && !data.runningNr) {
        // data.runningNr = data.sscc.slice(10, -1);
        return {success: false, message: "Missing data please try again", data: []};
    }

    let label;
    const filterQuery = labelData.replaceAll("[rn]", data.runningNr);

    try {
        label = await query(filterQuery, "Label data");
    } catch (error) {
        createLog("error", "ocme", "ocme", "There was an error getting the labelData");
    }
    const newPost = {
        sscc: data.sscc ? data.sscc : await createSSCC(data.runningNr),
        runningNr: data.runningNr,
        completed: data.completed,
        lineNum: label[0].machineLocation,
        areaFrom: data.areaFrom,
        pickedUp: false,
    };

    try {
        const enterNewData = await db.insert(ocmeData).values(newPost).returning({sscc: ocmeData.sscc});
        return {success: true, message: "Data was posted to ocme info", data: enterNewData};
    } catch (error) {
        console.log(error);
        return {success: false, message: "Data was posted to ocme info", data: newPost};
    }
};