Compare commits
12 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 026f2acc89 | |||
| 1cd0f09598 | |||
| d254f58a05 | |||
| c5e7b6f982 | |||
| d30c9619c5 | |||
| 7344ae2db3 | |||
| 3b29a150a8 | |||
| 59186d84a9 | |||
| 7fab4e5dd0 | |||
| 0dbaa1bc5d | |||
| 8b37ebc8f9 | |||
| 5d757207c8 |
Binary file not shown.
@@ -1,44 +0,0 @@
|
|||||||
# Code Style & Conventions
|
|
||||||
|
|
||||||
## TypeScript Standards
|
|
||||||
- **Target**: ES2022
|
|
||||||
- **Module System**: ESM with NodeNext resolution
|
|
||||||
- **Decorators**: Experimental decorators enabled
|
|
||||||
- **Strict Mode**: Implied through TypeScript configuration
|
|
||||||
|
|
||||||
## Naming Conventions
|
|
||||||
- **Interfaces**: Prefix with `I` (e.g., `IUserData`, `IConfig`)
|
|
||||||
- **Types**: Prefix with `T` (e.g., `TResponseType`, `TQueryResult`)
|
|
||||||
- **Classes**: PascalCase (e.g., `SmartdataDb`, `SmartDataDbDoc`)
|
|
||||||
- **Files**: All lowercase (e.g., `classes.doc.ts`, `plugins.ts`)
|
|
||||||
- **Methods**: camelCase (e.g., `findOne`, `saveToDb`)
|
|
||||||
|
|
||||||
## Import Patterns
|
|
||||||
- All external dependencies imported in `ts/plugins.ts`
|
|
||||||
- Reference as `plugins.moduleName.method()`
|
|
||||||
- Use full import paths for internal modules
|
|
||||||
- Maintain ESM syntax throughout
|
|
||||||
|
|
||||||
## Class Structure
|
|
||||||
- Use decorators for MongoDB document definitions
|
|
||||||
- Extend base classes (SmartDataDbDoc, SmartDataDbCollection)
|
|
||||||
- Static methods for factory patterns
|
|
||||||
- Instance methods for document operations
|
|
||||||
|
|
||||||
## Async Patterns
|
|
||||||
- Preserve Promise-based patterns
|
|
||||||
- Use async/await for clarity
|
|
||||||
- Handle errors appropriately
|
|
||||||
- Return typed Promises
|
|
||||||
|
|
||||||
## MongoDB Specifics
|
|
||||||
- Use `@unify()` decorator for unique fields
|
|
||||||
- Use `@svDb()` decorator for database fields
|
|
||||||
- Implement proper serialization/deserialization
|
|
||||||
- Type-safe query construction with DeepQuery<T>
|
|
||||||
|
|
||||||
## Testing Patterns
|
|
||||||
- Import from `@git.zone/tstest/tapbundle`
|
|
||||||
- End test files with `export default tap.start()`
|
|
||||||
- Use descriptive test names
|
|
||||||
- Cover edge cases and error conditions
|
|
||||||
@@ -1,37 +0,0 @@
|
|||||||
# Project Overview: @push.rocks/smartdata
|
|
||||||
|
|
||||||
## Purpose
|
|
||||||
An advanced TypeScript-first MongoDB wrapper library providing enterprise-grade features for distributed systems, real-time data synchronization, and easy data management.
|
|
||||||
|
|
||||||
## Tech Stack
|
|
||||||
- **Language**: TypeScript (ES2022 target)
|
|
||||||
- **Runtime**: Node.js >= 16.x
|
|
||||||
- **Database**: MongoDB >= 4.4
|
|
||||||
- **Build System**: tsbuild
|
|
||||||
- **Test Framework**: tstest with tapbundle
|
|
||||||
- **Package Manager**: pnpm (v10.7.0)
|
|
||||||
- **Module System**: ESM (ES Modules)
|
|
||||||
|
|
||||||
## Key Features
|
|
||||||
- Type-safe MongoDB integration with decorators
|
|
||||||
- Document management with automatic timestamps
|
|
||||||
- EasyStore for key-value storage
|
|
||||||
- Distributed coordination with leader election
|
|
||||||
- Real-time data sync with RxJS watchers
|
|
||||||
- Deep query type safety
|
|
||||||
- Enhanced cursor API
|
|
||||||
- Powerful search capabilities
|
|
||||||
|
|
||||||
## Project Structure
|
|
||||||
- **ts/**: Main TypeScript source code
|
|
||||||
- Core classes for DB, Collections, Documents, Cursors
|
|
||||||
- Distributed coordinator, EasyStore, Watchers
|
|
||||||
- Lucene adapter for search functionality
|
|
||||||
- **test/**: Test files using tstest framework
|
|
||||||
- **dist_ts/**: Compiled JavaScript output
|
|
||||||
|
|
||||||
## Key Dependencies
|
|
||||||
- MongoDB driver (v6.18.0)
|
|
||||||
- @push.rocks ecosystem packages
|
|
||||||
- @tsclass/tsclass for decorators
|
|
||||||
- RxJS for reactive programming
|
|
||||||
@@ -1,35 +0,0 @@
|
|||||||
# Suggested Commands for @push.rocks/smartdata
|
|
||||||
|
|
||||||
## Build & Development
|
|
||||||
- `pnpm build` - Build the TypeScript project with web support
|
|
||||||
- `pnpm buildDocs` - Generate documentation using tsdoc
|
|
||||||
- `tsbuild --web --allowimplicitany` - Direct build command
|
|
||||||
|
|
||||||
## Testing
|
|
||||||
- `pnpm test` - Run all tests in test/ directory
|
|
||||||
- `pnpm testSearch` - Run specific search test
|
|
||||||
- `tstest test/test.specific.ts --verbose` - Run specific test with verbose output
|
|
||||||
- `tsbuild check test/**/* --skiplibcheck` - Type check test files
|
|
||||||
|
|
||||||
## Package Management
|
|
||||||
- `pnpm install` - Install dependencies
|
|
||||||
- `pnpm install --save-dev <package>` - Add dev dependency
|
|
||||||
- `pnpm add <package>` - Add production dependency
|
|
||||||
|
|
||||||
## Version Control
|
|
||||||
- `git status` - Check current changes
|
|
||||||
- `git diff` - View uncommitted changes
|
|
||||||
- `git log --oneline -10` - View recent commits
|
|
||||||
- `git mv <old> <new>` - Move/rename files preserving history
|
|
||||||
|
|
||||||
## System Utilities (Linux)
|
|
||||||
- `ls -la` - List all files with details
|
|
||||||
- `grep -r "pattern" .` - Search for pattern in files
|
|
||||||
- `find . -name "*.ts"` - Find TypeScript files
|
|
||||||
- `ps aux | grep node` - Find Node.js processes
|
|
||||||
- `lsof -i :80` - Check process on port 80
|
|
||||||
|
|
||||||
## Debug & Development
|
|
||||||
- `tsx <script.ts>` - Run TypeScript file directly
|
|
||||||
- Store debug scripts in `.nogit/debug/`
|
|
||||||
- Curl endpoints for API testing
|
|
||||||
@@ -1,33 +0,0 @@
|
|||||||
# Task Completion Checklist
|
|
||||||
|
|
||||||
When completing any coding task in this project, always:
|
|
||||||
|
|
||||||
## Before Committing
|
|
||||||
1. **Build the project**: Run `pnpm build` to ensure TypeScript compiles
|
|
||||||
2. **Run tests**: Execute `pnpm test` to verify nothing is broken
|
|
||||||
3. **Type check**: Verify types compile correctly
|
|
||||||
4. **Check for lint issues**: Look for any code style violations
|
|
||||||
|
|
||||||
## Code Quality Checks
|
|
||||||
- Verify all imports are in `ts/plugins.ts` for external dependencies
|
|
||||||
- Check that interfaces are prefixed with `I`
|
|
||||||
- Check that types are prefixed with `T`
|
|
||||||
- Ensure filenames are lowercase
|
|
||||||
- Verify async patterns are preserved where needed
|
|
||||||
- Check that decorators are properly used for MongoDB documents
|
|
||||||
|
|
||||||
## Documentation
|
|
||||||
- Update relevant comments if functionality changed
|
|
||||||
- Ensure new exports are properly documented
|
|
||||||
- Update readme.md if new features added (only if explicitly requested)
|
|
||||||
|
|
||||||
## Git Hygiene
|
|
||||||
- Make small, focused commits
|
|
||||||
- Write clear commit messages
|
|
||||||
- Use `git mv` for file operations
|
|
||||||
- Never commit sensitive data or keys
|
|
||||||
|
|
||||||
## Final Verification
|
|
||||||
- Test the specific functionality that was changed
|
|
||||||
- Ensure no unintended side effects
|
|
||||||
- Verify the change solves the original problem completely
|
|
||||||
@@ -1,68 +0,0 @@
|
|||||||
# language of the project (csharp, python, rust, java, typescript, go, cpp, or ruby)
|
|
||||||
# * For C, use cpp
|
|
||||||
# * For JavaScript, use typescript
|
|
||||||
# Special requirements:
|
|
||||||
# * csharp: Requires the presence of a .sln file in the project folder.
|
|
||||||
language: typescript
|
|
||||||
|
|
||||||
# whether to use the project's gitignore file to ignore files
|
|
||||||
# Added on 2025-04-07
|
|
||||||
ignore_all_files_in_gitignore: true
|
|
||||||
# list of additional paths to ignore
|
|
||||||
# same syntax as gitignore, so you can use * and **
|
|
||||||
# Was previously called `ignored_dirs`, please update your config if you are using that.
|
|
||||||
# Added (renamed)on 2025-04-07
|
|
||||||
ignored_paths: []
|
|
||||||
|
|
||||||
# whether the project is in read-only mode
|
|
||||||
# If set to true, all editing tools will be disabled and attempts to use them will result in an error
|
|
||||||
# Added on 2025-04-18
|
|
||||||
read_only: false
|
|
||||||
|
|
||||||
|
|
||||||
# list of tool names to exclude. We recommend not excluding any tools, see the readme for more details.
|
|
||||||
# Below is the complete list of tools for convenience.
|
|
||||||
# To make sure you have the latest list of tools, and to view their descriptions,
|
|
||||||
# execute `uv run scripts/print_tool_overview.py`.
|
|
||||||
#
|
|
||||||
# * `activate_project`: Activates a project by name.
|
|
||||||
# * `check_onboarding_performed`: Checks whether project onboarding was already performed.
|
|
||||||
# * `create_text_file`: Creates/overwrites a file in the project directory.
|
|
||||||
# * `delete_lines`: Deletes a range of lines within a file.
|
|
||||||
# * `delete_memory`: Deletes a memory from Serena's project-specific memory store.
|
|
||||||
# * `execute_shell_command`: Executes a shell command.
|
|
||||||
# * `find_referencing_code_snippets`: Finds code snippets in which the symbol at the given location is referenced.
|
|
||||||
# * `find_referencing_symbols`: Finds symbols that reference the symbol at the given location (optionally filtered by type).
|
|
||||||
# * `find_symbol`: Performs a global (or local) search for symbols with/containing a given name/substring (optionally filtered by type).
|
|
||||||
# * `get_current_config`: Prints the current configuration of the agent, including the active and available projects, tools, contexts, and modes.
|
|
||||||
# * `get_symbols_overview`: Gets an overview of the top-level symbols defined in a given file.
|
|
||||||
# * `initial_instructions`: Gets the initial instructions for the current project.
|
|
||||||
# Should only be used in settings where the system prompt cannot be set,
|
|
||||||
# e.g. in clients you have no control over, like Claude Desktop.
|
|
||||||
# * `insert_after_symbol`: Inserts content after the end of the definition of a given symbol.
|
|
||||||
# * `insert_at_line`: Inserts content at a given line in a file.
|
|
||||||
# * `insert_before_symbol`: Inserts content before the beginning of the definition of a given symbol.
|
|
||||||
# * `list_dir`: Lists files and directories in the given directory (optionally with recursion).
|
|
||||||
# * `list_memories`: Lists memories in Serena's project-specific memory store.
|
|
||||||
# * `onboarding`: Performs onboarding (identifying the project structure and essential tasks, e.g. for testing or building).
|
|
||||||
# * `prepare_for_new_conversation`: Provides instructions for preparing for a new conversation (in order to continue with the necessary context).
|
|
||||||
# * `read_file`: Reads a file within the project directory.
|
|
||||||
# * `read_memory`: Reads the memory with the given name from Serena's project-specific memory store.
|
|
||||||
# * `remove_project`: Removes a project from the Serena configuration.
|
|
||||||
# * `replace_lines`: Replaces a range of lines within a file with new content.
|
|
||||||
# * `replace_symbol_body`: Replaces the full definition of a symbol.
|
|
||||||
# * `restart_language_server`: Restarts the language server, may be necessary when edits not through Serena happen.
|
|
||||||
# * `search_for_pattern`: Performs a search for a pattern in the project.
|
|
||||||
# * `summarize_changes`: Provides instructions for summarizing the changes made to the codebase.
|
|
||||||
# * `switch_modes`: Activates modes by providing a list of their names
|
|
||||||
# * `think_about_collected_information`: Thinking tool for pondering the completeness of collected information.
|
|
||||||
# * `think_about_task_adherence`: Thinking tool for determining whether the agent is still on track with the current task.
|
|
||||||
# * `think_about_whether_you_are_done`: Thinking tool for determining whether the task is truly completed.
|
|
||||||
# * `write_memory`: Writes a named memory (for future reference) to Serena's project-specific memory store.
|
|
||||||
excluded_tools: []
|
|
||||||
|
|
||||||
# initial prompt for the project. It will always be given to the LLM upon activating the project
|
|
||||||
# (contrary to the memories, which are loaded on demand).
|
|
||||||
initial_prompt: ""
|
|
||||||
|
|
||||||
project_name: "smartdata"
|
|
||||||
3
.vscode/settings.json
vendored
3
.vscode/settings.json
vendored
@@ -22,5 +22,6 @@
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
]
|
],
|
||||||
|
"deno.enable": false
|
||||||
}
|
}
|
||||||
|
|||||||
54
changelog.md
54
changelog.md
@@ -1,5 +1,59 @@
|
|||||||
# Changelog
|
# Changelog
|
||||||
|
|
||||||
|
## 2025-11-17 - 6.0.0 - BREAKING CHANGE(decorators)
|
||||||
|
Migrate to TC39 Stage 3 decorators and refactor decorator metadata handling; update class initialization, lucene adapter fixes and docs
|
||||||
|
|
||||||
|
- Switch all decorators to TC39 Stage 3 signatures and metadata usage (use context.metadata and context.addInitializer) — affects svDb, globalSvDb, searchable, unI, index, Collection and managed.
|
||||||
|
- Refactor Collection/managed decorators to read and initialize prototype/constructor properties from context.metadata to ensure prototype properties are available before instance creation (ts/classes.collection.ts).
|
||||||
|
- Improve search implementation: add a Lucene parser and transformer with safer MongoDB query generation, wildcard/fuzzy handling and properly structured boolean operators (ts/classes.lucene.adapter.ts).
|
||||||
|
- Search integration updated to use the new adapter and handle advanced Lucene syntax and edge cases more robustly.
|
||||||
|
- Bump dev tooling versions: @git.zone/tsbuild -> ^3.1.0 and @git.zone/tsrun -> ^2.0.0.
|
||||||
|
- Documentation: update README and add readme.hints.md describing the TC39 decorator migration, minimum TypeScript (>=5.2) and Deno notes; tests adjusted accordingly.
|
||||||
|
- Clean up project memory/config files related to the previous decorator approach and Deno configuration adjustments.
|
||||||
|
|
||||||
|
## 2025-11-17 - 5.16.7 - fix(classes.collection)
|
||||||
|
Improve Deno and TypeScript compatibility: Collection decorator _svDbOptions forwarding and config cleanup
|
||||||
|
|
||||||
|
- Collection decorator: capture original constructor and forward _svDbOptions to ensure property decorator options (serialize/deserialize) remain accessible in Deno environments.
|
||||||
|
- Collection decorator: keep instance getter defined on prototype for Deno compatibility (no behavior change, clarifies forwarding logic).
|
||||||
|
- Build/config: removed experimentalDecorators and useDefineForClassFields from deno.json and tsconfig.json to avoid Deno/TS build issues and rely on default compilation settings.
|
||||||
|
|
||||||
|
## 2025-11-17 - 5.16.6 - fix(classes)
|
||||||
|
Add Deno compatibility, prototype-safe decorators and safe collection accessor; bump a few deps
|
||||||
|
|
||||||
|
- Add deno.json to enable experimentalDecorators and target ES2022/DOM for Deno builds.
|
||||||
|
- Introduce getCollectionSafe() on SmartDataDbDoc and use it for save/update/delete/findOne to avoid runtime errors when instance 'collection' is not present.
|
||||||
|
- Change several instance properties (globalSaveableProperties, uniqueIndexes, regularIndexes, saveableProperties) to 'declare' so decorator-set prototype properties are not shadowed (Deno compatibility).
|
||||||
|
- Enhance @Collection decorator: capture original constructor/prototype for Deno, define prototype getter for collection on decorated class, attach docCtor for searchableFields, and forward _svDbOptions to the original constructor to preserve serializer metadata.
|
||||||
|
- Improve text/search index handling by relying on docCtor.searchableFields and guarding text index creation.
|
||||||
|
- Bump dependencies/devDependencies: @push.rocks/smartmongo -> ^2.0.14, @git.zone/tsbuild -> ^2.7.1, @git.zone/tstest -> ^2.8.1.
|
||||||
|
- These are non-breaking runtime compatibility and developer-experience fixes; intended as a patch release.
|
||||||
|
|
||||||
|
## 2025-11-16 - 5.16.5 - fix(watcher)
|
||||||
|
Update dependencies, tooling and watcher import; add .serena cache ignore
|
||||||
|
|
||||||
|
- Bump runtime dependencies: @push.rocks/smartlog 3.1.8 → 3.1.10, @push.rocks/smartstring 4.0.15 → 4.1.0, @push.rocks/taskbuffer 3.1.7 → 3.4.0, @tsclass/tsclass 9.2.0 → 9.3.0, mongodb 6.18.0 → 6.20.0
|
||||||
|
- Bump devDependencies: @git.zone/tsbuild 2.6.7 → 2.6.8, @git.zone/tsrun 1.2.44 → 1.6.2, @git.zone/tstest 2.3.5 → 2.6.2
|
||||||
|
- Switch EventEmitter import to node:events in ts/classes.watcher.ts to use the namespaced Node import
|
||||||
|
- Add .serena/.gitignore to ignore /cache
|
||||||
|
|
||||||
|
## 2025-08-18 - 5.16.4 - fix(classes.doc (convertFilterForMongoDb))
|
||||||
|
Improve filter conversion: handle logical operators, merge operator objects, add nested filter tests and docs, and fix test script
|
||||||
|
|
||||||
|
- Fix package.json test script: remove stray dot in tstest --verbose argument to ensure tests run correctly
|
||||||
|
- Enhance convertFilterForMongoDb in ts/classes.doc.ts to properly handle logical operators ($and, $or, $nor, $not) and return them recursively
|
||||||
|
- Merge operator objects for the same field path (e.g. combining $gte and $lte) to avoid overwriting operator clauses when object and dot-notation are mixed
|
||||||
|
- Add validation/guards for operator argument types (e.g. $in, $nin, $all must be arrays; $size must be numeric) and preserve existing behavior blocking $where for security
|
||||||
|
- Add comprehensive nested filter tests in test/test.filters.ts to cover deep nested object queries, $elemMatch, array size, $all, $in on nested fields and more
|
||||||
|
- Expand README filtering section with detailed examples for basic filtering, deep nested filters, comparison operators, array operations, logical and element operators, and advanced patterns
|
||||||
|
|
||||||
|
## 2025-08-18 - 5.16.3 - fix(docs)
|
||||||
|
Add local Claude settings and remove outdated codex.md
|
||||||
|
|
||||||
|
- Added .claude/settings.local.json to store local Claude/assistant permissions and configuration.
|
||||||
|
- Removed codex.md (project overview) — documentation file deleted.
|
||||||
|
- No runtime/library code changes; documentation/configuration-only update, bump patch version.
|
||||||
|
|
||||||
## 2025-08-18 - 5.16.2 - fix(readme)
|
## 2025-08-18 - 5.16.2 - fix(readme)
|
||||||
Update README: clarify examples, expand search/cursor/docs and add local Claude settings
|
Update README: clarify examples, expand search/cursor/docs and add local Claude settings
|
||||||
|
|
||||||
|
|||||||
77
codex.md
77
codex.md
@@ -1,77 +0,0 @@
|
|||||||
# SmartData Project Overview
|
|
||||||
|
|
||||||
This document provides a high-level overview of the SmartData library (`@push.rocks/smartdata`), its architecture, core components, and key features—including recent enhancements to the search API.
|
|
||||||
|
|
||||||
## 1. Project Purpose
|
|
||||||
- A TypeScript‑first wrapper around MongoDB that supplies:
|
|
||||||
- Strongly‑typed document & collection classes
|
|
||||||
- Decorator‑based schema definition (no external schema files)
|
|
||||||
- Advanced search capabilities with Lucene‑style queries
|
|
||||||
- Built‑in support for real‑time data sync, distributed coordination, and key‑value EasyStore
|
|
||||||
|
|
||||||
## 2. Core Concepts & Components
|
|
||||||
- **SmartDataDb**: Manages the MongoDB connection, pooling, and initialization of collections.
|
|
||||||
- **SmartDataDbDoc**: Base class for all document models; provides CRUD, upsert, and cursor APIs.
|
|
||||||
- **Decorators**:
|
|
||||||
- `@Collection`: Associates a class with a MongoDB collection
|
|
||||||
- `@svDb()`: Marks a field as persisted to the DB
|
|
||||||
- `@unI()`: Marks a field as a unique index
|
|
||||||
- `@index()`: Adds a regular index
|
|
||||||
- `@searchable()`: Marks a field for inclusion in text searches or regex queries
|
|
||||||
- **SmartdataCollection**: Wraps a MongoDB collection; auto‑creates indexes based on decorators.
|
|
||||||
- **Lucene Adapter**: Parses a Lucene query string into an AST and transforms it to a MongoDB filter object.
|
|
||||||
- **EasyStore**: A simple, schema‑less key‑value store built on top of MongoDB for sharing ephemeral data.
|
|
||||||
- **Distributed Coordinator**: Leader election and task‑distribution API for building resilient, multi‑instance systems.
|
|
||||||
- **Watcher**: Listens to change streams for real‑time updates and integrates with RxJS.
|
|
||||||
|
|
||||||
## 3. Search API
|
|
||||||
SmartData provides a unified `.search(query[, opts])` method on all models with `@searchable()` fields:
|
|
||||||
|
|
||||||
- **Supported Syntax**:
|
|
||||||
1. Exact field:value (e.g. `field:Value`)
|
|
||||||
2. Quoted phrases (e.g. `"exact phrase"` or `'exact phrase'`)
|
|
||||||
3. Wildcards: `*` (zero or more chars) and `?` (single char)
|
|
||||||
4. Boolean operators: `AND`, `OR`, `NOT`
|
|
||||||
5. Grouping: parenthesis `(A OR B) AND C`
|
|
||||||
6. Range queries: `[num TO num]`, `{num TO num}`
|
|
||||||
7. Multi‑term unquoted: terms AND’d across all searchable fields
|
|
||||||
8. Empty query returns all documents
|
|
||||||
|
|
||||||
- **Fallback Mechanisms**:
|
|
||||||
1. Text index based `$text` search (if supported)
|
|
||||||
2. Field‑scoped and multi‑field regex queries
|
|
||||||
3. In‑memory filtering for complex or unsupported cases
|
|
||||||
|
|
||||||
### New Security & Extensibility Hooks
|
|
||||||
The `.search(query, opts?)` signature now accepts a `SearchOptions<T>` object:
|
|
||||||
```ts
|
|
||||||
interface SearchOptions<T> {
|
|
||||||
filter?: Record<string, any>; // Additional MongoDB filter AND‑merged
|
|
||||||
validate?: (doc: T) => boolean; // Post‑fetch hook to drop results
|
|
||||||
}
|
|
||||||
```
|
|
||||||
- **filter**: Enforces mandatory constraints (e.g. multi‑tenant isolation) directly in the Mongo query.
|
|
||||||
- **validate**: An async function that runs after fetching; return `false` to exclude a document.
|
|
||||||
|
|
||||||
## 4. Testing Strategy
|
|
||||||
- Unit tests in `test/test.search.ts` cover basic search functionality and new options:
|
|
||||||
- Exact, wildcard, phrase, boolean and grouping cases
|
|
||||||
- Implicit AND and mixed free‑term + field searches
|
|
||||||
- Edge cases (non‑searchable fields, quoted wildcards, no matches)
|
|
||||||
- `filter` and `validate` tests ensure security hooks work as intended
|
|
||||||
- Advanced search scenarios are covered in `test/test.search.advanced.ts`.
|
|
||||||
|
|
||||||
## 5. Usage Example
|
|
||||||
```ts
|
|
||||||
// Basic search
|
|
||||||
const prods = await Product.search('wireless earbuds');
|
|
||||||
|
|
||||||
// Scoped search (only your organization’s items)
|
|
||||||
const myItems = await Product.search('book', { filter: { ownerId } });
|
|
||||||
|
|
||||||
// Post‑search validation (only cheap items)
|
|
||||||
const cheapItems = await Product.search('', { validate: p => p.price < 50 });
|
|
||||||
```
|
|
||||||
|
|
||||||
---
|
|
||||||
Last updated: 2025-04-22
|
|
||||||
22
package.json
22
package.json
@@ -1,13 +1,13 @@
|
|||||||
{
|
{
|
||||||
"name": "@push.rocks/smartdata",
|
"name": "@push.rocks/smartdata",
|
||||||
"version": "5.16.2",
|
"version": "6.0.0",
|
||||||
"private": false,
|
"private": false,
|
||||||
"description": "An advanced library for NoSQL data organization and manipulation using TypeScript with support for MongoDB, data validation, collections, and custom data types.",
|
"description": "An advanced library for NoSQL data organization and manipulation using TypeScript with support for MongoDB, data validation, collections, and custom data types.",
|
||||||
"main": "dist_ts/index.js",
|
"main": "dist_ts/index.js",
|
||||||
"typings": "dist_ts/index.d.ts",
|
"typings": "dist_ts/index.d.ts",
|
||||||
"type": "module",
|
"type": "module",
|
||||||
"scripts": {
|
"scripts": {
|
||||||
"test": "tstest test/ --verbose. --logfile --timeout 120",
|
"test": "tstest test/ --verbose --logfile --timeout 120",
|
||||||
"testSearch": "tsx test/test.search.ts",
|
"testSearch": "tsx test/test.search.ts",
|
||||||
"build": "tsbuild --web --allowimplicitany",
|
"build": "tsbuild --web --allowimplicitany",
|
||||||
"buildDocs": "tsdoc"
|
"buildDocs": "tsdoc"
|
||||||
@@ -25,21 +25,21 @@
|
|||||||
"dependencies": {
|
"dependencies": {
|
||||||
"@push.rocks/lik": "^6.2.2",
|
"@push.rocks/lik": "^6.2.2",
|
||||||
"@push.rocks/smartdelay": "^3.0.1",
|
"@push.rocks/smartdelay": "^3.0.1",
|
||||||
"@push.rocks/smartlog": "^3.1.8",
|
"@push.rocks/smartlog": "^3.1.10",
|
||||||
"@push.rocks/smartmongo": "^2.0.12",
|
"@push.rocks/smartmongo": "^2.0.14",
|
||||||
"@push.rocks/smartpromise": "^4.0.2",
|
"@push.rocks/smartpromise": "^4.0.2",
|
||||||
"@push.rocks/smartrx": "^3.0.10",
|
"@push.rocks/smartrx": "^3.0.10",
|
||||||
"@push.rocks/smartstring": "^4.0.15",
|
"@push.rocks/smartstring": "^4.1.0",
|
||||||
"@push.rocks/smarttime": "^4.0.6",
|
"@push.rocks/smarttime": "^4.0.6",
|
||||||
"@push.rocks/smartunique": "^3.0.8",
|
"@push.rocks/smartunique": "^3.0.8",
|
||||||
"@push.rocks/taskbuffer": "^3.1.7",
|
"@push.rocks/taskbuffer": "^3.4.0",
|
||||||
"@tsclass/tsclass": "^9.2.0",
|
"@tsclass/tsclass": "^9.3.0",
|
||||||
"mongodb": "^6.18.0"
|
"mongodb": "^6.20.0"
|
||||||
},
|
},
|
||||||
"devDependencies": {
|
"devDependencies": {
|
||||||
"@git.zone/tsbuild": "^2.6.7",
|
"@git.zone/tsbuild": "^3.1.0",
|
||||||
"@git.zone/tsrun": "^1.2.44",
|
"@git.zone/tsrun": "^2.0.0",
|
||||||
"@git.zone/tstest": "^2.3.5",
|
"@git.zone/tstest": "^2.8.1",
|
||||||
"@push.rocks/qenv": "^6.1.3",
|
"@push.rocks/qenv": "^6.1.3",
|
||||||
"@push.rocks/tapbundle": "^6.0.3",
|
"@push.rocks/tapbundle": "^6.0.3",
|
||||||
"@types/node": "^22.15.2"
|
"@types/node": "^22.15.2"
|
||||||
|
|||||||
3952
pnpm-lock.yaml
generated
3952
pnpm-lock.yaml
generated
File diff suppressed because it is too large
Load Diff
@@ -0,0 +1,80 @@
|
|||||||
|
# Project Memory - Smartdata
|
||||||
|
|
||||||
|
## TC39 Decorator Migration (v6.0.0) - ✅ COMPLETED
|
||||||
|
|
||||||
|
### Final Status: All Tests Passing (157/157)
|
||||||
|
Migration successfully completed on 2025-11-17.
|
||||||
|
|
||||||
|
### What Changed:
|
||||||
|
- ✅ Removed `experimentalDecorators` from tsconfig.json
|
||||||
|
- ✅ Refactored all 7 decorators to TC39 Stage 3 syntax
|
||||||
|
- 5 property decorators: @globalSvDb, @svDb, @unI, @index, @searchable
|
||||||
|
- 2 class decorators: @Collection, @managed
|
||||||
|
- ✅ Implemented context.metadata pattern for shared decorator state
|
||||||
|
- ✅ All tests passing across Node.js and Deno runtimes
|
||||||
|
|
||||||
|
### Critical Discovery: TC39 Metadata Access Pattern
|
||||||
|
**THE KEY INSIGHT**: In TC39 decorators, metadata is NOT accessed via `constructor[Symbol.metadata]`. Instead:
|
||||||
|
- **Field decorators**: Write to `context.metadata`
|
||||||
|
- **Class decorators**: Read from `context.metadata` (same shared object!)
|
||||||
|
- The `context.metadata` object is shared between all decorators on the same class
|
||||||
|
- Attempting to write to `constructor[Symbol.metadata]` throws: "Cannot assign to read only property"
|
||||||
|
|
||||||
|
### Implementation Pattern:
|
||||||
|
```typescript
|
||||||
|
// Field decorator - stores metadata
|
||||||
|
export function svDb() {
|
||||||
|
return (value: undefined, context: ClassFieldDecoratorContext) => {
|
||||||
|
const metadata = context.metadata as ISmartdataDecoratorMetadata;
|
||||||
|
if (!metadata.saveableProperties) {
|
||||||
|
metadata.saveableProperties = [];
|
||||||
|
}
|
||||||
|
metadata.saveableProperties.push(String(context.name));
|
||||||
|
};
|
||||||
|
}
|
||||||
|
|
||||||
|
// Class decorator - reads metadata and initializes prototype
|
||||||
|
export function Collection(dbArg: SmartdataDb) {
|
||||||
|
return function(value: Function, context: ClassDecoratorContext) => {
|
||||||
|
const metadata = context.metadata as ISmartdataDecoratorMetadata;
|
||||||
|
if (metadata?.saveableProperties) {
|
||||||
|
decoratedClass.prototype.saveableProperties = [...metadata.saveableProperties];
|
||||||
|
}
|
||||||
|
return decoratedClass;
|
||||||
|
};
|
||||||
|
}
|
||||||
|
```
|
||||||
|
|
||||||
|
### Runtime Compatibility:
|
||||||
|
- ✅ **Node.js v23.8.0**: Full TC39 support
|
||||||
|
- ✅ **Deno v2.5.4**: Full TC39 support
|
||||||
|
- ❌ **Bun v1.3.0**: No TC39 support (uses legacy decorators only)
|
||||||
|
- Removed "+bun" from test filenames to skip Bun tests
|
||||||
|
|
||||||
|
### Key Technical Notes:
|
||||||
|
1. **Metadata Initialization Timing**: Class decorators run AFTER field decorators, allowing them to read accumulated metadata and initialize prototypes before any instances are created
|
||||||
|
2. **Prototype vs Instance Properties**: Properties set on prototype are accessible via `this.propertyName` in instances
|
||||||
|
3. **TypeScript Lib Support**: TypeScript 5.9.3 includes built-in decorator types (no custom lib configuration needed)
|
||||||
|
4. **Interface Naming**: Used `ISmartdataDecoratorMetadata` extending `DecoratorMetadataObject` for type safety
|
||||||
|
|
||||||
|
### Files Modified:
|
||||||
|
- ts/classes.doc.ts (property decorators + metadata interface)
|
||||||
|
- ts/classes.collection.ts (class decorators + prototype initialization)
|
||||||
|
- tsconfig.json (removed experimentalDecorators flag)
|
||||||
|
- test/*.ts (renamed files to remove "+bun" suffix)
|
||||||
|
|
||||||
|
### Test Results:
|
||||||
|
All 157 tests passing across 10 test files:
|
||||||
|
- test.cursor.ts: 7/7
|
||||||
|
- test.deno.ts: 11/11 (queries working correctly!)
|
||||||
|
- test.search.advanced.ts: 41/41
|
||||||
|
- test.typescript.ts: 4/4
|
||||||
|
- test.watch.ts: 5/5
|
||||||
|
- And 5 more test files
|
||||||
|
|
||||||
|
### Migration Learnings for Future Reference:
|
||||||
|
1. `context.metadata` is the ONLY way to share state between decorators
|
||||||
|
2. Class decorators must initialize prototypes from metadata immediately
|
||||||
|
3. `Symbol.metadata` on constructors is read-only (managed by runtime)
|
||||||
|
4. Field decorators run before class decorators (guaranteed order)
|
||||||
|
5. TypeScript 5.2+ has built-in TC39 decorator support
|
||||||
|
|||||||
203
readme.md
203
readme.md
@@ -8,7 +8,7 @@
|
|||||||
|
|
||||||
SmartData isn't just another MongoDB wrapper - it's a complete paradigm shift in how you work with databases:
|
SmartData isn't just another MongoDB wrapper - it's a complete paradigm shift in how you work with databases:
|
||||||
|
|
||||||
- 🔒 **100% Type-Safe**: Full TypeScript with decorators, generics, and compile-time query validation
|
- 🔒 **100% Type-Safe**: Full TypeScript with TC39 Stage 3 decorators, generics, and compile-time query validation
|
||||||
- ⚡ **Lightning Fast**: Connection pooling, cursor streaming, and intelligent indexing
|
- ⚡ **Lightning Fast**: Connection pooling, cursor streaming, and intelligent indexing
|
||||||
- 🔄 **Real-time Ready**: MongoDB Change Streams with RxJS for reactive applications
|
- 🔄 **Real-time Ready**: MongoDB Change Streams with RxJS for reactive applications
|
||||||
- 🌍 **Distributed Systems**: Built-in leader election and task coordination
|
- 🌍 **Distributed Systems**: Built-in leader election and task coordination
|
||||||
@@ -31,8 +31,11 @@ yarn add @push.rocks/smartdata
|
|||||||
## 🚦 Requirements
|
## 🚦 Requirements
|
||||||
|
|
||||||
- **Node.js** >= 16.x
|
- **Node.js** >= 16.x
|
||||||
|
- **Deno** >= 1.40 (for Deno projects)
|
||||||
- **MongoDB** >= 4.4
|
- **MongoDB** >= 4.4
|
||||||
- **TypeScript** >= 4.x (for development)
|
- **TypeScript** >= 5.2 (for TC39 decorator support)
|
||||||
|
|
||||||
|
> **Note**: SmartData v6.0+ uses TC39 Stage 3 decorators (the new standard). If you're migrating from v5.x, you'll need to remove `experimentalDecorators` from your tsconfig.json. Bun is not currently supported as it doesn't implement TC39 decorators yet.
|
||||||
|
|
||||||
## 🎯 Quick Start
|
## 🎯 Quick Start
|
||||||
|
|
||||||
@@ -144,40 +147,130 @@ await foundUser.delete();
|
|||||||
|
|
||||||
SmartData provides the most advanced type-safe filtering system for MongoDB, supporting all operators while maintaining full IntelliSense:
|
SmartData provides the most advanced type-safe filtering system for MongoDB, supporting all operators while maintaining full IntelliSense:
|
||||||
|
|
||||||
|
#### Basic Filtering
|
||||||
|
|
||||||
```typescript
|
```typescript
|
||||||
|
// Simple equality
|
||||||
|
const john = await User.getInstances({ name: 'John Doe' });
|
||||||
|
|
||||||
|
// Multiple fields (implicit AND)
|
||||||
|
const activeAdults = await User.getInstances({
|
||||||
|
status: 'active',
|
||||||
|
age: { $gte: 18 }
|
||||||
|
});
|
||||||
|
|
||||||
// Union types work perfectly
|
// Union types work perfectly
|
||||||
const users = await User.getInstances({
|
const users = await User.getInstances({
|
||||||
status: { $in: ['active', 'pending'] } // TypeScript validates these values!
|
status: { $in: ['active', 'pending'] } // TypeScript validates these values!
|
||||||
});
|
});
|
||||||
|
```
|
||||||
|
|
||||||
// Comparison operators with type checking
|
#### Deep Nested Object Filtering
|
||||||
|
|
||||||
|
SmartData supports **both** nested object notation and dot notation for querying nested fields, with intelligent merging when both are used:
|
||||||
|
|
||||||
|
```typescript
|
||||||
|
// Nested object notation - natural TypeScript syntax
|
||||||
|
const users = await User.getInstances({
|
||||||
|
metadata: {
|
||||||
|
loginCount: { $gte: 5 }
|
||||||
|
}
|
||||||
|
});
|
||||||
|
|
||||||
|
// Dot notation - MongoDB style
|
||||||
|
const sameUsers = await User.getInstances({
|
||||||
|
'metadata.loginCount': { $gte: 5 }
|
||||||
|
});
|
||||||
|
|
||||||
|
// POWERFUL: Combine both notations - operators are merged!
|
||||||
|
const filtered = await User.getInstances({
|
||||||
|
metadata: { loginCount: { $gte: 3 } }, // Object notation
|
||||||
|
'metadata.loginCount': { $lte: 10 } // Dot notation
|
||||||
|
// Result: metadata.loginCount between 3 and 10
|
||||||
|
});
|
||||||
|
|
||||||
|
// Deep nesting with full type safety
|
||||||
|
const deepQuery = await User.getInstances({
|
||||||
|
profile: {
|
||||||
|
settings: {
|
||||||
|
notifications: {
|
||||||
|
email: true,
|
||||||
|
frequency: { $in: ['daily', 'weekly'] }
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
});
|
||||||
|
|
||||||
|
// Mix styles for complex queries
|
||||||
|
const advanced = await User.getInstances({
|
||||||
|
// Object notation for structure
|
||||||
|
profile: {
|
||||||
|
age: { $gte: 21 },
|
||||||
|
verified: true
|
||||||
|
},
|
||||||
|
// Dot notation for specific overrides
|
||||||
|
'profile.settings.theme': 'dark',
|
||||||
|
'profile.lastSeen': { $gte: new Date('2024-01-01') }
|
||||||
|
});
|
||||||
|
```
|
||||||
|
|
||||||
|
#### Comparison Operators
|
||||||
|
|
||||||
|
```typescript
|
||||||
|
// Numeric comparisons with type checking
|
||||||
const adults = await User.getInstances({
|
const adults = await User.getInstances({
|
||||||
age: { $gte: 18, $lt: 65 } // Type-safe numeric comparisons
|
age: { $gte: 18, $lt: 65 } // Type-safe numeric comparisons
|
||||||
});
|
});
|
||||||
|
|
||||||
|
// Date comparisons
|
||||||
|
const recentUsers = await User.getInstances({
|
||||||
|
createdAt: { $gte: new Date('2024-01-01') }
|
||||||
|
});
|
||||||
|
|
||||||
|
// Not equal
|
||||||
|
const nonAdmins = await User.getInstances({
|
||||||
|
role: { $ne: 'admin' }
|
||||||
|
});
|
||||||
|
```
|
||||||
|
|
||||||
|
#### Array Operations
|
||||||
|
|
||||||
|
```typescript
|
||||||
// Array operations with full type safety
|
// Array operations with full type safety
|
||||||
const experts = await User.getInstances({
|
const experts = await User.getInstances({
|
||||||
tags: { $all: ['typescript', 'mongodb'] }, // Must have all tags
|
tags: { $all: ['typescript', 'mongodb'] }, // Must have all tags
|
||||||
skills: { $size: 5 } // Exactly 5 skills
|
skills: { $size: 5 } // Exactly 5 skills
|
||||||
});
|
});
|
||||||
|
|
||||||
// Complex nested queries
|
// Array element matching
|
||||||
const results = await Order.getInstances({
|
const results = await Order.getInstances({
|
||||||
$and: [
|
|
||||||
{ status: { $in: ['pending', 'processing'] } },
|
|
||||||
{ 'items.price': { $gte: 100 } }, // Dot notation for nested fields
|
|
||||||
{
|
|
||||||
items: {
|
items: {
|
||||||
$elemMatch: { // Array element matching
|
$elemMatch: { // Match array elements
|
||||||
product: 'laptop',
|
product: 'laptop',
|
||||||
quantity: { $gte: 2 }
|
quantity: { $gte: 2 }
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
});
|
||||||
|
|
||||||
|
// Check if value exists in array field
|
||||||
|
const nodeUsers = await User.getInstances({
|
||||||
|
skills: { $in: ['nodejs'] } // Has nodejs in skills array
|
||||||
|
});
|
||||||
|
```
|
||||||
|
|
||||||
|
#### Logical Operators
|
||||||
|
|
||||||
|
```typescript
|
||||||
|
// Complex nested queries with $and
|
||||||
|
const results = await Order.getInstances({
|
||||||
|
$and: [
|
||||||
|
{ status: { $in: ['pending', 'processing'] } },
|
||||||
|
{ 'items.price': { $gte: 100 } },
|
||||||
|
{ customer: { verified: true } }
|
||||||
]
|
]
|
||||||
});
|
});
|
||||||
|
|
||||||
// Logical operators
|
// $or operator
|
||||||
const urgentOrHighValue = await Order.getInstances({
|
const urgentOrHighValue = await Order.getInstances({
|
||||||
$or: [
|
$or: [
|
||||||
{ priority: 'urgent' },
|
{ priority: 'urgent' },
|
||||||
@@ -185,8 +278,94 @@ const urgentOrHighValue = await Order.getInstances({
|
|||||||
]
|
]
|
||||||
});
|
});
|
||||||
|
|
||||||
// Security: $where is automatically blocked
|
// $nor operator - none of the conditions
|
||||||
|
const excluded = await User.getInstances({
|
||||||
|
$nor: [
|
||||||
|
{ status: 'banned' },
|
||||||
|
{ role: 'guest' }
|
||||||
|
]
|
||||||
|
});
|
||||||
|
|
||||||
|
// Combine logical operators
|
||||||
|
const complex = await Order.getInstances({
|
||||||
|
$and: [
|
||||||
|
{ status: 'active' },
|
||||||
|
{
|
||||||
|
$or: [
|
||||||
|
{ priority: 'high' },
|
||||||
|
{ value: { $gte: 1000 } }
|
||||||
|
]
|
||||||
|
}
|
||||||
|
]
|
||||||
|
});
|
||||||
|
```
|
||||||
|
|
||||||
|
#### Element Operators
|
||||||
|
|
||||||
|
```typescript
|
||||||
|
// Check field existence
|
||||||
|
const withEmail = await User.getInstances({
|
||||||
|
email: { $exists: true }
|
||||||
|
});
|
||||||
|
|
||||||
|
// Check for null or missing nested fields
|
||||||
|
const noPreferences = await User.getInstances({
|
||||||
|
'profile.preferences': { $exists: false }
|
||||||
|
});
|
||||||
|
```
|
||||||
|
|
||||||
|
#### Text and Pattern Matching
|
||||||
|
|
||||||
|
```typescript
|
||||||
|
// Regex patterns
|
||||||
|
const gmailUsers = await User.getInstances({
|
||||||
|
email: { $regex: '@gmail\\.com$', $options: 'i' }
|
||||||
|
});
|
||||||
|
|
||||||
|
// Starts with pattern
|
||||||
|
const johnUsers = await User.getInstances({
|
||||||
|
name: { $regex: '^John' }
|
||||||
|
});
|
||||||
|
```
|
||||||
|
|
||||||
|
#### Security Features
|
||||||
|
|
||||||
|
```typescript
|
||||||
|
// Security: $where is automatically blocked for injection protection
|
||||||
// await User.getInstances({ $where: '...' }); // ❌ Throws security error
|
// await User.getInstances({ $where: '...' }); // ❌ Throws security error
|
||||||
|
|
||||||
|
// Invalid operators are caught
|
||||||
|
// await User.getInstances({ $badOp: 'value' }); // ⚠️ Warning logged
|
||||||
|
```
|
||||||
|
|
||||||
|
#### Advanced Patterns
|
||||||
|
|
||||||
|
```typescript
|
||||||
|
// Combine multiple filtering approaches
|
||||||
|
const advancedQuery = await User.getInstances({
|
||||||
|
// Direct field matching
|
||||||
|
status: 'active',
|
||||||
|
|
||||||
|
// Nested object with operators
|
||||||
|
profile: {
|
||||||
|
age: { $gte: 18, $lte: 65 },
|
||||||
|
verified: true
|
||||||
|
},
|
||||||
|
|
||||||
|
// Dot notation for deep paths
|
||||||
|
'settings.notifications.email': true,
|
||||||
|
'metadata.lastLogin': { $gte: new Date(Date.now() - 30*24*60*60*1000) },
|
||||||
|
|
||||||
|
// Array operations
|
||||||
|
roles: { $in: ['admin', 'moderator'] },
|
||||||
|
tags: { $all: ['verified', 'premium'] },
|
||||||
|
|
||||||
|
// Logical grouping
|
||||||
|
$or: [
|
||||||
|
{ 'subscription.plan': 'premium' },
|
||||||
|
{ 'subscription.trial': true }
|
||||||
|
]
|
||||||
|
});
|
||||||
```
|
```
|
||||||
|
|
||||||
### 🔎 Powerful Search Engine
|
### 🔎 Powerful Search Engine
|
||||||
|
|||||||
255
test/test.deno.ts
Normal file
255
test/test.deno.ts
Normal file
@@ -0,0 +1,255 @@
|
|||||||
|
// TODO: Decorator support during testing for bun and deno in @git.zone/tstest
|
||||||
|
|
||||||
|
import { tap, expect } from '@push.rocks/tapbundle';
|
||||||
|
import { Qenv } from '@push.rocks/qenv';
|
||||||
|
import * as smartmongo from '@push.rocks/smartmongo';
|
||||||
|
import { smartunique } from '../ts/plugins.js';
|
||||||
|
|
||||||
|
import * as mongodb from 'mongodb';
|
||||||
|
|
||||||
|
const testQenv = new Qenv(process.cwd(), process.cwd() + '/.nogit/');
|
||||||
|
|
||||||
|
console.log(process.memoryUsage());
|
||||||
|
|
||||||
|
// the tested module
|
||||||
|
import * as smartdata from '../ts/index.js';
|
||||||
|
|
||||||
|
// =======================================
|
||||||
|
// Connecting to the database server
|
||||||
|
// =======================================
|
||||||
|
|
||||||
|
let smartmongoInstance: smartmongo.SmartMongo;
|
||||||
|
let testDb: smartdata.SmartdataDb;
|
||||||
|
|
||||||
|
const totalCars = 2000;
|
||||||
|
|
||||||
|
tap.test('should create a testinstance as database', async () => {
|
||||||
|
const databaseName = `test-smartdata-deno-${smartunique.shortId()}`;
|
||||||
|
testDb = new smartdata.SmartdataDb({
|
||||||
|
mongoDbUrl: await testQenv.getEnvVarOnDemand('MONGODB_URL'),
|
||||||
|
mongoDbName: databaseName,
|
||||||
|
});
|
||||||
|
await testDb.init();
|
||||||
|
});
|
||||||
|
|
||||||
|
// =======================================
|
||||||
|
// The actual tests
|
||||||
|
// =======================================
|
||||||
|
|
||||||
|
// ------
|
||||||
|
// Collections
|
||||||
|
// ------
|
||||||
|
|
||||||
|
@smartdata.Collection(() => {
|
||||||
|
return testDb;
|
||||||
|
})
|
||||||
|
class Car extends smartdata.SmartDataDbDoc<Car, Car> {
|
||||||
|
@smartdata.unI()
|
||||||
|
public index: string = smartunique.shortId();
|
||||||
|
|
||||||
|
@smartdata.svDb()
|
||||||
|
public color: string;
|
||||||
|
|
||||||
|
@smartdata.svDb()
|
||||||
|
public brand: string;
|
||||||
|
|
||||||
|
@smartdata.svDb()
|
||||||
|
public testBuffer = Buffer.from('hello');
|
||||||
|
|
||||||
|
@smartdata.svDb()
|
||||||
|
deepData = {
|
||||||
|
sodeep: 'yes',
|
||||||
|
};
|
||||||
|
|
||||||
|
constructor(colorArg: string, brandArg: string) {
|
||||||
|
super();
|
||||||
|
this.color = colorArg;
|
||||||
|
this.brand = brandArg;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
tap.test('should create a new id', async () => {
|
||||||
|
const newid = await Car.getNewId();
|
||||||
|
console.log(newid);
|
||||||
|
});
|
||||||
|
|
||||||
|
tap.test('should save the car to the db', async (toolsArg) => {
|
||||||
|
const myCar = new Car('red', 'Volvo');
|
||||||
|
console.log('Car.collection.smartdataDb:', (Car.collection as any).smartdataDb?.mongoDb?.databaseName);
|
||||||
|
console.log('Car.collection.collectionName:', (Car.collection as any).collectionName);
|
||||||
|
console.log('testDb.mongoDb.databaseName:', testDb.mongoDb.databaseName);
|
||||||
|
await myCar.save();
|
||||||
|
|
||||||
|
const myCar2 = new Car('red', 'Volvo');
|
||||||
|
await myCar2.save();
|
||||||
|
|
||||||
|
let counter = 0;
|
||||||
|
|
||||||
|
const gottenCarInstance = await Car.getInstance({});
|
||||||
|
console.log(gottenCarInstance.testBuffer instanceof mongodb.Binary);
|
||||||
|
process.memoryUsage();
|
||||||
|
do {
|
||||||
|
const myCar3 = new Car('red', 'Renault');
|
||||||
|
await myCar3.save();
|
||||||
|
counter++;
|
||||||
|
if (counter % 100 === 0) {
|
||||||
|
console.log(
|
||||||
|
`Filled database with ${counter} of ${totalCars} Cars and memory usage ${
|
||||||
|
process.memoryUsage().rss / 1e6
|
||||||
|
} MB`,
|
||||||
|
);
|
||||||
|
}
|
||||||
|
} while (counter < totalCars);
|
||||||
|
console.log(process.memoryUsage());
|
||||||
|
|
||||||
|
// DEBUG: Check what's actually in the database
|
||||||
|
const savedCount = await Car.getCount({});
|
||||||
|
console.log('Total cars saved in DB:', savedCount);
|
||||||
|
const renaultCount = await Car.getCount({ brand: 'Renault' });
|
||||||
|
console.log('Renault cars in DB:', renaultCount);
|
||||||
|
|
||||||
|
// Check what's actually in the first saved car
|
||||||
|
const firstCar = await Car.getInstance({});
|
||||||
|
console.log('First car data:', JSON.stringify({
|
||||||
|
color: firstCar?.color,
|
||||||
|
brand: firstCar?.brand,
|
||||||
|
index: firstCar?.index
|
||||||
|
}));
|
||||||
|
});
|
||||||
|
|
||||||
|
tap.test('expect to get instance of Car with shallow match', async () => {
|
||||||
|
console.log('Before query - testDb.mongoDb.databaseName:', testDb.mongoDb.databaseName);
|
||||||
|
console.log('Before query - Car.collection.smartdataDb:', (Car.collection as any).smartdataDb?.mongoDb?.databaseName);
|
||||||
|
console.log('Before query - Car.collection.collectionName:', (Car.collection as any).collectionName);
|
||||||
|
|
||||||
|
const totalQueryCycles = totalCars / 2;
|
||||||
|
let counter = 0;
|
||||||
|
do {
|
||||||
|
const timeStart = Date.now();
|
||||||
|
const myCars = await Car.getInstances({
|
||||||
|
brand: 'Renault',
|
||||||
|
});
|
||||||
|
if (counter % 10 === 0) {
|
||||||
|
console.log(
|
||||||
|
`performed ${counter} of ${totalQueryCycles} total query cycles: took ${
|
||||||
|
Date.now() - timeStart
|
||||||
|
}ms to query a set of 2000 with memory footprint ${process.memoryUsage().rss / 1e6} MB`,
|
||||||
|
);
|
||||||
|
console.log('myCars.length:', myCars.length);
|
||||||
|
console.log('myCars[0]:', myCars[0]);
|
||||||
|
}
|
||||||
|
expect(myCars[0].deepData.sodeep).toEqual('yes');
|
||||||
|
expect(myCars[0].brand).toEqual('Renault');
|
||||||
|
counter++;
|
||||||
|
} while (counter < totalQueryCycles);
|
||||||
|
});
|
||||||
|
|
||||||
|
tap.test('expect to get instance of Car with deep match', async () => {
|
||||||
|
const totalQueryCycles = totalCars / 6;
|
||||||
|
let counter = 0;
|
||||||
|
do {
|
||||||
|
const timeStart = Date.now();
|
||||||
|
const myCars2 = await Car.getInstances({
|
||||||
|
deepData: {
|
||||||
|
sodeep: 'yes',
|
||||||
|
},
|
||||||
|
});
|
||||||
|
if (counter % 10 === 0) {
|
||||||
|
console.log(
|
||||||
|
`performed ${counter} of ${totalQueryCycles} total query cycles: took ${
|
||||||
|
Date.now() - timeStart
|
||||||
|
}ms to deep query a set of 2000 with memory footprint ${process.memoryUsage().rss / 1e6} MB`,
|
||||||
|
);
|
||||||
|
}
|
||||||
|
expect(myCars2[0].deepData.sodeep).toEqual('yes');
|
||||||
|
expect(myCars2[0].brand).toEqual('Volvo');
|
||||||
|
counter++;
|
||||||
|
} while (counter < totalQueryCycles);
|
||||||
|
});
|
||||||
|
|
||||||
|
tap.test('expect to get instance of Car and update it', async () => {
|
||||||
|
const myCar = await Car.getInstance<Car>({
|
||||||
|
brand: 'Volvo',
|
||||||
|
});
|
||||||
|
expect(myCar.color).toEqual('red');
|
||||||
|
myCar.color = 'blue';
|
||||||
|
await myCar.save();
|
||||||
|
});
|
||||||
|
|
||||||
|
tap.test('should be able to delete an instance of car', async () => {
|
||||||
|
const myCars = await Car.getInstances({
|
||||||
|
brand: 'Volvo',
|
||||||
|
color: 'blue',
|
||||||
|
});
|
||||||
|
console.log(myCars);
|
||||||
|
expect(myCars[0].color).toEqual('blue');
|
||||||
|
for (const myCar of myCars) {
|
||||||
|
await myCar.delete();
|
||||||
|
}
|
||||||
|
|
||||||
|
const myCar2 = await Car.getInstance<Car>({
|
||||||
|
brand: 'Volvo',
|
||||||
|
});
|
||||||
|
expect(myCar2.color).toEqual('red');
|
||||||
|
});
|
||||||
|
|
||||||
|
// tslint:disable-next-line: max-classes-per-file
|
||||||
|
@smartdata.Collection(() => {
|
||||||
|
return testDb;
|
||||||
|
})
|
||||||
|
class Truck extends smartdata.SmartDataDbDoc<Car, Car> {
|
||||||
|
@smartdata.unI()
|
||||||
|
public id: string = smartunique.shortId();
|
||||||
|
|
||||||
|
@smartdata.svDb()
|
||||||
|
public color: string;
|
||||||
|
|
||||||
|
@smartdata.svDb()
|
||||||
|
public brand: string;
|
||||||
|
|
||||||
|
constructor(colorArg: string, brandArg: string) {
|
||||||
|
super();
|
||||||
|
this.color = colorArg;
|
||||||
|
this.brand = brandArg;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
tap.test('should store a new Truck', async () => {
|
||||||
|
const truck = new Truck('blue', 'MAN');
|
||||||
|
await truck.save();
|
||||||
|
const myTruck2 = await Truck.getInstance({ color: 'blue' });
|
||||||
|
expect(myTruck2.color).toEqual('blue');
|
||||||
|
myTruck2.color = 'red';
|
||||||
|
await myTruck2.save();
|
||||||
|
const myTruck3 = await Truck.getInstance({ color: 'blue' });
|
||||||
|
expect(myTruck3).toBeNull();
|
||||||
|
});
|
||||||
|
|
||||||
|
tap.test('should return a count', async () => {
|
||||||
|
const truckCount = await Truck.getCount();
|
||||||
|
expect(truckCount).toEqual(1);
|
||||||
|
});
|
||||||
|
|
||||||
|
tap.test('should use a cursor', async () => {
|
||||||
|
const cursor = await Car.getCursor({});
|
||||||
|
let counter = 0;
|
||||||
|
await cursor.forEach(async (carArg) => {
|
||||||
|
counter++;
|
||||||
|
counter % 50 === 0 ? console.log(`50 more of ${carArg.color}`) : null;
|
||||||
|
});
|
||||||
|
});
|
||||||
|
|
||||||
|
// =======================================
|
||||||
|
// close the database connection
|
||||||
|
// =======================================
|
||||||
|
tap.test('close', async () => {
|
||||||
|
if (smartmongoInstance) {
|
||||||
|
await smartmongoInstance.stopAndDumpToDir('./.nogit/dbdump/test.ts');
|
||||||
|
} else {
|
||||||
|
await testDb.mongoDb.dropDatabase();
|
||||||
|
await testDb.close();
|
||||||
|
}
|
||||||
|
setTimeout(() => process.exit(), 2000);
|
||||||
|
});
|
||||||
|
|
||||||
|
tap.start({ throwOnError: true });
|
||||||
@@ -213,6 +213,221 @@ tap.test('should filter by nested object fields', async () => {
|
|||||||
expect(users[0].name).toEqual('John Doe');
|
expect(users[0].name).toEqual('John Doe');
|
||||||
});
|
});
|
||||||
|
|
||||||
|
// ============= COMPREHENSIVE NESTED FILTER TESTS =============
|
||||||
|
tap.test('should filter by nested object with direct object syntax', async () => {
|
||||||
|
// Direct nested object matching (exact match)
|
||||||
|
const users = await TestUser.getInstances({
|
||||||
|
metadata: {
|
||||||
|
loginCount: 5,
|
||||||
|
lastLogin: (await TestUser.getInstances({}))[0].metadata.lastLogin // Get the exact date
|
||||||
|
}
|
||||||
|
});
|
||||||
|
expect(users.length).toEqual(1);
|
||||||
|
expect(users[0].name).toEqual('John Doe');
|
||||||
|
});
|
||||||
|
|
||||||
|
tap.test('should filter by partial nested object match', async () => {
|
||||||
|
// When using object syntax, only specified fields must match
|
||||||
|
const users = await TestUser.getInstances({
|
||||||
|
metadata: { loginCount: 5 } // Only checks loginCount, ignores other fields
|
||||||
|
});
|
||||||
|
expect(users.length).toEqual(1);
|
||||||
|
expect(users[0].name).toEqual('John Doe');
|
||||||
|
});
|
||||||
|
|
||||||
|
tap.test('should combine nested object and dot notation', async () => {
|
||||||
|
const users = await TestUser.getInstances({
|
||||||
|
metadata: { loginCount: { $gte: 3 } }, // Object syntax with operator
|
||||||
|
'metadata.loginCount': { $lte: 10 } // Dot notation with operator
|
||||||
|
});
|
||||||
|
expect(users.length).toEqual(3); // Jane (3), John (5), and Alice (10) have loginCount between 3-10
|
||||||
|
});
|
||||||
|
|
||||||
|
tap.test('should filter nested fields with operators using dot notation', async () => {
|
||||||
|
const users = await TestUser.getInstances({
|
||||||
|
'metadata.loginCount': { $gte: 5 }
|
||||||
|
});
|
||||||
|
expect(users.length).toEqual(2); // John (5) and Alice (10)
|
||||||
|
const names = users.map(u => u.name).sort();
|
||||||
|
expect(names).toEqual(['Alice Brown', 'John Doe']);
|
||||||
|
});
|
||||||
|
|
||||||
|
tap.test('should filter nested fields with multiple operators', async () => {
|
||||||
|
const users = await TestUser.getInstances({
|
||||||
|
'metadata.loginCount': { $gte: 3, $lt: 10 }
|
||||||
|
});
|
||||||
|
expect(users.length).toEqual(2); // Jane (3) and John (5)
|
||||||
|
const names = users.map(u => u.name).sort();
|
||||||
|
expect(names).toEqual(['Jane Smith', 'John Doe']);
|
||||||
|
});
|
||||||
|
|
||||||
|
tap.test('should handle deeply nested object structures', async () => {
|
||||||
|
// First, create a user with deep nesting in preferences
|
||||||
|
const deepUser = new TestUser({
|
||||||
|
name: 'Deep Nester',
|
||||||
|
age: 40,
|
||||||
|
email: 'deep@example.com',
|
||||||
|
roles: ['admin'],
|
||||||
|
tags: [],
|
||||||
|
status: 'active',
|
||||||
|
metadata: {
|
||||||
|
loginCount: 1,
|
||||||
|
preferences: {
|
||||||
|
theme: {
|
||||||
|
colors: {
|
||||||
|
primary: '#000000',
|
||||||
|
secondary: '#ffffff'
|
||||||
|
},
|
||||||
|
fonts: {
|
||||||
|
heading: 'Arial',
|
||||||
|
body: 'Helvetica'
|
||||||
|
}
|
||||||
|
},
|
||||||
|
notifications: {
|
||||||
|
email: true,
|
||||||
|
push: false
|
||||||
|
}
|
||||||
|
}
|
||||||
|
},
|
||||||
|
scores: []
|
||||||
|
});
|
||||||
|
await deepUser.save();
|
||||||
|
|
||||||
|
// Test deep nesting with dot notation
|
||||||
|
const deepResults = await TestUser.getInstances({
|
||||||
|
'metadata.preferences.theme.colors.primary': '#000000'
|
||||||
|
});
|
||||||
|
expect(deepResults.length).toEqual(1);
|
||||||
|
expect(deepResults[0].name).toEqual('Deep Nester');
|
||||||
|
|
||||||
|
// Test deep nesting with operators
|
||||||
|
const boolResults = await TestUser.getInstances({
|
||||||
|
'metadata.preferences.notifications.email': { $eq: true }
|
||||||
|
});
|
||||||
|
expect(boolResults.length).toEqual(1);
|
||||||
|
expect(boolResults[0].name).toEqual('Deep Nester');
|
||||||
|
|
||||||
|
// Clean up
|
||||||
|
await deepUser.delete();
|
||||||
|
});
|
||||||
|
|
||||||
|
tap.test('should filter arrays of nested objects using $elemMatch', async () => {
|
||||||
|
const orders = await TestOrder.getInstances({
|
||||||
|
items: {
|
||||||
|
$elemMatch: {
|
||||||
|
product: 'laptop',
|
||||||
|
price: { $gte: 1000 }
|
||||||
|
}
|
||||||
|
}
|
||||||
|
});
|
||||||
|
expect(orders.length).toEqual(2); // Both laptop orders have price >= 1000
|
||||||
|
});
|
||||||
|
|
||||||
|
tap.test('should filter nested arrays with dot notation', async () => {
|
||||||
|
// Query for any order that has an item with specific product
|
||||||
|
const orders = await TestOrder.getInstances({
|
||||||
|
'items.product': 'laptop'
|
||||||
|
});
|
||||||
|
expect(orders.length).toEqual(2); // Two orders contain laptops
|
||||||
|
});
|
||||||
|
|
||||||
|
tap.test('should combine nested object filters with logical operators', async () => {
|
||||||
|
const users = await TestUser.getInstances({
|
||||||
|
$or: [
|
||||||
|
{ 'metadata.loginCount': { $gte: 10 } }, // Alice has 10
|
||||||
|
{
|
||||||
|
$and: [
|
||||||
|
{ 'metadata.loginCount': { $lt: 5 } }, // Jane has 3, Bob has 0, Charlie has 1
|
||||||
|
{ status: 'active' } // Jane is active, Bob is inactive, Charlie is pending
|
||||||
|
]
|
||||||
|
}
|
||||||
|
]
|
||||||
|
});
|
||||||
|
expect(users.length).toEqual(2); // Alice (loginCount >= 10), Jane (loginCount < 5 AND active)
|
||||||
|
const names = users.map(u => u.name).sort();
|
||||||
|
expect(names).toEqual(['Alice Brown', 'Jane Smith']);
|
||||||
|
});
|
||||||
|
|
||||||
|
tap.test('should handle null and undefined in nested fields', async () => {
|
||||||
|
// Users without lastLogin
|
||||||
|
const noLastLogin = await TestUser.getInstances({
|
||||||
|
'metadata.lastLogin': { $exists: false }
|
||||||
|
});
|
||||||
|
expect(noLastLogin.length).toEqual(4); // Everyone except John
|
||||||
|
|
||||||
|
// Users with preferences (none have it set)
|
||||||
|
const withPreferences = await TestUser.getInstances({
|
||||||
|
'metadata.preferences': { $exists: true }
|
||||||
|
});
|
||||||
|
expect(withPreferences.length).toEqual(0);
|
||||||
|
});
|
||||||
|
|
||||||
|
tap.test('should filter nested arrays by size', async () => {
|
||||||
|
// Create an order with specific number of items
|
||||||
|
const multiItemOrder = new TestOrder({
|
||||||
|
userId: 'test-user',
|
||||||
|
items: [
|
||||||
|
{ product: 'item1', quantity: 1, price: 10 },
|
||||||
|
{ product: 'item2', quantity: 2, price: 20 },
|
||||||
|
{ product: 'item3', quantity: 3, price: 30 },
|
||||||
|
{ product: 'item4', quantity: 4, price: 40 }
|
||||||
|
],
|
||||||
|
totalAmount: 100,
|
||||||
|
status: 'pending',
|
||||||
|
tags: ['test']
|
||||||
|
});
|
||||||
|
await multiItemOrder.save();
|
||||||
|
|
||||||
|
const fourItemOrders = await TestOrder.getInstances({
|
||||||
|
items: { $size: 4 }
|
||||||
|
});
|
||||||
|
expect(fourItemOrders.length).toEqual(1);
|
||||||
|
|
||||||
|
// Clean up
|
||||||
|
await multiItemOrder.delete();
|
||||||
|
});
|
||||||
|
|
||||||
|
tap.test('should handle nested field comparison between documents', async () => {
|
||||||
|
// Find users where loginCount equals their age divided by 6 (John: 30/6=5)
|
||||||
|
const users = await TestUser.getInstances({
|
||||||
|
$and: [
|
||||||
|
{ 'metadata.loginCount': 5 },
|
||||||
|
{ age: 30 }
|
||||||
|
]
|
||||||
|
});
|
||||||
|
expect(users.length).toEqual(1);
|
||||||
|
expect(users[0].name).toEqual('John Doe');
|
||||||
|
});
|
||||||
|
|
||||||
|
tap.test('should filter using $in on nested fields', async () => {
|
||||||
|
const users = await TestUser.getInstances({
|
||||||
|
'metadata.loginCount': { $in: [0, 1, 5] }
|
||||||
|
});
|
||||||
|
expect(users.length).toEqual(3); // Bob (0), Charlie (1), John (5)
|
||||||
|
const names = users.map(u => u.name).sort();
|
||||||
|
expect(names).toEqual(['Bob Johnson', 'Charlie Wilson', 'John Doe']);
|
||||||
|
});
|
||||||
|
|
||||||
|
tap.test('should filter nested arrays with $all', async () => {
|
||||||
|
// Create an order with multiple tags
|
||||||
|
const taggedOrder = new TestOrder({
|
||||||
|
userId: 'test-user',
|
||||||
|
items: [{ product: 'test', quantity: 1, price: 10 }],
|
||||||
|
totalAmount: 10,
|
||||||
|
status: 'completed',
|
||||||
|
tags: ['urgent', 'priority', 'electronics']
|
||||||
|
});
|
||||||
|
await taggedOrder.save();
|
||||||
|
|
||||||
|
const priorityElectronics = await TestOrder.getInstances({
|
||||||
|
tags: { $all: ['priority', 'electronics'] }
|
||||||
|
});
|
||||||
|
expect(priorityElectronics.length).toEqual(2); // Original order and new one
|
||||||
|
|
||||||
|
// Clean up
|
||||||
|
await taggedOrder.delete();
|
||||||
|
});
|
||||||
|
|
||||||
// ============= COMPARISON OPERATOR TESTS =============
|
// ============= COMPARISON OPERATOR TESTS =============
|
||||||
tap.test('should filter using $gt operator', async () => {
|
tap.test('should filter using $gt operator', async () => {
|
||||||
const users = await TestUser.getInstances({
|
const users = await TestUser.getInstances({
|
||||||
|
|||||||
@@ -1,3 +1,5 @@
|
|||||||
|
// TODO: Decorator support during testing for bun and deno in @git.zone/tstest
|
||||||
|
|
||||||
import { tap, expect } from '@push.rocks/tapbundle';
|
import { tap, expect } from '@push.rocks/tapbundle';
|
||||||
import { Qenv } from '@push.rocks/qenv';
|
import { Qenv } from '@push.rocks/qenv';
|
||||||
import * as smartmongo from '@push.rocks/smartmongo';
|
import * as smartmongo from '@push.rocks/smartmongo';
|
||||||
@@ -3,6 +3,6 @@
|
|||||||
*/
|
*/
|
||||||
export const commitinfo = {
|
export const commitinfo = {
|
||||||
name: '@push.rocks/smartdata',
|
name: '@push.rocks/smartdata',
|
||||||
version: '5.16.2',
|
version: '6.0.0',
|
||||||
description: 'An advanced library for NoSQL data organization and manipulation using TypeScript with support for MongoDB, data validation, collections, and custom data types.'
|
description: 'An advanced library for NoSQL data organization and manipulation using TypeScript with support for MongoDB, data validation, collections, and custom data types.'
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -26,10 +26,16 @@ const collectionFactory = new CollectionFactory();
|
|||||||
* @param dbArg
|
* @param dbArg
|
||||||
*/
|
*/
|
||||||
export function Collection(dbArg: SmartdataDb | TDelayed<SmartdataDb>) {
|
export function Collection(dbArg: SmartdataDb | TDelayed<SmartdataDb>) {
|
||||||
return function classDecorator<T extends { new (...args: any[]): {} }>(constructor: T) {
|
return function classDecorator(value: Function, context: ClassDecoratorContext) {
|
||||||
const decoratedClass = class extends constructor {
|
if (context.kind !== 'class') {
|
||||||
public static className = constructor.name;
|
throw new Error('Collection can only decorate classes');
|
||||||
public static get collection() {
|
}
|
||||||
|
|
||||||
|
// Capture original constructor for _svDbOptions forwarding
|
||||||
|
const originalConstructor = value as any;
|
||||||
|
const constructor = value as { new (...args: any[]): any };
|
||||||
|
|
||||||
|
const getCollection = () => {
|
||||||
if (!(dbArg instanceof SmartdataDb)) {
|
if (!(dbArg instanceof SmartdataDb)) {
|
||||||
dbArg = dbArg();
|
dbArg = dbArg();
|
||||||
}
|
}
|
||||||
@@ -39,19 +45,75 @@ export function Collection(dbArg: SmartdataDb | TDelayed<SmartdataDb>) {
|
|||||||
(coll as any).docCtor = decoratedClass;
|
(coll as any).docCtor = decoratedClass;
|
||||||
}
|
}
|
||||||
return coll;
|
return coll;
|
||||||
|
};
|
||||||
|
|
||||||
|
const decoratedClass = class extends constructor {
|
||||||
|
public static className = constructor.name;
|
||||||
|
public static get collection() {
|
||||||
|
return getCollection();
|
||||||
}
|
}
|
||||||
public get collection() {
|
public get collection() {
|
||||||
if (!(dbArg instanceof SmartdataDb)) {
|
return getCollection();
|
||||||
dbArg = dbArg();
|
|
||||||
}
|
|
||||||
const coll = collectionFactory.getCollection(constructor.name, dbArg);
|
|
||||||
if (!(coll as any).docCtor) {
|
|
||||||
(coll as any).docCtor = decoratedClass;
|
|
||||||
}
|
|
||||||
return coll;
|
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
return decoratedClass;
|
|
||||||
|
// Ensure instance getter works in Deno by defining it on the prototype
|
||||||
|
Object.defineProperty(decoratedClass.prototype, 'collection', {
|
||||||
|
get: getCollection,
|
||||||
|
enumerable: false,
|
||||||
|
configurable: true
|
||||||
|
});
|
||||||
|
|
||||||
|
// Deno compatibility note: Property decorators set properties on the prototype.
|
||||||
|
// Since we removed instance property declarations from SmartDataDbDoc,
|
||||||
|
// the decorator-set prototype properties are now accessible without shadowing.
|
||||||
|
// No manual forwarding needed - natural prototype inheritance works!
|
||||||
|
|
||||||
|
// Point to original constructor's _svDbOptions
|
||||||
|
Object.defineProperty(decoratedClass, '_svDbOptions', {
|
||||||
|
get() { return originalConstructor._svDbOptions; },
|
||||||
|
set(value) { originalConstructor._svDbOptions = value; },
|
||||||
|
configurable: true
|
||||||
|
});
|
||||||
|
|
||||||
|
// Initialize prototype properties from context.metadata (TC39 decorator metadata)
|
||||||
|
// This ensures prototype properties are available before any instance is created
|
||||||
|
const metadata = context.metadata as any;
|
||||||
|
if (metadata) {
|
||||||
|
const proto = decoratedClass.prototype;
|
||||||
|
|
||||||
|
// Initialize globalSaveableProperties
|
||||||
|
if (metadata.globalSaveableProperties && !proto.globalSaveableProperties) {
|
||||||
|
proto.globalSaveableProperties = [...metadata.globalSaveableProperties];
|
||||||
|
}
|
||||||
|
|
||||||
|
// Initialize saveableProperties
|
||||||
|
if (metadata.saveableProperties && !proto.saveableProperties) {
|
||||||
|
proto.saveableProperties = [...metadata.saveableProperties];
|
||||||
|
}
|
||||||
|
|
||||||
|
// Initialize uniqueIndexes
|
||||||
|
if (metadata.uniqueIndexes && !proto.uniqueIndexes) {
|
||||||
|
proto.uniqueIndexes = [...metadata.uniqueIndexes];
|
||||||
|
}
|
||||||
|
|
||||||
|
// Initialize regularIndexes
|
||||||
|
if (metadata.regularIndexes && !proto.regularIndexes) {
|
||||||
|
proto.regularIndexes = [...metadata.regularIndexes];
|
||||||
|
}
|
||||||
|
|
||||||
|
// Initialize searchableFields on constructor (not prototype)
|
||||||
|
if (metadata.searchableFields && !Array.isArray((decoratedClass as any).searchableFields)) {
|
||||||
|
(decoratedClass as any).searchableFields = [...metadata.searchableFields];
|
||||||
|
}
|
||||||
|
|
||||||
|
// Initialize _svDbOptions from metadata
|
||||||
|
if (metadata._svDbOptions && !originalConstructor._svDbOptions) {
|
||||||
|
originalConstructor._svDbOptions = { ...metadata._svDbOptions };
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
return decoratedClass as any;
|
||||||
};
|
};
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -69,7 +131,13 @@ export const setDefaultManagerForDoc = <T,>(managerArg: IManager, dbDocArg: T):
|
|||||||
* @param dbArg
|
* @param dbArg
|
||||||
*/
|
*/
|
||||||
export function managed<TManager extends IManager>(managerArg?: TManager | TDelayed<TManager>) {
|
export function managed<TManager extends IManager>(managerArg?: TManager | TDelayed<TManager>) {
|
||||||
return function classDecorator<T extends { new (...args: any[]): any }>(constructor: T) {
|
return function classDecorator(value: Function, context: ClassDecoratorContext) {
|
||||||
|
if (context.kind !== 'class') {
|
||||||
|
throw new Error('managed can only decorate classes');
|
||||||
|
}
|
||||||
|
|
||||||
|
const constructor = value as { new (...args: any[]): any };
|
||||||
|
|
||||||
const decoratedClass = class extends constructor {
|
const decoratedClass = class extends constructor {
|
||||||
public static className = constructor.name;
|
public static className = constructor.name;
|
||||||
public static get collection() {
|
public static get collection() {
|
||||||
@@ -119,7 +187,46 @@ export function managed<TManager extends IManager>(managerArg?: TManager | TDela
|
|||||||
return manager;
|
return manager;
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
return decoratedClass;
|
|
||||||
|
// Initialize prototype properties from context.metadata (TC39 decorator metadata)
|
||||||
|
// This ensures prototype properties are available before any instance is created
|
||||||
|
const originalConstructor = value as any;
|
||||||
|
const metadata = context.metadata as any;
|
||||||
|
if (metadata) {
|
||||||
|
const proto = decoratedClass.prototype;
|
||||||
|
|
||||||
|
// Initialize globalSaveableProperties
|
||||||
|
if (metadata.globalSaveableProperties && !proto.globalSaveableProperties) {
|
||||||
|
proto.globalSaveableProperties = [...metadata.globalSaveableProperties];
|
||||||
|
}
|
||||||
|
|
||||||
|
// Initialize saveableProperties
|
||||||
|
if (metadata.saveableProperties && !proto.saveableProperties) {
|
||||||
|
proto.saveableProperties = [...metadata.saveableProperties];
|
||||||
|
}
|
||||||
|
|
||||||
|
// Initialize uniqueIndexes
|
||||||
|
if (metadata.uniqueIndexes && !proto.uniqueIndexes) {
|
||||||
|
proto.uniqueIndexes = [...metadata.uniqueIndexes];
|
||||||
|
}
|
||||||
|
|
||||||
|
// Initialize regularIndexes
|
||||||
|
if (metadata.regularIndexes && !proto.regularIndexes) {
|
||||||
|
proto.regularIndexes = [...metadata.regularIndexes];
|
||||||
|
}
|
||||||
|
|
||||||
|
// Initialize searchableFields on constructor (not prototype)
|
||||||
|
if (metadata.searchableFields && !Array.isArray((decoratedClass as any).searchableFields)) {
|
||||||
|
(decoratedClass as any).searchableFields = [...metadata.searchableFields];
|
||||||
|
}
|
||||||
|
|
||||||
|
// Initialize _svDbOptions from metadata
|
||||||
|
if (metadata._svDbOptions && !originalConstructor._svDbOptions) {
|
||||||
|
originalConstructor._svDbOptions = { ...metadata._svDbOptions };
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
return decoratedClass as any;
|
||||||
};
|
};
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -28,15 +28,42 @@ export interface SearchOptions<T> {
|
|||||||
|
|
||||||
export type TDocCreation = 'db' | 'new' | 'mixed';
|
export type TDocCreation = 'db' | 'new' | 'mixed';
|
||||||
|
|
||||||
|
// Type for decorator metadata - extends TypeScript's built-in DecoratorMetadataObject
|
||||||
|
interface ISmartdataDecoratorMetadata extends DecoratorMetadataObject {
|
||||||
|
globalSaveableProperties?: string[];
|
||||||
|
saveableProperties?: string[];
|
||||||
|
uniqueIndexes?: string[];
|
||||||
|
regularIndexes?: Array<{field: string, options: IIndexOptions}>;
|
||||||
|
searchableFields?: string[];
|
||||||
|
_svDbOptions?: Record<string, SvDbOptions>;
|
||||||
|
}
|
||||||
|
|
||||||
export function globalSvDb() {
|
export function globalSvDb() {
|
||||||
return (target: SmartDataDbDoc<unknown, unknown>, key: string) => {
|
return (value: undefined, context: ClassFieldDecoratorContext) => {
|
||||||
logger.log('debug', `called svDb() on >${target.constructor.name}.${key}<`);
|
if (context.kind !== 'field') {
|
||||||
if (!target.globalSaveableProperties) {
|
throw new Error('globalSvDb can only decorate fields');
|
||||||
target.globalSaveableProperties = [];
|
|
||||||
}
|
}
|
||||||
target.globalSaveableProperties.push(key);
|
|
||||||
|
// Store metadata at class level using Symbol.metadata
|
||||||
|
const metadata = context.metadata as ISmartdataDecoratorMetadata;
|
||||||
|
if (!metadata.globalSaveableProperties) {
|
||||||
|
metadata.globalSaveableProperties = [];
|
||||||
|
}
|
||||||
|
metadata.globalSaveableProperties.push(String(context.name));
|
||||||
|
|
||||||
|
logger.log('debug', `called globalSvDb() on metadata for property ${String(context.name)}`);
|
||||||
|
|
||||||
|
// Use addInitializer to ensure prototype arrays are set up once
|
||||||
|
context.addInitializer(function(this: any) {
|
||||||
|
const proto = this.constructor.prototype;
|
||||||
|
const metadata = this.constructor[Symbol.metadata];
|
||||||
|
|
||||||
|
if (metadata && metadata.globalSaveableProperties && !proto.globalSaveableProperties) {
|
||||||
|
// Initialize prototype array from metadata (runs once per class)
|
||||||
|
proto.globalSaveableProperties = [...metadata.globalSaveableProperties];
|
||||||
|
logger.log('debug', `initialized globalSaveableProperties with ${proto.globalSaveableProperties.length} properties`);
|
||||||
|
}
|
||||||
|
});
|
||||||
};
|
};
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -54,20 +81,47 @@ export interface SvDbOptions {
|
|||||||
* saveable - saveable decorator to be used on class properties
|
* saveable - saveable decorator to be used on class properties
|
||||||
*/
|
*/
|
||||||
export function svDb(options?: SvDbOptions) {
|
export function svDb(options?: SvDbOptions) {
|
||||||
return (target: SmartDataDbDoc<unknown, unknown>, key: string) => {
|
return (value: undefined, context: ClassFieldDecoratorContext) => {
|
||||||
logger.log('debug', `called svDb() on >${target.constructor.name}.${key}<`);
|
if (context.kind !== 'field') {
|
||||||
if (!target.saveableProperties) {
|
throw new Error('svDb can only decorate fields');
|
||||||
target.saveableProperties = [];
|
|
||||||
}
|
}
|
||||||
target.saveableProperties.push(key);
|
|
||||||
// attach custom serializer/deserializer options to the class constructor
|
const propName = String(context.name);
|
||||||
const ctor = target.constructor as any;
|
|
||||||
if (!ctor._svDbOptions) {
|
// Store metadata at class level using Symbol.metadata
|
||||||
ctor._svDbOptions = {};
|
const metadata = context.metadata as ISmartdataDecoratorMetadata;
|
||||||
|
if (!metadata.saveableProperties) {
|
||||||
|
metadata.saveableProperties = [];
|
||||||
}
|
}
|
||||||
|
metadata.saveableProperties.push(propName);
|
||||||
|
|
||||||
|
// Store options in metadata
|
||||||
if (options) {
|
if (options) {
|
||||||
ctor._svDbOptions[key] = options;
|
if (!metadata._svDbOptions) {
|
||||||
|
metadata._svDbOptions = {};
|
||||||
}
|
}
|
||||||
|
metadata._svDbOptions[propName] = options;
|
||||||
|
}
|
||||||
|
|
||||||
|
logger.log('debug', `called svDb() on metadata for property ${propName}`);
|
||||||
|
|
||||||
|
// Use addInitializer to ensure prototype arrays are set up once
|
||||||
|
context.addInitializer(function(this: any) {
|
||||||
|
const proto = this.constructor.prototype;
|
||||||
|
const ctor = this.constructor;
|
||||||
|
const metadata = ctor[Symbol.metadata];
|
||||||
|
|
||||||
|
if (metadata && metadata.saveableProperties && !proto.saveableProperties) {
|
||||||
|
// Initialize prototype array from metadata (runs once per class)
|
||||||
|
proto.saveableProperties = [...metadata.saveableProperties];
|
||||||
|
logger.log('debug', `initialized saveableProperties with ${proto.saveableProperties.length} properties`);
|
||||||
|
}
|
||||||
|
|
||||||
|
// Initialize svDbOptions from metadata
|
||||||
|
if (metadata && metadata._svDbOptions && !ctor._svDbOptions) {
|
||||||
|
ctor._svDbOptions = { ...metadata._svDbOptions };
|
||||||
|
}
|
||||||
|
});
|
||||||
};
|
};
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -75,13 +129,30 @@ export function svDb(options?: SvDbOptions) {
|
|||||||
* searchable - marks a property as searchable with Lucene query syntax
|
* searchable - marks a property as searchable with Lucene query syntax
|
||||||
*/
|
*/
|
||||||
export function searchable() {
|
export function searchable() {
|
||||||
return (target: SmartDataDbDoc<unknown, unknown>, key: string) => {
|
return (value: undefined, context: ClassFieldDecoratorContext) => {
|
||||||
// Attach to class constructor for direct access
|
if (context.kind !== 'field') {
|
||||||
const ctor = target.constructor as any;
|
throw new Error('searchable can only decorate fields');
|
||||||
if (!Array.isArray(ctor.searchableFields)) {
|
|
||||||
ctor.searchableFields = [];
|
|
||||||
}
|
}
|
||||||
ctor.searchableFields.push(key);
|
|
||||||
|
const propName = String(context.name);
|
||||||
|
|
||||||
|
// Store metadata at class level
|
||||||
|
const metadata = context.metadata as ISmartdataDecoratorMetadata;
|
||||||
|
if (!metadata.searchableFields) {
|
||||||
|
metadata.searchableFields = [];
|
||||||
|
}
|
||||||
|
metadata.searchableFields.push(propName);
|
||||||
|
|
||||||
|
// Use addInitializer to set up constructor property once
|
||||||
|
context.addInitializer(function(this: any) {
|
||||||
|
const ctor = this.constructor as any;
|
||||||
|
const metadata = ctor[Symbol.metadata];
|
||||||
|
|
||||||
|
if (metadata && metadata.searchableFields && !Array.isArray(ctor.searchableFields)) {
|
||||||
|
// Initialize from metadata (runs once per class)
|
||||||
|
ctor.searchableFields = [...metadata.searchableFields];
|
||||||
|
}
|
||||||
|
});
|
||||||
};
|
};
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -94,20 +165,44 @@ function escapeForRegex(input: string): string {
|
|||||||
* unique index - decorator to mark a unique index
|
* unique index - decorator to mark a unique index
|
||||||
*/
|
*/
|
||||||
export function unI() {
|
export function unI() {
|
||||||
return (target: SmartDataDbDoc<unknown, unknown>, key: string) => {
|
return (value: undefined, context: ClassFieldDecoratorContext) => {
|
||||||
logger.log('debug', `called unI on >>${target.constructor.name}.${key}<<`);
|
if (context.kind !== 'field') {
|
||||||
|
throw new Error('unI can only decorate fields');
|
||||||
// mark the index as unique
|
|
||||||
if (!target.uniqueIndexes) {
|
|
||||||
target.uniqueIndexes = [];
|
|
||||||
}
|
}
|
||||||
target.uniqueIndexes.push(key);
|
|
||||||
|
|
||||||
// and also save it
|
const propName = String(context.name);
|
||||||
if (!target.saveableProperties) {
|
|
||||||
target.saveableProperties = [];
|
// Store metadata at class level
|
||||||
|
const metadata = context.metadata as ISmartdataDecoratorMetadata;
|
||||||
|
if (!metadata.uniqueIndexes) {
|
||||||
|
metadata.uniqueIndexes = [];
|
||||||
}
|
}
|
||||||
target.saveableProperties.push(key);
|
metadata.uniqueIndexes.push(propName);
|
||||||
|
|
||||||
|
// Also mark as saveable
|
||||||
|
if (!metadata.saveableProperties) {
|
||||||
|
metadata.saveableProperties = [];
|
||||||
|
}
|
||||||
|
if (!metadata.saveableProperties.includes(propName)) {
|
||||||
|
metadata.saveableProperties.push(propName);
|
||||||
|
}
|
||||||
|
|
||||||
|
logger.log('debug', `called unI on metadata for property ${propName}`);
|
||||||
|
|
||||||
|
// Use addInitializer to ensure prototype arrays are set up once
|
||||||
|
context.addInitializer(function(this: any) {
|
||||||
|
const proto = this.constructor.prototype;
|
||||||
|
const metadata = this.constructor[Symbol.metadata];
|
||||||
|
|
||||||
|
if (metadata && metadata.uniqueIndexes && !proto.uniqueIndexes) {
|
||||||
|
proto.uniqueIndexes = [...metadata.uniqueIndexes];
|
||||||
|
logger.log('debug', `initialized uniqueIndexes with ${proto.uniqueIndexes.length} properties`);
|
||||||
|
}
|
||||||
|
|
||||||
|
if (metadata && metadata.saveableProperties && !proto.saveableProperties) {
|
||||||
|
proto.saveableProperties = [...metadata.saveableProperties];
|
||||||
|
}
|
||||||
|
});
|
||||||
};
|
};
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -126,28 +221,47 @@ export interface IIndexOptions {
|
|||||||
* index - decorator to mark a field for regular indexing
|
* index - decorator to mark a field for regular indexing
|
||||||
*/
|
*/
|
||||||
export function index(options?: IIndexOptions) {
|
export function index(options?: IIndexOptions) {
|
||||||
return (target: SmartDataDbDoc<unknown, unknown>, key: string) => {
|
return (value: undefined, context: ClassFieldDecoratorContext) => {
|
||||||
logger.log('debug', `called index() on >${target.constructor.name}.${key}<`);
|
if (context.kind !== 'field') {
|
||||||
|
throw new Error('index can only decorate fields');
|
||||||
// Initialize regular indexes array if it doesn't exist
|
|
||||||
if (!target.regularIndexes) {
|
|
||||||
target.regularIndexes = [];
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// Add this field to regularIndexes with its options
|
const propName = String(context.name);
|
||||||
target.regularIndexes.push({
|
|
||||||
field: key,
|
// Store metadata at class level
|
||||||
|
const metadata = context.metadata as ISmartdataDecoratorMetadata;
|
||||||
|
if (!metadata.regularIndexes) {
|
||||||
|
metadata.regularIndexes = [];
|
||||||
|
}
|
||||||
|
metadata.regularIndexes.push({
|
||||||
|
field: propName,
|
||||||
options: options || {}
|
options: options || {}
|
||||||
});
|
});
|
||||||
|
|
||||||
// Also ensure it's marked as saveable
|
// Also mark as saveable
|
||||||
if (!target.saveableProperties) {
|
if (!metadata.saveableProperties) {
|
||||||
target.saveableProperties = [];
|
metadata.saveableProperties = [];
|
||||||
|
}
|
||||||
|
if (!metadata.saveableProperties.includes(propName)) {
|
||||||
|
metadata.saveableProperties.push(propName);
|
||||||
}
|
}
|
||||||
|
|
||||||
if (!target.saveableProperties.includes(key)) {
|
logger.log('debug', `called index() on metadata for property ${propName}`);
|
||||||
target.saveableProperties.push(key);
|
|
||||||
|
// Use addInitializer to ensure prototype arrays are set up once
|
||||||
|
context.addInitializer(function(this: any) {
|
||||||
|
const proto = this.constructor.prototype;
|
||||||
|
const metadata = this.constructor[Symbol.metadata];
|
||||||
|
|
||||||
|
if (metadata && metadata.regularIndexes && !proto.regularIndexes) {
|
||||||
|
proto.regularIndexes = [...metadata.regularIndexes];
|
||||||
|
logger.log('debug', `initialized regularIndexes with ${proto.regularIndexes.length} indexes`);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if (metadata && metadata.saveableProperties && !proto.saveableProperties) {
|
||||||
|
proto.saveableProperties = [...metadata.saveableProperties];
|
||||||
|
}
|
||||||
|
});
|
||||||
};
|
};
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -199,21 +313,51 @@ export const convertFilterForMongoDb = (filterArg: { [key: string]: any }) => {
|
|||||||
throw new Error('$where operator is not allowed for security reasons');
|
throw new Error('$where operator is not allowed for security reasons');
|
||||||
}
|
}
|
||||||
|
|
||||||
// Special case: detect MongoDB operators and pass them through directly
|
// Handle logical operators recursively
|
||||||
const topLevelOperators = ['$and', '$or', '$nor', '$not', '$text', '$regex'];
|
const logicalOperators = ['$and', '$or', '$nor', '$not'];
|
||||||
|
const processedFilter: { [key: string]: any } = {};
|
||||||
|
|
||||||
for (const key of Object.keys(filterArg)) {
|
for (const key of Object.keys(filterArg)) {
|
||||||
if (topLevelOperators.includes(key)) {
|
if (logicalOperators.includes(key)) {
|
||||||
return filterArg; // Return the filter as-is for MongoDB operators
|
if (key === '$not') {
|
||||||
|
processedFilter[key] = convertFilterForMongoDb(filterArg[key]);
|
||||||
|
} else if (Array.isArray(filterArg[key])) {
|
||||||
|
processedFilter[key] = filterArg[key].map((subFilter: any) => convertFilterForMongoDb(subFilter));
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// If only logical operators, return them
|
||||||
|
const hasOnlyLogicalOperators = Object.keys(filterArg).every(key => logicalOperators.includes(key));
|
||||||
|
if (hasOnlyLogicalOperators) {
|
||||||
|
return processedFilter;
|
||||||
|
}
|
||||||
|
|
||||||
// Original conversion logic for non-MongoDB query objects
|
// Original conversion logic for non-MongoDB query objects
|
||||||
const convertedFilter: { [key: string]: any } = {};
|
const convertedFilter: { [key: string]: any } = {};
|
||||||
|
|
||||||
|
// Helper to merge operator objects
|
||||||
|
const mergeIntoConverted = (path: string, value: any) => {
|
||||||
|
const existing = convertedFilter[path];
|
||||||
|
if (!existing) {
|
||||||
|
convertedFilter[path] = value;
|
||||||
|
} else if (
|
||||||
|
typeof existing === 'object' && !Array.isArray(existing) &&
|
||||||
|
typeof value === 'object' && !Array.isArray(value) &&
|
||||||
|
(Object.keys(existing).some(k => k.startsWith('$')) || Object.keys(value).some(k => k.startsWith('$')))
|
||||||
|
) {
|
||||||
|
// Both have operators, merge them
|
||||||
|
convertedFilter[path] = { ...existing, ...value };
|
||||||
|
} else {
|
||||||
|
// Otherwise later wins
|
||||||
|
convertedFilter[path] = value;
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
const convertFilterArgument = (keyPathArg2: string, filterArg2: any) => {
|
const convertFilterArgument = (keyPathArg2: string, filterArg2: any) => {
|
||||||
if (Array.isArray(filterArg2)) {
|
if (Array.isArray(filterArg2)) {
|
||||||
// Arrays are typically used as values for operators like $in or as direct equality matches
|
// Arrays are typically used as values for operators like $in or as direct equality matches
|
||||||
convertedFilter[keyPathArg2] = filterArg2;
|
mergeIntoConverted(keyPathArg2, filterArg2);
|
||||||
return;
|
return;
|
||||||
} else if (typeof filterArg2 === 'object' && filterArg2 !== null) {
|
} else if (typeof filterArg2 === 'object' && filterArg2 !== null) {
|
||||||
// Check if this is an object with MongoDB operators
|
// Check if this is an object with MongoDB operators
|
||||||
@@ -264,8 +408,8 @@ export const convertFilterForMongoDb = (filterArg: { [key: string]: any }) => {
|
|||||||
throw new Error('$size operator requires a numeric value');
|
throw new Error('$size operator requires a numeric value');
|
||||||
}
|
}
|
||||||
|
|
||||||
// Pass the operator object through
|
// Use merge helper to handle duplicate paths
|
||||||
convertedFilter[keyPathArg2] = filterArg2;
|
mergeIntoConverted(keyPathArg2, filterArg2);
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -282,13 +426,20 @@ export const convertFilterForMongoDb = (filterArg: { [key: string]: any }) => {
|
|||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
// Primitive values
|
// Primitive values
|
||||||
convertedFilter[keyPathArg2] = filterArg2;
|
mergeIntoConverted(keyPathArg2, filterArg2);
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
|
|
||||||
for (const key of Object.keys(filterArg)) {
|
for (const key of Object.keys(filterArg)) {
|
||||||
|
// Skip logical operators, they were already processed
|
||||||
|
if (!logicalOperators.includes(key)) {
|
||||||
convertFilterArgument(key, filterArg[key]);
|
convertFilterArgument(key, filterArg[key]);
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// Add back processed logical operators
|
||||||
|
Object.assign(convertedFilter, processedFilter);
|
||||||
|
|
||||||
return convertedFilter;
|
return convertedFilter;
|
||||||
};
|
};
|
||||||
|
|
||||||
@@ -302,6 +453,13 @@ export class SmartDataDbDoc<T extends TImplements, TImplements, TManager extends
|
|||||||
public static manager;
|
public static manager;
|
||||||
public manager: TManager;
|
public manager: TManager;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Helper to get collection with fallback to static for Deno compatibility
|
||||||
|
*/
|
||||||
|
private getCollectionSafe(): SmartdataCollection<any> {
|
||||||
|
return this.collection || (this.constructor as any).collection;
|
||||||
|
}
|
||||||
|
|
||||||
// STATIC
|
// STATIC
|
||||||
public static createInstanceFromMongoDbNativeDoc<T>(
|
public static createInstanceFromMongoDbNativeDoc<T>(
|
||||||
this: plugins.tsclass.typeFest.Class<T>,
|
this: plugins.tsclass.typeFest.Class<T>,
|
||||||
@@ -661,23 +819,28 @@ export class SmartDataDbDoc<T extends TImplements, TImplements, TManager extends
|
|||||||
|
|
||||||
/**
|
/**
|
||||||
* an array of saveable properties of ALL doc
|
* an array of saveable properties of ALL doc
|
||||||
|
* Note: Set by decorators on prototype - NOT declared as instance property to avoid shadowing in Deno
|
||||||
|
* Declared with definite assignment assertion to satisfy TypeScript without creating instance property
|
||||||
*/
|
*/
|
||||||
public globalSaveableProperties: string[];
|
declare globalSaveableProperties: string[];
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* unique indexes
|
* unique indexes
|
||||||
|
* Note: Set by decorators on prototype - NOT declared as instance property to avoid shadowing in Deno
|
||||||
*/
|
*/
|
||||||
public uniqueIndexes: string[];
|
declare uniqueIndexes: string[];
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* regular indexes with their options
|
* regular indexes with their options
|
||||||
|
* Note: Set by decorators on prototype - NOT declared as instance property to avoid shadowing in Deno
|
||||||
*/
|
*/
|
||||||
public regularIndexes: Array<{field: string, options: IIndexOptions}> = [];
|
declare regularIndexes: Array<{field: string, options: IIndexOptions}>;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* an array of saveable properties of a specific doc
|
* an array of saveable properties of a specific doc
|
||||||
|
* Note: Set by decorators on prototype - NOT declared as instance property to avoid shadowing in Deno
|
||||||
*/
|
*/
|
||||||
public saveableProperties: string[];
|
declare saveableProperties: string[];
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* name
|
* name
|
||||||
@@ -710,10 +873,10 @@ export class SmartDataDbDoc<T extends TImplements, TImplements, TManager extends
|
|||||||
// perform insert or update
|
// perform insert or update
|
||||||
switch (this.creationStatus) {
|
switch (this.creationStatus) {
|
||||||
case 'db':
|
case 'db':
|
||||||
dbResult = await this.collection.update(self, { session: opts?.session });
|
dbResult = await this.getCollectionSafe().update(self, { session: opts?.session });
|
||||||
break;
|
break;
|
||||||
case 'new':
|
case 'new':
|
||||||
dbResult = await this.collection.insert(self, { session: opts?.session });
|
dbResult = await this.getCollectionSafe().insert(self, { session: opts?.session });
|
||||||
this.creationStatus = 'db';
|
this.creationStatus = 'db';
|
||||||
break;
|
break;
|
||||||
default:
|
default:
|
||||||
@@ -735,7 +898,7 @@ export class SmartDataDbDoc<T extends TImplements, TImplements, TManager extends
|
|||||||
await (this as any).beforeDelete();
|
await (this as any).beforeDelete();
|
||||||
}
|
}
|
||||||
// perform deletion
|
// perform deletion
|
||||||
const result = await this.collection.delete(this, { session: opts?.session });
|
const result = await this.getCollectionSafe().delete(this, { session: opts?.session });
|
||||||
// allow hook after delete
|
// allow hook after delete
|
||||||
if (typeof (this as any).afterDelete === 'function') {
|
if (typeof (this as any).afterDelete === 'function') {
|
||||||
await (this as any).afterDelete();
|
await (this as any).afterDelete();
|
||||||
@@ -765,7 +928,7 @@ export class SmartDataDbDoc<T extends TImplements, TImplements, TManager extends
|
|||||||
* updates an object from db
|
* updates an object from db
|
||||||
*/
|
*/
|
||||||
public async updateFromDb(): Promise<boolean> {
|
public async updateFromDb(): Promise<boolean> {
|
||||||
const mongoDbNativeDoc = await this.collection.findOne(await this.createIdentifiableObject());
|
const mongoDbNativeDoc = await this.getCollectionSafe().findOne(await this.createIdentifiableObject());
|
||||||
if (!mongoDbNativeDoc) {
|
if (!mongoDbNativeDoc) {
|
||||||
return false; // Document not found in database
|
return false; // Document not found in database
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1,6 +1,6 @@
|
|||||||
import { SmartDataDbDoc } from './classes.doc.js';
|
import { SmartDataDbDoc } from './classes.doc.js';
|
||||||
import * as plugins from './plugins.js';
|
import * as plugins from './plugins.js';
|
||||||
import { EventEmitter } from 'events';
|
import { EventEmitter } from 'node:events';
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* a wrapper for the native mongodb cursor. Exposes better
|
* a wrapper for the native mongodb cursor. Exposes better
|
||||||
|
|||||||
@@ -1,7 +1,5 @@
|
|||||||
{
|
{
|
||||||
"compilerOptions": {
|
"compilerOptions": {
|
||||||
"experimentalDecorators": true,
|
|
||||||
"useDefineForClassFields": false,
|
|
||||||
"target": "ES2022",
|
"target": "ES2022",
|
||||||
"module": "NodeNext",
|
"module": "NodeNext",
|
||||||
"moduleResolution": "NodeNext",
|
"moduleResolution": "NodeNext",
|
||||||
|
|||||||
Reference in New Issue
Block a user