sdis1819-t7g06

package Message;

import Peers.Peer;

import java.net.DatagramPacket;

public class WorkMessage implements Runnable {

    private Message packet;

    private Peer peer;

    public WorkMessage(DatagramPacket packet, Peer peer) {

        try {

            this.packet = new Message(packet);

            System.out.println("Received " + this.packet.getType().toString() + " Packet");

        } catch (Exception e) {

            //e.printStackTrace();

        }

        this.peer = peer;

    }

    @Override

    public void run() {

        switch (packet.getType()) {

            case CHUNK:

                peer.getControl().chunkControl(packet);

                break;

            case DELETE:

                peer.getControl().deleteControl(packet);

                break;

            case STORED:

                peer.getControl().storedControl(packet);

                break;

            case GETCHUNK:

                peer.getControl().getchunkControl(packet);

                break;

            case REMOVED:

                peer.getControl().removedControl(packet);

                break;

            case PUTCHUNK:

                peer.getControl().putchunkControl(packet);

                break;

        }

    }

}