add daemon ready (#62)

* add daemon ready

* refactor service startup sequence

app/app.go

@@ -2,6 +2,7 @@ package app
 
 import (
 	"context"
+	"fmt"
 	"log"
 	"os"
 	"os/signal"
@@ -115,6 +116,13 @@ func Start(ctx context.Context, cfg config.Config, env env.SpaceEnv) {
 		grpc.WithPort(cfg.GetInt(config.SpaceServerPort, 0)),
 	)
 
+	g.Go(func() error {
+		sync.RegisterNotifier(srv)
+		return sync.Start(ctx)
+	})
+
+	<-sync.WaitForReady()
+
 	// start the gRPC server
 	g.Go(func() error {
 		if svErr != nil {
@@ -124,10 +132,7 @@ func Start(ctx context.Context, cfg config.Config, env env.SpaceEnv) {
 		return srv.Start(ctx)
 	})
 
-	g.Go(func() error {
-		sync.RegisterNotifier(srv)
-		return sync.Start(ctx)
-	})
+	fmt.Println("daemon ready")
 
 	// wait for interruption or done signal
 	select {

core/sync/sync.go

@@ -31,6 +31,7 @@ type GrpcNotifier interface {
 }
 
 type BucketSynchronizer interface {
+	WaitForReady() chan bool
 	Start(ctx context.Context) error
 	Stop()
 	RegisterNotifier(notifier GrpcNotifier)
@@ -62,6 +63,7 @@ type bucketSynchronizer struct {
 	textileThreadListeners []textile.ThreadListener
 	notifier               GrpcNotifier
 	store                  store.Store
+	ready                  chan bool
 }
 
 // Creates a new bucketSynchronizer instancelistenerEventHandler
@@ -81,6 +83,7 @@ func New(
 		textileThreadListeners: textileThreadListeners,
 		notifier:               notifier,
 		store:                  store,
+		ready:                  make(chan bool),
 	}
 }
 
@@ -151,15 +154,25 @@ func (bs *bucketSynchronizer) Start(ctx context.Context) error {
 		}
 	}
 
+	go func() {
+		bs.ready <- true
+	}()
+
 	err = g.Wait()
 
 	if err != nil {
 		return err
 	}
 
+
+
 	return nil
 }
 
+func (bs *bucketSynchronizer) WaitForReady() chan bool {
+	return bs.ready
+}
+
 func (bs *bucketSynchronizer) Stop() {
 	// add shutdown logic here
 	log.Debug("shutting down folder watcher in bucketsync")
@@ -168,6 +181,8 @@ func (bs *bucketSynchronizer) Stop() {
 	for _, listener := range bs.textileThreadListeners {
 		listener.Close()
 	}
+
+	close(bs.ready)
 }
 
 func (bs *bucketSynchronizer) RegisterNotifier(notifier GrpcNotifier) {