Commit: ebe378b053c5cebf9505f4656abc8988eadc90a5 - beets-playersync (hg)

Commit MetaInfo

• Revisão: ebe378b053c5cebf9505f4656abc8988eadc90a5 (tree)
• Hora: 2017-10-15 00:30:14
• Autor: Jaime Marquínez Ferrándiz <jaime.marquinez.ferrandiz@fast...>
• Commiter: Jaime Marquínez Ferrándiz

Mensagem de Log

Initial commit

Mudança Sumário

• add: .hgignore
• add: LICENSE
• add: beetsplug/__init__.py
• add: beetsplug/playersync.py

Diff

diff -r 000000000000 -r ebe378b053c5 .hgignore
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/.hgignore	Sat Oct 14 17:30:14 2017 +0200
@@ -0,0 +1,2 @@
+syntax: glob
+*.pyc

diff -r 000000000000 -r ebe378b053c5 LICENSE
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/LICENSE	Sat Oct 14 17:30:14 2017 +0200
@@ -0,0 +1,24 @@
+This is free and unencumbered software released into the public domain.
+
+Anyone is free to copy, modify, publish, use, compile, sell, or
+distribute this software, either in source code form or as a compiled
+binary, for any purpose, commercial or non-commercial, and by any
+means.
+
+In jurisdictions that recognize copyright laws, the author or authors
+of this software dedicate any and all copyright interest in the
+software to the public domain. We make this dedication for the benefit
+of the public at large and to the detriment of our heirs and
+successors. We intend this dedication to be an overt act of
+relinquishment in perpetuity of all present and future rights to this
+software under copyright law.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
+EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
+MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.
+IN NO EVENT SHALL THE AUTHORS BE LIABLE FOR ANY CLAIM, DAMAGES OR
+OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE,
+ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR
+OTHER DEALINGS IN THE SOFTWARE.
+
+For more information, please refer to <http://unlicense.org/>

diff -r 000000000000 -r ebe378b053c5 beetsplug/__init__.py
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/beetsplug/__init__.py	Sat Oct 14 17:30:14 2017 +0200
@@ -0,0 +1,2 @@
+from pkgutil import extend_path
+__path__ = extend_path(__path__, __name__)

diff -r 000000000000 -r ebe378b053c5 beetsplug/playersync.py
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/beetsplug/playersync.py	Sat Oct 14 17:30:14 2017 +0200
@@ -0,0 +1,145 @@
+from __future__ import unicode_literals
+
+import os.path
+import os
+import sqlite3
+import shutil
+import datetime
+
+from beets.plugins import BeetsPlugin
+from beets.ui import Subcommand
+from beets.util import prune_dirs, bytestring_path
+from beets.dbcore import OrQuery
+from beets.library import parse_query_parts, Item
+
+_CREATE_DATABASE_SCRIPT='''
+CREATE TABLE song(idSong INTEGER PRIMARY KEY, filename TEXT NOT NULL, date TIMESTAMP, synced BOOL);
+CREATE TABLE query(idQuery INTEGER PRIMARY KEY AUTOINCREMENT, query TEXT NOT NULL);
+CREATE TABLE querysong(idQuery INT REFERENCES query, idSong INT REFERENCES song,
+    PRIMARY KEY (idQuery, idSong)
+    );
+CREATE TABLE playlist(idPlaylist INTEGER PRIMARY KEY AUTOINCREMENT, playlist TEXT NOT NULL);
+CREATE TABLE playlistsong(idPlaylist INTEGER REFERENCES playlist, idSong INTEGER REFERENCES song, listIndex INTEGER NOT NULL,
+    PRIMARY KEY (idPlaylist, idSong, listIndex));
+'''
+
+class PlayerSync(BeetsPlugin):
+    def info(self, *args, **kwargs):
+        return self._log.info(*args, **kwargs)
+
+    def error(self, *args, **kwargs):
+        return self._log.error(*args, **kwargs)
+
+    def commands(self):
+        sync_command = Subcommand('sync', help='Sync music player')
+        sync_command.func = self.sync
+        return [sync_command]
+
+    def sync(self, lib, opts, args):
+        for device in self.config['devices']:
+            self.sync_device(device, lib, opts, args)
+        self.info('Done')
+
+    def sync_device(self, config, lib, opts, args):
+        self.info("Syncing {0}", config['path'])
+        path = os.path.expanduser(config['path'].get())
+        if not os.path.exists(path):
+            self.error('Path doesn\'t exists {0}', path)
+            return
+        self.info('Creating database')
+        db_file = os.path.join(path, 'beetssync.db')
+        db = sqlite3.connect(db_file)
+        db.text_factory = str
+        if not db.execute('SELECT * FROM sqlite_master WHERE name="song"').fetchall():
+            with db:
+                db.executescript(_CREATE_DATABASE_SCRIPT)
+        with db:
+            db.execute('DELETE FROM query')
+            db.execute('DELETE FROM querysong')
+            db.execute('DELETE FROM playlist')
+            db.execute('DELETE FROM playlistsong')
+
+        for query in config['queries'].get(list):
+            self.info('Processing query: "{0}"', query)
+            items = lib.items(query)
+            for item in items:
+                self.add_item(lib, db, item)
+            with db:
+                db.execute('INSERT INTO query (query) VALUES (?)', (query,))
+                query_id = db.execute('SELECT idQuery FROM query WHERE query=?', (query,)).fetchone()[0]
+                db.executemany('INSERT INTO querysong VALUES (?, ?)', [(query_id, item['id']) for item in items])
+
+        for playlist in config['playlists'].get(list):
+            self.info('Processing playlist: "{0}"', playlist)
+            playlist_file = os.path.expanduser(playlist)
+            with open(playlist_file, 'rt') as f:
+                paths = [line for line in (line.strip() for line in f) if line and not line.startswith('#')]
+            items = []
+            for song_path in paths:
+                query, q_sort = parse_query_parts(['path:' + song_path], Item)
+                item = list(lib.items(OrQuery(query)))[0]
+                self.add_item(lib, db, item)
+                items.append(item)
+            with db:
+                db.execute(
+                    'INSERT INTO playlist (playlist) VALUES (?)',
+                    (playlist,))
+                playlist_id = db.execute(
+                    'SELECT idPlaylist FROM playlist WHERE playlist=?',
+                    (playlist,)).fetchone()[0]
+                db.executemany(
+                    'INSERT INTO playlistsong VALUES (?, ?, ?)',
+                    [(playlist_id, item['id'], index) for index, item in enumerate(items)])
+
+        self.info('Syncing songs')
+        for item_id, song_path in db.execute('''
+            SELECT song.idSong, song.filename FROM song JOIN querysong ON song.idSong=querysong.idSong WHERE synced=0 or synced is NULL
+            UNION
+            SELECT song.idSong, song.filename FROM song JOIN playlistsong ON song.idSong=playlistsong.idSong WHERE synced=0 or synced is NULL
+            '''):
+            item = lib.get_item(item_id)
+            copy_path = os.path.join(path, song_path)
+            if not os.path.exists(item['path']):
+                self.info('"{0}" does not exist', item['path'])
+                continue
+            with db:
+                self.info('Copying "{0}"', item)
+                if not os.path.exists(os.path.dirname(copy_path)):
+                    os.makedirs(os.path.dirname(copy_path))
+                shutil.copyfile(item['path'], copy_path)
+                db.execute('UPDATE song SET synced=1,date=? WHERE idSong=?', (datetime.datetime.now(), item_id))
+
+        for item_id, song_path in db.execute('''
+            SELECT song.idSong, filename FROM song 
+            LEFT JOIN querysong ON song.idSong=querysong.idSong
+            LEFT JOIN playlistsong ON song.idSong=playlistsong.idSong
+            WHERE synced=1 and (querysong.idQuery is NULL and playlistsong.idPlaylist is NULL)
+            '''):
+            item = lib.get_item(item_id)
+            copy_path = os.path.join(path, song_path)
+            with db:
+                self.info('Removing "{0}"', item)
+                if os.path.exists(copy_path):
+                    os.unlink(copy_path)
+                    prune_dirs(os.path.dirname(copy_path), root=path)
+                db.execute('DELETE FROM song WHERE idSong=?', (item_id,)) 
+
+        self.info('Creating playlists')
+        for playlist_id, playlist_path in db.execute('SELECT * FROM playlist'):
+            with open(os.path.join(path, os.path.basename(playlist_path)), 'wt') as f:
+                for (filename,) in db.execute('''
+                    SELECT filename FROM song JOIN playlistsong ON song.idSong=playlistsong.idSong
+                    WHERE idPlaylist=?
+                    ORDER BY listIndex
+                    ''', (playlist_id,)):
+                    f.write(filename + '\n')
+
+        self.info('Finished syncing {0}', config['path'])
+
+    def add_item(self, lib, db, item):
+        item_id = item['id']
+        fullpath = item['path']
+        copy_path = os.path.relpath(fullpath, lib.directory)
+        if not db.execute('SELECT * FROM song WHERE idSong=?', (item_id,)).fetchall():
+            with db:
+                db.execute('INSERT INTO song (idSong, filename) VALUES (?,?)', (item_id, copy_path))