formatted file
This commit is contained in:
@@ -85,16 +85,20 @@ func (m *AuthManager) routeInbox() {
|
|||||||
m.mu.Unlock()
|
m.mu.Unlock()
|
||||||
|
|
||||||
now := time.Now()
|
now := time.Now()
|
||||||
m.envoy.Observer().Record(msg.URL, ChallengeReceived{Challenge: challenge, At: now})
|
m.envoy.Observer().Record(msg.URL,
|
||||||
|
ChallengeReceived{Challenge: challenge, At: now})
|
||||||
|
|
||||||
signed, err := m.respond(challenge)
|
signed, err := m.respond(challenge)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
m.envoy.Observer().Record(msg.URL, AuthResponseFailed{Err: err, At: time.Now()})
|
m.envoy.Observer().Record(msg.URL,
|
||||||
|
AuthResponseFailed{Err: err, At: time.Now()})
|
||||||
continue
|
continue
|
||||||
}
|
}
|
||||||
|
|
||||||
if err := m.envoy.Send([]byte(envelope.EncloseAuthResponse(signed))); err != nil {
|
if err := m.envoy.Send(
|
||||||
m.envoy.Observer().Record(msg.URL, AuthResponseFailed{Err: err, At: time.Now()})
|
[]byte(envelope.EncloseAuthResponse(signed))); err != nil {
|
||||||
|
m.envoy.Observer().Record(msg.URL,
|
||||||
|
AuthResponseFailed{Err: err, At: time.Now()})
|
||||||
continue
|
continue
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user