SpaceNinjaServer/src/services/importService.ts

import { Types } from "mongoose";
import { IEquipmentClient, IEquipmentDatabase } from "../types/inventoryTypes/commonInventoryTypes";
import { IMongoDate } from "../types/commonTypes";
import { IInventoryResponse } from "../types/inventoryTypes/inventoryTypes";
import { TInventoryDatabaseDocument } from "../models/inventoryModels/inventoryModel";

const convertDate = (value: IMongoDate): Date => {
    return new Date(parseInt(value.$date.$numberLong));
};

const convertOptionalDate = (value: IMongoDate | undefined): Date | undefined => {
    return value ? convertDate(value) : undefined;
};

const convertEquipment = (client: IEquipmentClient): IEquipmentDatabase => {
    // eslint-disable-next-line @typescript-eslint/no-unused-vars
    const { ItemId, ...rest } = client;
    return {
        ...rest,
        _id: new Types.ObjectId(client.ItemId.$oid),
        InfestationDate: convertOptionalDate(client.InfestationDate),
        Expiry: convertOptionalDate(client.Expiry),
        UpgradesExpiry: convertOptionalDate(client.UpgradesExpiry)
    };
};

export const importInventory = (
    db: TInventoryDatabaseDocument,
    client: IInventoryResponse,
    replace: boolean = false,
    update: boolean = true
): void => {
    const clientSuitsInDbFormat = client.Suits.map(x => convertEquipment(x));
    if (replace) {
        db.Suits.splice(0, db.Suits.length);
    }
    clientSuitsInDbFormat.forEach(suitToImport => {
        if (update) {
            const index = db.Suits.findIndex(x => x._id == suitToImport._id);
            if (index != -1) {
                db.Suits.splice(index, 1);
            }
        } else {
            if (db.Suits.id(suitToImport._id)) {
                return;
            }
        }
        db.Suits.push(suitToImport);
    });
};