mirror of
https://github.com/sakaljurgis/plugin.video.sklk.git
synced 2026-11-06 14:38:03 +00:00
Jurgis SakalauskasandClaude Opus 5.5
5e20067d6d
Not automatically on the service's first start any more: with several Kodi
installs, only the one whose history counts should send it. The button
("Send this Kodi's watched history to the server") asks first, shows progress
and can be cancelled; sending again is harmless, the server keeps newer state.
Co-Authored-By: Claude Opus 5.5 <noreply@anthropic.com>
84 lines
3.1 KiB
Python
84 lines
3.1 KiB
Python
# -*- coding: utf-8 -*-
|
|
# Kodi's own watched history of this add-on (its video database) to the server,
|
|
# as late reports: whatever the server knows that's newer wins. Started from the
|
|
# add-on settings, on the Kodi whose history counts (e.g. the main one).
|
|
|
|
import os
|
|
import re
|
|
import sqlite3
|
|
import time
|
|
from datetime import datetime
|
|
from urllib.parse import unquote
|
|
|
|
import xbmcvfs
|
|
|
|
from service import ADDON_ID, FILE_ID, is_ours, log, report
|
|
|
|
|
|
def newest_video_database():
|
|
folder = xbmcvfs.translatePath('special://database')
|
|
versions = [(int(m.group(1)), name) for name in os.listdir(folder)
|
|
for m in [re.match(r'MyVideos(\d+)\.db$', name)] if m]
|
|
return os.path.join(folder, max(versions)[1]) if versions else None
|
|
|
|
|
|
def to_ms(last_played):
|
|
try:
|
|
return int(time.mktime(datetime.strptime(last_played, '%Y-%m-%d %H:%M:%S').timetuple()) * 1000)
|
|
except (TypeError, ValueError):
|
|
return 1 # unknown: older than anything the server has
|
|
|
|
|
|
def read_history():
|
|
"""{file id: (play count, resume position, total time, last played in ms)} of this add-on's files."""
|
|
database = newest_video_database()
|
|
if database is None:
|
|
return {}
|
|
connection = sqlite3.connect('file:{0}?mode=ro'.format(database), uri=True)
|
|
try:
|
|
rows = connection.execute(
|
|
'SELECT path.strPath, files.strFilename, files.playCount, files.lastPlayed,'
|
|
' bookmark.timeInSeconds, bookmark.totalTimeInSeconds'
|
|
' FROM files JOIN path ON path.idPath = files.idPath'
|
|
' LEFT JOIN bookmark ON bookmark.idFile = files.idFile AND bookmark.type = 1'
|
|
).fetchall()
|
|
finally:
|
|
connection.close()
|
|
|
|
# the latest wins (a file can be there by plugin url and by stream url)
|
|
history = {}
|
|
for folder, filename, play_count, last_played, position, total in rows:
|
|
url = unquote(unquote((folder or '') + (filename or '')))
|
|
match = FILE_ID.search(url)
|
|
if match is None or not (url.startswith('plugin://' + ADDON_ID) or is_ours(url)):
|
|
continue
|
|
if not play_count and not position:
|
|
continue
|
|
file_id = int(match.group(1))
|
|
at = to_ms(last_played)
|
|
if file_id not in history or history[file_id][3] < at:
|
|
history[file_id] = (play_count or 0, position or 0, total or 0, at)
|
|
return history
|
|
|
|
|
|
def send_history(history, on_progress=None):
|
|
"""
|
|
How many files went through: stops at the first one that doesn't (server
|
|
unreachable), or when on_progress(files done) returns False.
|
|
"""
|
|
done = 0
|
|
for file_id, (play_count, position, total, at) in history.items():
|
|
if on_progress is not None and on_progress(done) is False:
|
|
break
|
|
sent = True
|
|
if play_count > 0:
|
|
sent = report(file_id, total, total, 'end', at)
|
|
if sent and position > 0:
|
|
# (also) a resume point, e.g. rewatching
|
|
sent = report(file_id, position, total, 'stop', at)
|
|
if not sent:
|
|
break
|
|
done += 1
|
|
log('sent watched history of {0} of {1} files'.format(done, len(history)))
|
|
return done
|