Open Build Service

_service:tar_scm_kernel_repo:rubygem-actioncable.spec Changed

@@ -1,58 +1,47 @@
-%global pkg_name %{name}
-
 %global gem_name actioncable
-%global gem_require_name %{gem_name}
-
-Name: rubygem-%{gem_name}
-Version: 6.0.3.4
-Release: 1
-Summary: WebSocket framework for Rails
-Group: Development/Languages
-License: MIT
-URL: https://rubyonrails.org
-Source0: https://rubygems.org/gems/%{gem_name}-%{version}.gem
-Source1: https://github.com/rails/rails/archive/refs/tags/v%{version}.tar.gz
-
-Requires: ruby(release)
-Requires: ruby >= 2.5.0
-Requires: ruby(rubygems)
-Requires: rubygem(actionpack) = 6.0.3.4
-Requires: rubygem(nio4r) >= 2.0
-Requires: rubygem(nio4r) < 3
-Requires: rubygem(websocket-driver) >= 0.6.1
-BuildRequires: ruby(release)
-BuildRequires: ruby >= 2.5.0
-BuildRequires: rubygems-devel
-BuildRequires: %{_bindir}/redis-server rubygem(redis)
-
-BuildArch: noarch
-Provides: rubygem(%{gem_name}) = %{version}
-
-Obsoletes: tfm-ror52-rubygem-%{gem_name} <= 5.2.1
-
+%global recompile_js 1
+Name: rubygem-%{gem_name}
+Version: 5.2.4.4
+Release: 1
+Summary: WebSocket framework for Rails
+License: MIT
+URL: http://rubyonrails.org
+Source0: https://rubygems.org/gems/%{gem_name}-%{version}.gem
+Source1: https://github.com/rails/rails/archive/v%{version}.tar.gz
+# Recompile with script extracted from
+# https://github.com/rails/rails/blob/71d406697266fc2525706361b86aeb85183fe4c7/actioncable/Rakefile
+Source2: recompile_js.rb
+BuildRequires: ruby(release) rubygems-devel > 1.3.1 ruby >= 2.2.2
+BuildRequires: rubygem(actionpack) = %{version} rubygem(mocha) rubygem(nio4r) rubygem(puma)
+BuildRequires: %{_bindir}/redis-server rubygem(redis) rubygem(websocket-driver)
+%if 0%{?recompile_js} > 0
+BuildRequires: rubygem(coffee-script) rubygem(sprockets) nodejs
+%endif
+BuildArch: noarch
 %description
 Structure many real-time application concerns into channels over a single
 WebSocket connection.
 
 %package doc
-Summary: Documentation for %{pkg_name}
-Group: Documentation
-Requires: %{pkg_name} = %{version}-%{release}
-BuildArch: noarch
-
+Summary: Documentation for %{name}
+Requires: %{name} = %{version}-%{release}
+BuildArch: noarch
 %description doc
-Documentation for %{pkg_name}.
+Documentation for %{name}.
 
 %prep
 gem unpack %{SOURCE0}
-
-%setup -q -D -T -n %{gem_name}-%{version}
-
+%setup -q -D -T -n %{gem_name}-%{version} -a 1
+ln -s rails-%{version}/%{gem_name}/app app 
 gem spec %{SOURCE0} -l --ruby > %{gem_name}.gemspec
 
 %build
+%if 0%{?recompile_js} > 0
+cp -a %{SOURCE2} .
+rm -rf lib/assets/compiled
+RUBYOPT=-Ilib ruby recompile_js.rb
+%endif
 gem build %{gem_name}.gemspec
-
 %gem_install
 
 %install
@@ -68,14 +57,13 @@
 mv test/subscription_adapter/postgresql_test.rb{,.disable}
 REDIS_DIR=$(mktemp -d)
 redis-server --dir $REDIS_DIR --pidfile $REDIS_DIR/redis.pid --daemonize yes
-ruby -Ilib:test -e 'Dir.glob "./test/**/*_test.rb"'
+ruby -Ilib:test -e 'Dir.glob "./test/**/*_test.rb", &method(:require)'
 kill -INT $(cat $REDIS_DIR/redis.pid) || echo end
 popd
 
 %files
 %dir %{gem_instdir}
 %license %{gem_instdir}/MIT-LICENSE
-%{gem_instdir}/app
 %{gem_libdir}
 %exclude %{gem_cache}
 %{gem_spec}
@@ -86,9 +74,6 @@
 %doc %{gem_instdir}/README.md
 
 %changelog
-* Mon Jun 07 2021 jiangxinyu <jiangxinyu@kylinos.cn> - 6.0.3.4-1
-- Update to 6.0.3.4
-
 * Mon Feb 8 2021 sunguoshuai <sunguoshuai@huawei.com> - 5.2.4.4-1
 - Upgrade to 5.2.4.4

_service:tar_scm_kernel_repo:actioncable-6.0.3.4.gem/checksums.yaml.gz -> _service:tar_scm_kernel_repo:actioncable-5.2.4.4.gem/checksums.yaml.gz Changed

_service:tar_scm_kernel_repo:actioncable-6.0.3.4.gem/data/CHANGELOG.md -> _service:tar_scm_kernel_repo:actioncable-5.2.4.4.gem/data/CHANGELOG.md Changed

@@ -1,214 +1,74 @@
-## Rails 6.0.3.4 (October 07, 2020) ##
+## Rails 5.2.4.4 (September 09, 2020) ##
 
 * No changes.
 
 
-## Rails 6.0.3.3 (September 09, 2020) ##
+## Rails 5.2.4.3 (May 18, 2020) ##
 
 * No changes.
 
 
-## Rails 6.0.3.2 (June 17, 2020) ##
+## Rails 5.2.4.1 (December 18, 2019) ##
 
 * No changes.
 
 
-## Rails 6.0.3.1 (May 18, 2020) ##
+## Rails 5.2.4 (November 27, 2019) ##
 
 * No changes.
 
 
-## Rails 6.0.3 (May 06, 2020) ##
+## Rails 5.2.3 (March 27, 2019) ##
 
 * No changes.
 
 
-## Rails 6.0.2.2 (March 19, 2020) ##
+## Rails 5.2.2.1 (March 11, 2019) ##
 
 * No changes.
 
 
-## Rails 6.0.2.1 (December 18, 2019) ##
+## Rails 5.2.2 (December 04, 2018) ##
 
 * No changes.
 
 
-## Rails 6.0.2 (December 13, 2019) ##
+## Rails 5.2.1.1 (November 27, 2018) ##
 
 * No changes.
 
 
-## Rails 6.0.1 (November 5, 2019) ##
+## Rails 5.2.1 (August 07, 2018) ##
 
 * No changes.
 
 
-## Rails 6.0.0 (August 16, 2019) ##
+## Rails 5.2.0 (April 09, 2018) ##
 
-* No changes.
-
-
-## Rails 6.0.0.rc2 (July 22, 2019) ##
-
-* No changes.
-
-
-## Rails 6.0.0.rc1 (April 24, 2019) ##
-
-* No changes.
+* Removed deprecated evented redis adapter.
 
+ *Rafael Mendonça França*
 
-## Rails 6.0.0.beta3 (March 11, 2019) ##
-
-* No changes.
+* Support redis-rb 4.0.
 
+ *Jeremy Daer*
 
-## Rails 6.0.0.beta2 (February 25, 2019) ##
+* Hash long stream identifiers when using PostgreSQL adapter.
 
-* PostgreSQL subscription adapters now support `channel_prefix` option in cable.yml
+ PostgreSQL has a limit on identifiers length (63 chars, [docs](https://www.postgresql.org/docs/current/static/sql-syntax-lexical.html#SQL-SYNTAX-IDENTIFIERS)).
+ Provided fix minifies identifiers longer than 63 chars by hashing them with SHA1.
 
- Avoids channel name collisions when multiple apps use the same database for Action Cable.
+ Fixes #28751.
 
 *Vladimir Dementyev*
 
-* Allow passing custom configuration to `ActionCable::Server::Base`.
-
- You can now create a standalone Action Cable server with a custom configuration
- (e.g. to run it in isolation from the default one):
-
- ```ruby
- config = ActionCable::Server::Configuration.new
- config.cable = { adapter: "redis", channel_prefix: "custom_" }
-
- CUSTOM_CABLE = ActionCable::Server::Base.new(config: config)
- ```
-
- Then you can mount it in the `routes.rb` file:
-
- ```ruby
- Rails.application.routes.draw do
- mount CUSTOM_CABLE => "/custom_cable"
- # ...
- end
- ```
-
- *Vladimir Dementyev*
-
-* Add `:action_cable_connection` and `:action_cable_channel` load hooks.
-
- You can use them to extend `ActionCable::Connection::Base` and `ActionCable::Channel::Base`
- functionality:
-
- ```ruby
- ActiveSupport.on_load(:action_cable_channel) do
- # do something in the context of ActionCable::Channel::Base
- end
- ```
-
- *Vladimir Dementyev*
-
-* Add `Channel::Base#broadcast_to`.
-
- You can now call `broadcast_to` within a channel action, which equals to
- the `self.class.broadcast_to`.
-
- *Vladimir Dementyev*
-
-* Make `Channel::Base.broadcasting_for` a public API.
-
- You can use `.broadcasting_for` to generate a unique stream identifier within
- a channel for the specified target (e.g. Active Record model):
-
- ```ruby
- ChatChannel.broadcasting_for(model) # => "chat:<model.to_gid_param>"
- ```
-
- *Vladimir Dementyev*
-
-
-## Rails 6.0.0.beta1 (January 18, 2019) ##
-
-* [Rename npm package](https://github.com/rails/rails/pull/34905) from
- [`actioncable`](https://www.npmjs.com/package/actioncable) to
- [`@rails/actioncable`](https://www.npmjs.com/package/@rails/actioncable).
-
- *Javan Makhmali*
-
-* Merge [`action-cable-testing`](https://github.com/palkan/action-cable-testing) to Rails.
-
- *Vladimir Dementyev*
-
-* The JavaScript WebSocket client will no longer try to reconnect
- when you call `reject_unauthorized_connection` on the connection.
-
- *Mick Staugaard*
-
-* `ActionCable.Connection#getState` now references the configurable
- `ActionCable.adapters.WebSocket` property rather than the `WebSocket` global
- variable, matching the behavior of `ActionCable.Connection#open`.
-
- *Richard Macklin*
-
-* The ActionCable javascript package has been converted from CoffeeScript
- to ES2015, and we now publish the source code in the npm distribution.
-
- This allows ActionCable users to depend on the javascript source code
- rather than the compiled code, which can produce smaller javascript bundles.
-
- This change includes some breaking changes to optional parts of the
- ActionCable javascript API:
-
- - Configuration of the WebSocket adapter and logger adapter have been moved
- from properties of `ActionCable` to properties of `ActionCable.adapters`.
- If you are currently configuring these adapters you will need to make
- these changes when upgrading:
-
- ```diff
- - ActionCable.WebSocket = MyWebSocket
- + ActionCable.adapters.WebSocket = MyWebSocket
- ```
- ```diff
- - ActionCable.logger = myLogger
- + ActionCable.adapters.logger = myLogger
- ```
-
- - The `ActionCable.startDebugging()` and `ActionCable.stopDebugging()`
- methods have been removed and replaced with the property
- `ActionCable.logger.enabled`. If you are currently using these methods you
- will need to make these changes when upgrading:
-
- ```diff
- - ActionCable.startDebugging()

_service:tar_scm_kernel_repo:actioncable-6.0.3.4.gem/data/MIT-LICENSE -> _service:tar_scm_kernel_repo:actioncable-5.2.4.4.gem/data/MIT-LICENSE Changed

_service:tar_scm_kernel_repo:actioncable-6.0.3.4.gem/data/README.md -> _service:tar_scm_kernel_repo:actioncable-5.2.4.4.gem/data/README.md Changed

@@ -7,13 +7,556 @@
 JavaScript framework and a server-side Ruby framework. You have access to your full
 domain model written with Active Record or your ORM of choice.
 
-You can read more about Action Cable in the [Action Cable Overview](https://edgeguides.rubyonrails.org/action_cable_overview.html) guide.
+## Terminology
+
+A single Action Cable server can handle multiple connection instances. It has one
+connection instance per WebSocket connection. A single user may have multiple
+WebSockets open to your application if they use multiple browser tabs or devices.
+The client of a WebSocket connection is called the consumer.
+
+Each consumer can in turn subscribe to multiple cable channels. Each channel encapsulates
+a logical unit of work, similar to what a controller does in a regular MVC setup. For example,
+you could have a `ChatChannel` and an `AppearancesChannel`, and a consumer could be subscribed to either
+or to both of these channels. At the very least, a consumer should be subscribed to one channel.
+
+When the consumer is subscribed to a channel, they act as a subscriber. The connection between
+the subscriber and the channel is, surprise-surprise, called a subscription. A consumer
+can act as a subscriber to a given channel any number of times. For example, a consumer
+could subscribe to multiple chat rooms at the same time. (And remember that a physical user may
+have multiple consumers, one per tab/device open to your connection).
+
+Each channel can then again be streaming zero or more broadcastings. A broadcasting is a
+pubsub link where anything transmitted by the broadcaster is sent directly to the channel
+subscribers who are streaming that named broadcasting.
+
+As you can see, this is a fairly deep architectural stack. There's a lot of new terminology
+to identify the new pieces, and on top of that, you're dealing with both client and server side
+reflections of each unit.
+
+## Examples
+
+### A full-stack example
+
+The first thing you must do is define your `ApplicationCable::Connection` class in Ruby. This
+is the place where you authorize the incoming connection, and proceed to establish it,
+if all is well. Here's the simplest example starting with the server-side connection class:
+
+```ruby
+# app/channels/application_cable/connection.rb
+module ApplicationCable
+ class Connection < ActionCable::Connection::Base
+ identified_by :current_user
+
+ def connect
+ self.current_user = find_verified_user
+ end
+
+ private
+ def find_verified_user
+ if verified_user = User.find_by(id: cookies.encrypted[:user_id])
+ verified_user
+ else
+ reject_unauthorized_connection
+ end
+ end
+ end
+end
+```
+Here `identified_by` is a connection identifier that can be used to find the specific connection again or later.
+Note that anything marked as an identifier will automatically create a delegate by the same name on any channel instances created off the connection.
+
+This relies on the fact that you will already have handled authentication of the user, and
+that a successful authentication sets a signed cookie with the `user_id`. This cookie is then
+automatically sent to the connection instance when a new connection is attempted, and you
+use that to set the `current_user`. By identifying the connection by this same current_user,
+you're also ensuring that you can later retrieve all open connections by a given user (and
+potentially disconnect them all if the user is deleted or deauthorized).
+
+Next, you should define your `ApplicationCable::Channel` class in Ruby. This is the place where you put
+shared logic between your channels.
+
+```ruby
+# app/channels/application_cable/channel.rb
+module ApplicationCable
+ class Channel < ActionCable::Channel::Base
+ end
+end
+```
+
+The client-side needs to setup a consumer instance of this connection. That's done like so:
+
+```js
+// app/assets/javascripts/cable.js
+//= require action_cable
+//= require_self
+//= require_tree ./channels
+
+(function() {
+ this.App || (this.App = {});
+
+ App.cable = ActionCable.createConsumer("ws://cable.example.com");
+}).call(this);
+```
+
+The `ws://cable.example.com` address must point to your Action Cable server(s), and it
+must share a cookie namespace with the rest of the application (which may live under http://example.com).
+This ensures that the signed cookie will be correctly sent.
+
+That's all you need to establish the connection! But of course, this isn't very useful in
+itself. This just gives you the plumbing. To make stuff happen, you need content. That content
+is defined by declaring channels on the server and allowing the consumer to subscribe to them.
+
+
+### Channel example 1: User appearances
+
+Here's a simple example of a channel that tracks whether a user is online or not, and also what page they are currently on.
+(This is useful for creating presence features like showing a green dot next to a user's name if they're online).
+
+First you declare the server-side channel:
+
+```ruby
+# app/channels/appearance_channel.rb
+class AppearanceChannel < ApplicationCable::Channel
+ def subscribed
+ current_user.appear
+ end
+
+ def unsubscribed
+ current_user.disappear
+ end
+
+ def appear(data)
+ current_user.appear on: data['appearing_on']
+ end
+
+ def away
+ current_user.away
+ end
+end
+```
+
+The `#subscribed` callback is invoked when, as we'll show below, a client-side subscription is initiated. In this case,
+we take that opportunity to say "the current user has indeed appeared". That appear/disappear API could be backed by
+Redis or a database or whatever else. Here's what the client-side of that looks like:
+
+```coffeescript
+# app/assets/javascripts/cable/subscriptions/appearance.coffee
+App.cable.subscriptions.create "AppearanceChannel",
+ # Called when the subscription is ready for use on the server
+ connected: ->
+ @install()
+ @appear()
+
+ # Called when the WebSocket connection is closed
+ disconnected: ->
+ @uninstall()
+
+ # Called when the subscription is rejected by the server
+ rejected: ->
+ @uninstall()
+
+ appear: ->
+ # Calls `AppearanceChannel#appear(data)` on the server
+ @perform("appear", appearing_on: $("main").data("appearing-on"))
+
+ away: ->
+ # Calls `AppearanceChannel#away` on the server
+ @perform("away")
+
+
+ buttonSelector = "[data-behavior~=appear_away]"
+
+ install: ->
+ $(document).on "turbolinks:load.appearance", =>
+ @appear()
+
+ $(document).on "click.appearance", buttonSelector, =>
+ @away()
+ false
+
+ $(buttonSelector).show()
+
+ uninstall: ->
+ $(document).off(".appearance")
+ $(buttonSelector).hide()
+```
+
+Simply calling `App.cable.subscriptions.create` will setup the subscription, which will call `AppearanceChannel#subscribed`,
+which in turn is linked to the original `App.cable` -> `ApplicationCable::Connection` instances.
+
+Next, we link the client-side `appear` method to `AppearanceChannel#appear(data)`. This is possible because the server-side
+channel instance will automatically expose the public methods declared on the class (minus the callbacks), so that these
+can be reached as remote procedure calls via a subscription's `perform` method.
+
+### Channel example 2: Receiving new web notifications
+
+The appearance example was all about exposing server functionality to client-side invocation over the WebSocket connection.
+But the great thing about WebSockets is that it's a two-way street. So now let's show an example where the server invokes
+an action on the client.
+
+This is a web notification channel that allows you to trigger client-side web notifications when you broadcast to the right
+streams:
+
+```ruby
+# app/channels/web_notifications_channel.rb
+class WebNotificationsChannel < ApplicationCable::Channel
+ def subscribed
+ stream_from "web_notifications_#{current_user.id}"

_service:tar_scm_kernel_repo:actioncable-6.0.3.4.gem/data/lib/action_cable.rb -> _service:tar_scm_kernel_repo:actioncable-5.2.4.4.gem/data/lib/action_cable.rb Changed

@@ -1,7 +1,7 @@
 # frozen_string_literal: true
 
 #--
-# Copyright (c) 2015-2019 Basecamp, LLC
+# Copyright (c) 2015-2018 Basecamp, LLC
 #
 # Permission is hereby granted, free of charge, to any person obtaining
 # a copy of this software and associated documentation files (the
@@ -32,19 +32,13 @@
 
   INTERNAL = {
     message_types: {
-      welcome: "welcome",
-      disconnect: "disconnect",
-      ping: "ping",
-      confirmation: "confirm_subscription",
-      rejection: "reject_subscription"
+      welcome: "welcome".freeze,
+      ping: "ping".freeze,
+      confirmation: "confirm_subscription".freeze,
+      rejection: "reject_subscription".freeze
     },
-    disconnect_reasons: {
-      unauthorized: "unauthorized",
-      invalid_request: "invalid_request",
-      server_restart: "server_restart"
-    },
-    default_mount_path: "/cable",
-    protocols: ["actioncable-v1-json", "actioncable-unsupported"].freeze
+    default_mount_path: "/cable".freeze,
+    protocols: ["actioncable-v1-json".freeze, "actioncable-unsupported".freeze].freeze
   }
 
   # Singleton instance of the server
@@ -57,6 +51,4 @@
   autoload :Channel
   autoload :RemoteConnections
   autoload :SubscriptionAdapter
-  autoload :TestHelper
-  autoload :TestCase
 end

_service:tar_scm_kernel_repo:actioncable-6.0.3.4.gem/data/lib/action_cable/channel.rb -> _service:tar_scm_kernel_repo:actioncable-5.2.4.4.gem/data/lib/action_cable/channel.rb Changed

_service:tar_scm_kernel_repo:actioncable-6.0.3.4.gem/data/lib/action_cable/channel/base.rb -> _service:tar_scm_kernel_repo:actioncable-5.2.4.4.gem/data/lib/action_cable/channel/base.rb Changed

_service:tar_scm_kernel_repo:actioncable-6.0.3.4.gem/data/lib/action_cable/channel/broadcasting.rb -> _service:tar_scm_kernel_repo:actioncable-5.2.4.4.gem/data/lib/action_cable/channel/broadcasting.rb Changed

@@ -7,32 +7,22 @@
 module Broadcasting
 extend ActiveSupport::Concern
 
- delegate :broadcasting_for, :broadcast_to, to: :class
+ delegate :broadcasting_for, to: :class
 
 module ClassMethods
 # Broadcast a hash to a unique broadcasting for this <tt>model</tt> in this channel.
 def broadcast_to(model, message)
- ActionCable.server.broadcast(broadcasting_for(model), message)
+ ActionCable.server.broadcast(broadcasting_for([ channel_name, model ]), message)
 end
 
- # Returns a unique broadcasting identifier for this <tt>model</tt> in this channel:
- #
- # CommentsChannel.broadcasting_for("all") # => "comments:all"
- #
- # You can pass any object as a target (e.g. Active Record model), and it
- # would be serialized into a string under the hood.
- def broadcasting_for(model)
- serialize_broadcasting([ channel_name, model ])
- end
-
- def serialize_broadcasting(object) #:nodoc:
+ def broadcasting_for(model) #:nodoc:
 case
- when object.is_a?(Array)
- object.map { |m| serialize_broadcasting(m) }.join(":")
- when object.respond_to?(:to_gid_param)
- object.to_gid_param
+ when model.is_a?(Array)
+ model.map { |m| broadcasting_for(m) }.join(":")
+ when model.respond_to?(:to_gid_param)
+ model.to_gid_param
 else
- object.to_param
+ model.to_param
 end
 end
 end

_service:tar_scm_kernel_repo:actioncable-6.0.3.4.gem/data/lib/action_cable/channel/streams.rb -> _service:tar_scm_kernel_repo:actioncable-5.2.4.4.gem/data/lib/action_cable/channel/streams.rb Changed

_service:tar_scm_kernel_repo:actioncable-6.0.3.4.gem/data/lib/action_cable/connection.rb -> _service:tar_scm_kernel_repo:actioncable-5.2.4.4.gem/data/lib/action_cable/connection.rb Changed

_service:tar_scm_kernel_repo:actioncable-6.0.3.4.gem/data/lib/action_cable/connection/authorization.rb -> _service:tar_scm_kernel_repo:actioncable-5.2.4.4.gem/data/lib/action_cable/connection/authorization.rb Changed

_service:tar_scm_kernel_repo:actioncable-6.0.3.4.gem/data/lib/action_cable/connection/base.rb -> _service:tar_scm_kernel_repo:actioncable-5.2.4.4.gem/data/lib/action_cable/connection/base.rb Changed

@@ -95,12 +95,7 @@
       end
 
       # Close the WebSocket connection.
-      def close(reason: nil, reconnect: true)
-        transmit(
-          type: ActionCable::INTERNAL[:message_types][:disconnect],
-          reason: reason,
-          reconnect: reconnect
-        )
+      def close
         websocket.close
       end
 
@@ -141,10 +136,13 @@
         send_async :handle_close
       end
 
-      private
+      # TODO Change this to private once we've dropped Ruby 2.2 support.
+      # Workaround for Ruby 2.2 "private attribute?" warning.
+      protected
         attr_reader :websocket
         attr_reader :message_buffer
 
+      private
         # The request that initiated the WebSocket connection is available here. This gives access to the environment, cookies, etc.
         def request # :doc:
           @request ||= begin
@@ -175,7 +173,7 @@
           message_buffer.process!
           server.add_connection(self)
         rescue ActionCable::Connection::Authorization::UnauthorizedError
-          close(reason: ActionCable::INTERNAL[:disconnect_reasons][:unauthorized], reconnect: false) if websocket.alive?
+          respond_to_invalid_request
         end
 
         def handle_close
@@ -216,7 +214,7 @@
         end
 
         def respond_to_invalid_request
-          close(reason: ActionCable::INTERNAL[:disconnect_reasons][:invalid_request]) if websocket.alive?
+          close if websocket.alive?
 
           logger.error invalid_request_message
           logger.info finished_request_message
@@ -260,5 +258,3 @@
     end
   end
 end
-
-ActiveSupport.run_load_hooks(:action_cable_connection, ActionCable::Connection::Base)

_service:tar_scm_kernel_repo:actioncable-6.0.3.4.gem/data/lib/action_cable/connection/message_buffer.rb -> _service:tar_scm_kernel_repo:actioncable-5.2.4.4.gem/data/lib/action_cable/connection/message_buffer.rb Changed

_service:tar_scm_kernel_repo:actioncable-6.0.3.4.gem/data/lib/action_cable/connection/stream.rb -> _service:tar_scm_kernel_repo:actioncable-5.2.4.4.gem/data/lib/action_cable/connection/stream.rb Changed

_service:tar_scm_kernel_repo:actioncable-6.0.3.4.gem/data/lib/action_cable/connection/subscriptions.rb -> _service:tar_scm_kernel_repo:actioncable-5.2.4.4.gem/data/lib/action_cable/connection/subscriptions.rb Changed

_service:tar_scm_kernel_repo:actioncable-6.0.3.4.gem/data/lib/action_cable/connection/web_socket.rb -> _service:tar_scm_kernel_repo:actioncable-5.2.4.4.gem/data/lib/action_cable/connection/web_socket.rb Changed

_service:tar_scm_kernel_repo:actioncable-6.0.3.4.gem/data/lib/action_cable/gem_version.rb -> _service:tar_scm_kernel_repo:actioncable-5.2.4.4.gem/data/lib/action_cable/gem_version.rb Changed

_service:tar_scm_kernel_repo:actioncable-6.0.3.4.gem/data/lib/action_cable/server/base.rb -> _service:tar_scm_kernel_repo:actioncable-5.2.4.4.gem/data/lib/action_cable/server/base.rb Changed

_service:tar_scm_kernel_repo:actioncable-6.0.3.4.gem/data/lib/action_cable/server/worker.rb -> _service:tar_scm_kernel_repo:actioncable-5.2.4.4.gem/data/lib/action_cable/server/worker.rb Changed

_service:tar_scm_kernel_repo:actioncable-6.0.3.4.gem/data/lib/action_cable/subscription_adapter.rb -> _service:tar_scm_kernel_repo:actioncable-5.2.4.4.gem/data/lib/action_cable/subscription_adapter.rb Changed

_service:tar_scm_kernel_repo:actioncable-6.0.3.4.gem/data/lib/action_cable/subscription_adapter/postgresql.rb -> _service:tar_scm_kernel_repo:actioncable-5.2.4.4.gem/data/lib/action_cable/subscription_adapter/postgresql.rb Changed

@@ -8,15 +8,13 @@
 module ActionCable
 module SubscriptionAdapter
 class PostgreSQL < Base # :nodoc:
- prepend ChannelPrefix
-
 def initialize(*)
 super
 @listener = nil
 end
 
 def broadcast(channel, payload)
- with_broadcast_connection do |pg_conn|
+ with_connection do |pg_conn|
 pg_conn.exec("NOTIFY #{pg_conn.escape_identifier(channel_identifier(channel))}, '#{pg_conn.escape_string(payload)}'")
 end
 end
@@ -33,24 +31,14 @@
 listener.shutdown
 end
 
- def with_subscriptions_connection(&block) # :nodoc:
- ar_conn = ActiveRecord::Base.connection_pool.checkout.tap do |conn|
- # Action Cable is taking ownership over this database connection, and
- # will perform the necessary cleanup tasks
- ActiveRecord::Base.connection_pool.remove(conn)
- end
- pg_conn = ar_conn.raw_connection
-
- verify!(pg_conn)
- yield pg_conn
- ensure
- ar_conn.disconnect!
- end
-
- def with_broadcast_connection(&block) # :nodoc:
+ def with_connection(&block) # :nodoc:
 ActiveRecord::Base.connection_pool.with_connection do |ar_conn|
 pg_conn = ar_conn.raw_connection
- verify!(pg_conn)
+
+ unless pg_conn.is_a?(PG::Connection)
+ raise "The Active Record database must be PostgreSQL in order to use the PostgreSQL Action Cable storage adapter"
+ end
+
 yield pg_conn
 end
 end
@@ -64,12 +52,6 @@
 @listener || @server.mutex.synchronize { @listener ||= Listener.new(self, @server.event_loop) }
 end
 
- def verify!(pg_conn)
- unless pg_conn.is_a?(PG::Connection)
- raise "The Active Record database must be PostgreSQL in order to use the PostgreSQL Action Cable storage adapter"
- end
- end
-
 class Listener < SubscriberMap
 def initialize(adapter, event_loop)
 super()
@@ -85,7 +67,7 @@
 end
 
 def listen
- @adapter.with_subscriptions_connection do |pg_conn|
+ @adapter.with_connection do |pg_conn|
 catch :shutdown do
 loop do
 until @queue.empty?

_service:tar_scm_kernel_repo:actioncable-6.0.3.4.gem/data/lib/action_cable/subscription_adapter/redis.rb -> _service:tar_scm_kernel_repo:actioncable-5.2.4.4.gem/data/lib/action_cable/subscription_adapter/redis.rb Changed

_service:tar_scm_kernel_repo:actioncable-5.2.4.4.gem/data/lib/assets/compiled/action_cable.js Added

@@ -0,0 +1,601 @@
+(function() {
+ var context = this;
+
+ (function() {
+ (function() {
+ var slice = [].slice;
+
+ this.ActionCable = {
+ INTERNAL: {
+ "message_types": {
+ "welcome": "welcome",
+ "ping": "ping",
+ "confirmation": "confirm_subscription",
+ "rejection": "reject_subscription"
+ },
+ "default_mount_path": "/cable",
+ "protocols": ["actioncable-v1-json", "actioncable-unsupported"]
+ },
+ WebSocket: window.WebSocket,
+ logger: window.console,
+ createConsumer: function(url) {
+ var ref;
+ if (url == null) {
+ url = (ref = this.getConfig("url")) != null ? ref : this.INTERNAL.default_mount_path;
+ }
+ return new ActionCable.Consumer(this.createWebSocketURL(url));
+ },
+ getConfig: function(name) {
+ var element;
+ element = document.head.querySelector("meta[name='action-cable-" + name + "']");
+ return element != null ? element.getAttribute("content") : void 0;
+ },
+ createWebSocketURL: function(url) {
+ var a;
+ if (url && !/^wss?:/i.test(url)) {
+ a = document.createElement("a");
+ a.href = url;
+ a.href = a.href;
+ a.protocol = a.protocol.replace("http", "ws");
+ return a.href;
+ } else {
+ return url;
+ }
+ },
+ startDebugging: function() {
+ return this.debugging = true;
+ },
+ stopDebugging: function() {
+ return this.debugging = null;
+ },
+ log: function() {
+ var messages, ref;
+ messages = 1 <= arguments.length ? slice.call(arguments, 0) : [];
+ if (this.debugging) {
+ messages.push(Date.now());
+ return (ref = this.logger).log.apply(ref, ["[ActionCable]"].concat(slice.call(messages)));
+ }
+ }
+ };
+
+ }).call(this);
+ }).call(context);
+
+ var ActionCable = context.ActionCable;
+
+ (function() {
+ (function() {
+ var bind = function(fn, me){ return function(){ return fn.apply(me, arguments); }; };
+
+ ActionCable.ConnectionMonitor = (function() {
+ var clamp, now, secondsSince;
+
+ ConnectionMonitor.pollInterval = {
+ min: 3,
+ max: 30
+ };
+
+ ConnectionMonitor.staleThreshold = 6;
+
+ function ConnectionMonitor(connection) {
+ this.connection = connection;
+ this.visibilityDidChange = bind(this.visibilityDidChange, this);
+ this.reconnectAttempts = 0;
+ }
+
+ ConnectionMonitor.prototype.start = function() {
+ if (!this.isRunning()) {
+ this.startedAt = now();
+ delete this.stoppedAt;
+ this.startPolling();
+ document.addEventListener("visibilitychange", this.visibilityDidChange);
+ return ActionCable.log("ConnectionMonitor started. pollInterval = " + (this.getPollInterval()) + " ms");
+ }
+ };
+
+ ConnectionMonitor.prototype.stop = function() {
+ if (this.isRunning()) {
+ this.stoppedAt = now();
+ this.stopPolling();
+ document.removeEventListener("visibilitychange", this.visibilityDidChange);
+ return ActionCable.log("ConnectionMonitor stopped");
+ }
+ };
+
+ ConnectionMonitor.prototype.isRunning = function() {
+ return (this.startedAt != null) && (this.stoppedAt == null);
+ };
+
+ ConnectionMonitor.prototype.recordPing = function() {
+ return this.pingedAt = now();
+ };
+
+ ConnectionMonitor.prototype.recordConnect = function() {
+ this.reconnectAttempts = 0;
+ this.recordPing();
+ delete this.disconnectedAt;
+ return ActionCable.log("ConnectionMonitor recorded connect");
+ };
+
+ ConnectionMonitor.prototype.recordDisconnect = function() {
+ this.disconnectedAt = now();
+ return ActionCable.log("ConnectionMonitor recorded disconnect");
+ };
+
+ ConnectionMonitor.prototype.startPolling = function() {
+ this.stopPolling();
+ return this.poll();
+ };
+
+ ConnectionMonitor.prototype.stopPolling = function() {
+ return clearTimeout(this.pollTimeout);
+ };
+
+ ConnectionMonitor.prototype.poll = function() {
+ return this.pollTimeout = setTimeout((function(_this) {
+ return function() {
+ _this.reconnectIfStale();
+ return _this.poll();
+ };
+ })(this), this.getPollInterval());
+ };
+
+ ConnectionMonitor.prototype.getPollInterval = function() {
+ var interval, max, min, ref;
+ ref = this.constructor.pollInterval, min = ref.min, max = ref.max;
+ interval = 5 * Math.log(this.reconnectAttempts + 1);
+ return Math.round(clamp(interval, min, max) * 1000);
+ };
+
+ ConnectionMonitor.prototype.reconnectIfStale = function() {
+ if (this.connectionIsStale()) {
+ ActionCable.log("ConnectionMonitor detected stale connection. reconnectAttempts = " + this.reconnectAttempts + ", pollInterval = " + (this.getPollInterval()) + " ms, time disconnected = " + (secondsSince(this.disconnectedAt)) + " s, stale threshold = " + this.constructor.staleThreshold + " s");
+ this.reconnectAttempts++;
+ if (this.disconnectedRecently()) {
+ return ActionCable.log("ConnectionMonitor skipping reopening recent disconnect");
+ } else {
+ ActionCable.log("ConnectionMonitor reopening");
+ return this.connection.reopen();
+ }
+ }
+ };
+
+ ConnectionMonitor.prototype.connectionIsStale = function() {
+ var ref;
+ return secondsSince((ref = this.pingedAt) != null ? ref : this.startedAt) > this.constructor.staleThreshold;
+ };
+
+ ConnectionMonitor.prototype.disconnectedRecently = function() {
+ return this.disconnectedAt && secondsSince(this.disconnectedAt) < this.constructor.staleThreshold;
+ };
+
+ ConnectionMonitor.prototype.visibilityDidChange = function() {
+ if (document.visibilityState === "visible") {
+ return setTimeout((function(_this) {
+ return function() {
+ if (_this.connectionIsStale() || !_this.connection.isOpen()) {
+ ActionCable.log("ConnectionMonitor reopening stale connection on visibilitychange. visbilityState = " + document.visibilityState);
+ return _this.connection.reopen();
+ }
+ };
+ })(this), 200);
+ }
+ };
+
+ now = function() {
+ return new Date().getTime();
+ };
+
+ secondsSince = function(time) {
+ return (now() - time) / 1000;
+ };
+
+ clamp = function(number, min, max) {
+ return Math.max(min, Math.min(max, number));
+ };
+
+ return ConnectionMonitor;
+
+ })();

_service:tar_scm_kernel_repo:actioncable-6.0.3.4.gem/data/lib/rails/generators/channel/USAGE -> _service:tar_scm_kernel_repo:actioncable-5.2.4.4.gem/data/lib/rails/generators/channel/USAGE Changed

_service:tar_scm_kernel_repo:actioncable-6.0.3.4.gem/data/lib/rails/generators/channel/channel_generator.rb -> _service:tar_scm_kernel_repo:actioncable-5.2.4.4.gem/data/lib/rails/generators/channel/channel_generator.rb Changed

@@ -11,18 +11,15 @@
 
       check_class_collision suffix: "Channel"
 
-      hook_for :test_framework
-
       def create_channel_file
         template "channel.rb", File.join("app/channels", class_path, "#{file_name}_channel.rb")
 
         if options[:assets]
           if behavior == :invoke
-            template "javascript/index.js", "app/javascript/channels/index.js"
-            template "javascript/consumer.js", "app/javascript/channels/consumer.js"
+            template "assets/cable.js", "app/assets/javascripts/cable.js"
           end
 
-          js_template "javascript/channel", File.join("app/javascript/channels", class_path, "#{file_name}_channel")
+          js_template "assets/channel", File.join("app/assets/javascripts/channels", class_path, "#{file_name}")
         end
 
         generate_application_cable_files
@@ -30,7 +27,7 @@
 
       private
         def file_name
-          @_file_name ||= super.sub(/_channel\z/i, "")
+          @_file_name ||= super.gsub(/_channel/i, "")
         end
 
         # FIXME: Change these files to symlinks once RubyGems 2.5.0 is required.

_service:tar_scm_kernel_repo:actioncable-5.2.4.4.gem/data/lib/rails/generators/channel/templates/assets/cable.js.tt Added

_service:tar_scm_kernel_repo:actioncable-5.2.4.4.gem/data/lib/rails/generators/channel/templates/assets/channel.coffee.tt Added

_service:tar_scm_kernel_repo:actioncable-5.2.4.4.gem/data/lib/rails/generators/channel/templates/assets/channel.js.tt Added

_service:tar_scm_kernel_repo:actioncable-6.0.3.4.gem/metadata.gz -> _service:tar_scm_kernel_repo:actioncable-5.2.4.4.gem/metadata.gz Changed

@@ -1,15 +1,15 @@
 --- !ruby/object:Gem::Specification
 name: actioncable
 version: !ruby/object:Gem::Version
-  version: 6.0.3.4
+  version: 5.2.4.4
 platform: ruby
 authors:
 - Pratik Naik
 - David Heinemeier Hansson
-autorequire:
+autorequire: 
 bindir: bin
 cert_chain: []
-date: 2020-10-07 00:00:00.000000000 Z
+date: 2020-09-09 00:00:00.000000000 Z
 dependencies:
 - !ruby/object:Gem::Dependency
   name: actionpack
@@ -17,14 +17,14 @@
     requirements:
     - - '='
       - !ruby/object:Gem::Version
-        version: 6.0.3.4
+        version: 5.2.4.4
   type: :runtime
   prerelease: false
   version_requirements: !ruby/object:Gem::Requirement
     requirements:
     - - '='
       - !ruby/object:Gem::Version
-        version: 6.0.3.4
+        version: 5.2.4.4
 - !ruby/object:Gem::Dependency
   name: nio4r
   requirement: !ruby/object:Gem::Requirement
@@ -65,7 +65,6 @@
 - CHANGELOG.md
 - MIT-LICENSE
 - README.md
-- app/assets/javascripts/action_cable.js
 - lib/action_cable.rb
 - lib/action_cable/channel.rb
 - lib/action_cable/channel/base.rb
@@ -74,7 +73,6 @@
 - lib/action_cable/channel/naming.rb
 - lib/action_cable/channel/periodic_timers.rb
 - lib/action_cable/channel/streams.rb
-- lib/action_cable/channel/test_case.rb
 - lib/action_cable/connection.rb
 - lib/action_cable/connection/authorization.rb
 - lib/action_cable/connection/base.rb
@@ -86,7 +84,6 @@
 - lib/action_cable/connection/stream_event_loop.rb
 - lib/action_cable/connection/subscriptions.rb
 - lib/action_cable/connection/tagged_logger_proxy.rb
-- lib/action_cable/connection/test_case.rb
 - lib/action_cable/connection/web_socket.rb
 - lib/action_cable/engine.rb
 - lib/action_cable/gem_version.rb
@@ -107,30 +104,23 @@
 - lib/action_cable/subscription_adapter/postgresql.rb
 - lib/action_cable/subscription_adapter/redis.rb
 - lib/action_cable/subscription_adapter/subscriber_map.rb
-- lib/action_cable/subscription_adapter/test.rb
-- lib/action_cable/test_case.rb
-- lib/action_cable/test_helper.rb
 - lib/action_cable/version.rb
+- lib/assets/compiled/action_cable.js
 - lib/rails/generators/channel/USAGE
 - lib/rails/generators/channel/channel_generator.rb
 - lib/rails/generators/channel/templates/application_cable/channel.rb.tt
 - lib/rails/generators/channel/templates/application_cable/connection.rb.tt
+- lib/rails/generators/channel/templates/assets/cable.js.tt
+- lib/rails/generators/channel/templates/assets/channel.coffee.tt
+- lib/rails/generators/channel/templates/assets/channel.js.tt
 - lib/rails/generators/channel/templates/channel.rb.tt
-- lib/rails/generators/channel/templates/javascript/channel.js.tt
-- lib/rails/generators/channel/templates/javascript/consumer.js.tt
-- lib/rails/generators/channel/templates/javascript/index.js.tt
-- lib/rails/generators/test_unit/channel_generator.rb
-- lib/rails/generators/test_unit/templates/channel_test.rb.tt
-homepage: https://rubyonrails.org
+homepage: http://rubyonrails.org
 licenses:
 - MIT
 metadata:
-  bug_tracker_uri: https://github.com/rails/rails/issues
-  changelog_uri: https://github.com/rails/rails/blob/v6.0.3.4/actioncable/CHANGELOG.md
-  documentation_uri: https://api.rubyonrails.org/v6.0.3.4/
-  mailing_list_uri: https://discuss.rubyonrails.org/c/rubyonrails-talk
-  source_code_uri: https://github.com/rails/rails/tree/v6.0.3.4/actioncable
-post_install_message:
+  source_code_uri: https://github.com/rails/rails/tree/v5.2.4.4/actioncable
+  changelog_uri: https://github.com/rails/rails/blob/v5.2.4.4/actioncable/CHANGELOG.md
+post_install_message: 
 rdoc_options: []
 require_paths:
 - lib
@@ -138,15 +128,15 @@
   requirements:
   - - ">="
     - !ruby/object:Gem::Version
-      version: 2.5.0
+      version: 2.2.2
 required_rubygems_version: !ruby/object:Gem::Requirement
   requirements:
   - - ">="
     - !ruby/object:Gem::Version
       version: '0'
 requirements: []
-rubygems_version: 3.1.4
-signing_key:
+rubygems_version: 3.1.2
+signing_key: 
 specification_version: 4
 summary: WebSocket framework for Rails.
 test_files: []

_service:tar_scm_kernel_repo:actioncable-6.0.3.4.gem/data/app/assets/javascripts/action_cable.js Deleted

@@ -1,517 +0,0 @@
-(function(global, factory) {
- typeof exports === "object" && typeof module !== "undefined" ? factory(exports) : typeof define === "function" && define.amd ? define([ "exports" ], factory) : factory(global.ActionCable = {});
-})(this, function(exports) {
- "use strict";
- var adapters = {
- logger: self.console,
- WebSocket: self.WebSocket
- };
- var logger = {
- log: function log() {
- if (this.enabled) {
- var _adapters$logger;
- for (var _len = arguments.length, messages = Array(_len), _key = 0; _key < _len; _key++) {
- messages[_key] = arguments[_key];
- }
- messages.push(Date.now());
- (_adapters$logger = adapters.logger).log.apply(_adapters$logger, [ "[ActionCable]" ].concat(messages));
- }
- }
- };
- var _typeof = typeof Symbol === "function" && typeof Symbol.iterator === "symbol" ? function(obj) {
- return typeof obj;
- } : function(obj) {
- return obj && typeof Symbol === "function" && obj.constructor === Symbol && obj !== Symbol.prototype ? "symbol" : typeof obj;
- };
- var classCallCheck = function(instance, Constructor) {
- if (!(instance instanceof Constructor)) {
- throw new TypeError("Cannot call a class as a function");
- }
- };
- var createClass = function() {
- function defineProperties(target, props) {
- for (var i = 0; i < props.length; i++) {
- var descriptor = props[i];
- descriptor.enumerable = descriptor.enumerable || false;
- descriptor.configurable = true;
- if ("value" in descriptor) descriptor.writable = true;
- Object.defineProperty(target, descriptor.key, descriptor);
- }
- }
- return function(Constructor, protoProps, staticProps) {
- if (protoProps) defineProperties(Constructor.prototype, protoProps);
- if (staticProps) defineProperties(Constructor, staticProps);
- return Constructor;
- };
- }();
- var now = function now() {
- return new Date().getTime();
- };
- var secondsSince = function secondsSince(time) {
- return (now() - time) / 1e3;
- };
- var clamp = function clamp(number, min, max) {
- return Math.max(min, Math.min(max, number));
- };
- var ConnectionMonitor = function() {
- function ConnectionMonitor(connection) {
- classCallCheck(this, ConnectionMonitor);
- this.visibilityDidChange = this.visibilityDidChange.bind(this);
- this.connection = connection;
- this.reconnectAttempts = 0;
- }
- ConnectionMonitor.prototype.start = function start() {
- if (!this.isRunning()) {
- this.startedAt = now();
- delete this.stoppedAt;
- this.startPolling();
- addEventListener("visibilitychange", this.visibilityDidChange);
- logger.log("ConnectionMonitor started. pollInterval = " + this.getPollInterval() + " ms");
- }
- };
- ConnectionMonitor.prototype.stop = function stop() {
- if (this.isRunning()) {
- this.stoppedAt = now();
- this.stopPolling();
- removeEventListener("visibilitychange", this.visibilityDidChange);
- logger.log("ConnectionMonitor stopped");
- }
- };
- ConnectionMonitor.prototype.isRunning = function isRunning() {
- return this.startedAt && !this.stoppedAt;
- };
- ConnectionMonitor.prototype.recordPing = function recordPing() {
- this.pingedAt = now();
- };
- ConnectionMonitor.prototype.recordConnect = function recordConnect() {
- this.reconnectAttempts = 0;
- this.recordPing();
- delete this.disconnectedAt;
- logger.log("ConnectionMonitor recorded connect");
- };
- ConnectionMonitor.prototype.recordDisconnect = function recordDisconnect() {
- this.disconnectedAt = now();
- logger.log("ConnectionMonitor recorded disconnect");
- };
- ConnectionMonitor.prototype.startPolling = function startPolling() {
- this.stopPolling();
- this.poll();
- };
- ConnectionMonitor.prototype.stopPolling = function stopPolling() {
- clearTimeout(this.pollTimeout);
- };
- ConnectionMonitor.prototype.poll = function poll() {
- var _this = this;
- this.pollTimeout = setTimeout(function() {
- _this.reconnectIfStale();
- _this.poll();
- }, this.getPollInterval());
- };
- ConnectionMonitor.prototype.getPollInterval = function getPollInterval() {
- var _constructor$pollInte = this.constructor.pollInterval, min = _constructor$pollInte.min, max = _constructor$pollInte.max, multiplier = _constructor$pollInte.multiplier;
- var interval = multiplier * Math.log(this.reconnectAttempts + 1);
- return Math.round(clamp(interval, min, max) * 1e3);
- };
- ConnectionMonitor.prototype.reconnectIfStale = function reconnectIfStale() {
- if (this.connectionIsStale()) {
- logger.log("ConnectionMonitor detected stale connection. reconnectAttempts = " + this.reconnectAttempts + ", pollInterval = " + this.getPollInterval() + " ms, time disconnected = " + secondsSince(this.disconnectedAt) + " s, stale threshold = " + this.constructor.staleThreshold + " s");
- this.reconnectAttempts++;
- if (this.disconnectedRecently()) {
- logger.log("ConnectionMonitor skipping reopening recent disconnect");
- } else {
- logger.log("ConnectionMonitor reopening");
- this.connection.reopen();
- }
- }
- };
- ConnectionMonitor.prototype.connectionIsStale = function connectionIsStale() {
- return secondsSince(this.pingedAt ? this.pingedAt : this.startedAt) > this.constructor.staleThreshold;
- };
- ConnectionMonitor.prototype.disconnectedRecently = function disconnectedRecently() {
- return this.disconnectedAt && secondsSince(this.disconnectedAt) < this.constructor.staleThreshold;
- };
- ConnectionMonitor.prototype.visibilityDidChange = function visibilityDidChange() {
- var _this2 = this;
- if (document.visibilityState === "visible") {
- setTimeout(function() {
- if (_this2.connectionIsStale() || !_this2.connection.isOpen()) {
- logger.log("ConnectionMonitor reopening stale connection on visibilitychange. visbilityState = " + document.visibilityState);
- _this2.connection.reopen();
- }
- }, 200);
- }
- };
- return ConnectionMonitor;
- }();
- ConnectionMonitor.pollInterval = {
- min: 3,
- max: 30,
- multiplier: 5
- };
- ConnectionMonitor.staleThreshold = 6;
- var INTERNAL = {
- message_types: {
- welcome: "welcome",
- disconnect: "disconnect",
- ping: "ping",
- confirmation: "confirm_subscription",
- rejection: "reject_subscription"
- },
- disconnect_reasons: {
- unauthorized: "unauthorized",
- invalid_request: "invalid_request",
- server_restart: "server_restart"
- },
- default_mount_path: "/cable",
- protocols: [ "actioncable-v1-json", "actioncable-unsupported" ]
- };
- var message_types = INTERNAL.message_types, protocols = INTERNAL.protocols;
- var supportedProtocols = protocols.slice(0, protocols.length - 1);
- var indexOf = [].indexOf;
- var Connection = function() {
- function Connection(consumer) {
- classCallCheck(this, Connection);
- this.open = this.open.bind(this);
- this.consumer = consumer;
- this.subscriptions = this.consumer.subscriptions;
- this.monitor = new ConnectionMonitor(this);
- this.disconnected = true;
- }
- Connection.prototype.send = function send(data) {
- if (this.isOpen()) {
- this.webSocket.send(JSON.stringify(data));
- return true;
- } else {
- return false;
- }
- };
- Connection.prototype.open = function open() {
- if (this.isActive()) {
- logger.log("Attempted to open WebSocket, but existing socket is " + this.getState());
- return false;
- } else {
- logger.log("Opening WebSocket, current state is " + this.getState() + ", subprotocols: " + protocols);
- if (this.webSocket) {
- this.uninstallEventHandlers();
- }
- this.webSocket = new adapters.WebSocket(this.consumer.url, protocols);
- this.installEventHandlers();
- this.monitor.start();

_service:tar_scm_kernel_repo:actioncable-6.0.3.4.gem/data/lib/action_cable/channel/test_case.rb Deleted

@@ -1,310 +0,0 @@
-# frozen_string_literal: true
-
-require "active_support"
-require "active_support/test_case"
-require "active_support/core_ext/hash/indifferent_access"
-require "json"
-
-module ActionCable
- module Channel
- class NonInferrableChannelError < ::StandardError
- def initialize(name)
- super "Unable to determine the channel to test from #{name}. " +
- "You'll need to specify it using `tests YourChannel` in your " +
- "test case definition."
- end
- end
-
- # Stub `stream_from` to track streams for the channel.
- # Add public aliases for `subscription_confirmation_sent?` and
- # `subscription_rejected?`.
- module ChannelStub
- def confirmed?
- subscription_confirmation_sent?
- end
-
- def rejected?
- subscription_rejected?
- end
-
- def stream_from(broadcasting, *)
- streams << broadcasting
- end
-
- def stop_all_streams
- @_streams = []
- end
-
- def streams
- @_streams ||= []
- end
-
- # Make periodic timers no-op
- def start_periodic_timers; end
- alias stop_periodic_timers start_periodic_timers
- end
-
- class ConnectionStub
- attr_reader :transmissions, :identifiers, :subscriptions, :logger
-
- def initialize(identifiers = {})
- @transmissions = []
-
- identifiers.each do |identifier, val|
- define_singleton_method(identifier) { val }
- end
-
- @subscriptions = ActionCable::Connection::Subscriptions.new(self)
- @identifiers = identifiers.keys
- @logger = ActiveSupport::TaggedLogging.new ActiveSupport::Logger.new(StringIO.new)
- end
-
- def transmit(cable_message)
- transmissions << cable_message.with_indifferent_access
- end
- end
-
- # Superclass for Action Cable channel functional tests.
- #
- # == Basic example
- #
- # Functional tests are written as follows:
- # 1. First, one uses the +subscribe+ method to simulate subscription creation.
- # 2. Then, one asserts whether the current state is as expected. "State" can be anything:
- # transmitted messages, subscribed streams, etc.
- #
- # For example:
- #
- # class ChatChannelTest < ActionCable::Channel::TestCase
- # def test_subscribed_with_room_number
- # # Simulate a subscription creation
- # subscribe room_number: 1
- #
- # # Asserts that the subscription was successfully created
- # assert subscription.confirmed?
- #
- # # Asserts that the channel subscribes connection to a stream
- # assert_has_stream "chat_1"
- #
- # # Asserts that the channel subscribes connection to a specific
- # # stream created for a model
- # assert_has_stream_for Room.find(1)
- # end
- #
- # def test_does_not_stream_with_incorrect_room_number
- # subscribe room_number: -1
- #
- # # Asserts that not streams was started
- # assert_no_streams
- # end
- #
- # def test_does_not_subscribe_without_room_number
- # subscribe
- #
- # # Asserts that the subscription was rejected
- # assert subscription.rejected?
- # end
- # end
- #
- # You can also perform actions:
- # def test_perform_speak
- # subscribe room_number: 1
- #
- # perform :speak, message: "Hello, Rails!"
- #
- # assert_equal "Hello, Rails!", transmissions.last["text"]
- # end
- #
- # == Special methods
- #
- # ActionCable::Channel::TestCase will also automatically provide the following instance
- # methods for use in the tests:
- #
- # connection::
- # An ActionCable::Channel::ConnectionStub, representing the current HTTP connection.
- # subscription::
- # An instance of the current channel, created when you call `subscribe`.
- # transmissions::
- # A list of all messages that have been transmitted into the channel.
- #
- #
- # == Channel is automatically inferred
- #
- # ActionCable::Channel::TestCase will automatically infer the channel under test
- # from the test class name. If the channel cannot be inferred from the test
- # class name, you can explicitly set it with +tests+.
- #
- # class SpecialEdgeCaseChannelTest < ActionCable::Channel::TestCase
- # tests SpecialChannel
- # end
- #
- # == Specifying connection identifiers
- #
- # You need to set up your connection manually to provide values for the identifiers.
- # To do this just use:
- #
- # stub_connection(user: users(:john))
- #
- # == Testing broadcasting
- #
- # ActionCable::Channel::TestCase enhances ActionCable::TestHelper assertions (e.g.
- # +assert_broadcasts+) to handle broadcasting to models:
- #
- #
- # # in your channel
- # def speak(data)
- # broadcast_to room, text: data["message"]
- # end
- #
- # def test_speak
- # subscribe room_id: rooms(:chat).id
- #
- # assert_broadcasts_on(rooms(:chat), text: "Hello, Rails!") do
- # perform :speak, message: "Hello, Rails!"
- # end
- # end
- class TestCase < ActiveSupport::TestCase
- module Behavior
- extend ActiveSupport::Concern
-
- include ActiveSupport::Testing::ConstantLookup
- include ActionCable::TestHelper
-
- CHANNEL_IDENTIFIER = "test_stub"
-
- included do
- class_attribute :_channel_class
-
- attr_reader :connection, :subscription
-
- ActiveSupport.run_load_hooks(:action_cable_channel_test_case, self)
- end
-
- module ClassMethods
- def tests(channel)
- case channel
- when String, Symbol
- self._channel_class = channel.to_s.camelize.constantize
- when Module
- self._channel_class = channel
- else
- raise NonInferrableChannelError.new(channel)
- end
- end
-
- def channel_class
- if channel = self._channel_class
- channel
- else
- tests determine_default_channel(name)

_service:tar_scm_kernel_repo:actioncable-6.0.3.4.gem/data/lib/action_cable/connection/test_case.rb Deleted

@@ -1,234 +0,0 @@
-# frozen_string_literal: true
-
-require "active_support"
-require "active_support/test_case"
-require "active_support/core_ext/hash/indifferent_access"
-require "action_dispatch"
-require "action_dispatch/http/headers"
-require "action_dispatch/testing/test_request"
-
-module ActionCable
- module Connection
- class NonInferrableConnectionError < ::StandardError
- def initialize(name)
- super "Unable to determine the connection to test from #{name}. " +
- "You'll need to specify it using `tests YourConnection` in your " +
- "test case definition."
- end
- end
-
- module Assertions
- # Asserts that the connection is rejected (via +reject_unauthorized_connection+).
- #
- # # Asserts that connection without user_id fails
- # assert_reject_connection { connect params: { user_id: '' } }
- def assert_reject_connection(&block)
- assert_raises(Authorization::UnauthorizedError, "Expected to reject connection but no rejection was made", &block)
- end
- end
-
- # We don't want to use the whole "encryption stack" for connection
- # unit-tests, but we want to make sure that users test against the correct types
- # of cookies (i.e. signed or encrypted or plain)
- class TestCookieJar < ActiveSupport::HashWithIndifferentAccess
- def signed
- self[:signed] ||= {}.with_indifferent_access
- end
-
- def encrypted
- self[:encrypted] ||= {}.with_indifferent_access
- end
- end
-
- class TestRequest < ActionDispatch::TestRequest
- attr_accessor :session, :cookie_jar
- end
-
- module TestConnection
- attr_reader :logger, :request
-
- def initialize(request)
- inner_logger = ActiveSupport::Logger.new(StringIO.new)
- tagged_logging = ActiveSupport::TaggedLogging.new(inner_logger)
- @logger = ActionCable::Connection::TaggedLoggerProxy.new(tagged_logging, tags: [])
- @request = request
- @env = request.env
- end
- end
-
- # Unit test Action Cable connections.
- #
- # Useful to check whether a connection's +identified_by+ gets assigned properly
- # and that any improper connection requests are rejected.
- #
- # == Basic example
- #
- # Unit tests are written as follows:
- #
- # 1. Simulate a connection attempt by calling +connect+.
- # 2. Assert state, e.g. identifiers, has been assigned.
- #
- #
- # class ApplicationCable::ConnectionTest < ActionCable::Connection::TestCase
- # def test_connects_with_proper_cookie
- # # Simulate the connection request with a cookie.
- # cookies["user_id"] = users(:john).id
- #
- # connect
- #
- # # Assert the connection identifier matches the fixture.
- # assert_equal users(:john).id, connection.user.id
- # end
- #
- # def test_rejects_connection_without_proper_cookie
- # assert_reject_connection { connect }
- # end
- # end
- #
- # +connect+ accepts additional information the HTTP request with the
- # +params+, +headers+, +session+ and Rack +env+ options.
- #
- # def test_connect_with_headers_and_query_string
- # connect params: { user_id: 1 }, headers: { "X-API-TOKEN" => "secret-my" }
- #
- # assert_equal "1", connection.user.id
- # assert_equal "secret-my", connection.token
- # end
- #
- # def test_connect_with_params
- # connect params: { user_id: 1 }
- #
- # assert_equal "1", connection.user.id
- # end
- #
- # You can also setup the correct cookies before the connection request:
- #
- # def test_connect_with_cookies
- # # Plain cookies:
- # cookies["user_id"] = 1
- #
- # # Or signed/encrypted:
- # # cookies.signed["user_id"] = 1
- # # cookies.encrypted["user_id"] = 1
- #
- # connect
- #
- # assert_equal "1", connection.user_id
- # end
- #
- # == Connection is automatically inferred
- #
- # ActionCable::Connection::TestCase will automatically infer the connection under test
- # from the test class name. If the channel cannot be inferred from the test
- # class name, you can explicitly set it with +tests+.
- #
- # class ConnectionTest < ActionCable::Connection::TestCase
- # tests ApplicationCable::Connection
- # end
- #
- class TestCase < ActiveSupport::TestCase
- module Behavior
- extend ActiveSupport::Concern
-
- DEFAULT_PATH = "/cable"
-
- include ActiveSupport::Testing::ConstantLookup
- include Assertions
-
- included do
- class_attribute :_connection_class
-
- attr_reader :connection
-
- ActiveSupport.run_load_hooks(:action_cable_connection_test_case, self)
- end
-
- module ClassMethods
- def tests(connection)
- case connection
- when String, Symbol
- self._connection_class = connection.to_s.camelize.constantize
- when Module
- self._connection_class = connection
- else
- raise NonInferrableConnectionError.new(connection)
- end
- end
-
- def connection_class
- if connection = self._connection_class
- connection
- else
- tests determine_default_connection(name)
- end
- end
-
- def determine_default_connection(name)
- connection = determine_constant_from_test_name(name) do |constant|
- Class === constant && constant < ActionCable::Connection::Base
- end
- raise NonInferrableConnectionError.new(name) if connection.nil?
- connection
- end
- end
-
- # Performs connection attempt to exert #connect on the connection under test.
- #
- # Accepts request path as the first argument and the following request options:
- #
- # - params – URL parameters (Hash)
- # - headers – request headers (Hash)
- # - session – session data (Hash)
- # - env – additional Rack env configuration (Hash)
- def connect(path = ActionCable.server.config.mount_path, **request_params)
- path ||= DEFAULT_PATH
-
- connection = self.class.connection_class.allocate
- connection.singleton_class.include(TestConnection)
- connection.send(:initialize, build_test_request(path, **request_params))
- connection.connect if connection.respond_to?(:connect)
-
- # Only set instance variable if connected successfully
- @connection = connection
- end
-
- # Exert #disconnect on the connection under test.
- def disconnect
- raise "Must be connected!" if connection.nil?
-
- connection.disconnect if connection.respond_to?(:disconnect)

_service:tar_scm_kernel_repo:actioncable-6.0.3.4.gem/data/lib/action_cable/subscription_adapter/test.rb Deleted

@@ -1,40 +0,0 @@
-# frozen_string_literal: true
-
-require_relative "async"
-
-module ActionCable
- module SubscriptionAdapter
- # == Test adapter for Action Cable
- #
- # The test adapter should be used only in testing. Along with
- # <tt>ActionCable::TestHelper</tt> it makes a great tool to test your Rails application.
- #
- # To use the test adapter set +adapter+ value to +test+ in your +config/cable.yml+ file.
- #
- # NOTE: Test adapter extends the <tt>ActionCable::SubscriptionsAdapter::Async</tt> adapter,
- # so it could be used in system tests too.
- class Test < Async
- def broadcast(channel, payload)
- broadcasts(channel) << payload
- super
- end
-
- def broadcasts(channel)
- channels_data[channel] ||= []
- end
-
- def clear_messages(channel)
- channels_data[channel] = []
- end
-
- def clear
- @channels_data = nil
- end
-
- private
- def channels_data
- @channels_data ||= {}
- end
- end
- end
-end

_service:tar_scm_kernel_repo:actioncable-6.0.3.4.gem/data/lib/action_cable/test_case.rb Deleted

_service:tar_scm_kernel_repo:actioncable-6.0.3.4.gem/data/lib/action_cable/test_helper.rb Deleted

@@ -1,133 +0,0 @@
-# frozen_string_literal: true
-
-module ActionCable
-  # Provides helper methods for testing Action Cable broadcasting
-  module TestHelper
-    def before_setup # :nodoc:
-      server = ActionCable.server
-      test_adapter = ActionCable::SubscriptionAdapter::Test.new(server)
-
-      @old_pubsub_adapter = server.pubsub
-
-      server.instance_variable_set(:@pubsub, test_adapter)
-      super
-    end
-
-    def after_teardown # :nodoc:
-      super
-      ActionCable.server.instance_variable_set(:@pubsub, @old_pubsub_adapter)
-    end
-
-    # Asserts that the number of broadcasted messages to the stream matches the given number.
-    #
-    #   def test_broadcasts
-    #     assert_broadcasts 'messages', 0
-    #     ActionCable.server.broadcast 'messages', { text: 'hello' }
-    #     assert_broadcasts 'messages', 1
-    #     ActionCable.server.broadcast 'messages', { text: 'world' }
-    #     assert_broadcasts 'messages', 2
-    #   end
-    #
-    # If a block is passed, that block should cause the specified number of
-    # messages to be broadcasted.
-    #
-    #   def test_broadcasts_again
-    #     assert_broadcasts('messages', 1) do
-    #       ActionCable.server.broadcast 'messages', { text: 'hello' }
-    #     end
-    #
-    #     assert_broadcasts('messages', 2) do
-    #       ActionCable.server.broadcast 'messages', { text: 'hi' }
-    #       ActionCable.server.broadcast 'messages', { text: 'how are you?' }
-    #     end
-    #   end
-    #
-    def assert_broadcasts(stream, number)
-      if block_given?
-        original_count = broadcasts_size(stream)
-        yield
-        new_count = broadcasts_size(stream)
-        actual_count = new_count - original_count
-      else
-        actual_count = broadcasts_size(stream)
-      end
-
-      assert_equal number, actual_count, "#{number} broadcasts to #{stream} expected, but #{actual_count} were sent"
-    end
-
-    # Asserts that no messages have been sent to the stream.
-    #
-    #   def test_no_broadcasts
-    #     assert_no_broadcasts 'messages'
-    #     ActionCable.server.broadcast 'messages', { text: 'hi' }
-    #     assert_broadcasts 'messages', 1
-    #   end
-    #
-    # If a block is passed, that block should not cause any message to be sent.
-    #
-    #   def test_broadcasts_again
-    #     assert_no_broadcasts 'messages' do
-    #       # No job messages should be sent from this block
-    #     end
-    #   end
-    #
-    # Note: This assertion is simply a shortcut for:
-    #
-    #   assert_broadcasts 'messages', 0, &block
-    #
-    def assert_no_broadcasts(stream, &block)
-      assert_broadcasts stream, 0, &block
-    end
-
-    # Asserts that the specified message has been sent to the stream.
-    #
-    #   def test_assert_transmitted_message
-    #     ActionCable.server.broadcast 'messages', text: 'hello'
-    #     assert_broadcast_on('messages', text: 'hello')
-    #   end
-    #
-    # If a block is passed, that block should cause a message with the specified data to be sent.
-    #
-    #   def test_assert_broadcast_on_again
-    #     assert_broadcast_on('messages', text: 'hello') do
-    #       ActionCable.server.broadcast 'messages', text: 'hello'
-    #     end
-    #   end
-    #
-    def assert_broadcast_on(stream, data)
-      # Encode to JSON and back–we want to use this value to compare
-      # with decoded JSON.
-      # Comparing JSON strings doesn't work due to the order if the keys.
-      serialized_msg =
-        ActiveSupport::JSON.decode(ActiveSupport::JSON.encode(data))
-
-      new_messages = broadcasts(stream)
-      if block_given?
-        old_messages = new_messages
-        clear_messages(stream)
-
-        yield
-        new_messages = broadcasts(stream)
-        clear_messages(stream)
-
-        # Restore all sent messages
-        (old_messages + new_messages).each { |m| pubsub_adapter.broadcast(stream, m) }
-      end
-
-      message = new_messages.find { |msg| ActiveSupport::JSON.decode(msg) == serialized_msg }
-
-      assert message, "No messages sent with #{data} to #{stream}"
-    end
-
-    def pubsub_adapter # :nodoc:
-      ActionCable.server.pubsub
-    end
-
-    delegate :broadcasts, :clear_messages, to: :pubsub_adapter
-
-    private
-      def broadcasts_size(channel)
-        broadcasts(channel).size
-      end
-  end
-end

_service:tar_scm_kernel_repo:actioncable-6.0.3.4.gem/data/lib/rails/generators/channel/templates/javascript/channel.js.tt Deleted

_service:tar_scm_kernel_repo:actioncable-6.0.3.4.gem/data/lib/rails/generators/channel/templates/javascript/consumer.js.tt Deleted

_service:tar_scm_kernel_repo:actioncable-6.0.3.4.gem/data/lib/rails/generators/channel/templates/javascript/index.js.tt Deleted

_service:tar_scm_kernel_repo:actioncable-6.0.3.4.gem/data/lib/rails/generators/test_unit/channel_generator.rb Deleted

_service:tar_scm_kernel_repo:actioncable-6.0.3.4.gem/data/lib/rails/generators/test_unit/templates/channel_test.rb.tt Deleted

_service:tar_scm_kernel_repo:recompile_js.rb Added

_service:tar_scm_kernel_repo:v6.0.3.4.tar.gz -> _service:tar_scm_kernel_repo:v5.2.4.4.tar.gz Changed

Changes of Revision 18