import { BigDataCorp } from 'bigdatacorp-client';

const api = new BigDataCorp({
  accessToken: 'YOUR_ACCESS_TOKEN',
  tokenId: 'YOUR_TOKEN_ID',
});

// Get person basic data - just pass the CPF!
const person = await api.pessoas.basicData('12345678901');

// Get company data - just pass the CNPJ!
const company = await api.empresas.basicData('12345678000199');

// Get person addresses - use addresses_extended dataset
const addresses = await api.pessoas.addressesExtended('12345678901');

import { BigDataCorp, BigDataCorpConfig } from 'bigdatacorp-client';

const config: BigDataCorpConfig = {
  accessToken: 'YOUR_ACCESS_TOKEN',  // Required
  tokenId: 'YOUR_TOKEN_ID',          // Required
  baseUrl: 'https://custom.url',     // Optional, defaults to BigDataCorp platform
  timeout: 60000,                    // Optional, request timeout in ms (default: 30000)
  maxRetries: 5,                     // Optional, retry attempts (default: 3)
  headers: {                         // Optional, custom headers
    'X-Custom-Header': 'value'
  }
};

const api = new BigDataCorp(config);

// Basic data - just pass the CPF!
const basicData = await api.pessoas.basicData('12345678901');

// Or use params object for more control
const basicDataWithParams = await api.pessoas.basicData({
  q: 'doc{12345678901}',
  Limit: 1,
});

// Multiple datasets in one call
const fullProfile = await api.pessoas.query('12345678901', [
  'basic_data',
  'emails_extended',
  'phones_extended',
  'addresses_extended',
]);

// Financial risk analysis
const risk = await api.pessoas.financialRisk('12345678901');

// KYC data
const kyc = await api.pessoas.kyc('12345678901');

// Basic company data - just pass the CNPJ!
const company = await api.empresas.basicData('12345678000199');

// Company relationships and partners
const relationships = await api.empresas.relationships('12345678000199');

// Economic group analysis
const economicGroup = await api.empresas.economicGroupFull('12345678000199');

// Multiple datasets
const companyProfile = await api.empresas.query('12345678000199', [
  'basic_data',
  'relationships',
  'economic_group',
]);

// Create a batch job
const job = await api.batch.saveJobDefinition({
  InputFileUrl: 'web{https://example.com/input.csv}',
  InputKeysHeader: 'Documento',
  APIName: 'people',
  Datasets: 'basic_data',
  QueryTemplate: 'doc{{0}}'
});

// Start job execution
await api.batch.startJobExecution({
  JobId: job.JobId!
});

// Check job status
const details = await api.batch.getJobDetails({
  JobId: job.JobId!
});

// List all jobs
const jobs = await api.batch.listJobs({});

// Receita Federal status
const rfStatus = await api.ondemand.rfStatusCompany({
  q: 'doc{12345678000199}'
});

// PGFN (tax debts)
const pgfn = await api.ondemand.pgfnCompany({
  q: 'doc{12345678000199}'
});

// Subscribe to changes
const subscription = await api.monitoramento.subscribe({
  Document: '12345678901',
  Datasets: 'basic_data'
});

// List subscriptions
const subscriptions = await api.monitoramento.list({});

import {
  BigDataCorp,
  BigDataCorpError,
  AuthenticationError,
  RateLimitError,
  ValidationError,
  TimeoutError
} from 'bigdatacorp-client';

try {
  const result = await api.pessoas.basicData('12345678901');
} catch (error) {
  if (error instanceof AuthenticationError) {
    console.error('Invalid credentials');
  } else if (error instanceof RateLimitError) {
    console.error(`Rate limited. Retry after: ${error.retryAfter}ms`);
  } else if (error instanceof TimeoutError) {
    console.error('Request timed out');
  } else if (error instanceof ValidationError) {
    console.error(`Validation error: ${error.message}`);
  } else if (error instanceof BigDataCorpError) {
    console.error(`API error: ${error.message} (${error.statusCode})`);
  }
}

// Custom timeout
const result = await api.pessoas.basicData('12345678901', {
  timeout: 60000
});

// Abort signal for cancellation
const controller = new AbortController();
setTimeout(() => controller.abort(), 5000);

const result = await api.pessoas.basicData('12345678901', {
  signal: controller.signal
});

// Custom headers
const result = await api.pessoas.basicData('12345678901', {
  headers: { 'X-Request-Id': 'custom-id' }
});

import {
  isValidCPF,
  isValidCNPJ,
  formatCPF,
  formatCNPJ,
  cleanDocument
} from 'bigdatacorp-client';

// Validate documents
isValidCPF('123.456.789-09');     // true/false
isValidCNPJ('12.345.678/0001-99'); // true/false

// Format documents
formatCPF('12345678909');         // '123.456.789-09'
formatCNPJ('12345678000199');     // '12.345.678/0001-99'

// Remove formatting
cleanDocument('123.456.789-09');  // '12345678909'

import { BigDataCorp, Types } from 'bigdatacorp-client';

const api = new BigDataCorp({
  accessToken: 'YOUR_ACCESS_TOKEN',
  tokenId: 'YOUR_TOKEN_ID',
});

// Types are namespaced by domain
const request: Types.Pessoas.BasicDataRequest = {
  q: 'doc{12345678901}',
  Limit: 1,
};

const response = await api.pessoas.basicData(request);
// response is typed as Types.Pessoas.BasicDataResponse