o 'yAfñã@sDddlZddlZddlZddlZe d¡Zde_Gdd„deƒZdS)éNz ddns.databaseéc@s`eZdZdd„Zdd„Zdd„Zdd„Zdd d „Zd d „Zdd„Z ddd„Z dd„Z dd„Z d S)Ú DDNSDatabasecCs||_||_d|_dS©N)ÚcoreÚpathÚ_db)Úselfrr©r ú2/usr/lib/python3.10/site-packages/ddns/database.pyÚ__init__ s zDDNSDatabase.__init__cCsnt d|¡tj |¡}tj|tjtjBd}d|_ |s5|  ¡r5t d¡|  ¡}|  d¡|  dd¡|S)NzOpening database %s)Z detect_typeszInitialising database layouta% CREATE TABLE updates ( hostname TEXT NOT NULL, status TEXT NOT NULL, message TEXT, timestamp timestamp NOT NULL ); CREATE TABLE settings ( k TEXT NOT NULL, v TEXT NOT NULL ); CREATE INDEX idx_updates_hostname ON updates(hostname); z'INSERT INTO settings(k, v) VALUES(?, ?))ÚversionÚ1)ÚloggerÚdebugÚosrÚexistsÚsqlite3ZconnectZPARSE_DECLTYPESZPARSE_COLNAMESZisolation_levelÚ is_writableÚcursorZ executescriptÚexecute)rrrZconnÚcr r r Ú_open_database(s     zDDNSDatabase._open_databasecCs0t |jtj¡}|r dSt tj |j¡tj¡S)NT)rÚaccessrÚW_OKÚdirname)rZretr r r rFszDDNSDatabase.is_writablecGsH|jdur | |j¡|_|j ¡}z | ||¡W| ¡dS| ¡wr©rrrrrÚclose)rZqueryZ parametersrr r r Ú_executePs  zDDNSDatabase._executeNcCs2| ¡s t d¡dS| d|||tj ¡¡dS)Nz>Could not log any updates because the database is not writablezOINSERT INTO updates(hostname, status, message, timestamp) VALUES(?, ?, ?, ?))rrZwarningrÚdatetimeZutcnow)rÚhostnameÚstatusÚmessager r r Ú add_updateZs  ÿzDDNSDatabase.add_updatecCst d|¡| |d¡S)Nz Logging successful update for %sZsuccess)rrr")rrr r r Ú log_successbs zDDNSDatabase.log_successcCsB|r d|jj|jf}nd}t d||pdf¡|j|d|dS)Nz%s: %sz Logging failed update for %s: %sÚÚfailure)r!)Ú __class__Ú__name__Úreasonrrr")rrZ exceptionr!r r r Ú log_failuregs zDDNSDatabase.log_failurecCs~|jdur | |j¡|_|j ¡}z(|r| d||f¡n| d|f¡|D] }|dW| ¡SW| ¡dS| ¡w)zM Returns the timestamp of the last update (with the given status code). NzdSELECT timestamp FROM updates WHERE hostname = ? AND status = ? ORDER BY timestamp DESC LIMIT 1zUSELECT timestamp FROM updates WHERE hostname = ? ORDER BY timestamp DESC LIMIT 1rr)rrr rÚrowr r r Ú last_updateqs  ÿÿ  ýzDDNSDatabase.last_updatecCsh|jdur | |j¡|_|j ¡}z| d|f¡|D] }|dW| ¡SW| ¡dS| ¡w)z4 Returns the update status of the last update. NzQSELECT status FROM updates WHERE hostname = ? ORDER BY timestamp DESC LIMIT 1rr©rrrr*r r r Úlast_update_status‡s  ÿ  ýzDDNSDatabase.last_update_statuscCsj|jdur | |j¡|_|j ¡}z| d|df¡|D] }|dW| ¡SW| ¡dS| ¡w)zE Returns the reason string for the last failed update (if any). NzaSELECT message FROM updates WHERE hostname = ? AND status = ? ORDER BY timestamp DESC LIMIT 1r%rrr,r r r Úlast_update_failure_message™s  ÿ  ýz(DDNSDatabase.last_update_failure_messager) r'Ú __module__Ú __qualname__r rrrr"r#r)r+r-r.r r r r rs   r) rrrZloggingZ getLoggerrZ propagateÚobjectrr r r r Ús