Skip to content

Commit fc8d8b0

Browse files
committed
proxy: allow optional block
1 parent e42a1d1 commit fc8d8b0

1 file changed

Lines changed: 6 additions & 2 deletions

File tree

proxy/proxy_client_notification.go

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -33,14 +33,18 @@ func newProxyClientNotification(ctx context.Context, settings *ProxySettings) *p
3333
}
3434

3535
func (self *proxyClientNotification) run() {
36+
proxyHost := server.RequireHost()
37+
// FIXME allow an optional block until migration is complete
38+
block, _ := server.Block()
39+
3640
nextChangeId := int64(0)
3741
for {
3842
var proxyClients map[server.Id]*model.ProxyClient
3943
var err error
4044
proxyClients, nextChangeId, err = model.GetProxyClientsSince(
4145
self.ctx,
42-
server.RequireHost(),
43-
server.RequireBlock(),
46+
proxyHost,
47+
block,
4448
nextChangeId,
4549
)
4650
if err != nil {

0 commit comments

Comments
 (0)