I understand that there are probably technical complexities which make these operations very difficult to provide

For example, this needs parity with unfollow_many(follows)

# Batch following many feeds (requires ruby 2.1 or later)
follows = [
  {:source => 'flat:1', :target => 'user:1'},
  {:source => 'flat:1', :target => 'user:2'},
  {:source => 'flat:1', :target => 'user:3'},
]
client.follow_many(follows)

and user_feed_1.remove_activities(activities)

# Batch adding activities
activities = [
    [:actor => '1', :verb => 'tweet', :object => '1'],
    [:actor => '2', :verb => 'like', :object => '3']
]
user_feed_1.add_activities(activities)

I've seen a lot of questions where the response is usually ¯_(ツ)_/¯, or just to orphan the data. The biggest use case is user deletion/deactivation. To actually delete the users footprint is an incredibly painful operation with thousands and thousands of api calls required depending on the user.

make sure that the use case: get models from cache is easy to explain in the docs ;)

the readme and code should explain how to generate a token for usage in the client side API

Are there any plans on implementing an asynchronous HTTP client, as right now the client can be a real bottleneck in a web application if requests aren't moved into the background?

I am having this weird issue I can only reproduce on an app deployed with Heroku.

I am calling the Stream::Feed#followers and Stream::Feed#following methods, but they return an HTTParty object instead of an array as it does on my local machine.

E.g.:

irb(main):002:0> STREAM_CLIENT.feed("user", "139052").following
=> #<HTTParty::Response:0x7f05820da1b8 parsed_response={"duration"=>"12ms", "results"=>[]}, @response=#<Net::HTTPOK 200 OK readbody=true>, @headers={"allow"=>["GET, POST, HEAD, OPTIONS"], "cache-control"=>["max-age=0"], "content-type"=>["application/json"], "date"=>["Fri, 15 Jan 2016 00:08:51 GMT"], "server"=>["nginx/1.4.6 (Ubuntu)"], "vary"=>["Accept"], "content-length"=>["35"], "connection"=>["Close"]}>

Any ideas of what can be going wrong?

just wondering about it. thanks.

Let's say we're in a game lobby, and i'm modeling comment activity. Normally when a user would leave a comment i would add that activity to their user feed, and then utilize the to: field to add this activity to relevant users (in this scenario all users in the lobby).

So now anyone following that user will see this story in their newsfeed, and those directly involved will also get the notifications.

Now in some situations, i do not send this activity to the users feed because because of a privacy preference, so instead i take the activity and use the add_to_many (where as before i would attach it to the to field) and send them to the notification feeds, which is what i want.

https://stackoverflow.com/questions/46435072/does-batch-activity-add-trigger-on-firehose

After reading this it looks like my notification firehose don't get these updates per design, although I still don't really get why.

So instead of this:

to_array = push_users.pluck(:id).map {|id| "notification:#{id}" }
stream_client.add_to_many(activity_data, to_array)

I now have to do this in order to get the firehose.

push_users.pluck(:id).each do |id| 
  notification_feed = stream_client.feed('notification', id)  
  notification_feed.add_activity(activity_data)  
end

The problem is, I have decoupled my push logic and made the getstream firehose my clearing house for literal APN pushes, so any activity i want to push to multiple notification feeds has to be done individually, given that the activity cannot be added to the users feed.

Using the following code to post to my stream, while in @text parameter there is a text in Hebrew submitted by users:

activity_data = {:actor => @user_id, :verb => 'post', :object => 1, :post => @text}
activity_response = @user_feed.add_activity(activity_data)

Every time a text has break line in it, it rises the following exception on your side:
795: unexpected token at '{ "text" : "ש��� ��ר.......!" }'

Users have reported Net::ReadTimeout or Net::OpenTimeout in rare cases. Maybe our connection defaults can be improved?

with this gem is it possible to generate a user session token ?

cover adding

• lists, dicts and dates

"{"code": 413, "detail": "The request body was too large (limit is 128k)", "duration": "0ms", "exception": "RequestTooLarge", "status_code": 413}"

Any tips?

Some tests are consistently failing (while others are inconsistently passing). Either the service is having inconsistencies/problems, or perhaps the lack of test tear downs/mocks is causing some of these failures?

Firstly, having one key/secret combo means that anyone running the tests simultaneously are creating race conditions that could potentially cause them to fail (depending on the current and future test logic).

Second, the overlap of feed keys makes this even more likely. You could start with randomized feed keys in the setup (while still using the live service), and completely remove all data from them during the teardown, which would make a collision less likely.

But ultimately, the library shouldn't be testing the actual API (they should have their own tests), it should be testing the input/output. That probably means mocking the actual API results (maybe even programmatically during the setup).

Just some thoughts...

-r

Hi there! This is probably a very newbie question but I searched like whole internet and can't figure it out. So, I have stream.rb in config/initializers with:

require 'stream'
stream = Stream::Client.new(Rails.application.secrets.stream_key, Rails.application.secrets.stream_secret, Rails.application.secrets.stream_id, location: 'eu-central')

The problems is reaching this stream variable from controllers/models. Is there like a common practice on how to do this? I know this is probably simpler with stream-rails but it doesn't seem like its working with rails5 so I decided to go with ruby version.

Reported by A David Thyresson (Stattleship.com)

/Users/dthyresson/.rbenv/versions/2.1.5/lib/ruby/gems/2.1.0/gems/stream-ruby-2.1.2/lib/stream/client.rb:8: warning: nested repeat operator '?' and '' was replaced with '' in regular expression

08:04:13 web.1 | [32068] * Preloading application
08:04:15 web.1 | /Users/dthyresson/.rbenv/versions/2.1.5/lib/ruby/gems/2.1.0/gems/stream-ruby-2.1.2/lib/stream/client.rb:8: warning: nested repeat operator '?' and '' was replaced with '' in reg

Using the stream-ruby gem we're getting this in the logs:

WARNING: Unexpected middleware set after the adapter. This won't be supported from Faraday 1.0.

Looks like it's coming from here:

For my rails-api Rails App I am getting the following error with both the stream-ruby and stream-rails gems.

Environment:

• Ruby 2.3.1
• Rails 5.0.0.1

This error occurs whenever trying to create an activity, either as part of creating an ActiveRecord Object when include StreamRails::Activity is on the model, or simply creating an activity in the console with:

response = user_feed.add_activity(data)

JSON::ParserError: 743: unexpected token at ''
	from /Users/tom/.gem/ruby/2.3.1/gems/json-2.0.2/lib/json/common.rb:156:in `parse'
	from /Users/tom/.gem/ruby/2.3.1/gems/json-2.0.2/lib/json/common.rb:156:in `parse'
	from /Users/tom/.gem/ruby/2.3.1/gems/stream-ruby-2.6.0/lib/stream/client.rb:190:in `_build_error_message'
	from /Users/tom/.gem/ruby/2.3.1/gems/stream-ruby-2.6.0/lib/stream/client.rb:177:in `block in call'
	from /Users/tom/.gem/ruby/2.3.1/gems/faraday-0.15.0/lib/faraday/response.rb:61:in `on_complete'
	from /Users/tom/.gem/ruby/2.3.1/gems/stream-ruby-2.6.0/lib/stream/client.rb:166:in `call'
	from /Users/tom/.gem/ruby/2.3.1/gems/faraday-0.15.0/lib/faraday/rack_builder.rb:143:in `build_response'
	from /Users/tom/.gem/ruby/2.3.1/gems/faraday-0.15.0/lib/faraday/connection.rb:387:in `run_request'
	from /Users/tom/.gem/ruby/2.3.1/gems/stream-ruby-2.6.0/lib/stream/client.rb:150:in `make_http_request'
	from /Users/tom/.gem/ruby/2.3.1/gems/stream-ruby-2.6.0/lib/stream/client.rb:115:in `make_request'
	from /Users/tom/.gem/ruby/2.3.1/gems/stream-ruby-2.6.0/lib/stream/feed.rb:67:in `add_activity'
	from (irb):21
	from /Users/tom/.gem/ruby/2.3.1/gems/railties-5.0.0.1/lib/rails/commands/console.rb:65:in `start'
	from /Users/tom/.gem/ruby/2.3.1/gems/railties-5.0.0.1/lib/rails/commands/console_helper.rb:9:in `start'
	from /Users/tom/.gem/ruby/2.3.1/gems/railties-5.0.0.1/lib/rails/commands/commands_tasks.rb:78:in `console'
	from /Users/tom/.gem/ruby/2.3.1/gems/railties-5.0.0.1/lib/rails/commands/commands_tasks.rb:49:in `run_command!'
... 6 levels...
	from /Users/tom/.gem/ruby/2.3.1/gems/activesupport-5.0.0.1/lib/active_support/dependencies.rb:287:in `load'
	from /Users/tom/.gem/ruby/2.3.1/gems/activesupport-5.0.0.1/lib/active_support/dependencies.rb:287:in `block in load'
	from /Users/tom/.gem/ruby/2.3.1/gems/activesupport-5.0.0.1/lib/active_support/dependencies.rb:259:in `load_dependency'
	from /Users/tom/.gem/ruby/2.3.1/gems/activesupport-5.0.0.1/lib/active_support/dependencies.rb:287:in `load'
	from /Users/tom/.gem/ruby/2.3.1/gems/spring-1.7.2/lib/spring/commands/rails.rb:6:in `call'
	from /Users/tom/.gem/ruby/2.3.1/gems/spring-1.7.2/lib/spring/command_wrapper.rb:38:in `call'
	from /Users/tom/.gem/ruby/2.3.1/gems/spring-1.7.2/lib/spring/application.rb:191:in `block in serve'
	from /Users/tom/.gem/ruby/2.3.1/gems/spring-1.7.2/lib/spring/application.rb:161:in `fork'
	from /Users/tom/.gem/ruby/2.3.1/gems/spring-1.7.2/lib/spring/application.rb:161:in `serve'
	from /Users/tom/.gem/ruby/2.3.1/gems/spring-1.7.2/lib/spring/application.rb:131:in `block in run'
	from /Users/tom/.gem/ruby/2.3.1/gems/spring-1.7.2/lib/spring/application.rb:125:in `loop'
	from /Users/tom/.gem/ruby/2.3.1/gems/spring-1.7.2/lib/spring/application.rb:125:in `run'
	from /Users/tom/.gem/ruby/2.3.1/gems/spring-1.7.2/lib/spring/application/boot.rb:19:in `<top (required)>'
	from /Users/tom/.rubies/ruby-2.3.1/lib/ruby/2.3.0/rubygems/core_ext/kernel_require.rb:55:in `require'
	from /Users/tom/.rubies/ruby-2.3.1/lib/ruby/2.3.0/rubygems/core_ext/kernel_require.rb:55:in `require'
	from -e:1:in `<main>'

I am trying to retrieve a feed from getstream.io but it seems that the client is having trouble parsing the response because it is in HTML. Also not sure why the response says that the resource is not found, when the feed exists checking from the feed explorer on the getstream dashboard.

(pry)> stream_client.feed('user', self.id).get
JSON::ParserError: lexical error: invalid char in json text.
                                   <html>  <head><title>302 Found<
                 (right here) ------^

I tried prying the gem and the error happens at /lib/stream/feed.rb upon the @client.make_request call

def get(params = {})
  uri = "/feed/#{@feed_url}/"
  if params[:mark_read] && params[:mark_read].is_a?(Array)
    params[:mark_read] = params[:mark_read].join(',')
  end
  if params[:mark_seen] && params[:mark_seen].is_a?(Array)
    params[:mark_seen] = params[:mark_seen].join(',')
  end
  auth_token = create_jwt_token('feed', 'read')

  @client.make_request(:get, uri, auth_token, params)
end

python, js and ruby do it like this

Get the feed object for aggregated 3 and follow user 1

aggregated3 = client.feed('aggregated:3')
aggregated3.follow('user:1')

vs

// Get the feed object for aggregated 3 and follow user 1
$aggregated3 = $client->feed('aggregated:3');
$aggregated3->followFeed('user:1');

USER_AGENT should be "stream-ruby-client-#{version}"

secret = the api secret
token = a token for accessing a feed (generated from the secret)
authorization = the header sent for authorization combining the feed name and the token

seems like in some cases we don't include the full error message from the APIs (eg. when sending an invalid verb such as "this_is_not_good")

Follow Many and Add To Many use HTTPSig, we can now replace that with JWT (and remove it from deps)

Batch following many feeds (requires ruby 2.1 or later)

follows = [{
:source => 'flat:1', :target => 'user:1',
:source => 'flat:1', :target => 'user:2',
:source => 'flat:1', :target => 'user:3'
}]

should be:
follows = [
{:source => 'timeline:1', :target => 'user:1'},
{:source => 'timeline:1', :target => 'user:2'},
{:source => 'timeline:1', :target => 'user:3'}
]

Otherwise the keys will just get overwritten.

Are you able to allow faraday versions >= 0.9, and not limit jwt to exactly 1.5.2 (maybe allowing >= 1.0)?

I've had to go back to to version 2.2.5 version of this gem to avoid jwt and faraday conflicts with other gems we are using.

https://www.ruby-lang.org/en/downloads/

It'd be great to see ruby style guide enforced in the build - interested in a patch?

Rubocop

self_feed.unfollow(feed_name, 123, keep_history: true) is returning error
*** ArgumentError Exception: wrong number of arguments (3 for 2).

In the method declaration, def unfollow(target_feed_slug, target_user_id, keep_history = false) no longer has the symbol argument so the documentation is outdated; however, running this:

self_feed.unfollow(feed_name, 123, true) still returns the exact same argument error.
*** ArgumentError Exception: wrong number of arguments (3 for 2)

Without the keep_history argument, I receive a proper response from the API.
#<HTTParty::Response:0x7fa8d827a910 parsed_response={"duration"=>"44ms"}, @response=#<Net::HTTPOK 200 OK readbody=true>, @headers={"allow"=>["DELETE, OPTIONS"], "content-type"=>["application/json"], "date"=>["Thu, 29 Sep 2016 20:01:17 GMT"], "server"=>["nginx"], "vary"=>["Accept"], "content-length"=>["20"], "connection"=>["Close"]}>

Is there any way to update all activities? I'd like to add an information in them, but I don't know how to retrieve/update all

Currently they ruby client doesn't support updating activities.

Examples are failing with NoMethodError: undefined method `to_json' for {}:Hash.
Probably you should refer to ActiveSupport dependency somewhere

Can anyone of you push the 2.2.4 gem to rubygems.org? It's still at 2.2.3: https://rubygems.org/gems/stream-ruby/

The latest commits have broken support for Ruby 1.9.3, because the gem jwt doesn't support it. See here: https://travis-ci.org/GetStream/stream-ruby/jobs/115152833

/home/travis/.rvm/rubies/ruby-1.9.3-p551/bin/ruby -S rspec ./spec/client_spec.rb ./spec/errors_spec.rb ./spec/feed_spec.rb ./spec/integration_spec.rb ./spec/signer_spec.rb ./spec/stream_spec.rb
/home/travis/.rvm/gems/ruby-1.9.3-p551/gems/jwt-1.5.3/lib/jwt/decode.rb:2:in `require': /home/travis/.rvm/gems/ruby-1.9.3-p551/gems/jwt-1.5.3/lib/jwt/verify.rb:7: unknown type of %string (SyntaxError)
      %i[verify_aud verify_expiration ...
         ^
/home/travis/.rvm/gems/ruby-1.9.3-p551/gems/jwt-1.5.3/lib/jwt/verify.rb:7: syntax error, unexpected $end
      %i[verify_aud verify_expiration ...
         ^
    from /home/travis/.rvm/gems/ruby-1.9.3-p551/gems/jwt-1.5.3/lib/jwt/decode.rb:2:in `<top (required)>'
    from /home/travis/.rvm/gems/ruby-1.9.3-p551/gems/jwt-1.5.3/lib/jwt.rb:3:in `require'
    from /home/travis/.rvm/gems/ruby-1.9.3-p551/gems/jwt-1.5.3/lib/jwt.rb:3:in `<top (required)>'

The readme and gym support a Feed#delete method but I can't find it in the docs and it 404s.

Stream::StreamApiResponseException: DELETE https://eu-west-api.stream-io-api.com/api/v1.0/feed/gym/511/?api_key=[redacted]: 404: url not found