package main
import (
"context"
"crypto/tls"
"log"
pb "solstream/proto/solstream"
"google.golang.org/grpc"
"google.golang.org/grpc/credentials"
)
func main() {
for {
conn, err := grpc.Dial("solana.sandwich-detector.blockrazor.xyz:443", grpc.WithTransportCredentials(credentials.NewTLS(&tls.Config{})))
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
Signer: "",
RelevantProgramId: "",
})
if err != nil {
log.Printf("Error subscribing to stream: %v.\n", err)
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.Println(resp)
}
}
}
