List return inventories with pagination

import java.net.URI;
import java.net.http.HttpClient;
import java.net.http.HttpRequest;
import java.net.http.HttpResponse;
import java.time.Instant;
import java.time.temporal.ChronoUnit;

// Requires a JSON library on the classpath. Below uses org.json for brevity:
//   <dependency><groupId>org.json</groupId><artifactId>json</artifactId></dependency>
import org.json.JSONArray;
import org.json.JSONObject;

class Main {
  static final String BASE_URL  = "https://api.returnhelpercentre.com/v1/user"; // production
  // sandbox: "https://api.returnshelper.com/uat/user"
  static final String API_KEY   = "<your api key>";
  static final String API_TOKEN = "<your api token>";

  static final int PAGE_SIZE   = 50;
  static final int WINDOW_DAYS = 62; // server cap: createTo.Date - createFrom.Date <= 62

  public static void main(String[] args) throws Exception {
    Instant historyStart = Instant.parse("2024-01-01T00:00:00Z"); // backfill anchor
    Instant windowEnd    = Instant.now();                         // walk backwards from now

    HttpClient http = HttpClient.newHttpClient();

    while (windowEnd.isAfter(historyStart)) {
      Instant windowStart = windowEnd.minus(WINDOW_DAYS, ChronoUnit.DAYS);
      if (windowStart.isBefore(historyStart)) {
        windowStart = historyStart;
      }

      int offset = 0;
      int total  = Integer.MAX_VALUE;

      while (offset < total) {
        String url = BASE_URL + "/api/ReturnInventory/list"
                   + "?pageSize="   + PAGE_SIZE
                   + "&offset="     + offset
                   + "&createFrom=" + windowStart
                   + "&createTo="   + windowEnd;

        HttpRequest req = HttpRequest.newBuilder()
            .uri(URI.create(url))
            .header("x-rr-apikey",   API_KEY)
            .header("x-rr-apitoken", API_TOKEN)
            .header("Accept",        "application/json")
            .GET()
            .build();

        HttpResponse<String> resp = http.send(req, HttpResponse.BodyHandlers.ofString());
        JSONObject body = new JSONObject(resp.body());

        // Standard envelope: business status is in meta.status, not HTTP status.
        JSONObject meta = body.optJSONObject("meta");
        if (meta == null || meta.optInt("status") != 200) {
          System.err.println("list call failed: " + (meta == null ? "no meta" : meta.toString()));
          return;
        }

        total = body.optInt("totalNumberOfRecords", 0);
        JSONArray rows = body.optJSONArray("data");
        if (rows != null) {
          for (int i = 0; i < rows.length(); i++) {
            JSONObject inv = rows.getJSONObject(i);
            // TODO: UPSERT into your DB with returnInventoryId as primary key.
            //       Adjacent windows share a seam day, so the same row may be
            //       returned twice; UPSERT absorbs the duplicate.
            //   inv.getLong("returnInventoryId")
            //   inv.getString("handlingCode")
            //   inv.getString("handlingStatusCode")
            //   inv.getInt("warehouseId")
          }
        }

        offset += PAGE_SIZE;
        Thread.sleep(200); // light throttle
      }

      windowEnd = windowStart;
    }
  }
}

// Requires Node.js 18+ for built-in fetch.

const BASE_URL  = 'https://api.returnhelpercentre.com/v1/user'; // production
// sandbox: 'https://api.returnshelper.com/uat/user'
const API_KEY   = '<your api key>';
const API_TOKEN = '<your api token>';

const PAGE_SIZE   = 50;
const WINDOW_DAYS = 62; // server cap: createTo.Date - createFrom.Date <= 62

const MS_PER_DAY = 24 * 60 * 60 * 1000;

async function main() {
  const historyStart = new Date('2024-01-01T00:00:00Z'); // backfill anchor
  let windowEnd      = new Date();                       // walk backwards from now

  while (windowEnd > historyStart) {
    let windowStart = new Date(windowEnd.getTime() - WINDOW_DAYS * MS_PER_DAY);
    if (windowStart < historyStart) {
      windowStart = historyStart;
    }

    let offset = 0;
    let total  = Infinity;

    while (offset < total) {
      const params = new URLSearchParams({
        pageSize:   String(PAGE_SIZE),
        offset:     String(offset),
        createFrom: windowStart.toISOString(),
        createTo:   windowEnd.toISOString(),
      });

      const resp = await fetch(`${BASE_URL}/api/ReturnInventory/list?${params}`, {
        headers: {
          'x-rr-apikey':   API_KEY,
          'x-rr-apitoken': API_TOKEN,
          'Accept':        'application/json',
        },
      });
      const body = await resp.json();

      // Standard envelope: business status is in meta.status, not HTTP status.
      if (body?.meta?.status !== 200) {
        console.error('list call failed:', body?.meta);
        return;
      }

      total      = body.totalNumberOfRecords ?? 0;
      const rows = body.data ?? [];

      for (const inv of rows) {
        // TODO: UPSERT into your DB with returnInventoryId as primary key.
        //       Adjacent windows share a seam day, so the same row may be
        //       returned twice; UPSERT absorbs the duplicate.
        //   inv.returnInventoryId
        //   inv.handlingCode
        //   inv.handlingStatusCode
        //   inv.warehouseId
      }

      offset += PAGE_SIZE;
      await new Promise((r) => setTimeout(r, 200)); // light throttle
    }

    windowEnd = windowStart;
  }
}

main().catch(console.error);

// Requires Node.js 18+ for built-in fetch (or a fetch polyfill in older runtimes).

const BASE_URL  = 'https://api.returnhelpercentre.com/v1/user'; // production
// sandbox: 'https://api.returnshelper.com/uat/user'
const API_KEY   = '<your api key>';
const API_TOKEN = '<your api token>';

const PAGE_SIZE   = 50;
const WINDOW_DAYS = 62; // server cap: createTo.Date - createFrom.Date <= 62

const MS_PER_DAY = 24 * 60 * 60 * 1000;

interface ApiEnvelope<T> {
  correlationId: string;
  meta: {
    status: number;
    errorCode?: string | null;
    error?: Record<string, unknown>;
  };
  data?: T[];
  totalNumberOfRecords?: number;
}

interface ReturnInventoryRow {
  returnInventoryId: number;
  handlingCode: string;
  handlingStatusCode: string;
  warehouseId: number;
  // ...other fields documented in the API reference
}

async function main(): Promise<void> {
  const historyStart = new Date('2024-01-01T00:00:00Z'); // backfill anchor
  let windowEnd      = new Date();                       // walk backwards from now

  while (windowEnd > historyStart) {
    let windowStart = new Date(windowEnd.getTime() - WINDOW_DAYS * MS_PER_DAY);
    if (windowStart < historyStart) {
      windowStart = historyStart;
    }

    let offset = 0;
    let total  = Infinity;

    while (offset < total) {
      const params = new URLSearchParams({
        pageSize:   String(PAGE_SIZE),
        offset:     String(offset),
        createFrom: windowStart.toISOString(),
        createTo:   windowEnd.toISOString(),
      });

      const resp = await fetch(`${BASE_URL}/api/ReturnInventory/list?${params}`, {
        headers: {
          'x-rr-apikey':   API_KEY,
          'x-rr-apitoken': API_TOKEN,
          'Accept':        'application/json',
        },
      });
      const body = (await resp.json()) as ApiEnvelope<ReturnInventoryRow>;

      // Standard envelope: business status is in meta.status, not HTTP status.
      if (body.meta?.status !== 200) {
        console.error('list call failed:', body.meta);
        return;
      }

      total      = body.totalNumberOfRecords ?? 0;
      const rows = body.data ?? [];

      for (const inv of rows) {
        // TODO: UPSERT into your DB with returnInventoryId as primary key.
        //       Adjacent windows share a seam day, so the same row may be
        //       returned twice; UPSERT absorbs the duplicate.
        //   inv.returnInventoryId
        //   inv.handlingCode
        //   inv.handlingStatusCode
        //   inv.warehouseId
      }

      offset += PAGE_SIZE;
      await new Promise((r) => setTimeout(r, 200)); // light throttle
    }

    windowEnd = windowStart;
  }
}

main().catch(console.error);

// Salesforce Apex — callable from an execute-anonymous window or wrapped in a
// Queueable for large backfills (single-transaction callout limit is 100).
//
// Add the API host to "Remote Site Settings" before running.

public class Main {
    private static final String BASE_URL  = 'https://api.returnhelpercentre.com/v1/user'; // production
    // sandbox: 'https://api.returnshelper.com/uat/user'
    private static final String API_KEY   = '<your api key>';
    private static final String API_TOKEN = '<your api token>';

    private static final Integer PAGE_SIZE   = 50;
    private static final Integer WINDOW_DAYS = 62; // server cap: createTo.Date - createFrom.Date <= 62

    public static void main() {
        Datetime historyStart = Datetime.newInstanceGmt(2024, 1, 1, 0, 0, 0); // backfill anchor
        Datetime windowEnd    = Datetime.now();                               // walk backwards from now

        Http http = new Http();

        while (windowEnd > historyStart) {
            Datetime windowStart = windowEnd.addDays(-WINDOW_DAYS);
            if (windowStart < historyStart) {
                windowStart = historyStart;
            }

            Integer offset = 0;
            Integer total  = Integer.MAX_VALUE;

            while (offset < total) {
                String url = BASE_URL + '/api/ReturnInventory/list'
                    + '?pageSize='   + PAGE_SIZE
                    + '&offset='     + offset
                    + '&createFrom=' + EncodingUtil.urlEncode(formatGmt(windowStart), 'UTF-8')
                    + '&createTo='   + EncodingUtil.urlEncode(formatGmt(windowEnd),   'UTF-8');

                HttpRequest req = new HttpRequest();
                req.setMethod('GET');
                req.setEndpoint(url);
                req.setHeader('x-rr-apikey',   API_KEY);
                req.setHeader('x-rr-apitoken', API_TOKEN);
                req.setHeader('Accept',        'application/json');

                HttpResponse resp = http.send(req);

                Map<String, Object> body = (Map<String, Object>) JSON.deserializeUntyped(resp.getBody());
                Map<String, Object> meta = (Map<String, Object>) body.get('meta');

                // Standard envelope: business status is in meta.status, not HTTP status.
                if (meta == null || (Integer) meta.get('status') != 200) {
                    System.debug('list call failed: ' + meta);
                    return;
                }

                Object totalObj = body.get('totalNumberOfRecords');
                total = (totalObj == null) ? 0 : (Integer) totalObj;

                List<Object> rows = (List<Object>) body.get('data');
                if (rows != null) {
                    for (Object row : rows) {
                        Map<String, Object> inv = (Map<String, Object>) row;
                        // TODO: UPSERT into your custom object with returnInventoryId__c
                        //       as External Id. Adjacent windows share a seam day, so the
                        //       same row may be returned twice; UPSERT absorbs the duplicate.
                        //   inv.get('returnInventoryId')
                        //   inv.get('handlingCode')
                        //   inv.get('handlingStatusCode')
                        //   inv.get('warehouseId')
                    }
                }

                offset += PAGE_SIZE;
            }

            windowEnd = windowStart;
        }
    }

    private static String formatGmt(Datetime dt) {
        return dt.formatGmt('yyyy-MM-dd\'T\'HH:mm:ss\'Z\'');
    }
}