2 Commits

Author SHA1 Message Date
784671b0cc Merge branch 'develop'
Some checks failed
Gitea Actions Demo / test (push) Blocked by required conditions
Gitea Actions Demo / release-image (push) Blocked by required conditions
Gitea Actions Demo / lint (push) Has been cancelled
2025-03-04 10:30:31 -06:00
7250aaa43e remove ingress
All checks were successful
Gitea Actions Demo / lint (push) Successful in 2m58s
Gitea Actions Demo / test (push) Successful in 2m13s
Gitea Actions Demo / release-image (push) Successful in 4m41s
2025-03-04 10:29:50 -06:00
44 changed files with 224 additions and 1030 deletions

View File

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

View File

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

View File

@ -1,12 +0,0 @@
---
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

@ -1,20 +0,0 @@
{
"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,16 +1,7 @@
--- ---
name: Gitea Actions Demo name: Gitea Actions Demo
run-name: ${{ gitea.actor }} is testing out Gitea Actions 🚀 run-name: ${{ gitea.actor }} is testing out Gitea Actions 🚀
on: [push]
on:
schedule:
- cron: "0 10 * * *"
push:
branches:
- "**"
tags:
- "v*.*.*"
pull_request:
jobs: jobs:
lint: lint:
@ -19,19 +10,13 @@ jobs:
checks: write checks: write
contents: write contents: write
steps: steps:
- name: Login to Docker
uses: docker/login-action@v3
with:
username: ${{ vars.DOCKERHUB_USERNAME }}
password: ${{ secrets.DOCKERHUB_TOKEN }}
- name: Checkout - name: Checkout
uses: actions/checkout@v4 uses: actions/checkout@v4
- name: Ruby Setup - name: Ruby Setup
uses: ruby/setup-ruby@v1 uses: ruby/setup-ruby@v1
with: with:
ruby-version: '3.4' ruby-version: '3.3'
bundler-cache: true bundler-cache: true
- run: bundle install - run: bundle install
@ -50,12 +35,13 @@ jobs:
- name: Test - name: Test
uses: ruby/setup-ruby@v1 uses: ruby/setup-ruby@v1
with: with:
ruby-version: '3.4' ruby-version: '3.3'
bundler-cache: true bundler-cache: true
- run: bundle exec rake - run: bundle exec rspec
docker:
release-image:
needs: test needs: test
runs-on: ubuntu-latest runs-on: ubuntu-latest
container: container:
@ -63,41 +49,12 @@ jobs:
env: env:
DOCKER_ORG: ryanc DOCKER_ORG: ryanc
DOCKER_LATEST: latest DOCKER_LATEST: latest
defaults:
run:
shell: bash
steps: steps:
- name: Checkout - name: Checkout
uses: actions/checkout@v4 uses: actions/checkout@v4
with: with:
fetch-depth: 0 # all history for all branches and tags 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 - name: Set up Docker Buildx
uses: docker/setup-buildx-action@v3 uses: docker/setup-buildx-action@v3
@ -111,17 +68,5 @@ jobs:
- name: Docker build and push - name: Docker build and push
uses: docker/build-push-action@v5 uses: docker/build-push-action@v5
with: with:
push: ${{ github.event_name != 'pull_request' }} push: true
tags: ${{ steps.meta.outputs.tags }} tags: git.kill0.net/ryanc/kipunji:latest
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

4
.gitignore vendored
View File

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

View File

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

View File

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

View File

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

View File

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

View File

@ -1,11 +0,0 @@
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]

240
app.rb
View File

@ -5,7 +5,6 @@ require "sinatra/multi_route"
require "time" require "time"
require "fileutils" require "fileutils"
require "json" require "json"
require "singleton"
require "securerandom" require "securerandom"
require "random/formatter" require "random/formatter"
@ -14,23 +13,12 @@ require "anyflake"
require "jwt" require "jwt"
require "httparty"
$LOAD_PATH.unshift File.dirname(__FILE__) + "/lib"
require "config"
VERSION = "0.1.2"
CHUNK_SIZE = 1024**2
SESSION_SECRET_HEX_LENGTH = 64 SESSION_SECRET_HEX_LENGTH = 64
JWT_SECRET_HEX_LENGTH = 64
DEFAULT_FLAKEY = 50
NAME = "kubernaut".freeze set :session_secret, ENV.fetch("SESSION_SECRET") { SecureRandom.hex(SESSION_SECRET_HEX_LENGTH) }
ENV_PREFIX = NAME.upcase
CLK_TCK = 100 CLK_TCK = 100
PID_FILE_PATH = "/run/app/pid".freeze
PROC_UPTIME_PATH = "/proc/uptime".freeze PROC_UPTIME_PATH = "/proc/uptime".freeze
SECONDS_PER_YEAR = 31_556_952 SECONDS_PER_YEAR = 31_556_952
@ -50,10 +38,7 @@ DURATION_PARTS = [
[1, "second", "s"] [1, "second", "s"]
].freeze ].freeze
config = Config.new JWT_SECRET = SecureRandom.bytes(64).freeze
set :session_secret, config.session_secret.unwrap
set :public_folder, __dir__ + "/static"
module Sinatra module Sinatra
module RequestHeadersHelper module RequestHeadersHelper
@ -111,7 +96,7 @@ end
class TickTock class TickTock
def initialize def initialize
@pid = ppid @pid = master_pid
@procfs_f = format "/proc/%s/stat", @pid @procfs_f = format "/proc/%s/stat", @pid
puts @pid puts @pid
end end
@ -137,7 +122,7 @@ class Health
include UpDown include UpDown
def initialize def initialize
@file = "/dev/shm/healthy" @file = "./healthy"
end end
def healthy? def healthy?
@ -151,7 +136,7 @@ class Ready
include UpDown include UpDown
def initialize def initialize
@file = "/dev/shm/ready" @file = "./ready"
end end
def ready? def ready?
@ -164,7 +149,7 @@ class Sleep
include State include State
def initialize def initialize
@file = "/dev/shm/sleep" @file = "./sleep"
end end
def asleep? def asleep?
@ -180,22 +165,9 @@ class Sleep
end end
end end
def ppid def master_pid
pid = Process.pid pid_s = File.read PID_FILE_PATH
# self Integer pid_s.strip
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 end
def system_uptime def system_uptime
@ -223,19 +195,8 @@ Health.instance.up
Ready.instance.up Ready.instance.up
Sleep.instance.wake 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 enable :sessions
on_start do
puts "#{NAME} #{VERSION} staring, per aspera ad astra"
end
configure do configure do
mime_type :json, "application/json" mime_type :json, "application/json"
end end
@ -245,27 +206,15 @@ before do
sleep(1) while Sleep.instance.asleep? && request.path_info != "/livez/sleep" sleep(1) while Sleep.instance.asleep? && request.path_info != "/livez/sleep"
content_type :text if request.path_info.start_with? "/_cat" content_type :text if request.path_info.start_with? "/_cat"
request.session_options[:skip] = !request.path_info.start_with?("/session") 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 end
helpers do helpers do
def jsonify(obj, opts: nil, pretty: false) def json(obj, opts: nil, pretty: false)
buf = if pretty if pretty
JSON.pretty_generate obj, opts: JSON.pretty_generate obj, opts:
else else
JSON.generate(obj, opts:) JSON.generate(obj, opts:)
end end
"#{buf}\n"
end end
def protected! hidden = false def protected! hidden = false
@ -286,10 +235,6 @@ helpers do
@auth.credentials and @auth.credentials and
@auth.credentials == ["qwer", "asdf"] @auth.credentials == ["qwer", "asdf"]
end end
def hostname
ENV["HOSTNAME"]
end
end end
get "/" do get "/" do
@ -299,14 +244,14 @@ end
get "/env", provides: "json" do get "/env", provides: "json" do
pretty = params.key? :pretty pretty = params.key? :pretty
jsonify ENV.sort.to_h, pretty: json ENV.sort.to_h, pretty:
end end
get "/headers", provides: "json" do get "/headers", provides: "json" do
pretty = params.key? :pretty pretty = params.key? :pretty
h = req_headers h = req_headers
jsonify h, pretty: json h, pretty:
end end
get "/livez" do get "/livez" do
@ -321,7 +266,7 @@ get "/livez/uptime" do
tt = TickTock.new tt = TickTock.new
x = {started_at: tt.started_at, seconds: tt.uptime.to_i, human: human_time(tt.uptime.to_i)} x = {started_at: tt.started_at, seconds: tt.uptime.to_i, human: human_time(tt.uptime.to_i)}
jsonify x json x
end end
post "/livez/toggle" do post "/livez/toggle" do
@ -373,19 +318,19 @@ get "/snowflake" do
end end
post "/quit" do post "/quit" do
Process.kill("TERM", ppid) Process.kill("TERM", master_pid)
nil nil
end end
post "/halt" do post "/halt" do
Process.kill("QUIT", ppid) Process.kill("QUIT", master_pid)
nil nil
end end
get "/pid" do get "/pid" do
pretty = params.key? :pretty pretty = params.key? :pretty
jsonify({ppid: ppid, pid: Process.pid}, pretty:) json({puma: master_pid, pid: Process.pid}, pretty:)
end end
get "/token" do get "/token" do
@ -395,51 +340,31 @@ get "/token" do
token = JWT.encode payload, JWT_SECRET, "HS256" token = JWT.encode payload, JWT_SECRET, "HS256"
x = {token: token, expires_at: expires_at} x = {token: token, expires_at: expires_at}
jsonify x json x
end end
get "/token/validate" do get "/token/validate" do
token = req_headers["authorization"].split[1] token = req_headers["authorization"].split[1]
payload = JWT.decode token, JWT_SECRET, true, algorithm: "HS256" payload = JWT.decode token, JWT_SECRET, true, algorithm: "HS256"
jsonify payload json payload
end end
post "/session" do post "/session" do
session.merge! params session.merge! params
jsonify session.to_hash json session.to_hash
end end
get "/session" do get "/session" do
j = session.to_hash j = session.to_hash
j[:hostname] = ENV["HOSTNAME"] j[:hostname] = ENV["HOSTNAME"]
jsonify j json j
end end
get "/cookies" do get "/cookies" do
jsonify response.headers json 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 end
get "/_cat/headers" do get "/_cat/headers" do
@ -466,29 +391,6 @@ get "/_cat/cookies" do
end end
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 route :delete, :get, :patch, :post, :put, "/status/:code" do
# hello # hello
code = Integer(params[:code]) code = Integer(params[:code])
@ -496,14 +398,11 @@ route :delete, :get, :patch, :post, :put, "/status/:code" do
end end
get "/chunked/:delay" do get "/chunked/:delay" do
content_type "application/x-ndjson"
delay = Float(params[:delay]) delay = Float(params[:delay])
stream do |out| stream do |out|
30.times do |i| out << "Hello, world!\n"
out << jsonify({id: i, message: (i % 2).zero? ? "tick" : "tock"}) sleep delay
sleep delay out << "Hello, world!\n"
end
end end
end end
@ -516,90 +415,5 @@ route :delete, :get, :patch, :post, :put, "/auth/basic", provides: "json" do
protected! protected!
end end
jsonify({authenticated: true, user: @auth.username}, pretty:) json({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 end

View File

@ -1,23 +0,0 @@
# 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/

View File

@ -1,24 +0,0 @@
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.2
# 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.2"

View File

@ -1,22 +0,0 @@
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 }}

View File

@ -1,62 +0,0 @@
{{/*
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 }}

View File

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

View File

@ -1,78 +0,0 @@
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 }}

View File

@ -1,32 +0,0 @@
{{- 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 }}

View File

@ -1,43 +0,0 @@
{{- 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 }}

View File

@ -1,15 +0,0 @@
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 }}

View File

@ -1,13 +0,0 @@
{{- 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 }}

View File

@ -1,15 +0,0 @@
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

View File

@ -1,123 +0,0 @@
# 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: false
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: {}

3
config/puma.rb Normal file
View File

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

15
docker-compose.yml Normal file
View File

@ -0,0 +1,15 @@
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 apiVersion: v1
kind: ConfigMap kind: ConfigMap
metadata: metadata:
name: kubernaut-configmap name: kipunji-configmap
namespace: kubernaut namespace: kipunji
data: data:
KUBERNAUT_CAT: kilwin KIPUNJI_CAT: kilwin

View File

@ -2,21 +2,22 @@
apiVersion: apps/v1 apiVersion: apps/v1
kind: Deployment kind: Deployment
metadata: metadata:
name: kubernaut name: kipunji
annotations: annotations:
reloader.stakater.com/auto: "true" reloader.stakater.com/auto: "true"
spec: spec:
replicas: 5
selector: selector:
matchLabels: matchLabels:
app: kubernaut app: kipunji
template: template:
metadata: metadata:
labels: labels:
app: kubernaut app: kipunji
spec: spec:
containers: containers:
- name: kubernaut - name: kipunji
image: git.kill0.net/ryanc/kubernaut:0.1.2 image: git.kill0.net/ryanc/kipunji:latest
imagePullPolicy: Always imagePullPolicy: Always
ports: ports:
- name: sinatra-web - name: sinatra-web
@ -25,12 +26,12 @@ spec:
- name: SESSION_SECRET - name: SESSION_SECRET
valueFrom: valueFrom:
secretKeyRef: secretKeyRef:
name: kubernaut-session-secret name: kipunji-session-secret
key: session_secret key: session_secret
optional: true optional: true
envFrom: envFrom:
- configMapRef: - configMapRef:
name: kubernaut-configmap name: kipunji-configmap
livenessProbe: livenessProbe:
httpGet: httpGet:
path: /livez path: /livez

View File

@ -1,19 +0,0 @@
---
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,10 +1,10 @@
--- ---
apiVersion: kustomize.config.k8s.io/v1beta1 apiVersion: kustomize.config.k8s.io/v1beta1
kind: Kustomization kind: Kustomization
namespace: kubernaut namespace: kipunji
resources: resources:
- secret.yaml - secret.yaml
- configmap.yaml - configmap.yaml
- deployment.yaml - deployment.yaml
- hpa.yaml
- services.yaml - services.yaml
- ingress.yaml

View File

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

View File

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

View File

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

View File

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

View File

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

View File

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

View File

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

View File

@ -1,49 +0,0 @@
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

View File

@ -1,39 +0,0 @@
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

63
sig/app.rbs Normal file
View File

@ -0,0 +1,63 @@
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

Binary file not shown.

Before

Width:  |  Height:  |  Size: 47 KiB

Binary file not shown.

Before

Width:  |  Height:  |  Size: 626 KiB

Binary file not shown.

Before

Width:  |  Height:  |  Size: 156 KiB

View File

@ -1,26 +0,0 @@
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