Difference between revisions of "Java Example"

Revision as of 17:01, 2 February 2015

import java.io.BufferedReader;

import java.io.InputStream;

import java.io.InputStreamReader;

import java.io.PrintWriter;

import java.io.StringReader;

import java.net.HttpURLConnection;

import java.net.URL;

import java.net.URLEncoder;

import java.util.HashMap;

import java.util.Map;

import javax.xml.bind.JAXBContext;

import javax.xml.bind.Unmarshaller;

import javax.xml.bind.annotation.XmlAccessType;

import javax.xml.bind.annotation.XmlAccessorType;

import javax.xml.bind.annotation.XmlElement;

import javax.xml.bind.annotation.XmlRootElement;

import javax.xml.transform.stream.StreamSource;

import org.eclipse.persistence.jaxb.JAXBContextProperties;

import org.eclipse.persistence.jaxb.xmlmodel.ObjectFactory;

public class TestUpsideRESTAPI {

   public static final String APIEndPoint = "https://secureapi.upsidewireless.com"; // or "http://api.upsidewireless.com"
   public static final String APICredential_Token ="xxxxxxxx-8e4b-405b-998c-a580bf593b76";
   public static final String APICredential_Signature = "xxxxxxxxfyqQx95Gxxxxxxxx";
   
   private static String SMSMessageUrl = String.format("%s/RESTv1/%s/Message", APIEndPoint, APICredential_Token);

   public static void main(String[] argv) throws Exception {
       HttpURLConnection connection = null;
       boolean acceptJSON = false;
       
       System.out.println("SMS Message URL: " + SMSMessageUrl + "\n");
       
       try {
           URL smsMessageUrl = new URL(SMSMessageUrl);
           connection = (HttpURLConnection)smsMessageUrl.openConnection();

           connection.setRequestMethod("POST");
           connection.setRequestProperty("Content-Type", "application/x-www-form-urlencoded");
           connection.setRequestProperty("Accept", acceptJSON ? "application/json" : "application/xml");
           connection.setRequestProperty("User-Agent", "UpsideJavaAgent");
           connection.setConnectTimeout(100 * 1000); // 100 seconds
           connection.setReadTimeout(300 * 1000); // 300 seconds
           connection.setDoOutput(true);
           
           String smsPostData = "signature=%s";
           smsPostData += "&type=%s";
           smsPostData += "&message=%s";
           smsPostData += "&recipient=%s";
           smsPostData += "&encoding=%s";
           
           String type = "sms"; // see type list on wiki
           String message = "test sms message";
           String recipient = "16047891236"; // number in E.164 format
           String encoding = "7"; // 7, 8 or 16
           
           message = URLEncoder.encode(message, "UTF-8");
           smsPostData = String.format(smsPostData, APICredential_Signature, type, message, recipient, encoding);
           System.out.println("Post Data: " + smsPostData + "\n");
           
           PrintWriter pw = new PrintWriter(connection.getOutputStream());
           pw.println(smsPostData);
           pw.close();

           InputStream input = null;
           try {
               input = connection.getInputStream();
           } catch (Exception e) {
               input = connection.getErrorStream();
           }
           StringBuffer sbResponse = new StringBuffer(1024);
           BufferedReader reader = new BufferedReader(new InputStreamReader(input));
           String inputLine = null;
           while ((inputLine = reader.readLine()) != null) {
               sbResponse.append(inputLine);
           }
           reader.close();
           
           String responseString = sbResponse.toString();
           System.out.println("HTTP Response: " + responseString + "\n");
           
           RestResponse restResponse = null;
           if (acceptJSON) {
               Map<String, Object> properties = new HashMap<String, Object>(2);
               properties.put(JAXBContextProperties.MEDIA_TYPE, "application/json");
               properties.put(JAXBContextProperties.JSON_INCLUDE_ROOT, false);
               JAXBContext jaxbContext = JAXBContext.newInstance(new Class[] {RestResponse.class, ObjectFactory.class}, properties);
               Unmarshaller unmarshaller = jaxbContext.createUnmarshaller();
               StringReader sr = new StringReader(responseString);
              StreamSource json = new StreamSource(sr);
               restResponse = unmarshaller.unmarshal(json, RestResponse.class).getValue();
               
               // or use your favourite method to parse JSON object
           } else {
               JAXBContext jaxbContext = JAXBContext.newInstance(RestResponse.class);
               Unmarshaller unmarshaller = jaxbContext.createUnmarshaller();
               StringReader sr = new StringReader(responseString);
               restResponse = (RestResponse) unmarshaller.unmarshal(sr);
               
               // or use your favourite method to parse XML object
           }
           
           if (restResponse != null)
           {
               System.out.println("Rest Response - HasException: " + restResponse.isHasException());
               System.out.println("Rest Response - Token: " + restResponse.getToken());
               if (restResponse.isHasException())
               {
                   System.out.println("Rest Response - RestException.ErrorCode: " + restResponse.getRestException().getErrorCode());
                   System.out.println("Rest Response - RestException.Message: " + restResponse.getRestException().getMessage());
                   if (restResponse.getRestException().getStatus() != null)
                       System.out.println("Rest Response - RestException.Status: " + restResponse.getRestException().getStatus());
               }
               else
               {
                   System.out.println("Rest Response - SMSMessage.Status: " + restResponse.getSMSMessage().getStatus());
                   System.out.println("Rest Response - SMSMessage.Recipient: " + restResponse.getSMSMessage().getRecipient());
                   System.out.println("Rest Response - SMSMessage.Body: " + restResponse.getSMSMessage().getBody());
                   System.out.println("Rest Response - SMSMessage.Type: " + restResponse.getSMSMessage().getType());
                   System.out.println("Rest Response - SMSMessage.TrackingId: " + restResponse.getSMSMessage().getTrackingId());
                   if ("REJECTED".equals(restResponse.getSMSMessage().getStatus()))
                       System.out.println("Rest Response - SMSMessage.RejectReason: " + restResponse.getSMSMessage().getRejectReason());
               }
           }
           else
           {
               System.out.println("Can't get rest response object");
           }
           
       } catch (Exception e) {
           System.out.println("Error in calling REST API - " + e.getMessage());
           e.printStackTrace();
       } finally {
           if (connection != null) {
               connection.disconnect();
           }
       }
   }

}

@XmlRootElement(name="RestResponse") @XmlAccessorType(XmlAccessType.FIELD) class RestResponse {

   @XmlElement(name = "HasException")
   private boolean HasException;
   @XmlElement(name = "Token")
   private String Token;

   @XmlElement(name = "SMSMessage")
   private SMSMessage SMSMessage;
   @XmlElement(name = "RestException")
   private RestException RestException;
   
   public boolean isHasException() {
       return HasException;
   }
   
   public void setHasException(boolean hasException) {
       HasException = hasException;
   }

   public String getToken() {
       return Token;
   }

   public void setToken(String token) {
       Token = token;
   }

   public SMSMessage getSMSMessage() {
       return SMSMessage;
   }

   public void setSMSMessage(SMSMessage sMSMessage) {
       SMSMessage = sMSMessage;
   }

   public RestException getRestException() {
       return RestException;
   }

   public void setRestException(RestException restException) {
       RestException = restException;
   }

}

@XmlAccessorType(XmlAccessType.FIELD) class SMSMessage {

   @XmlElement(name = "Status")
   private String Status;
   @XmlElement(name = "Recipient")
   private String Recipient;
   @XmlElement(name = "Body")
   private String Body;
   @XmlElement(name = "Type")
   private String Type;
   @XmlElement(name = "TrackingId")
   private String TrackingId;
   @XmlElement(name = "RejectReason")
   private String RejectReason;
   
   public String getStatus() {
       return Status;
   }
   
   public void setStatus(String status) {
       Status = status;
   }

   public String getRecipient() {
       return Recipient;
   }

   public void setRecipient(String recipient) {
       Recipient = recipient;
   }

   public String getBody() {
       return Body;
   }

   public void setBody(String body) {
       Body = body;
   }

   public String getType() {
       return Type;
   }

   public void setType(String type) {
       Type = type;
   }

   public String getTrackingId() {
       return TrackingId;
   }

   public void setTrackingId(String trackingId) {
       TrackingId = trackingId;
   }

   public String getRejectReason() {
       return RejectReason;
   }

   public void setRejectReason(String rejectReason) {
       RejectReason = rejectReason;
   }
   

}

@XmlAccessorType(XmlAccessType.FIELD) class RestException {

   @XmlElement(name = "ErrorCode")
   private int ErrorCode;
   @XmlElement(name = "Message")
   private String Message;
   @XmlElement(name = "Status")
   private String Status;
   
   public int getErrorCode() {
       return ErrorCode;
   }
   
   public void setErrorCode(int errorCode) {
       ErrorCode = errorCode;
   }

   public String getMessage() {
       return Message;
   }

   public void setMessage(String message) {
       Message = message;
   }

   public String getStatus() {
       return Status;
   }

   public void setStatus(String status) {
       Status = status;
   }

}

Note: In order to run this sample, you need include MOXy library, as well as JAXB if no built-in JAXB in your JDK