2895: remove users.event_stream api
authorradhika <radhika@curoverse.com>
Fri, 30 May 2014 19:17:54 +0000 (15:17 -0400)
committerradhika <radhika@curoverse.com>
Fri, 30 May 2014 19:17:54 +0000 (15:17 -0400)
doc/api/methods/users.html.textile.liquid
sdk/cli/bin/arv
services/api/app/controllers/arvados/v1/users_controller.rb
services/api/config/routes.rb

index 59fa856b493d98d0c6c31fbc08f89b15d80a141b..33f884b6cc7ffd9599343503a34db89ee90ff6ad 100644 (file)
@@ -42,10 +42,6 @@ table(table table-bordered table-condensed).
 |_. Argument |_. Type |_. Description |_. Location |_. Example |
 {background:#ccffcc}.|uuid|string|The UUID of the User in question.|path||
 
-h2. event_stream
-
-event_stream users
-
 Arguments:
 
 table(table table-bordered table-condensed).
index d047204508fee386ee821bccbbd56fdde0a8dcfe..53956aa614d0fb8fbfd48e11455f6eca5dbb1a90 100755 (executable)
@@ -313,7 +313,6 @@ end
 
 case api_method
 when
-  'arvados.users.event_stream',
   'arvados.jobs.log_stream',
   'arvados.jobs.log_tail_follow'
 
index c2a32f02f1b7e0e68bd8da293e34a0269308b4c0..781bd882e72e28947acd09ac5a759db3a0625496 100644 (file)
@@ -1,8 +1,8 @@
 class Arvados::V1::UsersController < ApplicationController
   skip_before_filter :find_object_by_uuid, only:
-    [:activate, :event_stream, :current, :system, :setup]
+    [:activate, :current, :system, :setup]
   skip_before_filter :render_404_if_no_object, only:
-    [:activate, :event_stream, :current, :system, :setup]
+    [:activate, :current, :system, :setup]
   before_filter :admin_required, only: [:setup, :unsetup]
 
   def current
@@ -14,39 +14,6 @@ class Arvados::V1::UsersController < ApplicationController
     show
   end
 
-  class ChannelStreamer
-    Q_UPDATE_INTERVAL = 12
-    def initialize(opts={})
-      @opts = opts
-    end
-    def each
-      return unless @opts[:channel]
-      @redis = Redis.new(:timeout => 0)
-      @redis.subscribe(@opts[:channel]) do |event|
-        event.message do |channel, msg|
-          yield msg + "\n"
-        end
-      end
-    end
-  end
-
-  def event_stream
-    channel = current_user.andand.uuid
-    if current_user.andand.is_admin
-      channel = params[:uuid] || channel
-    end
-    if client_accepts_plain_text_stream
-      self.response.headers['Last-Modified'] = Time.now.ctime.to_s
-      self.response_body = ChannelStreamer.new(channel: channel)
-    else
-      render json: {
-        href: url_for(uuid: channel),
-        comment: ('To retrieve the event stream as plain text, ' +
-                  'use a request header like "Accept: text/plain"')
-      }
-    end
-  end
-
   def activate
     if current_user.andand.is_admin && params[:uuid]
       @object = User.find params[:uuid]
index 0223c04da4d4fc9783dce3eb61b0e8820a84f49d..49d78e4653d11f462ba48ca09e531d46d370796b 100644 (file)
@@ -49,7 +49,6 @@ Server::Application.routes.draw do
       resources :users do
         get 'current', on: :collection
         get 'system', on: :collection
-        get 'event_stream', on: :member
         post 'activate', on: :member
         post 'setup', on: :collection
         post 'unsetup', on: :member