Transports

1import {
2  createLogger,
3  ConsoleTransport,
4  HTTPTransport,
5  FileTransport
6} from 'vestig'
7 
8const logger = createLogger({
9  level: 'debug',
10  transports: [
11    // Console for development
12    new ConsoleTransport({
13      enabled: process.env.NODE_ENV !== 'production',
14      colors: true
15    }),
16 
17    // HTTP for log aggregation
18    new HTTPTransport({
19      endpoint: process.env.LOG_ENDPOINT,
20      batchSize: 50,
21      headers: {
22        'Authorization': `Bearer ${process.env.LOG_API_KEY}`
23      }
24    }),
25 
26    // File for local persistence
27    new FileTransport({
28      filename: './logs/app.log',
29      maxSize: '50mb',
30      maxFiles: 10
31    })
32  ]
33})

1interface TransportConfig {
2  // Minimum log level for this transport
3  level?: LogLevel
4 
5  // Enable/disable this transport
6  enabled?: boolean
7 
8  // Custom filter function
9  filter?: (entry: LogEntry) => boolean
10}

1new ConsoleTransport({ level: 'debug' })  // All logs
2new HTTPTransport({ level: 'warn' })      // Only warn and error
3new FileTransport({ level: 'error' })     // Only errors

1new HTTPTransport({
2  endpoint: '...',
3  filter: (entry) => {
4    // Only send logs from specific namespaces
5    return entry.namespace?.startsWith('api:')
6  }
7})

1import { ConsoleTransport } from 'vestig'
2 
3new ConsoleTransport({
4  // Enable colored output (default: true in TTY)
5  colors: true,
6 
7  // Use structured JSON (default: based on NODE_ENV)
8  structured: false,
9 
10  // Minimum level
11  level: 'debug'
12})

1[10:30:45] INFO  User signed up { userId: 'usr_123' }
2[10:30:46] ERROR Request failed { error: 'Connection timeout' }

1{"level":"info","message":"User signed up","metadata":{"userId":"usr_123"},"timestamp":"..."}

1import { HTTPTransport } from 'vestig'
2 
3new HTTPTransport({
4  // Required: Target endpoint
5  endpoint: 'https://logs.example.com/ingest',
6 
7  // Batching (for performance)
8  batchSize: 100,          // Logs per batch
9  flushInterval: 5000,     // Auto-flush every 5s
10 
11  // Authentication
12  headers: {
13    'Authorization': 'Bearer your-api-key',
14    'X-Source': 'my-app'
15  },
16 
17  // Retry configuration
18  maxRetries: 3,
19  retryDelay: 1000,        // Initial delay (doubles each retry)
20 
21  // Timeout
22  timeout: 10000,          // 10 seconds
23 
24  // Compression
25  compress: true           // gzip request body
26})

1import { HTTPTransport, HTTPTransportError } from 'vestig'
2 
3const transport = new HTTPTransport({
4  endpoint: '...',
5  onError: (error: HTTPTransportError) => {
6    console.error('Failed to send logs:', error.message)
7    console.error('Failed batch size:', error.batchSize)
8  }
9})

1import { FileTransport } from 'vestig'
2 
3new FileTransport({
4  // File path (supports date patterns)
5  filename: './logs/app-%DATE%.log',
6 
7  // Rotation settings
8  maxSize: '10mb',         // Rotate when file reaches this size
9  maxFiles: 5,             // Keep last 5 files
10  compress: true,          // Gzip rotated files
11 
12  // Batching
13  batchSize: 50,
14  flushInterval: 1000
15})

1filename: './logs/app-%DATE%.log'
2// Creates: app-2024-01-15.log, app-2024-01-16.log, etc.

1import { DatadogTransport } from 'vestig'
2 
3new DatadogTransport({
4  // Required
5  apiKey: process.env.DD_API_KEY,
6 
7  // Datadog configuration
8  site: 'datadoghq.com',   // or 'datadoghq.eu', etc.
9  service: 'my-app',
10  source: 'nodejs',
11 
12  // Tags for filtering
13  tags: [
14    'env:production',
15    'team:backend',
16    `version:${process.env.APP_VERSION}`
17  ],
18 
19  // Batching
20  batchSize: 100,
21  flushInterval: 5000
22})

1import { SentryTransport } from 'vestig'
2 
3new SentryTransport({
4  // Required: Sentry DSN
5  dsn: process.env.SENTRY_DSN,
6 
7  // Environment and release tracking
8  environment: 'production',
9  release: 'my-app@1.2.3',
10 
11  // Service identification
12  service: 'api-server',
13  serverName: 'api-01',
14 
15  // Tags for filtering in Sentry
16  tags: {
17    team: 'backend',
18    region: 'eu-west'
19  },
20 
21  // Minimum level to send (default: 'warn')
22  // Reduces noise by filtering out info/debug logs
23  minLevel: 'warn',
24 
25  // Batching
26  batchSize: 10,
27  flushInterval: 2000
28})

1import { BatchTransport, type LogEntry } from 'vestig'
2 
3class CustomTransport extends BatchTransport {
4  constructor(config: CustomConfig) {
5    super({
6      batchSize: config.batchSize ?? 50,
7      flushInterval: config.flushInterval ?? 5000,
8      level: config.level
9    })
10    // Your initialization
11  }
12 
13  protected async sendBatch(entries: LogEntry[]): Promise<void> {
14    // Your implementation to send logs
15    await myService.send(entries)
16  }
17}