Every swap, as a typed message.

syntax = "proto3";
package dexploit.v1;
 
service SwapStream {
  // Live tail. Streams every new swap matching the filter.
  rpc StreamLive(StreamLiveRequest) returns (stream UnifiedSwap);
 
  // Reserved for v1.1: the handler returns UNIMPLEMENTED today.
  rpc StreamFromCursor(StreamFromCursorRequest) returns (stream UnifiedSwap);
}
 
message StreamLiveRequest {
  SwapFilter filter = 1;
}
 
message SwapFilter {
  repeated string tokens           = 1;   // mints, base58; empty = all
  repeated string traders          = 2;
  repeated string pools            = 3;
  repeated string dexes            = 4;   // "pumpfun", "raydium_clmm", ...
  optional uint64 min_sol          = 5;   // lamports
  optional uint64 max_sol          = 6;
  optional uint64 min_token_amount = 7;
  optional uint64 max_token_amount = 8;
  optional bool   is_buy           = 9;
  optional string signature        = 10;
  repeated string wallet_tags      = 11;  // Pro tier
}
 
message UnifiedSwap {
  string signature                = 1;
  uint64 slot                     = 2;
  int64  timestamp                = 3;    // unix epoch seconds
  string dex                      = 4;
  string trader                   = 5;
  string token_mint               = 6;
  string pool_address             = 7;
  bool   is_buy                   = 8;
  uint64 amount_in                = 9;
  uint64 amount_out               = 10;
  uint64 sol_amount               = 11;   // lamports
  uint64 token_amount             = 12;   // raw token units
  optional double price_per_token = 13;   // SOL per token
  repeated string trader_tags     = 14;
  uint32 ix_index                 = 15;   // per-leg ordinal
}