+++ /dev/null
-#!/usr/bin/python
-# -*- coding: utf-8 -*-
-#
-# Copyright (c) 2007-2009 Guillaume Pellerin <yomguy@parisson.com>
-# All rights reserved.
-#
-# This software is licensed as described in the file COPYING, which
-# you should have received as part of this distribution. The terms
-# are also available at http://svn.parisson.org/defuzz/wiki/DefuzzLicense.
-#
-# Author: Guillaume Pellerin <yomguy@parisson.com>
-
-import os
-import sys
-import time
-import datetime
-import string
-import random
-import Queue
-import subprocess
-from shout import Shout
-from tools import *
-from threading import Thread
-from mutagen.oggvorbis import OggVorbis
-
-version = '0.2.2'
-year = datetime.datetime.now().strftime("%Y")
-
-def prog_info():
- desc = '\n defuzz : easy and light streaming tool\n'
- ver = ' version : %s \n\n' % (version)
- info = """ Copyright (c) 2007-%s Guillaume Pellerin <yomguy@parisson.com>
- All rights reserved.
-
- This software is licensed as described in the file COPYING, which
- you should have received as part of this distribution. The terms
- are also available at http://svn.parisson.org/d-fuzz/DFuzzLicense
-
- depends : python, python-xml, python-shout, libshout3, icecast2
- recommends : python-mutagen
- provides : python-shout
-
- Usage : defuzz $1
- where $1 is the path for a XML config file
- ex: defuzz example/myfuzz.xml
-
- see http://parisson.com/defuzz/ for more details
- """ % (year)
- text = desc + ver + info
- return text
-
-class DeFuzzError:
- """The DeFuzz main error class"""
- def __init__(self, message, command, subprocess):
- self.message = message
- self.command = str(command)
- self.subprocess = subprocess
-
- def __str__(self):
- if self.subprocess.stderr != None:
- error = self.subprocess.stderr.read()
- else:
- error = ''
- return "%s ; command: %s; error: %s" % (self.message,
- self.command,
- error)
-
-class DeFuzz:
- """A DeFuzz station"""
-
- def __init__(self, conf_file):
- self.conf_file = conf_file
- self.conf = self.get_conf_dict()
- #print self.conf
-
- def get_conf_dict(self):
- confile = open(self.conf_file,'r')
- conf_xml = confile.read()
- confile.close()
- dict = xmltodict(conf_xml,'utf-8')
- return dict
-
- def get_station_names(self):
- return self.conf['station']['name']
-
- def run(self):
- # Fix wrong type data from xmltodict when one station (*)
- if isinstance(self.conf['defuzz']['station'], dict):
- nb_stations = 1
- else:
- nb_stations = len(self.conf['defuzz']['station'])
- print 'Number of stations : ' + str(nb_stations)
-
- for i in range(0,nb_stations):
- # Create a Queue
- #q = Queue.Queue(1)
-
- # (*) idem
- if isinstance(self.conf['defuzz']['station'], dict):
- station = self.conf['defuzz']['station']
- else:
- station = self.conf['defuzz']['station'][i]
- #print station
- name = station['infos']['name']
- nb_channels = int(station['infos']['channels'])
- print 'Station %s: %s has %s channels' % (str(i+1), name, str(nb_channels))
- #s = Station(station, nb_channels, q)
- #s.start()
- #time.sleep(0.1)
- for channel_id in range(0, nb_channels):
- #print channel_id
- c = Channel(station, channel_id + 1)
- c.start()
- #time.sleep(0.5)
-
-
-class Station(Thread):
- """A DeFuzz Station thread"""
-
- def __init__(self, station, nb_channels):
- Thread.__init__(self)
- #self.station_q = station_q
- self.station = station
- self.nb_channels = nb_channels
-
- def run(self):
- #station_q = self.station_q
- i=0
- while 1 :
- #print currentThread(),"Produced One Item:",i
- self.station_q.put(i,1)
- i+=1
- #time.sleep(1)
-
-
-class Channel(Thread):
- """A channel shouting thread"""
-
- def __init__(self, station, channel_id):
- Thread.__init__(self)
- #self.channel_q = channel_q
- self.station = station
- self.buffer_size = 16384
- self.channel_id = channel_id
- self.channel = Shout()
- self.id = 999999
- self.counter = 0
- self.rand_list = []
- self.command = "cat "
- # Media
- self.media_dir = self.station['media']['dir']
- self.channel.format = self.station['media']['format']
- self.mode_shuffle = int(self.station['media']['shuffle'])
- # Infos
- self.short_name = self.station['infos']['short_name'] + '_' + str(self.channel_id)
- self.channel.name = self.station['infos']['name'] + '_' + str(self.channel_id)
- self.channel.genre = self.station['infos']['genre']
- self.channel.description = self.station['infos']['description']
- self.channel.url = self.station['infos']['url']
- # Server
- self.channel.protocol = 'http' # | 'xaudiocast' | 'icy'
- self.channel.host = self.station['server']['host']
- self.channel.port = int(self.station['server']['port'])
- self.channel.user = 'source'
- self.channel.password = self.station['server']['sourcepassword']
- self.channel.mount = '/' + self.short_name + '.' + self.channel.format
- #print self.channel.mount
- self.channel.public = int(self.station['server']['public'])
- # s.audio_info = { 'key': 'val', ... }
- # (keys are shout.SHOUT_AI_BITRATE, shout.SHOUT_AI_SAMPLERATE,
- # shout.SHOUT_AI_CHANNELS, shout.SHOUT_AI_QUALITY)
-
- def get_playlist(self):
- file_list = []
- for root, dirs, files in os.walk(self.media_dir):
- for file in files:
- file_list.append(root + os.sep + file)
- return file_list
-
- def get_next_media_lin(self, playlist):
- lp = len(playlist)
- if self.id >= (lp - 1):
- playlist = self.get_playlist()
- self.id = 0
- else:
- self.id = self.id + 1
- return playlist, playlist[self.id]
-
- def get_next_media_rand(self, playlist):
- lp = len(playlist)
- if self.id >= (lp - 1):
- #print 'Get random list...'
- playlist = self.get_playlist()
- lp_new = len(playlist)
- if lp_new != lp or self.counter == 0:
- self.rand_list = range(0,lp_new)
- random.shuffle(self.rand_list)
- #print self.rand_list
- self.id = 0
- else:
- self.id = self.id + 1
- index = self.rand_list[self.id]
- #print str(self.id) +':'+ str(index)
- return playlist, playlist[index]
-
- def core_process(self, media, buffer_size):
- """Read media and stream data through a generator.
- Taken from Telemeta (see http://telemeta.org)"""
-
- command = self.command + '"' + media + '"'
- __chunk = 0
- try:
- proc = subprocess.Popen(command,
- shell = True,
- bufsize = buffer_size,
- stdin = subprocess.PIPE,
- stdout = subprocess.PIPE,
- close_fds = True)
- except:
- raise DeFuzzError('Command failure:', command, proc)
-
- # Core processing
- while True:
- __chunk = proc.stdout.read(buffer_size)
- status = proc.poll()
- if status != None and status != 0:
- raise DeFuzzError('Command failure:', command, proc)
- if len(__chunk) == 0:
- break
- yield __chunk
-
- #__chunk = 0
- #file = open(media, 'r')
- ## Core processing
- #while True:
- #__chunk = file.read(buffer_size)
- #if len(__chunk) == 0:
- #break
- #yield __chunk
- #file.close()
-
- def run(self):
- #print "Using libshout version %s" % shout.version()
- #__chunk = 0
- self.channel.open()
- print 'Opening ' + self.channel.name + '...'
- time.sleep(0.1)
-
- # Playlist
- playlist = self.get_playlist()
- lp = len(playlist)-1
- self.rand_list = range(0,lp)
-
- while True:
- if lp == 0:
- break
- if self.mode_shuffle == 1:
- #print 'Shuffle mode'
- playlist, media = self.get_next_media_rand(playlist)
- else:
- playlist, media = self.get_next_media_lin(playlist)
- self.counter += 1
- if os.path.exists(media) and not '/.' in media:
- file_name = string.replace(media, self.media_dir + os.sep, '')
- #print 'Playlist (%s ch%s) : %s' % (self.short_name, self.channel_id, file_name)
- #print playlist
- #print media
- self.channel.set_metadata({'song': file_name})
- stream = self.core_process(media, self.buffer_size)
- print 'Defuzzing this file on %s (channel: %s, track: %s): %s' % (self.short_name, self.channel_id, self.id, file_name)
-
- for __chunk in stream:
- # Get the queue
- #self.channel_q.get(1)
- self.channel.send(__chunk)
- self.channel.sync()
-
- self.channel.close()
-
-
-def main():
- if len(sys.argv) == 2:
- print "Defuzz v"+version
- defuzz_main = DeFuzz(sys.argv[1])
- defuzz_main.run()
- else:
- text = prog_info()
- sys.exit(text)
-
-if __name__ == '__main__':
- main()
-
projects / deefuzzer.git / commitdiff