initial import

Author: DanielSchaffer

.gitignore

@@ -0,0 +1,11 @@
+.idea
+node_modules
+.DS_Store
+out
+reports
+coverage
+.nyc_output
+.out
+dist
+.env
+.aws-docker

.nycrc

@@ -0,0 +1,19 @@
+{
+  "sourceMap": true,
+  "instrument": true,
+  "reporter": [
+    "html",
+    "text"
+  ],
+  "include": [
+    "*/src/**/*.ts"
+  ],
+  "extension": [
+    ".ts"
+  ],
+  "exclude": [
+    "**/*.spec.ts",
+    "mocha.config.js",
+    "test"
+  ]
+}

README.md

@@ -1,3 +1 @@
 # dandi
-# dandi
-# dandi

cache/index.ts

@@ -0,0 +1,5 @@
+export * from './src/cache.key.generator';
+export * from './src/cache.provider';
+export * from './src/cascading.cache';
+export * from './src/memory.cache';
+export * from './src/service.context.cache.key.generator';

cache/npm.link

@@ -0,0 +1,4 @@
+#!/usr/bin/env bash
+
+npm link @dandi/core
+npm link @dandi/di-core

cache/package-lock.json

@@ -0,0 +1,23 @@
+{
+  "name": "@dandi/cache",
+  "version": "1.0.0-alpha.10",
+  "scripts": {},
+  "repository": {
+    "type": "git",
+    "url": "git+https://github.com/dandi-mvc/dandi.git"
+  },
+  "author": "Daniel Schaffer <[email protected]>",
+  "bugs": {
+    "url": "https://github.com/dandi-mvc/dandi/issues"
+  },
+  "homepage": "https://github.com/dandi-mvc/dandi#readme",
+  "devDependencies": {
+    "@types/fs-extra": "^5.0.2",
+    "luxon": "^1.2.1",
+    "uuid": "^3.2.1"
+  },
+  "peerDependencies": {
+    "@dandi/core": "1.0.0-alpha.10",
+    "@dandi/di-core": "1.0.0-alpha.10"
+  }
+}

cache/package.json

@@ -0,0 +1,10 @@
+import { InjectionToken } from '@dandi/di-core';
+
+import { localOpinionatedToken } from './local.token';
+
+export interface CacheKeyGenerator {
+    keyFor(...args: any[]): Symbol;
+}
+
+export const CacheKeyGenerator: InjectionToken<CacheKeyGenerator> =
+    localOpinionatedToken<CacheKeyGenerator>('CacheKeyGenerator', { multi: false });

cache/src/cache.key.generator.ts

@@ -0,0 +1,37 @@
+import { Duration } from '@dandi/core';
+import { MappedInjectionToken } from '@dandi/di-core';
+
+import { localOpinionatedToken } from './local.token';
+
+export enum CacheProviderType {
+    cascading = 'cascading',
+    localMemory = 'localMemory',
+    localService = 'localService',
+    network = 'networkCache',
+    remote = 'remoteCache',
+}
+
+export interface Cache {
+
+    get<T>(key: Symbol): Promise<T>;
+    set(key: Symbol, value: any, duration?: Duration): Promise<void>;
+    delete(key: Symbol): Promise<boolean>;
+
+}
+
+const tokens = new Map<CacheProviderType, MappedInjectionToken<CacheProviderType, Cache>>();
+
+export const Cache = CacheProvider(CacheProviderType.cascading);
+
+export function CacheProvider(type: CacheProviderType) {
+    let token: MappedInjectionToken<CacheProviderType, Cache> = tokens.get(type);
+    if (!token) {
+        token = {
+            provide: localOpinionatedToken<Cache>(`CacheProvider:${type}`, { multi: false }),
+            key: type,
+        };
+        tokens.set(type, token);
+    }
+    return token;
+}
+

cache/src/cache.provider.ts

@@ -0,0 +1,44 @@
+import { Duration }                     from '@dandi/core';
+import { Inject, Injectable, Optional } from '@dandi/di-core';
+
+import { Cache, CacheProvider, CacheProviderType } from './cache.provider';
+
+@Injectable(CacheProvider(CacheProviderType.cascading))
+export class CascadingCache implements Cache {
+
+    private readonly caches: Cache[];
+    private local: Cache;
+
+    constructor(
+        @Inject(CacheProvider(CacheProviderType.localMemory)) @Optional() localMem: Cache,
+        @Inject(CacheProvider(CacheProviderType.localService)) @Optional() localSvc: Cache,
+        @Inject(CacheProvider(CacheProviderType.network)) @Optional() network: Cache,
+        @Inject(CacheProvider(CacheProviderType.remote)) @Optional() remote: Cache,
+    ) {
+        this.caches = [
+            localMem,
+            localSvc,
+            network,
+            remote
+        ].filter(cache => cache);
+        this.local = this.caches[0];
+    }
+
+    public async get<T>(key: Symbol): Promise<T> {
+        for (let cache of this.caches) {
+            let result = await cache.get(key);
+            if (result) {
+                return result as T;
+            }
+        }
+    }
+
+    public async set(key: any, value: any, duration?: Duration): Promise<void> {
+        return await this.local.set(key, value, duration);
+    }
+
+    public async delete(key: any): Promise<boolean> {
+        return await this.local.delete(key);
+    }
+
+}

cache/src/cascading.cache.ts

@@ -0,0 +1,10 @@
+import { InjectionOptions, InjectionToken, OpinionatedToken, SymbolToken } from '@dandi/di-core';
+
+const PKG = '@dandi/cache';
+
+export function localSymbolToken<T>(target: string): InjectionToken<T> {
+    return SymbolToken.local<T>(PKG, target);
+}
+export function localOpinionatedToken<T>(target: string, options: InjectionOptions): InjectionToken<T> {
+    return OpinionatedToken.local<T>(PKG, target, options);
+}

cache/src/local.token.ts

@@ -0,0 +1,53 @@
+import { Duration }              from '@dandi/core';
+import { Injectable, Singleton } from '@dandi/di-core';
+
+import { Cache, CacheProvider, CacheProviderType } from './cache.provider';
+import Timer = NodeJS.Timer;
+
+@Injectable(CacheProvider(CacheProviderType.localMemory), Singleton)
+export class MemoryCache implements Cache {
+
+    private map = new Map<Symbol, any>();
+    private timeouts = new Map<Symbol, Timer>();
+
+    constructor() {
+    }
+
+    private clearTimeout(key: Symbol): void {
+        const existingTimeout = this.timeouts.get(key);
+        if (existingTimeout) {
+            clearTimeout(existingTimeout);
+            this.timeouts.delete(key);
+        }
+    }
+
+    public get<T>(key: Symbol): Promise<T> {
+        return Promise.resolve(this.map.get(key));
+    }
+
+    public set(key: Symbol, value: any, duration?: Duration): Promise<void> {
+        this.clearTimeout(key);
+        this.map.set(key, value);
+        if (duration) {
+            this.timeouts.set(key, setTimeout(() => {
+                this.map.delete(key);
+                this.timeouts.delete(key);
+            }, duration.as('milliseconds')));
+        }
+        return Promise.resolve();
+    }
+
+    public delete(key: Symbol): Promise<boolean> {
+        this.clearTimeout(key);
+        return Promise.resolve(this.map.delete(key));
+    }
+
+    public clear(): Promise<number> {
+        this.timeouts.forEach(timer => clearTimeout(timer));
+        const count = this.map.size;
+        this.map.clear();
+        this.timeouts.clear();
+        return Promise.resolve(count);
+    }
+
+}

cache/src/memory.cache.ts

@@ -0,0 +1,26 @@
+import { Inject, Injectable, InjectionContext, InjectionToken } from '@dandi/di-core';
+
+import { CacheKeyGenerator } from './cache.key.generator';
+
+const keys = new Map<string, Symbol>();
+
+@Injectable(CacheKeyGenerator)
+export class ServiceContextCacheKeyGenerator implements CacheKeyGenerator {
+
+    constructor(
+        @Inject(InjectionContext) private context: InjectionToken<any>,
+    ) {}
+
+    public keyFor(...args: any[]): Symbol {
+        const contextTag = `[${typeof this.context === 'function' ? this.context.name : this.context}]`;
+        args.unshift(contextTag);
+        const keyStr = args.map(arg => arg.toString()).join(':');
+        let key = keys.get(keyStr);
+        if (!key) {
+            key = Symbol(keyStr);
+            keys.set(keyStr, key);
+        }
+        return key;
+    }
+
+}

cache/src/service.context.cache.key.generator.ts

@@ -0,0 +1,6 @@
+{
+  "extends": "../tsconfig.json",
+  "files": [
+    "index.ts"
+  ]
+}

cache/tsconfig.json

@@ -0,0 +1,9 @@
+#!/usr/bin/env bash
+
+
+for dir in {'core','di-core','model','model-validation','config','config-aws-ssm','data','data-pg','cache','mvc','mvc-express','mvc-auth-firebase'}
+do
+    npm unpublish "@dandi/${dir%*/}@1.0.0-alpha.8"
+    npm unpublish "@dandi/${dir%*/}@1.0.0-alpha.9"
+
+done

cleanup.sh

@@ -0,0 +1,2 @@
+export * from './src/aws.ssm.config.client';
+export * from './src/aws.ssm.config.module';

config-aws-ssm/index.ts

@@ -0,0 +1,5 @@
+#!/usr/bin/env bash
+
+npm link @dandi/config
+npm link @dandi/core
+npm link @dandi/di-core