Pinterest API

gem "pinterest-ads"

Pinterest.configure do |c|
  c.client_id     = ENV["PINTEREST_CLIENT_ID"]
  c.client_secret = ENV["PINTEREST_CLIENT_SECRET"]
  c.access_token  = ENV["PINTEREST_ACCESS_TOKEN"]
  c.redirect_uri  = ENV["PINTEREST_REDIRECT_URI"]
end

client = Pinterest::Client.new(
  client_id:     "your_app_id",
  client_secret: "your_app_secret",
  access_token:  "your_bearer_token",
  redirect_uri:  "https://example.com/callback"
)

url = client.oauth.authorization_url(
  redirect_uri: "https://example.com/callback",
  scope: %w[ads:read ads:write],
  state: SecureRandom.hex(16)
)
# Redirect the user to this URL

tokens = client.oauth.exchange_code(
  code: params[:code],
  redirect_uri: "https://example.com/callback"
)
# tokens => { "access_token" => "...", "refresh_token" => "...", "expires_in" => 86400, ... }

tokens = client.oauth.refresh(refresh_token: "your_refresh_token")
client.access_token = tokens["access_token"]

client.oauth.revoke(token: "token_to_revoke", token_type_hint: "access_token")

result = client.oauth.conversion_token
# result => { "access_token" => "...", "token_type" => "conversion" }

# List audiences
audiences = client.audiences.list(ad_account_id: "123456")
# audiences => { "items" => [...], "bookmark" => "..." }

# Create an audience
audience = client.audiences.create(
  ad_account_id: "123456",
  name: "My Audience",
  audience_type: "CUSTOMER_LIST",
  rule: { ... }
)

# Get a specific audience
audience = client.audiences.find(ad_account_id: "123456", audience_id: "789")

# Update an audience
client.audiences.update(ad_account_id: "123456", audience_id: "789", name: "New Name")

# List customer lists
lists = client.customer_lists.list(ad_account_id: "123456")

# Create a customer list
list = client.customer_lists.create(
  ad_account_id: "123456",
  name: "Email Subscribers",
  list_type: "EMAIL",
  records: "user1@example.com\nuser2@example.com"
)

# Get a specific customer list
list = client.customer_lists.find(ad_account_id: "123456", customer_list_id: "789")

# Add or remove records
client.customer_lists.update(
  ad_account_id: "123456",
  customer_list_id: "789",
  operation_type: "ADD",
  records: "user3@example.com"
)

# 1. Create the upload (returns presigned S3 URLs)
upload = client.customer_list_uploads.create(
  ad_account_id: "123456",
  customer_list_id: "789",
  operation: "ADD",
  total_parts: 3
)
# upload => { "customer_list_upload" => {...}, "s3_multipart_upload_data" => {...} }

# 2. Upload parts to S3 using the presigned URLs (outside this gem)

# 3. Trigger processing
client.customer_list_uploads.run(
  ad_account_id: "123456",
  customer_list_id: "789",
  customer_list_upload_id: upload.dig("customer_list_upload", "id")
)

# Check upload status
status = client.customer_list_uploads.find(
  ad_account_id: "123456",
  customer_list_id: "789",
  customer_list_upload_id: "upload_id"
)

all_audiences = []
bookmark = nil

loop do
  result = client.audiences.list(ad_account_id: "123456", bookmark: bookmark, page_size: 25)
  all_audiences.concat(result["items"])
  bookmark = result["bookmark"]
  break if bookmark.nil?
end

begin
  client.audiences.find(ad_account_id: "123", audience_id: "bad_id")
rescue Pinterest::NotFoundError => e
  puts e.message # API error message
  puts e.status  # 404
rescue Pinterest::Error => e
  puts "Unexpected error: #{e.message} (HTTP #{e.status})"
end