"
- print ""
-
-def colophon():
- print "
"
- print "TeleOddCast "+version+" ©
2007 Parisson. Tous droits réservés."
- print "
"
+
+class Course:
+ """A course in a class room"""
+
+ def __init__(self, dict):
+ self.department = course_dict['department']
+ self.course = course_dict['course']
+ self.session = course_dict['session']
+ self.professor = course_dict['professor']
+ self.comment = course_dict['comment']
+
+ def get_info(self):
+ return self.title, self.department, self.course, self.session, self.professor, self.comment
+
+
+class TeleOddCast(Course):
+ """Control the Oddcastv3-jack thread which send audio data to the icecast server
+ and the Streamripper thread which write audio on the hard disk"""
+
+ def __init__(self, conf_file, course_dict):
+ Course.__init__(self, course_dict)
+ self.conf = xml2dict(conf_file)
+ self.title = self.conf['title']
+ self.root_dir = self.conf['root_dir']
+ self.media_dir = self.conf['media_dir']
+ self.server = self.conf['server']
+ self.port = self.conf['port']
+ self.url = 'http://'+self.server+':'+self.port
+ self.uid = os.getuid()
+ self.odd_pid = get_pid('^oddcastv3 -n [^LIVE]', self.uid)
+ self.rip_pid = get_pid('streamripper ' + self.url + self.mount_point, self.uid)
+ self.odd_conf_file = self.conf['odd_conf_file']
+ self.ServerDescription = clean_string('_-_'.join(self.title,
+ self.department,
+ self.course,
+ self.session,
+ self.professor,
+ self.comment))
+ self.ServerName = clean_string('_-_'.join(self.title,
+ self.department,
+ self.course,
+ self.session))
+ self.mount_point = '/' + clean_string(self.title) + '_-_' + \
+ clean_string(self.department) + '_-_' + \
+ clean_string(self.course)+'.ogg'
+ self.lock_file = self.root_dir + self.ServerDescription + '.lock'
+ self.filename = self.ServerDescription + '.ogg'
+
+ def set_oddcast_conf(self):
+ oddconf = open(self.odd_conf_file,'r')
+ lines = oddconf.readlines()
+ oddconf.close()
+ newlines = []
+ for line in lines:
+ if 'ServerDescription' in line.split('='):
+ newlines.append('ServerDescription=' + \
+ self.ServerDescription.replace(' ','_') + '\n')
+
+ elif 'ServerName' in line.split('='):
+ newlines.append('ServerName=' + self.ServerName + '\n')
+
+ elif 'ServerMountpoint' in line.split('='):
+ newlines.append('ServerMountpoint=' + self.mount_point + '\n')
+
+ else:
+ newlines.append(line)
+
+ oddconf = open(self.odd_conf_file,'w')
+ oddconf.writelines(newlines)
+ oddconf.close()
+
+ def start_oddcast(self):
+ command = 'oddcastv3 -n "'+clean_string(self.course)+'" -c '+self.odd_conf_file+ \
+ ' alsa_pcm:capture_1 alsa_pcm:capture_2 > /dev/null &'
+ os.system(command)
+ self.set_lock()
+ time.sleep(1)
+ return mount_point
+
+ def set_lock(self):
+ lock = open(self.lock_file,'w')
+ lock_text = clean_string('_*_'.join(self.title,
+ self.department,
+ self.course,
+ self.session,
+ self.professor,
+ self.comment))
+ lock_text = lock_text.replace('\n','')
+ lock.write(lock_text)
+ lock.close()
+
+
+ def del_lock(self):
+ os.remove(self.lock_file)
+
+ def start_rip(self):
+ output_dir = self.media_dir + os.sep + self.department + os.sep
+ #print mount_point
+ if not os.path.exists(output_dir):
+ os.mkdir(output_dir)
+ command = 'streamripper ' + self.url + self.mount_point + \
+ ' -d '+output_dir+' -D "%S" -s -t --quiet > /dev/null &'
+ os.system(command)
+
+ def stop_oddcast(self):
+ os.system('kill -9 ' + self.odd_pid[0])
+
+ def stop_rip(self):
+ os.system('kill -9 ' + self.rip_pid[0])
+ time.sleep(1)
+ date = datetime.datetime.now().strftime("%Y")
+ dirname = self.media_dir + os.sep + self.department + os.sep + \
+ clean_string('_-_'.join(self.title, self.department, self.course, self.session))
+
+ if os.path.exists(dirname) and os.path.exists(dirname+os.sep+'incomplete'):
+ shutil.move(dirname+os.sep+'incomplete'+os.sep+' - .ogg',dirname+os.sep)
+ shutil.rmtree(dirname+os.sep+'incomplete'+os.sep)
+ os.rename(dirname+os.sep+' - .ogg',dirname+os.sep+self.filename)
+
+ def write_tags(self):
+ date = datetime.datetime.now().strftime("%Y")
+ new_title = clean_string('_-_'.join(self.title, self.department, self.course, self.session)
+ dirname = self.media_dir + os.sep + self.department + os.sep + new_title
+ if os.path.exists(dirname+os.sep+self.filename):
+ audio = OggVorbis(dirname+os.sep+self.filename)
+ audio['TITLE'] = new_title
+ audio['ARTIST'] = self.professor
+ audio['ALBUM'] = self.title
+ audio['DATE'] = date
+ audio['GENRE'] = 'Vocal'
+ audio['SOURCE'] = self.title
+ audio['ENCODER'] = 'TeleOddCast by Parisson'
+ audio['COMMENT'] = self.comment
+ audio.save()
+
+ def start(self):
+ self.set_lock()
+ self.set_oddcast_conf()
+ self.start_oddcast()
+ self.start_rip()
+
+ def stop(self):
+ self.stop_rip
+ self.write_tags()
+ self.stop_oddcast()
+ self.del_lock()
-def footer():
- print "
"
+ print ""
+
+ def colophon(self):
+ print "
"
+ print "TeleOddCast "+self.version+" ©
2007 Parisson. Tous droits réservés."
+ print "
"
+
+ def footer(self):
+ print "
"
+ print "
"
+ for department in self.departments:
+ courses = self.conf[department]['courses']
+ print "\t
"
+ print "\t
Attention, il est important de remplir tous les champs, y compris le commentaire !
"
+ print "