39 lines
1.1 KiB
Python
39 lines
1.1 KiB
Python
import datetime
|
|
import sqlite3
|
|
import requests
|
|
|
|
from utils.config import JELLYFIN_URL, JELLYFIN_HEADERS
|
|
|
|
|
|
def delete_accounts():
|
|
"""
|
|
Delete Jellyfin accounts that have passed their deletion time
|
|
"""
|
|
# Get all expired Jellyfin accounts
|
|
db = sqlite3.connect("cordarr.db")
|
|
cursor = db.cursor()
|
|
cursor.execute(
|
|
"SELECT jellyfin_user_id FROM jellyfin_accounts WHERE"
|
|
" deletion_time < ?",
|
|
(datetime.datetime.now(),),
|
|
)
|
|
jellyfin_user_ids = cursor.fetchall()
|
|
|
|
# Delete the Jellyfin accounts
|
|
for jellyfin_user_id in jellyfin_user_ids:
|
|
request = requests.delete(
|
|
f"{JELLYFIN_URL}/Users/{jellyfin_user_id[0]}",
|
|
headers=JELLYFIN_HEADERS,
|
|
)
|
|
# If 204 - account deleted
|
|
# If 404 - account not found
|
|
# Either way, remove account from database
|
|
if request.status_code in (404, 204):
|
|
cursor.execute(
|
|
"DELETE FROM jellyfin_accounts WHERE jellyfin_user_id = ?",
|
|
(jellyfin_user_id,),
|
|
)
|
|
|
|
db.commit()
|
|
db.close()
|