everything passing with hyper-operation as a base

Author: catmando

Gemfile

@@ -1,6 +1,10 @@
 source 'https://rubygems.org'
 # Specify your gem's dependencies in synchromesh.gemspec
-gem 'hyper-trace'
-gem 'opal-browser'
-gem 'hyper-operation', git: 'https://github.com/ruby-hyperloop/hyper-operation.git' #path: '../hyper-operation'
+# gem 'hyper-trace'
+# gem 'opal-browser'
+# gem 'hyper-operation', path: '../hyper-operation' #git: 'https://github.com/ruby-hyperloop/hyper-operation.git' #
+# gem 'hyper-component', path: '../hyper-component'
+# gem 'hyper-react', path: '../hyper-react'
+# gem 'hyper-store', path: '../hyper-store'
+# gem 'hyperloop-config', path: '../hyperloop-config'
 gemspec

Rakefile

@@ -3,4 +3,8 @@ require "rspec/core/rake_task"
 
 RSpec::Core::RakeTask.new(:spec)
 
-task :default => :spec
+task :default do
+  sh 'DRIVER=ff bundle exec rspec spec/batch1'
+  sh 'DRIVER=ff bundle exec rspec spec/batch2'
+  sh 'DRIVER=ff bundle exec rspec spec/batch3-from-reactive-record'
+end

hyper-mesh.gemspec

@@ -23,8 +23,8 @@ Gem::Specification.new do |s|
     s.executables    = `git ls-files -- bin/*`.split("\n").map { |f| File.basename(f) }
     s.test_files     = `git ls-files -- {test,spec,features}/*`.split("\n")
     s.require_paths  = ['lib']
+
     s.add_dependency 'activerecord', '>= 0.3.0'
-    s.add_dependency 'hyper-react', '>= 0.10.0'
     s.add_dependency 'hyper-operation'
 
     s.add_development_dependency 'bundler', '~> 1.8'
@@ -82,6 +82,6 @@ Gem::Specification.new do |s|
       s.add_development_dependency 'jquery-rails'
       s.add_development_dependency 'pry-byebug'
       s.add_development_dependency 'hyper-spec'
-      #s.add_development_dependency 'hyper-trace'
+      s.add_development_dependency 'hyper-trace'
     end
 end

lib/hyper-mesh.rb

@@ -1,6 +1,5 @@
 require 'set'
 if RUBY_ENGINE == 'opal'
-  require "hyper-react"
   require 'hyper-operation'
   require 'active_support'
   require 'time'
@@ -33,10 +32,8 @@
   require_relative 'opal/equality_patches'
 else
   require 'opal'
-  require 'hyper-react'
   require 'hyper-operation'
   require "reactive_record/permissions"
-  #require "reactive_record/engine"
   require "reactive_record/server_data_cache"
   require "reactive_record/active_record/reactive_record/operations"
   require 'synchromesh/broadcast'
@@ -46,14 +43,9 @@
   require "reactive_record/pry"
   require_relative 'active_record_base'
   require 'hypermesh/version'
-  #require 'synchromesh/connection'
-  #require 'synchromesh/synchromesh'
-  #require 'synchromesh/policy'
-  #require 'synchromesh/synchromesh_controller'
 
   Opal.append_path File.expand_path('../sources/', __FILE__).untaint
   Opal.append_path File.expand_path('../', __FILE__).untaint
   Opal.append_path File.expand_path('../../vendor', __FILE__).untaint
 end
 require 'enumerable/pluck'
-#require_relative 'synchromesh/client_drivers'

lib/reactive_record/active_record/reactive_record/collection.rb

@@ -483,7 +483,6 @@ def method_missing(method, *args, &block)
       elsif ScopeDescription.find(@target_klass, method) || (args.count == 1 && method =~ /^find_by_/)
         apply_scope(method, *args)
       elsif @target_klass.respond_to?(method) && ScopeDescription.find(@target_klass, "_#{method}")
-        puts "here we are..."
         apply_scope("_#{method}", *args).first
       else
         super

lib/reactive_record/active_record/reactive_record/while_loading.rb

@@ -228,7 +228,7 @@ def hide_while_loading
 
   end
 
-  module Component
+  module Component  # not this needs to be rewritten
 
     alias_method :original_component_did_mount, :component_did_mount
 
@@ -299,6 +299,6 @@ def reactive_record_link_set_while_loading_container_class
 
     end
 
-  end if RUBY_ENGINE == 'opal'
+  end if false && RUBY_ENGINE == 'opal'
 
 end

lib/synchromesh/broadcast.rb

@@ -3,20 +3,22 @@ class Broadcast
 
     def self.after_commit(operation, model)
       Hyperloop::InternalPolicy.regulate_broadcast(model) do |data|
-        if !Hyperloop.on_server? && Connection.root_path
+        if !Hyperloop.on_server? && Hyperloop::Connection.root_path
           send_to_server(operation, data)
         else
           SendPacket.run(data, operation: operation)
         end
       end
+    rescue ActiveRecord::StatementInvalid => e
+      raise e unless e.message == "Could not find table 'hyperloop_connections'"
     end unless RUBY_ENGINE == 'opal'
 
     def self.send_to_server(operation, data)
       salt = SecureRandom.hex
-      authorization = authorization(salt, data)
-      raise 'no server running' unless Connection.root_path
+      authorization = Hyperloop.authorization(salt, data[:channel], data[:broadcast_id])
+      raise 'no server running' unless Hyperloop::Connection.root_path
       SendPacket.remote(
-        Connection.root_path,
+        Hyperloop::Connection.root_path,
         data,
         operation: operation,
         salt: salt,
@@ -39,8 +41,8 @@ class SendPacket < Hyperloop::ServerOp
       unless RUBY_ENGINE == 'opal'
         validate do
           params.authorization.nil? ||
-          authorization = Hyperloop.authorization(
-            params.channel, params.salt, params.broadcast_id
+          Hyperloop.authorization(
+            params.salt, params.channel, params.broadcast_id
           ) == params.authorization
         end
         dispatch_to { params.channel }

reactive_record_test_app/Gemfile

@@ -14,7 +14,7 @@ gem 'pry-rescue'
 gem 'opal-rspec-rails', github: 'opal/opal-rspec-rails', ref: '65de2771a539cda44a84c75082306869284b2ab4' # 10.0
 gem 'hyper-react'
 gem 'hyper-mesh', path: "../"
-gem 'hyper-operation', git: 'https://github.com/ruby-hyperloop/hyper-operation.git' # path: '../../hyper-operation'
+gem 'hyper-operation'
 gem 'web-console'
 gem 'hyper-trace'
 gem 'pry'

reactive_record_test_app/Gemfile.lock

@@ -8,23 +8,12 @@ GIT
       opal-rails (~> 0.9.0)
       opal-rspec (~> 0.6.0)
 
-PATH
-  remote: ../../hyper-operation
-  specs:
-    hyper-operation (0.1.0)
-      activerecord (>= 0.3.0)
-      hyper-react
-      hyperloop-config
-      mutations
-      opal-activesupport
-
 PATH
   remote: ../
   specs:
     hyper-mesh (0.5.4)
       activerecord (>= 0.3.0)
       hyper-operation
-      hyper-react (>= 0.10.0)
 
 GEM
   remote: http://rubygems.org/
@@ -63,6 +52,8 @@ GEM
       minitest (~> 5.1)
       thread_safe (~> 0.3, >= 0.3.4)
       tzinfo (~> 1.1)
+    addressable (2.5.0)
+      public_suffix (~> 2.0, >= 2.0.2)
     arel (6.0.4)
     babel-source (5.8.35)
     babel-transpiler (0.7.0)
@@ -76,18 +67,51 @@ GEM
     coffee-script-source (1.12.2)
     concurrent-ruby (1.0.5)
     connection_pool (2.2.1)
+    cookiejar (0.3.3)
+    daemons (1.2.4)
     debug_inspector (0.0.2)
+    em-http-request (1.1.5)
+      addressable (>= 2.3.4)
+      cookiejar (!= 0.3.1)
+      em-socksify (>= 0.3)
+      eventmachine (>= 1.0.3)
+      http_parser.rb (>= 0.6.0)
+    em-socksify (0.3.1)
+      eventmachine (>= 1.0.0.beta.4)
+    em-websocket (0.5.1)
+      eventmachine (>= 0.12.9)
+      http_parser.rb (~> 0.6.0)
     erubis (2.7.0)
+    eventmachine (1.2.3)
     execjs (2.7.0)
     globalid (0.3.7)
       activesupport (>= 4.1.0)
     hike (1.2.3)
-    hyper-react (0.11.0)
+    http_parser.rb (0.6.0)
+    httpclient (2.8.3)
+    hyper-component (0.12.2)
+      hyper-react (>= 0.12.0)
+      hyperloop-config (>= 0.9.2)
+      opal-rails (~> 0.9.0)
+      react-rails (< 1.10.0)
+    hyper-operation (0.5.0)
+      activerecord (>= 0.3.0)
+      hyper-component (>= 0.12.2)
+      hyperloop-config (>= 0.9.2)
+      mutations
+      opal-activesupport
+      pusher
+      pusher-fake
+    hyper-react (0.12.2)
+      hyper-store (>= 0.2.1)
+      hyperloop-config (>= 0.9.2)
       opal (>= 0.8.0)
       opal-activesupport (>= 0.2.0)
-      react-rails
+    hyper-store (0.2.1)
+      hyperloop-config (>= 0.9.2)
     hyper-trace (0.3.1)
-    hyperloop-config (0.8.1)
+    hyperloop-config (0.9.2)
+      opal
     i18n (0.8.1)
     interception (0.5)
     jquery-cookie-rails (1.3.1.1)
@@ -107,6 +131,7 @@ GEM
     mime-types-data (3.2016.0521)
     mini_portile2 (2.1.0)
     minitest (5.10.1)
+    multi_json (1.12.1)
     mutations (0.8.1)
       activesupport
     nokogiri (1.7.0.1)
@@ -143,6 +168,17 @@ GEM
     pry-rescue (1.4.4)
       interception (>= 0.5)
       pry
+    public_suffix (2.0.5)
+    pusher (1.3.1)
+      httpclient (~> 2.7)
+      multi_json (~> 1.0)
+      pusher-signature (~> 0.1.8)
+    pusher-fake (1.8.0)
+      em-http-request (~> 1.1)
+      em-websocket (~> 0.5)
+      multi_json (~> 1.6)
+      thin (~> 1.5)
+    pusher-signature (0.1.8)
     rack (1.6.5)
     rack-test (0.6.3)
       rack (>= 1.0)
@@ -171,7 +207,7 @@ GEM
       rake (>= 0.8.7)
       thor (>= 0.18.1, < 2.0)
     rake (12.0.0)
-    react-rails (1.10.0)
+    react-rails (1.9.0)
       babel-transpiler (>= 0.7.0)
       coffee-script-source (~> 1.8)
       connection_pool
@@ -192,6 +228,10 @@ GEM
     therubyracer (0.12.2)
       libv8 (~> 3.16.14.0)
       ref
+    thin (1.7.0)
+      daemons (~> 1.0, >= 1.0.9)
+      eventmachine (~> 1.0, >= 1.0.4)
+      rack (>= 1, < 3)
     thor (0.19.4)
     thread_safe (0.3.6)
     tilt (2.0.6)
@@ -209,7 +249,7 @@ PLATFORMS
 DEPENDENCIES
   byebug
   hyper-mesh!
-  hyper-operation!
+  hyper-operation
   hyper-react
   hyper-trace
   jquery-cookie-rails

reactive_record_test_app/config/application.rb

@@ -63,12 +63,13 @@ class Application < Rails::Application
     config.opal.arity_check         = false
     config.opal.const_missing       = true
     config.opal.dynamic_require_severity = :ignore
-    #config.opal.source_map_enabled = false
+    config.opal.source_map_enabled = false
 
     # Enable/disable /opal_specs route
     config.opal.enable_specs        = true
 
     config.opal.spec_location = 'spec-opal'
     config.web_console.development_only = false
+    config.hyperloop.auto_config = false
   end
 end