Scorch/events.py

#!/usr/bin/env python3
"""
WebSocket events.
"""
import os
import types
from urllib import parse

import config

async def select_artist(request, ws, data):
	"""Select an artist."""
	artist = data.get('artist', '')
	async with request.app['pool'].acquire() as conn:
		albums = await conn.fetch(
			"SELECT DISTINCT album, date FROM track "
			"WHERE albumartist = $1 ORDER BY date ASC",
			data.get('artist', ''))
	albums = [dict(record) for record in albums]
	ret = {'event': 'artist_albums', 'ok': True, 'data': albums}
	await ws.send_json(ret)


async def select_album(request, ws, data):
	"""Select an album."""
	artist = data.get('artist', '')
	album = data.get('album', '')
	date = data.get('date', '')
	async with request.app['pool'].acquire() as conn:
		tracks = await conn.fetch(
			"SELECT * FROM track "
			"WHERE albumartist = $1 AND album = $2 AND date = $3"
			"ORDER BY discnumber ASC, tracknumber ASC",
			artist, album, date)
	tracks = [dict(record) for record in tracks]
	for track in tracks:
		track.pop('filepath')
		track.pop('last_modified')
	ret = {'event': 'album_tracks', 'ok': True, 'data': tracks}
	await ws.send_json(ret)


async def select_track(request, ws, data):
	"""Select a track."""
	artist = data.get('artist', '')
	album = data.get('album', '')
	date = data.get('date', '')
	discnumber = data.get('discnumber', '')
	tracknumber = data.get('tracknumber', '')
	async with request.app['pool'].acquire() as conn:
		track = await conn.fetchrow(
			"SELECT * FROM track "
			"WHERE albumartist = $1 AND album = $2 AND date = $3 "
			"AND discnumber = $4 AND tracknumber = $5",
			artist, album, date, discnumber, tracknumber)
	track = dict(track)
	fpath = track.pop('filepath')
	track.pop('last_modified')
	fpath = config.static_prefix + os.path.relpath(fpath, config.music_dir)
	fpath = fpath.replace('flac', 'opus')
	fpath = parse.quote(fpath)
	track['url'] = fpath
	coverart = parse.urljoin(fpath, 'folder.jpg')
	track['coverart'] = coverart
	ret = {'event': 'track', 'ok': True, 'data': track}
	await ws.send_json(ret)


async def random_track(request, ws, data):
	"""Select a random track."""
	async with request.app['pool'].acquire() as conn:
		track = await conn.fetchrow(
			"SELECT * FROM TRACK ORDER BY random() LIMIT 1")
	track = dict(track)
	fpath = track.pop('filepath')
	track.pop('last_modified')
	fpath = config.static_prefix + os.path.relpath(fpath, config.music_dir)
	fpath = fpath.replace('.flac', '.opus')
	fpath = parse.quote(fpath)
	track['url'] = fpath
	coverart = parse.urljoin(fpath, 'folder.jpg')
	track['coverart'] = coverart
	ret = {'event': 'track', 'ok': True, 'data': track}
	await ws.send_json(ret)


events = {}
for obj in dir():
	if type(locals()[obj]) == types.FunctionType:
		events[locals()[obj].__name__] = locals()[obj]