+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ ++ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| seed.js | +
+
+ |
+ 95.83% | +23/24 | +75% | +3/4 | +100% | +1/1 | +95.83% | +23/24 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 +35 +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 +64 | 1x + + +2x +2x + + +2x + + + + + + + +2x +6x +5x +4x +4x + + + + +1x + + + + +1x +2x +2x + + + +1x + + + + + + + + + +1x +1x +1x + + +1x +1x + +1x +1x + + + +1x + +1x + + + | const { db, schema } = require('../src/db');
+
+async function seed() {
+ try {
+ console.log('--- Starting Seed Script ---');
+
+ // 1. Seed Categories
+ const categories = [
+ { name: 'Politics', slug: 'politics', description: 'World events, elections, and policy changes.' },
+ { name: 'Crypto', slug: 'crypto', description: 'Cryptocurrency prices and blockchain news.' },
+ { name: 'Sports', slug: 'sports', description: 'Major league results and athlete performance.' },
+ { name: 'Weather', slug: 'weather', description: 'Global temperature changes and natural phenomena.' },
+ { name: 'Science', slug: 'science', description: 'New discoveries and cosmic events.' },
+ ];
+
+ for (const cat of categories) {
+ const [existing] = await db.select().from(schema.categories).where(cat.slug);
+ if (!existing) {
+ await db.insert(schema.categories).values(cat);
+ console.log(`Added category: ${cat.name}`);
+ }
+ }
+
+ // 2. Seed User Profiles
+ const users = [
+ { walletAddress: 'GDX6X...123', username: 'StellarKing', bio: 'Early adopter and prediction market enthusiast.' },
+ { walletAddress: 'GC7H6...456', username: 'PolyWiz', bio: 'Expert in statistical modelling.' },
+ ];
+
+ for (const user of users) {
+ await db.insert(schema.userProfiles).values(user).onConflictDoNothing();
+ console.log(`Ensured user profile for: ${user.username}`);
+ }
+
+ // 3. Seed initial Markets
+ const markets = [
+ {
+ contractId: 'CAC...789',
+ title: 'Will Bitcoin cross $100k in 2026?',
+ description: 'Historical odds on BTC price hitting a massive milestone.',
+ status: 'ACTIVE',
+ categoryId: 1,
+ },
+ ];
+
+ for (const market of markets) {
+ await db.insert(schema.markets).values(market).onConflictDoNothing();
+ console.log(`Ensured initial market: ${market.title}`);
+ }
+
+ console.log('--- Seed Script Finished ---');
+ process.exit(0);
+ } catch (err) {
+ console.error('Error seeding DB:', err);
+ process.exit(1);
+ }
+}
+
+module.exports = { seed };
+
+Iif (require.main === module) {
+ seed();
+}
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 +35 +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 | 1x + + +2x + + +2x + + + + + + + +2x +6x +5x +4x +4x + + + + +1x + + + + +1x + +2x +2x + + + +1x + + + + + + + + + +1x +1x +1x + + +1x +1x + + +1x + +1x + + + + + + | const { db, schema } = require('../src/db');
+
+async function seed() {
+ console.log('--- Starting Seed Script ---');
+
+ // 1. Seed Categories
+ const categories = [
+ { name: 'Politics', slug: 'politics', description: 'World events, elections, and policy changes.' },
+ { name: 'Crypto', slug: 'crypto', description: 'Cryptocurrency prices and blockchain news.' },
+ { name: 'Sports', slug: 'sports', description: 'Major league results and athlete performance.' },
+ { name: 'Weather', slug: 'weather', description: 'Global temperature changes and natural phenomena.' },
+ { name: 'Science', slug: 'science', description: 'New discoveries and cosmic events.' },
+ ];
+
+ for (const cat of categories) {
+ const [existing] = await db.select().from(schema.categories).where(cat.slug);
+ if (!existing) {
+ await db.insert(schema.categories).values(cat);
+ console.log(`Added category: ${cat.name}`);
+ }
+ }
+
+ // 2. Seed User Profiles
+ const users = [
+ { walletAddress: 'GDX6X...123', username: 'StellarKing', bio: 'Early adopter and prediction market enthusiast.' },
+ { walletAddress: 'GC7H6...456', username: 'PolyWiz', bio: 'Expert in statistical modelling.' },
+ ];
+
+ for (const user of users) {
+ // Only insert if doesn't exist (basic logic for seeding)
+ await db.insert(schema.userProfiles).values(user).onConflictDoNothing();
+ console.log(`Ensured user profile for: ${user.username}`);
+ }
+
+ // 3. Seed initial Markets
+ const markets = [
+ {
+ contractId: 'CAC...789',
+ title: 'Will Bitcoin cross $100k in 2026?',
+ description: 'Historical odds on BTC price hitting a massive milestone.',
+ status: 'ACTIVE',
+ categoryId: 1, // Reference ID (might need a map if IDs aren't sequential)
+ },
+ ];
+
+ for (const market of markets) {
+ await db.insert(schema.markets).values(market).onConflictDoNothing();
+ console.log(`Ensured initial market: ${market.title}`);
+ }
+
+ console.log('--- Seed Script Finished ---');
+ process.exit(0);
+}
+
+module.exports = { seed };
+
+Iif (require.main === module) {
+ seed().catch((err) => {
+ console.error('Error seeding DB:', err);
+ process.exit(1);
+ });
+}
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| utils.js | +
+
+ |
+ 100% | +21/21 | +100% | +4/4 | +100% | +6/6 | +100% | +20/20 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 +35 +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 +64 +65 +66 +67 +68 +69 +70 +71 +72 +73 +74 +75 +76 +77 +78 +79 +80 +81 +82 +83 +84 | 1x +1x + + + + + + +2x + + + +2x + +1x + + + +1x + + + + + + +1x + + + +1x + + + + + + +1x + + + +1x + + +1x + + + + + + +1x + + +1x + + + +2x + + + +2x +1x + + + +1x + + +1x + + +1x + + +1x + + + + + + + + | const { db, schema } = require('../db');
+const { eq } = require('drizzle-orm');
+
+/**
+ * Fetch or Create User Profile
+ * @param {string} walletAddress
+ */
+async function getOrCreateUserProfile(walletAddress) {
+ const [profile] = await db.select()
+ .from(schema.userProfiles)
+ .where(eq(schema.userProfiles.walletAddress, walletAddress));
+
+ if (profile) return profile;
+
+ const [newProfile] = await db.insert(schema.userProfiles)
+ .values({ walletAddress })
+ .returning();
+
+ return newProfile;
+}
+
+/**
+ * Update user bio/avatar
+ */
+async function updateUserProfile(walletAddress, data) {
+ const [updated] = await db.update(schema.userProfiles)
+ .set({ ...data, updatedAt: new Date() })
+ .where(eq(schema.userProfiles.walletAddress, walletAddress))
+ .returning();
+ return updated;
+}
+
+/**
+ * Categories management
+ */
+async function getAllCategories() {
+ return db.select().from(schema.categories).where(eq(schema.categories.isActive, true));
+}
+
+async function addCategory(name, description, slug, imageUrl) {
+ const [cat] = await db.insert(schema.categories)
+ .values({ name, description, slug, imageUrl })
+ .returning();
+ return cat;
+}
+
+/**
+ * Market metadata management
+ */
+async function getMarketByContractId(contractId) {
+ const [market] = await db.select()
+ .from(schema.markets)
+ .where(eq(schema.markets.contractId, contractId));
+ return market;
+}
+
+async function upsertMarketMetadata(contractId, metadata) {
+ const [existing] = await db.select()
+ .from(schema.markets)
+ .where(eq(schema.markets.contractId, contractId));
+
+ if (existing) {
+ const [updated] = await db.update(schema.markets)
+ .set({ ...metadata, updatedAt: new Date() })
+ .where(eq(schema.markets.contractId, contractId))
+ .returning();
+ return updated;
+ }
+
+ const [newMarket] = await db.insert(schema.markets)
+ .values({ contractId, ...metadata })
+ .returning();
+ return newMarket;
+}
+
+module.exports = {
+ getOrCreateUserProfile,
+ updateUserProfile,
+ getAllCategories,
+ addCategory,
+ getMarketByContractId,
+ upsertMarketMetadata,
+};
+ |