feat: expose live commands to MCP

Author: mrmx

CHANGELOG.md

@@ -6,6 +6,17 @@ The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.1.0/),
 
 ## [Unreleased]
 
+## [0.16.0] — 2026-09-30
+
+### Added ✨
+
+- `send_live_command` delivers a transient command to an owned live run without restarting it. It explains handler requirements, non-persistence, accepted-versus-completed semantics, and safe retry limits.
+- `list_strategies` and `list_datasets` can include deleted entries for catalogue reconciliation; `get_account` reports the Cartesian sweep limit.
+
+### Changed 🔄
+
+- Build against `com.github.QTSurfer:sdk-java` `0.27.0`, which supplies the refreshed API client and live-command helper.
+
 ## [0.15.0] — 2026-09-23
 
 ### Added ✨

README.md

@@ -163,7 +163,7 @@ MCP transport: stdio (stdin/stdout JSON-RPC 2.0)
 |------|-------------|
 | `upload_dataset` | Atomically create or version a dataset, stream a guarded local CSV or Parquet file and start ingest; never exposes a presigned URL |
 | `import_dataset` / `get_dataset_import` | Fetch DEX history into a dataset and poll its asynchronous fetch and ingest state |
-| `list_datasets` / `get_dataset` | List datasets or read one dataset's metadata and current version |
+| `list_datasets` / `get_dataset` | List datasets (optionally including deleted entries) or read one dataset's metadata and current version |
 | `get_dataset_upload` | Poll the asynchronous ingest after an upload |
 | `finalize_dataset_upload` | Retry finalization after a successful PUT whose original MCP response was lost |
 | `delete_dataset` | Delete a caller-owned dataset and its versions |
@@ -180,13 +180,14 @@ MCP transport: stdio (stdin/stdout JSON-RPC 2.0)
 | `get_sweep_run_equity_curve` | Bounded normalized equity curve for one retained sweep trial |
 | `cancel_sweep` | Stop a running sweep between parameter vectors, keeping the rows already scored |
 | `get_sweep_sensitivity` | Which parameter mattered: marginals per axis, or one named interaction surface |
-| `list_strategies` | List every strategy registered under this account, most recently compiled first |
+| `list_strategies` | List every strategy registered under this account; optionally include deleted entries |
 | `delete_strategy` | Release a registered strategy |
 | `get_strategy_code` | Fetch the exact source last registered for a strategy id |
-| `get_account` / `get_account_usage` | Read account tier limits and current dataset, strategy, signal and shared-storage usage |
+| `get_account` / `get_account_usage` | Read account tier limits (including the Cartesian sweep cap) and current dataset, strategy, signal and shared-storage usage |
 | `start_live` / `get_live` / `stop_live` | Start a strategy's live run, inspect sandbox/live state, and request it to stop |
 | `list_live` / `list_public_live` | Page through all your own runs or browse currently-running public runs separately |
 | `update_live` / `update_live_params` | Change run visibility/metadata or queue updates to declared strategy parameters |
+| `send_live_command` | Send a transient event to a running strategy without restarting it |
 | `get_live_signals` | Read retained signals oldest-first with optional time/instrument filters and cursor pagination |
 
 ### Account and storage
@@ -217,13 +218,23 @@ catalog containing only public runs currently running and never exposes their ow
 Both accept optional `cursor` and `limit` (default 20, API maximum 100); pass `nextCursor` back
 unchanged to fetch the next page.
 
+`list_datasets` and `list_strategies` default to active entries; set `includeDeleted=true` to include
+soft-deleted entries marked with `deletedAt`. `get_account` reports `maxSweepCartesian`, the
+maximum allowed Cartesian combination count for a sweep.
+
 `update_live` takes `runId` plus at least one of `visibility`, `name`, or `description`.
 `update_live_params` takes `runId` and a non-empty `params` object containing only declared strategy
 properties; changes take effect at an event boundary. `get_live_signals` accepts `runId`, optional
 `sinceMs`, `instrument`, opaque `cursor`, and `limit`; cursor takes precedence over `sinceMs`. Read
 oldest-first, pass returned `nextCursor` unchanged, and if retention expires a cursor, restart from
 the reported `availableSinceMs` (deduplicate `signalId` if combining with another signal feed).
 
+`send_live_command` takes an owned `runId`, non-blank `command`, and optional arbitrary JSON
+`properties` object. The strategy must implement `CommandRequestHandler`. Commands are transient,
+not stored or replayed to later replicas; use `update_live_params` for persistent state. A `503`
+means the command was not sent; ambiguous network failures have no idempotency key, so avoid blind
+retries. A successful acceptance is not confirmation that the strategy finished processing it.
+
 Example tool arguments:
 
 ```json

pom.xml

@@ -5,7 +5,7 @@
 
     <groupId>com.qtsurfer</groupId>
     <artifactId>mcp-java</artifactId>
-    <version>0.15.0</version>
+    <version>0.16.0</version>
     <packaging>jar</packaging>
     <name>qtsurfer-mcp-java</name>
 
@@ -34,7 +34,7 @@
         <maven.compiler.release>${java.version}</maven.compiler.release>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
         <mcp.version>1.1.2</mcp.version>
-        <sdk.version>0.25.1</sdk.version>
+        <sdk.version>0.27.0</sdk.version>
         <slf4j.version>2.0.16</slf4j.version>
         <logback.version>1.5.11</logback.version>
         <junit.version>5.11.4</junit.version>

src/main/java/com/qtsurfer/mcp/model/DatasetSummary.java

@@ -9,4 +9,5 @@ public record DatasetSummary(
     String from,
     String to,
     String cadence,
-    String dataFormat) {}
+    String dataFormat,
+    String deletedAt) {}

src/main/java/com/qtsurfer/mcp/service/BacktestingService.java

@@ -10,12 +10,14 @@
 import com.qtsurfer.api.client.model.AccountUsage;
 import com.qtsurfer.api.client.model.LiveListResponse;
 import com.qtsurfer.api.client.model.LiveParamsUpdateResult;
+import com.qtsurfer.api.client.model.LiveCommandResult;
 import com.qtsurfer.api.client.model.LiveRun;
 import com.qtsurfer.api.client.model.LiveRunCompact;
 import com.qtsurfer.api.client.model.LiveSignalPage;
 import com.qtsurfer.api.client.model.PublicLiveListResponse;
 import com.qtsurfer.api.client.model.StartLiveRequest;
 import com.qtsurfer.api.client.model.UpdateLiveRequest;
+import com.qtsurfer.api.client.model.SendLiveCommandRequest;
 import com.qtsurfer.api.client.model.SweepSensitivity;
 import com.qtsurfer.api.sdk.SweepObjective;
 import com.qtsurfer.api.sdk.ValidationOutcome;
@@ -57,7 +59,9 @@ public interface BacktestingService {
   StrategyCompilation compileStrategy(String strategyCode);
 
   /** List datasets owned by the authenticated caller. */
-  List<DatasetSummary> listDatasets();
+  List<DatasetSummary> listDatasets(boolean includeDeleted);
+
+  default List<DatasetSummary> listDatasets() { return listDatasets(false); }
 
   /** Read one dataset owned by the authenticated caller. */
   Optional<DatasetSummary> getDataset(String datasetId);
@@ -235,7 +239,9 @@ Optional<BoundedEquityCurve> getSweepRunEquityCurve(
    *
    * @return the caller's registered strategies; empty when the account has none, never an error
    */
-  List<StrategySummary> listStrategies();
+  List<StrategySummary> listStrategies(boolean includeDeleted);
+
+  default List<StrategySummary> listStrategies() { return listStrategies(false); }
 
   /**
    * Release a registered strategy. Not undone by recompiling the same source afterward — that
@@ -279,6 +285,8 @@ Optional<BoundedEquityCurve> getSweepRunEquityCurve(
 
   LiveParamsUpdateResult updateLiveParams(String runId, Map<String, Object> params);
 
+  LiveCommandResult sendLiveCommand(String runId, SendLiveCommandRequest request);
+
   LiveSignalPage getLiveSignals(String runId, Long sinceMs, String instrument,
       String cursor, Integer limit);
 }

src/main/java/com/qtsurfer/mcp/service/BacktestingServiceStub.java

@@ -16,12 +16,14 @@
 import com.qtsurfer.api.client.model.AccountUsage;
 import com.qtsurfer.api.client.model.LiveListResponse;
 import com.qtsurfer.api.client.model.LiveParamsUpdateResult;
+import com.qtsurfer.api.client.model.LiveCommandResult;
 import com.qtsurfer.api.client.model.LiveRun;
 import com.qtsurfer.api.client.model.LiveRunCompact;
 import com.qtsurfer.api.client.model.LiveSignalPage;
 import com.qtsurfer.api.client.model.PublicLiveListResponse;
 import com.qtsurfer.api.client.model.StartLiveRequest;
 import com.qtsurfer.api.client.model.UpdateLiveRequest;
+import com.qtsurfer.api.client.model.SendLiveCommandRequest;
 import com.qtsurfer.api.client.model.SweepSensitivity;
 import com.qtsurfer.api.client.model.WalkForwardFold;
 import com.qtsurfer.api.client.model.WalkForwardResult;
@@ -83,7 +85,8 @@ public class BacktestingServiceStub implements BacktestingService {
   @Override
   public Account getAccount() {
     return new Account().userId("stub-user").tier("free")
-        .maxDatasets(10).maxDatasetBytes(1_000_000L).maxTotalStorageBytes(10_000_000L);
+        .maxDatasets(10).maxDatasetBytes(1_000_000L).maxTotalStorageBytes(10_000_000L)
+        .maxSweepCartesian(10_000);
   }
 
   @Override
@@ -150,6 +153,15 @@ public LiveParamsUpdateResult updateLiveParams(String runId, Map<String, Object>
         .effectiveAtMs(System.currentTimeMillis());
   }
 
+  @Override
+  public LiveCommandResult sendLiveCommand(String runId, SendLiveCommandRequest request) {
+    if (liveRuns.values().stream().noneMatch(candidate -> runId.equals(candidate.getRunId()))) {
+      throw new IllegalArgumentException("No live run: " + runId);
+    }
+    return new LiveCommandResult().runId(runId).commandId("cmd-stub")
+        .effectiveAtMs(System.currentTimeMillis());
+  }
+
   @Override
   public LiveSignalPage getLiveSignals(
       String runId, Long sinceMs, String instrument, String cursor, Integer limit) {
@@ -171,7 +183,7 @@ public StrategyCompilation compileStrategy(String strategyCode) {
   }
 
   @Override
-  public List<DatasetSummary> listDatasets() {
+  public List<DatasetSummary> listDatasets(boolean includeDeleted) {
     return new ArrayList<>(datasets.values());
   }
 
@@ -197,7 +209,7 @@ public DatasetUploadResult uploadDataset(
       }
       targetDatasetId = "ds-" + UUID.randomUUID().toString().substring(0, 8);
       datasets.put(targetDatasetId, new DatasetSummary(
-          targetDatasetId, name, instrument, null, null, null, null, null));
+          targetDatasetId, name, instrument, null, null, null, null, null, null));
     } else if (!datasets.containsKey(targetDatasetId)) {
       throw new IllegalArgumentException("No such dataset: " + targetDatasetId);
     }
@@ -226,7 +238,7 @@ public DatasetImportResult importDataset(String name, String instrument, String
     String datasetId = "ds-" + UUID.randomUUID().toString().substring(0, 8);
     String importId = "imp-" + UUID.randomUUID().toString().substring(0, 8);
     String jobId = "ing-" + UUID.randomUUID().toString().substring(0, 8);
-    datasets.put(datasetId, new DatasetSummary(datasetId, name, instrument, null, from, to, null, null));
+    datasets.put(datasetId, new DatasetSummary(datasetId, name, instrument, null, from, to, null, null, null));
     imports.put(uploadKey(datasetId, importId), new DatasetImportStatus(
         datasetId, importId, "FETCHING", jobId, null, null));
     return new DatasetImportResult(datasetId, importId, jobId, "FETCHING");
@@ -361,7 +373,7 @@ private StrategyState strategyState(String strategyId) {
   }
 
   @Override
-  public List<StrategySummary> listStrategies() {
+  public List<StrategySummary> listStrategies(boolean includeDeleted) {
     return new ArrayList<>(strategies.values());
   }
 

src/main/java/com/qtsurfer/mcp/service/SdkBacktestingService.java

@@ -24,12 +24,14 @@
 import com.qtsurfer.api.client.model.AccountUsage;
 import com.qtsurfer.api.client.model.LiveListResponse;
 import com.qtsurfer.api.client.model.LiveParamsUpdateResult;
+import com.qtsurfer.api.client.model.LiveCommandResult;
 import com.qtsurfer.api.client.model.LiveRun;
 import com.qtsurfer.api.client.model.LiveRunCompact;
 import com.qtsurfer.api.client.model.LiveSignalPage;
 import com.qtsurfer.api.client.model.PublicLiveListResponse;
 import com.qtsurfer.api.client.model.StartLiveRequest;
 import com.qtsurfer.api.client.model.UpdateLiveRequest;
+import com.qtsurfer.api.client.model.SendLiveCommandRequest;
 import com.qtsurfer.api.client.model.SweepSensitivity;
 import com.qtsurfer.api.sdk.Backtest;
 import com.qtsurfer.api.sdk.BacktestOptions;
@@ -154,6 +156,11 @@ public LiveParamsUpdateResult updateLiveParams(String runId, Map<String, Object>
     return qts.updateLiveParams(runId, UpdateLiveParamsRequestBuilder.builder().params(params));
   }
 
+  @Override
+  public LiveCommandResult sendLiveCommand(String runId, SendLiveCommandRequest request) {
+    return qts.sendLiveCommand(runId, request);
+  }
+
   @Override
   public LiveSignalPage getLiveSignals(
       String runId, Long sinceMs, String instrument, String cursor, Integer limit) {
@@ -221,8 +228,8 @@ public StrategyCompilation compileStrategy(String strategyCode) {
   }
 
   @Override
-  public List<DatasetSummary> listDatasets() {
-    return qts.getDatasets().stream().map(SdkBacktestingService::datasetSummary).toList();
+  public List<DatasetSummary> listDatasets(boolean includeDeleted) {
+    return qts.getDatasets(includeDeleted).stream().map(SdkBacktestingService::datasetSummary).toList();
   }
 
   @Override
@@ -322,13 +329,13 @@ private Path guardedUploadFile(String filePath) {
   private static DatasetSummary datasetSummary(Dataset dataset) {
     return new DatasetSummary(dataset.getDatasetId(), dataset.getName(), dataset.getInstrument(),
         dataset.getCurrentVersionId(), stringify(dataset.getFrom()), stringify(dataset.getTo()),
-        dataset.getCadence(), null);
+        dataset.getCadence(), null, stringify(dataset.getDeletedAt()));
   }
 
   private static DatasetSummary datasetSummary(DatasetWithLinks dataset) {
     return new DatasetSummary(dataset.getDatasetId(), dataset.getName(), dataset.getInstrument(),
         dataset.getCurrentVersionId(), stringify(dataset.getFrom()), stringify(dataset.getTo()),
-        dataset.getCadence(), stringify(dataset.getDataFormat()));
+        dataset.getCadence(), stringify(dataset.getDataFormat()), stringify(dataset.getDeletedAt()));
   }
 
   private static DatasetUploadStatus uploadStatus(String datasetId, DatasetUploadState state) {
@@ -640,8 +647,8 @@ public Optional<StrategyState> getStrategy(String strategyId) {
   }
 
   @Override
-  public List<StrategySummary> listStrategies() {
-    return qts.getStrategies();
+  public List<StrategySummary> listStrategies(boolean includeDeleted) {
+    return qts.getStrategies(includeDeleted);
   }
 
   @Override