(s *Service)
| 59 | } |
| 60 | |
| 61 | func validateApiKeyStreamMiddleware(s *Service) grpc.StreamServerInterceptor { |
| 62 | return func( |
| 63 | srv interface{}, |
| 64 | ss grpc.ServerStream, |
| 65 | info *grpc.StreamServerInfo, |
| 66 | handler grpc.StreamHandler, |
| 67 | ) error { |
| 68 | // Use common session validation logic |
| 69 | if err := validateApiKey(ss.Context(), s); err != nil { |
| 70 | log.Println("invalid api key stream:", err) |
| 71 | return err |
| 72 | } |
| 73 | |
| 74 | return handler(srv, ss) |
| 75 | } |
| 76 | } |
| 77 | |
| 78 | func checkBackendStatus(s *Service) error { |
| 79 | back := s.Backend() |
no test coverage detected