UDPServerThreadTest.groovy

package sk.vsds.udp

import sk.vsds.udp.processor.MessageProcessor
import spock.lang.Specification

/**
 * Tests {@link UDPServerThread}.
 *
 * @author Dominik Matta
 * @since 1.0
 */
class UDPServerThreadTest extends Specification {

    UDPServerThread udpServerThread
    DatagramSocket socket
    MessageProcessor processor

    def setup() {
        socket = Stub(DatagramSocket)
        processor = Mock(MessageProcessor)
        udpServerThread = new UDPServerThread(socket, processor)
    }

    def "received data should be sent to message processor"() {
        given:
        byte[] message = "Hello World!".getBytes()
        socket.receive(_) >> { DatagramPacket p ->
            p.data = message
        } >> { udpServerThread.stop() }

        when:
        udpServerThread.start()
        sleep(1000)

        then:
        1 * processor.process(message)
    }
}