#!/usr/bin/env python

# Copyright (C) 2007 Lars Immisch

import sys
import os
import getopt
import threading
import logging
import struct
import aculab
from aculab.error import AculabError
from aculab.snapshot import Snapshot
from aculab.speech import SpeechChannel, Glue
from aculab.reactor import Reactor
from aculab.switching import DefaultBus

class RecordController:

    def dtmf(self, channel, digit, user_data):
        log.info('dtmf: %s', digit)

    def record_done(self, channel, file, reason, size, user_data):
        raise StopIteration

def usage():
    print '''usage:
    ts_rec.py [-c <card>] [-m <module>] <stream>:<timeslot> <filename>
    '''
    sys.exit(-2)

if __name__ == '__main__':

    log = aculab.defaultLogging(logging.DEBUG)

    card = 0
    module = 0
    controller = RecordController()

    options, args = getopt.getopt(sys.argv[1:], 'c:m:')

    for o, a in options:
        if o == '-c':
            card = int(a)
        elif o == '-m':
            module = int(a)
        else:
            usage()

    if len(args) % 2 != 0:
        usage()

    slots = []
    filenames = []
    for i in range(0, len(args), 2):
        try:
            st = args[i].split(':')
            slots.append((int(st[0]), int(st[1])))
            filenames.append(args[i+1])
        except IndexError:
            usage()
        
    snapshot = Snapshot()

    channels = []
    connections = []

    for s, f in zip(slots, filenames):
        channel = SpeechChannel(controller, card, module)
        channels.append(channel)
        
        connections.append(channel.listen_to(s))

        channel.record(f)
    
    Reactor.run()