39 Commits

Author SHA1 Message Date
9bd8d0c131 all actions should use ruby 3.4
All checks were successful
Gitea Actions Demo / lint (push) Successful in 2m13s
Gitea Actions Demo / test (push) Successful in 2m17s
Gitea Actions Demo / docker (push) Successful in 1m31s
2025-03-30 17:52:00 -05:00
c2c1672802 add docker/metadata-action 2025-03-30 17:51:24 -05:00
af87ba5ed1 devcontainer: enable accessing host Docker socket
All checks were successful
Gitea Actions Demo / lint (push) Successful in 2m29s
Gitea Actions Demo / test (push) Successful in 2m20s
Gitea Actions Demo / release-image (push) Successful in 2m12s
2025-03-30 15:58:41 -05:00
af9f89a7f5 add hostname helper
All checks were successful
Gitea Actions Demo / lint (push) Successful in 29s
Gitea Actions Demo / test (push) Successful in 34s
Gitea Actions Demo / release-image (push) Has been skipped
2025-03-25 20:00:37 -05:00
6f84053124 devcontainer: remove /run directory creation 2025-03-25 19:58:51 -05:00
9c55277924 set the application name 2025-03-25 19:57:30 -05:00
2b7b338742 added /_cat/pid
All checks were successful
Gitea Actions Demo / lint (push) Successful in 26s
Gitea Actions Demo / test (push) Successful in 15s
Gitea Actions Demo / release-image (push) Has been skipped
2025-03-25 18:49:49 -05:00
312e570a02 add /_cat to list all of the other /_cat sub-endpoints 2025-03-25 18:48:25 -05:00
d6b1ed1046 remove unneccessary .gitignore patterns
All checks were successful
Gitea Actions Demo / lint (push) Successful in 21s
Gitea Actions Demo / test (push) Successful in 20s
Gitea Actions Demo / release-image (push) Has been skipped
2025-03-24 15:07:40 -05:00
768a58849d configure VS Code workspace to use Standard Ruby 2025-03-24 15:07:40 -05:00
54bc100d2a upgrade to bundler 2.6.6 2025-03-24 15:07:40 -05:00
c2b00f2c3e remove rubocop 2025-03-24 15:07:40 -05:00
a580e78d81 add devcontainer 2025-03-24 15:07:40 -05:00
8acc46c08d create a new method for inferring the PPID 2025-03-24 15:04:01 -05:00
8b094d64b1 add ?flakey=pct param to make the app return 500 errors intermittently
All checks were successful
Gitea Actions Demo / lint (push) Successful in 28s
Gitea Actions Demo / test (push) Successful in 16s
Gitea Actions Demo / release-image (push) Has been skipped
2025-03-14 19:14:56 -05:00
e1f29b555c store status files in /dev/shm
All checks were successful
Gitea Actions Demo / lint (push) Successful in 20s
Gitea Actions Demo / test (push) Successful in 15s
Gitea Actions Demo / release-image (push) Successful in 1m53s
2025-03-12 17:36:14 -05:00
8b69fb745a add an internal fallback URL for CaaS
All checks were successful
Gitea Actions Demo / lint (push) Successful in 27s
Gitea Actions Demo / test (push) Successful in 19s
Gitea Actions Demo / release-image (push) Has been skipped
2025-03-12 17:19:21 -05:00
9c8371e067 change /kitty to /meow 2025-03-12 17:18:41 -05:00
64941e86f0 only build container for the main branch
All checks were successful
Gitea Actions Demo / lint (push) Successful in 18s
Gitea Actions Demo / test (push) Successful in 21s
Gitea Actions Demo / release-image (push) Successful in 1m44s
2025-03-11 05:09:22 -05:00
38f92507f6 run tests with rake 2025-03-11 05:09:22 -05:00
70cd5d6247 fix frozen string literal warning 2025-03-11 05:07:43 -05:00
45862025cf add Rakefile 2025-03-11 04:53:38 -05:00
9a19b6bae0 clean up temporary files
All checks were successful
Gitea Actions Demo / lint (push) Successful in 23s
Gitea Actions Demo / test (push) Successful in 13s
Gitea Actions Demo / release-image (push) Successful in 1m44s
2025-03-11 00:49:19 -05:00
e72f4fb8fd modify HPA to have min 2 and max 5 replicas
All checks were successful
Gitea Actions Demo / lint (push) Successful in 23s
Gitea Actions Demo / test (push) Successful in 13s
Gitea Actions Demo / release-image (push) Successful in 1m52s
2025-03-11 00:03:50 -05:00
61c3acf9b2 add HPA to Kubernetes deployment
All checks were successful
Gitea Actions Demo / lint (push) Successful in 25s
Gitea Actions Demo / test (push) Successful in 13s
Gitea Actions Demo / release-image (push) Successful in 1m56s
2025-03-10 23:50:17 -05:00
9869e98346 stream caas file in chunks
All checks were successful
Gitea Actions Demo / lint (push) Successful in 25s
Gitea Actions Demo / test (push) Successful in 13s
Gitea Actions Demo / release-image (push) Successful in 1m51s
2025-03-10 23:31:24 -05:00
b247971b7e write CaaS cat as a temporary file
All checks were successful
Gitea Actions Demo / lint (push) Successful in 26s
Gitea Actions Demo / test (push) Successful in 14s
Gitea Actions Demo / release-image (push) Successful in 1m57s
this will make it eaiser to set the content-type correctly
2025-03-10 14:55:53 -05:00
54a3de77e2 add /kitty route to get a cat picture from CaaS
All checks were successful
Gitea Actions Demo / lint (push) Successful in 19s
Gitea Actions Demo / test (push) Successful in 18s
Gitea Actions Demo / release-image (push) Successful in 2m7s
2025-03-09 20:55:52 -05:00
62f204fa8b remove broken sensitive spec
All checks were successful
Gitea Actions Demo / lint (push) Successful in 22s
Gitea Actions Demo / test (push) Successful in 17s
Gitea Actions Demo / release-image (push) Successful in 1m39s
2025-03-09 17:49:38 -05:00
5beda31095 fix missing require
Some checks failed
Gitea Actions Demo / lint (push) Successful in 22s
Gitea Actions Demo / test (push) Failing after 2m26s
Gitea Actions Demo / release-image (push) Has been skipped
2025-03-09 17:43:44 -05:00
b25bf0445e test with ruby 3.4 2025-03-09 17:43:34 -05:00
ba740c330a add minitest
Some checks failed
Gitea Actions Demo / lint (push) Successful in 23s
Gitea Actions Demo / test (push) Failing after 15s
Gitea Actions Demo / release-image (push) Has been skipped
2025-03-09 16:25:16 -05:00
5c2c7ec3b7 fix lint errors
Some checks failed
Gitea Actions Demo / lint (push) Successful in 2m12s
Gitea Actions Demo / test (push) Failing after 2m4s
Gitea Actions Demo / release-image (push) Has been skipped
2025-03-09 16:12:50 -05:00
93e86e0f17 update gems
Some checks failed
Gitea Actions Demo / lint (push) Failing after 2m40s
Gitea Actions Demo / test (push) Has been skipped
Gitea Actions Demo / release-image (push) Has been skipped
2025-03-09 16:02:57 -05:00
c66d4676e3 rename project to Kubernaut
Some checks failed
Gitea Actions Demo / lint (push) Failing after 2m8s
Gitea Actions Demo / test (push) Has been skipped
Gitea Actions Demo / release-image (push) Has been skipped
2025-03-09 15:46:29 -05:00
a93cab4de5 remove namespace from kustomization
Some checks failed
Gitea Actions Demo / lint (push) Failing after 2m2s
Gitea Actions Demo / test (push) Has been skipped
Gitea Actions Demo / release-image (push) Has been skipped
2025-03-09 15:38:57 -05:00
b2e4fcbce1 add route to test chunked encoding 2025-03-09 15:38:34 -05:00
86ba2e6c1a add route to dump bytes
Some checks failed
Gitea Actions Demo / lint (push) Failing after 2m11s
Gitea Actions Demo / test (push) Has been skipped
Gitea Actions Demo / release-image (push) Has been skipped
2025-03-09 15:36:49 -05:00
3a78bf5d03 add routes to dump configuration 2025-03-09 15:36:07 -05:00
32 changed files with 402 additions and 241 deletions

2
.devcontainer/Dockerfile Normal file
View File

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

4
.devcontainer/boot.sh Executable file
View File

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

12
.devcontainer/compose.yml Normal file
View File

@ -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

View File

@ -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": {}
}
}

View File

@ -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
@ -35,13 +44,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
release-image:
docker:
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
tags: git.kill0.net/ryanc/kipunji:latest
push: ${{ github.event_name != 'pull_request' }}
tags: ${{ steps.meta.outputs.tags }}
labels: ${{ steps.meta.outputs.labels }}

4
.gitignore vendored
View File

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

9
.vscode/settings.json vendored Normal file
View File

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

View File

@ -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

View File

@ -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

View File

@ -2,115 +2,127 @@ 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)
json (2.7.2)
jwt (2.8.2)
bigdecimal (3.1.8)
csv (3.3.0)
diff-lcs (1.6.0)
httparty (0.22.0)
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.6.6)
mini_mime (1.1.5)
minitest (5.25.4)
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)
parallel (1.25.1)
parser (3.3.3.0)
nio4r (2.7.4)
parallel (1.26.3)
parser (3.3.7.2)
ast (~> 2.4.1)
racc
prism (0.30.0)
puma (6.4.2)
prism (1.3.0)
puma (6.6.0)
nio4r (~> 2.0)
racc (1.8.0)
rack (3.1.3)
rack-protection (4.0.0)
racc (1.8.1)
rack (3.1.11)
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.8.1)
logger
regexp_parser (2.9.2)
rexml (3.3.0)
strscan
regexp_parser (2.10.0)
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)
rubocop (1.64.1)
rspec-support (3.13.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)
regexp_parser (>= 1.8, < 3.0)
rexml (>= 3.2.5, < 4.0)
rubocop-ast (>= 1.31.1, < 2.0)
regexp_parser (>= 2.9.3, < 3.0)
rubocop-ast (>= 1.38.0, < 2.0)
ruby-progressbar (~> 1.7)
unicode-display_width (>= 2.4.0, < 3.0)
rubocop-ast (1.31.3)
parser (>= 3.3.1.0)
rubocop-performance (1.21.1)
rubocop (>= 1.48.1, < 2.0)
rubocop-ast (>= 1.31.1, < 2.0)
ruby-lsp (0.17.3)
unicode-display_width (>= 2.4.0, < 4.0)
rubocop-ast (1.41.0)
parser (>= 3.3.7.2)
rubocop-performance (1.24.0)
lint_roller (~> 1.1)
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 (>= 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)
sinatra (= 4.0.0)
rack-protection (= 4.1.1)
sinatra (= 4.1.1)
tilt (~> 2.0)
sorbet-runtime (0.5.11435)
standard (1.39.1)
sorbet-runtime (0.5.11911)
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)
strscan (3.1.0)
tilt (2.3.0)
rubocop-performance (~> 1.24.0)
tilt (2.6.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.6.15)
zeitwerk (2.7.2)
PLATFORMS
ruby
@ -118,15 +130,16 @@ PLATFORMS
DEPENDENCIES
anyflake
httparty
jwt
ksuid
minitest
nanoid
puma
rack-test
rackup
rbs
rake
rspec
rubocop
ruby-lsp
sinatra
sinatra-contrib
@ -135,4 +148,4 @@ DEPENDENCIES
uuid7
BUNDLED WITH
2.5.13
2.6.6

11
Rakefile Normal file
View File

@ -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]

200
app.rb
View File

@ -5,6 +5,7 @@ require "sinatra/multi_route"
require "time"
require "fileutils"
require "json"
require "singleton"
require "securerandom"
require "random/formatter"
@ -13,17 +14,21 @@ require "anyflake"
require "jwt"
require "httparty"
$LOAD_PATH.unshift File.dirname(__FILE__) + "/lib"
require "config"
CHUNK_SIZE = 1024**2
SESSION_SECRET_HEX_LENGTH = 64
JWT_SECRET_HEX_LENGTH = 64
DEFAULT_FLAKEY = 50
ENV_PREFIX = "KIPUNJI"
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
@ -46,6 +51,7 @@ DURATION_PARTS = [
config = Config.new
set :session_secret, config.session_secret.unwrap
set :public_folder, __dir__ + "/static"
module Sinatra
module RequestHeadersHelper
@ -103,7 +109,7 @@ end
class TickTock
def initialize
@pid = master_pid
@pid = ppid
@procfs_f = format "/proc/%s/stat", @pid
puts @pid
end
@ -129,7 +135,7 @@ class Health
include UpDown
def initialize
@file = "./healthy"
@file = "/dev/shm/healthy"
end
def healthy?
@ -143,7 +149,7 @@ class Ready
include UpDown
def initialize
@file = "./ready"
@file = "/dev/shm/ready"
end
def ready?
@ -156,7 +162,7 @@ class Sleep
include State
def initialize
@file = "./sleep"
@file = "/dev/shm/sleep"
end
def asleep?
@ -172,9 +178,22 @@ class Sleep
end
end
def master_pid
pid_s = File.read PID_FILE_PATH
Integer pid_s.strip
def ppid
pid = Process.pid
# 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
@ -202,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
@ -213,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
@ -243,6 +280,10 @@ helpers do
@auth.credentials and
@auth.credentials == ["qwer", "asdf"]
end
def hostname
ENV["HOSTNAME"]
end
end
get "/" do
@ -326,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
@ -375,6 +416,26 @@ get "/cookies" do
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
stream do |out|
req_headers.each do |k, v|
@ -399,6 +460,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])
@ -406,11 +490,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|
out << jsonify({id: i, message: (i % 2).zero? ? "tick" : "tock"})
sleep delay
out << "Hello, world!\n"
end
end
end
@ -425,3 +512,88 @@ route :delete, :get, :patch, :post, :put, "/auth/basic", provides: "json" do
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

View File

@ -1,3 +0,0 @@
# workers 3
pidfile "/run/app/pid"
preload_app!

View File

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

View File

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

View File

@ -2,22 +2,21 @@
apiVersion: apps/v1
kind: Deployment
metadata:
name: kipunji
name: kubernaut
annotations:
reloader.stakater.com/auto: "true"
spec:
replicas: 5
selector:
matchLabels:
app: kipunji
app: kubernaut
template:
metadata:
labels:
app: kipunji
app: kubernaut
spec:
containers:
- name: kipunji
image: git.kill0.net/ryanc/kipunji:latest
- name: kubernaut
image: git.kill0.net/ryanc/kubernaut:latest
imagePullPolicy: Always
ports:
- name: sinatra-web
@ -26,12 +25,12 @@ spec:
- 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

19
kustomize/app/hpa.yaml Normal file
View File

@ -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

View File

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

View File

@ -3,13 +3,13 @@ apiVersion: bitnami.com/v1alpha1
kind: SealedSecret
metadata:
creationTimestamp: null
name: kipunji-session-secret
namespace: kipunji
name: kubernaut-session-secret
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
namespace: kipunji
name: kubernaut-session-secret
namespace: kubernaut

View File

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

View File

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

View File

@ -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

View File

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

View File

@ -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

View File

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

View File

@ -31,8 +31,7 @@ class Config
end
def to_json(options = nil)
if options &&
options.key?(:pretty) &&
if options&.key?(:pretty) &&
options[:pretty] == true
JSON.pretty_generate as_json(options)
else

View File

@ -10,7 +10,7 @@ class Sensitive
end
def mask(v)
"".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

View File

@ -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

View File

@ -1,26 +0,0 @@
require "minitest/autorun"
$LOAD_PATH.unshift File.dirname(__FILE__) + "/../lib"
require "sensitive"
ALPHABET = ('a' .. 'z').reduce(:concat)
describe "Sensitive" do
before do
@s = Sensitive.new ALPHABET
end
it "test initialize" do
_(@s.to_s).must_equal "ab" + "*" * 22 + "yz"
end
it "test initialize" do
_(@s.unwrap).must_equal ALPHABET
end
it "test using different mask character" do
s = Sensitive.new ALPHABET, ch: "x"
_(s.to_s).must_equal "x"
end
end

BIN
static/cat-1.jpg Normal file

Binary file not shown.

After

Width:  |  Height:  |  Size: 47 KiB

BIN
static/cat-2.jpg Normal file

Binary file not shown.

After

Width:  |  Height:  |  Size: 626 KiB

BIN
static/cat-3.jpg Normal file

Binary file not shown.

After

Width:  |  Height:  |  Size: 156 KiB