From 53c3b68e2b0fd96ac45bec1b88f0ad6182c8d7cd Mon Sep 17 00:00:00 2001 From: Nick Pezza Date: Wed, 19 Aug 2026 20:05:27 -0400 Subject: [PATCH] Update bench app and loadtest script --- bench/.kamal/secrets | 4 + bench/.ruby-version | 2 +- bench/Dockerfile | 89 ++-- bench/Gemfile | 2 +- bench/Gemfile.lock | 352 +++++++------- .../stylesheets/application.tailwind.css | 13 - bench/app/channels/fanout_channel.rb | 13 + bench/app/views/layouts/application.html.erb | 2 - bench/bin/setup | 14 +- bench/bin/thrust | 16 + bench/config/cable.yml | 11 +- bench/config/credentials.yml.enc | 2 +- bench/config/database.yml | 32 +- bench/config/deploy.yml | 38 +- bench/config/environments/development.rb | 30 +- bench/config/environments/production.rb | 83 ++-- bench/config/environments/test.rb | 20 +- .../initializers/content_security_policy.rb | 4 + .../initializers/filter_parameter_logging.rb | 2 +- bench/config/puma.rb | 38 +- bench/config/tailwind.config.js | 22 - bench/loadtest.js | 449 ++++++++++++++++-- bench/public/400.html | 135 ++++++ bench/public/404.html | 200 +++++--- bench/public/406-unsupported-browser.html | 199 +++++--- bench/public/422.html | 200 +++++--- bench/public/500.html | 199 +++++--- bench/public/icon.png | Bin 5599 -> 4166 bytes bench/public/icon.svg | 4 +- 29 files changed, 1493 insertions(+), 682 deletions(-) create mode 100644 bench/.kamal/secrets delete mode 100644 bench/app/assets/stylesheets/application.tailwind.css create mode 100644 bench/app/channels/fanout_channel.rb create mode 100755 bench/bin/thrust delete mode 100644 bench/config/tailwind.config.js create mode 100644 bench/public/400.html diff --git a/bench/.kamal/secrets b/bench/.kamal/secrets new file mode 100644 index 0000000..a3510e4 --- /dev/null +++ b/bench/.kamal/secrets @@ -0,0 +1,4 @@ +MYSQL_ROOT_PASSWORD=secret +POSTGRES_PASSWORD=secret +RAILS_MASTER_KEY=$(cat config/master.key) +HOST=$HOST diff --git a/bench/.ruby-version b/bench/.ruby-version index fa7adc7..d13e837 100644 --- a/bench/.ruby-version +++ b/bench/.ruby-version @@ -1 +1 @@ -3.3.5 +4.0.6 diff --git a/bench/Dockerfile b/bench/Dockerfile index dcbd72f..ffa12c8 100644 --- a/bench/Dockerfile +++ b/bench/Dockerfile @@ -1,68 +1,65 @@ -# syntax = docker/dockerfile:1 +# syntax=docker/dockerfile:1 -# This Dockerfile is designed for production, not development. Use with Kamal or build'n'run by hand: -# docker build -t my-app . -# docker run -d -p 80:80 -p 443:443 --name my-app -e RAILS_MASTER_KEY= my-app +ARG RUBY_VERSION +FROM rubylang/ruby:$RUBY_VERSION-noble AS base -# For a containerized dev environment, see Dev Containers: https://guides.rubyonrails.org/getting_started_with_devcontainer.html - -# Make sure RUBY_VERSION matches the Ruby version in .ruby-version -ARG RUBY_VERSION=3.3.5 -FROM docker.io/library/ruby:$RUBY_VERSION-slim AS base - -# Rails app lives here WORKDIR /rails -# Install base packages -RUN apt-get update -qq && \ - apt-get install --no-install-recommends -y curl libjemalloc2 postgresql-client && \ - apt-get clean && rm -rf /var/lib/apt/lists/* /tmp/* /var/tmp/* +RUN --mount=type=cache,target=/var/cache/apt,sharing=locked \ + --mount=type=cache,target=/var/lib/apt,sharing=locked \ + < 2.0) websocket-driver (>= 0.6.1) zeitwerk (~> 2.6) - actionmailbox (8.0.0.alpha) - actionpack (= 8.0.0.alpha) - activejob (= 8.0.0.alpha) - activerecord (= 8.0.0.alpha) - activestorage (= 8.0.0.alpha) - activesupport (= 8.0.0.alpha) + actionmailbox (8.2.0.alpha) + actionpack (= 8.2.0.alpha) + activejob (= 8.2.0.alpha) + activerecord (= 8.2.0.alpha) + activestorage (= 8.2.0.alpha) + activesupport (= 8.2.0.alpha) mail (>= 2.8.0) - actionmailer (8.0.0.alpha) - actionpack (= 8.0.0.alpha) - actionview (= 8.0.0.alpha) - activejob (= 8.0.0.alpha) - activesupport (= 8.0.0.alpha) + actionmailer (8.2.0.alpha) + actionpack (= 8.2.0.alpha) + actionview (= 8.2.0.alpha) + activejob (= 8.2.0.alpha) + activesupport (= 8.2.0.alpha) mail (>= 2.8.0) rails-dom-testing (~> 2.2) - actionpack (8.0.0.alpha) - actionview (= 8.0.0.alpha) - activesupport (= 8.0.0.alpha) + actionpack (8.2.0.alpha) + actionview (= 8.2.0.alpha) + activesupport (= 8.2.0.alpha) nokogiri (>= 1.8.5) rack (>= 2.2.4) rack-session (>= 1.0.1) rack-test (>= 0.6.3) rails-dom-testing (~> 2.2) - rails-html-sanitizer (~> 1.6) + rails-html-sanitizer (~> 1.7) useragent (~> 0.16) - actiontext (8.0.0.alpha) - actionpack (= 8.0.0.alpha) - activerecord (= 8.0.0.alpha) - activestorage (= 8.0.0.alpha) - activesupport (= 8.0.0.alpha) + actiontext (8.2.0.alpha) + action_text-trix (~> 2.1.16) + actionpack (= 8.2.0.alpha) + activerecord (= 8.2.0.alpha) + activestorage (= 8.2.0.alpha) + activesupport (= 8.2.0.alpha) globalid (>= 0.6.0) nokogiri (>= 1.8.5) - actionview (8.0.0.alpha) - activesupport (= 8.0.0.alpha) + actionview (8.2.0.alpha) + activesupport (= 8.2.0.alpha) builder (~> 3.1) erubi (~> 1.11) rails-dom-testing (~> 2.2) - rails-html-sanitizer (~> 1.6) - activejob (8.0.0.alpha) - activesupport (= 8.0.0.alpha) - globalid (>= 0.3.6) - activemodel (8.0.0.alpha) - activesupport (= 8.0.0.alpha) - activerecord (8.0.0.alpha) - activemodel (= 8.0.0.alpha) - activesupport (= 8.0.0.alpha) + rails-html-sanitizer (~> 1.7) + activejob (8.2.0.alpha) + activesupport (= 8.2.0.alpha) + globalid (>= 1.4.0) + activemodel (8.2.0.alpha) + activesupport (= 8.2.0.alpha) + activerecord (8.2.0.alpha) + activemodel (= 8.2.0.alpha) + activesupport (= 8.2.0.alpha) timeout (>= 0.4.0) - activestorage (8.0.0.alpha) - actionpack (= 8.0.0.alpha) - activejob (= 8.0.0.alpha) - activerecord (= 8.0.0.alpha) - activesupport (= 8.0.0.alpha) + activestorage (8.2.0.alpha) + actionpack (= 8.2.0.alpha) + activejob (= 8.2.0.alpha) + activerecord (= 8.2.0.alpha) + activesupport (= 8.2.0.alpha) marcel (~> 1.0) - activesupport (8.0.0.alpha) + activesupport (8.2.0.alpha) base64 - benchmark (>= 0.3) bigdecimal concurrent-ruby (~> 1.0, >= 1.3.1) connection_pool (>= 2.2.5) drb i18n (>= 1.6, < 2) + json logger (>= 1.4.2) minitest (>= 5.1) + psych (>= 4) + ractor-dispatch (>= 0.2.0) securerandom (>= 0.3) tzinfo (~> 2.0, >= 2.0.5) uri (>= 0.13.1) - rails (8.0.0.alpha) - actioncable (= 8.0.0.alpha) - actionmailbox (= 8.0.0.alpha) - actionmailer (= 8.0.0.alpha) - actionpack (= 8.0.0.alpha) - actiontext (= 8.0.0.alpha) - actionview (= 8.0.0.alpha) - activejob (= 8.0.0.alpha) - activemodel (= 8.0.0.alpha) - activerecord (= 8.0.0.alpha) - activestorage (= 8.0.0.alpha) - activesupport (= 8.0.0.alpha) + rails (8.2.0.alpha) + actioncable (= 8.2.0.alpha) + actionmailbox (= 8.2.0.alpha) + actionmailer (= 8.2.0.alpha) + actionpack (= 8.2.0.alpha) + actiontext (= 8.2.0.alpha) + actionview (= 8.2.0.alpha) + activejob (= 8.2.0.alpha) + activemodel (= 8.2.0.alpha) + activerecord (= 8.2.0.alpha) + activestorage (= 8.2.0.alpha) + activesupport (= 8.2.0.alpha) bundler (>= 1.15.0) - railties (= 8.0.0.alpha) - railties (8.0.0.alpha) - actionpack (= 8.0.0.alpha) - activesupport (= 8.0.0.alpha) + railties (= 8.2.0.alpha) + railties (8.2.0.alpha) + actionpack (= 8.2.0.alpha) + activesupport (= 8.2.0.alpha) irb (~> 1.13) rackup (>= 1.0.0) rake (>= 12.2) thor (~> 1.0, >= 1.2.2) + tsort (>= 0.2) zeitwerk (~> 2.6) GIT remote: https://github.com/rails/solid_cable.git - revision: 2971cf3983ee0ed9359f69889f9a93f473fec387 + revision: bf8d45b9a6002f78f10e4035de6226a756eb8e61 branch: main specs: - solid_cable (2.0.2) + solid_cable (4.0.2) actioncable (>= 7.2) activejob (>= 7.2) activerecord (>= 7.2) @@ -111,167 +115,195 @@ GIT GEM remote: https://rubygems.org/ specs: - activeerror (1.1.2) + action_text-trix (2.1.19) + railties + activeerror (2.2.1) rails (>= 7.2) useragent - base64 (0.2.0) - bcrypt_pbkdf (1.1.1) - bcrypt_pbkdf (1.1.1-arm64-darwin) - bcrypt_pbkdf (1.1.1-x86_64-darwin) - benchmark (0.3.0) - bigdecimal (3.1.8) - bootsnap (1.18.4) + base64 (0.3.0) + bcrypt_pbkdf (1.1.2) + bigdecimal (4.1.2) + bootsnap (1.24.6) msgpack (~> 1.2) builder (3.3.0) - concurrent-ruby (1.3.4) - connection_pool (2.4.1) - crass (1.0.6) - date (3.3.4) - dotenv (2.8.1) - drb (2.2.1) - ed25519 (1.3.0) - erubi (1.13.0) - globalid (1.2.1) + concurrent-ruby (1.3.8) + connection_pool (3.0.2) + crass (1.0.7) + date (3.5.1) + dotenv (3.2.0) + drb (2.2.3) + ed25519 (1.4.0) + erb (6.0.7) + erubi (1.13.1) + globalid (1.4.0) activesupport (>= 6.1) - i18n (1.14.5) + i18n (1.15.2) concurrent-ruby (~> 1.0) - importmap-rails (2.0.1) + importmap-rails (2.2.3) actionpack (>= 6.0.0) activesupport (>= 6.0.0) railties (>= 6.0.0) - io-console (0.7.2) - irb (1.14.0) + io-console (0.9.2) + irb (1.18.0) + pp (>= 0.6.0) + prism (>= 1.3.0) rdoc (>= 4.0.0) reline (>= 0.4.2) - kamal (1.8.3) + json (2.21.2) + kamal (2.12.0) activesupport (>= 7.0) base64 (~> 0.2) bcrypt_pbkdf (~> 1.0) concurrent-ruby (~> 1.2) - dotenv (~> 2.8) - ed25519 (~> 1.2) - net-ssh (~> 7.0) + dotenv (~> 3.1) + ed25519 (~> 1.4) + net-ssh (~> 7.3) sshkit (>= 1.23.0, < 2.0) - thor (~> 1.2) - zeitwerk (~> 2.5) - logger (1.6.1) - loofah (2.22.0) + thor (~> 1.3) + zeitwerk (>= 2.6.18, < 3.0) + logger (1.7.0) + loofah (2.25.2) crass (~> 1.0.2) nokogiri (>= 1.12.0) - mail (2.8.1) + mail (2.9.1) + logger mini_mime (>= 0.1.1) net-imap net-pop net-smtp - marcel (1.0.4) + marcel (1.2.1) mini_mime (1.1.5) - minitest (5.25.1) - msgpack (1.7.2) - net-imap (0.4.16) + mini_portile2 (2.8.9) + minitest (6.0.6) + drb (~> 2.0) + prism (~> 1.5) + msgpack (1.8.3) + net-imap (0.6.6) date net-protocol net-pop (0.1.2) net-protocol net-protocol (0.2.2) timeout - net-scp (4.0.0) + net-scp (4.1.0) net-ssh (>= 2.6.5, < 8.0.0) net-sftp (4.0.0) net-ssh (>= 5.0.0, < 8.0.0) - net-smtp (0.5.0) + net-smtp (0.5.1) net-protocol - net-ssh (7.2.3) - nio4r (2.7.3) - nokogiri (1.16.7-aarch64-linux) + net-ssh (7.3.3) + nio4r (2.7.5) + nokogiri (1.19.4) + mini_portile2 (~> 2.8.2) racc (~> 1.4) - nokogiri (1.16.7-arm-linux) + nokogiri (1.19.4-aarch64-linux-gnu) racc (~> 1.4) - nokogiri (1.16.7-arm64-darwin) + nokogiri (1.19.4-aarch64-linux-musl) racc (~> 1.4) - nokogiri (1.16.7-x86-linux) + nokogiri (1.19.4-arm-linux-gnu) racc (~> 1.4) - nokogiri (1.16.7-x86_64-darwin) + nokogiri (1.19.4-arm-linux-musl) racc (~> 1.4) - nokogiri (1.16.7-x86_64-linux) + nokogiri (1.19.4-arm64-darwin) racc (~> 1.4) - ostruct (0.6.0) - pg (1.5.8) - propshaft (1.0.0) + nokogiri (1.19.4-x86_64-darwin) + racc (~> 1.4) + nokogiri (1.19.4-x86_64-linux-gnu) + racc (~> 1.4) + nokogiri (1.19.4-x86_64-linux-musl) + racc (~> 1.4) + ostruct (0.6.3) + pg (1.6.3) + pg (1.6.3-aarch64-linux) + pg (1.6.3-aarch64-linux-musl) + pg (1.6.3-arm64-darwin) + pg (1.6.3-x86_64-darwin) + pg (1.6.3-x86_64-linux) + pg (1.6.3-x86_64-linux-musl) + pp (0.6.4) + prettyprint + prettyprint (0.2.0) + prism (1.9.0) + propshaft (1.3.2) actionpack (>= 7.0.0) activesupport (>= 7.0.0) rack - railties (>= 7.0.0) - psych (5.1.2) + psych (5.4.0) + date stringio - puma (6.4.2) + puma (8.0.2) nio4r (~> 2.0) racc (1.8.1) - rack (3.1.7) - rack-session (2.0.0) + rack (3.2.7) + rack-session (2.1.2) + base64 (>= 0.1.0) rack (>= 3.0.0) - rack-test (2.1.0) + rack-test (2.2.0) rack (>= 1.3) - rackup (2.1.0) + rackup (2.3.1) rack (>= 3) - webrick (~> 1.8) - rails-dom-testing (2.2.0) + ractor-dispatch (0.2.0) + rails-dom-testing (2.3.0) activesupport (>= 5.0.0) minitest nokogiri (>= 1.6) - rails-html-sanitizer (1.6.0) - loofah (~> 2.21) - nokogiri (~> 1.14) - rake (13.2.1) - rdoc (6.7.0) - psych (>= 4.0.0) - redis (5.3.0) + rails-html-sanitizer (1.7.1) + loofah (~> 2.25, >= 2.25.2) + nokogiri (>= 1.15.7, != 1.16.7, != 1.16.6, != 1.16.5, != 1.16.4, != 1.16.3, != 1.16.2, != 1.16.1, != 1.16.0.rc1, != 1.16.0) + rake (13.4.2) + rbs (4.1.3) + logger + prism (>= 1.6.0) + tsort + rdoc (8.0.0) + erb + prism (>= 1.6.0) + rbs (>= 4.0.0) + tsort + redis (5.4.1) redis-client (>= 0.22.0) - redis-client (0.22.2) + redis-client (0.30.1) connection_pool - reline (0.5.10) + reline (0.7.0) io-console (~> 0.5) - securerandom (0.3.1) - sqlite3 (2.0.4-aarch64-linux-gnu) - sqlite3 (2.0.4-aarch64-linux-musl) - sqlite3 (2.0.4-arm-linux-gnu) - sqlite3 (2.0.4-arm-linux-musl) - sqlite3 (2.0.4-arm64-darwin) - sqlite3 (2.0.4-x86-linux-gnu) - sqlite3 (2.0.4-x86-linux-musl) - sqlite3 (2.0.4-x86_64-darwin) - sqlite3 (2.0.4-x86_64-linux-gnu) - sqlite3 (2.0.4-x86_64-linux-musl) - sshkit (1.23.1) + securerandom (0.4.1) + sqlite3 (2.9.5-aarch64-linux-gnu) + sqlite3 (2.9.5-aarch64-linux-musl) + sqlite3 (2.9.5-arm-linux-gnu) + sqlite3 (2.9.5-arm-linux-musl) + sqlite3 (2.9.5-arm64-darwin) + sqlite3 (2.9.5-x86-linux-gnu) + sqlite3 (2.9.5-x86-linux-musl) + sqlite3 (2.9.5-x86_64-darwin) + sqlite3 (2.9.5-x86_64-linux-gnu) + sqlite3 (2.9.5-x86_64-linux-musl) + sshkit (1.25.1) base64 + logger net-scp (>= 1.1.2) net-sftp (>= 2.1.2) net-ssh (>= 2.8.0) ostruct - stringio (3.1.1) - tailwindcss-rails (2.7.3) - railties (>= 7.0.0) - tailwindcss-rails (2.7.3-aarch64-linux) - railties (>= 7.0.0) - tailwindcss-rails (2.7.3-arm-linux) - railties (>= 7.0.0) - tailwindcss-rails (2.7.3-arm64-darwin) - railties (>= 7.0.0) - tailwindcss-rails (2.7.3-x86_64-darwin) - railties (>= 7.0.0) - tailwindcss-rails (2.7.3-x86_64-linux) - railties (>= 7.0.0) - thor (1.3.2) - timeout (0.4.1) - trilogy (2.8.1) + stringio (3.2.0) + thor (1.5.0) + thruster (0.1.23) + thruster (0.1.23-aarch64-linux) + thruster (0.1.23-arm64-darwin) + thruster (0.1.23-x86_64-darwin) + thruster (0.1.23-x86_64-linux) + timeout (0.6.1) + trilogy (2.12.6) + bigdecimal + tsort (0.2.0) tzinfo (2.0.6) concurrent-ruby (~> 1.0) - uri (0.13.1) - useragent (0.16.10) - webrick (1.8.1) - websocket-driver (0.7.6) + uri (1.1.1) + useragent (0.16.11) + websocket-driver (0.8.2) + base64 websocket-extensions (>= 0.1.0) websocket-extensions (0.1.5) - zeitwerk (2.6.18) + zeitwerk (2.8.3) PLATFORMS aarch64-linux @@ -301,8 +333,8 @@ DEPENDENCIES redis solid_cable! sqlite3 - tailwindcss-rails + thruster trilogy BUNDLED WITH - 2.5.18 + 4.0.16 diff --git a/bench/app/assets/stylesheets/application.tailwind.css b/bench/app/assets/stylesheets/application.tailwind.css deleted file mode 100644 index 8666d2f..0000000 --- a/bench/app/assets/stylesheets/application.tailwind.css +++ /dev/null @@ -1,13 +0,0 @@ -@tailwind base; -@tailwind components; -@tailwind utilities; - -/* - -@layer components { - .btn-primary { - @apply py-2 px-4 bg-blue-200; - } -} - -*/ diff --git a/bench/app/channels/fanout_channel.rb b/bench/app/channels/fanout_channel.rb new file mode 100644 index 0000000..8569963 --- /dev/null +++ b/bench/app/channels/fanout_channel.rb @@ -0,0 +1,13 @@ +class FanoutChannel < ApplicationCable::Channel + def subscribed + @stream_name = "fanout:#{params.fetch("stream")}" + stream_from @stream_name + end + + def publish(data) + ActionCable.server.broadcast( + @stream_name, + data.slice("sequence", "sent_at", "message", "complete", "expected_messages") + ) + end +end diff --git a/bench/app/views/layouts/application.html.erb b/bench/app/views/layouts/application.html.erb index 0c90f6c..aa97684 100644 --- a/bench/app/views/layouts/application.html.erb +++ b/bench/app/views/layouts/application.html.erb @@ -12,8 +12,6 @@ - <%= stylesheet_link_tag "tailwind", "inter-font", "data-turbo-track": "reload" %> - <%= stylesheet_link_tag :all, "data-turbo-track": "reload" %> <%= javascript_importmap_tags %> diff --git a/bench/bin/setup b/bench/bin/setup index 0c5ddfe..81be011 100755 --- a/bench/bin/setup +++ b/bench/bin/setup @@ -2,7 +2,6 @@ require "fileutils" APP_ROOT = File.expand_path("..", __dir__) -APP_NAME = "cablebench" def system!(*args) system(*args, exception: true) @@ -14,7 +13,6 @@ FileUtils.chdir APP_ROOT do # Add necessary setup steps to this file. puts "== Installing dependencies ==" - system! "gem install bundler --conservative" system("bundle check") || system!("bundle install") # puts "\n== Copying sample files ==" @@ -24,14 +22,14 @@ FileUtils.chdir APP_ROOT do puts "\n== Preparing database ==" system! "bin/rails db:prepare" + system! "bin/rails db:reset" if ARGV.include?("--reset") puts "\n== Removing old logs and tempfiles ==" system! "bin/rails log:clear tmp:clear" - puts "\n== Restarting application server ==" - system! "bin/rails restart" - - # puts "\n== Configuring puma-dev ==" - # system "ln -nfs #{APP_ROOT} ~/.puma-dev/#{APP_NAME}" - # system "curl -Is https://#{APP_NAME}.test/up | head -n 1" + unless ARGV.include?("--skip-server") + puts "\n== Starting development server ==" + STDOUT.flush # flush the output before exec(2) so that it displays + exec "bin/dev" + end end diff --git a/bench/bin/thrust b/bench/bin/thrust new file mode 100755 index 0000000..b1c45d1 --- /dev/null +++ b/bench/bin/thrust @@ -0,0 +1,16 @@ +#!/usr/bin/env ruby +# frozen_string_literal: true + +# +# This file was generated by Bundler. +# +# The application 'thrust' is installed as part of a gem, and +# this file is here to facilitate running it. +# + +ENV["BUNDLE_GEMFILE"] ||= File.expand_path("../Gemfile", __dir__) + +require "rubygems" +require "bundler/setup" + +load Gem.bin_path("thruster", "thrust") diff --git a/bench/config/cable.yml b/bench/config/cable.yml index 23ed495..2d2260e 100644 --- a/bench/config/cable.yml +++ b/bench/config/cable.yml @@ -10,15 +10,20 @@ test: production: # adapter: redis - # url: <%= ENV.fetch("REDIS_URL") { "redis://#{ENV["HOST"]}:6379/1" } %> + # url: <%= ENV.fetch("REDIS_URL") { "redis://solidcable-redis:6379/1" } %> # channel_prefix: cablebench_production # adapter: postgresql # database: cablebench # user: cablebench # password: <%= ENV["POSTGRES_PASSWORD"] %> - # host: <%= ENV["HOST"] %> + # host: solidcable-postgres adapter: solid_cable - message_retention: 1.day polling_interval: 0.1.seconds + message_retention: 30.seconds + autotrim: true + trim_batch_size: 100 + silence_polling: false + writer_batch_size: 4 + writer_batch_delay: 0.001.seconds diff --git a/bench/config/credentials.yml.enc b/bench/config/credentials.yml.enc index 724a4fa..9f608e8 100644 --- a/bench/config/credentials.yml.enc +++ b/bench/config/credentials.yml.enc @@ -1 +1 @@ -7lxKveoOh/YSo6BSUdrNHtg29iVtfI9AinJgpSiiQkSWpoVPHluT1PNVQpleQhs3LqM0WP4aMBX12xzUP843RI2LYQmtUmbjkJtfkMs/dCijfslkwfrwSI8ApQINOTwVG3fbYdFKe5N8C2Qhqbch+vMDktSL/eTXw7x1dSaUUjRF1zfEzi+xtn8D4nbDSv3m5tbUAzG2D3NU2bYIBaMtSNlnu0orY6RFPi8HRnGArsoMd41cBxUUJP6a23jatCGTl7BRrwRncBpoMKPbimiqE2YpE1XD+A25qcjA/1kxneSVvRl+0S0lUqVbUO9L84tsj9prt8YWKTeDWP9MWu9wGvyVoUb9eDMf15k3soBrKvG2++oZ6t/2S7pIg9gGEMBcRZwq9nHRnaS5SEhUFBmb4yr40/qWdpKGFKGAA/9al3sD3ChAlYXc5zQ81V4+o3hCxapvWbUr--2KQ9UYDapBokyl5i--Me6kHSK8rQVQyCeZM2w1lw== \ No newline at end of file +7YfkrfTcrF2K84BSQdkYac9Da/D0hG2TSUUMaNrdmxGRpz4HJcAQ394uNn1A97Vf1/Q7AjLkw0qmn9MZ5h/tNMTUXwec388N76TCKz54dlsLL6J9iHZf84NmV6YyF3GxHweAjqCFtnzsxmsdxO/U+5ULmrAjjZEZuRqcBepwhsPHjauSBhr28IAhbTsa40dnKAzMn1K2PsLHTVdkl6XytFzgeriPq3QtJiGw+Sale2IJk5gwp/SHsO08+t8eZF3pe3t40nh8zlVLoIRVl8xg3x+6OtZQDhUMcmDv3WhAAzgSAghN+2eWGQ6T4eMy4qKZ1IHVNfxn6EIBTJYbmehuqT/yQeBtUzf14DIxGeC5dmv1lSvnMCMYGJHVunzXnaCxYjRTN7yS9AdD0r2AysuxSRORs9TphUTz57+56vFocURpWuYKcBDVadbjmf6RDixYmpSqu+7Q+YQ4czqbgDealgT18/qPh6tO4nnA8/R3mDpcQdTsAGY7qdQZ--GAZWJSlLWkVaLISi--eEtSh4HKSLNpwMmHUHsdEA== \ No newline at end of file diff --git a/bench/config/database.yml b/bench/config/database.yml index c7793c7..374fb36 100644 --- a/bench/config/database.yml +++ b/bench/config/database.yml @@ -18,25 +18,29 @@ test: # Store production database in the storage/ directory, which by default # is mounted as a persistent Docker volume in config/deploy.yml. production: - # <<: *default - # adapter: sqlite3 - # pool: <%= ENV.fetch("RAILS_MAX_THREADS") { 5 } %> - # timeout: 5000 - # database: /data/production.sqlite3 + database: /data/production.sqlite3 + adapter: sqlite3 + min_connections: 1 + timeout: 5000 + pragmas: + auto_vacuum: incremental # adapter: trilogy - # pool: <%= ENV.fetch("RAILS_MAX_THREADS") { 50 } %> + # pool: <%= ENV.fetch("RAILS_MAX_THREADS") { 5 } %> # timeout: 5000 # database: solid_cable # user: root # password: <%= ENV["MYSQL_ROOT_PASSWORD"] %> - # host: <%= ENV["HOST"] %> + # host: solidcable-mysql + # port: 3306 # ssl: true - adapter: postgresql - pool: <%= ENV.fetch("RAILS_MAX_THREADS") { 50 } %> - timeout: 5000 - database: cablebench - user: cablebench - password: <%= ENV["POSTGRES_PASSWORD"] %> - host: <%= ENV["HOST"] %> + # adapter: postgresql + # pool: <%= ENV.fetch("RAILS_MAX_THREADS") { 5 } %> + # timeout: 5000 + # database: cablebench + # user: cablebench + # password: <%= ENV["POSTGRES_PASSWORD"] %> + # host: solidcable-postgres + # port: 5432 + # sslmode: disable diff --git a/bench/config/deploy.yml b/bench/config/deploy.yml index bc58afc..dbdaca7 100644 --- a/bench/config/deploy.yml +++ b/bench/config/deploy.yml @@ -1,31 +1,48 @@ service: solidcable -image: npezza/solid_cable asset_path: /rails/public/assets +retain_containers: 1 + servers: web: - <%= ENV["HOST"] %> + +proxy: + ssl: false + host: solid-cable.dev + forward_headers: true + registry: - username: npezza - password: - - KAMAL_REGISTRY_PASSWORD + server: localhost:5555 env: + clear: + HISTFILE: /hist/.bash_history + IRB_HISTFILE: /hist/.irb_history + WEB_CONCURRENCY: auto secret: - RAILS_MASTER_KEY - MYSQL_ROOT_PASSWORD - HOST - POSTGRES_PASSWORD +aliases: + console: app exec --interactive --reuse "bin/rails console" + bash: app exec -i --reuse "bash" + rails: app exec -p "bin/rails" + logs: app logs -f --roles=web + volumes: - "solidcable:/data" + - "hist:/hist" + builder: - context: "." - local: - arch: amd64 + arch: amd64 + args: + RUBY_VERSION: <%= ENV["RBENV_VERSION"] %> accessories: mysql: - image: mysql:8.3 + image: mysql:latest host: "<%= ENV['HOST'] %>" port: 3306 env: @@ -37,6 +54,7 @@ accessories: - config/init.sql:/docker-entrypoint-initdb.d/setup.sql directories: - data:/var/lib/mysql + cmd: mysqld --innodb-autoinc-lock-mode=0 redis: image: redis:latest host: "<%= ENV['HOST'] %>" @@ -45,7 +63,7 @@ accessories: volumes: - /var/lib/redis:/data postgres: - image: postgres:16 + image: postgres:latest host: "<%= ENV['HOST'] %>" port: 5432 env: @@ -57,4 +75,4 @@ accessories: files: - config/init.sql:/docker-entrypoint-initdb.d/setup.sql directories: - - data:/var/lib/postgresql/data + - data:/var/lib/postgresql diff --git a/bench/config/environments/development.rb b/bench/config/environments/development.rb index 62f6722..35a17d2 100644 --- a/bench/config/environments/development.rb +++ b/bench/config/environments/development.rb @@ -3,9 +3,7 @@ Rails.application.configure do # Settings specified here will take precedence over those in config/application.rb. - # In the development environment your application's code is reloaded any time - # it changes. This slows down response time but is perfect for development - # since you don't have to restart the web server when you make code changes. + # Make code changes take effect immediately without server restart. config.enable_reloading = true # Do not eager load code on boot. @@ -17,28 +15,29 @@ # Enable server timing. config.server_timing = true - # Enable/disable caching. By default caching is disabled. - # Run rails dev:cache to toggle caching. + # Enable/disable Action Controller caching. By default Action Controller caching is disabled. + # Run rails dev:cache to toggle Action Controller caching. if Rails.root.join("tmp/caching-dev.txt").exist? config.action_controller.perform_caching = true config.action_controller.enable_fragment_cache_logging = true - - config.cache_store = :memory_store - config.public_file_server.headers = { "Cache-Control" => "public, max-age=#{2.days.to_i}" } + config.public_file_server.headers = { "cache-control" => "public, max-age=#{2.days.to_i}" } else config.action_controller.perform_caching = false - - config.cache_store = :null_store end + # Change to :null_store to avoid any caching. + config.cache_store = :memory_store + # Store uploaded files on the local file system (see config/storage.yml for options). config.active_storage.service = :local # Don't care if the mailer can't send. config.action_mailer.raise_delivery_errors = false + # Make template changes take effect immediately. config.action_mailer.perform_caching = false + # Set localhost to be used by links generated in mailer templates. config.action_mailer.default_url_options = { host: "localhost", port: 3000 } # Print deprecation notices to the Rails logger. @@ -50,9 +49,17 @@ # Highlight code that triggered database queries in logs. config.active_record.verbose_query_logs = true + # Append comments with runtime information tags to SQL queries in logs. + config.active_record.query_log_tags_enabled = true + # Highlight code that enqueued background job in logs. config.active_job.verbose_enqueue_logs = true + # Highlight code that triggered redirect in logs. + config.action_dispatch.verbose_redirect_logs = true + + # Suppress logger output for asset requests. + config.assets.quiet = true # Raises error for missing translations. # config.i18n.raise_on_missing_translations = true @@ -65,7 +72,4 @@ # Raise error when a before_action's only/except options reference missing actions. config.action_controller.raise_on_missing_callback_actions = true - - # Apply autocorrection by RuboCop to files generated by `bin/rails generate`. - # config.generators.apply_rubocop_autocorrect_after_generate! end diff --git a/bench/config/environments/production.rb b/bench/config/environments/production.rb index 8ce1d0f..56b8fc5 100644 --- a/bench/config/environments/production.rb +++ b/bench/config/environments/production.rb @@ -1,46 +1,35 @@ require "active_support/core_ext/integer/time" Rails.application.configure do + config.active_storage.variant_processor = :disabled # Settings specified here will take precedence over those in config/application.rb. # Code is not reloaded between requests. config.enable_reloading = false - # Eager load code on boot. This eager loads most of Rails and - # your application in memory, allowing both threaded web servers - # and those relying on copy on write to perform better. - # Rake tasks automatically ignore this option for performance. + # Eager load code on boot for better performance and memory savings. config.eager_load = true - # Full error reports are disabled and caching is turned on. + # In Rake tasks, the previous assignment is ignored, config.eager_load is set + # from config.rake_eager_load. + config.rake_eager_load = false + + # Full error reports are disabled. config.consider_all_requests_local = false - config.action_controller.perform_caching = true - # Ensures that a master key has been made available in ENV["RAILS_MASTER_KEY"], config/master.key, or an environment - # key such as config/credentials/production.key. This key is used to decrypt credentials (and other encrypted files). - # config.require_master_key = true + # Turn on fragment caching in view templates. + config.action_controller.perform_caching = true - # Disable serving static files from `public/`, relying on NGINX/Apache to do so instead. - # config.public_file_server.enabled = false + # Cache assets for far-future expiry since they are all digest stamped. + config.public_file_server.headers = { "cache-control" => "public, max-age=#{1.year.to_i}" } # Enable serving of images, stylesheets, and JavaScripts from an asset server. - # config.asset_host = "http://assets.example.com" - - # Specifies the header that your server uses for sending files. - # config.action_dispatch.x_sendfile_header = "X-Sendfile" # for Apache - # config.action_dispatch.x_sendfile_header = "X-Accel-Redirect" # for NGINX + config.asset_host = ENV["CDN_HOST"] # Store uploaded files on the local file system (see config/storage.yml for options). config.active_storage.service = :local - # Mount Action Cable outside main process or domain. - # config.action_cable.mount_path = nil - # config.action_cable.url = "wss://example.com/cable" - # config.action_cable.allowed_request_origins = [ "http://example.com", /http:\/\/example.*/ ] - config.action_cable.worker_pool_size = 10 - # Assume all access to the app is happening through a SSL-terminating reverse proxy. - # Can be used together with config.force_ssl for Strict-Transport-Security and secure cookies. config.assume_ssl = true # Force all access to the app over SSL, use Strict-Transport-Security, and use secure cookies. @@ -49,47 +38,57 @@ # Skip http-to-https redirect for the default health check endpoint. # config.ssl_options = { redirect: { exclude: ->(request) { request.path == "/up" } } } - # Log to STDOUT by default - config.logger = ActiveSupport::Logger.new(STDOUT) - .tap { |logger| logger.formatter = ::Logger::Formatter.new } - .then { |logger| ActiveSupport::TaggedLogging.new(logger) } - - # Prepend all log lines with the following tags. + # Log to STDOUT with the current request id as a default log tag. config.log_tags = [ :request_id ] + config.logger = ActiveSupport::TaggedLogging.logger(STDOUT) - # "info" includes generic and useful information about system operation, but avoids logging too much - # information to avoid inadvertent exposure of personally identifiable information (PII). If you - # want to log everything, set the level to "debug". - config.log_level = ENV.fetch("RAILS_LOG_LEVEL", "debug") + # Change to "debug" to log everything (including potentially personally-identifiable information!). + config.log_level = ENV.fetch("RAILS_LOG_LEVEL", "info") - # Use a different cache store in production. - # config.cache_store = :mem_cache_store + # Prevent health checks from clogging up the logs. + config.silence_healthcheck_path = "/up" - # Use a real queuing backend for Active Job (and separate queues per environment). - # config.active_job.queue_adapter = :resque - # config.active_job.queue_name_prefix = "cablebench_production" + # Don't log any deprecations. + config.active_support.report_deprecations = false - config.action_mailer.perform_caching = false + # Replace the default file-based cache store with a more robust alternative. + # config.cache_store = :redis_cache_store, { url: ENV["REDIS_CACHE_URL"] } + + # Replace the default in-process and non-durable queuing backend for Active Job. + # config.active_job.queue_adapter = :resque # Ignore bad email addresses and do not raise email delivery errors. # Set this to true and configure the email server for immediate delivery to raise delivery errors. # config.action_mailer.raise_delivery_errors = false + # Set host to be used by links generated in mailer templates. + config.action_mailer.default_url_options = { host: "example.com" } + + # Specify outgoing SMTP server. Remember to add smtp/* credentials via bin/rails credentials:edit. + # config.action_mailer.smtp_settings = { + # user_name: Rails.app.credentials.dig(:smtp, :user_name), + # password: Rails.app.credentials.dig(:smtp, :password), + # address: "smtp.example.com", + # port: 587, + # authentication: :plain + # } + # Enable locale fallbacks for I18n (makes lookups for any locale fall back to # the I18n.default_locale when a translation cannot be found). config.i18n.fallbacks = true - # Don't log any deprecations. - config.active_support.report_deprecations = false - # Do not dump schema after migrations. config.active_record.dump_schema_after_migration = false + # Only use :id for inspections in production. + config.active_record.attributes_for_inspect = [ :id ] + # Enable DNS rebinding protection and other `Host` header attacks. # config.hosts = [ # "example.com", # Allow requests from example.com # /.*\.example\.com/ # Allow requests from subdomains like `www.example.com` # ] + # # Skip DNS rebinding protection for the default health check endpoint. # config.host_authorization = { exclude: ->(request) { request.path == "/up" } } end diff --git a/bench/config/environments/test.rb b/bench/config/environments/test.rb index 83d1fa9..ed60314 100644 --- a/bench/config/environments/test.rb +++ b/bench/config/environments/test.rb @@ -1,5 +1,3 @@ -require "active_support/core_ext/integer/time" - # The test environment is used exclusively to run your application's # test suite. You never need to work with it otherwise. Remember that # your test database is "scratch space" for the test suite and is wiped @@ -17,12 +15,15 @@ # loading is working properly before deploying your code. config.eager_load = ENV["CI"].present? - # Configure public file server for tests with Cache-Control for performance. - config.public_file_server.headers = { "Cache-Control" => "public, max-age=#{1.hour.to_i}" } + # In Rake tasks, the previous assignment is ignored, config.eager_load is set + # from config.rake_eager_load. + config.rake_eager_load = ENV["CI"].present? + + # Configure public file server for tests with cache-control for performance. + config.public_file_server.headers = { "cache-control" => "public, max-age=3600" } - # Show full error reports and disable caching. + # Show full error reports. config.consider_all_requests_local = true - config.action_controller.perform_caching = false config.cache_store = :null_store # Render exception templates for rescuable exceptions and raise for other exceptions. @@ -34,16 +35,13 @@ # Store uploaded files on the local file system in a temporary directory. config.active_storage.service = :test - config.action_mailer.perform_caching = false - # Tell Action Mailer not to deliver emails to the real world. # The :test delivery method accumulates sent emails in the # ActionMailer::Base.deliveries array. config.action_mailer.delivery_method = :test - # Unlike controllers, the mailer instance doesn't have any context about the - # incoming request so you'll need to provide the :host parameter yourself. - config.action_mailer.default_url_options = { host: "www.example.com" } + # Set host to be used by links generated in mailer templates. + config.action_mailer.default_url_options = { host: "example.com" } # Print deprecation notices to the stderr. config.active_support.deprecation = :stderr diff --git a/bench/config/initializers/content_security_policy.rb b/bench/config/initializers/content_security_policy.rb index b3076b3..d51d713 100644 --- a/bench/config/initializers/content_security_policy.rb +++ b/bench/config/initializers/content_security_policy.rb @@ -20,6 +20,10 @@ # config.content_security_policy_nonce_generator = ->(request) { request.session.id.to_s } # config.content_security_policy_nonce_directives = %w(script-src style-src) # +# # Automatically add `nonce` to `javascript_tag`, `javascript_include_tag`, and `stylesheet_link_tag` +# # if the corresponding directives are specified in `content_security_policy_nonce_directives`. +# # config.content_security_policy_nonce_auto = true +# # # Report violations without enforcing the policy. # # config.content_security_policy_report_only = true # end diff --git a/bench/config/initializers/filter_parameter_logging.rb b/bench/config/initializers/filter_parameter_logging.rb index c010b83..c0b717f 100644 --- a/bench/config/initializers/filter_parameter_logging.rb +++ b/bench/config/initializers/filter_parameter_logging.rb @@ -4,5 +4,5 @@ # Use this to limit dissemination of sensitive information. # See the ActiveSupport::ParameterFilter documentation for supported notations and behaviors. Rails.application.config.filter_parameters += [ - :passw, :email, :secret, :token, :_key, :crypt, :salt, :certificate, :otp, :ssn + :passw, :email, :secret, :token, :_key, :crypt, :salt, :certificate, :otp, :ssn, :cvv, :cvc ] diff --git a/bench/config/puma.rb b/bench/config/puma.rb index e86046e..ac72efd 100644 --- a/bench/config/puma.rb +++ b/bench/config/puma.rb @@ -1,10 +1,15 @@ # This configuration file will be evaluated by Puma. The top-level methods that # are invoked here are part of Puma's configuration DSL. For more information # about methods provided by the DSL, see https://puma.io/puma/Puma/DSL.html. - +# # Puma starts a configurable number of processes (workers) and each process # serves each request in a thread from an internal thread pool. # +# You can control the number of workers using ENV["WEB_CONCURRENCY"]. You +# should only set this value when you want to run 2 or more workers. The +# default is already 1. You can set it to `auto` to automatically start a worker +# for each available processor. +# # The ideal number of threads per worker depends both on how much time the # application spends waiting for IO operations and on how much you wish to # prioritize throughput over latency. @@ -20,30 +25,7 @@ # Any libraries that use a connection pool or another resource pool should # be configured to provide at least as many connections as the number of # threads. This includes Active Record's `pool` parameter in `database.yml`. -threads_count = ENV.fetch("RAILS_MAX_THREADS", 3) -threads threads_count, threads_count - -# Specifies the `environment` that Puma will run in. -rails_env = ENV.fetch("RAILS_ENV", "development") -environment rails_env - -case rails_env -when "production" - # If you are running more than 1 thread per process, the workers count - # should be equal to the number of processors (CPU cores) in production. - # - # Automatically detect the number of available processors in production. - require "concurrent-ruby" - workers_count = Integer(ENV.fetch("WEB_CONCURRENCY") { Concurrent.available_processor_count }) - workers workers_count if workers_count > 1 - worker_timeout 240 - - preload_app! -when "development" - # Specifies a very generous `worker_timeout` so that the worker - # isn't killed by Puma when suspended by a debugger. - worker_timeout 3600 -end +threads ENV.fetch("RAILS_MAX_THREADS", 3) # Specifies the `port` that Puma will listen on to receive requests; default is 3000. port ENV.fetch("PORT", 3000) @@ -51,5 +33,9 @@ # Allow puma to be restarted by `bin/rails restart` command. plugin :tmp_restart -# Only use a pidfile when requested +# Run the Solid Queue supervisor inside of Puma for single-server deployments. +plugin :solid_queue if ![ "", "false", "0" ].include?(ENV["SOLID_QUEUE_IN_PUMA"].to_s.downcase) + +# Specify the PID file. Defaults to tmp/pids/server.pid in development. +# In other environments, only set the PID file if requested. pidfile ENV["PIDFILE"] if ENV["PIDFILE"] diff --git a/bench/config/tailwind.config.js b/bench/config/tailwind.config.js deleted file mode 100644 index d6ad82c..0000000 --- a/bench/config/tailwind.config.js +++ /dev/null @@ -1,22 +0,0 @@ -const defaultTheme = require('tailwindcss/defaultTheme') - -module.exports = { - content: [ - './public/*.html', - './app/helpers/**/*.rb', - './app/javascript/**/*.js', - './app/views/**/*.{erb,haml,html,slim}' - ], - theme: { - extend: { - fontFamily: { - sans: ['Inter var', ...defaultTheme.fontFamily.sans], - }, - }, - }, - plugins: [ - require('@tailwindcss/forms'), - require('@tailwindcss/typography'), - require('@tailwindcss/container-queries'), - ] -} diff --git a/bench/loadtest.js b/bench/loadtest.js index d3738d7..7b36e0e 100644 --- a/bench/loadtest.js +++ b/bench/loadtest.js @@ -1,63 +1,424 @@ -import { check, sleep, fail } from "k6"; +import { check, fail, sleep } from "k6"; import cable from "k6/x/cable"; -import { randomIntBetween } from "https://jslib.k6.io/k6-utils/1.1.0/index.js"; -import { Trend } from "k6/metrics"; - -let rttTrend = new Trend("rtt", true); +import { Counter, Rate, Trend } from "k6/metrics"; +import { textSummary } from "https://jslib.k6.io/k6-summary/0.0.4/index.js"; const WS_URL = __ENV.WS_URL || "wss://solid-cable.dev/cable"; -const WS_COOKIE = __ENV.WS_COOKIE; // we need a valid cookie to authorize request -const MAX = parseInt(__ENV.MAX || "20"); -// Total test duration -const TIME = parseInt(__ENV.TIME || "90"); -const MESSAGES_NUM = parseInt(__ENV.NUM || "5"); - -export let options = { - thresholds: { - checks: ["rate>0.9"], - }, - scenarios: { - ping: { - // We use ramping executor to slowly increase the number of users during a test - executor: "ramping-vus", - startVUs: (MAX / 10 || 1) | 0, - stages: [ - { duration: `${TIME / 3}s`, target: (MAX / 4) | 0 }, - { duration: `${(7 * TIME) / 12}s`, target: MAX }, - { duration: `${TIME / 12}s`, target: 0 }, - ], - }, - }, +const WS_COOKIE = __ENV.WS_COOKIE || ""; +const ADAPTER = __ENV.ADAPTER || "unknown"; +const TEST_ID = __ENV.TEST_ID || ADAPTER; + +const MAX_VUS = intEnv("MAX", 20); +const TIME_SECONDS = intEnv("TIME", 90); +const MESSAGES_PER_ITERATION = intEnv("NUM", 5); +const PAYLOAD_BYTES = intEnv("PAYLOAD_BYTES", 64); +const RECEIVE_TIMEOUT_MS = intEnv("RECEIVE_TIMEOUT_MS", 90000); +const HANDSHAKE_TIMEOUT_SECONDS = intEnv("HANDSHAKE_TIMEOUT_SECONDS", 60); +const MIN_SLEEP_MS = intEnv("MIN_SLEEP_MS", 500); +const MAX_SLEEP_MS = intEnv("MAX_SLEEP_MS", 1000); +const CHURN_VUS = intEnv("CHURN_VUS", Math.max(1, Math.floor(MAX_VUS / 5))); +const CHURN_TIME_SECONDS = intEnv("CHURN_TIME", TIME_SECONDS); +const STORM_VUS = intEnv("STORM_VUS", MAX_VUS); +const STORM_TIME_SECONDS = intEnv("STORM_TIME", Math.max(15, Math.floor(TIME_SECONDS / 3))); +const STORM_ROUNDS = intEnv("STORM_ROUNDS", 5); +const STORM_SLEEP_MS = intEnv("STORM_SLEEP_MS", 100); +const FANOUT_VUS = intEnv("FANOUT_VUS", MAX_VUS); +const FANOUT_RATE = intEnv("FANOUT_RATE", 10); +const FANOUT_TIME_SECONDS = intEnv("FANOUT_TIME", TIME_SECONDS); +const FANOUT_WARMUP_SECONDS = intEnv("FANOUT_WARMUP", 15); +const FANOUT_DRAIN_SECONDS = intEnv("FANOUT_DRAIN", 10); +const FANOUT_STREAM = __ENV.FANOUT_STREAM || `${TEST_ID}-fanout`; +const RAMP_UP_SECONDS = Math.max(1, Math.floor(TIME_SECONDS / 3)); +const RAMP_HOLD_SECONDS = Math.max(1, Math.floor((7 * TIME_SECONDS) / 12)); +const RAMP_DOWN_SECONDS = Math.max(1, Math.floor(TIME_SECONDS / 12)); +const RAMP_TOTAL_SECONDS = RAMP_UP_SECONDS + RAMP_HOLD_SECONDS + RAMP_DOWN_SECONDS; +const SCENARIOS = (__ENV.SCENARIOS || "ramp,steady,churn,storm") + .split(",") + .map((name) => name.trim()) + .filter(Boolean); + +const metricTags = { + adapter: ADAPTER, + test_id: TEST_ID, }; +const connectionDuration = new Trend("cable_connection_duration", true); +const subscriptionDuration = new Trend("cable_subscription_duration", true); +const actionRtt = new Trend("cable_action_rtt", true); +const receiveDuration = new Trend("cable_receive_duration", true); +const iterationMessages = new Trend("cable_iteration_messages", false); +const connectionFailures = new Counter("cable_connection_failures"); +const subscriptionFailures = new Counter("cable_subscription_failures"); +const receiveFailures = new Counter("cable_receive_failures"); +const invalidMessages = new Counter("cable_invalid_messages"); +const messagesSent = new Counter("cable_messages_sent"); +const messagesReceived = new Counter("cable_messages_received"); +const successfulRoundTrips = new Rate("cable_round_trip_success"); +const fanoutDeliveryLatency = new Trend("cable_fanout_delivery_latency", true); +const fanoutMessagesPublished = new Counter("cable_fanout_messages_published"); +const fanoutDeliveriesReceived = new Counter("cable_fanout_deliveries_received"); +const fanoutSequenceGaps = new Counter("cable_fanout_sequence_gaps"); +const fanoutDuplicateDeliveries = new Counter("cable_fanout_duplicate_deliveries"); +const fanoutOutOfOrderDeliveries = new Counter("cable_fanout_out_of_order_deliveries"); +const fanoutSubscribersCompleted = new Counter("cable_fanout_subscribers_completed"); -export default function () { - const client = cable.connect(WS_URL, { cookies: WS_COOKIE, receiveTimeoutMS: 60000 }); +export const options = { + scenarios: buildScenarios(), +}; - if (!check(client, { "successful connection": (obj) => obj })) { - fail("connection failed"); +export function ramp() { + runPingIteration("ramp"); +} + +export function steady() { + runPingIteration("steady"); +} + +export function churn() { + const tags = scenarioTags("churn"); + const client = connectClient("churn"); + const channel = subscribe(client, "churn"); + const body = messageBody("churn", 0); + const startedAt = Date.now(); + + channel.perform("ping", { message: body }); + messagesSent.add(1, tags); + + const received = receive(channel, "churn"); + const rtt = Date.now() - startedAt; + const ok = received && received.message === `pong ${body}`; + + actionRtt.add(rtt, tags); + successfulRoundTrips.add(Boolean(ok), tags); + if (!ok) { + invalidMessages.add(1, tags); + client.disconnect(); + fail("expected churn ping response was not received"); } - const channel = client.subscribe("BroadcastChannel", {}); - if (!check(channel, { "successful subscription": (obj) => obj })) { - fail("failed to subscribe"); + messagesReceived.add(1, tags); + client.disconnect(); +} + +export function storm() { + const tags = scenarioTags("storm"); + + for (let i = 0; i < STORM_ROUNDS; i++) { + const client = connectClient("storm"); + const channel = subscribe(client, "storm"); + const body = messageBody("storm", i); + const startedAt = Date.now(); + + channel.perform("ping", { message: body }); + messagesSent.add(1, tags); + + const received = receive(channel, "storm"); + const rtt = Date.now() - startedAt; + const ok = received && received.message === `pong ${body}`; + + actionRtt.add(rtt, tags); + successfulRoundTrips.add(Boolean(ok), tags); + + if (!ok) { + invalidMessages.add(1, tags); + client.disconnect(); + fail(`expected storm ping response for ${body}`); + } + + messagesReceived.add(1, tags); + client.disconnect(); + sleep(STORM_SLEEP_MS / 1000); } +} + +export function fanoutSubscriber() { + const tags = scenarioTags("fanout"); + const client = connectClient("fanout"); + const channel = subscribeTo(client, "fanout", "FanoutChannel", { stream: FANOUT_STREAM }); + const seenSequences = {}; + let highestSequence = -1; + + while (true) { + const message = channel.receive(); + if (!message) continue; - for (let i = 0; i < MESSAGES_NUM; i++) { - let startMessage = Date.now(); - channel.perform("ping", { message: `Hello ${i}` }); + if (message.complete) { + const expectedMessages = Number(message.expected_messages); + let missingMessages = 0; - let message = channel.receive(); - if (!check(message, { "received res": (obj) => obj.message === `pong Hello ${i}` })) { - fail("expected message hasn't been received"); + for (let sequence = 0; sequence < expectedMessages; sequence++) { + if (seenSequences[sequence] !== true) missingMessages += 1; + } + + if (missingMessages > 0) fanoutSequenceGaps.add(missingMessages, tags); + fanoutSubscribersCompleted.add(1, tags); + break; + } + + const sequence = Number(message.sequence); + const sentAt = Number(message.sent_at); + + if (!Number.isInteger(sequence) || sequence < 0 || !Number.isFinite(sentAt)) { + invalidMessages.add(1, tags); + continue; } - let endMessage = Date.now(); - rttTrend.add(endMessage - startMessage); + if (seenSequences[sequence] === true) { + fanoutDuplicateDeliveries.add(1, tags); + continue; + } + + if (sequence < highestSequence) fanoutOutOfOrderDeliveries.add(1, tags); + + seenSequences[sequence] = true; + highestSequence = Math.max(highestSequence, sequence); + fanoutDeliveryLatency.add(Date.now() - sentAt, tags); + fanoutDeliveriesReceived.add(1, tags); + } + + client.disconnect(); +} + +export function fanoutPublisher() { + const tags = scenarioTags("fanout"); + const client = connectClient("fanout"); + const channel = subscribeTo(client, "fanout", "FanoutChannel", { stream: FANOUT_STREAM }); + const messageCount = FANOUT_RATE * FANOUT_TIME_SECONDS; + + for (let sequence = 0; sequence < messageCount; sequence++) { + channel.perform("publish", { + sequence, + sent_at: Date.now(), + message: messageBody("fanout", sequence), + }); + fanoutMessagesPublished.add(1, tags); + + if (sequence < messageCount - 1) sleep(1 / FANOUT_RATE); + } + + sleep(1); + channel.perform("publish", { complete: true, expected_messages: messageCount }); + sleep(1); + client.disconnect(); +} + +function runPingIteration(workload) { + const tags = scenarioTags(workload); + const client = connectClient(workload); + const channel = subscribe(client, workload); + let receivedCount = 0; + + for (let i = 0; i < MESSAGES_PER_ITERATION; i++) { + const body = messageBody(workload, i); + const startedAt = Date.now(); + + channel.perform("ping", { message: body }); + messagesSent.add(1, tags); - sleep(randomIntBetween(5, 10) / 10); + const message = receive(channel, workload); + const rtt = Date.now() - startedAt; + const ok = message && message.message === `pong ${body}`; + + actionRtt.add(rtt, tags); + successfulRoundTrips.add(Boolean(ok), tags); + + if (!ok) { + invalidMessages.add(1, tags); + client.disconnect(); + fail(`expected pong response for ${body}`); + } + + receivedCount += 1; + messagesReceived.add(1, tags); + sleep(randomSleepSeconds()); } - // Terminate the WS connection + iterationMessages.add(receivedCount, tags); client.disconnect(); } + +function connectClient(workload, receiveTimeoutMs) { + const tags = scenarioTags(workload); + const startedAt = Date.now(); + const client = cable.connect(WS_URL, { + cookies: WS_COOKIE, + receiveTimeoutMs: receiveTimeoutMs || RECEIVE_TIMEOUT_MS, + handshakeTimeoutS: HANDSHAKE_TIMEOUT_SECONDS, + tags, + }); + + connectionDuration.add(Date.now() - startedAt, tags); + + if (!check(client, { "successful connection": (obj) => Boolean(obj) }, tags)) { + connectionFailures.add(1, tags); + fail("connection failed"); + } + + return client; +} + +function subscribe(client, workload) { + return subscribeTo(client, workload, "BroadcastChannel", {}); +} + +function subscribeTo(client, workload, channelName, params) { + const tags = scenarioTags(workload); + const startedAt = Date.now(); + const channel = client.subscribe(channelName, params); + + subscriptionDuration.add(Date.now() - startedAt, tags); + + if (!check(channel, { "successful subscription": (obj) => Boolean(obj) }, tags)) { + subscriptionFailures.add(1, tags); + fail("failed to subscribe"); + } + + return channel; +} + +function receive(channel, workload) { + const tags = scenarioTags(workload); + const startedAt = Date.now(); + const message = channel.receive(); + + receiveDuration.add(Date.now() - startedAt, tags); + + if (!message) { + receiveFailures.add(1, tags); + } + + return message; +} + +function buildScenarios() { + const scenarios = {}; + let startAfterSeconds = 0; + + if (SCENARIOS.includes("ramp")) { + scenarios.ramp = { + exec: "ramp", + executor: "ramping-vus", + startTime: scenarioStartTime(startAfterSeconds), + startVUs: Math.max(1, Math.floor(MAX_VUS / 10)), + stages: [ + { duration: `${RAMP_UP_SECONDS}s`, target: Math.max(1, Math.floor(MAX_VUS / 4)) }, + { duration: `${RAMP_HOLD_SECONDS}s`, target: MAX_VUS }, + { duration: `${RAMP_DOWN_SECONDS}s`, target: 0 }, + ], + tags: scenarioTags("ramp"), + }; + startAfterSeconds += RAMP_TOTAL_SECONDS; + } + + if (SCENARIOS.includes("steady")) { + scenarios.steady = { + exec: "steady", + executor: "constant-vus", + vus: MAX_VUS, + duration: `${TIME_SECONDS}s`, + startTime: scenarioStartTime(startAfterSeconds), + tags: scenarioTags("steady"), + }; + startAfterSeconds += TIME_SECONDS; + } + + if (SCENARIOS.includes("churn")) { + scenarios.churn = { + exec: "churn", + executor: "constant-vus", + vus: CHURN_VUS, + duration: `${CHURN_TIME_SECONDS}s`, + startTime: scenarioStartTime(startAfterSeconds), + tags: scenarioTags("churn"), + }; + startAfterSeconds += CHURN_TIME_SECONDS; + } + + if (SCENARIOS.includes("storm")) { + scenarios.storm = { + exec: "storm", + executor: "per-vu-iterations", + vus: STORM_VUS, + iterations: 1, + maxDuration: `${Math.max(STORM_TIME_SECONDS, HANDSHAKE_TIMEOUT_SECONDS + 5)}s`, + startTime: scenarioStartTime(startAfterSeconds), + tags: scenarioTags("storm"), + }; + startAfterSeconds += STORM_TIME_SECONDS; + } + + if (SCENARIOS.includes("fanout")) { + const fanoutStartTime = startAfterSeconds; + + scenarios.fanout_subscribers = { + exec: "fanoutSubscriber", + executor: "per-vu-iterations", + vus: FANOUT_VUS, + iterations: 1, + maxDuration: `${FANOUT_WARMUP_SECONDS + FANOUT_TIME_SECONDS + FANOUT_DRAIN_SECONDS}s`, + startTime: scenarioStartTime(fanoutStartTime), + tags: scenarioTags("fanout"), + }; + + scenarios.fanout_publisher = { + exec: "fanoutPublisher", + executor: "per-vu-iterations", + vus: 1, + iterations: 1, + maxDuration: `${FANOUT_TIME_SECONDS + HANDSHAKE_TIMEOUT_SECONDS}s`, + startTime: scenarioStartTime(fanoutStartTime + FANOUT_WARMUP_SECONDS), + tags: scenarioTags("fanout"), + }; + } + + return scenarios; +} + +export function handleSummary(data) { + const output = { + stdout: textSummary(data, { indent: " ", enableColors: true }), + }; + + if (__ENV.SUMMARY_PATH) { + output[__ENV.SUMMARY_PATH] = JSON.stringify({ + adapter: ADAPTER, + test_id: TEST_ID, + ws_url: WS_URL, + scenarios: SCENARIOS, + metrics: data.metrics, + root_group: data.root_group, + }, null, 2); + } + + return output; +} + +function scenarioStartTime(seconds) { + return seconds === 0 ? "0s" : `${seconds}s`; +} + +function scenarioTags(workload) { + return Object.assign({}, metricTags, { workload: workload }); +} + +function messageBody(workload, index) { + const prefix = `${TEST_ID}:${workload}:vu-${__VU}:iter-${__ITER}:msg-${index}:`; + if (PAYLOAD_BYTES <= prefix.length) return prefix; + + return `${prefix}${"x".repeat(PAYLOAD_BYTES - prefix.length)}`; +} + +function randomSleepSeconds() { + if (MAX_SLEEP_MS <= MIN_SLEEP_MS) return MIN_SLEEP_MS / 1000; + + return randomIntBetween(MIN_SLEEP_MS, MAX_SLEEP_MS) / 1000; +} + +function randomIntBetween(min, max) { + return Math.floor(Math.random() * (max - min + 1)) + min; +} + +function intEnv(name, defaultValue) { + const value = parseInt(__ENV[name] || `${defaultValue}`, 10); + return Number.isNaN(value) ? defaultValue : value; +} diff --git a/bench/public/400.html b/bench/public/400.html new file mode 100644 index 0000000..640de03 --- /dev/null +++ b/bench/public/400.html @@ -0,0 +1,135 @@ + + + + + + + The server cannot process the request due to a client error (400 Bad Request) + + + + + + + + + + + + + +
+
+ +
+
+

The server cannot process the request due to a client error. Please check the request and try again. If you're the application owner check the logs for more information.

+
+
+ + + + diff --git a/bench/public/404.html b/bench/public/404.html index 2be3af2..d7f0f14 100644 --- a/bench/public/404.html +++ b/bench/public/404.html @@ -1,67 +1,135 @@ - - - - The page you were looking for doesn't exist (404) - - - - - - -
-
-

The page you were looking for doesn't exist.

-

You may have mistyped the address or the page may have moved.

-
-

If you are the application owner check the logs for more information.

-
- + + + + + + + The page you were looking for doesn't exist (404 Not found) + + + + + + + + + + + + + +
+
+ +
+
+

The page you were looking for doesn't exist. You may have mistyped the address or the page may have moved. If you're the application owner check the logs for more information.

+
+
+ + + diff --git a/bench/public/406-unsupported-browser.html b/bench/public/406-unsupported-browser.html index 7cf1e16..43d2811 100644 --- a/bench/public/406-unsupported-browser.html +++ b/bench/public/406-unsupported-browser.html @@ -1,66 +1,135 @@ - - - - Your browser is not supported (406) - - - - - - -
-
-

Your browser is not supported.

-

Please upgrade your browser to continue.

-
-
- + + + + + + + Your browser is not supported (406 Not Acceptable) + + + + + + + + + + + + + +
+
+ +
+
+

Your browser is not supported.
Please upgrade your browser to continue.

+
+
+ + + diff --git a/bench/public/422.html b/bench/public/422.html index c08eac0..f12fb4a 100644 --- a/bench/public/422.html +++ b/bench/public/422.html @@ -1,67 +1,135 @@ - - - - The change you wanted was rejected (422) - - - - - - -
-
-

The change you wanted was rejected.

-

Maybe you tried to change something you didn't have access to.

-
-

If you are the application owner check the logs for more information.

-
- + + + + + + + The change you wanted was rejected (422 Unprocessable Entity) + + + + + + + + + + + + + +
+
+ +
+
+

The change you wanted was rejected. Maybe you tried to change something you didn't have access to. If you're the application owner check the logs for more information.

+
+
+ + + diff --git a/bench/public/500.html b/bench/public/500.html index 78a030a..e4eb18a 100644 --- a/bench/public/500.html +++ b/bench/public/500.html @@ -1,66 +1,135 @@ - - - - We're sorry, but something went wrong (500) - - - - - - -
-
-

We're sorry, but something went wrong.

-
-

If you are the application owner check the logs for more information.

-
- + + + + + + + We're sorry, but something went wrong (500 Internal Server Error) + + + + + + + + + + + + + +
+
+ +
+
+

We're sorry, but something went wrong.
If you're the application owner check the logs for more information.

+
+
+ + + diff --git a/bench/public/icon.png b/bench/public/icon.png index f3b5abcbde91cf6d7a6a26e514eb7e30f476f950..c4c9dbfbbd2f7c1421ffd5727188146213abbcef 100644 GIT binary patch literal 4166 zcmd6qU;WFw?|v@m)Sk^&NvB8tcujdV-r1b=i(NJxn&7{KTb zX$3(M+3TP2o^#KAo{#tIjl&t~(8D-k004kqPglzn0HFG(Q~(I*AKsD#M*g7!XK0T7 zN6P7j>HcT8rZgKl$v!xr806dyN19Bd4C0x_R*I-a?#zsTvb_89cyhuC&T**i|Rc zq5b8M;+{8KvoJ~uj9`u~d_f6`V&3+&ZX9x5pc8s)d175;@pjm(?dapmBcm0&vl9+W zx1ZD2o^nuyUHWj|^A8r>lUorO`wFF;>9XL-Jy!P}UXC{(z!FO%SH~8k`#|9;Q|eue zqWL0^Bp(fg_+Pkm!fDKRSY;+^@BF?AJE zCUWpXPst~hi_~u)SzYBDZroR+Z4xeHIlm_3Yc_9nZ(o_gg!jDgVa=E}Y8uDgem9`b zf=mfJ_@(BXSkW53B)F2s!&?_R4ptb1fYXlF++@vPhd=marQgEGRZS@B4g1Mu?euknL= z67P~tZ?*>-Hmi7GwlisNHHJDku-dSm7g@!=a}9cSL6Pa^w^2?&?$Oi8ibrr>w)xqx zOH_EMU@m05)9kuNR>>4@H%|){U$^yvVQ(YgOlh;5oU_-vivG-p4=LrN-k7D?*?u1u zsWly%tfAzKd6Fb=`eU2un_uaTXmcT#tlOL+aRS=kZZf}A7qT8lvcTx~7j` z*b>=z)mwg7%B2_!D0!1IZ?Nq{^Y$uI4Qx*6T!E2Col&2{k?ImCO=dD~A&9f9diXy^$x{6CwkBimn|1E09 zAMSezYtiL?O6hS37KpvDM?22&d{l)7h-!F)C-d3j8Z`c@($?mfd{R82)H>Qe`h{~G z!I}(2j(|49{LR?w4Jspl_i!(4T{31|dqCOpI52r5NhxYV+cDAu(xp*4iqZ2e-$YP= zoFOPmm|u*7C?S{Fp43y+V;>~@FFR76bCl@pTtyB93vNWy5yf;HKr8^0d7&GVIslYm zo3Tgt@M!`8B6IW&lK{Xk>%zp41G%`(DR&^u z5^pwD4>E6-w<8Kl2DzJ%a@~QDE$(e87lNhy?-Qgep!$b?5f7+&EM7$e>|WrX+=zCb z=!f5P>MxFyy;mIRxjc(H*}mceXw5a*IpC0PEYJ8Y3{JdoIW)@t97{wcUB@u+$FCCO z;s2Qe(d~oJC^`m$7DE-dsha`glrtu&v&93IZadvl_yjp!c89>zo;Krk+d&DEG4?x$ zufC1n+c1XD7dolX1q|7}uelR$`pT0Z)1jun<39$Sn2V5g&|(j~Z!wOddfYiZo7)A< z!dK`aBHOOk+-E_xbWCA3VR-+o$i5eO9`rMI#p_0xQ}rjEpGW;U!&&PKnivOcG(|m9 z!C8?WC6nCXw25WVa*eew)zQ=h45k8jSIPbq&?VE{oG%?4>9rwEeB4&qe#?-y_es4c|7ufw%+H5EY#oCgv!Lzv291#-oNlX~X+Jl5(riC~r z=0M|wMOP)Tt8@hNg&%V@Z9@J|Q#K*hE>sr6@oguas9&6^-=~$*2Gs%h#GF@h)i=Im z^iKk~ipWJg1VrvKS;_2lgs3n1zvNvxb27nGM=NXE!D4C!U`f*K2B@^^&ij9y}DTLB*FI zEnBL6y{jc?JqXWbkIZd7I16hA>(f9T!iwbIxJj~bKPfrO;>%*5nk&Lf?G@c2wvGrY&41$W{7HM9+b@&XY@>NZM5s|EK_Dp zQX60CBuantx>|d#DsaZ*8MW(we|#KTYZ=vNa#d*DJQe6hr~J6{_rI#?wi@s|&O}FR zG$kfPxheXh1?IZ{bDT-CWB4FTvO-k5scW^mi8?iY5Q`f8JcnnCxiy@m@D-%lO;y0pTLhh6i6l@x52j=#^$5_U^os}OFg zzdHbo(QI`%9#o*r8GCW~T3UdV`szO#~)^&X_(VW>o~umY9-ns9-V4lf~j z`QBD~pJ4a#b`*6bJ^3RS5y?RAgF7K5$ll97Y8#WZduZ`j?IEY~H(s^doZg>7-tk*t z4_QE1%%bb^p~4F5SB$t2i1>DBG1cIo;2(xTaj*Y~hlM{tSDHojL-QPg%Mo%6^7FrpB*{ z4G0@T{-77Por4DCMF zB_5Y~Phv%EQ64W8^GS6h?x6xh;w2{z3$rhC;m+;uD&pR74j+i22P5DS-tE8ABvH(U~indEbBUTAAAXfHZg5QpB@TgV9eI<)JrAkOI z8!TSOgfAJiWAXeM&vR4Glh;VxH}WG&V$bVb`a`g}GSpwggti*&)taV1@Ak|{WrV|5 zmNYx)Ans=S{c52qv@+jmGQ&vd6>6yX6IKq9O$3r&0xUTdZ!m1!irzn`SY+F23Rl6# zFRxws&gV-kM1NX(3(gnKpGi0Q)Dxi~#?nyzOR9!en;Ij>YJZVFAL*=R%7y%Mz9hU% zs>+ZB?qRmZ)nISx7wxY)y#cd$iaC~{k0avD>BjyF1q^mNQ1QcwsxiTySe<6C&cC6P zE`vwO9^k-d`9hZ!+r@Jnr+MF*2;2l8WjZ}DrwDUHzSF{WoG zucbSWguA!3KgB3MU%HH`R;XqVv0CcaGq?+;v_A5A2kpmk5V%qZE3yzQ7R5XWhq=eR zyUezH=@V)y>L9T-M-?tW(PQYTRBKZSVb_!$^H-Pn%ea;!vS_?M<~Tm>_rWIW43sPW z=!lY&fWc1g7+r?R)0p8(%zp&vl+FK4HRkns%BW+Up&wK8!lQ2~bja|9bD12WrKn#M zK)Yl9*8$SI7MAwSK$%)dMd>o+1UD<2&aQMhyjS5R{-vV+M;Q4bzl~Z~=4HFj_#2V9 zB)Gfzx3ncy@uzx?yzi}6>d%-?WE}h7v*w)Jr_gBl!2P&F3DX>j_1#--yjpL%<;JMR z*b70Gr)MMIBWDo~#<5F^Q0$VKI;SBIRneuR7)yVsN~A9I@gZTXe)E?iVII+X5h0~H zx^c(fP&4>!*q>fb6dAOC?MI>Cz3kld#J*;uik+Ps49cwm1B4 zZc1|ZxYyTv;{Z!?qS=D)sgRKx^1AYf%;y_V&VgZglfU>d+Ufk5&LV$sKv}Hoj+s; xK3FZRYdhbXT_@RW*ff3@`D1#ps#~H)p+y&j#(J|vk^lW{fF9OJt5(B-_&*Xgn9~3N literal 5599 zcmeHL-D}fO6hCR_taXJlzs3}~RuB=Iujyo=i*=1|1FN%E=zNfMTjru|Q<6v{J{U!C zBEE}?j6I3sz>fzN!6}L_BKjcuASk~1;Dg|U_@d{g?V8mM`~#9U+>>*Ezw>c(PjYWA z4(;!cgge6k5E&d$G5`S-0}!Ik>CV(0Y#1}s-v_gAHhja2=W1?nBAte9D2HG<(+)uj z!5=W4u*{VKMw#{V@^NNs4TClr!FAA%ID-*gc{R%CFKEzG<6gm*9s_uy)oMGW*=nJf zw{(Mau|2FHfXIv6C0@Wk5k)F=3jo1srV-C{pl&k&)4_&JjYrnbJiul}d0^NCSh(#7h=F;3{|>EU>h z6U8_p;^wK6mAB(1b92>5-HxJ~V}@3?G`&Qq-TbJ2(&~-HsH6F#8mFaAG(45eT3VPO zM|(Jd<+;UZs;w>0Qw}0>D%{~r{uo_Fl5_Bo3ABWi zWo^j^_T3dxG6J6fH8X)$a^%TJ#PU!=LxF=#Fd9EvKx_x>q<(KY%+y-08?kN9dXjXK z**Q=yt-FTU*13ouhCdqq-0&;Ke{T3sQU9IdzhV9LhQIpq*P{N)+}|Mh+a-VV=x?R} c>%+pvTcMWshj-umO}|qP?%A)*_KlqT3uEqhU;qFB diff --git a/bench/public/icon.svg b/bench/public/icon.svg index 78307cc..04b34bf 100644 --- a/bench/public/icon.svg +++ b/bench/public/icon.svg @@ -1,3 +1,3 @@ - - + +