| 179 | } |
| 180 | |
| 181 | func createAuthHandler( |
| 182 | cfg config.AppConfig, |
| 183 | logger log.Logger, |
| 184 | backend sshserver.Handler, |
| 185 | metricsCollector metrics.Collector, |
| 186 | pool service.Pool, |
| 187 | ) (sshserver.Handler, error) { |
| 188 | authLogger := logger.WithLabel("module", "auth") |
| 189 | handler, services, err := authintegration.New( |
| 190 | cfg.Auth, |
| 191 | backend, |
| 192 | authLogger, |
| 193 | metricsCollector, |
| 194 | authintegration.BehaviorNoPassthrough, |
| 195 | ) |
| 196 | if err != nil { |
| 197 | return nil, err |
| 198 | } |
| 199 | for _, svc := range services { |
| 200 | pool.Add(svc) |
| 201 | } |
| 202 | return handler, nil |
| 203 | } |
| 204 | |
| 205 | func createBackend(cfg config.AppConfig, logger log.Logger, metricsCollector metrics.Collector) (sshserver.Handler, error) { |
| 206 | backendLogger := logger.WithLabel("module", "backend") |