Class: OMF::Web::DataSourceProxy
- Inherits:
-
Base::LObject
- Object
- Base::LObject
- OMF::Web::DataSourceProxy
- Defined in:
- lib/omf-web/data_source_proxy.rb
Overview
This object maintains synchronization between a JS DataSource object in a web browser and the corresponding OmlTable
in this server.
Constant Summary collapse
- @@datasources =
{}
Instance Attribute Summary collapse
-
#data_source ⇒ Object
readonly
Returns the value of attribute data_source.
-
#name ⇒ Object
readonly
Returns the value of attribute name.
Class Method Summary collapse
- .[](name) ⇒ Object
- .find(name, warn_if_not_exist = true) ⇒ Object
-
.for_source(ds_descr) ⇒ Object
Return proxies for ‘ds_name’.
-
.register_datasource(data_source, opts = {}) ⇒ Object
A data_source needs to support eh following methods:.
- .validate_ds_description(ds_descr) ⇒ Object
Instance Method Summary collapse
-
#create_slice(col_name, col_value) ⇒ Object
Create a new data source which only contains a slice of the underlying data source.
-
#initialize(name, data_source) ⇒ DataSourceProxy
constructor
A new instance of DataSourceProxy.
-
#on_changed(offset, &block) ⇒ Object
Register callback to be informed of changes to the underlying data source.
- #on_update(req) ⇒ Object
- #reset ⇒ Object
- #to_hash(opts = {}) ⇒ Object
- #to_javascript(opts = {}) ⇒ Object
Constructor Details
#initialize(name, data_source) ⇒ DataSourceProxy
Returns a new instance of DataSourceProxy.
181 182 183 184 |
# File 'lib/omf-web/data_source_proxy.rb', line 181 def initialize(name, data_source) @name = name @data_source = data_source end |
Instance Attribute Details
#data_source ⇒ Object (readonly)
Returns the value of attribute data_source.
119 120 121 |
# File 'lib/omf-web/data_source_proxy.rb', line 119 def data_source @data_source end |
#name ⇒ Object (readonly)
Returns the value of attribute name.
119 120 121 |
# File 'lib/omf-web/data_source_proxy.rb', line 119 def name @name end |
Class Method Details
.[](name) ⇒ Object
43 44 45 |
# File 'lib/omf-web/data_source_proxy.rb', line 43 def self.[](name) find(name) end |
.find(name, warn_if_not_exist = true) ⇒ Object
47 48 49 50 51 52 53 54 55 56 57 58 59 |
# File 'lib/omf-web/data_source_proxy.rb', line 47 def self.find(name, warn_if_not_exist = true) name = name.to_sym unless dsp = OMF::Web::SessionStore[name, :dsp] if ds = @@datasources[name] dsp = OMF::Web::SessionStore[name, :dsp] = self.new(name, ds) else if warn_if_not_exist warn "Requesting unknown datasource '#{name}', only know about '#{@@datasources.keys.join(', ')}'." end end end dsp end |
.for_source(ds_descr) ⇒ Object
Return proxies for ‘ds_name’. Note, there can be more then one proxy be needed for a datasource, such as a network which has one ds for the nodes and one for the links
@return: Array of proxies
TODO: This seems to hardcode networks.
83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 |
# File 'lib/omf-web/data_source_proxy.rb', line 83 def self.for_source(ds_descr) #raise "FOO #{ds_descr.inspect}" unless ds_descr.is_a? Hash raise "Expected Hash, but got '#{ds_descr.class}::#{ds_descr.inspect}'" end unless ds_name = ds_descr[:name] raise "Missing 'name' attribute in datasource description. (#{ds_descr.inspect})" end ds_name = ds_name.to_sym ds = @@datasources[ds_name] unless ds top = "#{ds_name}/" names = @@datasources.keys.find_all { |ds_name| ds_name.to_s.start_with? top } unless names.empty? return names.map do |ds_name| OMF::Web::SessionStore[ds_name, :dsp] ||= self.new(ds_name, @@datasources[ds_name]) end end unless ds raise "Unknown data source '#{ds_name}' (#{@@datasources.keys.inspect})" end end if ds.is_a? Hash raise "Is this actually used anywhere?" proxies = ds.map do |name, ds| id = "#{ds_name}_#{name}".to_sym proxy = OMF::Web::SessionStore[id, :dsp] ||= self.new(id, ds) end return proxies end #debug ">>>>> DS: #{ds_descr.inspect} - #{ds}" proxy = OMF::Web::SessionStore[ds_name, :dsp] ||= self.new(ds_name, ds) return [proxy] end |
.register_datasource(data_source, opts = {}) ⇒ Object
A data_source needs to support eh following methods:
* rows Returns an array of rows
* on_content_changed(lambda{action, rows}) Call provided block with actions :added, :removed
* create_sliced_table (optional)
* release Not exactly sure when that is being used
* schema Schema of row
* offset
32 33 34 35 36 37 38 39 40 41 |
# File 'lib/omf-web/data_source_proxy.rb', line 32 def self.register_datasource(data_source, opts = {}) name = (opts[:name] || data_source.name).to_sym if (@@datasources.key? name) raise "Repeated try to register data source '#{name}'" end if data_source.is_a? OMF::OML::OmlNetwork raise "Register link and node table separately " end @@datasources[name] = data_source end |
.validate_ds_description(ds_descr) ⇒ Object
61 62 63 64 65 66 67 68 69 70 71 72 73 |
# File 'lib/omf-web/data_source_proxy.rb', line 61 def self.validate_ds_description(ds_descr) debug "Validate datasource - #{ds_descr}" unless ds_descr.is_a? Hash raise "Expected Hash, but got '#{ds_descr.class}::#{ds_descr.inspect}'" end return true if ds_descr[:data_url] # We can fetch the data in the browser if necessary unless ds_name = ds_descr[:id] || ds_descr[:stream] || ds_descr[:name] raise "Missing 'name' attribute in datasource description. (#{ds_descr.inspect})" end ds_name = ds_name.to_sym ds = @@datasources[ds_name] ds != nil end |
Instance Method Details
#create_slice(col_name, col_value) ⇒ Object
Create a new data source which only contains a slice of the underlying data source
150 151 152 153 154 155 |
# File 'lib/omf-web/data_source_proxy.rb', line 150 def create_slice(col_name, col_value) ds = @data_source.create_sliced_table(col_name, col_value) dsp = self.class.new(ds.name, ds) def dsp.release; @data_source.release end dsp end |
#on_changed(offset, &block) ⇒ Object
Register callback to be informed of changes to the underlying data source. Call block when new rows are becoming available. Block needs ot return true if it wants to continue receiving updates.
offset: Number of records already downloaded
136 137 138 139 140 141 142 143 144 145 146 147 |
# File 'lib/omf-web/data_source_proxy.rb', line 136 def on_changed(offset, &block) ds = @data_source rows = ds.rows[(offset - ds.offset) .. -1] if rows && rows.length > 0 debug "on_changed: sending #{rows.length}" block.call :added, rows end @data_source.on_content_changed(block.object_id) do |action, rows| #debug "on_changed: #{action}: #{rows.inspect}" block.call action, rows end end |
#on_update(req) ⇒ Object
125 126 127 128 |
# File 'lib/omf-web/data_source_proxy.rb', line 125 def on_update(req) res = {:events => @data_source.rows} [res.to_json, "text/json"] end |
#reset ⇒ Object
121 122 123 |
# File 'lib/omf-web/data_source_proxy.rb', line 121 def reset() # TODO: Figure out partial sending end |
#to_hash(opts = {}) ⇒ Object
157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 |
# File 'lib/omf-web/data_source_proxy.rb', line 157 def to_hash(opts = {}) sid = Thread.current["sessionID"] opts = opts.dup opts[:name] ||= @name opts[:id] = @name opts[:stream] = @name # TODO: Should retire. Code should use :id opts[:schema] = @data_source.schema.describe opts[:update_url] ||= "/_update/#{@name}?sid=#{sid}" opts[:ws_url] ||= "/_ws?sid=#{sid}" opts[:sid] = sid unless opts[:slice] # don't send any data if this is a sliced one opts[:rows] = [] opts[:offset] = @data_source.offset end opts end |
#to_javascript(opts = {}) ⇒ Object
174 175 176 177 178 179 |
# File 'lib/omf-web/data_source_proxy.rb', line 174 def to_javascript(opts = {}) opts = to_hash(opts) %{ ds.register(#{opts.to_json}); } end |