kris/tarc
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Replace python-qbittorrent with qbittorrent-api

Browse Source
This commit is contained in:
Kris Lamoureux 2025-03-10 16:02:37 -04:00
parent f325768c1b
commit 7b42d55cc1
Signed by: kris
GPG Key ID: 105B748C1362EB96
2 changed files with 19 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
requirements.txt
View File

@ -1,2 +1,2 @@
python-qbittorrent==0.4.3 qbittorrent-api==2025.2.0
SQLAlchemy==2.0.38 SQLAlchemy==2.0.38

37
tarc/main.py
View File

@ -15,7 +15,7 @@ import uuid
import argparse import argparse
from datetime import datetime, timezone from datetime import datetime, timezone
import qbittorrent import qbittorrentapi
from sqlalchemy import create_engine, inspect from sqlalchemy import create_engine, inspect
from sqlalchemy.orm import Session from sqlalchemy.orm import Session
from sqlalchemy.exc import DatabaseError from sqlalchemy.exc import DatabaseError
@ -144,19 +144,18 @@ def main():
print("[INFO]: --directory is not implemented") print("[INFO]: --directory is not implemented")
sys.exit(0) sys.exit(0)
elif args.endpoint is not None: elif args.endpoint is not None:
qb = qbittorrent.Client(args.endpoint) qb = qbittorrentapi.Client(host=args.endpoint,
if qb.qbittorrent_version is None: username=args.username, password=args.password)
print(f'[ERROR]: Couldn\'t find client version at "{args.endpoint}"') try:
qb.auth_log_in()
except qbittorrentapi.LoginFailed as e:
print(f'[ERROR]: Login failed for endpoint "{args.endpoint}": {e}')
sys.exit(1) sys.exit(1)
elif not re.match(r"^v?\d+(\.\d+)*$", qb.qbittorrent_version): if not re.match(r"^v?\d+(\.\d+)*$", qb.app.version):
print(f'[ERROR]: Invalid version found at "{args.endpoint}"') print(f'[ERROR]: Invalid version "{qb.app.version}" found at "{args.endpoint}"')
if args.debug:
print(f"[DEBUG]: {qb.qbittorrent_version}")
sys.exit(1) sys.exit(1)
else: else:
print( print(f'[INFO]: Found qBittorrent {qb.app.version} at "{args.endpoint}"')
f'[INFO]: Found qbittorrent {qb.qbittorrent_version} at "{args.endpoint}"'
)
clients = find_client(engine, args.endpoint) clients = find_client(engine, args.endpoint)
if args.confirm_add: if args.confirm_add:
@ -181,16 +180,16 @@ def main():
print("[ERROR]: Use --confirm-add to add a new endpoint") print("[ERROR]: Use --confirm-add to add a new endpoint")
sys.exit(1) sys.exit(1)
elif len(clients) == 1: elif len(clients) == 1:
torrents = qb.torrents() torrents = qb.torrents_info()
print(f"[INFO]: There are {len(torrents)} torrents\n") print(f"[INFO]: There are {len(torrents)} torrents\n")
for torrent in torrents[:2]: for torrent in torrents[:2]:
files = qb.get_torrent_files(torrent["hash"]) files = qb.torrents_files(torrent.hash)
trackers = qb.get_torrent_trackers(torrent["hash"]) trackers = qb.torrents_trackers(torrent.hash)
print(f"[name]: {torrent['name']}") print(f"[name]: {torrent.name}")
print(f"[infohash_v1]: {torrent['infohash_v1']}") print(f"[infohash_v1]: {torrent.hash}")
print(f"[content_path]: {torrent['content_path']}") print(f"[content_path]: {torrent.content_path}")
print(f"[magent_uri]: {torrent['magnet_uri'][0:80]}") print(f"[magnet_uri]: {torrent.magnet_uri[:80]}")
print(f"[completed_on]: {torrent['completed']}") print(f"[completed_on]: {torrent.completed}\n")
print(f"[trackers]: {len(trackers)}") print(f"[trackers]: {len(trackers)}")
print(f"[file_count]: {len(files)}\n") print(f"[file_count]: {len(files)}\n")
if args.debug: if args.debug: