Add swap_executor type and improve executor handling

- Add swap_executor to EXECUTOR_TYPES for single swaps via Gateway
- Add swap_executor example in CreateExecutorRequest
- Handle swap_executor using network instead of connector_name
- Make trading_pair optional for lp_executor (resolved from pool_address)
- Update lp_executor example with simplified config

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>

Author: fengtality

models/executors.py

@@ -211,7 +211,8 @@ class PositionsSummaryResponse(BaseModel):
     "twap_executor",
     "xemm_executor",
     "order_executor",
-    "lp_executor"
+    "lp_executor",
+    "swap_executor"
 ]
 
 
@@ -246,14 +247,14 @@ class CreateExecutorRequest(BaseModel):
                 },
                 {
                     "summary": "LP Executor",
-                    "description": "Create an LP position on a CLMM DEX (Meteora, Raydium)",
+                    "description": "Create an LP position on a CLMM DEX",
                     "value": {
                         "account_name": "master_account",
                         "executor_config": {
                             "type": "lp_executor",
-                            "connector_name": "meteora/clmm",
-                            "trading_pair": "SOL-USDC",
+                            "connector_name": "meteora",
                             "pool_address": "HTvjzsfX3yU6BUodCjZ5vZkUrAxMDTrBs3CJaq43ashR",
+                            "network": "solana-mainnet-beta",
                             "lower_price": "80",
                             "upper_price": "100",
                             "base_amount": "0",
@@ -265,6 +266,22 @@ class CreateExecutorRequest(BaseModel):
                             "keep_position": False
                         }
                     }
+                },
+                {
+                    "summary": "Swap Executor",
+                    "description": "Execute a single swap on Gateway AMM connectors (Jupiter, Raydium, etc.)",
+                    "value": {
+                        "account_name": "master_account",
+                        "executor_config": {
+                            "type": "swap_executor",
+                            "network": "solana-mainnet-beta",
+                            "trading_pair": "SOL-USDC",
+                            "side": 2,
+                            "amount": "0.1",
+                            "slippage_pct": "0.5",
+                            "swap_providers": ["jupiter/router", "meteora/clmm", "orca/clmm"]
+                        }
+                    }
                 }
             ]
         }

services/executor_service.py

@@ -349,15 +349,38 @@ async def create_executor(
         trading_interface = self._get_trading_interface(account)
 
         # Extract connector and trading pair from config
+        # Note: swap_executor uses 'network' instead of 'connector_name' since it calls Gateway directly
         connector_name = executor_config.get("connector_name")
         trading_pair = executor_config.get("trading_pair")
-        if not connector_name:
-            raise HTTPException(status_code=400, detail="connector_name is required in executor_config")
-        if not trading_pair:
-            raise HTTPException(status_code=400, detail="trading_pair is required in executor_config")
 
-        # Ensure connector and market are ready
-        await trading_interface.add_market(connector_name, trading_pair)
+        if executor_type == "swap_executor":
+            # SwapExecutor uses network, not connector_name
+            network = executor_config.get("network")
+            if not network:
+                raise HTTPException(status_code=400, detail="network is required for swap_executor")
+            if not trading_pair:
+                raise HTTPException(status_code=400, detail="trading_pair is required in executor_config")
+            # Use network as connector_name for metadata tracking
+            connector_name = network
+        elif executor_type == "lp_executor":
+            # LPExecutor: trading_pair is optional (resolved from pool_address)
+            if not connector_name:
+                raise HTTPException(status_code=400, detail="connector_name is required for lp_executor")
+            pool_address = executor_config.get("pool_address")
+            if not pool_address:
+                raise HTTPException(status_code=400, detail="pool_address is required for lp_executor")
+            # Ensure connector is ready (trading_pair resolved in executor on_start)
+            await trading_interface.ensure_connector(connector_name)
+            # Use pool_address as trading_pair placeholder for metadata if not provided
+            if not trading_pair:
+                trading_pair = pool_address
+        else:
+            if not connector_name:
+                raise HTTPException(status_code=400, detail="connector_name is required in executor_config")
+            if not trading_pair:
+                raise HTTPException(status_code=400, detail="trading_pair is required in executor_config")
+            # Ensure connector and market are ready
+            await trading_interface.add_market(connector_name, trading_pair)
 
         # Set timestamp if not provided (required for time-based features like time_limit)
         if "timestamp" not in executor_config or executor_config["timestamp"] is None: