Lib/plat-irix6/readcd.py

# Class interface to the CD module.

import cd, CD

class Error(Exception):
    pass
class _Stop(Exception):
    pass

def _doatime(self, cb_type, data):
    if ((data[0] * 60) + data[1]) * 75 + data[2] > self.end:
##              print 'done with list entry', repr(self.listindex)
        raise _Stop
    func, arg = self.callbacks[cb_type]
    if func:
        func(arg, cb_type, data)

def _dopnum(self, cb_type, data):
    if data > self.end:
##              print 'done with list entry', repr(self.listindex)
        raise _Stop
    func, arg = self.callbacks[cb_type]
    if func:
        func(arg, cb_type, data)

class Readcd:
    def __init__(self, *arg):
        if len(arg) == 0:
            self.player = cd.open()
        elif len(arg) == 1:
            self.player = cd.open(arg[0])
        elif len(arg) == 2:
            self.player = cd.open(arg[0], arg[1])
        else:
            raise Error, 'bad __init__ call'
        self.list = []
        self.callbacks = [(None, None)] * 8
        self.parser = cd.createparser()
        self.playing = 0
        self.end = 0
        self.status = None
        self.trackinfo = None

    def eject(self):
        self.player.eject()
        self.list = []
        self.end = 0
        self.listindex = 0
        self.status = None
        self.trackinfo = None
        if self.playing:
##                      print 'stop playing from eject'
            raise _Stop

    def pmsf2msf(self, track, min, sec, frame):
        if not self.status:
            self.cachestatus()
        if track < self.status[5] or track > self.status[6]:
            raise Error, 'track number out of range'
        if not self.trackinfo:
            self.cacheinfo()
        start, total = self.trackinfo[track]
        start = ((start[0] * 60) + start[1]) * 75 + start[2]
        total = ((total[0] * 60) + total[1]) * 75 + total[2]
        block = ((min * 60) + sec) * 75 + frame
        if block > total:
            raise Error, 'out of range'
        block = start + block
        min, block = divmod(block, 75*60)
        sec, frame = divmod(block, 75)
        return min, sec, frame

    def reset(self):
        self.list = []

    def appendtrack(self, track):
        self.appendstretch(track, track)

    def appendstretch(self, start, end):
        if not self.status:
            self.cachestatus()
        if not start:
            start = 1
        if not end:
            end = self.status[6]
        if type(end) == type(0):
            if end < self.status[5] or end > self.status[6]:
                raise Error, 'range error'
        else:
            l = len(end)
            if l == 4:
                prog, min, sec, frame = end
                if prog < self.status[5] or prog > self.status[6]:
                    raise Error, 'range error'
                end = self.pmsf2msf(prog, min, sec, frame)
            elif l != 3:
                raise Error, 'syntax error'
        if type(start) == type(0):
            if start < self.status[5] or start > self.status[6]:
                raise Error, 'range error'
            if len(self.list) > 0:
                s, e = self.list[-1]
                if type(e) == type(0):
                    if start == e+1:
                        start = s
                        del self.list[-1]
        else:
            l = len(start)
            if l == 4:
                prog, min, sec, frame = start
                if prog < self.status[5] or prog > self.status[6]:
                    raise Error, 'range error'
                start = self.pmsf2msf(prog, min, sec, frame)
            elif l != 3:
                raise Error, 'syntax error'
        self.list.append((start, end))

    def settracks(self, list):
        self.list = []
        for track in list:
            self.appendtrack(track)

    def setcallback(self, cb_type, func, arg):
        if cb_type < 0 or cb_type >= 8:
            raise Error, 'type out of range'
        self.callbacks[cb_type] = (func, arg)
        if self.playing:
            start, end = self.list[self.listindex]
            if type(end) == type(0):
                if cb_type != CD.PNUM:
                    self.parser.setcallback(cb_type, func, arg)
            else:
                if cb_type != CD.ATIME:
                    self.parser.setcallback(cb_type, func, arg)

    def removecallback(self, cb_type):
        if cb_type < 0 or cb_type >= 8:
            raise Error, 'type out of range'
        self.callbacks[cb_type] = (None, None)
        if self.playing:
            start, end = self.list[self.listindex]
            if type(end) == type(0):
                if cb_type != CD.PNUM:
                    self.parser.removecallback(cb_type)
            else:
                if cb_type != CD.ATIME:
                    self.parser.removecallback(cb_type)

    def gettrackinfo(self, *arg):
        if not self.status:
            self.cachestatus()
        if not self.trackinfo:
            self.cacheinfo()
        if len(arg) == 0:
            return self.trackinfo[self.status[5]:self.status[6]+1]
        result = []
        for i in arg:
            if i < self.status[5] or i > self.status[6]:
                raise Error, 'range error'
            result.append(self.trackinfo[i])
        return result

    def cacheinfo(self):
        if not self.status:
            self.cachestatus()
        self.trackinfo = []
        for i in range(self.status[5]):
            self.trackinfo.append(None)
        for i in range(self.status[5], self.status[6]+1):
            self.trackinfo.append(self.player.gettrackinfo(i))

    def cachestatus(self):
        self.status = self.player.getstatus()
        if self.status[0] == CD.NODISC:
            self.status = None
            raise Error, 'no disc in player'

    def getstatus(self):
        return self.player.getstatus()

    def play(self):
        if not self.status:
            self.cachestatus()
        size = self.player.bestreadsize()
        self.listindex = 0
        self.playing = 0
        for i in range(8):
            func, arg = self.callbacks[i]
            if func:
                self.parser.setcallback(i, func, arg)
            else:
                self.parser.removecallback(i)
        if len(self.list) == 0:
            for i in range(self.status[5], self.status[6]+1):
                self.appendtrack(i)
        try:
            while 1:
                if not self.playing:
                    if self.listindex >= len(self.list):
                        return
                    start, end = self.list[self.listindex]
                    if type(start) == type(0):
                        dummy = self.player.seektrack(
                                start)
                    else:
                        min, sec, frame = start
                        dummy = self.player.seek(
                                min, sec, frame)
                    if type(end) == type(0):
                        self.parser.setcallback(
                                CD.PNUM, _dopnum, self)
                        self.end = end
                        func, arg = \
                              self.callbacks[CD.ATIME]
                        if func:
                            self.parser.setcallback(CD.ATIME, func, arg)
                        else:
                            self.parser.removecallback(CD.ATIME)
                    else:
                        min, sec, frame = end
                        self.parser.setcallback(
                                CD.ATIME, _doatime,
                                self)
                        self.end = (min * 60 + sec) * \
                                   75 + frame
                        func, arg = \
                              self.callbacks[CD.PNUM]
                        if func:
                            self.parser.setcallback(CD.PNUM, func, arg)
                        else:
                            self.parser.removecallback(CD.PNUM)
                    self.playing = 1
                data = self.player.readda(size)
                if data == '':
                    self.playing = 0
                    self.listindex = self.listindex + 1
                    continue
                try:
                    self.parser.parseframe(data)
                except _Stop:
                    self.playing = 0
                    self.listindex = self.listindex + 1
        finally:
            self.playing = 0