diff options
| author | bt <bt@rctt.net> | 2026-04-10 19:31:31 +0200 |
|---|---|---|
| committer | bt <bt@rctt.net> | 2026-04-18 22:33:20 +0200 |
| commit | e9aebac1a2a4732763c2f7e4428a23983d4eb6a3 (patch) | |
| tree | b66ea36939ea75360ed6c554cf352348d19786bb /client | |
| parent | f66e28aa88a5f4176934001fa9e4967ddccde4a9 (diff) | |
| download | solec-e9aebac1a2a4732763c2f7e4428a23983d4eb6a3.tar.gz solec-e9aebac1a2a4732763c2f7e4428a23983d4eb6a3.zip | |
[common] Exchange messages between servers
Diffstat (limited to 'client')
| -rw-r--r-- | client/client.go | 9 |
1 files changed, 7 insertions, 2 deletions
diff --git a/client/client.go b/client/client.go index 7fb9cc9..0fe967f 100644 --- a/client/client.go +++ b/client/client.go @@ -1,6 +1,8 @@ package client import ( + "errors" + "io" "net" "go.rctt.net/solec/core" @@ -37,12 +39,12 @@ func (c *Client) Connect() error { } defer c.conn.Close() - hs := core.Handshake{0, 1} + hs := core.Handshake{0, 1, core.ConnTypeUser} if err := core.Send(c.conn, hs); err != nil { return err } - auth := core.Auth{c.uname, c.pass} + auth := core.UserAuth{c.uname, c.pass} if err := core.Send(c.conn, auth); err != nil { return err } @@ -66,6 +68,9 @@ func (c *Client) read() { payload, err := core.Read(c.conn) if err != nil { c.h.HandleError(err) + if errors.Is(err, io.EOF) { + break + } } c.handlePayload(payload) |
