lee/puter
1
0
Fork 0
mirror of https://github.com/HeyPuter/puter.git synced 2026-05-03 16:10:31 +00:00
Code Issues Actions 4 Packages Projects Releases Wiki Activity

fix: make invalidations more robust (#2529)

Browse Source
This commit is contained in:
Daniel Salazar
2026-02-24 15:45:46 -08:00
committed by GitHub
parent 6544e8c250
commit 4c863cc5bc
5 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
extensions/api.d.ts
Vendored
+2 -2
View File
@@ -169,9 +169,9 @@ interface Extension extends RouterMethods {
on<E extends keyof ExtensionEventTypeMap>(
name: E,
listener: (event: ExtensionEventTypeMap[E]) => void | Promise<void>
listener: (event: ExtensionEventTypeMap[E], metadata?: { from_outside?: boolean }) => void | Promise<void>
): void;
on(name: string, listener: (event: unknown) => void | Promise<void>): void
on<T>(name: string, listener: (event: T, metadata?: { from_outside?: boolean }) => void | Promise<void>): void
import(module: 'data'): {
db: BaseDatabaseAccessService;
src/backend/src/clients/redis/cacheUpdate.ts
+3 -3
View File
@@ -72,7 +72,7 @@ const getEventService = (eventService?: CacheUpdateOptions['eventService']) => {
return null;
};
export const emitOuterCacheUpdate = async (
export const emitOuterCacheUpdate = (
{
cacheKey,
data,
@@ -100,7 +100,7 @@ export const emitOuterCacheUpdate = async (
payload.ttlSeconds = ttlSeconds;
}
await svc_event.emit('outer.cacheUpdate', payload);
svc_event.emit('outer.cacheUpdate', payload);
};
export const setRedisCacheValue = async (
@@ -124,7 +124,7 @@ export const setRedisCacheValue = async (
await redisClient.set(key, value);
}
await emitOuterCacheUpdate({
emitOuterCacheUpdate({
cacheKey: [key],
data: eventData === undefined ? value : eventData,
ttlSeconds,
src/backend/src/clients/redis/deleteRedisKeys.ts
+1 -1
View File
@@ -72,7 +72,7 @@ export const deleteRedisKeys = async (...inputs: (DeleteRedisKeysInput | DeleteR
deleted += await redisClient.del(key);
}
await emitOuterCacheUpdate({
emitOuterCacheUpdate({
cacheKey: uniqueKeys,
}, {
eventService: options.eventService,
src/backend/src/modules/apps/AppRedisCacheSpace.js
+1 -1
View File
@@ -89,7 +89,7 @@ export const AppRedisCacheSpace = {
.map(key => setKey(key, serialized, { ttlSeconds }));
if ( writes.length ) {
await Promise.all(writes);
await emitOuterCacheUpdate({
emitOuterCacheUpdate({
cacheKey: cacheKeys,
data: app,
ttlSeconds,
src/backend/src/services/UserRedisCacheSpace.js
+1 -1
View File
@@ -69,7 +69,7 @@ const UserRedisCacheSpace = {
}
if ( writes.length ) {
await Promise.all(writes);
await emitOuterCacheUpdate({
emitOuterCacheUpdate({
cacheKey: cacheKeys,
data: user,
ttlSeconds,