Skip to content

Commit

Permalink
moved request/response objects to shetland
Browse files Browse the repository at this point in the history
  • Loading branch information
autermann committed Nov 28, 2016
1 parent 522f708 commit d689fd5
Show file tree
Hide file tree
Showing 17 changed files with 35 additions and 35 deletions.
Expand Up @@ -17,14 +17,14 @@
package org.n52.javaps.request;

import org.n52.shetland.ogc.wps.JobId;
import org.n52.iceland.request.AbstractServiceRequest;
import org.n52.shetland.ogc.ows.service.OwsServiceRequest;

/**
* TODO JavaDoc
*
* @author Christian Autermann
*/
public abstract class AbstractJobIdRequest extends AbstractServiceRequest {
public abstract class AbstractJobIdRequest extends OwsServiceRequest {

private JobId jobId;

Expand Down
Expand Up @@ -22,10 +22,10 @@
import java.util.Objects;

import org.n52.shetland.ogc.wps.WPSConstants;
import org.n52.iceland.request.AbstractServiceRequest;
import org.n52.shetland.ogc.ows.service.OwsServiceRequest;
import org.n52.shetland.ogc.ows.OwsCode;

public class DescribeProcessRequest extends AbstractServiceRequest {
public class DescribeProcessRequest extends OwsServiceRequest {
public static final String ALL_KEYWORD = "ALL";

private final List<OwsCode> identifiers = new LinkedList<>();
Expand Down
4 changes: 2 additions & 2 deletions core/src/main/java/org/n52/javaps/request/ExecuteRequest.java
Expand Up @@ -26,13 +26,13 @@
import org.n52.shetland.ogc.wps.ResponseMode;
import org.n52.shetland.ogc.wps.WPSConstants;
import org.n52.shetland.ogc.wps.data.ProcessData;
import org.n52.iceland.request.AbstractServiceRequest;
import org.n52.shetland.ogc.ows.service.OwsServiceRequest;
import org.n52.shetland.ogc.ows.OwsCode;

/**
* @author Christian Autermann
*/
public class ExecuteRequest extends AbstractServiceRequest {
public class ExecuteRequest extends OwsServiceRequest {

private OwsCode id;
private ExecutionMode executionMode = ExecutionMode.AUTO;
Expand Down
Expand Up @@ -18,15 +18,15 @@

import java.util.Objects;

import org.n52.iceland.response.AbstractServiceResponse;
import org.n52.shetland.ogc.ows.service.OwsServiceResponse;
import org.n52.shetland.ogc.wps.ProcessOfferings;
import org.n52.shetland.ogc.wps.WPSConstants;

/**
* @author Benjamin Pross
*
*/
public class DescribeProcessResponse extends AbstractServiceResponse {
public class DescribeProcessResponse extends OwsServiceResponse {

private ProcessOfferings offerings;

Expand Down
Expand Up @@ -18,14 +18,14 @@

import java.util.Objects;

import org.n52.iceland.response.AbstractServiceResponse;
import org.n52.shetland.ogc.ows.service.OwsServiceResponse;
import org.n52.shetland.ogc.wps.StatusInfo;
import org.n52.shetland.ogc.wps.WPSConstants;

/**
* @author Christian Autermann
*/
public class DismissResponse extends AbstractServiceResponse {
public class DismissResponse extends OwsServiceResponse {
private StatusInfo status;

public DismissResponse(String service, String version, StatusInfo status) {
Expand Down
Expand Up @@ -21,12 +21,12 @@
import org.n52.shetland.ogc.wps.Result;
import org.n52.shetland.ogc.wps.StatusInfo;
import org.n52.shetland.ogc.wps.WPSConstants;
import org.n52.iceland.response.AbstractServiceResponse;
import org.n52.shetland.ogc.ows.service.OwsServiceResponse;

/**
* @author Christian Autermann
*/
public class ExecuteResponse extends AbstractServiceResponse {
public class ExecuteResponse extends OwsServiceResponse {

private Optional<Result> result;
private Optional<StatusInfo> status;
Expand Down
Expand Up @@ -18,14 +18,14 @@

import java.util.Objects;

import org.n52.iceland.response.AbstractServiceResponse;
import org.n52.shetland.ogc.ows.service.OwsServiceResponse;
import org.n52.shetland.ogc.wps.Result;
import org.n52.shetland.ogc.wps.WPSConstants;

/**
* @author Christian Autermann
*/
public class GetResultResponse extends AbstractServiceResponse {
public class GetResultResponse extends OwsServiceResponse {

private Result result;

Expand Down
Expand Up @@ -18,14 +18,14 @@

import java.util.Objects;

import org.n52.iceland.response.AbstractServiceResponse;
import org.n52.shetland.ogc.ows.service.OwsServiceResponse;
import org.n52.shetland.ogc.wps.StatusInfo;
import org.n52.shetland.ogc.wps.WPSConstants;

/**
* @author Christian Autermann
*/
public class GetStatusResponse extends AbstractServiceResponse {
public class GetStatusResponse extends OwsServiceResponse {
private StatusInfo status;

public GetStatusResponse() {
Expand Down
Expand Up @@ -20,7 +20,7 @@
import java.util.Map;
import java.util.Set;

import org.n52.iceland.response.AbstractServiceResponse;
import org.n52.shetland.ogc.ows.service.OwsServiceResponse;
import org.n52.janmayen.http.MediaType;
import org.n52.janmayen.http.MediaTypes;
import org.n52.shetland.ogc.ows.exception.OwsExceptionReport;
Expand All @@ -32,7 +32,7 @@

/**
* Helper class to wrap a thrown {@link OwsExceptionReport} into a
* {@link AbstractServiceResponse}.
* {@link OwsServiceResponse}.
*
* @author Christian Autermann
*/
Expand Down
Expand Up @@ -17,14 +17,14 @@
package org.n52.svalbard.encode.stream;

import org.n52.shetland.ogc.ows.exception.OwsExceptionReport;
import org.n52.iceland.response.AbstractServiceResponse;
import org.n52.shetland.ogc.ows.service.OwsServiceResponse;

/**
* TODO JavaDoc
*
* @author Christian Autermann
*/
public class OwsExceptionReportResponse extends AbstractServiceResponse {
public class OwsExceptionReportResponse extends OwsServiceResponse {

private final OwsExceptionReport owsExceptionReport;

Expand Down
Expand Up @@ -24,7 +24,7 @@
import org.n52.iceland.coding.encode.ResponseProxy;
import org.n52.iceland.coding.encode.ResponseWriter;
import org.n52.iceland.coding.encode.ResponseWriterKey;
import org.n52.iceland.response.AbstractServiceResponse;
import org.n52.shetland.ogc.ows.service.OwsServiceResponse;
import org.n52.janmayen.http.MediaType;
import org.n52.svalbard.encode.exception.EncodingException;
import org.n52.svalbard.encode.exception.NoEncoderForKeyException;
Expand All @@ -34,8 +34,8 @@
*
* @author Christian Autermann
*/
public class StreamingServiceResponseWriter implements ResponseWriter<AbstractServiceResponse> {
public static final ResponseWriterKey KEY = new ResponseWriterKey(AbstractServiceResponse.class);
public class StreamingServiceResponseWriter implements ResponseWriter<OwsServiceResponse> {
public static final ResponseWriterKey KEY = new ResponseWriterKey(OwsServiceResponse.class);

private MediaType contentType;
private final StreamWriterRepository repository;
Expand All @@ -55,15 +55,15 @@ public void setContentType(MediaType contentType) {
}

@Override
public void write(AbstractServiceResponse t, OutputStream out, ResponseProxy responseProxy)
public void write(OwsServiceResponse t, OutputStream out, ResponseProxy responseProxy)
throws IOException, EncodingException {
StreamWriterKey key = new StreamWriterKey(t.getClass(), t.getContentType());
StreamWriter<Object> writer = repository.getWriter(key).orElseThrow(() -> new NoEncoderForKeyException(key));
writer.write(t, out);
}

@Override
public boolean supportsGZip(AbstractServiceResponse t) {
public boolean supportsGZip(OwsServiceResponse t) {
return true;
}

Expand Down
Expand Up @@ -20,7 +20,7 @@
import org.n52.iceland.binding.kvp.AbstractKvpDecoder;
import org.n52.shetland.ogc.wps.WPS200Constants;
import org.n52.shetland.ogc.wps.WPSConstants;
import org.n52.iceland.request.GetCapabilitiesRequest;
import org.n52.shetland.ogc.ows.service.GetCapabilitiesRequest;
import org.n52.janmayen.http.MediaTypes;
import org.n52.shetland.ogc.ows.OWSConstants;
import org.n52.shetland.ogc.ows.OWSConstants.GetCapabilitiesParams;
Expand Down
Expand Up @@ -18,7 +18,7 @@

import javax.inject.Inject;

import org.n52.iceland.request.AbstractServiceRequest;
import org.n52.shetland.ogc.ows.service.OwsServiceRequest;
import org.n52.iceland.request.operator.ParameterValidator;
import org.n52.javaps.engine.Engine;

Expand All @@ -27,7 +27,7 @@
*
* @author Christian Autermann
*/
public abstract class EngineParameterValidator<T extends AbstractServiceRequest> implements ParameterValidator<T> {
public abstract class EngineParameterValidator<T extends OwsServiceRequest> implements ParameterValidator<T> {

private Engine engine;

Expand Down
Expand Up @@ -17,7 +17,7 @@
package org.n52.javaps.service.operator.validation;

import org.n52.shetland.ogc.ows.exception.OwsExceptionReport;
import org.n52.iceland.request.GetCapabilitiesRequest;
import org.n52.shetland.ogc.ows.service.GetCapabilitiesRequest;
import org.n52.iceland.request.operator.ParameterValidator;

/**
Expand Down
Expand Up @@ -46,8 +46,8 @@
import org.n52.shetland.ogc.wps.data.ReferenceProcessData;
import org.n52.shetland.ogc.wps.data.ValueProcessData;
import org.n52.shetland.ogc.wps.data.impl.StringValueProcessData;
import org.n52.iceland.request.AbstractServiceRequest;
import org.n52.iceland.request.GetCapabilitiesRequest;
import org.n52.shetland.ogc.ows.service.OwsServiceRequest;
import org.n52.shetland.ogc.ows.service.GetCapabilitiesRequest;
import org.n52.javaps.request.DescribeProcessRequest;
import org.n52.javaps.request.DismissRequest;
import org.n52.javaps.request.ExecuteRequest;
Expand Down Expand Up @@ -76,7 +76,7 @@ public Set<StreamReaderKey> getKeys() {
}

@Override
public AbstractServiceRequest readElement(XMLEventReader reader)
public OwsServiceRequest readElement(XMLEventReader reader)
throws XMLStreamException {
while (reader.hasNext()) {
XMLEvent event = reader.nextEvent();
Expand Down Expand Up @@ -131,7 +131,7 @@ private JobId readJobId(StartElement elem, XMLEventReader reader)
}

private void readServiceAndVersion(StartElement elem,
AbstractServiceRequest request) {
OwsServiceRequest request) {
getAttribute(elem, WPSConstants.Attr.AN_SERVICE).ifPresent(request::setService);
getAttribute(elem, WPSConstants.Attr.AN_VERSION).ifPresent(request::setVersion);
}
Expand Down
Expand Up @@ -19,7 +19,7 @@
import javax.xml.stream.XMLStreamException;

import org.n52.svalbard.encode.stream.xml.AbstractMultiElementXmlStreamWriter;
import org.n52.iceland.response.GetCapabilitiesResponse;
import org.n52.shetland.ogc.ows.service.GetCapabilitiesResponse;
import org.n52.javaps.response.DescribeProcessResponse;
import org.n52.javaps.response.DismissResponse;
import org.n52.javaps.response.ExecuteResponse;
Expand Down
Expand Up @@ -54,7 +54,7 @@
import org.n52.shetland.ogc.wps.data.GroupProcessData;
import org.n52.shetland.ogc.wps.data.ReferenceProcessData;
import org.n52.shetland.ogc.wps.data.impl.StringValueProcessData;
import org.n52.iceland.request.GetCapabilitiesRequest;
import org.n52.shetland.ogc.ows.service.GetCapabilitiesRequest;
import org.n52.javaps.request.DescribeProcessRequest;
import org.n52.javaps.request.DismissRequest;
import org.n52.javaps.request.ExecuteRequest;
Expand Down

0 comments on commit d689fd5

Please sign in to comment.