cosqnet/fitlien-services
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

Name Updated

Browse Source
This commit is contained in:
Sharon Dcruz 2025-09-18 17:49:54 +05:30
parent 0679992418
commit f56132dddd
3 changed files with 11 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
functions/src/index.ts
View File

@ -22,11 +22,10 @@ export {
esslDeleteUser, esslGetEmployeePunchLogs esslDeleteUser, esslGetEmployeePunchLogs
} from './dooraccess'; } from './dooraccess';
// Add member cache functions
export { export {
generateMemberCache, generateMemberCache,
updateTrainerAssignmentCache, updateTrainerAssignmentCache,
getCachedMembers, getCachedMembers,
rebuildGymCachee, rebuildGymCache,
batchRebuildCaches batchRebuildCaches
} from './memberCache'; } from './memberCache';

2
functions/src/memberCache/index.ts
View File

@ -2,6 +2,6 @@ export {
generateMemberCache, generateMemberCache,
updateTrainerAssignmentCache, updateTrainerAssignmentCache,
getCachedMembers, getCachedMembers,
rebuildGymCachee, rebuildGymCache,
batchRebuildCaches batchRebuildCaches
} from './memberCache'; } from './memberCache';

18
functions/src/memberCache/memberCache.ts
View File

@ -90,7 +90,7 @@ export const generateMemberCache = onDocumentWritten(
return; return;
} }
await rebuildGymCache(gymId); await rebuildGymCachee(gymId);
logger.info(`JSON cache updated for gym ${gymId} after member ${membershipId} change`); logger.info(`JSON cache updated for gym ${gymId} after member ${membershipId} change`);
} catch (error) { } catch (error) {
@ -126,7 +126,7 @@ export const updateTrainerAssignmentCache = onDocumentWritten(
} }
for (const gymId of gymIds) { for (const gymId of gymIds) {
await rebuildGymCache(gymId); await rebuildGymCachee(gymId);
} }
if (gymIds.size > 0) { if (gymIds.size > 0) {
@ -167,7 +167,7 @@ export const getCachedMembers = onCall(
const fiveMinutes = 5 * 60 * 1000; const fiveMinutes = 5 * 60 * 1000;
if (forceRefresh || !fileExists || fileAge > fiveMinutes) { if (forceRefresh || !fileExists || fileAge > fiveMinutes) {
logger.info(`Rebuilding cache for gym ${gymId} - forceRefresh: ${forceRefresh}, fileExists: ${fileExists}, fileAge: ${fileAge}ms`); logger.info(`Rebuilding cache for gym ${gymId} - forceRefresh: ${forceRefresh}, fileExists: ${fileExists}, fileAge: ${fileAge}ms`);
await rebuildGymCache(gymId); await rebuildGymCachee(gymId);
} }
try { try {
@ -178,7 +178,7 @@ export const getCachedMembers = onCall(
} catch (error) { } catch (error) {
logger.error(`Error reading cache file for gym ${gymId}:`, error); logger.error(`Error reading cache file for gym ${gymId}:`, error);
await rebuildGymCache(gymId); await rebuildGymCachee(gymId);
const [fileBuffer] = await file.download(); const [fileBuffer] = await file.download();
const jsonData: JsonCacheData = JSON.parse(fileBuffer.toString()); const jsonData: JsonCacheData = JSON.parse(fileBuffer.toString());
return jsonData.members || []; return jsonData.members || [];
@ -190,7 +190,7 @@ export const getCachedMembers = onCall(
} }
); );
export const rebuildGymCachee = onCall( export const rebuildGymCache = onCall(
{ {
region: "#{SERVICES_RGN}#", region: "#{SERVICES_RGN}#",
}, },
@ -201,7 +201,7 @@ export const rebuildGymCachee = onCall(
throw new HttpsError('invalid-argument', 'gymId is required'); throw new HttpsError('invalid-argument', 'gymId is required');
} }
await rebuildGymCache(gymId); await rebuildGymCachee(gymId);
return { success: true, message: `JSON cache rebuilt for gym ${gymId}` }; return { success: true, message: `JSON cache rebuilt for gym ${gymId}` };
} }
); );
@ -222,7 +222,7 @@ export const batchRebuildCaches = onCall(
for (const gymId of gymIds) { for (const gymId of gymIds) {
try { try {
await rebuildGymCache(gymId); await rebuildGymCachee(gymId);
results.push({ gymId, status: 'success' }); results.push({ gymId, status: 'success' });
} catch (error) { } catch (error) {
const errorMessage = error instanceof Error ? error.message : String(error); const errorMessage = error instanceof Error ? error.message : String(error);
@ -239,7 +239,7 @@ export const batchRebuildCaches = onCall(
} }
); );
async function rebuildGymCache(gymId: string): Promise<void> { async function rebuildGymCachee(gymId: string): Promise<void> {
try { try {
logger.info(`Starting JSON cache rebuild for gym: ${gymId}`); logger.info(`Starting JSON cache rebuild for gym: ${gymId}`);
@ -450,7 +450,7 @@ async function rebuildGymCacheFromDeletion(membershipId: string): Promise<void>
if (memberExists) { if (memberExists) {
const gymId = file.name.replace(`${CACHE_FOLDER}/`, '').replace('.json', ''); const gymId = file.name.replace(`${CACHE_FOLDER}/`, '').replace('.json', '');
logger.info(`Rebuilding cache for gym ${gymId} after member ${membershipId} deletion`); logger.info(`Rebuilding cache for gym ${gymId} after member ${membershipId} deletion`);
await rebuildGymCache(gymId); await rebuildGymCachee(gymId);
break; break;
} }
} catch (error) { } catch (error) {