MirrorSave
/
budibase
mirror of https://github.com/Budibase/budibase.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Making code more readable

This commit is contained in:
Adria Navarro 2024-03-01 11:04:30 +01:00
parent fd93eb79d5
commit eb9a163394
1 changed files with 9 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
packages/backend-core/src/cache/docWritethrough.ts vendored
View File

@ -15,7 +15,7 @@ async function getCache() {
} }
interface CacheItem { interface CacheItem {
lastWrite: number nextWrite: number
} }
export class DocWritethrough { export class DocWritethrough {
@ -40,8 +40,8 @@ export class DocWritethrough {
return this._docId return this._docId
} }
private makeCacheItem(): CacheItem { private makeNextWriteInfoItem(): CacheItem {
return { lastWrite: Date.now() } return { nextWrite: Date.now() + this.writeRateMs }
} }
async patch(data: Record<string, any>) { async patch(data: Record<string, any>) {
@ -62,7 +62,10 @@ export class DocWritethrough {
async () => { async () => {
if (await this.shouldUpdateDb(cache)) { if (await this.shouldUpdateDb(cache)) {
await this.persistToDb(cache) await this.persistToDb(cache)
await cache.store(this.docInfoCacheKey, this.makeCacheItem()) await cache.store(
this.docInfoCacheKey,
this.makeNextWriteInfoItem()
)
} }
} }
) )
@ -75,9 +78,9 @@ export class DocWritethrough {
private async shouldUpdateDb(cache: BaseCache) { private async shouldUpdateDb(cache: BaseCache) {
const cacheItem = await cache.withCache(this.docInfoCacheKey, null, () => const cacheItem = await cache.withCache(this.docInfoCacheKey, null, () =>
this.makeCacheItem() this.makeNextWriteInfoItem()
) )
return cacheItem.lastWrite <= Date.now() - this.writeRateMs return Date.now() >= cacheItem.nextWrite
} }
private async storeToCache(cache: BaseCache, data: Record<string, any>) { private async storeToCache(cache: BaseCache, data: Record<string, any>) {