Consuming Bids from mev-commit

import providerapiv1 "github.com/primev/mev-commit/p2p/gen/go/providerapi/v1"

conn, err = grpc.DialContext(
	context.Background(),
	"localhost:13524",
	grpc.WithBlock(),
	grpc.WithTransportCredentials(insecure.NewCredentials()),
)

if err != nil {
	// handle error
}

client := providerapiv1.NewProviderClient(conn)

bidStream, err := client.ReceiveBids(context.Background(), &providerapiv1.EmptyMessage{})
if err != nil {
	// handle error
}

bidC := make(chan *providerapiv1.Bid)
go func() {
	defer close(bidC)
	for {
		bid, err := bidStream.Recv()
		if err != nil {
			// handle error
		}
		select {
		case <-bidStream.Context().Done():
		case bidC <- bid:
		}
	}
}()

stream, err := client.SendProcessedBids(context.Background())
if err != nil {
	// handle error
}

for bid := range bidS {
	// check the bid details and communicate with the block-building
	// infrastructure to make a decision
	status := getDecision(bid)

	err := stream.Send(&providerapiv1.BidResponse{
			BidDigest: bid.BidDigest,
			Status:    status,
	})
	if err != nil {
		// handle error
	}
}