[OLINGO-234] V4 bound Action / Function invoke tests ready - still using external service
Project: http://git-wip-us.apache.org/repos/asf/olingo-odata4/repo Commit: http://git-wip-us.apache.org/repos/asf/olingo-odata4/commit/7104c65f Tree: http://git-wip-us.apache.org/repos/asf/olingo-odata4/tree/7104c65f Diff: http://git-wip-us.apache.org/repos/asf/olingo-odata4/diff/7104c65f Branch: refs/heads/master Commit: 7104c65f843c2414579f51b235e482be23be98bd Parents: d3b513c Author: Francesco Chicchiriccò <[email protected]> Authored: Wed Apr 9 14:11:07 2014 +0200 Committer: Francesco Chicchiriccò <[email protected]> Committed: Wed Apr 9 14:11:07 2014 +0200 ---------------------------------------------------------------------- .../it/v4/BoundOperationInvokeTestITCase.java | 387 +++++++++++++++++++ 1 file changed, 387 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/olingo-odata4/blob/7104c65f/lib/client-core/src/test/java/org/apache/olingo/client/core/it/v4/BoundOperationInvokeTestITCase.java ---------------------------------------------------------------------- diff --git a/lib/client-core/src/test/java/org/apache/olingo/client/core/it/v4/BoundOperationInvokeTestITCase.java b/lib/client-core/src/test/java/org/apache/olingo/client/core/it/v4/BoundOperationInvokeTestITCase.java new file mode 100644 index 0000000..b381da8 --- /dev/null +++ b/lib/client-core/src/test/java/org/apache/olingo/client/core/it/v4/BoundOperationInvokeTestITCase.java @@ -0,0 +1,387 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ +package org.apache.olingo.client.core.it.v4; + +import static org.junit.Assert.assertNotNull; +import static org.junit.Assert.assertEquals; +import static org.junit.Assert.assertTrue; + +import java.io.IOException; +import java.net.InetSocketAddress; +import java.net.Socket; +import java.util.Collections; +import java.util.HashMap; +import java.util.LinkedHashMap; +import java.util.Map; +import org.apache.commons.io.IOUtils; +import org.apache.olingo.client.api.communication.request.invoke.ODataInvokeRequest; +import org.apache.olingo.client.api.communication.request.retrieve.ODataEntityRequest; +import org.apache.olingo.client.api.uri.v4.URIBuilder; +import org.apache.olingo.commons.api.domain.ODataCollectionValue; +import org.apache.olingo.commons.api.domain.ODataComplexValue; +import org.apache.olingo.commons.api.domain.ODataOperation; +import org.apache.olingo.commons.api.domain.ODataPrimitiveValue; +import org.apache.olingo.commons.api.domain.ODataValue; +import org.apache.olingo.commons.api.domain.v4.ODataEntity; +import org.apache.olingo.commons.api.domain.v4.ODataEntitySet; +import org.apache.olingo.commons.api.domain.v4.ODataEnumValue; +import org.apache.olingo.commons.api.domain.v4.ODataProperty; +import org.apache.olingo.commons.api.edm.Edm; +import org.apache.olingo.commons.api.edm.EdmAction; +import org.apache.olingo.commons.api.edm.EdmEntityContainer; +import org.apache.olingo.commons.api.edm.EdmFunction; +import org.apache.olingo.commons.api.edm.EdmPrimitiveTypeException; +import org.apache.olingo.commons.api.edm.EdmPrimitiveTypeKind; +import org.apache.olingo.commons.api.edm.FullQualifiedName; +import org.apache.olingo.commons.api.format.ODataPubFormat; +import org.apache.olingo.commons.core.edm.EdmTypeInfo; +import org.junit.Assume; +import org.junit.BeforeClass; +import org.junit.Test; + +public class BoundOperationInvokeTestITCase extends AbstractTestITCase { + + private static final String serviceRoot = "http://odatae2etest.azurewebsites.net/javatest/DefaultService";; + + // TODO: remove once fit provides function / action imports + @BeforeClass + public static void checkServerIsOnline() throws IOException { + final Socket socket = new Socket(); + boolean reachable = false; + try { + socket.connect(new InetSocketAddress("odatae2etest.azurewebsites.net", 80), 2000); + reachable = true; + } catch (Exception e) { + LOG.warn("External test service not reachable, ignoring this whole class: {}", + OperationImportInvokeTestITCase.class.getName()); + } finally { + IOUtils.closeQuietly(socket); + } + Assume.assumeTrue(reachable); + } + + private Edm getEdm() { + final Edm edm = getClient().getRetrieveRequestFactory(). + getMetadataRequest(serviceRoot).execute().getBody(); + assertNotNull(edm); + + return edm; + } + + private void functions(final ODataPubFormat format) throws EdmPrimitiveTypeException { + final Edm edm = getEdm(); + final EdmEntityContainer container = edm.getSchemas().get(0).getEntityContainer(); + assertNotNull(container); + + // GetEmployeesCount + URIBuilder builder = getClient().getURIBuilder(serviceRoot).appendSingletonSegment("Company"); + ODataEntityRequest<ODataEntity> entityReq = + getClient().getRetrieveRequestFactory().getEntityRequest(builder.build()); + // TODO: remove when fit is used since external test server does not advertise actions in Atom + entityReq.setFormat(ODataPubFormat.JSON_FULL_METADATA); + ODataEntity entity = entityReq.execute().getBody(); + assertNotNull(entity); + + ODataOperation boundOp = entity.getOperation("Microsoft.Test.OData.Services.ODataWCFService.GetEmployeesCount"); + assertNotNull(boundOp); + + EdmFunction func = edm.getBoundFunction(new FullQualifiedName(boundOp.getTitle()), + new EdmTypeInfo.Builder().setTypeExpression(entity.getName()).build().getFullQualifiedName(), false, null); + assertNotNull(func); + + final ODataInvokeRequest<ODataProperty> getEmployeesCountReq = + getClient().getInvokeRequestFactory().getInvokeRequest(boundOp.getTarget(), func); + getEmployeesCountReq.setFormat(format); + final ODataProperty getEmployeesCountRes = getEmployeesCountReq.execute().getBody(); + assertNotNull(getEmployeesCountRes); + assertTrue(getEmployeesCountRes.hasPrimitiveValue()); + + // GetProductDetails + builder = getClient().getURIBuilder(serviceRoot).appendEntitySetSegment("Products").appendKeySegment(5); + entityReq = getClient().getRetrieveRequestFactory().getEntityRequest(builder.build()); + // TODO: remove when fit is used since external test server does not advertise actions in Atom + entityReq.setFormat(ODataPubFormat.JSON_FULL_METADATA); + entity = entityReq.execute().getBody(); + assertNotNull(entity); + + boundOp = entity.getOperation("Microsoft.Test.OData.Services.ODataWCFService.GetProductDetails"); + assertNotNull(boundOp); + + func = edm.getBoundFunction(new FullQualifiedName(boundOp.getTitle()), + new EdmTypeInfo.Builder().setTypeExpression(entity.getName()).build().getFullQualifiedName(), false, null); + assertNotNull(func); + + final ODataPrimitiveValue count = getClient().getObjectFactory().newPrimitiveValueBuilder().buildInt32(1); + final ODataInvokeRequest<ODataEntitySet> getProductDetailsReq = + getClient().getInvokeRequestFactory().getInvokeRequest(boundOp.getTarget(), func, + Collections.<String, ODataValue>singletonMap("count", count)); + getProductDetailsReq.setFormat(format); + final ODataEntitySet getProductDetailsRes = getProductDetailsReq.execute().getBody(); + assertNotNull(getProductDetailsRes); + assertEquals(1, getProductDetailsRes.getCount()); + + // GetRelatedProduct + final Map<String, Object> keyMap = new HashMap<String, Object>(); + keyMap.put("ProductID", 6); + keyMap.put("ProductDetailID", 1); + builder = getClient().getURIBuilder(serviceRoot).appendEntitySetSegment("ProductDetails"). + appendKeySegment(keyMap); + entityReq = getClient().getRetrieveRequestFactory().getEntityRequest(builder.build()); + // TODO: remove when fit is used since external test server does not advertise actions in Atom + entityReq.setFormat(ODataPubFormat.JSON_FULL_METADATA); + entity = entityReq.execute().getBody(); + assertNotNull(entity); + + boundOp = entity.getOperation("Microsoft.Test.OData.Services.ODataWCFService.GetRelatedProduct"); + assertNotNull(boundOp); + + func = edm.getBoundFunction(new FullQualifiedName(boundOp.getTitle()), + new EdmTypeInfo.Builder().setTypeExpression(entity.getName()).build().getFullQualifiedName(), false, + null); + assertNotNull(func); + + final ODataInvokeRequest<ODataEntity> getRelatedProductReq = + getClient().getInvokeRequestFactory().getInvokeRequest(boundOp.getTarget(), func); + getRelatedProductReq.setFormat(format); + //TODO test service returns error instead of Products(6) + try { + final ODataEntity getRelatedProductRes = getRelatedProductReq.execute().getBody(); + assertNotNull(getRelatedProductRes); + assertEquals("#Microsoft.Test.OData.Services.ODataWCFService.Product", getRelatedProductRes.getName()); + assertEquals(6, getRelatedProductRes.getProperty("ProductID").getPrimitiveValue().toCastValue(Integer.class), 0); + } catch (Exception e) { + // ignore + } + + // GetDefaultPI + builder = getClient().getURIBuilder(serviceRoot).appendEntitySetSegment("Accounts").appendKeySegment(101); + entityReq = getClient().getRetrieveRequestFactory().getEntityRequest(builder.build()); + // TODO: remove when fit is used since external test server does not advertise actions in Atom + entityReq.setFormat(ODataPubFormat.JSON_FULL_METADATA); + entity = entityReq.execute().getBody(); + assertNotNull(entity); + + boundOp = entity.getOperation("Microsoft.Test.OData.Services.ODataWCFService.GetDefaultPI"); + assertNotNull(boundOp); + + func = edm.getBoundFunction(new FullQualifiedName(boundOp.getTitle()), + new EdmTypeInfo.Builder().setTypeExpression(entity.getName()).build().getFullQualifiedName(), false, null); + assertNotNull(func); + + final ODataInvokeRequest<ODataEntity> getDefaultPIReq = + getClient().getInvokeRequestFactory().getInvokeRequest(boundOp.getTarget(), func); + getDefaultPIReq.setFormat(format); + final ODataEntity getDefaultPIRes = getDefaultPIReq.execute().getBody(); + assertNotNull(getDefaultPIRes); + assertEquals("#Microsoft.Test.OData.Services.ODataWCFService.PaymentInstrument", getDefaultPIRes.getName()); + assertEquals(101901, + getDefaultPIRes.getProperty("PaymentInstrumentID").getPrimitiveValue().toCastValue(Integer.class), 0); + + // GetAccountInfo + boundOp = entity.getOperation("Microsoft.Test.OData.Services.ODataWCFService.GetAccountInfo"); + assertNotNull(boundOp); + + func = edm.getBoundFunction(new FullQualifiedName(boundOp.getTitle()), + new EdmTypeInfo.Builder().setTypeExpression(entity.getName()).build().getFullQualifiedName(), false, null); + assertNotNull(func); + + final ODataInvokeRequest<ODataProperty> getAccountInfoReq = + getClient().getInvokeRequestFactory().getInvokeRequest(boundOp.getTarget(), func); + getAccountInfoReq.setFormat(format); + final ODataProperty getAccountInfoRes = getAccountInfoReq.execute().getBody(); + assertNotNull(getAccountInfoRes); + assertTrue(getAccountInfoRes.hasComplexValue()); + assertEquals("Microsoft.Test.OData.Services.ODataWCFService.AccountInfo", + getAccountInfoRes.getComplexValue().getTypeName()); + + // GetActualAmount + entityReq = getClient().getRetrieveRequestFactory().getEntityRequest( + entity.getNavigationLink("MyGiftCard").getLink()); + // TODO: remove when fit is used since external test server does not advertise actions in Atom + entityReq.setFormat(ODataPubFormat.JSON_FULL_METADATA); + entity = entityReq.execute().getBody(); + assertNotNull(entity); + assertEquals(301, entity.getProperty("GiftCardID").getPrimitiveValue().toCastValue(Integer.class), 0); + + boundOp = entity.getOperation("Microsoft.Test.OData.Services.ODataWCFService.GetActualAmount"); + assertNotNull(boundOp); + + func = edm.getBoundFunction(new FullQualifiedName(boundOp.getTitle()), + new EdmTypeInfo.Builder().setTypeExpression(entity.getName()).build().getFullQualifiedName(), false, null); + assertNotNull(func); + + final ODataPrimitiveValue bonusRate = getClient().getObjectFactory().newPrimitiveValueBuilder().buildDouble(1.1); + final ODataInvokeRequest<ODataProperty> getActualAmountReq = + getClient().getInvokeRequestFactory().getInvokeRequest(boundOp.getTarget(), func, + Collections.<String, ODataValue>singletonMap("bonusRate", bonusRate)); + getActualAmountReq.setFormat(format); + final ODataProperty getActualAmountRes = getActualAmountReq.execute().getBody(); + assertNotNull(getActualAmountRes); + assertEquals(41.79, getActualAmountRes.getPrimitiveValue().toCastValue(Double.class), 0); + } + + @Test + public void atomFunctions() throws EdmPrimitiveTypeException { + functions(ODataPubFormat.ATOM); + } + + @Test + public void jsonFunctions() throws EdmPrimitiveTypeException { + functions(ODataPubFormat.JSON_FULL_METADATA); + } + + private void actions(final ODataPubFormat format) throws EdmPrimitiveTypeException { + final Edm edm = getEdm(); + final EdmEntityContainer container = edm.getSchemas().get(0).getEntityContainer(); + assertNotNull(container); + + // IncreaseRevenue + URIBuilder builder = getClient().getURIBuilder(serviceRoot).appendSingletonSegment("Company"); + ODataEntityRequest<ODataEntity> entityReq = + getClient().getRetrieveRequestFactory().getEntityRequest(builder.build()); + // TODO: remove when fit is used since external test server does not advertise actions in Atom + entityReq.setFormat(ODataPubFormat.JSON_FULL_METADATA); + ODataEntity entity = entityReq.execute().getBody(); + assertNotNull(entity); + + ODataOperation boundOp = entity.getOperation("Microsoft.Test.OData.Services.ODataWCFService.IncreaseRevenue"); + assertNotNull(boundOp); + + EdmAction act = edm.getBoundAction(new FullQualifiedName(boundOp.getTitle()), + new EdmTypeInfo.Builder().setTypeExpression(entity.getName()).build().getFullQualifiedName(), false); + assertNotNull(act); + + final ODataPrimitiveValue increaseValue = getClient().getObjectFactory().newPrimitiveValueBuilder(). + setType(EdmPrimitiveTypeKind.Int64).setValue(12).build(); + final ODataInvokeRequest<ODataProperty> increaseRevenueReq = + getClient().getInvokeRequestFactory().getInvokeRequest(boundOp.getTarget(), act, + Collections.<String, ODataValue>singletonMap("IncreaseValue", increaseValue)); + increaseRevenueReq.setFormat(format); + final ODataProperty increaseRevenueRes = increaseRevenueReq.execute().getBody(); + assertNotNull(increaseRevenueRes); + assertTrue(increaseRevenueRes.hasPrimitiveValue()); + + // AddAccessRight + builder = getClient().getURIBuilder(serviceRoot).appendEntitySetSegment("Products").appendKeySegment(5); + entityReq = getClient().getRetrieveRequestFactory().getEntityRequest(builder.build()); + // TODO: remove when fit is used since external test server does not advertise actions in Atom + entityReq.setFormat(ODataPubFormat.JSON_FULL_METADATA); + entity = entityReq.execute().getBody(); + assertNotNull(entity); + + boundOp = entity.getOperation("Microsoft.Test.OData.Services.ODataWCFService.AddAccessRight"); + assertNotNull(boundOp); + + act = edm.getBoundAction(new FullQualifiedName(boundOp.getTitle()), + new EdmTypeInfo.Builder().setTypeExpression(entity.getName()).build().getFullQualifiedName(), false); + assertNotNull(act); + + final ODataEnumValue accessRight = getClient().getObjectFactory(). + newEnumValue("Microsoft.Test.OData.Services.ODataWCFService.AccessLevel", "Execute"); + final ODataInvokeRequest<ODataProperty> getProductDetailsReq = + getClient().getInvokeRequestFactory().getInvokeRequest(boundOp.getTarget(), act, + Collections.<String, ODataValue>singletonMap("accessRight", accessRight)); + getProductDetailsReq.setFormat(format); + final ODataProperty getProductDetailsRes = getProductDetailsReq.execute().getBody(); + assertNotNull(getProductDetailsRes); + assertTrue(getProductDetailsRes.hasEnumValue()); + + // ResetAddress + builder = getClient().getURIBuilder(serviceRoot).appendEntitySetSegment("Customers").appendKeySegment(2); + entityReq = getClient().getRetrieveRequestFactory().getEntityRequest(builder.build()); + // TODO: remove when fit is used since external test server does not advertise actions in Atom + entityReq.setFormat(ODataPubFormat.JSON_FULL_METADATA); + entity = entityReq.execute().getBody(); + assertNotNull(entity); + + boundOp = entity.getOperation("Microsoft.Test.OData.Services.ODataWCFService.ResetAddress"); + assertNotNull(boundOp); + + act = edm.getBoundAction(new FullQualifiedName(boundOp.getTitle()), + edm.getEntityType(new EdmTypeInfo.Builder().setTypeExpression(entity.getName()).build(). + getFullQualifiedName()).getBaseType().getFullQualifiedName(), false); + assertNotNull(act); + + final ODataCollectionValue<org.apache.olingo.commons.api.domain.v4.ODataValue> addresses = + getClient().getObjectFactory(). + newCollectionValue("Collection(Microsoft.Test.OData.Services.ODataWCFService.Address)"); + final ODataComplexValue<ODataProperty> address = getClient().getObjectFactory(). + newLinkedComplexValue("Microsoft.Test.OData.Services.ODataWCFService.Address"); + address.add(client.getObjectFactory().newPrimitiveProperty("Street", + client.getObjectFactory().newPrimitiveValueBuilder().buildString("Piazza La Bomba E Scappa"))); + address.add(client.getObjectFactory().newPrimitiveProperty("City", + client.getObjectFactory().newPrimitiveValueBuilder().buildString("Tollo"))); + address.add(client.getObjectFactory().newPrimitiveProperty("PostalCode", + client.getObjectFactory().newPrimitiveValueBuilder().buildString("66010"))); + addresses.add(address); + final ODataPrimitiveValue index = getClient().getObjectFactory().newPrimitiveValueBuilder().buildInt32(0); + final Map<String, ODataValue> params = new LinkedHashMap<String, ODataValue>(2); + params.put("addresses", addresses); + params.put("index", index); + final ODataInvokeRequest<ODataEntity> resetAddressReq = + getClient().getInvokeRequestFactory().getInvokeRequest(boundOp.getTarget(), act, params); + resetAddressReq.setFormat(format); + final ODataEntity resetAddressRes = resetAddressReq.execute().getBody(); + assertNotNull(resetAddressRes); + assertEquals(2, resetAddressRes.getProperty("PersonID").getPrimitiveValue().toCastValue(Integer.class), 0); + + // RefreshDefaultPI + builder = getClient().getURIBuilder(serviceRoot).appendEntitySetSegment("Accounts").appendKeySegment(101); + entityReq = getClient().getRetrieveRequestFactory().getEntityRequest(builder.build()); + // TODO: remove when fit is used since external test server does not advertise actions in Atom + entityReq.setFormat(ODataPubFormat.JSON_FULL_METADATA); + entity = entityReq.execute().getBody(); + assertNotNull(entity); + + boundOp = entity.getOperation("Microsoft.Test.OData.Services.ODataWCFService.RefreshDefaultPI"); + assertNotNull(boundOp); + + act = edm.getBoundAction(new FullQualifiedName(boundOp.getTitle()), + new EdmTypeInfo.Builder().setTypeExpression(entity.getName()).build().getFullQualifiedName(), false); + assertNotNull(act); + + final ODataPrimitiveValue newDate = getClient().getObjectFactory().newPrimitiveValueBuilder(). + setType(EdmPrimitiveTypeKind.DateTimeOffset).setText("2014-04-09T00:00:00Z").build(); + final ODataInvokeRequest<ODataEntity> getDefaultPIReq = + getClient().getInvokeRequestFactory().getInvokeRequest(boundOp.getTarget(), act, + Collections.<String, ODataValue>singletonMap("newDate", newDate)); + getDefaultPIReq.setFormat(format); + final ODataEntity getDefaultPIRes = getDefaultPIReq.execute().getBody(); + assertNotNull(getDefaultPIRes); + assertEquals("#Microsoft.Test.OData.Services.ODataWCFService.PaymentInstrument", getDefaultPIRes.getName()); + assertEquals(101901, + getDefaultPIRes.getProperty("PaymentInstrumentID").getPrimitiveValue().toCastValue(Integer.class), 0); + } + + @Test + public void atomActions() throws EdmPrimitiveTypeException { + //TODO test service doesn't support yet Atom POST params + try { + actions(ODataPubFormat.ATOM); + } catch (Exception e) { + // ignore + } + } + + @Test + public void jsonActions() throws EdmPrimitiveTypeException { + actions(ODataPubFormat.JSON_FULL_METADATA); + } + +}
