Company Search

curl --no-buffer --get 'https://api.topograph.co/v2/search' \
  --header 'x-api-key: <api-key>' \
  --header 'Accept: text/event-stream' \
  --data-urlencode 'country=DE' \
  --data-urlencode 'query=Siemens' \
  --data-urlencode 'stream=true'

event: progress
data: {"results":[{"id":"example-1","legalName":"Example Company A","countryCode":"DE"}]}

event: complete
data: {"results":[{"id":"example-1","legalName":"Example Company A","countryCode":"DE"},{"id":"example-2","legalName":"Example Company B","countryCode":"DE"}]}

import { createInterface } from 'node:readline';
import { Readable } from 'node:stream';

async function streamCompanySearch({ country, query, apiKey, signal, onResults }) {
  const url = new URL('https://api.topograph.co/v2/search');
  url.search = new URLSearchParams({ country, query, stream: 'true' }).toString();

  const response = await fetch(url, {
    headers: { 'x-api-key': apiKey, Accept: 'text/event-stream' },
    signal,
  });
  if (!response.ok) throw new Error(`Search HTTP error: ${response.status}`);
  if (!response.body) throw new Error('Search response has no body');
  if (!response.headers.get('content-type')?.includes('text/event-stream')) {
    await response.body.cancel();
    throw new Error('Expected a text/event-stream response');
  }

  const input = Readable.fromWeb(response.body);
  const lines = createInterface({ input, crlfDelay: Infinity });
  let event = '';
  let data = [];

  try {
    for await (const line of lines) {
      if (line === '') {
        const eventType = event;
        const payloadText = data.join('\n');
        event = '';
        data = [];
        if (!payloadText) continue;

        if (eventType === 'progress' || eventType === 'complete') {
          const payload = JSON.parse(payloadText);
          onResults(payload.results, eventType === 'complete');
          if (eventType === 'complete') return;
        } else if (eventType === 'error') {
          const payload = JSON.parse(payloadText);
          throw new Error(`${payload.error.code}: ${payload.error.message}`);
        }
      } else if (line.startsWith('event:')) {
        event = line.slice(6).trim();
      } else if (line.startsWith('data:')) {
        data.push(line.slice(5).replace(/^ /, ''));
      }
    }
    throw new Error('Search connection closed before a terminal event');
  } finally {
    lines.close();
    input.destroy();
  }
}

const controller = new AbortController();
// Call controller.abort() when this query is no longer needed.
try {
  await streamCompanySearch({
    country: 'DE',
    query: 'Siemens',
    apiKey: '<api-key>',
    signal: controller.signal,
    onResults(results, complete) {
      // Replace your stored/displayed list with results; do not append it.
      console.log({ results, loading: !complete });
    },
  });
} catch (error) {
  if (!controller.signal.aborted) console.error(error);
}

curl --get 'https://api.topograph.co/v2/search' \
  --header 'x-api-key: YOUR_API_KEY' \
  --data-urlencode 'country=DE' \
  --data-urlencode 'query=Topograph' \
  --data-urlencode 'activeOnly=true'

curl --get 'https://api.topograph.co/v2/search' \
  --header 'x-api-key: YOUR_API_KEY' \
  --data-urlencode 'country=FR' \
  --data-urlencode 'query=96950066U5XAAIRCPA78'

[
  {
    "id": "421100645",
    "legalName": "LA BANQUE POSTALE",
    "countryCode": "FR",
    "matchReason": { "matchType": "id", "identifier": { "siren": "421100645" } }
  }
]