Node.js-Specific Features

import { Analytics } from '@zixflow/analytics-node'

const analytics = new Analytics({
  writeKey: 'YOUR_WRITE_KEY',
  maxEventsInBatch: 15,  // default 15
  flushInterval: 10000,  // default 10s
  maxRetries: 3,
  httpRequestTimeout: 10000
})

await analytics.closeAndFlush()

await analytics.closeAndFlush({ timeout: 5000 })

process.on('SIGTERM', async () => {
  await analytics.closeAndFlush()
  process.exit(0)
})

analytics.on('error', (err) => {
  console.error('Analytics error:', err)
})

analytics.on('http_request', (event) => {
  console.log('HTTP request:', event)
})

analytics.on('drained', () => {
  console.log('Queue drained')
})

analytics.track(
  {
    userId: 'user@example.com',
    event: 'signup_completed'
  },
  (err, ctx) => {
    if (err) {
      console.error('Failed to track event:', err)
    } else {
      console.log('Event accepted:', ctx)
    }
  }
)

await analytics.register({
  name: 'Custom Plugin',
  type: 'enrichment',
  version: '1.0.0',
  isLoaded: () => true,
  load: async () => {},
  track: async (ctx) => ctx
})