lib/atome/helpers/utilities.rb in atome-0.5.1.9 vs lib/atome/helpers/utilities.rb in atome-0.5.2.5

@@ -22,25 +22,69 @@
 
   def identity_generator
     { date: Time.now, location: geolocation }
   end
 
-  def broadcasting(element, value)
-    return unless @broadcast[:particles]&.include?(element)
-
-    bloc_found = @broadcast[:bloc]
-    instance_exec(self, element, value, &bloc_found) if bloc_found.is_a?(Proc)
-  end
-
   def history(property, value)
     "historize : #{property} #{value}"
   end
 
+  # def broadcasting(modified_particle, value)
+  #   @broadcast.each_value do |particle_monitored|
+  #     if particle_monitored[modified_particle]
+  #       code_found = particle_monitored[modified_particle]
+  #       instance_exec(self, modified_particle, value, &code_found) if code_found.is_a?(Proc)
+  #     end
+  #   end
+  # end
+  #
+  # public
+  #
+  # def monitor(params, &proc_monitoring)
+  #   atome[:monitor] ||= {}
+  #   params[:atomes].each do |atome_id|
+  #     target_broadcaster = grab(atome_id).instance_variable_get('@broadcast')
+  #     monitor_id = params[:id] || "monitor#{target_broadcaster.length}"
+  #     atome[:monitor] [monitor_id]=params.merge({code: proc_monitoring})
+  #     params[:particles].each do |targeted_particle|
+  #       target_broadcaster[monitor_id] = { targeted_particle => proc_monitoring }
+  #     end
+  #   end
+  # end
+
+  def broadcasting(altered_particle, value)
+    @broadcast.each_value do |particle_monitored|
+      if particle_monitored[:particles].include?(altered_particle)
+        code_found=particle_monitored[:code]
+        instance_exec(self, altered_particle, value, &code_found) if code_found.is_a?(Proc)
+      end
+    end
+  end
+
   public
 
   def monitor(params, &proc_monitoring)
+    atome[:monitor] ||= {}
     params[:atomes].each do |atome_id|
-      grab(atome_id).instance_variable_set('@broadcast', { particles: params[:particles], bloc: proc_monitoring })
+      target_broadcaster = grab(atome_id).instance_variable_get('@broadcast')
+      monitor_id = params[:id] || "monitor#{target_broadcaster.length}"
+      atome[:monitor] [monitor_id]=params.merge({code: proc_monitoring})
+      target_broadcaster[monitor_id] = { particles: params[:particles], code:  proc_monitoring }
+    end
+  end
+  def store_code_bloc(element, &user_proc)
+    Object.attr_accessor "#{element}_code"
+
+    instance_variable_set("@#{element}_code", user_proc)
+  end
+
+  def particles(particles_found = nil)
+    if particles_found
+      particles_found.each do |particle_found, value_found|
+        atome[particle_found] = value_found
+      end
+    else
+      atome
     end
   end
 
   def <<(particle)
     value = particle.value