mirror of https://github.com/fluffle/goirc
151 lines
2.6 KiB
Go
151 lines
2.6 KiB
Go
package client
|
|
|
|
import (
|
|
"context"
|
|
"io"
|
|
"net"
|
|
"os"
|
|
"strings"
|
|
"testing"
|
|
"time"
|
|
)
|
|
|
|
type mockNetConn struct {
|
|
*testing.T
|
|
|
|
In, Out chan string
|
|
in, out chan []byte
|
|
die context.CancelFunc
|
|
|
|
closed bool
|
|
rt, wt time.Time
|
|
}
|
|
|
|
func MockNetConn(t *testing.T) *mockNetConn {
|
|
// Our mock connection is a testing object
|
|
ctx, cancel := context.WithCancel(context.Background())
|
|
m := &mockNetConn{T: t, die: cancel}
|
|
|
|
// buffer input
|
|
m.In = make(chan string, 20)
|
|
m.in = make(chan []byte)
|
|
go func() {
|
|
for {
|
|
select {
|
|
case <-ctx.Done():
|
|
return
|
|
case s := <-m.In:
|
|
m.in <- []byte(s)
|
|
}
|
|
}
|
|
}()
|
|
|
|
// buffer output
|
|
m.Out = make(chan string)
|
|
m.out = make(chan []byte, 20)
|
|
go func() {
|
|
for {
|
|
select {
|
|
case <-ctx.Done():
|
|
return
|
|
case b := <-m.out:
|
|
m.Out <- string(b)
|
|
}
|
|
}
|
|
}()
|
|
|
|
return m
|
|
}
|
|
|
|
// Test helpers
|
|
func (m *mockNetConn) Send(s string) {
|
|
m.In <- s + "\r\n"
|
|
}
|
|
|
|
func (m *mockNetConn) Expect(e string) {
|
|
select {
|
|
case <-time.After(time.Millisecond):
|
|
m.Errorf("Mock connection did not receive expected output.\n\t"+
|
|
"Expected: '%s', got nothing.", e)
|
|
case s := <-m.Out:
|
|
s = strings.Trim(s, "\r\n")
|
|
if e != s {
|
|
m.Errorf("Mock connection received unexpected value.\n\t"+
|
|
"Expected: '%s'\n\tGot: '%s'", e, s)
|
|
}
|
|
}
|
|
}
|
|
|
|
func (m *mockNetConn) ExpectNothing() {
|
|
select {
|
|
case <-time.After(time.Millisecond):
|
|
case s := <-m.Out:
|
|
s = strings.Trim(s, "\r\n")
|
|
m.Errorf("Mock connection received unexpected output.\n\t"+
|
|
"Expected nothing, got: '%s'", s)
|
|
}
|
|
}
|
|
|
|
// Implement net.Conn interface
|
|
func (m *mockNetConn) Read(b []byte) (int, error) {
|
|
if m.Closed() {
|
|
return 0, os.ErrInvalid
|
|
}
|
|
s, ok := <-m.in
|
|
copy(b, s)
|
|
if !ok {
|
|
return len(s), io.EOF
|
|
}
|
|
return len(s), nil
|
|
}
|
|
|
|
func (m *mockNetConn) Write(s []byte) (int, error) {
|
|
if m.Closed() {
|
|
return 0, os.ErrInvalid
|
|
}
|
|
b := make([]byte, len(s))
|
|
copy(b, s)
|
|
m.out <- b
|
|
return len(s), nil
|
|
}
|
|
|
|
func (m *mockNetConn) Close() error {
|
|
if m.Closed() {
|
|
return os.ErrInvalid
|
|
}
|
|
m.closed = true
|
|
// Shut down *ALL* the goroutines!
|
|
// This will trigger an EOF event in Read() too
|
|
m.die()
|
|
close(m.in)
|
|
return nil
|
|
}
|
|
|
|
func (m *mockNetConn) Closed() bool {
|
|
return m.closed
|
|
}
|
|
|
|
func (m *mockNetConn) LocalAddr() net.Addr {
|
|
return &net.IPAddr{IP: net.IPv4(127, 0, 0, 1)}
|
|
}
|
|
|
|
func (m *mockNetConn) RemoteAddr() net.Addr {
|
|
return &net.IPAddr{IP: net.IPv4(127, 0, 0, 1)}
|
|
}
|
|
|
|
func (m *mockNetConn) SetDeadline(t time.Time) error {
|
|
m.rt = t
|
|
m.wt = t
|
|
return nil
|
|
}
|
|
|
|
func (m *mockNetConn) SetReadDeadline(t time.Time) error {
|
|
m.rt = t
|
|
return nil
|
|
}
|
|
|
|
func (m *mockNetConn) SetWriteDeadline(t time.Time) error {
|
|
m.wt = t
|
|
return nil
|
|
}
|