first commit

Author: karacas

.eslintrc.js

@@ -0,0 +1,12 @@
+module.exports = {
+  "extends": [
+    "react-app",
+    "prettier/@typescript-eslint",
+    "plugin:prettier/recommended"
+  ],
+  "settings": {
+    "react": {
+      "version": "999.999.999"
+    }
+  }
+}

.gitignore

@@ -0,0 +1,13 @@
+diff
+.idea/*
+.nyc_output
+build
+coverage
+package-lock.json
+.timetracker.txt
+scratch/
+
+*.log
+.DS_Store
+node_modules
+dist

LICENSE

@@ -0,0 +1,21 @@
+MIT License
+
+Copyright (c) 2022 karacas
+
+Permission is hereby granted, free of charge, to any person obtaining a copy
+of this software and associated documentation files (the "Software"), to deal
+in the Software without restriction, including without limitation the rights
+to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+copies of the Software, and to permit persons to whom the Software is
+furnished to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in all
+copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+SOFTWARE.

package.json

@@ -0,0 +1,66 @@
+{
+  "name": "@karacas/kaysh",
+  "version": "0.1.38",
+  "author": "karacas",
+  "module": "dist/mylib.esm.js",
+  "repository": {
+    "type": "git",
+    "url": "https://github.com/karacas/kaysh"
+  },
+  "homepage": "https://github.com/karacas/kaysh",
+  "license": "MIT",
+  "main": "dist/index.js",
+  "typings": "dist/index.d.ts",
+  "files": [
+    "dist",
+    "src"
+  ],
+  "engines": {
+    "node": ">=14"
+  },
+  "scripts": {
+    "start": "tsdx watch",
+    "build": "tsdx build",
+    "test": "tsdx test",
+    "test:watch": "tsdx test --watch",
+    "test:coverage": "tsdx test --coverage",
+    "test_clearCache": "npx jest --clearCache",
+    "lint": "tsdx lint",
+    "prepare": "tsdx build",
+    "size": "size-limit",
+    "analyze": "size-limit --why"
+  },
+  "peerDependencies": {},
+  "husky": {
+    "hooks": {
+      "pre-commit": "tsdx lint"
+    }
+  },
+  "prettier__": {
+    "printWidth": 140,
+    "semi": true,
+    "singleQuote": true,
+    "trailingComma": "es5"
+  },
+  "size-limit": [
+    {
+      "path": "dist/mylib.cjs.production.min.js",
+      "limit": "20 KB"
+    },
+    {
+      "path": "dist/mylib.esm.js",
+      "limit": "20 KB"
+    }
+  ],
+  "dependencies": {
+    "rxjs": "^6.6.0"
+  },
+  "devDependencies": {
+    "@size-limit/preset-small-lib": "^7.0.5",
+    "husky": "^7.0.4",
+    "size-limit": "^7.0.5",
+    "tsdx": "^0.14.1",
+    "tslib": "^2.3.1",
+    "typescript": "^4.5.5"
+  }
+}

prettier.config.js

@@ -0,0 +1,30 @@
+const rxjs_cache = {
+  printWidth: 140,
+  singleQuote: true,
+  tabWidth: 2,
+  trailingComma: 'es5',
+  semi: true,
+  proseWrap: 'always',
+  arrowParens: 'avoid',
+  overrides: [
+    {
+      files: '*.html',
+      options: {
+        printWidth: 120,
+        parser: 'html',
+        proseWrap: 'preserve',
+        htmlWhitespaceSensitivity: 'ignore',
+        bracketSpacing: true,
+        arrowParens: 'avoid',
+      },
+    },
+    {
+      files: '*.scss',
+      options: {
+        parser: 'scss',
+      },
+    },
+  ],
+};
+
+module.exports = rxjs_cache;

src/.types/index.d.ts

@@ -0,0 +1 @@
+declare var __DEV__: boolean;

src/index.ts

@@ -0,0 +1,3 @@
+import { __rxjsCacheStore } from './lib/rxjs-cache-store';
+import { __simpleCacheStore } from './lib/simple-cache-store';
+export { __simpleCacheStore as kaysh, __rxjsCacheStore as rxjsKaysh };

src/lib/_aux.ts

@@ -0,0 +1,49 @@
+export function __strToHash(str = ''): string {
+  let hash = 0,
+    i,
+    chr;
+
+  for (i = 0; i < str.length; i++) {
+    chr = str.charCodeAt(i);
+    hash = (hash << 5) - hash + chr;
+    hash |= 0;
+  }
+
+  return hash.toString(36);
+}
+
+function getShortValue(val: any) {
+  if (Number.isInteger(val) && String(val).length) return 'num_' + val;
+
+  if (typeof val === 'string') {
+    if (val.length === 0) return 'emptyString__';
+    return 'str_' + val;
+  }
+
+  if (Array.isArray(val)) {
+    if (val.length === 0) return 'emptyArray__';
+
+    if (val.length === 1) {
+      if (Number.isInteger(val[0]) && String(val[0]).length) return '_num_' + val[0];
+
+      if (typeof val[0] === 'string') {
+        if (val[0].length === 0) return '_emptyString__';
+        return '_str_' + val[0];
+      }
+    }
+  }
+
+  return null;
+}
+
+export function __objToHash(val: any, fast = true) {
+  if (val === undefined) return '__undefined__';
+  if (val === null) return '__null__';
+
+  if (fast) {
+    let shortValue = getShortValue(val);
+    if (shortValue != null && shortValue.length > 0 && shortValue.length < 32) return shortValue;
+  }
+
+  return __strToHash(JSON.stringify(val));
+}

src/lib/rxjs-cache-store.ts

@@ -0,0 +1,44 @@
+import { of } from 'rxjs';
+import { Observable } from 'rxjs/internal/Observable';
+import { isObservable } from 'rxjs/internal/util/isObservable';
+import { shareReplay, tap } from 'rxjs/operators';
+import { DefaultConfigCacheModel, __simpleCacheStore } from './simple-cache-store';
+
+const getRxjsObservableCacheValue = (key: string, payloadToHash?: any): Observable<any> => {
+  const cache = __simpleCacheStore.getCacheValue(key, payloadToHash);
+
+  if (cache == null) return cache;
+
+  if (isObservable(cache)) return cache;
+
+  return of(cache);
+};
+
+const setRxjsObservableCacheValue = (
+  stream: Observable<any>,
+  key: string,
+  payloadToHash?: any,
+  config?: DefaultConfigCacheModel
+): Observable<any> => {
+  if (stream == null || key == null) return of(null);
+
+  const setCache = ($data: any) => {
+    if ($data != null) __simpleCacheStore.setCacheValue(key, $data, payloadToHash, config);
+  };
+
+  setCache(stream.pipe(shareReplay()));
+
+  return stream.pipe(
+    tap((_data: any) => setCache(_data)),
+    shareReplay()
+  );
+};
+
+const __rxCacheStore = {
+  getRxjsObservableCacheValue,
+  setRxjsObservableCacheValue,
+  resetCache: __simpleCacheStore.resetCache,
+  resetAllCaches: __simpleCacheStore.resetAllCaches,
+};
+
+export { __rxCacheStore as __rxjsCacheStore };