Receba seu primeiro pedido

const API = 'https://api.deliveryvip.com.br'
const processed = new Set() // em produção, guarde os eventIds no banco

async function getToken() {
  const response = await fetch(`${API}/authentication/v1/oauth/token`, {
    method: 'POST',
    headers: { 'Content-Type': 'application/x-www-form-urlencoded' },
    body: new URLSearchParams({
      grant_type: 'client_credentials',
      client_id: process.env.DV_CLIENT_ID,
      client_secret: process.env.DV_CLIENT_SECRET,
      scope: 'od.all',
    }),
  })
  if (!response.ok) throw new Error(`token: HTTP ${response.status}`)
  return (await response.json()).access_token
}

async function api(token, url, options = {}) {
  const response = await fetch(url.startsWith('http') ? url : `${API}${url}`, {
    ...options,
    headers: { Authorization: `Bearer ${token}`, 'Content-Type': 'application/json', ...options.headers },
  })
  if (response.status === 401) throw new Error('unauthorized')
  if (!response.ok) throw new Error(`${options.method ?? 'GET'} ${url}: HTTP ${response.status}`)
  return response.status === 204 ? null : response.json()
}

async function handle(token, event) {
  if (event.eventType !== 'CREATED') return

  const order = await api(token, event.orderURL)
  console.log(`Pedido ${order.displayId} (${order.type}) de ${order.customer?.name}: R$ ${order.total?.orderAmount?.value}`)
  await api(token, `/merchant/v3/orders/${order.id}/confirm`, { method: 'POST' })
}

let token = await getToken()

while (true) {
  try {
    const events = (await api(token, '/merchant/v3/events:polling')) ?? []

    for (const event of events) {
      if (processed.has(event.eventId)) continue
      await handle(token, event)
      processed.add(event.eventId)
    }

    if (events.length > 0) {
      const ids = events.map(({ eventId }) => ({ id: eventId }))
      await api(token, '/merchant/v3/events/acknowledgment', { method: 'POST', body: JSON.stringify(ids) })
    }

    if (events.length === 100) continue // fila acumulada: busca o próximo lote já
  } catch (error) {
    if (error.message === 'unauthorized') token = await getToken()
    else console.error(error.message)
  }

  await new Promise((resolve) => setTimeout(resolve, 30_000))
}

import os
import time

import requests

API = "https://api.deliveryvip.com.br"
processed = set()  # em produção, guarde os eventIds no banco


class Unauthorized(Exception):
    pass


def get_token():
    response = requests.post(
        f"{API}/authentication/v1/oauth/token",
        data={
            "grant_type": "client_credentials",
            "client_id": os.environ["DV_CLIENT_ID"],
            "client_secret": os.environ["DV_CLIENT_SECRET"],
            "scope": "od.all",
        },
    )
    response.raise_for_status()
    return response.json()["access_token"]


def api(token, url, method="GET", json=None):
    response = requests.request(
        method,
        url if url.startswith("http") else f"{API}{url}",
        headers={"Authorization": f"Bearer {token}"},
        json=json,
    )
    if response.status_code == 401:
        raise Unauthorized()
    response.raise_for_status()
    return None if response.status_code == 204 else response.json()


def handle(token, event):
    if event["eventType"] != "CREATED":
        return

    order = api(token, event["orderURL"])
    customer = (order.get("customer") or {}).get("name")
    amount = order.get("total", {}).get("orderAmount", {}).get("value")
    print(f"Pedido {order['displayId']} ({order['type']}) de {customer}: R$ {amount}")
    api(token, f"/merchant/v3/orders/{order['id']}/confirm", method="POST")


token = get_token()

while True:
    try:
        events = api(token, "/merchant/v3/events:polling") or []

        for event in events:
            if event["eventId"] in processed:
                continue
            handle(token, event)
            processed.add(event["eventId"])

        if events:
            ids = [{"id": event["eventId"]} for event in events]
            api(token, "/merchant/v3/events/acknowledgment", method="POST", json=ids)

        if len(events) == 100:
            continue  # fila acumulada: busca o próximo lote já
    except Unauthorized:
        token = get_token()
    except requests.RequestException as error:
        print(error)

    time.sleep(30)

node primeiro-pedido.mjs

pip install requests
python primeiro_pedido.py