diff options
Diffstat (limited to 'internal/server')
| -rw-r--r-- | internal/server/server.go | 9 |
1 files changed, 7 insertions, 2 deletions
diff --git a/internal/server/server.go b/internal/server/server.go index e9d62f0..c3e9e05 100644 --- a/internal/server/server.go +++ b/internal/server/server.go @@ -45,7 +45,12 @@ func runServer(ctx context.Context, conf config.Config, quo quorum.Quorum) error }() return tcpServerRun(serverCtx, conf, func(message string) string { - ch <- vote.New(conf, message) - return "ok - I received your message, dear client" + v, err := vote.NewFromJSON(message) + if err != nil { + return err.Error() + } + + ch <- v + return "I received your message, dear client" }) } |