[{"_1":2,"_174":-5,"_175":-5},"loaderData",{"_3":4,"_91":92},"root",{"_5":6,"_34":35,"_64":65},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":20,"_29":20,"_30":20,"_31":32,"_33":20},"auth",{"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20,"_21":22},"sessionClaims","sessionId","sessionStatus","userId","actor","orgId","orgRole","orgSlug","orgPermissions","factorVerificationAge","isAuthenticated",false,"tokenType","session_token","user","preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","notificationCount",0,"flagDenols","ENV",{"_36":37,"_38":39,"_40":41,"_42":43,"_44":45,"_46":47,"_48":49,"_50":51,"_52":53,"_54":55,"_56":57,"_58":59,"_60":61,"_62":63},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","a31a1550ad486cf340b818a53bc6ddc8c7db0295","RENDER_GIT_BRANCH","main","CLERK_PUBLISHABLE_KEY","pk_live_Y2xlcmsudmFsLnRvd24k","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","API_URL","https://api.val.town","clerkState",{"_66":67},"__internal_clerk_state",{"_68":69,"_70":45,"_71":72,"_73":72,"_74":20,"_75":72,"_76":72,"_77":72,"_78":72,"_79":80,"_89":20,"_90":20},"__clerk_ssr_state",{"_21":22,"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20},"__publishableKey","__proxyUrl","","__domain","__isSatellite","__signInUrl","__signUpUrl","__afterSignInUrl","__afterSignUpUrl","__clerk_debug",{"_81":20,"_19":20,"_82":72,"_83":84,"_85":72,"_86":45,"_87":20,"_88":72},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_93":94,"_95":96,"_97":98,"_99":100,"_147":148,"_171":172,"_173":-5},"handle","Omosola_1","name","Create","path","backend/database/queries.ts","project",{"_101":102,"_95":96,"_103":104,"_105":-5,"_106":20,"_107":108,"_109":-5,"_110":-5,"_12":111,"_112":-5,"_113":20,"_114":-5,"_115":-5,"_116":32,"_14":117,"_118":119,"_120":119,"_121":122,"_123":122,"_124":122,"_125":119,"_126":119,"_23":127,"_130":131,"_133":134,"_146":20},"id","7f913522-3fbb-11f0-8527-76b3cceeab13","createdAt",["D",1748873498012],"deletedAt","legacyEnvVars","privacy","public","description","imageUrl","0e34d7e0-3fb5-11f0-ad5b-814c56c8abb0","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount","ed0c482c-f125-41bf-ae53-9cfee79e7143","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_93":94,"_128":129},"profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoiZGVmYXVsdCIsImlpZCI6Imluc18yTm10cGhQUklwU0tqZHNiOHNnNGd2ZjJURFUiLCJyaWQiOiJ1c2VyXzJ4eERCbUppTjNsd0d1UU5DaUVUTFpySmdOMSJ9","org",{"_93":94,"_132":129,"_12":111},"avatar","branch",{"_135":136,"_95":43,"_101":137,"_138":102,"_139":-5,"_140":-5,"_141":-5,"_142":-5,"_143":-5,"_144":96,"_145":94},"version",28,"7f918b1c-3fbb-11f0-8527-76b3cceeab13","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_101":149,"_95":150,"_151":152,"_153":154,"_155":137,"_156":157,"_158":159,"_103":160,"_135":161,"_162":163,"_164":165,"_166":20,"_167":-5,"_97":168},"35e73586-3fbe-11f0-ac12-76b3cceeab13","queries.ts","fileId","a5fb42e2-3fbc-11f0-a441-76b3cceeab13","parentId","16270a59-44a8-42a3-b340-f8c8ad1b5d94","branchId","branchVersion",27,"latest",true,["D",1748874662907],1,"fileType","script","content","import { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\nimport { TABLES } from \"./migrations.ts\";\nimport type { \n User, Vendor, VendorApplication, Product, Review, Wishlist, Collection,\n Order, OrderItem, ProductFilters, VendorFilters, SearchParams,\n PaginatedResponse \n} from \"../../shared/types.ts\";\n\n// Helper function to parse JSON fields\nfunction parseJsonField(field: string | null): any[] {\n if (!field) return [];\n try {\n return JSON.parse(field);\n } catch {\n return [];\n }\n}\n\n// Helper function to parse JSON object fields\nfunction parseJsonObject(field: string | null): any {\n if (!field) return {};\n try {\n return JSON.parse(field);\n } catch {\n return {};\n }\n}\n\n// USER QUERIES\nexport async function createUser(user: Omit): Promise {\n const result = await sqlite.execute(`\n INSERT INTO ${TABLES.USERS} (username, email, fullName, bio, profileImage, userType, preferences)\n VALUES (?, ?, ?, ?, ?, ?, ?)\n `, [\n user.username, user.email, user.fullName, user.bio || null, \n user.profileImage || null, user.userType || 'customer', \n JSON.stringify(user.preferences || {})\n ]);\n \n return getUserById(result.lastInsertRowid as number);\n}\n\nexport async function getUserById(id: number): Promise {\n const result = await sqlite.execute(`SELECT * FROM ${TABLES.USERS} WHERE id = ? AND isActive = 1`, [id]);\n if (result.length === 0) return null;\n \n const user = result[0];\n return {\n ...user,\n preferences: parseJsonObject(user.preferences)\n } as User;\n}\n\nexport async function getUserByEmail(email: string): Promise {\n const result = await sqlite.execute(`SELECT * FROM ${TABLES.USERS} WHERE email = ? AND isActive = 1`, [email]);\n if (result.length === 0) return null;\n \n const user = result[0];\n return {\n ...user,\n preferences: parseJsonObject(user.preferences)\n } as User;\n}\n\nexport async function updateUser(id: number, updates: Partial): Promise {\n const fields = [];\n const values = [];\n \n if (updates.fullName !== undefined) {\n fields.push('fullName = ?');\n values.push(updates.fullName);\n }\n if (updates.bio !== undefined) {\n fields.push('bio = ?');\n values.push(updates.bio);\n }\n if (updates.profileImage !== undefined) {\n fields.push('profileImage = ?');\n values.push(updates.profileImage);\n }\n if (updates.preferences !== undefined) {\n fields.push('preferences = ?');\n values.push(JSON.stringify(updates.preferences));\n }\n \n if (fields.length === 0) return getUserById(id);\n \n values.push(id);\n await sqlite.execute(`UPDATE ${TABLES.USERS} SET ${fields.join(', ')} WHERE id = ?`, values);\n \n return getUserById(id);\n}\n\n// VENDOR QUERIES\nexport async function createVendor(vendor: Omit): Promise {\n const result = await sqlite.execute(`\n INSERT INTO ${TABLES.VENDORS} (userId, businessName, description, specialties, location, website, phone, email, logoUrl, isVerified)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?)\n `, [\n vendor.userId, vendor.businessName, vendor.description, \n JSON.stringify(vendor.specialties), vendor.location,\n vendor.website || null, vendor.phone || null, vendor.email || null,\n vendor.logoUrl || null, vendor.isVerified || false\n ]);\n \n // Update user type to vendor\n await sqlite.execute(`UPDATE ${TABLES.USERS} SET userType = 'vendor' WHERE id = ?`, [vendor.userId]);\n \n return getVendorById(result.lastInsertRowid as number);\n}\n\nexport async function getVendorById(id: number): Promise {\n const result = await sqlite.execute(`SELECT * FROM ${TABLES.VENDORS} WHERE id = ? AND isActive = 1`, [id]);\n if (result.length === 0) return null;\n \n const vendor = result[0];\n return {\n ...vendor,\n specialties: parseJsonField(vendor.specialties)\n } as Vendor;\n}\n\nexport async function getVendorByUserId(userId: number): Promise {\n const result = await sqlite.execute(`SELECT * FROM ${TABLES.VENDORS} WHERE userId = ? AND isActive = 1`, [userId]);\n if (result.length === 0) return null;\n \n const vendor = result[0];\n return {\n ...vendor,\n specialties: parseJsonField(vendor.specialties)\n } as Vendor;\n}\n\nexport async function getVendors(filters: VendorFilters = {}, page = 1, limit = 12): Promise> {\n let query = `SELECT * FROM ${TABLES.VENDORS} WHERE isActive = 1`;\n const params: any[] = [];\n \n if (filters.location) {\n query += ` AND location LIKE ?`;\n params.push(`%${filters.location}%`);\n }\n \n if (filters.rating) {\n query += ` AND rating >= ?`;\n params.push(filters.rating);\n }\n \n if (filters.isVerified !== undefined) {\n query += ` AND isVerified = ?`;\n params.push(filters.isVerified ? 1 : 0);\n }\n \n query += ` ORDER BY isVerified DESC, rating DESC, reviewCount DESC`;\n \n // Get total count\n const countQuery = query.replace('SELECT *', 'SELECT COUNT(*) as total');\n const countResult = await sqlite.execute(countQuery, params);\n const total = countResult[0].total;\n \n // Add pagination\n query += ` LIMIT ? OFFSET ?`;\n params.push(limit, (page - 1) * limit);\n \n const result = await sqlite.execute(query, params);\n const vendors = result.map(vendor => ({\n ...vendor,\n specialties: parseJsonField(vendor.specialties)\n })) as Vendor[];\n \n return {\n items: vendors,\n total,\n page,\n limit,\n hasMore: page * limit < total\n };\n}\n\n// PRODUCT QUERIES\nexport async function createProduct(product: Omit): Promise {\n const result = await sqlite.execute(`\n INSERT INTO ${TABLES.PRODUCTS} (\n vendorId, vendorName, name, brand, description, category, price, originalPrice, size, concentration,\n topNotes, middleNotes, baseNotes, occasions, seasons, gender, imageUrl, images, inStock, stockQuantity, isFeatured\n ) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)\n `, [\n product.vendorId, product.vendorName, product.name, product.brand, product.description,\n product.category, product.price, product.originalPrice || null, product.size, product.concentration,\n JSON.stringify(product.topNotes), JSON.stringify(product.middleNotes), JSON.stringify(product.baseNotes),\n JSON.stringify(product.occasions), JSON.stringify(product.seasons), product.gender,\n product.imageUrl || null, JSON.stringify(product.images || []), product.inStock ? 1 : 0,\n product.stockQuantity || 0, product.isFeatured ? 1 : 0\n ]);\n \n // Update vendor product count\n await updateVendorProductCount(product.vendorId);\n \n return getProductById(result.lastInsertRowid as number);\n}\n\nexport async function getProductById(id: number): Promise {\n const result = await sqlite.execute(`SELECT * FROM ${TABLES.PRODUCTS} WHERE id = ? AND isActive = 1`, [id]);\n if (result.length === 0) return null;\n \n const product = result[0];\n return {\n ...product,\n topNotes: parseJsonField(product.topNotes),\n middleNotes: parseJsonField(product.middleNotes),\n baseNotes: parseJsonField(product.baseNotes),\n occasions: parseJsonField(product.occasions),\n seasons: parseJsonField(product.seasons),\n images: parseJsonField(product.images),\n inStock: Boolean(product.inStock),\n isFeatured: Boolean(product.isFeatured)\n } as Product;\n}\n\nexport async function getProducts(filters: ProductFilters = {}, searchParams: SearchParams = {}, page = 1, limit = 12): Promise> {\n let query = `SELECT * FROM ${TABLES.PRODUCTS} WHERE isActive = 1`;\n const params: any[] = [];\n \n // Search query\n if (searchParams.query) {\n query += ` AND (name LIKE ? OR brand LIKE ? OR description LIKE ?)`;\n const searchTerm = `%${searchParams.query}%`;\n params.push(searchTerm, searchTerm, searchTerm);\n }\n \n // Filters\n if (filters.category) {\n query += ` AND category = ?`;\n params.push(filters.category);\n }\n \n if (filters.brand) {\n query += ` AND brand LIKE ?`;\n params.push(`%${filters.brand}%`);\n }\n \n if (filters.priceMin !== undefined) {\n query += ` AND price >= ?`;\n params.push(filters.priceMin);\n }\n \n if (filters.priceMax !== undefined) {\n query += ` AND price <= ?`;\n params.push(filters.priceMax);\n }\n \n if (filters.concentration) {\n query += ` AND concentration = ?`;\n params.push(filters.concentration);\n }\n \n if (filters.gender) {\n query += ` AND gender = ?`;\n params.push(filters.gender);\n }\n \n if (filters.inStock !== undefined) {\n query += ` AND inStock = ?`;\n params.push(filters.inStock ? 1 : 0);\n }\n \n if (filters.rating) {\n query += ` AND rating >= ?`;\n params.push(filters.rating);\n }\n \n if (filters.vendorId) {\n query += ` AND vendorId = ?`;\n params.push(filters.vendorId);\n }\n \n // Sorting\n const sortBy = searchParams.sortBy || 'newest';\n switch (sortBy) {\n case 'price_low':\n query += ` ORDER BY price ASC`;\n break;\n case 'price_high':\n query += ` ORDER BY price DESC`;\n break;\n case 'rating':\n query += ` ORDER BY rating DESC, reviewCount DESC`;\n break;\n case 'popularity':\n query += ` ORDER BY reviewCount DESC, rating DESC`;\n break;\n case 'name_asc':\n query += ` ORDER BY name ASC`;\n break;\n case 'name_desc':\n query += ` ORDER BY name DESC`;\n break;\n case 'oldest':\n query += ` ORDER BY createdAt ASC`;\n break;\n default: // newest\n query += ` ORDER BY isFeatured DESC, createdAt DESC`;\n }\n \n // Get total count\n const countQuery = query.replace('SELECT *', 'SELECT COUNT(*) as total').split(' ORDER BY')[0];\n const countResult = await sqlite.execute(countQuery, params);\n const total = countResult[0].total;\n \n // Add pagination\n query += ` LIMIT ? OFFSET ?`;\n params.push(limit, (page - 1) * limit);\n \n const result = await sqlite.execute(query, params);\n const products = result.map(product => ({\n ...product,\n topNotes: parseJsonField(product.topNotes),\n middleNotes: parseJsonField(product.middleNotes),\n baseNotes: parseJsonField(product.baseNotes),\n occasions: parseJsonField(product.occasions),\n seasons: parseJsonField(product.seasons),\n images: parseJsonField(product.images),\n inStock: Boolean(product.inStock),\n isFeatured: Boolean(product.isFeatured)\n })) as Product[];\n \n return {\n items: products,\n total,\n page,\n limit,\n hasMore: page * limit < total\n };\n}\n\nexport async function updateProduct(id: number, updates: Partial): Promise {\n const fields = [];\n const values = [];\n \n // Add updatable fields\n const updatableFields = [\n 'name', 'brand', 'description', 'category', 'price', 'originalPrice', 'size', 'concentration',\n 'gender', 'imageUrl', 'inStock', 'stockQuantity', 'isFeatured'\n ];\n \n updatableFields.forEach(field => {\n if (updates[field] !== undefined) {\n if (field === 'inStock' || field === 'isFeatured') {\n fields.push(`${field} = ?`);\n values.push(updates[field] ? 1 : 0);\n } else {\n fields.push(`${field} = ?`);\n values.push(updates[field]);\n }\n }\n });\n \n // Handle JSON fields\n const jsonFields = ['topNotes', 'middleNotes', 'baseNotes', 'occasions', 'seasons', 'images'];\n jsonFields.forEach(field => {\n if (updates[field] !== undefined) {\n fields.push(`${field} = ?`);\n values.push(JSON.stringify(updates[field]));\n }\n });\n \n if (fields.length === 0) return getProductById(id);\n \n fields.push('updatedAt = CURRENT_TIMESTAMP');\n values.push(id);\n \n await sqlite.execute(`UPDATE ${TABLES.PRODUCTS} SET ${fields.join(', ')} WHERE id = ?`, values);\n \n return getProductById(id);\n}\n\n// REVIEW QUERIES\nexport async function createReview(review: Omit): Promise {\n const result = await sqlite.execute(`\n INSERT INTO ${TABLES.REVIEWS} (\n productId, vendorId, userId, userName, userImage, rating, title, content, pros, cons,\n longevity, sillage, valueForMoney, wouldRecommend, verifiedPurchase\n ) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)\n `, [\n review.productId || null, review.vendorId || null, review.userId, review.userName, review.userImage || null,\n review.rating, review.title, review.content, JSON.stringify(review.pros || []), JSON.stringify(review.cons || []),\n review.longevity || null, review.sillage || null, review.valueForMoney || null,\n review.wouldRecommend ? 1 : 0, review.verifiedPurchase ? 1 : 0\n ]);\n \n // Update product or vendor rating\n if (review.productId) {\n await updateProductRating(review.productId);\n }\n if (review.vendorId) {\n await updateVendorRating(review.vendorId);\n }\n \n return getReviewById(result.lastInsertRowid as number);\n}\n\nexport async function getReviewById(id: number): Promise {\n const result = await sqlite.execute(`SELECT * FROM ${TABLES.REVIEWS} WHERE id = ? AND isActive = 1`, [id]);\n if (result.length === 0) return null;\n \n const review = result[0];\n return {\n ...review,\n pros: parseJsonField(review.pros),\n cons: parseJsonField(review.cons),\n wouldRecommend: Boolean(review.wouldRecommend),\n verifiedPurchase: Boolean(review.verifiedPurchase)\n } as Review;\n}\n\nexport async function getProductReviews(productId: number, page = 1, limit = 10): Promise> {\n const query = `SELECT * FROM ${TABLES.REVIEWS} WHERE productId = ? AND isActive = 1 ORDER BY createdAt DESC LIMIT ? OFFSET ?`;\n const countQuery = `SELECT COUNT(*) as total FROM ${TABLES.REVIEWS} WHERE productId = ? AND isActive = 1`;\n \n const [result, countResult] = await Promise.all([\n sqlite.execute(query, [productId, limit, (page - 1) * limit]),\n sqlite.execute(countQuery, [productId])\n ]);\n \n const reviews = result.map(review => ({\n ...review,\n pros: parseJsonField(review.pros),\n cons: parseJsonField(review.cons),\n wouldRecommend: Boolean(review.wouldRecommend),\n verifiedPurchase: Boolean(review.verifiedPurchase)\n })) as Review[];\n \n const total = countResult[0].total;\n \n return {\n items: reviews,\n total,\n page,\n limit,\n hasMore: page * limit < total\n };\n}\n\n// WISHLIST QUERIES\nexport async function addToWishlist(userId: number, productId: number): Promise {\n const result = await sqlite.execute(`\n INSERT OR IGNORE INTO ${TABLES.WISHLISTS} (userId, productId) VALUES (?, ?)\n `, [userId, productId]);\n \n const wishlistResult = await sqlite.execute(`\n SELECT * FROM ${TABLES.WISHLISTS} WHERE userId = ? AND productId = ?\n `, [userId, productId]);\n \n return wishlistResult[0] as Wishlist;\n}\n\nexport async function removeFromWishlist(userId: number, productId: number): Promise {\n const result = await sqlite.execute(`\n DELETE FROM ${TABLES.WISHLISTS} WHERE userId = ? AND productId = ?\n `, [userId, productId]);\n \n return result.changes > 0;\n}\n\nexport async function getUserWishlist(userId: number): Promise {\n const result = await sqlite.execute(`\n SELECT p.* FROM ${TABLES.PRODUCTS} p\n JOIN ${TABLES.WISHLISTS} w ON p.id = w.productId\n WHERE w.userId = ? AND p.isActive = 1\n ORDER BY w.addedAt DESC\n `, [userId]);\n \n return result.map(product => ({\n ...product,\n topNotes: parseJsonField(product.topNotes),\n middleNotes: parseJsonField(product.middleNotes),\n baseNotes: parseJsonField(product.baseNotes),\n occasions: parseJsonField(product.occasions),\n seasons: parseJsonField(product.seasons),\n images: parseJsonField(product.images),\n inStock: Boolean(product.inStock),\n isFeatured: Boolean(product.isFeatured)\n })) as Product[];\n}\n\n// Helper functions\nasync function updateProductRating(productId: number): Promise {\n const result = await sqlite.execute(`\n SELECT AVG(rating) as avgRating, COUNT(*) as reviewCount \n FROM ${TABLES.REVIEWS} \n WHERE productId = ? AND isActive = 1\n `, [productId]);\n \n const { avgRating, reviewCount } = result[0];\n await sqlite.execute(`\n UPDATE ${TABLES.PRODUCTS} \n SET rating = ?, reviewCount = ? \n WHERE id = ?\n `, [avgRating || 0, reviewCount, productId]);\n}\n\nasync function updateVendorRating(vendorId: number): Promise {\n const result = await sqlite.execute(`\n SELECT AVG(rating) as avgRating, COUNT(*) as reviewCount \n FROM ${TABLES.REVIEWS} \n WHERE vendorId = ? AND isActive = 1\n `, [vendorId]);\n \n const { avgRating, reviewCount } = result[0];\n await sqlite.execute(`\n UPDATE ${TABLES.VENDORS} \n SET rating = ?, reviewCount = ? \n WHERE id = ?\n `, [avgRating || 0, reviewCount, vendorId]);\n}\n\nasync function updateVendorProductCount(vendorId: number): Promise {\n const result = await sqlite.execute(`\n SELECT COUNT(*) as productCount \n FROM ${TABLES.PRODUCTS} \n WHERE vendorId = ? AND isActive = 1\n `, [vendorId]);\n \n const { productCount } = result[0];\n await sqlite.execute(`\n UPDATE ${TABLES.VENDORS} \n SET productCount = ? \n WHERE id = ?\n `, [productCount, vendorId]);\n}","deleted","label",[169,170,150],"backend","database","permalink","https://www.val.town/x/Omosola_1/Create/code/backend/database/queries.ts","extension","actionData","errors"]