aspyplayer.py - aspyplayer - ASPY Player - Audioscrobbler (Last.fm) PyS60 Player

Source path: svn/ trunk/ src/ aspyplayer.py

‹r47

r48

# Author: Douglas Fernando da Silva - doug.fernando at gmail.com
# Copyright 2008
# 
# Licensed under the Apache License, Version 2.0 (the "License")
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
# 
#     http://www.apache.org/licenses/LICENSE-2.0
# 
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.

__version__ = "0.1.5 beta"

from random import shuffle
from key_codes import EKeyLeftArrow, EKeyRightArrow, EKeyUpArrow, EKeyDownArrow, EKeySelect 

import appuifw
import audio
import e32
import e32db
import md5
import os
import time
import urllib
import socket
import sys
import graphics
import traceback

##########################################################
######################### DOMAIN MODEL 

class Id3InfoReader(object):
	def __init__(self, file_path):
		self.file_path = file_path
		version_marker, fp = self.init_file(self.file_path)
		
		if version_marker == "TAG":
			self.read_v1(fp)
		else:
			self.read_v2(fp)

	def init_file(self, path):
		path = self.file_path.encode("utf8")
		fp = open(path, "r")
		fp.seek(-128, 2)
		marker = fp.read(3)
		
		return (marker, fp)

	def file_path_to_title(self):
		if len(self.file_path) > 18:
			return UnicodeHelper.safe_unicode("..." + self.file_path[-18:-4])
		else:
			return UnicodeHelper.safe_unicode(self.file_path)
		
	def read_v1(self, fp):
		self.title = UnicodeHelper.safe_unicode(self.remove_X00(fp.read(30)))
		if not self.title: 
			self.title = self.file_path_to_title()
		
		self.artist = UnicodeHelper.safe_unicode(self.remove_X00(fp.read(30)))
		if not self.artist: 
			self.artist = u"Unknown"
		
		self.album = UnicodeHelper.safe_unicode(self.remove_X00(fp.read(30)))
		if not self.album: 
			self.album = u"Unknown"
		
		self.year = UnicodeHelper.safe_unicode(self.remove_X00(fp.read(4)))
		
		comment = fp.read(30)
		if ord(comment[-2]) == 0 and ord(comment[-1]) != 0:
			self.number = ord(comment[-1])
			self.comment = UnicodeHelper.safe_unicode(self.remove_X00(comment[:-2]))
		else:
			self.number = -1
			self.comment = UnicodeHelper.safe_unicode(self.remove_X00(comment))
		
		fp.close()
	
	def read_v2(self, fp):
		self.title = self.file_path_to_title()
		self.artist = u"Unknown"
		self.album = u"Unknown"
		self.year = None
		self.comment = None
		self.number = -1
	
	def remove_X00(self, value):
		return value.replace("\x00", "")


class Music(object):
	def __init__(self, file_path=""):
		self.file_path = UnicodeHelper.safe_unicode(file_path);
		self.init_music()
		self.player = MusicPlayer(self)
		self.length = 0
		self.music_brainz_ID = ""
		self.played_at = 0
		self.position = 0
		self.now_playing_sent = False
		self.__logger = LogFactory.create_for(self.__class__.__name__)
	
	def init_music(self):
		if self.file_path:
			id3_reader = Id3InfoReader(self.file_path)
			self.title = id3_reader.title
			self.artist = id3_reader.artist
			self.album = id3_reader.album
			self.year = id3_reader.year
			self.comment = id3_reader.comment
			self.number = id3_reader.number
		else:
			self.title = None
			self.artist = None
			self.album = None
			self.year = None
			self.comment = None
			self.number = -1

	def __str__(self):
		return u"  Artist: %s\n  Title: %s\n" % (self.artist, self.title)

	def play(self, callback):
		self.player.play(callback)
		self.__logger.debug("Playing: %s" % self.title)
	
	def stop(self):
		self.player.stop()
		
	def pause(self):	
		self.player.pause()
		
	def volume_up(self):
		self.player.volume_up()

	def volume_down(self):
		self.player.volume_down()

	def is_playing(self):
		return self.player.is_playing()

	def is_loading(self):
		return self.player.is_loading()

	def get_player_position_in_seconds(self):
		return int(self.player.current_position() / 1e6)

	def can_update_position(self):
		curr_pos = self.get_player_position_in_seconds()
		if self.position != curr_pos:
			self.position = curr_pos
			return True
	
		return False

	def can_be_added_to_history(self):
		if self.length == 0: return False

		player_curr_pos = self.get_player_position_in_seconds()
		min_length_cond = player_curr_pos > 30
		min_length_played_cond = (player_curr_pos > 240 or (
				float(player_curr_pos) / self.length) > 0.5)
		
		return min_length_cond and min_length_played_cond

	def current_position_formatted(self):
		return self.format_secs_to_str(self.position)
	
	def length_formatted(self):
		return self.format_secs_to_str(self.length)
	
	def format_secs_to_str(self, input_seconds):
		hours = input_seconds / 3600
		seconds_remaining = input_seconds % 3600
		minutes = seconds_remaining / 60
		seconds = input_seconds % 60

		if hours >= 1:
			return unicode("%02i:%02i:%02i" % (hours, minutes, seconds))
		else:
			return unicode("%02i:%02i" % (minutes, seconds))
	
	def get_status_formatted(self):
		return self.player.get_status_formatted() 

	def played_at_formatted(self):
		ts = time.gmtime(self.played_at)
		return unicode(time.strftime("%b/%d %H:%M", ts))

	def artist_played_at_formatted(self):
		return u"%s - %s" % (self.played_at_formatted(), self.artist)

	def can_send_now_playing(self):
		return not self.now_playing_sent and self.position > 5

	def number_to_str(self):
		if self.number == -1:
			return u""
		else:
			return unicode(str(self.number))


class MusicPlayer(object):
	current_volume = -1

	def __init__(self, music, player=None):
		self.__music = music
		self.__paused = False
		self.__player = player
		self.__current_position = None
		self.__loading = False
		self.loaded = False
		self.volume_step = 1
	
	def play(self, callback=None):
		if not self.__paused:
			self.__loading = True
			self.__player = self.create_player_for(self.__music.file_path)
			self.__loading = False
			self.configure_volume()
			self.__music.length = int(self.__player.duration() / 1e6)
			self.__music.played_at = int(time.time())
			self.loaded = True
		else:
			self.__player.set_position(self.__current_position)
		
		self.__paused = False
		self.__player.play(times=1, interval=0, callback=callback)

	def create_player_for(self, path):
		return audio.Sound.open(path)

	def configure_volume(self):
		volume = self.__class__.current_volume 
		if volume < 0: # default value = -1
			default_volume = self.__player.max_volume() / 4
			self.__class__.current_volume = default_volume

		self.volume_step = self.__player.max_volume() / 10
		self.__player.set_volume(self.__class__.current_volume)
		
	def is_loading(self):
		return self.__loading or self.__player.state() == self.get_not_ready_state() 
			
	def stop(self):
		if self.loaded:
			if self.is_playing():
				self.__player.stop()
			self.__player.close()
			self.loaded = False
			self.__paused = False
	
	def pause(self):
		if self.loaded:
			self.__current_position = self.__player.current_position()
			self.__player.stop()
			self.__paused = True

	def volume_up(self):
		if self.loaded:
			self.__class__.current_volume = self.__class__.current_volume + self.volume_step
			if self.__class__.current_volume > self.__player.max_volume(): 
				self.__class__.current_volume = self.__player.max_volume()
			
			self.__player.set_volume(self.__class__.current_volume)
	
	def volume_down(self):
		if self.loaded:
			self.__class__.current_volume = self.__class__.current_volume - self.volume_step
			if self.__class__.current_volume < 0:
				self.__class__.current_volume = 0
			
			self.__player.set_volume(self.__class__.current_volume)

	def get_status_formatted(self):
		if self.__player:
			state = self.__player.state()
			if state == self.get_is_playing_state():
				return "Playing"
			elif self.__paused:
				return "Paused"
		
		return "Stopped"

	def is_playing(self):
		if not self.__player: 
			return False
		
		return self.__player.state() == self.get_is_playing_state()

	def get_not_ready_state(self):
		return audio.ENotReady

	def get_is_playing_state(self):
		return audio.EPlaying

	def current_volume_percentage(self):
		return int((float(self.__class__.current_volume) / self.__player.max_volume()) * 100)
	
	def current_position(self):
		return self.__player.current_position()


class MusicList(object):
	def __init__(self, musics, listener, random=False):
		self.__timer = e32.Ao_timer()
		self.__listener = listener
		self.__should_stop = False
		self.__current_index = 0
		self.__random = random
		self.__update_play_mode = False
		self.__logger = LogFactory.create_for(self.__class__.__name__)
		self.is_playing = False
		self.is_new = True

		if musics:
			self.__linear_musics = musics
			self.__random_musics = musics[:]
			shuffle(self.__random_musics)
		
			if random: 
				self.__musics = self.__random_musics
			else:
				self.__musics = self.__linear_musics
			
			self.current_music = self.__musics[0]
			
			self.log_music_list()
		else:
			self.current_music = None
	
	def log_music_list(self):
		if self.__logger.debug_enabled():
			self.__logger.debug("Music list:")
			for music in self.__musics:
				self.__logger.debug("\t%s-%s" % (music.number, music.title))
			self.__logger.debug("----")
	
	def is_empty(self):
		return len(self.__musics) < 1

	def __len__(self):
		if not self.__musics: return 0
		return len(self.__musics)
	
	def play(self):
		self.__should_stop = False
		self.is_new = False
		
		while self.current_music != None:
			self.update_playing_mode_if_necessary()
			self.current_music.play(self.play_callback)
			self.is_playing = True
			self.__listener.update_music(self.current_music)

			self.play_current_music()
				
			if self.__should_stop: break
			if not self.move_next(): break
			
			self.__timer.after(0.3) # time between the musics
	
		self.is_playing = False
	
	def set_current_index(self, index):
		self.__current_index = index
		self.current_music = self.__musics[self.__current_index]
	
	def play_current_music(self):
		added_to_history = False;
		while self.current_music.is_playing():
			if not added_to_history:
				if self.current_music.can_be_added_to_history():
					self.__listener.add_to_history(self.current_music)
					added_to_history = True
			
			if self.current_music.can_update_position():
				self.__listener.update_music(self.current_music)
			
			e32.ao_yield()

		self.__listener.finished_music(self.current_music)

	def play_callback(self, current, previous, err):
		pass

	def pause(self):
		self.__should_stop = True
		if self.current_music: 
			self.wait_if_trying_to_play()
			self.current_music.pause()
			self.is_playing = False
		
	def stop(self):
		self.__should_stop = True
		if self.current_music: 
			self.wait_if_trying_to_play()
			was_playing = self.current_music.is_playing()
			self.current_music.stop()
			if was_playing:
				self.__listener.finished_music(self.current_music)

			self.is_playing = False
			
	def wait_if_trying_to_play(self):
		if self.current_music: 
			i = 0
			while self.current_music.is_loading():
				self.__timer.after(300)
				if i > 10:
					raise Exception("Could not load the music")
			
	def next(self):
		self.wait_if_trying_to_play()
		self.stop()
		self.update_playing_mode_if_necessary()
		self.move_next()
		self.play()
		
	def previous(self):
		self.wait_if_trying_to_play()
		self.stop()
		self.update_playing_mode_if_necessary()
		self.move_previous()
		self.play()

	def move_next(self):
		last_index = len(self.__musics) - 1
		if self.__current_index < last_index:
			self.__current_index = self.__current_index + 1
			self.current_music = self.__musics[self.__current_index]
			return True
	
		return False
	
	def move_previous(self):
		if self.__current_index > 0:
			self.__current_index = self.__current_index - 1
			self.current_music = self.__musics[self.__current_index]
			return True
		
		return False

	def current_position_formated(self):
		return unicode("%i / %i" % (self.__current_index + 1, len(self)))

	def update_playing_mode_if_necessary(self):
		if self.__update_play_mode:
			if not self.__random:
				self.__musics = self.__linear_musics
			else:
				self.__musics = self.__random_musics
	
			self.__update_play_mode = False

	def random(self, random=True):
		self.__random = random
		self.__update_play_mode = True


class MusicHistory(object):
	def __init__(self, repository, audio_scrobbler_service):
		self.__batch_size = 50
		self.__repository = repository
		self.__audio_scrobbler_service = audio_scrobbler_service

	def add_music(self, music):
		self.__repository.save_music(music)
	
	def clear(self):
		self.__repository.clear_history()
	
	def send_to_audioscrobbler(self):
		musics = self.__repository.load_all_history()
		musics.sort(lambda m1, m2: cmp(m1.played_at, m2.played_at))
		if musics and len(musics) < self.__batch_size:
			if self.__audio_scrobbler_service.send(musics):
				self.clear()
		elif musics:
			self.send_batches_to_audioscrobbler(musics)

	def send_batches_to_audioscrobbler(self, musics):
		assert len(musics) >= self.__batch_size
		
		num_full_batches = len(musics) / self.__batch_size
		for i in range(num_full_batches):
			start = i * self.__batch_size
			end = start + self.__batch_size
			batch = musics[start:end]
			self.send_batch(batch)
		
		remainings = len(musics) % self.__batch_size
		if remainings > 0:
			batch = musics[len(musics)-remainings:len(musics)]
			self.send_batch(batch)
		
	def send_batch(self, musics_batch):
		if self.__audio_scrobbler_service.send(musics_batch):
			self.__repository.remove_musics(musics_batch)


class AudioScrobblerUser(object):
	def __init__(self, username, password, password_hashed=False):
		self.username = username
		if not password_hashed:
			self.password = md5.md5(password).hexdigest()
		else:
			self.password = password

##########################################################
######################### REPOSITORIES 

class MusicRepository(object):
	def __init__(self, db_helper):
		self.__db_helper = db_helper
		self.__logger = LogFactory.create_for(self.__class__.__name__)

	def exists(self, path):
		return os.path.exists(path.encode("utf8"))

	def distinct(self, collection):
		result = []
		for item in collection:
			if item not in result:
				result.append(item)
		
		return result
		
	def count_all(self):
		cmd = "SELECT Path FROM Music"
		rows = self.__db_helper.execute_reader(cmd)
		return len(rows)
	
	def count_all_artists(self):
		return len(self.find_all_artists())
	
	def count_all_albums(self):
		return len(self.find_all_albums())
	
	def find_all(self):
		cmd = "SELECT Path FROM Music"
		rows = self.__db_helper.execute_reader(cmd)
		result = [Music(row[0]) for row in rows if self.exists(row[0])]
		return self.distinct(result)

	def find_all_musics_path(self):
		cmd = "SELECT Path FROM Music"
		rows = self.__db_helper.execute_reader(cmd)
		result = [row[0] for row in rows]
		return self.distinct(result)

	def find_all_artists(self):
		cmd = "SELECT Artist FROM Music"
		rows = self.__db_helper.execute_reader(cmd)
		result = [row[0] for row in rows]
		return self.distinct(result)

	def find_all_albums(self):
		cmd = "SELECT Album FROM Music"
		rows = self.__db_helper.execute_reader(cmd)
		result = [row[0] for row in rows]
		return self.distinct(result)

	def find_all_albums_by_artist(self, artist):
		cmd = "SELECT Album FROM Music WHERE Artist = '%s'" % artist.replace("'", "''")
		rows = self.__db_helper.execute_reader(cmd)
		result = [row[0] for row in rows]
		return self.distinct(result)

	def find_all_musics_artist_album(self, artist, album):
		cmd = "SELECT Path FROM Music WHERE Album = '%s' AND Artist = '%s'" % (
										album.replace("'", "''"), artist.replace("'", "''"))
		rows = self.__db_helper.execute_reader(cmd)
		result = [Music(row[0]) for row in rows if self.exists(row[0])]
		return result
	
	def find_all_by_artist(self, artist):
		cmd = "SELECT Path FROM Music WHERE Artist = '%s'" % artist.replace("'", "''")
		rows = self.__db_helper.execute_reader(cmd)
		result = [Music(row[0]) for row in rows if self.exists(row[0])]
		return result

	def find_all_by_album(self, album):
		cmd = "SELECT Path FROM Music WHERE Album = '%s'" % album.replace("'", "''")
		rows = self.__db_helper.execute_reader(cmd)
		result = [Music(row[0]) for row in rows if self.exists(row[0])]
		return result

	def save(self, music):
		cmd = "INSERT INTO Music (Path, Artist, Album) VALUES('%s', '%s', '%s')" % (
			music.file_path.replace("'", "''"),	music.artist.replace("'", "''"), 
			music.album.replace("'", "''"))
		result = self.__db_helper.execute_nonquery(cmd)
		assert result > 0

	def delete(self, music_path):
		cmd = "DELETE FROM Music WHERE Path = '%s'" % music_path.replace("'", "''")
		
		result = self.__db_helper.execute_nonquery(cmd)
		assert result > 0

	def rebuild_library(self, musics_path):
		cmd = "DELETE FROM Music"
		result = self.__db_helper.execute_nonquery(cmd)

		new_musics = []
		for file in musics_path:
			try:
				music = Music(file)
				new_musics.append(music)
			except:
				self.__logger.debug("Adding file to library error: '%s'" % \
					''.join(traceback.format_exception(*sys.exc_info())))

		for music in new_musics:
			self.save(music) 

		return len(new_musics)

	def update_library(self, musics_path):
		all_music_in_db_path = self.find_all_musics_path()
		
		to_be_added = [x for x in musics_path if x not in all_music_in_db_path]
		to_be_deleted = [x for x in all_music_in_db_path if x not in musics_path]
		
		new_musics = []
		for file in to_be_added:
			try:
				music = Music(file)
				new_musics.append(music)
			except:
				self.__logger.debug("Adding file to library error: '%s'" % \
					''.join(traceback.format_exception(*sys.exc_info())))

		for music in new_musics:
			self.save(music) 
	
		for music_path in to_be_deleted:
			self.delete(music_path)

		return (len(new_musics), len(to_be_deleted))


class AudioScrobblerUserRepository(object):
	def __init__(self, db_helper):
		self.__db_helper = db_helper

	def load(self):
		cmd = "SELECT UserName, Password FROM User"
		rows = self.__db_helper.execute_reader(cmd)
		if rows:
			return AudioScrobblerUser(rows[0][0], rows[0][1], True)
		
		return None
	
	def save(self, user):
		remove_cmd = "DELETE FROM User"
		insert_cmd = "INSERT INTO User (UserName, Password) VALUES('%s', '%s')" % (
					user.username.replace("'", "''"), user.password.replace("'", "''"))

		result = self.__db_helper.execute_nonquery(remove_cmd)
		result = self.__db_helper.execute_nonquery(insert_cmd)
		assert result > 0
	

class MusicHistoryRepository(object):
	def __init__(self, db_helper):
		self.__db_helper = db_helper
	
	def save_music(self, music):
		cmd = "INSERT INTO Music_History (Artist, Track, PlayedAt, Album, TrackLength) VALUES('%s', '%s', %i, '%s', %i)" % \
				(music.artist.replace("'", "''"), music.title.replace("'", "''"), 
					music.played_at, music.album.replace("'", "''"), music.length)
		
		result = self.__db_helper.execute_nonquery(cmd)
		assert result > 0

	def remove_musics(self, musics):
		for music in musics:
			cmd = "DELETE FROM Music_History WHERE PlayedAt = %i" % (music.played_at)
			self.__db_helper.execute_nonquery(cmd)
	
	def clear_history(self):
		cmd = "DELETE FROM Music_History"
		self.__db_helper.execute_nonquery(cmd)
	
	def load_all_history(self):
		cmd = "SELECT Artist, Track, PlayedAt, Album, TrackLength FROM Music_History"
		rows = self.__db_helper.execute_reader(cmd)
		result = []
		for row in rows:
			music = Music()
			music.artist = row[0]
			music.title = row[1]
			music.played_at = row[2]
			music.album = row[3]
			music.length = row[4]
			result.append(music)
	
		return result


##########################################################
######################### SERVICES 

class AudioScrobblerWaitError(Exception):
	pass


class AudioScrobblerError(Exception):
	pass


class AudioScrobblerCredentialsError(Exception):
	pass


class NoAudioScrobblerUserError(Exception):
	pass


class HardErrorController(object):
	def __init__(self, disconnect_handler):
		self.__hard_error_counter = 0
		self.__should_wait = None
		self.__disconnect_handler = disconnect_handler
		self.__max_waiting = 120 * 60

	def how_long_to_wait(self):
		if self.__should_wait:
			how_long = self.__should_wait[1]
			last_atempt = self.__should_wait[0]
			now = self.now()
			time_span = now - last_atempt 
			diff = how_long - time_span
			if diff > 0:
				return diff
		
		self.__should_wait = None
		return 0
	
	def check_waiting(self):
		have_to_wait = self.how_long_to_wait()
		if have_to_wait > 0:
			raise AudioScrobblerWaitError("You have to wait %i seconds to try again!" % have_to_wait)
 
	def handle_hard_error(self, during_handshake=False):
		if during_handshake:
			if not self.__should_wait:
				self.__should_wait = (self.now(), 60)
			else:
				if self.__should_wait[1] != self.__max_waiting:
					self.__should_wait = (self.now(), self.__should_wait[1] * 2)
				else:
					self.__should_wait = (self.now(), self.__max_waiting)
		else:
			self.__hard_error_counter += 1
			if self.__hard_error_counter == 3:
				self.force_new_handshake()

	def now(self):
		return time.time()
			
	def force_new_handshake(self):
		self.__hard_error_counter = 0
		self.__disconnect_handler()
	
	def logging_sucessful(self):
		self.__hard_error_counter = 0
		self.__should_wait = None


class AudioScrobblerService(object):
	def __init__(self, user_repository): 
		self.__handshake_url = "http://post.audioscrobbler.com/"
		self.__user_repository = user_repository
		self.__logger = LogFactory.create_for(self.__class__.__name__)
		self.__session_id = None
		self.__now_url = None
		self.__post_url = None
		self.__hard_error_controller = HardErrorController(self.force_disconnect)
		self.__force_new_login = False

	def force_disconnect(self):
		self.__force_new_login = True
	
	def check_connection(self):
		if self.__force_new_login:
			self.login()
			self.__force_new_login()
	
	def set_credentials(self, user):
		self.__user_repository.save(user)
	
	def user_changed(self, username):
		user = self.__user_repository.load()
		if user:
			return user.username != username
		
		return False
		
	def create_handshake_data(self):
		user = self.__user_repository.load()
		if not user:
			raise NoAudioScrobblerUserError("You must set an user/password first")
		
		client_id = "asp"
		client_version = "0.1"
		tstamp = int(time.time())
		token  = md5.md5("%s%d" % (user.password, tstamp)).hexdigest()
   		
   		values = {
			"hs": "true", 
			"p": '1.2', 
			"c": client_id, 
			"v": client_version, 
			"u": user.username, 
			"t": tstamp, 
			"a": token
	 	}
   		
   		return urllib.urlencode(values)

	def login(self):
		self.__hard_error_controller.check_waiting()
		
		try:
			hand_shake_data = self.create_handshake_data()
			response = urllib.urlopen("%s?%s" % (self.__handshake_url, hand_shake_data))
			as_response_data = self.handle_handshake_response(response)
			self.__session_id, self.__now_url, self.__post_url = as_response_data
			self.__hard_error_controller.logging_sucessful()
			self.__logger.debug("Login was OK: ID %s, NowUrl %s, PostUrl %s" % (
																as_response_data))
		except NoAudioScrobblerUserError: raise
		except AudioScrobblerError: raise
		except AudioScrobblerCredentialsError: raise
		except:
			self.__hard_error_controller.handle_hard_error(True)
			self.__logger.debug("Login error: '%s'" % \
							''.join(traceback.format_exception(*sys.exc_info())))
			raise
		
	def handle_handshake_response(self, response):
		result = response.read()
		lines = result.split("\n")

		if lines[0] == "OK":
			return (lines[1], lines[2], lines[3])
		else:
			self.handle_handshake_error(lines[0])
		
	def handle_handshake_error(self, error):
		if error == "BADAUTH":
			raise AudioScrobblerCredentialsError("Bad username/password")
		elif error == "BANNED":
			raise AudioScrobblerError("This client-version was banned by Audioscrobbler. Please contact the author!")
		elif error == "BADTIME":
			raise AudioScrobblerError("Your system time is out of sync with Audioscrobbler. Update it!.")
		elif error.startswith("FAILED"):
	  		raise Exception("Authentication with AS failed. Reason: %s" % error)
		else:
			raise Exception("Authentication with AS failed.")
	
	def now_playing(self, music):
		if not music.can_send_now_playing(): return True
		self.check_connection()
		
		values = {
			"s": self.__session_id, 
			"a": unicode(music.artist).encode("utf-8"), 
			"t": unicode(music.title).encode("utf-8"), 
			"b": unicode(music.album).encode("utf-8"), 
			"l": music.length, 
			"n": music.number_to_str(), 
			"m": music.music_brainz_ID
		}

		try:
			data = urllib.urlencode(values)
			response = urllib.urlopen(self.__now_url, data)
			result = response.read()

			if result.strip() == "OK":
				music.now_playing_sent = True
				self.__logger.debug("Now playing sent for %s" % music.title)
				return True
			elif result.strip() == "BADSESSION":
				self.__hard_error_controller.force_new_handshake()
		except:
			self.__hard_error_controller.handle_hard_error()
			self.__logger.debug("Now playing error: '%s'" % \
							''.join(traceback.format_exception(*sys.exc_info())))
		
		return False
	
	def send(self, musics):
		self.check_connection()
		try:
			data = self.create_send_music_data(musics)
			response = urllib.urlopen(self.__post_url, data)
			result = response.read()
			result_value = result.split("\n")[0]
			
			if result_value == "OK":
				for music in musics:
					self.__logger.debug("Scrobbled %s" % music.title)
				
				return True
			elif result_value.startswith("BADSESSION"):
				self.__hard_error_controller.force_new_handshake()
			elif result_value.startswith("FAILED"):
				raise AudioScrobblerError("Submission to AS failed. Reason: %s" % result_value)
		except:
			self.__hard_error_controller.handle_hard_error()
			self.__logger.debug("Scrobbling error: '%s'" % \
							 ''.join(traceback.format_exception(*sys.exc_info())))

		return False

	def create_send_music_data(self, musics):
		musics_data = []
		
		for music in musics:
			musics_data.append({ 
				"a": unicode(music.artist).encode("utf-8"), 
				"t": unicode(music.title).encode("utf-8"), 
				"i": music.played_at, 
				"o": "P", 
				"r": "", 
				"l": music.length, 
				"b": unicode(music.album).encode("utf-8"), 
				"n": music.number_to_str(), 
				"m": music.music_brainz_ID
			})

		values = {}
		i = 0
		for item in musics_data:
			for key in item:
				values[key + ("[%d]" % i)] = item[key]
			i = i + 1
			
		values["s"] = self.__session_id
		data = urllib.urlencode(values)
		
		return data


##########################################################
######################### INFRASTRUCTURE 

class UnicodeHelper(object):
	def safe_unicode(value):
		if type(value) == type(unicode("unicode")):
			return value

		result = ""
		for enc in ['utf8', 'latin1']:
			try:
				result = value.decode(enc)
				break
			except UnicodeError:
				pass
			
		return unicode(result)
	
	safe_unicode = staticmethod(safe_unicode)


class LogFactory(object):
	def create_for(name):
		file_path = "%sdata\\aspyplayer\\log.txt" % FileSystemServices().get_data_drive()
		logger = Logger(str(name), file_path)
		return logger
	
	create_for = staticmethod(create_for)


class Logger(object):
	def __init__(self, name, path):
		self.name = name
		self.path = path
		self.level = 0
		
	def debug_enabled(self):
		return self.level < 1
	
	def info_enabled(self):
		return self.level < 2
		
	def debug(self, msg):
		if self.debug_enabled():
			try:
				f = open(self.path, "a")
				f.write("DEBUG - %s \n#" % msg)
				f.close()
			except: pass
	
	def info(self, msg):
		if self.info_enabled():
			try:
				f = open(self.path, "a")
				f.write("INFO - %s \n#" % msg)
				f.close()
			except: pass
			

class ServiceLocator(object):
	def __init__(self):
		self.file_system_services = FileSystemServices()
		self.db_helper = DbHelper(self.file_system_services.get_db_file_path(), self.file_system_services)
		self.history_repository = MusicHistoryRepository(self.db_helper)
		self.user_repository = AudioScrobblerUserRepository(self.db_helper)
		self.as_service = AudioScrobblerService(self.user_repository)	
		self.music_history = MusicHistory(self.history_repository, self.as_service)
		self.music_repository = MusicRepository(self.db_helper)

	def close(self):
		self.file_system_services = None
		self.db_helper.close()
		self.db_helper = None
		self.history_repository = None
		self.user_repository = None
		self.as_service = None	
		self.music_history = None
		self.music_factory = None


class FileSystemServices:
	def find_all_files(self, root_dir, file_extension):
		result = []
		predicate = lambda f: f.endswith(file_extension)
		
		def walk(arg, dirname, names):
			files_filtered = filter(predicate, map(UnicodeHelper.safe_unicode, names))
			
			for file in files_filtered:
				full_file_path = "%s\\%s" %(UnicodeHelper.safe_unicode(dirname), file)
				result.append(full_file_path)
		
		os.path.walk(root_dir, walk, None)
		
		return result

	def exists(self, path):
		return os.path.exists(path)

	def create_base_directories_for(self, full_path):
		dir = os.path.split(full_path)[0]
		if not os.path.exists(dir):
			os.makedirs(dir)

	def get_all_music_files_path_in_device(self):
		all_musics_in_c = self.find_all_files("C:\\", ".mp3")
		all_musics_in_e = self.find_all_files("E:\\", ".mp3")
		all_music = []
		all_music.extend(all_musics_in_c)
		all_music.extend(all_musics_in_e)
		return all_music

	def get_db_file_path(self):
		return "%sdata\\aspyplayer\\aspyplayer.db" % self.get_data_drive()

	def get_data_drive(self):
		if not self.exists("E:\\"):
			return "C:\\"
		
		return "E:\\"


class DbHelper(object):
	def __init__(self, dbpath, file_system_services):
		self.__db_path = dbpath
		self.__fs_services = file_system_services
		db_already_exists = self.__fs_services.exists(self.__db_path) 
		
		self.db = e32db.Dbms()
		self.dbv = e32db.Db_view()
		
		if db_already_exists:
			self.db.open(unicode(dbpath))
		else:
			self.check_db_directory()
			self.db.create(unicode(dbpath))
			self.db.open(unicode(dbpath))
			self.create_tables()

	def close(self):
		self.db.close()

	def check_db_directory(self):
		self.__fs_services.create_base_directories_for(self.__db_path)

	def execute_nonquery(self, sql):
		return self.db.execute(unicode(sql))

	def execute_reader(self, sql):
		self.dbv.prepare(self.db, unicode(sql))
		self.dbv.first_line()
		result = []
		
		for i in range(self.dbv.count_line()):
			self.dbv.get_line()
			row = []
			
			for i in range(self.dbv.col_count()):
				try:
					row.append(self.dbv.col(i+1))
				except:    # in case coltype 16
					row.append(None)
			
			result.append(row)
			self.dbv.next_line()
		
		return result

	def create_tables(self):
		self.create_music_history_table()
		self.create_user_table()
		self.create_music_table()
	
	def create_music_table(self):
		cmd = "CREATE TABLE Music (Path varchar(200), Artist varchar(200), Album varchar(200))"
		self.execute_nonquery(cmd)
	
	def create_music_history_table(self):
		cmd = "CREATE TABLE Music_History (Artist varchar(200), Track varchar(200), PlayedAt integer, Album varchar(200), TrackLength integer)"
		self.execute_nonquery(cmd)

	def create_user_table(self):
		cmd = "CREATE TABLE User (UserName varchar(200), Password varchar(200))"
		self.execute_nonquery(cmd)


##########################################################
######################### USER INTERFACE 

class PlayerUI(object):
	def __init__(self, service_locator):
		self.navigator = ScreenNavigator(self.quit, service_locator)
		self.__applock = e32.Ao_lock()
		
	def quit(self):
		try:
			self.navigator.close()
		finally:
			self.__applock.signal()
			appname = appuifw.app.full_name().lower()
			if appname.find("ython") == -1:
				appuifw.app.set_exit()
	
	def close(self):
		appuifw.app.menu = []
		appuifw.app.body = None
		appuifw.app.exit_key_handler = None

	def start(self):
		self.navigator.go_to_main_window()
		self.__applock.wait()


class ScreenNavigator(object):
	def __init__(self, quit_handler, service_locator):
		self.__quit_handler = quit_handler
		self.__service_locator = service_locator
		self.__as_presenter = AudioScrobblerPresenter(self.__service_locator)
		self.__last_window = None
		self.__current_window = None
		
		# Application screens
		self.__main_window = None
		self.__select_window = None
		self.__all_musics_window = None
		self.__artists_window = None
		self.__albums_window = None
		self.__musics_window = None
		self.__artist_musics_window = None
		self.__current_history_window = None
		self.__now_playing_window = None

	def go_to_last(self):
		if self.__last_window == self.__now_playing_window:
			self.go_to_now_playing()
		elif self.__last_window != None:
			self.go_to(self.__last_window)
	
	def go_to_current_history(self):
		if not self.__current_history_window:
			self.__current_history_window = CurrentHistoryWindow(self.__quit_handler, self, self.__service_locator)
					
		self.go_to(self.__current_history_window)
	
	def go_to_artist_musics(self, artist=None):
		if not self.__artist_musics_window:
			self.__artist_musics_window = ArtistMusicsWindow(self.__quit_handler, self, self.__service_locator)
		
		if not artist:
			assert self.__artist_musics_window.artist
		else:
			self.__artist_musics_window.artist = artist
		
		self.go_to(self.__artist_musics_window)
	
	def go_to_main_window(self):
		if not self.__main_window:
			self.__main_window = MainWindow(self.__quit_handler, self, self.__service_locator)
		
		self.go_to(self.__main_window)

	def go_to_select_window(self):
		if not self.__select_window:
			self.__select_window = SelectWindow(self.__quit_handler, self, self.__service_locator)
		
		self.go_to(self.__select_window)

	def go_to_all_musics_window(self):
		if not self.__all_musics_window:
			self.__all_musics_window = AllMusicsWindow(self.__quit_handler, self, self.__service_locator)
		
		self.go_to(self.__all_musics_window)

	def go_to_artists_window(self):
		if not self.__artists_window:
			self.__artists_window = ArtistsWindow(self.__quit_handler, self, self.__service_locator)
		
		self.go_to(self.__artists_window)

	def go_to_albums_window(self):
		if not self.__albums_window:
			self.__albums_window = AlbumsWindow(self.__quit_handler, self, self.__service_locator)
		
		self.go_to(self.__albums_window)

	def go_to_musics(self, musics=None, musics_comparer=None):
		if not self.__musics_window:
			self.__musics_window = MusicsWindow(self.__quit_handler, self)
		
		if musics:
			self.__musics_window.musics = musics
		else:
			assert self.__musics_window.musics
		
		if musics_comparer != None:
			self.__musics_window.musics_comparer = musics_comparer
		
		self.go_to(self.__musics_window)

	def go_to_now_playing(self, musics=[], index=0):
		if not self.__now_playing_window and not musics:
			Window.static_show_message("No music selected yet")
			return
		
		if not self.__now_playing_window:
			self.__now_playing_window = NowPlayingWindow(self.__quit_handler, self)

		if musics:
			music_list = MusicList(musics, self.__now_playing_window)
			self.__now_playing_window.update_music_list(music_list)
			self.__now_playing_window.music_list.set_current_index(index)
			self.go_to(self.__now_playing_window)
		else:
			self.go_to(self.__now_playing_window)

	def go_to(self, window):
		self.__last_window = self.__current_window
		self.__current_window = window
		
		if self.__now_playing_window:
			self.__now_playing_window.is_visible = (window == self.__now_playing_window)
		
		self.__as_presenter.set_view(window)
		
		appuifw.app.body = window.body
		appuifw.app.menu = window.menu
		appuifw.app.title = window.title

		window.show()

	def close(self):
		if self.__now_playing_window:
			self.__now_playing_window.close()
		
		self.__as_presenter.close()


class Window(object):
	def __init__(self, quit_handler, navigator, title="ASPY Player"):
		self.quit_handler = quit_handler
		self.navigator = navigator
		self.title = unicode(title)
		self.body = None
		self.menu = []
		self.as_presenter = None
		appuifw.app.screen = "normal"

	def static_show_message(message):
		appuifw.note(unicode(message), "info")
		
	static_show_message = staticmethod(static_show_message)
	
	def about(self):
		self.show_message("ASPY Player\nCreated by Douglas\n(doug.fernando at gmail)\n\naspyplayer.googlecode.com")

	def show_message(self, message):
		appuifw.note(unicode(message), "info")

	def show_error_message(self, message):
		appuifw.note(unicode(message), "error")

	def ask_text(self, info):
		return appuifw.query(unicode(info), "text")

	def ask_password(self, info):
		return appuifw.query(unicode(info), "code")

	def confirm(self, question):
		return appuifw.query(unicode(question), "query")

	def show(self):
		appuifw.app.exit_key_handler = self.quit_handler()

	def set_right_key_handler(self, handler):
		appuifw.app.exit_key_handler = handler

	def tests(self):
		if self.confirm("For development purposes only. It may crash the application. Continue?"):
			AspyFixtures().run()

	def basic_lastfm_menu_items(self):
			return [
			(u"Last.fm", (
				(u"Connect", self.as_presenter.connect),
				(u"Disconnect", self.as_presenter.disconnect), 
				(u"Clear History", self.as_presenter.clear_as_db), 
				(u"Submit History", self.as_presenter.send_history),
				(u"Show History", self.navigator.go_to_current_history),
				(u"Set Credentials", self.as_presenter.create_as_credentials)))]

	def basic_last_menu_items(self):
		return [
			(u"About", self.about), 
			(u"Exit", self.quit)]

	def update_menu(self, new_menu):
		if self.menu:
			while self.menu:
				self.menu.pop()
		
		self.menu.extend(new_menu)

	def quit(self):
		self.quit_handler()

	def create_listbox(self, items, handler):
		return appuifw.Listbox(items, handler)
	
	def create_canvas(self, redraw_handler):
		return appuifw.Canvas(redraw_handler)
	
	
class MainWindow(Window):
	def __init__(self, quit_handler, navigator, service_locator):
		Window.__init__(self, quit_handler, navigator)
		self.__fs_services = service_locator.file_system_services
		self.__music_repository = service_locator.music_repository
		self.body = self.create_listbox(self.get_list_items(), self.go_to)
	
	def go_to(self):
		index = self.body.current()
		if index == 0:
			self.navigator.go_to_select_window()
		else:
			self.about()
	
	def get_list_items(self):
		items = [(u"Musics", unicode("%i musics" % self.__music_repository.count_all())), 
				(u"About", u"aspyplayer.googlecode.com")]
		
		return items
	
	def update_music_library(self):
		self.show_message("This operation can take some time...")
		result = self.__music_repository.update_library(self.get_all_music_files_path())
		self.body.set_list(self.get_list_items())
		self.show_message("Library updated. Added: %i, Deleted: %i" % result)
	
	def rebuild_music_library(self):
		self.show_message("This operation can take some time...")
		result = self.__music_repository.rebuild_library(self.get_all_music_files_path())
		self.body.set_list(self.get_list_items())
		self.show_message("Library rebuilt. Added: %i" % result)

	def get_all_music_files_path(self):
		return self.__fs_services.get_all_music_files_path_in_device()
	
	def get_menu_items(self):
		items = [
			(u"Update Music Library", self.update_music_library),
			(u"Now playing", self.navigator.go_to_now_playing)]
		items.extend(self.basic_lastfm_menu_items())
		items.append((u"Admin", (
				(u"Testing", self.tests),
				(u"Rebuild Music Library", self.rebuild_music_library))))
		items.extend(self.basic_last_menu_items())
		
		return items
	
	def show(self):
		self.update_menu(self.get_menu_items())
		self.set_right_key_handler(self.quit)


class SelectWindow(Window):
	def __init__(self, quit_handler, navigator, service_locator):
		Window.__init__(self, quit_handler, navigator)
		self.__music_repository = service_locator.music_repository
		self.body = self.create_listbox([(u"empty", u"empty")], self.go_to)
		self.menu = self.get_menu_items()

	def get_list_items(self):
		items = [(u"All Music", unicode("%i musics" % self.__music_repository.count_all())), 
				(u"Artists", u"%i artists" % self.__music_repository.count_all_artists()),
				(u"Albums", u"%i albums" % self.__music_repository.count_all_albums())]
		return items

	def back(self):
		self.navigator.go_to_main_window()
	
	def get_menu_items(self):
		items = [
			(u"Back", self.back),
			(u"Now playing", self.navigator.go_to_now_playing)]
		items.extend(self.basic_last_menu_items())

		return items

	def go_to(self):
		index = self.body.current()
		if index == 0:
			self.navigator.go_to_all_musics_window()
		elif index == 1:
			self.navigator.go_to_artists_window()
		else:
			self.navigator.go_to_albums_window()

	def show(self):
		self.body.set_list(self.get_list_items())
		self.set_right_key_handler(self.back)


class MusicsWindow(Window):
	def __init__(self, quit_handler, navigator, title=""):
		if title: 
			Window.__init__(self, quit_handler, navigator, title)
		else:
			Window.__init__(self, quit_handler, navigator)
		
		self.body = self.create_listbox([u"empty"], self.go_to)
		self.menu = self.get_menu_items()
		self.musics = []
		self.musics_comparer = self.title_comparer

	def get_list_items(self):
		list_items = []
		
		self.sort_musics()
		
		i = 1
		for music in self.musics:
			list_items.append(u"%i-%s" % (i, music.title))
			i += 1
		
		return list_items
	
	def title_comparer(self, x, y):
		if x.title.startswith(".."):
			return 1
		elif y.title.startswith(".."):
			return -1
		else:
			return cmp(x.title.upper(), y.title.upper())
	
	def sort_musics(self):
		self.musics.sort(self.musics_comparer)
		self.musics_comparer = self.title_comparer
	
	def back(self):
		self.navigator.go_to_select_window()
	
	def get_menu_items(self):
		items = [
			(u"Back", self.back),
			(u"Now playing", self.navigator.go_to_now_playing)]
		items.extend(self.basic_last_menu_items())

		return items

	def go_to(self):
		index = self.body.current()
		self.navigator.go_to_now_playing(self.musics, index)

	def show(self):
		self.body.set_list(self.get_list_items())
		self.set_right_key_handler(self.back)


class AllMusicsWindow(MusicsWindow):
	def __init__(self, quit_handler, navigator, service_locator):
		MusicsWindow.__init__(self, quit_handler, navigator)
		self.__music_repository = service_locator.music_repository
	
	def show(self):
		self.musics = self.__music_repository.find_all()
		MusicsWindow.show(self)

		
class ArtistsWindow(Window):
	def __init__(self, quit_handler, navigator, service_locator):
		Window.__init__(self, quit_handler, navigator)
		self.__music_repository = service_locator.music_repository
			
		self.body = self.create_listbox([u"empty"], self.go_to)
		self.menu = self.get_menu_items()

	def get_list_items(self):
		self.artists = map(unicode, self.__music_repository.find_all_artists())
		if not self.artists:
			self.artists.append(u"empty")
		
		self.artists.sort(lambda x, y: cmp(x.lower(), y.lower()))
		
		return self.artists

	def back(self):
		self.navigator.go_to_last()
	
	def get_menu_items(self):
		items = [
			(u"Back", self.back),
			(u"Now playing", self.navigator.go_to_now_playing)]
		items.extend(self.basic_last_menu_items())

		return items

	def go_to(self):
		index = self.body.current()
		artist_selected = self.artists[index]
		self.navigator.go_to_artist_musics(artist_selected)

	def show(self):
		self.body.set_list(self.get_list_items())
		self.set_right_key_handler(self.back)


class ArtistMusicsWindow(Window):
	def __init__(self, quit_handler, navigator, service_locator):
		Window.__init__(self, quit_handler, navigator)
		self.__music_repository = service_locator.music_repository
		self.body = self.create_listbox([u"empty"], self.go_to)
		self.menu = self.get_menu_items()
		self.artist = None

	def go_to(self):
		index = self.body.current()
		comparer = None
		if index == 0:
			musics = self.__music_repository.find_all_by_artist(self.artist)
		else:
			album_selected = self.albums[index]
			musics = self.__music_repository.find_all_musics_artist_album(self.artist, album_selected)
			comparer = lambda x, y: cmp(x.number, y.number)

		assert musics
		self.navigator.go_to_musics(musics, comparer)

	def get_list_items(self):
		assert self.artist
		
		albums = map(unicode, self.__music_repository.find_all_albums_by_artist(self.artist))
		if not albums:
			self.albums.append(u"All")
		else:
			self.albums = [u"All"]
			albums.sort(lambda x, y: cmp(x.lower(), y.lower()))
			self.albums.extend(albums)
				
		return self.albums

	def back(self):
		self.navigator.go_to_last()

	def get_menu_items(self):
		items = [
			(u"Back", self.back),
			(u"Now playing", self.navigator.go_to_now_playing)]
		items.extend(self.basic_last_menu_items())

		return items

	def show(self):
		self.body.set_list(self.get_list_items())
		self.set_right_key_handler(self.navigator.go_to_last)


class AlbumsWindow(Window):
	def __init__(self, quit_handler, navigator, service_locator):
		Window.__init__(self, quit_handler, navigator)
		self.__music_repository = service_locator.music_repository
			
		self.body = self.create_listbox([u"empty"], self.go_to)
		self.menu = self.get_menu_items()

	def get_list_items(self):
		self.albums = map(unicode, self.__music_repository.find_all_albums())
		if not self.albums:
			self.albums.append(u"empty")
		
		self.albums.sort(lambda x, y: cmp(x.lower(), y.lower()))
		
		return self.albums
	
	def back(self):
		self.navigator.go_to_select_window()
	
	def get_menu_items(self):
		items = [
			(u"Back", self.back),
			(u"Now playing", self.navigator.go_to_now_playing)]
		items.extend(self.basic_last_menu_items())

		return items

	def go_to(self):
		index = self.body.current()
		album_selected = self.albums[index]
		musics = self.__music_repository.find_all_by_album(album_selected)
		assert musics
		self.navigator.go_to_musics(musics, lambda x, y: cmp(x.number, y.number))

	def show(self):
		self.body.set_list(self.get_list_items())
		self.set_right_key_handler(self.back)


class NowPlayingWindow(Window):
	def __init__(self, quit_handler, navigator):
		Window.__init__(self, quit_handler, navigator)
		self.music_list = None
		self.is_visible = False
		self.bg_img = self.load_image()
		self.body = self.create_canvas(self.render)
		self.presenter = None
		self.__random = False

	def load_image(self):
		possible_locations = ["E:\\python\\now_playing_bg.jpg", "C:\\python\\now_playing_bg.jpg"]
		possible_locations.append(os.path.join(sys.path[0], "now_playing_bg.jpg"))
		
		for location in possible_locations:
			if os.path.exists(location):
				try:
					return graphics.Image.open(location)
				except:
					pass

	def can_be_shown(self):
		return self.music_list

	def close(self):
		self.stop()

	def render(self, coord=(100,100)):
		if self.is_visible and self.music_list:
			if self.music_list.current_music:
				self.show_music_information(self.music_list.current_music)

	def stop(self):
		if self.music_list:
			if self.music_list.is_playing: 
				self.music_list.stop()

	def update_music_list(self, music_list):
		self.stop()
		self.music_list = music_list
		if self.__random:
			self.music_list.random()

		self.presenter = NowPlayingPresenter(self, music_list)

	def show_music_information(self, music):
		if not self.is_visible: return

		self.body.blit(self.bg_img)

		tr = TextRenderer(self.body)
		tr.spacing = 6
		tr.set_position((10,9))
		
		tr.render_line("Now playing...", (u"legend", 19, graphics.FONT_BOLD | graphics.FONT_ANTIALIAS), fill=(255, 255, 255))
		tr.add_blank_line(2)
		tr.render_line("  Artist: %s" % music.artist, (u"title", 16, graphics.FONT_BOLD | graphics.FONT_ANTIALIAS))
		tr.render_line("  Track: %s" % music.title, (u"title", 16, graphics.FONT_BOLD | graphics.FONT_ANTIALIAS))
		tr.add_blank_line()
		tr.render_line("     %s - %s" % (music.current_position_formatted(), 
					music.length_formatted()), (u"normal", 13, graphics.FONT_ANTIALIAS))
		tr.render_line("     Status: %s       %s" % (music.get_status_formatted(), 
					self.music_list.current_position_formated()), (u"normal", 13, graphics.FONT_ANTIALIAS))
		tr.add_blank_line(5)
		if self.__random:
			tr.render_line("         Playing in random mode", (u"normal", 10, graphics.FONT_BOLD | graphics.FONT_ANTIALIAS))
		
	def finished_music(self, music):
		self.as_presenter.finished_music(music)
		
	def update_music(self, music):
		if self.is_visible:
			self.show_music_information(music)
			self.as_presenter.audio_scrobbler_now_playing(music)
	
	def add_to_history(self, music):
		self.as_presenter.add_to_history(music)

	def back(self):
		self.navigator.go_to_select_window()

	def random(self):
		self.__random = self.presenter.random()

	def get_menu_items(self):
		items = [
			(u"Back", self.back),
			(u"Controls", (
				(u"Play", self.presenter.play),
				(u"Stop", self.presenter.stop),
				(u"Pause", self.presenter.pause), 
				(u"Next", self.presenter.next),
				(u"Previous", self.presenter.previous),
				(u"Random", self.random))), 
			(u"Volume", (
				(u"Up", self.presenter.volume_up), 
				(u"Down", self.presenter.volume_down)))]
		items.extend(self.basic_lastfm_menu_items())
		items.extend(self.basic_last_menu_items())
		return items

	def bind_key_events(self):
		self.body.bind(EKeyRightArrow, self.presenter.next)
		self.body.bind(EKeyLeftArrow, self.presenter.previous)
		self.body.bind(EKeyUpArrow, self.presenter.volume_up)
		self.body.bind(EKeyDownArrow, self.presenter.volume_down)
		self.body.bind(EKeySelect, self.presenter.play_stop)
	
	def show(self):
		self.set_right_key_handler(self.back)
		self.update_menu(self.get_menu_items())
		self.bind_key_events()
		
		if self.music_list.is_new:
			self.presenter.play()

		self.show_music_information(self.music_list.current_music)


class CurrentHistoryWindow(Window):
	def __init__(self, quit_handler, navigator, service_locator):
		Window.__init__(self, quit_handler, navigator)
		self.__music_history_repository = service_locator.history_repository
		self.body = self.create_listbox([(u"empty", u"empty")], self.go_to)
		self.menu = self.get_menu_items()

	def get_list_items(self):
		self.history = self.__music_history_repository.load_all_history()
		if not self.history:
			return [(u"empty", u"empty")]
		
		self.history.sort(lambda m1, m2: cmp(m1.played_at, m2.played_at))
		
		return map(lambda m: (m.title, m.artist_played_at_formatted()), self.history)
		
	def back(self):
		self.navigator.go_to_last()
	
	def get_menu_items(self):
		items = [
			(u"Back", self.back),
			(u"Now playing", self.navigator.go_to_now_playing)]
		items.extend(self.basic_last_menu_items())

		return items

	def go_to(self):
		pass

	def show(self):
		self.body.set_list(self.get_list_items())
		self.set_right_key_handler(self.back)


class NowPlayingPresenter(object):
	def __init__(self, view, music_list):
		self.view = view
		self.music_list = music_list

	def is_in_play_mode(self):
		return self.music_list
	
	def random(self):
		if self.view.confirm("Play in random mode?"):
			self.music_list.random()
			return True
		else:
			self.music_list.random(False)
			return False

	def play(self): 
		if not self.music_list.is_empty():
			self.music_list.play()

	def play_stop(self):
		if self.music_list:
			if self.music_list.current_music.is_playing():
				self.pause()
			else:
				self.play()
			
	def pause(self): 
		if self.music_list:
			self.music_list.pause()
			self.view.update_music(self.music_list.current_music)
	
	def stop(self):
		if self.music_list:	
			self.music_list.stop()
			self.view.update_music(self.music_list.current_music)
			
	def next(self):
		if self.music_list:	
			self.music_list.next()

	def previous(self):
		if self.music_list:	
			self.music_list.previous()

	def volume_up(self):
		if self.music_list:	
			self.music_list.current_music.volume_up()
			self.show_current_volume()

	def show_current_volume(self):
		self.view.show_message("Current volume: %s%%" % (
						self.music_list.current_music.player.current_volume_percentage()))
		
	def volume_down(self):
		if self.music_list:	
			self.music_list.current_music.volume_down()
			self.show_current_volume()
		
		
class AudioScrobblerPresenter(object):
	def __init__(self, service_locator):
		self.view = None
		self.__ap_services = AccessPointServices()
		self.__music_history = service_locator.music_history
		self.__audio_scrobbler_service = service_locator.as_service
		self.__now_playing_error_counter = 0
		self.__wanna_connect = False

	def close(self):
		self.__ap_services.close()

	def online_operation(self, operation):
		result = False
		try:
			operation()
			result = True
		except IOError:
			while self.view.confirm("Connection failed. Wanna try again?"):
				try:
					operation()
					result = True
				except: pass
			if not result:
				self.__wanna_connect = False
		
		return result 

	def set_view(self, view):
		self.view = view
		view.as_presenter = self

	def clear_as_db(self):
		if self.view.confirm("Are you sure you want to clear your history?"):
			self.__music_history.clear()
	
	def disconnect(self):
		self.__wanna_connect = False
		self.__ap_services.close()
	
	def connect(self):
		if not self.__ap_services.set_accesspoint():
			self.show_cannot_connect()
			return False
			
		try:
			self.__wanna_connect = True
			return self.online_operation(self.try_login)
		except NoAudioScrobblerUserError:
			self.create_as_credentials()
			return self.online_operation(self.try_login)
		except:
			self.view.show_error_message("It was not possible to login!")
		
		return False
	
	def try_login(self):
		try:
			self.__audio_scrobbler_service.login()
			self.view.show_message("Connected")
		except AudioScrobblerWaitError, msg:
			self.view.show_error_message(msg)
		except AudioScrobblerCredentialsError:
			self.view.show_error_message("Bad Username/Password. Change your credentials")
		except NoAudioScrobblerUserError: raise

	def create_as_credentials(self):
		user_name = self.view.ask_text("Inform your username")
		if not user_name: return
		
		password = self.view.ask_password("Inform your password")
		if not password: return
		
		if self.__audio_scrobbler_service.user_changed(user_name):
			if self.view.confirm("The username changed. The previous user music history will be removed. Proceed?"):
				self.__music_history.clear()
			else:
				return
			
		self.__audio_scrobbler_service.set_credentials(AudioScrobblerUser(user_name, password))
		self.view.show_message("Credentials saved")
		
	def send_history(self):
		if self.__wanna_connect:
			if self.online_operation(self.__music_history.send_to_audioscrobbler):
				self.view.show_message("History sent")
	
	def show_cannot_connect(self):
		self.view.show_error_message("It was not possible to connect!")
	
	def play(self): 
		if self.check_selected_directory():
			self.music_list.play()

	def finished_music(self, music):
		if self.__wanna_connect:
			self.online_operation(self.__music_history.send_to_audioscrobbler)
	
	def add_to_history(self, music):
		self.__music_history.add_music(music)
	
	def audio_scrobbler_now_playing(self, music):
		if self.__wanna_connect:
			if not self.online_operation(lambda: self.__audio_scrobbler_service.now_playing(music)):
				self.__now_playing_error_counter += 1
				if self.__now_playing_error_counter % 30 == 0:
					self.view.show_message("It was not possible to send now playing to Last.fm")
			else:
				self.__now_playing_error_counter = 0


class AccessPointServices(object):
	def __init__(self, default_ap=None):
		self.__default_ap = default_ap
		self.__ap = None
	
	def set_accesspoint(self):
		apid = self.__default_ap
		if not apid:
			apid = socket.select_access_point()
		if apid:
			try:
				apo = socket.access_point(apid)
				socket.set_default_access_point(apo)
				self.__ap = apo
				return True
			except:
				pass
			
		return False

	def close(self):
		if self.__ap:
			self.__ap.stop()
			socket.set_default_access_point(None)


class TextRenderer:
	def __init__(self, canvas):
		self.canvas = canvas
		self.coords = [0,0]
		self.spacing = 1

	def set_position(self, coords):
		self.coords = coords

	def add_blank_line(self, num_of_blank_lines=1, line_height=10):
		self.coords[1] += line_height * num_of_blank_lines

	def move_cursor(self, x, y):
		self.coords[0] += x
		self.coords[1] += y

	def render_line(self, text, font=(u"normal", 16), fill=0x000000):
		bounding, to_right, fits = self.canvas.measure_text(text, font=font)

		self.canvas.text([self.coords[0], self.coords[1] - bounding[1]], 
										unicode(text), font=font, fill=fill)

		self.coords = [self.coords[0],
					self.coords[1] - bounding[1] + bounding[3] + self.spacing]


class AspyPlayerApplication(object):
	def run(self):
		sl = ServiceLocator()
		ui = PlayerUI(sl)
	
		try:
			ui.start()
		finally:
			ui.close()
			sl.close()

##########################################################
######################### TESTING 

class Fixture(object):
	def __init__(self):
		self.errors = []
		self.title = ""
	
	def assertEquals(self, expected, result, description):
		if expected != result:
			self.errors.append("expected: %s - found: %s for -> %s" % (expected, result, description))
	
	def assertTrue(self, condition, description):
		if not condition: 
			self.errors.append(description + " => NOT OK")

class FixtureRunner(object):
	def __init__(self, fixtures):
		self.fixtures = fixtures
	
	def run(self):
		summary = []
		for test in self.fixtures:
			test.run()
			if test.errors:
				summary.append(u"\n")
				summary.append(test.title)
				summary.extend(test.errors)
		
		if not summary:
			appuifw.note(unicode("All %i test suites passed!" % len(self.fixtures)), "info")
		else:
			msg = ""
			for item in summary:
				msg += item + "\n"
			
			prev_body = appuifw.app.body
			prev_back = appuifw.app.exit_key_handler
			
			def back():
				appuifw.app.body = prev_body
				appuifw.app.exit_key_handler = prev_back
			
			appuifw.app.body = appuifw.Text()
			appuifw.app.body.set(unicode("Failed: Info: \n%s" % msg))
			appuifw.app.exit_key_handler = back


class AspyFixture(Fixture):
	def __init__(self):
		Fixture.__init__(self)
		self.sl = ServiceLocator()
	
	def load_music(self):
		music = Music("E:\\Music\\Bloc Party - Silent Alarm\\01 - Like Eating Glass.mp3")
		music.length = 261
		music.played_at = int(time.time()) - 40
		return music

class AudioScrobblerServiceFixture(AspyFixture):
	def __init__(self):
		AspyFixture.__init__(self)
		f = open("E:\\as.pwd", "rb")
		self.pwd = f.read().replace(" ", "")
		f.close()
		self.title = "Audio scrobbler service tests"

	def run(self):
		if self.pwd:
			as_service = self.sl.as_service
			as_service.set_credentials(AudioScrobblerUser("doug_fernando", self.pwd))
			as_service.login()
		
			music = self.load_music()
			result = as_service.now_playing(music)
			self.assertTrue(result, "Sent now playing to AS")
			
			result = as_service.send([music])
			self.assertTrue(result, "Sent music to AS")


class FileSystemServicesFixture(AspyFixture):
	def __init__(self):
		AspyFixture.__init__(self)
		self.title = "File System Services tests"

	def run(self):
		t = os.listdir("E:\\Music\\Bloc Party - Silent Alarm\\")
		
		fss = FileSystemServices()
		files = fss.find_all_files("E:\\Music\\Bloc Party - Silent Alarm\\", ".mp3")
		self.assertEquals(16, len(files), "Num of files loaded")
		
		files = fss.find_all_files("E:\\Music\\Muse - Absolution", ".mp3")
		self.assertEquals(14, len(files), "Num of files loaded")

		self.assertEquals("E:\\data\\aspyplayer\\aspyplayer.db", fss.get_db_file_path(), "DB file path")


class MusicHistoryRepositoryFixture(AspyFixture):		
	def __init__(self):
		AspyFixture.__init__(self)
		self.title = "Music history repository tests"

	def run(self):
		repos = self.sl.history_repository
		repos.clear_history()

		musics = repos.load_all_history()
		self.assertTrue(len(musics) == 0, "Repository empty")

		music = self.load_music()
		repos.save_music(music)
		musics = repos.load_all_history()
		self.assertTrue(len(musics) > 0, "Repository not empty")


class MusicFixture(AspyFixture):
	def __init__(self):
		AspyFixture.__init__(self)
		self.title = "Music tests"

	def run(self):
		music = self.load_music()
		music.position = 135
		
		self.assertEquals(u"Like Eating Glass", unicode(music.title), "Music title")
		self.assertEquals(u"Bloc Party", unicode(music.artist), "Music artist")
		self.assertEquals(u"Silent Alarm [Japan Bonus Trac", unicode(music.album), "Music Album")
		self.assertEquals(1, music.number, "Music Number")
		
		length_formatted = music.length_formatted()
		self.assertTrue(unicode("04:21") == unicode(length_formatted), "Correct length formatted") 
		
		current_pos_formatted = music.current_position_formatted()
		self.assertTrue(unicode("02:15") == unicode(current_pos_formatted), "Current position formatted")
		
		music.get_player_position_in_seconds = lambda: 200
		self.assertTrue(music.can_update_position(), "Can update position")
		self.assertTrue(music.can_update_position() == False, "Cannot update position")

		music.get_player_position_in_seconds = lambda: 20
		self.assertTrue(music.can_be_added_to_history() == False, "Cannot add to history")
		music.length = 600
		music.get_player_position_in_seconds = lambda: 200
		self.assertTrue(music.can_be_added_to_history() == False, "Cannot add to history")
		music.get_player_position_in_seconds = lambda: 250
		self.assertTrue(music.can_be_added_to_history(), "Can add to history")
		music.length = 261
		music.get_player_position_in_seconds = lambda: 135
		self.assertTrue(music.can_be_added_to_history(), "Can add to history")

#		music_test = Music("E:\\Music\\Kasabian - Empire\\03 - Last Trip (In Flight).mp3");
#		self.assertEquals("Last Trip (In Flight)", music_test.title, "UUUU... teste")

class UserFixture(AspyFixture):
	def __init__(self):
		AspyFixture.__init__(self)
		self.title = "User tests"

	def run(self):
		user = AudioScrobblerUser("doug_fernando", "hiaa29348")
		self.assertTrue(user.username == "doug_fernando", "Username")
		self.assertTrue(user.password == "894f117cc2e31a7195ad628cadf8da1a", "Password hashed")

		user2 = AudioScrobblerUser("doug_fernando", "abc", True)
		self.assertTrue(user2.username == "doug_fernando", "Username")
		self.assertTrue(user2.password == "abc", "Password")


class MusicPlayerFixture(AspyFixture):
	def __init__(self):
		AspyFixture.__init__(self)
		self.title = "Music player tests"

	def run(self):
		audio_player = FakePlayer()
		
		player = MusicPlayer(None, audio_player)
		player.__class__.current_volume = -1
		
		player.configure_volume()
		
		self.assertTrue(player.__class__.current_volume == 2, "Current volume")
		self.assertTrue(player.volume_step == 1, "Correct step")
		
		player.loaded = True
		
		player.__class__.current_volume = 0
		player.volume_up()
		self.assertTrue(player.__class__.current_volume == 1, "Current volume")

		player.__class__.current_volume = 9
		player.volume_up()
		self.assertTrue(player.__class__.current_volume == 10, "Current volume")
		player.volume_up()
		self.assertTrue(player.__class__.current_volume == 10, "Current volume")
		
		player.__class__.current_volume = 2
		player.volume_down()
		self.assertTrue(player.__class__.current_volume == 1, "Current volume")
		player.volume_down()
		self.assertTrue(player.__class__.current_volume == 0, "Current volume")
		player.volume_down()
		self.assertTrue(player.__class__.current_volume == 0, "Current volume")

		player.__class__.current_volume = 2
		self.assertTrue(player.current_volume_percentage() == 20, "Current percentage")
		
		player.__class__.current_volume = 0
		self.assertTrue(player.current_volume_percentage() == 0, "Current percentage")
		
		player.__class__.current_volume = 10
		self.assertTrue(player.current_volume_percentage() == 100, "Current percentage")
		
		player.__class__.current_volume = 2

		audio_player.state = lambda: 2
		self.assertEquals("Playing", player.get_status_formatted(), "playing status formatted")

		audio_player.state = lambda: 0
		self.assertEquals("Stopped", player.get_status_formatted(), "stopped status formatted")


class FakePlayer(object):
	def max_volume(self):
		return 10;
	
	def set_volume(self, value):
		pass

	def state(self):
		return 2

class MusicHistoryFixture(AspyFixture):
	def __init__(self):
		AspyFixture.__init__(self)
		self.title = "Music history tests"

	def run(self):
		self.music_history_tests()
		self.send_batches_tests()
	
	def music_history_tests(self):
		ms = []
		for i in range(10):
			ms.append(self.load_music())
		
		repos = MusicHistoryRepository(None)
		repos.load_all_history = lambda: ms
		repos.clear_history = lambda: None
		
		as_service = AudioScrobblerService(None)
		empty = []
		as_service.send = lambda musics:empty.append(1)
		
		m_h = MusicHistory(repos, as_service)
		m_h.send_to_audioscrobbler()
		
		self.assertTrue(len(empty) > 0, "Simple send expected")
		
		for i in range(50):
			ms.append(self.load_music())
		
		empty.pop()
		old_method = m_h.send_batches_to_audioscrobbler
		m_h.send_batches_to_audioscrobbler = lambda musics: None

		m_h.send_to_audioscrobbler()
		
		self.assertTrue(len(empty) == 0, "Batch expected")
		
	def send_batches_tests(self):
		musics = [i for i in range(135)]
		l = []
		m_h = MusicHistory(None, None)
		m_h.send_batch = lambda batch: l.append(len(batch))
		m_h.send_batches_to_audioscrobbler(musics)
		self.assertTrue(l[0] == 50, "Batch 1")
		self.assertTrue(l[1] == 50, "Batch 2")
		self.assertTrue(l[2] == 35, "Batch 3")
	

class AudioScrobblerUserRepositoryFixture(AspyFixture):
	def __init__(self):
		AspyFixture.__init__(self)
		self.title = "AudioScrobblerUserRepository tests"
		f = open("E:\\as.pwd", "rb")
		self.pwd = f.read().replace(" ", "")
		f.close()

	def run(self):
		u = AudioScrobblerUser("doug_fernando", self.pwd)
		self.sl.user_repository.save(u)
		u2 = self.sl.user_repository.load()
		
		self.assertEquals(u.username, u2.username, "Users")
		self.assertEquals(u.password, u2.password, "Passwords")
	

class MusicListFixture(AspyFixture):
	def __init__(self):
		AspyFixture.__init__(self)
	
	def run(self):
		musics = [Music() for i in range(3)]
		
		ml = MusicList(musics, None, None)
		
		self.assertEquals("1 / 3", ml.current_position_formated(), "Correct first position")
		self.assertTrue(ml.move_previous() == False, "Cannot move back from start")
		self.assertTrue(ml.move_next(), "Can move forward")
		self.assertEquals("2 / 3", ml.current_position_formated(), "Correct sec position")
		self.assertTrue(ml.move_next(), "Can move forward")
		self.assertEquals("3 / 3", ml.current_position_formated(), "Correct last position")
		self.assertTrue(ml.move_next() == False, "Cannot move forward")
		self.assertEquals("3 / 3", ml.current_position_formated(), "Correct last position")
		self.assertTrue(ml.move_previous(), "Can move back")
		self.assertEquals("2 / 3", ml.current_position_formated(), "Correct sec position")
		self.assertTrue(ml.move_previous(), "Can move back")
		self.assertTrue(ml.move_previous() == False, "Cannot move back")
		
		# random
		m1 = Music()
		m1.number = 1
		m2 = Music()
		m2.number = 2
		m3 = Music()
		m3.number = 3
		m4 = Music()
		m4.number = 4
		m5 = Music()
		m5.number = 5
		musics2 = [m1, m2, m3, m4, m5]

		
		ml2 = MusicList(musics2, None, None)
		ml2.random()
		ml2.update_playing_mode_if_necessary()
		ml2.move_next()
		
		self.assertTrue(ml2.current_music.number != m2.number, "Next is not really the next now (shuffle, sometimes test can fail)")
		

class HardErrorControllerFixture(AspyFixture):
	def __init__(self):
		AspyFixture.__init__(self)
		self.title = "HardErrorControllerFixture"
		
	def run(self):
		l =[]
		action = lambda: l.append(1)
		hec = HardErrorController(action)
		hec.now = lambda: 100 # constant
		
		hec.handle_hard_error(True)
		self.assertEquals(60, hec.how_long_to_wait(), "First error on handshake")
		hec.handle_hard_error(True)
		self.assertEquals(120, hec.how_long_to_wait(), "Second error on handshake")
		hec.handle_hard_error(True)
		self.assertEquals(240, hec.how_long_to_wait(), "Third error on handshake")
		hec.logging_sucessful()
		self.assertEquals(0, hec.how_long_to_wait(), "No waiting required")
		
		hec.handle_hard_error()
		self.assertTrue(not l, "No new handshake required")
		hec.handle_hard_error()
		self.assertTrue(not l, "No new handshake required")
		hec.handle_hard_error()
		self.assertTrue(l, "New handshake required")

class UnicodeHelperFixture(AspyFixture):
	def __init__(self):
		AspyFixture.__init__(self)
	
	def run(self):
		input_a = "E:\\Music\\Testing\\Lêusy Reputation.mp3"
		val = UnicodeHelper.safe_unicode(input_a)
		valx = UnicodeHelper.safe_unicode(val)
		f = open(val.encode("utf8"))
		f.close()
		
		input_b = "E:\\Music\\Bloc Party - Silent Alarm\\01 - Like Eating Glass.mp3"
		val = UnicodeHelper.safe_unicode(input_b)
		f = open(val.encode("utf8"))
		f.close()
		

class Id3InfoReaderFixture(AspyFixture):
	def __init__(self):
		AspyFixture.__init__(self)
		self.title = "Id3InfoReaderFixture"	
	
	def run(self):
		input_a = "E:\\Music\\Testing\\02 - Shoot The Runner.mp3"
		reader = Id3InfoReader(input_a)
		
		marker, fp = reader.init_file(input_a)
		self.assertTrue(marker != "TAG", "Not Id3v1")
		
		reader = Id3InfoReader(input_a)
		title = reader.title
		self.assertEquals("Runner", title[-6:], "Uses the file name if v2")
		
		
class AspyFixtures(object):
	def __init__(self):
		self.tests = [
			MusicFixture(),
			MusicPlayerFixture(),
			MusicListFixture(),
			MusicHistoryFixture(),
			UserFixture(),
			AudioScrobblerUserRepositoryFixture(),
			MusicHistoryRepositoryFixture(),
			#AudioScrobblerServiceFixture(),
			FileSystemServicesFixture(),
			#DbHelper
			#PlayerUI,
			HardErrorControllerFixture(),
			UnicodeHelperFixture(),
			Id3InfoReaderFixture()
		]
		
	def run(self):
		FixtureRunner(self.tests).run()
 

##########################################################
######################### PROGRAM ENTRY POINT  
 
if __name__ == '__main__':
	logger = LogFactory.create_for("main")
	try:
		logger.info("Starting the ASPY player")
		AspyPlayerApplication().run()
		logger.info("Exiting the ASPY player")
	except:
		logger.info("ASPY Player General error: '%s'" % ''.join(traceback.format_exception(*sys.exc_info())))

Show details Hide details

Change log

r48 by doug.fernando on Apr 15, 2008 Diff

pause feature details implemented

Go to:

Project members, sign in to write a code review

Older revisions

r47 by doug.fernando on Apr 15, 2008 Diff

pause feature implemented

r46 by doug.fernando on Apr 13, 2008 Diff

Added rebuild music library feature

r45 by doug.fernando on Apr 13, 2008 Diff

application data on E:\ drive if it
exists

All revisions of this file

File info

Size: 72821 bytes, 2481 lines

View raw file