src/main/java/org/eclipse/openk/api/ServiceRequestEnvelope.java

/**
******************************************************************************
* Copyright © 2018 PTA GmbH.
* All rights reserved. This program and the accompanying materials
* are made available under the terms of the Eclipse Public License v1.0
* which accompanies this distribution, and is available at
* 
*     http://www.eclipse.org/legal/epl-v10.html
* 
******************************************************************************
*/

package org.eclipse.openk.api;

import com.fasterxml.jackson.annotation.JsonProperty;
import org.apache.log4j.Logger;
import org.glassfish.jersey.internal.util.Base64;

import java.io.UnsupportedEncodingException;
import java.net.URLDecoder;

public class ServiceRequestEnvelope {
    private static final Logger logger = Logger.getLogger(ServiceRequestEnvelope.class);
    public static class HttpHeader {
        private String attribute;
        private String value;

        public String getAttribute() {
            return attribute;
        }

        public void setAttribute(String attribute) {
            this.attribute = attribute;
        }

        public String getValue() {
            return value;
        }

        public void setValue(String value) {
            this.value = value;
        }
    }

    private String serviceName;
    private String method;
    private String uriFragment;
    private String payload;
    private HttpHeader[] headers;

    @JsonProperty
    public String getServiceName() {
        return serviceName;
    }

    @JsonProperty
    public void setServiceName(String serviceName) {
        this.serviceName = serviceName;
    }

    @JsonProperty
    public String getMethod() {
        return method;
    }

    @JsonProperty
    public void setMethod(String method) {
        this.method = method;
    }

    @JsonProperty
    public String getUriFragment() {
        return uriFragment;
    }

    @JsonProperty
    public void setUriFragment(String uriFragment) {
        this.uriFragment = uriFragment;
    }

    @JsonProperty
    public String getPayload() {
        return payload;
    }

    @JsonProperty
    public void setPayload(String payload) {
        this.payload = payload;
    }

    @JsonProperty
    public HttpHeader[] getHeaders() {
        return headers;
    }

    @JsonProperty
    public void setHeaders(HttpHeader[] headers) {
        this.headers = headers;
    }

    public String getPayloadDecode() {
        if( payload != null && !payload.isEmpty()) {
            try {
                return URLDecoder.decode(Base64.decodeAsString(payload), "UTF-8");
            } catch (UnsupportedEncodingException e) {
                logger.error("Unsupported Encoding", e);
                return "";
            }
        }
        else {
            return "";
        }
    }

    public void setPayloadEncode(String payload) {
        this.payload = Base64.encodeAsString(payload);
    }
}