X-Git-Url: http://www.git.cypherpunks.ru/?a=blobdiff_plain;ds=sidebyside;f=daemon_test.go;h=b67fbd4664743662709cd8890b220aa3acbf8072;hb=HEAD;hp=efdb39fd3e3598dea52a2cd2431bcdadb7a5d8f0;hpb=0b8c40aa61e899edb3e563b7771e3d7927d6e859;p=goircd.git diff --git a/daemon_test.go b/daemon_test.go index efdb39f..b67fbd4 100644 --- a/daemon_test.go +++ b/daemon_test.go @@ -1,25 +1,21 @@ -/* -goircd -- minimalistic simple Internet Relay Chat (IRC) server -Copyright (C) 2014-2015 Sergey Matveev - -This program is free software: you can redistribute it and/or modify -it under the terms of the GNU General Public License as published by -the Free Software Foundation, either version 3 of the License, or -(at your option) any later version. - -This program is distributed in the hope that it will be useful, -but WITHOUT ANY WARRANTY; without even the implied warranty of -MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the -GNU General Public License for more details. - -You should have received a copy of the GNU General Public License -along with this program. If not, see . -*/ +// goircd -- minimalistic simple Internet Relay Chat (IRC) server +// Copyright (C) 2014-2024 Sergey Matveev +// +// This program is free software: you can redistribute it and/or modify +// it under the terms of the GNU General Public License as published by +// the Free Software Foundation, version 3 of the License. +// +// This program is distributed in the hope that it will be useful, +// but WITHOUT ANY WARRANTY; without even the implied warranty of +// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the +// GNU General Public License for more details. +// +// You should have received a copy of the GNU General Public License +// along with this program. If not, see . package main import ( - "io/ioutil" "os" "strings" "testing" @@ -27,21 +23,25 @@ import ( func TestRegistrationWorkflow(t *testing.T) { host := "foohost" - daemon := NewDaemon("ver1", &host, nil, nil, nil, nil) + hostname = &host events := make(chan ClientEvent) - go daemon.Processor(events) + finished := make(chan struct{}) + defer func() { + events <- ClientEvent{eventType: EventTerm} + <-finished + }() + go Processor(events, finished) conn := NewTestingConn() - client := NewClient(&host, conn) - go client.Processor(events) + client := NewClient(conn, events) - conn.inbound <- "UNEXISTENT CMD" // should recieve nothing on this + conn.inbound <- "UNEXISTENT CMD" // should receive nothing on this conn.inbound <- "NICK" if r := <-conn.outbound; r != ":foohost 431 :No nickname given\r\n" { t.Fatal("431 for NICK", r) } - for _, n := range []string{"привет", " foo", "longlonglong", "#foo", "mein nick", "foo_bar"} { + for _, n := range []string{"привет", " foo", "#foo", "mein nick", "foo_bar"} { conn.inbound <- "NICK " + n if r := <-conn.outbound; r != ":foohost 432 * "+n+" :Erroneous nickname\r\n" { t.Fatal("nickname validation", r) @@ -61,7 +61,7 @@ func TestRegistrationWorkflow(t *testing.T) { t.Fatal("461 again for USER", r) } - daemon.SendLusers(client) + client.SendLusers() if r := <-conn.outbound; !strings.Contains(r, "There are 0 users") { t.Fatal("LUSERS", r) } @@ -96,7 +96,7 @@ func TestRegistrationWorkflow(t *testing.T) { t.Fatal("reply for unexistent command", r) } - daemon.SendLusers(client) + client.SendLusers() if r := <-conn.outbound; !strings.Contains(r, "There are 1 users") { t.Fatal("1 users logged in", r) } @@ -107,14 +107,10 @@ func TestRegistrationWorkflow(t *testing.T) { } conn.inbound <- "QUIT\r\nUNEXISTENT CMD" - <-conn.outbound - if !conn.closed { - t.Fatal("closed connection on QUIT") - } } func TestMotd(t *testing.T) { - fd, err := ioutil.TempFile("", "motd") + fd, err := os.CreateTemp("", "motd") if err != nil { t.Fatalf("can not create temporary file: %v", err) } @@ -123,11 +119,15 @@ func TestMotd(t *testing.T) { conn := NewTestingConn() host := "foohost" - client := NewClient(&host, conn) + hostname = &host + client := NewClient(conn, make(chan ClientEvent, 2)) + defer func() { + client.Close() + }() motdName := fd.Name() - daemon := NewDaemon("ver1", &host, &motdName, nil, nil, nil) + motd = &motdName - daemon.SendMotd(client) + client.SendMotd() if r := <-conn.outbound; !strings.HasPrefix(r, ":foohost 375") { t.Fatal("MOTD start", r) }