The mev-share-go from duoxehyon

mev-share-go's People

Contributors

Stargazers

Watchers

mev-share-go's Issues

grant feedback

making this issue to collect comments from Flashbots reviewers

Stream subscription drops silently without a way for user to handle the subscription drop error

I am using your package in production.

Running this snippet

func mevShareMainEventLoop() {
	// Create a new client
	client := sse.New("https://mev-share.flashbots.net")

	// Make event channel for receiving events
	eventChan := make(chan sse.Event)

	// Subscribe to events
	_, err := client.Subscribe(eventChan)
	if err != nil {
		log.Fatalf("Failed to create initial mev-share sub=%v\n", err)
	}

	// Read events
	for {

		select {

		case event := <-eventChan:
			...
		}

	}
}

The stream subscription always drops silently within a few hours of starting the program and no more events come out of the channel.

Right now, I have to do manual detection on this event and restart the process whenever it happens.

Is there a way to do something similar to below ?

func mevShareMainEventLoop() {
	// Create a new client
	client := sse.New("https://mev-share.flashbots.net")

	// Make event channel for receiving events
	eventChan := make(chan sse.Event)

	// Subscribe to events
	sub, err := client.Subscribe(eventChan)
	if err != nil {
		log.Fatalf("Failed to create initial mev-share sub=%v\n", err)
	}

	// Read events
	for {

		select {
                 case error := sub.Error():
                       // handle subscription dropped event by re-susbcribing ?
                      sub, err = client.Subscribe(eventChan)
		case event := <-eventChan:
			....
		}

	}
}

Recommend Projects