diff options
| author | Paul Buetow <pbuetow@mimecast.com> | 2022-02-15 12:22:00 +0000 |
|---|---|---|
| committer | Paul Buetow <pbuetow@mimecast.com> | 2022-02-15 12:22:00 +0000 |
| commit | 37fe6052586cdeecd5975cf2b83b8b1109109817 (patch) | |
| tree | c5dceab08f2a37b8b9b7d0a17cbc2900656256d9 /internal/server/handlers/basehandler.go | |
| parent | 267d7a92a31b01ef5dfdfd5a85bfa1243b40d989 (diff) | |
minor fix, add missing newlines to server messages
Diffstat (limited to 'internal/server/handlers/basehandler.go')
| -rw-r--r-- | internal/server/handlers/basehandler.go | 10 |
1 files changed, 7 insertions, 3 deletions
diff --git a/internal/server/handlers/basehandler.go b/internal/server/handlers/basehandler.go index 4fd718e..7daf071 100644 --- a/internal/server/handlers/basehandler.go +++ b/internal/server/handlers/basehandler.go @@ -150,7 +150,7 @@ func (h *baseHandler) handleCommand(commandStr string) { } args, argc, err = h.handleBase64(args, argc) if err != nil { - h.send(h.serverMessages, dlog.Server.Error(h.user, err)) + h.sendln(h.serverMessages, dlog.Server.Error(h.user, err)) return } ctx, cancel := context.WithCancel(context.Background()) @@ -170,7 +170,7 @@ func (h *baseHandler) handleCommand(commandStr string) { options, ltx, err := config.DeserializeOptions(parts[1:]) if err != nil { - h.send(h.serverMessages, dlog.Server.Error(h.user, err)) + h.sendln(h.serverMessages, dlog.Server.Error(h.user, err)) return } h.handleOptions(options) @@ -231,7 +231,7 @@ func (h *baseHandler) handleBase64(args []string, argc int) ([]string, int, erro func (h *baseHandler) handleAckCommand(argc int, args []string) { if argc < 3 { if !h.quiet { - h.send(h.serverMessages, dlog.Server.Warn(h.user, + h.sendln(h.serverMessages, dlog.Server.Warn(h.user, "Unable to parse command", args, argc)) } return @@ -274,6 +274,10 @@ func (h *baseHandler) send(ch chan<- string, message string) { } } +func (h *baseHandler) sendln(ch chan<- string, message string) { + h.send(ch, message+"\n") +} + func (h *baseHandler) flush() { dlog.Server.Trace(h.user, "flush()") numUnsentMessages := func() int { |