Added subscription identifier in user schema.

Author: shrihari-prakash

src/model/mongo/user.ts

@@ -470,6 +470,17 @@ export const userSchema = {
       write: SensitivityLevel.MEDIUM,
     },
   },
+  subscriptionIdentifier: {
+    type: mongoose.Schema.Types.Mixed,
+    required: false,
+    willProjectForUserSelect: true,
+    willProjectForUserAdminSelect: true,
+    willProjectForUserClientSelect: true,
+    sensitivityScore: {
+      read: SensitivityLevel.MEDIUM,
+      write: SensitivityLevel.MEDIUM,
+    },
+  },
   credits: {
     type: Number,
     required: true,
@@ -752,6 +763,7 @@ export type UserInterface = {
   subscriptionActivatedAt: Date;
   subscriptionExpiry: Date;
   subscriptionTier: string;
+  subscriptionIdentifier?: string | number;
   credits: number;
   scope: string[];
   invitedBy: string | ObjectId;
@@ -820,3 +832,4 @@ const schemaInstance = new mongoose.Schema(userSchema, {
   UserModel = mongoose.model("user", schemaInstance);
 
 export default UserModel;
+

src/service/api/user/shared/subscription.post.ts

@@ -19,6 +19,7 @@ export const POST_SubscriptionValidator = [
   body("state").exists().isBoolean(),
   body("expiry").optional().isISO8601(),
   body("tier").optional().isString().isLength({ max: 128 }),
+  body("subscriptionIdentifier").optional().custom((value) => typeof value === "string" || typeof value === "number"),
 ];
 
 const POST_Subscription = async (req: Request, res: Response): Promise<void> => {
@@ -31,6 +32,7 @@ const POST_Subscription = async (req: Request, res: Response): Promise<void> =>
     const state = req.body.state;
     const tier = req.body.tier;
     const expiry = req.body.expiry;
+    const subscriptionIdentifier = req.body.subscriptionIdentifier;
     if (state === true && !expiry) {
       const errors = [
         {
@@ -53,14 +55,17 @@ const POST_Subscription = async (req: Request, res: Response): Promise<void> =>
       res.status(statusCodes.clientInputError).json(new ErrorResponse(errorMessages.clientInputError, { errors }));
       return;
     }
-    const query = {
+    const query: any = {
       $set: {
         isSubscribed: state,
         subscriptionActivatedAt: moment().toDate(),
         subscriptionExpiry: moment(expiry).toDate(),
         subscriptionTier: tier || null,
       },
     };
+    if (typeof subscriptionIdentifier !== 'undefined') {
+      query.$set.subscriptionIdentifier = subscriptionIdentifier;
+    }
     await UserModel.updateOne({ _id: target }, query);
     res.status(statusCodes.success).json(new SuccessResponse());
     flushUserInfoFromRedis(target);