RhoConnect REST API
===
The RhoConnect REST API allows you to control, monitor, and debug a running RhoConnect application using a simple HTTP API.

Below we describe the REST API using ruby sample code.

## API Errors
All API calls will return http 200 and requested data (if applied). Otherwise, API will return http error code and specific error message in the http message body.

	:::ruby
	def handle_api_error(error_message)
	  @errors ||= []
	  begin
	    yield
	  rescue RestClient::Exception => re
	    if re.response.body.nil? or re.response.body.length == 0
	      @errors << "#{error_message}: [#{re.http_code}] #{re.message}"  
	    else
	      @errors << "#{error_message}: #{re.response.body}"
	    end
	  rescue Exception => e      
	    @errors << "#{error_message}: #{e.message}"
	  end     
	end  

	handle_api_error("Can't get license information") do
	  @license_info = JSON.parse(
		RestClient.post(
		  "#{server}/api/get_license_info", 
	      { :api_token => @token }.to_json, 
	      :content_type => :json
	    ).body
	  )
	end

## API Methods

### `login`
Login to the RhoConnect server.

	:::ruby
	require 'rest_client'
	require 'json'

	server = "http://localhost:9292"
	login = "rhoadmin"
	password = ""

	res = RestClient.post("#{server}/login", { :login => login, :password => password }.to_json, :content_type => :json)

### `get_api_token`
Before you can use RhoConnect API you should get API token:

	:::ruby
	require 'rest_client'
	require 'json'

	server = "http://localhost:9292"
	login = "rhoadmin"
	password = ""

	res = RestClient.post("#{server}/login", { :login => login, :password => password }.to_json, :content_type => :json)
	rhoconnect_session_cookie = 'rhoconnect_session='  + res.cookies['rhoconnect_session']
	token = RestClient.post("#{server}/api/get_api_token",'',{ 'Cookie' => rhoconnect_session_cookie })
      	
### `get_license_info`
Returns license information of the currently used license

	:::ruby
	license_info = RestClient.post(
	  "#{server}/api/get_license_info",
      {:api_token => token}.to_json, :content_type => :json
    ).body

### `reset`
Reset the server: flush db and re-bootstrap server

	:::ruby
	RestClient.post("#{server}/api/reset",
  	  { :api_token => token }.to_json, 
      :content_type => :json
    )

### `ping`
Sends PUSH message to all devices of the specified user(s):

	:::ruby
	# :message - message which will be used to display notification popup dialog on the device
	# :badge - iphone specific badge
	# :sound - name of the sound file to play upon receiving PUSH notification
	# :vibrate - number of seconds to vibrate upon receiving PUSH notification
	# :sources - list of data source names to be synced upon receiving PUSH notification
	ping_params = {
      :api_token => token,
      :user_id => [array_of_users],
      :sources => source_name,
      :message => 'hello world',
      :vibrate => 2000,
      :sound => 'hello.mp3'
    }

	RestClient.post(
	  "#{server}/api/ping",ping_params.to_json, 
	  :content_type => :json
	) 

### `push_objects`
Push new objects or object updates to RhoConnect. These changes will be sent to device next time it synchronizes.

**NOTE: you may use [ping](/rhoconnect/push) to notify client and trigger sync.**

	:::ruby
	# list of objects in the canonical hash of hashes structure
	data = {
	  '5' => {
	    'name' => 'iPhone'  
	  }
	}
	RestClient.post(
	  "#{server}/api/push_objects", 
	  { 
		:api_token => token, 
        :user_id => user_id, 
	    :source_id => source_name, 
	    :objects => data 
	  }.to_json, 
	  :content_type => :json
	)
	
**NOTE: Normally, `push_objects` method will refresh the whole :md document in Redis. However, in case of large-size
documents, `push_objects` method can be optimized by invoking only the necessary updates. This can help reducing
the number of transactions with Redis. To force the optimization, user can use the `:rebuild_md => false` flag
in the `push_objects` parameters hash.**

### `push_deletes`
Delete objects from RhoConnect. These objects will be deleted from the device the next time it synchronizes.

**NOTE: You may use [ping](/rhoconnect/push) to notify client and trigger sync.**

	:::ruby
	# object_ids is an array of objects to be deleted
	RestClient.post(
	  "/api/push_deletes", 
	  { 
		:api_token => api_token, 
	    :user_id => user_id, 
	    :source_id => source_name, 
	    :objects => object_ids 
      }.to_json, 
     :content_type => :json
    )

**NOTE: Normally, `push_deletes` method will refresh the whole :md document in Redis. However, in case of large-size
documents, `push_deletes` method can be optimized by invoking only the necessary updates. This can help reducing
the number of transactions with Redis. To force the optimization, user can use the `:rebuild_md => false` flag
in the `push_deletes` parameters hash.

### `fast_insert`
Push new objects to RhoConnect. Changes are inserted into the Redis set without any checking for previous existence.
This way, the insert is very fast, but user must ensure that the object didn't exist before. No safeguards are implemented. 
Use this method only when you can ensure the integrity of the data.

**NOTE: you may use [ping](/rhoconnect/push) to notify client after the insert and trigger sync.**

	:::ruby
	# list of objects in the canonical hash of hashes structure
	data = {
	  '5' => {
	    'name' => 'iPhone'  
	  }
	}
	RestClient.post(
	  "#{server}/api/fast_insert", 
	  { 
		:api_token => token, 
        :user_id => user_id, 
	    :source_id => source_name, 
	    :data => data 
	  }.to_json, 
	  :content_type => :json
	)
	
### `fast_update`
Push object updates to RhoConnect. This method doesn't involve pulling the existing data out of Redis. Instead it required user to provide the previous state of the data. This way, this method allows for very fast updates (since it just removes the previous data from set and adds new ones). However, no data integrity checks are performed. Therefore, this method must be used only if user can ensure the integrity of the data (i.e. previous state must exist, otherwise it won't be properly deleted). Also, this method can be used to perform fast appends and deletes for any of the object's attributes (However, you shoudn't use this method to remove all of the attributes, `fast_delete` should be used instead.)

**NOTE: you may use [ping](/rhoconnect/push) to notify client after the update and trigger sync.**

	:::ruby
	# list of objects in the canonical hash of hashes structure
	# delete_data contains previous state of the object (to be deleted)
	delete_data = {
	  '5' => {
	    'name' => 'iPhone'  
	  }
	}
	# data contains new state of the object
	# to be inserted
	data = {
	  '5' => {
	    'name' => 'HTC'  
	  }
	}
	RestClient.post(
	  "#{server}/api/fast_update", 
	  { 
		:api_token => token, 
        :user_id => user_id, 
	    :source_id => source_name,
	 	:delete_data => delete_data,
	    :data => data 
	  }.to_json, 
	  :content_type => :json
	)

### `fast_delete`
Push object deletes to RhoConnect. This method doesn't involve pulling the existing data out of Redis and removing all of its attributes. Instead it required user to provide all of the object's data in the hash to be removed. This way, this method allows for very fast deletes (since it just removes the object's data from set). However, no data integrity checks are performed. Therefore, this method must be used only if user can ensure the integrity of the data (i.e. supply all of the object's data to be removed, otherwise some object's data will remain in Redis).

**NOTE: you may use [ping](/rhoconnect/push) to notify client after the delete and trigger sync.**

	:::ruby
	# list of objects in the canonical hash of hashes structure
	# data contains all of the object's data (to be deleted)
	data = {
	  '5' => {
	    'name' => 'iPhone'  
	  }
	}
	RestClient.post(
	  "#{server}/api/fast_delete", 
	  { 
		:api_token => token, 
        :user_id => user_id, 
	    :source_id => source_name,
	    :data => data 
	  }.to_json, 
	  :content_type => :json
	)

### `get_adapter`
Returns the url of the source adapter from the RhoConnect server.

	:::ruby
	adapter_url = RestClient.post(
	  "#{server}/api/get_adapter",
      {
        :api_token => token
      }.to_json, 
      :content_type => :json
    ).body

### `save_adapter`
Saves the url of the source adapter to the RhoConnect server.

	:::ruby
	RestClient.post(
	  "#{server}/api/save_adapter",
      {
        :api_token => token,
        :adapter_url => url
      }.to_json,
      :content_type => :json
    )

### `upload_file`
Upload a file to the RhoConnect server.

	:::ruby
	RestClient.post(
	  "#{server}/api/upload_file",
	  {
	    :api_token => token,
	    :upload_file => path_to_file
	  }.to_json,
	  :content_type => :json
	)

### `list_users`
List users registered with this RhoConnect application.

	:::ruby
 	users = RestClient.post(
	  "#{server}/api/list_users",
      { :api_token => token }.to_json, 
      :content_type => :json
    ).body

### `create_user`
Create a user in this RhoConnect application.

	:::ruby
	RestClient.post("#{server}/api/create_user",
	  { 
		:api_token => token,
	    :attributes => { 
		  :login => login, 
		  :password => password 
		} 
	  }.to_json, 
	  :content_type => :json
	)

### `delete_user`
Delete User and all associated devices from the RhoConnect application.

	:::ruby
	RestClient.post(
	  "#{server}/api/delete_user",
	  { 
		:api_token => token, 
		:user_id => user_id 
	  }.to_json, 
	 :content_type => :json
	)

### `update_user`
Update attributes for a user on this RhoConnect application.

	:::ruby
	RestClient.post(
	  "#{server}/api/update_user",
	  { 
		:api_token => token,
		:user_id => user_id 
		:attributes => {
		  :a_user_specific_attribute => a_user_specific_attribute_value
		} 
	  }.to_json, 
	 :content_type => :json
	)

### `list_clients`
List clients (devices) associated with given user.

	:::ruby
	clients = RestClient.post("#{server}/api/list_clients", 
	  { 
		:api_token => token, 
		:user_id => user_id 
	  }.to_json, 
	 :content_type => :json
	).body

Returns list of client ids.

### `create_client`
Creates a client (device) for a given user.
 
	:::ruby
	RestClient.post(
	  "#{server}/api/create_client",
	  { 
		:api_token => token, 
		:user_id => user_id 
	  }.to_json, 
	  :content_type => :json
	).body

### `delete_client`
Deletes the specified client (device).

	:::ruby
	RestClient.post(
	  "#{server}/api/delete_client",
	  { 
		:api_token => token, 
		:user_id => user_id,  
		:client_id => client_id 
	  }.to_json, 
	 :content_type => :json
    )    

### `get_client_params`
Returns client (device) attributes, such as `device_type`, `device_pin`, `device_port`. These attributes used by [RhoConnect push](/rhoconnect/push). 

	:::ruby
	RestClient.post(
	  "#{server}/api/get_client_params", 
	  { 
		:api_token => token, 
		:client_id => client_id 
	  }.to_json, 
	  :content_type => :json
	).body

### `list_client_docs`
Returns list of document keys associated with particular client. These documents are used by the server to sync data with the client. 
CD (:cd) - client document; represents the state of the client (set of all objects on the given client).

	:::ruby
	RestClient.post(
	  "#{server}/api/list_client_docs", 
	  { 
		:api_token => token, 
		:source_id => source_id, 
		:client_id => client_id 
	  }.to_json, 
	  :content_type => :json
	).body

### `list_sources`
Return list of source adapters for this RhoConnect application.

	:::ruby
	sources = RestClient.post("#{server}/api/list_sources", 
	  { 
		:api_token => token, 
		:partition_type => partition 
	  }.to_json, 
	  :content_type => :json
	).body

### `get_source_params`
Return attributes associated with a given source:

* `name` - name of the data source
* `poll_interval` - query poll interval; defines how often RhoConnect will call source adapter to query for new data, set to -1 to disable polling, 0 to always poll
* `partition_type` - to share data across all users, set partition to :app; otherwise use `:user` partition (default)  
* `sync_type` - set to `:bulk_only` to disable `:incremental` sync; regular sync is `:incremental` (default) 
* `queue` - name of the queue for both query and create/update/delete (CUD) jobs (used if no specific queues not specified)
* `query_queue` - name of query queue
* `cud_queue` - name of CUD queue

**NOTE: query or create/update/delete methods of the source adapter will be executed [asynchronously](/rhoconnect/async-jobs) if a queue name is defined.**

	:::ruby
	attributes = RestClient.post("#{server}/api/get_source_params", 
	  { 
		:api_token => token, 
		:source_id => source_id 
	  }.to_json, 
	  :content_type => :json
	).body

### `update_source_params`
Updates attributes associated with a given source:

`poll_interval` - query poll interval; defines how often RhoConnect will call source adapter to query for new data, set to -1 to disable polling, 0 to always poll.

	:::ruby
	attributes = RestClient.post("#{server}/api/update_source_params", 
	  { 
		:api_token => token, 
		:source_name => source_name,
		:user_name => user,
		:data => {:poll_interval => 25} 
	  }.to_json, 
	  :content_type => :json
	).body

### `set_refresh_time`
Sets source poll interval to "current time plus x seconds".

	:::ruby
	RestClient.post(
	  "/api/set_refresh_time", 
	  { 
		:api_token => @api_token, 
	    :source_name => source_name, 
	    :user_name => user, 
	    :refresh_time => 100 
	  }.to_json, 
	  :content_type => :json
	)

This will set the refresh time to 100 seconds from the current time.  Calling `set_refresh_time` with no `:refresh_time` will trigger a refresh on the sync request for the source.

### `list_source_docs`
Return list of document keys associated with given source and user. 

If `:user_id` set to '*', this call will return list of keys for 'shared' documents. 

MD(:md) - master document; represents state of the backend (set of all objects for the given app/user/source on the backend service).

	:::ruby
	docs = RestClient.post(
	  "#{server}/api/list_source_docs", 
	  { 
		:api_token => token, 
		:source_id => source_id, 
		:user_id => user_id 
	  }.to_json, 
	  :content_type => :json
	).body

### `get_db_doc`
Return content of a given document (client or source).

	:::ruby
	res = RestClient.post(
	  "#{server}/api/get_db_doc", 
	  { 
		:api_token => token, 
		:doc => doc, 
		:data_type => data_type 
	  }.to_json, 
	  :content_type => :json
	).body

`:data_type` should be 'string' for the documents containing single string (size or token docs); otherwise this call will return hash of hashes.

### `set_db_doc`
Sets the content of the specified server document. Data should be either a string or hash of hashes. Data type should be set accordingly.
If `append` flag is set to `true` , the data is appended to the current doc (if it exists) instead of replacing it.

	:::ruby
	RestClient.post(
	  "#{server}/api/set_db_doc", 
	  { 
		:api_token => token, 
		:doc => doc, 
		:data => data, 
		:data_type => data_type,
		:append => false
	  }.to_json, 
	  :content_type => :json
    )

### `stats`
Retrieves stats for a given metric key:

	:::ruby
	RestClient.post(
	  "#{server}/api/stats", 
	  { 
		:api_token => @api_token, 
		:metric => 'foo', 
		:start => 0, 
		:finish => -1 
	  }.to_json, 
	  :content_type => :json
	)

Retrieves a list of metric keys matching a given pattern.  This supports 'glob' or '*' style pattern matching.  For example, all metric keys associated with 'Product' source adapter methods:

	:::ruby
	RestClient.post(
	  "#{server}/api/stats", 
	  { 
		:api_token => @api_token, 
		:names => 'sources:*:Product' 
	  }.to_json, 
	  :content_type => :json
	)