blob: 1f0cbfc7c5c19daf348614c591c30938e3c5f086 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
|
package o1game.Server
// TODO: TLS/SSL / import javax.net.ssl.SSLServerSocketFactory
import java.io.IOException
import java.lang.Thread.sleep
import java.net.{ServerSocket, Socket}
import o1game.constants.*
/** `Server` exists to initialize a server for the game
* and run it with its method `startServer`.
*/
class Server(port: Int, maxClients: Int):
private val socket = ServerSocket(port)
private val clientGetter = ConnectionGetter(socket)
private val clients: Clients = Clients(maxClients)
private val buffer: Array[Byte] = Array.ofDim(1024)
private var bufferIndex = 0
/** Starts the server. Won't terminate under normal circumstances. */
def startServer(): Unit =
while true do
sleep(POLL_INTERVAL)
this.receiveNewClient()
this.writeToAll("Test message.")
this.readFromAll()
clients.foreach(_.executeActions())
/** Receives a new client and stores it in `clients`.
*
* @return describes if a client was added
*/
private def receiveNewClient(): Boolean =
clientGetter.newClient() match
case Some(c) =>
clients.addClient(Client(c, None))
true
case None =>
false
/** Sends `message` to all clients
*
* @param message the message to send
*/
private def writeToAll(message: String): Unit =
clients.mapAndRemove(c =>
val output = c.socket.getOutputStream
output.write(message.toVector.map(_.toByte).toArray)
output.flush()
)
/** Reads data sent by clients and stores it in the `Client`s of `clients` */
private def readFromAll(): Unit =
clients.mapAndRemove(c =>
val input = c.socket.getInputStream
while input.available() != 0 do
val bytesRead = input.read(buffer)
if bytesRead != -1 then
c.receiveData(buffer.take(bytesRead).toVector)
)
end Server
|
