all actions should use ruby 3.4

.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:
@@ -16,7 +25,7 @@ jobs:
       - name: Ruby Setup
         uses: ruby/setup-ruby@v1
         with:
-          ruby-version: '3.3'
+          ruby-version: '3.4'
           bundler-cache: true
 
       - run: bundle install
@@ -38,10 +47,9 @@ jobs:
           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:
@@ -55,6 +63,21 @@ jobs:
         with:
           fetch-depth: 0 # all history for all branches and tags
 
+      - 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 +91,6 @@ 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/kubernaut:latest
+          tags: ${{ steps.meta.outputs.tags }}
+          labels: ${{ steps.meta.outputs.labels }}

.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

@@ -16,8 +16,6 @@ gem "httparty"
 
 group :development do
   gem "ruby-lsp"
-  gem "rubocop"
-  gem "rbs"
   gem "rack-test"
   gem "rspec"
   gem "standard"

Gemfile.lock

@@ -2,7 +2,7 @@ GEM
   remote: https://rubygems.org/
   specs:
     anyflake (0.0.1)
-    ast (2.4.2)
+    ast (2.4.3)
     base64 (0.2.0)
     bigdecimal (3.1.8)
     csv (3.3.0)
@@ -11,7 +11,7 @@ GEM
       csv
       mini_mime (>= 1.0.0)
       multi_xml (>= 0.5.2)
-    json (2.10.1)
+    json (2.10.2)
     jwt (2.10.1)
       base64
     ksuid (1.0.0)
@@ -28,7 +28,7 @@ GEM
     nanoid (2.0.0)
     nio4r (2.7.4)
     parallel (1.26.3)
-    parser (3.3.7.1)
+    parser (3.3.7.2)
       ast (~> 2.4.1)
       racc
     prism (1.3.0)
@@ -65,9 +65,10 @@ GEM
       diff-lcs (>= 1.2.0, < 2.0)
       rspec-support (~> 3.13.0)
     rspec-support (3.13.2)
-    rubocop (1.71.2)
+    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)
@@ -75,11 +76,12 @@ GEM
       rubocop-ast (>= 1.38.0, < 2.0)
       ruby-progressbar (~> 1.7)
       unicode-display_width (>= 2.4.0, < 4.0)
-    rubocop-ast (1.38.1)
+    rubocop-ast (1.41.0)
-      parser (>= 3.3.1.0)
+      parser (>= 3.3.7.2)
-    rubocop-performance (1.23.1)
+    rubocop-performance (1.24.0)
-      rubocop (>= 1.48.1, < 2.0)
+      lint_roller (~> 1.1)
-      rubocop-ast (>= 1.31.1, < 2.0)
+      rubocop (>= 1.72.1, < 2.0)
+      rubocop-ast (>= 1.38.0, < 2.0)
     ruby-lsp (0.23.11)
       language_server-protocol (~> 3.17.0)
       prism (>= 1.2, < 2.0)
@@ -101,18 +103,18 @@ GEM
       sinatra (= 4.1.1)
       tilt (~> 2.0)
     sorbet-runtime (0.5.11911)
-    standard (1.45.0)
+    standard (1.47.0)
       language_server-protocol (~> 3.17.0.2)
       lint_roller (~> 1.0)
-      rubocop (~> 1.71.0)
+      rubocop (~> 1.73.0)
       standard-custom (~> 1.0.0)
-      standard-performance (~> 1.6)
+      standard-performance (~> 1.7)
     standard-custom (1.0.2)
       lint_roller (~> 1.0)
       rubocop (~> 1.50)
-    standard-performance (1.6.0)
+    standard-performance (1.7.0)
       lint_roller (~> 1.1)
-      rubocop-performance (~> 1.23.0)
+      rubocop-performance (~> 1.24.0)
     tilt (2.6.0)
     ulid (1.4.0)
     unicode-display_width (3.1.4)
@@ -137,9 +139,7 @@ DEPENDENCIES
   rack-test
   rackup
   rake
-  rbs
   rspec
-  rubocop
   ruby-lsp
   sinatra
   sinatra-contrib
@@ -148,4 +148,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

@@ -23,11 +23,12 @@ require "config"
 CHUNK_SIZE = 1024**2
 SESSION_SECRET_HEX_LENGTH = 64
 JWT_SECRET_HEX_LENGTH = 64
+DEFAULT_FLAKEY = 50
 
-ENV_PREFIX = "KUBERNAUT"
+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
@@ -50,6 +51,7 @@ DURATION_PARTS = [
 config = Config.new
 
 set :session_secret, config.session_secret.unwrap
+set :public_folder, __dir__ + "/static"
 
 module Sinatra
   module RequestHeadersHelper
@@ -107,7 +109,7 @@ end
 
 class TickTock
   def initialize
-    @pid = master_pid
+    @pid = ppid
     @procfs_f = format "/proc/%s/stat", @pid
     puts @pid
   end
@@ -133,7 +135,7 @@ class Health
   include UpDown
 
   def initialize
-    @file = "./healthy"
+    @file = "/dev/shm/healthy"
   end
 
   def healthy?
@@ -147,7 +149,7 @@ class Ready
   include UpDown
 
   def initialize
-    @file = "./ready"
+    @file = "/dev/shm/ready"
   end
 
   def ready?
@@ -160,7 +162,7 @@ class Sleep
   include State
 
   def initialize
-    @file = "./sleep"
+    @file = "/dev/shm/sleep"
   end
 
   def asleep?
@@ -176,9 +178,22 @@ class Sleep
   end
 end
 
-def master_pid
+def ppid
-  pid_s = File.read PID_FILE_PATH
+  pid = Process.pid
-  Integer pid_s.strip
+  # self
+  ps = File.open "/proc/#{pid}/stat", &:readline
+  ps = ps.split(" ")
+  ppid = Integer(ps[3])
+
+  # ppid
+  ps = File.open "/proc/#{ppid}/stat", &:readline
+  ps = ps.split(" ")
+
+  if ps[1].include? "ruby"
+    ppid
+  else
+    pid
+  end
 end
 
 def system_uptime
@@ -206,6 +221,13 @@ 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
 
 configure do
@@ -217,6 +239,17 @@ 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
@@ -247,6 +280,10 @@ helpers do
       @auth.credentials and
       @auth.credentials == ["qwer", "asdf"]
   end
+
+  def hostname
+    ENV["HOSTNAME"]
+  end
 end
 
 get "/" do
@@ -330,19 +367,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
   pretty = params.key? :pretty
 
-  jsonify({puma: master_pid, pid: Process.pid}, pretty:)
+  jsonify({ppid: ppid, pid: Process.pid}, pretty:)
 end
 
 get "/token" do
@@ -385,6 +422,20 @@ get "/config", provides: "json" do
   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
   stream do |out|
     req_headers.each do |k, v|
@@ -424,6 +475,14 @@ get "/_cat/config" do
   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])
@@ -499,13 +558,16 @@ get "/bytes/:size" do
   generate_bytes(Integer(n))
 end
 
-get "/kitty" do
+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
-    # fail-safe url
+    url = url("/api/caas")
-    url = "https://i.imgur.com/epzPw7L.jpeg"
   end
   tmp_file = Tempfile.open binmode: true do |f|
     # f.chmod 0o644

config/puma.rb

@@ -1,3 +0,0 @@
-# workers 3
-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

lib/sensitive.rb

@@ -10,7 +10,7 @@ class Sensitive
   end
 
   def mask(v)
-    String.new.concat(v[0, @head], @ch * (v.length - (@head + @tail)), v[-@tail, @tail])
+    +"".concat(v[0, @head], @ch * (v.length - (@head + @tail)), v[-@tail, @tail])
   end
 
   def unwrap

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