Compare commits
No commits in common. "master" and "v4.0.12" have entirely different histories.
57
changelog.md
57
changelog.md
@ -1,57 +0,0 @@
|
|||||||
# Changelog
|
|
||||||
|
|
||||||
## 2024-11-06 - 5.1.2 - fix(appdata)
|
|
||||||
Fix iteration over overwriteObject in AppData class
|
|
||||||
|
|
||||||
- Corrected the for loop from in to of inside the AppData class for iterating over overwriteObject keys.
|
|
||||||
|
|
||||||
## 2024-11-05 - 5.1.1 - fix(AppData)
|
|
||||||
Fix issue with overwrite object handling in AppData class
|
|
||||||
|
|
||||||
- Corrected logic to handle cases when overwriteObject is undefined.
|
|
||||||
|
|
||||||
## 2024-11-05 - 5.1.0 - feat(appdata)
|
|
||||||
Add support for overwriting keys using the overwriteObject option in AppData
|
|
||||||
|
|
||||||
- Introduced the overwriteObject option in IAppDataOptions to allow overwriting specific keys in the AppData class.
|
|
||||||
|
|
||||||
## 2024-06-19 - 5.0.17 - 5.0.23 - Core Updates
|
|
||||||
Routine maintenance and updates to the core components.
|
|
||||||
|
|
||||||
- Multiple core updates and fixes improving stability
|
|
||||||
|
|
||||||
## 2024-06-12 - 5.0.13 - 5.0.16 - Core Updates
|
|
||||||
Maintenance focus on core systems with enhancements and problem resolutions.
|
|
||||||
|
|
||||||
- Enhancements and updates in the core functionality
|
|
||||||
|
|
||||||
## 2024-05-29 - 5.0.13 - Documentation Update
|
|
||||||
Descriptive improvements aligned with current features.
|
|
||||||
|
|
||||||
- Updated core description for better clarity in documentation
|
|
||||||
|
|
||||||
## 2024-04-01 - 5.0.10 - Configuration Update
|
|
||||||
Improved configuration management for build processes.
|
|
||||||
|
|
||||||
- Updated `npmextra.json` to reflect changes in git repository management
|
|
||||||
|
|
||||||
## 2024-02-12 - 5.0.0 - 5.0.9 - Major Core Enhancements
|
|
||||||
A series of critical updates with resolved issues in the core components.
|
|
||||||
|
|
||||||
- Introduction of new core features
|
|
||||||
- Several core system updates
|
|
||||||
|
|
||||||
## 2024-02-12 - 4.0.16 - Major Version Transition
|
|
||||||
Migration to the new major version with impactful changes.
|
|
||||||
|
|
||||||
- BREAKING CHANGE: Significant updates requiring attention for smooth transition
|
|
||||||
|
|
||||||
## 2023-08-24 - 3.0.9 - 4.0.16 - Organization Updates
|
|
||||||
Formatted updates with attention to organizational standards and practice.
|
|
||||||
|
|
||||||
- SWITCH to a new organizational scheme
|
|
||||||
|
|
||||||
## 2023-07-11 - 3.0.9 - Organizational Enhancement
|
|
||||||
Shifts aligning with contemporary structuring and logistics.
|
|
||||||
|
|
||||||
- Strategic realignment with organizational principles
|
|
@ -11,32 +11,12 @@
|
|||||||
"gitzone": {
|
"gitzone": {
|
||||||
"projectType": "npm",
|
"projectType": "npm",
|
||||||
"module": {
|
"module": {
|
||||||
"githost": "code.foss.global",
|
"githost": "gitlab.com",
|
||||||
"gitscope": "push.rocks",
|
"gitscope": "push.rocks",
|
||||||
"gitrepo": "npmextra",
|
"gitrepo": "npmextra",
|
||||||
"description": "A utility to enhance npm with additional configuration, tool management capabilities, and a key-value store for project setups.",
|
"description": "do more with npm",
|
||||||
"npmPackagename": "@push.rocks/npmextra",
|
"npmPackagename": "@push.rocks/npmextra",
|
||||||
"license": "MIT",
|
"license": "MIT"
|
||||||
"keywords": [
|
}
|
||||||
"npm",
|
|
||||||
"configuration management",
|
|
||||||
"tool management",
|
|
||||||
"key-value store",
|
|
||||||
"project setup",
|
|
||||||
"typescript",
|
|
||||||
"environment setup",
|
|
||||||
"dependencies management",
|
|
||||||
"npm package enhancement",
|
|
||||||
"automation",
|
|
||||||
"async operations",
|
|
||||||
"app configuration",
|
|
||||||
"smart file handling",
|
|
||||||
"workflow improvement",
|
|
||||||
"persistent storage"
|
|
||||||
]
|
|
||||||
}
|
|
||||||
},
|
|
||||||
"tsdoc": {
|
|
||||||
"legal": "\n## License and Legal Information\n\nThis repository contains open-source code that is licensed under the MIT License. A copy of the MIT License can be found in the [license](license) file within this repository. \n\n**Please note:** The MIT License does not grant permission to use the trade names, trademarks, service marks, or product names of the project, except as required for reasonable and customary use in describing the origin of the work and reproducing the content of the NOTICE file.\n\n### Trademarks\n\nThis project is owned and maintained by Task Venture Capital GmbH. The names and logos associated with Task Venture Capital GmbH and any related products or services are trademarks of Task Venture Capital GmbH and are not included within the scope of the MIT license granted herein. Use of these trademarks must comply with Task Venture Capital GmbH's Trademark Guidelines, and any usage must be approved in writing by Task Venture Capital GmbH.\n\n### Company Information\n\nTask Venture Capital GmbH \nRegistered at District court Bremen HRB 35230 HB, Germany\n\nFor any legal inquiries or if you require further information, please contact us via email at hello@task.vc.\n\nBy using this repository, you acknowledge that you have read this section, agree to comply with its terms, and understand that the licensing of the code does not imply endorsement by Task Venture Capital GmbH of any derivative works.\n"
|
|
||||||
}
|
}
|
||||||
}
|
}
|
47
package.json
47
package.json
@ -1,8 +1,8 @@
|
|||||||
{
|
{
|
||||||
"name": "@push.rocks/npmextra",
|
"name": "@push.rocks/npmextra",
|
||||||
"version": "5.1.2",
|
"version": "4.0.12",
|
||||||
"private": false,
|
"private": false,
|
||||||
"description": "A utility to enhance npm with additional configuration, tool management capabilities, and a key-value store for project setups.",
|
"description": "do more with npm",
|
||||||
"main": "dist_ts/index.js",
|
"main": "dist_ts/index.js",
|
||||||
"typings": "dist_ts/index.d.ts",
|
"typings": "dist_ts/index.d.ts",
|
||||||
"scripts": {
|
"scripts": {
|
||||||
@ -12,31 +12,29 @@
|
|||||||
},
|
},
|
||||||
"repository": {
|
"repository": {
|
||||||
"type": "git",
|
"type": "git",
|
||||||
"url": "https://code.foss.global/push.rocks/npmextra.git"
|
"url": "git+ssh://git@gitlab.com/pushrocks/npmextra.git"
|
||||||
},
|
},
|
||||||
"author": "Lossless GmbH",
|
"author": "Lossless GmbH",
|
||||||
"license": "MIT",
|
"license": "MIT",
|
||||||
"bugs": {
|
"bugs": {
|
||||||
"url": "https://gitlab.com/pushrocks/npmextra/issues"
|
"url": "https://gitlab.com/pushrocks/npmextra/issues"
|
||||||
},
|
},
|
||||||
"homepage": "https://code.foss.global/push.rocks/npmextra",
|
"homepage": "https://gitlab.com/pushrocks/npmextra#README",
|
||||||
"dependencies": {
|
"dependencies": {
|
||||||
"@push.rocks/qenv": "^6.0.5",
|
"@push.rocks/smartfile": "^11.0.4",
|
||||||
"@push.rocks/smartfile": "^11.0.20",
|
"@push.rocks/smartjson": "^5.0.10",
|
||||||
"@push.rocks/smartjson": "^5.0.20",
|
"@push.rocks/smartlog": "^3.0.2",
|
||||||
"@push.rocks/smartlog": "^3.0.7",
|
"@push.rocks/smartpath": "^5.0.11",
|
||||||
"@push.rocks/smartpath": "^5.0.18",
|
|
||||||
"@push.rocks/smartpromise": "^4.0.2",
|
"@push.rocks/smartpromise": "^4.0.2",
|
||||||
"@push.rocks/smartrx": "^3.0.7",
|
"@push.rocks/smartrx": "^3.0.7",
|
||||||
"@push.rocks/taskbuffer": "^3.1.7",
|
"@push.rocks/taskbuffer": "^3.1.7"
|
||||||
"@tsclass/tsclass": "^4.0.59"
|
|
||||||
},
|
},
|
||||||
"devDependencies": {
|
"devDependencies": {
|
||||||
"@git.zone/tsbuild": "^2.1.80",
|
"@git.zone/tsbuild": "^2.1.66",
|
||||||
"@git.zone/tsrun": "^1.2.44",
|
"@git.zone/tsrun": "^1.2.44",
|
||||||
"@git.zone/tstest": "^1.0.90",
|
"@git.zone/tstest": "^1.0.77",
|
||||||
"@push.rocks/tapbundle": "^5.0.23",
|
"@push.rocks/tapbundle": "^5.0.15",
|
||||||
"@types/node": "^20.14.5"
|
"@types/node": "^20.11.6"
|
||||||
},
|
},
|
||||||
"files": [
|
"files": [
|
||||||
"ts/**/*",
|
"ts/**/*",
|
||||||
@ -53,22 +51,5 @@
|
|||||||
"browserslist": [
|
"browserslist": [
|
||||||
"last 1 chrome versions"
|
"last 1 chrome versions"
|
||||||
],
|
],
|
||||||
"type": "module",
|
"type": "module"
|
||||||
"keywords": [
|
|
||||||
"npm",
|
|
||||||
"configuration management",
|
|
||||||
"tool management",
|
|
||||||
"key-value store",
|
|
||||||
"project setup",
|
|
||||||
"typescript",
|
|
||||||
"environment setup",
|
|
||||||
"dependencies management",
|
|
||||||
"npm package enhancement",
|
|
||||||
"automation",
|
|
||||||
"async operations",
|
|
||||||
"app configuration",
|
|
||||||
"smart file handling",
|
|
||||||
"workflow improvement",
|
|
||||||
"persistent storage"
|
|
||||||
]
|
|
||||||
}
|
}
|
||||||
|
8278
pnpm-lock.yaml
generated
8278
pnpm-lock.yaml
generated
File diff suppressed because it is too large
Load Diff
325
readme.md
325
readme.md
@ -1,311 +1,70 @@
|
|||||||
# @push.rocks/npmextra
|
# @push.rocks/npmextra
|
||||||
A utility to enhance npm with additional configuration, tool management capabilities, and a key-value store for project setups.
|
do more with npm
|
||||||
|
|
||||||
## Install
|
## Availabililty and Links
|
||||||
To install `@push.rocks/npmextra`, use the following npm command:
|
* [npmjs.org (npm package)](https://www.npmjs.com/package/@push.rocks/npmextra)
|
||||||
|
* [gitlab.com (source)](https://gitlab.com/push.rocks/npmextra)
|
||||||
|
* [github.com (source mirror)](https://github.com/push.rocks/npmextra)
|
||||||
|
* [docs (typedoc)](https://push.rocks.gitlab.io/npmextra/)
|
||||||
|
|
||||||
```bash
|
## Status for master
|
||||||
npm install @push.rocks/npmextra --save
|
|
||||||
```
|
|
||||||
|
|
||||||
This package is available on [npm](https://www.npmjs.com/package/@push.rocks/npmextra) and can be installed into your project as a dependency to enhance npm with additional configuration and tool management capabilities.
|
Status Category | Status Badge
|
||||||
|
-- | --
|
||||||
|
GitLab Pipelines | [](https://lossless.cloud)
|
||||||
|
GitLab Pipline Test Coverage | [](https://lossless.cloud)
|
||||||
|
npm | [](https://lossless.cloud)
|
||||||
|
Snyk | [](https://lossless.cloud)
|
||||||
|
TypeScript Support | [](https://lossless.cloud)
|
||||||
|
node Support | [](https://nodejs.org/dist/latest-v10.x/docs/api/)
|
||||||
|
Code Style | [](https://lossless.cloud)
|
||||||
|
PackagePhobia (total standalone install weight) | [](https://lossless.cloud)
|
||||||
|
PackagePhobia (package size on registry) | [](https://lossless.cloud)
|
||||||
|
BundlePhobia (total size when bundled) | [](https://lossless.cloud)
|
||||||
|
|
||||||
## Usage
|
## Usage
|
||||||
`@push.rocks/npmextra` is designed to supplement npm functionalities with enhanced configuration and tool management. It facilitates the management of project configurations and tool setups in a consolidated manner, enabling a smoother workflow and maintenance process. Below are detailed use cases and examples implemented with ESM syntax and TypeScript.
|
|
||||||
|
|
||||||
### Initial Setup and Configuration
|
Use TypeScript for best in class instellisense.
|
||||||
To start using `npmextra` in your project, first include it with an import statement:
|
|
||||||
|
|
||||||
```typescript
|
## Using npmextra for managing toolconfigs
|
||||||
import { Npmextra } from '@push.rocks/npmextra';
|
|
||||||
```
|
|
||||||
|
|
||||||
Instantiate the `Npmextra` class optionally with a custom path to your project's working directory. If no path is provided, the current working directory (`process.cwd()`) is used.
|
The main purpose of npmextra is to configure different tools using one npmextra.json. This way complex setups avoid additional complexity caused by too many configuration files.
|
||||||
|
|
||||||
```typescript
|
npmextra.json
|
||||||
const npmExtraInstance = new Npmextra('/path/to/your/project');
|
|
||||||
```
|
|
||||||
|
|
||||||
### Managing Tool Configurations with `npmextra.json`
|
|
||||||
`@push.rocks/npmextra` excels in unifying tool configurations through a single `npmextra.json` file. Instead of scattering configurations across multiple files, `npmextra` enables you to define tool-specific settings within this centralized configuration file, which can then be accessed programmatically.
|
|
||||||
|
|
||||||
#### Creating and Utilizing `npmextra.json`
|
|
||||||
|
|
||||||
Create a `npmextra.json` in your project root with the following structure:
|
|
||||||
|
|
||||||
```json
|
```json
|
||||||
{
|
{
|
||||||
"toolname": {
|
"sometool": {
|
||||||
"setting1": "value1",
|
"defaultKey1": "awesomeValueFromConfig"
|
||||||
"setting2": "value2"
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
```
|
```
|
||||||
|
|
||||||
For example, to configure a hypothetical tool named `toolname`, define its settings as shown above.
|
|
||||||
|
|
||||||
#### Accessing Configuration in Your Project
|
|
||||||
|
|
||||||
With the configuration defined, you can easily access these settings in your TypeScript code as follows:
|
|
||||||
|
|
||||||
```typescript
|
```typescript
|
||||||
// Import the npmextra module
|
import { Npmextra } from 'npmextra';
|
||||||
import { Npmextra } from '@push.rocks/npmextra';
|
|
||||||
|
|
||||||
// Create an instance pointing at the current directory
|
let myNpmExtra = new Npmextra('my/path/to/cwd'); // cwd argument is optional
|
||||||
const npmExtraInstance = new Npmextra();
|
mergedData = myNpmExtra.dataFor('sometool', {
|
||||||
|
// gets merged with whatever is in the configfile
|
||||||
// Retrieve the configuration for 'toolname', merging defaults with any found in npmextra.json
|
defaultKey1: 'defaultValue1', // so this will get overwritten with "awesomeValueFromConfig"
|
||||||
const toolConfig = npmExtraInstance.dataFor<{ setting1: string, setting2: string }>('toolname', {
|
defaultKey2: 'defaultValue2', // this one will pass through unaltered
|
||||||
setting1: 'defaultValue1',
|
|
||||||
setting2: 'defaultValue2'
|
|
||||||
});
|
|
||||||
|
|
||||||
// toolConfig now contains the merged settings from npmextra.json and provided defaults
|
|
||||||
console.log(toolConfig);
|
|
||||||
```
|
|
||||||
|
|
||||||
### Key-Value Store Management
|
|
||||||
`@push.rocks/npmextra` also includes a Key-Value Store (KeyValueStore) functionality enabling persistent storage of key-value pairs between script executions.
|
|
||||||
|
|
||||||
#### Setting Up KeyValueStore
|
|
||||||
|
|
||||||
To utilize the KeyValueStore, create an instance specifying its scope (e.g., 'userHomeDir') and a unique identity for your application or tool:
|
|
||||||
|
|
||||||
```typescript
|
|
||||||
import { KeyValueStore } from '@push.rocks/npmextra';
|
|
||||||
|
|
||||||
const kvStore = new KeyValueStore<'userHomeDir'>({
|
|
||||||
typeArg: 'userHomeDir',
|
|
||||||
identityArg: 'myUniqueAppName'
|
|
||||||
});
|
});
|
||||||
```
|
```
|
||||||
|
|
||||||
You can then use the `writeKey`, `readKey`, `writeAll`, and `readAll` methods to manage your store respectively.
|
### Tools that already use the config feature of npmextra
|
||||||
|
|
||||||
#### Example: Storing and Retrieving Data
|
- [npmts](https://www.npmjs.com/package/npmts)
|
||||||
|
- [npmci](https://www.npmjs.com/package/npmci)
|
||||||
|
- [npmdocker](https://www.npmjs.com/package/npmdocker)
|
||||||
|
|
||||||
```typescript
|
## Using the KeyValueStore
|
||||||
// Write a single key-value pair
|
|
||||||
await kvStore.writeKey('username', 'johnDoe');
|
|
||||||
|
|
||||||
// Read a single key
|
## Contribution
|
||||||
const username = await kvStore.readKey('username');
|
|
||||||
console.log(username); // Outputs: johnDoe
|
|
||||||
|
|
||||||
// Write multiple key-value pairs
|
We are always happy for code contributions. If you are not the code contributing type that is ok. Still, maintaining Open Source repositories takes considerable time and thought. If you like the quality of what we do and our modules are useful to you we would appreciate a little monthly contribution: You can [contribute one time](https://lossless.link/contribute-onetime) or [contribute monthly](https://lossless.link/contribute). :)
|
||||||
await kvStore.writeAll({
|
|
||||||
email: 'john@example.com',
|
|
||||||
isAdmin: true
|
|
||||||
});
|
|
||||||
|
|
||||||
// Read all key-value pairs
|
For further information read the linked docs at the top of this readme.
|
||||||
const allData = await kvStore.readAll();
|
|
||||||
console.log(allData); // Outputs the entire store's contents
|
|
||||||
```
|
|
||||||
|
|
||||||
### Advanced Key-Value Store Management
|
## Legal
|
||||||
|
> MIT licensed | **©** [Task Venture Capital GmbH](https://task.vc)
|
||||||
In addition to basic read/write operations, `npmextra`’s `KeyValueStore` supports advanced scenarios like mandatory keys and custom file paths.
|
| By using this npm module you agree to our [privacy policy](https://lossless.gmbH/privacy)
|
||||||
|
|
||||||
#### Example: Mandatory Keys and Custom Paths
|
|
||||||
|
|
||||||
Consider a scenario where your application requires specific keys to be present in the KeyValueStore. You can define mandatory keys and use a custom path for your store like this:
|
|
||||||
|
|
||||||
```typescript
|
|
||||||
import { KeyValueStore } from '@push.rocks/npmextra';
|
|
||||||
|
|
||||||
interface CustomData {
|
|
||||||
key1: string;
|
|
||||||
key2: number;
|
|
||||||
key3?: boolean;
|
|
||||||
}
|
|
||||||
|
|
||||||
const kvStore = new KeyValueStore<CustomData>({
|
|
||||||
typeArg: 'custom',
|
|
||||||
identityArg: 'customApp',
|
|
||||||
customPath: '/custom/path/to/store.json',
|
|
||||||
mandatoryKeys: ['key1', 'key2']
|
|
||||||
});
|
|
||||||
|
|
||||||
// Ensure all mandatory keys are present
|
|
||||||
const missingKeys = await kvStore.getMissingMandatoryKeys();
|
|
||||||
if (missingKeys.length) {
|
|
||||||
console.log(`Missing mandatory keys: ${missingKeys.join(', ')}`);
|
|
||||||
}
|
|
||||||
|
|
||||||
// Use the KeyValueStore
|
|
||||||
await kvStore.writeKey('key1', 'value1');
|
|
||||||
await kvStore.writeKey('key2', 123);
|
|
||||||
|
|
||||||
const key1Value = await kvStore.readKey('key1');
|
|
||||||
const allData = await kvStore.readAll();
|
|
||||||
|
|
||||||
console.log(key1Value); // Outputs: value1
|
|
||||||
console.log(allData); // Outputs: { key1: 'value1', key2: 123 }
|
|
||||||
```
|
|
||||||
|
|
||||||
### Combining AppData and KeyValueStore
|
|
||||||
|
|
||||||
The `AppData` class extends the functionality of `KeyValueStore` by integrating environmental variables, specifying additional configurations, and providing a more structured approach to data management.
|
|
||||||
|
|
||||||
#### Example: AppData Usage
|
|
||||||
|
|
||||||
```typescript
|
|
||||||
import { AppData } from '@push.rocks/npmextra';
|
|
||||||
|
|
||||||
interface AppSettings {
|
|
||||||
settingA: string;
|
|
||||||
settingB: number;
|
|
||||||
nestedSetting: {
|
|
||||||
innerSetting: boolean;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
const appDataInstance = await AppData.createAndInit<AppSettings>({
|
|
||||||
dirPath: '/custom/path/to/appdata',
|
|
||||||
requiredKeys: ['settingA', 'settingB'],
|
|
||||||
envMapping: {
|
|
||||||
settingA: 'MY_ENV_A',
|
|
||||||
settingB: 'hard:42',
|
|
||||||
nestedSetting: {
|
|
||||||
innerSetting: 'MY_ENV_INNER'
|
|
||||||
}
|
|
||||||
}
|
|
||||||
});
|
|
||||||
|
|
||||||
const appDataKvStore = await appDataInstance.getKvStore();
|
|
||||||
|
|
||||||
// Writing values
|
|
||||||
await appDataKvStore.writeKey('settingA', 'exampleValue');
|
|
||||||
await appDataKvStore.writeKey('settingB', 100);
|
|
||||||
await appDataKvStore.writeKey('nestedSetting', { innerSetting: true });
|
|
||||||
|
|
||||||
// Reading values
|
|
||||||
const settingA = await appDataKvStore.readKey('settingA');
|
|
||||||
const allSettings = await appDataKvStore.readAll();
|
|
||||||
|
|
||||||
console.log(settingA); // Outputs: 'exampleValue'
|
|
||||||
console.log(allSettings); // Outputs: { settingA: 'exampleValue', settingB: 100, nestedSetting: { innerSetting: true } }
|
|
||||||
```
|
|
||||||
|
|
||||||
### Error Handling and Debugging
|
|
||||||
|
|
||||||
Proper error handling ensures your integrations with `npmextra` are robust and stable. Below are some strategies for error handling and debugging potential issues.
|
|
||||||
|
|
||||||
#### Example: Error Handling in KeyValueStore
|
|
||||||
|
|
||||||
```typescript
|
|
||||||
import { KeyValueStore } from '@push.rocks/npmextra';
|
|
||||||
|
|
||||||
const kvStore = new KeyValueStore('userHomeDir', 'errorHandlingApp');
|
|
||||||
|
|
||||||
try {
|
|
||||||
await kvStore.writeKey('importantKey', 'importantValue');
|
|
||||||
const value = await kvStore.readKey('importantKey');
|
|
||||||
console.log(value); // Outputs: importantValue
|
|
||||||
} catch (error) {
|
|
||||||
console.error('Error managing key-value store:', error);
|
|
||||||
}
|
|
||||||
```
|
|
||||||
|
|
||||||
#### Debugging Configuration Issues in `npmextra.json`
|
|
||||||
|
|
||||||
To debug configuration issues, you can utilize conditional logging and checks:
|
|
||||||
|
|
||||||
```typescript
|
|
||||||
import { Npmextra } from '@push.rocks/npmextra';
|
|
||||||
|
|
||||||
const npmExtraInstance = new Npmextra();
|
|
||||||
const toolConfig = npmExtraInstance.dataFor('toolname', {
|
|
||||||
configKey1: 'defaultValue1',
|
|
||||||
configKey2: 'defaultValue2'
|
|
||||||
});
|
|
||||||
|
|
||||||
if (!toolConfig.configKey1) {
|
|
||||||
console.error('configKey1 is missing in npmextra.json');
|
|
||||||
}
|
|
||||||
|
|
||||||
console.log(toolConfig);
|
|
||||||
```
|
|
||||||
|
|
||||||
### Integration Tests
|
|
||||||
|
|
||||||
Writing tests ensures that your integration with `npmextra` works as expected. Below are examples of integration tests for both `Npmextra` and `KeyValueStore`.
|
|
||||||
|
|
||||||
#### Example: Testing `Npmextra` Class
|
|
||||||
|
|
||||||
```typescript
|
|
||||||
import { expect, tap } from '@push.rocks/tapbundle';
|
|
||||||
import { Npmextra } from '@push.rocks/npmextra';
|
|
||||||
|
|
||||||
let npmExtraInstance: Npmextra;
|
|
||||||
|
|
||||||
tap.test('should create an instance of Npmextra', async () => {
|
|
||||||
npmExtraInstance = new Npmextra();
|
|
||||||
expect(npmExtraInstance).toBeInstanceOf(Npmextra);
|
|
||||||
});
|
|
||||||
|
|
||||||
tap.test('should load configuration from npmextra.json', async () => {
|
|
||||||
const config = npmExtraInstance.dataFor('toolname', {
|
|
||||||
defaultKey1: 'defaultValue1',
|
|
||||||
});
|
|
||||||
expect(config).toHaveProperty('defaultKey1');
|
|
||||||
});
|
|
||||||
|
|
||||||
tap.start();
|
|
||||||
```
|
|
||||||
|
|
||||||
#### Example: Testing `KeyValueStore` Class
|
|
||||||
|
|
||||||
```typescript
|
|
||||||
import { expect, tap } from '@push.rocks/tapbundle';
|
|
||||||
import { KeyValueStore } from '@push.rocks/npmextra';
|
|
||||||
|
|
||||||
let kvStore: KeyValueStore<{ key1: string, key2: number }>;
|
|
||||||
|
|
||||||
tap.test('should create a KeyValueStore instance', async () => {
|
|
||||||
kvStore = new KeyValueStore({
|
|
||||||
typeArg: 'userHomeDir',
|
|
||||||
identityArg: 'testApp'
|
|
||||||
});
|
|
||||||
expect(kvStore).toBeInstanceOf(KeyValueStore);
|
|
||||||
});
|
|
||||||
|
|
||||||
tap.test('should write and read back a value', async () => {
|
|
||||||
await kvStore.writeKey('key1', 'value1');
|
|
||||||
const result = await kvStore.readKey('key1');
|
|
||||||
expect(result).toEqual('value1');
|
|
||||||
});
|
|
||||||
|
|
||||||
tap.test('should write and read back multiple values', async () => {
|
|
||||||
await kvStore.writeAll({ key1: 'updatedValue1', key2: 2 });
|
|
||||||
const result = await kvStore.readAll();
|
|
||||||
expect(result).toEqual({ key1: 'updatedValue1', key2: 2 });
|
|
||||||
});
|
|
||||||
|
|
||||||
tap.start();
|
|
||||||
```
|
|
||||||
|
|
||||||
### Summary
|
|
||||||
|
|
||||||
By centralizing configuration management and offering a versatile key-value store, `@push.rocks/npmextra` significantly simplifies the setup and management of tools and settings in modern JavaScript and TypeScript projects. Whether you're managing project-wide configurations or need persistent storage for key-value pairs, `npmextra` provides an efficient and streamlined solution. Leveraging these robust features will ensure your project is well-configured and maintainable.
|
|
||||||
|
|
||||||
## License and Legal Information
|
|
||||||
|
|
||||||
This repository contains open-source code that is licensed under the MIT License. A copy of the MIT License can be found in the [license](license) file within this repository.
|
|
||||||
|
|
||||||
**Please note:** The MIT License does not grant permission to use the trade names, trademarks, service marks, or product names of the project, except as required for reasonable and customary use in describing the origin of the work and reproducing the content of the NOTICE file.
|
|
||||||
|
|
||||||
### Trademarks
|
|
||||||
|
|
||||||
This project is owned and maintained by Task Venture Capital GmbH. The names and logos associated with Task Venture Capital GmbH and any related products or services are trademarks of Task Venture Capital GmbH and are not included within the scope of the MIT license granted herein. Use of these trademarks must comply with Task Venture Capital GmbH's Trademark Guidelines, and any usage must be approved in writing by Task Venture Capital GmbH.
|
|
||||||
|
|
||||||
### Company Information
|
|
||||||
|
|
||||||
Task Venture Capital GmbH
|
|
||||||
Registered at District court Bremen HRB 35230 HB, Germany
|
|
||||||
|
|
||||||
For any legal inquiries or if you require further information, please contact us via email at hello@task.vc.
|
|
||||||
|
|
||||||
By using this repository, you acknowledge that you have read this section, agree to comply with its terms, and understand that the licensing of the code does not imply endorsement by Task Venture Capital GmbH of any derivative works.
|
|
||||||
|
@ -1,27 +0,0 @@
|
|||||||
import { expect, tap } from '@push.rocks/tapbundle';
|
|
||||||
import path = require('path');
|
|
||||||
|
|
||||||
// module to test
|
|
||||||
import * as npmextra from '../ts/index.js';
|
|
||||||
|
|
||||||
interface ITestOptions {
|
|
||||||
hi: string;
|
|
||||||
deep: {
|
|
||||||
deep1: string;
|
|
||||||
deep2: string;
|
|
||||||
};
|
|
||||||
}
|
|
||||||
|
|
||||||
let testAppdata: npmextra.AppData<ITestOptions>;
|
|
||||||
|
|
||||||
tap.test('should create a valid AppData', async () => {
|
|
||||||
testAppdata = new npmextra.AppData<ITestOptions>({
|
|
||||||
envMapping: {
|
|
||||||
deep: {
|
|
||||||
deep1: '',
|
|
||||||
},
|
|
||||||
},
|
|
||||||
});
|
|
||||||
});
|
|
||||||
|
|
||||||
export default tap.start();
|
|
@ -2,14 +2,10 @@ import { expect, tap } from '@push.rocks/tapbundle';
|
|||||||
|
|
||||||
import * as npmextra from '../ts/index.js';
|
import * as npmextra from '../ts/index.js';
|
||||||
|
|
||||||
let myKeyValueStore: npmextra.KeyValueStore<any>;
|
let myKeyValueStore: npmextra.KeyValueStore;
|
||||||
|
|
||||||
tap.test('should create a keyValueStore', async () => {
|
tap.test('should create a keyValueStore', async () => {
|
||||||
myKeyValueStore = new npmextra.KeyValueStore<any>({
|
myKeyValueStore = new npmextra.KeyValueStore('custom', 'test', 'test/somekv.json');
|
||||||
typeArg: 'custom',
|
|
||||||
identityArg: 'test',
|
|
||||||
customPath: 'test/somekv.json',
|
|
||||||
});
|
|
||||||
expect(myKeyValueStore).toBeInstanceOf(npmextra.KeyValueStore);
|
expect(myKeyValueStore).toBeInstanceOf(npmextra.KeyValueStore);
|
||||||
});
|
});
|
||||||
|
|
||||||
|
@ -1,8 +1,8 @@
|
|||||||
/**
|
/**
|
||||||
* autocreated commitinfo by @push.rocks/commitinfo
|
* autocreated commitinfo by @pushrocks/commitinfo
|
||||||
*/
|
*/
|
||||||
export const commitinfo = {
|
export const commitinfo = {
|
||||||
name: '@push.rocks/npmextra',
|
name: '@push.rocks/npmextra',
|
||||||
version: '5.1.2',
|
version: '4.0.12',
|
||||||
description: 'A utility to enhance npm with additional configuration, tool management capabilities, and a key-value store for project setups.'
|
description: 'do more with npm'
|
||||||
}
|
}
|
||||||
|
@ -2,43 +2,29 @@ import * as plugins from './npmextra.plugins.js';
|
|||||||
import * as paths from './npmextra.paths.js';
|
import * as paths from './npmextra.paths.js';
|
||||||
import { KeyValueStore } from './npmextra.classes.keyvaluestore.js';
|
import { KeyValueStore } from './npmextra.classes.keyvaluestore.js';
|
||||||
|
|
||||||
export interface IAppDataOptions<T = any> {
|
export interface IAppDataOptions {
|
||||||
dirPath?: string;
|
dirPath?: string;
|
||||||
requiredKeys?: Array<keyof T>;
|
requiredKeys?: string[];
|
||||||
|
|
||||||
/**
|
|
||||||
* wether keys should be persisted on disk or not
|
|
||||||
*/
|
|
||||||
ephermal?: boolean;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* kvStoreKey: 'MY_ENV_VAR'
|
|
||||||
*/
|
|
||||||
envMapping?: plugins.tsclass.typeFest.PartialDeep<T>;
|
|
||||||
overwriteObject?: plugins.tsclass.typeFest.PartialDeep<T>;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
export class AppData<T = any> {
|
export class AppData {
|
||||||
/**
|
/**
|
||||||
* creates appdata. If no pathArg is given, data will be stored here:
|
* creates appdata. If no pathArg is given, data will be stored here:
|
||||||
* ${PWD}/.nogit/appdata
|
* ${PWD}/.nogit/appdata
|
||||||
* @param pathArg
|
* @param pathArg
|
||||||
* @returns
|
* @returns
|
||||||
*/
|
*/
|
||||||
public static async createAndInit<T = any>(
|
public static async createAndInit(optionsArg: IAppDataOptions = {}) {
|
||||||
optionsArg: IAppDataOptions<T> = {}
|
const appData = new AppData(optionsArg);
|
||||||
): Promise<AppData<T>> {
|
|
||||||
const appData = new AppData<T>(optionsArg);
|
|
||||||
await appData.readyDeferred.promise;
|
await appData.readyDeferred.promise;
|
||||||
return appData;
|
return appData;
|
||||||
}
|
}
|
||||||
|
|
||||||
// instance
|
// instance
|
||||||
public readyDeferred = plugins.smartpromise.defer<void>();
|
public readyDeferred = plugins.smartpromise.defer();
|
||||||
public options: IAppDataOptions<T>;
|
public options: IAppDataOptions;
|
||||||
private kvStore: KeyValueStore<T>;
|
private kvStore: KeyValueStore;
|
||||||
|
constructor(optionsArg: IAppDataOptions = {}) {
|
||||||
constructor(optionsArg: IAppDataOptions<T> = {}) {
|
|
||||||
this.options = optionsArg;
|
this.options = optionsArg;
|
||||||
this.init();
|
this.init();
|
||||||
}
|
}
|
||||||
@ -48,7 +34,7 @@ export class AppData<T = any> {
|
|||||||
* @param pathArg
|
* @param pathArg
|
||||||
*/
|
*/
|
||||||
private async init(pathArg?: string) {
|
private async init(pathArg?: string) {
|
||||||
if (this.options.dirPath || this.options.ephermal) {
|
if (this.options.dirPath) {
|
||||||
// ok, nothing to do here;
|
// ok, nothing to do here;
|
||||||
} else {
|
} else {
|
||||||
const appDataDir = '/app/data';
|
const appDataDir = '/app/data';
|
||||||
@ -65,155 +51,25 @@ export class AppData<T = any> {
|
|||||||
this.options.dirPath = nogitAppData;
|
this.options.dirPath = nogitAppData;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
this.kvStore = new KeyValueStore('custom', 'appkv', this.options.dirPath, this.options.requiredKeys);
|
||||||
this.kvStore = new KeyValueStore<T>({
|
|
||||||
typeArg: this.options.ephermal ? 'ephemeral' : 'custom',
|
|
||||||
identityArg: 'appkv',
|
|
||||||
customPath: this.options.dirPath,
|
|
||||||
mandatoryKeys: this.options.requiredKeys as Array<keyof T>,
|
|
||||||
});
|
|
||||||
|
|
||||||
if (this.options.envMapping) {
|
|
||||||
const qenvInstance = new plugins.qenv.Qenv(
|
|
||||||
process.cwd(),
|
|
||||||
plugins.path.join(process.cwd(), '.nogit')
|
|
||||||
);
|
|
||||||
|
|
||||||
// Recursive function to handle nested objects, now includes key parameter
|
|
||||||
const processEnvMapping = async (
|
|
||||||
key: keyof T,
|
|
||||||
mappingValue: any,
|
|
||||||
parentKey: keyof T | '' = ''
|
|
||||||
): Promise<any> => {
|
|
||||||
if (typeof mappingValue === 'string') {
|
|
||||||
let envValue: string | boolean | T[keyof T];
|
|
||||||
let convert: 'none' | 'json' | 'base64' | 'boolean' = 'none';
|
|
||||||
switch (true) {
|
|
||||||
case mappingValue.startsWith('hard:'):
|
|
||||||
envValue = mappingValue.replace('hard:', '') as T[keyof T];
|
|
||||||
break;
|
|
||||||
case mappingValue.startsWith('hard_boolean:'):
|
|
||||||
envValue = mappingValue.replace('hard_boolean:', '') === 'true';
|
|
||||||
convert = 'boolean';
|
|
||||||
break;
|
|
||||||
case mappingValue.startsWith('hard_json:'):
|
|
||||||
envValue = JSON.parse(mappingValue.replace('hard_json:', '')) as T[keyof T];
|
|
||||||
convert = 'json';
|
|
||||||
break;
|
|
||||||
case mappingValue.startsWith('hard_base64:'):
|
|
||||||
envValue = Buffer.from(
|
|
||||||
mappingValue.replace('hard_base64:', ''),
|
|
||||||
'base64'
|
|
||||||
).toString() as T[keyof T];
|
|
||||||
convert = 'base64';
|
|
||||||
break;
|
|
||||||
case mappingValue.startsWith('boolean:'):
|
|
||||||
envValue = (await qenvInstance.getEnvVarOnDemand(
|
|
||||||
mappingValue.replace('boolean:', '')
|
|
||||||
)) as T[keyof T];
|
|
||||||
convert = 'boolean';
|
|
||||||
break;
|
|
||||||
case mappingValue.startsWith('json:'):
|
|
||||||
envValue = (await qenvInstance.getEnvVarOnDemand(
|
|
||||||
mappingValue.replace('json:', '')
|
|
||||||
)) as T[keyof T];
|
|
||||||
convert = 'json';
|
|
||||||
break;
|
|
||||||
case mappingValue.startsWith('base64:'):
|
|
||||||
envValue = (await qenvInstance.getEnvVarOnDemand(
|
|
||||||
mappingValue.replace('base64:', '')
|
|
||||||
)) as T[keyof T];
|
|
||||||
convert = 'base64';
|
|
||||||
break;
|
|
||||||
default:
|
|
||||||
envValue = (await qenvInstance.getEnvVarOnDemand(mappingValue)) as T[keyof T];
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
|
|
||||||
// lets format the env value
|
|
||||||
if (envValue) {
|
|
||||||
if (typeof envValue === 'string' && convert === 'boolean') {
|
|
||||||
envValue = envValue === 'true';
|
|
||||||
}
|
|
||||||
if (
|
|
||||||
typeof envValue === 'string' &&
|
|
||||||
(mappingValue.endsWith('_JSON') || convert === 'json')
|
|
||||||
) {
|
|
||||||
envValue = JSON.parse(envValue as string) as T[keyof T];
|
|
||||||
}
|
|
||||||
if (
|
|
||||||
typeof envValue === 'string' &&
|
|
||||||
(mappingValue.endsWith('_BASE64') || convert === 'base64')
|
|
||||||
) {
|
|
||||||
envValue = Buffer.from(envValue as string, 'base64').toString();
|
|
||||||
}
|
|
||||||
if (!parentKey) {
|
|
||||||
await this.kvStore.writeKey(key, envValue as any);
|
|
||||||
} else {
|
|
||||||
return envValue;
|
|
||||||
}
|
|
||||||
} else {
|
|
||||||
return undefined;
|
|
||||||
}
|
|
||||||
} else if (typeof mappingValue === 'object' && mappingValue !== null) {
|
|
||||||
const resultObject: Partial<T> = {};
|
|
||||||
for (const innerKey in mappingValue) {
|
|
||||||
const nestedValue = mappingValue[innerKey];
|
|
||||||
// For nested objects, call recursively but do not immediately write to kvStore
|
|
||||||
const nestedResult = await processEnvMapping(innerKey as keyof T, nestedValue, key);
|
|
||||||
resultObject[innerKey as keyof T] = nestedResult;
|
|
||||||
}
|
|
||||||
if (parentKey === '') {
|
|
||||||
// Only write to kvStore if at the top level
|
|
||||||
await this.kvStore.writeKey(key, resultObject as T[keyof T]);
|
|
||||||
} else {
|
|
||||||
// For nested objects, return the constructed object instead of writing to kvStore
|
|
||||||
return resultObject;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
||||||
for (const key in this.options.envMapping) {
|
|
||||||
await processEnvMapping(key as keyof T, this.options.envMapping[key]);
|
|
||||||
}
|
|
||||||
|
|
||||||
if (this.options.overwriteObject) {
|
|
||||||
for (const key of Object.keys(this.options.overwriteObject)) {
|
|
||||||
console.log(`-> heads up: overwriting key ${key} from options.overwriteObject`);
|
|
||||||
await this.kvStore.writeKey(key as keyof T, this.options.overwriteObject[key]);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
this.readyDeferred.resolve();
|
this.readyDeferred.resolve();
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* returns a kvstore that resides in appdata
|
* returns a kvtore that resides in appdata
|
||||||
*/
|
*/
|
||||||
public async getKvStore(): Promise<KeyValueStore<T>> {
|
public async getKvStore() {
|
||||||
await this.readyDeferred.promise;
|
await this.readyDeferred.promise;
|
||||||
return this.kvStore;
|
return this.kvStore;
|
||||||
}
|
}
|
||||||
|
|
||||||
public async logMissingKeys(): Promise<Array<keyof T>> {
|
public async logMissingKeys() {
|
||||||
const kvStore = await this.getKvStore();
|
const kvStore = await this.getKvStore();
|
||||||
const missingMandatoryKeys = await kvStore.getMissingMandatoryKeys();
|
const missingMandatoryKeys = kvStore.getMissingMandatoryKeys();
|
||||||
if (missingMandatoryKeys.length > 0) {
|
if (missingMandatoryKeys.length > 0) {
|
||||||
console.log(
|
console.log(`The following mandatory keys are missing in the appdata:\n -> ${missingMandatoryKeys.join(',\n -> ')}`);
|
||||||
`The following mandatory keys are missing in the appdata:\n -> ${missingMandatoryKeys.join(
|
|
||||||
',\n -> '
|
|
||||||
)}`
|
|
||||||
);
|
|
||||||
} else {
|
} else {
|
||||||
console.log('All mandatory keys are present in the appdata');
|
console.log('All mandatory keys are present in the appdata');
|
||||||
}
|
}
|
||||||
return missingMandatoryKeys;
|
|
||||||
}
|
|
||||||
|
|
||||||
public async waitForAndGetKey<K extends keyof T>(keyArg: K): Promise<T[K] | undefined> {
|
|
||||||
await this.readyDeferred.promise;
|
|
||||||
await this.kvStore.waitForKeysPresent([keyArg]);
|
|
||||||
return this.kvStore.readKey(keyArg);
|
|
||||||
}
|
}
|
||||||
}
|
}
|
@ -3,23 +3,16 @@ import * as paths from './npmextra.paths.js';
|
|||||||
|
|
||||||
import { Task } from '@push.rocks/taskbuffer';
|
import { Task } from '@push.rocks/taskbuffer';
|
||||||
|
|
||||||
export type TKeyValueStore = 'custom' | 'userHomeDir' | 'ephemeral';
|
export type TKeyValueStore = 'custom' | 'userHomeDir';
|
||||||
|
|
||||||
export interface IKvStoreConstructorOptions<T> {
|
|
||||||
typeArg: TKeyValueStore;
|
|
||||||
identityArg: string;
|
|
||||||
customPath?: string;
|
|
||||||
mandatoryKeys?: Array<keyof T>;
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* kvStore is a simple key value store to store data about projects between runs
|
* kvStore is a simple key value store to store data about projects between runs
|
||||||
*/
|
*/
|
||||||
export class KeyValueStore<T = any> {
|
export class KeyValueStore {
|
||||||
private dataObject: Partial<T> = {};
|
private dataObject: any = {};
|
||||||
private deletedObject: Partial<T> = {};
|
private deletedObject: any = {};
|
||||||
private mandatoryKeys: Set<keyof T> = new Set();
|
private mandatoryKeys: Set<string> = new Set();
|
||||||
public changeSubject = new plugins.smartrx.rxjs.Subject<Partial<T>>();
|
public changeSubject = new plugins.smartrx.rxjs.Subject();
|
||||||
|
|
||||||
private storedStateString: string = '';
|
private storedStateString: string = '';
|
||||||
public syncTask = new Task({
|
public syncTask = new Task({
|
||||||
@ -28,12 +21,12 @@ export class KeyValueStore<T = any> {
|
|||||||
bufferMax: 1,
|
bufferMax: 1,
|
||||||
execDelay: 0,
|
execDelay: 0,
|
||||||
taskFunction: async () => {
|
taskFunction: async () => {
|
||||||
if (this.type !== 'ephemeral') {
|
|
||||||
this.dataObject = {
|
this.dataObject = {
|
||||||
...plugins.smartfile.fs.toObjectSync(this.filePath),
|
...plugins.smartfile.fs.toObjectSync(this.filePath),
|
||||||
...this.dataObject,
|
...this.dataObject,
|
||||||
};
|
};
|
||||||
for (const key of Object.keys(this.deletedObject) as Array<keyof T>) {
|
for (const key of Object.keys(this.deletedObject)) {
|
||||||
delete this.dataObject[key];
|
delete this.dataObject[key];
|
||||||
}
|
}
|
||||||
this.deletedObject = {};
|
this.deletedObject = {};
|
||||||
@ -41,7 +34,6 @@ export class KeyValueStore<T = any> {
|
|||||||
plugins.smartjson.stringifyPretty(this.dataObject),
|
plugins.smartjson.stringifyPretty(this.dataObject),
|
||||||
this.filePath
|
this.filePath
|
||||||
);
|
);
|
||||||
}
|
|
||||||
const newStateString = plugins.smartjson.stringify(this.dataObject);
|
const newStateString = plugins.smartjson.stringify(this.dataObject);
|
||||||
|
|
||||||
// change detection
|
// change detection
|
||||||
@ -56,10 +48,6 @@ export class KeyValueStore<T = any> {
|
|||||||
* computes the identity and filePath
|
* computes the identity and filePath
|
||||||
*/
|
*/
|
||||||
private initFilePath = () => {
|
private initFilePath = () => {
|
||||||
if (this.type === 'ephemeral') {
|
|
||||||
// No file path is needed for ephemeral type
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
if (this.customPath) {
|
if (this.customPath) {
|
||||||
// Use custom path if provided
|
// Use custom path if provided
|
||||||
const absolutePath = plugins.smartpath.transform.makeAbsolute(this.customPath, paths.cwd);
|
const absolutePath = plugins.smartpath.transform.makeAbsolute(this.customPath, paths.cwd);
|
||||||
@ -85,7 +73,7 @@ export class KeyValueStore<T = any> {
|
|||||||
// if no custom path is provided, try to store at home directory
|
// if no custom path is provided, try to store at home directory
|
||||||
public type: TKeyValueStore;
|
public type: TKeyValueStore;
|
||||||
public identity: string;
|
public identity: string;
|
||||||
public filePath?: string;
|
public filePath: string;
|
||||||
private customPath?: string; // Optionally allow custom path
|
private customPath?: string; // Optionally allow custom path
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@ -94,26 +82,26 @@ export class KeyValueStore<T = any> {
|
|||||||
* @param identityArg
|
* @param identityArg
|
||||||
* @param customPath Optional custom path for the keyValue store
|
* @param customPath Optional custom path for the keyValue store
|
||||||
*/
|
*/
|
||||||
constructor(optionsArg: IKvStoreConstructorOptions<T>) {
|
constructor(typeArg: TKeyValueStore, identityArg: string, customPath?: string, mandatoryKeys?: string[]) {
|
||||||
if (optionsArg.customPath && optionsArg.typeArg !== 'custom') {
|
if (customPath && typeArg !== 'custom') {
|
||||||
throw new Error('customPath can only be provided if typeArg is custom');
|
throw new Error('customPath can only be provided if typeArg is custom');
|
||||||
}
|
}
|
||||||
if (optionsArg.typeArg === 'custom' && !optionsArg.customPath) {
|
if (typeArg === 'custom' && !customPath) {
|
||||||
throw new Error('customPath must be provided if typeArg is custom');
|
throw new Error('customPath must be provided if typeArg is custom');
|
||||||
}
|
}
|
||||||
this.type = optionsArg.typeArg;
|
this.type = typeArg;
|
||||||
this.identity = optionsArg.identityArg;
|
this.identity = identityArg;
|
||||||
this.customPath = optionsArg.customPath; // Store custom path if provided
|
this.customPath = customPath; // Store custom path if provided
|
||||||
this.initFilePath();
|
this.initFilePath();
|
||||||
if (optionsArg.mandatoryKeys) {
|
if (mandatoryKeys) {
|
||||||
this.setMandatoryKeys(optionsArg.mandatoryKeys);
|
this.setMandatoryKeys(mandatoryKeys);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* reads all keyValue pairs at once and returns them
|
* reads all keyValue pairs at once and returns them
|
||||||
*/
|
*/
|
||||||
public async readAll(): Promise<Partial<T>> {
|
public async readAll() {
|
||||||
await this.syncTask.trigger();
|
await this.syncTask.trigger();
|
||||||
return this.dataObject;
|
return this.dataObject;
|
||||||
}
|
}
|
||||||
@ -121,21 +109,21 @@ export class KeyValueStore<T = any> {
|
|||||||
/**
|
/**
|
||||||
* reads a keyValueFile from disk
|
* reads a keyValueFile from disk
|
||||||
*/
|
*/
|
||||||
public async readKey<K extends keyof T>(keyArg: K): Promise<T[K]> {
|
public async readKey(keyArg: string) {
|
||||||
await this.syncTask.trigger();
|
await this.syncTask.trigger();
|
||||||
return this.dataObject[keyArg] as T[K];
|
return this.dataObject[keyArg];
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* writes a specific key to the keyValueStore
|
* writes a specific key to the keyValueStore
|
||||||
*/
|
*/
|
||||||
public async writeKey<K extends keyof T>(keyArg: K, valueArg: T[K]): Promise<void> {
|
public async writeKey(keyArg: string, valueArg: any) {
|
||||||
await this.writeAll({
|
await this.writeAll({
|
||||||
[keyArg]: valueArg,
|
[keyArg]: valueArg,
|
||||||
} as unknown as Partial<T>);
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
public async deleteKey<K extends keyof T>(keyArg: K): Promise<void> {
|
public async deleteKey(keyArg: string) {
|
||||||
this.deletedObject[keyArg] = this.dataObject[keyArg];
|
this.deletedObject[keyArg] = this.dataObject[keyArg];
|
||||||
await this.syncTask.trigger();
|
await this.syncTask.trigger();
|
||||||
}
|
}
|
||||||
@ -143,7 +131,7 @@ export class KeyValueStore<T = any> {
|
|||||||
/**
|
/**
|
||||||
* writes all keyValue pairs in the object argument
|
* writes all keyValue pairs in the object argument
|
||||||
*/
|
*/
|
||||||
public async writeAll(keyValueObject: Partial<T>): Promise<void> {
|
public async writeAll(keyValueObject: { [key: string]: any }) {
|
||||||
this.dataObject = { ...this.dataObject, ...keyValueObject };
|
this.dataObject = { ...this.dataObject, ...keyValueObject };
|
||||||
await this.syncTask.trigger();
|
await this.syncTask.trigger();
|
||||||
}
|
}
|
||||||
@ -151,21 +139,19 @@ export class KeyValueStore<T = any> {
|
|||||||
/**
|
/**
|
||||||
* wipes a key value store from disk
|
* wipes a key value store from disk
|
||||||
*/
|
*/
|
||||||
public async wipe(): Promise<void> {
|
public async wipe() {
|
||||||
this.dataObject = {};
|
this.dataObject = {};
|
||||||
if (this.type !== 'ephemeral') {
|
|
||||||
await plugins.smartfile.fs.remove(this.filePath);
|
await plugins.smartfile.fs.remove(this.filePath);
|
||||||
}
|
}
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* resets the KeyValueStore to the initial state by syncing first, deleting all keys, and then triggering a sync again
|
* resets the KeyValueStore to the initial state by syncing first, deleting all keys, and then triggering a sync again
|
||||||
*/
|
*/
|
||||||
public async reset(): Promise<void> {
|
public async reset() {
|
||||||
await this.syncTask.trigger(); // Sync to get the latest state
|
await this.syncTask.trigger(); // Sync to get the latest state
|
||||||
|
|
||||||
// Delete all keys from the dataObject and add them to deletedObject
|
// Delete all keys from the dataObject and add them to deletedObject
|
||||||
for (const key of Object.keys(this.dataObject) as Array<keyof T>) {
|
for (const key of Object.keys(this.dataObject)) {
|
||||||
this.deletedObject[key] = this.dataObject[key];
|
this.deletedObject[key] = this.dataObject[key];
|
||||||
delete this.dataObject[key];
|
delete this.dataObject[key];
|
||||||
}
|
}
|
||||||
@ -173,21 +159,20 @@ export class KeyValueStore<T = any> {
|
|||||||
await this.syncTask.trigger(); // Sync again to reflect the deletion
|
await this.syncTask.trigger(); // Sync again to reflect the deletion
|
||||||
}
|
}
|
||||||
|
|
||||||
private setMandatoryKeys(keys: Array<keyof T>) {
|
private setMandatoryKeys(keys: string[]) {
|
||||||
keys.forEach(key => this.mandatoryKeys.add(key));
|
keys.forEach(key => this.mandatoryKeys.add(key));
|
||||||
}
|
}
|
||||||
|
|
||||||
public async getMissingMandatoryKeys(): Promise<Array<keyof T>> {
|
public getMissingMandatoryKeys(): string[] {
|
||||||
await this.readAll();
|
|
||||||
return Array.from(this.mandatoryKeys).filter(key => !(key in this.dataObject));
|
return Array.from(this.mandatoryKeys).filter(key => !(key in this.dataObject));
|
||||||
}
|
}
|
||||||
|
|
||||||
public async waitForKeysPresent<K extends keyof T>(keysArg: K[]): Promise<void> {
|
public async waitForKeysPresent(keysArg: []): Promise<void> {
|
||||||
const missingKeys = keysArg.filter(keyArg => !this.dataObject[keyArg]);
|
const missingKeys = keysArg.filter(keyArg => !this.dataObject[keyArg]);
|
||||||
if (missingKeys.length === 0) {
|
if (missingKeys.length === 0) {
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
return new Promise<void>((resolve, reject) => {
|
return new Promise((resolve, reject) => {
|
||||||
const subscription = this.changeSubject.subscribe(() => {
|
const subscription = this.changeSubject.subscribe(() => {
|
||||||
const missingKeys = keysArg.filter(keyArg => !this.dataObject[keyArg]);
|
const missingKeys = keysArg.filter(keyArg => !this.dataObject[keyArg]);
|
||||||
if (missingKeys.length === 0) {
|
if (missingKeys.length === 0) {
|
||||||
@ -197,9 +182,4 @@ export class KeyValueStore<T = any> {
|
|||||||
});
|
});
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
public async waitForAndGetKey<K extends keyof T>(keyArg: K): Promise<T[K] | undefined> {
|
|
||||||
await this.waitForKeysPresent([keyArg]);
|
|
||||||
return this.readKey(keyArg);
|
|
||||||
}
|
|
||||||
}
|
}
|
@ -1,10 +1,3 @@
|
|||||||
import * as tsclass from '@tsclass/tsclass';
|
|
||||||
|
|
||||||
export {
|
|
||||||
tsclass
|
|
||||||
}
|
|
||||||
|
|
||||||
import * as qenv from '@push.rocks/qenv';
|
|
||||||
import * as smartlog from '@push.rocks/smartlog';
|
import * as smartlog from '@push.rocks/smartlog';
|
||||||
import * as path from 'path';
|
import * as path from 'path';
|
||||||
import * as smartfile from '@push.rocks/smartfile';
|
import * as smartfile from '@push.rocks/smartfile';
|
||||||
@ -14,4 +7,4 @@ import * as smartpromise from '@push.rocks/smartpromise';
|
|||||||
import * as smartrx from '@push.rocks/smartrx';
|
import * as smartrx from '@push.rocks/smartrx';
|
||||||
import * as taskbuffer from '@push.rocks/taskbuffer';
|
import * as taskbuffer from '@push.rocks/taskbuffer';
|
||||||
|
|
||||||
export { qenv, smartlog, path, smartfile, smartjson, smartpath, smartpromise, smartrx, taskbuffer };
|
export { smartlog, path, smartfile, smartjson, smartpath, smartpromise, smartrx, taskbuffer };
|
||||||
|
Loading…
x
Reference in New Issue
Block a user