Add Server.Logger
This commit is contained in:
parent
003ce38bf8
commit
06cd1ce44f
@ -15,7 +15,10 @@ func main() {
|
|||||||
log.Fatalf("failed to start listener: %v", err)
|
log.Fatalf("failed to start listener: %v", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
s := jounce.Server{Hostname: "localhost"}
|
s := jounce.Server{
|
||||||
|
Hostname: "localhost",
|
||||||
|
Logger: log.New(log.Writer(), "", log.LstdFlags),
|
||||||
|
}
|
||||||
|
|
||||||
log.Printf("Server listening on %v", addr)
|
log.Printf("Server listening on %v", addr)
|
||||||
log.Fatal(s.Serve(ln))
|
log.Fatal(s.Serve(ln))
|
||||||
|
10
server.go
10
server.go
@ -9,6 +9,11 @@ import (
|
|||||||
"gopkg.in/irc.v3"
|
"gopkg.in/irc.v3"
|
||||||
)
|
)
|
||||||
|
|
||||||
|
type Logger interface {
|
||||||
|
Print(v ...interface{})
|
||||||
|
Printf(format string, v ...interface{})
|
||||||
|
}
|
||||||
|
|
||||||
type ircError struct {
|
type ircError struct {
|
||||||
Message *irc.Message
|
Message *irc.Message
|
||||||
}
|
}
|
||||||
@ -169,6 +174,7 @@ func (c *downstreamConn) handleMessageRegistered(msg *irc.Message) error {
|
|||||||
|
|
||||||
type Server struct{
|
type Server struct{
|
||||||
Hostname string
|
Hostname string
|
||||||
|
Logger Logger
|
||||||
}
|
}
|
||||||
|
|
||||||
func (s *Server) prefix() *irc.Prefix {
|
func (s *Server) prefix() *irc.Prefix {
|
||||||
@ -176,6 +182,8 @@ func (s *Server) prefix() *irc.Prefix {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (s *Server) handleConn(netConn net.Conn) error {
|
func (s *Server) handleConn(netConn net.Conn) error {
|
||||||
|
s.Logger.Printf("Handling connection from %v", netConn.RemoteAddr())
|
||||||
|
|
||||||
c := downstreamConn{net: netConn, irc: irc.NewConn(netConn), srv: s}
|
c := downstreamConn{net: netConn, irc: irc.NewConn(netConn), srv: s}
|
||||||
defer c.Close()
|
defer c.Close()
|
||||||
for {
|
for {
|
||||||
@ -185,7 +193,7 @@ func (s *Server) handleConn(netConn net.Conn) error {
|
|||||||
} else if err != nil {
|
} else if err != nil {
|
||||||
return fmt.Errorf("failed to read IRC command: %v", err)
|
return fmt.Errorf("failed to read IRC command: %v", err)
|
||||||
}
|
}
|
||||||
log.Println(msg)
|
s.Logger.Print(msg)
|
||||||
|
|
||||||
err = c.handleMessage(msg)
|
err = c.handleMessage(msg)
|
||||||
if ircErr, ok := err.(ircError); ok {
|
if ircErr, ok := err.(ircError); ok {
|
||||||
|
Loading…
Reference in New Issue
Block a user