Upload de arquivos na API v2 do SULTS

curl -X POST "https://api.sults.com.br/api/v2/attachment/upload" \
  -H "Authorization: SEU_TOKEN" \
  -F "file=@fachada-unidade-centro.jpg"

import requests

with open("fachada-unidade-centro.jpg", "rb") as arquivo:
    resposta = requests.post(
        "https://api.sults.com.br/api/v2/attachment/upload",
        headers={"Authorization": "SEU_TOKEN"},
        files={"file": arquivo},
    )
resposta.raise_for_status()

id_arquivo = resposta.json()["id"]
print(id_arquivo)

import { openAsBlob } from "node:fs";

const formulario = new FormData();
formulario.append(
  "file",
  await openAsBlob("fachada-unidade-centro.jpg"),
  "fachada-unidade-centro.jpg",
);

const resposta = await fetch(
  "https://api.sults.com.br/api/v2/attachment/upload",
  {
    method: "POST",
    headers: { Authorization: "SEU_TOKEN" },
    body: formulario,
  },
);
if (!resposta.ok) throw new Error(`HTTP ${resposta.status}`);

const { id } = await resposta.json();
console.log(id);

<?php
$ch = curl_init("https://api.sults.com.br/api/v2/attachment/upload");
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
curl_setopt($ch, CURLOPT_POST, true);
curl_setopt($ch, CURLOPT_HTTPHEADER, ["Authorization: SEU_TOKEN"]);
curl_setopt($ch, CURLOPT_POSTFIELDS, [
    "file" => new CURLFile("fachada-unidade-centro.jpg"),
]);
$resposta = curl_exec($ch);
curl_close($ch);

$idArquivo = json_decode($resposta, true)["id"];
echo $idArquivo . PHP_EOL;

using System.IO;
using System.Net.Http;
using System.Text.Json;

var http = new HttpClient();
http.DefaultRequestHeaders.Add("Authorization", "SEU_TOKEN");

using var formulario = new MultipartFormDataContent();
await using var arquivo = File.OpenRead("fachada-unidade-centro.jpg");
formulario.Add(new StreamContent(arquivo), "file", "fachada-unidade-centro.jpg");

var resposta = await http.PostAsync(
    "https://api.sults.com.br/api/v2/attachment/upload", formulario);
resposta.EnsureSuccessStatusCode();

using var doc = JsonDocument.Parse(await resposta.Content.ReadAsStringAsync());
Console.WriteLine(doc.RootElement.GetProperty("id").GetString());

# 1. Liste os disponíveis e anote o id dos que não vai usar
curl "https://api.sults.com.br/api/v2/attachment/list" \
  -H "Authorization: SEU_TOKEN"

# 2. Remova cada um pelo id
curl -X DELETE "https://api.sults.com.br/api/v2/attachment/remove?id=c810e86e-616d-45b7-8a5e-669319021829" \
  -H "Authorization: SEU_TOKEN"

import time
from datetime import datetime, timedelta, timezone

import requests

BASE = "https://api.sults.com.br/api/v2/attachment"
HEADERS = {"Authorization": "SEU_TOKEN"}

resposta = requests.get(f"{BASE}/list", headers=HEADERS)
resposta.raise_for_status()

limite = datetime.now(timezone.utc) - timedelta(minutes=30)
for arquivo in resposta.json():
    enviado = datetime.fromisoformat(arquivo["uploadedAt"].replace("Z", "+00:00"))
    if enviado < limite:
        time.sleep(0.5)
        remocao = requests.delete(f"{BASE}/remove", headers=HEADERS, params={"id": arquivo["id"]})
        remocao.raise_for_status()
        print(f"Removido: {arquivo['name']} ({arquivo['id']})")

const BASE = "https://api.sults.com.br/api/v2/attachment";
const headers = { Authorization: "SEU_TOKEN" };
const esperar = (ms) => new Promise((resolver) => setTimeout(resolver, ms));

const resposta = await fetch(`${BASE}/list`, { headers });
if (!resposta.ok) throw new Error(`HTTP ${resposta.status}`);

const limite = Date.now() - 30 * 60 * 1000;
for (const arquivo of await resposta.json()) {
  if (Date.parse(arquivo.uploadedAt) < limite) {
    await esperar(500);
    const remocao = await fetch(`${BASE}/remove?id=${arquivo.id}`, {
      method: "DELETE",
      headers,
    });
    if (!remocao.ok) throw new Error(`HTTP ${remocao.status}`);
    console.log(`Removido: ${arquivo.name} (${arquivo.id})`);
  }
}

<?php
const BASE = "https://api.sults.com.br/api/v2/attachment";

function chamar(string $metodo, string $url): string
{
    $ch = curl_init($url);
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
    curl_setopt($ch, CURLOPT_CUSTOMREQUEST, $metodo);
    curl_setopt($ch, CURLOPT_HTTPHEADER, ["Authorization: SEU_TOKEN"]);
    $corpo = curl_exec($ch);
    $status = curl_getinfo($ch, CURLINFO_HTTP_CODE);
    curl_close($ch);
    if ($status >= 400) {
        throw new RuntimeException("HTTP $status: $corpo");
    }
    return $corpo;
}

$disponiveis = json_decode(chamar("GET", BASE . "/list"), true);
$limite = time() - 30 * 60;

foreach ($disponiveis as $arquivo) {
    if (strtotime($arquivo["uploadedAt"]) < $limite) {
        usleep(500000);
        chamar("DELETE", BASE . "/remove?id=" . $arquivo["id"]);
        echo "Removido: {$arquivo['name']} ({$arquivo['id']})" . PHP_EOL;
    }
}

using System;
using System.Net.Http;
using System.Text.Json;
using System.Threading.Tasks;

const string Base = "https://api.sults.com.br/api/v2/attachment";

var http = new HttpClient();
http.DefaultRequestHeaders.Add("Authorization", "SEU_TOKEN");

var resposta = await http.GetAsync($"{Base}/list");
resposta.EnsureSuccessStatusCode();

using var doc = JsonDocument.Parse(await resposta.Content.ReadAsStringAsync());
var limite = DateTimeOffset.UtcNow.AddMinutes(-30);

foreach (var arquivo in doc.RootElement.EnumerateArray())
{
    var enviado = arquivo.GetProperty("uploadedAt").GetDateTimeOffset();
    if (enviado < limite)
    {
        await Task.Delay(500);
        var id = arquivo.GetProperty("id").GetString();
        var remocao = await http.DeleteAsync($"{Base}/remove?id={id}");
        remocao.EnsureSuccessStatusCode();
        Console.WriteLine($"Removido: {arquivo.GetProperty("name").GetString()} ({id})");
    }
}