Function handleSocketClient

modes/handler.go:87–122

(conn net.Conn, engine *engine.DbEngine)

}

func handleSocketClient(conn net.Conn, engine *engine.DbEngine) {
	defer func(conn net.Conn) {
		err := conn.Close()
		if err != nil {
			log.Fatal("Error:", err)
		}
	}(conn)

	buffer := make([]byte, 2048)

	for {
		n, err := conn.Read(buffer)
		if err != nil && err.Error() != "EOF" {
			log.Fatal(err.Error())
		}
		sequences, err := bytesToSequences(buffer)

		if err != nil {
			log.Fatal(err.Error())
		}

		commandResult, err := engine.Evaluate(sequences)

		if err != nil {
			_, err = conn.Write([]byte(err.Error()))
		} else if len(commandResult) > 0 {
			_, err = conn.Write([]byte(commandResult))
		}

		if err != nil {
			log.Fatal(err.Error())
		}

		log.Printf("Received: %s\n", buffer[:n])
	}
}