Add Cockroach schema backfill

src/db.js

@@ -42,6 +42,26 @@ export class BetStore {
         updated_at TIMESTAMPTZ NOT NULL DEFAULT NOW()
       );
     `);
+    await this.pool.query(`
+      ALTER TABLE users
+      ADD COLUMN IF NOT EXISTS username TEXT NOT NULL DEFAULT '';
+    `);
+    await this.pool.query(`
+      ALTER TABLE users
+      ADD COLUMN IF NOT EXISTS display_name TEXT NOT NULL DEFAULT '';
+    `);
+    await this.pool.query(`
+      ALTER TABLE users
+      ADD COLUMN IF NOT EXISTS next_bet_number INT NOT NULL DEFAULT 1;
+    `);
+    await this.pool.query(`
+      ALTER TABLE users
+      ADD COLUMN IF NOT EXISTS created_at TIMESTAMPTZ NOT NULL DEFAULT NOW();
+    `);
+    await this.pool.query(`
+      ALTER TABLE users
+      ADD COLUMN IF NOT EXISTS updated_at TIMESTAMPTZ NOT NULL DEFAULT NOW();
+    `);
 
     await this.pool.query(`
       CREATE TABLE IF NOT EXISTS bets (
@@ -61,6 +81,58 @@ export class BetStore {
         CONSTRAINT bets_user_bet_number_unique UNIQUE (discord_user_id, bet_number)
       );
     `);
+    await this.pool.query(`
+      ALTER TABLE bets
+      ADD COLUMN IF NOT EXISTS discord_user_id TEXT;
+    `);
+    await this.pool.query(`
+      ALTER TABLE bets
+      ADD COLUMN IF NOT EXISTS bet_number INT;
+    `);
+    await this.pool.query(`
+      ALTER TABLE bets
+      ADD COLUMN IF NOT EXISTS book TEXT;
+    `);
+    await this.pool.query(`
+      ALTER TABLE bets
+      ADD COLUMN IF NOT EXISTS odds_input TEXT;
+    `);
+    await this.pool.query(`
+      ALTER TABLE bets
+      ADD COLUMN IF NOT EXISTS normalized_decimal_odds DOUBLE PRECISION;
+    `);
+    await this.pool.query(`
+      ALTER TABLE bets
+      ADD COLUMN IF NOT EXISTS prop TEXT;
+    `);
+    await this.pool.query(`
+      ALTER TABLE bets
+      ADD COLUMN IF NOT EXISTS stake DOUBLE PRECISION;
+    `);
+    await this.pool.query(`
+      ALTER TABLE bets
+      ADD COLUMN IF NOT EXISTS status TEXT NOT NULL DEFAULT 'open';
+    `);
+    await this.pool.query(`
+      ALTER TABLE bets
+      ADD COLUMN IF NOT EXISTS profit_loss DOUBLE PRECISION;
+    `);
+    await this.pool.query(`
+      ALTER TABLE bets
+      ADD COLUMN IF NOT EXISTS raw_input TEXT;
+    `);
+    await this.pool.query(`
+      ALTER TABLE bets
+      ADD COLUMN IF NOT EXISTS created_at TIMESTAMPTZ NOT NULL DEFAULT NOW();
+    `);
+    await this.pool.query(`
+      ALTER TABLE bets
+      ADD COLUMN IF NOT EXISTS resolved_at TIMESTAMPTZ;
+    `);
+    await this.pool.query(`
+      CREATE UNIQUE INDEX IF NOT EXISTS bets_user_bet_number_unique
+      ON bets (discord_user_id, bet_number);
+    `);
   }
 
   async createBet(user, bet) {

src/index.js

@@ -4,6 +4,7 @@ import {
   Client,
   Events,
   GatewayIntentBits,
+  MessageFlags,
   ModalBuilder,
   TextInputBuilder,
   TextInputStyle,
@@ -75,13 +76,13 @@ async function main() {
       console.error(error);
       const payload = {
         embeds: [
-          buildErrorEmbed(
-            'Something went wrong',
-            'The bot hit an unexpected error while handling that request.'
-          ),
-        ],
-        ephemeral: true,
-      };
+        buildErrorEmbed(
+          'Something went wrong',
+          'The bot hit an unexpected error while handling that request.'
+        ),
+      ],
+      flags: MessageFlags.Ephemeral,
+    };
 
       if (interaction.replied || interaction.deferred) {
         await interaction.followUp(payload).catch(() => null);
@@ -201,7 +202,7 @@ async function handleBetModal(interaction, store) {
           `I still need valid values for: **${parsed.missingFields.join(', ')}**.\n\nAccepted odds: \`-110\`, \`+150\`, or decimal like \`1.91\`.\nAccepted stake examples: \`25\` or \`$25\`.`
         ),
       ],
-      ephemeral: true,
+      flags: MessageFlags.Ephemeral,
     });
     return;
   }
@@ -210,7 +211,7 @@ async function handleBetModal(interaction, store) {
     const savedBet = await store.createBet(interaction.user, parsed.bet);
     await interaction.reply({
       embeds: [buildBetSavedEmbed(savedBet)],
-      ephemeral: true,
+      flags: MessageFlags.Ephemeral,
     });
   } catch (error) {
     console.error('Failed to create bet', {
@@ -227,7 +228,7 @@ async function handleBetModal(interaction, store) {
           'The bet looked valid, but the database rejected it. Check the Space logs for the detailed error and try again.'
         ),
       ],
-      ephemeral: true,
+      flags: MessageFlags.Ephemeral,
     });
   }
 }
@@ -240,7 +241,7 @@ async function handleResolve(interaction, store) {
   if (resolution.type === 'missing') {
     await interaction.reply({
       embeds: [buildErrorEmbed('Bet not found', `I could not find your bet #${betId}.`)],
-      ephemeral: true,
+      flags: MessageFlags.Ephemeral,
     });
     return;
   }
@@ -253,14 +254,14 @@ async function handleResolve(interaction, store) {
           `Bet #${betId} is already marked as **${resolution.bet.status}**.`
         ),
       ],
-      ephemeral: true,
+      flags: MessageFlags.Ephemeral,
     });
     return;
   }
 
   await interaction.reply({
     embeds: [buildResolveEmbed(resolution.bet)],
-    ephemeral: true,
+    flags: MessageFlags.Ephemeral,
   });
 }
 
@@ -275,7 +276,7 @@ async function handleRoi(interaction, store) {
   await interaction.reply({
     embeds: [embed],
     files: [chart],
-    ephemeral: true,
+    flags: MessageFlags.Ephemeral,
   });
 }
 
@@ -285,7 +286,7 @@ async function handleBets(interaction, store) {
 
   await interaction.reply({
     embeds: [buildBetsEmbed(summary, bets)],
-    ephemeral: true,
+    flags: MessageFlags.Ephemeral,
   });
 }
 
@@ -300,7 +301,7 @@ async function handleSummary(interaction, store) {
   await interaction.reply({
     embeds: [embed],
     files: [chart],
-    ephemeral: true,
+    flags: MessageFlags.Ephemeral,
   });
 }
 
@@ -313,7 +314,7 @@ async function handleWelcome(interaction, config) {
           'Only the configured welcome manager can use this command.'
         ),
       ],
-      ephemeral: true,
+      flags: MessageFlags.Ephemeral,
     });
     return;
   }