vendor/sync/Store/README.txt @@ -162,8 +162,6 @@ class SourcesController < ApplicationController # RETURNS: # a hash of the object_values table ID columns as keys and the updated_at times as values def createobjects - @app=App.find_by_permalink(params[:app_id]) if params[:app_id] - @source=Source.find_by_permalink(params[:id]) if params[:id] check_access(@source.app) objects={} @client = Client.find_by_client_id(params[:client_id]) if params[:client_id] app/controllers/sources_controller.rb @@ -222,7 +222,7 @@ module SourcesHelper res = nil tmp_object = ClientTempObject.find_by_temp_objectid(x.object) begin - res = eval cmd + res = eval(cmd) if res and res.is_a?(String) and tmp_object tmp_object.update_attributes(:objectid => res, :source_id => id) end app/helpers/sources_helper.rb @@ -1,6 +1,6 @@ <h2>Creating Object for Sync </h2> Creates an object with up to five attribute value pairs -<% form_for :source, :url => "/apps/#{@source.app.id}/sources/#{@source.id}/createobjects" do |f| %> +<% form_for :source, :url => createobjects_source_path(@source) do |f| %> <input type="Submit" value="Create Object Value"/><br/> <input type="hidden" name="attrvals[][object]" value="temp1"/> Attribute Name <input name="attrvals[][attrib]" value=""/><br/> app/views/sources/newobject.html.erb @@ -201,7 +201,7 @@ describe SourcesController do describe "responding to createobjects, deleteobjects, updateobjects" do it "should createobjects" do - Source.should_receive(:find).twice.with(37).and_return(mock_source) + Source.should_receive(:find).with(37).and_return(mock_source) get :createobjects,:id => "37", :attrvals => [{"object"=>"temp1","attrib"=>"name","value"=>"rhomobile"}] response.should be_redirect end spec/controllers/sources_controller_spec.rb @@ -1,5 +1,6 @@ require 'json' require 'open-uri' + class Customer < SourceAdapter def initialize(source,credential) super(source,credential) @@ -9,6 +10,8 @@ class Customer < SourceAdapter end def query(conditions=nil,limit=nil,offset=nil) + # backend for this source adapter implements condtions + logger = Logger.new('log/store.log', File::WRONLY | File::APPEND) logger.debug "query called with conditions=#{conditions} limit=#{limit} and offset=#{offset}" @@ -20,11 +23,11 @@ class Customer < SourceAdapter open(url) do |f| parsed=JSON.parse(f.read) end - logger.debug parsed.inspect.to_s + + logger.debug parsed.inspect.to_s @result={} parsed.each { |item|@result[item["customer"]["id"].to_s]=item["customer"] } if parsed - logger.debug @result.inspect.to_s @result @@ -82,7 +85,7 @@ class Customer < SourceAdapter open(res['location']+".json") do |f| parsed=JSON.parse(f.read) end - return parsed["customer"]["id"] + return parsed["customer"]["id"] rescue nil end end vendor/sync/Store/customer.rb @@ -1,7 +1,104 @@ -require 'rubygems' -require 'active_resource' -require 'rho_helper' -class Product < ActiveResource::Base - include RhoHelper - self.site = "http://rhostore.heroku.com/" +require 'json' +require 'open-uri' + +class Product < SourceAdapter + def initialize(source,credential) + super(source,credential) + end + + def login + end + + # backend for this source adapter doesnt implement condtions but limit and offset + def query(conditions=nil,limit=nil,offset=nil) + + url="http://rhostore.heroku.com/products.json" + if limit & offset + url += "?limit=#{limit}&offset=#{offset}" + end + + parsed=nil + open(url) do |f| + parsed=JSON.parse(f.read) + end + + Rails.logger.debug parsed.inspect.to_s + @result={} + + parsed.each { |item|@result[item["product"]["id"].to_s]=item["product"] } if parsed + Rails.logger.debug @result.inspect.to_s + + @result + end + + # ENABLE THIS IF YOU WANT TO TEST BACKGROUND SYNC AKA PAGED QUERY + # implemented in terms of query + # for testing only we have hardcoded a page size of 10 + def page(num) + Rails.logger.debug "page %d num class is %s" % [num, num.class.to_s] + @result = query(nil, 10, num.to_i * 10) + return nil if @result.empty? # nil tells rhosync there are no more pages + end + + def sync + # TODO: write code here that converts the data you got back from query into an @result object + # where @result is an array of hashes, each array item representing an object + super # this creates object value triples from an @result variable that contains an array of hashes + end + + def create(name_value_list) + attrvals={} + name_value_list.each { |nv| attrvals["product["+nv["name"]+"]"]=nv["value"]} # convert name-value list to hash + res = Net::HTTP.post_form(URI.parse("http://rhostore.heroku.com/products"),attrvals) + + # after create we are redirected to the new record. We need to get the id of that record and return it as part of create + # so rhosync can establish connection from its temporary object on the client to this newly created object on the server + case res + when Net::HTTPRedirection + parsed = {} + open(res['location']+".json") do |f| + parsed=JSON.parse(f.read) + end + return parsed["product"]["id"] rescue nil + end + end + + def update(name_value_list) + obj_id = name_value_list.find { |item| item['name'] == 'id' } + name_value_list.delete(obj_id) + + params={} + name_value_list.each {|nv|params[nv["name"]]=nv["value"]} + + uri = URI.parse('http://rhostore.heroku.com') + Net::HTTP.start(uri.host) do |http| + request = Net::HTTP::Put.new(uri.path + "/products/#{obj_id['value']}.xml", {'Content-type' => 'application/xml'}) + request.body = xml_template(params) + response = http.request(request) + end + end + + def delete(name_value_list) + attrvals={} + name_value_list.each {|nv|attrvals["product["+nv["name"]+"]"]=nv["value"]} + http=Net::HTTP.new(‘rhostore.heroku.com’,80) + path="/products/#{attrvals['id']}" + resp=http.delete(path) + end + + def logoff + #TODO: write some code here if applicable + # no need to do a raise here + end + + protected + # API is expecting us to send XML content + def xml_template(params) + xml_str = "<product>" + params.each do |key,value| + xml_str += "<#{key}>#{value}</#{key}>" + end + xml_str += "</product>" + xml_str + end end \ No newline at end of file vendor/sync/Store/product.rb vendor/sync/Store/product_adapter.rb 71918209a529832cfad7312196aeba2218abb1d0 Vidal Graupera vidal@vdggroup.com http://github.com/rhomobile/rhosync/commit/6aef6cda71e129e9ff5e34379ae7a7de8b2137de 6aef6cda71e129e9ff5e34379ae7a7de8b2137de 2009-11-09T13:56:24-08:00 2009-11-09T13:56:24-08:00 updated store and product adapters per adam, fixed one test, cleaned up one page and removed a duplicate query for source... 102b616b1209a0be01993ecc73790a6854a0d264 Vidal Graupera vidal@vdggroup.com