j$ d dl mZ d dlZd dlZd dlZd dlZd dlZd dlZd dlmZm Z d dl
m Z d dl m
Z
mZmZmZ d dlmZmZmZ d dlmZ e ej. dd j1 Zej5 d
d
ed z Zed
z Z e j5 d
ej. dd Z ej. dd Z e
dddd Z d Z d Z! e! d2dZ"d Z#d Z$ G d de Z%e jM d d Z'e jQ d d3d Z)e jM d d! Z*e jM d" d4d# Z+e jM d$e% d2d& Z,e jQ d' d2d( Z-e jQ d) d* Z. G d+ d,e Z/e jQ d- ee" fd5d. Z0e jc d/ ee" fd6d0 Z2e jg d/ ee" fd6d1 Z3y)7 ) annotationsN)datetimetimezone)Path)FastAPIRequest
HTTPExceptionDepends) HTMLResponse JSONResponse FileResponse) BaseModelSTREAMFORGE_LICENSE_DATAz./license_server/dataT)parentsexist_okz licences.dbupdates)r STREAMFORGE_LICENSE_ADMINadmin STREAMFORGE_LICENSE_PASSWORDz
change-me-nowzStreamForge Licence Server)titledocs_url redoc_url openapi_urlc b t j t } t j | _ | S )N)sqlite3connectDBRow row_factorycs +/var/www/html/streamforge-license/server.pyconnr#
s
??2W[[q} c d t 5 } | j d d d d y # 1 sw Y y xY w)Na CREATE TABLE IF NOT EXISTS licences(id INTEGER PRIMARY KEY AUTOINCREMENT,identifier TEXT UNIQUE NOT NULL,identifier_type TEXT NOT NULL CHECK(identifier_type IN ('ip','domain')),plan TEXT NOT NULL CHECK(plan IN ('basic','premium','legend')),status TEXT DEFAULT 'active',customer TEXT DEFAULT '',notes TEXT DEFAULT '',created_at TEXT DEFAULT CURRENT_TIMESTAMP,updated_at TEXT DEFAULT CURRENT_TIMESTAMP,last_seen_at TEXT,last_install_id TEXT DEFAULT '');CREATE TABLE IF NOT EXISTS sessions(token_hash TEXT PRIMARY KEY,expires REAL NOT NULL);)r#
executescriptr s r" initr' s4
f D !// #C D D D D s &/c | j j d }|s t d t j |j j
}t 5 }|j d|f j }d d d r|d t j k r t d y# 1 sw Y 1xY w)Nsfls z/SELECT expires FROM sessions WHERE token_hash=?expiresT) cookiesgetr hashlibsha256encode hexdigestr# executefetchonetime)reqrawhr! rs r" authr9 s [[__V -$ $
>>#**, ))+
f`AII OQRPTU^^`!` Qy\$))+
%M#,>&> a`s $"B66B?c | j j j d d j d S )N:r .)striplowersplitrstrip)ds r" normalize_domainrB s/ qwwy 0 6 6s ;A > E Ec JJr$ c J | j r| j j S dS )N )clienthost)r5 s r" client_iprG s ::
-2-r$ c * e Zd ZU dZded< dZded< y)CheckrD strdomain
install_idN)__name__
__module__ __qualname__rK __annotations__rL r$ r" rI rI s "vc}BZ%6r$ rI z/healthc l ddt j t j j dS )NTzstreamforge-licence-server)okservicer4 )r nowr utc isoformatrQ r$ r" healthrX ! s) )EX\\ZbZfZfMgMqMqMst
tr$ z /v1/checkc t | }t | j }t 5 }d }|r!|j d|f j }|s#|r!|j d|f j }|sdddd||dcd d d S |j d| j |d f |j |d }d ||d
v |d k( ||d t j d
cd d d S # 1 sw Y y xY w)NzaSELECT * FROM licences WHERE identifier_type='domain' AND lower(identifier)=? AND status='active'zVSELECT * FROM licences WHERE identifier_type='ip' AND identifier=? AND status='active'Fnone)validplanr load_balancing observed_iprK zlUPDATE licences SET last_seen_at=CURRENT_TIMESTAMP,last_install_id=?,updated_at=CURRENT_TIMESTAMP WHERE id=?idr\ T)premiumlegendra
identifier)r[ r\ r r] r^ matched_identifierlast_valid_unix) rG rB rK r# r2 r3 rL commitr4 )rA r5 iprK r! r8 r\ s r" checkrg # s
cN*18846
f ! aii{ ~D }F G P P RA
rAII vxzw|} G G I!
5PUdfpvw
)) z|} }I }I JK LP JQ |R S TU T\ T\ T^ de fl dm _cdT5I-I[_ai[ixz QR S_ Q` sw s| s| s~
s AC-
AC--C6z/v1/updates/stable.jsonc t dz } | j sddddS t j | j S )Nz stable.jsonrD )versionurlr/ )UPDATESexistsjsonloads read_text)ps r" update_manifestrq - s6
=
Rb"==
1;;=!!r$ z/v1/updates/files/{name}c t t | j z }|j s t d t | S )Ni )rk r namerl r r
)rs rp s r" update_filert 2 s1 DJOO
s++Qr$ /)response_classc J t | d}|s t d S t 5 }|j d D cg c]
}t | }}d d d t j j dd }t d|z dz S # d}Y xY wc c}w # 1 sw Y MxY w) NTFa StreamForge Licence Server
StreamForge Licence Server
z'SELECT * FROM licences ORDER BY id DESCzStreamForge Licence Server
StreamForge Licence Server
● Online
Register IP / Domain
Identifier
Type
Plan
Status
Customer
Last seen
)r9 r r# r2 dictrm dumpsreplace)r5 loggedr! xrowsdatas r" homer 7 s #Ydvl $F G G
f^3\)]^AQ^$^^
jj tF+ M NR R SK+ K+ L+ L+ u^^^s'
B BB B BBB"z/loginc K | j d { }t j t |j dd t
r3t j t |j dd t s t d t j d }t j |j j }t 5 }|j d|t j dz f |j! d d d t# dd i }|j% d
|d d d |S 7 -# 1 sw Y 1xY ww)
NusernamerD passwordr* z4INSERT INTO sessions(token_hash,expires) VALUES(?,?)iQ rS Tr) strict)httponlysamesitemax_age)rm secretscompare_digestrJ r-
ADMIN_USER
ADMIN_PASSr
token_urlsafer. r/ r0 r1 r# r2 r4 re r
set_cookie)r5 rA r6 r7 r! r8 s r" loginr ? s s155B#7 8DGLbLbcfghglglmwxzg{c| ~H MI P] ^a Pb Jb 2
!=!G!G!Iq
ft!)) RTUVZV_V_VabgVgShijkjrjrjttd Q\\&dH]b\ ckldl uts( EECE :E.EE Ez/logoutc B t ddi } | j d | S )NrS Tr) )r
delete_cookie)r8 s r" logoutr F s T$K(Q )@r$ c H e Zd ZU ded< ded< ded< dZded< dZded< y) LicInrJ rb identifier_typer\ rD customernotesN)rM rN rO rP r r rQ r$ r" r r H s$ #~c&9s(PR8C?]_SXY\S_r$ r z/admin/licencesc | j dk( rt | j n| j j }| j dvs| j dvr t dd t
5 }|j d|| j | j | j | j f }|j d|j icd d d S # 1 sw Y y xY w# t $ r}t dt | d }~ww xY w)NrK )rf rK )basicr` ra i zInvalid licence fieldszVINSERT INTO licences(identifier,identifier_type,plan,customer,notes) VALUES(?,?,?,?,?)r_ )r rB rb r= r\ r r# r2 r r re lastrowid ExceptionrJ )r| r5 _identr! cures r" add_licr I sT )*):):H)D %!,,J\J\J^_,>Z0Zanor tL bM \M7 v Vqyy!y |A BC BS BS TU TZ TZ [\ [e [e fg fm fm {n o3 pq px px pz CG HK HU HU BV V V V6]3s1v 666s7 (
C% 2A C C% C" C% "C% % D.DDz/admin/licences/{lid}c K |j d { }h d}g }g }|j D ]/ \ }}||v s |j |dz |j | 1 |r_|j | t 5 } | j ddj | z dz | | j
d d d ddiS ddiS 7 # 1 sw Y ddiS xY ww)N> r\ r statusr z=?zUPDATE licences SET ,z(,updated_at=CURRENT_TIMESTAMP WHERE id=?rS T)rm itemsappendr# r2 joinre )
lidr5 r rA allowedsetsargskvr! s
r" editr P s @Gbb
GGI 5SQq'\$++af%dkk!n5++c v~199 3CHHTN BCm mnrstut|t|t~~
d d
d s- CC
&CAC8C :C C
Cc t 5 }|j d| f |j d d d ddiS # 1 sw Y ddiS xY w)Nz DELETE FROM licences WHERE id=?rS T)r# r2 re )r r5 r r! s r" deleter Y sB
fP!)) =sfEahhjP
d Q
d s $;A)r5 r )rA rI r5 r )rs rJ )r| r r5 r )r intr5 r )4
__future__r r. rm osr r r4 r r pathlibr fastapir r r r
fastapi.responsesr r r
pydanticr getenvresolveDATAmkdirr rk r r appr# r' r9 rB rG rI r- rX postrg rq rt r r r r r patchr r rQ r$ r" r s] " + + + & 9 9 D D )"))./F
GHPPRSWS]S]fjtxS]Sy ~B CP ~Pz| Y] ^g Yg QX ho hu hu C hu hD 2990 9
YRYYOmn}E~* .tX\]:D
K. 7I 6 t t+ "#" $" #$ % L)L+ *L+ (m m ) I I _I _
")$- 7 7 "#%,T] $ #$!( %r$