X-Git-Url: http://www.git.cypherpunks.ru/?p=goircd.git;a=blobdiff_plain;f=client_test.go;h=4c9682ecb25785f4675befeb8522cb983d6a4b23;hp=3735e1f71034f8c3ebcd03f7efb63c522eff4c1a;hb=e657ffd2ab2cd5fae8c1d19e39b2268fa758153e;hpb=186ec4b4bd91f9fd101b2f62d30c0f2bd4ed50ce diff --git a/client_test.go b/client_test.go index 3735e1f..4c9682e 100644 --- a/client_test.go +++ b/client_test.go @@ -19,86 +19,17 @@ along with this program. If not, see . package main import ( - "net" "testing" - "time" ) -// Testing network connection that satisfies net.Conn interface -// Can send predefined messages and store all written ones -type TestingConn struct { - inbound chan string - outbound chan string - closed bool -} - -func NewTestingConn() *TestingConn { - inbound := make(chan string, 8) - outbound := make(chan string, 8) - return &TestingConn{inbound: inbound, outbound: outbound} -} - -func (conn TestingConn) Error() string { - return "i am finished" -} - -func (conn *TestingConn) Read(b []byte) (n int, err error) { - msg := <-conn.inbound - if msg == "" { - return 0, conn - } - for n, bt := range append([]byte(msg), CRLF...) { - b[n] = bt - } - return len(msg)+2, nil -} - -type MyAddr struct{} - -func (a MyAddr) String() string { - return "someclient" -} -func (a MyAddr) Network() string { - return "somenet" -} - -func (conn *TestingConn) Write(b []byte) (n int, err error) { - conn.outbound <- string(b) - return len(b), nil -} - -func (conn *TestingConn) Close() error { - conn.closed = true - return nil -} - -func (conn TestingConn) LocalAddr() net.Addr { - return nil -} - -func (conn TestingConn) RemoteAddr() net.Addr { - return MyAddr{} -} - -func (conn TestingConn) SetDeadline(t time.Time) error { - return nil -} - -func (conn TestingConn) SetReadDeadline(t time.Time) error { - return nil -} - -func (conn TestingConn) SetWriteDeadline(t time.Time) error { - return nil -} - // New client creation test. It must send an event about new client, // two predefined messages from it and deletion one func TestNewClient(t *testing.T) { conn := NewTestingConn() sink := make(chan ClientEvent) host := "foohost" - client := NewClient(&host, conn) + hostname = &host + client := NewClient(conn) go client.Processor(sink) event := <-sink @@ -126,8 +57,10 @@ func TestNewClient(t *testing.T) { func TestClientReplies(t *testing.T) { conn := NewTestingConn() host := "foohost" - client := NewClient(&host, conn) - client.nickname = "мойник" + hostname = &host + client := NewClient(conn) + nickname := "мойник" + client.nickname = &nickname client.Reply("hello") if r := <-conn.outbound; r != ":foohost hello\r\n" {