Admin Control Plane Matcher Subscriptions

curl --request POST \
  --url https://api.glider.fi/v1/admin/control-plane/matcher-subscriptions \
  --header 'x-api-key: <api-key>'

const options = {method: 'POST', headers: {'x-api-key': '<api-key>'}};

fetch('https://api.glider.fi/v1/admin/control-plane/matcher-subscriptions', options)
  .then(res => res.json())
  .then(res => console.log(res))
  .catch(err => console.error(err));

<?php

$curl = curl_init();

curl_setopt_array($curl, [
  CURLOPT_URL => "https://api.glider.fi/v1/admin/control-plane/matcher-subscriptions",
  CURLOPT_RETURNTRANSFER => true,
  CURLOPT_ENCODING => "",
  CURLOPT_MAXREDIRS => 10,
  CURLOPT_TIMEOUT => 30,
  CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
  CURLOPT_CUSTOMREQUEST => "POST",
  CURLOPT_HTTPHEADER => [
    "x-api-key: <api-key>"
  ],
]);

$response = curl_exec($curl);
$err = curl_error($curl);

curl_close($curl);

if ($err) {
  echo "cURL Error #:" . $err;
} else {
  echo $response;
}

package main

import (
	"fmt"
	"net/http"
	"io"
)

func main() {

	url := "https://api.glider.fi/v1/admin/control-plane/matcher-subscriptions"

	req, _ := http.NewRequest("POST", url, nil)

	req.Header.Add("x-api-key", "<api-key>")

	res, _ := http.DefaultClient.Do(req)

	defer res.Body.Close()
	body, _ := io.ReadAll(res.Body)

	fmt.Println(string(body))

}

require 'uri'
require 'net/http'

url = URI("https://api.glider.fi/v1/admin/control-plane/matcher-subscriptions")

http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true

request = Net::HTTP::Post.new(url)
request["x-api-key"] = '<api-key>'

response = http.request(request)
puts response.read_body

POST

admin

control-plane

matcher-subscriptions

Admin Control Plane Matcher Subscriptions

curl --request POST \
  --url https://api.glider.fi/v1/admin/control-plane/matcher-subscriptions \
  --header 'x-api-key: <api-key>'

const options = {method: 'POST', headers: {'x-api-key': '<api-key>'}};

fetch('https://api.glider.fi/v1/admin/control-plane/matcher-subscriptions', options)
  .then(res => res.json())
  .then(res => console.log(res))
  .catch(err => console.error(err));

<?php

$curl = curl_init();

curl_setopt_array($curl, [
  CURLOPT_URL => "https://api.glider.fi/v1/admin/control-plane/matcher-subscriptions",
  CURLOPT_RETURNTRANSFER => true,
  CURLOPT_ENCODING => "",
  CURLOPT_MAXREDIRS => 10,
  CURLOPT_TIMEOUT => 30,
  CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
  CURLOPT_CUSTOMREQUEST => "POST",
  CURLOPT_HTTPHEADER => [
    "x-api-key: <api-key>"
  ],
]);

$response = curl_exec($curl);
$err = curl_error($curl);

curl_close($curl);

if ($err) {
  echo "cURL Error #:" . $err;
} else {
  echo $response;
}

package main

import (
	"fmt"
	"net/http"
	"io"
)

func main() {

	url := "https://api.glider.fi/v1/admin/control-plane/matcher-subscriptions"

	req, _ := http.NewRequest("POST", url, nil)

	req.Header.Add("x-api-key", "<api-key>")

	res, _ := http.DefaultClient.Do(req)

	defer res.Body.Close()
	body, _ := io.ReadAll(res.Body)

	fmt.Println(string(body))

}

require 'uri'
require 'net/http'

url = URI("https://api.glider.fi/v1/admin/control-plane/matcher-subscriptions")

http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true

request = Net::HTTP::Post.new(url)
request["x-api-key"] = '<api-key>'

response = http.request(request)
puts response.read_body

This route gives a centralized matcher service a stable, typed feed of active authored workflow subscriptions without coupling that matcher to raw workflow rows or Cloudflare dynamic worker internals.

Scope

Internal-only
Protected by ADMIN_AUTH_SECRET_TOKEN
Intended for matcher/control-plane infrastructure, not browser traffic

Request

{
  "limit": 200,
  "ownerAddress": "0x1111111111111111111111111111111111111111",
  "portfolioId": "pf_123"
}

Optional fields:

limit
ownerAddress
portfolioId
workflowIds

Response

{
  "asOfIso": "2026-04-14T20:15:00.000Z",
  "subscriptions": [
    {
      "subscriptionId": "wf_123",
      "workflowId": "wf_123",
      "workflowKind": "monitor_then_action",
      "ownerAddress": "0x1111111111111111111111111111111111111111",
      "portfolioId": "pf_123",
      "linkedPortfolioIds": ["pf_123"],
      "status": "active",
      "title": "Buy ETH on threshold",
      "trigger": {
        "dependencies": [
          {
            "kind": "market.price",
            "assetId": "eth:8453",
            "venue": "coinbase"
          },
          {
            "kind": "account.cash_usd",
            "ref": "source"
          },
          {
            "kind": "portfolio.held_asset_metrics",
            "ref": "target",
            "lookbackWindow": "24h"
          },
          {
            "kind": "portfolio.held_asset_accounting_metrics",
            "ref": "target"
          }
        ],
        "watchKeys": [
          "market.price:eth:8453:coinbase",
          "account.cash_usd:source",
          "portfolio.held_asset_metrics:target:24h",
          "portfolio.held_asset_accounting_metrics:target"
        ],
        "cadence": {
          "mode": "event",
          "minIntervalSeconds": 60
        },
        "semantics": {
          "matchMode": "edge",
          "rearm": "cooldown",
          "cooldownSeconds": 3600
        },
        "runtime": {
          "singleton": {
            "kind": "portfolio",
            "ref": "target"
          }
        },
        "summary": "Monitor ETH and portfolio metrics for a buy opportunity."
      },
      "monitor": {
        "status": "waiting",
        "lastEvaluatedAt": "2026-04-14T10:00:00.000Z",
        "nextWakeAt": "2026-04-14T11:00:00.000Z",
        "waitingUntil": "2026-04-14T11:00:00.000Z",
        "retryAfter": null,
        "retryCount": 0,
        "triggerSummary": null
      },
      "evaluationTarget": {
        "provider": "cloudflare_strategy_facet",
        "portfolioId": "pf_123",
        "strategyId": "wf_123",
        "workflowId": "wf_123"
      },
      "route": {
        "notifyPath": "/v1/admin/control-plane/workflow-monitors/notify-trigger-match",
        "ownerAddress": "0x1111111111111111111111111111111111111111",
        "portfolioId": "pf_123",
        "workflowId": "wf_123"
      }
    }
  ]
}

Notes

The first cut intentionally includes only authored_sdk workflows.
watchKeys are matcher indexing helpers, not replacements for canonical dependency descriptors.
Supported shared-fact families now include market, account, approval, and portfolio-relative lanes such as approval.pending_count, account.buying_power_usd, portfolio.cash_pct, portfolio.drift_from_target, and portfolio.concentration.
evaluationTarget.provider tells downstream infrastructure whether the authored evaluation path currently resolves to Cloudflare StrategyFacet runtime or a temporary shared-service fallback.
Trigger delivery still flows through POST /v1/admin/control-plane/workflow-monitors/notify-trigger-match.
ownerAddress is useful for tenant-scoped matcher workers that only want subscriptions for one authenticated owner lane at a time.

Runtime behavior

The intended centralized matcher loop is:

load matcher subscriptions
compile shared dependency watches from trigger.dependencies and watchKeys
maintain cooldown/rearm state outside per-portfolio actors
on match, call notify-trigger-match
let Cloudflare resume or start the correct durable monitor workflow

Admin Control Plane Snapshot Admin Control Plane Workflow Monitors

B2B API Reference

tRPC Endpoints

Internal Admin Endpoints

Admin Control Plane Matcher Subscriptions

Scope

Request

Response

Notes

Runtime behavior

​Scope

​Request

​Response

​Notes

​Runtime behavior

Scope

Request

Response

Notes

Runtime behavior