StoreBackEnd/pkg/network/ServerUnicast.go

44 lines
827 B
Go

package network
import (
"StorBackEnd/pkg/protocol/managers"
"bufio"
"fmt"
"net"
)
type ServerUnicast struct {
Network string
Address string
ReqManager *managers.RequestManager
}
func (server ServerUnicast) Run() {
listen, err := net.Listen(server.Network, server.Address) // "tcp", "0.0.0.0:58000"
if err != nil {
fmt.Printf("Can't start server : %s\n", err)
return
}
// Attente connexion du FileFrontEnd
con, err := listen.Accept()
if err != nil {
fmt.Printf("Error while accepting client : %s\n", err)
return
} else {
for { // TODO : Extraire cette partie de code
line, err := bufio.NewReader(con).ReadString('\n')
if err != nil {
return
}
result := server.ReqManager.Execute(line)
con.Write(append([]byte(result), '\n')) // TODO : ATTENTION laisser les \n
}
}
}