From a406e60db0d396cc7891364f57bfe62905eeac48 Mon Sep 17 00:00:00 2001
From: Guillaume Pellerin <yomguy@parisson.com>
Date: Tue, 10 Mar 2009 13:07:28 +0000
Subject: [PATCH] kill d-fuzz

---
 d-fuzz.py | 292 ------------------------------------------------------
 1 file changed, 292 deletions(-)
 delete mode 100755 d-fuzz.py

diff --git a/d-fuzz.py b/d-fuzz.py
deleted file mode 100755
index e57cc37..0000000
--- a/d-fuzz.py
+++ /dev/null
@@ -1,292 +0,0 @@
-#!/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()
-
-- 
2.39.5