diff options
author | meskio <meskio@torproject.org> | 2022-05-20 09:43:03 +0200 |
---|---|---|
committer | meskio <meskio@torproject.org> | 2022-05-25 18:09:06 +0200 |
commit | 1d592b06e51b42ca4ed13ec219f012a2915c2b1d (patch) | |
tree | 9e802a5af049b64fab839354f5038b58fb29b21c /client | |
parent | 9757784c5aa25a6148f7bdf39295b08c738b06d5 (diff) | |
download | snowflake-1d592b06e51b42ca4ed13ec219f012a2915c2b1d.tar.gz snowflake-1d592b06e51b42ca4ed13ec219f012a2915c2b1d.zip |
Implement String() method on events
To make it safe for logging safelog.Scrub function is now public.
Closes: #40141
Diffstat (limited to 'client')
-rw-r--r-- | client/pt_event_logger.go | 67 |
1 files changed, 1 insertions, 66 deletions
diff --git a/client/pt_event_logger.go b/client/pt_event_logger.go index aae8716..483a3c6 100644 --- a/client/pt_event_logger.go +++ b/client/pt_event_logger.go @@ -1,12 +1,8 @@ package main import ( - "bytes" - "fmt" pt "git.torproject.org/pluggable-transports/goptlib.git" "git.torproject.org/pluggable-transports/snowflake.git/v2/common/event" - "git.torproject.org/pluggable-transports/snowflake.git/v2/common/safelog" - "strings" ) func NewPTEventLogger() event.SnowflakeEventReceiver { @@ -16,67 +12,6 @@ func NewPTEventLogger() event.SnowflakeEventReceiver { type ptEventLogger struct { } -type logSeverity int - -const ( - Debug logSeverity = iota - Info - Notice - Warning - Error -) - -func safePTLog(severity logSeverity, format string, a ...interface{}) { - var buff bytes.Buffer - scrubber := &safelog.LogScrubber{Output: &buff} - - // make sure logString ends with exactly one "\n" so it's not stuck in scrubber.Write()'s internal buffer - logString := strings.TrimRight(fmt.Sprintf(format, a...), "\n") + "\n" - scrubber.Write([]byte(logString)) - - // remove newline before calling pt.Log because it adds a newline - msg := strings.TrimRight(buff.String(), "\n") - - switch severity { - case Error: - pt.Log(pt.LogSeverityError, msg) - case Warning: - pt.Log(pt.LogSeverityWarning, msg) - case Notice: - pt.Log(pt.LogSeverityWarning, msg) - case Info: - pt.Log(pt.LogSeverityInfo, msg) - case Debug: - pt.Log(pt.LogSeverityDebug, msg) - default: - pt.Log(pt.LogSeverityNotice, msg) - } -} - func (p ptEventLogger) OnNewSnowflakeEvent(e event.SnowflakeEvent) { - switch e.(type) { - case event.EventOnOfferCreated: - e := e.(event.EventOnOfferCreated) - if e.Error != nil { - safePTLog(Notice, "offer creation failure %v", e.Error.Error()) - } else { - safePTLog(Notice, "offer created") - } - - case event.EventOnBrokerRendezvous: - e := e.(event.EventOnBrokerRendezvous) - if e.Error != nil { - safePTLog(Notice, "broker failure %v", e.Error.Error()) - } else { - safePTLog(Notice, "broker rendezvous peer received") - } - - case event.EventOnSnowflakeConnected: - safePTLog(Notice, "connected") - - case event.EventOnSnowflakeConnectionFailed: - e := e.(event.EventOnSnowflakeConnectionFailed) - safePTLog(Notice, "trying a new proxy: %v", e.Error.Error()) - } - + pt.Log(pt.LogSeverityNotice, e.String()) } |