RhoConnect-Java
===

RhoConnect-Java library is designed for the [RhoConnect](http://rhomobile.com/products/rhoconnect/) Application Integration Server.

Using the RhoConnect-Java plugin, your [Spring 3 MVC](http://www.springsource.org/) application's data will transparently synchronize with a mobile application built on the [Rhodes framework](http://rhomobile.com/products/rhodes), or any of the available [RhoConnect clients](http://rhomobile.com/products/rhoconnect/).

## Prerequisites

* Java (1.6)
* Maven
* Git
* [rhoconnect-java](https://s3.amazonaws.com/rhoconnect-java/rhoconnect-java-1.0.2.jar) RhoConnect Java plugin jar
* [rhoconnect-java-api](https://s3.amazonaws.com/rhoconnect-java/rhoconnect-java-api-1.0.0.jar) RhoConnect Java API jar

## Getting started

We assume that you have a complete java end-to-end application using Spring 3.0 MVC as the front end technology and Hibernate as backend ORM. For this application we will also use Maven for build and dependency management and some database to persist the data. The database is accessed by a Data Access (DAO) layer.

Copy [rhoconnect-java](https://s3.amazonaws.com/rhoconnect-java/rhoconnect-java-1.0.2.jar) and [rhoconnect-java-api](https://s3.amazonaws.com/rhoconnect-java/rhoconnect-java-api-1.0.0.jar) jar files to your PC.
You can also create target rhoconnect-java plugin jar from sources by cloning rhoconnect-java repository 

    :::term
    $ git clone git@github.com:rhomobile/rhoconnect-java.git

and executing in cloned project directory the following commands:

    :::term
	$ mvn package

The archived rhoconnect-java-x.y.z.jar file will be created in the project java-plugin/target/ directory. The accompanying rhoconnect-java-api-x.y.z.jar file will be created in the project java-api/target/ directory. 

For testing and evaluation purposes you can use [RhoconnectJavaSample](https://github.com/shurab/RhoconnectJavaSample) application as a starting point before continuing with the following steps. 

### Adding Dependencies to Your Maven Project

Add dependencies to your Apache Maven project object model (POM): log4j, Apache common beanutils, and Jackson JSON mapper. In the RhoconnectJavaSample application, this code is in the pom.xml file.

    :::xml
    <!-- Log4j -->
    <dependency>
        <groupId>log4j</groupId>
        <artifactId>log4j</artifactId>
        <version>1.2.9</version>
        <type>jar</type>
        <optional>false</optional>
    </dependency>
    <!-- Apache Commons Beanutils and Jackson JSON Mapper required by rhoconnect-java plugin -->
    <dependency>
        <groupId>commons-beanutils</groupId>
        <artifactId>commons-beanutils</artifactId>
        <version>1.8.3</version>
    </dependency>
    <dependency>  
        <groupId>org.codehaus.jackson</groupId>  
        <artifactId>jackson-mapper-asl</artifactId>  
        <version>1.9.0</version>  
        <type>jar</type>  
        <optional>false</optional>  
    </dependency>

You must also add the rhoconnect-java and rhoconnect-java-api jars to your Maven project. At this moment they are not available in Maven public repositories and you need install the jar manually into your Maven's local repository.

    :::term
	$ mvn install:install-file -Dfile=/path-to-jar/rhoconnect-java-api-1.0.0.jar -DgroupId=com.msi.rhoconnect.api \
	  -DartifactId=rhoconnect-java-api -Dversion=1.0.0 -Dpackaging=jar
	$ mvn install:install-file -Dfile=/path-to-jar/rhoconnect-java-1.0.2.jar \
	  -DgroupId=com.rhomobile.rhoconnect  -DartifactId=rhoconnect-java -Dversion=1.0.2 -Dpackaging=jar

Now, the `rhoconnect-java` jar library is included into your Maven local repository.
In the RhoconnectJavaSample application, you would add this code to the pom.xml file.

    :::xml
    <!-- Rhoconnect-java plugin -->
	<dependency>
    	<groupId>com.rhomobile.rhoconnect</groupId>
    	<artifactId>rhoconnect-java</artifactId>
    	<version>1.0.1</version>
    	<type>jar</type>
	</dependency>
    <!-- Rhoconnect-java-api and its dependencies -->
    <dependency>
        <groupId>com.msi.rhoconnect.api</groupId>
        <artifactId>rhoconnect-java-api</artifactId>
        <version>1.0.0</version>
        <type>jar</type>
    </dependency>
    <dependency>
      <groupId>com.sun.jersey</groupId>
      <artifactId>jersey-bundle</artifactId>
      <version>1.17</version>
    </dependency>
    <dependency>
      <groupId>com.googlecode.json-simple</groupId>
      <artifactId>json-simple</artifactId>
      <version>1.1.1</version>
    </dependency>
	
### Updating Your Servlet XML Configuration File

Update your servlet xml configuration file to include rhoconnect-java metadata: the packages, converters, and beans. In the RhoconnectJavaSample, the following code is added to src/main/webapp/WEB-INF/spring-servlet.xml file.

    :::xml
    <!-- rhoconnect-java plugin packages -->
    <context:component-scan base-package="com.rhomobile.rhoconnect.controller" /> 

    <!-- rhoconnect-java plugin converters -->
    <bean class="org.springframework.web.servlet.mvc.annotation.AnnotationMethodHandlerAdapter">
     	<property name="order" value="1" />
     	<property name="messageConverters">
         	<list>
             	<ref bean="stringHttpMessageConverter"/>
             	<ref bean="jsonConverter" />
         	</list>
     	</property>
    </bean>
    <bean id="jsonConverter" class="org.springframework.http.converter.json.MappingJacksonHttpMessageConverter">
     	<property name="supportedMediaTypes" value="application/json" />
    </bean>
    <bean id="stringHttpMessageConverter" class="org.springframework.http.converter.StringHttpMessageConverter">
    </bean>
    <bean id="restTemplate" class="org.springframework.web.client.RestTemplate">
     	<property name="messageConverters">
         	<list>
             	<ref bean="jsonConverter" />
             	<ref bean="stringHttpMessageConverter"/>
         	</list>
     	</property>
    </bean>    

    <!-- rhoconnect-java plugin beans -->
    <bean id="dispatcher" class = "com.rhomobile.rhoconnect.RhoconnectDispatcher"></bean>
    <bean id="rhoconnectClient" class = "com.rhomobile.rhoconnect.RhoconnectClient" init-method="setAppEndpoint" >
     	<property name="endpointUrl" value="your_rhoconnect_server_url" />
     	<property name="appEndpoint" value="your_spring_app_url" />
     	<property name="apiToken" value="my-rhoconnect-token" />
    </bean>
    
    <!--The following bean handles the application's authentication routine and should be implemented by you -->
    <bean id="authenticate" class = "com.rhomobile.contact.ContactAuthenticate" />

The `setAppEndpoint` method in the `rhoconnectClient` bean in the above code sample is a main point in establishing the communication 
link between the `Rhoconnect` server and the Spring 3 MVC application. It has the following properties that you need to configure.

<table border="1">
  <tr>
	<td><code>endpointUrl</code></td>
	<td>rhoconnect server's url, for example <code>http://localhost:9292</code></td>
  </tr>
  <tr>
	<td><code>appEndpoint</code></td>
	<td>your Spring 3 MVC app url, for example <code>http://localhost:8080/contacts</code></td>
  </tr>
  <tr>
	<td><code>apiToken</code></td>
	<td>rhoconnect server's api_token, for example <code>my-rhoconnect-token</code></td>
  </tr>
</table>

The `authenticate` bean will be called by rhoconnect server to authenticate users, and has to implement `Rhoconnect` interface provided by rhoconnect-java plugin: 

    :::java
    package com.rhomobile.rhoconnect;
    import java.util.Map;

    public interface Rhoconnect {
	    String authenticate(String userName, String password, Map<String, Object> attributes);
    }

For example:

    :::java
    package com.rhomobile.contact;

    import java.util.Map;
    import org.apache.log4j.Logger;
    import com.rhomobile.rhoconnect.Rhoconnect;

    public class ContactAuthenticate implements Rhoconnect {
        private static final Logger logger = Logger.getLogger(ContactAuthenticate.class);

        @Override
        public String authenticate(String login, String password, Map<String, Object> attributes) {
			logger.debug("ContactAuthenticate#authenticate: implement your authentication code!");
	        // TODO: your authentication code goes here ...		
			// Return null value if authentication fails.

			// Otherwise, returned value is data partitioning: i.e. user name for filtering data on per user basis
			//return login;

			// But if you want your data to be partitioned by ‘app’ (i.e. the data will be shared among all users),
	        // you should return string "app": it will instruct Rhoconnect to partition the data accordingly.
	        return "app";
        }
    }

### Establishing communication from the RhoConnect server to java back-end application

You need to establish communication from the RhoConnect instance to your java back-end application by mixing RhoconnectResource interface in your data access (DAO) service class:

    :::java
	package com.rhomobile.rhoconnect;

	import java.util.Map;

	public interface RhoconnectResource {
		Map<String, Object> rhoconnectQuery(String partition);
		Integer rhoconnectCreate(String partition, Map<String, Object> attributes);
		Integer rhoconnectUpdate(String partition, Map<String, Object> attributes);
		Integer rhoconnetDelete(String partition, Map<String, Object> attributes);
	}

To help rhoconnect-java plugin correctly do mapping of model name to service bean you should take into account the following conventions:

* Name of the DAO service bean (class) should be model name followed by `ServiceImpl` suffix (i. e. `ContactServiceImpl` for model `Contact`)  
* Service bean should be auto-wired into corresponding controller via @Autowired annotation 

Data partitioning in your code should be based on filtering data for unique user (i.e. your user name) or per application (shared dataset for all users).
For more information about RhoConnect partitions, please refer to the [RhoConnect docs](http://docs.rhomobile.com/rhosync/source-adapters#data-partitioning).

### Establishing communication from java back-end application to the RhoConnect server

You also must to establish the communication from your java back-end application to the RhoConnect instance by auto-wiring `RhoconnectClient` bean into your DAO service class and inserting notifications hooks into data access (create/update/delete) methods. 
`RhoconnectClient` bean is provided by rhoconnect-java plugin and responds to the following methods you have to call:

* boolean notifyOnCreate(String sourceName, Object objId, Object object)
* boolean notifyOnUpdate(String sourceName, Object objId, Object object)
* boolean notifyOnDelete(String sourceName, Object objId)

Example for `RhoconnectJavaSample` application:

    :::java
	package com.rhomobile.contact.service;

	import java.util.HashMap;
	import java.util.Iterator;
	import java.util.List;
	import java.util.Map;

	import org.apache.commons.beanutils.BeanUtils;
	import org.springframework.beans.factory.annotation.Autowired;
	import org.springframework.stereotype.Service;
	import org.springframework.transaction.annotation.Transactional;

	import com.rhomobile.contact.dao.ContactDAO;
	import com.rhomobile.contact.form.Contact;

	import com.rhomobile.rhoconnect.RhoconnectClient;
	import com.rhomobile.rhoconnect.RhoconnectResource;

	@Service
	public class ContactServiceImpl implements ContactService, RhoconnectResource {
	    //private static final Logger logger = Logger.getLogger(ContactServiceImpl.class);

	    @Autowired
	    private ContactDAO contactDAO;
	    @Autowired
	    private RhoconnectClient client;
	    private static final String sourceName  = "Contact"; // name of DAO model

	    @Transactional
	    public int addContact(Contact contact) {
	        int id = contactDAO.addContact(contact);
	        client.notifyOnCreate(sourceName, Integer.toString(id), contact);
	        return id;
	    }

	    @Transactional
	    public void updateContact(Contact contact) {
	        contactDAO.updateContact(contact);
	        client.notifyOnUpdate(sourceName, Integer.toString(contact.getId()), contact);       
	    }

	    @Transactional
	    public void removeContact(Integer id) {
	        contactDAO.removeContact(id);
	        client.notifyOnDelete(sourceName, Integer.toString(id));
	    }

	    @Transactional
	    public List<Contact> listContact() {
	        return contactDAO.listContact();
	    }

	    @Transactional
	    public Contact getContact(Integer id) {
	        return contactDAO.getContact(id);
	    }

	    @Override
	    @Transactional
	    public Map<String, Object> rhoconnectQuery(String partition) {
	        Map<String, Object> h = new HashMap<String, Object>();
	        List<Contact> contacts =  listContact();

	        Iterator<Contact> it = contacts.iterator( );
	        while(it.hasNext()) {
	            Contact c =(Contact)it.next();
	            h.put(c.getId().toString(), c);
	        }
	        return h;
	    }

	    @Override
	    @Transactional
	    public Integer rhoconnectCreate(String partition, Map<String, Object> attributes) {
	        Contact contact = new Contact();
	        try {
	            BeanUtils.populate(contact, attributes);
	            int id = addContact(contact);
	            return id;
	        } catch(Exception e) {
	            e.printStackTrace();
	        }
	        return null;
	    }

	    @Override
	    @Transactional
		public Integer rhoconnectUpdate(String partition, Map<String, Object> attributes) {
	        Integer id = Integer.parseInt((String)attributes.get("id"));
	        Contact contact = getContact(id);
	        try {
	            BeanUtils.populate(contact, attributes);
	            updateContact(contact);
	            return id;
	        } catch(Exception e) {
	            e.printStackTrace();
	        }
	        return null;
	    }

	    @Override
	    @Transactional
	    public Integer rhoconnetDelete(String partition, Map<String, Object> attributes) {
	        String objId = (String)attributes.get("id");
	        Integer id = Integer.parseInt(objId);
	        removeContact(id);       
	        return id;
	    }
	 }

Click [here](https://github.com/shurab/RhoconnectJavaPluginDemo) to download full source code of Contact manager application with rhoconnect-java plugin.

## RhoConnect-Java-API

The rhoconnect-java project contains `java-api` module that provides Java API to all resources available in <a href='http://docs.rhomobile.com/rhoconnect/rest-api'>Rhoconnect</a>.  
The `rhoconnect-java-api`is a generic Java library for communicating with RhoConnect RESTful API and it might be used to implement java client apps or components of back-end servers. 
This library also is used by RhoConnect-Java plugin to directly access RhoConnect resources.

The library has the following dependencies:

* [jersey java](http://jersey.java.net/)
* [json-simple](http://code.google.com/p/json-simple)

Every usage of API call follows this pattern:

	:::java
	ClientResponse response = NameOfResource.method(serverUrl, params);
	// Every call returns as a response Jersey object 
	// To get status code call `response.getStatus()`
	// To get body as a jason string  call `response.getEntity(String.class)` 
	
### SystemResource

#### `POST /rc/v1/system/login`
Login to the RhoConnect server and get API token.

    :::java
	public static ClientResponse login(String url, String password);

#### `POST /rc/v1/system/reset`
Reset the server: flush db and re-bootstrap server.

	:::java
	public static ClientResponse reset(String url, String token);

#### `GET /rc/v1/system/appserver`
Returns the url of the plugin’s backend from the RhoConnect server.

	:::java
	public static ClientResponse getAppserver(String url, String token);
	
#### `POST /rc/v1/system/appserver`
Saves the url of the plugin’s backend to the RhoConnect server.
	
    :::java
	public static ClientResponse setAppserver(String url, String token, String adapterUrl)

#### `GET /rc/v1/system/stats`
Retrieves stats for a given metric key.

	:::java
	public static ClientResponse statsMetricKey(String url, String token, String metricKey, int start, int finish)
	
Retrieves a list of metric keys matching a given pattern. This supports ‘glob’ or ‘*’ style pattern matching.

	:::java
	public static ClientResponse statsMetricPattern(String url, String token, String pattern);	


### StoreResource

#### `GET /rc/v1/store/:doc`
Return content of a given document stored in Redis.

	:::java
	public static ClientResponse get(String url, String token, String docname);


#### `POST /rc/v1/store/:doc`
Sets the content of the specified server document. Data should be a string. 
If append flag is set to true , the data is appended to the current doc (if it exists) 
instead of replacing it.

	:::java
	public static ClientResponse set(String url, String token, String docname, String data, boolean append);

### UserResource

#### `GET /rc/v1/users`
List users registered with this RhoConnect application.

	:::java
	public static ClientResponse list(String url, String token);
	
#### `POST /rc/v1/users`
Create a user in this RhoConnect application.

	:::java
	public static ClientResponse create(String url, String token, String login, String password);
	
#### `DELETE /rc/v1/users/:user_id`
Delete User and all associated devices from the RhoConnect application.

	:::java
	public static ClientResponse delete(String url, String token, String userId);
		
#### `PUT /rc/v1/users/:user_id`
Update attributes for a user on this RhoConnect application.
userAttributes is a hash of attribute/value pairs:
{:a_user_specific_attribute => a_user_specific_attribute_value}.

	:::java
	public static ClientResponse update(String url, String token, String userId, JSONObject userAttributes);
	
#### `GET /rc/v1/users/:user_id`
Returns the information for the specified user.

	:::java
	public static ClientResponse show(String url, String token, String userId);
		
#### `GET /rc/v1/users/:user_id/clients`
List clients (devices) associated with given user.

	:::java
	public static ClientResponse listClients(String url, String token, String userId);
	
#### `DELETE /rc/v1/users/:user_id/clients/:client_id`
Deletes the specified client (device) for the given user.

	:::java
	public static ClientResponse deleteClient(String url, String token, String userId, String clientId);
		
#### `GET /rc/v1/users/:user_id/sources/:source_id/docnames`
Return list of document keys associated with given source and user.
If userId set to '*', this call will return list of keys for 'shared' documents.

	:::java
	public static ClientResponse sourcesDocnames(String url, String token, String userId, String sources);
		
#### `POST /rc/v1/users/ping`
Sends PUSH message to all devices of the specified user(s).
pingParams is a hash of the following attribute/pairs:
{ "user_id":[array_of_users], "sources":"source_name", 
"message": "hello world", "vibrate": 2000, "sound": "hello.mp3" }

	:::java
	public static ClientResponse ping(String url, String token, JSONObject pingParams);
		
#### `GET /rc/v1/users/:user_id/sources/:source_id/docs/:doc`
Return content of a given source document for the specified user.

	:::java
	public static ClientResponse getSourcesDocs(String url, String token, String userId, String sourceId, String docname);
		
#### `POST /rc/v1/users/:user_id/sources/:source_id/docs/:doc`
Sets the content of the specified source document for the given user. 
Data should be either a string or hash of hashes. 
If append flag is set to true , the data is appended to the current doc (if it exists) 
instead of replacing it.

	:::java
	public static ClientResponse setSourcesDocs(String url, String token, String userId, String sourceId, 
			String docname, String data, boolean append);
	public static ClientResponse setSourcesDocs(String url, String token, String userId, String sourceId,
			String docname, JSONObject data, boolean append);
					
### SourceResource

#### `GET /rc/v1/sources/type/:partition_type`
Return list of source adapters for this RhoConnect application for the given partition type. 
Partition type is one of PartitionType.App, PartitionType.User, PartitionType.All.

	:::java
	public static ClientResponse getSources(String url, String token, PartitionType partitionType);
	
#### `GET /rc/v1/sources/:source_id`
Return attributes associated with a given source.

	:::java
	public static ClientResponse getAttributes(String url, String token, String sourceId);
	
#### `PUT /rc/v1/sources/:source_id`
Updates attributes associated with a given source. Attributes defined as a hash of attribute/value pair(s).

	:::java
	public static ClientResponse setAttributes(String url, String token, String sourceId, JSONObject sourceParams);

### ClientResource

#### `GET /rc/v1/clients/:client_id`
Returns client (device) attributes, such as device_type, device_pin, device_port.

	:::java
	public static ClientResponse getAttributes(String url, String token, String clientId);

#### `GET /rc/v1/clients/:client_id/sources/:source_id/docnames`
Returns list of document keys associated with particular client for a given source.

	:::java
	public static ClientResponse getSourcesDocnames(String url, String token, String clientId, String sourceId);
	
#### `GET /rc/v1/clients/:client_id/sources/:source_id/docs/:doc`
Return content of a given source document for the specified client.

	:::java
	public static ClientResponse getSourceDocument(String url, String token, String clientId, String sourceId, String docname);
	
#### `POST /rc/v1/clients/:client_id/sources/:source_id/docnames`
Sets the content of the specified source document for the given client. 
Data should be either a string or hash of hashes. If append flag is set to true, 
the data is appended to the current doc (if it exists) instead of replacing it.

	:::java
	public static ClientResponse setSourcesDocnames(String url, String token, String clientId, String sourceId, 
			String data, boolean append);
	public static ClientResponse setSourcesDocnames(String url, String token, String clientId, String sourceId, 
			JSONObject data, boolean append);
				
### PluginResource

#### `POST /app/v1/:source_name/push_objects`
Push new objects or object updates to RhoConnect.
	
	:::java
	public static ClientResponse pushObjects(String url, String token, String userId, String sourceName, JSONObject data);
	
#### `POST /app/v1/:source_name/push_deletes`
Delete objects from RhoConnect.
	
	:::java
	public static ClientResponse deleteObjects(String url, String token, String userId, String sourceName, JSONArray objectIds);

### ReadStateResource

#### `PUT /rc/v1/readstate/users/:user_id/sources/:source_id`
Sets source poll interval to “current time plus x seconds”.
Calling method with refreshTime = null will trigger a refresh on the sync request for the source.

	:::java
	public static ClientResponse setPollInterval(String url, String token, String userId, String sourceName, Integer refreshTime);


### Sample of Java RhoConnect client app
  
	:::java
	import com.msi.rhoconnect.api.SystemResource;
	import com.msi.rhoconnect.api.UserResource;
	import com.sun.jersey.api.client.ClientResponse;
	import org.json.simple.JSONArray;
	import org.json.simple.JSONValue;

	public class JavaClient {
		static String URL = "http://localhost:9292";

		public static void main(String[] args) {
			try {
				ClientResponse response = SystemResource.login(URL, "");
				if(response.getStatus() == 200) {
					String token = response.getEntity(String.class);
					System.out.println("Login to server. Got API token: " + token);

					// List users registered with this RhoConnect application
					response = UserResource.list(URL, token);
					JSONArray users = (JSONArray)JSONValue.parse(response.getEntity(String.class));
					System.out.println(users);

					// Create "testuser" in this RhoConnect application
					response = UserResource.create(URL, token, "testuser", "password");

					// Make sure that 'testuser' is registered
					response = UserResource.list(URL, token);
					users = (JSONArray)JSONValue.parse(response.getEntity(String.class));
					if(users.contains("testuser")) 
						System.out.println("User 'testuser' created");
					System.out.println(users);

					// ....

					// Delete "testuser" from this rhoconnect app
					response = UserResource.delete(URL, token, "testuser");
					if (response.getStatus() == 200) 
						System.out.println("User 'testuser' deleted");
				}
			} catch (Exception e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}		
		}
	}
 

## Meta
Created and maintained by Alexander Babichev.

Released under the [MIT License](http://www.opensource.org/licenses/mit-license.php).