import { VectorAIClient, Field, Filter } from '@actian/vectorai-client';

const client = new VectorAIClient('localhost:6574');

// Create a collection
await client.collections.create('products', {
    dimension: 128,
    distanceMetric: 'COSINE',
});

// Insert points
await client.points.upsert('products', [
    { id: 1, vector: new Array(128).fill(0.1), payload: { category: 'electronics' } },
    { id: 2, vector: new Array(128).fill(0.2), payload: { category: 'books' } },
]);

// Search with a filter
const filter = Filter.and(
    Field.of('category').eq('electronics'),
);
const results = await client.points.search('products', new Array(128).fill(0.15), {
    limit: 5,
    filter,
});

console.log(results);

// Cleanup
await client.collections.delete('products');
client.close();

const client = new VectorAIClient('localhost:6574', {
    tls: true,
    tlsCaCert: '/path/to/ca.pem',
    accessToken: 'vdai_my-secret-key',
    timeout: 30,
    maxRetries: 3,
});

const client = new VectorAIClient('localhost:6574', {
    accessToken: 'vdai_abc123...',
});

// No args needed — reads from env
const client = new VectorAIClient();
await client.healthCheck();

import { AuthManager } from '@actian/vectorai-client';

const auth = new AuthManager('http://localhost:6573');
await auth.login('admin-password');           // obtain JWT
const key = await auth.createApiKey({         // create API key
    name: 'my-service',
    permission: 'read,write',
});
console.log(key.apiKey);                      // vdai_...

const client = new VectorAIClient('localhost:6574');
await client.auth.login('admin-password');
const keys = await client.auth.listApiKeys();

import { Field, Filter, FilterBuilder, hasId, hasVector, nested, isEmpty, isNull } from '@actian/vectorai-client';

// Field conditions
const f1 = Field.of('price').lt(100);
const f2 = Field.of('category').in(['electronics', 'books']);
const f3 = Field.of('tags').contains('sale');

// Aliases
const f2b = Field.of('category').anyOf(['electronics', 'books']); // same as .in()

// Datetime filters
const f9 = Field.of('created_at').datetimeGt(new Date('2024-01-01'));
const f10 = Field.of('expires').datetimeBetween(new Date('2024-01-01'), new Date('2024-12-31'));

// Geo conditions
const f4 = Field.of('location').geoRadius({ lat: 40.7, lon: -74.0 }, 5000);

// Utility conditions
const f5 = hasId([1, 2, 3]);
const f6 = hasVector('image_embedding');
const f7 = isEmpty('description'); // standalone factory
const f8 = nested('address', Filter.and(Field.of('city').eq('NYC')));

// Combine
const filter = Filter.and(f1, f2, Filter.not(f3));

// FilterBuilder (fluent must/should/mustNot composition)
const fb = new FilterBuilder();
fb.must(f1);
fb.should(f2).should(f3);
fb.withMinShould(1);
const builtFilter = fb.build(); // returns a Filter (recommended)

// Use with search
await client.points.search('products', queryVector, { filter, limit: 10 });

import { CircuitBreaker, BackpressureController, RetryConfig, createCircuitBreakerInterceptor } from '@actian/vectorai-client';

// Circuit breaker (standalone — not auto-wired to client)
const cb = new CircuitBreaker(/* failureThreshold */ 5, /* recoveryTimeout */ 30_000);
cb.ensureClosed();  // throws CircuitBreakerOpenError if open
cb.recordSuccess(); // after successful call
cb.recordFailure(); // after failed call

// Use as gRPC interceptor
const interceptor = createCircuitBreakerInterceptor(cb);

// Backpressure controller (adaptive concurrency)
const bp = new BackpressureController({ initialConcurrency: 16 });
await bp.acquire();
try { /* ... call ... */ } finally { bp.release(); }

// Retry config (standalone utility)
const rc = new RetryConfig({ maxRetries: 5, initialBackoffMs: 200 });
const delay = rc.computeDelay(/* attempt */ 2); // jittered exponential backoff