diff --git a/internal/metrics/metrics.go b/internal/metrics/metrics.go index 11da2b7..4a7fe95 100644 --- a/internal/metrics/metrics.go +++ b/internal/metrics/metrics.go @@ -86,6 +86,7 @@ const ( errUnexpectedEOFStr = "unexpected_eof_str" errJSONSyntax = "json_syntax" errBlobTooBig = "blob_too_big" + errInvalidPeerJSON = "invalid_peer_json" errInvalidPeerData = "invalid_peer_data" errDeadlineExceeded = "deadline_exceeded" errHashMismatch = "hash_mismatch" @@ -297,6 +298,8 @@ func TrackError(direction string, e error) (shouldLog bool) { // shouldLog is a } else if strings.Contains(err.Error(), "blob must be at most") { //log.Warnln("blob must be at most X bytes is not the same as ErrBlobTooBig") errType = errBlobTooBig + } else if strings.Contains(err.Error(), "invalid json request") { + errType = errInvalidPeerJSON } else if strings.Contains(err.Error(), "Invalid data") { errType = errInvalidPeerData } else if strings.Contains(err.Error(), "hash of received blob data does not match hash from send request") { diff --git a/server/peer/server.go b/server/peer/server.go index 72ab04a..52c4a80 100644 --- a/server/peer/server.go +++ b/server/peer/server.go @@ -227,7 +227,7 @@ func (s *Server) handleCompositeRequest(data []byte) ([]byte, error) { if err != nil { var je *json.SyntaxError if ee.As(err, &je) { - return nil, errors.Err("invalid json at offset %d in data %s", je.Offset, hex.EncodeToString(data)) + return nil, errors.Err("invalid json request: offset %d in data %s", je.Offset, hex.EncodeToString(data)) } return nil, errors.Err(err) }