Backup_Repos/beets
1
0
Fork 0
mirror of https://github.com/beetbox/beets.git synced 2026-02-21 23:03:26 +01:00
Code Issues Projects Releases Wiki Activity

saving ipfs hashes in database

Browse source
This commit is contained in:
multikatt 2015-05-11 15:27:03 -04:00
parent 58a8a3d386
commit b08ccb5d37
1 changed files with 25 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

28
beetsplug/ipfs.py
View file

@ -37,7 +37,10 @@ class IPFSPlugin(BeetsPlugin):
def func(lib, opts, args):
if opts.add:
self.ipfs_add(lib.albums(ui.decargs(args)))
for album in lib.albums(ui.decargs(args)):
self.ipfs_add(album)
album.store()
if opts.get:
self.ipfs_get(lib, ui.decargs(args))
@ -46,11 +49,30 @@ class IPFSPlugin(BeetsPlugin):
def ipfs_add(self, lib):
try:
album_dir = lib.get().item_dir()
album_dir = lib.item_dir()
except AttributeError:
return
self._log.info('Adding {0} to ipfs', album_dir)
subprocess.call(["ipfs", "add", "-r", album_dir])
_proc = subprocess.Popen(["ipfs", "add", "-q", "-p", "-r", album_dir],
stdout=subprocess.PIPE)
count = 0
while True:
line = _proc.stdout.readline().strip()
if line != '':
if count < len(lib.items()):
item = lib.items()[count]
print "item:: %s" % line
item.ipfs = line
item.store()
count += 1
else:
print "album:: %s" % line
lib.ipfs = line
else:
break
return True
def ipfs_get(self, lib, _hash):
try: