fix: Add customerId in user table

build/index.d.ts

@@ -21,4 +21,5 @@ import { ProjectService } from './projects/services/ProjectService';
 import { OrganizationService } from './organizations/services/OrganizationService';
 import { updateUserService } from './users/services/updateUserService';
 import { UserService } from './usersProject/UserService';
-export { createUserCollectionWithValidation, connectToDatabase, checkConnectionStatus, subscribeToDatabaseEvents, createEntityCollectionWithValidation, createProjectCollectionWithValidation, createOrganizationCollectionWithValidation, deleteUserService, getOneUserService, getUsersService, createUserService, updateUserService, getUserByEmail, UserService, OrganizationService, EntityService, ProjectService, UserModel, entityModel, organizationModel, IUsers, IUser, IEntityDb, IProjectDb, projectModel, IOrganizationDb, IMemberDb, };
+import { updateCustomerId } from './users/services/updateCustomerIdService';
+export { createUserCollectionWithValidation, connectToDatabase, checkConnectionStatus, subscribeToDatabaseEvents, createEntityCollectionWithValidation, createProjectCollectionWithValidation, createOrganizationCollectionWithValidation, deleteUserService, getOneUserService, getUsersService, createUserService, updateUserService, getUserByEmail, updateCustomerId, UserService, OrganizationService, EntityService, ProjectService, UserModel, entityModel, organizationModel, IUsers, IUser, IEntityDb, IProjectDb, projectModel, IOrganizationDb, IMemberDb, };

build/interfaces.d.ts

@@ -15,6 +15,11 @@ export interface IUsers {
     complement: string;
     quota: UserQuota;
     validatedMail: boolean;
+    paymentInfo: {
+        customerId: string;
+        plan: string;
+        expirationDate: Date;
+    };
     [key: string]: any;
 }
 export interface IEntityDb {

build/users/services/createUserService.js

@@ -43,6 +43,11 @@ function createUserService(user) {
                     imageUsedMB: 0,
                     pointCloudUsedMB: 0,
                 },
+                paymentInfo: {
+                    customerId: user.paymentInfo.customerId,
+                    plan: user.paymentInfo.plan,
+                    expirationDate: user.paymentInfo.expirationDate,
+                },
             });
             const savedUser = yield newUser.save();
             return savedUser;

build/users/services/updateCustomerIdService.d.ts

@@ -0,0 +1,2 @@
+import { IUsers } from '../../interfaces';
+export declare function updateCustomerId(email: string, updates: Partial<IUsers['paymentInfo']>): Promise<IUsers | null>;

build/users/services/updateCustomerIdService.js

@@ -0,0 +1,42 @@
+"use strict";
+var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
+    function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
+    return new (P || (P = Promise))(function (resolve, reject) {
+        function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
+        function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
+        function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); }
+        step((generator = generator.apply(thisArg, _arguments || [])).next());
+    });
+};
+Object.defineProperty(exports, "__esModule", { value: true });
+exports.updateCustomerId = void 0;
+const duna_web_platform_error_defs_1 = require("duna-web-platform-error-defs");
+const validationUserModel_1 = require("../validationUserModel");
+function updateCustomerId(email, updates) {
+    return __awaiter(this, void 0, void 0, function* () {
+        try {
+            const filter = { email };
+            const update = {
+                $set: {
+                    'paymentInfo.customerId': updates.customerId,
+                    'paymentInfo.plan': updates.plan,
+                    'paymentInfo.expirationDate': updates.expirationDate,
+                },
+            };
+            const options = { new: true };
+            const updatedUser = yield validationUserModel_1.UserModel.findOneAndUpdate(filter, update, options);
+            if (!updatedUser) {
+                const err = duna_web_platform_error_defs_1.ErrorMessages.UserNotFound.Message;
+                throw err;
+            }
+            return updatedUser;
+        }
+        catch (error) {
+            console.error('Error in updateCustomerId:', error);
+            const err = duna_web_platform_error_defs_1.ErrorMessages.InternalServerError;
+            err.Details = 'Error updating user data.';
+            throw err;
+        }
+    });
+}
+exports.updateCustomerId = updateCustomerId;

build/users/services/updateUserService.js

@@ -45,6 +45,15 @@ function updateUserService(userId, updates) {
                 existingUser.complement = updates.complement;
             if (updates.quota)
                 existingUser.quota = updates.quota;
+            if (updates.paymentInfo) {
+                if (updates.paymentInfo.plan) {
+                    existingUser.paymentInfo.plan = updates.paymentInfo.plan;
+                }
+                if (updates.paymentInfo.expirationDate) {
+                    existingUser.paymentInfo.expirationDate =
+                        updates.paymentInfo.expirationDate;
+                }
+            }
             yield existingUser.save();
             return existingUser;
         }

build/users/validationUserModel.js

@@ -27,6 +27,11 @@ const UserSchema = new mongoose_1.default.Schema({
         imageUsedMB: { type: Number, required: true },
         BIMUsedMB: { type: Number, required: true },
     },
+    paymentInfo: {
+        customerId: { type: String, required: false, default: '' },
+        plan: { type: String, required: false, default: '' },
+        expirationDate: { type: String, required: false, default: '' },
+    },
     validatedMail: { type: Boolean, required: true, default: false },
 });
 const UserModel = mongoose_1.default.model('user', UserSchema);

src/index.ts

@@ -25,6 +25,7 @@ import { ProjectService } from './projects/services/ProjectService'
 import { OrganizationService } from './organizations/services/OrganizationService'
 import { updateUserService } from './users/services/updateUserService'
 import { UserService } from './usersProject/UserService'
+import { updateCustomerId } from './users/services/updateCustomerIdService'
 
 export {
     createUserCollectionWithValidation,
@@ -40,6 +41,7 @@ export {
     createUserService,
     updateUserService,
     getUserByEmail,
+    updateCustomerId,
     UserService,
     OrganizationService,
     EntityService,

src/interfaces.ts

@@ -15,6 +15,11 @@ export interface IUsers {
     complement: string
     quota: UserQuota
     validatedMail: boolean
+    paymentInfo: {
+        customerId: string
+        plan: string
+        expirationDate: Date
+    }
     [key: string]: any
 }
 

src/users/services/createUserService.ts

@@ -34,6 +34,11 @@ export async function createUserService(user: IUsers): Promise<IUsers> {
                 imageUsedMB: 0,
                 pointCloudUsedMB: 0,
             },
+            paymentInfo: {
+                customerId: user.paymentInfo.customerId,
+                plan: user.paymentInfo.plan,
+                expirationDate: user.paymentInfo.expirationDate,
+            },
         })
 
         const savedUser = await newUser.save()

src/users/services/updateCustomerIdService.ts

@@ -0,0 +1,39 @@
+import { ErrorMessages } from 'duna-web-platform-error-defs'
+import { IUsers } from '../../interfaces'
+import { UserModel } from '../validationUserModel'
+
+export async function updateCustomerId(
+    email: string,
+    updates: Partial<IUsers['paymentInfo']>
+): Promise<IUsers | null> {
+    try {
+        const filter = { email }
+        const update = {
+            $set: {
+                'paymentInfo.customerId': updates.customerId,
+                'paymentInfo.plan': updates.plan,
+                'paymentInfo.expirationDate': updates.expirationDate,
+            },
+        }
+
+        const options = { new: true }
+
+        const updatedUser = await UserModel.findOneAndUpdate(
+            filter,
+            update,
+            options
+        )
+
+        if (!updatedUser) {
+            const err = ErrorMessages.UserNotFound.Message
+            throw err
+        }
+
+        return updatedUser
+    } catch (error) {
+        console.error('Error in updateCustomerId:', error)
+        const err = ErrorMessages.InternalServerError
+        err.Details = 'Error updating user data.'
+        throw err
+    }
+}

src/users/services/updateUserService.ts

@@ -28,6 +28,16 @@ export async function updateUserService(
         if (updates.complement) existingUser.complement = updates.complement
         if (updates.quota) existingUser.quota = updates.quota
 
+        if (updates.paymentInfo) {
+            if (updates.paymentInfo.plan) {
+                existingUser.paymentInfo.plan = updates.paymentInfo.plan
+            }
+            if (updates.paymentInfo.expirationDate) {
+                existingUser.paymentInfo.expirationDate =
+                    updates.paymentInfo.expirationDate
+            }
+        }
+
         await existingUser.save()
 
         return existingUser

src/users/validationUserModel.ts

@@ -23,6 +23,11 @@ const UserSchema = new mongoose.Schema<IUsers>({
         imageUsedMB: { type: Number, required: true },
         BIMUsedMB: { type: Number, required: true },
     },
+    paymentInfo: {
+        customerId: { type: String, required: false, default: '' },
+        plan: { type: String, required: false, default: '' },
+        expirationDate: { type: String, required: false, default: '' },
+    },
     validatedMail: { type: Boolean, required: true, default: false },
 })