bingo: serve datacenter bingo on bingo.asxp.io
Add a second public site to the same process: a 5x5 card of the 25 largest Russian datacenters where a cell is crossed out once an incident with a public source is recorded (Yandex Sasovo and Kaluga drone strikes on 2026-10-08/09 are seeded). config.ru dispatches by Host, so it rides the existing container, DB and bucket instead of a new deploy. The card is localized ru/en/uk with per-locale columns falling back to ru. Content is managed from /admin/bingo on asxp.io, reusing AdminAuth and CSRF. Photos go to the existing bucket under bingo/ and are proxied by the app, so the bucket stays private and storage needs no change. The seed data was fact-checked against operator sites and press on 2026-10-10; several entries in the original list were wrong or vague. Assisted-by: Claude:opus-5
This commit is contained in:
parent
1f059dc2f6
commit
bdb3682e18
GPG key ID:
4F8851660FA4121B
19 changed files with 1428 additions and 2 deletions
197
lib/bingo.rb
Normal file
197
lib/bingo.rb
Normal file
|
|
@ -0,0 +1,197 @@
|
|||
require 'sequel'
|
||||
require 'json'
|
||||
require 'net/http'
|
||||
require 'securerandom'
|
||||
require_relative 's3'
|
||||
|
||||
# Datacenter bingo: a 5x5 card of the largest Russian datacenters; a cell is
|
||||
# crossed out once a publicly sourced incident is recorded for it.
|
||||
module Bingo
|
||||
LOCALES = %w[ru en uk].freeze
|
||||
KINDS = %w[strike fire outage flood cooling other].freeze
|
||||
ICONS = { 'strike' => '💥', 'fire' => '🔥', 'outage' => '⚡', 'flood' => '💧', 'cooling' => '🌡️', 'other' => '⚠️' }.freeze
|
||||
SIZE = 5
|
||||
|
||||
# Every row, column and both diagonals, as 0-based cell indices.
|
||||
LINES = (
|
||||
(0...SIZE).map { |r| (0...SIZE).map { |c| r * SIZE + c } } +
|
||||
(0...SIZE).map { |c| (0...SIZE).map { |r| r * SIZE + c } } +
|
||||
[(0...SIZE).map { |i| i * SIZE + i }, (0...SIZE).map { |i| i * SIZE + SIZE - 1 - i }]
|
||||
).freeze
|
||||
|
||||
T = {
|
||||
'ru' => {
|
||||
title: 'Бинго ЦОДов', accent: 'ЦОДов', lead: 'Бинго',
|
||||
desc: 'Топ-25 дата-центров России по мощности. Клетка зачёркивается после публично подтверждённого инцидента.',
|
||||
crossed: 'Зачёркнуто', lines: 'линий', updated: 'обновлено',
|
||||
log: 'Журнал инцидентов', empty: 'Пока всё работает. Пока.',
|
||||
bingo: 'БИНГО!', bingo_n: 'БИНГО ×%d!', full: 'ПОЛНАЯ КАРТА. Интернета больше нет.',
|
||||
building: 'строится', mw: 'МВт', since: 'с %d г.', photo: 'Фото', source: 'Источник',
|
||||
close: 'Закрыть', no_incidents: 'Инцидентов не зафиксировано.',
|
||||
footer: 'Данные из открытых источников (2025–2026). Клетка зачёркивается только по публичному источнику.',
|
||||
kinds: { 'strike' => 'Атака БПЛА', 'fire' => 'Пожар', 'outage' => 'Отключение', 'flood' => 'Затопление', 'cooling' => 'Перегрев', 'other' => 'Инцидент' },
|
||||
letters: %w[Б И Н Г О]
|
||||
},
|
||||
'en' => {
|
||||
title: 'Datacenter Bingo', accent: 'Bingo', lead: 'Datacenter',
|
||||
desc: "Russia's 25 largest datacenters by power. A cell is crossed out after a publicly reported incident.",
|
||||
crossed: 'Crossed out', lines: 'lines', updated: 'updated',
|
||||
log: 'Incident log', empty: 'Everything is up. For now.',
|
||||
bingo: 'BINGO!', bingo_n: 'BINGO ×%d!', full: 'FULL CARD. There is no more internet.',
|
||||
building: 'under construction', mw: 'MW', since: 'since %d', photo: 'Photo', source: 'Source',
|
||||
close: 'Close', no_incidents: 'No incidents recorded.',
|
||||
footer: 'Open-source data (2025–2026). A cell is crossed out only with a public source.',
|
||||
kinds: { 'strike' => 'Drone strike', 'fire' => 'Fire', 'outage' => 'Outage', 'flood' => 'Flood', 'cooling' => 'Overheating', 'other' => 'Incident' },
|
||||
letters: %w[B I N G O]
|
||||
},
|
||||
'uk' => {
|
||||
title: 'Бінго ЦОДів', accent: 'ЦОДів', lead: 'Бінго',
|
||||
desc: 'Топ-25 дата-центрів Росії за потужністю. Клітинка закреслюється після публічно підтвердженого інциденту.',
|
||||
crossed: 'Закреслено', lines: 'ліній', updated: 'оновлено',
|
||||
log: 'Журнал інцидентів', empty: 'Поки що все працює. Поки що.',
|
||||
bingo: 'БІНГО!', bingo_n: 'БІНГО ×%d!', full: 'ПОВНА КАРТКА. Інтернету більше немає.',
|
||||
building: 'будується', mw: 'МВт', since: 'з %d р.', photo: 'Фото', source: 'Джерело',
|
||||
close: 'Закрити', no_incidents: 'Інцидентів не зафіксовано.',
|
||||
footer: 'Дані з відкритих джерел (2025–2026). Клітинка закреслюється лише за публічним джерелом.',
|
||||
kinds: { 'strike' => 'Атака БПЛА', 'fire' => 'Пожежа', 'outage' => 'Відключення', 'flood' => 'Затоплення', 'cooling' => 'Перегрів', 'other' => 'Інцидент' },
|
||||
letters: %w[Б І Н Г О]
|
||||
}
|
||||
}.freeze
|
||||
|
||||
# Localized column with fallback to ru.
|
||||
module Localized
|
||||
def l(field, locale)
|
||||
v = self[:"#{field}_#{locale}"].to_s.strip
|
||||
v.empty? ? self[:"#{field}_ru"] : v
|
||||
end
|
||||
end
|
||||
|
||||
class Datacenter < Sequel::Model(:bingo_datacenters)
|
||||
include Localized
|
||||
one_to_many :incidents, class: 'Bingo::Incident', key: :datacenter_id, order: Sequel.desc(:occurred_on)
|
||||
|
||||
def before_create
|
||||
self.created_at ||= Time.now.utc
|
||||
super
|
||||
end
|
||||
|
||||
def building?
|
||||
status == 'building'
|
||||
end
|
||||
|
||||
def photo_file
|
||||
photo_key&.delete_prefix(Photo::PREFIX)
|
||||
end
|
||||
end
|
||||
|
||||
class Incident < Sequel::Model(:bingo_incidents)
|
||||
include Localized
|
||||
many_to_one :datacenter, class: 'Bingo::Datacenter'
|
||||
|
||||
def before_create
|
||||
self.created_at ||= Time.now.utc
|
||||
super
|
||||
end
|
||||
end
|
||||
|
||||
# Board state for rendering: ordered cells, hits and completed lines.
|
||||
Board = Struct.new(:cells, :hit, :wins, :incidents, :updated_on) do
|
||||
def self.load
|
||||
cells = Datacenter.order(:position, :id).limit(SIZE * SIZE).eager(:incidents).all
|
||||
hit = cells.map { |dc| dc.incidents.any? }
|
||||
wins = LINES.select { |line| line.all? { |i| hit[i] } }
|
||||
incidents = cells.flat_map(&:incidents).sort_by { |i| [i.occurred_on, i.id] }.reverse
|
||||
updated = [Datacenter.max(:created_at), Incident.max(:created_at)].compact.max
|
||||
new(cells, hit, wins, incidents, updated)
|
||||
end
|
||||
|
||||
def win_cells
|
||||
@win_cells ||= wins.flatten.to_set
|
||||
end
|
||||
end
|
||||
|
||||
# Photos live in the app's MinIO bucket under bingo/ and are proxied by the
|
||||
# app, so the bucket stays private.
|
||||
module Photo
|
||||
PREFIX = 'bingo/'.freeze
|
||||
MAX_BYTES = 8 * 1024 * 1024
|
||||
FILE_RE = /\A[a-z0-9-]+-[0-9a-f]{8}\.(jpg|png|webp)\z/
|
||||
TYPES = { 'jpg' => 'image/jpeg', 'png' => 'image/png', 'webp' => 'image/webp' }.freeze
|
||||
|
||||
class Error < StandardError; end
|
||||
|
||||
module_function
|
||||
|
||||
def sniff(bytes)
|
||||
return 'jpg' if bytes.start_with?("\xFF\xD8\xFF".b)
|
||||
return 'png' if bytes.start_with?("\x89PNG\r\n\x1A\n".b)
|
||||
return 'webp' if bytes[0, 4] == 'RIFF' && bytes[8, 4] == 'WEBP'
|
||||
nil
|
||||
end
|
||||
|
||||
# Stores bytes and returns the new key; the old object is left in place
|
||||
# (cheap, and keeps cached URLs valid until their max-age runs out).
|
||||
def store(slug, bytes)
|
||||
bytes = bytes.b
|
||||
raise Error, 'image too large (max 8 MB)' if bytes.bytesize > MAX_BYTES
|
||||
ext = sniff(bytes) or raise Error, 'not a JPEG, PNG or WebP image'
|
||||
key = "#{PREFIX}#{slug}-#{SecureRandom.hex(4)}.#{ext}"
|
||||
S3.put(key, bytes, content_type: TYPES[ext])
|
||||
key
|
||||
end
|
||||
|
||||
# Admin-only "import from URL". https only, a few redirects, size-capped.
|
||||
def fetch(url, redirects: 3)
|
||||
uri = URI(url)
|
||||
raise Error, 'https URL required' unless uri.is_a?(URI::HTTPS)
|
||||
Net::HTTP.start(uri.host, uri.port, use_ssl: true, open_timeout: 5, read_timeout: 15) do |http|
|
||||
req = Net::HTTP::Get.new(uri)
|
||||
req['User-Agent'] = 'Mozilla/5.0 (bingo photo import)'
|
||||
http.request(req) do |res|
|
||||
case res
|
||||
when Net::HTTPRedirection
|
||||
raise Error, 'too many redirects' if redirects.zero?
|
||||
return fetch(URI.join(uri, res['location']).to_s, redirects: redirects - 1)
|
||||
when Net::HTTPSuccess
|
||||
body = +''
|
||||
res.read_body do |chunk|
|
||||
body << chunk
|
||||
raise Error, 'image too large (max 8 MB)' if body.bytesize > MAX_BYTES
|
||||
end
|
||||
return body
|
||||
else
|
||||
raise Error, "HTTP #{res.code} from #{uri.host}"
|
||||
end
|
||||
end
|
||||
end
|
||||
rescue URI::InvalidURIError, SocketError, Net::OpenTimeout, Net::ReadTimeout, OpenSSL::SSL::SSLError, Errno::ECONNREFUSED => e
|
||||
raise Error, e.message
|
||||
end
|
||||
|
||||
def read(file)
|
||||
raise Error, 'bad name' unless file =~ FILE_RE
|
||||
[S3.get(PREFIX + file), TYPES[Regexp.last_match(1)]]
|
||||
end
|
||||
end
|
||||
|
||||
# First boot: fill the card (and any already-known incidents) from
|
||||
# db/bingo_seed.json. Never touches rows once any exist; edits happen in
|
||||
# /admin/bingo.
|
||||
def self.seed!
|
||||
return if Datacenter.count.positive?
|
||||
path = File.join($root, 'db', 'bingo_seed.json')
|
||||
return unless File.exist?(path)
|
||||
seed = JSON.parse(File.read(path, encoding: 'UTF-8'))
|
||||
cols = Datacenter.columns.map(&:to_s) - %w[id created_at]
|
||||
DB.connection.transaction do
|
||||
ids = seed.fetch('datacenters').each_with_index.to_h do |row, i|
|
||||
dc = Datacenter.create(row.slice(*cols).merge('position' => row['position'] || i + 1))
|
||||
[dc.slug, dc.id]
|
||||
end
|
||||
seed.fetch('incidents', []).each do |row|
|
||||
Incident.create(row.slice(*(Incident.columns.map(&:to_s) - %w[id created_at datacenter_id]))
|
||||
.merge('datacenter_id' => ids.fetch(row.fetch('slug'))))
|
||||
end
|
||||
end
|
||||
end
|
||||
end
|
||||
144
lib/bingo_admin.rb
Normal file
144
lib/bingo_admin.rb
Normal file
|
|
@ -0,0 +1,144 @@
|
|||
require 'uri'
|
||||
|
||||
# /admin/bingo/* on asxp.io: edit the card and record incidents for BingoWeb.
|
||||
# Registered into AsxpioWeb, so AdminAuth (HTTP Basic) and CSRF apply.
|
||||
module BingoAdmin
|
||||
DC_TEXT = %w[name_ru name_en name_uk city_ru city_en city_uk operator mw status
|
||||
photo_credit photo_source_url info_url].freeze
|
||||
|
||||
module Helpers
|
||||
def bingo_public_url
|
||||
ENV['BINGO_HOST'] && "https://#{ENV['BINGO_HOST']}/ru"
|
||||
end
|
||||
|
||||
def http_url?(s)
|
||||
s.empty? || s.match?(URI::DEFAULT_PARSER.make_regexp(%w[http https]))
|
||||
end
|
||||
|
||||
def blank_nil(s)
|
||||
s = s.to_s.strip
|
||||
s.empty? ? nil : s
|
||||
end
|
||||
end
|
||||
|
||||
def self.registered(app)
|
||||
app.helpers Helpers
|
||||
|
||||
app.get '/admin/bingo' do
|
||||
@page_title = 'Bingo · admin'
|
||||
@noindex = true
|
||||
@dcs = Bingo::Datacenter.order(:position, :id).eager(:incidents).all
|
||||
@incidents = Bingo::Incident.order(Sequel.desc(:occurred_on), Sequel.desc(:id)).eager(:datacenter).all
|
||||
@flash = session.delete(:bingo_flash)
|
||||
erb :'admin/bingo/index'
|
||||
end
|
||||
|
||||
app.get '/admin/bingo/dc/:id' do
|
||||
@dc = Bingo::Datacenter[params[:id].to_i] or halt 404
|
||||
@page_title = "#{@dc.name_ru} · bingo admin"
|
||||
@noindex = true
|
||||
@flash = session.delete(:bingo_flash)
|
||||
erb :'admin/bingo/edit'
|
||||
end
|
||||
|
||||
app.post '/admin/bingo/dc/:id' do
|
||||
dc = Bingo::Datacenter[params[:id].to_i] or halt 404
|
||||
DC_TEXT.each { |f| dc[f.to_sym] = blank_nil(params[f]) }
|
||||
dc.position = params[:position].to_i if params[:position].to_s =~ /\A\d+\z/
|
||||
dc.year = params[:year].to_s =~ /\A\d{4}\z/ ? params[:year].to_i : nil
|
||||
dc.status = 'operational' unless %w[operational building].include?(dc.status)
|
||||
errs = []
|
||||
errs << 'Name (ru), city (ru) and operator are required' if [dc.name_ru, dc.city_ru, dc.operator].any?(&:nil?)
|
||||
errs << 'URLs must be http(s)' unless [dc.photo_source_url, dc.info_url].all? { |u| http_url?(u.to_s) }
|
||||
if errs.empty?
|
||||
dc.save_changes
|
||||
session[:bingo_flash] = 'Saved.'
|
||||
else
|
||||
session[:bingo_flash] = errs.join('; ')
|
||||
end
|
||||
redirect "/admin/bingo/dc/#{dc.id}"
|
||||
end
|
||||
|
||||
# Either an uploaded file or "import from URL" (defaults to photo_source_url).
|
||||
app.post '/admin/bingo/dc/:id/photo' do
|
||||
dc = Bingo::Datacenter[params[:id].to_i] or halt 404
|
||||
begin
|
||||
bytes =
|
||||
if params[:photo].is_a?(Hash) && params[:photo][:tempfile]
|
||||
params[:photo][:tempfile].read(Bingo::Photo::MAX_BYTES + 1)
|
||||
else
|
||||
url = blank_nil(params[:url]) || dc.photo_source_url or raise Bingo::Photo::Error, 'no file and no URL'
|
||||
dc.photo_source_url = url
|
||||
Bingo::Photo.fetch(url)
|
||||
end
|
||||
dc.photo_key = Bingo::Photo.store(dc.slug, bytes)
|
||||
dc.save_changes
|
||||
session[:bingo_flash] = 'Photo stored.'
|
||||
rescue Bingo::Photo::Error => e
|
||||
session[:bingo_flash] = "Photo failed: #{e.message}"
|
||||
end
|
||||
redirect "/admin/bingo/dc/#{dc.id}"
|
||||
end
|
||||
|
||||
app.post '/admin/bingo/dc/:id/photo/delete' do
|
||||
dc = Bingo::Datacenter[params[:id].to_i] or halt 404
|
||||
dc.update(photo_key: nil)
|
||||
session[:bingo_flash] = 'Photo removed from card (object kept in bucket).'
|
||||
redirect "/admin/bingo/dc/#{dc.id}"
|
||||
end
|
||||
|
||||
# Bulk: import every missing photo from its photo_source_url.
|
||||
app.post '/admin/bingo/photos/import' do
|
||||
ok, failed = 0, []
|
||||
Bingo::Datacenter.where(photo_key: nil).exclude(photo_source_url: nil).each do |dc|
|
||||
dc.update(photo_key: Bingo::Photo.store(dc.slug, Bingo::Photo.fetch(dc.photo_source_url)))
|
||||
ok += 1
|
||||
rescue Bingo::Photo::Error => e
|
||||
failed << "#{dc.slug}: #{e.message}"
|
||||
end
|
||||
session[:bingo_flash] = (["Imported #{ok}."] + failed).join(' | ')
|
||||
redirect '/admin/bingo'
|
||||
end
|
||||
|
||||
app.get '/admin/bingo/p/:file' do
|
||||
bytes, type = Bingo::Photo.read(params[:file])
|
||||
content_type type
|
||||
bytes
|
||||
rescue Bingo::Photo::Error, Aws::S3::Errors::NoSuchKey, Aws::S3::Errors::NotFound
|
||||
halt 404
|
||||
end
|
||||
|
||||
app.post '/admin/bingo/incidents' do
|
||||
dc = Bingo::Datacenter[params[:datacenter_id].to_i]
|
||||
date = begin
|
||||
Date.iso8601(params[:occurred_on].to_s)
|
||||
rescue Date::Error
|
||||
nil
|
||||
end
|
||||
url = params[:url].to_s.strip
|
||||
errs = []
|
||||
errs << 'Pick a datacenter' unless dc
|
||||
errs << 'Valid date required' unless date
|
||||
errs << 'Unknown kind' unless Bingo::KINDS.include?(params[:kind])
|
||||
errs << 'Title (ru) required' if params[:title_ru].to_s.strip.empty?
|
||||
errs << 'Source URL must be http(s)' unless http_url?(url)
|
||||
if errs.empty?
|
||||
Bingo::Incident.create(
|
||||
datacenter_id: dc.id, occurred_on: date, kind: params[:kind],
|
||||
title_ru: params[:title_ru].strip, title_en: blank_nil(params[:title_en]),
|
||||
title_uk: blank_nil(params[:title_uk]), url: blank_nil(url)
|
||||
)
|
||||
session[:bingo_flash] = "Incident recorded for #{dc.name_ru}."
|
||||
else
|
||||
session[:bingo_flash] = errs.join('; ')
|
||||
end
|
||||
redirect '/admin/bingo'
|
||||
end
|
||||
|
||||
app.post '/admin/bingo/incidents/:id/delete' do
|
||||
Bingo::Incident.where(id: params[:id].to_i).delete
|
||||
session[:bingo_flash] = 'Incident deleted.'
|
||||
redirect '/admin/bingo'
|
||||
end
|
||||
end
|
||||
end
|
||||
|
|
@ -40,6 +40,10 @@ module S3
|
|||
key
|
||||
end
|
||||
|
||||
def get(key)
|
||||
client.get_object(bucket: bucket, key: key).body.read
|
||||
end
|
||||
|
||||
def exists?(key)
|
||||
client.head_object(bucket: bucket, key: key)
|
||||
true
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue