http://git-wip-us.apache.org/repos/asf/camel/blob/58515451/components/camel-cm/src/main/java/org/apache/camel/component/cm/CMComponent.java ---------------------------------------------------------------------- diff --git a/components/camel-cm/src/main/java/org/apache/camel/component/cm/CMComponent.java b/components/camel-cm/src/main/java/org/apache/camel/component/cm/CMComponent.java deleted file mode 100644 index ab26e14..0000000 --- a/components/camel-cm/src/main/java/org/apache/camel/component/cm/CMComponent.java +++ /dev/null @@ -1,99 +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.camel.component.cm; - -import java.util.Map; -import java.util.Set; - -import javax.validation.ConstraintViolation; -import javax.validation.Validator; - -import org.apache.camel.BeanInject; -import org.apache.camel.CamelContext; -import org.apache.camel.Endpoint; -import org.apache.camel.ResolveEndpointFailedException; -import org.apache.camel.impl.UriEndpointComponent; -import org.apache.camel.util.URISupport; -import org.apache.commons.validator.routines.UrlValidator; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -/** - * Represents the component that manages {@link CMEndpoint}s. - */ -public class CMComponent extends UriEndpointComponent { - - private static final Logger LOG = LoggerFactory.getLogger(CMComponent.class); - - @BeanInject - private Validator validator; - - // public CMComponent() { - // super(CMEndpoint.class); - // } - - public CMComponent(final CamelContext context) { - super(context, CMEndpoint.class); - } - - /** - * Endpoints factory - */ - @Override - protected Endpoint createEndpoint(final String uri, final String remaining, final Map<String, Object> parameters) throws Exception { - - LOG.debug("Creating CM Endpoint ... "); - - final String url = CMConstants.DEFAULT_SCHEME + remaining; - if (!UrlValidator.getInstance().isValid(url)) { - throw new ResolveEndpointFailedException(uri, String.format("HOST provided: %s seem to be invalid. Remember SCHEME has to be excluded.", url)); - } - - LOG.debug("Uri=[{}], path=[{}], parameters=[{}]", new Object[] {URISupport.sanitizeUri(uri), URISupport.sanitizePath(remaining), parameters }); - - // Set configuration based on uri parameters - final CMConfiguration config = new CMConfiguration(); - setProperties(config, parameters); - - // Validate configuration - LOG.debug("Validating uri based configuration"); - final Set<ConstraintViolation<CMConfiguration>> constraintViolations = validator.validate(config); - if (constraintViolations.size() > 0) { - final StringBuffer msg = new StringBuffer(); - for (final ConstraintViolation<CMConfiguration> cv : constraintViolations) { - msg.append(String.format("- Invalid value for %s: %s", cv.getPropertyPath().toString(), cv.getMessage())); - } - throw new ResolveEndpointFailedException(uri, msg.toString()); - } - LOG.debug("CMConfiguration - OK!"); - - // Component is an Endpoint factory. So far, just one Endpoint type. - // Endpoint construction and configuration. - - LOG.debug("Creating CMEndpoint"); - final CMEndpoint endpoint = new CMEndpoint(uri, this); - endpoint.setConfiguration(config); - endpoint.setHost(remaining); - - return endpoint; - } - - public Validator getValidator() { - return validator; - } - -}
http://git-wip-us.apache.org/repos/asf/camel/blob/58515451/components/camel-cm/src/main/java/org/apache/camel/component/cm/CMConfiguration.java ---------------------------------------------------------------------- diff --git a/components/camel-cm/src/main/java/org/apache/camel/component/cm/CMConfiguration.java b/components/camel-cm/src/main/java/org/apache/camel/component/cm/CMConfiguration.java deleted file mode 100644 index c95c06e..0000000 --- a/components/camel-cm/src/main/java/org/apache/camel/component/cm/CMConfiguration.java +++ /dev/null @@ -1,92 +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.camel.component.cm; - -import java.util.UUID; - -import javax.validation.constraints.Max; -import javax.validation.constraints.Min; -import javax.validation.constraints.NotNull; -import javax.validation.constraints.Size; - -import org.apache.camel.spi.UriParam; -import org.apache.camel.spi.UriParams; - -@UriParams -public class CMConfiguration { - - @UriParam - @NotNull - private UUID productToken; - - /** - * This is the sender name. The maximum length is 11 characters. - */ - @UriParam - @NotNull - @Size(min = 1, max = 11) - private String defaultFrom; - - /** - * If it is a multipart message forces the max number. Message can be truncated. Technically the gateway will first check if a message is larger than 160 characters, if so, the message will be cut - * into multiple 153 characters parts limited by these parameters. <br> - * {@link https://dashboard.onlinesmsgateway.com/docs#send-a-message-multipart} - */ - @UriParam - @Max(8) - @Min(1) - private int defaultMaxNumberOfParts = 8; - - @UriParam - private boolean testConnectionOnStartup; - - public UUID getProductToken() { - return productToken; - } - - public void setProductToken(String productTokenAsString) { - productToken = UUID.fromString(productTokenAsString); - } - - public String getDefaultFrom() { - return defaultFrom; - } - - public void setDefaultFrom(final String defaultFrom) { - this.defaultFrom = defaultFrom; - } - - public int getDefaultMaxNumberOfParts() { - return defaultMaxNumberOfParts; - } - - public void setDefaultMaxNumberOfParts(final int defaultMaxNumberOfParts) { - this.defaultMaxNumberOfParts = defaultMaxNumberOfParts; - } - - public boolean isTestConnectionOnStartup() { - return testConnectionOnStartup; - } - - public void setTestConnectionOnStartup(final boolean testConnectionOnStartup) { - this.testConnectionOnStartup = testConnectionOnStartup; - } - - public void setProductTokenAsUUID(final UUID productToken) { - this.productToken = productToken; - } -} http://git-wip-us.apache.org/repos/asf/camel/blob/58515451/components/camel-cm/src/main/java/org/apache/camel/component/cm/CMConstants.java ---------------------------------------------------------------------- diff --git a/components/camel-cm/src/main/java/org/apache/camel/component/cm/CMConstants.java b/components/camel-cm/src/main/java/org/apache/camel/component/cm/CMConstants.java deleted file mode 100644 index afe8fde..0000000 --- a/components/camel-cm/src/main/java/org/apache/camel/component/cm/CMConstants.java +++ /dev/null @@ -1,44 +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.camel.component.cm; - -public interface CMConstants { - - String DEFAULT_SCHEME = "https://";; - - int DEFAULT_MULTIPARTS = 8; - - int MAX_UNICODE_MESSAGE_LENGTH = 70; - int MAX_GSM_MESSAGE_LENGTH = 160; - int MAX_UNICODE_MESSAGE_LENGTH_PER_PART_IF_MULTIPART = 67; - int MAX_GSM_MESSAGE_LENGTH_PER_PART_IF_MULTIPART = 153; - - // status code 200 - Error substrings - check it contains. - String ERROR_UNKNOWN = "Unknown error"; - String ERROR_NO_ACCOUNT = "No account found"; - String ERROR_INSUFICIENT_BALANCE = "Insufficient balance"; - String ERROR_UNROUTABLE_MESSAGE = "Message is unroutable"; - String ERROR_INVALID_PRODUCT_TOKEN = "Invalid product token"; - - // TODO: Review this pattern. - // or it should be foundnd an alternative to jcharset to check if a message is GSM 03.38 encodable - // See: - // https://en.wikipedia.org/wiki/GSM_03.38 - // http://frightanic.com/software-development/regex-for-gsm-03-38-7bit-character-set/ - String GSM_0338_REGEX = "^[A-Za-z0-9 \\r\\n@£$\u0394_\u03A6\u0393\u039B\u03A9\u03A0\u03A8\u03A3\u0398\u039E!\"#$%&'()*+,\\-./:;<=>?¡¿^{}\\\\\\[~\\]|" - + "\u20AC\u00a5\u00e8\u00e9\u00f9\u00ec\u00f2\u00c7\u00d8\u00f8\u00c5\u00e5\u00c6\u00e6\u00df\u00c9\u00c4\u00d6\u00d1\u00dc\u00a7\u00e4\u00f6\u00f1\u00fc\u00e0]*$"; -} http://git-wip-us.apache.org/repos/asf/camel/blob/58515451/components/camel-cm/src/main/java/org/apache/camel/component/cm/CMEndpoint.java ---------------------------------------------------------------------- diff --git a/components/camel-cm/src/main/java/org/apache/camel/component/cm/CMEndpoint.java b/components/camel-cm/src/main/java/org/apache/camel/component/cm/CMEndpoint.java deleted file mode 100644 index 860967d..0000000 --- a/components/camel-cm/src/main/java/org/apache/camel/component/cm/CMEndpoint.java +++ /dev/null @@ -1,141 +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.camel.component.cm; - -import org.apache.camel.Consumer; -import org.apache.camel.ExchangePattern; -import org.apache.camel.Processor; -import org.apache.camel.Producer; -import org.apache.camel.RuntimeCamelException; -import org.apache.camel.api.management.ManagedAttribute; -import org.apache.camel.api.management.ManagedOperation; -import org.apache.camel.api.management.ManagedResource; -import org.apache.camel.impl.DefaultEndpoint; -import org.apache.camel.spi.Metadata; -import org.apache.camel.spi.UriPath; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -@ManagedResource(description = "CM SMS Endpoint") -// @UriEndpoint(scheme = "cm", title = "CM DIRECT SMS", syntax = "cm:host", -// label = "sms provider", producerOnly = true) -public class CMEndpoint extends DefaultEndpoint { - - private static final Logger LOG = LoggerFactory.getLogger(CMEndpoint.class); - - @UriPath - @Metadata(description = "SMS Provider HOST with scheme", required = "true") - private String host; - - /** - * data needed for exchange interaction - */ - private CMConfiguration configuration; - - private CMProducer producer; - - /** - * Constructs a partially-initialized CMEndpoint instance. Useful when creating endpoints manually (e.g., as beans in Spring). - */ - // We are just going to allow fully initialized endpoint instances - // public CMEndpoint() { - // } - - /** - * Constructs a fully-initialized CMEndpoint instance. This is the preferred method of constructing an object from Java code (as opposed to Spring beans, etc.). - * - * @param endpointUri the full URI used to create this endpoint - * @param component the component that created this endpoint - */ - public CMEndpoint(final String uri, final CMComponent component) { - super(uri, component); - setExchangePattern(ExchangePattern.InOut); - LOG.debug("CM Endpoint created"); - } - - /** - * Provides a channel on which clients can send Messages to a CM Endpoint - */ - @Override - public Producer createProducer() throws Exception { - final CMConfiguration config = getConfiguration(); - - // This is the camel exchange processor. Allows to send messages to CM - // API. - // TODO: Should i provide a CMSender factory? Dynamically choose - // CMSender implementation? Sending strategy? - // Consider: - // 1. single - Single Message strategy. - // 2. Multi - CM Api supports to 1000 messages per call. - // 3. sliding - sliding window? 1000 messages or time thresold? - // 4. mocked - in order to fake cm responses - - // CMConstants.DEFAULT_SCHEME + host is a valid URL. It was previously - // checked - LOG.debug("Creating CM Producer"); - producer = new CMProducer(this, new CMSenderOneMessageImpl(getCMUrl(), config.getProductToken())); - LOG.debug("CM Producer: OK!"); - return producer; - } - - @Override - public Consumer createConsumer(final Processor processor) throws Exception { - - throw new RuntimeCamelException("So far, cannot consume from CM Endpoint: " + getEndpointUri()); - } - - public CMConfiguration getConfiguration() { - return configuration; - } - - public void setConfiguration(final CMConfiguration configuration) { - this.configuration = configuration; - } - - @Override - public boolean isSingleton() { - return true; - } - - // @Override - // public Exchange createExchange() { - // return super.createExchange(); - // } - - @ManagedAttribute - public String getHost() { - return host; - } - - public String getCMUrl() { - return CMConstants.DEFAULT_SCHEME + host; - } - - @ManagedOperation(description = "Dynamically modify Service HOST") - public void setHost(final String host) { - this.host = host; - } - - @Override - public CMComponent getComponent() { - return (CMComponent) super.getComponent(); - } - - public CMProducer getProducer() { - return producer; - } -} http://git-wip-us.apache.org/repos/asf/camel/blob/58515451/components/camel-cm/src/main/java/org/apache/camel/component/cm/CMMessage.java ---------------------------------------------------------------------- diff --git a/components/camel-cm/src/main/java/org/apache/camel/component/cm/CMMessage.java b/components/camel-cm/src/main/java/org/apache/camel/component/cm/CMMessage.java deleted file mode 100644 index 2f98936..0000000 --- a/components/camel-cm/src/main/java/org/apache/camel/component/cm/CMMessage.java +++ /dev/null @@ -1,153 +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.camel.component.cm; - -/** - * Valid message to be serialized and sent to CM Endpoints. If the message only uses GSM 7-bit characters, then 160 characters will fit in 1 SMS part, and 153*n characters will fit in n SMS parts for - * n>1. If the message contains other characters, then only 70 characters will fit in 1 SMS part, and 67*n characters will fit in n SMS parts for n>1. <br> - * <br> - * {@link https://dashboard.onlinesmsgateway.com/docs} <br> - * {@link http://support.telerivet.com/customer/portal/articles/1957426-multipart-unicode-sms-messages} - */ -public class CMMessage { - - /** - * Restrictions: 1 - 32 alphanumeric characters and reference will not work for demo accounts - */ - // TODO: use a ID generator? - private String idAsString; - - private String phoneNumber; - private String message; - - private String sender; - - private boolean unicode; - private int multipart = 1; - - public CMMessage(final String phoneNumber, final String message) { - this.message = message; - this.phoneNumber = phoneNumber; - } - - public String getMessage() { - return message; - } - - public void setMessage(final String message) { - this.message = message; - } - - public String getPhoneNumber() { - return phoneNumber; - } - - public void setPhoneNumber(final String phoneNumber) { - this.phoneNumber = phoneNumber; - } - - public String getSender() { - return sender; - } - - public void setSender(final String sender) { - this.sender = sender; - } - - public String getIdAsString() { - return idAsString; - } - - public void setIdAsString(final String idAsString) { - this.idAsString = idAsString; - } - - public boolean isUnicode() { - return unicode; - } - - public void setUnicode(final boolean unicode) { - this.unicode = unicode; - } - - public boolean isMultipart() { - return multipart > 1; - } - - /** - * For a CMMessage instance - * - * @param defaultMaxNumberOfParts - */ - public void setUnicodeAndMultipart(int defaultMaxNumberOfParts) { - - // Set UNICODE and MULTIPART - final String msg = getMessage(); - if (CMUtils.isGsm0338Encodeable(msg)) { - - // Not Unicode is Multipart? - if (msg.length() > CMConstants.MAX_GSM_MESSAGE_LENGTH) { - - // Multiparts. 153 caracteres max per part - int parts = msg.length() / CMConstants.MAX_GSM_MESSAGE_LENGTH_PER_PART_IF_MULTIPART; - if (msg.length() % CMConstants.MAX_GSM_MESSAGE_LENGTH_PER_PART_IF_MULTIPART != 0) { - parts++; - } - - setMultiparts((parts > defaultMaxNumberOfParts) ? defaultMaxNumberOfParts : parts); - } else { // Otherwise multipart = 1 - setMultiparts(1); - } - } else { - // Unicode Message - setUnicode(true); - - if (msg.length() > CMConstants.MAX_UNICODE_MESSAGE_LENGTH) { - - // Multiparts. 67 caracteres max per part - int parts = msg.length() / CMConstants.MAX_UNICODE_MESSAGE_LENGTH_PER_PART_IF_MULTIPART; - if (msg.length() % CMConstants.MAX_UNICODE_MESSAGE_LENGTH_PER_PART_IF_MULTIPART != 0) { - parts++; - } - - setMultiparts((parts > defaultMaxNumberOfParts) ? defaultMaxNumberOfParts : parts); - } else { // Otherwise multipart = 1 - setMultiparts(1); - } - } - } - - public void setMultiparts(final int multipart) { - this.multipart = multipart; - } - - public int getMultiparts() { - return multipart; - } - - @Override - public String toString() { - - StringBuffer sb = new StringBuffer(" {phoneNumber: " + phoneNumber + ", message: " + message + ", sender=" + sender + ", unicode: " + unicode + ", multipart: " + multipart); - if (idAsString != null && !idAsString.isEmpty()) { - sb.append(", idAsString=" + idAsString); - } - sb.append(" }"); - return sb.toString(); - } - -} http://git-wip-us.apache.org/repos/asf/camel/blob/58515451/components/camel-cm/src/main/java/org/apache/camel/component/cm/CMProducer.java ---------------------------------------------------------------------- diff --git a/components/camel-cm/src/main/java/org/apache/camel/component/cm/CMProducer.java b/components/camel-cm/src/main/java/org/apache/camel/component/cm/CMProducer.java deleted file mode 100644 index e4f5722..0000000 --- a/components/camel-cm/src/main/java/org/apache/camel/component/cm/CMProducer.java +++ /dev/null @@ -1,149 +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.camel.component.cm; - -import java.util.Set; - -import javax.validation.ConstraintViolation; -import javax.validation.Validator; - -import org.apache.camel.Exchange; -import org.apache.camel.InvalidPayloadRuntimeException; -import org.apache.camel.component.cm.client.SMSMessage; -import org.apache.camel.component.cm.exceptions.HostUnavailableException; -import org.apache.camel.impl.DefaultProducer; -import org.apache.http.client.methods.HttpHead; -import org.apache.http.impl.client.HttpClientBuilder; - -/** - * is the exchange processor. Sends a validated sms message to CM Endpoints. - */ -public class CMProducer extends DefaultProducer { - - private Validator validator; - - /** - * sends a valid message to CM endpoints. - */ - private CMSender sender; - - public CMProducer(final CMEndpoint endpoint, final CMSender sender) { - super(endpoint); - this.sender = sender; - } - - /** - * Producer is a exchange processor. This process is built in several steps. 1. Validate message receive from client 2. Send validated message to CM endpoints. 3. Process response from CM - * endpoints. - */ - @Override - public void process(final Exchange exchange) throws Exception { - - // Immutable message receive from clients. Throws camel ' s - // InvalidPayloadException - final SMSMessage smsMessage = exchange.getIn().getMandatoryBody(SMSMessage.class); - - // Validates Payload - SMSMessage - log.trace("Validating SMSMessage instance provided: {}", smsMessage.toString()); - final Set<ConstraintViolation<SMSMessage>> constraintViolations = getValidator().validate(smsMessage); - if (constraintViolations.size() > 0) { - final StringBuffer msg = new StringBuffer(); - for (final ConstraintViolation<SMSMessage> cv : constraintViolations) { - msg.append(String.format("- Invalid value for %s: %s", cv.getPropertyPath().toString(), cv.getMessage())); - } - log.debug(msg.toString()); - throw new InvalidPayloadRuntimeException(exchange, SMSMessage.class); - } - log.trace("SMSMessage instance is valid: {}", smsMessage.toString()); - - // We have a valid (immutable) SMSMessage instance, lets extend to - // CMMessage - // This is the instance we will use to build the XML document to be - // sent to CM SMS GW. - final CMMessage cmMessage = new CMMessage(smsMessage.getPhoneNumber(), smsMessage.getMessage()); - log.debug("CMMessage instance build from valid SMSMessage instance"); - - if (smsMessage.getFrom() == null || smsMessage.getFrom().isEmpty()) { - String df = getConfiguration().getDefaultFrom(); - cmMessage.setSender(df); - log.debug("Dynamic sender is set to default dynamic sender: {}", df); - } - - // Remember, this can be null. - cmMessage.setIdAsString(smsMessage.getId()); - - // Unicode and multipart - cmMessage.setUnicodeAndMultipart(getConfiguration().getDefaultMaxNumberOfParts()); - - // 2. Send a validated sms message to CM endpoints - // for abnormal situations. - sender.send(cmMessage); - - log.debug("Request accepted by CM Host: {}", cmMessage.toString()); - } - - @Override - protected void doStart() throws Exception { - - // log at debug level for singletons, for prototype scoped log at trace - // level to not spam logs - - log.debug("Starting CMProducer"); - - final CMConfiguration configuration = getConfiguration(); - - if (configuration.isTestConnectionOnStartup()) { - try { - log.debug("Checking connection - {}", getEndpoint().getCMUrl()); - HttpClientBuilder.create().build().execute(new HttpHead(getEndpoint().getCMUrl())); - log.debug("Connection to {}: OK", getEndpoint().getCMUrl()); - } catch (final Exception e) { - throw new HostUnavailableException(String.format("Connection to %s: NOT AVAILABLE", getEndpoint().getCMUrl()), e); - } - } - - // keep starting - super.doStart(); - - log.debug("CMProducer started"); - } - - @Override - public CMEndpoint getEndpoint() { - return (CMEndpoint) super.getEndpoint(); - } - - public CMConfiguration getConfiguration() { - return getEndpoint().getConfiguration(); - } - - public Validator getValidator() { - if (validator == null) { - validator = getEndpoint().getComponent().getValidator(); - } - return validator; - } - - public CMSender getSender() { - return sender; - } - - public void setSender(CMSender sender) { - this.sender = sender; - } - -} http://git-wip-us.apache.org/repos/asf/camel/blob/58515451/components/camel-cm/src/main/java/org/apache/camel/component/cm/CMSender.java ---------------------------------------------------------------------- diff --git a/components/camel-cm/src/main/java/org/apache/camel/component/cm/CMSender.java b/components/camel-cm/src/main/java/org/apache/camel/component/cm/CMSender.java deleted file mode 100644 index 661f4dd..0000000 --- a/components/camel-cm/src/main/java/org/apache/camel/component/cm/CMSender.java +++ /dev/null @@ -1,28 +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.camel.component.cm; - -/** - * Sends a validated sms message to CM endpoints - */ -public interface CMSender { - - /** - * Sends a validated sms message to CM Endpoints. - */ - void send(CMMessage cmMessage); -} http://git-wip-us.apache.org/repos/asf/camel/blob/58515451/components/camel-cm/src/main/java/org/apache/camel/component/cm/CMSenderOneMessageImpl.java ---------------------------------------------------------------------- diff --git a/components/camel-cm/src/main/java/org/apache/camel/component/cm/CMSenderOneMessageImpl.java b/components/camel-cm/src/main/java/org/apache/camel/component/cm/CMSenderOneMessageImpl.java deleted file mode 100644 index 07e0e14..0000000 --- a/components/camel-cm/src/main/java/org/apache/camel/component/cm/CMSenderOneMessageImpl.java +++ /dev/null @@ -1,254 +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.camel.component.cm; - -import java.io.BufferedReader; -import java.io.ByteArrayOutputStream; -import java.io.IOException; -import java.io.InputStreamReader; -import java.nio.charset.Charset; -import java.util.UUID; - -import javax.xml.parsers.DocumentBuilder; -import javax.xml.parsers.DocumentBuilderFactory; -import javax.xml.parsers.ParserConfigurationException; -import javax.xml.transform.OutputKeys; -import javax.xml.transform.Result; -import javax.xml.transform.Source; -import javax.xml.transform.Transformer; -import javax.xml.transform.TransformerException; -import javax.xml.transform.TransformerFactory; -import javax.xml.transform.dom.DOMSource; -import javax.xml.transform.stream.StreamResult; - -import org.w3c.dom.DOMImplementation; -import org.w3c.dom.Document; -import org.w3c.dom.Element; -import org.w3c.dom.Text; - -import org.apache.camel.component.cm.exceptions.CMDirectException; -import org.apache.camel.component.cm.exceptions.XMLConstructionException; -import org.apache.camel.component.cm.exceptions.cmresponse.CMResponseException; -import org.apache.camel.component.cm.exceptions.cmresponse.InsufficientBalanceException; -import org.apache.camel.component.cm.exceptions.cmresponse.InvalidProductTokenException; -import org.apache.camel.component.cm.exceptions.cmresponse.NoAccountFoundForProductTokenException; -import org.apache.camel.component.cm.exceptions.cmresponse.UnknownErrorException; -import org.apache.camel.component.cm.exceptions.cmresponse.UnroutableMessageException; -import org.apache.http.HttpResponse; -import org.apache.http.client.HttpClient; -import org.apache.http.client.methods.HttpPost; -import org.apache.http.entity.StringEntity; -import org.apache.http.impl.client.HttpClientBuilder; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -public class CMSenderOneMessageImpl implements CMSender { - - private static final Logger LOG = LoggerFactory.getLogger(CMSenderOneMessageImpl.class); - - private final String url; - private final UUID productToken; - - public CMSenderOneMessageImpl(final String url, final UUID productToken) { - - this.url = url; - this.productToken = productToken; - } - - /** - * Sends a message to CM endpoints. 1. CMMessage instance is going to be marshalled to xml. 2. Post request xml string to CMEndpoint. - */ - @Override - public void send(final CMMessage cmMessage) { - - // See: Check https://dashboard.onlinesmsgateway.com/docs for responses - - // 1.Construct XML. Throws XMLConstructionException - final String xml = createXml(cmMessage); - - // 2. Try to send to CM SMS Provider ...Throws CMResponseException - doHttpPost(url, xml); - } - - private String createXml(final CMMessage message) { - - try { - - final ByteArrayOutputStream xml = new ByteArrayOutputStream(); - final DocumentBuilderFactory factory = DocumentBuilderFactory.newInstance(); - factory.setNamespaceAware(true); - - // Get the DocumentBuilder - final DocumentBuilder docBuilder = factory.newDocumentBuilder(); - - // Create blank DOM Document - final DOMImplementation impl = docBuilder.getDOMImplementation(); - final Document doc = impl.createDocument(null, "MESSAGES", null); - - // ROOT Element es MESSAGES - final Element root = doc.getDocumentElement(); - - // AUTHENTICATION element - final Element authenticationElement = doc.createElement("AUTHENTICATION"); - final Element productTokenElement = doc.createElement("PRODUCTTOKEN"); - authenticationElement.appendChild(productTokenElement); - final Text productTokenValue = doc.createTextNode("" + productToken); - productTokenElement.appendChild(productTokenValue); - root.appendChild(authenticationElement); - - // MSG Element - final Element msgElement = doc.createElement("MSG"); - root.appendChild(msgElement); - - // <FROM>VALUE</FROM> - final Element fromElement = doc.createElement("FROM"); - fromElement.appendChild(doc.createTextNode(message.getSender())); - msgElement.appendChild(fromElement); - - // <BODY>VALUE</BODY> - final Element bodyElement = doc.createElement("BODY"); - bodyElement.appendChild(doc.createTextNode(message.getMessage())); - msgElement.appendChild(bodyElement); - - // <TO>VALUE</TO> - final Element toElement = doc.createElement("TO"); - toElement.appendChild(doc.createTextNode(message.getPhoneNumber())); - msgElement.appendChild(toElement); - - // <DCS>VALUE</DCS> - if UNICODE - messageOut.isGSM338Enc - // false - if (message.isUnicode()) { - final Element dcsElement = doc.createElement("DCS"); - dcsElement.appendChild(doc.createTextNode("8")); - msgElement.appendChild(dcsElement); - } - - // <REFERENCE>VALUE</REFERENCE> -Alfanum - final String id = message.getIdAsString(); - if (id != null && !id.isEmpty()) { - final Element refElement = doc.createElement("REFERENCE"); - refElement.appendChild(doc.createTextNode("" + message.getIdAsString())); - msgElement.appendChild(refElement); - } - - // <MINIMUMNUMBEROFMESSAGEPARTS>1</MINIMUMNUMBEROFMESSAGEPARTS> - // <MAXIMUMNUMBEROFMESSAGEPARTS>8</MAXIMUMNUMBEROFMESSAGEPARTS> - if (message.isMultipart()) { - final Element minMessagePartsElement = doc.createElement("MINIMUMNUMBEROFMESSAGEPARTS"); - minMessagePartsElement.appendChild(doc.createTextNode("1")); - msgElement.appendChild(minMessagePartsElement); - - final Element maxMessagePartsElement = doc.createElement("MAXIMUMNUMBEROFMESSAGEPARTS"); - maxMessagePartsElement.appendChild(doc.createTextNode(Integer.toString(message.getMultiparts()))); - msgElement.appendChild(maxMessagePartsElement); - } - - // Creatate XML as String - final Transformer aTransformer = TransformerFactory.newInstance().newTransformer(); - aTransformer.setOutputProperty(OutputKeys.INDENT, "yes"); - final Source src = new DOMSource(doc); - final Result dest = new StreamResult(xml); - aTransformer.transform(src, dest); - return xml.toString(); - } catch (final TransformerException e) { - throw new XMLConstructionException(String.format("Cant serialize CMMessage %s", message), e); - } catch (final ParserConfigurationException e) { - throw new XMLConstructionException(String.format("Cant serialize CMMessage %s", message), e); - } - } - - private void doHttpPost(final String urlString, final String requestString) { - - final HttpClient client = HttpClientBuilder.create().build(); - final HttpPost post = new HttpPost(urlString); - post.setEntity(new StringEntity(requestString, Charset.forName("UTF-8"))); - - try { - - final HttpResponse response = client.execute(post); - - final int statusCode = response.getStatusLine().getStatusCode(); - - LOG.debug("Response Code : {}", statusCode); - - if (statusCode == 400) { - throw new CMDirectException("CM Component and CM API show some kind of inconsistency. " - + "CM is complaining about not using a post method for the request. And this component only uses POST requests. What happens?"); - } - - if (statusCode != 200) { - throw new CMDirectException("CM Component and CM API show some kind of inconsistency. The component expects the status code to be 200 or 400. New api released? "); - } - - // So we have 200 status code... - - // The response type is 'text/plain' and contains the actual - // result of the request processing. - - // We obtaing the result text - final BufferedReader rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent())); - - final StringBuffer result = new StringBuffer(); - String line = null; - while ((line = rd.readLine()) != null) { - result.append(line); - } - - // ... and process it - - line = result.toString(); - if (!line.isEmpty()) { - - // Line is not empty = error - LOG.debug("Result of the request processing: FAILED\n{}", line); - - // The response text contains the error description. We will - // throw a custom exception for each. - - if (line.contains(CMConstants.ERROR_UNKNOWN)) { - throw new UnknownErrorException(); - } else if (line.contains(CMConstants.ERROR_NO_ACCOUNT)) { - throw new NoAccountFoundForProductTokenException(); - } else if (line.contains(CMConstants.ERROR_INSUFICIENT_BALANCE)) { - throw new InsufficientBalanceException(); - } else if (line.contains(CMConstants.ERROR_UNROUTABLE_MESSAGE)) { - throw new UnroutableMessageException(); - } else if (line.contains(CMConstants.ERROR_INVALID_PRODUCT_TOKEN)) { - throw new InvalidProductTokenException(); - } else { - - // SO FAR i would expect other kind of ERROR. - - // MSISDN correctness and message validity is client - // responsibility - throw new CMResponseException("CHECK ME. I am not expecting this. "); - } - } - - // Ok. Line is EMPTY - successfully submitted - LOG.debug("Result of the request processing: Successfully submited"); - } catch (final IOException io) { - throw new CMDirectException(io); - } catch (Throwable t) { - if (!(t instanceof CMDirectException)) { - // Chain it - t = new CMDirectException(t); - } - throw (CMDirectException) t; - } - } -} http://git-wip-us.apache.org/repos/asf/camel/blob/58515451/components/camel-cm/src/main/java/org/apache/camel/component/cm/CMUtils.java ---------------------------------------------------------------------- diff --git a/components/camel-cm/src/main/java/org/apache/camel/component/cm/CMUtils.java b/components/camel-cm/src/main/java/org/apache/camel/component/cm/CMUtils.java deleted file mode 100644 index f0581da..0000000 --- a/components/camel-cm/src/main/java/org/apache/camel/component/cm/CMUtils.java +++ /dev/null @@ -1,30 +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.camel.component.cm; - -public final class CMUtils { - - private CMUtils() { - } - - public static boolean isGsm0338Encodeable(final String message) { - return message.matches(CMConstants.GSM_0338_REGEX); - } - - // TODO: Have a look at - // https:// github.com/apache/camel/blob/master/components/camel-smpp/src/main/java/org/apache/camel/component/smpp/SmppUtils.java -} http://git-wip-us.apache.org/repos/asf/camel/blob/58515451/components/camel-cm/src/main/java/org/apache/camel/component/cm/client/SMSMessage.java ---------------------------------------------------------------------- diff --git a/components/camel-cm/src/main/java/org/apache/camel/component/cm/client/SMSMessage.java b/components/camel-cm/src/main/java/org/apache/camel/component/cm/client/SMSMessage.java deleted file mode 100644 index 869c9f8..0000000 --- a/components/camel-cm/src/main/java/org/apache/camel/component/cm/client/SMSMessage.java +++ /dev/null @@ -1,114 +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.camel.component.cm.client; - -import javax.validation.constraints.NotNull; -import javax.validation.constraints.Pattern; -import javax.validation.constraints.Size; - -import org.apache.camel.component.cm.validation.constraints.E164; - -/** - * Immutable. The message instance provided by the client. - */ -public class SMSMessage { - - /** - * Required MSISDN. E164 value. The destination phone number. Format with a '+' and country code. - * - * @see <a href="https://en.wikipedia.org/wiki/E.164";>https://en.wikipedia.org/wiki/E.164</a> - */ - @E164 - private final String phoneNumber; - - /** - * This is the message to be sent. 2 options: - * <ul> - * <li>If the message is GSM 0038 encodeable the gateway will first check if a message is larger than 160 characters, if so, the message will be cut into multiple 153 characters parts limited by - * defaultMaxNumberOfParts set in the component uri.</li> - * <li>Otherwise, the gateway will check if a message is larger than 70 characters, if so, the message will be cut into multiple 67 characters parts to a maximum of defaultMaxNumberOfParts set in - * the component uri.</li> - * </ul> - * - * @see <a href="https://en.wikipedia.org/wiki/GSM_03.38";>E.164</a> - */ - @NotNull - private final String message; - - /** - * This is an optional dynamic sender name. - * <p> - * 1 - 11 alphanumeric characters and + char. Not Empty Strings. This field has a maximum length of 11 characters. If it is not set the defaultFrom required to configure the component will be set. - */ - @Size(min = 1, max = 11) - @Pattern(regexp = "^[A-Za-z0-9]+$") - private final String from; - - /** - * Unique identifier for a message. - * <p> - * 1 - 32 alphanumeric characters. Not Empty Strings. Will not work for demo accounts. This field corresponds to REFERENCE parameter in CM Api. - */ - @Size(min = 1, max = 32) - @Pattern(regexp = "^[A-Za-z0-9]+$") - private final String id; - - public SMSMessage(final String message, final String phoneNumber) { - this(null, message, phoneNumber, null); - } - - public SMSMessage(String id, final String message, final String phoneNumber) { - this(id, message, phoneNumber, null); - } - - public SMSMessage(final String id, final String message, final String phoneNumber, final String from) { - this.id = id; - this.message = message; - this.phoneNumber = phoneNumber; - this.from = from; - } - - public String getId() { - return id; - } - - public String getMessage() { - return message; - } - - public String getPhoneNumber() { - return phoneNumber; - } - - public String getFrom() { - return from; - } - - @Override - public String toString() { - StringBuffer toS = new StringBuffer("{phoneNumber: " + phoneNumber + ", message: " + message); - if (from != null && !from.isEmpty()) { - toS.append(", from: " + from); - } - if (id != null && !id.isEmpty()) { - toS.append(", id: " + id); - } - toS.append(" }"); - return toS.toString(); - } - -} http://git-wip-us.apache.org/repos/asf/camel/blob/58515451/components/camel-cm/src/main/java/org/apache/camel/component/cm/client/Translator.java ---------------------------------------------------------------------- diff --git a/components/camel-cm/src/main/java/org/apache/camel/component/cm/client/Translator.java b/components/camel-cm/src/main/java/org/apache/camel/component/cm/client/Translator.java deleted file mode 100644 index 4c6e9e9..0000000 --- a/components/camel-cm/src/main/java/org/apache/camel/component/cm/client/Translator.java +++ /dev/null @@ -1,23 +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.camel.component.cm.client; - -public interface Translator<T> { - - SMSMessage translate(T t); - -} http://git-wip-us.apache.org/repos/asf/camel/blob/58515451/components/camel-cm/src/main/java/org/apache/camel/component/cm/exceptions/CMDirectException.java ---------------------------------------------------------------------- diff --git a/components/camel-cm/src/main/java/org/apache/camel/component/cm/exceptions/CMDirectException.java b/components/camel-cm/src/main/java/org/apache/camel/component/cm/exceptions/CMDirectException.java deleted file mode 100644 index 70912ff..0000000 --- a/components/camel-cm/src/main/java/org/apache/camel/component/cm/exceptions/CMDirectException.java +++ /dev/null @@ -1,40 +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.camel.component.cm.exceptions; - -public class CMDirectException extends RuntimeException { - - public CMDirectException() { - } - - public CMDirectException(final String message) { - super(message); - } - - public CMDirectException(final Throwable cause) { - super(cause); - } - - public CMDirectException(final String message, final Throwable cause) { - super(message, cause); - } - - public CMDirectException(final String message, final Throwable cause, - final boolean enableSuppression, final boolean writableStackTrace) { - super(message, cause, enableSuppression, writableStackTrace); - } -} http://git-wip-us.apache.org/repos/asf/camel/blob/58515451/components/camel-cm/src/main/java/org/apache/camel/component/cm/exceptions/HostUnavailableException.java ---------------------------------------------------------------------- diff --git a/components/camel-cm/src/main/java/org/apache/camel/component/cm/exceptions/HostUnavailableException.java b/components/camel-cm/src/main/java/org/apache/camel/component/cm/exceptions/HostUnavailableException.java deleted file mode 100644 index 73bf0d0..0000000 --- a/components/camel-cm/src/main/java/org/apache/camel/component/cm/exceptions/HostUnavailableException.java +++ /dev/null @@ -1,39 +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.camel.component.cm.exceptions; - -public class HostUnavailableException extends CMDirectException { - - public HostUnavailableException() { - } - - public HostUnavailableException(final String message) { - super(message); - } - - public HostUnavailableException(final Throwable cause) { - super(cause); - } - - public HostUnavailableException(final String message, final Throwable cause) { - super(message, cause); - } - - public HostUnavailableException(final String message, final Throwable cause, final boolean enableSuppression, final boolean writableStackTrace) { - super(message, cause, enableSuppression, writableStackTrace); - } -} http://git-wip-us.apache.org/repos/asf/camel/blob/58515451/components/camel-cm/src/main/java/org/apache/camel/component/cm/exceptions/XMLConstructionException.java ---------------------------------------------------------------------- diff --git a/components/camel-cm/src/main/java/org/apache/camel/component/cm/exceptions/XMLConstructionException.java b/components/camel-cm/src/main/java/org/apache/camel/component/cm/exceptions/XMLConstructionException.java deleted file mode 100644 index 5086e70..0000000 --- a/components/camel-cm/src/main/java/org/apache/camel/component/cm/exceptions/XMLConstructionException.java +++ /dev/null @@ -1,39 +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.camel.component.cm.exceptions; - -public class XMLConstructionException extends CMDirectException { - - public XMLConstructionException() { - } - - public XMLConstructionException(final String message) { - super(message); - } - - public XMLConstructionException(final Throwable cause) { - super(cause); - } - - public XMLConstructionException(final String message, final Throwable cause) { - super(message, cause); - } - - public XMLConstructionException(final String message, final Throwable cause, final boolean enableSuppression, final boolean writableStackTrace) { - super(message, cause, enableSuppression, writableStackTrace); - } -} http://git-wip-us.apache.org/repos/asf/camel/blob/58515451/components/camel-cm/src/main/java/org/apache/camel/component/cm/exceptions/cmresponse/CMResponseException.java ---------------------------------------------------------------------- diff --git a/components/camel-cm/src/main/java/org/apache/camel/component/cm/exceptions/cmresponse/CMResponseException.java b/components/camel-cm/src/main/java/org/apache/camel/component/cm/exceptions/cmresponse/CMResponseException.java deleted file mode 100644 index 4ed4f6e..0000000 --- a/components/camel-cm/src/main/java/org/apache/camel/component/cm/exceptions/cmresponse/CMResponseException.java +++ /dev/null @@ -1,41 +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.camel.component.cm.exceptions.cmresponse; - -import org.apache.camel.component.cm.exceptions.CMDirectException; - -public class CMResponseException extends CMDirectException { - - public CMResponseException() { - } - - public CMResponseException(final String message) { - super(message); - } - - public CMResponseException(final Throwable cause) { - super(cause); - } - - public CMResponseException(final String message, final Throwable cause) { - super(message, cause); - } - - public CMResponseException(final String message, final Throwable cause, final boolean enableSuppression, final boolean writableStackTrace) { - super(message, cause, enableSuppression, writableStackTrace); - } -} http://git-wip-us.apache.org/repos/asf/camel/blob/58515451/components/camel-cm/src/main/java/org/apache/camel/component/cm/exceptions/cmresponse/InsufficientBalanceException.java ---------------------------------------------------------------------- diff --git a/components/camel-cm/src/main/java/org/apache/camel/component/cm/exceptions/cmresponse/InsufficientBalanceException.java b/components/camel-cm/src/main/java/org/apache/camel/component/cm/exceptions/cmresponse/InsufficientBalanceException.java deleted file mode 100644 index bb73cc5..0000000 --- a/components/camel-cm/src/main/java/org/apache/camel/component/cm/exceptions/cmresponse/InsufficientBalanceException.java +++ /dev/null @@ -1,26 +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.camel.component.cm.exceptions.cmresponse; - -/** - * You are out of trial messages. Order new messages via your dashboard. - */ -public class InsufficientBalanceException extends CMResponseException { - - public InsufficientBalanceException() { - } -} http://git-wip-us.apache.org/repos/asf/camel/blob/58515451/components/camel-cm/src/main/java/org/apache/camel/component/cm/exceptions/cmresponse/InvalidMSISDNException.java ---------------------------------------------------------------------- diff --git a/components/camel-cm/src/main/java/org/apache/camel/component/cm/exceptions/cmresponse/InvalidMSISDNException.java b/components/camel-cm/src/main/java/org/apache/camel/component/cm/exceptions/cmresponse/InvalidMSISDNException.java deleted file mode 100644 index c80fbdd..0000000 --- a/components/camel-cm/src/main/java/org/apache/camel/component/cm/exceptions/cmresponse/InvalidMSISDNException.java +++ /dev/null @@ -1,23 +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.camel.component.cm.exceptions.cmresponse; - -public class InvalidMSISDNException extends CMResponseException { - - public InvalidMSISDNException() { - } -} http://git-wip-us.apache.org/repos/asf/camel/blob/58515451/components/camel-cm/src/main/java/org/apache/camel/component/cm/exceptions/cmresponse/InvalidProductTokenException.java ---------------------------------------------------------------------- diff --git a/components/camel-cm/src/main/java/org/apache/camel/component/cm/exceptions/cmresponse/InvalidProductTokenException.java b/components/camel-cm/src/main/java/org/apache/camel/component/cm/exceptions/cmresponse/InvalidProductTokenException.java deleted file mode 100644 index ce81bcb..0000000 --- a/components/camel-cm/src/main/java/org/apache/camel/component/cm/exceptions/cmresponse/InvalidProductTokenException.java +++ /dev/null @@ -1,26 +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.camel.component.cm.exceptions.cmresponse; - -/** - * Invalid or missing - */ -public class InvalidProductTokenException extends CMResponseException { - - public InvalidProductTokenException() { - } -} http://git-wip-us.apache.org/repos/asf/camel/blob/58515451/components/camel-cm/src/main/java/org/apache/camel/component/cm/exceptions/cmresponse/NoAccountFoundForProductTokenException.java ---------------------------------------------------------------------- diff --git a/components/camel-cm/src/main/java/org/apache/camel/component/cm/exceptions/cmresponse/NoAccountFoundForProductTokenException.java b/components/camel-cm/src/main/java/org/apache/camel/component/cm/exceptions/cmresponse/NoAccountFoundForProductTokenException.java deleted file mode 100644 index a718ff3..0000000 --- a/components/camel-cm/src/main/java/org/apache/camel/component/cm/exceptions/cmresponse/NoAccountFoundForProductTokenException.java +++ /dev/null @@ -1,28 +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.camel.component.cm.exceptions.cmresponse; - -/** - * No account found for the provided product token. - * - * @author Omar - */ -public class NoAccountFoundForProductTokenException extends CMResponseException { - - public NoAccountFoundForProductTokenException() { - } -} http://git-wip-us.apache.org/repos/asf/camel/blob/58515451/components/camel-cm/src/main/java/org/apache/camel/component/cm/exceptions/cmresponse/NoMessageException.java ---------------------------------------------------------------------- diff --git a/components/camel-cm/src/main/java/org/apache/camel/component/cm/exceptions/cmresponse/NoMessageException.java b/components/camel-cm/src/main/java/org/apache/camel/component/cm/exceptions/cmresponse/NoMessageException.java deleted file mode 100644 index 4398219..0000000 --- a/components/camel-cm/src/main/java/org/apache/camel/component/cm/exceptions/cmresponse/NoMessageException.java +++ /dev/null @@ -1,23 +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.camel.component.cm.exceptions.cmresponse; - -public class NoMessageException extends CMResponseException { - - public NoMessageException() { - } -} http://git-wip-us.apache.org/repos/asf/camel/blob/58515451/components/camel-cm/src/main/java/org/apache/camel/component/cm/exceptions/cmresponse/NotPhoneNumberFoundException.java ---------------------------------------------------------------------- diff --git a/components/camel-cm/src/main/java/org/apache/camel/component/cm/exceptions/cmresponse/NotPhoneNumberFoundException.java b/components/camel-cm/src/main/java/org/apache/camel/component/cm/exceptions/cmresponse/NotPhoneNumberFoundException.java deleted file mode 100644 index 877b972..0000000 --- a/components/camel-cm/src/main/java/org/apache/camel/component/cm/exceptions/cmresponse/NotPhoneNumberFoundException.java +++ /dev/null @@ -1,23 +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.camel.component.cm.exceptions.cmresponse; - -public class NotPhoneNumberFoundException extends CMResponseException { - - public NotPhoneNumberFoundException() { - } -} http://git-wip-us.apache.org/repos/asf/camel/blob/58515451/components/camel-cm/src/main/java/org/apache/camel/component/cm/exceptions/cmresponse/UnknownErrorException.java ---------------------------------------------------------------------- diff --git a/components/camel-cm/src/main/java/org/apache/camel/component/cm/exceptions/cmresponse/UnknownErrorException.java b/components/camel-cm/src/main/java/org/apache/camel/component/cm/exceptions/cmresponse/UnknownErrorException.java deleted file mode 100644 index bb0951a..0000000 --- a/components/camel-cm/src/main/java/org/apache/camel/component/cm/exceptions/cmresponse/UnknownErrorException.java +++ /dev/null @@ -1,26 +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.camel.component.cm.exceptions.cmresponse; - -/** - * An unexpected error occurred. Check the provided values. Contact CM for support. - */ -public class UnknownErrorException extends CMResponseException { - - public UnknownErrorException() { - } -} http://git-wip-us.apache.org/repos/asf/camel/blob/58515451/components/camel-cm/src/main/java/org/apache/camel/component/cm/exceptions/cmresponse/UnroutableMessageException.java ---------------------------------------------------------------------- diff --git a/components/camel-cm/src/main/java/org/apache/camel/component/cm/exceptions/cmresponse/UnroutableMessageException.java b/components/camel-cm/src/main/java/org/apache/camel/component/cm/exceptions/cmresponse/UnroutableMessageException.java deleted file mode 100644 index ec07c1f..0000000 --- a/components/camel-cm/src/main/java/org/apache/camel/component/cm/exceptions/cmresponse/UnroutableMessageException.java +++ /dev/null @@ -1,23 +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.camel.component.cm.exceptions.cmresponse; - -public class UnroutableMessageException extends CMResponseException { - - public UnroutableMessageException() { - } -} http://git-wip-us.apache.org/repos/asf/camel/blob/58515451/components/camel-cm/src/main/java/org/apache/camel/component/cm/validation/constraints/E164.java ---------------------------------------------------------------------- diff --git a/components/camel-cm/src/main/java/org/apache/camel/component/cm/validation/constraints/E164.java b/components/camel-cm/src/main/java/org/apache/camel/component/cm/validation/constraints/E164.java deleted file mode 100644 index 3d7dd95..0000000 --- a/components/camel-cm/src/main/java/org/apache/camel/component/cm/validation/constraints/E164.java +++ /dev/null @@ -1,41 +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.camel.component.cm.validation.constraints; - -import java.lang.annotation.Documented; -import java.lang.annotation.ElementType; -import java.lang.annotation.Retention; -import java.lang.annotation.RetentionPolicy; -import java.lang.annotation.Target; - -import javax.validation.Constraint; -import javax.validation.Payload; - -@Target({ ElementType.FIELD, ElementType.METHOD, ElementType.PARAMETER, - ElementType.ANNOTATION_TYPE }) -@Retention(RetentionPolicy.RUNTIME) -@Constraint(validatedBy = E164Validator.class) -@Documented -public @interface E164 { - - // String message() default "{e164.message}"; - String message() default "E164 format expected for that phone number"; - - Class<?>[] groups() default {}; - - Class<? extends Payload>[] payload() default {}; -} http://git-wip-us.apache.org/repos/asf/camel/blob/58515451/components/camel-cm/src/main/java/org/apache/camel/component/cm/validation/constraints/E164Validator.java ---------------------------------------------------------------------- diff --git a/components/camel-cm/src/main/java/org/apache/camel/component/cm/validation/constraints/E164Validator.java b/components/camel-cm/src/main/java/org/apache/camel/component/cm/validation/constraints/E164Validator.java deleted file mode 100644 index d8160f7..0000000 --- a/components/camel-cm/src/main/java/org/apache/camel/component/cm/validation/constraints/E164Validator.java +++ /dev/null @@ -1,66 +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.camel.component.cm.validation.constraints; - -import javax.validation.ConstraintValidator; -import javax.validation.ConstraintValidatorContext; - -import com.google.i18n.phonenumbers.NumberParseException; -import com.google.i18n.phonenumbers.PhoneNumberUtil; -import com.google.i18n.phonenumbers.PhoneNumberUtil.PhoneNumberFormat; -import com.google.i18n.phonenumbers.Phonenumber.PhoneNumber; - -/** - * Checks that a given character sequence (e.g. string) is a valid E164 formatted phonenumber. https://www.cmtelecom.com/newsroom/how-to-format-international-telephone- numbers - * https://github.com/googlei18n/libphonenumber - */ -public class E164Validator implements ConstraintValidator<E164, String> { - - private final PhoneNumberUtil pnu = PhoneNumberUtil.getInstance(); - - @Override - public void initialize(final E164 constraintAnnotation) { - } - - @Override - public boolean isValid(final String value, final ConstraintValidatorContext context) { - - if (value == null) { - return false; - } - try { - - final PhoneNumber parsingResult = pnu.parse(value, null); - if (!pnu.format(parsingResult, PhoneNumberFormat.E164).equals(value)) { - return false; - } - return true; - } catch (final NumberParseException t) { - // Errors when parsing phonenumber - return false; - } - - // CountryCodeSource.FROM_NUMBER_WITH_PLUS_SIGN - // log.debug("Phone Number: {}", value); - // log.debug("Country code: {}", numberProto.getCountryCode()); - // log.debug("National Number: {}", numberProto.getNationalNumber()); - // log.debug("E164 format: {}", pnu.format(numberProto, - // PhoneNumberFormat.E164)); - - } - -} http://git-wip-us.apache.org/repos/asf/camel/blob/58515451/components/camel-cm/src/main/resources/META-INF/services/org/apache/camel/component/cm ---------------------------------------------------------------------- diff --git a/components/camel-cm/src/main/resources/META-INF/services/org/apache/camel/component/cm b/components/camel-cm/src/main/resources/META-INF/services/org/apache/camel/component/cm deleted file mode 100644 index bf9d84b..0000000 --- a/components/camel-cm/src/main/resources/META-INF/services/org/apache/camel/component/cm +++ /dev/null @@ -1,18 +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. -# - -class=org.apache.camel.component.cm.CMComponent http://git-wip-us.apache.org/repos/asf/camel/blob/58515451/components/camel-cm/src/main/resources/log4j.properties ---------------------------------------------------------------------- diff --git a/components/camel-cm/src/main/resources/log4j.properties b/components/camel-cm/src/main/resources/log4j.properties deleted file mode 100644 index 8c6ec38..0000000 --- a/components/camel-cm/src/main/resources/log4j.properties +++ /dev/null @@ -1,37 +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. -# -log4j.rootLogger=error, stdout - -log4j.appender.stdout=org.apache.log4j.ConsoleAppender -log4j.appender.stdout.layout=org.apache.log4j.PatternLayout - -# Print the date in ISO 8601 format -log4j.appender.stdout.layout.ConversionPattern=%d [%t] %-5p %c - %m%n - -log4j.appender.R=org.apache.log4j.RollingFileAppender -log4j.appender.R.File=application.log - -log4j.appender.R.MaxFileSize=100KB -# Keep one backup file -log4j.appender.R.MaxBackupIndex=1 - -log4j.appender.R.layout=org.apache.log4j.PatternLayout -log4j.appender.R.layout.ConversionPattern=%p %t %c - %m%n - -# LOGGERS -log4j.logger.org.apache=INFO -log4j.logger.org.apache.camel.cm=TRACE http://git-wip-us.apache.org/repos/asf/camel/blob/58515451/components/camel-cm/src/test/java/org/apache/camel/component/cm/test/CMConfigurationTest.java ---------------------------------------------------------------------- diff --git a/components/camel-cm/src/test/java/org/apache/camel/component/cm/test/CMConfigurationTest.java b/components/camel-cm/src/test/java/org/apache/camel/component/cm/test/CMConfigurationTest.java deleted file mode 100644 index beafa33..0000000 --- a/components/camel-cm/src/test/java/org/apache/camel/component/cm/test/CMConfigurationTest.java +++ /dev/null @@ -1,142 +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.camel.component.cm.test; - -import java.util.Set; -import java.util.UUID; - -import javax.validation.ConstraintViolation; -import javax.validation.Validator; - -import org.apache.camel.component.cm.CMConfiguration; -import org.junit.Before; -import org.junit.Test; -import org.junit.runner.RunWith; -import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.test.context.ContextConfiguration; -import org.springframework.test.context.junit4.AbstractJUnit4SpringContextTests; -import org.springframework.test.context.junit4.SpringJUnit4ClassRunner; -import org.springframework.util.Assert; - -@RunWith(SpringJUnit4ClassRunner.class) -@ContextConfiguration(classes = { ValidatorConfiguration.class }) -// @DirtiesContext(classMode = ClassMode.AFTER_EACH_TEST_METHOD) -// @DisableJmx(false) -// @FixMethodOrder(MethodSorters.NAME_ASCENDING) -public class CMConfigurationTest extends AbstractJUnit4SpringContextTests { - - @Autowired - private Validator validator; - - @Before - public void beforeTest() throws Exception { - } - - // @After - // public void afterTest() { - - @Test - public void testNullProductToken() throws Exception { - - final CMConfiguration configuration = new CMConfiguration(); - - // length: 1-11 - configuration.setDefaultFrom("DefaultFrom"); - configuration.setProductTokenAsUUID(null); - configuration.setDefaultMaxNumberOfParts(8); - configuration.setTestConnectionOnStartup(false); - - final Set<ConstraintViolation<CMConfiguration>> constraintViolations = validator.validate(configuration); - Assert.isTrue(1 == constraintViolations.size()); - } - - @Test - public void testNullDefaultFrom() throws Exception { - - final CMConfiguration configuration = new CMConfiguration(); - - // length: 1-11 - configuration.setDefaultFrom(null); - - configuration.setProductTokenAsUUID(UUID.randomUUID()); - configuration.setDefaultMaxNumberOfParts(8); - configuration.setTestConnectionOnStartup(false); - - final Set<ConstraintViolation<CMConfiguration>> constraintViolations = validator.validate(configuration); - Assert.isTrue(1 == constraintViolations.size()); - } - - @Test - public void testDefaultFromFieldMaxLength() throws Exception { - - final CMConfiguration configuration = new CMConfiguration(); - - // length: 1-11 - configuration.setDefaultFrom("123456789012"); - - configuration.setProductTokenAsUUID(UUID.randomUUID()); - configuration.setDefaultMaxNumberOfParts(8); - configuration.setTestConnectionOnStartup(false); - - final Set<ConstraintViolation<CMConfiguration>> constraintViolations = validator.validate(configuration); - Assert.isTrue(1 == constraintViolations.size()); - } - - @Test - public void testDefaultFromFieldZeroLength() throws Exception { - - final CMConfiguration configuration = new CMConfiguration(); - - // length: 1-11 - configuration.setDefaultFrom(""); - - configuration.setProductTokenAsUUID(UUID.randomUUID()); - configuration.setDefaultMaxNumberOfParts(8); - configuration.setTestConnectionOnStartup(false); - - final Set<ConstraintViolation<CMConfiguration>> constraintViolations = validator.validate(configuration); - Assert.isTrue(1 == constraintViolations.size()); - } - - @Test - public void testMaxNumberOfParts() throws Exception { - - final CMConfiguration configuration = new CMConfiguration(); - - configuration.setProductTokenAsUUID(UUID.randomUUID()); - configuration.setDefaultFrom("DefaultFrom"); - configuration.setDefaultMaxNumberOfParts(9); - configuration.setTestConnectionOnStartup(false); - - final Set<ConstraintViolation<CMConfiguration>> constraintViolations = validator.validate(configuration); - Assert.isTrue(1 == constraintViolations.size()); - } - - @Test - public void testMaxNumberOfPartsZero() throws Exception { - - final CMConfiguration configuration = new CMConfiguration(); - - configuration.setProductTokenAsUUID(UUID.randomUUID()); - configuration.setDefaultFrom("DefaultFrom"); - configuration.setDefaultMaxNumberOfParts(0); - configuration.setTestConnectionOnStartup(false); - - final Set<ConstraintViolation<CMConfiguration>> constraintViolations = validator.validate(configuration); - Assert.isTrue(1 == constraintViolations.size()); - } -}
