feat: async cache.read()/write(), remove .has()

This commit is contained in:
harttle
2020-03-05 01:47:53 +08:00
parent 65b849c02a
commit 61dac49b04
4 changed files with 26 additions and 10 deletions
+2 -3
View File
@@ -1,5 +1,4 @@
export interface Cache<T> { export interface Cache<T> {
write (key: string, value: T): void; write (key: string, value: T): void | Promise<void>;
read (key: string): T | undefined; read (key: string): T | undefined | Promise<T | undefined>;
has (key: string): boolean;
} }
-4
View File
@@ -42,10 +42,6 @@ export class LRU<T> implements Cache<T> {
return value return value
} }
has (key: string): boolean {
return !!this.cache[key]
}
remove (key: string) { remove (key: string) {
const node = this.cache[key] const node = this.cache[key]
node.prev.next = node.next node.prev.next = node.next
+5 -2
View File
@@ -76,10 +76,13 @@ export class Liquid {
for (const filepath of paths) { for (const filepath of paths) {
const { cache } = this.options const { cache } = this.options
if (cache && cache.has(filepath)) return cache.read(filepath) if (cache) {
const tpls = yield cache.read(filepath)
if (tpls) return tpls
}
if (!(sync ? this.fs.existsSync(filepath) : yield this.fs.exists(filepath))) continue if (!(sync ? this.fs.existsSync(filepath) : yield this.fs.exists(filepath))) continue
const tpl = this.parse(sync ? this.fs.readFileSync(filepath) : yield this.fs.readFile(filepath), filepath) const tpl = this.parse(sync ? this.fs.readFileSync(filepath) : yield this.fs.readFile(filepath), filepath)
cache && cache.write(filepath, tpl) if (cache) cache.write(filepath, tpl)
return tpl return tpl
} }
throw this.lookupError(file, options.root) throw this.lookupError(file, options.root)
+19 -1
View File
@@ -71,7 +71,6 @@ describe('LiquidOptions#cache', function () {
extname: '.html', extname: '.html',
cache: { cache: {
read: (): Template[] | undefined => last, read: (): Template[] | undefined => last,
has: (): boolean => !!last,
write: (key: string, value: Template[]) => { last = value } write: (key: string, value: Template[]) => { last = value }
} }
}) })
@@ -82,6 +81,25 @@ describe('LiquidOptions#cache', function () {
expect(await engine.renderFile('files/bar')).to.equal('foo') expect(await engine.renderFile('files/bar')).to.equal('foo')
expect(await engine.renderFile('files/coo')).to.equal('foo') expect(await engine.renderFile('files/coo')).to.equal('foo')
}) })
it('should respect cache={} option (async)', async function () {
const cached: { [key: string]: Template[] | undefined } = {}
const engine = new Liquid({
root: '/root/',
extname: '.html',
cache: {
read: (key: string) => Promise.resolve(cached[key]),
write: (key: string, value: Template[]) => { cached[key] = value; Promise.resolve() }
}
})
mock({ '/root/files/foo.html': 'foo' })
mock({ '/root/files/bar.html': 'bar' })
mock({ '/root/files/coo.html': 'coo' })
expect(await engine.renderFile('files/foo')).to.equal('foo')
expect(await engine.renderFile('files/bar')).to.equal('bar')
expect(await engine.renderFile('files/coo')).to.equal('coo')
mock({ '/root/files/coo.html': 'COO' })
expect(await engine.renderFile('files/coo')).to.equal('coo')
})
it('should not cache not exist file', async function () { it('should not cache not exist file', async function () {
const engine = new Liquid({ const engine = new Liquid({
root: '/root/', root: '/root/',