From aa19d59914aeffc70043bd05b1f2226d2799fe49 Mon Sep 17 00:00:00 2001
From: Brian Smith <briansmith@jamkazam.com>
Date: Sat, 16 Feb 2013 16:10:45 -0500
Subject: [PATCH 1/3] limit to 1 genre

---
 lib/jam_ruby/constants/limits.rb       | 2 +-
 spec/jam_ruby/models/recording_spec.rb | 4 ++--
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/lib/jam_ruby/constants/limits.rb b/lib/jam_ruby/constants/limits.rb
index fc7158b10..5d5e409d0 100644
--- a/lib/jam_ruby/constants/limits.rb
+++ b/lib/jam_ruby/constants/limits.rb
@@ -6,7 +6,7 @@ module Limits
 
   # recording genres
   MIN_GENRES_PER_RECORDING = 1
-  MAX_GENRES_PER_RECORDING = 3
+  MAX_GENRES_PER_RECORDING = 1
 
   # instruments
   MIN_INSTRUMENTS_PER_MUSICIAN = 1
diff --git a/spec/jam_ruby/models/recording_spec.rb b/spec/jam_ruby/models/recording_spec.rb
index 76c5d9e10..62a529f50 100644
--- a/spec/jam_ruby/models/recording_spec.rb
+++ b/spec/jam_ruby/models/recording_spec.rb
@@ -86,10 +86,10 @@ describe Recording do
     @genre2 = FactoryGirl.create(:genre)
     @genre3 = FactoryGirl.create(:genre)
     
-    @recording.update_fields :name => "name1", :description => "description", :genres => [@genre1, @genre2], :is_downloadable => true, :is_public => true
+    @recording.update_fields :name => "name1", :description => "description", :genres => [@genre1], :is_downloadable => true, :is_public => true
     @recording.name.should == "name1"
     @recording.description.should == "description"
-    @recording.genres.length.should == 2    
+    @recording.genres.length.should == 1  
     @recording.is_public.should == true
     @recording.is_downloadable.should == true
     

From 1b62522ce36580520679eabce5646b963e0237df Mon Sep 17 00:00:00 2001
From: Jonathan Kolyer <jonathan@jamkazam.com>
Date: Thu, 21 Feb 2013 11:36:58 -0600
Subject: [PATCH 2/3] vrfs192:  added stale_connection_client_ids and
 flag_connection_stale_with_client_ids to allow websocket-gateway ability to
 cleanup when stale connection is deleted

---
 lib/jam_ruby/connection_manager.rb       | 36 +++++++++++++++---------
 spec/jam_ruby/connection_manager_spec.rb |  7 +++--
 2 files changed, 27 insertions(+), 16 deletions(-)

diff --git a/lib/jam_ruby/connection_manager.rb b/lib/jam_ruby/connection_manager.rb
index 3a2cd424f..4df6916fd 100644
--- a/lib/jam_ruby/connection_manager.rb
+++ b/lib/jam_ruby/connection_manager.rb
@@ -26,6 +26,17 @@ module JamRuby
       #TODO
     end
 
+    def flag_connection_stale_with_client_id(client_id)
+      sql =<<SQL
+UPDATE connections SET aasm_state = '#{Connection::STALE_STATE.to_s}' 
+WHERE 
+  client_id = '#{client_id}' AND
+  aasm_state = '#{Connection::CONNECT_STATE.to_s}'
+SQL
+      # @log.info("*** flag_connection_stale_with_client_id: client_id = #{client_id}; sql = #{sql}")
+      self.pg_conn.exec(sql) 
+    end
+
     # flag  connections as stale
     def flag_stale_connections(max_seconds)
       ConnectionManager.active_record_transaction do |connection_manager|
@@ -40,7 +51,7 @@ SQL
         conn.exec(sql) do |result|
           count = result.getvalue(0, 0)
           if 0 < count.to_i
-            @log.info("flag_stale_connections: flagging #{count.length} stale connections")
+            # @log.info("flag_stale_connections: flagging #{count.length} stale connections")
             sql =<<SQL
 UPDATE connections SET aasm_state = '#{Connection::STALE_STATE.to_s}' 
 WHERE 
@@ -53,12 +64,16 @@ SQL
       end
     end
 
-    # expiring connections in stale state, which deletes them
+    # NOTE this is only used for testing purposes; actual deletes will be processed in the websocket context which cleans up dependencies
     def expire_stale_connections(max_seconds)
+      self.stale_connection_client_ids(max_seconds).each { |cid| self.delete_connection(cid) }
+    end
+
+    # expiring connections in stale state, which deletes them
+    def stale_connection_client_ids(max_seconds)
+      client_ids = []
       ConnectionManager.active_record_transaction do |connection_manager|
         conn = connection_manager.pg_conn
-
-        stale_clients = []
 sql =<<SQL
 SELECT client_id FROM connections 
 WHERE 
@@ -66,18 +81,11 @@ WHERE
   aasm_state = '#{Connection::STALE_STATE.to_s}'
 SQL
         conn.exec(sql) do |result|
-          result.each do |row|
-            stale_clients.push(row['client_id'])
-          end
-        end
-
-        if 0 < stale_clients.size
-          @log.info("expire_stale_connections: expiring:#{stale_clients.length} stale connections")
-          stale_clients.each do |client_id|
-            delete_connection(client_id)
-          end
+          result.each { |row| client_ids << row['client_id'] }
+          # @log.debug("*** stale_connection_client_ids: client_ids = #{client_ids.inspect}")
         end
       end
+      client_ids
     end
 
 
diff --git a/spec/jam_ruby/connection_manager_spec.rb b/spec/jam_ruby/connection_manager_spec.rb
index c33198d03..9f3c036f6 100644
--- a/spec/jam_ruby/connection_manager_spec.rb
+++ b/spec/jam_ruby/connection_manager_spec.rb
@@ -199,7 +199,11 @@ describe ConnectionManager do
     num.should == 1
     assert_num_connections(client_id, 1)
 
-    @connman.expire_stale_connections(1)
+    cids = @connman.stale_connection_client_ids(1)
+    cids.size.should == 1
+    cids[0].should == client_id
+    cids.each { |cid| @connman.delete_connection(cid) }
+
     sleep(1)
     assert_num_connections(client_id, 0)
   end
@@ -218,7 +222,6 @@ describe ConnectionManager do
     assert_num_connections(client_id, 1)
 
     sleep(1)
-
     # this should delete the stale connection
     @connman.expire_stale_connections(1)
     assert_num_connections(client_id, 0)

From 54d0675672cd25a59aa60cf4ff9cbf1b2567da8c Mon Sep 17 00:00:00 2001
From: Jonathan Kolyer <jonathan@jamkazam.com>
Date: Thu, 21 Feb 2013 19:34:04 -0600
Subject: [PATCH 3/3] added reconnect method

---
 lib/jam_ruby/connection_manager.rb | 13 ++++++++++++-
 1 file changed, 12 insertions(+), 1 deletion(-)

diff --git a/lib/jam_ruby/connection_manager.rb b/lib/jam_ruby/connection_manager.rb
index 4df6916fd..a4f8f2cad 100644
--- a/lib/jam_ruby/connection_manager.rb
+++ b/lib/jam_ruby/connection_manager.rb
@@ -26,6 +26,16 @@ module JamRuby
       #TODO
     end
 
+    def reconnect(conn) 
+        sql =<<SQL
+UPDATE connections SET (aasm_state,updated_at) = ('#{Connection::CONNECT_STATE.to_s}', NOW()) 
+WHERE 
+  client_id = '#{conn.client_id}'
+SQL
+      # @log.info("*** reconnect: client_id = #{conn.client_id}")
+      self.pg_conn.exec(sql) 
+    end
+
     def flag_connection_stale_with_client_id(client_id)
       sql =<<SQL
 UPDATE connections SET aasm_state = '#{Connection::STALE_STATE.to_s}' 
@@ -50,8 +60,9 @@ WHERE
 SQL
         conn.exec(sql) do |result|
           count = result.getvalue(0, 0)
+          # @log.info("flag_stale_connections: flagging #{count} stale connections")
           if 0 < count.to_i
-            # @log.info("flag_stale_connections: flagging #{count.length} stale connections")
+            # @log.info("flag_stale_connections: flagging #{count} stale connections")
             sql =<<SQL
 UPDATE connections SET aasm_state = '#{Connection::STALE_STATE.to_s}' 
 WHERE