Implement the server-to-server API contract

curl -X POST https://prologbooks.com/api/v1/connectors/import-emails.php \
  -H "Authorization: Bearer YOUR_CONNECTOR_API_KEY" \
  -H "Accept: application/json" \
  -H "Content-Type: application/json" \
  --data '{
    "emails": [
      "pilot.one@example.com",
      "pilot.two@example.com",
      {
        "email": "pilot.three@example.com"
      }
    ],
    "remove_emails": [
      "former.pilot@example.com"
    ]
  }'

import requests

endpoint = "https://prologbooks.com/api/v1/connectors/import-emails.php"
api_key = "YOUR_CONNECTOR_API_KEY"

payload = {
    "emails": [
        "pilot.one@example.com",
        "pilot.two@example.com",
        {"email": "pilot.three@example.com"},
    ],
    "remove_emails": [
        "former.pilot@example.com",
    ],
}

response = requests.post(
    endpoint,
    headers={
        "Authorization": f"Bearer {api_key}",
        "Accept": "application/json",
        "Content-Type": "application/json",
    },
    json=payload,
    timeout=20,
)

print(response.status_code)
print(response.text)

import java.net.URI;
import java.net.http.HttpClient;
import java.net.http.HttpRequest;
import java.net.http.HttpResponse;

public class ImportConnectorEmails
{
    public static void main(String[] args) throws Exception
    {
        String endpoint = "https://prologbooks.com/api/v1/connectors/import-emails.php";
        String apiKey = "YOUR_CONNECTOR_API_KEY";
        String payload = """
            {
              "emails": [
                "pilot.one@example.com",
                "pilot.two@example.com",
                { "email": "pilot.three@example.com" }
              ],
              "remove_emails": [
                "former.pilot@example.com"
              ]
            }
            """;

        HttpRequest request = HttpRequest.newBuilder()
            .uri(URI.create(endpoint))
            .header("Authorization", "Bearer " + apiKey)
            .header("Accept", "application/json")
            .header("Content-Type", "application/json")
            .POST(HttpRequest.BodyPublishers.ofString(payload))
            .build();

        HttpClient client = HttpClient.newHttpClient();
        HttpResponse<String> response = client.send(request, HttpResponse.BodyHandlers.ofString());

        System.out.println(response.statusCode());
        System.out.println(response.body());
    }
}

const endpoint = "https://prologbooks.com/api/v1/connectors/import-emails.php";
const apiKey = "YOUR_CONNECTOR_API_KEY";

const payload = {
    emails: [
        "pilot.one@example.com",
        "pilot.two@example.com",
        { email: "pilot.three@example.com" },
    ],
    remove_emails: [
        "former.pilot@example.com",
    ],
};

const response = await fetch(endpoint, {
    method: "POST",
    headers: {
        Authorization: `Bearer ${apiKey}`,
        Accept: "application/json",
        "Content-Type": "application/json",
    },
    body: JSON.stringify(payload),
});

console.log(response.status);
console.log(await response.text());

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

var endpoint = "https://prologbooks.com/api/v1/connectors/import-emails.php";
var apiKey = "YOUR_CONNECTOR_API_KEY";
var payload = """
{
  "emails": [
    "pilot.one@example.com",
    "pilot.two@example.com",
    { "email": "pilot.three@example.com" }
  ],
  "remove_emails": [
    "former.pilot@example.com"
  ]
}
""";

using var client = new HttpClient();
using var request = new HttpRequestMessage(HttpMethod.Post, endpoint);
request.Headers.Authorization = new AuthenticationHeaderValue("Bearer", apiKey);
request.Headers.Accept.Add(new MediaTypeWithQualityHeaderValue("application/json"));
request.Content = new StringContent(payload, Encoding.UTF8, "application/json");

var response = await client.SendAsync(request);
var responseBody = await response.Content.ReadAsStringAsync();

Console.WriteLine((int) response.StatusCode);
Console.WriteLine(responseBody);

<?php

declare(strict_types=1);

$endpoint = 'https://prologbooks.com/api/v1/connectors/import-emails.php';
$apiKey = 'YOUR_CONNECTOR_API_KEY';

$payload = json_encode([
    'emails' => [
        'pilot.one@example.com',
        'pilot.two@example.com',
        ['email' => 'pilot.three@example.com'],
    ],
    'remove_emails' => [
        'former.pilot@example.com',
    ],
], JSON_UNESCAPED_SLASHES | JSON_UNESCAPED_UNICODE);

$ch = curl_init($endpoint);
curl_setopt_array($ch, [
    CURLOPT_POST => true,
    CURLOPT_RETURNTRANSFER => true,
    CURLOPT_HTTPHEADER => [
        'Authorization: Bearer ' . $apiKey,
        'Accept: application/json',
        'Content-Type: application/json',
        'Content-Length: ' . strlen((string) $payload),
    ],
    CURLOPT_POSTFIELDS => $payload,
    CURLOPT_TIMEOUT => 20,
]);

$responseBody = curl_exec($ch);
$responseCode = (int) curl_getinfo($ch, CURLINFO_RESPONSE_CODE);
$curlError = curl_error($ch);
curl_close($ch);

if ($responseBody === false) {
    throw new RuntimeException('Request failed: ' . $curlError);
}

echo "HTTP {$responseCode}\n";
echo $responseBody . "\n";

curl -X POST https://partner.example.com/connector/checkuser.php \
  -H "Authorization: Bearer YOUR_CONNECTOR_API_KEY" \
  -H "Accept: application/json" \
  -H "Content-Type: application/json" \
  --data '{
    "email": "pilot@example.com",
    "access_token": "stable-token-generated-by-prologbooks"
  }'

import requests

endpoint = "https://partner.example.com/connector/checkuser.php"
api_key = "YOUR_CONNECTOR_API_KEY"

payload = {
    "email": "pilot@example.com",
    "access_token": "stable-token-generated-by-prologbooks",
}

response = requests.post(
    endpoint,
    headers={
        "Authorization": f"Bearer {api_key}",
        "Accept": "application/json",
        "Content-Type": "application/json",
    },
    json=payload,
    timeout=12,
)

print(response.status_code)
print(response.text)

import java.net.URI;
import java.net.http.HttpClient;
import java.net.http.HttpRequest;
import java.net.http.HttpResponse;

public class CheckConnectorUser
{
    public static void main(String[] args) throws Exception
    {
        String endpoint = "https://partner.example.com/connector/checkuser.php";
        String apiKey = "YOUR_CONNECTOR_API_KEY";
        String payload = """
            {
              "email": "pilot@example.com",
              "access_token": "stable-token-generated-by-prologbooks"
            }
            """;

        HttpRequest request = HttpRequest.newBuilder()
            .uri(URI.create(endpoint))
            .header("Authorization", "Bearer " + apiKey)
            .header("Accept", "application/json")
            .header("Content-Type", "application/json")
            .POST(HttpRequest.BodyPublishers.ofString(payload))
            .build();

        HttpClient client = HttpClient.newHttpClient();
        HttpResponse<String> response = client.send(request, HttpResponse.BodyHandlers.ofString());

        System.out.println(response.statusCode());
        System.out.println(response.body());
    }
}

const endpoint = "https://partner.example.com/connector/checkuser.php";
const apiKey = "YOUR_CONNECTOR_API_KEY";

const payload = {
    email: "pilot@example.com",
    access_token: "stable-token-generated-by-prologbooks",
};

const response = await fetch(endpoint, {
    method: "POST",
    headers: {
        Authorization: `Bearer ${apiKey}`,
        Accept: "application/json",
        "Content-Type": "application/json",
    },
    body: JSON.stringify(payload),
});

console.log(response.status);
console.log(await response.text());

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

var endpoint = "https://partner.example.com/connector/checkuser.php";
var apiKey = "YOUR_CONNECTOR_API_KEY";
var payload = """
{
  "email": "pilot@example.com",
  "access_token": "stable-token-generated-by-prologbooks"
}
""";

using var client = new HttpClient();
using var request = new HttpRequestMessage(HttpMethod.Post, endpoint);
request.Headers.Authorization = new AuthenticationHeaderValue("Bearer", apiKey);
request.Headers.Accept.Add(new MediaTypeWithQualityHeaderValue("application/json"));
request.Content = new StringContent(payload, Encoding.UTF8, "application/json");

var response = await client.SendAsync(request);
var responseBody = await response.Content.ReadAsStringAsync();

Console.WriteLine((int) response.StatusCode);
Console.WriteLine(responseBody);

<?php

declare(strict_types=1);

$endpoint = 'https://partner.example.com/connector/checkuser.php';
$apiKey = 'YOUR_CONNECTOR_API_KEY';

$payload = json_encode([
    'email' => 'pilot@example.com',
    'access_token' => 'stable-token-generated-by-prologbooks',
], JSON_UNESCAPED_SLASHES | JSON_UNESCAPED_UNICODE);

$ch = curl_init($endpoint);
curl_setopt_array($ch, [
    CURLOPT_POST => true,
    CURLOPT_RETURNTRANSFER => true,
    CURLOPT_HTTPHEADER => [
        'Authorization: Bearer ' . $apiKey,
        'Accept: application/json',
        'Content-Type: application/json',
        'Content-Length: ' . strlen((string) $payload),
    ],
    CURLOPT_POSTFIELDS => $payload,
    CURLOPT_TIMEOUT => 12,
]);

$responseBody = curl_exec($ch);
$responseCode = (int) curl_getinfo($ch, CURLINFO_RESPONSE_CODE);
$curlError = curl_error($ch);
curl_close($ch);

if ($responseBody === false) {
    throw new RuntimeException('Request failed: ' . $curlError);
}

echo "HTTP {$responseCode}\n";
echo $responseBody . "\n";

curl -X POST https://partner.example.com/connector/getnewids.php \
  -H "Authorization: Bearer YOUR_CONNECTOR_API_KEY" \
  -H "Accept: application/json" \
  -H "Content-Type: application/json" \
  --data '{
    "email": "pilot@example.com",
    "access_token": "stable-token-generated-by-prologbooks",
    "synced_partner_item_uids": [
      "flight-10001",
      "flight-10002"
    ],
    "syncable_flight_columns": [
      "flight_date",
      "aircraft_type",
      "flight_number",
      "aircraft_registration",
      "departure_airport",
      "departure_time",
      "arrival_airport",
      "arrival_time",
      "block_time_minutes",
      "remarks"
    ]
  }'

import requests

endpoint = "https://partner.example.com/connector/getnewids.php"
api_key = "YOUR_CONNECTOR_API_KEY"

payload = {
    "email": "pilot@example.com",
    "access_token": "stable-token-generated-by-prologbooks",
    "synced_partner_item_uids": [
        "flight-10001",
        "flight-10002",
    ],
    "syncable_flight_columns": [
        "flight_date",
        "aircraft_type",
        "flight_number",
        "aircraft_registration",
        "departure_airport",
        "departure_time",
        "arrival_airport",
        "arrival_time",
        "block_time_minutes",
        "remarks",
    ],
}

response = requests.post(
    endpoint,
    headers={
        "Authorization": f"Bearer {api_key}",
        "Accept": "application/json",
        "Content-Type": "application/json",
    },
    json=payload,
    timeout=20,
)

print(response.status_code)
print(response.text)

import java.net.URI;
import java.net.http.HttpClient;
import java.net.http.HttpRequest;
import java.net.http.HttpResponse;

public class GetNewConnectorFlights
{
    public static void main(String[] args) throws Exception
    {
        String endpoint = "https://partner.example.com/connector/getnewids.php";
        String apiKey = "YOUR_CONNECTOR_API_KEY";
        String payload = """
            {
              "email": "pilot@example.com",
              "access_token": "stable-token-generated-by-prologbooks",
              "synced_partner_item_uids": [
                "flight-10001",
                "flight-10002"
              ],
              "syncable_flight_columns": [
                "flight_date",
                "aircraft_type",
                "flight_number",
                "aircraft_registration",
                "departure_airport",
                "departure_time",
                "arrival_airport",
                "arrival_time",
                "block_time_minutes",
                "remarks"
              ]
            }
            """;

        HttpRequest request = HttpRequest.newBuilder()
            .uri(URI.create(endpoint))
            .header("Authorization", "Bearer " + apiKey)
            .header("Accept", "application/json")
            .header("Content-Type", "application/json")
            .POST(HttpRequest.BodyPublishers.ofString(payload))
            .build();

        HttpClient client = HttpClient.newHttpClient();
        HttpResponse<String> response = client.send(request, HttpResponse.BodyHandlers.ofString());

        System.out.println(response.statusCode());
        System.out.println(response.body());
    }
}

const endpoint = "https://partner.example.com/connector/getnewids.php";
const apiKey = "YOUR_CONNECTOR_API_KEY";

const payload = {
    email: "pilot@example.com",
    access_token: "stable-token-generated-by-prologbooks",
    synced_partner_item_uids: [
        "flight-10001",
        "flight-10002",
    ],
    syncable_flight_columns: [
        "flight_date",
        "aircraft_type",
        "flight_number",
        "aircraft_registration",
        "departure_airport",
        "departure_time",
        "arrival_airport",
        "arrival_time",
        "block_time_minutes",
        "remarks",
    ],
};

const response = await fetch(endpoint, {
    method: "POST",
    headers: {
        Authorization: `Bearer ${apiKey}`,
        Accept: "application/json",
        "Content-Type": "application/json",
    },
    body: JSON.stringify(payload),
});

console.log(response.status);
console.log(await response.text());

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

var endpoint = "https://partner.example.com/connector/getnewids.php";
var apiKey = "YOUR_CONNECTOR_API_KEY";
var payload = """
{
  "email": "pilot@example.com",
  "access_token": "stable-token-generated-by-prologbooks",
  "synced_partner_item_uids": [
    "flight-10001",
    "flight-10002"
  ],
  "syncable_flight_columns": [
    "flight_date",
    "aircraft_type",
    "flight_number",
    "aircraft_registration",
    "departure_airport",
    "departure_time",
    "arrival_airport",
    "arrival_time",
    "block_time_minutes",
    "remarks"
  ]
}
""";

using var client = new HttpClient();
using var request = new HttpRequestMessage(HttpMethod.Post, endpoint);
request.Headers.Authorization = new AuthenticationHeaderValue("Bearer", apiKey);
request.Headers.Accept.Add(new MediaTypeWithQualityHeaderValue("application/json"));
request.Content = new StringContent(payload, Encoding.UTF8, "application/json");

var response = await client.SendAsync(request);
var responseBody = await response.Content.ReadAsStringAsync();

Console.WriteLine((int) response.StatusCode);
Console.WriteLine(responseBody);

<?php

declare(strict_types=1);

$endpoint = 'https://partner.example.com/connector/getnewids.php';
$apiKey = 'YOUR_CONNECTOR_API_KEY';

$payload = json_encode([
    'email' => 'pilot@example.com',
    'access_token' => 'stable-token-generated-by-prologbooks',
    'synced_partner_item_uids' => [
        'flight-10001',
        'flight-10002',
    ],
    'syncable_flight_columns' => [
        'flight_date',
        'aircraft_type',
        'flight_number',
        'aircraft_registration',
        'departure_airport',
        'departure_time',
        'arrival_airport',
        'arrival_time',
        'block_time_minutes',
        'remarks',
    ],
], JSON_UNESCAPED_SLASHES | JSON_UNESCAPED_UNICODE);

$ch = curl_init($endpoint);
curl_setopt_array($ch, [
    CURLOPT_POST => true,
    CURLOPT_RETURNTRANSFER => true,
    CURLOPT_HTTPHEADER => [
        'Authorization: Bearer ' . $apiKey,
        'Accept: application/json',
        'Content-Type: application/json',
        'Content-Length: ' . strlen((string) $payload),
    ],
    CURLOPT_POSTFIELDS => $payload,
    CURLOPT_TIMEOUT => 20,
]);

$responseBody = curl_exec($ch);
$responseCode = (int) curl_getinfo($ch, CURLINFO_RESPONSE_CODE);
$curlError = curl_error($ch);
curl_close($ch);

if ($responseBody === false) {
    throw new RuntimeException('Request failed: ' . $curlError);
}

echo "HTTP {$responseCode}\n";
echo $responseBody . "\n";