Request History

import { Lava } from '@lavapayments/nodejs';

const lava = new Lava();

async function getRequestHistory(connectionId: string, cursor?: string) {
  const response = await lava.requests.list({
    connection_id: connectionId,
    limit: 20,
    cursor,
  });

  return {
    requests: response.data.map((req) => ({
      id: req.request_id,
      date: req.created_at,
      provider: req.provider,
      model: req.model,
      tokens: req.model_usage.total_tokens,
      cost: parseFloat(req.total_wallet_cost).toFixed(4),
      status: req.status,
    })),
    hasMore: response.has_more,
    nextCursor: response.next_cursor,
  };
}

app.get('/api/requests', async (req, res) => {
  const { cursor } = req.query;
  const history = await getRequestHistory(
    req.user.connectionId,
    cursor as string | undefined
  );
  res.json(history);
});

// When making requests — tag with metadata
headers['X-Lava-Metadata-Feature'] = 'chat';
headers['X-Lava-Metadata-Session'] = sessionId;

// When querying — filter by metadata
const chatRequests = await lava.requests.list({
  connection_id: connectionId,
  metadata_filters: { feature: 'chat' },
  limit: 50,
});

async function exportToCSV(connectionId: string) {
  const allRequests = [];
  let cursor: string | undefined;

  do {
    const response = await lava.requests.list({
      connection_id: connectionId,
      limit: 100,
      cursor,
    });
    allRequests.push(...response.data);
    cursor = response.next_cursor;
  } while (cursor);

  const lines = [
    'Date,Provider,Model,Tokens,Cost',
    ...allRequests.map((r) =>
      [r.created_at, r.provider, r.model, r.model_usage.total_tokens, r.total_request_cost].join(',')
    ),
  ];

  return lines.join('\n');
}