import { z } from "https://esm.sh/zod"; import { sqlite } from "https://esm.town/v/stevekrouse/sqlite"; // Constants const SCHEMA_VERSION = 10; const KEY = new URL(import.meta.url).pathname.split("/").at(-1); const INVENTORY_TABLE = `${KEY}_inventory_${SCHEMA_VERSION}`; const DEFAULT_IMAGE_URL = "https://res.cloudinary.com/dzkwltgyd/image/upload/v1733165766/image-input-block-production/apjbm5nfc6yoevwnisxh.jpg"; // Inventory Database Initialization async function initializeInventoryDatabase() { await sqlite.execute(` CREATE TABLE IF NOT EXISTS ${INVENTORY_TABLE} ( id TEXT PRIMARY KEY, address TEXT NOT NULL, item_name TEXT NOT NULL, item_type TEXT NOT NULL, image_url TEXT NOT NULL, description TEXT, quantity INTEGER NOT NULL DEFAULT 1, weight REAL, rarity TEXT, durability REAL, created_at DATETIME DEFAULT CURRENT_TIMESTAMP, UNIQUE(address, item_name, item_type) ) `); await sqlite.execute(` CREATE INDEX IF NOT EXISTS idx_inventory_address ON ${INVENTORY_TABLE} (address) `); await sqlite.execute(` CREATE INDEX IF NOT EXISTS idx_inventory_item_type ON ${INVENTORY_TABLE} (item_type) `); } // Enum for Item Rarity const ItemRarityEnum = z.enum([ "common", "uncommon", "rare", "legendary", ]); // Item Schema const CreateItemSchema = z.object({ name: z.string() .min(1, "Item name is required") .max(100, "Item name must be 100 characters or less"), image: z.string() .url("Valid image URL is required") .max(500, "Image URL must be 500 characters or less") .optional(), type: z.string() .min(1, "Item type is required") .max(50, "Item type must be 50 characters or less"), description: z.string() .max(500, "Description must be 500 characters or less") .optional(), quantity: z.number() .int("Quantity must be an integer") .positive("Quantity must be positive") .default(1) .optional(), weight: z.number().optional(), rarity: ItemRarityEnum.optional(), durability: z.number().optional(), }); // Inventory Operations async function getUserInventory(address?: string, itemId?: string, type?: string) { let query = `SELECT * FROM ${INVENTORY_TABLE}`; let params: string[] = []; let conditions: string[] = []; if (address) { const normalizedAddress = normalizeAddress(address); conditions.push("address = ?"); params.push(normalizedAddress); } if (itemId) { conditions.push("id = ?"); params.push(itemId); } if (type) { conditions.push("item_type = ?"); params.push(type); } if (conditions.length > 0) { query += ` WHERE ${conditions.join(" AND ")}`; } console.log(`Fetching inventory with query: ${query}`); const result = await sqlite.execute(query, params); console.log(`Found ${result.rows.length} inventory items`); // Explicitly return an empty array if no rows found if (result.rows.length === 0) { return []; } return result.rows.map(row => ({ id: row.id, name: row.item_name, image: row.image_url, type: row.item_type, description: row.description, quantity: row.quantity, weight: row.weight, rarity: row.rarity, durability: row.durability, address: row.address, createdAt: new Date(row.created_at), })); } async function addItemToInventory(address: string, item: z.infer) { const normalizedAddress = normalizeAddress(address); const itemId = crypto.randomUUID(); await sqlite.execute( `INSERT INTO ${INVENTORY_TABLE} ( id, address, item_name, item_type, image_url, description, quantity, weight, rarity, durability ) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?) ON CONFLICT(address, item_name, item_type) DO UPDATE SET quantity = quantity + ?, durability = COALESCE(?, durability)`, [ itemId, normalizedAddress, item.name, item.type, item.image || DEFAULT_IMAGE_URL, item.description || null, item.quantity || 1, item.weight || null, item.rarity || null, item.durability || null, item.quantity || 1, item.durability, ], ); return itemId; } async function removeItemFromInventory(address: string, itemId: string, quantity: number = 1) { const normalizedAddress = normalizeAddress(address); const result = await sqlite.execute( `UPDATE ${INVENTORY_TABLE} SET quantity = quantity - ? WHERE address = ? AND id = ? AND quantity >= ?`, [quantity, normalizedAddress, itemId, quantity] ); if (result.rowsAffected === 0) { throw new Error("Item not found or insufficient quantity"); } await sqlite.execute( `DELETE FROM ${INVENTORY_TABLE} WHERE quantity <= 0` ); return { message: "Item removed successfully" }; } async function transferItem(fromAddress: string, toAddress: string, itemId: string, quantity: number = 1) { const normalizedFromAddress = normalizeAddress(fromAddress); const normalizedToAddress = normalizeAddress(toAddress); let transactionActive = false; try { await sqlite.execute('BEGIN TRANSACTION'); transactionActive = true; // Remove from sender const removeResult = await sqlite.execute( `UPDATE ${INVENTORY_TABLE} SET quantity = quantity - ? WHERE address = ? AND id = ? AND quantity >= ?`, [quantity, normalizedFromAddress, itemId, quantity] ); if (removeResult.rowsAffected === 0) { throw new Error("Item not found or insufficient quantity"); } // Add to receiver const item = (await sqlite.execute( `SELECT * FROM ${INVENTORY_TABLE} WHERE id = ?`, [itemId] )).rows[0]; if (!item) { throw new Error("Item not found"); } await addItemToInventory(normalizedToAddress, { ...item, quantity: quantity }); await sqlite.execute('COMMIT'); transactionActive = false; return { message: "Item transferred successfully" }; } catch (error) { if (transactionActive) { await sqlite.execute('ROLLBACK'); } throw error; } } function normalizeAddress(address: string): string { return address.toLowerCase().trim(); } // Main Handler export default async function(req: Request): Promise { await initializeInventoryDatabase(); const url = new URL(req.url); const path = url.pathname; try { // Public routes if (req.method === "GET" && path === "/") { return new Response(generateInstructions(url.origin), { headers: { "Content-Type": "text/html" }, }); } // Get Inventory Route if (req.method === "GET" && path === "/inventory") { const address = url.searchParams.get("address"); const itemId = url.searchParams.get("id"); const type = url.searchParams.get("type"); if (!address && !itemId && !type) { return new Response( JSON.stringify({ error: "At least one of address, id, or type is required", }), { status: 400, headers: { "Content-Type": "application/json" }, }, ); } const inventory = await getUserInventory(address || undefined, itemId || undefined, type || undefined); return new Response( JSON.stringify({ inventory, message: inventory.length > 0 ? `Inventory retrieved${address ? ` for ${address}` : ''}${itemId ? ` with item ID ${itemId}` : ''}${type ? ` of type ${type}` : ''}` : `No items found${address ? ` for ${address}` : ''}${itemId ? ` with item ID ${itemId}` : ''}${type ? ` of type ${type}` : ''}`, }), { headers: { "Content-Type": "application/json" }, }, ); } // Add Item Route if (req.method === "POST" && path === "/add") { const { address, item } = await req.json(); try { CreateItemSchema.parse(item); } catch (validationError) { return new Response( JSON.stringify({ error: "Invalid item", details: validationError.errors, }), { status: 400, headers: { "Content-Type": "application/json" }, }, ); } const itemId = await addItemToInventory(address, item); return new Response( JSON.stringify({ message: `Item added to ${address}'s inventory`, itemId, }), { headers: { "Content-Type": "application/json" }, }, ); } // Remove Item Route if (req.method === "POST" && path === "/remove") { const { address, itemId, quantity } = await req.json(); const result = await removeItemFromInventory(address, itemId, quantity); return new Response( JSON.stringify(result), { headers: { "Content-Type": "application/json" }, }, ); } // Transfer Item Route if (req.method === "POST" && path === "/transfer") { const { fromAddress, toAddress, itemId, quantity = 1 } = await req.json(); const result = await transferItem(fromAddress, toAddress, itemId, quantity); return new Response( JSON.stringify(result), { headers: { "Content-Type": "application/json" }, }, ); } return new Response( JSON.stringify({ error: "Not Found", }), { status: 404, headers: { "Content-Type": "application/json" }, }, ); } catch (error) { console.error("Unhandled error:", error); return new Response( JSON.stringify({ error: error.message || "An unexpected error occurred", }), { status: 500, headers: { "Content-Type": "application/json" }, }, ); } } function generateInstructions(baseUrl: string): string { return ` 🎒 Inventory Management System

🎒 Inventory Management System

API Routes

GET /inventory

Retrieve inventory items. Use address, id, or type parameter:

?address=USER_ADDRESS - Retrieve a user's entire inventory
?id=ITEM_ID - Retrieve a specific item by its ID
?type=ITEM_TYPE - Retrieve all items of a specific type

Examples:

curl "${baseUrl}/inventory?address=0x123456789abcdef"
curl "${baseUrl}/inventory?id=item-uuid-here"
curl "${baseUrl}/inventory?type=tool"

POST /add

Add a new item to a user's inventory

curl -X POST "${baseUrl}/add" \
-H "Content-Type: application/json" \
-d '{
  "address": "0x123456789abcdef",
  "item": {
    "name": "Magic Sword",
    "image": "https://example.com/sword.png",
    "type": "tool",
    "description": "A powerful magical sword",
    "quantity": 1,
    "rarity": "legendary"
  }
}'

Note: The "image" field is optional. If not provided, a default image will be used.

POST /remove

Remove an item from a user's inventory

curl -X POST "${baseUrl}/remove" \
-H "Content-Type: application/json" \
-d '{
  "address": "0x123456789abcdef",
  "itemId": "item-uuid-here",
  "quantity": 1
}'

POST /transfer

Transfer an item between users. If quantity is not specified, it defaults to 1.

curl -X POST "${baseUrl}/transfer" \
-H "Content-Type: application/json" \
-d '{
  "fromAddress": "0x123456789abcdef",
  "toAddress": "0x987654321fedcba",
  "itemId": "item-uuid-here",
  "quantity": 1
}'

Item Types

Any string is allowed for item type (e.g., furniture, electronics, clothing, tool, misc)

Item Rarities

common, uncommon, rare, legendary

View source: Val Town

`; }

glifInventory

Version 29