aboutsummaryrefslogtreecommitdiff
path: root/client
diff options
context:
space:
mode:
authormeskio <meskio@torproject.org>2022-05-20 09:43:03 +0200
committermeskio <meskio@torproject.org>2022-05-25 18:09:06 +0200
commit1d592b06e51b42ca4ed13ec219f012a2915c2b1d (patch)
tree9e802a5af049b64fab839354f5038b58fb29b21c /client
parent9757784c5aa25a6148f7bdf39295b08c738b06d5 (diff)
downloadsnowflake-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.go67
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())
}