Class: MPDTestServer

Inherits:

GServer

Object
GServer
MPDTestServer

show all

Defined in:: lib/mpdserver.rb

Instance Method Summary collapse

Constructor Details

#initialize(port, db_file = nil, *args) ⇒ `MPDTestServer`

Returns a new instance of MPDTestServer.

# File 'lib/mpdserver.rb', line 57

def initialize( port, db_file = nil, *args )
	super port, *args

	if db_file.nil?
		db_file = __FILE__.gsub(/\/[^\/]*$/, '') + '/../data/database.yaml'
	end

	@status = {
		:volume => 0,
		:repeat => 0,
		:random => 0,
		:playlist => 1,
		:state => 'stop',
		:xfade => 0
	}
	@elapsed_time = 0
	@current_song = nil
	@database = YAML::load( File.open( db_file ) )
	@songs = @database[0]
	@playlists = @database[1]
	@artists = []
	@albums = []
	@titles = []
	@the_playlist = []
	@playback_thread = nil
	@filetree = {:name =>'', :dirs =>[], :songs =>[]}
	@songs.each_with_index do |song,i|
		song['id'] = i
		if !song['artist'].nil? and !@artists.include? song['artist']
			@artists << song['artist']
		end
		if !song['album'].nil? and !@albums.include? song['album']
			@albums << song['album']
		end
		if !song['title'].nil?
			@titles << song['title']
		end
		if !song['file'].nil?
			dirs = song['file'].split '/'
			dirs.pop
			the_dir = @filetree
			dirs.each do |d|
				found = nil
				the_dir[:dirs].each do |sub|
					if sub[:name] == d
						found = sub
						break
					end
				end
				if found.nil?
					found = {:name => d, :dirs =>[], :songs =>[]}
					the_dir[:dirs] << found
				end
				the_dir = found
			end # End dirs.each
			the_dir[:songs] << song
		end # End if !song['file'].nil?
	end # End @songs.each

	sort_dir @filetree
	@artists.sort!
	@albums.sort!
	@titles.sort!
end

Instance Method Details

#add_dir_to_pls(dir) ⇒ `Object`

# File 'lib/mpdserver.rb', line 1182

def add_dir_to_pls( dir )
	dir[:songs].each do |song|
		song['_mod_ver'] = @status[:playlist]
		incr_version
		@the_playlist << song
	end

	dir[:dirs].each do |d|
		add_dir_to_pls d
	end
end

#args_check(sock, cmd, argv, argc) ⇒ `Object`

# File 'lib/mpdserver.rb', line 1119

def args_check( sock, cmd, argv, argc )
	if (argc.kind_of? Range and argc.include?(argv.length)) or
			(argv.length == argc)
		yield argv
	else
		sock.puts "ACK [2@0] {#{cmd}} wrong number of arguments for \"#{cmd}\""
	end
end

#build_args(line) ⇒ `Object`

# File 'lib/mpdserver.rb', line 1087

def build_args( line )
	ret = []
	word = ''
	escaped = false
	in_quote = false

	line.strip!

	line.each_byte do |c|
		c = c.chr
		if c == ' ' and !in_quote
			ret << word unless word.empty?
			word = ''
		elsif c == '"' and !escaped
			if in_quote
				in_quote = false
			else
				in_quote = true
			end
			ret << word unless word.empty?
			word = ''
		else
			escaped = (c == '\\')
			word += c
		end
	end

	ret << word unless word.empty?

	return ret
end

#cmd_fail(sock, msg) ⇒ `Object`

# File 'lib/mpdserver.rb', line 1082

def cmd_fail( sock, msg )
	sock.puts msg
	return false
end

#do_cmd(sock, cmd, args) ⇒ `Object`

# File 'lib/mpdserver.rb', line 224

def do_cmd( sock, cmd, args )
	case cmd
		when 'add'
			if args.length == 0
				# Add the entire database
				@songs.each do |s|
					s['_mod_ver'] = @status[:playlist]
					incr_version
					@the_playlist << s
				end
				return true
			else
				# Add a single entry
				the_song = nil
				@songs.each do |s|
					if s['file'] == args[0]
						the_song = s
						break
					end
				end

				if the_song.nil?
					dir = locate_dir(args[0])
					if not dir.nil?
						# Add the dir
						add_dir_to_pls dir
						return true
					else
						return(cmd_fail(sock,'ACK [50@0] {add} directory or file not found'))
					end
				else
					the_song['_mod_ver'] = @status[:playlist]
					incr_version
					@the_playlist << the_song
					return true
				end
			end
		when 'clear'
			args_check( sock, cmd, args, 0 ) do
				incr_version
				@the_playlist = []
				@current_song = nil
				return true
			end
		when 'clearerror'
			args_check( sock, cmd, args, 0 ) do
				the_error = nil
				return true
			end
		when 'close'
			sock.close
			return true
		when 'crossfade'
			args_check( sock, cmd, args, 1 ) do |args|
				if is_int(args[0]) and args[0].to_i >= 0
					@status[:xfade] = args[0].to_i
					return true
				else
					return(cmd_fail(sock,"ACK [2@0] {crossfade} \"#{args[0]}\" is not a integer >= 0"))
				end
			end
		when 'currentsong'
			args_check( sock, cmd, args, 0 ) do
				if @current_song != nil and @current_song < @the_playlist.length
					send_song sock, @the_playlist[@current_song]
				end
				return true
			end
		when 'delete'
			args_check( sock, cmd, args, 1 ) do |args|
				if is_int args[0]
					if args[0].to_i < 0 or args[0].to_i >= @the_playlist.length
						return(cmd_fail(sock,"ACK [50@0] {delete} song doesn't exist: \"#{args[0]}\""))
					else
						@the_playlist.delete_at args[0].to_i
						args[0].to_i.upto @the_playlist.length - 1 do |i|
							@the_playlist[i]['_mod_ver'] = @status[:playlist]
						end
						incr_version
						return true
					end
				else
					return(cmd_fail('ACK [2@0] {delete} need a positive integer'))
				end
			end
		when 'deleteid'
			args_check( sock, cmd, args, 1 ) do |args|
				if is_int args[0]
					the_song = nil
					@the_playlist.each do |song|
						if song['id'] == args[0].to_i
							the_song = song
							break
						end
					end

					if not the_song.nil?
						index = @the_playlist.index the_song
						@the_playlist.delete the_song
						index.upto @the_playlist.length - 1 do |i|
							@the_playlist[i]['_mod_ver'] = @status[:playlist]
						end
						incr_version
						return true
					else
						return(cmd_fail(sock,"ACK [50@0] {deleteid} song id doesn't exist: \"#{args[0]}\""))
					end
				else
					return(cmd_fail(sock,'ACK [2@0] {deleteid} need a positive integer'))
				end
			end
		when 'find'
			args_check( sock, cmd, args, 2 ) do |args|
				if args[0] != 'album' and args[0] != 'artist' and args[0] != 'title'
					return(cmd_fail(sock,'ACK [2@0] {find} incorrect arguments'))
				else
					if args[0] == 'album'
						@songs.each do |song|
							if song['album'] == args[1]
								send_song sock, song
							end
						end
					elsif args[0] == 'artist'
						@songs.each do |song|
							if song['artist'] == args[1]
								send_song sock, song
							end
						end
					elsif args[0] == 'title'
						@songs.each do |song|
							if song['title'] == args[1]
								send_song sock, song
							end
						end
					end
					return true
				end
			end
		when 'kill'
			args_check( sock, cmd, args, 0 ) do
				sock.close
				return true
			end
		when 'list'
			args_check( sock, cmd, args, 1..2 ) do |args|
				if args[0] != 'album' and args[0] != 'artist' and args[0] != 'title'
					return(cmd_fail(sock,"ACK [2@0] {list} \"#{args[0]}\" is not known"))
				elsif args[0] == 'artist' and args.length > 1
					return(cmd_fail(sock,'ACK [2@0] {list} should be "Album" for 3 arguments'))
				else
					if args[0] == 'artist'
						# List all Artists
						@artists.each do |artist|
							sock.puts "Artist: #{artist}"
						end
						return true
					elsif args[0] == 'title'
						# List all Titles
						@titles.each do |title|
							sock.puts "Title: #{title}"
						end
						return true
					else
						if args.length == 2
							# List all Albums by Artist
							# artist == args[1]
							listed = []
							@songs.each do |song|
								if song['artist'] == args[1]
									if not song['album'].nil? and !listed.include? song['album']
										sock.puts "Album: #{song['album']}"
										listed << song['album']
									end
								end
							end
							return true
						else
							# List all Albums
							@albums.each do |album|
								sock.puts "Album: #{album}"
							end
							return true
						end
					end
				end
			end
		when 'listall'
			args_check( sock, cmd, args, 0..1 ) do |args|
				if args.length == 0
					@filetree[:dirs].each do |d|
						send_dir sock, d, false
					end
				else
					was_song = false
					@songs.each do |song|
						if song['file'] == args[0]
							sock.puts "file: #{song['file']}"
							was_song = true
							break
						end
					end

					if was_song
						return true
					end

					dir = locate_dir args[0]
					if not dir.nil?
						parents = args[0].split '/'
						parents.pop
						parents = parents.join '/'
						parents += '/' unless parents.length == 0
						send_dir sock, dir, false, parents
					else
						return(cmd_fail(sock,'ACK [50@0] {listall} directory or file not found'))
					end
				end
				return true
			end
		when 'listallinfo'
			args_check( sock, cmd, args, 0..1 ) do |args|
				if args.length == 0
					@filetree[:dirs].each do |d|
						send_dir sock, d, true
					end
				else
					was_song = false
					@songs.each do |song|
						if song['file'] == args[0]
							send_song song
							was_song = true
							break
						end
					end

					if was_song
						return true
					end

					dir = locate_dir args[0]
					if not dir.nil?
						parents = args[0].split '/'
						parents.pop
						parents = parents.join '/'
						parents += '/' unless parents.length == 0
						send_dir sock, dir, true, parents
					else
						return(cmd_fail(sock,'ACK [50@0] {listallinfo} directory or file not found'))
					end
				end
				return true
			end
		when 'load'
			args_check( sock, cmd, args, 1 ) do
				# incr_version for each song loaded
				pls = args[0] + '.m3u'
				the_pls = nil
				@playlists.each do |p|
					if p['file'] == pls
						the_pls = p
						break
					end
				end

				unless the_pls.nil?
					the_pls['songs'].each do |song|
						song['_mod_ver'] = @status[:playlist]
						@the_playlist << song
						incr_version
					end
				else
					return(cmd_fail(sock,"ACK [50@0] {load} playlist \"#{args[0]}\" not found"))
				end
			end
		when 'lsinfo'
			args_check( sock, cmd, args, 0..1 ) do
				if args.length == 0
					@filetree[:dirs].each do |d|
						sock.puts "directory: #{d[:name]}"
						d[:songs].each do |s|
							send_song sock, s
						end
					end
					@playlists.each do |pls|
						sock.puts "playlist: #{pls['file'].gsub( /\.m3u$/, '' )}"
					end
				else
					dir = locate_dir args[0]
					if dir.nil?
						return(cmd_fail(sock,"ACK [50@0] {lsinfo} directory not found"))
					else
						dir[:dirs].each do |d|
							sock.puts "directory: #{args[0] + '/' + d[:name]}"
						end
						dir[:songs].each do |s|
							send_song sock, s
						end
					end
				end
				return true
			end
		when 'move'
			args_check( sock, cmd, args, 2 ) do |args|
				if !is_int args[0]
					return(cmd_fail(sock,"ACK [2@0] {move} \"#{args[0]}\" is not a integer"))
				elsif !is_int args[1]
					return(cmd_fail(sock,"ACK [2@0] {move} \"#{args[1]}\" is not a integer"))
				elsif args[0].to_i < 0 or args[0].to_i >= @the_playlist.length
					return(cmd_fail(sock,"ACK [50@0] {move} song doesn't exist: \"#{args[0]}\""))
				elsif args[1].to_i < 0 or args[1].to_i >= @the_playlist.length
					return(cmd_fail(sock,"ACK [50@0] {move} song doesn't exist: \"#{args[1]}\""))
				else
					tmp = @the_playlist.delete_at args[0].to_i
					@the_playlist.insert args[1].to_i, tmp
					if args[0].to_i < args[1].to_i
						args[0].to_i.upto args[1].to_i do |i|
							@the_playlist[i]['_mod_ver'] = @status[:playlist]
						end
					else
						args[1].to_i.upto args[0].to_i do |i|
							@the_playlist[i]['_mod_ver'] = @status[:playlist]
						end
					end
					incr_version
					return true
				end
			end
		when 'moveid'
			args_check( sock, cmd, args, 2 ) do |args|
				if !is_int args[0]
					return(cmd_fail(sock,"ACK [2@0] {moveid} \"#{args[0]}\" is not a integer"))
				elsif !is_int args[1]
					return(cmd_fail(sock,"ACK [2@0] {moveid} \"#{args[1]}\" is not a integer"))
				elsif args[1].to_i < 0 or args[1].to_i >= @the_playlist.length
					return(cmd_fail(sock,"ACK [50@0] {moveid} song doesn't exist: \"#{args[1]}\""))
				else
					# Note: negative args should be checked
					the_song = nil
					index = -1
					@the_playlist.each_with_index do |song,i|
						if song['id'] == args[0].to_i
							the_song = song
							index = i
						end
					end
					if the_song.nil?
						return(cmd_fail(sock,"ACK [50@0] {moveid} song id doesn't exist: \"#{args[0]}\""))
					end
					tmp = @the_playlist.delete_at index
					@the_playlist.insert args[1].to_i, tmp
					if index < args[1].to_i
						index.upto args[1].to_i do |i|
							@the_playlist[i]['_mod_ver'] = @status[:playlist]
						end
					else
						args[1].to_i.upto index do |i|
							@the_playlist[i]['_mod_ver'] = @status[:playlist]
						end
					end
					incr_version
					return true
				end
			end
		when 'next'
			args_check( sock, cmd, args, 0 ) do
				if @status[:state] != 'stop'
					next_song
					@elapsed_time = 0
					@status[:state] = 'play'
				end
				return true
			end
		when 'pause'
			args_check( sock, cmd, args, 0..1 ) do |args|
				if args.length > 0 and not is_bool args[0]
					return(cmd_fail(sock,"ACK [2@0] {pause} \"#{args[0]}\" is not 0 or 1"))
				end
				
				if @status[:state] != 'stop'
					if args.length == 1
						@status[:state] = ( args[0] == '1' ? 'pause' : 'play' )
					else
						@status[:state] = ( @status[:state] == 'pause' ? 'play' : 'pause' )
					end
				end

				return true
			end
		when 'password'
			args_check( sock, cmd, args, 1 ) do |args|
			return true if args[0] == 'test'
			return(cmd_fail(sock,"ACK [3@0] {password} incorrect password"))
			end
		when 'ping'
			args_check( sock, cmd, args, 0 ) do
				return true
			end
		when 'play'
			args_check( sock, cmd, args, 0..1 ) do |args|
				if args.length > 0 and !is_int(args[0])
					return(cmd_fail(sock,'ACK [2@0] {play} need a positive integer'))
				else
					args.clear if args[0] == '-1'
					if args.length == 0
						if @the_playlist.length > 0 and @status[:state] != 'play'
							@current_song = 0 if @current_song.nil?
							@elapsed_time = 0
							@status[:state] = 'play'
						end
					else
						if args[0].to_i < 0 or args[0].to_i >= @the_playlist.length
							return(cmd_fail(sock,"ACK [50@0] {play} song doesn't exist: \"#{args[0]}\""))
						end

						@current_song = args[0].to_i
						@elapsed_time = 0
						@status[:state] = 'play'
					end
					return true
				end
			end
		when 'playid'
			args_check( sock, cmd, args, 0..1 ) do |args|
				if args.length > 0 and !is_int(args[0])
					return(cmd_fail(sock,'ACK [2@0] {playid} need a positive integer'))
				else
					args.clear if args[0] == '-1'
					if args.length == 0
						if @the_playlist.length > 0 and @status[:state] != 'play'
							@current_song = 0 if @current_song.nil?
							@elapsed_time = 0
							@status[:state] = 'play'
						end
					else
						index = nil
						@the_playlist.each_with_index do |s,i|
							if s['id'] == args[0].to_i
								index = i
								break;
							end
						end

						return(cmd_fail(sock,"ACK [50@0] {playid} song id doesn't exist: \"#{args[0]}\"")) if index.nil?

						@current_song = index
						@elapsed_time = 0
						@status[:state] = 'play'
					end
					return true
				end
			end
		when 'playlist'
			log 'MPD Warning: Call to Deprecated API: "playlist"' if audit
			args_check( sock, cmd, args, 0 ) do
				@the_playlist.each_with_index do |v,i|
					sock.puts "#{i}:#{v['file']}"
				end
				return true
			end
		when 'playlistinfo'
			args_check( sock, cmd, args, 0..1 ) do |args|
				if args.length > 0 and !is_int(args[0])
					return(cmd_fail(sock,'ACK [2@0] {playlistinfo} need a positive integer'))
				else
					args.clear if args.length > 0 and args[0].to_i < 0
					if args.length != 0
						if args[0].to_i >= @the_playlist.length
							return(cmd_fail(sock,"ACK [50@0] {playlistinfo} song doesn't exist: \"#{args[0]}\""))
						else
							song = @the_playlist[args[0].to_i]
							send_song sock, song
							sock.puts "Pos: #{args[0].to_i}"
							return true
						end
					else
						@the_playlist.each_with_index do |song,i|
							send_song sock, song
							sock.puts "Pos: #{i}"
						end
						return true
					end
				end
			end
		when 'playlistid'
			args_check( sock, cmd, args, 0..1 ) do |args|
				if args.length > 0 and !is_int(args[0])
					return(cmd_fail(sock,'ACK [2@0] {playlistid} need a positive integer'))
				else
					song = nil
					pos = nil
					args.clear if args[0].to_i < 0
					if args.length != 0
						@the_playlist.each_with_index do |s,i|
							if s['id'] == args[0].to_i
								song = s
								pos = i
								break;
							end
						end

						return(cmd_fail(sock,"ACK [50@0] {playlistid} song id doesn't exist: \"#{args[0]}\"")) if song.nil?

						send_song sock, song
						sock.puts "Pos: #{pos}"
						return true
					else
						@the_playlist.each_with_index do |song,i|
							send_song sock, song
							sock.puts "Pos: #{i}"
						end
						return true
					end
				end
			end
		when 'plchanges'
			args_check( sock, cmd, args, 1 ) do |args|
				if args.length > 0 and !is_int(args[0])
					return(cmd_fail(sock,'ACK [2@0] {plchanges} need a positive integer'))
				else
					# Note: args[0] < 0 just return OK...
					@the_playlist.each_with_index do |song,i|
						if args[0].to_i > @status[:playlist] or song['_mod_ver'] >= args[0].to_i or song['_mod_ver'] == 0
							send_song sock, song
							sock.puts "Pos: #{i}"
						end
					end
					return true
				end
			end
		when 'plchangesposid'
			args_check( sock, cmd, args, 1 ) do |args|
				if args.length > 0 and !is_int(args[0])
					return(cmd_fail(sock,'ACK [2@0] {plchangesposid} need a positive integer'))
				else
					# Note: args[0] < 0 just return OK...
					@the_playlist.each_with_index do |song,i|
						if args[0].to_i > @status[:playlist] or song['_mod_ver'] >= args[0].to_i or song['_mod_ver'] == 0
							sock.puts "cpos: #{i}"
							sock.puts "Id: #{song['id']}"
						end
					end
					return true
				end
			end
		when 'previous'
			args_check( sock, cmd, args, 0 ) do
				return true if @status[:state] == 'stop'
				prev_song
				@elapsed_time = 0
				@status[:state] = 'play'
				return true
			end
		when 'random'
			args_check( sock, cmd, args, 1 ) do |args|
				if is_bool args[0]
					@status[:random] = args[0].to_i
					return true
				elsif is_int args[0]
					return(cmd_fail(sock,"ACK [2@0] {random} \"#{args[0]}\" is not 0 or 1"))
				else
					return(cmd_fail(sock,'ACK [2@0] {random} need an integer'))
				end
			end
		when 'repeat'
			args_check( sock, cmd, args, 1 ) do |args|
				if is_bool args[0]
					@status[:repeat] = args[0].to_i
					return true
				elsif is_int args[0]
					return(cmd_fail(sock,"ACK [2@0] {repeat} \"#{args[0]}\" is not 0 or 1"))
				else
					return(cmd_fail(sock,'ACK [2@0] {repeat} need an integer'))
				end
			end
		when 'rm'
			args_check( sock, cmd, args, 1 ) do |args|
				rm_pls = args[0] + '.m3u'
				the_pls = -1
				@playlists.each_with_index do |pls,i|
					the_pls = i if pls['file'] == rm_pls
				end

				if the_pls != -1
					@playlists.delete_at the_pls
					return true
				else
					return(cmd_fail(sock,"ACK [50@0] {rm} playlist \"#{args[0]}\" not found"))
				end
			end
		when 'save'
			args_check( sock, cmd, args, 1 ) do |args|
				new_playlist = {'file' => args[0]+'.m3u', 'songs' => @the_playlist}
				@playlists << new_playlist
				return true
			end
		when 'search'
			args_check( sock, cmd, args, 2 ) do |args|
				if args[0] != 'title' and args[0] != 'artist' and args[0] != 'album' and args[0] != 'filename'
					return(cmd_fail(sock,'ACK [2@0] {search} incorrect arguments'))
				end
				args[0] = 'file' if args[0] == 'filename'
				@songs.each do |song|
					data = song[args[0]]
					if not data.nil? and data.downcase.include? args[1]
						send_song sock, song
					end
				end
				return true
			end
		when 'seek'
			args_check( sock, cmd, args, 2 ) do |args|
				if !is_int args[0]
					return(cmd_fail(sock,"ACK [2@0] {seek} \"#{args[0]}\" is not a integer"))
				elsif !is_int args[1]
					return(cmd_fail(sock,"ACK [2@0] {seek} \"#{args[1]}\" is not a integer"))
				else
					if args[0].to_i > @the_playlist.length or args[0].to_i < 0
						return(cmd_fail(sock,"ACK [50@0] {seek} song doesn't exist: \"#{args[0]}\""))
					end
					args[1] = '0' if args[1].to_i < 0
					song = @the_playlist[args[0].to_i]
					if args[1].to_i >= song['time'].to_i
						if args[0].to_i + 1 < @the_playlist.length
							@current_song = args[0].to_i + 1
							@elapsed_time = 0
							@status[:state] = 'play' unless @status[:state] == 'pause'
						else
							@current_song = nil
							@elapsed_time = 0
							@status[:state] = 'stop'
						end
					else
						@current_song = args[0].to_i
						@elapsed_time = args[1].to_i
						@status[:state] = 'play' unless @status[:state] == 'pause'
					end
					return true
				end
			end
		when 'seekid'
			args_check( sock, cmd, args, 2 ) do |args|
				if !is_int args[0]
					return(cmd_fail(sock,"ACK [2@0] {seekid} \"#{args[0]}\" is not a integer"))
				elsif !is_int args[1]
					return(cmd_fail(sock,"ACK [2@0] {seekid} \"#{args[1]}\" is not a integer"))
				else
					pos = nil
					song = nil
					@the_playlist.each_with_index do |s,i|
						if s['id'] == args[0].to_i
							song = s
							pos = i
							break;
						end
					end

					if song.nil?
						return(cmd_fail(sock,"ACK [50@0] {seekid} song id doesn't exist: \"#{args[0]}\""))
					end

					args[1] = '0' if args[1].to_i < 0
					if args[1].to_i >= song['time'].to_i
						if pos + 1 < @the_playlist.length
							@current_song = pos + 1
							@elapsed_time = 0
							@status[:state] = 'play' unless @status[:state] == 'pause'
						else
							@current_song = nil
							@elapsed_time = 0
							@status[:state] = 'stop'
						end
					else
						@current_song = pos
						@elapsed_time = args[1].to_i
						@status[:state] = 'play' unless @status[:state] == 'pause'
					end
					return true
				end
			end
		when 'setvol'
			args_check( sock, cmd, args, 1 ) do |args|
				if !is_int args[0]
					return(cmd_fail(sock,'ACK [2@0] {setvol} need an integer'))
				else
					# Note: args[0] < 0 actually sets the vol val to < 0
					@status[:volume] = args[0].to_i
					return true
				end
			end
		when 'shuffle'
			args_check( sock, cmd, args, 0 ) do
				@the_playlist.each do |s|
					s['_mod_ver'] = @status[:playlist]
				end
				incr_version
				@the_playlist.reverse!
				return true
			end
		when 'stats'
			args_check( sock, cmd, args, 0 ) do
			# artists
			sock.puts "artists: #{@artists.size}"
			# albums
			sock.puts "albums: #{@albums.size}"
			# songs
			sock.puts "songs: #{@songs.size}"
			# uptime
			sock.puts "uptime: 500"
			# db_playtime
			time = 0
			@songs.each do |s|
				time += s['time'].to_i
			end
			sock.puts "db_playtime: #{time}"
			# db_update
			sock.puts "db_update: 1159418502"
			# playtime
			sock.puts "playtime: 10"
			return true
			end
		when 'status'
			args_check( sock, cmd, args, 0 ) do
				@status.each_pair do |key,val|
					sock.puts "#{key}: #{val}" unless val.nil?
				end
				sock.puts "playlistlength: #{@the_playlist.length}"

				if @current_song != nil and @the_playlist.length > @current_song
					sock.puts "song: #{@current_song}"
					sock.puts "songid: #{@the_playlist[@current_song]['id']}"
				end

				@status[:updating_db] = nil
				return true
			end
		when 'stop'
			args_check( sock, cmd, args, 0 ) do
				@status[:state] = 'stop'
				@status[:time] = nil
				@status[:bitrate] = nil
				@status[:audio] = nil
				return true
			end
		when 'swap'
			args_check( sock, cmd, args, 2 ) do |args|
				if !is_int args[0]
					return(cmd_fail(sock,"ACK [2@0] {swap} \"#{args[0]}\" is not a integer"))
				elsif !is_int args[1]
					return(cmd_fail(sock,"ACK [2@0] {swap} \"#{args[1]}\" is not a integer"))
				elsif args[0].to_i >= @the_playlist.length or args[0].to_i < 0
					return(cmd_fail(sock,"ACK [50@0] {swap} song doesn't exist: \"#{args[0]}\""))
				elsif args[1].to_i >= @the_playlist.length or args[1].to_i < 0
					return(cmd_fail(sock,"ACK [50@0] {swap} song doesn't exist: \"#{args[1]}\""))
				else
					tmp = @the_playlist[args[1].to_i]
					@the_playlist[args[1].to_i] = @the_playlist[args[0].to_i]
					@the_playlist[args[0].to_i] = tmp
					@the_playlist[args[0].to_i]['_mod_ver'] = @status[:playlist]
					@the_playlist[args[1].to_i]['_mod_ver'] = @status[:playlist]
					incr_version
					return true
				end
			end
		when 'swapid'
			args_check( sock, cmd, args, 2 ) do |args|
				if !is_int args[0]
					return(cmd_fail(sock,"ACK [2@0] {swapid} \"#{args[0]}\" is not a integer"))
				elsif !is_int args[1]
					return(cmd_fail(sock,"ACK [2@0] {swapid} \"#{args[1]}\" is not a integer"))
				else
					from = nil
					to = nil
					@the_playlist.each_with_index do |song,i|
						if song['id'] == args[0].to_i
							from = i
						elsif song['id'] == args[1].to_i
							to = i
						end
					end
					if from.nil?
						return(cmd_fail(sock,"ACK [50@0] {swapid} song id doesn't exist: \"#{args[0]}\""))
					elsif to.nil?
						return(cmd_fail(sock,"ACK [50@0] {swapid} song id doesn't exist: \"#{args[1]}\""))
					end
					tmp = @the_playlist[to]
					@the_playlist[to] = @the_playlist[from]
					@the_playlist[from] = tmp
					@the_playlist[to]['_mod_ver'] = @status[:playlist]
					@the_playlist[from]['_mod_ver'] = @status[:playlist]

					incr_version
					return true
				end
			end
		when 'update'
			args_check( sock, cmd, args, 0..1 ) do |args|
				incr_version
				sock.puts 'updating_db: 1'
				@status[:updating_db] = '1'
				return true
			end
		when 'volume'
			log 'MPD Warning: Call to Deprecated API: "volume"' if audit
			args_check( sock, cmd, args, 1 ) do |args|
				if !is_int args[0]
					return(cmd_fail(sock,'ACK [2@0] {volume} need an integer'))
				else
					# Note: args[0] < 0 subtract from the volume
					@status[:volume] += args[0].to_i
					return true
				end
			end
		else
			return(cmd_fail(sock,"ACK [5@0] {} unknown command #{cmd}"))
	end # End Case cmd
end

#elapsed_time ⇒ `Object`



1067
1068
1069

# File 'lib/mpdserver.rb', line 1067

def elapsed_time
	@elapsed_time
end

#elapsed_time=(new_time) ⇒ `Object`



1063
1064
1065

# File 'lib/mpdserver.rb', line 1063

def elapsed_time=( new_time )
	@elapsed_time = new_time
end

#get_current_song ⇒ `Object`

# File 'lib/mpdserver.rb', line 1041

def get_current_song
	if @current_song != nil and @current_song < @the_playlist.length
		return @the_playlist[@current_song]
	else
		return nil
	end
end

#incr_version ⇒ `Object`

# File 'lib/mpdserver.rb', line 1071

def incr_version
	if @status[:playlist] == 2147483647
		@status[:playlist] = 1
		@the_playlist.each do |song|
			song['_mod_ver'] = 0
		end
	else
		@status[:playlist] += 1
	end
end

#is_bool(val) ⇒ `Object`



1132
1133
1134

# File 'lib/mpdserver.rb', line 1132

def is_bool( val )
	val == '0' or val == '1'
end

#is_int(val) ⇒ `Object`



1128
1129
1130

# File 'lib/mpdserver.rb', line 1128

def is_int( val )
 	val =~ /^[-+]?[0-9]*$/
end

#locate_dir(path) ⇒ `Object`

# File 'lib/mpdserver.rb', line 1136

def locate_dir( path )
	dirs = path.split '/'

	the_dir = @filetree
	dirs.each do |d|
		found = nil
		the_dir[:dirs].each do |sub|
			if sub[:name] == d
				found = sub
				break
			end
		end
		if found.nil?
			return nil
		else
			the_dir = found
		end
	end

	return the_dir
end

#next_song ⇒ `Object`

# File 'lib/mpdserver.rb', line 1058

def next_song
	return if @current_song.nil?
	@current_song = (@current_song +1 < @the_playlist.length ? @current_song +1 : nil)
end

#prev_song ⇒ `Object`

# File 'lib/mpdserver.rb', line 1049

def prev_song
	return if @current_song.nil?
	if @current_song == 0
		@elapsed_time = 0
	else
		@current_song -= 1
	end
end

#send_dir(sock, dir, allinfo, path = '') ⇒ `Object`

# File 'lib/mpdserver.rb', line 1166

def send_dir( sock, dir, allinfo, path = '' )
	sock.puts "directory: #{path}#{dir[:name]}"

	dir[:songs].each do |song|
		if allinfo
			send_song sock, song
		else
			sock.puts "file: #{song['file']}"
		end
	end

	dir[:dirs].each do |d|
		send_dir(sock, d, allinfo, dir[:name] + '/')
	end
end

#send_song(sock, song) ⇒ `Object`

# File 'lib/mpdserver.rb', line 1158

def send_song( sock, song )
	return if song.nil?
	sock.puts "file: #{song['file']}"
	song.each_pair do |key,val|
		sock.puts "#{key.capitalize}: #{val}" unless key == 'file' or key == '_mod_ver'
	end
end

#serve(sock) ⇒ `Object`

# File 'lib/mpdserver.rb', line 166

def serve( sock )
	command_list = []
	in_cmd_list = false
	in_ok_list = false
	the_error = nil
	sock.puts 'OK MPD 0.11.5'
	begin
		while line = sock.gets

			args = build_args line

			cmd = args.shift

			if cmd == 'command_list_begin' and args.length == 0 and !in_cmd_list
				in_cmd_list = true
				log 'MPD: Starting Command List' if audit
			elsif cmd == 'command_list_ok_begin' and args.length == 0 and !in_cmd_list
				in_cmd_list = true
				in_ok_list = true
				log 'MPD: Starting Command OK List' if audit
			elsif cmd == 'command_list_end' and in_cmd_list
				log 'MPD: Running Command List' if audit

				the_ret = true
				command_list.each_with_index do |set,i|
					the_ret = do_cmd sock, set[0], set[1]

					if audit
						log "MPD Command List: CMD ##{i}: \"#{set[0]}(#{set[1].join(', ')})\": " + (the_ret ? 'successful' : 'failed')
					end
					
					break unless the_ret

					sock.puts 'list_OK' if in_ok_list
					
				end

				sock.puts 'OK' if the_ret

				command_list.clear
				in_cmd_list = false
				in_ok_list = false
			else
				if in_cmd_list
					command_list << [cmd, args]
				else
					ret = do_cmd sock, cmd, args
					sock.puts 'OK' if ret
					if audit
						log "MPD Command \"#{cmd}(#{args.join(', ')})\": " + (ret ? 'successful' : 'failed')
					end # End if audit
				end # End if in_cmd_list
			end # End if cmd == 'comand_list_begin' ...
		end # End while line = sock.gets
	rescue
	end
end

#sort_dir(dir) ⇒ `Object`

# File 'lib/mpdserver.rb', line 1194

def sort_dir( dir )
	dir[:dirs].sort! do |x,y|
		x[:name] <=> y[:name]
	end

	dir[:dirs].each do |d|
		sort_dir d
	end
end

#start ⇒ `Object`

# File 'lib/mpdserver.rb', line 122

def start
	super

	@playback_thread = Thread.new(@status, self) do |status, server|
		while not server.stopped?
			if status[:state] == 'play'
				song = server.get_current_song
				if song.nil?
					server.elapsed_time = 0
					status[:state] = 'stop'
					next
				end

				status[:time] = "#{server.elapsed_time}:#{song['time']}"
				status[:bitrate] = 192
				status[:audio] = '44100:16:2'

				if server.elapsed_time >= song['time'].to_i
					server.elapsed_time = 0
					server.next_song
				end

				server.elapsed_time = server.elapsed_time + 1
			elsif status[:state] == 'pause'
				song = server.get_current_song
				if song.nil?
					server.elapsed_time = 0
					status[:state] = 'stop'
					next
				end
				status[:time] = "#{server.elapsed_time}:#{song['time']}"
				status[:bitrate] = 192
				status[:audio] = '44100:16:2'
			else
				status[:time] = nil
				status[:bitrate] = nil
				status[:audio] = nil
				server.elapsed_time = 0
			end
			sleep 1
		end
	end
end

Class: MPDTestServer

Instance Method Summary collapse

Constructor Details

#initialize(port, db_file = nil, *args) ⇒ MPDTestServer

Instance Method Details

#add_dir_to_pls(dir) ⇒ Object

#args_check(sock, cmd, argv, argc) ⇒ Object

#build_args(line) ⇒ Object

#cmd_fail(sock, msg) ⇒ Object

#do_cmd(sock, cmd, args) ⇒ Object

#elapsed_time ⇒ Object

#elapsed_time=(new_time) ⇒ Object

#get_current_song ⇒ Object

#incr_version ⇒ Object

#is_bool(val) ⇒ Object

#is_int(val) ⇒ Object

#locate_dir(path) ⇒ Object

#next_song ⇒ Object

#prev_song ⇒ Object

#send_dir(sock, dir, allinfo, path = '') ⇒ Object

#send_song(sock, song) ⇒ Object

#serve(sock) ⇒ Object

#sort_dir(dir) ⇒ Object

#start ⇒ Object

#initialize(port, db_file = nil, *args) ⇒ `MPDTestServer`

#add_dir_to_pls(dir) ⇒ `Object`

#args_check(sock, cmd, argv, argc) ⇒ `Object`

#build_args(line) ⇒ `Object`

#cmd_fail(sock, msg) ⇒ `Object`

#do_cmd(sock, cmd, args) ⇒ `Object`

#elapsed_time ⇒ `Object`

#elapsed_time=(new_time) ⇒ `Object`

#get_current_song ⇒ `Object`

#incr_version ⇒ `Object`

#is_bool(val) ⇒ `Object`

#is_int(val) ⇒ `Object`

#locate_dir(path) ⇒ `Object`

#next_song ⇒ `Object`

#prev_song ⇒ `Object`

#send_dir(sock, dir, allinfo, path = '') ⇒ `Object`

#send_song(sock, song) ⇒ `Object`

#serve(sock) ⇒ `Object`

#sort_dir(dir) ⇒ `Object`

#start ⇒ `Object`