# encoding: utf-8

require 'open-uri'
require 'open3'

class WebRadio
	class DownloadError < StandardError; end

	def self.instance(url, options)
		case url
		when %r[^http://hibiki-radio\.jp/]
			require 'hibiki'
			Hibiki.new(url, options)
		when %r[^http://sp\.animate\.tv/]
			require 'animate'
			Animate.new(url)
		when %r[^http://onsen\.ag/program/]
			require 'onsen'
			Onsen.new(url, options)
		when %r[^http://seaside-c\.jp/program/], %r[http://nakamuland\.net/]
			require 'seaside-c'
			SeasideCommnunications.new(url, options)
		when %r[nicovideo\.jp]
			require 'nicovideo'
			Nicovideo.new(url, options)
		when %r[www\.youtube\.com]
			require 'youtube'
			YouTube.new(url, options)
		else
			raise 'unsupported url.'
		end
	end

	def initialize(url, options)
		raise 'do not instanciate directly, use WebRadio method.' if self.class == WebRadio
		@url = url
		@options = options
		if @options.path =~ %r|^dropbox://|
			require 'dropbox'
			@dropbox = DropboxAuth.client
		end
	end

	def download(name)
		raise 'not implemented.'
	end

private
	def mp3ize(src, dst, delete_src = true)
		if @options.mp3
			if exist?(dst)
				puts "#{dst} is existent, skipped."
				return
			end
		else
			if exist?(src)
				puts "#{src} is existent, skipped."
				return
			end
		end


		# download src file
		unless File.exist?(src)
			print "getting #{src}..."
			begin
				yield
				puts "done."
			rescue DownloadError => e
				File.delete(src) if File.exist?(src)
				puts "failed."
				$stderr.puts e.message
				return
			end
		end
		if !@options.mp3 || src == dst
			move(src) if @options.path
			return
		end

		# convert to mp3
		print "converting to mp3..."
		ffmpeg = (@options['mp3nize'] || "ffmpeg -i '$1' -ab 64k '$2'").gsub(/\$(.)/){|s|
			case $1
				when '1'; src
				when '2'; dst
				when '$'; '$'
				else; s
			end
		}
		result = Open3.capture3(ffmpeg)
		if result[2].to_i == 0
			File.delete(src) if delete_src
			puts "done."
		else
			File.delete(dst) if File.exist?(dst)
			puts "failed."
			$stderr.puts result[1]
			return
		end
		move(dst) if @options.path
	end

	def exist?(dst)
		if @dropbox
			begin
				!@dropbox.ls(dropbox_file(dst))[0]['is_deleted']
			rescue Dropbox::API::Error::NotFound, NoMethodError
				false
			end
		elsif @options.path
			File.exist?(File.join(@options.path, dst))
		else
			File.exist?(dst)
		end
	end

	def move(dst)
		if @options.path
			print "move to #{@options.path}..."
			begin
				if @dropbox
					@dropbox.chunked_upload(dropbox_file(dst), open(dst))
					File.delete(dst)
				elsif @options.path
					FileUtils.mv(dst, @options.path)
				end
				puts "done."
			rescue => e
				puts "failed."
				$stderr.puts e.message
			end
		end
	end

	def dropbox_file(file)
		path = @options.path.sub(%r|^dropbox://|, '')
		File.join(path, file)
	end
end

def WebRadio(url, options)
	radio = WebRadio.instance(url, options)
	yield radio if block_given?
	radio
end