XFESpaceNinjaServer

import type { RequestHandler } from "express";
import { getAccountForRequest, getBuildLabel } from "../../services/loginService.ts";
import { ePurchaseSource } from "../../types/purchaseTypes.ts";
import type { IPurchaseRequest, IPurchaseRequestU16 } from "../../types/purchaseTypes.ts";
import { handlePurchase } from "../../services/purchaseService.ts";
import { getInventory } from "../../services/inventoryService.ts";
import { sendWsBroadcastTo } from "../../services/wsService.ts";
import { toStoreItem } from "../../services/itemDataService.ts";
import { ExportBundles } from "warframe-public-export-plus";
import { version_compare } from "../../helpers/inventoryHelpers.ts";
import gameToBuildVersion from "../../constants/gameToBuildVersion.ts";
import { logger } from "../../utils/logger.ts";

export const purchasePostController: RequestHandler = async (req, res) => {
    let purchaseRequest = JSON.parse(String(req.body)) as IPurchaseRequest | IPurchaseRequestU16;
    if (!("PurchaseParams" in purchaseRequest)) {
        logger.debug("converting legacy purchase request", purchaseRequest);
        purchaseRequest = {
            PurchaseParams: {
                Source: purchaseRequest.voidTraderId ? ePurchaseSource.VoidTrader : ePurchaseSource.Market,
                SourceId: purchaseRequest.voidTraderId,
                StoreItem: toStoreItem(purchaseRequest.productName),
                Quantity: purchaseRequest.quantity,
                UsePremium: purchaseRequest.usePremium == "1"
            },
            buildLabel: ""
        } satisfies IPurchaseRequest;
    }
    const account = await getAccountForRequest(req);
    if (!purchaseRequest.buildLabel) {
        purchaseRequest.buildLabel = getBuildLabel(req, account);
    }
    const inventory = await getInventory(account._id, undefined);
    const response = await handlePurchase(purchaseRequest, inventory);
    await inventory.save();
    logger.trace("purchase response:", response);
    res.json(response);
    sendWsBroadcastTo(account._id.toString(), { update_inventory: true });
};

export const purchaseGetController: RequestHandler = async (req, res) => {
    const account = await getAccountForRequest(req);
    const accountId = account._id.toString();
    let internalName = String(req.query.productName);
    if (!(internalName in ExportBundles)) internalName = toStoreItem(internalName);
    const purchaseRequest: IPurchaseRequest = {
        PurchaseParams: {
            Source: ePurchaseSource.Market,
            StoreItem: internalName,
            Quantity: 1,
            UsePremium: Boolean(Number(req.query.usePremium))
        },
        buildLabel: getBuildLabel(req, account)
    };
    if (req.query.durability) purchaseRequest.PurchaseParams.Durability = Number(req.query.durability);
    const inventory = await getInventory(accountId, undefined);
    const response = await handlePurchase(purchaseRequest, inventory);
    await inventory.save();
    if (response.Body) {
        let body = response.Body.replace(/\/StoreItems/g, "");
        if (version_compare(purchaseRequest.buildLabel, gameToBuildVersion["8.3.0"]) <= 0) {
            body = body.replace(/lvl=\d+;/g, "");
        }
        res.send(body);
    } else {
        if (version_compare(purchaseRequest.buildLabel, gameToBuildVersion["8.0.0"]) > 0) {
            res.send(String(req.query.productName));
        } else {
            res.json(1);
        }
    }
    sendWsBroadcastTo(accountId, { update_inventory: true });
};