mirror of
https://github.com/wso2/open-mcp-auth-proxy.git
synced 2025-06-27 17:13:31 +00:00
Add eof
This commit is contained in:
parent
69fac360ba
commit
68d7cf1f91
10 changed files with 10 additions and 10 deletions
|
@ -131,4 +131,4 @@ func main() {
|
||||||
logger.Error("HTTP server shutdown error: %v", err)
|
logger.Error("HTTP server shutdown error: %v", err)
|
||||||
}
|
}
|
||||||
logger.Info("Stopped.")
|
logger.Info("Stopped.")
|
||||||
}
|
}
|
||||||
|
|
|
@ -335,4 +335,4 @@ func randomString(n int) string {
|
||||||
b[i] = letters[rand.Intn(len(letters))]
|
b[i] = letters[rand.Intn(len(letters))]
|
||||||
}
|
}
|
||||||
return string(b)
|
return string(b)
|
||||||
}
|
}
|
||||||
|
|
|
@ -93,4 +93,4 @@ func (p *defaultProvider) WellKnownHandler() http.HandlerFunc {
|
||||||
|
|
||||||
func (p *defaultProvider) RegisterHandler() http.HandlerFunc {
|
func (p *defaultProvider) RegisterHandler() http.HandlerFunc {
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
|
@ -187,4 +187,4 @@ func LoadConfig(path string) (*Config, error) {
|
||||||
}
|
}
|
||||||
|
|
||||||
return &cfg, nil
|
return &cfg, nil
|
||||||
}
|
}
|
||||||
|
|
|
@ -31,4 +31,4 @@ func Warn(format string, v ...interface{}) {
|
||||||
// Error logs an error-level message
|
// Error logs an error-level message
|
||||||
func Error(format string, v ...interface{}) {
|
func Error(format string, v ...interface{}) {
|
||||||
log.Printf("ERROR: "+format, v...)
|
log.Printf("ERROR: "+format, v...)
|
||||||
}
|
}
|
||||||
|
|
|
@ -201,4 +201,4 @@ func (m *RegisterModifier) ModifyRequest(req *http.Request) (*http.Request, erro
|
||||||
}
|
}
|
||||||
|
|
||||||
return req, nil
|
return req, nil
|
||||||
}
|
}
|
||||||
|
|
|
@ -307,4 +307,4 @@ func skipHeader(h string) bool {
|
||||||
return true
|
return true
|
||||||
}
|
}
|
||||||
return false
|
return false
|
||||||
}
|
}
|
||||||
|
|
|
@ -106,4 +106,4 @@ func (t *sseTransport) RoundTrip(req *http.Request) (*http.Response, error) {
|
||||||
// Replace the response body with our modified pipe
|
// Replace the response body with our modified pipe
|
||||||
resp.Body = pr
|
resp.Body = pr
|
||||||
return resp, nil
|
return resp, nil
|
||||||
}
|
}
|
||||||
|
|
|
@ -265,4 +265,4 @@ func (m *Manager) Shutdown() {
|
||||||
case <-time.After(m.shutdownDelay):
|
case <-time.After(m.shutdownDelay):
|
||||||
logger.Warn("Subprocess termination timed out")
|
logger.Warn("Subprocess termination timed out")
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -94,4 +94,4 @@ func ValidateJWT(authHeader string) error {
|
||||||
return errors.New("invalid token: token not valid")
|
return errors.New("invalid token: token not valid")
|
||||||
}
|
}
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue