GEODE-2996: incorporating review feedback and adding integration test Addresses review feedback for GEODE-2996, mainly refactoring getOpertionHandler to handle failures like the putOperationHandler Adding put operations to the RoundTripCacheConnectionJUnitTest, which is the integration test for the protobuf module Removing service loading for protobuf operations and instead have the ProtobufStreamProcessor populate its OperationHandlerRegistry Remove exception throwing from OperationHandler.process calls and remove TypeEncodingException
Signed-off-by: Brian Rowe <br...@pivotal.io> Signed-off-by: Alexander Murmann <amurm...@pivotal.io> This closes #605 Project: http://git-wip-us.apache.org/repos/asf/geode/repo Commit: http://git-wip-us.apache.org/repos/asf/geode/commit/565e61f7 Tree: http://git-wip-us.apache.org/repos/asf/geode/tree/565e61f7 Diff: http://git-wip-us.apache.org/repos/asf/geode/diff/565e61f7 Branch: refs/heads/feature/GEODE-3109 Commit: 565e61f74409d59cc96c9fbf1ad75d331b728301 Parents: 06961ec Author: Alexander Murmann <amurm...@pivotal.io> Authored: Mon Jun 26 17:56:06 2017 -0700 Committer: Hitesh Khamesra <hkhame...@pivotal.io> Committed: Tue Jun 27 14:48:32 2017 -0700 ---------------------------------------------------------------------- .../protocol/operations/OperationHandler.java | 14 +- .../registry/OperationsHandlerRegistry.java | 7 - .../protocol/protobuf/ProtobufOpsProcessor.java | 29 +++- .../protobuf/ProtobufStreamProcessor.java | 22 ++- .../protocol/protobuf/ProtobufUtilities.java | 11 ++ .../operations/GetRequestOperationHandler.java | 51 ++++--- .../operations/PutRequestOperationHandler.java | 62 +++++++++ .../exception/TypeEncodingException.java | 21 --- .../UnsupportedEncodingTypeException.java | 2 +- .../CodecNotRegisteredForTypeException.java | 4 +- geode-protobuf/src/main/proto/region_API.proto | 4 +- .../org/apache/geode/protocol/MessageUtil.java | 65 +++++++++ .../RoundTripCacheConnectionJUnitTest.java | 45 ++++-- .../protobuf/ProtobufOpsProcessorJUnitTest.java | 7 +- .../GetRequestOperationHandlerJUnitTest.java | 79 +++++++---- .../PutRequestOperationHandlerJUnitTest.java | 139 +++++++++++++++++++ 16 files changed, 440 insertions(+), 122 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/geode/blob/565e61f7/geode-protobuf/src/main/java/org/apache/geode/protocol/operations/OperationHandler.java ---------------------------------------------------------------------- diff --git a/geode-protobuf/src/main/java/org/apache/geode/protocol/operations/OperationHandler.java b/geode-protobuf/src/main/java/org/apache/geode/protocol/operations/OperationHandler.java index 7683e3b..90fe177 100644 --- a/geode-protobuf/src/main/java/org/apache/geode/protocol/operations/OperationHandler.java +++ b/geode-protobuf/src/main/java/org/apache/geode/protocol/operations/OperationHandler.java @@ -15,10 +15,8 @@ package org.apache.geode.protocol.operations; import org.apache.geode.cache.Cache; -import org.apache.geode.protocol.operations.registry.OperationsHandlerRegistry; import org.apache.geode.protocol.protobuf.ProtobufOpsProcessor; import org.apache.geode.serialization.SerializationService; -import org.apache.geode.serialization.exception.TypeEncodingException; /** * This interface is implemented by a object capable of handling request types 'Req' and returning @@ -30,16 +28,6 @@ public interface OperationHandler<Req, Resp> { /** * Decode the message, deserialize contained values using the serialization service, do the work * indicated on the provided cache, and return a response. - * - * @throws TypeEncodingException if a problem occurs decoding an encoded value contained in the - * request. */ - Resp process(SerializationService serializationService, Req request, Cache cache) - throws TypeEncodingException; - - /** - * @return the magic number used for registering the operation type with the - * {@link OperationsHandlerRegistry}. - */ - int getOperationCode(); + Resp process(SerializationService serializationService, Req request, Cache cache); } http://git-wip-us.apache.org/repos/asf/geode/blob/565e61f7/geode-protobuf/src/main/java/org/apache/geode/protocol/operations/registry/OperationsHandlerRegistry.java ---------------------------------------------------------------------- diff --git a/geode-protobuf/src/main/java/org/apache/geode/protocol/operations/registry/OperationsHandlerRegistry.java b/geode-protobuf/src/main/java/org/apache/geode/protocol/operations/registry/OperationsHandlerRegistry.java index 8e3a331..2b9f525 100644 --- a/geode-protobuf/src/main/java/org/apache/geode/protocol/operations/registry/OperationsHandlerRegistry.java +++ b/geode-protobuf/src/main/java/org/apache/geode/protocol/operations/registry/OperationsHandlerRegistry.java @@ -27,13 +27,6 @@ import java.util.ServiceLoader; public class OperationsHandlerRegistry { private HashMap<Integer, OperationHandler> registeredOperations = new HashMap<>(); - public OperationsHandlerRegistry() throws OperationHandlerAlreadyRegisteredException { - ServiceLoader<OperationHandler> operationHandlers = ServiceLoader.load(OperationHandler.class); - for (OperationHandler operationHandler : operationHandlers) { - registerOperationHandlerForOperationId(operationHandler.getOperationCode(), operationHandler); - } - } - public OperationHandler getOperationHandlerForOperationId(int operationCode) throws OperationHandlerNotRegisteredException { OperationHandler operationHandler = registeredOperations.get(operationCode); http://git-wip-us.apache.org/repos/asf/geode/blob/565e61f7/geode-protobuf/src/main/java/org/apache/geode/protocol/protobuf/ProtobufOpsProcessor.java ---------------------------------------------------------------------- diff --git a/geode-protobuf/src/main/java/org/apache/geode/protocol/protobuf/ProtobufOpsProcessor.java b/geode-protobuf/src/main/java/org/apache/geode/protocol/protobuf/ProtobufOpsProcessor.java index d426149..29d3317 100644 --- a/geode-protobuf/src/main/java/org/apache/geode/protocol/protobuf/ProtobufOpsProcessor.java +++ b/geode-protobuf/src/main/java/org/apache/geode/protocol/protobuf/ProtobufOpsProcessor.java @@ -20,7 +20,6 @@ import org.apache.geode.protocol.operations.OperationHandler; import org.apache.geode.protocol.operations.registry.OperationsHandlerRegistry; import org.apache.geode.protocol.operations.registry.exception.OperationHandlerNotRegisteredException; import org.apache.geode.serialization.SerializationService; -import org.apache.geode.serialization.exception.TypeEncodingException; /** * This handles protobuf requests by determining the operation type of the request and dispatching @@ -37,15 +36,14 @@ public class ProtobufOpsProcessor { } public ClientProtocol.Response process(ClientProtocol.Request request, Cache cache) - throws TypeEncodingException, OperationHandlerNotRegisteredException, - InvalidProtocolMessageException { - OperationHandler opsHandler = opsHandlerRegistry - .getOperationHandlerForOperationId(request.getRequestAPICase().getNumber()); + throws OperationHandlerNotRegisteredException, InvalidProtocolMessageException { + ClientProtocol.Request.RequestAPICase requestType = request.getRequestAPICase(); + OperationHandler opsHandler = + opsHandlerRegistry.getOperationHandlerForOperationId(requestType.getNumber()); Object responseMessage = opsHandler.process(serializationService, getRequestForOperationTypeID(request), cache); - return ClientProtocol.Response.newBuilder() - .setGetResponse((RegionAPI.GetResponse) responseMessage).build(); + return wrapResponseForOperationTypeID(requestType, responseMessage); } // package visibility for testing @@ -63,4 +61,21 @@ public class ProtobufOpsProcessor { "Unknown request type: " + request.getRequestAPICase().getNumber()); } } + + static ClientProtocol.Response wrapResponseForOperationTypeID( + ClientProtocol.Request.RequestAPICase requestType, Object response) + throws InvalidProtocolMessageException { + ClientProtocol.Response.Builder builder = ClientProtocol.Response.newBuilder(); + switch (requestType) { + case PUTREQUEST: + return builder.setPutResponse((RegionAPI.PutResponse) response).build(); + case GETREQUEST: + return builder.setGetResponse((RegionAPI.GetResponse) response).build(); + case PUTALLREQUEST: + return builder.setPutAllResponse((RegionAPI.PutAllResponse) response).build(); + default: + throw new InvalidProtocolMessageException( + "Unknown request type: " + requestType.getNumber()); + } + } } http://git-wip-us.apache.org/repos/asf/geode/blob/565e61f7/geode-protobuf/src/main/java/org/apache/geode/protocol/protobuf/ProtobufStreamProcessor.java ---------------------------------------------------------------------- diff --git a/geode-protobuf/src/main/java/org/apache/geode/protocol/protobuf/ProtobufStreamProcessor.java b/geode-protobuf/src/main/java/org/apache/geode/protocol/protobuf/ProtobufStreamProcessor.java index d7b5d4b..21dbef5 100644 --- a/geode-protobuf/src/main/java/org/apache/geode/protocol/protobuf/ProtobufStreamProcessor.java +++ b/geode-protobuf/src/main/java/org/apache/geode/protocol/protobuf/ProtobufStreamProcessor.java @@ -18,14 +18,13 @@ import org.apache.geode.cache.Cache; import org.apache.geode.internal.cache.InternalCache; import org.apache.geode.internal.cache.tier.sockets.ClientProtocolMessageHandler; import org.apache.geode.protocol.exception.InvalidProtocolMessageException; +import org.apache.geode.protocol.protobuf.operations.GetRequestOperationHandler; +import org.apache.geode.protocol.protobuf.operations.PutRequestOperationHandler; import org.apache.geode.protocol.protobuf.serializer.ProtobufProtocolSerializer; import org.apache.geode.protocol.operations.registry.OperationsHandlerRegistry; import org.apache.geode.protocol.operations.registry.exception.OperationHandlerAlreadyRegisteredException; import org.apache.geode.protocol.operations.registry.exception.OperationHandlerNotRegisteredException; -import org.apache.geode.serialization.exception.TypeEncodingException; -import org.apache.geode.serialization.exception.UnsupportedEncodingTypeException; import org.apache.geode.serialization.registry.exception.CodecAlreadyRegisteredForTypeException; -import org.apache.geode.serialization.registry.exception.CodecNotRegisteredForTypeException; import java.io.IOException; import java.io.InputStream; @@ -46,13 +45,23 @@ public class ProtobufStreamProcessor implements ClientProtocolMessageHandler { throws OperationHandlerAlreadyRegisteredException, CodecAlreadyRegisteredForTypeException { protobufProtocolSerializer = new ProtobufProtocolSerializer(); registry = new OperationsHandlerRegistry(); + addOperationHandlers(registry); protobufSerializationService = new ProtobufSerializationService(); protobufOpsProcessor = new ProtobufOpsProcessor(registry, protobufSerializationService); } + private void addOperationHandlers(OperationsHandlerRegistry registry) + throws OperationHandlerAlreadyRegisteredException { + registry.registerOperationHandlerForOperationId( + ClientProtocol.Request.RequestAPICase.GETREQUEST.getNumber(), + new GetRequestOperationHandler()); + registry.registerOperationHandlerForOperationId( + ClientProtocol.Request.RequestAPICase.PUTREQUEST.getNumber(), + new PutRequestOperationHandler()); + } + public void processOneMessage(InputStream inputStream, OutputStream outputStream, Cache cache) - throws InvalidProtocolMessageException, OperationHandlerNotRegisteredException, - TypeEncodingException, IOException { + throws InvalidProtocolMessageException, OperationHandlerNotRegisteredException, IOException { ClientProtocol.Message message = protobufProtocolSerializer.deserialize(inputStream); ClientProtocol.Request request = message.getRequest(); @@ -68,8 +77,7 @@ public class ProtobufStreamProcessor implements ClientProtocolMessageHandler { InternalCache cache) throws IOException { try { processOneMessage(inputStream, outputStream, cache); - } catch (InvalidProtocolMessageException | OperationHandlerNotRegisteredException - | TypeEncodingException e) { + } catch (InvalidProtocolMessageException | OperationHandlerNotRegisteredException e) { throw new IOException(e); } } http://git-wip-us.apache.org/repos/asf/geode/blob/565e61f7/geode-protobuf/src/main/java/org/apache/geode/protocol/protobuf/ProtobufUtilities.java ---------------------------------------------------------------------- diff --git a/geode-protobuf/src/main/java/org/apache/geode/protocol/protobuf/ProtobufUtilities.java b/geode-protobuf/src/main/java/org/apache/geode/protocol/protobuf/ProtobufUtilities.java index d763662..c92da67 100644 --- a/geode-protobuf/src/main/java/org/apache/geode/protocol/protobuf/ProtobufUtilities.java +++ b/geode-protobuf/src/main/java/org/apache/geode/protocol/protobuf/ProtobufUtilities.java @@ -18,6 +18,9 @@ import com.google.protobuf.ByteString; import org.apache.geode.protocol.protobuf.BasicTypes; import org.apache.geode.protocol.protobuf.ClientProtocol; +import org.apache.geode.serialization.SerializationService; +import org.apache.geode.serialization.exception.UnsupportedEncodingTypeException; +import org.apache.geode.serialization.registry.exception.CodecNotRegisteredForTypeException; public abstract class ProtobufUtilities { public static BasicTypes.EncodedValue getEncodedValue(BasicTypes.EncodingType resultEncodingType, @@ -31,4 +34,12 @@ public abstract class ProtobufUtilities { return ClientProtocol.Message.newBuilder() .setMessageHeader(ClientProtocol.MessageHeader.newBuilder()).setResponse(response).build(); } + + public static Object decodeValue(SerializationService serializationService, + BasicTypes.EncodedValue encodedValue) + throws UnsupportedEncodingTypeException, CodecNotRegisteredForTypeException { + BasicTypes.EncodingType encoding = encodedValue.getEncodingType(); + byte[] bytes = encodedValue.getValue().toByteArray(); + return serializationService.decode(encoding, bytes); + } } http://git-wip-us.apache.org/repos/asf/geode/blob/565e61f7/geode-protobuf/src/main/java/org/apache/geode/protocol/protobuf/operations/GetRequestOperationHandler.java ---------------------------------------------------------------------- diff --git a/geode-protobuf/src/main/java/org/apache/geode/protocol/protobuf/operations/GetRequestOperationHandler.java b/geode-protobuf/src/main/java/org/apache/geode/protocol/protobuf/operations/GetRequestOperationHandler.java index d9c1475..95026e8 100644 --- a/geode-protobuf/src/main/java/org/apache/geode/protocol/protobuf/operations/GetRequestOperationHandler.java +++ b/geode-protobuf/src/main/java/org/apache/geode/protocol/protobuf/operations/GetRequestOperationHandler.java @@ -19,11 +19,9 @@ import org.apache.geode.cache.Cache; import org.apache.geode.cache.Region; import org.apache.geode.protocol.operations.OperationHandler; import org.apache.geode.protocol.protobuf.BasicTypes; -import org.apache.geode.protocol.protobuf.ClientProtocol; import org.apache.geode.protocol.protobuf.RegionAPI; import org.apache.geode.serialization.SerializationService; import org.apache.geode.protocol.protobuf.EncodingTypeTranslator; -import org.apache.geode.serialization.exception.TypeEncodingException; import org.apache.geode.serialization.exception.UnsupportedEncodingTypeException; import org.apache.geode.serialization.registry.exception.CodecNotRegisteredForTypeException; @@ -32,31 +30,52 @@ public class GetRequestOperationHandler @Override public RegionAPI.GetResponse process(SerializationService serializationService, - RegionAPI.GetRequest request, Cache cache) throws TypeEncodingException { + RegionAPI.GetRequest request, Cache cache) { String regionName = request.getRegionName(); - BasicTypes.EncodedValue key = request.getKey(); - BasicTypes.EncodingType encodingType = key.getEncodingType(); - byte[] value = key.getValue().toByteArray(); - Object decodedValue = serializationService.decode(encodingType, value); + try { + Object decodedKey = ProtobufUtilities.decodeValue(serializationService, request.getKey()); - Region region = cache.getRegion(regionName); - Object resultValue = region.get(decodedValue); - return buildGetResponse(serializationService, resultValue); + Region region = cache.getRegion(regionName); + + if (region == null) { + return buildGetResponseFailure(); + } + + Object resultValue = region.get(decodedKey); + + if (resultValue == null) { + return buildGetResponseKeyNotFound(); + } + + return buildGetResponseSuccess(serializationService, resultValue); + } catch (UnsupportedEncodingTypeException ex) { + // can be thrown by encoding or decoding. + cache.getLogger().error("encoding not supported ", ex); + } catch (CodecNotRegisteredForTypeException ex) { + cache.getLogger().error("codec error in protobuf deserialization ", ex); + } + return buildGetResponseFailure(); } - @Override - public int getOperationCode() { - return ClientProtocol.Request.RequestAPICase.GETREQUEST.getNumber(); + private RegionAPI.GetResponse buildGetResponseKeyNotFound() { + return RegionAPI.GetResponse.newBuilder().setSuccess(true).setKeyExists(false).build(); + } + + private RegionAPI.GetResponse buildGetResponseFailure() { + return RegionAPI.GetResponse.newBuilder().setSuccess(false).build(); } - private RegionAPI.GetResponse buildGetResponse(SerializationService serializationService, - Object resultValue) throws TypeEncodingException { + // throws if the object in the cache is not of a class that be serialized via the protobuf + // protocol. + private RegionAPI.GetResponse buildGetResponseSuccess(SerializationService serializationService, + Object resultValue) + throws UnsupportedEncodingTypeException, CodecNotRegisteredForTypeException { BasicTypes.EncodingType resultEncodingType = EncodingTypeTranslator.getEncodingTypeForObject(resultValue); byte[] resultEncodedValue = serializationService.encode(resultEncodingType, resultValue); - return RegionAPI.GetResponse.newBuilder() + return RegionAPI.GetResponse.newBuilder().setSuccess(true).setKeyExists(true) .setResult(ProtobufUtilities.getEncodedValue(resultEncodingType, resultEncodedValue)) .build(); } http://git-wip-us.apache.org/repos/asf/geode/blob/565e61f7/geode-protobuf/src/main/java/org/apache/geode/protocol/protobuf/operations/PutRequestOperationHandler.java ---------------------------------------------------------------------- diff --git a/geode-protobuf/src/main/java/org/apache/geode/protocol/protobuf/operations/PutRequestOperationHandler.java b/geode-protobuf/src/main/java/org/apache/geode/protocol/protobuf/operations/PutRequestOperationHandler.java new file mode 100644 index 0000000..f375244 --- /dev/null +++ b/geode-protobuf/src/main/java/org/apache/geode/protocol/protobuf/operations/PutRequestOperationHandler.java @@ -0,0 +1,62 @@ +/* + * 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.geode.protocol.protobuf.operations; + +import org.apache.geode.cache.Cache; +import org.apache.geode.cache.Region; +import org.apache.geode.protocol.operations.OperationHandler; +import org.apache.geode.protocol.protobuf.BasicTypes; +import org.apache.geode.protocol.protobuf.ClientProtocol; +import org.apache.geode.protocol.protobuf.ProtobufUtilities; +import org.apache.geode.protocol.protobuf.RegionAPI; +import org.apache.geode.serialization.SerializationService; +import org.apache.geode.serialization.exception.UnsupportedEncodingTypeException; +import org.apache.geode.serialization.registry.exception.CodecNotRegisteredForTypeException; + +public class PutRequestOperationHandler + implements OperationHandler<RegionAPI.PutRequest, RegionAPI.PutResponse> { + + @Override + public RegionAPI.PutResponse process(SerializationService serializationService, + RegionAPI.PutRequest request, Cache cache) { + try { + String regionName = request.getRegionName(); + BasicTypes.Entry entry = request.getEntry(); + + Object decodedValue = ProtobufUtilities.decodeValue(serializationService, entry.getValue()); + Object decodedKey = ProtobufUtilities.decodeValue(serializationService, entry.getKey()); + + Region region = cache.getRegion(regionName); + if (region == null) { + cache.getLogger().error("Region passed by client did not exist:" + region); + } else { + try { + region.put(decodedKey, decodedValue); + return RegionAPI.PutResponse.newBuilder().setSuccess(true).build(); + } catch (ClassCastException ex) { + cache.getLogger() + .error("invalid key or value type for region " + regionName + ",passed key: " + + entry.getKey().getEncodingType() + " value: " + + entry.getValue().getEncodingType(), ex); + } + } + } catch (UnsupportedEncodingTypeException ex) { + cache.getLogger().error("encoding not supported ", ex); + } catch (CodecNotRegisteredForTypeException ex) { + cache.getLogger().error("codec error in protobuf deserialization ", ex); + } + return RegionAPI.PutResponse.newBuilder().setSuccess(false).build(); + } +} http://git-wip-us.apache.org/repos/asf/geode/blob/565e61f7/geode-protobuf/src/main/java/org/apache/geode/serialization/exception/TypeEncodingException.java ---------------------------------------------------------------------- diff --git a/geode-protobuf/src/main/java/org/apache/geode/serialization/exception/TypeEncodingException.java b/geode-protobuf/src/main/java/org/apache/geode/serialization/exception/TypeEncodingException.java deleted file mode 100644 index f3145a7..0000000 --- a/geode-protobuf/src/main/java/org/apache/geode/serialization/exception/TypeEncodingException.java +++ /dev/null @@ -1,21 +0,0 @@ -/* - * 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.geode.serialization.exception; - -public class TypeEncodingException extends Exception { - public TypeEncodingException(String message) { - super(message); - } -} http://git-wip-us.apache.org/repos/asf/geode/blob/565e61f7/geode-protobuf/src/main/java/org/apache/geode/serialization/exception/UnsupportedEncodingTypeException.java ---------------------------------------------------------------------- diff --git a/geode-protobuf/src/main/java/org/apache/geode/serialization/exception/UnsupportedEncodingTypeException.java b/geode-protobuf/src/main/java/org/apache/geode/serialization/exception/UnsupportedEncodingTypeException.java index c577e76..6d2a032 100644 --- a/geode-protobuf/src/main/java/org/apache/geode/serialization/exception/UnsupportedEncodingTypeException.java +++ b/geode-protobuf/src/main/java/org/apache/geode/serialization/exception/UnsupportedEncodingTypeException.java @@ -17,7 +17,7 @@ package org.apache.geode.serialization.exception; /** * This indicates an encoding type that we don't know how to handle. */ -public class UnsupportedEncodingTypeException extends TypeEncodingException { +public class UnsupportedEncodingTypeException extends Exception { public UnsupportedEncodingTypeException(String message) { super(message); } http://git-wip-us.apache.org/repos/asf/geode/blob/565e61f7/geode-protobuf/src/main/java/org/apache/geode/serialization/registry/exception/CodecNotRegisteredForTypeException.java ---------------------------------------------------------------------- diff --git a/geode-protobuf/src/main/java/org/apache/geode/serialization/registry/exception/CodecNotRegisteredForTypeException.java b/geode-protobuf/src/main/java/org/apache/geode/serialization/registry/exception/CodecNotRegisteredForTypeException.java index 5c923a5..58cb691 100644 --- a/geode-protobuf/src/main/java/org/apache/geode/serialization/registry/exception/CodecNotRegisteredForTypeException.java +++ b/geode-protobuf/src/main/java/org/apache/geode/serialization/registry/exception/CodecNotRegisteredForTypeException.java @@ -14,12 +14,10 @@ */ package org.apache.geode.serialization.registry.exception; -import org.apache.geode.serialization.exception.TypeEncodingException; - /** * This indicates we're attempting to handle a type for which we don't have a registered codec. */ -public class CodecNotRegisteredForTypeException extends TypeEncodingException { +public class CodecNotRegisteredForTypeException extends Exception { public CodecNotRegisteredForTypeException(String message) { super(message); } http://git-wip-us.apache.org/repos/asf/geode/blob/565e61f7/geode-protobuf/src/main/proto/region_API.proto ---------------------------------------------------------------------- diff --git a/geode-protobuf/src/main/proto/region_API.proto b/geode-protobuf/src/main/proto/region_API.proto index 52291c4..adeb011 100644 --- a/geode-protobuf/src/main/proto/region_API.proto +++ b/geode-protobuf/src/main/proto/region_API.proto @@ -33,7 +33,9 @@ message GetRequest { } message GetResponse { - EncodedValue result = 1; + bool success = 1; + bool keyExists = 2; + EncodedValue result = 3; } message PutAllRequest { http://git-wip-us.apache.org/repos/asf/geode/blob/565e61f7/geode-protobuf/src/test/java/org/apache/geode/protocol/MessageUtil.java ---------------------------------------------------------------------- diff --git a/geode-protobuf/src/test/java/org/apache/geode/protocol/MessageUtil.java b/geode-protobuf/src/test/java/org/apache/geode/protocol/MessageUtil.java index f0b0b41..73d0803 100644 --- a/geode-protobuf/src/test/java/org/apache/geode/protocol/MessageUtil.java +++ b/geode-protobuf/src/test/java/org/apache/geode/protocol/MessageUtil.java @@ -14,8 +14,19 @@ */ package org.apache.geode.protocol; +import com.google.protobuf.ByteString; + +import org.apache.geode.protocol.protobuf.BasicTypes; import org.apache.geode.protocol.protobuf.ClientProtocol; +import org.apache.geode.protocol.protobuf.EncodingTypeTranslator; import org.apache.geode.protocol.protobuf.RegionAPI; +import org.apache.geode.serialization.codec.StringCodec; +import org.apache.geode.serialization.exception.UnsupportedEncodingTypeException; +import org.apache.geode.serialization.registry.SerializationCodecRegistry; +import org.apache.geode.serialization.registry.exception.CodecAlreadyRegisteredForTypeException; +import org.apache.geode.serialization.registry.exception.CodecNotRegisteredForTypeException; + +import java.nio.ByteBuffer; public class MessageUtil { public static ClientProtocol.Message createGetRequestMessage() { @@ -27,6 +38,60 @@ public class MessageUtil { return messageBuilder.build(); } + public static RegionAPI.PutRequest makePutRequest(String requestKey, String requestValue, + String requestRegion) throws CodecNotRegisteredForTypeException, + UnsupportedEncodingTypeException, CodecAlreadyRegisteredForTypeException { + StringCodec stringCodec = getStringCodec(); + BasicTypes.EncodedValue.Builder key = + BasicTypes.EncodedValue.newBuilder().setEncodingType(BasicTypes.EncodingType.STRING) + .setValue(ByteString.copyFrom(stringCodec.encode(requestKey))); + BasicTypes.EncodedValue.Builder value = + BasicTypes.EncodedValue.newBuilder().setEncodingType(BasicTypes.EncodingType.STRING) + .setValue(ByteString.copyFrom(stringCodec.encode(requestValue))); + BasicTypes.Entry.Builder entry = BasicTypes.Entry.newBuilder().setKey(key).setValue(value); + RegionAPI.PutRequest.Builder putRequestBuilder = RegionAPI.PutRequest.newBuilder(); + putRequestBuilder.setRegionName(requestRegion).setEntry(entry); + + return putRequestBuilder.build(); + } + + public static ClientProtocol.Message makePutRequestMessage(String requestKey, String requestValue, + String requestRegion, ClientProtocol.MessageHeader header) + throws CodecNotRegisteredForTypeException, UnsupportedEncodingTypeException, + CodecAlreadyRegisteredForTypeException { + ClientProtocol.Request request = ClientProtocol.Request.newBuilder() + .setPutRequest(makePutRequest(requestKey, requestValue, requestRegion)).build(); + return ClientProtocol.Message.newBuilder().setMessageHeader(header).setRequest(request).build(); + } + + public static RegionAPI.GetRequest makeGetRequest(String requestKey, String requestRegion) + throws CodecNotRegisteredForTypeException, UnsupportedEncodingTypeException, + CodecAlreadyRegisteredForTypeException { + StringCodec stringCodec = getStringCodec(); + RegionAPI.GetRequest.Builder getRequestBuilder = RegionAPI.GetRequest.newBuilder(); + getRequestBuilder.setRegionName(requestRegion) + .setKey(BasicTypes.EncodedValue.newBuilder().setEncodingType(BasicTypes.EncodingType.STRING) + .setValue(ByteString.copyFrom(stringCodec.encode(requestKey)))); + + return getRequestBuilder.build(); + } + + public static ClientProtocol.Message makeGetRequestMessage(String requestKey, + String requestRegion, ClientProtocol.MessageHeader header) + throws CodecAlreadyRegisteredForTypeException, UnsupportedEncodingTypeException, + CodecNotRegisteredForTypeException { + ClientProtocol.Request request = ClientProtocol.Request.newBuilder() + .setGetRequest(makeGetRequest(requestKey, requestRegion)).build(); + return ClientProtocol.Message.newBuilder().setMessageHeader(header).setRequest(request).build(); + } + + public static StringCodec getStringCodec() throws CodecAlreadyRegisteredForTypeException, + CodecNotRegisteredForTypeException, UnsupportedEncodingTypeException { + SerializationCodecRegistry serializationCodecRegistry = new SerializationCodecRegistry(); + return (StringCodec) serializationCodecRegistry.getCodecForType( + EncodingTypeTranslator.getSerializationTypeForEncodingType(BasicTypes.EncodingType.STRING)); + } + private static ClientProtocol.Request.Builder getRequestBuilder() { return ClientProtocol.Request.newBuilder(); } http://git-wip-us.apache.org/repos/asf/geode/blob/565e61f7/geode-protobuf/src/test/java/org/apache/geode/protocol/RoundTripCacheConnectionJUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-protobuf/src/test/java/org/apache/geode/protocol/RoundTripCacheConnectionJUnitTest.java b/geode-protobuf/src/test/java/org/apache/geode/protocol/RoundTripCacheConnectionJUnitTest.java index b9faca3..1fbe821 100644 --- a/geode-protobuf/src/test/java/org/apache/geode/protocol/RoundTripCacheConnectionJUnitTest.java +++ b/geode-protobuf/src/test/java/org/apache/geode/protocol/RoundTripCacheConnectionJUnitTest.java @@ -26,12 +26,16 @@ import org.apache.geode.cache.RegionFactory; import org.apache.geode.cache.server.CacheServer; import org.apache.geode.internal.AvailablePortHelper; import org.apache.geode.internal.cache.tier.sockets.GenericProtocolServerConnection; +import org.apache.geode.protocol.exception.InvalidProtocolMessageException; import org.apache.geode.protocol.protobuf.BasicTypes; import org.apache.geode.protocol.protobuf.ClientProtocol; import org.apache.geode.protocol.protobuf.ProtobufSerializationService; import org.apache.geode.protocol.protobuf.RegionAPI; import org.apache.geode.protocol.protobuf.serializer.ProtobufProtocolSerializer; import org.apache.geode.serialization.codec.StringCodec; +import org.apache.geode.serialization.exception.UnsupportedEncodingTypeException; +import org.apache.geode.serialization.registry.exception.CodecAlreadyRegisteredForTypeException; +import org.apache.geode.serialization.registry.exception.CodecNotRegisteredForTypeException; import org.apache.geode.test.junit.categories.IntegrationTest; import org.awaitility.Awaitility; import org.junit.After; @@ -75,7 +79,6 @@ public class RoundTripCacheConnectionJUnitTest { RegionFactory<Object, Object> regionFactory = cache.createRegionFactory(); Region<Object, Object> testRegion = regionFactory.create(TEST_REGION); - testRegion.put(TEST_KEY, TEST_VALUE); } @After @@ -93,8 +96,33 @@ public class RoundTripCacheConnectionJUnitTest { outputStream.write(110); ProtobufProtocolSerializer protobufProtocolSerializer = new ProtobufProtocolSerializer(); - protobufProtocolSerializer.serialize(makeTestGetRequest(new StringCodec()), outputStream); + ClientProtocol.Message putMessage = MessageUtil.makePutRequestMessage(TEST_KEY, TEST_VALUE, + TEST_REGION, ClientProtocol.MessageHeader.newBuilder().build()); + protobufProtocolSerializer.serialize(putMessage, outputStream); + validatePutResponse(socket, protobufProtocolSerializer); + + ClientProtocol.Message getMessage = MessageUtil.makeGetRequestMessage(TEST_KEY, TEST_REGION, + ClientProtocol.MessageHeader.newBuilder().build()); + protobufProtocolSerializer.serialize(getMessage, outputStream); + validateGetResponse(socket, protobufProtocolSerializer); + } + + private void validatePutResponse(Socket socket, + ProtobufProtocolSerializer protobufProtocolSerializer) throws Exception { + ClientProtocol.Message message = + protobufProtocolSerializer.deserialize(socket.getInputStream()); + assertEquals(ClientProtocol.Message.MessageTypeCase.RESPONSE, message.getMessageTypeCase()); + ClientProtocol.Response response = message.getResponse(); + assertEquals(ClientProtocol.Response.ResponseAPICase.PUTRESPONSE, + response.getResponseAPICase()); + RegionAPI.PutResponse putResponse = response.getPutResponse(); + assertEquals(true, putResponse.getSuccess()); + } + private void validateGetResponse(Socket socket, + ProtobufProtocolSerializer protobufProtocolSerializer) + throws InvalidProtocolMessageException, IOException, UnsupportedEncodingTypeException, + CodecNotRegisteredForTypeException, CodecAlreadyRegisteredForTypeException { ClientProtocol.Message message = protobufProtocolSerializer.deserialize(socket.getInputStream()); assertEquals(ClientProtocol.Message.MessageTypeCase.RESPONSE, message.getMessageTypeCase()); @@ -107,17 +135,4 @@ public class RoundTripCacheConnectionJUnitTest { assertEquals(TEST_VALUE, new ProtobufSerializationService().decode(result.getEncodingType(), result.getValue().toByteArray())); } - - private ClientProtocol.Message makeTestGetRequest(StringCodec stringCodec) { - RegionAPI.GetRequest.Builder getRequestBuilder = RegionAPI.GetRequest.newBuilder(); - getRequestBuilder.setRegionName(TEST_REGION) - .setKey(BasicTypes.EncodedValue.newBuilder().setEncodingType(BasicTypes.EncodingType.STRING) - .setValue(ByteString.copyFrom(stringCodec.encode(TEST_KEY)))); - ClientProtocol.Request request = - ClientProtocol.Request.newBuilder().setGetRequest(getRequestBuilder).build(); - ClientProtocol.Message requestMessage = ClientProtocol.Message.newBuilder() - .setMessageHeader(ClientProtocol.MessageHeader.newBuilder()).setRequest(request).build(); - - return requestMessage; - } } http://git-wip-us.apache.org/repos/asf/geode/blob/565e61f7/geode-protobuf/src/test/java/org/apache/geode/protocol/protobuf/ProtobufOpsProcessorJUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-protobuf/src/test/java/org/apache/geode/protocol/protobuf/ProtobufOpsProcessorJUnitTest.java b/geode-protobuf/src/test/java/org/apache/geode/protocol/protobuf/ProtobufOpsProcessorJUnitTest.java index fc980ae..c51be5c 100644 --- a/geode-protobuf/src/test/java/org/apache/geode/protocol/protobuf/ProtobufOpsProcessorJUnitTest.java +++ b/geode-protobuf/src/test/java/org/apache/geode/protocol/protobuf/ProtobufOpsProcessorJUnitTest.java @@ -24,9 +24,6 @@ import org.apache.geode.protocol.operations.OperationHandler; import org.apache.geode.protocol.operations.registry.OperationsHandlerRegistry; import org.apache.geode.protocol.operations.registry.exception.OperationHandlerNotRegisteredException; import org.apache.geode.serialization.SerializationService; -import org.apache.geode.serialization.exception.TypeEncodingException; -import org.apache.geode.serialization.exception.UnsupportedEncodingTypeException; -import org.apache.geode.serialization.registry.exception.CodecNotRegisteredForTypeException; import org.apache.geode.test.junit.categories.UnitTest; import org.junit.Assert; import org.junit.Test; @@ -35,8 +32,8 @@ import org.junit.experimental.categories.Category; @Category(UnitTest.class) public class ProtobufOpsProcessorJUnitTest { @Test - public void testOpsProcessor() throws TypeEncodingException, - OperationHandlerNotRegisteredException, InvalidProtocolMessageException { + public void testOpsProcessor() + throws OperationHandlerNotRegisteredException, InvalidProtocolMessageException { OperationsHandlerRegistry opsHandlerRegistryStub = mock(OperationsHandlerRegistry.class); OperationHandler operationHandlerStub = mock(OperationHandler.class); SerializationService serializationServiceStub = mock(SerializationService.class); http://git-wip-us.apache.org/repos/asf/geode/blob/565e61f7/geode-protobuf/src/test/java/org/apache/geode/protocol/protobuf/operations/GetRequestOperationHandlerJUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-protobuf/src/test/java/org/apache/geode/protocol/protobuf/operations/GetRequestOperationHandlerJUnitTest.java b/geode-protobuf/src/test/java/org/apache/geode/protocol/protobuf/operations/GetRequestOperationHandlerJUnitTest.java index daa5870..f92b194 100644 --- a/geode-protobuf/src/test/java/org/apache/geode/protocol/protobuf/operations/GetRequestOperationHandlerJUnitTest.java +++ b/geode-protobuf/src/test/java/org/apache/geode/protocol/protobuf/operations/GetRequestOperationHandlerJUnitTest.java @@ -14,19 +14,14 @@ */ package org.apache.geode.protocol.protobuf.operations; -import com.google.protobuf.ByteString; - +import org.apache.geode.LogWriter; import org.apache.geode.cache.Cache; import org.apache.geode.cache.Region; +import org.apache.geode.protocol.MessageUtil; import org.apache.geode.protocol.protobuf.BasicTypes; import org.apache.geode.protocol.protobuf.RegionAPI; -import org.apache.geode.protocol.protobuf.operations.GetRequestOperationHandler; import org.apache.geode.serialization.SerializationService; -import org.apache.geode.serialization.codec.StringCodec; -import org.apache.geode.protocol.protobuf.EncodingTypeTranslator; -import org.apache.geode.serialization.exception.TypeEncodingException; import org.apache.geode.serialization.exception.UnsupportedEncodingTypeException; -import org.apache.geode.serialization.registry.SerializationCodecRegistry; import org.apache.geode.serialization.registry.exception.CodecAlreadyRegisteredForTypeException; import org.apache.geode.serialization.registry.exception.CodecNotRegisteredForTypeException; import org.apache.geode.test.dunit.Assert; @@ -37,7 +32,10 @@ import org.junit.experimental.categories.Category; import java.nio.charset.Charset; +import static org.mockito.ArgumentMatchers.any; +import static org.mockito.ArgumentMatchers.eq; import static org.mockito.Mockito.mock; +import static org.mockito.Mockito.verify; import static org.mockito.Mockito.when; @Category(UnitTest.class) @@ -45,8 +43,11 @@ public class GetRequestOperationHandlerJUnitTest { public static final String TEST_KEY = "my key"; public static final String TEST_VALUE = "my value"; public static final String TEST_REGION = "test region"; + public static final String MISSING_REGION = "missing region"; + public static final String MISSING_KEY = "missing key"; public Cache cacheStub; public SerializationService serializationServiceStub; + private GetRequestOperationHandler operationHandler; @Before public void setUp() throws Exception { @@ -61,36 +62,62 @@ public class GetRequestOperationHandlerJUnitTest { cacheStub = mock(Cache.class); when(cacheStub.getRegion(TEST_REGION)).thenReturn(regionStub); + when(cacheStub.getRegion(MISSING_REGION)).thenReturn(null); + operationHandler = new GetRequestOperationHandler(); } @Test public void processReturnsTheEncodedValueFromTheRegion() - throws TypeEncodingException, CodecAlreadyRegisteredForTypeException { - GetRequestOperationHandler operationHandler = new GetRequestOperationHandler(); - - RegionAPI.GetResponse response = - operationHandler.process(serializationServiceStub, makeGetRequest(), cacheStub); + throws CodecAlreadyRegisteredForTypeException, UnsupportedEncodingTypeException, + CodecNotRegisteredForTypeException { + RegionAPI.GetResponse response = operationHandler.process(serializationServiceStub, + MessageUtil.makeGetRequest(TEST_KEY, TEST_REGION), cacheStub); + Assert.assertEquals(true, response.getSuccess()); + Assert.assertEquals(true, response.getKeyExists()); Assert.assertEquals(BasicTypes.EncodingType.STRING, response.getResult().getEncodingType()); - String actualValue = getStringCodec().decode(response.getResult().getValue().toByteArray()); + String actualValue = + MessageUtil.getStringCodec().decode(response.getResult().getValue().toByteArray()); Assert.assertEquals(TEST_VALUE, actualValue); } - private RegionAPI.GetRequest makeGetRequest() throws CodecNotRegisteredForTypeException, - UnsupportedEncodingTypeException, CodecAlreadyRegisteredForTypeException { - StringCodec stringCodec = getStringCodec(); - RegionAPI.GetRequest.Builder getRequestBuilder = RegionAPI.GetRequest.newBuilder(); - getRequestBuilder.setRegionName(TEST_REGION) - .setKey(BasicTypes.EncodedValue.newBuilder().setEncodingType(BasicTypes.EncodingType.STRING) - .setValue(ByteString.copyFrom(stringCodec.encode(TEST_KEY)))); + @Test + public void processReturnsUnsucessfulResponseForInvalidRegion() + throws CodecAlreadyRegisteredForTypeException, UnsupportedEncodingTypeException, + CodecNotRegisteredForTypeException { + RegionAPI.GetResponse response = operationHandler.process(serializationServiceStub, + MessageUtil.makeGetRequest(TEST_KEY, MISSING_REGION), cacheStub); + + Assert.assertEquals(false, response.getSuccess()); + } + + @Test + public void processReturnsKeyNotFoundWhenKeyIsNotFound() + throws CodecAlreadyRegisteredForTypeException, UnsupportedEncodingTypeException, + CodecNotRegisteredForTypeException { + RegionAPI.GetResponse response = operationHandler.process(serializationServiceStub, + MessageUtil.makeGetRequest(MISSING_KEY, TEST_REGION), cacheStub); - return getRequestBuilder.build(); + Assert.assertEquals(true, response.getSuccess()); + Assert.assertEquals(false, response.getKeyExists()); } - private StringCodec getStringCodec() throws CodecAlreadyRegisteredForTypeException, - CodecNotRegisteredForTypeException, UnsupportedEncodingTypeException { - SerializationCodecRegistry serializationCodecRegistry = new SerializationCodecRegistry(); - return (StringCodec) serializationCodecRegistry.getCodecForType( - EncodingTypeTranslator.getSerializationTypeForEncodingType(BasicTypes.EncodingType.STRING)); + @Test + public void processReturnsErrorWhenUnableToDecodeRequest() + throws CodecAlreadyRegisteredForTypeException, UnsupportedEncodingTypeException, + CodecNotRegisteredForTypeException { + LogWriter loggerMock = mock(LogWriter.class); + when(cacheStub.getLogger()).thenReturn(loggerMock); + + CodecNotRegisteredForTypeException exception = + new CodecNotRegisteredForTypeException("error finding codec for type"); + when(serializationServiceStub.decode(BasicTypes.EncodingType.STRING, + TEST_KEY.getBytes(Charset.forName("UTF-8")))).thenThrow(exception); + + RegionAPI.GetResponse response = operationHandler.process(serializationServiceStub, + MessageUtil.makeGetRequest(TEST_KEY, TEST_REGION), cacheStub); + + Assert.assertEquals(false, response.getSuccess()); + verify(loggerMock).error(any(String.class), eq(exception)); } } http://git-wip-us.apache.org/repos/asf/geode/blob/565e61f7/geode-protobuf/src/test/java/org/apache/geode/protocol/protobuf/operations/PutRequestOperationHandlerJUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-protobuf/src/test/java/org/apache/geode/protocol/protobuf/operations/PutRequestOperationHandlerJUnitTest.java b/geode-protobuf/src/test/java/org/apache/geode/protocol/protobuf/operations/PutRequestOperationHandlerJUnitTest.java new file mode 100644 index 0000000..ddc23fc --- /dev/null +++ b/geode-protobuf/src/test/java/org/apache/geode/protocol/protobuf/operations/PutRequestOperationHandlerJUnitTest.java @@ -0,0 +1,139 @@ +/* + * 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.geode.protocol.protobuf.operations; + +import com.google.protobuf.ByteString; +import org.apache.geode.LogWriter; +import org.apache.geode.cache.Cache; +import org.apache.geode.cache.Region; +import org.apache.geode.protocol.MessageUtil; +import org.apache.geode.protocol.protobuf.BasicTypes; +import org.apache.geode.protocol.protobuf.EncodingTypeTranslator; +import org.apache.geode.protocol.protobuf.RegionAPI; +import org.apache.geode.serialization.SerializationService; +import org.apache.geode.serialization.codec.StringCodec; +import org.apache.geode.serialization.exception.UnsupportedEncodingTypeException; +import org.apache.geode.serialization.registry.SerializationCodecRegistry; +import org.apache.geode.serialization.registry.exception.CodecAlreadyRegisteredForTypeException; +import org.apache.geode.serialization.registry.exception.CodecNotRegisteredForTypeException; +import org.apache.geode.test.dunit.Assert; +import org.apache.geode.test.junit.categories.UnitTest; +import org.junit.Before; +import org.junit.Test; +import org.junit.experimental.categories.Category; + +import java.nio.ByteBuffer; +import java.nio.charset.Charset; + +import static org.mockito.Mockito.*; + +@Category(UnitTest.class) +public class PutRequestOperationHandlerJUnitTest { + public static final String TEST_KEY = "my key"; + public static final String TEST_VALUE = "99"; + public static final String TEST_REGION = "test region"; + public Cache cacheStub; + public SerializationService serializationServiceStub; + private Region regionMock; + private LogWriter loggerMock; + + @Before + public void setUp() throws Exception { + serializationServiceStub = mock(SerializationService.class); + when(serializationServiceStub.decode(BasicTypes.EncodingType.STRING, + TEST_KEY.getBytes(Charset.forName("UTF-8")))).thenReturn(TEST_KEY); + when(serializationServiceStub.decode(BasicTypes.EncodingType.STRING, + TEST_VALUE.getBytes(Charset.forName("UTF-8")))).thenReturn(TEST_VALUE); + + regionMock = mock(Region.class); + when(regionMock.put(TEST_KEY, TEST_VALUE)).thenReturn(1); + + cacheStub = mock(Cache.class); + when(cacheStub.getRegion(TEST_REGION)).thenReturn(regionMock); + + loggerMock = mock(LogWriter.class); + when(cacheStub.getLogger()).thenReturn(loggerMock); + } + + @Test + public void test_puttingTheEncodedEntryIntoRegion() throws UnsupportedEncodingTypeException, + CodecNotRegisteredForTypeException, CodecAlreadyRegisteredForTypeException { + PutRequestOperationHandler operationHandler = new PutRequestOperationHandler(); + + + RegionAPI.PutResponse response = operationHandler.process(serializationServiceStub, + MessageUtil.makePutRequest(TEST_KEY, TEST_VALUE, TEST_REGION), cacheStub); + + Assert.assertTrue(response.getSuccess()); + verify(regionMock).put(TEST_KEY, TEST_VALUE); + verify(regionMock, times(1)).put(anyString(), anyString()); + } + + @Test + public void test_invalidEncodingType() throws CodecAlreadyRegisteredForTypeException, + UnsupportedEncodingTypeException, CodecNotRegisteredForTypeException { + UnsupportedEncodingTypeException exception = + new UnsupportedEncodingTypeException("unsupported type!"); + when(serializationServiceStub.decode(BasicTypes.EncodingType.STRING, + TEST_KEY.getBytes(Charset.forName("UTF-8")))).thenThrow(exception); + PutRequestOperationHandler operationHandler = new PutRequestOperationHandler(); + + RegionAPI.PutResponse response = operationHandler.process(serializationServiceStub, + MessageUtil.makePutRequest(TEST_KEY, TEST_VALUE, TEST_REGION), cacheStub); + + verify(loggerMock).error(any(String.class), eq(exception)); + Assert.assertFalse(response.getSuccess()); + } + + @Test + public void test_codecNotRegistered() throws CodecAlreadyRegisteredForTypeException, + UnsupportedEncodingTypeException, CodecNotRegisteredForTypeException { + CodecNotRegisteredForTypeException exception = + new CodecNotRegisteredForTypeException("error finding codec for type"); + when(serializationServiceStub.decode(BasicTypes.EncodingType.STRING, + TEST_KEY.getBytes(Charset.forName("UTF-8")))).thenThrow(exception); + PutRequestOperationHandler operationHandler = new PutRequestOperationHandler(); + + RegionAPI.PutResponse response = operationHandler.process(serializationServiceStub, + MessageUtil.makePutRequest(TEST_KEY, TEST_VALUE, TEST_REGION), cacheStub); + + verify(loggerMock).error(any(String.class), eq(exception)); + Assert.assertFalse(response.getSuccess()); + } + + @Test + public void test_RegionNotFound() throws CodecAlreadyRegisteredForTypeException, + UnsupportedEncodingTypeException, CodecNotRegisteredForTypeException { + when(cacheStub.getRegion(TEST_REGION)).thenReturn(null); + PutRequestOperationHandler operationHandler = new PutRequestOperationHandler(); + RegionAPI.PutResponse response = operationHandler.process(serializationServiceStub, + MessageUtil.makePutRequest(TEST_KEY, TEST_VALUE, TEST_REGION), cacheStub); + + Assert.assertFalse(response.getSuccess()); + } + + @Test + public void test_RegionThrowsClasscastException() throws CodecAlreadyRegisteredForTypeException, + UnsupportedEncodingTypeException, CodecNotRegisteredForTypeException { + when(regionMock.put(any(), any())).thenThrow(ClassCastException.class); + + PutRequestOperationHandler operationHandler = new PutRequestOperationHandler(); + RegionAPI.PutResponse response = operationHandler.process(serializationServiceStub, + MessageUtil.makePutRequest(TEST_KEY, TEST_VALUE, TEST_REGION), cacheStub); + + verify(loggerMock).error(any(String.class), any(ClassCastException.class)); + Assert.assertFalse(response.getSuccess()); + } +}
