> For the complete documentation index, see [llms.txt](https://docs.blockrazor.io/llms.txt). Markdown versions of documentation pages are available by appending `.md` to page URLs; this page is available as [Markdown](https://docs.blockrazor.io/streams/network-fee-stream/bsc/sandwich-detector.md). # Sandwich Detector ## Introduction Sandwich Detector provides projects(e.g. wallet, DEX, and trading bot) with a sandwich attack monitoring service for BSC transactions. Projects can subscribe to the sandwich attack transaction information on BSC in real time based on gRPC. The subscription endpoint is: bsc.sandwich-detector.blockrazor.me:443 ## Plan | | Tier 4 | Tier 3 | Tier 2 | Tier 1 | Tier 0 | | ----------------- | ------ | ------ | ------ | ------ | ------ | | Sandwich Detector | - | - | - | - | ✅ | The Sandwich Detector service will open a whitelist to projects(e.g. wallet, DEX, and trading bot) subscribing to Tier 0 plan, who can monitor the sandwich attack information on BSC in real time. Please contact us after subscribing to the Tier 0 plan. ## Request Parameter
ParametersMandatoryFormatExampleRemarks
fromoptionalString""0x3879……42d82a"Filtering sandwich transactions by the "from" of the attacked transaction
tooptionalString"0xda77……7098a2"Filter sandwich transactions by the contract address that the attacked transaction has interacted with
methodoptionalString"0xac9650d8"Filter sandwich transaction by the method called by the attacked transaction
## Request Example {% tabs %} {% tab title="grpcurl" %} ```go # without filter grpcurl -plaintext=false -import-path /path/to/proto -proto bscstream.proto -d '' bsc.sandwich-detector.blockrazor.me:443 bscstream.TxStreamService/SubscribeTxStream # with filter grpcurl -plaintext=false -import-path /path/to/proto -proto bscstream.proto -d '{"to":"0xaa..bb"}' bsc.sandwich-detector.blockrazor.me:443 bscstream.TxStreamService/SubscribeTxStream ``` {% endtab %} {% tab title="Go" %} ```python package main import ( "context" "crypto/tls" "log" pb "bscstream/proto/bscstream" "google.golang.org/grpc" "google.golang.org/grpc/credentials" ) func main() { for { conn, err := grpc.Dial( "bsc.sandwich-detector.blockrazor.me:443", grpc.WithTransportCredentials(credentials.NewTLS(&tls.Config{})), grpc.WithContextDialer(func(ctx context.Context, addr string) (net.Conn, error) { d := net.Dialer{DualStack: false} return d.DialContext(ctx, "tcp4", addr) }), ) if err != nil { log.Printf("Failed to connect: %v.\n", err) continue } client := pb.NewTxStreamServiceClient(conn) stream, err := client.SubscribeTxStream(context.Background(), &pb.TxFilter{ // Empty for no filter From: "", To: "", Method: "", }) if err != nil { conn.Close() continue } log.Println("Successfully subscribed to the stream.") for { resp, err := stream.Recv() if err != nil { log.Printf("Error receiving stream data: %v. Reconnecting...\n", err) conn.Close() break } log.Printf("+%v\n", resp) } } } ``` {% endtab %} {% endtabs %} ### **Proto** ```go // bscstream.proto syntax = "proto3"; package bscstream; option go_package = "proto/bscstream"; service TxStreamService { rpc SubscribeTxStream(TxFilter) returns (stream TxStreamResponse); } message TxFilter { string from = 1; // (optional) from of victim tx to filter string to = 2; // (optional) to of victim tx to filter string method = 3; // (optional) method of victim tx fo filter } message TxStreamResponse { repeated string txs = 1; // all sandwich tx hash string victimtx = 2; // victim tx hash repeated string attackertxs = 3; // frontrun and backrun tx hash string from = 4; // from of victim hash string to = 5; // to of victim hash string method = 6; // method of victim hash repeated string tokens = 7; // sandwiched token uint64 block = 8; // block number of txs bool heartbeat = 9; // if this resp is heartbeat, to keep stream alive if no sandwich data available } ``` ## Response Example ```json { "txs": [ "0xee5b2cfb7a5120206450b7edf2ac824ea810442d982b71923240115ef906acfa", "0xb2c9048de1af5be6733b3ed3d1ea4ac74c3d7a9e6c58a9e07ebdac7b8708399b", "0x046455f9207b5209489cfada58bfe593acdca58d4a730210e552e56199bfcfe8" ], "victimtx": "0xb2c9048de1af5be6733b3ed3d1ea4ac74c3d7a9e6c58a9e07ebdac7b8708399b", "attackertxs": [ "0xee5b2cfb7a5120206450b7edf2ac824ea810442d982b71923240115ef906acfa", "0x046455f9207b5209489cfada58bfe593acdca58d4a730210e552e56199bfcfe8" ], "from": "0x387965d0b2dfbebb24aa02e0a068d79a0b42d82a", "to": "0xda77c035e4d5a748b4ab6674327fa446f17098a2", "method": "0xac9650d8", "tokens": [ "0xdd1b2aaf66a030315a821e7588cf691d73b64444", "0xbb4cdb9cbd36b01bd1cbaebf2de08d9173bc095c" ], "block": "47993864" } ``` --- # Agent Instructions This documentation is published with GitBook. GitBook is the documentation platform designed so that both humans and AI agents can read, navigate, and reason over technical content effectively. Learn more at gitbook.com. ## Querying This Documentation If you need additional information that is not directly available in this page, you can query the documentation dynamically by asking a question. Perform an HTTP GET request on the current page URL with the `ask` query parameter, and the optional `goal` query parameter: ``` GET https://docs.blockrazor.io/streams/network-fee-stream/bsc/sandwich-detector.md?ask=&goal= ``` `ask` is the immediate question: it should be specific, self-contained, and written in natural language. `goal` is optional and describes the broader end goal you are ultimately trying to accomplish on behalf of the user. GitBook uses it to tailor the answer towards what is most useful for that goal. The response will contain a direct answer to the question and relevant excerpts and sources from the documentation. Use this mechanism when the answer is not explicitly present in the current page, you need clarification or additional context, or you want to retrieve related documentation sections.