Idempotency

curl -X POST "$FLUX_BASE_URL/api/v1/customers" \
  -H "Authorization: ApiKey $FLUX_API_KEY" \
  -H "Content-Type: application/json" \
  -H "Idempotency-Key: create-customer-ws_42" \
  -d '{
  "customerType": "company",
  "companyName": "Leadway Group",
  "email": "finance@leadway.example",
  "externalRef": "ws_42"
}'

// Node.js 18+ (built-in fetch). Save as an .mjs file.
const response = await fetch(`${process.env.FLUX_BASE_URL}/api/v1/customers`, {
  method: "POST",
  headers: {
    Authorization: `ApiKey ${process.env.FLUX_API_KEY}`,
    "Content-Type": "application/json",
    "Idempotency-Key": "create-customer-ws_42",
  },
  body: JSON.stringify({
    customerType: "company",
    companyName: "Leadway Group",
    email: "finance@leadway.example",
    externalRef: "ws_42",
  }),
});
console.log(response.status, await response.json());

import os

import requests

response = requests.post(
    f"{os.environ['FLUX_BASE_URL']}/api/v1/customers",
    headers={
        "Authorization": f"ApiKey {os.environ['FLUX_API_KEY']}",
        "Idempotency-Key": "create-customer-ws_42",
    },
    json={
        "customerType": "company",
        "companyName": "Leadway Group",
        "email": "finance@leadway.example",
        "externalRef": "ws_42",
    },
    timeout=30,
)
print(response.status_code, response.json())

<?php
$body = <<<'JSON'
{
  "customerType": "company",
  "companyName": "Leadway Group",
  "email": "finance@leadway.example",
  "externalRef": "ws_42"
}
JSON;

$ch = curl_init(getenv('FLUX_BASE_URL') . '/api/v1/customers');
curl_setopt_array($ch, [
    CURLOPT_CUSTOMREQUEST => 'POST',
    CURLOPT_HTTPHEADER => [
        'Authorization: ApiKey ' . getenv('FLUX_API_KEY'),
        'Content-Type: application/json',
        'Idempotency-Key: create-customer-ws_42',
    ],
    CURLOPT_POSTFIELDS => $body,
    CURLOPT_RETURNTRANSFER => true,
]);
$response = curl_exec($ch);
echo curl_getinfo($ch, CURLINFO_HTTP_CODE), ' ', $response, PHP_EOL;

using System.Net.Http.Headers;
using System.Text;

var baseUrl = Environment.GetEnvironmentVariable("FLUX_BASE_URL");
using var http = new HttpClient();
http.DefaultRequestHeaders.Authorization =
    new AuthenticationHeaderValue("ApiKey", Environment.GetEnvironmentVariable("FLUX_API_KEY"));

using var request = new HttpRequestMessage(HttpMethod.Post, $"{baseUrl}/api/v1/customers");
request.Headers.Add("Idempotency-Key", "create-customer-ws_42");
request.Content = new StringContent("""
    {
      "customerType": "company",
      "companyName": "Leadway Group",
      "email": "finance@leadway.example",
      "externalRef": "ws_42"
    }
    """, Encoding.UTF8, "application/json");

using var response = await http.SendAsync(request);
Console.WriteLine($"{(int)response.StatusCode} {await response.Content.ReadAsStringAsync()}");

package main

import (
	"fmt"
	"io"
	"net/http"
	"os"
	"strings"
)

func main() {
	body := strings.NewReader(`{
	  "customerType": "company",
	  "companyName": "Leadway Group",
	  "email": "finance@leadway.example",
	  "externalRef": "ws_42"
	}`)
	req, err := http.NewRequest("POST", os.Getenv("FLUX_BASE_URL")+"/api/v1/customers", body)
	if err != nil {
		panic(err)
	}
	req.Header.Set("Authorization", "ApiKey "+os.Getenv("FLUX_API_KEY"))
	req.Header.Set("Content-Type", "application/json")
	req.Header.Set("Idempotency-Key", "create-customer-ws_42")

	resp, err := http.DefaultClient.Do(req)
	if err != nil {
		panic(err)
	}
	defer resp.Body.Close()
	out, _ := io.ReadAll(resp.Body)
	fmt.Println(resp.StatusCode, string(out))
}