GetPrice API reference

import os

import requests

BASE = "https://api.getprice.ai/v1"
KEY = os.environ["GETPRICE_API_KEY"]

resp = requests.get(
    f"{BASE}/me",
    headers={"Authorization": f"Bearer {KEY}"},
    timeout=30,
)
resp.raise_for_status()
me = resp.json()
print(me["company"]["name"], me["limits"]["per_minute"])

interface Me {
  company: { name: string };
  limits: { per_minute: number };
}

const BASE = "https://api.getprice.ai/v1";
const KEY = process.env.GETPRICE_API_KEY;
const url = `${BASE}/me`;
const res = await fetch(url, {
  headers: { Authorization: `Bearer ${KEY}` },
});
if (!res.ok) {
  throw new Error(`GetPrice returned ${res.status}`);
}
const me = (await res.json()) as Me;
console.log(me.company.name, me.limits.per_minute);

<?php
$base = "https://api.getprice.ai/v1";
$key = getenv("GETPRICE_API_KEY");
$ch = curl_init("$base/me");
curl_setopt_array($ch, [
    CURLOPT_HTTPHEADER => [
        "Authorization: Bearer $key",
    ],
    CURLOPT_RETURNTRANSFER => true,
    CURLOPT_TIMEOUT => 30,
]);
$body = curl_exec($ch);
$status = curl_getinfo($ch, CURLINFO_RESPONSE_CODE);
if ($body === false || $status >= 400) {
    throw new RuntimeException(
        "GetPrice returned $status: $body"
    );
}
$data = json_decode(
    $body, true, flags: JSON_THROW_ON_ERROR
);

echo $data["company"]["name"], " ",
    $data["limits"]["per_minute"], "\n";

using System.Net.Http.Headers;
using System.Net.Http.Json;
using System.Text.Json;
using Naming = System.Text.Json.JsonNamingPolicy;

var key = Environment.GetEnvironmentVariable(
    "GETPRICE_API_KEY");
var api = new Uri("https://api.getprice.ai/v1/");
var http = new HttpClient { BaseAddress = api };
http.Timeout = TimeSpan.FromSeconds(30);
http.DefaultRequestHeaders.Authorization =
    new AuthenticationHeaderValue("Bearer", key);
var json = new JsonSerializerOptions
{
    PropertyNamingPolicy = Naming.SnakeCaseLower,
};

var res = await http.GetAsync("me");
res.EnsureSuccessStatusCode();
var me = await res.Content
    .ReadFromJsonAsync<Me>(json);
Console.WriteLine(
    $"{me!.Company.Name} {me.Limits.PerMinute}");

record Me(Company Company, Limits Limits);
record Company(string Name);
record Limits(int PerMinute);

import requests
from odoo import models

API = "https://api.getprice.ai/v1"


class ResConfigSettings(models.TransientModel):
    _inherit = "res.config.settings"

    def action_getprice_test_key(self):
        """Settings button: check the GetPrice key."""
        icp = self.env["ir.config_parameter"].sudo()
        key = icp.get_param("getprice.api_key")
        resp = requests.get(
            f"{API}/me",
            headers={"Authorization": f"Bearer {key}"},
            timeout=30,
        )
        resp.raise_for_status()
        name = resp.json()["company"]["name"]
        return {
            "type": "ir.actions.client",
            "tag": "display_notification",
            "params": {
                "message": f"Connected as {name}",
                "type": "success",
            },
        }

import os

import requests

BASE = "https://api.getprice.ai/v1"
KEY = os.environ["GETPRICE_API_KEY"]

resp = requests.get(
    f"{BASE}/comparison-sets",
    params=[("sku", "10072L"), ("sku", "11247P")],
    headers={"Authorization": f"Bearer {KEY}"},
    timeout=30,
)
resp.raise_for_status()
page = resp.json()
for entry in page["skus"]:
    print(entry["sku"], entry["status"])
for cset in page["data"]:
    for entry in cset["competitors"]:
        price = entry["price"]
        if price:
            name = entry["competitor"]["name"]
            print(cset["sku"], name, price["amount"])

interface Entry {
  competitor: { name: string };
  price: { amount: string } | null;
}
interface Page {
  data: { sku: string | null; competitors: Entry[] }[];
  skus: { sku: string; status: string }[];
}

const BASE = "https://api.getprice.ai/v1";
const KEY = process.env.GETPRICE_API_KEY;
const params = new URLSearchParams([
  ["sku", "10072L"],
  ["sku", "11247P"],
]);
const url = `${BASE}/comparison-sets?${params}`;
const res = await fetch(url, {
  headers: { Authorization: `Bearer ${KEY}` },
});
if (!res.ok) {
  throw new Error(`GetPrice returned ${res.status}`);
}
const page = (await res.json()) as Page;
for (const { sku, status } of page.skus) {
  console.log(sku, status);
}
for (const set of page.data) {
  for (const { competitor, price } of set.competitors) {
    if (!price) continue;
    console.log(set.sku, competitor.name, price.amount);
  }
}

<?php
$base = "https://api.getprice.ai/v1";
$key = getenv("GETPRICE_API_KEY");
// Repeat sku once per SKU.
$skus = ["10072L", "11247P"];
$query = implode("&", array_map(
    fn ($sku) => "sku=" . rawurlencode($sku),
    $skus,
));
$ch = curl_init("$base/comparison-sets?$query");
curl_setopt_array($ch, [
    CURLOPT_HTTPHEADER => [
        "Authorization: Bearer $key",
    ],
    CURLOPT_RETURNTRANSFER => true,
    CURLOPT_TIMEOUT => 30,
]);
$body = curl_exec($ch);
$status = curl_getinfo($ch, CURLINFO_RESPONSE_CODE);
if ($body === false || $status >= 400) {
    throw new RuntimeException(
        "GetPrice returned $status: $body"
    );
}
$data = json_decode(
    $body, true, flags: JSON_THROW_ON_ERROR
);

foreach ($data["skus"] as $entry) {
    echo $entry["sku"], " ", $entry["status"], "\n";
}
foreach ($data["data"] as $set) {
    foreach ($set["competitors"] as $entry) {
        if ($entry["price"] === null) {
            continue;
        }
        echo $set["sku"], " ",
            $entry["competitor"]["name"], " ",
            $entry["price"]["amount"], "\n";
    }
}

using System.Net.Http.Headers;
using System.Net.Http.Json;
using System.Text.Json;
using Naming = System.Text.Json.JsonNamingPolicy;

var key = Environment.GetEnvironmentVariable(
    "GETPRICE_API_KEY");
var api = new Uri("https://api.getprice.ai/v1/");
var http = new HttpClient { BaseAddress = api };
http.Timeout = TimeSpan.FromSeconds(30);
http.DefaultRequestHeaders.Authorization =
    new AuthenticationHeaderValue("Bearer", key);
var json = new JsonSerializerOptions
{
    PropertyNamingPolicy = Naming.SnakeCaseLower,
};

var res = await http.GetAsync(
    "comparison-sets?sku=10072L&sku=11247P");
res.EnsureSuccessStatusCode();
var page = await res.Content
    .ReadFromJsonAsync<Page>(json);
foreach (var s in page!.Skus)
    Console.WriteLine($"{s.Sku} {s.Status}");
foreach (var set in page.Data)
    foreach (var e in set.Competitors)
        if (e.Price is { } price)
            Console.WriteLine(
                $"{set.Sku} {e.Competitor.Name} "
                + price.Amount);

record Page(List<CompSet> Data, List<SkuStatus> Skus);
record SkuStatus(string Sku, string Status);
record CompSet(string? Sku, List<Entry> Competitors);
record Entry(Competitor Competitor, Price? Price);
record Competitor(string Name);
record Price(string Amount);

from decimal import Decimal

import requests
from odoo import models

API = "https://api.getprice.ai/v1"


class ProductProduct(models.Model):
    _inherit = "product.product"

    def action_getprice_competitor_prices(self):
        """Post the cheapest fresh competitor price.

        Up to 100 products per call.
        """
        icp = self.env["ir.config_parameter"].sudo()
        key = icp.get_param("getprice.api_key")
        resp = requests.get(
            f"{API}/comparison-sets",
            params=[
                ("sku", p.default_code) for p in self
            ],
            headers={"Authorization": f"Bearer {key}"},
            timeout=30,
        )
        resp.raise_for_status()
        sets = {
            s["sku"].strip().upper(): s
            for s in resp.json()["data"]
        }
        for product in self:
            sku = product.default_code.strip().upper()
            cset = sets.get(sku, {})
            entries = cset.get("competitors", [])
            offers = [
                e
                for e in entries
                if e["price"]
                and not e["stale"]
                and e["match"]["review"] == "same"
            ]
            if not offers:
                continue
            best = min(
                offers,
                key=lambda e: Decimal(
                    e["price"]["amount"]
                ),
            )
            name = best["competitor"]["name"]
            price = best["price"]
            line = f"{name}: R{price['amount']}"
            if price["was"]:  # on promotion
                line += f" (was R{price['was']})"
            product.message_post(
                body=f"Cheapest: {line}"
            )

import os

import requests

BASE = "https://api.getprice.ai/v1"
KEY = os.environ["GETPRICE_API_KEY"]

resp = requests.get(
    f"{BASE}/comparison-sets/set_x7Kp2Lm9",
    headers={"Authorization": f"Bearer {KEY}"},
    timeout=30,
)
resp.raise_for_status()
cset = resp.json()
for entry in cset["competitors"]:
    price = entry["price"]
    amount = f"R{price['amount']}" if price else "-"
    name = entry["competitor"]["name"]
    print(name, amount, entry["last_collected_at"])

interface Entry {
  competitor: { name: string };
  price: { amount: string } | null;
  last_collected_at: string | null;
}

const BASE = "https://api.getprice.ai/v1";
const KEY = process.env.GETPRICE_API_KEY;
const url = `${BASE}/comparison-sets/set_x7Kp2Lm9`;
const res = await fetch(url, {
  headers: { Authorization: `Bearer ${KEY}` },
});
if (!res.ok) {
  throw new Error(`GetPrice returned ${res.status}`);
}
const set = (await res.json()) as {
  competitors: Entry[];
};
for (const entry of set.competitors) {
  const { price } = entry;
  const amount = price ? `R${price.amount}` : "-";
  const name = entry.competitor.name;
  console.log(name, amount, entry.last_collected_at);
}

<?php
$base = "https://api.getprice.ai/v1";
$key = getenv("GETPRICE_API_KEY");
$ch = curl_init("$base/comparison-sets/set_x7Kp2Lm9");
curl_setopt_array($ch, [
    CURLOPT_HTTPHEADER => [
        "Authorization: Bearer $key",
    ],
    CURLOPT_RETURNTRANSFER => true,
    CURLOPT_TIMEOUT => 30,
]);
$body = curl_exec($ch);
$status = curl_getinfo($ch, CURLINFO_RESPONSE_CODE);
if ($body === false || $status >= 400) {
    throw new RuntimeException(
        "GetPrice returned $status: $body"
    );
}
$data = json_decode(
    $body, true, flags: JSON_THROW_ON_ERROR
);

foreach ($data["competitors"] as $entry) {
    $price = $entry["price"];
    $amount = $price ? "R" . $price["amount"] : "-";
    echo $entry["competitor"]["name"], " ", $amount,
        " ", $entry["last_collected_at"], "\n";
}

using System.Net.Http.Headers;
using System.Net.Http.Json;
using System.Text.Json;
using Naming = System.Text.Json.JsonNamingPolicy;

var key = Environment.GetEnvironmentVariable(
    "GETPRICE_API_KEY");
var api = new Uri("https://api.getprice.ai/v1/");
var http = new HttpClient { BaseAddress = api };
http.Timeout = TimeSpan.FromSeconds(30);
http.DefaultRequestHeaders.Authorization =
    new AuthenticationHeaderValue("Bearer", key);
var json = new JsonSerializerOptions
{
    PropertyNamingPolicy = Naming.SnakeCaseLower,
};

var res = await http.GetAsync(
    "comparison-sets/set_x7Kp2Lm9");
res.EnsureSuccessStatusCode();
var set = await res.Content
    .ReadFromJsonAsync<CompSet>(json);
foreach (var e in set!.Competitors)
{
    var amount = e.Price is null
        ? "-" : $"R{e.Price.Amount}";
    var name = e.Competitor.Name;
    Console.WriteLine(
        $"{name} {amount} {e.LastCollectedAt}");
}

record CompSet(List<Entry> Competitors);
record Entry(
    Competitor Competitor,
    Price? Price,
    string? LastCollectedAt);
record Competitor(string Name);
record Price(string Amount);

import requests
from odoo import models

API = "https://api.getprice.ai/v1"


class ProductProduct(models.Model):
    _inherit = "product.product"

    def getprice_post_comparison_set(self, set_id):
        """Post every competitor price in one set."""
        self.ensure_one()
        icp = self.env["ir.config_parameter"].sudo()
        key = icp.get_param("getprice.api_key")
        resp = requests.get(
            f"{API}/comparison-sets/{set_id}",
            headers={"Authorization": f"Bearer {key}"},
            timeout=30,
        )
        resp.raise_for_status()
        lines = []
        for e in resp.json()["competitors"]:
            name = e["competitor"]["name"]
            price = e["price"]
            amount = "-"
            if price:
                amount = f"R{price['amount']}"
            if price and price["was"]:  # on promotion
                amount += f" (was R{price['was']})"
            lines.append(f"{name}: {amount}")
        self.message_post(body="; ".join(lines))

import os

import requests

BASE = "https://api.getprice.ai/v1"
KEY = os.environ["GETPRICE_API_KEY"]

resp = requests.get(
    f"{BASE}/products",
    params=[("q", "pilchards"), ("unmapped", "true")],
    headers={"Authorization": f"Bearer {KEY}"},
    timeout=30,
)
resp.raise_for_status()
for product in resp.json()["data"]:
    print(product["id"], product["name"])

interface Product {
  id: string;
  name: string;
}

const BASE = "https://api.getprice.ai/v1";
const KEY = process.env.GETPRICE_API_KEY;
const params = new URLSearchParams([
  ["q", "pilchards"],
  ["unmapped", "true"],
]);
const url = `${BASE}/products?${params}`;
const res = await fetch(url, {
  headers: { Authorization: `Bearer ${KEY}` },
});
if (!res.ok) {
  throw new Error(`GetPrice returned ${res.status}`);
}
const page = (await res.json()) as {
  data: Product[];
};
for (const product of page.data) {
  console.log(product.id, product.name);
}

<?php
$base = "https://api.getprice.ai/v1";
$key = getenv("GETPRICE_API_KEY");
$query = http_build_query([
    "q" => "pilchards",
    "unmapped" => "true",
]);
$ch = curl_init("$base/products?$query");
curl_setopt_array($ch, [
    CURLOPT_HTTPHEADER => [
        "Authorization: Bearer $key",
    ],
    CURLOPT_RETURNTRANSFER => true,
    CURLOPT_TIMEOUT => 30,
]);
$body = curl_exec($ch);
$status = curl_getinfo($ch, CURLINFO_RESPONSE_CODE);
if ($body === false || $status >= 400) {
    throw new RuntimeException(
        "GetPrice returned $status: $body"
    );
}
$data = json_decode(
    $body, true, flags: JSON_THROW_ON_ERROR
);

foreach ($data["data"] as $product) {
    echo $product["id"], " ", $product["name"], "\n";
}

using System.Net.Http.Headers;
using System.Net.Http.Json;
using System.Text.Json;
using Naming = System.Text.Json.JsonNamingPolicy;

var key = Environment.GetEnvironmentVariable(
    "GETPRICE_API_KEY");
var api = new Uri("https://api.getprice.ai/v1/");
var http = new HttpClient { BaseAddress = api };
http.Timeout = TimeSpan.FromSeconds(30);
http.DefaultRequestHeaders.Authorization =
    new AuthenticationHeaderValue("Bearer", key);
var json = new JsonSerializerOptions
{
    PropertyNamingPolicy = Naming.SnakeCaseLower,
};

var res = await http.GetAsync(
    "products?q=pilchards&unmapped=true");
res.EnsureSuccessStatusCode();
var page = await res.Content
    .ReadFromJsonAsync<Page>(json);
foreach (var p in page!.Data)
    Console.WriteLine($"{p.Id} {p.Name}");

record Page(List<Product> Data);
record Product(string Id, string Name);

import requests
from odoo import models

API = "https://api.getprice.ai/v1"


class ProductProduct(models.Model):
    _inherit = "product.product"

    def action_getprice_find_matches(self):
        """Suggest unlinked products by name."""
        self.ensure_one()
        icp = self.env["ir.config_parameter"].sudo()
        key = icp.get_param("getprice.api_key")
        resp = requests.get(
            f"{API}/products",
            params={"q": self.name, "unmapped": "true"},
            headers={"Authorization": f"Bearer {key}"},
            timeout=30,
        )
        resp.raise_for_status()
        found = [
            f"{p['id']} {p['name']}"
            for p in resp.json()["data"]
        ]
        text = "; ".join(found) or "none"
        self.message_post(body=f"Candidates: {text}")

import os

import requests

BASE = "https://api.getprice.ai/v1"
KEY = os.environ["GETPRICE_API_KEY"]

resp = requests.get(
    f"{BASE}/products/prd_8fK2mQa1",
    headers={"Authorization": f"Bearer {KEY}"},
    timeout=30,
)
resp.raise_for_status()
product = resp.json()
price = product["price"]
amount = f"R{price['amount']}" if price else "-"
print(product["name"], amount)

interface Product {
  name: string;
  price: { amount: string } | null;
}

const BASE = "https://api.getprice.ai/v1";
const KEY = process.env.GETPRICE_API_KEY;
const url = `${BASE}/products/prd_8fK2mQa1`;
const res = await fetch(url, {
  headers: { Authorization: `Bearer ${KEY}` },
});
if (!res.ok) {
  throw new Error(`GetPrice returned ${res.status}`);
}
const product = (await res.json()) as Product;
const { price } = product;
const amount = price ? `R${price.amount}` : "-";
console.log(product.name, amount);

<?php
$base = "https://api.getprice.ai/v1";
$key = getenv("GETPRICE_API_KEY");
$ch = curl_init("$base/products/prd_8fK2mQa1");
curl_setopt_array($ch, [
    CURLOPT_HTTPHEADER => [
        "Authorization: Bearer $key",
    ],
    CURLOPT_RETURNTRANSFER => true,
    CURLOPT_TIMEOUT => 30,
]);
$body = curl_exec($ch);
$status = curl_getinfo($ch, CURLINFO_RESPONSE_CODE);
if ($body === false || $status >= 400) {
    throw new RuntimeException(
        "GetPrice returned $status: $body"
    );
}
$data = json_decode(
    $body, true, flags: JSON_THROW_ON_ERROR
);

$price = $data["price"];
$amount = $price ? "R" . $price["amount"] : "-";
echo $data["name"], " ", $amount, "\n";

using System.Net.Http.Headers;
using System.Net.Http.Json;
using System.Text.Json;
using Naming = System.Text.Json.JsonNamingPolicy;

var key = Environment.GetEnvironmentVariable(
    "GETPRICE_API_KEY");
var api = new Uri("https://api.getprice.ai/v1/");
var http = new HttpClient { BaseAddress = api };
http.Timeout = TimeSpan.FromSeconds(30);
http.DefaultRequestHeaders.Authorization =
    new AuthenticationHeaderValue("Bearer", key);
var json = new JsonSerializerOptions
{
    PropertyNamingPolicy = Naming.SnakeCaseLower,
};

var res = await http.GetAsync("products/prd_8fK2mQa1");
res.EnsureSuccessStatusCode();
var product = await res.Content
    .ReadFromJsonAsync<Product>(json);
var amount = product!.Price is null
    ? "-" : $"R{product.Price.Amount}";
Console.WriteLine($"{product.Name} {amount}");

record Product(string Name, Price? Price);
record Price(string Amount);

import requests
from odoo import models

API = "https://api.getprice.ai/v1"


class ProductProduct(models.Model):
    _inherit = "product.product"

    def getprice_post_shop_price(self, gp_product_id):
        """Post the price collected from your shop."""
        self.ensure_one()
        icp = self.env["ir.config_parameter"].sudo()
        key = icp.get_param("getprice.api_key")
        resp = requests.get(
            f"{API}/products/{gp_product_id}",
            headers={"Authorization": f"Bearer {key}"},
            timeout=30,
        )
        resp.raise_for_status()
        price = resp.json()["price"]
        if price:
            self.message_post(
                body=f"Shop price R{price['amount']}"
            )

import os

import requests

BASE = "https://api.getprice.ai/v1"
KEY = os.environ["GETPRICE_API_KEY"]

resp = requests.get(
    f"{BASE}/competitors",
    headers={"Authorization": f"Bearer {KEY}"},
    timeout=30,
)
resp.raise_for_status()
for c in resp.json()["data"]:
    print(c["id"], c["name"], c["domain"])

interface Competitor {
  id: string;
  name: string;
  domain: string;
}

const BASE = "https://api.getprice.ai/v1";
const KEY = process.env.GETPRICE_API_KEY;
const url = `${BASE}/competitors`;
const res = await fetch(url, {
  headers: { Authorization: `Bearer ${KEY}` },
});
if (!res.ok) {
  throw new Error(`GetPrice returned ${res.status}`);
}
const page = (await res.json()) as {
  data: Competitor[];
};
for (const { id, name, domain } of page.data) {
  console.log(id, name, domain);
}

<?php
$base = "https://api.getprice.ai/v1";
$key = getenv("GETPRICE_API_KEY");
$ch = curl_init("$base/competitors");
curl_setopt_array($ch, [
    CURLOPT_HTTPHEADER => [
        "Authorization: Bearer $key",
    ],
    CURLOPT_RETURNTRANSFER => true,
    CURLOPT_TIMEOUT => 30,
]);
$body = curl_exec($ch);
$status = curl_getinfo($ch, CURLINFO_RESPONSE_CODE);
if ($body === false || $status >= 400) {
    throw new RuntimeException(
        "GetPrice returned $status: $body"
    );
}
$data = json_decode(
    $body, true, flags: JSON_THROW_ON_ERROR
);

foreach ($data["data"] as $c) {
    echo $c["id"], " ", $c["name"], " ",
        $c["domain"], "\n";
}

using System.Net.Http.Headers;
using System.Net.Http.Json;
using System.Text.Json;
using Naming = System.Text.Json.JsonNamingPolicy;

var key = Environment.GetEnvironmentVariable(
    "GETPRICE_API_KEY");
var api = new Uri("https://api.getprice.ai/v1/");
var http = new HttpClient { BaseAddress = api };
http.Timeout = TimeSpan.FromSeconds(30);
http.DefaultRequestHeaders.Authorization =
    new AuthenticationHeaderValue("Bearer", key);
var json = new JsonSerializerOptions
{
    PropertyNamingPolicy = Naming.SnakeCaseLower,
};

var res = await http.GetAsync("competitors");
res.EnsureSuccessStatusCode();
var page = await res.Content
    .ReadFromJsonAsync<Page>(json);
foreach (var c in page!.Data)
    Console.WriteLine($"{c.Id} {c.Name} {c.Domain}");

record Page(List<Competitor> Data);
record Competitor(
    string Id,
    string Name,
    string Domain);

import requests
from odoo import api, models

API = "https://api.getprice.ai/v1"


class ResPartner(models.Model):
    _inherit = "res.partner"

    @api.model
    def getprice_sync_competitors(self):
        """Create a contact per tracked competitor."""
        icp = self.env["ir.config_parameter"].sudo()
        key = icp.get_param("getprice.api_key")
        resp = requests.get(
            f"{API}/competitors",
            headers={"Authorization": f"Bearer {key}"},
            timeout=30,
        )
        resp.raise_for_status()
        for c in resp.json()["data"]:
            domain = [("website", "=", c["url"])]
            if not self.search(domain, limit=1):
                self.create({
                    "name": c["name"],
                    "website": c["url"],
                    "is_company": True,
                })

import os

import requests

BASE = "https://api.getprice.ai/v1"
KEY = os.environ["GETPRICE_API_KEY"]

resp = requests.get(
    f"{BASE}/sku-mappings",
    params=[("limit", "100")],
    headers={"Authorization": f"Bearer {KEY}"},
    timeout=30,
)
resp.raise_for_status()
page = resp.json()
for m in page["data"]:
    target = m["product_id"] or m["comparison_set_id"]
    print(m["sku"], target)
# More? Send page["next_cursor"] as cursor.

interface SkuMapping {
  sku: string;
  product_id: string | null;
  comparison_set_id: string | null;
}

const BASE = "https://api.getprice.ai/v1";
const KEY = process.env.GETPRICE_API_KEY;
const params = new URLSearchParams([
  ["limit", "100"],
]);
const url = `${BASE}/sku-mappings?${params}`;
const res = await fetch(url, {
  headers: { Authorization: `Bearer ${KEY}` },
});
if (!res.ok) {
  throw new Error(`GetPrice returned ${res.status}`);
}
const page = (await res.json()) as {
  data: SkuMapping[];
  next_cursor: string | null;
};
for (const m of page.data) {
  const target = m.product_id ?? m.comparison_set_id;
  console.log(m.sku, target);
}
// More? Send page.next_cursor as cursor.

<?php
$base = "https://api.getprice.ai/v1";
$key = getenv("GETPRICE_API_KEY");
$query = http_build_query([
    "limit" => "100",
]);
$ch = curl_init("$base/sku-mappings?$query");
curl_setopt_array($ch, [
    CURLOPT_HTTPHEADER => [
        "Authorization: Bearer $key",
    ],
    CURLOPT_RETURNTRANSFER => true,
    CURLOPT_TIMEOUT => 30,
]);
$body = curl_exec($ch);
$status = curl_getinfo($ch, CURLINFO_RESPONSE_CODE);
if ($body === false || $status >= 400) {
    throw new RuntimeException(
        "GetPrice returned $status: $body"
    );
}
$data = json_decode(
    $body, true, flags: JSON_THROW_ON_ERROR
);

foreach ($data["data"] as $m) {
    $target = $m["product_id"]
        ?? $m["comparison_set_id"];
    echo $m["sku"], " ", $target, "\n";
}
// More? Send $data["next_cursor"] as cursor.

using System.Net.Http.Headers;
using System.Net.Http.Json;
using System.Text.Json;
using Naming = System.Text.Json.JsonNamingPolicy;

var key = Environment.GetEnvironmentVariable(
    "GETPRICE_API_KEY");
var api = new Uri("https://api.getprice.ai/v1/");
var http = new HttpClient { BaseAddress = api };
http.Timeout = TimeSpan.FromSeconds(30);
http.DefaultRequestHeaders.Authorization =
    new AuthenticationHeaderValue("Bearer", key);
var json = new JsonSerializerOptions
{
    PropertyNamingPolicy = Naming.SnakeCaseLower,
};

var res = await http.GetAsync("sku-mappings?limit=100");
res.EnsureSuccessStatusCode();
var page = await res.Content
    .ReadFromJsonAsync<Page>(json);
foreach (var m in page!.Data)
    Console.WriteLine(
        $"{m.Sku} {m.ProductId ?? m.ComparisonSetId}");
// More? Send page.NextCursor as cursor.

record Page(List<SkuMapping> Data, string? NextCursor);
record SkuMapping(
    string Sku,
    string? ProductId,
    string? ComparisonSetId);

import logging

import requests
from odoo import api, models

API = "https://api.getprice.ai/v1"
_logger = logging.getLogger(__name__)


class ProductProduct(models.Model):
    _inherit = "product.product"

    @api.model
    def getprice_unlinked_products(self):
        """Products whose reference has no SKU link."""
        icp = self.env["ir.config_parameter"].sudo()
        key = icp.get_param("getprice.api_key")
        linked, params = set(), {"limit": 100}
        while True:
            resp = requests.get(
                f"{API}/sku-mappings",
                params=params,
                headers={
                    "Authorization": f"Bearer {key}"
                },
                timeout=30,
            )
            resp.raise_for_status()
            page = resp.json()
            for m in page["data"]:
                linked.add(m["sku"].strip().upper())
            if page["next_cursor"] is None:
                break
            params["cursor"] = page["next_cursor"]
        products = self.search(
            [("default_code", "!=", False)]
        )
        unlinked = products.filtered(
            lambda p: p.default_code.strip().upper()
            not in linked
        )
        _logger.info("%s unlinked", len(unlinked))
        return unlinked