FlowStatusResponseTest.java

Go to the documentation of this file.

package org.openkilda.messaging.info.flow;

import com.fasterxml.jackson.core.JsonProcessingException;
import org.junit.Assert;
import org.junit.Test;
import org.openkilda.messaging.Destination;
import org.openkilda.messaging.info.InfoMessage;
import org.openkilda.messaging.payload.flow.FlowIdStatusPayload;
import org.openkilda.messaging.payload.flow.FlowState;

import java.io.IOException;

import static org.openkilda.messaging.Utils.MAPPER;


public class FlowStatusResponseTest {

    /*
     * JSON: {  "clazz":"org.openkilda.messaging.info.InfoMessage",
     *          "destination":"NORTHBOUND",
     *          "payload":{
     *              "clazz":"org.openkilda.messaging.info.flow.FlowStatusResponse",
     *              "payload":{
     *                  "flowid":"FLOW",
     *                  "status":"UP"},
     *              "timestamp":1520475170274},
     *          "timestamp":10,
     *          "correlation_id":"CORRELATION"}

     */

    private final String json = "{" +
            "\"clazz\":\"org.openkilda.messaging.info.InfoMessage\"," +
            "\"destination\":\"NORTHBOUND\"," +
            "\"payload\":{" +
                "\"clazz\":\"org.openkilda.messaging.info.flow.FlowStatusResponse\"," +
                "\"payload\":{" +
                    "\"flowid\":\"FLOW\"," +
                    "\"status\":\"UP\"}," +
                "\"timestamp\":1520474258050}," +
            "\"timestamp\":10," +
            "\"correlation_id\":\"CORRELATION\"}";

    @Test
    public void testJsonSerialization() throws IOException {
        /*
         * Start with serializing to JSON.
         * Then re-populate from JSON.
         */
        InfoMessage msg = new InfoMessage(new FlowStatusResponse(new FlowIdStatusPayload("FLOW", FlowState.UP)), 10L,"CORRELATION", Destination.NORTHBOUND);

        InfoMessage fromJson = MAPPER.readValue(json, InfoMessage.class);
        FlowStatusResponse fsrJson = (FlowStatusResponse) fromJson.getData();
        FlowStatusResponse fsrObj = (FlowStatusResponse) msg.getData();

        Assert.assertEquals(fsrJson.getPayload().getId(), fsrObj.getPayload().getId());
        Assert.assertEquals(fsrJson.getPayload().getStatus(), fsrObj.getPayload().getStatus());
        Assert.assertEquals(fsrJson.getPayload().getStatus(), FlowState.UP);
        Assert.assertEquals(fromJson.getCorrelationId(), msg.getCorrelationId());


        System.out.println("JSON: " + MAPPER.writeValueAsString(msg));
    }
}