Datastar Ruby SDK

Implement the Datastar SSE procotocol in Ruby. It can be used in any Rack handler, and Rails controllers.

Installation

Add this gem to your Gemfile

gem 'datastar'

Or point your Gemfile to the source

gem 'datastar', github: 'starfederation/datastar-ruby'

Usage

Initialize the Datastar dispatcher

In your Rack handler or Rails controller:

# Rails controllers, as well as Sinatra and others, # already have request and response objects.# `view_context` is optional and is used to render Rails templates.# Or view components that need access to helpers, routes, or any other context.datastar=Datastar.new(request:,response:,view_context:)# In a Rack handler, you can instantiate from the Rack envdatastar=Datastar.from_rack_env(env)

Sending updates to the browser

There are two ways to use this gem in HTTP handlers:

• One-off responses, where you want to send a single update down to the browser.
• Streaming responses, where you want to send multiple updates down to the browser.

One-off update:

datastar.patch_elements(%(<h1 id="title">Hello, World!</h1>))

In this mode, the response is closed after the fragment is sent.

Streaming updates

datastar.streamdo |sse|
sse.patch_elements(%(<h1 id="title">Hello, World!</h1>))# Streaming multiple updates100.timesdo |i|
sleep1sse.patch_elements(%(<h1 id="title">Hello, World #{i}!</h1>))endend

In this mode, the response is kept open until stream blocks have finished.

Concurrent streaming blocks

Multiple stream blocks will be launched in threads/fibers, and will run concurrently. Their updates are linearized and sent to the browser as they are produced.

# Stream to the browser from two concurrent threadsdatastar.streamdo |sse|
100.timesdo |i|
sleep1sse.patch_elements(%(<h1 id="slow">#{i}!</h1>))endenddatastar.streamdo |sse|
1000.timesdo |i|
sleep0.1sse.patch_elements(%(<h1 id="fast">#{i}!</h1>))endend

See the examples directory.

Datastar methods

All these methods are available in both the one-off and the streaming modes.

patch_elements

See https://data-star.dev/reference/sse_events#datastar-patch-elements

sse.patch_elements(%(<div id="foo">\n<span>hello</span>\n</div>))# or a Phlex view objectsse.patch_elements(UserComponent.new)# Or pass optionssse.patch_elements(%(<div id="foo">\n<span>hello</span>\n</div>),mode: 'append')

You can patch multiple elements at once by passing an array of elements (or components):

sse.patch_elements([%(<div id="foo">\n<span>hello</span>\n</div>),%(<div id="bar">\n<span>world</span>\n</div>)])

remove_elements

Sugar on top of #patch_elements See https://data-star.dev/reference/sse_events#datastar-patch-elements

sse.remove_elements('#users')

patch_signals

See https://data-star.dev/reference/sse_events#datastar-patch-signals

sse.patch_signals(count: 4,user: {name: 'John'})

remove_signals

Sugar on top of #patch_signals

sse.remove_signals(['user.name','user.email'])

execute_script

Sugar on top of #patch_elements. Appends a temporary <script> tag to the DOM, which will execute the script in the browser.

sse.execute_script(%(alert('Hello World!'))

Pass attributes that will be added to the <script> tag:

sse.execute_script(%(alert('Hello World!')),attributes: {type: 'text/javascript'})

These script tags are automatically removed after execution, so they can be used to run one-off scripts in the browser. Pass auto_remove: false if you want to keep the script tag in the DOM.

sse.execute_script(%(alert('Hello World!')),auto_remove: false)

signals

See https://data-star.dev/guide/reactive_signals

Returns signals sent by the browser.

sse.signals# => { user: { name: 'John' } }

redirect

This is just a helper to send a script to update the browser's location.

sse.redirect('/new_location')

Lifecycle callbacks

on_connect

Register server-side code to run when the connection is first handled.

datastar.on_connectdoputs'A user has connected'end

on_client_disconnect

Register server-side code to run when the connection is closed by the client

datastar.on_client_disconnectdoputs'A user has disconnected connected'end

This callback's behaviour depends on the configured heartbeat

on_server_disconnect

Register server-side code to run when the connection is closed by the server. Ie when the served is done streaming without errors.

datastar.on_server_disconnectdoputs'Server is done streaming'end

on_error

Ruby code to handle any exceptions raised by streaming blocks.

datastar.on_errordo |exception|
Sentry.notify(exception)end

Note that this callback can be configured globally, too.

heartbeat

By default, streaming responses (using the #stream block) launch a background thread/fiber to periodically check the connection.

This is because the browser could have disconnected during a long-lived, idle connection (for example waiting on an event bus).

The default heartbeat is 3 seconds, and it will close the connection and trigger on_client_disconnect callbacks if the client has disconnected.

In cases where a streaming block doesn't need a heartbeat and you want to save precious threads (for example a regular ticker update, ie non-idle), you can disable the heartbeat:

datastar=Datastar.new(request:,response:,view_context:,heartbeat: false)datastar.streamdo |sse|
100.timesdo |i|
sleep1sse.merge_signalscount: iendend

You can also set it to a different number (in seconds)

heartbeat: 0.5

Per-stream override

The #stream method also accepts a heartbeat: keyword that overrides the constructor-level setting for a single call. This is useful when a dispatcher is generally configured with a heartbeat but a particular response doesn't need one (e.g. a one-shot update). The previous value is restored once the call returns.

datastar=Datastar.new(request:,response:)# default heartbeat# Disable heartbeat for this single responsedatastar.stream(heartbeat: false)do |sse|
sse.patch_elements(html)end

The one-shot helpers (#patch_elements, #remove_elements, #patch_signals, #remove_signals, #execute_script, #redirect) use this internally to avoid spawning a heartbeat thread for a single message.

Manual connection check

If you want to check connection status on your own, you can disable the heartbeat and use sse.check_connection!, which will close the connection and trigger callbacks if the client is disconnected.

datastar=Datastar.new(request:,response:,view_context:,heartbeat: false)datastar.streamdo |sse|
# The event bus implementaton will check connection status when idle# by calling #check_connection! on itEventBus.subscribe('channel',sse)do |event|
sse.merge_signalseventName: event.nameendend

Global configuration

Datastar.configuredo |config|
# Global on_error callback# Can be overriden on specific instancesconfig.on_errordo |exception|
Sentry.notify(exception)end# Global heartbeat interval (or false, to disable)# Can be overriden on specific instancesconfig.heartbeat=0.3# Enable compression for SSE streams (default: false)# See the Compression section below for detailsconfig.compression=trueend

Compression

SSE data (JSON + HTML) is highly compressible, and long-lived connections benefit significantly from compression. This SDK supports opt-in Brotli and gzip compression for SSE streams.

Enabling compression

Per-instance:

datastar=Datastar.new(request:,response:,view_context:,compression: true)

Or globally:

Datastar.configuredo |config|
config.compression=trueend

When enabled, the SDK negotiates compression with the client via the Accept-Encoding header and sets the appropriate Content-Encoding response header. If the client does not support compression, responses are sent uncompressed.

Brotli vs gzip

Brotli (:br) is preferred by default as it offers better compression ratios. It requires the host app to require the brotli gem. Gzip uses Ruby built-in zlib and requires no extra dependencies.

To use Brotli, add the gem to your Gemfile:

gem'brotli'

Configuration options

Datastar.configuredo |config|
# Enable compression (default: false)# true enables both :br and :gzip (br preferred)config.compression=true# Or pass an array of encodings (first = preferred)config.compression=[:br,:gzip]# Per-encoder options via [symbol, options] pairsconfig.compression=[[:br,{quality: 5}],:gzip]end

You can also set these per-instance:

datastar=Datastar.new(request:,response:,view_context:,compression: [:gzip]# only gzip, no brotli)# Or with per-encoder optionsdatastar=Datastar.new(request:,response:,view_context:,compression: [[:gzip,{level: 1}]])

Per-encoder options

Options are passed directly to the underlying compressor via the array form. Available options depend on the encoder.

Gzip (via Zlib::Deflate):

Option	Default	Description
:level	Zlib::DEFAULT_COMPRESSION	Compression level (0-9). 0 = none, 1 = fastest, 9 = smallest. Zlib::BEST_SPEED and Zlib::BEST_COMPRESSION also work.
:mem_level	8	Memory usage (1-9). Higher uses more memory for better compression.
:strategy	Zlib::DEFAULT_STRATEGY	Algorithm strategy. Alternatives: Zlib::FILTERED, Zlib::HUFFMAN_ONLY, Zlib::RLE, Zlib::FIXED.

Brotli (via Brotli::Compressor, requires the brotli gem):

Option	Default	Description
:quality	11	Compression quality (0-11). Lower is faster, higher compresses better.
:lgwin	22	Base-2 log of sliding window size (10-24).
:lgblock	0 (auto)	Base-2 log of max input block size (16-24, or 0 for auto).
:mode	:generic	Compression mode: :generic, :text, or :font. :text is a good choice for SSE (UTF-8 HTML/JSON).

Proxy considerations

Even with X-Accel-Buffering: no (set by default), some proxies like Nginx may buffer compressed responses. You may need to add proxy_buffering off to your Nginx configuration when using compression with SSE.

Rendering Rails templates

In Rails, make sure to initialize Datastar with the view_context in a controller. This is so that rendered templates, components or views have access to helpers, routes, etc.

datastar=Datastar.new(request:,response:,view_context:)datastar.streamdo |sse|
10.timesdo |i|
sleep1tpl=render_to_string('events/user',layout: false,locals: {name: "David #{i}"})sse.patch_elementstplendend

Rendering Phlex components

#patch_elements supports Phlex component instances.

sse.patch_elements(UserComponent.new(user: User.first))

Rendering ViewComponent instances

#patch_elements also works with ViewComponent instances.

sse.patch_elements(UserViewComponent.new(user: User.first))

Rendering #render_in(view_context) interfaces

Any object that supports the #render_in(view_context) => String API can be used as a fragment.

classMyComponentdefinitialize(name)@name=nameenddefrender_in(view_context)"<div>Hello #{@name}</div>""
endend

sse.patch_elementsMyComponent.new('Joe')

Tests

bundleexecrspec

Running Datastar's SDK test suite

Install dependencies.

bundle install

From this library's root, run the bundled-in test Rack app:

bundle puma -p 8000 examples/test.ru

From the main Datastar repo (you'll need Go installed)

cd sdk/tests
go run ./cmd/datastar-sdk-tests -server http://localhost:8000 

Development

After checking out the repo, run bin/setup to install dependencies. Then, run rake spec to run the tests. You can also run bin/console for an interactive prompt that will allow you to experiment.

To install this gem onto your local machine, run bundle exec rake install. To release a new version, update the version number in version.rb, and then run bundle exec rake release, which will create a git tag for the version, push git commits and the created tag, and push the .gem file to rubygems.org.

Contributing

Bug reports and pull requests are welcome on GitHub at https://github.com/starfederation/datastar.