-
Notifications
You must be signed in to change notification settings - Fork 177
/
subscribe_events.go
40 lines (35 loc) · 1.1 KB
/
subscribe_events.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
package routes
import (
"context"
"github.com/onflow/flow-go/engine/access/rest/models"
"github.com/onflow/flow-go/engine/access/rest/request"
"github.com/onflow/flow-go/engine/access/state_stream"
"github.com/onflow/flow-go/engine/access/subscription"
)
// SubscribeEvents create websocket connection and write to it requested events.
func SubscribeEvents(
ctx context.Context,
request *request.Request,
wsController *WebsocketController,
) (subscription.Subscription, error) {
req, err := request.SubscribeEventsRequest()
if err != nil {
return nil, models.NewBadRequestError(err)
}
// Retrieve the filter parameters from the request, if provided
filter, err := state_stream.NewEventFilter(
wsController.eventFilterConfig,
request.Chain,
req.EventTypes,
req.Addresses,
req.Contracts,
)
if err != nil {
return nil, models.NewBadRequestError(err)
}
// Check if heartbeat interval was passed via request
if req.HeartbeatInterval > 0 {
wsController.heartbeatInterval = req.HeartbeatInterval
}
return wsController.api.SubscribeEvents(ctx, req.StartBlockID, req.StartHeight, filter), nil
}