package pl.edu.agh.dsrg.sr.protos;

import com.google.protobuf.InvalidProtocolBufferException;

import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;


public class Main {

    public static void main(String[] args) throws InvalidProtocolBufferException, InterruptedException {

        BankOperationProtos.BankOperation operation;
        DatagramSocket socket = null;

        for(int i=0;i<2000;i++) {
            operation= BankOperationProtos.BankOperation.newBuilder().setValue(Math.random()/100+1.0).setType(BankOperationProtos.BankOperation.OperationType.MULTIPLY).build();
            operation.toByteArray();
            try {
                socket = new DatagramSocket();
                InetAddress address = InetAddress.getByName("224.0.0.7");
                byte[] sendBuffer = operation.toByteArray();
                DatagramPacket sendPacket = new DatagramPacket(sendBuffer, sendBuffer.length, address, 6789);
                socket.send(sendPacket);
            } catch (Exception e) {
                e.printStackTrace();
            } finally {
                if (socket != null)
                    socket.close();
            }

            Thread.sleep((long)(Math.random()*10));
        }

    }
}