client.java

/*
 * To change this license header, choose License Headers in Project Properties.
 * To change this template file, choose Tools | Templates
 * and open the template in the editor.
 */
package fxmlimageborderpane;

import java.awt.TrayIcon.MessageType;
import java.awt.image.BufferedImage;
import java.awt.image.DataBufferByte;
import java.io.BufferedOutputStream;
import java.io.BufferedReader;
import java.io.ByteArrayOutputStream;
import java.io.DataOutputStream;
import java.io.File;
import java.io.FileOutputStream;
import java.io.FileReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
import java.rmi.server.Operation;
import java.util.ArrayList;
import java.util.logging.Level;
import java.util.logging.Logger;
import javafx.scene.image.Image;
import javax.imageio.ImageIO;
import javax.net.ssl.SSLEngineResult.Status;
//import org.json.simple.JSONObject;
//import org.json.simple.parser.JSONParser;
//import org.json.simple.parser.ParseException;

/**
 *
 * @author ArteneR
 */
public class Client {

    private static final String JSON_FILES_PATH = "json/";
    private static int PORT = 5012;
    private static String SERVER = "raspberrypi.local";//IP-ul PI0ului
    private Socket clientSocket;
    private static PrintWriter outToServer;
    private static BufferedReader inFromServer;
    private static InputStream is;
    private static DataOutputStream os;
    private BufferedReader inFromUser;
    private String messageToSend;
    private String messageReceived;
    private static String username = "picture";
    private static String userID;
    private static String status;
    private static Image userPhoto;
    private static final int BUFFER_SIZE = 10240;

    public Client() {
//                JSONParser parser = new JSONParser();
        try {
//                        Object obj = parser.parse(new FileReader(JSON_FILES_PATH + "config.json"));
//                        JSONObject jsonObject = (JSONObject) obj;

            System.out.println("Port: " + PORT + "\nServer: " + SERVER);

            System.out.println("Creating new Client...");
            clientSocket = new Socket(SERVER, PORT);

            inFromServer = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
            outToServer = new PrintWriter(clientSocket.getOutputStream(), true);
            is = clientSocket.getInputStream();
            os = new DataOutputStream(clientSocket.getOutputStream());


        } catch (IOException ex) {
            Logger.getLogger(Client.class.getName()).log(Level.SEVERE, null, ex);
        }
    }

    /**
     * messageType: can be: MESSAGE - regular message CLOSE_CONNECTION - message
     * for closing connection message: is the actual message to be sent
     * receiver: the username of the message receiver OR the name of the
     * conference
	 *
     */
    public static void sendQuery(String messageType, String operation, String params) throws IOException {
                System.out.println(messageType + ":" + operation + ":" + params);
                outToServer.println(messageType + ":" + operation + ":" + params);
                System.out.println("Query message sent!");
        }
    public static String waitForResponse() throws IOException {//astept ceva de la server
        System.out.println("waiting..");
        String response = inFromServer.readLine();
        System.out.println("Response from server: " + response);
        return response;
    }
//de masurat pe server: timpul de procesare a imaginii(clock cycles) si memory footprint
    public static byte[] waitForFileBytes() throws IOException, InterruptedException {
        byte[] allReceivedBytes = new byte[0];
        byte[] readBytes = new byte[BUFFER_SIZE];
        byte[] enlargedAllReceivedBytes;

        FileOutputStream fos = new FileOutputStream(username + ".png");
        BufferedOutputStream bos = new BufferedOutputStream(fos);

        int bytesRead;
        int totalBytes = 0;
        while ((bytesRead = is.read(readBytes, 0, readBytes.length)) > 0) {
            String message = new String(readBytes, "UTF-8");
            if (message.contains(":")) {
                String messageType = message.substring(0, message.indexOf(":"));
                if (messageType.equals("RESPONSE_SUCCESS")) {
                    break;
                }
            }
            enlargedAllReceivedBytes = new byte[allReceivedBytes.length + BUFFER_SIZE];
            for (int i = 0; i < allReceivedBytes.length; i++) {
                enlargedAllReceivedBytes[i] = allReceivedBytes[i];
            }
            for (int i = 0, j = allReceivedBytes.length; j < enlargedAllReceivedBytes.length; i++, j++) {
                enlargedAllReceivedBytes[j] = readBytes[i];
            }
            allReceivedBytes = new byte[allReceivedBytes.length + BUFFER_SIZE];
            System.arraycopy(enlargedAllReceivedBytes, 0, allReceivedBytes, 0, enlargedAllReceivedBytes.length);

            totalBytes += bytesRead;
            readBytes = new byte[BUFFER_SIZE];
            outToServer.println("ACKNOWLEDGE" + ":" + Status.OK);
        }
        bos.write(allReceivedBytes, 0, totalBytes);
        bos.flush();
        fos.close();

        return allReceivedBytes;
    }

}