#!/usr/bin/env python3 """Test cursor-based pagination with Webgains""" import requests, json API = "https://platform-api.webgains.com" PUB = "1347930" TOKEN = "eyJ0eXAiOiJKV1QiLCJhbGciOiJSUzI1NiJ9.eyJhdWQiOiIxMDAwMzEiLCJqdGkiOiIwNjM5ODEwYzQ0YzM1MTBlZmZiMGRkYWNiM2EyNWFlNTg2YzFmNmQ5ODNjNGQ2MDA4NzkwZmM0NTkzY2EyNjg4ZGViZDE4NTgwOThmYjJjYiIsImlhdCI6MTc3MTUxNjc4OS44MzAxMzUsIm5iZiI6MTc3MTUxNjc4OS44MzAxMzcsImV4cCI6MjA4NzA0OTU4OS44MjcwODgsInN1YiI6IjIwMTcwOCIsInNjb3BlcyI6W119.ZxlCDsyBI7_SNUWjO-PUxDYKvQVfuUBzU5n-SgqHdAZCnOj9253yVcJIS5NRXJLrnyx0E_9bn8ymfXS71cvPISA4hPAlKCSMjdkv9f2k2FFwdAlQQ6mdhBB2m9dzHUIn34QwA8s4-ikB1ATKIZeqiJL-3Gh9eiMYPpvaJdCCjN-oGPMhhlehkgA04cZSgwy6HfKgb6uPvUSG9w_tvN8U06uEHKV11DedQHNWWGzuXpd2FEL3baV0z9KjSNMZsJZHx2yHUb6gVWJwaR7_louahMvrPXG-YLgnGvNMcPDPjm-z5HJ-JKcPv9_FBqAYGItZxgeGgVoS8MVhW6lc1a-6CvYtVanfXF42MPPNP-Qq76qRtHPLRBdkIATMuBxVJrMzlprT3n4F0sUUltGR4ixZuzMUm5LeyPMHgmjy2UfYzsl9eVqx0oJCmKUyY9maBXwFLJa8J1NHM_nWp3hPpCGkMyhzHK1DIf_z8Wirg1hp5vKts93eERWJBlQwhucUUS_KnZeC_gVaQ7kT4jCwaEWkpPxPxyXWRoK0mcYS_JGz3JbpVhRLj5DVYIB9k54DXqjYlCx8ezJZE9sf2SX3VWvPvD1xSQD1caTCm0To0B-MkeU1YpEfWdUslpCJXrpOy2Wbs8iDHR1BzNrMnOEr4zbz_EoB4JJe3tGTGjzNLNIw6XI" H = {"Authorization": f"Bearer {TOKEN}"} CAMP = "1622230" FEED = "17108" url = f"{API}/auth/publishers/{PUB}/campaigns/{CAMP}/feeds/products" all_ids = set() cursor = None for page in range(5): params = { "feeds[]": [FEED], "size": 1000, "fields[]": ["title", "id", "brand"], } if cursor: params["search_after"] = cursor r = requests.get(url, headers=H, params=params, timeout=60) data = r.json() pagination = data.get("pagination", {}) products = data.get("data", []) ids = set(p["id"] for p in products) new_ids = ids - all_ids all_ids |= ids cursor = pagination.get("search_cursor") print(f"Page {page}: {len(products)} products, {len(new_ids)} new, cumulative: {len(all_ids)}") print(f" Cursor: {cursor}") print(f" Pagination: {json.dumps(pagination)}") if not new_ids or not products: print(" No new products, stopping") break