// This sample is only a snippet, the complete code for a client can be found in the Registry service repository.

import modellibrary.RequestInfo;
import modellibrary.ResponseInfo;

public class RegistryCoreClient implements NodeConnectionListener {
    @Override
    public void connected(NodeConnection remoteCon) {
        // REQUEST send
        JSONObject xresult = new JSONObject();
        JSONObject xinfo = new JSONObject();

        try {
            xresult.put("uuid", "987654321");
            xresult.put("name", "mynode");
            xinfo.put("email", "mynode@example.com");
            xinfo.put("city", "Rio de Janeiro");
            xinfo.put("phone", "555-555-555");
            xinfo.put("birthday", "01/01/1970");
            xinfo.put("pass", "password");
            xresult.put("info", xinfo.toString());
        } catch (JSONException e1) {
            e1.printStackTrace();
        }

        ApplicationMessage appMessage4 = new ApplicationMessage();
        RequestInfo requestMessage4 = new RequestInfo(
                appMessage4.getSenderID(), "addNode", xresult.toString());
        appMessage4.setContentObject(requestMessage4);
        try {
            remoteCon.sendMessage(appMessage4);
        } catch (IOException e) {
            e.printStackTrace();
        }

        ApplicationMessage appMessage1 = new ApplicationMessage();
        RequestInfo requestMessage1 = new RequestInfo(
                appMessage1.getSenderID(), "lstNodes", "");
        appMessage1.setContentObject(requestMessage1);
        try {
            remoteCon.sendMessage(appMessage1);
        } catch (IOException e) {
            e.printStackTrace();
        }

        ApplicationMessage appMessage2 = new ApplicationMessage();
        RequestInfo requestMessage2 = new RequestInfo(
                appMessage2.getSenderID(), "srchNodes", "myn");
        appMessage2.setContentObject(requestMessage2);
        try {
            remoteCon.sendMessage(appMessage2);
        } catch (IOException e) {
            e.printStackTrace();
        }

        ApplicationMessage appMessage3 = new ApplicationMessage();
        RequestInfo requestMessage3 = new RequestInfo(
                appMessage3.getSenderID(), "getNode", "mynode");
        appMessage3.setContentObject(requestMessage3);
        try {
            remoteCon.sendMessage(appMessage3);
        } catch (IOException e) {
            e.printStackTrace();
        }

        ApplicationMessage appMessage5 = new ApplicationMessage();
        RequestInfo requestMessage5 = new RequestInfo(
                appMessage5.getSenderID(), "delNode", "mynode");
        appMessage5.setContentObject(requestMessage5);
        try {
            remoteCon.sendMessage(appMessage5);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    @Override
    public void newMessageReceived(NodeConnection remoteCon, Message message) {
        String className = message.getContentObject().getClass()
                .getCanonicalName();

        if (className != null) {
            // RESPONSE recv
            if (className.equals(ResponseInfo.class.getCanonicalName())) {
                ResponseInfo responseMessage = (ResponseInfo) Serialization
                        .fromJavaByteStream(message.getContent());
                System.out.println("[RegistryCoreClient] Response type: "
                        + responseMessage.getType() + " | payload: "
                        + responseMessage.getPayload());
            } else {
                System.out
                        .println("[RegistryCoreClient] Objeto desconhecido recebido do servidor: "
                                + className);
            }
        }
    }
}