Documentation Index
Fetch the complete documentation index at: /llms.txt
Use this file to discover all available pages before exploring further.
curl --request POST \
--url http://localhost:3000/v2/admin/replay-mapper \
--header 'Authorization: Bearer <token>' \
--header 'Content-Type: application/json' \
--data '
{
"org_slug": "<string>",
"dataset_query_id": [
"<string>"
],
"domains": [],
"on_finish": [
{
"type": "trigger.dev",
"token_id": "<string>"
}
]
}
'import requests
url = "http://localhost:3000/v2/admin/replay-mapper"
payload = {
"org_slug": "<string>",
"dataset_query_id": ["<string>"],
"domains": [],
"on_finish": [
{
"type": "trigger.dev",
"token_id": "<string>"
}
]
}
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({
org_slug: '<string>',
dataset_query_id: ['<string>'],
domains: [],
on_finish: [{type: 'trigger.dev', token_id: '<string>'}]
})
};
fetch('http://localhost:3000/v2/admin/replay-mapper', options)
.then(res => res.json())
.then(res => console.log(res))
.catch(err => console.error(err));<?php
$curl = curl_init();
curl_setopt_array($curl, [
CURLOPT_PORT => "3000",
CURLOPT_URL => "http://localhost:3000/v2/admin/replay-mapper",
CURLOPT_RETURNTRANSFER => true,
CURLOPT_ENCODING => "",
CURLOPT_MAXREDIRS => 10,
CURLOPT_TIMEOUT => 30,
CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
CURLOPT_CUSTOMREQUEST => "POST",
CURLOPT_POSTFIELDS => json_encode([
'org_slug' => '<string>',
'dataset_query_id' => [
'<string>'
],
'domains' => [
],
'on_finish' => [
[
'type' => 'trigger.dev',
'token_id' => '<string>'
]
]
]),
CURLOPT_HTTPHEADER => [
"Authorization: Bearer <token>",
"Content-Type: application/json"
],
]);
$response = curl_exec($curl);
$err = curl_error($curl);
curl_close($curl);
if ($err) {
echo "cURL Error #:" . $err;
} else {
echo $response;
}package main
import (
"fmt"
"strings"
"net/http"
"io"
)
func main() {
url := "http://localhost:3000/v2/admin/replay-mapper"
payload := strings.NewReader("{\n \"org_slug\": \"<string>\",\n \"dataset_query_id\": [\n \"<string>\"\n ],\n \"domains\": [],\n \"on_finish\": [\n {\n \"type\": \"trigger.dev\",\n \"token_id\": \"<string>\"\n }\n ]\n}")
req, _ := http.NewRequest("POST", url, payload)
req.Header.Add("Authorization", "Bearer <token>")
req.Header.Add("Content-Type", "application/json")
res, _ := http.DefaultClient.Do(req)
defer res.Body.Close()
body, _ := io.ReadAll(res.Body)
fmt.Println(string(body))
}HttpResponse<String> response = Unirest.post("http://localhost:3000/v2/admin/replay-mapper")
.header("Authorization", "Bearer <token>")
.header("Content-Type", "application/json")
.body("{\n \"org_slug\": \"<string>\",\n \"dataset_query_id\": [\n \"<string>\"\n ],\n \"domains\": [],\n \"on_finish\": [\n {\n \"type\": \"trigger.dev\",\n \"token_id\": \"<string>\"\n }\n ]\n}")
.asString();require 'uri'
require 'net/http'
url = URI("http://localhost:3000/v2/admin/replay-mapper")
http = Net::HTTP.new(url.host, url.port)
request = Net::HTTP::Post.new(url)
request["Authorization"] = 'Bearer <token>'
request["Content-Type"] = 'application/json'
request.body = "{\n \"org_slug\": \"<string>\",\n \"dataset_query_id\": [\n \"<string>\"\n ],\n \"domains\": [],\n \"on_finish\": [\n {\n \"type\": \"trigger.dev\",\n \"token_id\": \"<string>\"\n }\n ]\n}"
response = http.request(request)
puts response.read_body{
"results": [
{
"queryId": "<string>",
"datasetSlug": "<string>",
"domainsExecuted": [
"<string>"
],
"success": true
}
]
}Loads successful dataset_queries and enqueues the existing BullMQ dataset-query-observation Flow. The mapper worker remains the only executor of domain writes.
curl --request POST \
--url http://localhost:3000/v2/admin/replay-mapper \
--header 'Authorization: Bearer <token>' \
--header 'Content-Type: application/json' \
--data '
{
"org_slug": "<string>",
"dataset_query_id": [
"<string>"
],
"domains": [],
"on_finish": [
{
"type": "trigger.dev",
"token_id": "<string>"
}
]
}
'import requests
url = "http://localhost:3000/v2/admin/replay-mapper"
payload = {
"org_slug": "<string>",
"dataset_query_id": ["<string>"],
"domains": [],
"on_finish": [
{
"type": "trigger.dev",
"token_id": "<string>"
}
]
}
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({
org_slug: '<string>',
dataset_query_id: ['<string>'],
domains: [],
on_finish: [{type: 'trigger.dev', token_id: '<string>'}]
})
};
fetch('http://localhost:3000/v2/admin/replay-mapper', options)
.then(res => res.json())
.then(res => console.log(res))
.catch(err => console.error(err));<?php
$curl = curl_init();
curl_setopt_array($curl, [
CURLOPT_PORT => "3000",
CURLOPT_URL => "http://localhost:3000/v2/admin/replay-mapper",
CURLOPT_RETURNTRANSFER => true,
CURLOPT_ENCODING => "",
CURLOPT_MAXREDIRS => 10,
CURLOPT_TIMEOUT => 30,
CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
CURLOPT_CUSTOMREQUEST => "POST",
CURLOPT_POSTFIELDS => json_encode([
'org_slug' => '<string>',
'dataset_query_id' => [
'<string>'
],
'domains' => [
],
'on_finish' => [
[
'type' => 'trigger.dev',
'token_id' => '<string>'
]
]
]),
CURLOPT_HTTPHEADER => [
"Authorization: Bearer <token>",
"Content-Type: application/json"
],
]);
$response = curl_exec($curl);
$err = curl_error($curl);
curl_close($curl);
if ($err) {
echo "cURL Error #:" . $err;
} else {
echo $response;
}package main
import (
"fmt"
"strings"
"net/http"
"io"
)
func main() {
url := "http://localhost:3000/v2/admin/replay-mapper"
payload := strings.NewReader("{\n \"org_slug\": \"<string>\",\n \"dataset_query_id\": [\n \"<string>\"\n ],\n \"domains\": [],\n \"on_finish\": [\n {\n \"type\": \"trigger.dev\",\n \"token_id\": \"<string>\"\n }\n ]\n}")
req, _ := http.NewRequest("POST", url, payload)
req.Header.Add("Authorization", "Bearer <token>")
req.Header.Add("Content-Type", "application/json")
res, _ := http.DefaultClient.Do(req)
defer res.Body.Close()
body, _ := io.ReadAll(res.Body)
fmt.Println(string(body))
}HttpResponse<String> response = Unirest.post("http://localhost:3000/v2/admin/replay-mapper")
.header("Authorization", "Bearer <token>")
.header("Content-Type", "application/json")
.body("{\n \"org_slug\": \"<string>\",\n \"dataset_query_id\": [\n \"<string>\"\n ],\n \"domains\": [],\n \"on_finish\": [\n {\n \"type\": \"trigger.dev\",\n \"token_id\": \"<string>\"\n }\n ]\n}")
.asString();require 'uri'
require 'net/http'
url = URI("http://localhost:3000/v2/admin/replay-mapper")
http = Net::HTTP.new(url.host, url.port)
request = Net::HTTP::Post.new(url)
request["Authorization"] = 'Bearer <token>'
request["Content-Type"] = 'application/json'
request.body = "{\n \"org_slug\": \"<string>\",\n \"dataset_query_id\": [\n \"<string>\"\n ],\n \"domains\": [],\n \"on_finish\": [\n {\n \"type\": \"trigger.dev\",\n \"token_id\": \"<string>\"\n }\n ]\n}"
response = http.request(request)
puts response.read_body{
"results": [
{
"queryId": "<string>",
"datasetSlug": "<string>",
"domainsExecuted": [
"<string>"
],
"success": true
}
]
}OAuth2 Authorization Code flow
Organization slug that owns the dataset_queries
Persisted dataset_query ids to replay
Domains to enqueue. When omitted, the mapper resolves enabled domains from dataset rules.
graph, lawsuits, people, shareholders Completion directives signalled when the enqueued Flow settles (all domain mappers done). Used to release a trigger.dev waitpoint token. Requires exactly one dataset_query_id.
Show child attributes
Show child attributes