v0.1.4

this will make it eaiser to set the content-type correctly

.devcontainer/Dockerfile

@@ -0,0 +1,2 @@
+ARG VARIANT="3.4.2"
+FROM ghcr.io/rails/devcontainer/images/ruby:${VARIANT}

.devcontainer/boot.sh

@@ -0,0 +1,4 @@
+#!/bin/bash
+
+bundle update --bundler
+bundler install

.devcontainer/compose.yml

@@ -0,0 +1,12 @@
+---
+services:
+  kubernaut:
+    build:
+      context: .
+      dockerfile: Dockerfile
+    volumes:
+      - ..:/workspace:cached
+      - /var/run/docker.sock:/var/run/docker-host.sock
+    command: sleep infinity
+  memcached:
+    image: memcached:latest

.devcontainer/devcontainer.json

@@ -0,0 +1,20 @@
+{
+    "dockerComposeFile": "compose.yml",
+    "service": "kubernaut",
+    "workspaceFolder": "/workspace",
+    "customizations": {
+        "vscode": {
+            "extensions": [
+                "Shopify.ruby-lsp",
+                "ms-azuretools.vscode-docker"
+            ]
+        }
+    },
+    "postCreateCommand": ".devcontainer/boot.sh",
+    "forwardPorts": [
+        4567
+    ],
+    "features": {
+        "ghcr.io/devcontainers/features/docker-outside-of-docker:1": {}
+    }
+}

.gitea/workflows/ci.yaml

@@ -1,7 +1,16 @@
 ---
 name: Gitea Actions Demo
 run-name: ${{ gitea.actor }} is testing out Gitea Actions 🚀
-on: [push]
+
+on:
+  schedule: 
+    - cron: "0 10 * * *"
+  push:
+    branches:
+      - "**"
+    tags:
+      - "v*.*.*"
+  pull_request:
 
 jobs:
   lint:
@@ -10,13 +19,19 @@ jobs:
       checks: write
       contents: write
     steps:
+      - name: Login to Docker
+        uses: docker/login-action@v3
+        with:
+          username: ${{ vars.DOCKERHUB_USERNAME }}
+          password: ${{ secrets.DOCKERHUB_TOKEN }}
+
       - name: Checkout
         uses: actions/checkout@v4
 
       - name: Ruby Setup
         uses: ruby/setup-ruby@v1
         with:
-          ruby-version: '3.3'
+          ruby-version: '3.4'
           bundler-cache: true
 
       - run: bundle install
@@ -35,13 +50,12 @@ jobs:
       - name: Test
         uses: ruby/setup-ruby@v1
         with:
-          ruby-version: '3.3'
+          ruby-version: '3.4'
           bundler-cache: true
 
-      - run: bundle exec rspec
+      - run: bundle exec rake
 
-
+  docker:
-  release-image:
     needs: test
     runs-on: ubuntu-latest
     container:
@@ -49,12 +63,41 @@ jobs:
     env:
       DOCKER_ORG: ryanc
       DOCKER_LATEST: latest
+    defaults:
+      run:
+        shell: bash
     steps:
       - name: Checkout
         uses: actions/checkout@v4
         with:
           fetch-depth: 0 # all history for all branches and tags
 
+      - name: Prepare
+        id: prep
+        run: |
+          VERSION="sha-${GITHUB_SHA::8}"
+          if [[ "$GITHUB_REF" == refs/tags/* ]]; then
+            VERSION="${GITHUB_REF/refs\/tags\//}"
+          fi
+          printf "GITHUB_REF=%s\n" "$GITHUB_REF"
+          printf "GITHUB_SHA=%s\n" "$GITHUB_SHA"
+          printf "VERSION=%s\n" "$VERSION" | tee -a "$GITHUB_OUTPUT"
+
+      - name: Docker meta
+        id: meta
+        uses: docker/metadata-action@v5
+        with:
+          images: |
+            git.kill0.net/ryanc/kubernaut
+          tags: |
+            type=schedule
+            type=ref,event=branch
+            type=ref,event=pr
+            type=semver,pattern={{version}}
+            type=semver,pattern={{major}}.{{minor}}
+            type=semver,pattern={{major}}
+            type=sha
+
       - name: Set up Docker Buildx
         uses: docker/setup-buildx-action@v3
 
@@ -68,5 +111,17 @@ jobs:
       - name: Docker build and push
         uses: docker/build-push-action@v5
         with:
-          push: true
+          push: ${{ github.event_name != 'pull_request' }}
-          tags: git.kill0.net/ryanc/kipunji:latest
+          tags: ${{ steps.meta.outputs.tags }}
+          labels: ${{ steps.meta.outputs.labels }}
+
+      - name: Setup Helm
+        uses: azure/setup-helm@v4.3.0
+
+      - name: Publish Helm chart
+        if: ${{ contains(github.ref, 'refs/tags/') }}
+        run: |
+          HELM_VERSION="${{ steps.prep.outputs.VERSION }}"
+          HELM_VERSION="${HELM_VERSION#v}"
+          helm package charts/kubernaut
+          helm push "kubernaut-${HELM_VERSION}.tgz" oci://git.kill0.net/ryanc/helm-charts

.gitignore

@@ -1,5 +1,3 @@
 .bundle
-.cache
-.local
 .ruby-lsp
-.ash_history
+/vendor

.vscode/settings.json

@@ -0,0 +1,9 @@
+{
+  "[ruby]": {
+    "editor.defaultFormatter": "Shopify.ruby-lsp"
+  },
+  "rubyLsp.formatter": "standard",
+  "rubyLsp.linters": [
+    "standard"
+  ],
+}

Dockerfile

@@ -9,8 +9,6 @@ RUN <<EOT
   apk upgrade --no-cache
 EOT
 
-RUN mkdir -p /run/app
-
 
 FROM base AS build
 
@@ -25,25 +23,12 @@ RUN <<EOT
   bundle install
 EOT
 
-FROM build AS dev
-
-WORKDIR /app
-
-RUN <<EOT
-  bundle install
-EOT
-
-CMD [ "sleep", "infinity" ]
 
 FROM base
 
 # RUN useradd ruby --home /app --shell /bin/sh
 RUN adduser ruby -h /app -D
 
-RUN mkdir -p /run/app
-
-RUN chown ruby:ruby /run/app
-
 USER ruby:ruby
 
 COPY --from=build /usr/local/bundle /usr/local/bundle

Gemfile

@@ -12,12 +12,13 @@ gem "ulid"
 gem "uuid7"
 
 gem "jwt"
+gem "httparty"
 
 group :development do
   gem "ruby-lsp"
-  gem "rubocop"
-  gem "rbs"
   gem "rack-test"
   gem "rspec"
   gem "standard"
+  gem "minitest"
+  gem "rake"
 end

Gemfile.lock

@@ -2,115 +2,128 @@ GEM
   remote: https://rubygems.org/
   specs:
     anyflake (0.0.1)
-    ast (2.4.2)
+    ast (2.4.3)
     base64 (0.2.0)
-    diff-lcs (1.5.1)
+    bigdecimal (3.1.9)
-    json (2.7.2)
+    csv (3.3.3)
-    jwt (2.8.2)
+    diff-lcs (1.6.1)
+    httparty (0.23.1)
+      csv
+      mini_mime (>= 1.0.0)
+      multi_xml (>= 0.5.2)
+    json (2.10.2)
+    jwt (2.10.1)
       base64
     ksuid (1.0.0)
-    language_server-protocol (3.17.0.3)
+    language_server-protocol (3.17.0.4)
     lint_roller (1.1.0)
-    logger (1.6.0)
+    logger (1.7.0)
+    mini_mime (1.1.5)
+    minitest (5.25.5)
     multi_json (1.15.0)
-    mustermann (3.0.0)
+    multi_xml (0.7.1)
+      bigdecimal (~> 3.1)
+    mustermann (3.0.3)
       ruby2_keywords (~> 0.0.1)
     nanoid (2.0.0)
-    nio4r (2.7.3)
+    nio4r (2.7.4)
-    parallel (1.25.1)
+    parallel (1.26.3)
-    parser (3.3.3.0)
+    parser (3.3.7.4)
       ast (~> 2.4.1)
       racc
-    prism (0.30.0)
+    prism (1.4.0)
-    puma (6.4.2)
+    puma (6.6.0)
       nio4r (~> 2.0)
-    racc (1.8.0)
+    racc (1.8.1)
-    rack (3.1.3)
+    rack (3.1.12)
-    rack-protection (4.0.0)
+    rack-protection (4.1.1)
       base64 (>= 0.1.0)
+      logger (>= 1.6.0)
       rack (>= 3.0.0, < 4)
-    rack-session (2.0.0)
+    rack-session (2.1.0)
+      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.2.1)
       rack (>= 3)
-      webrick (~> 1.8)
     rainbow (3.1.1)
-    rbs (3.5.1)
+    rake (13.2.1)
+    rbs (3.9.2)
       logger
-    regexp_parser (2.9.2)
+    regexp_parser (2.10.0)
-    rexml (3.3.0)
-      strscan
     rspec (3.13.0)
       rspec-core (~> 3.13.0)
       rspec-expectations (~> 3.13.0)
       rspec-mocks (~> 3.13.0)
-    rspec-core (3.13.0)
+    rspec-core (3.13.3)
       rspec-support (~> 3.13.0)
-    rspec-expectations (3.13.1)
+    rspec-expectations (3.13.3)
       diff-lcs (>= 1.2.0, < 2.0)
       rspec-support (~> 3.13.0)
-    rspec-mocks (3.13.1)
+    rspec-mocks (3.13.2)
       diff-lcs (>= 1.2.0, < 2.0)
       rspec-support (~> 3.13.0)
-    rspec-support (3.13.1)
+    rspec-support (3.13.2)
-    rubocop (1.64.1)
+    rubocop (1.73.2)
       json (~> 2.3)
-      language_server-protocol (>= 3.17.0)
+      language_server-protocol (~> 3.17.0.2)
+      lint_roller (~> 1.1.0)
       parallel (~> 1.10)
       parser (>= 3.3.0.2)
       rainbow (>= 2.2.2, < 4.0)
-      regexp_parser (>= 1.8, < 3.0)
+      regexp_parser (>= 2.9.3, < 3.0)
-      rexml (>= 3.2.5, < 4.0)
+      rubocop-ast (>= 1.38.0, < 2.0)
-      rubocop-ast (>= 1.31.1, < 2.0)
       ruby-progressbar (~> 1.7)
-      unicode-display_width (>= 2.4.0, < 3.0)
+      unicode-display_width (>= 2.4.0, < 4.0)
-    rubocop-ast (1.31.3)
+    rubocop-ast (1.43.0)
-      parser (>= 3.3.1.0)
+      parser (>= 3.3.7.2)
-    rubocop-performance (1.21.1)
+      prism (~> 1.4)
-      rubocop (>= 1.48.1, < 2.0)
+    rubocop-performance (1.24.0)
-      rubocop-ast (>= 1.31.1, < 2.0)
+      lint_roller (~> 1.1)
-    ruby-lsp (0.17.3)
+      rubocop (>= 1.72.1, < 2.0)
+      rubocop-ast (>= 1.38.0, < 2.0)
+    ruby-lsp (0.23.13)
       language_server-protocol (~> 3.17.0)
-      prism (>= 0.29.0, < 0.31)
+      prism (>= 1.2, < 2.0)
       rbs (>= 3, < 4)
       sorbet-runtime (>= 0.5.10782)
     ruby-progressbar (1.13.0)
     ruby2_keywords (0.0.5)
-    sinatra (4.0.0)
+    sinatra (4.1.1)
+      logger (>= 1.6.0)
       mustermann (~> 3.0)
       rack (>= 3.0.0, < 4)
-      rack-protection (= 4.0.0)
+      rack-protection (= 4.1.1)
       rack-session (>= 2.0.0, < 3)
       tilt (~> 2.0)
-    sinatra-contrib (4.0.0)
+    sinatra-contrib (4.1.1)
       multi_json (>= 0.0.2)
       mustermann (~> 3.0)
-      rack-protection (= 4.0.0)
+      rack-protection (= 4.1.1)
-      sinatra (= 4.0.0)
+      sinatra (= 4.1.1)
       tilt (~> 2.0)
-    sorbet-runtime (0.5.11435)
+    sorbet-runtime (0.5.11971)
-    standard (1.39.1)
+    standard (1.47.0)
       language_server-protocol (~> 3.17.0.2)
       lint_roller (~> 1.0)
-      rubocop (~> 1.64.0)
+      rubocop (~> 1.73.0)
       standard-custom (~> 1.0.0)
-      standard-performance (~> 1.4)
+      standard-performance (~> 1.7)
     standard-custom (1.0.2)
       lint_roller (~> 1.0)
       rubocop (~> 1.50)
-    standard-performance (1.4.0)
+    standard-performance (1.7.0)
       lint_roller (~> 1.1)
-      rubocop-performance (~> 1.21.0)
+      rubocop-performance (~> 1.24.0)
-    strscan (3.1.0)
+    tilt (2.6.0)
-    tilt (2.3.0)
     ulid (1.4.0)
-    unicode-display_width (2.5.0)
+    unicode-display_width (3.1.4)
+      unicode-emoji (~> 4.0, >= 4.0.4)
+    unicode-emoji (4.0.4)
     uuid7 (0.2.0)
       zeitwerk (~> 2.4)
-    webrick (1.8.1)
+    zeitwerk (2.7.2)
-    zeitwerk (2.6.15)
 
 PLATFORMS
   ruby
@@ -118,15 +131,16 @@ PLATFORMS
 
 DEPENDENCIES
   anyflake
+  httparty
   jwt
   ksuid
+  minitest
   nanoid
   puma
   rack-test
   rackup
-  rbs
+  rake
   rspec
-  rubocop
   ruby-lsp
   sinatra
   sinatra-contrib
@@ -135,4 +149,4 @@ DEPENDENCIES
   uuid7
 
 BUNDLED WITH
-   2.5.13
+   2.6.6

Rakefile

@@ -0,0 +1,11 @@
+begin
+  require "rspec/core/rake_task"
+  RSpec::Core::RakeTask.new(:spec)
+rescue LoadError
+end
+
+require "minitest/test_task"
+
+Minitest::TestTask.create
+
+task default: [:test, :spec]

app.rb

@@ -2,9 +2,11 @@ require "bundler/setup"
 require "sinatra"
 require "sinatra/cookies"
 require "sinatra/multi_route"
+require "sinatra/quiet_logger"
 require "time"
 require "fileutils"
 require "json"
+require "singleton"
 
 require "securerandom"
 require "random/formatter"
@@ -13,12 +15,23 @@ require "anyflake"
 
 require "jwt"
 
-SESSION_SECRET_HEX_LENGTH = 64
+require "httparty"
 
-set :session_secret, ENV.fetch("SESSION_SECRET") { SecureRandom.hex(SESSION_SECRET_HEX_LENGTH) }
+$LOAD_PATH.unshift File.dirname(__FILE__) + "/lib"
+
+require "config"
+
+VERSION = "0.1.4"
+
+CHUNK_SIZE = 1024**2
+SESSION_SECRET_HEX_LENGTH = 64
+JWT_SECRET_HEX_LENGTH = 64
+DEFAULT_FLAKEY = 50
+
+NAME = "kubernaut".freeze
+ENV_PREFIX = NAME.upcase
 
 CLK_TCK = 100
-PID_FILE_PATH = "/run/app/pid".freeze
 PROC_UPTIME_PATH = "/proc/uptime".freeze
 
 SECONDS_PER_YEAR = 31_556_952
@@ -38,7 +51,13 @@ DURATION_PARTS = [
   [1, "second", "s"]
 ].freeze
 
-JWT_SECRET = SecureRandom.bytes(64).freeze
+config = Config.new
+
+set :quiet_logger_prefixes, %w[livez readyz]
+set :session_secret, config.session_secret.unwrap
+set :public_folder, __dir__ + "/static"
+
+register Sinatra::QuietLogger
 
 module Sinatra
   module RequestHeadersHelper
@@ -96,9 +115,8 @@ end
 
 class TickTock
   def initialize
-    @pid = master_pid
+    @pid = ppid
     @procfs_f = format "/proc/%s/stat", @pid
-    puts @pid
   end
 
   def uptime
@@ -122,7 +140,7 @@ class Health
   include UpDown
 
   def initialize
-    @file = "./healthy"
+    @file = "/dev/shm/healthy"
   end
 
   def healthy?
@@ -136,7 +154,7 @@ class Ready
   include UpDown
 
   def initialize
-    @file = "./ready"
+    @file = "/dev/shm/ready"
   end
 
   def ready?
@@ -149,7 +167,7 @@ class Sleep
   include State
 
   def initialize
-    @file = "./sleep"
+    @file = "/dev/shm/sleepy"
   end
 
   def asleep?
@@ -165,9 +183,13 @@ class Sleep
   end
 end
 
-def master_pid
+def ppid
-  pid_s = File.read PID_FILE_PATH
+  pid = ENV.fetch "PUMA_PID", Process.pid
-  Integer pid_s.strip
+  begin
+    Integer pid
+  rescue ArgumentError
+    -1
+  end
 end
 
 def system_uptime
@@ -195,8 +217,17 @@ Health.instance.up
 Ready.instance.up
 Sleep.instance.wake
 
+def flaky(pct = DEFAULT_FLAKEY)
+  r = Random.rand(0..100)
+  unless r < (100 - pct)
+    halt 500, "so unreliable"
+  end
+end
+
 enable :sessions
 
+puts "#{NAME} #{VERSION} staring, per aspera ad astra"
+
 configure do
   mime_type :json, "application/json"
 end
@@ -206,15 +237,27 @@ before do
   sleep(1) while Sleep.instance.asleep? && request.path_info != "/livez/sleep"
   content_type :text if request.path_info.start_with? "/_cat"
   request.session_options[:skip] = !request.path_info.start_with?("/session")
+
+  if params.has_key? :flaky
+    begin
+      pct = Integer(params[:flaky])
+      pct = pct.clamp(0, 100)
+    rescue => e
+      logger.warn "#{e.message}: falling back to default flaky percentage of #{DEFAULT_FLAKEY}"
+      pct = DEFAULT_FLAKEY
+    end
+    flaky(pct)
+  end
 end
 
 helpers do
-  def json(obj, opts: nil, pretty: false)
+  def jsonify(obj, opts: nil, pretty: false)
-    if pretty
+    buf = if pretty
       JSON.pretty_generate obj, opts:
     else
       JSON.generate(obj, opts:)
     end
+    "#{buf}\n"
   end
 
   def protected! hidden = false
@@ -235,6 +278,10 @@ helpers do
       @auth.credentials and
       @auth.credentials == ["qwer", "asdf"]
   end
+
+  def hostname
+    ENV["HOSTNAME"]
+  end
 end
 
 get "/" do
@@ -244,14 +291,31 @@ end
 get "/env", provides: "json" do
   pretty = params.key? :pretty
 
-  json ENV.sort.to_h, pretty:
+  jsonify ENV.sort.to_h, pretty:
 end
 
 get "/headers", provides: "json" do
   pretty = params.key? :pretty
   h = req_headers
 
-  json h, pretty:
+  jsonify h, pretty:
+end
+
+get "/uptime", provides: "json" do
+  tt = TickTock.new
+  x = {started_at: tt.started_at, seconds: tt.uptime.to_i, human: human_time(tt.uptime.to_i)}
+
+  jsonify x
+end
+
+post "/api/livez/toggle" do
+  Health.instance.toggle
+  "ok\n"
+end
+
+post "/api/livez/sleep" do
+  Sleep.instance.toggle
+  "ok\n"
 end
 
 get "/livez" do
@@ -262,23 +326,6 @@ get "/livez" do
   Health.instance.to_s
 end
 
-get "/livez/uptime" do
-  tt = TickTock.new
-  x = {started_at: tt.started_at, seconds: tt.uptime.to_i, human: human_time(tt.uptime.to_i)}
-
-  json x
-end
-
-post "/livez/toggle" do
-  Health.instance.toggle
-  "ok\n"
-end
-
-post "/livez/sleep" do
-  Sleep.instance.toggle
-  "ok\n"
-end
-
 get "/readyz" do
   error 503 unless Ready.instance.ready?
 
@@ -318,19 +365,19 @@ get "/snowflake" do
 end
 
 post "/quit" do
-  Process.kill("TERM", master_pid)
+  Process.kill("TERM", ppid)
   nil
 end
 
 post "/halt" do
-  Process.kill("QUIT", master_pid)
+  Process.kill("QUIT", ppid)
   nil
 end
 
-get "/pid" do
+get "/pid", provides: "json" do
   pretty = params.key? :pretty
 
-  json({puma: master_pid, pid: Process.pid}, pretty:)
+  jsonify({ppid: ppid, pid: Process.pid}, pretty:)
 end
 
 get "/token" do
@@ -340,31 +387,51 @@ get "/token" do
   token = JWT.encode payload, JWT_SECRET, "HS256"
   x = {token: token, expires_at: expires_at}
 
-  json x
+  jsonify x
 end
 
 get "/token/validate" do
   token = req_headers["authorization"].split[1]
   payload = JWT.decode token, JWT_SECRET, true, algorithm: "HS256"
 
-  json payload
+  jsonify payload
 end
 
 post "/session" do
   session.merge! params
 
-  json session.to_hash
+  jsonify session.to_hash
 end
 
 get "/session" do
   j = session.to_hash
   j[:hostname] = ENV["HOSTNAME"]
 
-  json j
+  jsonify j
 end
 
 get "/cookies" do
-  json response.headers
+  jsonify response.headers
+end
+
+get "/config", provides: "json" do
+  pretty = params.key? :pretty
+
+  jsonify config.as_json, pretty:
+end
+
+get "/_cat" do
+  stream do |out|
+    out << "=^.^=\n"
+    x = Sinatra::Application.routes.map do |method, route|
+      route.map do |route|
+        route.first.to_s
+      end
+    end
+    x.flatten.sort.uniq.each do |route|
+      out << "#{route}\n" if route.start_with? "/_cat"
+    end
+  end
 end
 
 get "/_cat/headers" do
@@ -391,6 +458,29 @@ get "/_cat/cookies" do
   end
 end
 
+get "/_cat/config" do
+  stream do |out|
+    config.instance_variables.each do |k|
+      k = k.to_s.delete_prefix "@"
+      begin
+        v = config.send(k)
+      rescue NoMethodError
+        next
+      end
+
+      out << "#{k}(#{v.to_s.length})=#{v}\n"
+    end
+  end
+end
+
+get "/_cat/pid" do
+  stream do |out|
+    {ppid: ppid, pid: Process.pid}.sort.each do |k, v|
+      out << "#{k}=#{v}\n"
+    end
+  end
+end
+
 route :delete, :get, :patch, :post, :put, "/status/:code" do
   # hello
   code = Integer(params[:code])
@@ -398,11 +488,14 @@ route :delete, :get, :patch, :post, :put, "/status/:code" do
 end
 
 get "/chunked/:delay" do
+  content_type "application/x-ndjson"
+
   delay = Float(params[:delay])
   stream do |out|
-    out << "Hello, world!\n"
+    30.times do |i|
-    sleep delay
+      out << jsonify({id: i, message: (i % 2).zero? ? "tick" : "tock"})
-    out << "Hello, world!\n"
+      sleep delay
+    end
   end
 end
 
@@ -415,5 +508,90 @@ route :delete, :get, :patch, :post, :put, "/auth/basic", provides: "json" do
     protected!
   end
 
-  json({authenticated: true, user: @auth.username}, pretty:)
+  jsonify({authenticated: true, user: @auth.username}, pretty:)
+end
+
+def human_size_to_bytes(size)
+  units = %i[b kb mb gb tb pb eb zb yb rb qb]
+
+  number, unit = size.split(/(?<=\d)(?=[A-Za-z])/)
+
+  raise ArgumentError, "the unit is not recognized" if unit.nil?
+
+  number = Float(number)
+  unit = unit.downcase.to_sym
+
+  exponent = units.find_index(unit)
+
+  number *= (1024**exponent)
+  Integer(number.ceil)
+end
+
+MAX_DOWNLOAD_SIZE = "1GB"
+
+get "/bytes/:size" do
+  size = params[:size]
+  n = [human_size_to_bytes(size), human_size_to_bytes(MAX_DOWNLOAD_SIZE)].min
+
+  headers["content-type"] = "application/octet-stream"
+  headers["content-length"] = n
+
+  headers["content-disposition"] = "attachment; filename=\"#{params[:f]}\"" if params.key? :f
+
+  def generate_bytes(number, byte = "\x00", block_size = 4096)
+    raise ArgumentError, "'byte' must be 1 byte" unless byte.b.length == 1
+
+    bytes_written = 0
+    block = byte * block_size
+    Enumerator.new do |g|
+      while bytes_written < number
+        remaining_bytes = number - bytes_written
+        bytes_to_write = [block_size, remaining_bytes].min
+        g.yield block[0, bytes_to_write]
+        bytes_written += bytes_to_write
+      end
+    end
+  end
+
+  generate_bytes(Integer(n))
+end
+
+get "/api/caas" do
+  send_file Dir[__dir__ + "/static/cat*.jpg"].sample
+end
+
+get "/meow" do
+  caas_host = ENV.fetch "CAAS_SERVICE_HOST", nil
+  caas_port = ENV.fetch "CAAS_SERVICE_PORT", nil
+  url = "http://#{caas_host}:#{caas_port}/"
+  unless caas_host && caas_port
+    url = url("/api/caas")
+  end
+  tmp_file = Tempfile.open binmode: true do |f|
+    # f.chmod 0o644
+    response = HTTParty.get(url, stream_body: true) do |fragment|
+      if [301, 302].include? fragment.code
+        print "skip writing for redirect"
+      elsif fragment.code == 200
+        f.write fragment
+      else
+        raise StandardError, "non-success status code while streaming #{fragment.code}"
+      end
+    end
+
+    content_type response.headers["content-type"]
+    f
+  end
+
+  tmp_file.open do |f|
+    stream do |out|
+      out << f.read
+      until f.eof?
+        out << f.read(CHUNK_SIZE)
+      end
+    end
+  ensure
+    f.close
+    f.unlink
+  end
 end

charts/kubernaut/.helmignore

@@ -0,0 +1,23 @@
+# Patterns to ignore when building packages.
+# This supports shell glob matching, relative path matching, and
+# negation (prefixed with !). Only one pattern per line.
+.DS_Store
+# Common VCS dirs
+.git/
+.gitignore
+.bzr/
+.bzrignore
+.hg/
+.hgignore
+.svn/
+# Common backup files
+*.swp
+*.bak
+*.tmp
+*.orig
+*~
+# Various IDEs
+.project
+.idea/
+*.tmproj
+.vscode/

charts/kubernaut/Chart.yaml

@@ -0,0 +1,24 @@
+apiVersion: v2
+name: kubernaut
+description: A Helm chart for Kubernetes
+
+# A chart can be either an 'application' or a 'library' chart.
+#
+# Application charts are a collection of templates that can be packaged into versioned archives
+# to be deployed.
+#
+# Library charts provide useful utilities or functions for the chart developer. They're included as
+# a dependency of application charts to inject those utilities and functions into the rendering
+# pipeline. Library charts do not define any templates and therefore cannot be deployed.
+type: application
+
+# This is the chart version. This version number should be incremented each time you make changes
+# to the chart and its templates, including the app version.
+# Versions are expected to follow Semantic Versioning (https://semver.org/)
+version: 0.1.4
+
+# This is the version number of the application being deployed. This version number should be
+# incremented each time you make changes to the application. Versions are not expected to
+# follow Semantic Versioning. They should reflect the version the application is using.
+# It is recommended to use it with quotes.
+appVersion: "0.1.4"

charts/kubernaut/templates/NOTES.txt

@@ -0,0 +1,22 @@
+1. Get the application URL by running these commands:
+{{- if .Values.ingress.enabled }}
+{{- range $host := .Values.ingress.hosts }}
+  {{- range .paths }}
+  http{{ if $.Values.ingress.tls }}s{{ end }}://{{ $host.host }}{{ .path }}
+  {{- end }}
+{{- end }}
+{{- else if contains "NodePort" .Values.service.type }}
+  export NODE_PORT=$(kubectl get --namespace {{ .Release.Namespace }} -o jsonpath="{.spec.ports[0].nodePort}" services {{ include "kubernaut.fullname" . }})
+  export NODE_IP=$(kubectl get nodes --namespace {{ .Release.Namespace }} -o jsonpath="{.items[0].status.addresses[0].address}")
+  echo http://$NODE_IP:$NODE_PORT
+{{- else if contains "LoadBalancer" .Values.service.type }}
+     NOTE: It may take a few minutes for the LoadBalancer IP to be available.
+           You can watch its status by running 'kubectl get --namespace {{ .Release.Namespace }} svc -w {{ include "kubernaut.fullname" . }}'
+  export SERVICE_IP=$(kubectl get svc --namespace {{ .Release.Namespace }} {{ include "kubernaut.fullname" . }} --template "{{"{{ range (index .status.loadBalancer.ingress 0) }}{{.}}{{ end }}"}}")
+  echo http://$SERVICE_IP:{{ .Values.service.port }}
+{{- else if contains "ClusterIP" .Values.service.type }}
+  export POD_NAME=$(kubectl get pods --namespace {{ .Release.Namespace }} -l "app.kubernetes.io/name={{ include "kubernaut.name" . }},app.kubernetes.io/instance={{ .Release.Name }}" -o jsonpath="{.items[0].metadata.name}")
+  export CONTAINER_PORT=$(kubectl get pod --namespace {{ .Release.Namespace }} $POD_NAME -o jsonpath="{.spec.containers[0].ports[0].containerPort}")
+  echo "Visit http://127.0.0.1:8080 to use your application"
+  kubectl --namespace {{ .Release.Namespace }} port-forward $POD_NAME 8080:$CONTAINER_PORT
+{{- end }}

charts/kubernaut/templates/_helpers.tpl

@@ -0,0 +1,62 @@
+{{/*
+Expand the name of the chart.
+*/}}
+{{- define "kubernaut.name" -}}
+{{- default .Chart.Name .Values.nameOverride | trunc 63 | trimSuffix "-" }}
+{{- end }}
+
+{{/*
+Create a default fully qualified app name.
+We truncate at 63 chars because some Kubernetes name fields are limited to this (by the DNS naming spec).
+If release name contains chart name it will be used as a full name.
+*/}}
+{{- define "kubernaut.fullname" -}}
+{{- if .Values.fullnameOverride }}
+{{- .Values.fullnameOverride | trunc 63 | trimSuffix "-" }}
+{{- else }}
+{{- $name := default .Chart.Name .Values.nameOverride }}
+{{- if contains $name .Release.Name }}
+{{- .Release.Name | trunc 63 | trimSuffix "-" }}
+{{- else }}
+{{- printf "%s-%s" .Release.Name $name | trunc 63 | trimSuffix "-" }}
+{{- end }}
+{{- end }}
+{{- end }}
+
+{{/*
+Create chart name and version as used by the chart label.
+*/}}
+{{- define "kubernaut.chart" -}}
+{{- printf "%s-%s" .Chart.Name .Chart.Version | replace "+" "_" | trunc 63 | trimSuffix "-" }}
+{{- end }}
+
+{{/*
+Common labels
+*/}}
+{{- define "kubernaut.labels" -}}
+helm.sh/chart: {{ include "kubernaut.chart" . }}
+{{ include "kubernaut.selectorLabels" . }}
+{{- if .Chart.AppVersion }}
+app.kubernetes.io/version: {{ .Chart.AppVersion | quote }}
+{{- end }}
+app.kubernetes.io/managed-by: {{ .Release.Service }}
+{{- end }}
+
+{{/*
+Selector labels
+*/}}
+{{- define "kubernaut.selectorLabels" -}}
+app.kubernetes.io/name: {{ include "kubernaut.name" . }}
+app.kubernetes.io/instance: {{ .Release.Name }}
+{{- end }}
+
+{{/*
+Create the name of the service account to use
+*/}}
+{{- define "kubernaut.serviceAccountName" -}}
+{{- if .Values.serviceAccount.create }}
+{{- default (include "kubernaut.fullname" .) .Values.serviceAccount.name }}
+{{- else }}
+{{- default "default" .Values.serviceAccount.name }}
+{{- end }}
+{{- end }}

charts/kubernaut/templates/configmap.yaml

@@ -0,0 +1,8 @@
+apiVersion: v1
+kind: ConfigMap
+metadata:
+  name: {{ .Release.Name }}-configmap
+data:
+  {{- with.Values.cat }}
+  KUBERNAUT_CAT: {{ toYaml . }}
+  {{- end }}

charts/kubernaut/templates/deployment.yaml

@@ -0,0 +1,78 @@
+apiVersion: apps/v1
+kind: Deployment
+metadata:
+  name: {{ include "kubernaut.fullname" . }}
+  labels:
+    {{- include "kubernaut.labels" . | nindent 4 }}
+spec:
+  {{- if not .Values.autoscaling.enabled }}
+  replicas: {{ .Values.replicaCount }}
+  {{- end }}
+  selector:
+    matchLabels:
+      {{- include "kubernaut.selectorLabels" . | nindent 6 }}
+  template:
+    metadata:
+      {{- with .Values.podAnnotations }}
+      annotations:
+        {{- toYaml . | nindent 8 }}
+      {{- end }}
+      labels:
+        {{- include "kubernaut.labels" . | nindent 8 }}
+        {{- with .Values.podLabels }}
+        {{- toYaml . | nindent 8 }}
+        {{- end }}
+    spec:
+      {{- with .Values.imagePullSecrets }}
+      imagePullSecrets:
+        {{- toYaml . | nindent 8 }}
+      {{- end }}
+      serviceAccountName: {{ include "kubernaut.serviceAccountName" . }}
+      {{- with .Values.podSecurityContext }}
+      securityContext:
+        {{- toYaml . | nindent 8 }}
+      {{- end }}
+      containers:
+        - name: {{ .Chart.Name }}
+          {{- with .Values.securityContext }}
+          securityContext:
+            {{- toYaml . | nindent 12 }}
+          {{- end }}
+          image: "{{ .Values.image.repository }}:{{ .Values.image.tag | default .Chart.AppVersion }}"
+          imagePullPolicy: {{ .Values.image.pullPolicy }}
+          ports:
+            - name: http
+              containerPort: {{ .Values.service.port }}
+              protocol: TCP
+          {{- with .Values.livenessProbe }}
+          livenessProbe:
+            {{- toYaml . | nindent 12 }}
+          {{- end }}
+          {{- with .Values.readinessProbe }}
+          readinessProbe:
+            {{- toYaml . | nindent 12 }}
+          {{- end }}
+          {{- with .Values.resources }}
+          resources:
+            {{- toYaml . | nindent 12 }}
+          {{- end }}
+          {{- with .Values.volumeMounts }}
+          volumeMounts:
+            {{- toYaml . | nindent 12 }}
+          {{- end }}
+      {{- with .Values.volumes }}
+      volumes:
+        {{- toYaml . | nindent 8 }}
+      {{- end }}
+      {{- with .Values.nodeSelector }}
+      nodeSelector:
+        {{- toYaml . | nindent 8 }}
+      {{- end }}
+      {{- with .Values.affinity }}
+      affinity:
+        {{- toYaml . | nindent 8 }}
+      {{- end }}
+      {{- with .Values.tolerations }}
+      tolerations:
+        {{- toYaml . | nindent 8 }}
+      {{- end }}

charts/kubernaut/templates/hpa.yaml

@@ -0,0 +1,32 @@
+{{- if .Values.autoscaling.enabled }}
+apiVersion: autoscaling/v2
+kind: HorizontalPodAutoscaler
+metadata:
+  name: {{ include "kubernaut.fullname" . }}
+  labels:
+    {{- include "kubernaut.labels" . | nindent 4 }}
+spec:
+  scaleTargetRef:
+    apiVersion: apps/v1
+    kind: Deployment
+    name: {{ include "kubernaut.fullname" . }}
+  minReplicas: {{ .Values.autoscaling.minReplicas }}
+  maxReplicas: {{ .Values.autoscaling.maxReplicas }}
+  metrics:
+    {{- if .Values.autoscaling.targetCPUUtilizationPercentage }}
+    - type: Resource
+      resource:
+        name: cpu
+        target:
+          type: Utilization
+          averageUtilization: {{ .Values.autoscaling.targetCPUUtilizationPercentage }}
+    {{- end }}
+    {{- if .Values.autoscaling.targetMemoryUtilizationPercentage }}
+    - type: Resource
+      resource:
+        name: memory
+        target:
+          type: Utilization
+          averageUtilization: {{ .Values.autoscaling.targetMemoryUtilizationPercentage }}
+    {{- end }}
+{{- end }}

charts/kubernaut/templates/ingress.yaml

@@ -0,0 +1,43 @@
+{{- if .Values.ingress.enabled -}}
+apiVersion: networking.k8s.io/v1
+kind: Ingress
+metadata:
+  name: {{ include "kubernaut.fullname" . }}
+  labels:
+    {{- include "kubernaut.labels" . | nindent 4 }}
+  {{- with .Values.ingress.annotations }}
+  annotations:
+    {{- toYaml . | nindent 4 }}
+  {{- end }}
+spec:
+  {{- with .Values.ingress.className }}
+  ingressClassName: {{ . }}
+  {{- end }}
+  {{- if .Values.ingress.tls }}
+  tls:
+    {{- range .Values.ingress.tls }}
+    - hosts:
+        {{- range .hosts }}
+        - {{ . | quote }}
+        {{- end }}
+      secretName: {{ .secretName }}
+    {{- end }}
+  {{- end }}
+  rules:
+    {{- range .Values.ingress.hosts }}
+    - host: {{ .host | quote }}
+      http:
+        paths:
+          {{- range .paths }}
+          - path: {{ .path }}
+            {{- with .pathType }}
+            pathType: {{ . }}
+            {{- end }}
+            backend:
+              service:
+                name: {{ include "kubernaut.fullname" $ }}
+                port:
+                  number: {{ $.Values.service.port }}
+          {{- end }}
+    {{- end }}
+{{- end }}

charts/kubernaut/templates/service.yaml

@@ -0,0 +1,15 @@
+apiVersion: v1
+kind: Service
+metadata:
+  name: {{ include "kubernaut.fullname" . }}
+  labels:
+    {{- include "kubernaut.labels" . | nindent 4 }}
+spec:
+  type: {{ .Values.service.type }}
+  ports:
+    - port: {{ .Values.service.port }}
+      targetPort: http
+      protocol: TCP
+      name: http
+  selector:
+    {{- include "kubernaut.selectorLabels" . | nindent 4 }}

charts/kubernaut/templates/serviceaccount.yaml

@@ -0,0 +1,13 @@
+{{- if .Values.serviceAccount.create -}}
+apiVersion: v1
+kind: ServiceAccount
+metadata:
+  name: {{ include "kubernaut.serviceAccountName" . }}
+  labels:
+    {{- include "kubernaut.labels" . | nindent 4 }}
+  {{- with .Values.serviceAccount.annotations }}
+  annotations:
+    {{- toYaml . | nindent 4 }}
+  {{- end }}
+automountServiceAccountToken: {{ .Values.serviceAccount.automount }}
+{{- end }}

charts/kubernaut/templates/tests/test-connection.yaml

@@ -0,0 +1,15 @@
+apiVersion: v1
+kind: Pod
+metadata:
+  name: "{{ include "kubernaut.fullname" . }}-test-connection"
+  labels:
+    {{- include "kubernaut.labels" . | nindent 4 }}
+  annotations:
+    "helm.sh/hook": test
+spec:
+  containers:
+    - name: wget
+      image: busybox
+      command: ['wget']
+      args: ['{{ include "kubernaut.fullname" . }}:{{ .Values.service.port }}']
+  restartPolicy: Never

charts/kubernaut/values.yaml

@@ -0,0 +1,123 @@
+# Default values for kubernaut.
+# This is a YAML-formatted file.
+# Declare variables to be passed into your templates.
+
+# This will set the replicaset count more information can be found here: https://kubernetes.io/docs/concepts/workloads/controllers/replicaset/
+replicaCount: 1
+
+# This sets the container image more information can be found here: https://kubernetes.io/docs/concepts/containers/images/
+image:
+  repository: git.kill0.net/ryanc/kubernaut
+  # This sets the pull policy for images.
+  pullPolicy: IfNotPresent
+  # Overrides the image tag whose default is the chart appVersion.
+  tag: ""
+
+# This is for the secrets for pulling an image from a private repository more information can be found here: https://kubernetes.io/docs/tasks/configure-pod-container/pull-image-private-registry/
+imagePullSecrets: []
+# This is to override the chart name.
+nameOverride: ""
+fullnameOverride: ""
+
+# This section builds out the service account more information can be found here: https://kubernetes.io/docs/concepts/security/service-accounts/
+serviceAccount:
+  # Specifies whether a service account should be created
+  create: true
+  # Automatically mount a ServiceAccount's API credentials?
+  automount: true
+  # Annotations to add to the service account
+  annotations: {}
+  # The name of the service account to use.
+  # If not set and create is true, a name is generated using the fullname template
+  name: ""
+
+# This is for setting Kubernetes Annotations to a Pod.
+# For more information checkout: https://kubernetes.io/docs/concepts/overview/working-with-objects/annotations/
+podAnnotations: {}
+# This is for setting Kubernetes Labels to a Pod.
+# For more information checkout: https://kubernetes.io/docs/concepts/overview/working-with-objects/labels/
+podLabels: {}
+
+podSecurityContext: {}
+  # fsGroup: 2000
+
+securityContext: {}
+  # capabilities:
+  #   drop:
+  #   - ALL
+  # readOnlyRootFilesystem: true
+  # runAsNonRoot: true
+  # runAsUser: 1000
+
+# This is for setting up a service more information can be found here: https://kubernetes.io/docs/concepts/services-networking/service/
+service:
+  # This sets the service type more information can be found here: https://kubernetes.io/docs/concepts/services-networking/service/#publishing-services-service-types
+  type: ClusterIP
+  # This sets the ports more information can be found here: https://kubernetes.io/docs/concepts/services-networking/service/#field-spec-ports
+  port: 4567
+
+# This block is for setting up the ingress for more information can be found here: https://kubernetes.io/docs/concepts/services-networking/ingress/
+ingress:
+  enabled: true
+  className: ""
+  annotations: {}
+    # kubernetes.io/ingress.class: nginx
+    # kubernetes.io/tls-acme: "true"
+  hosts:
+    - host:
+      paths:
+        - path: /
+          pathType: ImplementationSpecific
+  tls: []
+  #  - secretName: chart-example-tls
+  #    hosts:
+  #      - chart-example.local
+
+resources: {}
+  # We usually recommend not to specify default resources and to leave this as a conscious
+  # choice for the user. This also increases chances charts run on environments with little
+  # resources, such as Minikube. If you do want to specify resources, uncomment the following
+  # lines, adjust them as necessary, and remove the curly braces after 'resources:'.
+  # limits:
+  #   cpu: 100m
+  #   memory: 128Mi
+  # requests:
+  #   cpu: 100m
+  #   memory: 128Mi
+
+# This is to setup the liveness and readiness probes more information can be found here: https://kubernetes.io/docs/tasks/configure-pod-container/configure-liveness-readiness-startup-probes/
+livenessProbe:
+  httpGet:
+    path: /livez
+    port: http
+readinessProbe:
+  httpGet:
+    path: /readyz
+    port: http
+
+# This section is for setting up autoscaling more information can be found here: https://kubernetes.io/docs/concepts/workloads/autoscaling/
+autoscaling:
+  enabled: true
+  minReplicas: 2
+  maxReplicas: 100
+  targetCPUUtilizationPercentage: 80
+  # targetMemoryUtilizationPercentage: 80
+
+# Additional volumes on the output Deployment definition.
+volumes: []
+# - name: foo
+#   secret:
+#     secretName: mysecret
+#     optional: false
+
+# Additional volumeMounts on the output Deployment definition.
+volumeMounts: []
+# - name: foo
+#   mountPath: "/etc/foo"
+#   readOnly: true
+
+nodeSelector: {}
+
+tolerations: []
+
+affinity: {}

config/puma.rb

@@ -1,3 +1 @@
-# workers 3
+ENV["PUMA_PID"] = Process.pid.to_s
-pidfile "/run/app/pid"
-preload_app!

docker-compose.yml

@@ -1,15 +0,0 @@
-services:
-  web:
-    build:
-      context: .
-      target: dev
-    ports:
-      - "4567:4567"
-    volumes:
-      - .:/app
-    environment:
-      {}
-      # WEB_CONCURRENCY: 3
-    command:
-      - sleep
-      - infinity

kustomize/app/configmap.yaml

@@ -2,7 +2,7 @@
 apiVersion: v1
 kind: ConfigMap
 metadata:
-  name: kipunji-configmap
+  name: kubernaut-configmap
-  namespace: kipunji
+  namespace: kubernaut
 data:
-  KIPUNJI_CAT: kilwin
+  KUBERNAUT_CAT: kilwin

kustomize/app/deployment.yaml

@@ -1,49 +1,36 @@
 ---
-apiVersion: argoproj.io/v1alpha1
+apiVersion: apps/v1
-kind: Rollout
+kind: Deployment
 metadata:
-  name: kipunji
+  name: kubernaut
   annotations:
     reloader.stakater.com/auto: "true"
 spec:
-  replicas: 5
-  strategy:
-    canary:
-      steps:
-      - setWeight: 20
-      - pause: {}
-      - setWeight: 40
-      - pause: {duration: 10}
-      - setWeight: 60
-      - pause: {duration: 10}
-      - setWeight: 80
-      - pause: {duration: 10}
-  revisionHistoryLimit: 2
   selector:
     matchLabels:
-      app: kipunji
+      app: kubernaut
   template:
     metadata:
       labels:
-        app: kipunji
+        app: kubernaut
     spec:
       containers:
-        - name: kipunji
+        - name: kubernaut
-          image: git.kill0.net/ryanc/kipunji:latest
+          image: git.kill0.net/ryanc/kubernaut:0.1.4
           imagePullPolicy: Always
           ports:
-            - name: web
+            - name: sinatra-web
               containerPort: 4567
           env:
             - name: SESSION_SECRET
               valueFrom:
                 secretKeyRef:
-                  name: kipunji-session-secret
+                  name: kubernaut-session-secret
                   key: session_secret
                   optional: true
           envFrom:
             - configMapRef:
-                name: kipunji-configmap
+                name: kubernaut-configmap
           livenessProbe:
             httpGet:
               path: /livez

kustomize/app/hpa.yaml

@@ -0,0 +1,19 @@
+---
+apiVersion: autoscaling/v2
+kind: HorizontalPodAutoscaler
+metadata:
+  name: kubernaut
+spec:
+  scaleTargetRef:
+    apiVersion: apps/v1
+    kind: Deployment
+    name: kubernaut
+  minReplicas: 2
+  maxReplicas: 5
+  metrics:
+  - type: Resource
+    resource:
+      name: cpu
+      target:
+        type: Utilization
+        averageUtilization: 50

kustomize/app/ingress.yaml

@@ -1,16 +0,0 @@
----
-apiVersion: networking.k8s.io/v1
-kind: Ingress
-metadata:
-  name: kipunji-ingress
-spec:
-  rules:
-    - http:
-        paths:
-          - path: /
-            pathType: Prefix
-            backend:
-              service:
-                name: kipunji
-                port:
-                  name: web

kustomize/app/kustomization.yaml

@@ -1,10 +1,10 @@
 ---
 apiVersion: kustomize.config.k8s.io/v1beta1
 kind: Kustomization
-namespace: kipunji
+namespace: kubernaut
 resources:
   - secret.yaml
   - configmap.yaml
-  - rollout.yaml
+  - deployment.yaml
+  - hpa.yaml
   - services.yaml
-  - ingress.yaml

kustomize/app/secret.yaml

@@ -3,13 +3,13 @@ apiVersion: bitnami.com/v1alpha1
 kind: SealedSecret
 metadata:
   creationTimestamp: null
-  name: kipunji-session-secret
+  name: kubernaut-session-secret
-  namespace: kipunji
+  namespace: kubernaut
 spec:
   encryptedData:
     session_secret: AgCY08t0AU418znEZt5d252J+lH+fwYki2g6jdJpfdRfVQjnA+b52P0KWrs/x5pB0PKab6Z3JY/Tz0SQCaoIsCR4IzUO3a095aulRqb6Qr1Lz8udBVta4JJMZLmo26tuUfVHlpD1d6J8rkBSm8vzckFLkOA1Wfl/9rS3K4qwiDogA5pI0ULghFkeEx1yKdRwPq0k8PuvOvLUJ6oNq3e5n+B/BrVWdQ+7XQxUq/AMANJrDbe+RD33f99LArHYA7bFMbY8YRazXSTAkeunpTlxTjuGZKYvJKupo29LHz2OVbZVX/hI0nZkdVpcgqvbxF6Vw9CuCeAmtKYl7A3qsAWqDLUdP3hRLsk2P9RDNhEzYWh4ml8APzziWzihdJbGEjwLy7HsHgKslM0XbBnRQDlxp/JtvcWdjQp33A+QOON32zOKHi+qJjDYyGebS1+xkPbnyb1MPSJVAtFpj7dlLbFekLFDZEbXuJYUl1wKdFOIjJHmNK/MTEV2kOhtiVj/aeKgSXwor9hR7Uxzs5ZSawp9uWw+hpr58EX6I+RtfO4yjFC6FjnagiU6SlI1Q2F7/nv82g1UWTYMpNN5bduS1YFWmsnXvK+W7YQHpSForr5ndtCSHmclbXb5Fc33sywC5u6Bi2Gu5/MW6d73BOog5BC3QtOuEQ044Q+cuU3RIlKADBqKLzZmHlmukyyGuZfXJnGjlWGKp3J1KecucTo6XC9QHpUkjXEKdlE63mOI1VuOGyBIHl60v4bnWiBg+aDZVHipz4JLKsVB0HOgBBK7+tOX6tr1GDG/F7Nz/i9ebzUV6i8Ec1jHf+2ZcTtBkNXBIkHc84+4Qd33/gOuP+lizLfIhfQ3DFWbwyfYumpVbeapyYhB0CE=
   template:
     metadata:
       creationTimestamp: null
-      name: kipunji-session-secret
+      name: kubernaut-session-secret
-      namespace: kipunji
+      namespace: kubernaut

kustomize/app/services.yaml

@@ -2,12 +2,11 @@
 apiVersion: v1
 kind: Service
 metadata:
-  name: kipunji
+  name: kubernaut
-
 spec:
   ports:
     - name: web
       port: 80
-      targetPort: web
+      targetPort: sinatra-web
   selector:
-    app: kipunji
+    app: kubernaut

kustomize/kustomization.yaml

@@ -2,8 +2,7 @@
 apiVersion: kustomize.config.k8s.io/v1beta1
 kind: Kustomization
 metadata:
-  name: kipunji
+  name: kubernaut
-namespace: kipunji
 resources:
   - namespace.yaml
   - ./app

kustomize/memcached/deployment.yaml

@@ -2,19 +2,19 @@
 kind: Deployment
 apiVersion: apps/v1
 metadata:
-  name: kipunji-memcached
+  name: kubernaut-memcached
 
 spec:
   selector:
     matchLabels:
-      app: kipunji-memcached
+      app: kubernaut-memcached
   template:
     metadata:
       labels:
-        app: kipunji-memcached
+        app: kubernaut-memcached
     spec:
       containers:
-        - name: kipunji-memcached
+        - name: kubernaut-memcached
           image: memcached:latest
           ports:
             - name: memcached

kustomize/memcached/kustomization.yaml

@@ -1,7 +1,7 @@
 ---
 apiVersion: kustomize.config.k8s.io/v1beta1
 kind: Kustomization
-namespace: kipunji
+namespace: kubernaut
 resources:
   - deployment.yaml
   - services.yaml

kustomize/memcached/services.yaml

@@ -2,7 +2,7 @@
 apiVersion: v1
 kind: Service
 metadata:
-  name: kipunji-memcached
+  name: kubernaut-memcached
 
 spec:
   ports:
@@ -10,4 +10,4 @@ spec:
       port: 11211
       targetPort: memcached
   selector:
-    app: kipunji-memcached
+    app: kubernaut-memcached

kustomize/namespace.yaml

@@ -2,5 +2,6 @@
 apiVersion: v1
 kind: Namespace
 metadata:
-  name: kipunji
+  name: kubernaut
+  labels: {}
 

lib/config.rb

@@ -0,0 +1,49 @@
+require "sensitive"
+
+class Config
+  attr_accessor :cat
+
+  attr_reader :jwt_secret, :session_secret
+
+  def initialize(prefix = ENV_PREFIX, jwt_secret = nil, session_secret = nil, cat = nil)
+    @prefix = prefix
+    @cat = cat
+
+    session_secret ||= ENV.fetch "SESSION_SECRET" do
+      SecureRandom.hex SESSION_SECRET_HEX_LENGTH
+    end
+
+    jwt_secret ||= fetch_env "JWT_SECRET" do
+      SecureRandom.hex JWT_SECRET_HEX_LENGTH
+    end
+
+    @session_secret = Sensitive.new session_secret
+    @jwt_secret = Sensitive.new jwt_secret
+    @cat ||= ENV.fetch "#{@prefix}_CAT", nil
+  end
+
+  def fetch_env(name, &)
+    ENV.fetch "#{@prefix}_#{name}", &
+  end
+
+  def as_json(options = nil)
+    {jwt_secret: jwt_secret, session_secret: @session_secret, cat: @cat}
+  end
+
+  def to_json(options = nil)
+    if options&.key?(:pretty) &&
+        options[:pretty] == true
+      JSON.pretty_generate as_json(options)
+    else
+      JSON.generate as_json(options)
+    end
+  end
+
+  def session_secret=(v)
+    @session_secret = Sensitive.new v
+  end
+
+  def jwt_secret=(v)
+    @jwt_secret = Sensitive.new v
+  end
+end

lib/sensitive.rb

@@ -0,0 +1,39 @@
+class Sensitive
+  alias_method :eql?, :==
+  alias_method :equal?, :==
+
+  def initialize(v, ch: "*", head: 2, tail: 2)
+    @v = v
+    @ch = ch
+    @head = head
+    @tail = tail
+  end
+
+  def mask(v)
+    +"".concat(v[0, @head], @ch * (v.length - (@head + @tail)), v[-@tail, @tail])
+  end
+
+  def unwrap
+    @v
+  end
+
+  def length
+    @v.length
+  end
+
+  def to_s
+    mask @v
+  end
+
+  def inspect
+    "#<#{self.class.name} @v=#{wrap}>"
+  end
+
+  def hash
+    @v.hash
+  end
+
+  def ==(other)
+    other.is_a?(Sensitive) && other.hash == hash
+  end
+end

sig/app.rbs

@@ -1,63 +0,0 @@
-module State
-  def enable: () -> untyped
-
-  def disable: () -> (untyped | nil)
-
-  def enabled?: () -> bool
-
-  def toggle: () -> untyped
-end
-
-module UpDown
-  def up: () -> untyped
-
-  def down: () -> untyped
-
-  def to_s: () -> ("up" | "down")
-
-  def to_json: (*untyped _args) -> (nil | untyped)
-end
-
-class Health
-  @file: untyped
-
-  include Singleton
-
-  include State
-
-  include UpDown
-
-  def initialize: () -> void
-
-  def healthy?: () -> bool
-end
-
-class Ready
-  @file: untyped
-
-  include Singleton
-
-  include State
-
-  include UpDown
-
-  def initialize: () -> void
-
-  def ready?: () -> bool
-end
-
-class Sleep
-  @file: untyped
-
-  include Singleton
-
-  include State
-
-  def initialize: () -> void
-
-  def asleep?: () -> bool
-
-  def wake: () -> untyped
-
-  def sleep: () -> untyped
-end

test/test_sensitive.rb

@@ -0,0 +1,26 @@
+require "minitest/autorun"
+
+$LOAD_PATH.unshift File.dirname(__FILE__) + "/../lib"
+
+require "sensitive"
+
+ALPHABET = ("a".."z").reduce(:concat)
+
+class TestSensitive < Minitest::Test
+  def setup
+    @s = Sensitive.new ALPHABET
+  end
+
+  def test_initialize
+    assert_equal @s.to_s, "ab" + "*" * 22 + "yz"
+  end
+
+  def test_unwrap
+    assert_equal @s.unwrap, ALPHABET
+  end
+
+  def test_using_a_different_mask_character
+    s = Sensitive.new ALPHABET, ch: "x"
+    assert_equal s.to_s, "ab" + "x" * 22 + "yz"
+  end
+end