diff --git a/services/collaboration/pkg/command/version.go b/services/collaboration/pkg/command/version.go index 57aa0f6ece..ce31ba5c25 100644 --- a/services/collaboration/pkg/command/version.go +++ b/services/collaboration/pkg/command/version.go @@ -24,14 +24,14 @@ func Version(cfg *config.Config) *cli.Command { fmt.Println("") reg := registry.GetRegistry() - services, err := reg.GetService(cfg.HTTP.Namespace + "." + cfg.Service.Name) + services, err := reg.GetService(cfg.HTTP.Namespace + "." + cfg.Service.Name + "." + cfg.App.Name) if err != nil { - fmt.Println(fmt.Errorf("could not get %s services from the registry: %v", cfg.Service.Name, err)) + fmt.Println(fmt.Errorf("could not get %s services from the registry: %v", cfg.Service.Name+"."+cfg.App.Name, err)) return err } if len(services) == 0 { - fmt.Println("No running " + cfg.Service.Name + " service found.") + fmt.Println("No running " + cfg.Service.Name + "." + cfg.App.Name + " service found.") return nil } diff --git a/services/collaboration/pkg/connector/fileconnector.go b/services/collaboration/pkg/connector/fileconnector.go index 8b98851f21..21ab33acd9 100644 --- a/services/collaboration/pkg/connector/fileconnector.go +++ b/services/collaboration/pkg/connector/fileconnector.go @@ -161,7 +161,7 @@ func (f *FileConnector) Lock(ctx context.Context, lockID, oldLockID string) (str Ref: &wopiContext.FileReference, Lock: &providerv1beta1.Lock{ LockId: lockID, - AppName: f.cfg.App.LockName, + AppName: f.cfg.App.LockName + "." + f.cfg.App.Name, Type: providerv1beta1.LockType_LOCK_TYPE_WRITE, Expiration: &typesv1beta1.Timestamp{ Seconds: uint64(time.Now().Add(lockDuration).Unix()), @@ -182,7 +182,7 @@ func (f *FileConnector) Lock(ctx context.Context, lockID, oldLockID string) (str Ref: &wopiContext.FileReference, Lock: &providerv1beta1.Lock{ LockId: lockID, - AppName: f.cfg.App.LockName, + AppName: f.cfg.App.LockName + "." + f.cfg.App.Name, Type: providerv1beta1.LockType_LOCK_TYPE_WRITE, Expiration: &typesv1beta1.Timestamp{ Seconds: uint64(time.Now().Add(lockDuration).Unix()), @@ -295,7 +295,7 @@ func (f *FileConnector) RefreshLock(ctx context.Context, lockID string) (string, Ref: &wopiContext.FileReference, Lock: &providerv1beta1.Lock{ LockId: lockID, - AppName: f.cfg.App.LockName, + AppName: f.cfg.App.LockName + "." + f.cfg.App.Name, Type: providerv1beta1.LockType_LOCK_TYPE_WRITE, Expiration: &typesv1beta1.Timestamp{ Seconds: uint64(time.Now().Add(lockDuration).Unix()), @@ -403,7 +403,7 @@ func (f *FileConnector) UnLock(ctx context.Context, lockID string) (string, erro Ref: &wopiContext.FileReference, Lock: &providerv1beta1.Lock{ LockId: lockID, - AppName: f.cfg.App.LockName, + AppName: f.cfg.App.LockName + "." + f.cfg.App.Name, }, } diff --git a/services/collaboration/pkg/helpers/registration.go b/services/collaboration/pkg/helpers/registration.go index a3b83f4d4f..c4967dac7d 100644 --- a/services/collaboration/pkg/helpers/registration.go +++ b/services/collaboration/pkg/helpers/registration.go @@ -19,7 +19,7 @@ import ( // There are no explicit requirements for the context, and it will be passed // without changes to the underlying RegisterService method. func RegisterOcisService(ctx context.Context, cfg *config.Config, logger log.Logger) error { - svc := registry.BuildGRPCService(cfg.GRPC.Namespace+"."+cfg.Service.Name, uuid.Must(uuid.NewV4()).String(), cfg.GRPC.Addr, version.GetString()) + svc := registry.BuildGRPCService(cfg.GRPC.Namespace+"."+cfg.Service.Name+"."+cfg.App.Name, uuid.Must(uuid.NewV4()).String(), cfg.GRPC.Addr, version.GetString()) return registry.RegisterService(ctx, svc, logger) } @@ -62,7 +62,7 @@ func RegisterAppProvider( Name: cfg.App.Name, Description: cfg.App.Description, Icon: cfg.App.Icon, - Address: cfg.GRPC.Namespace + "." + cfg.Service.Name, + Address: cfg.GRPC.Namespace + "." + cfg.Service.Name + "." + cfg.App.Name, MimeTypes: mimeTypes, }, } diff --git a/services/collaboration/pkg/server/debug/server.go b/services/collaboration/pkg/server/debug/server.go index abcbe9e8a7..89de713708 100644 --- a/services/collaboration/pkg/server/debug/server.go +++ b/services/collaboration/pkg/server/debug/server.go @@ -15,7 +15,7 @@ func Server(opts ...Option) (*http.Server, error) { return debug.NewService( debug.Logger(options.Logger), - debug.Name(options.Config.Service.Name), + debug.Name(options.Config.Service.Name+"."+options.Config.App.Name), debug.Version(version.GetString()), debug.Address(options.Config.Debug.Addr), debug.Token(options.Config.Debug.Token), diff --git a/services/collaboration/pkg/server/http/server.go b/services/collaboration/pkg/server/http/server.go index d1f3b73948..ca494549a0 100644 --- a/services/collaboration/pkg/server/http/server.go +++ b/services/collaboration/pkg/server/http/server.go @@ -25,7 +25,7 @@ func Server(opts ...Option) (http.Service, error) { http.TLSConfig(options.Config.HTTP.TLS), http.Logger(options.Logger), http.Namespace(options.Config.HTTP.Namespace), - http.Name(options.Config.Service.Name), + http.Name(options.Config.Service.Name+"."+options.Config.App.Name), http.Version(version.GetString()), http.Address(options.Config.HTTP.Addr), http.Context(options.Context), @@ -41,7 +41,7 @@ func Server(opts ...Option) (http.Service, error) { middlewares := []func(stdhttp.Handler) stdhttp.Handler{ chimiddleware.RequestID, middleware.Version( - options.Config.Service.Name, + options.Config.Service.Name+"."+options.Config.App.Name, version.GetString(), ), middleware.Logger( @@ -69,7 +69,7 @@ func Server(opts ...Option) (http.Service, error) { mux.Use( otelchi.Middleware( - options.Config.Service.Name, + options.Config.Service.Name+"."+options.Config.App.Name, otelchi.WithChiRoutes(mux), otelchi.WithTracerProvider(options.TracerProvider), otelchi.WithPropagators(tracing.GetPropagator()), diff --git a/services/collaboration/pkg/service/grpc/v0/service.go b/services/collaboration/pkg/service/grpc/v0/service.go index 67ae47eb0d..994a211493 100644 --- a/services/collaboration/pkg/service/grpc/v0/service.go +++ b/services/collaboration/pkg/service/grpc/v0/service.go @@ -38,7 +38,7 @@ func NewHandler(opts ...Option) (*Service, func(), error) { } return &Service{ - id: options.Config.GRPC.Namespace + "." + options.Config.Service.Name, + id: options.Config.GRPC.Namespace + "." + options.Config.Service.Name + "." + options.Config.App.Name, appURLs: options.AppURLs, logger: options.Logger, config: options.Config,