Merge pull request #723 from sparrowapp-dev/development

Release Version 2.28.1 [Merging development into prod]

Author: Astitva877

.env.example

@@ -95,6 +95,7 @@ ENCRYPTION_SECRET=                # Encryption key for LLM key's Encryption
 DEEPSEEK_ENDPOINT=                # Deepseek API endpoint
 DEEPSEEK_API_KEY=                 # Deepseek API authentication key
 DEEPSEEK_API_VERSION=             # Deepseek API version
+DEEPSEEK_API_MODEL=               # Deepseek Model
 
 # [HUBSPOT INTEGRATION]
 HUBSPOT_BASEURL=                  # HubSpot API base URL

deploymentManifests/deployment.yml

@@ -336,6 +336,11 @@ spec:
                 secretKeyRef:
                   name: sparrow-api-secret
                   key: DEEPSEEK_API_VERSION
+            - name: DEEPSEEK_API_MODEL
+              valueFrom:
+                secretKeyRef:
+                  name: sparrow-api-secret
+                  key: DEEPSEEK_API_MODEL      
             - name: DB_NAME
               valueFrom:
                 secretKeyRef:

deploymentManifests/release-v2.yml

@@ -305,6 +305,11 @@ spec:
                 secretKeyRef:
                   name: release-api-v2-secret
                   key: DEEPSEEK_API_VERSION
+            - name: DEEPSEEK_API_MODEL
+              valueFrom:
+                secretKeyRef:
+                  name: release-api-v2-secret
+                  key: DEEPSEEK_API_MODEL      
             - name: DB_NAME
               valueFrom:
                 secretKeyRef:

migrations/create-superadmin.migration.ts

@@ -0,0 +1,42 @@
+import { Injectable, OnModuleInit, Inject } from "@nestjs/common";
+import { Collections } from "@src/modules/common/enum/database.collection.enum";
+import { Db } from "mongodb";
+
+@Injectable()
+export class CreateSuperadminMigration implements OnModuleInit {
+  private hasRun = false;
+  constructor(
+    @Inject("DATABASE_CONNECTION") private readonly db: Db, // Inject the MongoDB connection
+  ) {}
+
+  async onModuleInit(): Promise<void> {
+    try {
+      if (this.hasRun) {
+        // Check if migration has already run
+        return;
+      }
+
+      const superadminsCollection = this.db.collection(Collections.SUPERADMINS);
+
+      // Check if super admin already exists
+      const existingSuperAdmin = await superadminsCollection.findOne({
+        emails: { $in: ["[email protected]"] },
+      });
+
+      if (!existingSuperAdmin) {
+        const superAdmin = {
+          emails: ["[email protected]"],
+        };
+
+        await superadminsCollection.insertOne(superAdmin);
+        console.log("\x1b[36mSuper admin created successfully.\x1b[0m");
+      } else {
+        console.log("\x1b[33mSuper admin already exists. Skipping.\x1b[0m");
+      }
+
+      this.hasRun = true; // Set flag after successful execution
+    } catch (error) {
+      console.error("Error during super admin migration:", error);
+    }
+  }
+}

migrations/migrate-promocode-provider.migration.ts

@@ -0,0 +1,157 @@
+import { Db, MongoClient } from "mongodb";
+import { Collections } from "@src/modules/common/enum/database.collection.enum";
+
+/**
+ * Migration to convert stripePromoCodeId to promoCodeProvider array structure
+ * This migration updates existing promo codes from the old structure:
+ * { stripePromoCodeId: "promo_123" }
+ * 
+ * To the new structure:
+ * { promoCodeProvider: [{ id: "promo_123", provider: "stripe" }] }
+ */
+export class MigratePromoCodeProviderMigration {
+  constructor(private readonly db: Db) {}
+
+  async up(): Promise<void> {
+    console.log("Starting promo code provider migration...");
+
+    const collection = this.db.collection(Collections.PROMOCODES);
+
+    // Find all documents with the old stripePromoCodeId field
+    const promoCodes = await collection
+      .find({ stripePromoCodeId: { $exists: true } })
+      .toArray();
+
+    console.log(`Found ${promoCodes.length} promo codes to migrate`);
+
+    if (promoCodes.length === 0) {
+      console.log("No promo codes found with old structure. Migration complete.");
+      return;
+    }
+
+    // Process each promo code
+    for (const promoCode of promoCodes) {
+      try {
+        // Create the new promoCodeProvider array
+        const promoCodeProvider = [
+          {
+            id: promoCode.stripePromoCodeId,
+            provider: "stripe"
+          }
+        ];
+
+        // Update the document
+        await collection.updateOne(
+          { _id: promoCode._id },
+          {
+            $set: { promoCodeProvider },
+            $unset: { stripePromoCodeId: "" }
+          }
+        );
+
+        console.log(`Migrated promo code: ${promoCode.code} (${promoCode._id})`);
+      } catch (error) {
+        console.error(`Failed to migrate promo code ${promoCode.code}:`, error);
+        throw error;
+      }
+    }
+
+    console.log(`Successfully migrated ${promoCodes.length} promo codes`);
+  }
+
+  async down(): Promise<void> {
+    console.log("Rolling back promo code provider migration...");
+
+    const collection = this.db.collection(Collections.PROMOCODES);
+
+    // Find all documents with the new promoCodeProvider field
+    const promoCodes = await collection
+      .find({ promoCodeProvider: { $exists: true } })
+      .toArray();
+
+    console.log(`Found ${promoCodes.length} promo codes to rollback`);
+
+    if (promoCodes.length === 0) {
+      console.log("No promo codes found with new structure. Rollback complete.");
+      return;
+    }
+
+    // Process each promo code
+    for (const promoCode of promoCodes) {
+      try {
+        // Find the stripe provider entry
+        const stripeProvider = promoCode.promoCodeProvider?.find(
+          (provider: any) => provider.provider === "stripe"
+        );
+
+        if (stripeProvider) {
+          // Restore the old stripePromoCodeId field
+          await collection.updateOne(
+            { _id: promoCode._id },
+            {
+              $set: { stripePromoCodeId: stripeProvider.id },
+              $unset: { promoCodeProvider: "" }
+            }
+          );
+
+          console.log(`Rolled back promo code: ${promoCode.code} (${promoCode._id})`);
+        } else {
+          console.log(`No stripe provider found for promo code: ${promoCode.code}`);
+        }
+      } catch (error) {
+        console.error(`Failed to rollback promo code ${promoCode.code}:`, error);
+        throw error;
+      }
+    }
+
+    console.log(`Successfully rolled back ${promoCodes.length} promo codes`);
+  }
+}
+
+// Migration runner function
+export async function runPromoCodeProviderMigration(
+  mongoUrl: string,
+  dbName: string,
+  direction: "up" | "down" = "up"
+): Promise<void> {
+  const client = new MongoClient(mongoUrl);
+
+  try {
+    await client.connect();
+    console.log("Connected to MongoDB");
+
+    const db = client.db(dbName);
+    const migration = new MigratePromoCodeProviderMigration(db);
+
+    if (direction === "up") {
+      await migration.up();
+    } else {
+      await migration.down();
+    }
+
+    console.log("Migration completed successfully");
+  } catch (error) {
+    console.error("Migration failed:", error);
+    throw error;
+  } finally {
+    await client.close();
+    console.log("Disconnected from MongoDB");
+  }
+}
+
+// If this file is run directly
+if (require.main === module) {
+  const mongoUrl = process.env.MONGODB_URI || "mongodb://localhost:27017";
+  const dbName = process.env.DATABASE_NAME || "sparrow";
+  const direction = (process.argv[2] as "up" | "down") || "up";
+
+  runPromoCodeProviderMigration(mongoUrl, dbName, direction)
+    .then(() => {
+      console.log("Migration script completed");
+      process.exit(0);
+    })
+    .catch((error) => {
+      console.error("Migration script failed:", error);
+      process.exit(1);
+    });
+}

package.json

@@ -32,7 +32,9 @@
     "start:create-plan": "ts-node -r tsconfig-paths/register src/create-plan.ts",
     "start:upgrade-plan": "ts-node -r tsconfig-paths/register src/upgrade-plan.ts",
     "start:migration-mock-url": "ts-node -r tsconfig-paths/register src/migrationMockRequestUrl.ts",
-    "start:migration-hub-billing": "ts-node -r tsconfig-paths/register src/migrationHubBilling.ts"
+    "start:migration-hub-billing": "ts-node -r tsconfig-paths/register src/migrationHubBilling.ts",
+    "start:migration-superadmin": "ts-node -r tsconfig-paths/register src/migration-superadmin.ts",
+    "start:migration-promocode-provider": "ts-node -r tsconfig-paths/register src/migration-promocode-provider.ts"
   },
   "dependencies": {
     "@anthropic-ai/sdk": "^0.54.0",
@@ -145,6 +147,6 @@
   },
   "packageManager": "[email protected]",
   "optionalDependencies": {
-    "@sparrowapp-dev/stripe-billing": "^1.2.2"
+    "@sparrowapp-dev/stripe-billing": "^1.2.7"
   }
 }