Consumers

Create a managed feed consumer

Save a where predicate and let smry retain one processing checkpoint. New consumers start at the current high-water mark, so they receive future discoveries rather than replaying history. For history, create the Consumer first, query the historical window separately, then poll; that order closes the query/create race. Create one per independent processing loop, not per source. Retrying the same case-insensitive name and predicate returns the existing Consumer; the same name with another predicate is a 409.

POST

https://api.smry.ai

feeds

consumers

Create a managed feed consumer

curl --request POST \
  --url https://api.smry.ai/v1/feeds/consumers \
  --header 'Authorization: Bearer <token>' \
  --header 'Content-Type: application/json' \
  --data '
{
  "name": "Engineering briefing"
}
'

import requests

url = "https://api.smry.ai/v1/feeds/consumers"

payload = { "name": "Engineering briefing" }
headers = {
    "Authorization": "Bearer <token>",
    "Content-Type": "application/json"
}

response = requests.post(url, json=payload, headers=headers)

print(response.text)

const options = {
  method: 'POST',
  headers: {Authorization: 'Bearer <token>', 'Content-Type': 'application/json'},
  body: JSON.stringify({name: 'Engineering briefing'})
};

fetch('https://api.smry.ai/v1/feeds/consumers', options)
  .then(res => res.json())
  .then(res => console.log(res))
  .catch(err => console.error(err));

{
  "id": 123,
  "name": "<string>",
  "where": "<unknown>",
  "acknowledged_cursor": "<string>",
  "created_at": "<string>",
  "last_delivered_at": "<string>",
  "last_acknowledged_at": "<string>"
}

{
  "error": "cursor: expected a next_cursor from a previous response.",
  "code": "invalid_request",
  "field": "where.published_after",
  "hint": "<string>",
  "retryable": true,
  "retryAfter": 123,
  "details": "<string>"
}

{
  "error": "cursor: expected a next_cursor from a previous response.",
  "code": "invalid_request",
  "field": "where.published_after",
  "hint": "<string>",
  "retryable": true,
  "retryAfter": 123,
  "details": "<string>"
}

{
  "error": "cursor: expected a next_cursor from a previous response.",
  "code": "invalid_request",
  "field": "where.published_after",
  "hint": "<string>",
  "retryable": true,
  "retryAfter": 123,
  "details": "<string>"
}

{
  "error": "cursor: expected a next_cursor from a previous response.",
  "code": "invalid_request",
  "field": "where.published_after",
  "hint": "<string>",
  "retryable": true,
  "retryAfter": 123,
  "details": "<string>"
}

{
  "error": "cursor: expected a next_cursor from a previous response.",
  "code": "invalid_request",
  "field": "where.published_after",
  "hint": "<string>",
  "retryable": true,
  "retryAfter": 123,
  "details": "<string>"
}

{
  "error": "cursor: expected a next_cursor from a previous response.",
  "code": "invalid_request",
  "field": "where.published_after",
  "hint": "<string>",
  "retryable": true,
  "retryAfter": 123,
  "details": "<string>"
}

Authorizations

Authorization

string

header

required

Clerk OAuth 2.0 Authorization Code flow with PKCE. Request the minimum scope required by the operation.

Body

application/json

name

string

required

Required string length: 1 - 120

where

object

Entry selection predicate: fields AND together; omit a field to not filter on it. Source queries/mutations accept only collection and source; use query having for source-health filters.

Hide child attributes

where.discovered_after

string

When smry first saw the entry. Backfill makes old posts look new here, so use it for diffs, not for "what's new". Relative window ("7d", "36h", "45m", "2w"), "now", or ISO date.

Required string length: 1 - 64

where.discovered_before

string

Relative window ("7d", "36h", "45m", "2w"), "now", or ISO date.

Required string length: 1 - 64

where.published_after

string

When the source published the entry (entries with no publish date are excluded; use top-level since to include them). Relative window ("7d", "36h", "45m", "2w"), "now", or ISO date.

Required string length: 1 - 64

where.published_before

string

Relative window ("7d", "36h", "45m", "2w"), "now", or ISO date.

Required string length: 1 - 64

where.collection

(integer | string)[]

Required array length: 1 - 20 elements

A collection id or its exact name.

Required range: x >= 1

where.source

object

Hide child attributes

where.source.include

(integer | string)[]

Required array length: 1 - 100 elements

A source id (from any v2 response) or its title. Reads also accept a fragment that matches exactly one title.

Required range: x >= 1

where.source.exclude

(integer | string)[]

Required array length: 1 - 100 elements

A source id (from any v2 response) or its title. Reads also accept a fragment that matches exactly one title.

Required range: x >= 1

where.unread

boolean

true = only unread entries, false = only read entries.

where.classification

object

The Collection filter's binary delivery decision and optional underlying assessment. Requires exactly one Collection.

Hide child attributes

where.classification.decision

required

Allowed value: "include"

where.classification.assessment

Allowed value: "relevant"

where.match

string

Case-insensitive text match over title and summary. "a OR b" matches either.

Required string length: 1 - 500

Response

Create a managed feed consumer. The operation succeeded.

integer

required

name

string

required

where

any

required

acknowledged_cursor

string

required

The Consumer's durable acknowledged position. Poll with consumer_id; acknowledge the next_cursor returned by that poll.

created_at

string

required

last_delivered_at

string | null

required

last_acknowledged_at

string | null

required

Last modified on September 13, 2026

Create a managed feed consumer

curl --request POST \
  --url https://api.smry.ai/v1/feeds/consumers \
  --header 'Authorization: Bearer <token>' \
  --header 'Content-Type: application/json' \
  --data '
{
  "name": "Engineering briefing"
}
'

import requests

url = "https://api.smry.ai/v1/feeds/consumers"

payload = { "name": "Engineering briefing" }
headers = {
    "Authorization": "Bearer <token>",
    "Content-Type": "application/json"
}

response = requests.post(url, json=payload, headers=headers)

print(response.text)

const options = {
  method: 'POST',
  headers: {Authorization: 'Bearer <token>', 'Content-Type': 'application/json'},
  body: JSON.stringify({name: 'Engineering briefing'})
};

fetch('https://api.smry.ai/v1/feeds/consumers', options)
  .then(res => res.json())
  .then(res => console.log(res))
  .catch(err => console.error(err));

{
  "id": 123,
  "name": "<string>",
  "where": "<unknown>",
  "acknowledged_cursor": "<string>",
  "created_at": "<string>",
  "last_delivered_at": "<string>",
  "last_acknowledged_at": "<string>"
}

{
  "error": "cursor: expected a next_cursor from a previous response.",
  "code": "invalid_request",
  "field": "where.published_after",
  "hint": "<string>",
  "retryable": true,
  "retryAfter": 123,
  "details": "<string>"
}

{
  "error": "cursor: expected a next_cursor from a previous response.",
  "code": "invalid_request",
  "field": "where.published_after",
  "hint": "<string>",
  "retryable": true,
  "retryAfter": 123,
  "details": "<string>"
}

{
  "error": "cursor: expected a next_cursor from a previous response.",
  "code": "invalid_request",
  "field": "where.published_after",
  "hint": "<string>",
  "retryable": true,
  "retryAfter": 123,
  "details": "<string>"
}

{
  "error": "cursor: expected a next_cursor from a previous response.",
  "code": "invalid_request",
  "field": "where.published_after",
  "hint": "<string>",
  "retryable": true,
  "retryAfter": 123,
  "details": "<string>"
}

{
  "error": "cursor: expected a next_cursor from a previous response.",
  "code": "invalid_request",
  "field": "where.published_after",
  "hint": "<string>",
  "retryable": true,
  "retryAfter": 123,
  "details": "<string>"
}

{
  "error": "cursor: expected a next_cursor from a previous response.",
  "code": "invalid_request",
  "field": "where.published_after",
  "hint": "<string>",
  "retryable": true,
  "retryAfter": 123,
  "details": "<string>"
}

Overview

Account

Articles

Library

Feeds

Collections

Consumers

Monitors

Create a managed feed consumer

Authorizations

Body

Response