openpondai/agents/polymarket-market-watcher
OpenTool app
1Branch0Tags
OP
OpenPond Syncsync: merge local template master into production
typescript
import { store } from "opentool/store";
import type { ToolProfile } from "opentool";
import {
backtestDecisionRequestSchema,
buildBacktestDecisionSeriesInput,
resolveBacktestMode,
} from "opentool/backtest";
import {
POLYMARKET_MARKET_WATCHER_TEMPLATE_CONFIG,
requestOverrideSchema,
resolveProfileAssets,
resolveRuntimeConfig,
resolveScheduleConfig,
} from "../src/config";
import { buildBacktestDecisionSeries, runSignalBot } from "../src/signal-bot";
const config = resolveRuntimeConfig();
export const schema = requestOverrideSchema.or(backtestDecisionRequestSchema.partial());
type BacktestAwareToolProfile = ToolProfile & {
backtest?: {
mode: "decisions";
};
};
export const profile: BacktestAwareToolProfile = {
description: "Watch one exact Polymarket market outcome and map its threshold to a Hyperliquid trade signal.",
category: "strategy",
backtest: {
mode: "decisions",
},
schedule: resolveScheduleConfig(config),
assets: resolveProfileAssets(config),
templatePreview: {
subtitle: "Exact Polymarket outcome watcher with Hyperliquid execution.",
description: `Resolves one exact Polymarket market by slug, id, or condition id.
Watches a configured Yes or No probability threshold.
Maps that signal into a standardized Hyperliquid trade decision.
Supports decision-series backtests using Polymarket price history and Hyperliquid bars.`,
},
templateConfig: POLYMARKET_MARKET_WATCHER_TEMPLATE_CONFIG,
};
export async function POST(req: Request) {
const payload = await req.json().catch(() => null);
const mode =
payload && typeof payload === "object" && !Array.isArray(payload)
? (payload as { mode?: unknown }).mode
: null;
const normalizedMode = resolveBacktestMode(mode);
if (normalizedMode === "backtest_decisions") {
try {
const parsed = backtestDecisionRequestSchema.safeParse(payload);
if (!parsed.success) {
return new Response(
JSON.stringify({
ok: false,
error: parsed.error.issues[0]?.message ?? "invalid backtest request payload",
}),
{
status: 400,
headers: { "content-type": "application/json" },
},
);
}
const runtimeConfig = resolveRuntimeConfig();
const backtest = await buildBacktestDecisionSeries({
config: runtimeConfig,
request: buildBacktestDecisionSeriesInput(parsed.data),
});
return Response.json({
ok: true,
mode: normalizedMode,
backtest,
});
} catch (error) {
const message = error instanceof Error ? error.message : "unknown";
return new Response(JSON.stringify({ ok: false, error: message }), {
status: 400,
headers: { "content-type": "application/json" },
});
}
}
const parsed = requestOverrideSchema.safeParse(payload ?? {});
if (!parsed.success) {
return new Response(
JSON.stringify({
ok: false,
error: parsed.error.issues[0]?.message ?? "invalid request payload",
}),
{
status: 400,
headers: { "content-type": "application/json" },
},
);
}
try {
const runtimeConfig = resolveRuntimeConfig(parsed.data);
const result = await runSignalBot(runtimeConfig);
await store({
source: "polymarket-market-watcher",
ref: `polymarket-market-watcher-${Date.now()}`,
status: "info",
action: "polymarket_market_signal",
metadata: result,
});
return Response.json(result);
} catch (error) {
const message = error instanceof Error ? error.message : "unknown";
await store({
source: "polymarket-market-watcher",
ref: `polymarket-market-watcher-${Date.now()}`,
status: "failed",
action: "polymarket_market_signal",
metadata: { ok: false, error: message },
});
return new Response(JSON.stringify({ ok: false, error: message }), {
status: 400,
headers: { "content-type": "application/json" },
});
}
}