StoreBackEnd/pkg/network/ServerUnicast.go

package network

import (
	"_StorBackEnd/pkg/protocol"
	"bufio"
	"fmt"
	"net"
)

type ServerUnicast struct {
	Network    string
	Address    string
	ReqManager *protocol.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'))
		}
	}

}