<?php
declare(strict_types=1);

require_once dirname(dirname(dirname(__DIR__))) . '/common/sqlsave/common.php';

try {
    $request = sqlsave_read_request();
    $userId = sqlsave_require_string($request, 'user_id');

    if (!array_key_exists('inventory', $request)) {
        throw new InvalidArgumentException('Missing required field: inventory');
    }
    if (!array_key_exists('equipped_monsters', $request)) {
        throw new InvalidArgumentException('Missing required field: equipped_monsters');
    }

    $inventoryPayload = $request['inventory'];
    if (is_string($inventoryPayload)) {
        $inventoryPayload = json_decode($inventoryPayload, true);
    }
    if (!is_array($inventoryPayload)) {
        throw new InvalidArgumentException("Field 'inventory' must be a JSON object or associative array.");
    }

    $equippedPayload = $request['equipped_monsters'];
    if (is_string($equippedPayload)) {
        $equippedPayload = json_decode($equippedPayload, true);
    }
    if (!is_array($equippedPayload)) {
        throw new InvalidArgumentException("Field 'equipped_monsters' must be a JSON object or associative array.");
    }

    $inventorySchemaVersion = isset($inventoryPayload['schema_version']) ? (int)$inventoryPayload['schema_version'] : 1;
    $inventoryUserUpdatedAt = isset($inventoryPayload['updated_at']) ? (int)$inventoryPayload['updated_at'] : time();

    $equippedSchemaVersion = isset($equippedPayload['schema_version']) ? (int)$equippedPayload['schema_version'] : $inventorySchemaVersion;
    $equippedSlotCount = isset($equippedPayload['slot_count']) ? max(1, (int)$equippedPayload['slot_count']) : 5;
    $equippedUserUpdatedAt = isset($equippedPayload['updated_at']) ? (int)$equippedPayload['updated_at'] : $inventoryUserUpdatedAt;

    $inventoryJson = json_encode($inventoryPayload, JSON_UNESCAPED_UNICODE | JSON_UNESCAPED_SLASHES);
    $equippedJson = json_encode($equippedPayload, JSON_UNESCAPED_UNICODE | JSON_UNESCAPED_SLASHES);
    if ($inventoryJson === false || $equippedJson === false) {
        throw new RuntimeException('Failed to encode crafting payload JSON.');
    }

    $inventoryHash = sha1($inventoryJson);
    $equippedHash = sha1($equippedJson);

    $db = sqlsave_connect();
    $db->begin_transaction();

    sqlsave_execute_prepared(
        $db,
        'INSERT INTO sqlsave_crafting_inventory
            (user_id, schema_version, user_updated_at, payload_json, payload_hash)
         VALUES (?, ?, ?, ?, ?)
         ON DUPLICATE KEY UPDATE
            schema_version = VALUES(schema_version),
            user_updated_at = VALUES(user_updated_at),
            payload_json = VALUES(payload_json),
            payload_hash = VALUES(payload_hash),
            updated_at = CURRENT_TIMESTAMP',
        [$userId, $inventorySchemaVersion, $inventoryUserUpdatedAt, $inventoryJson, $inventoryHash]
    );

    sqlsave_execute_prepared(
        $db,
        'INSERT INTO sqlsave_crafting_equipped_monsters
            (user_id, schema_version, slot_count, user_updated_at, payload_json, payload_hash)
         VALUES (?, ?, ?, ?, ?, ?)
         ON DUPLICATE KEY UPDATE
            schema_version = VALUES(schema_version),
            slot_count = VALUES(slot_count),
            user_updated_at = VALUES(user_updated_at),
            payload_json = VALUES(payload_json),
            payload_hash = VALUES(payload_hash),
            updated_at = CURRENT_TIMESTAMP',
        [$userId, $equippedSchemaVersion, $equippedSlotCount, $equippedUserUpdatedAt, $equippedJson, $equippedHash]
    );

    $db->commit();

    sqlsave_ok('crafting_sqlsave_save', [
        'user_id' => $userId,
        'inventory' => [
            'schema_version' => $inventorySchemaVersion,
            'user_updated_at' => $inventoryUserUpdatedAt,
            'payload_hash' => $inventoryHash,
        ],
        'equipped_monsters' => [
            'schema_version' => $equippedSchemaVersion,
            'slot_count' => $equippedSlotCount,
            'user_updated_at' => $equippedUserUpdatedAt,
            'payload_hash' => $equippedHash,
        ],
    ]);
} catch (InvalidArgumentException $e) {
    if (isset($db) && $db instanceof mysqli) {
        $db->rollback();
    }
    sqlsave_fail('crafting_sqlsave_save', 'invalid_request', $e->getMessage(), 400);
} catch (mysqli_sql_exception $e) {
    if (isset($db) && $db instanceof mysqli) {
        $db->rollback();
    }
    sqlsave_fail('crafting_sqlsave_save', 'database_error', $e->getMessage(), 500);
} catch (Throwable $e) {
    if (isset($db) && $db instanceof mysqli) {
        $db->rollback();
    }
    sqlsave_fail('crafting_sqlsave_save', 'internal_error', $e->getMessage(), 500);
}