Node (server)

npm install @malvo/server

import { MalvoClient } from "@malvo/server";

const malvo = new MalvoClient({
  clientId: process.env.MALVO_CLIENT_ID!,
  clientSecret: process.env.MALVO_CLIENT_SECRET!,
  // baseUrl: "https://api.malvo.io" (padrão)
});

// A apiKey é obtida de forma preguiçosa, cacheada, renovada e retentada por você.
const { results: connectors } = await malvo.fetchConnectors({ sandbox: true });

const { accessToken } = await malvo.createConnectToken(undefined, {
  clientUserId: "user-42",
  webhookUrl: process.env.MALVO_WEBHOOK_URL,
});

// Atualização: malvo.createConnectToken("a8f4...", { clientUserId: "user-42" });

import express from "express";
import { MalvoClient } from "@malvo/server";

const malvo = new MalvoClient({
  clientId: process.env.MALVO_CLIENT_ID!,
  clientSecret: process.env.MALVO_CLIENT_SECRET!,
});

const app = express();

// Proteja com a sua própria autenticação de usuário antes deste handler.
app.post("/api/malvo/connect-token", async (req, res) => {
  try {
    const { accessToken } = await malvo.createConnectToken(undefined, {
      clientUserId: req.user.id, // seu id interno de usuário
    });
    res.json({ accessToken });
  } catch {
    res.status(502).json({ error: "could not create connect token" });
  }
});

app.listen(3000);

const { results: accounts } = await malvo.fetchAccounts(itemId);

for (const account of accounts) {
  const transactions = await malvo.fetchAllTransactions(account.id);
  for (const tx of transactions) {
    console.log(tx.date, tx.description, tx.amount);
  }
}

import { MalvoApiError } from "@malvo/server";

try {
  await malvo.fetchItem(itemId);
} catch (err) {
  if (err instanceof MalvoApiError && err.codeDescription === "ITEM_NOT_FOUND") {
    // Item inexistente
  } else {
    throw err;
  }
}

import { parseWebhookEvent } from "@malvo/server";

app.post("/webhooks/malvo", express.json(), (req, res) => {
  const event = parseWebhookEvent(req.body); // tipado; lança em payload malformado
  res.sendStatus(200); // confirme rápido; deduplique por event.eventId

  if (event.event === "transactions/created") {
    // re-busque as transações da conta afetada
  }
});