DB migrations; UI enhancements;

Author: Rajat Saxena

…env-npm-14.2.4-9859535528-ff47297f95.zip …nv-npm-14.2.25-22db491964-c937d4e8b6.zip.yarn/cache/@next-env-npm-14.2.4-9859535528-ff47297f95.zip renamed to .yarn/cache/@next-env-npm-14.2.25-22db491964-c937d4e8b6.zip .yarn/cache/@next-env-npm-14.2.4-9859535528-ff47297f95.zip renamed to .yarn/cache/@next-env-npm-14.2.25-22db491964-c937d4e8b6.zip

@@ -1,8 +1,10 @@
-import { InternalUser } from "@courselit/common-logic";
 import CourseModel, { Course } from "./model/course";
 import UserModel from "./model/user";
 import mailQueue from "./queue";
 import { Liquid } from "liquidjs";
+import { getMemberships } from "./queries";
+import { Constants } from "@courselit/common-models";
+import { InternalUser } from "@courselit/common-logic";
 const liquidEngine = new Liquid();
 
 export async function processDrip() {
@@ -32,9 +34,17 @@ export async function processDrip() {
                 )
                 .map((group) => group.id);
 
+            const memberships = await getMemberships(
+                course.courseId,
+                Constants.MembershipEntityType.COURSE,
+            );
             const users: InternalUser[] = await UserModel.find({
-                "purchases.courseId": course.courseId,
+                domain: course.domain,
+                userId: { $in: memberships.map((m) => m.userId) },
             });
+            // const users: InternalUser[] = await UserModel.find({
+            //     "purchases.courseId": course.courseId,
+            // });
 
             for (const user of users) {
                 const userProgressInCourse = user.purchases.find(

…darwin-arm64-npm-14.2.4-86d534c3ee-8.zip …arwin-arm64-npm-14.2.25-3d28e40873-8.zip.yarn/cache/@next-swc-darwin-arm64-npm-14.2.4-86d534c3ee-8.zip renamed to .yarn/cache/@next-swc-darwin-arm64-npm-14.2.25-3d28e40873-8.zip .yarn/cache/@next-swc-darwin-arm64-npm-14.2.4-86d534c3ee-8.zip renamed to .yarn/cache/@next-swc-darwin-arm64-npm-14.2.25-3d28e40873-8.zip

@@ -3,13 +3,18 @@ import OngoingSequenceModel, {
     OngoingSequence,
 } from "./model/ongoing-sequence";
 import SequenceModel from "./model/sequence";
+import MembershipModel from "./model/membership";
 import UserModel from "./model/user";
 import RuleModel from "./model/rule";
 import mongoose from "mongoose";
 import DomainModel from "./model/domain";
 import { Constants, EmailTemplate } from "@courselit/common-models";
 import emailTemplate from "./model/email-template";
-import { AdminSequence, InternalUser } from "@courselit/common-logic";
+import {
+    AdminSequence,
+    InternalMembership,
+    InternalUser,
+} from "@courselit/common-logic";
 
 export async function getDueOngoingSequences(): Promise<OngoingSequence[]> {
     const currentTime = new Date().getTime();
@@ -61,3 +66,11 @@ export async function getDomain(id: mongoose.Schema.Types.ObjectId) {
 export async function getTemplate(id: string): Promise<EmailTemplate | null> {
     return (await emailTemplate.find({ templateId: id }).lean()) as any;
 }
+
+export async function getMemberships(entityId: string, entityType: string) {
+    return await MembershipModel.find<InternalMembership>({
+        entityId,
+        entityType,
+        status: Constants.MembershipStatus.ACTIVE,
+    });
+}

.yarn/cache/@next-swc-linux-x64-gnu-npm-14.2.4-80ebbf3a12-8.zip

@@ -84,6 +84,22 @@ const setupFreePayment = async () => {
             domain: domain._id,
             permissions: { $elemMatch: { $eq: "site:manage" } },
         });
+        if (!creator) {
+            console.log("No creator found for domain", domain.name);
+            const users = await User.find({
+                domain: domain._id,
+            });
+            console.log(`Other users for ${domain.name}:`, users);
+            continue;
+        }
+        const existingPaymentPlan = await PaymentPlan.findOne({
+            domain: domain._id,
+            internal: true,
+        });
+        if (existingPaymentPlan) {
+            console.log("Payment plan already exists for domain", domain.name);
+            continue;
+        }
         const paymentPlan = await PaymentPlan.create({
             domain: domain._id,
             name: "Internal Payment Plan",

…ext-npm-14.2.4-37fb4e5b51-3b858cfec2.zip …xt-npm-14.2.25-cd023f1b24-ca47d0f1d4.zip.yarn/cache/next-npm-14.2.4-37fb4e5b51-3b858cfec2.zip renamed to .yarn/cache/next-npm-14.2.25-cd023f1b24-ca47d0f1d4.zip .yarn/cache/next-npm-14.2.4-37fb4e5b51-3b858cfec2.zip renamed to .yarn/cache/next-npm-14.2.25-cd023f1b24-ca47d0f1d4.zip

@@ -0,0 +1,80 @@
+import mongoose from "mongoose";
+
+mongoose.connect(process.env.DB_CONNECTION_STRING, {
+    useNewUrlParser: true,
+    useUnifiedTopology: true,
+});
+
+const DomainSchema = new mongoose.Schema({
+    name: { type: String, required: true, unique: true },
+    sharedWidgets: {
+        type: mongoose.Schema.Types.Mixed,
+        default: {},
+    },
+});
+
+const Domain = mongoose.model("Domain", DomainSchema);
+
+const updateLinks = async () => {
+    const domains = await Domain.find({});
+    let updatedCount = 0;
+
+    for (const domain of domains) {
+        let needsUpdate = false;
+        const sharedWidgets = domain.sharedWidgets || {};
+
+        // Update header widget links
+        if (sharedWidgets.header?.settings?.links) {
+            sharedWidgets.header.settings.links =
+                sharedWidgets.header.settings.links.map((link) => {
+                    if (link.href === "/courses") {
+                        needsUpdate = true;
+                        return {
+                            ...link,
+                            href: "/products",
+                            label: "Products",
+                        };
+                    }
+                    return link;
+                });
+        }
+
+        // Update any other widgets that might have /courses links
+        for (const widgetKey in sharedWidgets) {
+            const widget = sharedWidgets[widgetKey];
+            if (widget?.settings?.links) {
+                widget.settings.links = widget.settings.links.map((link) => {
+                    if (link.href === "/courses") {
+                        needsUpdate = true;
+                        return {
+                            ...link,
+                            href: "/products",
+                            label: "Products",
+                        };
+                    }
+                    return link;
+                });
+            }
+        }
+
+        if (needsUpdate) {
+            domain.markModified("sharedWidgets");
+            await domain.save();
+            updatedCount++;
+            console.log(`Updated links for domain: ${domain.name}`);
+        }
+    }
+
+    console.log(`Migration completed. Updated ${updatedCount} domains.`);
+};
+
+(async () => {
+    try {
+        await updateLinks();
+        console.log("Migration completed successfully");
+    } catch (error) {
+        console.error("Migration failed:", error);
+    } finally {
+        mongoose.connection.close();
+    }
+})();