# APPLOI_API_KEY must hold the Partner API key you received from Apploi.
# These examples do not set it for you: set it yourself, in your own
# environment, before running them. For example, in your shell:
#   export APPLOI_API_KEY="<the API key you received from Apploi>"

curl -sS https://partners.apploi.com/applicants/98765432/message \
  -H "X-Api-Key: $APPLOI_API_KEY" \
  -w "\nHTTP status: %{http_code}\n"

import os

import requests

# APPLOI_API_KEY must hold the Partner API key you received from Apploi.
# These examples do not set it for you: set it yourself, in your own
# environment, before running them. For example, in your shell:
#   export APPLOI_API_KEY="<the API key you received from Apploi>"
API_KEY = os.environ["APPLOI_API_KEY"]

def get_messages(job_application_id):
    response = requests.get(
        f"https://partners.apploi.com/applicants/{job_application_id}/message",
        headers={"X-Api-Key": API_KEY},
        timeout=30,
    )
    response.raise_for_status()
    try:
        body = response.json()
    except ValueError:
        # A server error can arrive with status 200 and a body that isn't JSON. Retry later.
        raise RuntimeError(f"Unexpected response, retry later: {response.text[:200]}")
    if "data" not in body:
        # Some errors arrive with status 200, for example when messaging isn't enabled.
        raise RuntimeError(f"Request failed: {body.get('developer_message')}")
    return body["data"]  # newest first

for message in get_messages(98765432):
    print(message["sent_at"], message["message_direction"], message["message_type"], message["message_body"])

// APPLOI_API_KEY must hold the Partner API key you received from Apploi.
// These examples do not set it for you: set it yourself, in your own
// environment, before running them. For example, in your shell:
//   export APPLOI_API_KEY="<the API key you received from Apploi>"
if (!process.env.APPLOI_API_KEY) {
  throw new Error("Set APPLOI_API_KEY to the Partner API key you received from Apploi");
}
const API_KEY: string = process.env.APPLOI_API_KEY;

async function getMessages(jobApplicationId: number): Promise<any[]> {
  const response = await fetch(
    `https://partners.apploi.com/applicants/${jobApplicationId}/message`,
    { headers: { "X-Api-Key": API_KEY } },
  );
  if (!response.ok) {
    throw new Error(`Request failed with status ${response.status}: ${await response.text()}`);
  }
  const text = await response.text();
  let body: any;
  try {
    body = JSON.parse(text);
  } catch {
    // A server error can arrive with status 200 and a body that isn't JSON. Retry later.
    throw new Error(`Unexpected response, retry later: ${text.slice(0, 200)}`);
  }
  if (!("data" in body)) {
    // Some errors arrive with status 200, for example when messaging isn't enabled.
    throw new Error(`Request failed: ${body.developer_message}`);
  }
  return body.data; // newest first
}

for (const message of await getMessages(98765432)) {
  console.log(message.sent_at, message.message_direction, message.message_type, message.message_body);
}

require "json"
require "net/http"
require "uri"

# APPLOI_API_KEY must hold the Partner API key you received from Apploi.
# These examples do not set it for you: set it yourself, in your own
# environment, before running them. For example, in your shell:
#   export APPLOI_API_KEY="<the API key you received from Apploi>"
API_KEY = ENV.fetch("APPLOI_API_KEY")

def get_messages(job_application_id)
  uri = URI("https://partners.apploi.com/applicants/#{job_application_id}/message")
  request = Net::HTTP::Get.new(uri)
  request["X-Api-Key"] = API_KEY

  response = Net::HTTP.start(uri.hostname, uri.port, use_ssl: true, read_timeout: 30) do |http|
    http.request(request)
  end
  raise "Request failed with status #{response.code}: #{response.body}" unless response.is_a?(Net::HTTPSuccess)

  body = begin
    JSON.parse(response.body)
  rescue JSON::ParserError
    # A server error can arrive with status 200 and a body that isn't JSON. Retry later.
    raise "Unexpected response, retry later: #{response.body[0, 200]}"
  end
  # Some errors arrive with status 200, for example when messaging isn't enabled.
  raise "Request failed: #{body['developer_message']}" unless body.key?("data")

  body["data"] # newest first
end

get_messages(98765432).each do |message|
  puts [message["sent_at"], message["message_direction"], message["message_type"], message["message_body"]].join(" ")
end

{
  "data": [
    {
      "message_id": "TWVzc2FnZUlkOjU1NTEyMzQ=",
      "external_id": "msg7f3a9c",
      "message_direction": "from_candidate",
      "message_type": "text",
      "message_body": "Yes, Tuesday at 10am works for me.",
      "subject": null,
      "status": "received",
      "sent_at": "Tue, 29 Sep 2026 14:05:12 GMT"
    },
    {
      "message_id": "TWVzc2FnZUlkOjU1NTEyMDE=",
      "external_id": "msg7f3a91",
      "message_direction": "to_candidate",
      "message_type": "email",
      "message_body": "Thanks for applying. Could you come in for an interview on Tuesday at 10am?",
      "subject": "Interview invitation",
      "status": "sent",
      "sent_at": "Tue, 29 Sep 2026 13:40:03 GMT"
    }
  ]
}

# APPLOI_API_KEY must hold the Partner API key you received from Apploi.
# These examples do not set it for you: set it yourself, in your own
# environment, before running them. For example, in your shell:
#   export APPLOI_API_KEY="<the API key you received from Apploi>"

# Only the applicant's replies (requires jq)
curl -sS https://partners.apploi.com/applicants/98765432/message \
  -H "X-Api-Key: $APPLOI_API_KEY" \
  | jq '.data[] | select(.message_direction == "from_candidate")'

def new_replies(job_application_id, handled_message_ids):
    replies = [
        message
        for message in get_messages(job_application_id)
        if message["message_direction"] == "from_candidate"
        and message["message_id"] not in handled_message_ids
    ]
    return list(reversed(replies))  # oldest first, in the order they were sent

handled_message_ids = set()  # load these from your own storage
for reply in new_replies(98765432, handled_message_ids):
    print(reply["sent_at"], reply["message_body"])
    handled_message_ids.add(reply["message_id"])  # and save it

async function newReplies(jobApplicationId: number, handledMessageIds: Set<string>): Promise<any[]> {
  const messages = await getMessages(jobApplicationId);
  return messages
    .filter(
      (message) =>
        message.message_direction === "from_candidate" && !handledMessageIds.has(message.message_id),
    )
    .reverse(); // oldest first, in the order they were sent
}

const handledMessageIds = new Set<string>(); // load these from your own storage
for (const reply of await newReplies(98765432, handledMessageIds)) {
  console.log(reply.sent_at, reply.message_body);
  handledMessageIds.add(reply.message_id); // and save it
}

require "set"

def new_replies(job_application_id, handled_message_ids)
  get_messages(job_application_id)
    .select { |message| message["message_direction"] == "from_candidate" }
    .reject { |message| handled_message_ids.include?(message["message_id"]) }
    .reverse # oldest first, in the order they were sent
end

handled_message_ids = Set.new # load these from your own storage
new_replies(98765432, handled_message_ids).each do |reply|
  puts [reply["sent_at"], reply["message_body"]].join(" ")
  handled_message_ids.add(reply["message_id"]) # and save it
end