apps/cunicu
1
0
Fork 0
mirror of https://codeberg.org/cunicu/cunicu.git synced 2025-09-26 21:01:14 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix(signaling): Do not block daemon start-up by signaling IO

Browse Source 
Signed-off-by: Steffen Vogel <post@steffenvogel.de>
This commit is contained in:
Steffen Vogel
2025-01-02 03:10:43 +01:00
parent 30aa4d1acc
commit f98286c5fd
1 changed files with 17 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

32
pkg/signaling/grpc/backend.go
View File

@@ -57,23 +57,25 @@ func NewBackend(cfg *signaling.BackendConfig, logger *log.Logger) (signaling.Bac
b.client = signalingproto.NewSignalingClient(b.conn)
bi, err := b.client.GetBuildInfo(context.Background(), &proto.Empty{}, grpc.WaitForReady(true))
if err != nil {
return nil, fmt.Errorf("failed to connect to GRPC signaling server: %w", err)
}
go func() {
bi, err := b.client.GetBuildInfo(context.Background(), &proto.Empty{}, grpc.WaitForReady(true))
if err != nil {
b.logger.Error("Failed to get build info from the gRPC signaling server", zap.Error(err))
}
b.logger.Debug("Connected to GRPC signaling server",
zap.String("server_arch", bi.Arch),
zap.String("server_version", bi.Version),
zap.String("server_commit", bi.Commit),
zap.String("server_tag", bi.Tag),
zap.String("server_branch", bi.Branch),
zap.String("server_os", bi.Os),
)
b.logger.Debug("Connected to GRPC signaling server",
zap.String("server_arch", bi.Arch),
zap.String("server_version", bi.Version),
zap.String("server_commit", bi.Commit),
zap.String("server_tag", bi.Tag),
zap.String("server_branch", bi.Branch),
zap.String("server_os", bi.Os),
)
for _, h := range cfg.OnReady {
h.OnSignalingBackendReady(b)
}
for _, h := range cfg.OnReady {
h.OnSignalingBackendReady(b)
}
}()
return b, nil
}