Skip to content

Commit 86af128

Browse files
kwertopkwertop
committed
generating declaration files and renaming destination folder
1 parent b1890c5 commit 86af128

12 files changed

Lines changed: 99 additions & 31 deletions

‎lib/benchmarkCache.d.ts‎

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
export {};

build/benchmarkCache.js renamed to lib/benchmarkCache.js

File renamed without changes.

‎lib/examples/cache.d.ts‎

Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,13 @@
1+
export declare class LocalCache {
2+
private static cache;
3+
private constructor();
4+
static InitiateInstance(): void;
5+
static get(key: string): any;
6+
static set(key: string, value: any, ttl?: number): void;
7+
static del(key: string): void;
8+
static getTtl(key: string): number | undefined;
9+
static recover(): void;
10+
private static createNodeCacheInstance;
11+
private static getTtlWithJitter;
12+
static flushAll(): Promise<void>;
13+
}

build/examples/cache.js renamed to lib/examples/cache.js

File renamed without changes.

‎lib/index.d.ts‎

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
export { default as PersistentNodeCache } from "./persistentNodeCache";

build/index.js renamed to lib/index.js

Lines changed: 0 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -1,17 +1,8 @@
11
"use strict";
2-
// import { LocalCache } from "./cache";
32
var __importDefault = (this && this.__importDefault) || function (mod) {
43
return (mod && mod.__esModule) ? mod : { "default": mod };
54
};
65
Object.defineProperty(exports, "__esModule", { value: true });
76
exports.PersistentNodeCache = void 0;
8-
// import { PersistentNodeCache } from "./persistentNodeCache";
9-
// LocalCache.InitiateInstance();
10-
// LocalCache.set("foo", "bar");
11-
// LocalCache.set("cat", "dog");
12-
// LocalCache.set("something", "nothing");
13-
// LocalCache.recover();
14-
// let val = LocalCache.get("foo")
15-
// console.log(val);
167
var persistentNodeCache_1 = require("./persistentNodeCache");
178
Object.defineProperty(exports, "PersistentNodeCache", { enumerable: true, get: function () { return __importDefault(persistentNodeCache_1).default; } });

‎lib/persistentNodeCache.d.ts‎

Lines changed: 22 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,22 @@
1+
import NodeCache, { Key, ValueSetItem } from "node-cache";
2+
export default class PersistentNodeCache extends NodeCache {
3+
private readonly interval;
4+
private readonly cacheName;
5+
private readonly emitter;
6+
private readonly backupFilePath;
7+
private readonly appendFilePath;
8+
private flushingToDisk;
9+
private appendFileDescriptor;
10+
constructor(cacheName: string, period?: number, dir?: string, opts?: any);
11+
set<T>(key: Key, value: T, ttl?: number | string): boolean;
12+
mset<T>(keyValueSet: ValueSetItem<T>[]): boolean;
13+
del(keys: Key | Key[]): number;
14+
take<T>(key: Key): T | undefined;
15+
ttl(key: Key, ttl?: number): boolean;
16+
flushAll(): void;
17+
close(): void;
18+
recover(): Promise<void>;
19+
private appendExpiredEvent;
20+
private saveToDisk;
21+
private appendToFile;
22+
}

build/persistentNodeCache.js renamed to lib/persistentNodeCache.js

Lines changed: 4 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -29,14 +29,14 @@ class PersistentNodeCache extends node_cache_1.default {
2929
constructor(cacheName, period, dir, opts) {
3030
super(opts);
3131
this.cacheName = cacheName;
32-
this.interval = setInterval(() => { this.saveToDisk(); }, period);
32+
this.interval = setInterval(() => { this.saveToDisk(); }, period || 1000);
3333
this.emitter = new events_1.EventEmitter();
3434
this.flushingToDisk = false;
3535
if (dir === null || dir === void 0 ? void 0 : dir.endsWith('/')) {
3636
dir = dir.slice(0, -1);
3737
}
38-
this.backupFilePath = (dir || os_1.default.homedir()) + `/${cacheName}.backup`;
39-
this.appendFilePath = (dir || os_1.default.homedir()) + `/${cacheName}.append`;
38+
this.backupFilePath = (dir || os_1.default.homedir()) + `/${this.cacheName}.backup`;
39+
this.appendFilePath = (dir || os_1.default.homedir()) + `/${this.cacheName}.append`;
4040
fs_1.default.writeFileSync(this.appendFilePath, '');
4141
super.on("expired", (key, _) => { this.appendExpiredEvent(key); });
4242
}
@@ -186,11 +186,6 @@ class PersistentNodeCache extends node_cache_1.default {
186186
let bf = Buffer.from(JSON.stringify(data));
187187
fs_1.default.writeFileSync(this.backupFilePath, bf);
188188
fs_1.default.writeFileSync(this.appendFilePath, '');
189-
// fs.write(this.appendFileDescriptor, '', (writeErr, written, buffer) => {
190-
// if (writeErr) {
191-
// console.error('Error writing to file:', writeErr);
192-
// }
193-
// });
194189
this.appendFileDescriptor.close();
195190
}
196191
catch (err) {
@@ -220,13 +215,8 @@ class PersistentNodeCache extends node_cache_1.default {
220215
this.appendFileDescriptor = fd;
221216
fs_1.default.write(fd, data, 0, data.length, null, (writeErr, written, buffer) => {
222217
if (writeErr) {
223-
console.error('Error witing to file:', writeErr);
218+
console.error('Error writing to file:', writeErr);
224219
}
225-
// fs.close(fd, (closeErr) => {
226-
// if(closeErr) {
227-
// console.error('Error closing file:', closeErr);
228-
// }
229-
// });
230220
});
231221
});
232222
}

‎lib/waitFor.d.ts‎

Lines changed: 22 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,22 @@
1+
export declare const waitFor: <Event_1 extends string>(event: Event_1, emitter: EventEmitter<Event_1>, callback?: Callback) => Promise<void>;
2+
export declare const removeListener: <Event_1 extends string>(emitter: EventEmitterOff<Event_1> | EventEmitterRemoveListener<Event_1>, event: "error" | Event_1, listener: EventListener) => void;
3+
interface Callback {
4+
(error: any): void;
5+
}
6+
interface EventListener {
7+
(...args: any[]): void;
8+
}
9+
interface EventEmitterOn<Event extends string> {
10+
on(event: Event | 'error', listener: EventListener): void;
11+
}
12+
interface EventEmitterOff<Event extends string> {
13+
off(event: Event | 'error', listener: EventListener): void;
14+
}
15+
interface EventEmitterAddListener<Event extends string> {
16+
addListener(event: Event | 'error', listener: EventListener): void;
17+
}
18+
interface EventEmitterRemoveListener<Event extends string> {
19+
removeListener(event: Event | 'error', listener: EventListener): void;
20+
}
21+
type EventEmitter<Event extends string> = (EventEmitterOn<Event> | EventEmitterAddListener<Event>) & (EventEmitterOff<Event> | EventEmitterRemoveListener<Event>);
22+
export {};

build/waitFor.js renamed to lib/waitFor.js

File renamed without changes.

0 commit comments

Comments
 (0)