Synnefo

                     Commission, Provision, ProvisionLog, CallSerial,

                     db_get_commission, db_filter_provision, db_get_callserial)

                  context=None, clientkey=None, serial=None,

        if serial is not None:

            if clientkey is None:

                all_pairs = [(q[0], q[1]) for q in sub_quota + add_quota]

                raise QuotaholderError(all_pairs)

            try:

                cs = CallSerial.objects.get(serial=serial, clientkey=clientkey)

                all_pairs = [(q[0], q[1]) for q in sub_quota + add_quota]

                raise QuotaholderError(all_pairs)

            except CallSerial.DoesNotExist:

                pass

        if serial is not None and clientkey is not None:

            CallSerial.objects.create(serial=serial, clientkey=clientkey)

    def ack_serials(self, context=None, clientkey=None, serials=()):

        if clientkey is None:

            return

        for serial in serials:

            try:

                c = db_get_callserial(clientkey=clientkey,

                                      serial=serial,

                                      for_update=True)

                c.delete()

            except CallSerial.DoesNotExist:

                pass

        return

    def query_serials(self, context=None, clientkey=None, serials=()):

        result = []

        append = result.append

        if clientkey is None:

            return result

        if not serials:

            cs = CallSerial.objects.filter(clientkey=clientkey)

            return [c.serial for c in cs]

        for serial in serials:

            try:

                db_get_callserial(clientkey=clientkey, serial=serial)

                append(serial)

            except CallSerial.DoesNotExist:

                pass

        return result