Module: SData::Sync::ControllerMixin::InstanceMethods::Actions

Included in:
SData::Sync::ControllerMixin::InstanceMethods
Defined in:
lib/s_data/sync/controller_mixin.rb

Instance Method Summary collapse

Instance Method Details

#sdata_collection_sync_feed ⇒ Object

TODO: error handling

Raises:

  • (Sage::BusinessLogic::Exception::AccessDeniedException) 


15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
 
# File 'lib/s_data/sync/controller_mixin.rb', line 15

def sdata_collection_sync_feed
  # get the target digest
  payload = params[:entry].sdata_payload
  
  raise "no payload!" if payload.blank?

  sd_sync_run = SData::SdSyncRun.find_by_tracking_id(tracking_id)
  raise Sage::BusinessLogic::Exception::AccessDeniedException, "Access denied" unless sd_sync_run.nil?
  
  # prepare a sync run to hold our state
  sd_sync_run = SData::SdSyncRun.new(   :tracking_id => tracking_id, 
                                        :run_name => params[:runName], 
                                        # :created_at => params[:runStamp],
                                        :sd_class => model_class.sdata_name,
                                        :created_by => target_user)
  sd_sync_run.target_digest = payload.sync_digest
  
  sd_sync_run.start!
  sd_sync_run.process!
  xml = sd_sync_run.to_xml.to_s
  render :xml => xml, :content_type => "application/xml", :location => sync_source_url(sd_sync_run.tracking_id), :status => 202
end

#sdata_collection_sync_feed_delete ⇒ Object 



79
80
81
82
83
 
# File 'lib/s_data/sync/controller_mixin.rb', line 79

def sdata_collection_sync_feed_delete
  sd_sync_run = SData::SdSyncRun.find_by_tracking_id(tracking_id)
  sd_sync_run.destroy
  render :text => "OK"
end

#sdata_collection_sync_feed_status ⇒ Object

Raises:

  • (Sage::BusinessLogic::Exception::AccessDeniedException) 


38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
 
# File 'lib/s_data/sync/controller_mixin.rb', line 38

def sdata_collection_sync_feed_status
  sd_sync_run = SData::SdSyncRun.find_by_tracking_id(tracking_id)
  raise Sage::BusinessLogic::Exception::AccessDeniedException, "Access denied" if sd_sync_run.nil?
  assert_access_to sd_sync_run
  if sd_sync_run.finished?
    @total_results = sd_sync_run.total_results
    feed =  build_sdata_feed(:feed => {:title => "#{model_class.sdata_name} synchronization feed #{params[:trackingID]}"})
    feed[SData.config[:schemas]['sync'], 'syncMode'] << "catchUp"

    feed.sync_digest = sd_sync_run.source_digest

    atom_entries = []
    errors = []
    sd_sync_run.objects[zero_based_start_index,records_to_return].each do |obj|
      begin
        # RADAR: this (the (params) part) will allow user to insert a different dataset (and possibly
        # other data) than that which was synchronized during the run. If this is somehow a security
        # problem, need to freeze that data during synctime. an be also solved by freezing username 
        # in feed and matching dataset against it at accestime.
        # RADAR: children (e.g. line items) will be embedded in parent (e.g. invoice) during this
        # request, but from live data rather than syncronized one, is this a potential problem?
        feed.entries << obj.to_atom(params.merge(:sync => true)){|entry| entry.sync_syncState = obj.sd_sync_state }
      rescue Exception => e
        errors << ApplicationDiagnosis.new(:exception => e).to_xml(:feed)
      end
    end
    #TODO: syntactic sugar if possible (such as diagnosing_errors(&block) which does the dirty work)
    errors.each do |error|
      feed[SData.config[:schemas]['sdata'], 'diagnosis'] << error
    end
    populate_open_search_for(feed)
    build_feed_links_for(feed)
    render :xml => feed, :content_type => "application/atom+xml; type=feed"
  else
    render :xml => sd_sync_run.to_xml.to_s, 
        :content_type => "application/atom+xml; type=feed", 
        :location => sync_source_url(sd_sync_run.tracking_id),
        :status => 202
  end
end

#sdata_collection_sync_results ⇒ Object 



85
86
87
 
# File 'lib/s_data/sync/controller_mixin.rb', line 85

def sdata_collection_sync_results
  render :text => "Not implemented!"
end