rohit/probo
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix no error with duplicate connector name

Browse Source 
Signed-off-by: Bryan Frimin <bryan@getprobo.com>
This commit is contained in:
Bryan Frimin
2025-04-19 20:04:44 -07:00
parent 7d3a9e6d3b
commit fd698d8485
2 changed files with 8 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
pkg/connector/registry.go
View File

@@ -34,10 +34,14 @@ func NewConnectorRegistry() *ConnectorRegistry {
}
}
func (cr *ConnectorRegistry) Register(connectorID string, connector Connector) {
func (cr *ConnectorRegistry) Register(connectorID string, connector Connector) error {
cr.Lock()
defer cr.Unlock()
if _, ok := cr.connectors[connectorID]; ok {
return fmt.Errorf("connector %q already registered", connectorID)
}
cr.connectors[connectorID] = connector
return nil
}
func (cr *ConnectorRegistry) Get(connectorID string) (Connector, error) {

4
pkg/probod/probod.go
View File

@@ -178,7 +178,9 @@ func (impl *Implm) Run(
defaultConnectorRegistry := connector.NewConnectorRegistry()
for _, connector := range impl.cfg.Connectors {
defaultConnectorRegistry.Register(connector.Name, connector.Config)
if err := defaultConnectorRegistry.Register(connector.Name, connector.Config); err != nil {
return fmt.Errorf("cannot register connector: %w", err)
}
}
usrmgrService, err := usrmgr.NewService(