SDK de conector e protocolo

// A chave de conector é secreta: só no seu servidor.
async function entregar(observations: Observation[]) {
  const res = await fetch(`${BASE}/internal/v1/connections/${CONNECTION_ID}/observations`, {
    method: "POST",
    headers: { Authorization: `Bearer ${process.env.CCT_KEY}`, "Content-Type": "application/json" },
    body: JSON.stringify({ observations }), // até 500
  });
  const { results } = await res.json();
  return results; // um por posição: accepted · unchanged · stale · quarantined
}

func entregar(ctx context.Context, observations []Observation) ([]ObservationResult, error) {
    body, _ := json.Marshal(map[string]any{"observations": observations}) // até 500
    url := base + "/internal/v1/connections/" + connectionID + "/observations"
    req, _ := http.NewRequestWithContext(ctx, http.MethodPost, url, bytes.NewReader(body))
    req.Header.Set("Authorization", "Bearer "+os.Getenv("CCT_KEY")) // secreta: só no seu servidor
    req.Header.Set("Content-Type", "application/json")
    res, err := http.DefaultClient.Do(req)
    if err != nil {
        return nil, err
    }
    defer res.Body.Close()
    var out struct {
        Results []ObservationResult `json:"results"` // um por posição
    }
    if err := json.NewDecoder(res.Body).Decode(&out); err != nil {
        return nil, err
    }
    return out.Results, nil
}

curl -X POST "$BASE/internal/v1/connections/$CONNECTION_ID/observations" \
  -H "Authorization: Bearer $CCT_KEY" -H "Content-Type: application/json" \
  -d '{ "observations": [ { "entity": "item", "external_id": "1003", "operation": "delete" } ] }'