mirror of
https://github.com/hcengineering/platform.git
synced 2026-08-26 06:12:23 +02:00
+1








98652c6476
* Add bump-changes * Add utility tests * Add utility tests * Bump to new version of esbuild and typescript * v0.7.3 * use platform rig 0.7.10 * upgrade: memory engine optimized; change name to (was recommended by Copilot and Onnikov, TODO: CHANGE CLIENT TOO!!!) Signed-off-by: Leonid Kaganov <lleo@lleo.me> * Fix rate limits bug * Bump versions * Fix lock file * Fix bug in queue cleanup * Add more tests for queue * Add api-test tests * Initial commit * Improve hierarchy + tests Add tests for hierarchy and few performance/memory optimizations. * Add more hierarchy tests * Move from Huly platform repository * Add docker tests setup * Fix test to be executed only once * Add connection tests * Fix package include source files * More tests * Create README.md * Fix pnpm lock * Fix packages publish * Remove broken tests * feat: adjust hulylake client for storage adapter Signed-off-by: Alexander Onnikov <Alexander.Onnikov@xored.com> * Fix export * Fix publish * Fix message update (#114) Signed-off-by: Kristina Fefelova <kristin.fefelova@gmail.com> * Bump version Signed-off-by: Kristina Fefelova <kristin.fefelova@gmail.com> * Bump versions Signed-off-by: Alexander Onnikov <Alexander.Onnikov@xored.com> * Fix lang store (#115) Signed-off-by: Kristina Fefelova <kristin.fefelova@gmail.com> * update hulylake client Signed-off-by: Alexander Onnikov <Alexander.Onnikov@xored.com> * Bump version Signed-off-by: Alexander Onnikov <Alexander.Onnikov@xored.com> * Add hulylake storage adapter Signed-off-by: Alexander Onnikov <Alexander.Onnikov@xored.com> * Bump version Signed-off-by: Alexander Onnikov <Alexander.Onnikov@xored.com> * fix validation issues Signed-off-by: Alexander Onnikov <Alexander.Onnikov@xored.com> * fix: do not fail on deseralization error and add logs Signed-off-by: Alexander Onnikov <Alexander.Onnikov@xored.com> * bump version -> 0.1.14 Signed-off-by: Alexander Onnikov <Alexander.Onnikov@xored.com> * fix collaboration test Signed-off-by: Alexander Onnikov <Alexander.Onnikov@xored.com> * Update prettier and new update-deps script Prettier + svelte support * fix unstable ydoc tests Signed-off-by: Alexander Onnikov <Alexander.Onnikov@xored.com> * Add tx ordering middleware * Fix ordering tests * Fix Kafka close of admin * Add tests for measurement and understand overhead * Fix not updated lock file * Fix update-deps * Fix update-deps * Use latest platform-rig * Fix deps * Add rush check to CI * Use latest versions * Bump versions * Fix lock file * validate json patch Signed-off-by: Alexander Onnikov <Alexander.Onnikov@xored.com> * bump version -> 0.1.15 Signed-off-by: Alexander Onnikov <Alexander.Onnikov@xored.com> * fix merge unit tests Signed-off-by: Alexander Onnikov <Alexander.Onnikov@xored.com> * Script to sync eslint deps * Fix deps * Fix tests * Fix platform-rig detection * Update to latest platform-rig * Update to latest platform rig and core * Bump typescript * Bump typescript * Rollback eslint plugins * Fix lock file * Bump platform-rig * Update to latest platform-rig * update to latest platform-rig * Allow to compile svelte files * Add ui-test component for checking compile * Fix log levels rename compile ui -> compile ui-esbuild * Fix build * Bump esbuild svelte version * Chore: use fixed versions in update-deps Signed-off-by: Alexey Zinoviev <alexey.zinoviev@xored.com> * Chore: commit changes Signed-off-by: Alexey Zinoviev <alexey.zinoviev@xored.com> * Update deps * Add tests for session manager * Fix txOrdering implementation * Bump ordering * Prevent metrics zero values in measure + Fix format svelte files * Revert update-deps script logic * v0.7.19 * update to latest platform-rig * Update deps * Fix pnpm * Session counters * Fix pnpm lock * Add storage client Signed-off-by: Alexander Onnikov <Alexander.Onnikov@xored.com> * Bump versions Signed-off-by: Alexander Onnikov <Alexander.Onnikov@xored.com> * fix versions Signed-off-by: Alexander Onnikov <Alexander.Onnikov@xored.com> * Bump core * Fix pnpm * Get rid of communication dependency * Add copilot memory file * Use proper name for instructions file * Fix instructions * Use domain instead of test name in gauges * Update instructions file * fix front service upload Signed-off-by: Alexander Onnikov <Alexander.Onnikov@xored.com> * remove incorrect test Signed-off-by: Alexander Onnikov <Alexander.Onnikov@xored.com> * Move packages to huly.core * Move packages to core, since they are not utils * Add global user profile Signed-off-by: Alexey Zinoviev <alexey.zinoviev@xored.com> * Fix lock file Signed-off-by: Alexey Zinoviev <alexey.zinoviev@xored.com> * Add support for memory limit check * Bump version * Fix pnpm * report more accurate upload progress Signed-off-by: Alexander Onnikov <Alexander.Onnikov@xored.com> * fic validation issues Signed-off-by: Alexander Onnikov <Alexander.Onnikov@xored.com> * Fix deps Signed-off-by: Kristina Fefelova <kristin.fefelova@gmail.com> * Move LowLevelStorage to server * Fix linting * Revert "Fix linting" This reverts commit54631d353e. * Revert "Move LowLevelStorage to server" This reverts commitaafb8f6f12. * feature: add regorus engine with permit file Signed-off-by: Leonid Kaganov <lleo@lleo.me> * Fix one second counters for memory usage * Fix kafka test * use fresh core * Version bump * fix: key parameter added Signed-off-by: Leonid Kaganov <lleo@lleo.me> * Fix readme and few author mistakes * Export domain schemas * Bump version * Tests (#117) Signed-off-by: Kristina Fefelova <kristin.fefelova@gmail.com> * Bump version Signed-off-by: Kristina Fefelova <kristin.fefelova@gmail.com> * feat: compact compact worker (#4) Signed-off-by: Alexander Onnikov <Alexander.Onnikov@xored.com> * bump version -> 0.1.16 Signed-off-by: Alexander Onnikov <Alexander.Onnikov@xored.com> * Add TypeIdentifier Signed-off-by: Denis Bykhov <bykhov.denis@gmail.com> * Add change logs Signed-off-by: Denis Bykhov <bykhov.denis@gmail.com> * rename send -> try_send Signed-off-by: Alexander Onnikov <Alexander.Onnikov@xored.com> * Bump Signed-off-by: Denis Bykhov <bykhov.denis@gmail.com> * Fix pnpm lock Signed-off-by: Denis Bykhov <bykhov.denis@gmail.com> * Add identifier middleware, bump core Signed-off-by: Denis Bykhov <bykhov.denis@gmail.com> * Add subsciption methods to account client Signed-off-by: Alexey Zinoviev <alexey.zinoviev@xored.com> * Fix lock file Signed-off-by: Alexey Zinoviev <alexey.zinoviev@xored.com> * Fix reaction notification (#118) Signed-off-by: Kristina Fefelova <kristin.fefelova@gmail.com> * Bump version Signed-off-by: Kristina Fefelova <kristin.fefelova@gmail.com> * Improve find methods schemas to convert to valid types Signed-off-by: Nikolay Marchuk <nikolay.marchuk@hardcoreeng.com> * Add change description Signed-off-by: Nikolay Marchuk <nikolay.marchuk@hardcoreeng.com> * Do not transcode while recording Signed-off-by: Alexander Onnikov <Alexander.Onnikov@xored.com> * Open telemetry support Signed-off-by: Alexander Onnikov <Alexander.Onnikov@xored.com> * use proper content type in multipart upload Signed-off-by: Alexander Onnikov <Alexander.Onnikov@xored.com> * Bump versions Signed-off-by: Alexander Onnikov <Alexander.Onnikov@xored.com> * fix build (#26) Signed-off-by: Alexander Onnikov <Alexander.Onnikov@xored.com> * Fix peers (#120) Signed-off-by: Kristina Fefelova <kristin.fefelova@gmail.com> * Bump version Signed-off-by: Kristina Fefelova <kristin.fefelova@gmail.com> * Add ActivityCollaborativeChange Signed-off-by: Denis Bykhov <bykhov.denis@gmail.com> * Update pnpm Signed-off-by: Denis Bykhov <bykhov.denis@gmail.com> * Allow to suspend errors on with * Fix pnpm cache * update versions * v0.7.17 for all * v0.7.11 * v0.7.14 * remove arc from worker Signed-off-by: Alexander Onnikov <Alexander.Onnikov@xored.com> * bump version -> 0.1.17 Signed-off-by: Alexander Onnikov <Alexander.Onnikov@xored.com> * Rank for attributes Signed-off-by: Denis Bykhov <bykhov.denis@gmail.com> * Update pnpm Signed-off-by: Denis Bykhov <bykhov.denis@gmail.com> * Fix one second counters * Fix withContext and allow pass options * Fix formatting * Use updated deps * Bump versions * Update deps * Update deps to platform.core * add support for textColor mark Signed-off-by: Alexander Onnikov <Alexander.Onnikov@xored.com> * add support for textStyle mark Signed-off-by: Alexander Onnikov <Alexander.Onnikov@xored.com> * Bump versions Signed-off-by: Alexander Onnikov <Alexander.Onnikov@xored.com> * Bump versions again Signed-off-by: Alexander Onnikov <Alexander.Onnikov@xored.com> * Fix Signed-off-by: Denis Bykhov <bykhov.denis@gmail.com> * Rework on second timers * fix merge of large blobs feched from s3 Signed-off-by: Alexander Onnikov <Alexander.Onnikov@xored.com> * bump version -> 0.1.18 Signed-off-by: Alexander Onnikov <Alexander.Onnikov@xored.com> * New subscription methods in account-client * Update lock file Signed-off-by: Alexey Zinoviev <alexey.zinoviev@xored.com> * Send error on find for wrong domain * Suspend connect custom errors events in traces * Bump client * Bump core * update deps * Fix lock file * Sorting for TypeIdentifier Signed-off-by: Denis Bykhov <bykhov.denis@gmail.com> * Bump version Signed-off-by: Denis Bykhov <bykhov.denis@gmail.com> * add workspace usage info Signed-off-by: Alexander Onnikov <Alexander.Onnikov@xored.com> * Bump versions Signed-off-by: Alexander Onnikov <Alexander.Onnikov@xored.com> * Improve pg security perfomance Signed-off-by: Denis Bykhov <bykhov.denis@gmail.com> * Fix identifier middleware Signed-off-by: Denis Bykhov <bykhov.denis@gmail.com> * Update TxAccessLevel interface Signed-off-by: Alexey Zinoviev <alexey.zinoviev@xored.com> * Allow guest to update its identities Signed-off-by: Alexey Zinoviev <alexey.zinoviev@xored.com> * Add password login locked platform status Signed-off-by: Alexey Zinoviev <alexey.zinoviev@xored.com> * Fix Uptrace normalizeMarkdown errors Signed-off-by: Artem Savchenko <armisav@gmail.com> * Add change log Signed-off-by: Artem Savchenko <armisav@gmail.com> * Add txMatch to permission Signed-off-by: Denis Bykhov <bykhov.denis@gmail.com> * update pnpm lock Signed-off-by: Denis Bykhov <bykhov.denis@gmail.com> * Bump Signed-off-by: Denis Bykhov <bykhov.denis@gmail.com> * Fix permission middleware Signed-off-by: Denis Bykhov <bykhov.denis@gmail.com> * Fix enum sorting Signed-off-by: Denis Bykhov <bykhov.denis@gmail.com> * Enable formatting check Signed-off-by: Andrey Sobolev <haiodo@gmail.com> * Enable formatting check * Add change Signed-off-by: Andrey Sobolev <haiodo@gmail.com> * Fix Uptrace NaN error Signed-off-by: Artem Savchenko <armisav@gmail.com> * feature: removed actors, improved performance Signed-off-by: Leonid Kaganov <lleo@lleo.me> * feature: ping from server to clients added Signed-off-by: Leonid Kaganov <lleo@lleo.me> * feature: ping from server to clients added Signed-off-by: Leonid Kaganov <lleo@lleo.me> * Compress kafka messages and fix exception in findAll Signed-off-by: Artem Savchenko <armisav@gmail.com> * Bump versions Signed-off-by: Artem Savchenko <armisav@gmail.com> * Bump versions Signed-off-by: Artem Savchenko <armisav@gmail.com> * Rush change Signed-off-by: Artem Savchenko <armisav@gmail.com> * Fix compression param Signed-off-by: Artem Savchenko <armisav@gmail.com> * Trigger change Signed-off-by: Artem Savchenko <armisav@gmail.com> * Clean up Signed-off-by: Artem Savchenko <armisav@gmail.com> * Trigger change Signed-off-by: Artem Savchenko <armisav@gmail.com> * Bump markdown version Signed-off-by: Artem Savchenko <armisav@gmail.com> * Enable sub projects * Fix wrong double symbol scripts * Include foundation packages * Add support for custom exclude filters Add support for custom exclude filters - by Andrey Sobolev - haiodo@gmail.com Signed-off-by: Andrey Sobolev <haiodo@gmail.com> * Bump Signed-off-by: Denis Bykhov <bykhov.denis@gmail.com> * Fix Uptrace filter is not a function error Signed-off-by: Artem Savchenko <armisav@gmail.com> * Sync versions Signed-off-by: Andrey Sobolev <haiodo@gmail.com> --------- Signed-off-by: Leonid Kaganov <lleo@lleo.me> Signed-off-by: Alexander Onnikov <Alexander.Onnikov@xored.com> Signed-off-by: Kristina Fefelova <kristin.fefelova@gmail.com> Signed-off-by: Alexey Zinoviev <alexey.zinoviev@xored.com> Signed-off-by: Denis Bykhov <bykhov.denis@gmail.com> Signed-off-by: Nikolay Marchuk <nikolay.marchuk@hardcoreeng.com> Signed-off-by: Artem Savchenko <armisav@gmail.com> Signed-off-by: Andrey Sobolev <haiodo@gmail.com> Co-authored-by: Leonid Kaganov <lleo@lleo.me> Co-authored-by: Alexander Onnikov <Alexander.Onnikov@xored.com> Co-authored-by: Alexander Onnikov <Alexander.Onnikov@gmail.com> Co-authored-by: Kristina <kristin.fefelova@gmail.com> Co-authored-by: Alexey Zinoviev <alexey.zinoviev@xored.com> Co-authored-by: Denis Bykhov <bykhov.denis@gmail.com> Co-authored-by: Nikolay Marchuk <nikolay.marchuk@hardcoreeng.com> Co-authored-by: Alexander Onnikov <aonnikov@hardcoreeng.com> Co-authored-by: Artem Savchenko <armisav@gmail.com>
229 lines
5.7 KiB
Markdown
229 lines
5.7 KiB
Markdown
# Auto-Disposal Guide for Network Clients
|
|
|
|
This guide explains how to properly use auto-disposal with the `createNetworkClient()` function.
|
|
|
|
## Overview
|
|
|
|
The `NetworkClientWithAgents` class implements JavaScript's explicit resource management proposal via `Symbol.dispose` and `Symbol.asyncDispose`. This provides automatic cleanup of resources when clients go out of scope.
|
|
|
|
## When to Use `await using`
|
|
|
|
### ✅ Use `await using` for:
|
|
|
|
1. **Short-lived scripts and examples** that complete and exit
|
|
2. **Test cases** where cleanup is needed after each test
|
|
3. **Client-only applications** that don't serve agents or containers
|
|
4. **Request-response patterns** where the client is used temporarily
|
|
|
|
```typescript
|
|
// Example: Simple client usage with auto-disposal
|
|
async function fetchData() {
|
|
await using client = createNetworkClient('localhost:3737')
|
|
await client.waitConnection(5000)
|
|
|
|
const container = await client.get('my-service' as ContainerKind, {})
|
|
const result = await container.request('getData')
|
|
|
|
return result
|
|
// Client automatically disposed here
|
|
}
|
|
```
|
|
|
|
### ❌ Do NOT use `await using` for:
|
|
|
|
1. **Long-running services** that need to stay connected
|
|
2. **Applications hosting agents and containers** via `serveAgent()`
|
|
3. **Production servers** that should run indefinitely
|
|
4. **Background workers** that process jobs continuously
|
|
|
|
```typescript
|
|
// Example: Long-running service (DON'T use 'await using')
|
|
class MyService {
|
|
private client: ReturnType<typeof createNetworkClient> | null = null
|
|
|
|
async start() {
|
|
// Keep strong reference - NO 'await using'
|
|
this.client = createNetworkClient('localhost:3737')
|
|
await this.client.waitConnection(5000)
|
|
|
|
// Serve containers
|
|
await this.client.serveAgent('localhost:3738', {
|
|
'my-container': myContainerFactory
|
|
})
|
|
|
|
console.log('Service started - will run indefinitely')
|
|
}
|
|
|
|
async stop() {
|
|
// Manual cleanup when ready
|
|
if (this.client) {
|
|
await this.client.close()
|
|
this.client = null
|
|
}
|
|
}
|
|
}
|
|
|
|
// Usage
|
|
const service = new MyService()
|
|
await service.start()
|
|
|
|
// Graceful shutdown
|
|
process.on('SIGTERM', () => service.stop())
|
|
process.on('SIGINT', () => service.stop())
|
|
|
|
// Keep running
|
|
await new Promise(() => {})
|
|
```
|
|
|
|
## Auto-Disposal Behavior
|
|
|
|
When you use `await using`, the client will be automatically disposed:
|
|
|
|
1. **At the end of the block** where it was declared
|
|
2. **On exception/error** (ensures cleanup even on failures)
|
|
3. **On early return** from the function
|
|
|
|
```typescript
|
|
async function example() {
|
|
await using client = createNetworkClient('localhost:3737')
|
|
|
|
// If an error occurs here...
|
|
throw new Error('Something went wrong')
|
|
|
|
// ...client.close() is still called automatically
|
|
}
|
|
```
|
|
|
|
## Manual Disposal
|
|
|
|
For long-running services, manage the lifecycle manually:
|
|
|
|
```typescript
|
|
// Create without auto-disposal
|
|
const client = createNetworkClient('localhost:3737')
|
|
|
|
// Use the client...
|
|
await client.waitConnection(5000)
|
|
|
|
// Manual cleanup when done
|
|
await client.close()
|
|
```
|
|
|
|
## Best Practices
|
|
|
|
### For Examples and Demos
|
|
|
|
All example scripts should use `await using` for automatic cleanup:
|
|
|
|
```typescript
|
|
async function main() {
|
|
// Setup infrastructure (servers, agents)
|
|
const server = new NetworkServer(...)
|
|
const agent = new AgentImpl(...)
|
|
|
|
// Client with auto-disposal
|
|
await using client = createNetworkClient('localhost:3737')
|
|
await client.register(agent)
|
|
|
|
// Do work...
|
|
|
|
// Manual cleanup of infrastructure
|
|
await server.close()
|
|
}
|
|
```
|
|
|
|
### For Production Services
|
|
|
|
Production services should use manual lifecycle management:
|
|
|
|
```typescript
|
|
class ProductionService {
|
|
private client: NetworkClient | null = null
|
|
|
|
async start() {
|
|
this.client = createNetworkClient(config.networkUrl)
|
|
await this.client.waitConnection()
|
|
await this.setupContainers()
|
|
|
|
// Setup signal handlers
|
|
process.on('SIGTERM', () => this.shutdown())
|
|
process.on('SIGINT', () => this.shutdown())
|
|
}
|
|
|
|
async shutdown() {
|
|
console.log('Graceful shutdown initiated...')
|
|
if (this.client) {
|
|
await this.client.close()
|
|
}
|
|
process.exit(0)
|
|
}
|
|
}
|
|
```
|
|
|
|
## Migration from Old Code
|
|
|
|
If you have existing code using manual `client.close()`:
|
|
|
|
### Before (manual cleanup):
|
|
|
|
```typescript
|
|
const client = createNetworkClient('localhost:3737')
|
|
try {
|
|
await client.waitConnection(5000)
|
|
// ... use client ...
|
|
} finally {
|
|
await client.close()
|
|
}
|
|
```
|
|
|
|
### After (auto-disposal):
|
|
|
|
```typescript
|
|
await using client = createNetworkClient('localhost:3737')
|
|
await client.waitConnection(5000)
|
|
// ... use client ...
|
|
// Automatically closed
|
|
```
|
|
|
|
## Common Pitfalls
|
|
|
|
### ❌ Wrong: Using `await using` in long-running services
|
|
|
|
```typescript
|
|
// BAD: Service will stop when function returns!
|
|
async function startService() {
|
|
await using client = createNetworkClient('localhost:3737')
|
|
await client.serveAgent('localhost:3738', factories)
|
|
// Client disposed when function returns - service stops!
|
|
}
|
|
```
|
|
|
|
### ✅ Correct: Keep reference for long-running services
|
|
|
|
```typescript
|
|
// GOOD: Service keeps running
|
|
let client: NetworkClient | null = null
|
|
|
|
async function startService() {
|
|
client = createNetworkClient('localhost:3737')
|
|
await client.serveAgent('localhost:3738', factories)
|
|
// Service continues running
|
|
}
|
|
|
|
async function stopService() {
|
|
if (client) {
|
|
await client.close()
|
|
client = null
|
|
}
|
|
}
|
|
```
|
|
|
|
## Summary
|
|
|
|
- **Short-lived operations**: Use `await using` for automatic cleanup
|
|
- **Long-running services**: Use regular assignment and manual cleanup
|
|
- **Hosting agents/containers**: Always use manual lifecycle management
|
|
- **Examples and tests**: Prefer `await using` for cleaner code
|
|
|
|
The auto-disposal feature makes resource management simpler and safer for temporary client usage while still allowing full control for production services.
|