Skip to content

Commit

Permalink
Adjust logging unknown types in LS tables
Browse files Browse the repository at this point in the history
  • Loading branch information
tulir committed May 28, 2024
1 parent 9287a71 commit c4eadec
Showing 1 changed file with 13 additions and 7 deletions.
20 changes: 13 additions & 7 deletions messagix/lightspeed/decode.go
Original file line number Diff line number Diff line change
Expand Up @@ -9,6 +9,7 @@ import (
"strings"
"time"

"github.com/rs/zerolog"
badGlobalLog "github.com/rs/zerolog/log"
)

Expand Down Expand Up @@ -208,10 +209,12 @@ func (ls *LightSpeedDecoder) Decode(data interface{}) interface{} {
func (ls *LightSpeedDecoder) handleStoredProcedure(referenceName string, data []interface{}) {
depReference, ok := ls.Dependencies[referenceName]
if !ok {
badGlobalLog.Warn().
Str("reference_name", referenceName).
Any("data", data).
Msg("Skipping dependency with reference name (unknown dependency)")
logEvt := badGlobalLog.Warn().
Str("reference_name", referenceName)
if badGlobalLog.Logger.GetLevel() == zerolog.TraceLevel {
logEvt.Any("data", data)
}
logEvt.Msg("Skipping dependency with no reference")
return
}

Expand All @@ -220,10 +223,13 @@ func (ls *LightSpeedDecoder) handleStoredProcedure(referenceName string, data []
depField := reflectedMs.FieldByName(depReference)

if !depField.IsValid() {
badGlobalLog.Warn().
logEvt := badGlobalLog.Warn().
Str("reference_name", referenceName).
Any("data", data).
Msg("Skipping dependency with reference name (invalid field)")
Str("ls_type", depReference)
if badGlobalLog.Logger.GetLevel() == zerolog.TraceLevel {
logEvt.Any("data", data)
}
logEvt.Msg("Skipping dependency with unrecognized type")
return
}

Expand Down

0 comments on commit c4eadec

Please sign in to comment.