message_bus 4.3.2 → 4.3.3
This diff represents the content of publicly available package versions that have been released to one of the supported registries. The information contained in this diff is provided for informational purposes only and reflects changes between package versions as they appear in their respective public registries.
- checksums.yaml +4 -4
- data/CHANGELOG +7 -3
- data/README.md +3 -8
- data/lib/message_bus/client.rb +1 -1
- data/lib/message_bus/rack/middleware.rb +4 -4
- data/lib/message_bus/version.rb +1 -1
- data/package-lock.json +573 -847
- data/spec/lib/message_bus/client_spec.rb +6 -0
- metadata +2 -2
checksums.yaml
CHANGED
|
@@ -1,7 +1,7 @@
|
|
|
1
1
|
---
|
|
2
2
|
SHA256:
|
|
3
|
-
metadata.gz:
|
|
4
|
-
data.tar.gz:
|
|
3
|
+
metadata.gz: 1b692999acb957ed29356cbe5611bc0e1227bf13af613523aea54782aea2983f
|
|
4
|
+
data.tar.gz: 14ac3f99c3155428caa990e40cc50d1a1ed35fafced96d8de88d6d982acb8dc0
|
|
5
5
|
SHA512:
|
|
6
|
-
metadata.gz:
|
|
7
|
-
data.tar.gz:
|
|
6
|
+
metadata.gz: 5391f6c888f343f0d383745e0ac60390ad82b1666426ffbe6b8bac924e959ddb585bbc118a9cfdb713683b7ec1d38c2a7b3fbb53a7de9abf9e6a4b92e67b372d
|
|
7
|
+
data.tar.gz: c50d50cf2e443eb25d68e858b20a023c735b8c155231805d7cddea40fc4039c9be0a1e3704bcfe6adf1368de2a0760905329d1632b37e13636e990c79c4bcf1c
|
data/CHANGELOG
CHANGED
|
@@ -1,9 +1,13 @@
|
|
|
1
|
-
|
|
1
|
+
19-06-2023
|
|
2
2
|
|
|
3
|
+
- Version 4.3.3
|
|
4
|
+
|
|
5
|
+
- FIX: Use lowercase header names in `MessageBus::Rack::Middleware` for compatibility with Rack 3.x.
|
|
6
|
+
- FIX: Don't error when trying to write a message to a closed client
|
|
3
7
|
|
|
4
8
|
13-01-2023
|
|
5
9
|
|
|
6
|
-
- Version 4.2
|
|
10
|
+
- Version 4.3.2
|
|
7
11
|
|
|
8
12
|
- FIX: Do not disable chunking on cancel/error
|
|
9
13
|
|
|
@@ -34,7 +38,7 @@ FUTURE
|
|
|
34
38
|
|
|
35
39
|
- PERF: Optimize Client#backlog for up-to-date clients
|
|
36
40
|
|
|
37
|
-
Also introduces a new MessageBus#last_ids(
|
|
41
|
+
Also introduces a new MessageBus#last_ids(\*channels) api for fetching the last_ids of
|
|
38
42
|
multiple channels simultaneously
|
|
39
43
|
|
|
40
44
|
11-01-2022
|
data/README.md
CHANGED
|
@@ -416,7 +416,7 @@ message_bus also supports PostgreSQL as a backend, and can be configured like so
|
|
|
416
416
|
MessageBus.configure(backend: :postgres, backend_options: {user: 'message_bus', dbname: 'message_bus'})
|
|
417
417
|
```
|
|
418
418
|
|
|
419
|
-
The PostgreSQL client message_bus uses is [ruby-pg](https://
|
|
419
|
+
The PostgreSQL client message_bus uses is [ruby-pg](https://github.com/ged/ruby-pg), so you can visit it's repo to see what options you can include in `:backend_options`.
|
|
420
420
|
|
|
421
421
|
A `:clear_every` option is also supported, which limits backlog trimming frequency to the specified number of publications. If you set `clear_every: 100`, the backlog will only be cleared every 100 publications. This can improve performance in cases where exact backlog length limiting is not required.
|
|
422
422
|
|
|
@@ -526,16 +526,11 @@ Rails.application.config do |config|
|
|
|
526
526
|
end
|
|
527
527
|
```
|
|
528
528
|
|
|
529
|
-
Specifically, if you use a Rack middleware-based authentication solution (such as Warden) in a Rails application and wish to use it for authenticating message_bus requests, you must ensure that the MessageBus middleware comes after it in the stack.
|
|
529
|
+
Specifically, if you use a Rack middleware-based authentication solution (such as Warden) in a Rails application and wish to use it for authenticating message_bus requests, you must ensure that the MessageBus middleware comes after it in the stack.
|
|
530
530
|
|
|
531
531
|
```ruby
|
|
532
532
|
# config/initializers/message_bus.rb
|
|
533
|
-
Rails.application.config
|
|
534
|
-
# See https://github.com/rails/rails/issues/26303#issuecomment-442894832
|
|
535
|
-
MyAppMessageBusMiddleware = Class.new(MessageBus::Rack::Middleware)
|
|
536
|
-
config.middleware.delete(MessageBus::Rack::Middleware)
|
|
537
|
-
config.middleware.insert_after(Warden::Manager, MyAppMessageBusMiddleware)
|
|
538
|
-
end
|
|
533
|
+
Rails.application.config.middleware.move_after(Warden::Manager, MessageBus::Rack::Middleware)
|
|
539
534
|
```
|
|
540
535
|
|
|
541
536
|
### A Distributed Cache
|
data/lib/message_bus/client.rb
CHANGED
|
@@ -82,10 +82,10 @@ class MessageBus::Rack::Middleware
|
|
|
82
82
|
return [404, {}, ["not found"]] unless client_id
|
|
83
83
|
|
|
84
84
|
headers = {}
|
|
85
|
-
headers["
|
|
86
|
-
headers["
|
|
87
|
-
headers["
|
|
88
|
-
headers["
|
|
85
|
+
headers["cache-control"] = "must-revalidate, private, max-age=0"
|
|
86
|
+
headers["content-type"] = "application/json; charset=utf-8"
|
|
87
|
+
headers["pragma"] = "no-cache"
|
|
88
|
+
headers["expires"] = "0"
|
|
89
89
|
|
|
90
90
|
if @bus.extra_response_headers_lookup
|
|
91
91
|
@bus.extra_response_headers_lookup.call(env).each do |k, v|
|
data/lib/message_bus/version.rb
CHANGED