Compare commits

..

63 Commits

Author SHA1 Message Date
f3ff657fc2 Sposta overlay video sull'app Android e rimuove ffmpeg server-side.
Il tabellone stile SportCam e il watermark Match Live TV sono bruciati in GPU via RootEncoder; sul backend spariscono OverlayRelay, job Sidekiq e volume stream_overlays.

Co-authored-by: Cursor <cursoragent@cursor.com>
2026-06-06 18:12:35 +02:00
68b4390282 Completa app Android nativa e rimuove il client Flutter.
Il monorepo punta a native/android (login, wizard, diretta RTMP, tabellone WebSocket, pausa/telemetria) con encode 16:9 e orientamento via sensore; eliminati mobile/ e gli script Flutter obsoleti.

Co-authored-by: Cursor <cursoragent@cursor.com>
2026-06-06 17:38:56 +02:00
499aee8988 Aggiunge app Android nativa da zero su branch dedicato.
Nuovo progetto Compose in native/android con API, auth, streaming RTMP e schermate base; nessun codice copiato dalla app Flutter.

Co-authored-by: Cursor <cursoragent@cursor.com>
2026-06-06 15:36:36 +02:00
854738b46d Stabilizza live YouTube/RTMP e fix crash rotazione mobile.
Pipeline YouTube con relay, overlay e publisher sync lato backend; fix GL pauseGlDuringRotation su Android per evitare crash in rotazione durante lo streaming Flutter.

Co-authored-by: Cursor <cursoragent@cursor.com>
2026-06-06 15:30:55 +02:00
1058c644bd PublisherSync: go_live anche con bytesReceived su path camera
Co-authored-by: Cursor <cursoragent@cursor.com>
2026-06-04 09:47:57 +02:00
3ef3c59d94 PublisherSync: rileva publisher anche con source RTMP attivo
Co-authored-by: Cursor <cursoragent@cursor.com>
2026-06-04 09:45:05 +02:00
61bb22ce44 Fix overlay _air: probesize su intake RTMP e rilevamento zombie
Senza analyzeduration/probesize l'overlay non pubblicava su _air;
YouTube restava in attesa. Esclusi processi ffmpeg zombie da running?.

Co-authored-by: Cursor <cursoragent@cursor.com>
2026-06-04 09:39:11 +02:00
10fff7ffcb Fix YouTube in attesa: disabilita auto_stop e ricrea broadcast chiusa
YouTube chiudeva la diretta (complete) senza ingest stabile; ora
enable_auto_stop è false e SetupBroadcast.recreate! rigenera link/stream key.

Co-authored-by: Cursor <cursoragent@cursor.com>
2026-06-04 09:33:07 +02:00
d835bce148 Fix relay YouTube: rimuovi opzioni reconnect non supportate da ffmpeg RTMP
ffmpeg usciva subito con "Option reconnect not found", ingest mai attivo.

Co-authored-by: Cursor <cursoragent@cursor.com>
2026-06-04 09:21:58 +02:00
4c7be615f1 Fix freeze YouTube al cambio punteggio: PNG atomica e relay stabile
rsvg scrive su .tmp poi rename; il feeder ignora PNG parziali.
YouTube relay: no doppio avvio, reconnect RTMP; overlay restart solo dopo 3 miss.

Co-authored-by: Cursor <cursoragent@cursor.com>
2026-06-04 09:07:06 +02:00
fde1213ca5 Fix YouTube relay instabile e timer LIVE a zero in app
ffmpeg: probesize/analyzeduration su _air, restart più rapido e avvio relay
al go_live. App: sincronizza started_at dal server e fallback al passaggio live.

Co-authored-by: Cursor <cursoragent@cursor.com>
2026-06-04 08:56:59 +02:00
841e99c775 Fix Process.spawn: redirect log ffmpeg fuori dallo splat
Co-authored-by: Cursor <cursoragent@cursor.com>
2026-06-04 08:46:02 +02:00
02ff1de0f6 Fix relay YouTube bloccato: rimuovi ffprobe su RTMP live
ffprobe su rtmp://mediamtx si bloccava in Sidekiq e impediva
l'avvio del relay verso YouTube (pagina sempre in attesa).

Co-authored-by: Cursor <cursoragent@cursor.com>
2026-06-04 08:44:57 +02:00
8263475146 Fix YouTube in attesa: audio AAC di riserva, retry attivazione broadcast
Il relay verso YouTube ora gestisce _air senza traccia audio, ritenta
activate_broadcast finché l'ingest è active e riduce la finestra
scheduledStartTime a ~20s.

Co-authored-by: Cursor <cursoragent@cursor.com>
2026-06-04 08:37:47 +02:00
bac655aca8 Fix API YouTube: id e mine non insieme in list_live_streams
Co-authored-by: Cursor <cursoragent@cursor.com>
2026-06-04 08:34:50 +02:00
d08cd36527 Fix YouTube waiting: transcode verso RTMP e sync stato live.
Il relay non usa più copy (stream inactive su YouTube); PublisherSync
nel refresh overlay; activate solo quando lo stream YouTube è active.

Co-authored-by: Cursor <cursoragent@cursor.com>
2026-06-04 08:32:30 +02:00
2c5f4f82eb YouTube live immediata: relay sempre attivo e attivazione broadcast.
Il relay parte dal job overlay ogni 2s; scheduledStartTime ~90s invece di 5 min;
transition testing/live quando l'ingest RTMP raggiunge YouTube.

Co-authored-by: Cursor <cursoragent@cursor.com>
2026-06-04 08:19:20 +02:00
2ccbfea75e Corregge avvio RTMP bloccato dopo errore o cambio sessione.
Il motore Android ignorava startStream in CONNECTING/RECONNECTING; la camera
ora resetta prima di pubblicare. YouTube relay parte solo con overlay attivo.

Co-authored-by: Cursor <cursoragent@cursor.com>
2026-06-04 07:32:15 +02:00
1d67459bbe YouTube come destinazione pubblica, non Match Live TV.
Non propone più il link MLTV per sessioni YouTube; la pagina /live
reindirizza a YouTube; il relay verso YouTube si riavvia al connect.

Co-authored-by: Cursor <cursoragent@cursor.com>
2026-06-04 07:25:07 +02:00
9fd4d865b3 Corregge keyword youtube_channel in SetupBroadcast.
Il job Sidekiq falliva con ArgumentError unknown keyword :channel,
impedendo la creazione broadcast YouTube dopo la sessione API.

Co-authored-by: Cursor <cursoragent@cursor.com>
2026-06-04 00:32:15 +02:00
70e704827e Risolve timeout creazione sessione YouTube lato app.
La setup broadcast YouTube (~23s) passa in background job; l'API risponde
subito. Aumentato anche il timeout Dio mobile per createSession YouTube.

Co-authored-by: Cursor <cursoragent@cursor.com>
2026-06-04 00:18:07 +02:00
fd7a5c2c8e Fix bind_live_broadcast: stream_id come keyword arg.
La gem google-apis-youtube_v3 richiede stream_id: e non un terzo argomento
posizionale, causando 500 in creazione sessione YouTube.

Co-authored-by: Cursor <cursoragent@cursor.com>
2026-06-04 00:11:38 +02:00
8139d84d88 Fix orario YouTube scheduledStartTime per dirette immediate.
Normalizza la data partita nel futuro richiesto dall'API: se scheduled_at
è passato o assente usa now+5min, con messaggio d'errore più chiaro.

Co-authored-by: Cursor <cursoragent@cursor.com>
2026-06-04 00:03:19 +02:00
ab9cb02083 Aggiunge overlay server-side burn-in e stabilizza diretta live.
Tabellone, badge e brand sono ricodificati nel flusso _air via OverlayRelay;
sync punteggio HTTP, volume condiviso rails/sidekiq, qualità 720p migliorata
e badge CONNECTING in ripresa da pausa.

Co-authored-by: Cursor <cursoragent@cursor.com>
2026-06-03 23:55:17 +02:00
fd225fbadd Aggiunge Garage al compose di produzione e script di bootstrap.
Rails e Sidekiq usano S3 interno (http://garage:3900); setup_garage_production.sh
configura bucket, chiavi e infra/.env sul server.

Co-authored-by: Cursor <cursoragent@cursor.com>
2026-06-03 08:05:35 +02:00
565bc2c548 Aggiunge cookie policy, banner consenso e Google Analytics opzionale.
Il banner consente solo necessari o tutti i cookie; GA4 si carica solo dopo
consenso. Aggiornati privacy, footer, sitemap e variabile GOOGLE_ANALYTICS_MEASUREMENT_ID.

Co-authored-by: Cursor <cursoragent@cursor.com>
2026-06-03 08:00:30 +02:00
1f273f849d Aggiunge modulo Replay, Garage dev e YouTube a livello società.
Pipeline registrazione/upload con storage S3, archivio web e app, proxy replay
per il browser, OAuth YouTube sulla pagina club (Premium Full) e footer legale.

Co-authored-by: Cursor <cursoragent@cursor.com>
2026-06-03 07:53:11 +02:00
a87cda156b Implementa pausa diretta con copertina slate e ripresa.
Metti in pausa ferma RTMP lato app mantenendo la camera aperta, MediaMTX
manda offline.mp4 agli spettatori e Chiudi termina definitivamente.

Co-authored-by: Cursor <cursoragent@cursor.com>
2026-06-02 23:31:48 +02:00
1bd81d84af Aggiunge tabellone punteggio in app senza link regia.
Controlli +1/− e chiudi set in camera e dopo test rete, sync via WebSocket.

Co-authored-by: Cursor <cursoragent@cursor.com>
2026-06-02 23:19:17 +02:00
8882e7854f Semplifica condivisione link dopo test rete in app.
Mostra link diretta e regia solo a test completato; rimuove pulsante
duplicato e nasconde «Avvia test rete».

Co-authored-by: Cursor <cursoragent@cursor.com>
2026-06-02 23:11:40 +02:00
422d8848f6 Corregge chiusura diretta YouTube e stop sessione senza broadcast.
transition_live_broadcast richiede status, id e part; evita 500 in chiusura
diretta Match Live TV quando non c'è broadcast YouTube.

Co-authored-by: Cursor <cursoragent@cursor.com>
2026-06-02 23:06:46 +02:00
787161807c Ripristina scelta visibilità con due pulsanti segmentati in app.
Pubblico (default) e privato/non in elenco, stessa logica di prima.

Co-authored-by: Cursor <cursoragent@cursor.com>
2026-06-02 23:03:56 +02:00
1677df7f86 Visibilità pubblico/link-only su tutte le piattaforme di streaming.
Default pubblico; opzione unica privato/non in elenco per Match Live TV,
YouTube piattaforma e canale società. Elenco dirette solo sessioni pubbliche.

Co-authored-by: Cursor <cursoragent@cursor.com>
2026-06-02 23:00:34 +02:00
1fb5cd5aa2 App: scelta canale YouTube MLTV/società, privacy e condivisione link.
Premium Full può forzare il canale piattaforma; visibilità non in elenco o privato;
share_url unificato per Match Live TV e YouTube.

Co-authored-by: Cursor <cursoragent@cursor.com>
2026-06-02 22:52:07 +02:00
6ac4db98bb Messaggi chiari per errori YouTube API in creazione diretta.
Include guida su liveStreamingNotEnabled e token non validi.

Co-authored-by: Cursor <cursoragent@cursor.com>
2026-06-02 22:44:49 +02:00
92c0058085 Corregge OAuth YouTube piattaforma senza access token in memoria.
Il refresh token ENV non veniva scambiato finché expires_at era vuoto,
causando 500 Unauthorized alla creazione sessione YouTube.

Co-authored-by: Cursor <cursoragent@cursor.com>
2026-06-02 22:43:31 +02:00
9b40deeb61 Unifica admin società/squadre e YouTube Full con fallback MLTV.
Premium Full senza canale società usa il canale piattaforma come Light;
in app restano solo Match Live TV e YouTube Live.

Co-authored-by: Cursor <cursoragent@cursor.com>
2026-06-02 22:38:28 +02:00
82ff1972a0 Aggiunge abbonamenti omaggio admin per sponsor e promozioni.
Gli admin possono concedere o revocare Premium Light/Full senza Stripe;
il piano omaggio ha priorità sui webhook e la società vede un messaggio dedicato.

Co-authored-by: Cursor <cursoragent@cursor.com>
2026-06-02 22:26:19 +02:00
566104aff4 Billing upgrade/downgrade, inviti in app e diretta YouTube da mobile.
Upgrade Stripe con addebito immediato; downgrade programmato a fine periodo.
UX billing più sobria con box info; icone piani. API inviti e OAuth YouTube
per staff trasmissione; deep link join; scelta partita programmata o nuova.

Co-authored-by: Cursor <cursoragent@cursor.com>
2026-06-02 22:15:27 +02:00
2cb267f991 Admin: voce menu YouTube per collegamento canale piattaforma.
Co-authored-by: Cursor <cursoragent@cursor.com>
2026-06-02 21:12:12 +02:00
d051d60415 Fix 500 callback YouTube: pagina token senza layout admin.
Il layout admin richiedeva admin_logged_in? non disponibile nel callback OAuth.

Co-authored-by: Cursor <cursoragent@cursor.com>
2026-06-02 21:02:51 +02:00
cd8e97243f Allinea branding homepage a Match Live TV per verifica OAuth Google.
Nome visibile in hero, meta application-name, JSON-LD e documentazione; corregge mismatch con «Match Live Tv» in Console.

Co-authored-by: Cursor <cursoragent@cursor.com>
2026-06-02 20:04:34 +02:00
71eaf9cf56 Fix callback OAuth YouTube: pagina HTML con refresh token invece di risposta API vuota.
Il codice OAuth va usato una sola volta; messaggio chiaro se si ricarica il callback.

Co-authored-by: Cursor <cursoragent@cursor.com>
2026-06-02 19:57:08 +02:00
462f050977 Deploy YouTube: non richiede credenziali nel .env locale se già sul server.
Co-authored-by: Cursor <cursoragent@cursor.com>
2026-06-02 19:41:23 +02:00
d0552e1aaa Fix: migration YouTube con timestamp univoco (evita conflitto 20260525120000).
Co-authored-by: Cursor <cursoragent@cursor.com>
2026-06-02 19:39:27 +02:00
994c1e3c09 Integrazione YouTube Live: OAuth squadra, canale piattaforma Light e UI.
Collegamento da Dettagli squadra e admin per il refresh token Match Live TV; API e app mobile allineate ai piani Light/Full.

Co-authored-by: Cursor <cursoragent@cursor.com>
2026-06-02 19:36:56 +02:00
1a84d6ae42 Fix checkout Stripe: ricrea customer se ID test su ambiente live.
Evita errore «No such customer» dopo passaggio da sk_test a sk_live.

Co-authored-by: Cursor <cursoragent@cursor.com>
2026-06-02 19:11:42 +02:00
2b8f842752 Dirette: nasconde partite programmate nel passato.
La pagina /live mostrava tutte le partite da inizio giornata; ora solo con orario futuro.

Co-authored-by: Cursor <cursoragent@cursor.com>
2026-06-02 19:10:07 +02:00
964e3f472c Admin fatturazione: coda pagamenti senza PDF e upload diretto.
Lista globale dei pagamenti da fatturare con dati intestazione, caricamento
PDF per riga che crea la fattura e invia email; rimuove il flusso bozza manuale.

Co-authored-by: Cursor <cursoragent@cursor.com>
2026-06-02 17:31:49 +02:00
b073ded6c1 Admin: voce Fatturazione nel menu e elenco società.
Rende raggiungibili pagamenti e fatture PDF senza passare solo dal dettaglio squadra.

Co-authored-by: Cursor <cursoragent@cursor.com>
2026-06-02 17:27:09 +02:00
ef805984ee Rimuove featured anche da billing squadra.
Co-authored-by: Cursor <cursoragent@cursor.com>
2026-06-02 17:23:57 +02:00
15e57cddee Card piani: un solo stile di bordo grigio per tutte e tre.
Rimuove featured con contorno rosso che creava 2 card rosse e 1 grigia.

Co-authored-by: Cursor <cursoragent@cursor.com>
2026-06-02 17:23:51 +02:00
cf06acf24d Allinea card piani: stessa altezza e bordo uniforme.
Flex column con azioni in basso; highlight Premium Light con box-shadow
invece di bordo rosso diverso che spezzava l’allineamento.

Co-authored-by: Cursor <cursoragent@cursor.com>
2026-06-02 17:21:42 +02:00
1901fcce68 Premium Light: canale YouTube indicato come Match Live TV.
Sostituisce la dicitura obsoleta Match TV Light in prezzi, FAQ e funzionalità.

Co-authored-by: Cursor <cursoragent@cursor.com>
2026-06-02 17:19:43 +02:00
62d86d16ec Fix prezzi pubblici: Premium Light €5/€40, Full €20/€200.
Ripristina le etichette in PriceCatalog usate da prezzi, abbonamento e checkout.

Co-authored-by: Cursor <cursoragent@cursor.com>
2026-06-02 17:17:32 +02:00
a5e781729c Billing: fatture manuali, profilo obbligatorio e piani Stripe mensile/annuale.
Rimuove link al portale Stripe in area cliente, aggiunge flusso admin per PDF
fattura e email, blocca checkout senza dati di fatturazione, allinea prezzi
a €4,90/€39,90 e €9,90/€69,90, locale italiano e documentazione deploy.

Co-authored-by: Cursor <cursoragent@cursor.com>
2026-06-02 17:10:12 +02:00
148402a97c Fix PCI Stripe e anteprima regia; checkout sempre hosted.
Blocca l'invio di numeri carta dall'API server, usa Checkout anche per i cambi piano e nasconde correttamente il placeholder video in regia.

Co-authored-by: Cursor <cursoragent@cursor.com>
2026-05-29 08:00:28 +02:00
f4b7be0f80 Billing Stripe, link regia mobile e staff solo trasmissione.
Aggiunge fatturazione club, pagina regia condivisibile senza account, roster squadre e rimuove la modalità controller dall'app (v1.1.0).

Co-authored-by: Cursor <cursoragent@cursor.com>
2026-05-29 07:23:13 +02:00
4083bc5dee Club come entità principale, branding e fix infrastruttura streaming.
Introduce clubs con abbonamento, branding Active Storage e flusso registrazione società; corregge healthcheck MediaMTX (immagine distroless) e allinea dominio produzione matchlivetv.it.

Co-authored-by: Cursor <cursoragent@cursor.com>
2026-05-27 09:16:24 +02:00
471291b2c4 Sito marketing, SEO, legal, live programmata e branding Match Live Tv.
Logo e favicon nel header, partite programmate su web e mobile, reset password,
pagine FAQ/sitemap, privacy/termini GDPR e icona Android «Match Live Tv».

Co-authored-by: Cursor <cursoragent@cursor.com>
2026-05-26 23:17:15 +02:00
3a5649f482 Admin protetto, dashboard KPI e aggiornamenti sito marketing.
Login admin con cambio password, metriche server (CPU/RAM/disco/banda), grafici e statistiche streaming; sezione piani ridimensionata.

Co-authored-by: Cursor <cursoragent@cursor.com>
2026-05-26 18:18:47 +02:00
3d3420cc4a Merge repository Gitea: conserva LICENSE GPL v3, README del monorepo.
Co-authored-by: Cursor <cursoragent@cursor.com>
2026-05-26 17:45:54 +02:00
bba6df52c0 Initial commit: monorepo Match Live TV.
Rails API, app Flutter, infrastruttura Docker/MediaMTX, sito marketing e documentazione di deploy.

Co-authored-by: Cursor <cursoragent@cursor.com>
2026-05-26 17:45:37 +02:00
541 changed files with 32292 additions and 2 deletions

36
.gitignore vendored Normal file
View File

@@ -0,0 +1,36 @@
# Ruby
backend/.bundle
backend/vendor/bundle
backend/tmp/
backend/log/
backend/storage/
backend/.env
backend/.env.*
# Flutter
mobile/.dart_tool/
mobile/.flutter-plugins
mobile/.flutter-plugins-dependencies
mobile/build/
mobile/.packages
mobile/pubspec.lock
# Infra
infra/certs/
infra/recordings/
infra/.env
infra/.env.production.generated
infra/garage/dev-credentials.env
infra/garage/prod-credentials.env
infra/garage/garage.prod.toml
# OS
.DS_Store
*.swp
.idea/
.vscode/
# Secrets
.env
*.pem
credentials.json

View File

@@ -1,3 +1,71 @@
# MatchLiveTv # Match Live TV
Piattaforma di live streaming per sport dilettantistico con regia remota, gestione squadre, streaming mobile e archivio partite. Piattaforma mobile-first per streaming di partite sportive giovanili — MVP su **Match Live TV** (HLS sul nostro sito); YouTube/Facebook/Twitch come integrazioni premium.
**Slogan:** *Ogni partita, ogni evento, per i tuoi tifosi.*
## Struttura monorepo
```
├── backend/ # Rails 7.2 API + Action Cable + Sidekiq
├── native/android/ # App Android nativa (Kotlin + Compose)
├── infra/ # Docker Compose, MediaMTX, Nginx, Kamal
└── docs/ # Documentazione
```
## Deploy produzione (server 192.168.1.146)
Vedi [docs/infrastructure/SERVER_DEPLOYMENT.md](docs/infrastructure/SERVER_DEPLOYMENT.md) per porte router, NPM e procedura completa.
**Porte da aprire sul router:** `1935/TCP` (RTMP). Opzionale `8888/TCP` (HLS). HTTPS via Nginx Proxy Manager verso `http://192.168.1.146:3000`.
**Sul server (una tantum, con sudo):**
```bash
sudo bash ~/matchlivetv/scripts/deploy/server_bootstrap.sh
bash ~/matchlivetv/scripts/deploy/post_bootstrap_deploy.sh
```
## Avvio rapido (locale)
```bash
cd infra
cp .env.example .env
docker compose up -d --build
```
- API Rails: http://localhost:3000
- MediaMTX RTMP: rtmp://localhost:1935
- MediaMTX API: http://localhost:9997
- Admin: http://localhost:3000/admin
### Seed utente demo
```
email: coach@matchlivetv.test
password: password123
```
## App Android nativa
```bash
./scripts/build_native_android_apk_prod.sh
adb install -r native/android/app/build/outputs/apk/release/app-release.apk
```
API produzione: `https://www.matchlivetv.it` (override con `-PAPI_BASE_URL=...` in Gradle).
Vedi [native/android/README.md](native/android/README.md).
## Architettura
- Video (MVP): Phone → MediaMTX (RTMP) → HLS su `matchlivetv.*` (pagina `/live/:session_id`)
- Video (premium): stesso ingest + relay ffmpeg verso YouTube
- Controllo: Phone ↔ Action Cable ↔ Rails ↔ PostgreSQL
- Disconnessioni: MediaMTX `alwaysAvailable` slate + timeout 5 min (Sidekiq)
### App Android produzione
```bash
./scripts/build_native_android_apk_prod.sh
# API: https://www.matchlivetv.it
```

42
backend/.dockerignore Normal file
View File

@@ -0,0 +1,42 @@
# See https://docs.docker.com/engine/reference/builder/#dockerignore-file for more about ignoring files.
# Ignore git directory.
/.git/
/.gitignore
# Ignore bundler config.
/.bundle
# Ignore all environment files (except templates).
/.env*
!/.env*.erb
# Ignore all default key files.
/config/master.key
/config/credentials/*.key
# Ignore all logfiles and tempfiles.
/log/*
/tmp/*
!/log/.keep
!/tmp/.keep
# Ignore pidfiles, but keep the directory.
/tmp/pids/*
!/tmp/pids/.keep
# Ignore storage (uploaded files in development and any SQLite databases).
/storage/*
!/storage/.keep
/tmp/storage/*
!/tmp/storage/.keep
# Ignore CI service files.
/.github
# Ignore development files
/.devcontainer
# Ignore Docker-related files
/.dockerignore
/Dockerfile*

9
backend/.gitattributes vendored Normal file
View File

@@ -0,0 +1,9 @@
# See https://git-scm.com/docs/gitattributes for more about git attribute files.
# Mark the database schema as having been generated.
db/schema.rb linguist-generated
# Mark any vendored files as having been vendored.
vendor/* linguist-vendored
config/credentials/*.yml.enc diff=rails_credentials
config/credentials.yml.enc diff=rails_credentials

12
backend/.github/dependabot.yml vendored Normal file
View File

@@ -0,0 +1,12 @@
version: 2
updates:
- package-ecosystem: bundler
directory: "/"
schedule:
interval: daily
open-pull-requests-limit: 10
- package-ecosystem: github-actions
directory: "/"
schedule:
interval: daily
open-pull-requests-limit: 10

39
backend/.github/workflows/ci.yml vendored Normal file
View File

@@ -0,0 +1,39 @@
name: CI
on:
pull_request:
push:
branches: [ main ]
jobs:
scan_ruby:
runs-on: ubuntu-latest
steps:
- name: Checkout code
uses: actions/checkout@v4
- name: Set up Ruby
uses: ruby/setup-ruby@v1
with:
ruby-version: .ruby-version
bundler-cache: true
- name: Scan for common Rails security vulnerabilities using static analysis
run: bin/brakeman --no-pager
lint:
runs-on: ubuntu-latest
steps:
- name: Checkout code
uses: actions/checkout@v4
- name: Set up Ruby
uses: ruby/setup-ruby@v1
with:
ruby-version: .ruby-version
bundler-cache: true
- name: Lint code for consistent style
run: bin/rubocop -f github

33
backend/.gitignore vendored Normal file
View File

@@ -0,0 +1,33 @@
# See https://help.github.com/articles/ignoring-files for more about ignoring files.
#
# Temporary files generated by your text editor or operating system
# belong in git's global ignore instead:
# `$XDG_CONFIG_HOME/git/ignore` or `~/.config/git/ignore`
# Ignore bundler config.
/.bundle
# Ignore all environment files (except templates).
/.env*
!/.env*.erb
# Ignore all logfiles and tempfiles.
/log/*
/tmp/*
!/log/.keep
!/tmp/.keep
# Ignore pidfiles, but keep the directory.
/tmp/pids/*
!/tmp/pids/
!/tmp/pids/.keep
# Ignore storage (uploaded files in development and any SQLite databases).
/storage/*
!/storage/.keep
/tmp/storage/*
!/tmp/storage/
!/tmp/storage/.keep
# Ignore master key for decrypting credentials and more.
/config/master.key

8
backend/.rubocop.yml Normal file
View File

@@ -0,0 +1,8 @@
# Omakase Ruby styling for Rails
inherit_gem: { rubocop-rails-omakase: rubocop.yml }
# Overwrite or add rules to create your own house style
#
# # Use `[a, [b, c]]` not `[ a, [ b, c ] ]`
# Layout/SpaceInsideArrayLiteralBrackets:
# Enabled: false

1
backend/.ruby-version Normal file
View File

@@ -0,0 +1 @@
ruby-3.3.11

19
backend/Dockerfile Normal file
View File

@@ -0,0 +1,19 @@
FROM ruby:3.3-bookworm
RUN apt-get update -qq && \
apt-get install -y --no-install-recommends build-essential libpq-dev curl ffmpeg librsvg2-bin fonts-dejavu-core && \
rm -rf /var/lib/apt/lists/*
WORKDIR /app
ENV BUNDLE_WITHOUT="development:test"
ENV BUNDLE_DEPLOYMENT="1"
COPY Gemfile Gemfile.lock ./
RUN bundle install
COPY . .
EXPOSE 3000
CMD ["bundle", "exec", "puma", "-C", "config/puma.rb", "-b", "tcp://0.0.0.0:3000"]

34
backend/Gemfile Normal file
View File

@@ -0,0 +1,34 @@
source "https://rubygems.org"
gem "rails", "~> 7.2.2"
gem "pg", "~> 1.1"
gem "puma", ">= 5.0"
gem "bootsnap", require: false
gem "tzinfo-data", platforms: %i[ windows jruby ]
gem "redis", ">= 4.0.1"
gem "bcrypt", "~> 3.1.7"
gem "rack-cors"
gem "jwt"
gem "sidekiq"
gem "rack-attack"
gem "aasm"
gem "attr_encrypted"
gem "google-apis-youtube_v3"
gem "faraday"
gem "stripe"
gem "aws-sdk-s3", "~> 1.0", require: false
gem "kamal", require: false
group :development, :test do
gem "debug", platforms: %i[ mri windows ], require: "debug/prelude"
gem "brakeman", require: false
gem "rubocop-rails-omakase", require: false
gem "rspec-rails"
gem "factory_bot_rails"
gem "faker"
end
group :development do
gem "letter_opener"
end

464
backend/Gemfile.lock Normal file
View File

@@ -0,0 +1,464 @@
GEM
remote: https://rubygems.org/
specs:
aasm (5.5.2)
concurrent-ruby (~> 1.0)
actioncable (7.2.3.1)
actionpack (= 7.2.3.1)
activesupport (= 7.2.3.1)
nio4r (~> 2.0)
websocket-driver (>= 0.6.1)
zeitwerk (~> 2.6)
actionmailbox (7.2.3.1)
actionpack (= 7.2.3.1)
activejob (= 7.2.3.1)
activerecord (= 7.2.3.1)
activestorage (= 7.2.3.1)
activesupport (= 7.2.3.1)
mail (>= 2.8.0)
actionmailer (7.2.3.1)
actionpack (= 7.2.3.1)
actionview (= 7.2.3.1)
activejob (= 7.2.3.1)
activesupport (= 7.2.3.1)
mail (>= 2.8.0)
rails-dom-testing (~> 2.2)
actionpack (7.2.3.1)
actionview (= 7.2.3.1)
activesupport (= 7.2.3.1)
cgi
nokogiri (>= 1.8.5)
racc
rack (>= 2.2.4, < 3.3)
rack-session (>= 1.0.1)
rack-test (>= 0.6.3)
rails-dom-testing (~> 2.2)
rails-html-sanitizer (~> 1.6)
useragent (~> 0.16)
actiontext (7.2.3.1)
actionpack (= 7.2.3.1)
activerecord (= 7.2.3.1)
activestorage (= 7.2.3.1)
activesupport (= 7.2.3.1)
globalid (>= 0.6.0)
nokogiri (>= 1.8.5)
actionview (7.2.3.1)
activesupport (= 7.2.3.1)
builder (~> 3.1)
cgi
erubi (~> 1.11)
rails-dom-testing (~> 2.2)
rails-html-sanitizer (~> 1.6)
activejob (7.2.3.1)
activesupport (= 7.2.3.1)
globalid (>= 0.3.6)
activemodel (7.2.3.1)
activesupport (= 7.2.3.1)
activerecord (7.2.3.1)
activemodel (= 7.2.3.1)
activesupport (= 7.2.3.1)
timeout (>= 0.4.0)
activestorage (7.2.3.1)
actionpack (= 7.2.3.1)
activejob (= 7.2.3.1)
activerecord (= 7.2.3.1)
activesupport (= 7.2.3.1)
marcel (~> 1.0)
activesupport (7.2.3.1)
base64
benchmark (>= 0.3)
bigdecimal
concurrent-ruby (~> 1.0, >= 1.3.1)
connection_pool (>= 2.2.5)
drb
i18n (>= 1.6, < 2)
logger (>= 1.4.2)
minitest (>= 5.1, < 6)
securerandom (>= 0.3)
tzinfo (~> 2.0, >= 2.0.5)
addressable (2.9.0)
public_suffix (>= 2.0.2, < 8.0)
ast (2.4.3)
attr_encrypted (4.2.0)
encryptor (~> 3.0.0)
aws-eventstream (1.4.0)
aws-partitions (1.1256.0)
aws-sdk-core (3.251.0)
aws-eventstream (~> 1, >= 1.3.0)
aws-partitions (~> 1, >= 1.992.0)
aws-sigv4 (~> 1.9)
base64
bigdecimal
jmespath (~> 1, >= 1.6.1)
logger
aws-sdk-kms (1.129.0)
aws-sdk-core (~> 3, >= 3.248.0)
aws-sigv4 (~> 1.5)
aws-sdk-s3 (1.225.0)
aws-sdk-core (~> 3, >= 3.248.0)
aws-sdk-kms (~> 1)
aws-sigv4 (~> 1.5)
aws-sigv4 (1.12.1)
aws-eventstream (~> 1, >= 1.0.2)
base64 (0.3.0)
bcrypt (3.1.22)
bcrypt_pbkdf (1.1.2)
bcrypt_pbkdf (1.1.2-arm64-darwin)
bcrypt_pbkdf (1.1.2-x86_64-darwin)
benchmark (0.5.0)
bigdecimal (4.1.2)
bootsnap (1.24.5)
msgpack (~> 1.2)
brakeman (8.0.4)
racc
builder (3.3.0)
cgi (0.5.1)
childprocess (5.1.0)
logger (~> 1.5)
concurrent-ruby (1.3.6)
connection_pool (3.0.2)
crass (1.0.6)
date (3.5.1)
debug (1.11.1)
irb (~> 1.10)
reline (>= 0.3.8)
declarative (0.0.20)
diff-lcs (1.6.2)
dotenv (3.2.0)
drb (2.2.3)
ed25519 (1.4.0)
encryptor (3.0.0)
erb (6.0.4)
erubi (1.13.1)
factory_bot (6.6.0)
activesupport (>= 6.1.0)
factory_bot_rails (6.5.1)
factory_bot (~> 6.5)
railties (>= 6.1.0)
faker (3.8.0)
i18n (>= 1.8.11, < 2)
faraday (2.14.2)
faraday-net_http (>= 2.0, < 3.5)
json
logger
faraday-follow_redirects (0.5.0)
faraday (>= 1, < 3)
faraday-net_http (3.4.3)
net-http (~> 0.5)
globalid (1.3.0)
activesupport (>= 6.1)
google-apis-core (1.0.2)
addressable (~> 2.8, >= 2.8.7)
faraday (~> 2.13)
faraday-follow_redirects (~> 0.3)
googleauth (~> 1.14)
mini_mime (~> 1.1)
representable (~> 3.0)
retriable (~> 3.1)
google-apis-youtube_v3 (0.64.0)
google-apis-core (>= 0.15.0, < 2.a)
google-cloud-env (2.3.1)
base64 (~> 0.2)
faraday (>= 1.0, < 3.a)
google-logging-utils (0.2.0)
googleauth (1.16.2)
faraday (>= 1.0, < 3.a)
google-cloud-env (~> 2.2)
google-logging-utils (~> 0.1)
jwt (>= 1.4, < 4.0)
multi_json (~> 1.11)
os (>= 0.9, < 2.0)
signet (>= 0.16, < 2.a)
i18n (1.14.8)
concurrent-ruby (~> 1.0)
io-console (0.8.2)
irb (1.18.0)
pp (>= 0.6.0)
prism (>= 1.3.0)
rdoc (>= 4.0.0)
reline (>= 0.4.2)
jmespath (1.6.2)
json (2.19.5)
jwt (3.2.0)
base64
kamal (2.11.0)
activesupport (>= 7.0)
base64 (~> 0.2)
bcrypt_pbkdf (~> 1.0)
concurrent-ruby (~> 1.2)
dotenv (~> 3.1)
ed25519 (~> 1.4)
net-ssh (~> 7.3)
sshkit (>= 1.23.0, < 2.0)
thor (~> 1.3)
zeitwerk (>= 2.6.18, < 3.0)
language_server-protocol (3.17.0.5)
launchy (3.1.1)
addressable (~> 2.8)
childprocess (~> 5.0)
logger (~> 1.6)
letter_opener (1.10.0)
launchy (>= 2.2, < 4)
lint_roller (1.1.0)
logger (1.7.0)
loofah (2.25.1)
crass (~> 1.0.2)
nokogiri (>= 1.12.0)
mail (2.9.0)
logger
mini_mime (>= 0.1.1)
net-imap
net-pop
net-smtp
marcel (1.2.1)
mini_mime (1.1.5)
minitest (5.27.0)
msgpack (1.8.0)
multi_json (1.21.1)
net-http (0.9.1)
uri (>= 0.11.1)
net-imap (0.6.4)
date
net-protocol
net-pop (0.1.2)
net-protocol
net-protocol (0.2.2)
timeout
net-scp (4.1.0)
net-ssh (>= 2.6.5, < 8.0.0)
net-sftp (4.0.0)
net-ssh (>= 5.0.0, < 8.0.0)
net-smtp (0.5.1)
net-protocol
net-ssh (7.3.2)
nio4r (2.7.5)
nokogiri (1.19.3-aarch64-linux-gnu)
racc (~> 1.4)
nokogiri (1.19.3-aarch64-linux-musl)
racc (~> 1.4)
nokogiri (1.19.3-arm-linux-gnu)
racc (~> 1.4)
nokogiri (1.19.3-arm-linux-musl)
racc (~> 1.4)
nokogiri (1.19.3-arm64-darwin)
racc (~> 1.4)
nokogiri (1.19.3-x86_64-darwin)
racc (~> 1.4)
nokogiri (1.19.3-x86_64-linux-gnu)
racc (~> 1.4)
nokogiri (1.19.3-x86_64-linux-musl)
racc (~> 1.4)
os (1.1.4)
ostruct (0.6.3)
parallel (2.1.0)
parser (3.3.11.1)
ast (~> 2.4.1)
racc
pg (1.6.3)
pg (1.6.3-aarch64-linux)
pg (1.6.3-aarch64-linux-musl)
pg (1.6.3-arm64-darwin)
pg (1.6.3-x86_64-darwin)
pg (1.6.3-x86_64-linux)
pg (1.6.3-x86_64-linux-musl)
pp (0.6.3)
prettyprint
prettyprint (0.2.0)
prism (1.9.0)
psych (5.3.1)
date
stringio
public_suffix (7.0.5)
puma (8.0.1)
nio4r (~> 2.0)
racc (1.8.1)
rack (3.2.6)
rack-attack (6.8.0)
rack (>= 1.0, < 4)
rack-cors (3.0.0)
logger
rack (>= 3.0.14)
rack-session (2.1.2)
base64 (>= 0.1.0)
rack (>= 3.0.0)
rack-test (2.2.0)
rack (>= 1.3)
rackup (2.3.1)
rack (>= 3)
rails (7.2.3.1)
actioncable (= 7.2.3.1)
actionmailbox (= 7.2.3.1)
actionmailer (= 7.2.3.1)
actionpack (= 7.2.3.1)
actiontext (= 7.2.3.1)
actionview (= 7.2.3.1)
activejob (= 7.2.3.1)
activemodel (= 7.2.3.1)
activerecord (= 7.2.3.1)
activestorage (= 7.2.3.1)
activesupport (= 7.2.3.1)
bundler (>= 1.15.0)
railties (= 7.2.3.1)
rails-dom-testing (2.3.0)
activesupport (>= 5.0.0)
minitest
nokogiri (>= 1.6)
rails-html-sanitizer (1.7.0)
loofah (~> 2.25)
nokogiri (>= 1.15.7, != 1.16.7, != 1.16.6, != 1.16.5, != 1.16.4, != 1.16.3, != 1.16.2, != 1.16.1, != 1.16.0.rc1, != 1.16.0)
railties (7.2.3.1)
actionpack (= 7.2.3.1)
activesupport (= 7.2.3.1)
cgi
irb (~> 1.13)
rackup (>= 1.0.0)
rake (>= 12.2)
thor (~> 1.0, >= 1.2.2)
tsort (>= 0.2)
zeitwerk (~> 2.6)
rainbow (3.1.1)
rake (13.4.2)
rdoc (7.2.0)
erb
psych (>= 4.0.0)
tsort
redis (5.4.1)
redis-client (>= 0.22.0)
redis-client (0.29.0)
connection_pool
regexp_parser (2.12.0)
reline (0.6.3)
io-console (~> 0.5)
representable (3.2.0)
declarative (< 0.1.0)
trailblazer-option (>= 0.1.1, < 0.2.0)
uber (< 0.2.0)
retriable (3.5.0)
rspec-core (3.13.6)
rspec-support (~> 3.13.0)
rspec-expectations (3.13.5)
diff-lcs (>= 1.2.0, < 2.0)
rspec-support (~> 3.13.0)
rspec-mocks (3.13.8)
diff-lcs (>= 1.2.0, < 2.0)
rspec-support (~> 3.13.0)
rspec-rails (8.0.4)
actionpack (>= 7.2)
activesupport (>= 7.2)
railties (>= 7.2)
rspec-core (>= 3.13.0, < 5.0.0)
rspec-expectations (>= 3.13.0, < 5.0.0)
rspec-mocks (>= 3.13.0, < 5.0.0)
rspec-support (>= 3.13.0, < 5.0.0)
rspec-support (3.13.7)
rubocop (1.86.2)
json (~> 2.3)
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 (>= 2.9.3, < 3.0)
rubocop-ast (>= 1.49.0, < 2.0)
ruby-progressbar (~> 1.7)
unicode-display_width (>= 2.4.0, < 4.0)
rubocop-ast (1.49.1)
parser (>= 3.3.7.2)
prism (~> 1.7)
rubocop-performance (1.26.1)
lint_roller (~> 1.1)
rubocop (>= 1.75.0, < 2.0)
rubocop-ast (>= 1.47.1, < 2.0)
rubocop-rails (2.35.2)
activesupport (>= 4.2.0)
lint_roller (~> 1.1)
rack (>= 1.1)
rubocop (>= 1.75.0, < 2.0)
rubocop-ast (>= 1.44.0, < 2.0)
rubocop-rails-omakase (1.1.0)
rubocop (>= 1.72)
rubocop-performance (>= 1.24)
rubocop-rails (>= 2.30)
ruby-progressbar (1.13.0)
securerandom (0.4.1)
sidekiq (8.1.5)
connection_pool (>= 3.0.0)
json (>= 2.16.0)
logger (>= 1.7.0)
rack (>= 3.2.0)
redis-client (>= 0.29.0)
signet (0.21.0)
addressable (~> 2.8)
faraday (>= 0.17.5, < 3.a)
jwt (>= 1.5, < 4.0)
multi_json (~> 1.10)
sshkit (1.25.0)
base64
logger
net-scp (>= 1.1.2)
net-sftp (>= 2.1.2)
net-ssh (>= 2.8.0)
ostruct
stringio (3.2.0)
stripe (19.1.0)
bigdecimal
logger
thor (1.5.0)
timeout (0.6.1)
trailblazer-option (0.1.2)
tsort (0.2.0)
tzinfo (2.0.6)
concurrent-ruby (~> 1.0)
uber (0.1.0)
unicode-display_width (3.2.0)
unicode-emoji (~> 4.1)
unicode-emoji (4.2.0)
uri (1.1.1)
useragent (0.16.11)
websocket-driver (0.8.0)
base64
websocket-extensions (>= 0.1.0)
websocket-extensions (0.1.5)
zeitwerk (2.8.2)
PLATFORMS
aarch64-linux
aarch64-linux-gnu
aarch64-linux-musl
arm-linux-gnu
arm-linux-musl
arm64-darwin
x86_64-darwin
x86_64-linux
x86_64-linux-gnu
x86_64-linux-musl
DEPENDENCIES
aasm
attr_encrypted
aws-sdk-s3 (~> 1.0)
bcrypt (~> 3.1.7)
bootsnap
brakeman
debug
factory_bot_rails
faker
faraday
google-apis-youtube_v3
jwt
kamal
letter_opener
pg (~> 1.1)
puma (>= 5.0)
rack-attack
rack-cors
rails (~> 7.2.2)
redis (>= 4.0.1)
rspec-rails
rubocop-rails-omakase
sidekiq
stripe
tzinfo-data
BUNDLED WITH
2.5.22

24
backend/README.md Normal file
View File

@@ -0,0 +1,24 @@
# README
This README would normally document whatever steps are necessary to get the
application up and running.
Things you may want to cover:
* Ruby version
* System dependencies
* Configuration
* Database creation
* Database initialization
* How to run the test suite
* Services (job queues, cache servers, search engines, etc.)
* Deployment instructions
* ...

6
backend/Rakefile Normal file
View File

@@ -0,0 +1,6 @@
# Add your own tasks in files placed in lib/tasks ending in .rake,
# for example lib/tasks/capistrano.rake, and they will automatically be available to Rake.
require_relative "config/application"
Rails.application.load_tasks

View File

@@ -0,0 +1,4 @@
module ApplicationCable
class Channel < ActionCable::Channel::Base
end
end

View File

@@ -0,0 +1,23 @@
module ApplicationCable
class Connection < ActionCable::Connection::Base
identified_by :current_user, :regia_session
def connect
if (regia_token = request.params[:regia_token].presence)
self.regia_session = Sessions::RegiaAccess.find_session_by_token(regia_token)
reject_unauthorized_connection unless regia_session
return
end
payload = JsonWebToken.decode(token_from_header)
self.current_user = User.find_by(id: payload[:user_id]) if payload
reject_unauthorized_connection unless current_user
end
private
def token_from_header
request.headers["Authorization"].to_s.delete_prefix("Bearer ").presence
end
end
end

View File

@@ -0,0 +1,9 @@
module CableBroadcastable
extend ActiveSupport::Concern
class_methods do
def broadcast_message(session, data)
broadcast_to(session, method: "receive_message", data: data)
end
end
end

View File

@@ -0,0 +1,88 @@
class SessionChannel < ApplicationCable::Channel
include CableBroadcastable
def subscribed
session = resolve_session
reject unless session && session.id.to_s == params[:session_id].to_s
stream_for session
session.device_states.find_or_create_by!(device_role: params[:device_role] || "controller")
end
def resolve_session
if connection.regia_session
connection.regia_session
else
StreamSession.joins(match: :team)
.merge(connection.current_user.manageable_teams)
.find_by(id: params[:session_id])
end
end
def unsubscribed
stop_all_streams
end
def receive(data)
session = resolve_session
return unless session
handle_message(session, data)
end
private
def handle_message(session, data)
case data["type"]
when "command"
SessionChannel.broadcast_message(session, data)
execute_command(session, data)
when "score_update"
update_score(session, data)
when "timeout"
update_timeout(session, data)
when "device_state"
update_device(session, data)
end
end
def execute_command(session, data)
case data["action"]
when "start_stream"
Sessions::Start.new(session).call
when "stop_stream"
Sessions::Stop.new(session).call
when "pause_stream"
Sessions::Pause.new(session).call
when "resume_stream"
Sessions::Resume.new(session).call
end
end
def update_score(session, data)
Scoring::SyncState.new(session: session, payload: data).call
end
def update_timeout(session, data)
score = session.score_state
return unless score
if data["team"] == "home"
score.update!(timeout_home: true)
else
score.update!(timeout_away: true)
end
SessionChannel.broadcast_message(session, { type: "timeout", team: data["team"] })
end
def update_device(session, data)
state = session.device_states.find_or_initialize_by(device_role: data["device_role"] || "camera")
state.update!(
battery_level: data["battery"],
network_type: data["network"],
current_bitrate: data["bitrate"],
fps: data["fps"],
last_seen_at: Time.current
)
SessionChannel.broadcast_message(session, state.as_cable_payload)
end
end

View File

@@ -0,0 +1,25 @@
module Admin
class AuthController < Admin::BaseController
skip_before_action :require_admin_login, only: %i[new create]
def new
redirect_to admin_root_path if admin_logged_in?
end
def create
account = AdminAccount.find_by(username: params[:username]&.strip)
if account&.authenticate(params[:password])
session[:admin_account_id] = account.id
redirect_to session.delete(:admin_return_to) || admin_root_path, notice: "Accesso effettuato"
else
flash.now[:alert] = "Username o password non validi"
render :new, status: :unauthorized
end
end
def destroy
reset_session
redirect_to admin_login_path, notice: "Disconnesso"
end
end
end

View File

@@ -0,0 +1,30 @@
module Admin
class BaseController < ActionController::Base
layout "admin"
protect_from_forgery with: :exception
before_action :require_admin_login
include ::AdminHelper
helper_method :current_admin_account, :admin_logged_in?
private
def require_admin_login
return if admin_logged_in?
session[:admin_return_to] = request.fullpath unless request.path == admin_login_path
redirect_to admin_login_path, alert: "Accedi per continuare"
end
def current_admin_account
return unless session[:admin_account_id]
@current_admin_account ||= AdminAccount.find_by(id: session[:admin_account_id])
end
def admin_logged_in?
current_admin_account.present?
end
end
end

View File

@@ -0,0 +1,33 @@
module Admin
class BillingController < BaseController
def index
@pending_payments = pending_scope.recent
@completed_payments = Billing::Payment.with_invoice_pdf.includes(:club, :invoice).recent.limit(40)
@filter_club = Club.find_by(id: params[:club_id]) if params[:club_id].present?
@clubs = Club.order(:name)
end
def attach_pdf
payment = Billing::Payment.find(params[:payment_id])
Billing::AttachPaymentInvoice.call(payment: payment, pdf: params[:pdf])
redirect_to admin_billing_path(billing_redirect_params(payment)),
notice: "Fattura caricata e inviata a #{payment.club.billing_email}."
rescue Billing::AttachPaymentInvoice::Error, Billing::IssueInvoice::Error => e
payment ||= Billing::Payment.find_by(id: params[:payment_id])
redirect_to admin_billing_path(payment ? billing_redirect_params(payment) : {}),
alert: e.message
end
private
def pending_scope
scope = Billing::Payment.awaiting_invoice_pdf.includes(:club, invoice: { pdf_attachment: :blob })
scope = scope.where(club_id: params[:club_id]) if params[:club_id].present?
scope
end
def billing_redirect_params(payment)
{ club_id: payment.club_id, anchor: "payment-#{payment.id}" }.compact
end
end
end

View File

@@ -0,0 +1,84 @@
module Admin
class BillingInvoicesController < BaseController
before_action :set_club
before_action :set_invoice, only: %i[edit update]
def index
redirect_to admin_billing_path(club_id: @club.id)
end
def new
redirect_to admin_billing_path(club_id: @club.id), alert: "Carica il PDF dalla lista «Pagamenti da fatturare»."
end
def create
@invoice = @club.billing_invoices.build(invoice_params)
@invoice.source = "manual"
@invoice.status = "draft"
if @invoice.save
redirect_to edit_admin_club_billing_invoice_path(@club, @invoice),
notice: "Bozza creata. Carica il PDF dalla pagina Fatturazione o qui sotto."
else
@payment = @invoice.billing_payment
flash.now[:alert] = @invoice.errors.full_messages.join(", ")
render :new, status: :unprocessable_entity
end
end
def edit
@payment = @invoice.billing_payment
end
def update
@invoice.assign_attributes(invoice_params.except(:pdf))
if issuing?
Billing::IssueInvoice.call(invoice: @invoice, pdf: params.dig(:billing_invoice, :pdf))
redirect_to admin_billing_path(club_id: @club.id),
notice: "Fattura #{@invoice.number} emessa e inviata a #{@club.billing_email}."
elsif @invoice.save
redirect_to admin_billing_path(club_id: @club.id), notice: "Fattura #{@invoice.number} aggiornata."
else
@payment = @invoice.billing_payment
flash.now[:alert] = @invoice.errors.full_messages.join(", ")
render :edit, status: :unprocessable_entity
end
rescue Billing::IssueInvoice::Error => e
@payment = @invoice.billing_payment
flash.now[:alert] = e.message
render :edit, status: :unprocessable_entity
end
private
def set_club
@club = Club.find(params[:club_id])
end
def set_invoice
@invoice = @club.billing_invoices.find(params[:id])
end
def issuing?
params[:commit].to_s == "Emetti e invia via email"
end
def invoice_params
params.require(:billing_invoice).permit(
:number,
:issued_on,
:amount_cents,
:amount_euros,
:currency,
:billing_payment_id,
:notes,
:pdf
).tap do |p|
if p[:amount_euros].present?
p[:amount_cents] = (p.delete(:amount_euros).to_f * 100).round
end
end
end
end
end

View File

@@ -0,0 +1,46 @@
module Admin
class ClubsController < BaseController
before_action :set_club, only: %i[show grant_comped revoke_comped]
def index
@clubs = Club.includes(:teams, subscription: %i[plan admin_comped_by])
.order(:name)
end
def show
@subscription = @club.subscription || @club.build_subscription(plan: Plan["free"], status: "active")
@plans = Plan.ordered.reject { |p| p.slug == "free" }
@teams = @club.teams.order(:name)
end
def grant_comped
Billing::AdminCompedSubscription.grant(
club: @club,
plan_slug: params.require(:plan_slug),
reason: params[:reason],
admin: current_admin_account
)
redirect_back_or_club notice: "Abbonamento omaggio #{Plan[params[:plan_slug]].name} attivato per #{@club.name}."
rescue Billing::AdminCompedSubscription::Error, ActiveRecord::RecordInvalid => e
redirect_back_or_club alert: e.message
end
def revoke_comped
Billing::AdminCompedSubscription.revoke(club: @club, admin: current_admin_account)
redirect_back_or_club notice: "Abbonamento omaggio revocato per #{@club.name}."
rescue Billing::AdminCompedSubscription::Error => e
redirect_back_or_club alert: e.message
end
private
def set_club
@club = Club.find(params[:id])
end
def redirect_back_or_club(notice: nil, alert: nil)
target = params[:return_to].presence || admin_club_path(@club)
redirect_to target, notice: notice, alert: alert
end
end
end

View File

@@ -0,0 +1,19 @@
module Admin
class DashboardController < Admin::BaseController
def index
@stats = DashboardStats.new.call
@host = HostMetrics.new.sample!
@active_sessions = StreamSession
.where(status: DashboardStats::ACTIVE_STATUSES)
.includes(match: :team)
.order(started_at: :desc)
@teams = Team.includes(:matches).order(:name).limit(8)
end
def metrics
host = HostMetrics.new.sample!
stats = DashboardStats.new.call
render json: { host: host, stats: stats, at: Time.current.iso8601 }
end
end
end

View File

@@ -0,0 +1,30 @@
module Admin
class PasswordsController < Admin::BaseController
def edit
end
def update
unless current_admin_account.authenticate(params[:current_password])
flash.now[:alert] = "Password attuale non corretta"
return render :edit, status: :unprocessable_entity
end
if params[:password].blank? || params[:password].length < 8
flash.now[:alert] = "La nuova password deve avere almeno 8 caratteri"
return render :edit, status: :unprocessable_entity
end
if params[:password] != params[:password_confirmation]
flash.now[:alert] = "Le password non coincidono"
return render :edit, status: :unprocessable_entity
end
if current_admin_account.update(password: params[:password])
redirect_to admin_root_path, notice: "Password aggiornata"
else
flash.now[:alert] = current_admin_account.errors.full_messages.to_sentence
render :edit, status: :unprocessable_entity
end
end
end
end

View File

@@ -0,0 +1,26 @@
module Admin
class SessionsController < Admin::BaseController
def index
@sessions = StreamSession.includes(:match, :user).order(created_at: :desc).limit(50)
end
def show
@session = StreamSession.find(params[:id])
@events = @session.stream_events.recent.limit(50)
end
def stop
@session = StreamSession.find(params[:id])
if @session.terminal?
redirect_to admin_session_path(@session), alert: "Sessione già terminata (#{@session.status})."
return
end
Sessions::Stop.new(@session).call
redirect_to admin_session_path(@session), notice: "Sessione terminata."
rescue StandardError => e
Rails.logger.error("[admin] stop session #{@session.id}: #{e.class} #{e.message}")
redirect_to admin_session_path(@session), alert: "Errore durante la chiusura: #{e.message}"
end
end
end

View File

@@ -0,0 +1,12 @@
module Admin
class TeamsController < Admin::BaseController
def index
redirect_to admin_clubs_path, status: :moved_permanently
end
def show
@team = Team.find(params[:id])
@matches = @team.matches.order(scheduled_at: :desc)
end
end
end

View File

@@ -0,0 +1,13 @@
module Admin
class YoutubeController < Admin::BaseController
def platform
if ENV["YOUTUBE_CLIENT_ID"].blank?
redirect_to admin_root_path, alert: "Configura YOUTUBE_CLIENT_ID e YOUTUBE_CLIENT_SECRET in .env"
return
end
state = Youtube::OauthState.for_platform(admin_id: current_admin_account.id)
redirect_to Youtube::OauthUrl.build(state: state), allow_other_host: true
end
end
end

View File

@@ -0,0 +1,65 @@
module Api
module V1
class AuthController < ApplicationController
skip_before_action :authenticate_request!, only: %i[login refresh register]
def register
user = User.new(
email: params[:email]&.downcase,
name: params[:name],
password: params[:password],
role: "coach"
)
if user.save
render json: token_response(user), status: :created
else
render json: { error: user.errors.full_messages.join(", ") }, status: :unprocessable_entity
end
end
def login
user = User.find_by(email: params[:email]&.downcase)
if user&.authenticate(params[:password])
render json: token_response(user), status: :ok
else
render json: { error: "Invalid credentials" }, status: :unauthorized
end
end
def logout
render json: { message: "Logged out" }
end
def refresh
payload = JsonWebToken.decode(params[:refresh_token] || bearer_token)
user = User.find_by(id: payload&.dig(:user_id))
return render json: { error: "Invalid token" }, status: :unauthorized unless user
render json: token_response(user)
end
def me
render json: user_json(current_user)
end
private
def token_response(user)
{
user: user_json(user),
access_token: JsonWebToken.encode({ user_id: user.id, type: "access" }),
refresh_token: JsonWebToken.encode({ user_id: user.id, type: "refresh" }, exp: 30.days.from_now)
}
end
def user_json(user)
{
id: user.id,
email: user.email,
name: user.name,
role: user.role
}
end
end
end
end

View File

@@ -0,0 +1,25 @@
module Api
module V1
class BaseController < ApplicationController
rescue_from Teams::EntitlementError, with: :render_entitlement_error
rescue_from Youtube::BroadcastService::Error, with: :render_youtube_error
private
def render_youtube_error(error)
render json: {
error: "YouTube: #{error.message}",
error_code: "youtube_api_error"
}, status: :unprocessable_entity
end
def render_entitlement_error(error)
render json: {
error: error.message,
error_code: error.code,
billing_url: error.billing_url
}, status: :forbidden
end
end
end
end

View File

@@ -0,0 +1,52 @@
module Api
module V1
class InvitationsController < BaseController
skip_before_action :authenticate_request!, only: :show
def show
invitation = find_pending_invitation
unless invitation
return render json: { valid: false, error: "Invito non valido o scaduto" }, status: :not_found
end
render json: {
valid: true,
email: invitation.email,
team_id: invitation.team_id,
team_name: invitation.team.name,
club_name: invitation.team.club.name,
staff_kind: invitation.staff_kind,
expires_at: invitation.expires_at
}
end
def accept
invitation = find_pending_invitation
return render json: { error: "Invito non valido o scaduto" }, status: :not_found unless invitation
if current_user.email.downcase != invitation.email.downcase
return render json: {
error: "Questo invito è per #{invitation.email}. Accedi con quell'indirizzo email.",
invited_email: invitation.email
}, status: :unprocessable_entity
end
invitation.accept!(current_user)
render json: {
team_id: invitation.team_id,
team_name: invitation.team.name,
message: "Sei entrato in #{invitation.team.name} come responsabile trasmissione."
}
end
private
def find_pending_invitation
token = params[:token].to_s
return nil if token.blank?
TeamInvitation.pending.find_by(token_digest: Digest::SHA256.hexdigest(token))
end
end
end
end

View File

@@ -0,0 +1,87 @@
module Api
module V1
class MatchesController < BaseController
before_action :set_team, only: %i[index create]
before_action :set_match, only: %i[show update destroy]
def index
matches = @team.matches
.includes(:team, :stream_sessions)
.order(Arel.sql("scheduled_at ASC NULLS LAST"), created_at: :desc)
render json: matches.map { |m| match_json(m) }
end
def create
match = @team.matches.create!(match_params)
render json: match_json(match), status: :created
end
def show
render json: match_json(@match, detail: true)
end
def update
@match.update!(match_params)
render json: match_json(@match)
end
def destroy
active = active_session_for(@match)
if active&.resumable?
return render json: {
error: "Chiudi la diretta prima di eliminare questa partita"
}, status: :unprocessable_entity
end
@match.destroy!
head :no_content
end
private
def set_team
@team = current_user.streamable_teams.find { |t| t.id == params[:team_id] }
raise ActiveRecord::RecordNotFound unless @team
end
def set_match
team_ids = current_user.streamable_teams.map(&:id)
@match = Match.where(team_id: team_ids).find(params[:id])
end
def match_params
params.require(:match).permit(
:opponent_name, :location, :scheduled_at, :sport, :sets_to_win,
:category, :phase, roster_numbers: [],
scoring_rules: %i[points_per_set points_deciding_set min_point_lead]
)
end
def match_json(match, detail: false)
active = active_session_for(match)
{
id: match.id,
team_id: match.team_id,
team_name: match.team.name,
opponent_name: match.opponent_name,
location: match.location,
scheduled_at: match.scheduled_at,
sport: match.sport,
sets_to_win: match.sets_to_win,
scoring_rules: match.scoring_rules.presence,
roster_numbers: match.roster_numbers,
category: match.category,
phase: match.phase,
active_session_id: active&.id,
active_session_status: active&.status
}
end
def active_session_for(match)
match.stream_sessions
.order(created_at: :desc)
.find { |s| !%w[ended error].include?(s.status) }
end
end
end
end

View File

@@ -0,0 +1,105 @@
module Api
module V1
class RecordingsController < BaseController
before_action :set_recording
def update
authorize_manage!
@recording.update!(recording_update_attrs)
render json: recording_json(@recording)
end
def destroy
authorize_manage!
Recordings::Delete.new(@recording).call
head :no_content
end
def download
url = Recordings::DownloadUrl.new(@recording, viewer: current_user).call
render json: { download_url: url, expires_in_seconds: MatchLiveTv.replay_download_url_ttl_seconds }
rescue Recordings::DownloadUrl::NotAllowed
render json: { error: "Download non disponibile per il tuo piano", error_code: "download_not_allowed" },
status: :forbidden
rescue ArgumentError => e
render json: { error: e.message }, status: :unprocessable_entity
end
def publish_youtube
authorize_manage!
ent = @recording.team.entitlements
unless ent.premium_full? && ent.youtube_enabled?
return render json: { error: "Republicazione YouTube con Premium Full" }, status: :forbidden
end
Recordings::PublishToYoutubeJob.perform_async(@recording.id)
render json: { queued: true, message: "Pubblicazione su YouTube in corso" }
end
private
def set_recording
team_ids = current_user.manageable_teams.map(&:id)
@recording = Recording.not_deleted
.includes(stream_session: :match)
.where(team_id: team_ids)
.find(params[:id])
end
def authorize_manage!
team = @recording.team
return if team.club.owned_by?(current_user)
return if current_user.manageable_teams.exists?(id: team.id)
render json: { error: "Non autorizzato" }, status: :forbidden
end
def recording_update_attrs
p = params.require(:recording).permit(:privacy_status, :title)
p = p.to_h
p[:privacy_status] = "unlisted" if p[:privacy_status] == "private"
if params.dig(:recording, :metadata).present?
p[:metadata] = @recording.metadata.merge(
params[:recording][:metadata].to_unsafe_h.stringify_keys
)
end
p
end
def recording_json(recording)
session = recording.stream_session
match = session.match
ent = recording.team.entitlements
{
id: recording.id,
session_id: session.id,
match_id: match.id,
title: recording.title_or_default,
opponent_name: match.opponent_name,
team_name: match.team.name,
team_id: recording.team_id,
status: recording.status,
status_label: recording.status_label,
privacy_status: recording.privacy_status,
ended_at: session.ended_at,
recorded_at: recording.recorded_at_or_fallback,
duration_secs: recording.duration_secs,
duration_label: recording.duration_label,
byte_size: recording.byte_size,
byte_size_label: recording.byte_size_label,
view_count: recording.view_count,
views_label: recording.views_label,
replay_url: recording.replay_url,
playback_url: recording.playback_stream_url,
thumbnail_url: recording.thumbnail_url,
download_enabled: ent.phone_download_enabled?,
youtube_video_id: recording.youtube_video_id,
youtube_watch_url: recording.youtube_watch_url,
youtube_publish_enabled: ent.premium_full? && ent.youtube_enabled?,
expires_at: recording.expires_at,
metadata: recording.metadata
}
end
end
end
end

View File

@@ -0,0 +1,191 @@
module Api
module V1
class StreamSessionsController < BaseController
before_action :set_session, except: :create
def create
team_ids = current_user.streamable_teams.map(&:id)
match = Match.where(team_id: team_ids).find(params[:match_id])
session = Sessions::Create.new(user: current_user, match: match, params: session_params).call
render json: session_json(session), status: :created
end
def show
render json: session_json(@session, detail: true)
end
def start
Sessions::Start.new(@session).call
render json: session_json(@session)
end
def stop
Sessions::Stop.new(@session).call
render json: session_json(@session)
end
def pause
Sessions::Pause.new(@session).call
render json: session_json(@session)
end
def resume
Sessions::Resume.new(@session).call
render json: session_json(@session)
end
def score
Scoring::SyncState.new(session: @session, payload: score_sync_params).call
render json: session_json(@session, detail: true)
end
def events
events = @session.stream_events.recent.limit(100)
render json: events.map { |e| event_json(e) }
end
def telemetry
role = params.require(:device_role)
state = @session.device_states.find_or_initialize_by(device_role: role)
state.update!(
battery_level: params[:battery_level],
network_type: params[:network_type],
signal_strength: params[:signal_strength],
current_bitrate: params[:current_bitrate],
target_bitrate: params[:target_bitrate],
fps: params[:fps],
last_seen_at: Time.current
)
sync_publisher_when_streaming!(params[:fps].to_f)
SessionChannel.broadcast_message(@session, state.as_cable_payload)
head :no_content
end
def pairing_token
token = SecureRandom.urlsafe_base64(24)
@session.update!(
pairing_token_digest: Digest::SHA256.hexdigest(token),
pairing_token_expires_at: 15.minutes.from_now
)
render json: {
pairing_token: token,
expires_at: @session.pairing_token_expires_at,
qr_payload: {
session_id: @session.id,
pairing_token: token,
api_url: request.base_url
}
}
end
def regia_link
access = Sessions::RegiaAccess.new(@session)
token = access.issue_token!
render json: {
regia_url: access.url(token),
expires_at: @session.regia_token_expires_at
}
end
def claim_pairing
token = params.require(:pairing_token)
digest = Digest::SHA256.hexdigest(token)
unless @session.pairing_token_digest == digest &&
@session.pairing_token_expires_at&.future?
return render json: { error: "Invalid or expired token" }, status: :unauthorized
end
@session.device_states.find_or_create_by!(device_role: params[:device_role] || "controller")
render json: session_json(@session)
end
def network_test
@session.stream_events.create!(
event_type: "network_test",
metadata: params.permit(:download_mbps, :upload_mbps, :latency_ms, :network_type).to_h,
occurred_at: Time.current
)
ready = params[:upload_mbps].to_f >= (@session.target_bitrate / 1_000_000.0 * 0.8)
render json: { ready: ready, target_upload_mbps: @session.target_bitrate / 1_000_000.0 }
end
def youtube_stats
count = if @session.platform == "youtube" && @session.youtube_broadcast_id.present?
Youtube::BroadcastService.new(@session.match.team)
.viewer_count(@session.youtube_broadcast_id)
else
0
end
render json: { concurrent_viewers: count, live: @session.live? }
end
private
def set_session
team_ids = current_user.streamable_teams.map(&:id)
@session = StreamSession.joins(:match)
.where(matches: { team_id: team_ids })
.find(params[:id])
end
def session_params
params.permit(:platform, :privacy_status, :quality_preset, :target_bitrate, :target_fps, :youtube_channel)
end
def score_sync_params
params.permit(
:home_sets, :away_sets, :home_points, :away_points, :current_set,
set_partials: %i[set home away]
)
end
def session_json(session, detail: false)
data = {
id: session.id,
match_id: session.match_id,
status: session.status,
platform: session.platform,
rtmp_ingest_url: session.rtmp_ingest_url,
hls_playback_url: session.hls_playback_url,
watch_page_url: session.matchlivetv_platform? ? session.watch_page_url : nil,
share_url: session.share_url,
youtube_watch_url: session.youtube_watch_url,
youtube_broadcast_id: session.youtube_broadcast_id,
youtube_ready: session.youtube_ready?,
privacy_status: session.privacy_status,
quality_preset: session.quality_preset,
target_bitrate: session.target_bitrate,
started_at: session.started_at,
disconnection_count: session.disconnection_count
}
if detail
data[:score] = session.score_state&.as_cable_payload
data[:devices] = session.device_states.map(&:as_cable_payload)
end
data
end
def event_json(event)
{
id: event.id,
event_type: event.event_type,
metadata: event.metadata,
occurred_at: event.occurred_at
}
end
# L'app invia fps ogni ~10s; poll status.json per allineare stato sessione e relay YouTube.
def sync_publisher_when_streaming!(fps)
return if fps < 1
return if @session.terminal? || @session.paused?
return unless @session.platform == "youtube"
return unless @session.status.in?(%w[connecting live reconnecting])
Mediamtx::PublisherSync.new(@session).call
if @session.platform == "youtube" && @session.status.in?(%w[live connecting reconnecting])
Mediamtx::PublisherSync.schedule_youtube_pipeline!(@session, force: false)
end
end
end
end
end

View File

@@ -0,0 +1,160 @@
module Api
module V1
class TeamsController < BaseController
def index
teams = current_user.streamable_teams
render json: teams.map { |t| team_json(t) }
end
def show
team = current_user.manageable_teams.find(params[:id])
render json: team_json(team, detail: true)
end
def create
if current_user.owned_clubs.exists?
return render json: {
error: "Registra o gestisci la società dal sito web per aggiungere squadre."
}, status: :unprocessable_entity
end
club = Club.create!(name: team_params[:name], sport: team_params[:sport] || "volleyball",
primary_color: "#e53935", secondary_color: "#ffffff")
ClubMembership.create!(user: current_user, club: club, role: "owner")
team = club.teams.create!(name: team_params[:name], sport: club.sport)
Billing::AssignPlan.call(club: club, plan_slug: "free")
render json: team_json(team), status: :created
end
def recordings
team = current_user.streamable_teams.find { |t| t.id.to_s == params[:id].to_s }
raise ActiveRecord::RecordNotFound unless team
unless team.entitlements.can_access_recordings?
return render json: {
error: "Archivio gare disponibile con Premium Light o Full",
error_code: "premium_required",
billing_url: team.entitlements.billing_url
}, status: :forbidden
end
recs = team.recordings.not_deleted
.where(status: %w[ready processing])
.includes(stream_session: :match)
.order(recorded_at: :desc, created_at: :desc)
.limit(50)
render json: recs.map { |r| recording_json(r) }
end
def update
team = current_user.manageable_teams.find(params[:id])
team.update!(team_params)
render json: team_json(team)
end
def add_member
team = current_user.manageable_teams.find(params[:id])
team.entitlements.assert_can_invite!
member = User.find(params[:user_id])
UserTeam.find_or_create_by!(user: member, team: team) { |ut| ut.role = "member" }
head :no_content
end
def remove_member
team = current_user.manageable_teams.find(params[:id])
ut = team.user_teams.find_by!(user_id: params[:user_id], role: "member")
ut.destroy!
head :no_content
end
private
def team_params
params.require(:team).permit(:name, :sport, :logo_url)
end
def team_json(team, detail: false)
ent = team.entitlements
yt = Youtube::TeamStatus.new(team)
resolver = Youtube::CredentialResolver.new(team)
data = {
id: team.id,
name: team.name,
sport: team.sport,
logo_url: team.effective_logo_url,
primary_color: team.effective_primary_color,
secondary_color: team.effective_secondary_color,
club_id: team.club_id,
club_name: team.club.name,
youtube_connected: yt.connected?,
youtube_selectable: yt.selectable?,
youtube_channel_title: yt.channel_title,
youtube_uses_platform_channel: yt.uses_platform_channel?,
youtube_platform_available: resolver.platform_available?,
youtube_team_channel_available: resolver.team_channel_available?,
youtube_team_channel_title: team.club.youtube_credential&.channel_title,
plan_slug: ent.plan.slug,
plan_name: ent.plan.name,
premium_active: ent.premium_active?,
premium_full: ent.premium_full?,
subscription_status: ent.subscription.status,
features: ent.plan.features,
billing_url: ent.billing_url,
staff_manage_url: ent.staff_manage_url,
max_staff: ent.max_staff,
max_staff_transmission: ent.max_staff_transmission,
staff_used: ent.staff_count,
staff_transmission_used: ent.staff_count_for("transmission"),
concurrent_streams_used: ent.concurrent_streams_used,
concurrent_streams_limit: ent.concurrent_streams_limit,
recordings_enabled: ent.can_access_recordings?,
phone_download_enabled: ent.phone_download_enabled?,
youtube_enabled: ent.youtube_enabled?,
youtube_mode: ent.plan.youtube_mode,
staff_role: current_user.staff_role_for(team),
can_stream: current_user.can_stream_for?(team),
can_connect_youtube: team.club.owned_by?(current_user) && ent.premium_full? && ent.youtube_enabled?
}
if detail
data[:members] = team.user_teams.includes(:user).where.not(role: "owner").map do |ut|
{ id: ut.user.id, name: ut.user.name, email: ut.user.email, role: ut.role }
end
end
data
end
def recording_json(recording)
session = recording.stream_session
match = session.match
ent = recording.team.entitlements
{
id: recording.id,
session_id: session.id,
match_id: match.id,
title: recording.title_or_default,
opponent_name: match.opponent_name,
team_name: match.team.name,
status: recording.status,
status_label: recording.status_label,
privacy_status: recording.privacy_status,
ended_at: session.ended_at,
recorded_at: recording.recorded_at_or_fallback,
duration_secs: recording.duration_secs,
duration_label: recording.duration_label,
byte_size: recording.byte_size,
byte_size_label: recording.byte_size_label,
replay_url: recording.replay_url,
playback_url: recording.playback_stream_url,
thumbnail_url: recording.thumbnail_url,
download_enabled: ent.phone_download_enabled?,
view_count: recording.view_count,
views_label: recording.views_label,
youtube_video_id: recording.youtube_video_id,
youtube_watch_url: recording.youtube_watch_url,
youtube_publish_enabled: ent.premium_full? && ent.youtube_enabled?,
expires_at: recording.expires_at,
metadata: recording.metadata
}
end
end
end
end

View File

@@ -0,0 +1,23 @@
module Api
module V1
class YoutubeController < BaseController
def authorize
team = current_user.streamable_teams.find { |t| t.id.to_s == params[:team_id].to_s }
raise ActiveRecord::RecordNotFound unless team
unless team.club.owned_by?(current_user)
return render json: { error: "Solo il titolare della società può collegare YouTube" }, status: :forbidden
end
team.entitlements.assert_can_connect_youtube!
return_app = ActiveModel::Type::Boolean.new.cast(params[:return_app])
state = Youtube::OauthState.for_team(
team_id: team.id,
user_id: current_user.id,
return_app: return_app
)
url = Youtube::OauthUrl.build(state: state, redirect_uri: ENV.fetch("YOUTUBE_REDIRECT_URI"))
render json: { authorization_url: url, return_app: return_app }
end
end
end
end

View File

@@ -0,0 +1,25 @@
class ApplicationController < ActionController::API
include ActionController::HttpAuthentication::Token::ControllerMethods
before_action :authenticate_request!
attr_reader :current_user
private
def authenticate_request!
token = bearer_token
payload = JsonWebToken.decode(token)
@current_user = User.find_by(id: payload[:user_id]) if payload
render json: { error: "Unauthorized" }, status: :unauthorized unless @current_user
end
def bearer_token
auth = request.headers["Authorization"].to_s
auth.start_with?("Bearer ") ? auth.split(" ", 2).last : nil
end
def skip_auth?
false
end
end

View File

View File

@@ -0,0 +1,16 @@
module BrandingAttachments
extend ActiveSupport::Concern
private
def attach_branding_logo(record)
file = params.dig(:branding, :logo_file)
record.logo_file.attach(file) if file.present?
end
def normalize_hex_color(value, fallback)
v = value.to_s.strip
v = "##{v}" if v.match?(/\A[0-9A-Fa-f]{6}\z/)
v.match?(Brandable::HEX_COLOR) ? v : fallback
end
end

View File

@@ -0,0 +1,34 @@
module MediamtxPlayback
extend ActiveSupport::Concern
private
def mediamtx_paths_index
@mediamtx_paths_index ||= Mediamtx::Client.new.list_paths.index_by { |i| i["name"] }
end
def mediamtx_path_info(session, path_name: mediamtx_playback_path_name(session))
mediamtx_paths_index[path_name]
end
def mediamtx_playback_path_name(session)
session.effective_hls_path_name
end
# Player HLS: path grezzo MediaMTX (live/match_{uuid}).
def mediamtx_stream_playable?(session)
return false if session.terminal?
mediamtx_path_has_output?(session)
end
def mediamtx_path_has_output?(session)
info = mediamtx_path_info(session)
info && (info["ready"] || info["available"] || info["online"])
end
def mediamtx_publisher_online?(session)
info = mediamtx_paths_index[session.mediamtx_path_name]
info && info["online"]
end
end

View File

@@ -0,0 +1,44 @@
class HlsProxyController < ActionController::Base
# Proxy pubblico verso MediaMTX HLS (NPM inoltra tutto a Rails :3000).
def show
upstream_path = params[:path].to_s
return head :not_found if upstream_path.blank?
upstream = "#{MatchLiveTv.mediamtx_hls_url}/#{upstream_path}"
upstream = "#{upstream}?#{request.query_string}" if request.query_string.present?
cookie = request.headers["Cookie"].presence || "cookieCheck=1"
response = hls_conn.get(upstream) { |req| req.headers["Cookie"] = cookie }
if response.status == 302
location = response.headers["location"].to_s
follow_url = if location.start_with?("http")
location
else
"#{MatchLiveTv.mediamtx_hls_url.sub(%r{/$}, "")}#{location}"
end
set_cookie = response.headers["set-cookie"].to_s
cookie = set_cookie.presence || cookie
response = hls_conn.get(follow_url) { |req| req.headers["Cookie"] = cookie }
end
response.headers.each do |key, value|
next if %w[transfer-encoding connection].include?(key.downcase)
headers[key] = value
end
render body: response.body, status: response.status
rescue Faraday::Error => e
Rails.logger.warn("[HlsProxy] #{upstream_path}: #{e.message}")
head :bad_gateway
end
private
def hls_conn
@hls_conn ||= Faraday.new do |f|
f.adapter Faraday.default_adapter
f.options.timeout = 15
f.options.open_timeout = 5
end
end
end

View File

@@ -0,0 +1,93 @@
module Public
class ClubBillingController < WebBaseController
before_action :require_login!
before_action :set_club
before_action :require_club_owner_for_club!
def profile
end
def update_profile
@club.assign_attributes(billing_profile_params)
if @club.save(context: :billing_profile)
if premium_checkout_return_params.present? && @club.billing_profile_complete?
redirect_to public_club_checkout_path(
@club,
plan: premium_checkout_return_params[:plan],
interval: premium_checkout_return_params[:interval]
), notice: "Dati salvati. Procedi con il pagamento."
else
redirect_to public_club_billing_path(@club), notice: "Dati di fatturazione aggiornati."
end
else
flash.now[:alert] = @club.errors.full_messages.join(", ")
render :profile, status: :unprocessable_entity
end
end
def cancel_subscription
unless MatchLiveTv.stripe_enabled?
redirect_to public_club_billing_path(@club), alert: "Stripe non configurato."
return
end
Billing::Stripe::CancelSubscription.call(club: @club)
sub = @club.subscription.reload
date = sub.current_period_end ? helpers.l_local(sub.current_period_end.to_date) : "fine periodo"
redirect_to public_club_billing_path(@club),
notice: "Abbonamento disdetto. Resta attivo fino al #{date}; da quel giorno passerai al piano Free."
rescue ArgumentError, RuntimeError => e
redirect_to public_club_billing_path(@club), alert: e.message
rescue ::Stripe::StripeError => e
redirect_to public_club_billing_path(@club), alert: "Errore Stripe: #{e.message}"
end
def download_invoice
invoice = @club.billing_invoices.find(params[:invoice_id])
unless invoice.pdf.attached?
redirect_to public_club_billing_path(@club), alert: "PDF fattura non disponibile."
return
end
redirect_to rails_blob_path(invoice.pdf, disposition: "attachment"), allow_other_host: true
end
private
def set_club
@club = current_user.owned_clubs.find(params[:id])
end
def require_club_owner_for_club!
require_club_owner!(@club)
end
def premium_checkout_return_params
plan = params[:plan].presence_in(%w[premium_light premium_full])
return nil if plan.blank?
{
plan: plan,
interval: params[:interval].presence || Billing::Stripe::PriceCatalog::DEFAULT_INTERVAL
}
end
def billing_profile_params
params.require(:club).permit(
:billing_entity_type,
:billing_legal_name,
:billing_vat_number,
:billing_fiscal_code,
:billing_email,
:billing_phone,
:billing_address_line,
:billing_city,
:billing_province,
:billing_postal_code,
:billing_country,
:billing_recipient_code,
:billing_pec
)
end
end
end

View File

@@ -0,0 +1,85 @@
module Public
class ClubMatchesController < WebBaseController
before_action :require_login!
before_action :set_club
before_action :load_schedulable_teams
before_action :require_any_schedulable_team!
def new
@match = default_match_for_form
@selected_team = resolve_selected_team
end
def create
@selected_team = @schedulable_teams.find { |t| t.id.to_s == params[:team_id].to_s }
unless @selected_team
@match = default_match_for_form
flash.now[:alert] = "Seleziona una squadra valida."
return render :new, status: :unprocessable_entity
end
@match = @selected_team.matches.create!(
match_params.merge(sport: @selected_team.sport, sets_to_win: 3)
)
redirect_to public_live_index_path(club_id: @club.id),
notice: "Partita programmata: #{@selected_team.name} vs #{@match.opponent_name}."
rescue ActiveRecord::RecordInvalid => e
@match = @selected_team.matches.build(match_params)
flash.now[:alert] = e.record.errors.full_messages.join(", ")
render :new, status: :unprocessable_entity
end
private
def set_club
@club = Club.find(params[:club_id])
end
def load_schedulable_teams
@schedulable_teams = current_user.schedulable_teams_for(@club)
@club_admin = @club.owned_by?(current_user)
end
def require_any_schedulable_team!
return if @schedulable_teams.any?
redirect_to public_live_index_path(club_id: @club.id),
alert: "Non hai permessi per programmare partite in questa società."
end
def resolve_selected_team
if params[:team_id].present?
@schedulable_teams.find { |t| t.id.to_s == params[:team_id].to_s }
end || @schedulable_teams.first
end
def default_match_for_form
team = resolve_selected_team
Match.new(
sport: team&.sport || @club.sport,
sets_to_win: 3,
scheduled_at: default_scheduled_at
)
end
def match_params
p = params.require(:match).permit(:opponent_name, :location, :scheduled_at)
p[:scheduled_at] = parse_scheduled_at(p[:scheduled_at]) if p[:scheduled_at].present?
p
end
def parse_scheduled_at(value)
raw = value.to_s.strip
return nil if raw.blank?
Time.zone.strptime(raw, "%Y-%m-%dT%H:%M")
rescue ArgumentError
Time.zone.parse(raw)
end
def default_scheduled_at
t = Time.current + 2.hours
Time.zone.local(t.year, t.month, t.day, t.hour, 0, 0)
end
end
end

View File

@@ -0,0 +1,55 @@
module Public
class ClubRecordingsController < WebBaseController
before_action :require_login!
before_action :set_club
before_action -> { require_club_owner!(@club) }
before_action :set_recording, only: %i[update destroy publish_youtube]
def index
@stats = Recordings::ClubStats.new(@club).call
@recordings = Recording.for_club(@club)
.not_deleted
.includes(stream_session: { match: :team })
.order(recorded_at: :desc, created_at: :desc)
@teams = @club.teams.order(:name)
end
def update
privacy = params.require(:recording).permit(:privacy_status, :title)[:privacy_status]
attrs = {}
attrs[:privacy_status] = privacy if privacy.in?(Recording::PRIVACY_STATUSES)
title = params.dig(:recording, :title)
attrs[:title] = title if title.present?
@recording.update!(attrs)
redirect_to public_club_recordings_path(@club), notice: "Replay aggiornato"
rescue ActiveRecord::RecordInvalid => e
redirect_to public_club_recordings_path(@club), alert: e.record.errors.full_messages.join(", ")
end
def destroy
Recordings::Delete.new(@recording).call
redirect_to public_club_recordings_path(@club), notice: "Replay eliminato"
end
def publish_youtube
ent = @recording.team.entitlements
unless ent.premium_full? && ent.youtube_enabled?
redirect_to public_club_recordings_path(@club), alert: "Republicazione YouTube con Premium Full"
return
end
Recordings::PublishToYoutubeJob.perform_async(@recording.id)
redirect_to public_club_recordings_path(@club), notice: "Pubblicazione su YouTube avviata"
end
private
def set_club
@club = current_user.owned_clubs.find(params[:club_id])
end
def set_recording
@recording = Recording.for_club(@club).not_deleted.find(params[:id])
end
end
end

View File

@@ -0,0 +1,245 @@
module Public
class ClubsController < WebBaseController
include BrandingAttachments
before_action :require_login!
before_action :set_club, only: %i[show edit update billing checkout portal youtube_connect youtube_disconnect]
before_action :require_billing_profile_for_premium_checkout!, only: :checkout
def new
redirect_to public_club_path(current_user.primary_club) if current_user.primary_club
end
def create
if current_user.owned_clubs.exists?
redirect_to public_club_path(current_user.primary_club), alert: "Hai già registrato una società"
return
end
club = Club.new(club_params)
attach_branding_logo(club)
club.save!
ClubMembership.create!(user: current_user, club: club, role: "owner")
first_team_name = params.dig(:first_team, :name).presence || "Prima squadra"
club.teams.create!(
name: first_team_name,
sport: club.sport
)
plan = params[:plan].presence_in(%w[free premium_light premium_full]) || "free"
Billing::AssignPlan.call(club: club, plan_slug: plan)
if plan.in?(%w[premium_light premium_full]) && MatchLiveTv.stripe_enabled?
unless club.billing_profile_complete?
redirect_to public_club_billing_profile_path(club, plan: plan, interval: checkout_interval_param),
alert: "Completa i dati di fatturazione prima di attivare un piano premium."
return
end
interval = checkout_interval_param
redirect_to public_club_checkout_path(club, plan: plan, interval: interval)
else
redirect_to public_club_path(club), notice: "Società e prima squadra create."
end
rescue ActiveRecord::RecordInvalid => e
flash.now[:alert] = e.record.errors.full_messages.join(", ")
render :new, status: :unprocessable_entity
end
def show
require_club_owner!(@club)
apply_checkout_flash!
@entitlements_team = @club.teams.first
@entitlements = @entitlements_team&.entitlements
@teams = @club.teams.order(:name)
@replay_stats = Recordings::ClubStats.new(@club).call if @entitlements&.can_access_recordings?
end
def edit
require_club_owner!(@club)
end
def update
require_club_owner!(@club)
@club.assign_attributes(club_params)
attach_branding_logo(@club)
@club.save!
redirect_to public_club_path(@club), notice: "Società aggiornata."
rescue ActiveRecord::RecordInvalid => e
flash.now[:alert] = e.record.errors.full_messages.join(", ")
render :edit, status: :unprocessable_entity
end
def billing
require_club_owner!(@club)
sync_checkout_return!
finalize_subscription_if_due!
@subscription = @club.subscription&.reload
apply_checkout_flash!
@team = @club.teams.first!
@entitlements = @team.entitlements
@plans = Plan.ordered
@payments = @club.billing_payments.recent.includes(:invoice).limit(50)
end
def checkout
require_club_owner!(@club)
if @club.subscription&.admin_comped?
redirect_to public_club_billing_path(@club),
alert: "Il piano è un abbonamento omaggio gestito da Match Live TV. Per passare a un abbonamento a pagamento contatta il supporto."
return
end
unless MatchLiveTv.stripe_enabled?
redirect_to public_club_billing_path(@club), alert: "Pagamenti non ancora configurati sul server"
return
end
plan_slug = params[:plan].presence_in(%w[premium_light premium_full]) || "premium_light"
interval = checkout_interval_param
target_plan = Plan[plan_slug]
sub = @club.subscription
if sub&.stripe_subscription_id.present? && sub.active? &&
sub.plan.slug == plan_slug && sub.billing_interval == interval && !sub.plan_change_pending?
redirect_to public_club_billing_path(@club),
notice: "Sei già su #{target_plan.name} (#{Billing::Stripe::PriceCatalog.label(plan_slug: plan_slug, interval: interval)})."
return
end
if sub&.plan_change_pending? && sub.pending_plan&.slug == plan_slug &&
sub.pending_billing_interval == interval
when_label = sub.current_period_end.present? ? I18n.l(sub.current_period_end, format: :long) : "il prossimo rinnovo"
redirect_to public_club_billing_path(@club),
notice: "Il passaggio a #{target_plan.name} è già programmato dal #{when_label}."
return
end
if sub&.stripe_subscription_id.present? && sub.active?
result = Billing::Stripe::ChangePlan.call(club: @club, plan_slug: plan_slug, interval: interval)
redirect_to public_club_billing_path(@club),
notice: Billing::Stripe::PlanChangeMessages.flash_notice(
result,
current_plan: sub.plan
)
else
url = Billing::Stripe::CheckoutSession.new(
club: @club, user: current_user, plan_slug: plan_slug, interval: interval
).url
redirect_to url, allow_other_host: true
end
rescue ArgumentError => e
redirect_to public_club_billing_path(@club), alert: e.message
rescue ::Stripe::StripeError => e
Rails.logger.warn("[Stripe checkout] #{e.message}")
redirect_to public_club_billing_path(@club), alert: "Errore Stripe: #{e.message}"
end
def youtube_connect
require_club_owner!(@club)
entitlements = @club.teams.first!.entitlements
entitlements.assert_can_connect_youtube!
if ENV["YOUTUBE_CLIENT_ID"].blank?
redirect_to public_club_path(@club), alert: "YouTube OAuth non configurato sul server"
return
end
return_app = params[:return_app] == "1"
state = Youtube::OauthState.for_club(
club_id: @club.id,
user_id: current_user.id,
return_app: return_app
)
redirect_to Youtube::OauthUrl.build(state: state), allow_other_host: true
rescue Teams::EntitlementError => e
redirect_to public_club_path(@club), alert: e.message
end
def youtube_disconnect
require_club_owner!(@club)
@club.youtube_credential&.destroy!
redirect_to public_club_path(@club), notice: "Canale YouTube della società scollegato"
end
def portal
require_club_owner!(@club)
unless MatchLiveTv.stripe_enabled?
redirect_to public_club_billing_path(@club), alert: "Portale pagamenti non configurato"
return
end
url = Billing::Stripe::CheckoutSession.new(club: @club, user: current_user).portal_url
redirect_to url, allow_other_host: true
end
private
def set_club
@club = current_user.owned_clubs.find(params[:id])
end
def club_params
p = params.require(:club).permit(
:name, :sport, :logo_url, :primary_color, :secondary_color,
:billing_entity_type, :billing_legal_name, :billing_vat_number, :billing_fiscal_code,
:billing_email, :billing_phone, :billing_address_line, :billing_city, :billing_province,
:billing_postal_code, :billing_country, :billing_recipient_code, :billing_pec
)
p[:primary_color] = normalize_hex_color(p[:primary_color], "#e53935")
p[:secondary_color] = normalize_hex_color(p[:secondary_color], "#ffffff")
p
end
def require_billing_profile_for_premium_checkout!
require_club_owner!(@club)
plan_slug = params[:plan].presence_in(%w[premium_light premium_full])
return if plan_slug.blank?
return if @club.billing_profile_complete?
redirect_to public_club_billing_profile_path(
@club,
plan: plan_slug,
interval: params[:interval].presence
), alert: "Completa i dati di fatturazione prima di attivare un piano premium."
end
def checkout_interval_param
Billing::Stripe::PriceCatalog.normalize_interval(params[:interval])
rescue ArgumentError
Billing::Stripe::PriceCatalog::DEFAULT_INTERVAL
end
def finalize_subscription_if_due!
return unless MatchLiveTv.stripe_enabled?
Billing::Stripe::FinalizeSubscription.call(club: @club)
rescue ::Stripe::StripeError => e
Rails.logger.warn("[Stripe finalize subscription] #{e.message}")
end
def sync_checkout_return!
return unless params[:checkout] == "success"
return unless MatchLiveTv.stripe_enabled?
Billing::Stripe::CheckoutSync.call(
club: @club,
session_id: params[:session_id].presence
)
rescue ::Stripe::StripeError => e
Rails.logger.warn("[Stripe checkout sync] #{e.message}")
end
def apply_checkout_flash!
case params[:checkout]
when "success"
plan_name = @subscription&.plan&.name || "premium"
flash.now[:notice] = "Pagamento completato! Piano attivo: #{plan_name}."
when "canceled"
flash.now[:alert] = "Pagamento annullato. Nessun addebito è stato effettuato."
end
end
end
end

View File

@@ -0,0 +1,28 @@
module Public
class InvitationsController < WebBaseController
def show
@token = params[:token]
@invitation = TeamInvitation.pending.find_by(token_digest: Digest::SHA256.hexdigest(@token.to_s))
unless @invitation
redirect_to public_pricing_path, alert: "Invito non valido o scaduto"
end
end
def accept
invitation = TeamInvitation.pending.find_by(token_digest: Digest::SHA256.hexdigest(params[:token].to_s))
return redirect_to public_pricing_path, alert: "Invito non valido" unless invitation
if logged_in?
if current_user.email.downcase != invitation.email.downcase
redirect_to public_pricing_path, alert: "Questo invito è per #{invitation.email}"
return
end
invitation.accept!(current_user)
redirect_to public_team_details_path(invitation.team), notice: "Sei entrato nella squadra!"
else
session[:pending_invite_token] = params[:token]
redirect_to public_signup_path, notice: "Registrati con #{invitation.email} per accettare l'invito"
end
end
end
end

View File

@@ -0,0 +1,86 @@
module Public
class LiveController < SiteBaseController
include MediamtxPlayback
layout "marketing_live"
ACTIVE_STATUSES = %w[live connecting reconnecting].freeze
def index
@query = params[:q].to_s.strip
@club = Club.find_by(id: params[:club_id]) if params[:club_id].present?
team_ids = @club&.teams&.pluck(:id)
sessions = StreamSession
.broadcasting
.publicly_listed
.where(platform: "matchlivetv")
.includes(:score_state, match: { team: :club })
sessions = sessions.joins(:match).where(matches: { team_id: team_ids }) if team_ids.present?
@sessions = sessions
.search_by_team_or_opponent(@query)
.order(Arel.sql("started_at DESC NULLS LAST"), created_at: :desc)
# Solo dirette già in onda: le partite «programmate» restano visibili anche se cè sessione idle.
broadcasting_match_ids = StreamSession.broadcasting.select(:match_id)
upcoming = Match.scheduled_for_live.includes(team: :club)
upcoming = upcoming.where(team_id: team_ids) if team_ids.present?
@upcoming_matches = upcoming
.search_teams_or_opponents(@query)
.where.not(id: broadcasting_match_ids)
.order(scheduled_at: :asc)
.limit(50)
@online_paths = Mediamtx::Client.new.online_path_names
return unless logged_in? && @club
@schedulable_teams = current_user.schedulable_teams_for(@club)
@can_schedule_match = @schedulable_teams.any?
end
def show
@session = StreamSession.includes(match: { team: :club }).find(params[:id])
@session = Mediamtx::PublisherSync.new(@session).call unless @session.terminal?
@match = @session.match
@stream_closed = @session.terminal?
@on_air = !@stream_closed && (
mediamtx_stream_playable?(@session) ||
@session.status.in?(%w[connecting live reconnecting paused])
)
@publisher_online = !@stream_closed && mediamtx_publisher_online?(@session)
end
def status
# Mai cache: il tabellone deve restare allineato con l'app (poll ogni ~1,5s).
response.headers["Cache-Control"] = "no-store, no-cache, must-revalidate"
response.headers["Pragma"] = "no-cache"
session = StreamSession.includes(match: { team: :club }).find(params[:id])
session = Mediamtx::PublisherSync.new(session).call unless session.terminal?
closed = session.terminal?
publisher_online = !closed && mediamtx_publisher_online?(session)
playable = !closed && mediamtx_stream_playable?(session)
render json: {
status: session.status,
paused: session.paused?,
stream_closed: closed,
live: !closed && (
session.live? || session.paused? || session.connecting? || session.reconnecting? ||
mediamtx_publisher_online?(session)
),
on_air: playable || (!closed && session.status.in?(%w[connecting live reconnecting paused])),
publisher_online: publisher_online,
awaiting_signal: !closed && !mediamtx_path_has_output?(session),
showing_cover: !closed && mediamtx_path_has_output?(session) &&
(session.paused? || !mediamtx_publisher_online?(session)),
ended_at: session.ended_at,
home_name: session.match.team.name,
away_name: session.match.opponent_name,
score: session.score_state&.as_cable_payload
}
end
end
end

View File

@@ -0,0 +1,102 @@
module Public
class MatchesController < WebBaseController
before_action :require_login!
before_action :set_team
before_action :require_can_schedule!
before_action :set_match, only: %i[edit update destroy]
def index
@matches = @team.matches
.includes(:stream_sessions)
.order(Arel.sql("scheduled_at ASC NULLS LAST"), created_at: :desc)
@can_manage = @team.club.owned_by?(current_user)
end
def new
@match = @team.matches.build(
sport: @team.sport,
sets_to_win: 3,
scheduled_at: default_scheduled_at
)
end
def create
@match = @team.matches.create!(
match_params.merge(sport: @team.sport, sets_to_win: match_params[:sets_to_win].presence || 3)
)
redirect_to public_team_matches_path(@team),
notice: "Partita programmata: #{@match.opponent_name}. Avvia lo streaming dallapp quando sei in palestra."
rescue ActiveRecord::RecordInvalid => e
@match = @team.matches.build(match_params)
flash.now[:alert] = e.record.errors.full_messages.join(", ")
render :new, status: :unprocessable_entity
end
def edit
end
def update
@match.update!(match_params)
redirect_to public_team_matches_path(@team), notice: "Partita aggiornata."
rescue ActiveRecord::RecordInvalid => e
flash.now[:alert] = e.record.errors.full_messages.join(", ")
render :edit, status: :unprocessable_entity
end
def destroy
active = active_session_for(@match)
if active&.resumable?
redirect_to public_team_matches_path(@team),
alert: "Chiudi la diretta prima di eliminare questa partita."
return
end
@match.destroy!
redirect_to public_team_matches_path(@team), notice: "Partita eliminata."
end
private
def set_team
@team = current_user.manageable_teams.find(params[:team_id])
@club = @team.club
end
def require_can_schedule!
return if current_user.can_schedule_for?(@team)
redirect_to public_team_details_path(@team),
alert: "Solo un responsabile trasmissione o il titolare della società possono programmare le partite."
end
def set_match
@match = @team.matches.find(params[:id])
end
def match_params
p = params.require(:match).permit(:opponent_name, :location, :scheduled_at, :sport, :sets_to_win)
p[:scheduled_at] = parse_scheduled_at(p[:scheduled_at]) if p[:scheduled_at].present?
p
end
def parse_scheduled_at(value)
raw = value.to_s.strip
return nil if raw.blank?
Time.zone.strptime(raw, "%Y-%m-%dT%H:%M")
rescue ArgumentError
Time.zone.parse(raw)
end
def default_scheduled_at
t = Time.current + 2.hours
Time.zone.local(t.year, t.month, t.day, t.hour, 0, 0)
end
def active_session_for(match)
match.stream_sessions
.order(created_at: :desc)
.find { |s| !%w[ended error].include?(s.status) }
end
end
end

View File

@@ -0,0 +1,42 @@
module Public
class PagesController < WebBaseController
def home
end
def features
end
def pricing
@plans = Plan.ordered
load_club_billing_context_for_pricing
end
private
def load_club_billing_context_for_pricing
return unless logged_in?
@club = current_user.primary_club
return unless @club
@subscription = @club.subscription
@team = @club.teams.order(:name).first
@entitlements = @team&.entitlements
end
def privacy
end
def terms
end
def cookies
end
def faq
end
def pallavolo
end
end
end

View File

@@ -0,0 +1,52 @@
module Public
class PasswordResetsController < WebBaseController
def new
end
def create
user = User.find_by(email: params[:email]&.downcase&.strip)
if user
token = user.generate_password_reset!
UserMailer.password_reset(user, token).deliver_now
end
redirect_to public_login_path,
notice: "Se l'email è registrata, riceverai a breve un link per reimpostare la password."
end
def edit
@user = User.find_by_password_reset_token(params[:token])
if @user.nil? || @user.password_reset_expired?
redirect_to new_public_password_reset_path,
alert: "Link non valido o scaduto. Richiedi un nuovo reset password."
return
end
@token = params[:token]
end
def update
@user = User.find_by_password_reset_token(params[:token])
if @user.nil? || @user.password_reset_expired?
redirect_to new_public_password_reset_path,
alert: "Link non valido o scaduto. Richiedi un nuovo reset password."
return
end
if params[:password].blank? || params[:password].length < 8
flash.now[:alert] = "La password deve avere almeno 8 caratteri"
@token = params[:token]
return render :edit, status: :unprocessable_entity
end
if params[:password] != params[:password_confirmation]
flash.now[:alert] = "Le password non coincidono"
@token = params[:token]
return render :edit, status: :unprocessable_entity
end
@user.update!(password: params[:password])
@user.clear_password_reset!
redirect_to public_login_path, notice: "Password aggiornata. Ora puoi accedere."
end
end
end

View File

@@ -0,0 +1,81 @@
module Public
class RegiaController < SiteBaseController
include Public::LiveHelper
include MediamtxPlayback
layout "regia"
protect_from_forgery with: :null_session
skip_before_action :verify_authenticity_token, only: %i[score pause stop]
before_action :set_session_from_token
def show
@match = @session.match
@team = @match.team
@score = @session.score_state || @session.create_score_state!(
home_sets: 0, away_sets: 0, home_points: 0, away_points: 0, current_set: 1, set_partials: []
)
@rules = Scoring::Rules.from_match(@match)
@stream_closed = @session.terminal?
@on_air = !@stream_closed && mediamtx_stream_playable?(@session)
@share_url = request.original_url
@share_title = "Regia — #{@team.name} vs #{@match.opponent_name}"
end
def status
render json: status_payload
end
def score
cmd = params[:cmd].presence || params[:score_action].presence
result = Scoring::ApplyAction.new(session: @session, action: cmd).call
render json: status_payload.merge(
set_won: result.set_won,
match_won: result.match_won,
winner: result.winner&.to_s
)
rescue ArgumentError => e
render json: { error: e.message }, status: :unprocessable_entity
end
def pause
Sessions::Pause.new(@session).call
render json: status_payload
end
def stop
Sessions::Stop.new(@session).call
render json: status_payload
end
private
def set_session_from_token
@session = Sessions::RegiaAccess.find_session_by_token(params[:token])
return if @session
render file: Rails.root.join("public/404.html"), status: :not_found, layout: false
throw :abort
end
def status_payload
score = @session.score_state
closed = @session.terminal?
playable = !closed && mediamtx_stream_playable?(@session)
{
status: @session.status,
paused: @session.paused?,
stream_closed: closed,
live: !closed && (@session.live? || @session.paused? || mediamtx_publisher_online?(@session)),
on_air: playable,
publisher_online: !closed && mediamtx_publisher_online?(@session),
ended_at: @session.ended_at,
home_name: @session.match.team.name,
away_name: @session.match.opponent_name,
points_target: Scoring::Rules.from_match(@session.match).points_target(score&.current_set || 1),
score: score&.as_cable_payload
}
end
end
end

View File

@@ -0,0 +1,39 @@
module Public
class RegistrationsController < WebBaseController
def new
redirect_to public_club_path(current_user.primary_club) if logged_in? && current_user.primary_club
@user = User.new
end
def create
unless params[:accept_terms] == "1"
@user = User.new(user_params.merge(role: "coach"))
flash.now[:alert] = "Devi accettare linformativa privacy e i termini di servizio per registrarti."
return render :new, status: :unprocessable_entity
end
@user = User.new(user_params.merge(role: "coach"))
if @user.save
session[:user_id] = @user.id
if session[:pending_invite_token].present?
token = session.delete(:pending_invite_token)
invitation = TeamInvitation.pending.find_by(token_digest: Digest::SHA256.hexdigest(token))
if invitation && invitation.email.downcase == @user.email.downcase
invitation.accept!(@user)
return redirect_to public_team_details_path(invitation.team), notice: "Benvenuto nella squadra!"
end
end
redirect_to public_new_club_path, notice: "Account creato. Ora registra la tua società."
else
flash.now[:alert] = @user.errors.full_messages.join(", ")
render :new, status: :unprocessable_entity
end
end
private
def user_params
params.require(:user).permit(:name, :email, :password, :password_confirmation)
end
end
end

View File

@@ -0,0 +1,103 @@
module Public
class ReplayController < SiteBaseController
layout "marketing_live"
before_action :set_session_and_recording, only: %i[show stream thumbnail download]
before_action :authorize_replay_access!, only: %i[show stream thumbnail download]
def index
@query = params[:q].to_s.strip
@recordings = Recording.ready.publicly_listed
.includes(stream_session: { match: { team: :club } })
.search_replays(@query)
.order(recorded_at: :desc, created_at: :desc)
.limit(100)
if params[:club_id].present?
@recordings = @recordings.joins(:team).where(teams: { club_id: params[:club_id] })
end
if params[:team_id].present?
@recordings = @recordings.where(team_id: params[:team_id])
end
@clubs = Club.joins(teams: :recordings)
.merge(Recording.ready.publicly_listed)
.distinct
.order(:name)
@filter_club = @clubs.find { |c| c.id.to_s == params[:club_id].to_s } if params[:club_id].present?
end
def show
@match = @session.match
end
def stream
Recordings::IncrementViews.new(@recording).call
serve_video(disposition: "inline")
end
def thumbnail
serve_thumbnail
end
def download
unless download_allowed?
redirect_to public_replay_path(@session), alert: "Download non disponibile"
return
end
serve_video(disposition: "attachment")
end
private
def serve_video(disposition:)
Recordings::ServeFromStorage.new(
key: @recording.storage_key,
content_type: "video/mp4",
disposition: disposition,
filename: disposition == "attachment" ? download_filename : nil
).call(self)
rescue ArgumentError
head :not_found
end
def serve_thumbnail
key = @recording.thumbnail_storage_key
return head :not_found if key.blank?
Recordings::ServeFromStorage.new(
key: key,
content_type: "image/jpeg",
disposition: "inline"
).call(self)
rescue ArgumentError
head :not_found
end
def download_allowed?
ent = @recording.team.entitlements
return false unless ent.phone_download_enabled?
Recordings::AccessPolicy.new(@recording, viewer: current_user).allowed? ||
Recordings::AccessPolicy.new(@recording, viewer: current_user).manage_allowed?
end
def download_filename
slug = @recording.title_or_default.parameterize.presence || "replay"
"#{slug}.mp4"
end
def set_session_and_recording
@session = StreamSession.includes(match: { team: :club }).find(params[:id])
@recording = Recording.not_deleted.find_by(stream_session: @session)
return if @recording
redirect_to public_live_path(@session), alert: "Replay non disponibile"
end
def authorize_replay_access!
return if Recordings::AccessPolicy.new(@recording, viewer: current_user).allowed?
redirect_to public_live_index_path, alert: "Replay non disponibile"
end
end
end

View File

@@ -0,0 +1,32 @@
module Public
class SessionsController < WebBaseController
def new
if logged_in? && current_user.primary_club
redirect_to public_club_path(current_user.primary_club)
end
end
def create
user = User.find_by(email: params[:email]&.downcase)
if user&.authenticate(params[:password])
session[:user_id] = user.id
dest = if user.primary_club
public_club_path(user.primary_club)
elsif user.manageable_teams.first
public_team_details_path(user.manageable_teams.first)
else
public_new_club_path
end
redirect_to dest, notice: "Bentornato!"
else
flash.now[:alert] = "Email o password non validi"
render :new, status: :unauthorized
end
end
def destroy
reset_session
redirect_to public_pricing_path, notice: "Disconnesso"
end
end
end

View File

@@ -0,0 +1,28 @@
module Public
class SiteBaseController < ActionController::Base
layout "marketing"
include ::SeoHelper
include ::LegalHelper
helper ApplicationHelper
helper_method :current_user, :logged_in?
before_action :set_site_locale
private
def set_site_locale
I18n.locale = :it
end
def current_user
return @current_user if defined?(@current_user)
@current_user = User.find_by(id: session[:user_id]) if session[:user_id]
end
def logged_in?
current_user.present?
end
end
end

View File

@@ -0,0 +1,22 @@
module Public
class SitemapController < ActionController::Base
def show
base = MatchLiveTv.app_public_url.chomp("/")
@entries = [
{ loc: "#{base}/", changefreq: "weekly", priority: "1.0" },
{ loc: "#{base}/funzionalita", changefreq: "monthly", priority: "0.9" },
{ loc: "#{base}/prezzi", changefreq: "monthly", priority: "0.9" },
{ loc: "#{base}/pallavolo-giovanile", changefreq: "monthly", priority: "0.85" },
{ loc: "#{base}/faq", changefreq: "monthly", priority: "0.8" },
{ loc: "#{base}/live", changefreq: "hourly", priority: "0.85" },
{ loc: "#{base}/privacy", changefreq: "yearly", priority: "0.3" },
{ loc: "#{base}/cookie", changefreq: "yearly", priority: "0.3" },
{ loc: "#{base}/termini", changefreq: "yearly", priority: "0.3" }
]
respond_to do |format|
format.xml { render layout: false }
end
end
end
end

View File

@@ -0,0 +1,63 @@
module Public
class TeamRosterMembersController < WebBaseController
before_action :require_login!
before_action :set_team
before_action :require_team_owner!
before_action :set_member, only: %i[edit update destroy]
def create
member = @team.roster_members.build(member_params)
attach_photo(member)
member.save!
redirect_to public_team_details_path(@team), notice: "#{member.full_name} aggiunto all'organico."
rescue ActiveRecord::RecordInvalid => e
redirect_to public_team_details_path(@team), alert: e.record.errors.full_messages.join(", ")
end
def edit
@club = @team.club
end
def update
@member.assign_attributes(member_params)
attach_photo(@member)
@member.save!
redirect_to public_team_details_path(@team), notice: "Scheda aggiornata."
rescue ActiveRecord::RecordInvalid => e
@club = @team.club
flash.now[:alert] = e.record.errors.full_messages.join(", ")
render :edit, status: :unprocessable_entity
end
def destroy
name = @member.full_name
@member.destroy!
redirect_to public_team_details_path(@team), notice: "#{name} rimosso dall'organico."
end
private
def set_team
@team = current_user.manageable_teams.find(params[:team_id])
end
def require_team_owner!
require_club_owner_for_team!(@team)
end
def set_member
@member = @team.roster_members.find(params[:id])
end
def member_params
params.require(:team_roster_member).permit(
:category, :full_name, :role_label, :jersey_number, :bio, :position
)
end
def attach_photo(member)
file = params.dig(:team_roster_member, :photo_file)
member.photo_file.attach(file) if file.present?
end
end
end

View File

@@ -0,0 +1,180 @@
module Public
class TeamsController < WebBaseController
include BrandingAttachments
before_action :require_login!
before_action :set_club, only: %i[new create]
before_action :set_team, only: %i[
details dashboard roster edit update invite create_invitation
assign_self_staff clear_self_staff remove_member destroy_invitation
youtube_connect youtube_disconnect
]
def new
redirect_to public_new_club_path if current_user.owned_clubs.none?
require_club_owner!(@club)
end
def create
require_club_owner!(@club)
team = @club.teams.create!(team_params)
attach_branding_logo(team)
redirect_to public_club_path(@club), notice: "Squadra «#{team.name}» aggiunta."
rescue ActiveRecord::RecordInvalid => e
flash.now[:alert] = e.record.errors.full_messages.join(", ")
render :new, status: :unprocessable_entity
end
def details
load_team_details!
render :details
end
def dashboard
redirect_to public_team_details_path(params[:id])
end
def roster
redirect_to public_team_details_path(params[:id])
end
def edit
require_club_owner_for_team!(@team)
@club = @team.club
end
def update
require_club_owner_for_team!(@team)
@team.assign_attributes(team_params)
attach_branding_logo(@team)
attach_team_photo(@team)
@team.save!
redirect_to public_team_details_path(@team), notice: "Squadra aggiornata."
rescue ActiveRecord::RecordInvalid => e
@club = @team.club
flash.now[:alert] = e.record.errors.full_messages.join(", ")
render :edit, status: :unprocessable_entity
end
def invite
require_club_owner_for_team!(@team)
@entitlements = @team.entitlements
end
def assign_self_staff
require_club_owner_for_team!(@team)
membership = current_user.user_teams.find_or_initialize_by(team: @team)
membership.role = "member" if membership.new_record?
Teams::StaffAssignment.call(team: @team, user: current_user, membership: membership)
redirect_to public_team_details_path(@team), notice: "Il tuo account è ora responsabile trasmissione."
rescue Teams::StaffAssignmentError, Teams::EntitlementError => e
redirect_to public_team_details_path(@team), alert: e.message
end
def clear_self_staff
require_club_owner_for_team!(@team)
membership = current_user.user_teams.find_by(team: @team)
membership&.update!(staff_kind: nil)
redirect_to public_team_details_path(@team), notice: "Ruolo staff rimosso dal tuo account."
end
def create_invitation
require_club_owner_for_team!(@team)
@entitlements = @team.entitlements
staff_kind = "transmission"
@entitlements.assert_can_invite!(staff_kind: staff_kind)
email = params[:email]&.downcase&.strip
Teams::StaffEmailValidator.assert_available!(team: @team, email: email, staff_kind: staff_kind)
token = TeamInvitation.generate_token
@team.team_invitations.create!(
email: email,
token_digest: Digest::SHA256.hexdigest(token),
role: "member",
staff_kind: staff_kind,
expires_at: 7.days.from_now
)
@invite_url = join_public_invitation_url(token: token)
flash.now[:notice] = "Link invito generato (valido 7 giorni)"
render :invite
rescue Teams::EntitlementError, Teams::StaffAssignmentError => e
redirect_to public_team_invite_path(@team), alert: e.message
end
def remove_member
require_club_owner_for_team!(@team)
ut = @team.user_teams.find_by!(user_id: params[:user_id], role: "member")
ut.destroy!
redirect_to public_team_details_path(@team), notice: "Accesso revocato"
end
def destroy_invitation
require_club_owner_for_team!(@team)
inv = @team.team_invitations.pending.find(params[:invitation_id])
inv.destroy!
redirect_to public_team_details_path(@team), notice: "Invito annullato"
end
def youtube_connect
redirect_to public_club_youtube_connect_path(
@team.club_id,
return_app: params[:return_app]
)
end
def youtube_disconnect
require_club_owner_for_team!(@team)
@team.club.youtube_credential&.destroy!
redirect_to public_club_path(@team.club), notice: "Canale YouTube della società scollegato"
end
private
def load_team_details!
@club = @team.club
@can_manage = @club.owned_by?(current_user)
@entitlements = @team.entitlements
@roster_by_category = @team.roster_by_category
if @can_manage
@roster_member = @team.roster_members.build(
category: params[:category].presence_in(TeamRosterMember::CATEGORIES) || "player"
)
end
@recordings = @team.recordings.not_deleted
.where(status: %w[ready processing])
.includes(stream_session: :match)
.order(recorded_at: :desc, created_at: :desc)
.limit(10)
@owner_membership = current_user.user_teams.find_by(team: @team)
@staff_memberships = @team.user_teams.includes(:user)
.where("user_teams.role = 'member' OR (user_teams.staff_kind IS NOT NULL)")
@pending_invitations = @team.team_invitations.pending.order(created_at: :desc)
end
def set_club
@club = current_user.owned_clubs.find(params[:club_id])
end
def set_team
@team = current_user.manageable_teams.find(params[:id])
end
def attach_team_photo(team)
file = params.dig(:team, :photo_file)
team.photo_file.attach(file) if file.present?
end
def team_params
p = params.require(:team).permit(:name, :sport, :description, :logo_url, :primary_color, :secondary_color)
p[:primary_color] = p[:primary_color].presence
p[:secondary_color] = p[:secondary_color].presence
if p[:primary_color].present?
p[:primary_color] = normalize_hex_color(p[:primary_color], p[:primary_color])
end
if p[:secondary_color].present?
p[:secondary_color] = normalize_hex_color(p[:secondary_color], p[:secondary_color])
end
p
end
end
end

View File

@@ -0,0 +1,21 @@
module Public
class WebBaseController < SiteBaseController
protect_from_forgery with: :exception
private
def require_login!
return if logged_in?
redirect_to public_login_path, alert: "Accedi per continuare"
end
def require_club_owner!(club)
redirect_to public_prezzi_path, alert: "Accesso non consentito" unless club.owned_by?(current_user)
end
def require_club_owner_for_team!(team)
redirect_to public_prezzi_path, alert: "Accesso non consentito" unless team.club&.owned_by?(current_user)
end
end
end

View File

@@ -0,0 +1,53 @@
module Webhooks
class MediamtxController < ApplicationController
skip_before_action :authenticate_request!
before_action :verify_signature!
def connect
handle_event("connect")
end
def disconnect
handle_event("disconnect")
end
def ready
handle_event("ready")
end
def validate_publish
session_id = params[:session_id] || extract_session_id(params[:path])
token = params[:token]
session = StreamSession.find_by(id: session_id)
valid = session && session.publish_token == token && !session.ended?
render json: { valid: valid }, status: valid ? :ok : :forbidden
end
private
def handle_event(event)
session_id = params[:session_id].presence || extract_session_id(params[:path])
Webhooks::MediamtxHandler.new(
event: event,
session_id: session_id,
metadata: params.permit!.to_h.except("controller", "action")
).call
head :ok
end
def extract_session_id(path)
path.to_s[%r{match_([0-9a-f-]+)}, 1]
end
def verify_signature!
signature = request.headers["X-MediaMTX-Signature"]
payload = request.raw_post.presence || request.query_string
return if Webhooks::Signature.valid?(payload, signature)
return if Rails.env.development? && signature.blank?
head :unauthorized
end
end
end

View File

@@ -0,0 +1,32 @@
module Webhooks
class StripeController < ActionController::API
def create
payload = request.body.read
sig_header = request.env["HTTP_STRIPE_SIGNATURE"]
unless MatchLiveTv.stripe_webhook_secret.present?
Rails.logger.info("[Stripe webhook] ignored — STRIPE_WEBHOOK_SECRET not set")
return head :ok
end
event = ::Stripe::Webhook.construct_event(
payload, sig_header, MatchLiveTv.stripe_webhook_secret
)
Billing::Stripe::WebhookHandler.call(event)
head :ok
rescue JSON::ParserError, ::Stripe::SignatureVerificationError => e
Rails.logger.warn("[Stripe webhook] #{e.message}")
head :bad_request
end
private
def stripe_object_from_hash(hash)
OpenStruct.new(hash.transform_keys(&:to_s).transform_values do |v|
v.is_a?(Hash) ? stripe_object_from_hash(v) : v
end)
end
end
end

View File

@@ -0,0 +1,49 @@
# Callback OAuth YouTube (HTML). Non usare Api::V1 — ActionController::API non renderizza le view.
class YoutubeOauthCallbackController < ActionController::Base
def show
return redirect_to_oauth_error("Codice OAuth mancante") if params[:code].blank?
ctx = Youtube::OauthState.verify!(params[:state])
tokens = Youtube::OauthExchange.call(params[:code])
if ctx[:kind] == :platform
@refresh_token = tokens[:refresh_token]
@channel_title = tokens[:channel_title]
return render "admin/youtube/platform_token", layout: false
end
user = User.find(ctx[:user_id])
club = Club.find(ctx[:club_id])
unless club.owned_by?(user)
return redirect_to_oauth_error("Solo il titolare della società può collegare il canale YouTube")
end
cred = club.youtube_credential || club.build_youtube_credential
cred.update!(
access_token: tokens[:access_token],
refresh_token: tokens[:refresh_token] || cred.refresh_token,
expires_at: Time.current + tokens[:expires_in].seconds,
channel_id: tokens[:channel_id],
channel_title: tokens[:channel_title]
)
if ctx[:return_app]
redirect_to "matchlivetv://youtube-connected?club_id=#{club.id}", allow_other_host: true
else
redirect_to "#{public_base_url}/clubs/#{club.id}?youtube=connected", allow_other_host: true
end
rescue ArgumentError, Youtube::BroadcastService::Error => e
redirect_to_oauth_error(e.message)
end
private
def public_base_url
MatchLiveTv.app_public_url.chomp("/")
end
def redirect_to_oauth_error(message)
redirect_to "#{public_base_url}/prezzi?youtube_error=#{ERB::Util.url_encode(message)}",
allow_other_host: true
end
end

View File

@@ -0,0 +1,22 @@
module AdminHelper
def format_bytes(bytes)
return "" if bytes.nil?
units = %w[B KB MB GB TB]
size = bytes.to_f
unit = units.shift
while size >= 1024 && units.any?
size /= 1024
unit = units.shift
end
"#{size.round(size >= 10 ? 0 : 1)} #{unit}"
end
def format_duration_minutes(minutes)
return "0 min" if minutes.to_i <= 0
hours = minutes / 60
mins = minutes % 60
hours.positive? ? "#{hours}h #{mins}m" : "#{mins} min"
end
end

View File

@@ -0,0 +1,19 @@
module ApplicationHelper
PLAN_ICONS = {
"free" => "fa-solid fa-seedling",
"premium_light" => "fa-solid fa-rocket",
"premium_full" => "fa-solid fa-crown"
}.freeze
def plan_icon_class(plan)
PLAN_ICONS[plan.slug] || "fa-solid fa-circle"
end
# Data/ora nel fuso dell'app (Europe/Rome) e nella lingua del sito.
def l_local(date_or_time, format: :long)
return nil if date_or_time.blank?
value = date_or_time.respond_to?(:in_time_zone) ? date_or_time.in_time_zone : date_or_time
I18n.with_locale(:it) { I18n.l(value, format: format) }
end
end

View File

@@ -0,0 +1,9 @@
module LegalHelper
def legal_last_updated
"3 giugno 2026"
end
def cookie_policy_last_updated
"3 giugno 2026"
end
end

View File

@@ -0,0 +1,96 @@
module Public
module BillingHelper
def plan_billing_action(current_slug:, target_plan:, stripe_subscription_active:, current_interval: nil, subscription: nil)
if target_plan.slug == "free"
return { kind: :current, label: "Piano attuale" } if current_slug == "free"
return { kind: :none } if stripe_subscription_active
return { kind: :contact, label: "Per passare al piano Free, contatta il supporto." }
end
unless MatchLiveTv.stripe_enabled?
return { kind: :disabled, label: "Stripe non configurato" }
end
intervals = Billing::Stripe::PriceCatalog.available_intervals(plan_slug: target_plan.slug)
return { kind: :disabled, label: "Prezzi Stripe non configurati" } if intervals.empty?
active_interval = current_interval.presence || Billing::Stripe::PriceCatalog::DEFAULT_INTERVAL
if current_slug == target_plan.slug && stripe_subscription_active && !subscription&.plan_change_pending?
other_intervals = intervals - [active_interval]
if other_intervals.empty?
label = "Piano attuale — #{Billing::Stripe::PriceCatalog.label(plan_slug: target_plan.slug, interval: active_interval)}"
return { kind: :current, label: label }
end
return {
kind: :interval_switch,
plan: target_plan,
intervals: other_intervals,
current_interval: active_interval,
current_slug: current_slug,
subscription: subscription
}
end
if current_slug == "free" || !stripe_subscription_active
{ kind: :checkout_options, plan: target_plan, intervals: intervals, subscription: subscription }
else
{
kind: :change_options,
plan: target_plan,
intervals: intervals,
current_slug: current_slug,
current_interval: active_interval,
subscription: subscription
}
end
end
def plan_interval_checkout_path(club, plan, interval)
public_club_checkout_path(club, plan: plan.slug, interval: interval)
end
def plan_interval_button_label(plan, interval, kind: :checkout, **)
btn_kind = kind == :checkout_options ? :checkout : :change
Billing::Stripe::PlanChangeMessages.button_label(plan: plan, interval: interval, kind: btn_kind)
end
def billing_plan_change_info_lines(subscription: nil)
Billing::Stripe::PlanChangeMessages.billing_info_lines(subscription: subscription)
end
def stripe_subscription_active?(subscription)
subscription&.stripe_subscription_id.present? && subscription.active?
end
def stripe_interval_available?(plan_slug, interval)
Billing::Stripe::PriceCatalog.configured?(plan_slug: plan_slug, interval: interval)
end
def plan_interval_button_class(interval, **)
if interval.to_s == "yearly"
"btn btn-primary plan-interval-btn plan-interval-btn--yearly"
else
"btn btn-outline plan-interval-btn plan-interval-btn--monthly"
end
end
def plan_intervals_for_display(intervals)
Array(intervals).sort_by { |i| i.to_s == "yearly" ? 0 : 1 }
end
def billing_profile_blocks_premium?(club)
club.present? && !club.billing_profile_complete?
end
def billing_profile_incomplete_message(club)
missing = club.billing_profile_errors
return "Completa i dati di fatturazione prima di attivare un piano premium." if missing.empty?
"Mancano: #{missing.join(", ")}."
end
end
end

View File

@@ -0,0 +1,94 @@
module Public
module LiveHelper
def live_score_sets_label(score_state)
return nil unless score_state
"Set #{score_state.current_set} · Set vinti #{score_state.home_sets}-#{score_state.away_sets}"
end
def live_score_partials_label(score_state)
return nil unless score_state
partials = Array(score_state.set_partials)
return nil if partials.empty?
partials.map { |p| format_set_partial_entry(p) }.join(" · ")
end
def live_scheduled_label(datetime)
return nil unless datetime
datetime.in_time_zone.strftime("%d/%m/%Y alle %H:%M")
end
def live_scheduled_relative(datetime)
return nil unless datetime
if datetime.to_date == Time.zone.today
"Oggi alle #{datetime.strftime('%H:%M')}"
elsif datetime.to_date == Time.zone.tomorrow
"Domani alle #{datetime.strftime('%H:%M')}"
else
live_scheduled_label(datetime)
end
end
def live_match_card_heading(match)
team = match.team
club_name = team.club&.name.presence || "Società"
content_tag(:h3, class: "live-card__title") do
safe_join([
content_tag(:span, club_name, class: "live-card__club"),
content_tag(:span, "#{team.name} vs #{match.opponent_name}", class: "live-card__matchup")
])
end
end
def live_match_page_heading(match)
team = match.team
club_name = team.club&.name.presence || "Società"
content_tag(:div, class: "live-page-heading") do
safe_join([
content_tag(:p, club_name, class: "live-page-heading__club"),
content_tag(:h1, "#{team.name} vs #{match.opponent_name}", class: "live-page-heading__matchup")
])
end
end
def live_score_points_label(match, score_state)
return "" unless score_state
"#{match.team.name} #{score_state.home_points} - #{score_state.away_points} #{match.opponent_name}"
end
# Colore ospite sul tabellone: secondario società se leggibile su bianco, altrimenti blu visitatore.
def live_scorebug_away_color(team)
club = team.club
candidate = club&.effective_secondary_color.presence || "#1565c0"
return candidate unless light_hex_color?(candidate)
"#1565c0"
end
private
def light_hex_color?(hex)
h = hex.to_s.delete_prefix("#")
return false unless h.match?(/\A\h{6}\z/i)
r = h[0..1].to_i(16)
g = h[2..3].to_i(16)
b = h[4..5].to_i(16)
(0.299 * r + 0.587 * g + 0.114 * b) > 200
end
def format_set_partial_entry(partial)
data = partial.respond_to?(:with_indifferent_access) ? partial.with_indifferent_access : partial
set_no = data[:set] || data["set"]
home = data[:home] || data["home"]
away = data[:away] || data["away"]
label = set_no.present? ? "Set #{set_no}" : "Set"
"#{label} #{home}-#{away}"
end
end
end

View File

@@ -0,0 +1,32 @@
module RosterHelper
def roster_person_avatar(person, team, size: 96)
primary = team.effective_primary_color
secondary = team.effective_secondary_color
style = "--avatar-primary:#{primary};--avatar-secondary:#{secondary};width:#{size}px;height:#{size}px"
if person.photo_url.present?
image_tag person.photo_url, alt: person.full_name, class: "roster-avatar roster-avatar--photo",
style: style, width: size, height: size
else
tag.div(
person.initials,
class: "roster-avatar roster-avatar--placeholder",
style: "#{style};font-size:#{(size * 0.34).round}px",
aria: { label: person.full_name }
)
end
end
def roster_category_options
TeamRosterMember::DISPLAY_ORDER.map do |cat|
[TeamRosterMember::CATEGORY_LABELS[cat], cat]
end
end
def roster_player_role_options(selected = nil)
options_for_select(
[["— Seleziona ruolo —", ""]] + TeamRosterMember::VOLLEYBALL_PLAYER_ROLES.map { |r| [r, r] },
selected
)
end
end

View File

@@ -0,0 +1,33 @@
module SeoHelper
DEFAULT_OG_IMAGE_PATH = "/og-share.png"
def seo_site_url
MatchLiveTv.app_public_url.chomp("/")
end
def seo_absolute_url(path)
path = "/#{path}" unless path.start_with?("/")
"#{seo_site_url}#{path}"
end
def seo_canonical_url
if content_for?(:canonical_url)
content_for(:canonical_url)
else
request.original_url.split("?").first
end
end
def seo_og_image_url
if content_for?(:og_image)
img = content_for(:og_image)
img.start_with?("http") ? img : seo_absolute_url(img)
else
seo_absolute_url(DEFAULT_OG_IMAGE_PATH)
end
end
def seo_robots_content
content_for?(:robots) ? content_for(:robots) : "index, follow"
end
end

View File

@@ -0,0 +1,9 @@
module StaffHelper
def staff_role_label(membership, team)
Teams::StaffCoverage.new(team).role_label_for(membership)
end
def staff_coverage_for(team)
Teams::StaffCoverage.new(team)
end
end

View File

@@ -0,0 +1,7 @@
class ApplicationJob < ActiveJob::Base
# Automatically retry jobs that encountered a deadlock
# retry_on ActiveRecord::Deadlocked
# Most jobs are safe to ignore if the underlying records are no longer available
# discard_on ActiveJob::DeserializationError
end

View File

@@ -0,0 +1,12 @@
class CleanupExpiredSessionsJob
include Sidekiq::Job
def perform
StreamSession.where(status: %w[connecting reconnecting])
.where("updated_at < ?", 6.hours.ago)
.find_each do |session|
session.fail! if session.may_fail?
Mediamtx::Client.new.delete_path(session)
end
end
end

View File

@@ -0,0 +1,22 @@
class DisconnectionTimeoutJob
include Sidekiq::Job
def perform(session_id)
session = StreamSession.find_by(id: session_id)
return unless session&.reconnecting?
session.finish! if session.may_finish?
session.update!(timeout_job_id: nil)
session.stream_events.create!(
event_type: "error",
metadata: { reason: "reconnect_timeout" },
occurred_at: Time.current
)
SessionChannel.broadcast_message(session, {
type: "stream_event",
event: "timeout_ended",
message: "Session ended after reconnect timeout"
})
Sessions::Stop.new(session).call
end
end

View File

@@ -0,0 +1,17 @@
# Passa a Free le società con disdetta programmata e periodo scaduto (anche senza visita pagina billing).
class ExpireEndedSubscriptionsJob
include Sidekiq::Job
def perform
free_plan = Plan["free"]
Subscription.where(cancel_at_period_end: true)
.where("current_period_end <= ?", Time.current)
.where.not(plan_id: free_plan.id)
.find_each do |sub|
Billing::Stripe::FinalizeSubscription.call(club: sub.club)
rescue StandardError => e
Rails.logger.warn("[ExpireEndedSubscriptions] club=#{sub.club_id} #{e.message}")
end
end
end

View File

@@ -0,0 +1,17 @@
class NotifyStreamHealthJob
include Sidekiq::Job
def perform(session_id)
session = StreamSession.find_by(id: session_id)
return unless session&.live?
camera = session.device_states.find_by(device_role: "camera")
return unless camera&.current_bitrate && camera.current_bitrate < session.target_bitrate * 0.5
SessionChannel.broadcast_message(session, {
type: "stream_event",
event: "quality_degraded",
bitrate: camera.current_bitrate
})
end
end

View File

@@ -0,0 +1,18 @@
module Recordings
class ExpiryWarningJob
include Sidekiq::Job
sidekiq_options retry: 1, queue: "default"
def perform
Recording.ready
.where(expiry_warning_sent_at: nil)
.where.not(expires_at: nil)
.where(expires_at: ..7.days.from_now)
.find_each do |recording|
Recordings::NotifyExpiring.new(recording).call
rescue StandardError => e
Rails.logger.warn("[Recordings::ExpiryWarningJob] #{recording.id}: #{e.message}")
end
end
end
end

View File

@@ -0,0 +1,18 @@
module Recordings
class PostProcessJob
include Sidekiq::Job
sidekiq_options retry: 2, queue: "default"
def perform(recording_id)
recording = Recording.find_by(id: recording_id)
return unless recording&.ready?
Recordings::NotifyReady.new(recording).call
return unless recording.auto_publish_youtube?
return if recording.youtube_video_id.present?
Recordings::PublishToYoutubeJob.perform_async(recording.id)
end
end
end

View File

@@ -0,0 +1,17 @@
module Recordings
class PublishToYoutubeJob
include Sidekiq::Job
sidekiq_options retry: 2, queue: "default"
def perform(recording_id)
recording = Recording.find_by(id: recording_id)
return unless recording&.ready?
Recordings::PublishToYoutube.new(recording).call
rescue Recordings::PublishToYoutube::Error => e
meta = recording.metadata.merge("youtube_publish_error" => e.message, "youtube_publish_failed_at" => Time.current.iso8601)
recording.update!(metadata: meta)
Rails.logger.warn("[Recordings::PublishToYoutubeJob] #{recording_id}: #{e.message}")
end
end
end

View File

@@ -0,0 +1,14 @@
module Recordings
class PurgeExpiredJob
include Sidekiq::Job
sidekiq_options retry: 1, queue: "default"
def perform
Recording.expired_pending_purge.find_each do |recording|
Recordings::Delete.new(recording, reason: :expired).call
rescue StandardError => e
Rails.logger.warn("[Recordings::PurgeExpiredJob] #{recording.id}: #{e.message}")
end
end
end
end

View File

@@ -0,0 +1,14 @@
module Recordings
class UploadJob
include Sidekiq::Job
sidekiq_options retry: 3, queue: "default"
def perform(session_id)
session = StreamSession.find_by(id: session_id)
return unless session
Recordings::UploadFromSession.new(session).call
Recordings::PurgeExpiredJob.perform_async
end
end
end

View File

@@ -0,0 +1,16 @@
class StreamAnalyticsJob
include Sidekiq::Job
def perform(session_id)
session = StreamSession.find_by(id: session_id)
return unless session&.ended?
duration = session.total_duration_secs
disconnects = session.disconnection_count
session.stream_events.create!(
event_type: "quality_changed",
metadata: { analytics: true, duration: duration, disconnects: disconnects },
occurred_at: Time.current
)
end
end

View File

@@ -0,0 +1,37 @@
# Poll MediaMTX + pipeline YouTube automatica (webhook MediaMTX non disponibile in prod).
class StreamPublisherSyncJob < ApplicationJob
queue_as :default
INTERVAL = 5.seconds
ACTIVE_STATUSES = %w[connecting live reconnecting paused].freeze
REDIS_CHAIN_KEY = "stream_publisher_sync:chain"
RUN_LOCK_KEY = "stream_publisher_sync:run_lock"
def self.ensure_chain
return if redis.get(REDIS_CHAIN_KEY)
redis.set(REDIS_CHAIN_KEY, "1", ex: INTERVAL.to_i * 4)
set(wait: INTERVAL).perform_later
end
def self.redis
@redis ||= Redis.new(url: ENV.fetch("REDIS_URL", "redis://localhost:6379/0"))
end
def perform
return unless self.class.redis.set(RUN_LOCK_KEY, "1", nx: true, ex: INTERVAL.to_i)
begin
self.class.redis.set(REDIS_CHAIN_KEY, "1", ex: INTERVAL.to_i * 4)
StreamSession
.where(status: ACTIVE_STATUSES)
.find_each do |session|
Mediamtx::PublisherSync.new(session).call
end
ensure
self.class.set(wait: INTERVAL).perform_later
self.class.redis.del(RUN_LOCK_KEY)
end
end
end

View File

@@ -0,0 +1,54 @@
class YoutubeBroadcastActivateJob < ApplicationJob
queue_as :default
MAX_ATTEMPTS = 30
RETRY_WAIT = 15.seconds
RATE_LIMIT_WAIT = 90.seconds
LIVE_STATUSES = %w[live connecting reconnecting paused].freeze
def perform(session_id, attempt = 1)
session = StreamSession.find_by(id: session_id)
return unless session&.platform == "youtube"
return if session.terminal?
return if session.youtube_broadcast_id.blank?
return unless LIVE_STATUSES.include?(session.status)
return unless Youtube::LivePipeline.broadcast_ready?(session)
unless Streams::YoutubeRelay.running?(session.id)
Streams::YoutubeRelay.ensure_publishing!(session)
return reschedule(session_id, attempt + 1) if attempt < MAX_ATTEMPTS
return
end
result = Youtube::BroadcastService.new(session.match.team).activate_broadcast!(session.youtube_broadcast_id)
Rails.logger.info("[YoutubeBroadcastActivate] session=#{session.id} attempt=#{attempt} result=#{result}")
return if result == :live || result == :transitioned
if result == :rate_limited
reschedule(session_id, attempt, wait: RATE_LIMIT_WAIT)
return
end
if result == :broadcast_ended
Youtube::SetupBroadcast.recreate!(session.reload)
Youtube::LivePipeline.schedule!(session.reload, force: true)
return
end
if result == :waiting_ingest && (attempt % 4).zero?
Streams::YoutubeRelay.ensure_publishing!(session)
end
return if attempt >= MAX_ATTEMPTS
reschedule(session_id, attempt + 1)
end
private
def reschedule(session_id, attempt, wait: RETRY_WAIT)
self.class.set(wait: wait).perform_later(session_id, attempt)
end
end

View File

@@ -0,0 +1,61 @@
class YoutubeBroadcastSetupJob < ApplicationJob
queue_as :default
RUN_LOCK_KEY = "youtube_setup:running:%s"
MAX_RATE_LIMIT_ATTEMPTS = 15
RATE_LIMIT_WAITS = [30, 45, 60, 90, 120, 120, 120, 120, 120, 120, 120, 120, 120, 120, 120].freeze
def perform(session_id, youtube_channel = nil, attempt = 1)
session = StreamSession.find_by(id: session_id)
return unless session&.platform == "youtube"
return if session.terminal?
return if session.youtube_broadcast_id.present? && session.stream_key.present?
return unless acquire_run_lock!(session_id, attempt)
Youtube::SetupBroadcast.call(session, youtube_channel: youtube_channel.presence)
release_run_lock!(session_id)
rescue Youtube::SetupBroadcast::Error => e
if rate_limit?(e) && attempt < MAX_RATE_LIMIT_ATTEMPTS
Youtube::ApiThrottle.mark_rate_limited!
wait = RATE_LIMIT_WAITS[attempt - 1] || 120
extend_run_lock!(session_id, wait + 90)
Rails.logger.warn(
"[YoutubeBroadcastSetupJob] rate limit session=#{session_id} attempt=#{attempt} retry_in=#{wait}s"
)
self.class.set(wait: wait.seconds).perform_later(session_id, youtube_channel, attempt + 1)
return
end
release_run_lock!(session_id)
raise
end
private
def rate_limit?(error)
msg = error.message.to_s
msg.include?("rate limit") ||
msg.include?("userRequestsExceedRateLimit") ||
msg.include?("temporaneamente occupato")
end
def acquire_run_lock!(session_id, attempt)
key = format(RUN_LOCK_KEY, session_id)
if attempt > 1
return redis.exists?(key).positive?
end
redis.set(key, "1", nx: true, ex: 90)
end
def extend_run_lock!(session_id, seconds)
redis.expire(format(RUN_LOCK_KEY, session_id), seconds)
end
def release_run_lock!(session_id)
redis.del(format(RUN_LOCK_KEY, session_id))
end
def redis
@redis ||= Redis.new(url: ENV.fetch("REDIS_URL", "redis://localhost:6379/0"))
end
end

View File

@@ -0,0 +1,57 @@
# Controlli ripetuti finché YouTube non ha ingest active (poi attiva la broadcast).
class YoutubeIngestWatchdogJob < ApplicationJob
queue_as :default
FIRST_WAIT = 20.seconds
NEXT_WAITS = [35.seconds, 45.seconds, 60.seconds].freeze
def perform(session_id, phase = 0)
session = StreamSession.find_by(id: session_id)
return unless Youtube::LivePipeline.broadcast_ready?(session)
return if Youtube::ApiThrottle.rate_limited?
ingest = youtube_ingest_status(session)
if ingest == "active"
Youtube::LivePipeline.schedule_activate!(session, force: true, wait: 3.seconds)
return
end
if Streams::YoutubeRelay.running?(session.id)
Rails.logger.info("[YoutubeIngestWatchdog] relay ok ingest=#{ingest} phase=#{phase} session=#{session.id}")
else
Rails.logger.warn("[YoutubeIngestWatchdog] avvio relay ingest=#{ingest} session=#{session.id}")
Streams::YoutubeRelay.ensure_publishing!(session)
end
schedule_next(session_id, phase)
rescue StandardError => e
Rails.logger.warn("[YoutubeIngestWatchdog] session=#{session_id}: #{e.message}")
schedule_next(session_id, phase)
end
def self.schedule_chain(session_id)
set(wait: FIRST_WAIT).perform_later(session_id, 0)
end
private
def schedule_next(session_id, phase)
wait = NEXT_WAITS[phase]
return unless wait
self.class.set(wait: wait).perform_later(session_id, phase + 1)
end
def youtube_ingest_status(session)
return nil if session.youtube_broadcast_id.blank?
client = Youtube::BroadcastService.new(session.match.team).send(:authorized_client)
b = client.list_live_broadcasts("status,contentDetails", id: session.youtube_broadcast_id).items&.first
return nil unless b
sid = b.content_details.bound_stream_id
client.list_live_streams("status", id: sid).items.first&.status&.stream_status
rescue StandardError
nil
end
end

View File

@@ -0,0 +1,11 @@
# Avvia/riavvia il relay YouTube solo nel container sidekiq (YOUTUBE_RELAY_WORKER=1).
class YoutubeRelayEnsureJob < ApplicationJob
queue_as :default
def perform(session_id)
session = StreamSession.find_by(id: session_id)
return unless session
Streams::YoutubeRelay.ensure_on_worker!(session)
end
end

View File

@@ -0,0 +1,10 @@
class YoutubeRelayStopJob < ApplicationJob
queue_as :default
def perform(session_id)
session = StreamSession.find_by(id: session_id)
return unless session
Streams::YoutubeRelay.stop_on_worker!(session) if Streams::YoutubeRelay.worker?
end
end

View File

@@ -0,0 +1,4 @@
class ApplicationMailer < ActionMailer::Base
default from: -> { MatchLiveTv.mail_from }
layout "mailer"
end

View File

@@ -0,0 +1,18 @@
module Billing
class InvoiceMailer < ApplicationMailer
def invoice_pdf
@invoice = params[:invoice]
@club = @invoice.club
attachments["fattura-#{@invoice.number.parameterize}.pdf"] = {
mime_type: "application/pdf",
content: @invoice.pdf.download
}
mail(
to: @club.billing_email,
subject: "Fattura #{@invoice.display_number} — Match Live TV"
)
end
end
end

View File

@@ -0,0 +1,34 @@
module Recordings
class ReplayMailer < ApplicationMailer
default from: -> { MatchLiveTv.mail_from }
def replay_ready(recording:, recipient:)
@recording = recording
@team = recording.team
@club = @team.club
@recipient = recipient
@replay_url = recording.replay_url
@expires_at = recording.expires_at
mail(
to: recipient.email,
subject: "Replay pronto — #{recording.title_or_default}"
)
end
def replay_expiring_soon(recording:, recipient:)
@recording = recording
@team = recording.team
@club = @team.club
@recipient = recipient
@replay_url = recording.replay_url
@expires_at = recording.expires_at
@days_left = ((recording.expires_at - Time.current) / 1.day).ceil
mail(
to: recipient.email,
subject: "Replay in scadenza tra #{@days_left} giorni — #{recording.title_or_default}"
)
end
end
end

View File

@@ -0,0 +1,11 @@
class UserMailer < ApplicationMailer
default from: -> { MatchLiveTv.mail_from }
def password_reset(user, token)
@user = user
@reset_url = public_password_reset_url(token: token)
@expiry_hours = MatchLiveTv.password_reset_expiry_hours
mail to: user.email, subject: "Reimposta la password — Match Live TV"
end
end

View File

@@ -0,0 +1,5 @@
class AdminAccount < ApplicationRecord
has_secure_password
validates :username, presence: true, uniqueness: true
end

View File

@@ -0,0 +1,3 @@
class ApplicationRecord < ActiveRecord::Base
primary_abstract_class
end

View File

@@ -0,0 +1,63 @@
module Billing
class Invoice < ApplicationRecord
self.table_name = "billing_invoices"
STATUSES = %w[draft issued sent cancelled].freeze
SOURCES = %w[manual aruba].freeze
belongs_to :club
belongs_to :billing_payment, class_name: "Billing::Payment", optional: true
has_one_attached :pdf
validates :number, presence: true, uniqueness: { scope: :club_id }
validates :issued_on, presence: true
validates :amount_cents, numericality: { greater_than: 0 }
validates :currency, presence: true
validates :status, inclusion: { in: STATUSES }
validates :source, inclusion: { in: SOURCES }
validates :billing_payment_id, uniqueness: true, allow_nil: true
validate :pdf_present_when_issued, on: :issue
scope :recent, -> { order(issued_on: :desc, created_at: :desc) }
def amount_euros
amount_cents / 100.0
end
def formatted_amount
format("%.2f €", amount_euros)
end
def downloadable?
pdf.attached? && status.in?(%w[issued sent])
end
def draft?
status == "draft"
end
def display_number
n = number.to_s.strip
cleaned = n.gsub(/\baruba[-_\s]*/i, "").strip
cleaned.presence || n
end
def display_status
{
"draft" => "In preparazione",
"issued" => "Emessa",
"sent" => "Inviata",
"cancelled" => "Annullata"
}[status] || status
end
private
def pdf_present_when_issued
return unless validation_context == :issue
return if pdf.attached?
errors.add(:pdf, "è obbligatorio per emettere la fattura")
end
end
end

View File

@@ -0,0 +1,72 @@
module Billing
class Payment < ApplicationRecord
self.table_name = "billing_payments"
STATUSES = %w[paid failed refunded].freeze
belongs_to :club
has_one :invoice, class_name: "Billing::Invoice", foreign_key: :billing_payment_id, dependent: :nullify
validates :amount_cents, numericality: { greater_than: 0 }
validates :currency, presence: true
validates :status, inclusion: { in: STATUSES }
validates :stripe_invoice_id, uniqueness: true, allow_nil: true
scope :recent, -> { order(paid_at: :desc, created_at: :desc) }
# Pagamenti pagati senza PDF fattura caricato (da gestire in admin).
scope :awaiting_invoice_pdf, lambda {
where(status: "paid").where(
<<~SQL.squish,
NOT EXISTS (
SELECT 1 FROM billing_invoices bi
INNER JOIN active_storage_attachments asa
ON asa.record_type = 'Billing::Invoice'
AND asa.record_id = bi.id
AND asa.name = 'pdf'
WHERE bi.billing_payment_id = billing_payments.id
)
SQL
)
}
scope :with_invoice_pdf, lambda {
where(status: "paid").where(
<<~SQL.squish,
EXISTS (
SELECT 1 FROM billing_invoices bi
INNER JOIN active_storage_attachments asa
ON asa.record_type = 'Billing::Invoice'
AND asa.record_id = bi.id
AND asa.name = 'pdf'
WHERE bi.billing_payment_id = billing_payments.id
)
SQL
)
}
def awaiting_invoice_pdf?
status == "paid" && !invoice&.pdf&.attached?
end
def amount_euros
amount_cents / 100.0
end
def formatted_amount
format("%.2f €", amount_euros)
end
def display_description
PaymentDescription.for_payment(self)
end
def display_status
{ "paid" => "Pagato", "failed" => "Non riuscito", "refunded" => "Rimborsato" }[status] || status
end
def invoice_for_display
invoice
end
end
end

View File

@@ -0,0 +1,31 @@
class Club < ApplicationRecord
include Brandable
include ClubBillingProfile
has_many :club_memberships, dependent: :destroy
has_many :users, through: :club_memberships
has_many :teams, dependent: :destroy
has_one :youtube_credential, dependent: :destroy
has_one :subscription, dependent: :destroy
has_many :billing_payments, class_name: "Billing::Payment", dependent: :destroy
has_many :billing_invoices, class_name: "Billing::Invoice", dependent: :destroy
validates :name, presence: true
validates :sport, presence: true
validates :primary_color, presence: true
validates :secondary_color, presence: true
def owner
club_memberships.find_by(role: "owner")&.user
end
def owned_by?(user)
club_memberships.exists?(user: user, role: "owner")
end
private
def branding_parent
nil
end
end

View File

@@ -0,0 +1,9 @@
class ClubMembership < ApplicationRecord
ROLES = %w[owner].freeze
belongs_to :user
belongs_to :club
validates :role, inclusion: { in: ROLES }
validates :user_id, uniqueness: { scope: :club_id }
end

View File

View File

@@ -0,0 +1,43 @@
module Brandable
extend ActiveSupport::Concern
HEX_COLOR = /\A#[0-9A-Fa-f]{6}\z/
included do
has_one_attached :logo_file
validates :primary_color, format: { with: HEX_COLOR }, allow_blank: true
validates :secondary_color, format: { with: HEX_COLOR }, allow_blank: true
end
def effective_primary_color
primary_color.presence || default_primary_color
end
def effective_secondary_color
secondary_color.presence || default_secondary_color
end
def effective_logo_url
if logo_file.attached?
Rails.application.routes.url_helpers.rails_blob_path(logo_file, only_path: true)
elsif logo_url.present?
logo_url
else
branding_parent&.effective_logo_url
end
end
private
def default_primary_color
"#e53935"
end
def default_secondary_color
"#ffffff"
end
def branding_parent
nil
end
end

View File

@@ -0,0 +1,79 @@
module ClubBillingProfile
extend ActiveSupport::Concern
BILLING_ENTITY_TYPES = {
"company" => "Società / ASD con P.IVA",
"individual" => "Persona fisica",
"nonprofit" => "Associazione senza scopo di lucro"
}.freeze
included do
validates :billing_entity_type, inclusion: { in: BILLING_ENTITY_TYPES.keys }, allow_nil: true
validates :billing_email, format: { with: URI::MailTo::EMAIL_REGEXP }, allow_blank: true
validates :billing_recipient_code, length: { is: 7 }, allow_blank: true
validates :billing_province, length: { is: 2 }, allow_blank: true
validates :billing_country, length: { is: 2 }, allow_blank: true
validate :billing_profile_for_invoicing, on: :billing_profile
end
def billing_profile_complete?
billing_profile_errors.empty?
end
# Campi minimi per intestazione fattura e invio (email PDF + SDI/PEC).
def billing_profile_errors
errors = []
errors << "Tipo intestatario" if billing_entity_type.blank?
errors << "Ragione sociale o nome intestatario" if billing_legal_name.blank?
errors << "Email di fatturazione" if billing_email.blank?
errors << "Indirizzo" if billing_address_line.blank?
errors << "Città" if billing_city.blank?
errors << "Provincia (sigla 2 lettere)" if billing_province.blank? || billing_province.to_s.length != 2
errors << "CAP" if billing_postal_code.blank?
errors << "Paese (ISO)" if billing_country.blank? || billing_country.to_s.length != 2
errors.concat(billing_tax_id_errors)
errors << "Codice destinatario SDI (7 caratteri) o PEC" if billing_recipient_code.blank? && billing_pec.blank?
errors << "Codice destinatario SDI (7 caratteri)" if billing_recipient_code.present? && billing_recipient_code.length != 7
errors
end
def billing_tax_id_errors
case billing_entity_type
when "company"
billing_vat_number.blank? ? ["Partita IVA"] : []
when "individual"
billing_fiscal_code.blank? ? ["Codice Fiscale"] : []
else
billing_vat_number.blank? && billing_fiscal_code.blank? ? ["P.IVA o Codice Fiscale"] : []
end
end
def billing_profile_summary
parts = [billing_legal_name.presence, billing_vat_number.presence && "P.IVA #{billing_vat_number}"]
parts.compact.join(" · ")
end
# Righe per intestazione fattura in admin (etichetta, valore).
def billing_profile_invoice_lines
lines = []
lines << ["Tipo", BILLING_ENTITY_TYPES[billing_entity_type]] if billing_entity_type.present?
lines << ["Intestatario", billing_legal_name]
lines << ["P.IVA", billing_vat_number] if billing_vat_number.present?
lines << ["Codice fiscale", billing_fiscal_code] if billing_fiscal_code.present?
lines << ["Email fatturazione", billing_email]
lines << ["Telefono", billing_phone] if billing_phone.present?
addr = [billing_address_line, billing_postal_code, billing_city, billing_province, billing_country].compact.join(", ")
lines << ["Indirizzo", addr] if addr.present?
lines << ["SDI", billing_recipient_code] if billing_recipient_code.present?
lines << ["PEC", billing_pec] if billing_pec.present?
lines
end
private
def billing_profile_for_invoicing
billing_profile_errors.each do |message|
errors.add(:base, message)
end
end
end

Some files were not shown because too many files have changed in this diff Show More