add DependenciesFunc to get service erda.oap.collector.authentication…

….Validator

Signed-off-by: Ash <[email protected]>

internal/tools/monitor/oap/collector/plugins/receivers/collector/provider.go

@@ -41,13 +41,19 @@ var _ model.Receiver = (*provider)(nil)
 type provider struct {
 	Cfg       *config
 	Log       logs.Logger
-	Router    httpserver.Router        `autowired:"http-router"`
-	Validator authentication.Validator `autowired:"erda.oap.collector.authentication.Validator"`
+	Router    httpserver.Router `autowired:"http-router"`
+	Validator authentication.Validator
 
 	auth     *Authenticator
 	consumer model.ObservableDataConsumerFunc
 }
 
+type skipValidator struct{}
+
+func (skipValidator) Validate(scope string, scopeId string, token string) bool {
+	return true
+}
+
 func (p *provider) ComponentClose() error {
 	return nil
 }
@@ -62,6 +68,11 @@ func (p *provider) RegisterConsumer(consumer model.ObservableDataConsumerFunc) {
 
 // Run this is optional
 func (p *provider) Init(ctx servicehub.Context) error {
+	if p.Cfg.Auth.Skip {
+		p.Validator = skipValidator{}
+	} else {
+		p.Validator = ctx.Service("erda.oap.collector.authentication.Validator").(authentication.Validator)
+	}
 	p.auth = NewAuthenticator(
 		WithLogger(p.Log),
 		WithValidator(p.Validator),
@@ -84,6 +95,15 @@ func init() {
 	servicehub.Register(providerName, &servicehub.Spec{
 		Services:    []string{providerName},
 		Description: "here is description of erda.oap.collector.receiver.collector",
+		DependenciesFunc: func(hub *servicehub.Hub) (list []string) {
+			hub.ForeachServices(func(service string) bool {
+				if service == "erda.oap.collector.authentication.Validator" {
+					list = append(list, service)
+				}
+				return true
+			})
+			return list
+		},
 		ConfigFunc: func() interface{} {
 			return &config{}
 		},