Backup à casa

import javax.xml.crypto.Data;
import java.awt.*;
import java.io.Serializable;
import java.net.MulticastSocket;
import java.net.DatagramPacket;
import java.net.InetAddress;
import java.io.IOException;
import java.net.Socket;
import java.sql.SQLOutput;
import java.util.ArrayList;
import java.util.Scanner;
import java.io.*;
import static java.lang.Thread.sleep;

class User implements Serializable {
    private String username, password;

    public User(String username, String password) {
        this.username = username;
        this.password = password;
    }

    public String getUsername() {
        return username;
    }

    public String getPassword() {
        return password;
    }
}

class DatabaseConnection  {
    //Estudar ficheiros de texto e de objetos
    //Rever projeto de POO
    //Ver como ir buscar a música a uma diretoria e colocar música nessa diretoria

}



class UDPMulticastProtocol implements Serializable {

    public UDPMulticastProtocol() {

    }

    // De acordo com o tipo de argumento no primeiro campo (type)
    //vamos definir a operacao pretendida e vai ser invocado o respetivo método

    //Acho que vou ter que responder a cada mensagem, mas para enviar o pacote tenho que ver onde

    void login (String username, String password){
        System.out.println("O cliente deseja fazer login");
        System.out.println("Username inserido: " + username);
        System.out.println("Password inserida: " + password);
        //Temos que ir à base de dados checkar se o username existe e qual a password associada e se é igual à inserida ou não
        //username_match(username);
        //password_match(password);

    }

    void register (String username, String password){
        //ArrayList que contém todos os utilizadores
        ArrayList <User> users = new ArrayList<>();

        System.out.println("O cliente deseja registar-se");
        System.out.println("Username inserido: " + username);
        System.out.println("Password inserida: " + password);
        //Temos que ver se existe o username ou não
        //username_match(username);

        //Abrir para escrita no ficheiro de objetos
        User u = new User(username, password);
        users.add(u);
        try{
            ObjectOutputStream oS = new ObjectOutputStream(new FileOutputStream("Users_obj.txt"));
            oS.writeObject(users);
            oS.close();

        }catch(IOException e){
            System.out.print("ERRO");
            System.out.printf("Ocorreu a exceçao %s ao escrever no ficheiro\n", e);
    }

        //Abrir para a leitura do ficheiro de objetos

        try (ObjectInputStream oin = new ObjectInputStream (new FileInputStream("Users_obj.txt"))) {
            users = (ArrayList) oin.readObject();
            //}catch(IOException | ClassNotFoundException e){
        } catch (IOException e){
            System.out.println(e.getMessage());
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        }

        for (User us : users){
            System.out.println(us.getUsername() + " " + us.getPassword());
        }


    }

    void search_music (){
        System.out.println("O cliente deseja procurar musica");

    }

    void make_editor (String novo_editor){
        System.out.println("O cliente deseja tornar o utilizador " + novo_editor + " editor");

        //É primeiro necessário verificar se o utilizador que está a querer tornar o outro num editor é também um editor
    }

    void manage_data (){
        System.out.println("O cliente pretende gerir artistas, álbuns e músicas");
    }

    void search_info (){
        System.out.println("O cliente pretende consultar detalhes sobre álbum e sobre artista");
    }

    void album_review (){
        System.out.println("O cliente pretende escrever uma crítica a um álbum");
    }

    void download (){
        System.out.println("O cliente quer fazer download de uma música");
    }

    void upload (){
        System.out.println("O cliente quer fazer upload de uma música");
    }

    void share_music (){
        System.out.println("O cliente pretende partilhar música com outros utilizadores");
    }

}


class AnswerRequests extends Thread {

    private String MULTICAST_ADDRESS = "224.3.2.1";
    private int PORT = 4444; //Porto de envio
    private String message;
    private String ip;
    private int porto;

    public AnswerRequests(String message, String ip, int porto) {
        this.message = message;
        this.ip = ip;
        this.porto = porto;
    }


    public String [] MessageParsing (String message){

        //Separar por ";" e saber o número de pares
        String [] pares  = message.split(";");
        String  [] campos = new String[pares.length] ;

        if (pares.length >= 3){
            for (int i = 0; i < pares.length; i++){
                String [] aux = pares[i].split("\\|");
                campos[i] = aux[1];
            }
        }

        //É melhor imprimir num ciclo que vai ate ao total de elementos do array, caso contrario opde criar exception
        //System.out.println ("Tipo da mensagem: " + campos[0] + " campo2: " + campos[1] + " campo3: " + campos[2]);

        return campos;
    }


    public void run(){

        System.out.println("Mensagem do cliente (IP: " + ip + ";Porto: " + porto + ")" + ": " + message);
        //Enviar resposta para o cliente
        MulticastSocket socket = null;

        //Parsing da mensagem
        String [] pares = MessageParsing(message);

        /*for (int i = 0; i < pares.length; i++){
            System.out.println (pares[i]);
        }*/

        UDPMulticastProtocol prot = new UDPMulticastProtocol(); //Ver se é aqui que devo chamar o construtor ou não

        //Trata do pedido para depois enviar a resposta para o cliente
        if (pares[0].equals("login")){
            prot.login(pares[1], pares[2]);
        }
        else if (pares[0].equals("search music")){
            prot.search_music();
        }
        else if (pares[0].equals("make editor")){
            prot.make_editor(pares[1]);
        }
        else if (pares[0].equals("register")){
            prot.register(pares[1], pares[2]);
        }


        try{
            socket = new MulticastSocket(); //Não é necessário dar bind porque está apenas a enviar
            socket.setTimeToLive(1);

            Scanner keyboardScaner = new Scanner(System.in);
            while (true){
                String keyboard = keyboardScaner.nextLine();
                byte[] buffer = keyboard.getBytes();

                InetAddress group = InetAddress.getByName(MULTICAST_ADDRESS);
                DatagramPacket packet = new DatagramPacket(buffer, buffer.length, InetAddress.getByName(MULTICAST_ADDRESS), PORT); //mudei aqui
                socket.send(packet);
            }
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            socket.close();
        }




    }

}

public class MulticastServer extends Thread {

    private String MULTICAST_ADDRESS = "224.3.2.1";
    private int PORT = 4321; //Porto de recepção
    private int BUFFER_SIZE = 4096;

    public static void main(String[] args) {
        MulticastServer server = new MulticastServer();
        server.start(); //Ao invocar o start da thread, estamos a chamar o metodo run()
    }

    public MulticastServer() {
        super ("Server Multicast #" + (long) (Math.random() * 100));
    }

    public void run(){
        MulticastSocket socket = null;

        System.out.println(this.getName() + " running..."); //Vai buscar o que está dentro do método do construtor

        try {
            socket = new MulticastSocket(PORT); //cria socket e dá bind
            InetAddress group = InetAddress.getByName(MULTICAST_ADDRESS);
            socket.joinGroup(group); //dá join ao grupo multicast


            while (true) {
                //Recepcao
                byte[] inBuffer = new byte[BUFFER_SIZE];
                DatagramPacket msgIn = new DatagramPacket(inBuffer, inBuffer.length);
                socket.receive(msgIn); //Recebe o datagrama UDP

                String clientIP = msgIn.getAddress().getHostAddress(); //Endereço IP do cliente que enviou a mensagem
                int clientport = msgIn.getPort(); //Porto do cliente

                //System.out.println("Received packet from IP " + clientIP + "; Port number -> " + clientport + " with message:");
                String message = new String(msgIn.getData(), 0, msgIn.getLength());
                //System.out.println("Mensagem recebida: " + message);

                //Vai buscar a informação da mensagem e lança a thread para tratar do pedido
                AnswerRequests work = new AnswerRequests(message, clientIP , clientport);
                work.start();

            }

        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            socket.close(); //Fechar a socket
        }
    }

}

//Outra forma de "descompactar" o pacote recebido
//System.out.println("Mensagem recebida: " + new String(inBuffer, 0, inBuffer.length));


//socket.joinGroup(group);
//socket.setTimeToLive(1);

//Envio
/*String msg = this.getName() + "is giving you an warm welcome!";
byte[] buffer = msg.getBytes();

//InetAddress group = InetAddress.getByName(MULTICAST_ADDRESS); //Vou mandar um print, mas acho que isto vai buscar o endereço Multicast
DatagramPacket packet = new DatagramPacket(buffer, buffer.length, group, PORT);
socket.send(packet);

try { sleep((long) (Math.random() * PAUSE)); } catch (InterruptedException e ){} //Não irá ser necessário
*/