CONNECT APP
Build with Polar
Commerce
- OAuth
MCP
Give your agent Polar tools
Every Polar action is exposed as an MCP tool on Pipedream's remote server. Point a client at it with your end user's ID and Connect resolves that user's Polar account for each tool call — you store no tokens.
// accessToken: mint a short-lived token with the Connect SDK — see the MCP guide
const transport = new StreamableHTTPClientTransport(
new URL("https://remote.mcp.pipedream.net/v3"),
{
requestInit: {
headers: {
Authorization: `Bearer ${accessToken}`,
"x-pd-project-id": "{project_id}",
"x-pd-environment": "production",
"x-pd-external-user-id": "{external_user_id}", // any stable ID for this user in your system
"x-pd-app-slug": "polar",
},
},
},
)
const mcp = new Client({ name: "my-agent", version: "1.0.0" })
await mcp.connect(transport)
const { tools } = await mcp.listTools()
// e.g. run Create Checkout:
const result = await mcp.callTool({
name: "polar-create-checkout",
arguments: {
products: ["Products"],
prices: "Prices",
},
})# access_token: mint a short-lived token with the Connect SDK — see the MCP guide
headers = {
"Authorization": f"Bearer {access_token}",
"x-pd-project-id": "{project_id}",
"x-pd-environment": "production",
"x-pd-external-user-id": "{external_user_id}", # any stable ID for this user in your system
"x-pd-app-slug": "polar",
}
async with streamablehttp_client("https://remote.mcp.pipedream.net/v3", headers=headers) as (read, write, _):
async with ClientSession(read, write) as session:
await session.initialize()
tools = await session.list_tools()
# e.g. run Create Checkout:
result = await session.call_tool("polar-create-checkout", {
"products": ["Products"],
"prices": "Prices",
})API PROXY
Call the Polar API directly
For an endpoint with no pre-built tool, the Connect proxy forwards your request to the Polar API with the connected user's credentials attached. You store no tokens and write no refresh logic.
const resp = await pd.proxy.get({
externalUserId: "{external_user_id}", // any stable ID for this user in your system
accountId: "apn_xxxxxxx",
url: "https://api.polar.sh/v1/oauth2/userinfo",
})
// Any allowed Polar endpoint works here. Pipedream attaches the
// connected account's credentials to the outgoing request.# The path segment is the target URL, URL-safe base64 encoded:
# https://api.polar.sh/v1/oauth2/userinfo
curl "https://api.pipedream.com/v1/connect/{project_id}/proxy/aHR0cHM6Ly9hcGkucG9sYXIuc2gvdjEvb2F1dGgyL3VzZXJpbmZv?external_user_id={external_user_id}&account_id=apn_xxxxxxx" \
-H "Authorization: Bearer {access_token}" \
-H "x-pd-environment: production"SDK
Run Polar actions from your backend
Connect a user's Polar account once, then run Create Checkout on their behalf from your own code — TypeScript, Python, or plain HTTP.
import { PipedreamClient } from "@pipedream/sdk"
const pd = new PipedreamClient({
projectId: process.env.PIPEDREAM_PROJECT_ID!,
clientId: process.env.PIPEDREAM_CLIENT_ID!,
clientSecret: process.env.PIPEDREAM_CLIENT_SECRET!,
projectEnvironment: "production",
})
const result = await pd.actions.run({
id: "polar-create-checkout",
externalUserId: "{external_user_id}", // any stable ID for this user in your system
configuredProps: {
polar: { authProvisionId: "apn_xxxxxxx" },
products: ["Products"],
prices: "Prices",
},
})from pipedream import Pipedream
pd = Pipedream(
client_id="{oauth_client_id}",
client_secret="{oauth_client_secret}",
project_id="{project_id}",
project_environment="production",
)
result = pd.actions.run(
id="polar-create-checkout",
external_user_id="{external_user_id}", # any stable ID for this user in your system
configured_props={
"polar": {"authProvisionId": "apn_xxxxxxx"},
"products": ["Products"],
"prices": "Prices",
},
)curl -X POST https://api.pipedream.com/v1/connect/{project_id}/actions/run \
-H "Content-Type: application/json" \
-H "X-PD-Environment: production" \
-H "Authorization: Bearer {access_token}" \
-d '{
"external_user_id": "{external_user_id}",
"id": "polar-create-checkout",
"configured_props": {
"polar": { "authProvisionId": "apn_xxxxxxx" },
"products": ["Products"],
"prices": "Prices"
}
}'TOOLS
Polar actions
On-demand operations your product or agent can configure and run on behalf of a connected user.
-
Create Checkout
actionCreate a checkout session for one or more products. See the documentationWritev0.0.2 -
List Customers
actionList customers according to the specified filters. See the API docsRead-onlyv0.0.1 -
List Orders
actionList orders according to the specified filters. See the API docsRead-onlyv0.0.2 -
List Products
actionList products according to the specified filters. See the API docsRead-onlyv0.0.1 -
List Subscriptions
actionList subscriptions according to the specified filters. See the API docsRead-onlyv0.0.2
-
New Benefit Created
triggerEmit new event when a new benefit is created. See the API docsInstantv0.0.2 -
New Benefit Updated
triggerEmit new event when a benefit is updated. See the API docsInstantv0.0.2 -
New Subscription Created
triggerEmit new event when a new subscription is created. See the API docsInstantv0.0.2 -
New Subscription Updated
triggerEmit new event when a subscription is updated. See the API docsInstantv0.0.2 -
New Webhook Event
triggerEmit new event when the selected webhook event occurs. See the API docsInstantv0.0.2
MULTI-APP
Use Polar with other popular apps
Most products don't stop at one integration. Pair Polar with the other apps your users rely on, and ship use cases that span both.
- App slug
- polar
- Authentication
- OAuth
- Categories
- Commerce
- Actions
- 5
- Triggers
- 5
- API proxy
- Available
OAuth scopes
These are the scopes Pipedream's managed Polar OAuth client requests when one of your users connects an account. Supply your own OAuth client to request a different set.
- openid
- profile
- user:read
- webhooks:read
- webhooks:write
- orders:read
- subscriptions:read
- transactions:read
- metrics:read
- products:read
- checkouts:write
- checkout_links:write
- customers:read