Merge pull request #23 from onflow/chasefleming/wait-server

Add WaitServer

flowkit.go

@@ -136,6 +136,10 @@ func (f *Flowkit) Ping() error {
 	return f.gateway.Ping()
 }
 
+func (f *Flowkit) WaitServer(ctx context.Context) error {
+	return f.gateway.WaitServer(ctx)
+}
+
 // GetAccount fetches account on the Flow network.
 func (f *Flowkit) GetAccount(ctx context.Context, address flow.Address) (*flow.Account, error) {
 	return f.gateway.GetAccount(ctx, address)

gateway/emulator.go

@@ -159,6 +159,10 @@ func (g *EmulatorGateway) Ping() error {
 	return nil
 }
 
+func (g *EmulatorGateway) WaitServer(ctx context.Context) error {
+	return nil
+}
+
 type scriptQuery struct {
 	id     flow.Identifier
 	height uint64

gateway/gateway.go

@@ -45,5 +45,6 @@ type Gateway interface {
 	GetCollection(context.Context, flow.Identifier) (*flow.Collection, error)
 	GetLatestProtocolStateSnapshot(context.Context) ([]byte, error)
 	Ping() error
+	WaitServer(context.Context) error
 	SecureConnection() bool
 }

gateway/grpc.go

@@ -206,6 +206,10 @@ func (g *GrpcGateway) Ping() error {
 	return g.client.Ping(ctx)
 }
 
+func (g *GrpcGateway) WaitServer(ctx context.Context) error {
+	return g.client.WaitServer(ctx)
+}
+
 // SecureConnection is used to log warning if a service should be using a secure client but is not
 func (g *GrpcGateway) SecureConnection() bool {
 	return g.secureClient

services.go

@@ -38,6 +38,7 @@ import (
 type Services interface {
 	Network() config.Network
 	Ping() error
+	WaitServer(context.Context) error
 	Gateway() gateway.Gateway
 	SetLogger(output.Logger)