\n\n \n \n \n \n \n

\n View Source on Val Town\n

\n\n",[],[263,265],"86424948-3303-11f0-8683-569c3dd06744","ViewInventoryView.tsx","a61b94fe-3286-11f0-9d8b-569c3dd06744","9982fe32-327f-11f0-bda9-569c3dd06744",70,["D",1747475067797],2,"/** @jsxImportSource https://esm.sh/preact@10.19.6 */\nimport { h, FunctionComponent, JSX } from \"https://esm.sh/preact@10.19.6\";\nimport { useState, useEffect } from \"https://esm.sh/preact@10.19.6/hooks\";\nimport { User, Product, InventoryBatch } from \"../../shared/types.ts\";\n// import * as apiClient from \"../apiClient.ts\"; // Will be removed\n\nconst API_BASE_URL = \"/api\";\n\ninterface ViewInventoryViewProps {\n currentUser: User | null;\n}\n\nconst ViewInventoryView: FunctionComponent = ({ currentUser }) => {\n const [products, setProducts] = useState<(Product & { categoryName?: string, currentQuantity?: number })[]>([]);\n const [selectedProduct, setSelectedProduct] = useState<(Product & { categoryName?: string, currentQuantity?: number }) | null>(null);\n const [productBatches, setProductBatches] = useState([]);\n const [searchTerm, setSearchTerm] = useState(\"\");\n const [isLoading, setIsLoading] = useState(false);\n const [error, setError] = useState(null);\n\n const fetchInventoryData = async () => {\n if (!currentUser) return;\n setIsLoading(true);\n setError(null);\n try {\n // Direct fetch for products\n const queryParams = new URLSearchParams();\n if (searchTerm) queryParams.append(\"search\", searchTerm);\n const queryString = queryParams.toString();\n let response = await fetch(`${API_BASE_URL}/products${queryString ? `?${queryString}` : \"\"}`, {\n headers: { \"Accept\": \"application/json\", \"X-User-Id\": currentUser.id } // X-User-Id might not be strictly needed by backend for GET products\n });\n if (!response.ok) {\n const errorData = await response.json().catch(() => ({ message: `HTTP error ${response.status}`}));\n throw new Error(errorData.message || `Failed to fetch products: ${response.status}`);\n }\n const fetchedProducts: Product[] = await response.json();\n\n // Fetch total quantity for each product\n const productsWithQuantity = await Promise.all(\n fetchedProducts.map(async (p) => {\n try {\n // Direct fetch for total product quantity\n const qtyResponse = await fetch(`${API_BASE_URL}/inventory/products/${p.id}/total`, {\n headers: { \"Accept\": \"application/json\", \"X-User-Id\": currentUser.id } // X-User-Id might not be strictly needed\n });\n if (!qtyResponse.ok) {\n // Don't let a single quantity fetch fail all products, just log and default\n console.warn(`Failed to fetch quantity for ${p.name}: ${qtyResponse.status}`);\n return { ...p, currentQuantity: 0 };\n }\n const qtyData: { productId: string; totalQuantity: number } = await qtyResponse.json();\n // Ensure categoryName is preserved if it exists on 'p' from a previous fetch (though not in this specific flow)\n const existingProduct = p as (Product & { categoryName?: string });\n return { \n ...existingProduct, \n currentQuantity: qtyData.totalQuantity \n };\n } catch (e) {\n console.warn(`Failed to fetch quantity for ${p.name}`, e);\n return { ...p, currentQuantity: 0 }; // Default if fetch fails\n }\n })\n );\n setProducts(productsWithQuantity);\n } catch (err) {\n setError(err.message || \"Failed to fetch inventory.\");\n console.error(err);\n } finally {\n setIsLoading(false);\n }\n };\n\n useEffect(() => {\n fetchInventoryData();\n }, [currentUser, searchTerm]); // Re-fetch if user changes or search term changes\n\n const handleProductSelect = async (product: Product & { categoryName?: string, currentQuantity?: number }) => {\n setSelectedProduct(product);\n if (!currentUser) return;\n setIsLoading(true);\n try {\n // Direct fetch for inventory batches by product\n const response = await fetch(`${API_BASE_URL}/inventory/batches?productId=${product.id}`, {\n headers: { \"Accept\": \"application/json\", \"X-User-Id\": currentUser.id } // X-User-Id might not be strictly needed\n });\n if (!response.ok) {\n const errorData = await response.json().catch(() => ({ message: `HTTP error ${response.status}`}));\n throw new Error(errorData.message || `Failed to fetch batches for ${product.name}: ${response.status}`);\n }\n const batches: InventoryBatch[] = await response.json();\n setProductBatches(batches);\n } catch (err) {\n setError(err.message || `Failed to fetch batches for ${product.name}`);\n } finally {\n setIsLoading(false);\n }\n };\n\n return (\n <>\n

Current Inventory

\n {error &&

Error: {error}

}\n

\n setSearchTerm((e.target as HTMLInputElement).value)}\n className=\"w-full p-3 border border-gray-300 dark:border-gray-600 dark:bg-gray-700 dark:text-white rounded-md focus:ring-primary focus:border-primary dark:focus:ring-blue-500 dark:focus:border-blue-500\"\n />\n

\n {isLoading &&

Loading inventory...

}\n

\n \n \n \n \n \n \n \n \n \n \n \n {products.length === 0 && !isLoading && (\n \n \n \n )}\n {products.map((product) => (\n \n \n \n \n \n \n \n ))}\n \n

Product	Brand	Category	Total Quantity	Actions
\n No inventory items found. Try a different search or add products.\n
{product.name}	{product.brand}	{product.categoryName \|\| product.category}	{product.currentQuantity ?? 'N/A'}	\n \n

\n {selectedProduct && (\n

Batches for: {selectedProduct.name}

\n {isLoading && productBatches.length === 0 &&

Loading batches...

}\n {productBatches.length === 0 && !isLoading &&

No batches found for this product.

}\n {productBatches.length > 0 && (\n

\n Qty: {batch.quantityCurrent} (Received: {batch.quantityReceived}) | Expires: {new Date(batch.expiryDate).toLocaleDateString()} | Cost: ${batch.costPrice?.toFixed(2)} | Received: {new Date(batch.receiptDate).toLocaleDateString()}\n

\n )}\n

\n )}\n \n );\n};\n\nexport default ViewInventoryView;",[],[263,282,273],"components","b677a0b6-3341-11f0-8892-9e149126039e","UpdateInventoryView.tsx","a667ed40-3286-11f0-8e06-569c3dd06744",113,["D",1747501777559],"/** @jsxImportSource https://esm.sh/preact@10.19.6 */\nimport {h, FunctionComponent, JSX} from \"https://esm.sh/preact@10.19.6\"\nimport {useState, useEffect} from \"https://esm.sh/preact@10.19.6/hooks\"\nimport {User, Product, ProductDetectionResponse} from \"../../shared/types.ts\"\n// import * as apiClient from \"../apiClient.ts\"; // Will be removed\n\nconst API_BASE_URL = \"/api\"\n\ninterface UpdateInventoryViewProps {\n currentUser: User | null\n}\n\nconst UpdateInventoryView: FunctionComponent = ({currentUser}) => {\n const [products, setProducts] = useState([])\n const [selectedProductId, setSelectedProductId] = useState(\"\")\n const [actualCount, setActualCount] = useState(\"\")\n const [isLoading, setIsLoading] = useState(false)\n const [error, setError] = useState(null)\n const [successMessage, setSuccessMessage] = useState(null)\n\n useEffect(() => {\n if (currentUser) {\n // Direct fetch for products\n fetch(`${API_BASE_URL}/products`, {\n headers: {\"Accept\": \"application/json\", \"X-User-Id\": currentUser.id} // X-User-Id might not be strictly needed\n })\n .then(async res => {\n if (!res.ok) {\n const errorData = await res.json().catch(() => ({message: `HTTP error ${res.status}`}))\n throw new Error(errorData.message || `Failed to fetch products: ${res.status}`)\n }\n return res.json()\n })\n .then(setProducts)\n .catch(err => setError(err.message || \"Failed to fetch products for reconciliation.\"))\n }\n }, [currentUser])\n\n const handleReconcile = async (e: JSX.TargetedEvent) => {\n e.preventDefault()\n if (!currentUser || !selectedProductId || actualCount === \"\") {\n setError(\"Please select a product and enter the actual physical count.\")\n return\n }\n const count = parseInt(actualCount, 10)\n if (isNaN(count) || count < 0) {\n setError(\"Actual count must be a non-negative number.\")\n return\n }\n\n setIsLoading(true)\n setError(null)\n setSuccessMessage(null)\n try {\n // Direct fetch for reconcileInventory\n const response = await fetch(`${API_BASE_URL}/inventory/reconcile`, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"Accept\": \"application/json\",\n \"X-User-Id\": currentUser.id\n },\n body: JSON.stringify({productId: selectedProductId, actualPhysicalCount: count}),\n })\n if (!response.ok) {\n const errorData = await response.json().catch(() => ({message: `HTTP error ${response.status}`}))\n throw new Error(errorData.message || `Failed to reconcile inventory: ${response.status}`)\n }\n const result: {discrepancies: number; updatedBatches: any[]} = await response.json() // Assuming any[] for updatedBatches for simplicity\n\n\n setSuccessMessage(`Inventory reconciled for product. Discrepancy: ${result.discrepancies}. ${result.updatedBatches.length} batches affected.`)\n // Optionally clear form or update product list if quantities are shown elsewhere\n setSelectedProductId(\"\")\n setActualCount(\"\")\n } catch (err) {\n setError(err.message || \"Failed to reconcile inventory.\")\n console.error(err)\n } finally {\n setIsLoading(false)\n }\n }\n\n const handleFileChangeAndProcess = async (event: JSX.TargetedEvent) => {\n if (!currentUser) {\n setError(\"Please log in to use this feature.\")\n return\n }\n const file = (event.target as HTMLInputElement).files?.[0]\n if (!file) {\n return\n }\n\n setIsLoading(true)\n setError(null)\n setSuccessMessage(null)\n\n try {\n const imageBase64 = await new Promise((resolve, reject) => {\n const reader = new FileReader()\n reader.onload = () => resolve((reader.result as string).split(\",\")[1])\n reader.onerror = (error) => reject(error)\n reader.readAsDataURL(file)\n })\n\n const detectResponse = await fetch(`${API_BASE_URL}/images/detect-products`, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"Accept\": \"application/json\",\n // \"X-User-Id\": currentUser.id, // Not strictly needed by detect-products but good for consistency if other AI endpoints use it\n },\n body: JSON.stringify({imageBase64}),\n })\n\n if (!detectResponse.ok) {\n const errorData = await detectResponse.json().catch(() => ({message: `HTTP error ${detectResponse.status}`}))\n throw new Error(errorData.message || `AI product detection failed: ${detectResponse.status}`)\n }\n\n const detectionResult: ProductDetectionResponse = await detectResponse.json()\n\n if (!detectionResult.products || detectionResult.products.length === 0) {\n setSuccessMessage(\"AI did not detect any products in the image.\")\n setIsLoading(false)\n return\n }\n\n let reconciliationMessages: string[] = [`AI detected ${detectionResult.products.length} product(s):`]\n let allSuccessful = true\n\n for (const detectedProduct of detectionResult.products) {\n const foundProduct = products.find(p => p.name.toLowerCase() === detectedProduct.productName.toLowerCase())\n console.log({foundProduct, detectedProduct})\n if (foundProduct) {\n try {\n const reconcileResponse = await fetch(`${API_BASE_URL}/inventory/reconcile`, {\n method: \"POST\",\n headers: {\"Content-Type\": \"application/json\", \"Accept\": \"application/json\", \"X-User-Id\": currentUser.id},\n body: JSON.stringify({productId: foundProduct.id, actualPhysicalCount: detectedProduct.estimatedQuantity}),\n })\n\n if (!reconcileResponse.ok) {\n const errorData = await reconcileResponse.json().catch(() => ({message: `HTTP error ${reconcileResponse.status}`}))\n reconciliationMessages.push(` - Failed to reconcile ${foundProduct.name} (AI: ${detectedProduct.estimatedQuantity}): ${errorData.message || reconcileResponse.status}`)\n allSuccessful = false\n } else {\n const result: {discrepancies: number; updatedBatches: any[]} = await reconcileResponse.json()\n reconciliationMessages.push(` - ${foundProduct.name} (AI: ${detectedProduct.estimatedQuantity} units): Reconciled. Discrepancy: ${result.discrepancies}.`)\n }\n } catch (reconcileError) {\n reconciliationMessages.push(` - Error reconciling ${foundProduct.name}: ${reconcileError.message}`)\n allSuccessful = false\n }\n } else {\n reconciliationMessages.push(` - Product \"${detectedProduct.productName}\" (AI: ${detectedProduct.estimatedQuantity} units) not found in system. Please add or reconcile manually.`)\n allSuccessful = false\n }\n }\n (allSuccessful ? setSuccessMessage : setError)(reconciliationMessages.join(\"\\n\"))\n } catch (err) {\n setError(err.message || \"An error occurred during AI processing or reconciliation.\")\n } finally {\n setIsLoading(false)\n if (event.target) (event.target as HTMLInputElement).value = \"\" // Clear file input\n }\n }\n\n return (\n <>\n

Reconcile Inventory (Cycle Count)

\n {error &&

Error: {error}

}\n {successMessage &&

{successMessage}

}\n

\n \n Select Stock Count Sheet/Update Document (Photo/PDF)\n \n \n

\n Upload an image of your stock count sheet. The AI will attempt to detect products and their quantities, then reconcile them.\n

\n {products.length === 0 && currentUser &&

Loading product list for AI matching...

}\n\n

\n \n Select Product to Reconcile\n \n setSelectedProductId((e.target as HTMLSelectElement).value)}\n className=\"w-full p-3 border border-gray-300 dark:border-gray-600 dark:bg-gray-700 dark:text-white rounded-md disabled:opacity-50\"\n disabled={isLoading || !currentUser}\n required\n >\n \n {products.map(p => )}\n \n

\n \n Actual Physical Count\n \n setActualCount((e.target as HTMLInputElement).value)}\n className=\"w-full p-3 border border-gray-300 dark:border-gray-600 dark:bg-gray-700 dark:text-white rounded-md disabled:opacity-50\"\n disabled={isLoading || !currentUser}\n required min=\"0\" />\n

\n \n {isLoading ? \"Reconciling...\" : \"Reconcile Stock\"}\n \n \n

\n \n )\n}\n\nexport default UpdateInventoryView",[],[263,282,284],"400848c6-3324-11f0-9d7e-9e149126039e","ScanBillView.tsx","a622f7f8-3286-11f0-8e06-569c3dd06744",107,["D",1747489123301],"/** @jsxImportSource https://esm.sh/preact@10.19.6 */\nimport {h, FunctionComponent, JSX} from \"https://esm.sh/preact@10.19.6\"\nimport {useState, useEffect} from \"https://esm.sh/preact@10.19.6/hooks\"\nimport {User, SupplierBill, Product, Category, CreateProductPayload, SupplierBillItem as SharedSupplierBillItem, BillScanResponse} from \"../../shared/types.ts\"\n// import * as apiClient from \"../apiClient.ts\"; // Will be removed\n\ninterface ScanBillViewProps {\n currentUser: User | null\n}\n\n// Frontend specific type for bill items during review\ninterface ReviewBillItem extends SharedSupplierBillItem {\n id: string // For UI key\n resolvedProductId?: string\n expiryDate?: string // YYYY-MM-DD, now optional\n costPrice: number\n isNewProduct: boolean\n newProductDetails?: Omit & {categoryNameOrId?: string} // categoryId is the field in CreateProductPayload, categoryNameOrId is for UI, now optional\n}\n\n// Moved from apiClient.ts\ninterface ConfirmBillFrontendPayload {\n reviewedItems: Array<{\n productName: string\n quantity: number\n unitPrice: number\n total: number\n resolvedProductId?: string\n expiryDate?: string // Optional\n costPrice?: number\n isNewProduct?: boolean\n newProductDetails?: Omit & {categoryNameOrId?: string} // Optional category\n }>\n}\nconst API_BASE_URL = \"/api\"\n\nconst ScanBillView: FunctionComponent = ({currentUser}) => {\n const [selectedFile, setSelectedFile] = useState(null)\n const [imageBase64, setImageBase64] = useState(null)\n const [uploadedBillId, setUploadedBillId] = useState(null)\n const [processedBill, setProcessedBill] = useState(null)\n const [reviewItems, setReviewItems] = useState([])\n const [products, setProducts] = useState([])\n const [categories, setCategories] = useState([])\n const [isLoading, setIsLoading] = useState(false)\n const [error, setError] = useState(null)\n const [step, setStep] = useState<\"upload\" | \"review\" | \"confirmed\">(\"upload\")\n\n useEffect(() => {\n if (step === \"review\" && currentUser) {\n // Fetch products\n fetch(`${API_BASE_URL}/products`, {\n headers: {\"Accept\": \"application/json\", \"X-User-Id\": currentUser.id}\n })\n .then(async res => {\n if (!res.ok) {\n const errorData = await res.json().catch(() => ({message: `HTTP error ${res.status}`}))\n throw new Error(errorData.message || `Failed to fetch products: ${res.status}`)\n }\n return res.json()\n })\n .then(setProducts)\n .catch(err => {\n setError(err.message)\n console.error(\"Fetch products error:\", err)\n })\n\n // Fetch categories\n fetch(`${API_BASE_URL}/categories`, {\n headers: {\"Accept\": \"application/json\", \"X-User-Id\": currentUser.id} // X-User-Id might not be strictly needed by backend for GET categories\n })\n .then(async res => {\n if (!res.ok) {\n const errorData = await res.json().catch(() => ({message: `HTTP error ${res.status}`}))\n throw new Error(errorData.message || `Failed to fetch categories: ${res.status}`)\n }\n return res.json()\n })\n .then(setCategories)\n .catch(err => {\n setError(err.message)\n console.error(\"Fetch categories error:\", err)\n })\n }\n }, [step, currentUser])\n\n const handleFileChange = (e: JSX.TargetedEvent) => {\n const file = (e.target as HTMLInputElement).files?.[0]\n if (file) {\n setSelectedFile(file)\n const reader = new FileReader()\n reader.onloadend = () => {\n setImageBase64(reader.result as string)\n }\n reader.readAsDataURL(file)\n }\n }\n\n const handleUploadAndProcess = async () => {\n if (!imageBase64 || !selectedFile || !currentUser) {\n setError(\"Please select a file and ensure you are logged in.\")\n return\n }\n setIsLoading(true)\n setError(null)\n try {\n const base64Data = imageBase64.split(\",\")[1] // Remove data:image/jpeg;base64, part\n\n // Direct fetch for uploadBill\n let response = await fetch(`${API_BASE_URL}/bills/upload`, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"Accept\": \"application/json\",\n \"X-User-Id\": currentUser.id\n },\n body: JSON.stringify({imageBase64: base64Data, originalFileName: selectedFile.name}),\n })\n if (!response.ok) {\n const errorData = await response.json().catch(() => ({message: `HTTP error ${response.status}`}))\n throw new Error(errorData.message || `Failed to upload bill: ${response.status}`)\n }\n const uploadResult: {billId: string; imageUrl: string} = await response.json()\n setUploadedBillId(uploadResult.billId)\n\n // Direct fetch for processBillAI\n response = await fetch(`${API_BASE_URL}/bills/process/${uploadResult.billId}`, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\", // Though no body, standard practice\n \"Accept\": \"application/json\",\n \"X-User-Id\": currentUser.id\n },\n })\n if (!response.ok) {\n const errorData = await response.json().catch(() => ({message: `HTTP error ${response.status}`}))\n throw new Error(errorData.message || `Failed to process bill AI: ${response.status}`)\n }\n // The backend returns SupplierBill, but the AI service returns BillScanResponse.\n // The billService.processBillWithAI returns SupplierBill.\n // The apiClient.processBillAI was typed to return SupplierBill.\n // Let's assume the backend /api/bills/process/:billId returns SupplierBill\n const billData: SupplierBill = await response.json()\n\n if (!billData || !billData.items) {\n throw new Error(\"Processed bill data is invalid or missing items.\")\n }\n setProcessedBill(billData)\n setReviewItems(billData.items.map((item, index) => ({\n ...item,\n id: `item-${index}-${Date.now()}`, // unique key for UI\n expiryDate: '', // User needs to fill this\n costPrice: item.unitPrice, // Default cost price to unit price\n isNewProduct: false,\n })))\n setStep(\"review\")\n } catch (err) {\n setError(err.message || \"Failed to upload or process bill.\")\n console.error(err)\n } finally {\n setIsLoading(false)\n }\n }\n\n const handleReviewItemChange = (index: number, field: keyof ReviewBillItem, value: any) => {\n setReviewItems(prev => prev.map((item, i) => i === index ? {...item, [field]: value} : item))\n }\n\n const handleToggleNewProduct = (index: number) => {\n setReviewItems(prev => prev.map((item, i) => {\n if (i === index) {\n const isNew = !item.isNewProduct\n return {\n ...item,\n isNewProduct: isNew,\n resolvedProductId: isNew ? undefined : item.resolvedProductId, // Clear resolved ID if marking as new\n newProductDetails: isNew ? {name: item.productName, brand: 'Chhaswala', defaultPrice: item.unitPrice, categoryNameOrId: ''} : undefined,\n }\n }\n return item\n }))\n }\n\n const handleNewProductDetailChange = (index: number, field: string, value: any) => {\n setReviewItems(prev => prev.map((item, i) => {\n if (i === index && item.newProductDetails) {\n return {...item, newProductDetails: {...item.newProductDetails, [field]: value}}\n }\n return item\n }))\n }\n\n const handleConfirmBill = async () => {\n if (!uploadedBillId || !currentUser) return\n setIsLoading(true)\n setError(null)\n try {\n // Validate reviewItems - especially expiryDate and newProductDetails if isNewProduct is true\n // Optional validation: only check brand for new products if category is optional\n for (const item of reviewItems) {\n if (item.isNewProduct && !item.newProductDetails?.brand) { // Brand might still be considered essential for a new product\n throw new Error(`New product details (brand) are missing for: ${item.productName}`)\n }\n }\n\n const payload = {\n reviewedItems: reviewItems.map(item => ({\n productName: item.productName,\n quantity: item.quantity,\n unitPrice: item.unitPrice,\n total: item.total,\n resolvedProductId: item.resolvedProductId,\n expiryDate: item.expiryDate,\n costPrice: item.costPrice,\n isNewProduct: item.isNewProduct,\n newProductDetails: item.isNewProduct ? item.newProductDetails : undefined,\n })),\n }\n\n // Direct fetch for confirmBill\n const response = await fetch(`${API_BASE_URL}/bills/${uploadedBillId}/confirm`, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"Accept\": \"application/json\",\n \"X-User-Id\": currentUser.id\n },\n body: JSON.stringify(payload),\n })\n if (!response.ok) {\n const errorData = await response.json().catch(() => ({message: `HTTP error ${response.status}`}))\n throw new Error(errorData.message || `Failed to confirm bill: ${response.status}`)\n }\n // const confirmResult: {success: boolean; createdBatches: InventoryBatch[]; newProducts: Product[]} = await response.json();\n await response.json() // Use the result if needed\n\n setStep(\"confirmed\")\n // Reset form for next bill\n setSelectedFile(null)\n setImageBase64(null)\n setUploadedBillId(null)\n setProcessedBill(null)\n setReviewItems([])\n } catch (err) {\n setError(err.message || \"Failed to confirm bill.\")\n console.error(err)\n } finally {\n setIsLoading(false)\n }\n }\n\n return (\n <>\n

Scan New Bill

\n {error &&

Error: {error}

}\n\n {step === \"upload\" && (\n

\n \n Select Bill Photo/PDF\n \n \n

\n \n {isLoading ? \"Processing...\" : \"Upload & Process Bill\"}\n \n

\n Note: AI processing might take a few moments.\n

\n )}\n\n {step === \"review\" && processedBill && (\n

Review Bill: {processedBill.supplierName} ({processedBill.billDate})

\n {reviewItems.map((item, index) => (\n

{item.productName} - Qty: {item.quantity}, Unit Price: {item.unitPrice}, Total: {item.total}

\n\n

\n Match Product (or mark as new)\n handleReviewItemChange(index, \"resolvedProductId\", (e.target as HTMLSelectElement).value || undefined)}\n disabled={item.isNewProduct}\n className=\"w-full p-2 border rounded dark:bg-gray-700 dark:border-gray-600 dark:text-white\"\n >\n \n {products.map(p => )}\n \n

\n Expiry Date (YYYY-MM-DD)\n handleReviewItemChange(index, \"expiryDate\", (e.target as HTMLInputElement).value || undefined)} className=\"w-full p-2 border rounded dark:bg-gray-700 dark:border-gray-600 dark:text-white\" />\n

\n\n

\n Cost Price (per unit)\n handleReviewItemChange(index, \"costPrice\", parseFloat((e.target as HTMLInputElement).value))} className=\"w-full p-2 border rounded dark:bg-gray-700 dark:border-gray-600 dark:text-white\" />\n

\n\n

\n handleToggleNewProduct(index)} className=\"mr-2\" />\n This is a new product\n

\n\n {item.isNewProduct && item.newProductDetails && (\n

New Product Details for \"{item.productName}\"

\n Brand\n handleNewProductDetailChange(index, \"brand\", (e.target as HTMLInputElement).value)} className=\"w-full p-1 border rounded text-sm dark:bg-gray-600 dark:border-gray-500 dark:text-white\" required />\n

\n Category\n handleNewProductDetailChange(index, \"categoryNameOrId\", (e.target as HTMLSelectElement).value)}\n className=\"w-full p-1 border rounded text-sm dark:bg-gray-600 dark:border-gray-500 dark:text-white\"\n >\n \n {categories.map(cat => )}\n \n

\n Default Price (optional, uses bill item price if blank)\n handleNewProductDetailChange(index, \"defaultPrice\", parseFloat((e.target as HTMLInputElement).value))} className=\"w-full p-1 border rounded text-sm dark:bg-gray-600 dark:border-gray-500 dark:text-white\" />\n

\n )}\n

\n ))}\n \n {isLoading ? \"Confirming...\" : \"Confirm Bill & Add to Inventory\"}\n \n

\n )}\n\n {step === \"confirmed\" && (\n

Bill Confirmed!

Inventory has been updated.

\n setStep(\"upload\")}\n className=\"mt-4 bg-primary dark:bg-blue-600 text-white py-2 px-4 rounded hover:bg-blue-700 dark:hover:bg-blue-500\"\n >\n Scan Another Bill\n \n

\n )}\n \n )\n}\n\nexport default ScanBillView",[],[263,282,292],"a648e5d0-3286-11f0-b9e8-569c3dd06744","QuickActions.tsx","a648e698-3286-11f0-b9e8-569c3dd06744",44,["D",1747421434466],"/** @jsxImportSource https://esm.sh/preact@10.19.6 */\nimport { h, FunctionComponent, JSX } from \"https://esm.sh/preact@10.19.6\";\n\ninterface QuickActionsProps {\n activeView: string;\n onNavigate: (view: string) => void;\n}\n\nconst QuickActions: FunctionComponent = ({ activeView, onNavigate }) => {\n // The original App.tsx had two

elements with similar content.\n // I'm using the first one (lines 333-342) as the primary source and adding the alerts section from the second one (lines 346-359)\n // The \"Initial Inventory Setup\" button from the second aside (line 353) is included here.\n // If this was a mistake in the original App.tsx, this can be adjusted.\n return (\n

Quick Actions

Alerts

Low stock warnings and expiry alerts will appear here.

\n );\n};\n\nexport default QuickActions;",[],[263,282,300],"e1b1fda6-3302-11f0-98a2-569c3dd06744","LoginView.tsx","a653e9a8-3286-11f0-86dc-569c3dd06744",64,["D",1747474791781],"/** @jsxImportSource https://esm.sh/preact@10.19.6 */\nimport { h, FunctionComponent, JSX } from \"https://esm.sh/preact@10.19.6\";\nimport { User } from \"../../shared/types.ts\";\n\ninterface LoginViewProps {\n users: User[];\n newUserName: string;\n onNewUserNameChange: (name: string) => void;\n onUserSelect: (userId: string) => void;\n onAddUser: () => void;\n loading: boolean;\n error?: string | null; // Add error prop\n}\n\nconst LoginView: FunctionComponent = ({\n users,\n newUserName,\n onNewUserNameChange,\n onUserSelect,\n onAddUser,\n loading,\n error,\n}) => {\n return (\n

Welcome to Inventory AI

Who are you?

\n {users.length > 0 && (\n

\n {users.map((user: User) => (\n onUserSelect(user.id)}\n className=\"w-full bg-primary dark:bg-blue-600 text-white p-3 rounded-md hover:bg-blue-600 dark:hover:bg-blue-700 transition-colors\"\n >\n {user.name}\n \n ))}\n

\n )}\n

Or, add a new user:

\n ) => onNewUserNameChange((e.target as HTMLInputElement).value)}\n placeholder=\"Enter your name\"\n className=\"w-full p-3 border border-gray-300 dark:border-gray-600 dark:bg-gray-700 dark:text-white rounded-md mb-3 focus:ring-primary focus:border-primary dark:focus:ring-blue-500 dark:focus:border-blue-500\"\n />\n \n {loading ? \"Adding...\" : \"Add & Login as Staff\"}\n \n {error && (\n

{error}

\n )}\n

\n );\n};\n\nexport default LoginView;",[],[263,282,308],"864ec5ec-3303-11f0-9f58-569c3dd06744","ExpiringItemsView.tsx","a6500996-3286-11f0-b9e1-569c3dd06744",71,["D",1747475067796],"/** @jsxImportSource https://esm.sh/preact@10.19.6 */\nimport { h, FunctionComponent, JSX } from \"https://esm.sh/preact@10.19.6\";\nimport { useState, useEffect } from \"https://esm.sh/preact@10.19.6/hooks\";\nimport { User, InventoryBatch } from \"../../shared/types.ts\";\n// import * as apiClient from \"../apiClient.ts\"; // Will be removed\n\nconst API_BASE_URL = \"/api\";\n\ninterface ExpiringItemsViewProps {\n currentUser: User | null;\n}\n\ntype ExpiringItem = InventoryBatch & { productName: string };\n\nconst ExpiringItemsView: FunctionComponent = ({ currentUser }) => {\n const [expiringItems, setExpiringItems] = useState([]);\n const [filterDays, setFilterDays] = useState(7);\n const [isLoading, setIsLoading] = useState(false);\n const [error, setError] = useState(null);\n\n useEffect(() => {\n if (!currentUser) return;\n \n const fetchItems = async () => {\n setIsLoading(true);\n setError(null);\n try {\n // Direct fetch for expiring items\n const queryParams = new URLSearchParams();\n if (filterDays !== undefined) queryParams.append(\"days\", String(filterDays));\n const queryString = queryParams.toString();\n const response = await fetch(`${API_BASE_URL}/inventory/expiring${queryString ? `?${queryString}` : \"\"}`, {\n headers: { \"Accept\": \"application/json\", \"X-User-Id\": currentUser.id } // X-User-Id might not be strictly needed\n });\n if (!response.ok) {\n const errorData = await response.json().catch(() => ({ message: `HTTP error ${response.status}`}));\n throw new Error(errorData.message || `Failed to fetch expiring items: ${response.status}`);\n }\n const items: ExpiringItem[] = await response.json();\n setExpiringItems(items);\n } catch (err) {\n setError(err.message || \"Failed to fetch expiring items.\");\n console.error(err);\n } finally {\n setIsLoading(false);\n }\n };\n\n fetchItems();\n }, [currentUser, filterDays]);\n\n return (\n <>\n

Check Expiring Items

\n {error &&

Error: {error}

}\n

\n \n Show items expiring within:\n \n setFilterDays(Number((e.target as HTMLSelectElement).value))}\n className=\"w-full p-3 border border-gray-300 dark:border-gray-600 dark:bg-gray-700 dark:text-white rounded-md focus:ring-primary focus:border-primary dark:focus:ring-blue-500 dark:focus:border-blue-500\"\n >\n \n \n \n {/* Backend needs to support \"all\" or a very large number */}\n \n

\n {isLoading &&

Loading expiring items...

}\n

\n No expiring items to display based on current filter, or inventory is empty.\n
\n
{item.productName}
\n
Quantity: {item.quantityCurrent} | Expires: {new Date(item.expiryDate).toLocaleDateString()}
\n

\n \n );\n};\n\nexport default ExpiringItemsView;",[],[263,282,316],"e18d6a2c-3302-11f0-82eb-569c3dd06744","DashboardView.tsx","a63f11a4-3286-11f0-8e06-569c3dd06744",61,["D",1747474791512],"/** @jsxImportSource https://esm.sh/preact@10.19.6 */\nimport { h, FunctionComponent, JSX } from \"https://esm.sh/preact@10.19.6\";\nimport { User } from \"../../shared/types.ts\";\n\ninterface DashboardViewProps {\n currentUser: User | null;\n}\n\nconst DashboardView: FunctionComponent = ({ currentUser }) => {\n return (\n <>\n

Dashboard

\n Welcome, {currentUser?.name || 'User'}! Select an action from the right panel.\n

\n \n );\n};\n\nexport default DashboardView;",[],[263,282,324],"5900542e-3287-11f0-8584-569c3dd06744","AppHeader.tsx","a628a8d8-3286-11f0-971a-569c3dd06744",49,["D",1747421734357],"/** @jsxImportSource https://esm.sh/preact@10.19.6 */\nimport { h, FunctionComponent, JSX } from \"https://esm.sh/preact@10.19.6\";\nimport { User } from \"../../shared/types.ts\"; // Import User type\n\ninterface AppHeaderProps {\n currentUser: User;\n theme: 'light' | 'dark';\n onToggleTheme: () => void;\n onLogout: () => void;\n}\n\nconst AppHeader: FunctionComponent = ({\n currentUser,\n theme,\n onToggleTheme,\n onLogout,\n}) => {\n return (\n

Inventory AI Demo

\n Welcome, {currentUser.name}!\n \n {theme === 'light' ? '🌙' : '☀️'}\n \n \n Logout\n \n

\n );\n};\n\nexport default AppHeader;",[],[263,282,332],"20905134-331d-11f0-8077-9e149126039e","App.tsx","9a44dad4-327f-11f0-9694-569c3dd06744",83,["D",1747486064148],13,"/** @jsxImportSource https://esm.sh/preact@10.19.6 */\nimport {h, FunctionComponent, JSX} from \"https://esm.sh/preact@10.19.6\"\nimport {useState, useEffect} from \"https://esm.sh/preact@10.19.6/hooks\"\n\nimport LoginView from \"./LoginView.tsx\"\nimport AppHeader from \"./AppHeader.tsx\"\nimport DashboardView from \"./DashboardView.tsx\"\nimport ScanBillView from \"./ScanBillView.tsx\"\nimport ViewInventoryView from \"./ViewInventoryView.tsx\"\nimport UpdateInventoryView from \"./UpdateInventoryView.tsx\"\nimport ExpiringItemsView from \"./ExpiringItemsView.tsx\"\nimport QuickActions from \"./QuickActions.tsx\"\nimport {User, CreateUserPayload} from \"../../shared/types.ts\"\n// import * as apiClient from \"../apiClient.ts\"; // This was removed\n\nconst API_BASE_URL = \"/api\" // Ensure this is defined\n\nconst App: FunctionComponent = () => {\n const [currentUser, setCurrentUser] = useState(null)\n const [loading, setLoading] = useState(true)\n const [error, setError] = useState(null)\n const [users, setUsers] = useState([])\n const [newUserName, setNewUserName] = useState(\"\")\n const [activeView, setActiveView] = useState(\"dashboard\") // \"dashboard\", \"scanBill\", \"updateInventory\", \"viewInventory\", \"expiringItems\", \"initialSetup\"\n const [theme, setTheme] = useState<'light' | 'dark'>(() => {\n if (typeof window !== 'undefined' && window.localStorage) {\n const storedTheme = localStorage.getItem('theme')\n return (storedTheme === 'dark' || storedTheme === 'light') ? storedTheme : 'light'\n }\n return 'light'\n })\n\n useEffect(() => {\n if (typeof window !== 'undefined' && window.document) {\n if (theme === 'dark') {\n document.documentElement.classList.add('dark')\n } else {\n document.documentElement.classList.remove('dark')\n }\n localStorage.setItem('theme', theme)\n }\n }, [theme])\n\n const toggleTheme = () => {\n setTheme(prevTheme => prevTheme === 'light' ? 'dark' : 'light')\n }\n\n useEffect(() => {\n // Renamed from fetchUsers to fetchInitialData or similar to reflect its purpose\n const fetchInitialData = async () => {\n setLoading(true)\n try {\n // Direct fetch for users\n const response = await fetch(`/api/users`)\n if (!response.ok) {\n let errorData\n try {\n errorData = await response.json()\n } catch (e) {\n errorData = {error: \"Request failed\", message: response.statusText || \"Unknown error\"}\n }\n console.error(\"API Error (fetchUsers):\", errorData, \"Status:\", response.status)\n throw new Error(errorData.message || errorData.error || `Failed to fetch users: ${response.status}`)\n }\n const fetchedUsers: User[] = await response.json()\n\n setUsers(fetchedUsers)\n const storedUserJSON = localStorage.getItem(\"currentUser\")\n if (storedUserJSON) {\n try {\n const storedUser = JSON.parse(storedUserJSON) as User\n if (storedUser && typeof storedUser.id === 'string') {\n const foundUser = fetchedUsers.find((u: User) => u.id === storedUser.id)\n if (foundUser) {\n setCurrentUser(foundUser)\n } else {\n localStorage.removeItem(\"currentUser\") // Stale user data\n }\n } else {\n localStorage.removeItem(\"currentUser\") // Malformed user data\n }\n } catch (e) {\n console.error(\"Failed to parse currentUser from localStorage\", e)\n localStorage.removeItem(\"currentUser\")\n }\n }\n } catch (err) {\n setError(\"Failed to load users.\")\n console.error(err)\n } finally {\n setLoading(false)\n }\n }\n fetchInitialData()\n }, [])\n\n // Temporarily comment out to isolate rendering issues\n // useEffect(() => {\n // const viewSourceLink = document.getElementById(\"view-source-link\") as HTMLAnchorElement | null;\n // if (viewSourceLink && window.location.href.includes(\"esm.town\")) {\n // viewSourceLink.href = window.location.href.replace(\"web.val.run\", \"val.town\").replace(\".web.val.run\", \".val.town\");\n // } else if (viewSourceLink) {\n // viewSourceLink.parentElement?.remove();\n // }\n // }, []);\n\n const handleUserSelect = (userId: string) => {\n const selected = users.find((u: User) => u.id === userId)\n if (selected) {\n setCurrentUser(selected)\n localStorage.setItem(\"currentUser\", JSON.stringify(selected))\n }\n }\n\n const handleAddUser = async () => {\n if (!newUserName.trim()) return\n setLoading(true)\n try {\n const payload: CreateUserPayload = {\n name: newUserName.trim(),\n role: \"staff\", // Default new users to staff\n }\n // Direct fetch to add user\n const response = await fetch(`${API_BASE_URL}/users`, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"Accept\": \"application/json\",\n },\n body: JSON.stringify(payload),\n })\n\n if (!response.ok) {\n let errorData\n try {\n errorData = await response.json()\n } catch (e) {\n errorData = {error: \"Request failed\", message: response.statusText || \"Unknown error\"}\n }\n throw new Error(errorData.message || errorData.error || `Failed to add user: ${response.status}`)\n }\n const newUser: User = await response.json()\n setUsers(prevUsers => [...prevUsers, newUser])\n setCurrentUser(newUser)\n localStorage.setItem(\"currentUser\", JSON.stringify(newUser))\n setNewUserName(\"\")\n } catch (err) {\n setError(\"Failed to add user.\")\n console.error(err)\n } finally {\n setLoading(false)\n }\n }\n\n const handleNavigate = (view: string) => {\n setActiveView(view)\n }\n\n const handleLogout = () => {\n setCurrentUser(null)\n localStorage.removeItem(\"currentUser\")\n setActiveView(\"dashboard\") // Reset to dashboard view on logout\n }\n\n if (loading && !users.length && !currentUser) {\n return

Loading application...

\n }\n\n if (error) {\n return

Error: {error}

\n }\n\n if (!currentUser) {\n return (\n \n )\n }\n\n return (\n

\n \n\n

\n {activeView === \"dashboard\" && }\n {activeView === \"scanBill\" && }\n {activeView === \"viewInventory\" && }\n {activeView === \"updateInventory\" && }\n {activeView === \"expiringItems\" && }\n {/* Placeholder for initialSetup view if it's added back */}\n {/* {activeView === \"initialSetup\" &&

Initial Setup View Content

} */}\n

\n\n {/* QuickActions component now renders the aside itself */}\n \n

\n )\n}\n\nexport default App",[],[263,282,340],"9982fd42-327f-11f0-bda9-569c3dd06744",8,["D",1747418406588],[187,188,189,190,191,192,193,194,195],[263,282],"ffc93764-3302-11f0-af96-569c3dd06744",66,["D",1747474842270],[186,196,197],[263],"98fd645c-327f-11f0-8e23-569c3dd06744","docs","98fd652e-327f-11f0-8e23-569c3dd06744",5,["D",1747418405726],[],[359],"3fefd1c4-3324-11f0-a479-9e149126039e","api.ts","9a0cd24c-327f-11f0-af1d-569c3dd06744","9857369a-327f-11f0-8c28-569c3dd06744",104,["D",1747489123294],12,"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport {Hono} from \"npm:hono\"\nimport {cors} from \"npm:hono/cors\"\nimport {secureHeaders} from \"npm:hono/secure-headers\"\nimport {csrf} from \"npm:hono/csrf\"\nimport {logger} from 'npm:hono/logger'\n\n\n// Import services\nimport * as userService from \"./services/userService.ts\"\nimport * as productService from \"./services/productService.ts\"\nimport * as inventoryService from \"./services/inventoryService.ts\"\nimport * as billService from \"./services/billService.ts\"\nimport {aiServiceInstance} from \"./services/aiService.ts\" // Added for direct AI calls\n\nimport {runMigrations} from \"./database/migrations.ts\"\nimport {\n CreateUserPayload,\n CreateCategoryPayload,\n CreateProductPayload,\n CreateInventoryBatchPayload,\n SupplierBillItem, // Assuming this is part of shared types\n BillScanResponse, // Assuming this is part of shared types\n ActionType, // For action log filtering\n // These are assumed to be defined in shared/types.ts for new endpoints\n // ConfirmBillPayload, UpdateBillAIDataPayload, ImageProcessRequestPayload \n} from \"../shared/types.ts\"\n\nconst backend = new Hono()\n\n// Apply CORS and secure headers middleware\nbackend.use(\"*\", cors()) // Allow all origins for demo purposes\nbackend.use(\"*\", secureHeaders())\n// CSRF protection can be added if using cookie-based sessions, might be overkill for this API demo if using token auth\n// app.use(\"*\", csrf());\n\n// Assumed payload types for new endpoints (these should ideally be in shared/types.ts)\ninterface ConfirmBillPayload {\n reviewedItems: Array & {categoryNameOrId?: string} // categoryId in CreateProductPayload, categoryNameOrId for UI, now optional\n }>\n}\n\nbackend.use(logger()) // Initialize logger\n\ntype UpdateBillAIDataPayload = Partial> & {items?: Array>}\ninterface ImageProcessRequestPayload {imageBase64: string}\n\n\n// Error handler - Unwrap Hono errors to see original error details\nbackend.onError((err, c) => {\n console.error(\"API Error:\", err)\n // Check if it's an HTTPError from Hono, otherwise it's an internal error\n if (err && typeof err === 'object' && 'getResponse' in err && typeof err.getResponse === 'function') {\n // This is a Hono HTTPError or a compatible error\n return (err as any).getResponse()\n }\n const message = (err instanceof Error) ? err.message : \"Unknown error\"\n return c.json({error: \"Internal Server Error\", message: message}, 500)\n})\n\n// --- Migrations ---\n// Potentially run migrations on startup (can be slow, consider a separate trigger for production)\nlet migrationsRun = false\nbackend.use(\"*\", async (c, next) => {\n //Check if users table is empty, if it is not. Then we don't need to run the migrations.\n const users = await userService.getAllUsers()\n if (users.length !== 0) {\n migrationsRun = true\n }\n\n if (!migrationsRun) {\n try {\n console.log(\"Running database migrations...\")\n await runMigrations()\n migrationsRun = true\n console.log(\"Database migrations completed.\")\n } catch (e) {\n console.error(\"Migration failed:\", e)\n // Optionally, you could prevent the app from starting or return an error response\n return c.json({error: \"Database migration failed\", message: e.message}, 500)\n }\n }\n await next()\n})\n\n\n// --- User Service Endpoints (docs/inventory-ai-technical-plan.md:343-361) ---\nbackend.post(\"/users\", async (c) => {\n try {\n const payload = await c.req.json() as CreateUserPayload\n if (!payload.name || !payload.role) {\n return c.json({error: \"Name and role are required\"}, 400)\n }\n const newUser = await userService.createUser(payload)\n return c.json(newUser, 201)\n } catch (e) {\n return c.json({error: \"Failed to create user\", message: e.message}, 500)\n }\n})\n\nbackend.get(\"/users\", async (c) => {\n console.log(\"Fetching users...\")\n try {\n const users = await userService.getAllUsers()\n console.log({users})\n return c.json(users)\n } catch (e) {\n console.error(e)\n return c.json({error: \"Failed to fetch users\", message: e}, 500)\n }\n})\n\nbackend.get(\"/users/:id\", async (c) => {\n try {\n const id = c.req.param(\"id\")\n const user = await userService.getUserById(id)\n if (!user) {\n return c.json({error: \"User not found\"}, 404)\n }\n return c.json(user)\n } catch (e) {\n return c.json({error: \"Failed to fetch user\", message: e.message}, 500)\n }\n})\n\nbackend.get(\"/action-logs\", async (c) => {\n try {\n const {startDate, endDate, userId, action, limit: limitStr} = c.req.query()\n const limit = limitStr ? parseInt(limitStr, 10) : 50\n if (limitStr && isNaN(limit)) {\n return c.json({error: \"Invalid 'limit' query parameter\"}, 400)\n }\n const logs = await userService.getActionLogs({startDate, endDate, userId, action: action as ActionType, limit})\n return c.json(logs)\n } catch (e) {\n return c.json({error: \"Failed to fetch action logs\", message: e.message}, 500)\n }\n})\n\nbackend.get(\"/users/:id/action-logs\", async (c) => {\n try {\n const userId = c.req.param(\"id\")\n const {limit: limitStr} = c.req.query()\n const limit = limitStr ? parseInt(limitStr, 10) : 20\n if (limitStr && isNaN(limit)) {\n return c.json({error: \"Invalid 'limit' query parameter\"}, 400)\n }\n const logs = await userService.getActionLogsForUser(userId, limit)\n return c.json(logs)\n } catch (e) {\n return c.json({error: \"Failed to fetch action logs\", message: e.message}, 500)\n }\n})\n\n\n// --- Product Service Endpoints (docs/inventory-ai-technical-plan.md:362-390) ---\nbackend.post(\"/categories\", async (c) => {\n try {\n // TODO: Get userId from auth context in a real app\n const userId = c.req.header(\"X-User-Id\") || \"demo-user\" // Placeholder for demo\n if (!userId) return c.json({error: \"User ID is required via X-User-Id header\"}, 400)\n\n const payload = await c.req.json() as CreateCategoryPayload\n if (!payload.name) {\n return c.json({error: \"Category name is required\"}, 400)\n }\n const newCategory = await productService.createCategory(payload, userId)\n return c.json(newCategory, 201)\n } catch (e) {\n return c.json({error: \"Failed to create category\", message: e.message}, 500)\n }\n})\n\nbackend.get(\"/categories\", async (c) => {\n try {\n const categories = await productService.getAllCategories()\n return c.json(categories)\n } catch (e) {\n return c.json({error: \"Failed to fetch categories\", message: e.message}, 500)\n }\n})\n\nbackend.get(\"/categories/:id\", async (c) => {\n try {\n const id = c.req.param(\"id\")\n const category = await productService.getCategoryById(id)\n if (!category) {\n return c.json({error: \"Category not found\"}, 404)\n }\n return c.json(category)\n } catch (e) {\n return c.json({error: \"Failed to fetch category\", message: e.message}, 500)\n }\n})\n\n\nbackend.post(\"/products\", async (c) => {\n try {\n const userId = c.req.header(\"X-User-Id\") || \"demo-user\" // Placeholder\n if (!userId) return c.json({error: \"User ID is required via X-User-Id header\"}, 400)\n\n const payload = await c.req.json() as CreateProductPayload\n // Basic validation\n if (!payload.name || !payload.brand || payload.defaultPrice === undefined) { // categoryId is now optional\n return c.json({error: \"Missing required product fields: name, brand, defaultPrice\"}, 400)\n }\n const newProduct = await productService.createProduct(payload, userId)\n return c.json(newProduct, 201)\n } catch (e) {\n return c.json({error: \"Failed to create product\", message: e.message}, 500)\n }\n})\n\nbackend.get(\"/products\", async (c) => {\n try {\n const categoryId = c.req.query(\"category\")\n const searchTerm = c.req.query(\"search\")\n let products\n if (categoryId) {\n products = await productService.getProductsByCategory(categoryId)\n } else {\n products = await productService.getAllProducts() // Add search term filtering in service if needed\n }\n return c.json(products)\n } catch (e) {\n return c.json({error: \"Failed to fetch products\", message: e.message}, 500)\n }\n})\n\nbackend.get(\"/products/:id\", async (c) => {\n try {\n const id = c.req.param(\"id\")\n const product = await productService.getProductById(id)\n if (!product) {\n return c.json({error: \"Product not found\"}, 404)\n }\n return c.json(product)\n } catch (e) {\n return c.json({error: \"Failed to fetch product\", message: e.message}, 500)\n }\n})\n\nbackend.put(\"/products/:id\", async (c) => {\n try {\n const userId = c.req.header(\"X-User-Id\") || \"demo-user\" // Placeholder\n if (!userId) return c.json({error: \"User ID is required via X-User-Id header\"}, 400)\n const productId = c.req.param(\"id\")\n const payload = await c.req.json() as Partial\n const updatedProduct = await productService.updateProduct(productId, payload, userId)\n if (!updatedProduct) {\n return c.json({error: \"Product not found or update failed\"}, 404)\n }\n return c.json(updatedProduct)\n } catch (e) {\n return c.json({error: \"Failed to update product\", message: e.message}, 500)\n }\n})\n\nbackend.delete(\"/products/:id\", async (c) => {\n try {\n const userId = c.req.header(\"X-User-Id\") || \"demo-user\"\n if (!userId) return c.json({error: \"User ID is required via X-User-Id header\"}, 400)\n const productId = c.req.param(\"id\")\n // Assuming productService.deleteProduct(productId, userId) exists and returns boolean\n // This function needs to be implemented in productService.ts and queries.ts\n // For now, let's simulate it:\n // const success = await productService.deleteProduct(productId, userId);\n console.warn(`productService.deleteProduct for ${productId} by ${userId} is not fully implemented. Simulating success.`)\n const success = true // Placeholder\n if (!success) {\n return c.json({error: \"Product not found or deletion failed\"}, 404)\n }\n return c.json({message: \"Product deleted successfully\"}, 200)\n } catch (e) {\n return c.json({error: \"Failed to delete product\", message: e.message}, 500)\n }\n})\n\nbackend.get(\"/products/low-stock\", async (c) => {\n try {\n const lowStockProducts = await productService.getLowStockProducts()\n return c.json(lowStockProducts)\n } catch (e) {\n return c.json({error: \"Failed to fetch low stock products\", message: e.message}, 500)\n }\n})\n\n// --- Inventory Service Endpoints (docs/inventory-ai-technical-plan.md:391-419) ---\nbackend.post(\"/inventory/batches\", async (c) => {\n try {\n const userId = c.req.header(\"X-User-Id\") || \"demo-user\"\n if (!userId) return c.json({error: \"User ID is required via X-User-Id header\"}, 400)\n const payload = await c.req.json() as CreateInventoryBatchPayload\n // Basic validation\n if (!payload.productId || payload.quantityReceived === undefined || !payload.expiryDate || !payload.receiptDate) {\n return c.json({error: \"Missing required fields: productId, quantityReceived, expiryDate, receiptDate\"}, 400)\n }\n const newBatch = await inventoryService.createInventoryBatch(payload, userId)\n return c.json(newBatch, 201)\n } catch (e) {\n return c.json({error: \"Failed to create inventory batch\", message: e.message}, 500)\n }\n})\n\nbackend.get(\"/inventory/batches\", async (c) => {\n try {\n const productId = c.req.query(\"productId\")\n const expiryBefore = c.req.query(\"expiryBefore\")\n const expiryAfter = c.req.query(\"expiryAfter\")\n const isInitialInventoryStr = c.req.query(\"isInitialInventory\")\n let isInitialInventory: boolean | undefined = undefined\n if (isInitialInventoryStr) {\n isInitialInventory = isInitialInventoryStr.toLowerCase() === 'true'\n }\n\n if (productId) {\n const batches = await inventoryService.getBatchesForProduct(productId)\n // Further filter in memory if service doesn't support all filters directly\n // This is a simplified example; ideally, filtering is done at DB level.\n return c.json(batches)\n }\n // TODO: Implement getAllBatches with filters in inventoryService & queries\n // For now, returning error if no productId\n return c.json({error: \"productId query parameter is required. Full batch listing with filters TBD.\"}, 400)\n } catch (e) {\n return c.json({error: \"Failed to fetch inventory batches\", message: e.message}, 500)\n }\n})\n\nbackend.get(\"/inventory/batches/:id\", async (c) => {\n try {\n const batchId = c.req.param(\"id\")\n const batch = await inventoryService.getInventoryBatchById(batchId)\n if (!batch) {\n return c.json({error: \"Inventory batch not found\"}, 404)\n }\n return c.json(batch)\n } catch (e) {\n return c.json({error: \"Failed to fetch inventory batch\", message: e.message}, 500)\n }\n})\n\nbackend.put(\"/inventory/batches/:id\", async (c) => {\n try {\n const userId = c.req.header(\"X-User-Id\") || \"demo-user\"\n if (!userId) return c.json({error: \"User ID is required via X-User-Id header\"}, 400)\n const batchId = c.req.param(\"id\")\n const payload = await c.req.json() as Partial // Or a more specific update payload\n const updatedBatch = await inventoryService.updateInventoryBatch(batchId, payload, userId)\n if (!updatedBatch) return c.json({error: \"Batch not found or update failed\"}, 404)\n return c.json(updatedBatch)\n } catch (e) {\n return c.json({error: \"Failed to fetch inventory batches\", message: e.message}, 500)\n }\n})\n\nbackend.get(\"/inventory/products/:productId/total\", async (c) => {\n try {\n const productId = c.req.param(\"productId\")\n const totalQuantity = await inventoryService.getTotalProductQuantity(productId)\n return c.json({productId, totalQuantity})\n } catch (e) {\n return c.json({error: \"Failed to get product total quantity\", message: e.message}, 500)\n }\n})\n\nbackend.get(\"/inventory/expiring\", async (c) => {\n try {\n const daysStr = c.req.query(\"days\")\n const days = daysStr ? parseInt(daysStr, 10) : undefined\n if (daysStr && isNaN(days)) {\n return c.json({error: \"Invalid 'days' query parameter\"}, 400)\n }\n const expiringBatches = await inventoryService.getExpiringBatches(days)\n return c.json(expiringBatches)\n } catch (e) {\n return c.json({error: \"Failed to fetch expiring batches\", message: e.message}, 500)\n }\n})\n\nbackend.post(\"/inventory/reconcile\", async (c) => {\n try {\n const userId = c.req.header(\"X-User-Id\") || \"demo-user\"\n if (!userId) return c.json({error: \"User ID is required via X-User-Id header\"}, 400)\n const {productId, actualPhysicalCount} = await c.req.json() as {productId: string, actualPhysicalCount: number}\n if (!productId || actualPhysicalCount === undefined) {\n return c.json({error: \"productId and actualPhysicalCount are required\"}, 400)\n }\n if (typeof actualPhysicalCount !== 'number' || actualPhysicalCount < 0) {\n return c.json({error: \"actualPhysicalCount must be a non-negative number\"}, 400)\n }\n const result = await inventoryService.reconcileInventory(productId, actualPhysicalCount, userId)\n return c.json(result)\n } catch (e) {\n return c.json({error: \"Failed to reconcile inventory\", message: e.message}, 500)\n }\n})\n\n// --- Bill Processing Endpoints (docs/inventory-ai-technical-plan.md:420-445) ---\nbackend.post(\"/bills/upload\", async (c) => {\n try {\n const userId = c.req.header(\"X-User-Id\") || \"demo-user\"\n if (!userId) return c.json({error: \"User ID is required via X-User-Id header\"}, 400)\n const {imageBase64, originalFileName} = await c.req.json() as {imageBase64: string, originalFileName?: string}\n if (!imageBase64) {\n return c.json({error: \"imageBase64 content is required\"}, 400)\n }\n const result = await billService.uploadBillImage(imageBase64, userId, originalFileName)\n return c.json(result, 201)\n } catch (e) {\n console.error(\"Bill upload error:\", e)\n return c.json({error: \"Failed to upload bill image\", message: e.message}, 500)\n }\n})\n\nbackend.post(\"/bills/process/:billId\", async (c) => {\n try {\n const userId = c.req.header(\"X-User-Id\") || \"demo-user\"\n if (!userId) return c.json({error: \"User ID is required via X-User-Id header\"}, 400)\n const billId = c.req.param(\"billId\")\n const processedBill = await billService.processBillWithAI(billId, userId)\n if (!processedBill) {\n return c.json({error: \"Bill processing failed or bill not found\"}, 404)\n }\n return c.json(processedBill)\n } catch (e) {\n console.error(\"Bill processing error:\", e)\n return c.json({error: \"Failed to process bill with AI\", message: e.message}, 500)\n }\n})\n\nbackend.get(\"/bills\", async (c) => {\n try {\n const {startDate, endDate, processed: processedStr, limit: limitStr} = c.req.query()\n const limit = limitStr ? parseInt(limitStr, 10) : 20\n let processed: boolean | undefined = undefined\n if (processedStr) processed = processedStr.toLowerCase() === 'true'\n\n // Assuming billService.getAllBills is implemented to handle these filters\n // For now, it's a placeholder in billService.ts\n const bills = await billService.getAllBills({startDate, endDate, processed, limit})\n return c.json(bills)\n } catch (e) {\n console.error(\"Get bills error:\", e)\n return c.json({error: \"Failed to fetch bills\", message: e.message}, 500)\n }\n})\n\nbackend.get(\"/bills/:billId\", async (c) => {\n try {\n const billId = c.req.param(\"billId\")\n const bill = await billService.getBillById(billId)\n if (!bill) {\n return c.json({error: \"Bill not found\"}, 404)\n }\n return c.json(bill)\n } catch (e) {\n console.error(\"Get bill by ID error:\", e)\n return c.json({error: \"Failed to fetch bill\", message: e.message}, 500)\n }\n})\n\nbackend.put(\"/bills/:billId\", async (c) => {\n try {\n const userId = c.req.header(\"X-User-Id\") || \"demo-user\"\n if (!userId) return c.json({error: \"User ID is required via X-User-Id header\"}, 400)\n const billId = c.req.param(\"billId\")\n const payload = await c.req.json() as UpdateBillAIDataPayload\n\n // This would call a service function like billService.updateBillDetailsManually\n // For now, let's assume db.updateSupplierBillWithAIData can be reused or adapted\n // The payload for updateSupplierBillWithAIData expects a full BillScanResponse structure.\n // This might need a dedicated service method if the payload is different.\n console.warn(`PUT /api/bills/:billId - Manual bill update logic might need a dedicated service method. Reusing updateSupplierBillWithAIData for now if payload matches.`)\n const updatedBill = await db.updateSupplierBillWithAIData(billId, payload as BillScanResponse, userId) // Casting payload, ensure it's compatible\n\n if (!updatedBill) {\n return c.json({error: \"Bill not found or update failed\"}, 404)\n }\n return c.json(updatedBill)\n } catch (e) {\n console.error(\"Update bill error:\", e)\n return c.json({error: \"Failed to update bill\", message: e.message}, 500)\n }\n})\n\nbackend.post(\"/bills/:billId/confirm\", async (c) => {\n try {\n const userId = c.req.header(\"X-User-Id\") || \"demo-user\"\n if (!userId) return c.json({error: \"User ID is required via X-User-Id header\"}, 400)\n const billId = c.req.param(\"billId\")\n const payload = await c.req.json() as ConfirmBillPayload\n if (!payload.reviewedItems || !Array.isArray(payload.reviewedItems)) {\n return c.json({error: \"reviewedItems array is required\"}, 400)\n }\n const result = await billService.confirmBillAndCreateBatches(billId, payload.reviewedItems, userId)\n return c.json(result)\n } catch (e) {\n console.error(\"Confirm bill error:\", e)\n return c.json({error: \"Failed to confirm bill and create batches\", message: e.message}, 500)\n }\n})\n\n// --- Image Processing Endpoints (docs/inventory-ai-technical-plan.md:446-451) ---\nbackend.post(\"/images/extract-expiry\", async (c) => {\n try {\n const {imageBase64} = await c.req.json() as ImageProcessRequestPayload\n if (!imageBase64) return c.json({error: \"imageBase64 is required\"}, 400)\n const result = await aiServiceInstance.extractExpiryDate(imageBase64)\n return c.json(result)\n } catch (e) {\n return c.json({error: \"Failed to extract expiry date\", message: e.message}, 500)\n }\n})\n\nbackend.post(\"/images/detect-products\", async (c) => {\n try {\n const {imageBase64} = await c.req.json() as ImageProcessRequestPayload\n if (!imageBase64) return c.json({error: \"imageBase64 is required\"}, 400)\n const result = await aiServiceInstance.detectProducts(imageBase64)\n return c.json(result)\n } catch (e) {\n return c.json({error: \"Failed to detect products\", message: e.message}, 500)\n }\n})\n\n\n\n// 404 handler\nbackend.notFound((c) => {\n console.log({req: c.req})\n return c.json({error: \"Not found\"}, 404)\n})\n\n// Error handler\nbackend.onError((err, c) => {\n console.error(\"Application error:\", err)\n return c.json({error: \"An unexpected error occurred\"}, 500)\n})\n\n// Val Town entry point\nexport default backend",[],[375,366],"backend","355a5730-3305-11f0-8ee8-569c3dd06744","userService.ts","99e4db52-327f-11f0-888d-569c3dd06744","995101fc-327f-11f0-8bd6-569c3dd06744",76,["D",1747475791120],"import {\n User,\n ActionLog,\n ActionType,\n CreateUserPayload,\n} from \"../../shared/types.ts\"\nimport * as db from \"../database/queries.ts\"\n// Use crypto.randomUUID() for generating IDs, standard in Deno\n// const uuid = () => crypto.randomUUID(); // No longer needed here as db.createUser handles ID generation\n\nexport async function createUser(payload: CreateUserPayload): Promise {\n const existingUser = await db.getAllUsers() // In a real app, check for existing name if it should be unique\n if (existingUser.find(u => u.name.toLowerCase() === payload.name.toLowerCase())) {\n // For this demo, we'll allow duplicate names but log it.\n // In a production app, you might throw an error or append a number.\n console.warn(`User with name \"${payload.name}\" already exists or similar name found.`)\n }\n\n const user = await db.createUser(payload)\n await db.logAction(user.id, \"user_login\", {name: user.name}, user.name) // Log initial creation as a login\n return user\n}\n\nexport async function getUserById(id: string): Promise {\n return db.getUserById(id)\n}\n\nexport function getAllUsers(): Promise {\n return db.getAllUsers()\n}\n\nexport async function logUserAction(\n userId: string,\n action: ActionType,\n details: any,\n): Promise {\n const user = await db.getUserById(userId)\n if (!user) {\n throw new Error(`User not found for logging action: ${userId}`)\n }\n return db.logAction(userId, action, details, user.name)\n}\n\nexport async function getActionLogsForUser(\n userId: string,\n limit: number = 20,\n): Promise {\n return db.getActionLogs({userId, limit})\n}\n\nexport async function getAllActionLogs(limit: number = 50): Promise {\n return db.getActionLogs({limit})\n}",[],[375,385,377],"services","3ffb37bc-3324-11f0-9c6a-9e149126039e","productService.ts","99de4c9c-327f-11f0-b555-569c3dd06744",106,["D",1747489123295],"import {\n Product,\n Category,\n CreateProductPayload,\n CreateCategoryPayload,\n} from \"../../shared/types.ts\";\nimport * as db from \"../database/queries.ts\";\nimport { logUserAction } from \"./userService.ts\"; // For logging actions\n\n// --- Category Service Functions ---\nexport async function createCategory(\n payload: CreateCategoryPayload,\n userId: string,\n): Promise {\n // Check if category with the same name already exists (case-insensitive)\n const existingCategories = await db.getAllCategories();\n const duplicate = existingCategories.find(\n (cat) => cat.name.toLowerCase() === payload.name.toLowerCase(),\n );\n if (duplicate) {\n // In a real app, you might throw an error or return the existing one.\n // For this demo, we'll allow it but log a warning.\n console.warn(`Category with name \"${payload.name}\" already exists or similar name found.`);\n // Potentially, you could return the existing category here if that's the desired behavior.\n // return duplicate; \n }\n\n const category = await db.createCategory(payload, userId);\n await logUserAction(userId, \"add_category\", { categoryId: category.id, name: category.name });\n return category;\n}\n\nexport async function getCategoryById(id: string): Promise {\n return db.getCategoryById(id);\n}\n\nexport async function getAllCategories(): Promise {\n return db.getAllCategories();\n}\n\n// --- Product Service Functions ---\nexport async function createProduct(\n payload: CreateProductPayload,\n userId: string,\n): Promise {\n // payload.categoryId is now optional\n let resolvedCategoryId: string;\n\n if (payload.categoryId) {\n const categoryExists = await db.getCategoryById(payload.categoryId);\n if (!categoryExists) {\n throw new Error(`Category with ID \"${payload.categoryId}\" not found.`);\n }\n resolvedCategoryId = payload.categoryId;\n } else {\n // Find or create \"Uncategorized\" category\n const defaultCategoryName = \"Uncategorized\";\n // Use a predefined user for creating this default category, e.g., 'user_1' (Vipulbhai)\n // Ensure this user exists from migrations.\n const defaultCategoryCreator = await db.getUserById(\"user_1\"); \n if (!defaultCategoryCreator) {\n // This is a critical issue if migrations didn't run or user_1 was deleted.\n // Fallback to current user or throw a more specific error.\n console.error(\"Default user 'user_1' for creating 'Uncategorized' category not found. Falling back to current user.\");\n const currentUser = await db.getUserById(userId);\n if(!currentUser) throw new Error(\"Current user not found for creating 'Uncategorized' category.\");\n resolvedCategoryId = await createDefaultCategory(defaultCategoryName, currentUser.id, currentUser.name);\n } else {\n resolvedCategoryId = await createDefaultCategory(defaultCategoryName, defaultCategoryCreator.id, defaultCategoryCreator.name);\n }\n }\n \n // Check for existing product by name (optional, depending on requirements)\n // For this demo, we'll allow products with the same name but different brands/categories.\n\n // Create a new payload object for db.createProduct, ensuring 'categoryId' is set.\n const dbPayload: CreateProductPayload = {\n ...payload,\n categoryId: resolvedCategoryId, // Set the resolved categoryId\n };\n\n const product = await db.createProduct(dbPayload, userId);\n await logUserAction(userId, \"add_product\", { productId: product.id, name: product.name });\n return product;\n}\n\nexport async function getProductById(id: string): Promise {\n return db.getProductById(id);\n}\n\nasync function createDefaultCategory(name: string, creatorId: string, creatorName: string): Promise {\n let category = await db.getCategoryByName(name);\n if (!category) {\n console.log(`Creating default category \"${name}\" by user ${creatorId} (${creatorName})`);\n category = await db.createCategory(\n { name: name, description: `Default category for ${name.toLowerCase()} products` },\n creatorId\n );\n await db.logAction(creatorId, \"add_category\", { categoryId: category.id, name: category.name, autoCreated: true }, creatorName);\n }\n return category.id;\n}\n\nexport async function getAllProducts(): Promise> {\n return db.getAllProductsWithCategory(); // Fetches products with their category names\n}\n\nexport async function updateProduct(\n productId: string,\n payload: Partial, // Use CreateProductPayload for partial updates\n userId: string,\n): Promise {\n if (payload.categoryId) {\n const category = await db.getCategoryById(payload.categoryId);\n if (!category) {\n throw new Error(`Category with ID \"${payload.categoryId}\" not found for product update.`);\n }\n }\n const updatedProduct = await db.updateProduct(productId, payload, userId);\n if (updatedProduct) {\n await logUserAction(userId, \"update_product\", { productId: updatedProduct.id, changes: payload });\n }\n return updatedProduct;\n}\n\nexport async function getProductsByCategory(categoryId: string): Promise> {\n const allProducts = await db.getAllProductsWithCategory();\n return allProducts.filter(product => product.category === categoryId); // 'category' in Product is categoryId\n}\n\nexport async function getLowStockProducts(): Promise> {\n return db.getLowStockProducts();\n}",[],[375,385,387],"99f546a4-327f-11f0-af1d-569c3dd06744","inventoryService.ts","99f5476c-327f-11f0-af1d-569c3dd06744",16,["D",1747418407365],"import {\n InventoryBatch,\n CreateInventoryBatchPayload,\n Product,\n} from \"../../shared/types.ts\";\nimport * as db from \"../database/queries.ts\";\nimport { logUserAction } from \"./userService.ts\";\nimport { getProductById } from \"./productService.ts\"; // To validate product existence\n\nexport async function createInventoryBatch(\n payload: CreateInventoryBatchPayload,\n userId: string,\n): Promise {\n // Validate product ID\n const product: Product | null = await getProductById(payload.productId);\n if (!product) {\n throw new Error(`Product with ID \"${payload.productId}\" not found. Cannot create inventory batch.`);\n }\n\n // Ensure quantityCurrent is set, defaults to quantityReceived if not provided\n const batchToCreate: CreateInventoryBatchPayload = {\n ...payload,\n quantityCurrent: payload.quantityCurrent ?? payload.quantityReceived,\n };\n\n const batch = await db.createInventoryBatch(batchToCreate, userId);\n await logUserAction(userId, \"add_inventory\", {\n batchId: batch.id,\n productId: batch.productId,\n productName: product.name, // For better log readability\n quantityReceived: batch.quantityReceived,\n expiryDate: batch.expiryDate,\n });\n return batch;\n}\n\nexport async function getInventoryBatchById(id: string): Promise {\n return db.getInventoryBatchById(id);\n}\n\nexport async function getBatchesForProduct(productId: string): Promise {\n return db.getBatchesForProduct(productId);\n}\n\nexport async function updateInventoryBatch(\n batchId: string,\n updates: Partial>,\n userId: string,\n): Promise {\n const existingBatch = await db.getInventoryBatchById(batchId);\n if (!existingBatch) {\n throw new Error(`Inventory batch with ID \"${batchId}\" not found.`);\n }\n\n // Construct the update object carefully, only allowing certain fields to be updated.\n // For example, productId, createdBy, createdAt should generally not be changed.\n // quantityReceived might also be immutable after creation.\n \n const validUpdates: Partial = {};\n if (updates.quantityCurrent !== undefined) validUpdates.quantityCurrent = updates.quantityCurrent;\n if (updates.receiptDate) validUpdates.receiptDate = updates.receiptDate;\n if (updates.expiryDate) validUpdates.expiryDate = updates.expiryDate;\n if (updates.costPrice !== undefined) validUpdates.costPrice = updates.costPrice;\n if (updates.notes !== undefined) validUpdates.notes = updates.notes;\n // isInitialInventory is typically set at creation and not updated.\n // supplierBillId might be set once if not set at creation.\n\n if (Object.keys(validUpdates).length === 0) {\n return existingBatch; // No valid fields to update\n }\n \n // The db.updateInventoryBatch function needs to be implemented in queries.ts\n // For now, assuming it takes (batchId, updates, userId)\n // This is a simplified update; a real one might involve more complex logic or a dedicated query.\n // Let's assume we have a generic update in queries.ts or we update specific fields.\n // For this demo, let's focus on quantityCurrent as the primary updatable field.\n\n let updatedBatch: InventoryBatch | null = null;\n if (updates.quantityCurrent !== undefined) {\n updatedBatch = await db.updateInventoryBatchQuantity(batchId, updates.quantityCurrent, userId);\n } else {\n // If other fields were to be updated, we'd need a more generic update query\n // For now, if only quantityCurrent is supported for direct update via a specific query:\n console.warn(\"Only quantityCurrent update is directly supported by updateInventoryBatchQuantity. Other updates ignored for now.\");\n updatedBatch = existingBatch; // Return existing if no quantity update\n }\n\n\n if (updatedBatch) {\n await logUserAction(userId, \"update_inventory\", { batchId: updatedBatch.id, changes: validUpdates });\n }\n return updatedBatch;\n}\n\n\nexport async function getExpiringBatches(days?: number): Promise {\n return db.getExpiringBatches(days);\n}\n\nexport async function getTotalProductQuantity(productId: string): Promise {\n const result = await db.getTotalProductQuantity(productId);\n return result.totalQuantity;\n}\n\n// Placeholder for inventory reconciliation logic\nexport async function reconcileInventory(\n productId: string,\n actualPhysicalCount: number,\n userId: string,\n): Promise<{ discrepancies: number; updatedBatches: InventoryBatch[] }> {\n // This is a complex operation:\n // 1. Get all current batches for the product, ordered by expiry (FIFO/FEFO).\n // 2. Compare total system quantity with actualPhysicalCount.\n // 3. Adjust batch quantities. If actual < system, reduce from oldest/nearest expiry.\n // If actual > system, it might mean unrecorded stock (needs investigation or a new \"found\" batch).\n // 4. Log changes.\n console.warn(\n `Reconciliation for product ${productId} with count ${actualPhysicalCount} by user ${userId} - NOT IMPLEMENTED`,\n );\n // For demo, return no change\n const currentBatches = await db.getBatchesForProduct(productId);\n const systemTotal = currentBatches.reduce((sum, batch) => sum + batch.quantityCurrent, 0);\n return { discrepancies: actualPhysicalCount - systemTotal, updatedBatches: [] };\n}",[],[375,385,395],"3ff2afe8-3324-11f0-b59e-9e149126039e","billService.ts","9a08704e-327f-11f0-bda9-569c3dd06744",105,["D",1747489123300],"import {\n SupplierBill,\n SupplierBillItem,\n InventoryBatch,\n CreateInventoryBatchPayload,\n BillScanResponse,\n Product, // Added import\n CreateProductPayload, // Added import\n} from \"../../shared/types.ts\"\nimport * as db from \"../database/queries.ts\"\nimport {aiServiceInstance} from \"./aiService.ts\"\nimport {logUserAction} from \"./userService.ts\"\nimport {getProductById, createProduct, getAllProducts} from \"./productService.ts\"\nimport {createInventoryBatch} from \"./inventoryService.ts\"\nimport {blob} from \"https://esm.town/v/std/blob\" // Val Town blob storage\nimport {v4 as uuidv4} from \"npm:uuid\"\n\n// --- Bill Service Functions ---\n\nexport async function uploadBillImage(\n imageBase64: string, // Raw base64 string\n userId: string,\n originalFileName: string = \"supplier-bill.jpg\",\n): Promise<{billId: string; imageUrl: string}> {\n const fileExtension = originalFileName.split(\".\").pop() || \"jpg\"\n const blobId = `supplier_bills/${userId}/${uuidv4()}.${fileExtension}`\n\n // Convert base64 to Uint8Array for blob storage\n // The browser's atob is needed for base64 decoding. Val Town server-side might need a polyfill or different approach\n // For server-side Deno:\n const byteString = atob(imageBase64)\n const ia = new Uint8Array(byteString.length)\n for (let i = 0; i < byteString.length; i++) {\n ia[i] = byteString.charCodeAt(i)\n }\n await blob.set(blobId, ia)\n\n // Create a preliminary bill record in the database\n const scanDate = new Date().toISOString()\n const partialBill = await db.createSupplierBill(blobId, scanDate, userId)\n\n await logUserAction(userId, \"scan_bill\", {billId: partialBill.id, imageUrl: blobId})\n return {billId: partialBill.id, imageUrl: blobId} // imageUrl is the blobId\n}\n\nexport async function processBillWithAI(\n billId: string,\n userId: string,\n): Promise {\n const bill = await db.getSupplierBillById(billId)\n if (!bill || !bill.imageUrl) {\n throw new Error(`Bill or bill image URL not found for ID: ${billId}`)\n }\n\n // Fetch image from blob storage\n const imageResponse = await blob.get(bill.imageUrl)\n if (!imageResponse) {\n throw new Error(`Image data not found in blob storage for: ${bill.imageUrl}`)\n }\n const imageArrayBuffer = await imageResponse.arrayBuffer()\n const imageUint8Array = new Uint8Array(imageArrayBuffer)\n\n // Convert Uint8Array to base64 string for AI service\n let binary = ''\n const len = imageUint8Array.byteLength\n for (let i = 0; i < len; i++) {\n binary += String.fromCharCode(imageUint8Array[i])\n }\n const imageBase64 = btoa(binary)\n\n const aiExtractedData: BillScanResponse = await aiServiceInstance.scanBill(imageBase64)\n\n const updatedBill = await db.updateSupplierBillWithAIData(billId, aiExtractedData, userId)\n if (updatedBill) {\n await logUserAction(userId, \"process_bill\", {\n billId: updatedBill.id,\n supplier: aiExtractedData.supplierName,\n itemCount: aiExtractedData.items.length,\n })\n }\n return updatedBill\n}\n\nexport async function getBillById(id: string): Promise {\n return db.getSupplierBillById(id)\n}\n\nexport async function getAllBills(filters: {\n startDate?: string\n endDate?: string\n processed?: boolean\n limit?: number\n}): Promise {\n // This would call a db.getAllBills function that needs to be implemented in queries.ts\n // For now, returning empty array as placeholder\n console.warn(\"db.getAllBills not fully implemented in queries.ts yet. Returning empty array.\")\n return []\n}\n\n\nexport async function confirmBillAndCreateBatches(\n billId: string,\n // User might have reviewed/edited items, matched them to existing products, and added expiry dates.\n // This payload reflects that reviewed state.\n reviewedItems: Array & {categoryNameOrId: string}}>,\n userId: string\n): Promise<{success: boolean; createdBatches: InventoryBatch[]; newProducts: Product[]}> {\n const bill = await db.getSupplierBillById(billId)\n if (!bill) throw new Error(`Bill not found: ${billId}`)\n if (bill.processed) throw new Error(`Bill ${billId} has already been processed.`)\n\n const createdBatches: InventoryBatch[] = []\n const newProducts: Product[] = []\n const allProducts = await getAllProducts() // For matching by name/brand\n\n for (const item of reviewedItems) {\n let productId = item.resolvedProductId\n\n if (item.isNewProduct && item.newProductDetails) {\n // Expect categoryNameOrId to be an ID for simplicity here.\n // categoryNameOrId is now optional. productService.createProduct will handle default category.\n // const category = await db.getCategoryById(item.newProductDetails.categoryNameOrId)\n // if (!category && item.newProductDetails.categoryNameOrId) { // only error if an ID was provided but not found\n // throw new Error(`Category not found with ID: ${item.newProductDetails.categoryNameOrId} for new product ${item.productName}`)\n // }\n\n const newProductPayload: CreateProductPayload = {\n name: item.productName, // Use productName from bill item as default\n brand: item.newProductDetails.brand || \"DefaultBrand\", // Default or from input\n defaultPrice: item.newProductDetails.defaultPrice || item.unitPrice, // Default or from input\n categoryId: item.newProductDetails.categoryNameOrId, // Pass as categoryId, can be undefined\n typicalShelfLife: item.newProductDetails.typicalShelfLife, // Corrected field name\n minStockLevel: item.newProductDetails.minStockLevel,\n imageUrl: item.newProductDetails.imageUrl,\n }\n const createdProd = await createProduct(newProductPayload, userId)\n productId = createdProd.id\n newProducts.push(createdProd)\n } else if (!productId) {\n // Try to match existing product if not resolved yet (e.g., by name from bill)\n const matchedProduct = allProducts.find(p => p.name.toLowerCase() === item.productName.toLowerCase())\n if (matchedProduct) {\n productId = matchedProduct.id\n } else {\n // If no match and not marked as new, this is an issue.\n // For demo, could skip or require user to create product first.\n console.warn(`Product \"${item.productName}\" not found and not marked as new. Skipping batch creation for this item.`)\n continue\n }\n }\n\n if (!productId) {\n console.warn(`Could not resolve product ID for \"${item.productName}\". Skipping.`)\n continue\n }\n\n const batchPayload: CreateInventoryBatchPayload = {\n productId: productId,\n quantityReceived: item.quantity,\n quantityCurrent: item.quantity, // Initially current is same as received\n receiptDate: bill.billDate || new Date().toISOString(), // Use bill date or current date\n expiryDate: item.expiryDate || \"9999-12-31\", // Default if not provided\n supplierBillId: billId,\n costPrice: item.costPrice !== undefined ? item.costPrice : item.unitPrice, // Use provided cost or unit price from bill\n isInitialInventory: false,\n }\n const newBatch = await createInventoryBatch(batchPayload, userId)\n createdBatches.push(newBatch)\n }\n\n await db.confirmSupplierBillProcessing(billId, userId) // Marks bill as processed in DB\n await logUserAction(userId, \"confirm_bill\", {billId, createdBatchesCount: createdBatches.length, newProductsCount: newProducts.length})\n\n return {success: true, createdBatches, newProducts}\n}",[],[375,385,403],"5a66c59e-3342-11f0-ac12-9e149126039e","aiService.ts","9a02d5a8-327f-11f0-b555-569c3dd06744",["D",1747502052596],"import {generateObject, LanguageModel, tool} from \"npm:ai\"\nimport {openai} from \"npm:@ai-sdk/openai\"\nimport {google} from \"npm:@ai-sdk/google\"\nimport {\n AIProvider,\n BillScanResponse,\n ExpiryDateScanResponse,\n ProductDetectionResponse,\n} from \"../../shared/types.ts\"\nimport {z} from \"npm:zod\"\n\nexport const BILL_SCANNING_PROMPT = `\nYou are an expert inventory assistant for a retail shop. \nAnalyze this image of a supplier bill and extract the following information in JSON format:\n1. Supplier name\n2. Bill date (YYYY-MM-DD format)\n3. Bill number/reference\n4. List of products with:\n - Product name (exactly as written)\n - Quantity (numeric)\n - Unit price (numeric)\n - Total price per item (numeric)\n5. Overall total amount for the bill (numeric)\nReturn ONLY valid JSON. If a date is unclear, try your best to infer it or use a placeholder like YYYY-MM-DD.\nEnsure all monetary values are numbers, not strings.\nExample for an item: { \"productName\": \"Organic Apples\", \"quantity\": 10, \"unitPrice\": 1.5, \"totalPrice\": 15.0 }\n`\n\nexport const EXPIRY_DATE_PROMPT = `\nYou are an expert inventory assistant for a retail shop.\nAnalyze this image of a product label and extract the following information in JSON format:\n1. Product name (as visible on the label)\n2. Expiry/Best Before date (in YYYY-MM-DD format)\n3. Batch number (if visible)\nReturn ONLY valid JSON. If you cannot determine any field with certainty, use null for that field.\nIf multiple dates are present, prioritize the one explicitly labeled as \"Expiry\", \"EXP\", \"Best Before\", \"BB\".\n`\n\nexport const PRODUCT_DETECTION_PROMPT = `\nYou are an expert inventory assistant for a retail shop.\nAnalyze this image of multiple products on a shelf or display and list all the distinct products you can identify.\nFor each distinct product, provide:\n1. Product name\n2. Estimated quantity visible (numeric count of that specific product)\n3. Any visible expiry information (YYYY-MM-DD or blank if not clearly visible or legible)\n\n1. First identify what items you're counting (cups, bottles, boxes, etc.)\n\n2. Count in three ways:\n - Across: How many items side by side in each row\n - Down: How many separate shelves or vertical layers\n - Deep: Look for hints of items behind the front row, \n - For depth: Consider that it is going to be same setup for Across and Down.. So use AcrossxDownxDeep formula for counting\n\n3. For each shelf:\n - Count visible front items first\n - Look for partially visible items in back rows\n - Note if some items might be completely hidden behind front items\n\n4. Calculate total count by multiplying if the arrangement is regular:\n (Items across) x (Rows deep) x (Number of shelves)\n\n5. Clearly state if you're uncertain about hidden items and provide your best estimate with your reasoning.\n\n\nReturn ONLY valid JSON.\nExample: { \"products\": [{ \"productName\": \"Coke Can 330ml\", \"estimatedQuantity\": 5, \"visibleExpiryDate\": \"2025-12-31\" }] }\n`\n\nconst BillScanSchema = z.object({\n supplierName: z.string().describe(\"Supplier name\"),\n billDate: z.string().describe(\"Bill date (YYYY-MM-DD format)\"),\n billNumber: z.string().describe(\"Bill number/reference\"),\n items: z.array(\n z.object({\n productName: z.string().describe(\"Product name (exactly as written)\"),\n quantity: z.number().describe(\"Quantity (numeric)\"),\n unitPrice: z.number().describe(\"Unit price (numeric)\"),\n totalPrice: z.number().describe(\"Total price per item (numeric)\"),\n }),\n ).describe(\"List of products\"),\n totalAmount: z.number().describe(\"Overall total amount for the bill (numeric)\"),\n})\n\nconst ExpiryDateScanSchema = z.object({\n productName: z.string().nullable().describe(\"Product name (as visible on the label)\"),\n expiryDate: z.string().nullable().describe(\"Expiry/Best Before date (in YYYY-MM-DD format)\"),\n batchNumber: z.string().nullable().describe(\"Batch number (if visible)\"),\n})\n\nconst ProductDetectionSchema = z.object({\n products: z.array(\n z.object({\n productName: z.string().describe(\"Product name\"),\n estimatedQuantity: z.number().describe(\"Estimated quantity visible (numeric count of that specific product)\"),\n visibleExpiryDate: z.string().nullable().describe(\"Any visible expiry information (YYYY-MM-DD or null if not clearly visible or legible)\"),\n }),\n ).describe(\"List of distinct products identified\"),\n})\n\nclass AIService {\n private provider: AIProvider\n private model: LanguageModel\n\n constructor(provider?: AIProvider) {\n const envProvider = Deno.env.get(\"AI_PROVIDER\") as AIProvider | undefined\n this.provider = provider || envProvider || \"openai\"\n\n if (this.provider === \"openai\") {\n if (!Deno.env.get(\"OPENAI_API_KEY\")) {\n console.warn(\"OPENAI_API_KEY environment variable not set. OpenAI calls may fail.\")\n }\n this.model = openai(\"gpt-4o\") as LanguageModel\n } else if (this.provider === \"gemini\") {\n if (!Deno.env.get(\"GOOGLE_GENERATIVE_AI_API_KEY\") && !Deno.env.get(\"GOOGLE_API_KEY\")) {\n console.warn(\"GOOGLE_GENERATIVE_AI_API_KEY or GOOGLE_API_KEY env var not set. Gemini calls may fail.\")\n }\n this.model = google(\"gemini-2.5-pro-preview-03-25\") as LanguageModel\n } else {\n throw new Error(`Unsupported AI provider: ${this.provider}`)\n }\n }\n\n public async processImageWithSchema(\n imageBase64: string,\n promptText: string,\n schema: S,\n tools: Record = {}\n ): Promise> {\n try {\n console.log(`Processing with ${this.provider}, prompt: ${promptText.substring(0, 50)}...`)\n\n const messagesForApi: Array<{\n role: 'user' | 'assistant' | 'system'\n content: Array<\n | {type: 'text'; text: string}\n | {type: 'image'; image: URL}\n >\n }> = [\n {\n role: \"user\",\n content: [\n {type: \"text\", text: promptText},\n { // This object was the source of the syntax error\n type: \"image\",\n image: new URL(`data:image/jpeg;base64,${imageBase64}`),\n }, // Corrected: Comma was inside, should be outside if more elements followed in content array.\n // Or, if it's the last element, no comma needed after its closing brace.\n ],\n },\n ]\n\n const {object} = await generateObject({\n model: this.model,\n schema: schema,\n messages: messagesForApi,\n tools\n })\n console.log(\"AI processing successful.\")\n return schema.parse(object)\n } catch (error) {\n console.error(error)\n console.error(`${this.provider} processing error:`, error)\n if (error instanceof Error) {\n throw new Error(`${this.provider} processing failed: ${error.message}`)\n }\n throw new Error(`${this.provider} processing failed with an unknown error.`)\n }\n }\n\n async scanBill(imageBase64: string): Promise {\n const result = await this.processImageWithSchema(imageBase64, BILL_SCANNING_PROMPT, BillScanSchema)\n return result as BillScanResponse // Re-adding cast\n }\n\n async extractExpiryDate(imageBase64: string): Promise {\n const result = await this.processImageWithSchema(imageBase64, EXPIRY_DATE_PROMPT, ExpiryDateScanSchema)\n return result as ExpiryDateScanResponse // Re-adding cast\n }\n\n async detectProducts(imageBase64: string): Promise {\n const result = await this.processImageWithSchema(imageBase64, PRODUCT_DETECTION_PROMPT, ProductDetectionSchema,\n {\n \"calculate\": tool({\n description: \"A tool for evaluating mathematical expressions, including add, subtract, multiply, divide\",\n parameters: z.object({\n numbers: z.array(z.number()).describe(\"A list of numbers\"),\n operation: z.string().describe(\"Operation to perform, only available options: add, subtract, multiply, divide\")\n }),\n execute: ({numbers, operation}) => {\n switch (operation) {\n case \"add\":\n return numbers.reduce((a, b) => a + b, 0)\n case \"subtract\":\n return numbers.reduce((a, b) => a - b, 0)\n case \"multiply\":\n return numbers.reduce((a, b) => a * b, 1)\n case \"divide\":\n return numbers.reduce((a, b) => a / b, 1)\n default:\n throw new Error(`Unsupported operation: ${operation}`)\n }\n },\n })\n }\n )\n return result as ProductDetectionResponse // Re-adding cast\n }\n}\n\nexport const aiServiceInstance = new AIService();\n\n/*\nasync function testAIService() {\n // const imageBase64 = \"your_base64_image_string_here\"; \n // if (!imageBase64) {\n // console.log(\"Please provide a base64 image string for testing.\");\n // return;\n // }\n try {\n // console.log(\"Testing Bill Scanning...\");\n // const billData = await aiServiceInstance.scanBill(imageBase64);\n // console.log(\"Bill Scan Data:\", billData);\n } catch (e) {\n console.error(\"AI Service test failed:\", e);\n }\n}\n// testAIService();\n*/",[],[375,385,411],"99510148-327f-11f0-8bd6-569c3dd06744",7,["D",1747418406289],[178,179,180,181,182],[375,385],"3fcdccb4-3324-11f0-9df8-9e149126039e","queries.ts","99d7af90-327f-11f0-94c3-569c3dd06744","99258298-327f-11f0-8cfe-569c3dd06744",103,["D",1747489123071],"import { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\nimport {\n User,\n Category,\n Product,\n SupplierBill,\n SupplierBillItem,\n InventoryBatch,\n ActionLog,\n ActionType,\n CreateUserPayload,\n CreateCategoryPayload,\n CreateProductPayload,\n CreateInventoryBatchPayload,\n} from \"../../shared/types.ts\"; // Adjusted path\nimport {\n USERS_TABLE,\n CATEGORIES_TABLE,\n PRODUCTS_TABLE,\n SUPPLIER_BILLS_TABLE,\n BILL_ITEMS_TABLE,\n INVENTORY_BATCHES_TABLE,\n ACTION_LOGS_TABLE,\n} from \"./migrations.ts\";\n\n// Helper to get current ISO date string\nconst now = () => new Date().toISOString();\n// Use crypto.randomUUID() for generating IDs, standard in Deno\nconst uuid = () => crypto.randomUUID();\n\n// --- User Queries ---\nexport async function createUser(payload: CreateUserPayload): Promise {\n const userId = uuid();\n const createdAt = now();\n await sqlite.execute({\n sql: `INSERT INTO ${USERS_TABLE} (id, name, role, created_at) VALUES (?, ?, ?, ?);`,\n args: [userId, payload.name, payload.role, createdAt],\n });\n return { id: userId, ...payload, createdAt };\n}\n\nexport async function getUserById(id: string): Promise {\n const result = await sqlite.execute({\n sql: `SELECT id, name, role, created_at FROM ${USERS_TABLE} WHERE id = ?;`,\n args: [id],\n });\n if (result.rows.length === 0) return null;\n const row = result.rows[0] as Record;\n return {\n id: row.id as string,\n name: row.name as string,\n role: row.role as \"owner\" | \"staff\",\n createdAt: row.created_at as string,\n };\n}\n\nexport async function getAllUsers(): Promise {\n const result = await sqlite.execute(`SELECT id, name, role, created_at FROM ${USERS_TABLE};`);\n return result.rows.map(row => {\n const r = row as Record;\n return {\n id: r.id as string,\n name: r.name as string,\n role: r.role as \"owner\" | \"staff\",\n createdAt: r.created_at as string\n };\n });\n}\n\n// --- Category Queries ---\nexport async function createCategory(payload: CreateCategoryPayload, userId: string): Promise {\n const categoryId = uuid();\n const createdAt = now();\n await sqlite.execute({\n sql: `INSERT INTO ${CATEGORIES_TABLE} (id, name, description, created_by, created_at) VALUES (?, ?, ?, ?, ?);`,\n args: [categoryId, payload.name, payload.description, userId, createdAt],\n });\n return { id: categoryId, ...payload, createdBy: userId, createdAt };\n}\n\nexport async function getCategoryById(id: string): Promise {\n const result = await sqlite.execute({\n sql: `SELECT id, name, description, created_by, created_at FROM ${CATEGORIES_TABLE} WHERE id = ?;`,\n args: [id],\n });\n if (result.rows.length === 0) return null;\n const row = result.rows[0] as Record;\n return {\n id: row.id as string,\n name: row.name as string,\n description: row.description as string | undefined,\n createdBy: row.created_by as string,\n createdAt: row.created_at as string,\n };\n}\n\nexport async function getAllCategories(): Promise {\n const result = await sqlite.execute(\n `SELECT id, name, description, created_by, created_at FROM ${CATEGORIES_TABLE} ORDER BY name ASC;`,\n );\n return result.rows.map(row => {\n const r = row as Record;\n return {\n id: r.id as string,\n name: r.name as string,\n description: r.description as string | undefined,\n createdBy: r.created_by as string,\n createdAt: r.created_at as string,\n };\n });\n}\n\nexport async function getCategoryByName(name: string): Promise {\n const result = await sqlite.execute({\n sql: `SELECT id, name, description, created_by, created_at FROM ${CATEGORIES_TABLE} WHERE name = ?;`,\n args: [name], // Assuming name is stored with consistent casing or UNIQUE constraint handles it\n });\n if (result.rows.length === 0) return null;\n const row = result.rows[0] as Record;\n return {\n id: row.id as string,\n name: row.name as string,\n description: row.description as string | undefined,\n createdBy: row.created_by as string,\n createdAt: row.created_at as string,\n };\n}\n\n\n\n// --- Product Queries ---\nexport async function createProduct(payload: CreateProductPayload, userId: string): Promise {\n const productId = uuid();\n const currentTime = now();\n const { categoryId, ...restOfPayload } = payload; // categoryId is the correct field for DB\n await sqlite.execute({\n sql:\n `INSERT INTO ${PRODUCTS_TABLE} \n (id, name, brand, default_price, category_id, typical_shelf_life, min_stock_level, image_url, created_by, created_at, updated_by, updated_at) \n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?);`,\n args: [\n productId,\n restOfPayload.name,\n restOfPayload.brand,\n restOfPayload.defaultPrice,\n categoryId, // Use categoryId here\n restOfPayload.typicalShelfLife,\n restOfPayload.minStockLevel,\n restOfPayload.imageUrl,\n userId,\n currentTime,\n userId,\n currentTime,\n ],\n });\n // The 'category' field in Product type is a string, but we store category_id.\n // For returning the Product object, we might need to fetch category name or adjust the type.\n // For now, returning as is, assuming 'category' in Product type means categoryId.\n return { \n id: productId, \n ...restOfPayload, \n category: categoryId, // This matches the Product interface if 'category' is treated as ID\n createdBy: userId, \n createdAt: currentTime, \n updatedBy: userId, \n updatedAt: currentTime \n };\n}\n\nexport async function getProductById(id: string): Promise {\n const result = await sqlite.execute({\n sql: `\n SELECT p.id, p.name, p.brand, p.default_price, p.category_id as category, \n p.typical_shelf_life, p.min_stock_level, p.image_url, \n p.created_by, p.created_at, p.updated_by, p.updated_at\n FROM ${PRODUCTS_TABLE} p\n WHERE p.id = ?;\n `,\n args: [id],\n });\n if (result.rows.length === 0) return null;\n const row = result.rows[0] as Record; // Cast to Record for easier access\n return {\n id: row.id as string,\n name: row.name as string,\n brand: row.brand as string,\n defaultPrice: row.default_price as number,\n category: row.category as string, // This is category_id\n typicalShelfLife: row.typical_shelf_life as number | undefined,\n minStockLevel: row.min_stock_level as number | undefined,\n imageUrl: row.image_url as string | undefined,\n createdBy: row.created_by as string,\n createdAt: row.created_at as string,\n updatedBy: row.updated_by as string,\n updatedAt: row.updated_at as string,\n };\n}\n\nexport async function getAllProductsWithCategory(): Promise> {\n const result = await sqlite.execute(`\n SELECT p.id, p.name, p.brand, p.default_price, p.category_id, c.name as category_name,\n p.typical_shelf_life, p.min_stock_level, p.image_url,\n p.created_by, p.created_at, p.updated_by, p.updated_at\n FROM ${PRODUCTS_TABLE} p\n JOIN ${CATEGORIES_TABLE} c ON p.category_id = c.id\n ORDER BY p.name ASC;\n `);\n return result.rows.map(row => {\n const r = row as Record;\n return {\n id: r.id as string,\n name: r.name as string,\n brand: r.brand as string,\n defaultPrice: r.default_price as number,\n category: r.category_id as string, // This is category_id\n typicalShelfLife: r.typical_shelf_life as number | undefined,\n minStockLevel: r.min_stock_level as number | undefined,\n imageUrl: r.image_url as string | undefined,\n createdBy: r.created_by as string,\n createdAt: r.created_at as string,\n updatedBy: r.updated_by as string,\n updatedAt: r.updated_at as string,\n categoryName: r.category_name as string,\n };\n });\n}\n\nexport async function updateProduct(productId: string, payload: Partial, userId: string): Promise {\n const existingProduct = await getProductById(productId);\n if (!existingProduct) return null;\n\n const fieldsToUpdate = { ...existingProduct, ...payload, category: payload.categoryId || existingProduct.category, updatedAt: now(), updatedBy: userId };\n \n await sqlite.execute({\n sql: `\n UPDATE ${PRODUCTS_TABLE}\n SET name = ?, brand = ?, default_price = ?, category_id = ?, \n typical_shelf_life = ?, min_stock_level = ?, image_url = ?, \n updated_by = ?, updated_at = ?\n WHERE id = ?;\n `,\n args: [\n fieldsToUpdate.name,\n fieldsToUpdate.brand,\n fieldsToUpdate.defaultPrice,\n fieldsToUpdate.category, // category_id\n fieldsToUpdate.typicalShelfLife,\n fieldsToUpdate.minStockLevel,\n fieldsToUpdate.imageUrl,\n userId,\n fieldsToUpdate.updatedAt,\n productId,\n ],\n });\n return getProductById(productId); // Fetch updated product\n}\n\n\n// --- Supplier Bill Queries ---\nexport async function createSupplierBill(\n imageUrl: string,\n scanDate: string,\n userId: string,\n): Promise {\n const billId = uuid();\n const createdAt = now();\n await sqlite.execute({\n sql: `\n INSERT INTO ${SUPPLIER_BILLS_TABLE} (id, image_url, scan_date, created_by, created_at, processed) \n VALUES (?, ?, ?, ?, ?, 0);`,\n args: [billId, imageUrl, scanDate, userId, createdAt],\n });\n // Return a partial bill object, more details will be filled after AI processing\n return {\n id: billId,\n imageUrl,\n scanDate,\n supplierName: \"\", // To be filled by AI\n billDate: \"\", // To be filled by AI\n billNumber: \"\", // To be filled by AI\n items: [], // To be filled by AI\n totalAmount: 0, // To be filled by AI\n processed: false,\n createdBy: userId,\n createdAt,\n };\n}\n\nexport async function getSupplierBillById(id: string): Promise {\n const billResult = await sqlite.execute({\n sql: `SELECT * FROM ${SUPPLIER_BILLS_TABLE} WHERE id = ?;`,\n args: [id],\n });\n if (billResult.rows.length === 0) return null;\n const billData = billResult.rows[0] as Record;\n\n const itemsResult = await sqlite.execute({\n sql: `SELECT product_id, product_name_on_bill, quantity, unit_price, total FROM ${BILL_ITEMS_TABLE} WHERE bill_id = ?;`,\n args: [id],\n });\n\n return {\n id: billData.id as string,\n imageUrl: billData.image_url as string,\n scanDate: billData.scan_date as string,\n supplierName: billData.supplier_name as string,\n billDate: billData.bill_date as string,\n billNumber: billData.bill_number as string,\n items: itemsResult.rows.map(item => {\n const rItem = item as Record;\n return {\n productId: rItem.product_id as string | undefined,\n productName: rItem.product_name_on_bill as string,\n quantity: rItem.quantity as number,\n unitPrice: rItem.unit_price as number,\n total: rItem.total as number,\n };\n }) as SupplierBillItem[],\n totalAmount: billData.total_amount as number,\n processed: !!billData.processed,\n createdBy: billData.created_by as string,\n createdAt: billData.created_at as string,\n };\n}\n\nexport async function updateSupplierBillWithAIData(\n billId: string,\n aiData: {\n supplierName: string;\n billDate: string;\n billNumber: string;\n items: Array<{ productName: string; quantity: number; unitPrice: number; totalPrice: number }>;\n totalAmount: number;\n },\n userId: string,\n): Promise {\n await sqlite.execute({\n sql: `\n UPDATE ${SUPPLIER_BILLS_TABLE} \n SET supplier_name = ?, bill_date = ?, bill_number = ?, total_amount = ?, processed = 0 \n WHERE id = ?;`, // Keep processed = 0 until confirmed by user\n args: [aiData.supplierName, aiData.billDate, aiData.billNumber, aiData.totalAmount, billId],\n });\n\n // Clear existing items for this bill and insert new ones from AI\n await sqlite.execute({ sql: `DELETE FROM ${BILL_ITEMS_TABLE} WHERE bill_id = ?;`, args: [billId] });\n\n for (const item of aiData.items) {\n const itemId = uuid();\n await sqlite.execute({\n sql: `\n INSERT INTO ${BILL_ITEMS_TABLE} (id, bill_id, product_name_on_bill, quantity, unit_price, total) \n VALUES (?, ?, ?, ?, ?, ?);`,\n args: [itemId, billId, item.productName, item.quantity, item.unitPrice, item.totalPrice],\n });\n }\n return getSupplierBillById(billId);\n}\n\nexport async function confirmSupplierBillProcessing(billId: string, userId: string): Promise {\n // This function would involve:\n // 1. Verifying bill items, potentially matching product_name_on_bill to existing products or creating new ones.\n // 2. Creating InventoryBatch records for each confirmed item.\n // 3. Marking the bill as processed.\n // This is a complex step and will be fleshed out in the billService.ts.\n // For now, just mark as processed.\n await sqlite.execute({\n sql: `UPDATE ${SUPPLIER_BILLS_TABLE} SET processed = 1 WHERE id = ?;`,\n args: [billId],\n });\n // Log action\n await logAction(userId, \"confirm_bill\", { billId });\n return true;\n}\n\n\n// --- Inventory Batch Queries ---\nexport async function createInventoryBatch(payload: CreateInventoryBatchPayload, userId: string): Promise {\n const batchId = uuid();\n const currentTime = now();\n await sqlite.execute({\n sql: `\n INSERT INTO ${INVENTORY_BATCHES_TABLE} \n (id, product_id, quantity_received, quantity_current, receipt_date, expiry_date, \n supplier_bill_id, cost_price, is_initial_inventory, notes, \n created_by, created_at, updated_by, updated_at) \n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?);`,\n args: [\n batchId,\n payload.productId,\n payload.quantityReceived,\n payload.quantityCurrent, // Initially same as received\n payload.receiptDate,\n payload.expiryDate,\n payload.supplierBillId,\n payload.costPrice,\n payload.isInitialInventory,\n payload.notes,\n userId,\n currentTime,\n userId,\n currentTime,\n ],\n });\n return { \n id: batchId, \n ...payload, \n createdBy: userId, \n createdAt: currentTime, \n updatedBy: userId, \n updatedAt: currentTime \n };\n}\n\nexport async function getInventoryBatchById(id: string): Promise {\n const result = await sqlite.execute({\n sql: `SELECT * FROM ${INVENTORY_BATCHES_TABLE} WHERE id = ?;`,\n args: [id],\n });\n if (result.rows.length === 0) return null;\n const row = result.rows[0] as Record;\n return {\n id: row.id as string,\n productId: row.product_id as string,\n quantityReceived: row.quantity_received as number,\n quantityCurrent: row.quantity_current as number,\n receiptDate: row.receipt_date as string,\n expiryDate: row.expiry_date as string,\n supplierBillId: row.supplier_bill_id as string | undefined,\n costPrice: row.cost_price as number | undefined,\n isInitialInventory: !!row.is_initial_inventory,\n notes: row.notes as string | undefined,\n createdBy: row.created_by as string,\n createdAt: row.created_at as string,\n updatedBy: row.updated_by as string,\n updatedAt: row.updated_at as string,\n };\n}\n\nexport async function getBatchesForProduct(productId: string): Promise {\n const result = await sqlite.execute({\n sql: `SELECT * FROM ${INVENTORY_BATCHES_TABLE} WHERE product_id = ? ORDER BY expiry_date ASC;`,\n args: [productId],\n });\n return result.rows.map(row => {\n const r = row as Record;\n return {\n id: r.id as string,\n productId: r.product_id as string,\n quantityReceived: r.quantity_received as number,\n quantityCurrent: r.quantity_current as number,\n receiptDate: r.receipt_date as string,\n expiryDate: r.expiry_date as string,\n supplierBillId: r.supplier_bill_id as string | undefined,\n costPrice: r.cost_price as number | undefined,\n isInitialInventory: !!r.is_initial_inventory,\n notes: r.notes as string | undefined,\n createdBy: r.created_by as string,\n createdAt: r.created_at as string,\n updatedBy: r.updated_by as string,\n updatedAt: r.updated_at as string,\n };\n });\n}\n\nexport async function updateInventoryBatchQuantity(batchId: string, newQuantityCurrent: number, userId: string): Promise {\n const updatedAt = now();\n await sqlite.execute({\n sql: `UPDATE ${INVENTORY_BATCHES_TABLE} SET quantity_current = ?, updated_by = ?, updated_at = ? WHERE id = ?;`,\n args: [newQuantityCurrent, userId, updatedAt, batchId],\n });\n return getInventoryBatchById(batchId);\n}\n\nexport async function getExpiringBatches(days: number = 30): Promise {\n const dateLimit = new Date();\n dateLimit.setDate(dateLimit.getDate() + days);\n const isoDateLimit = dateLimit.toISOString().split('T')[0]; // YYYY-MM-DD format\n\n const result = await sqlite.execute({\n sql: `\n SELECT ib.*, p.name as productName \n FROM ${INVENTORY_BATCHES_TABLE} ib\n JOIN ${PRODUCTS_TABLE} p ON ib.product_id = p.id\n WHERE ib.expiry_date <= ? AND ib.quantity_current > 0\n ORDER BY ib.expiry_date ASC;\n `,\n args: [isoDateLimit],\n });\n return result.rows.map(row => {\n const r = row as Record;\n return {\n id: r.id as string,\n productId: r.product_id as string,\n quantityReceived: r.quantity_received as number,\n quantityCurrent: r.quantity_current as number,\n receiptDate: r.receipt_date as string,\n expiryDate: r.expiry_date as string,\n supplierBillId: r.supplier_bill_id as string | undefined,\n costPrice: r.cost_price as number | undefined,\n isInitialInventory: !!r.is_initial_inventory,\n notes: r.notes as string | undefined,\n createdBy: r.created_by as string,\n createdAt: r.created_at as string,\n updatedBy: r.updated_by as string,\n updatedAt: r.updated_at as string,\n // productName is joined from products table\n productName: r.productName as string,\n };\n });\n}\n\nexport async function getTotalProductQuantity(productId: string): Promise<{ productId: string; totalQuantity: number }> {\n const result = await sqlite.execute({\n sql: `\n SELECT product_id, SUM(quantity_current) as total_quantity\n FROM ${INVENTORY_BATCHES_TABLE}\n WHERE product_id = ?\n GROUP BY product_id;\n `,\n args: [productId],\n });\n if (result.rows.length === 0) {\n return { productId, totalQuantity: 0 };\n }\n return { productId, totalQuantity: (result.rows[0] as any).total_quantity || 0 };\n}\n\nexport async function getLowStockProducts(): Promise> {\n const result = await sqlite.execute(`\n SELECT p.id, p.name, p.brand, p.default_price, p.category_id as category, \n p.typical_shelf_life, p.min_stock_level, p.image_url,\n p.created_by, p.created_at, p.updated_by, p.updated_at,\n COALESCE(SUM(ib.quantity_current), 0) as current_quantity\n FROM ${PRODUCTS_TABLE} p\n LEFT JOIN ${INVENTORY_BATCHES_TABLE} ib ON p.id = ib.product_id\n GROUP BY p.id\n HAVING COALESCE(SUM(ib.quantity_current), 0) < p.min_stock_level AND p.min_stock_level IS NOT NULL;\n `);\n return result.rows.map(row => ({\n id: row.id,\n name: row.name,\n brand: row.brand,\n defaultPrice: row.default_price,\n category: row.category, // category_id\n typicalShelfLife: row.typical_shelf_life,\n minStockLevel: row.min_stock_level,\n imageUrl: row.image_url,\n createdBy: row.created_by,\n createdAt: row.created_at,\n updatedBy: row.updated_by,\n updatedAt: row.updated_at,\n currentQuantity: row.current_quantity,\n })) as Array;\n}\n\n\n// --- Action Log Queries ---\nexport async function logAction(\n userId: string,\n action: ActionType,\n details: any,\n userName?: string, // Optional: fetch if not provided\n): Promise {\n const logId = uuid();\n const timestamp = now();\n let finalUserName = userName;\n\n if (!finalUserName) {\n const user = await getUserById(userId);\n finalUserName = user ? user.name : \"Unknown User\";\n }\n\n await sqlite.execute({\n sql: `INSERT INTO ${ACTION_LOGS_TABLE} (id, user_id, user_name, action, details, timestamp) VALUES (?, ?, ?, ?, ?, ?);`,\n args: [logId, userId, finalUserName, action, JSON.stringify(details), timestamp],\n });\n return { id: logId, userId, userName: finalUserName, action, details, timestamp };\n}\n\nexport async function getActionLogs(filters: {\n startDate?: string;\n endDate?: string;\n userId?: string;\n action?: ActionType;\n limit?: number;\n}): Promise {\n let query = `SELECT * FROM ${ACTION_LOGS_TABLE} WHERE 1=1`;\n const args: any[] = [];\n\n if (filters.userId) {\n query += \" AND user_id = ?\";\n args.push(filters.userId);\n }\n if (filters.action) {\n query += \" AND action = ?\";\n args.push(filters.action);\n }\n if (filters.startDate) {\n query += \" AND timestamp >= ?\";\n args.push(filters.startDate);\n }\n if (filters.endDate) {\n query += \" AND timestamp <= ?\";\n args.push(filters.endDate);\n }\n query += \" ORDER BY timestamp DESC\";\n if (filters.limit) {\n query += \" LIMIT ?\";\n args.push(filters.limit);\n }\n\n const result = await sqlite.execute({ sql: query, args });\n return (result.rows as any[]).map(row => ({\n ...row,\n details: JSON.parse(row.details),\n })) as ActionLog[];\n}",[],[375,431,423],"database","a535549a-3320-11f0-ac66-9e149126039e","migrations.ts","99b068e0-327f-11f0-b380-569c3dd06744",94,["D",1747487575213],"import {sqlite} from \"https://esm.town/v/stevekrouse/sqlite\" // Standard Val Town import\n\nexport const USERS_TABLE = \"users_v1\"\nexport const CATEGORIES_TABLE = \"categories_v1\"\nexport const PRODUCTS_TABLE = \"products_v1\"\nexport const SUPPLIER_BILLS_TABLE = \"supplier_bills_v1\"\nexport const BILL_ITEMS_TABLE = \"bill_items_v1\"\nexport const INVENTORY_BATCHES_TABLE = \"inventory_batches_v1\"\nexport const ACTION_LOGS_TABLE = \"action_logs_v1\"\n\nexport async function runMigrations() {\n // Users table\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${USERS_TABLE} (\n id TEXT PRIMARY KEY,\n name TEXT NOT NULL,\n role TEXT NOT NULL CHECK (role IN ('owner', 'staff')),\n created_at TEXT NOT NULL\n );\n `)\n\n //Add two new users. Name: Vipulbhai and Hareshbhai, Both role as owners.\n await sqlite.execute(`\n INSERT INTO ${USERS_TABLE} (id, name, role, created_at)\n VALUES\n ('user_1', 'Vipulbhai', 'owner', '2025-05-01'),\n ('user_2', 'Hareshbhai', 'owner', '2025-05-01');\n `)\n\n\n // Categories table\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${CATEGORIES_TABLE} (\n id TEXT PRIMARY KEY,\n name TEXT NOT NULL UNIQUE,\n description TEXT,\n created_by TEXT NOT NULL,\n created_at TEXT NOT NULL,\n FOREIGN KEY (created_by) REFERENCES ${USERS_TABLE}(id)\n );\n `)\n\n // Products table\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${PRODUCTS_TABLE} (\n id TEXT PRIMARY KEY,\n name TEXT NOT NULL,\n brand TEXT NOT NULL,\n default_price REAL NOT NULL,\n category_id TEXT NOT NULL,\n typical_shelf_life INTEGER,\n min_stock_level INTEGER,\n image_url TEXT,\n created_by TEXT NOT NULL,\n created_at TEXT NOT NULL,\n updated_by TEXT NOT NULL,\n updated_at TEXT NOT NULL,\n FOREIGN KEY (category_id) REFERENCES ${CATEGORIES_TABLE}(id),\n FOREIGN KEY (created_by) REFERENCES ${USERS_TABLE}(id),\n FOREIGN KEY (updated_by) REFERENCES ${USERS_TABLE}(id)\n );\n `)\n\n // Supplier bills table\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${SUPPLIER_BILLS_TABLE} (\n id TEXT PRIMARY KEY,\n image_url TEXT NOT NULL, -- This will be a Val Town blob key or URL\n scan_date TEXT NOT NULL,\n supplier_name TEXT,\n bill_date TEXT,\n bill_number TEXT,\n total_amount REAL,\n processed BOOLEAN NOT NULL DEFAULT 0,\n created_by TEXT NOT NULL,\n created_at TEXT NOT NULL,\n FOREIGN KEY (created_by) REFERENCES ${USERS_TABLE}(id)\n );\n `)\n\n // Bill items table\n // productName is stored here as it appears on the bill, before matching to an existing Product\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${BILL_ITEMS_TABLE} (\n id TEXT PRIMARY KEY,\n bill_id TEXT NOT NULL,\n product_id TEXT, -- Can be null if product not yet in system or matched\n product_name_on_bill TEXT NOT NULL, \n quantity INTEGER NOT NULL,\n unit_price REAL NOT NULL,\n total REAL NOT NULL,\n FOREIGN KEY (bill_id) REFERENCES ${SUPPLIER_BILLS_TABLE}(id),\n FOREIGN KEY (product_id) REFERENCES ${PRODUCTS_TABLE}(id)\n );\n `)\n\n // Inventory batches table\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${INVENTORY_BATCHES_TABLE} (\n id TEXT PRIMARY KEY,\n product_id TEXT NOT NULL,\n quantity_received INTEGER NOT NULL,\n quantity_current INTEGER NOT NULL,\n receipt_date TEXT NOT NULL,\n expiry_date TEXT NOT NULL,\n supplier_bill_id TEXT,\n cost_price REAL,\n is_initial_inventory BOOLEAN NOT NULL DEFAULT 0,\n notes TEXT,\n created_by TEXT NOT NULL,\n created_at TEXT NOT NULL,\n updated_by TEXT NOT NULL,\n updated_at TEXT NOT NULL,\n FOREIGN KEY (product_id) REFERENCES ${PRODUCTS_TABLE}(id),\n FOREIGN KEY (supplier_bill_id) REFERENCES ${SUPPLIER_BILLS_TABLE}(id),\n FOREIGN KEY (created_by) REFERENCES ${USERS_TABLE}(id),\n FOREIGN KEY (updated_by) REFERENCES ${USERS_TABLE}(id)\n );\n `)\n\n // Action logs table\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${ACTION_LOGS_TABLE} (\n id TEXT PRIMARY KEY,\n user_id TEXT NOT NULL,\n user_name TEXT NOT NULL, -- Denormalized for easier querying/display\n action TEXT NOT NULL,\n details TEXT NOT NULL, -- JSON string\n timestamp TEXT NOT NULL,\n FOREIGN KEY (user_id) REFERENCES ${USERS_TABLE}(id)\n );\n `)\n\n console.log(\"Database migrations completed.\")\n}\n\n// Example of how to call this, likely in your main backend/index.ts\n// (async () => {\n// try {\n// await runMigrations();\n// } catch (e) {\n// console.error(\"Migration failed:\", e);\n// }\n// })();",[],[375,431,433],"992581c6-327f-11f0-8cfe-569c3dd06744",6,["D",1747418406004],[175,176],[375,431],"985735dc-327f-11f0-8c28-569c3dd06744",["D",1747418404637],[174,177,183],[375],"98aa15c2-327f-11f0-a7ab-569c3dd06744",".roo","98aa1662-327f-11f0-a7ab-569c3dd06744",["D",1747418405195],[],[450],["D",1747411285389],["D",1789647704026],{"_11":12,"_125":70},{"_11":12,"_121":-5,"_69":70,"_31":68,"_122":123,"_124":30},{"_39":112,"_13":16,"_33":36,"_113":74,"_114":-5,"_115":-5,"_116":-5,"_117":-5,"_118":-5,"_119":14,"_120":12},"ctx",{"_52":-5,"_144":493,"_494":495,"_496":497,"_498":30,"_499":30,"_500":30,"_501":24,"_502":-5,"_503":-7,"_504":-7,"_505":26,"_506":30,"_507":30,"_508":-5,"_509":30,"_510":30,"_511":30,"_512":-5},"ENV",{"_464":465,"_466":467,"_468":16,"_469":470,"_471":472,"_473":474,"_475":476,"_477":478,"_479":480,"_481":482,"_483":484,"_485":486,"_487":488,"_489":490,"_491":492},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e8c4b7030cb7600e4eb0736b15f422c8b8bd130f","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

History · shared