Revision e3685916 snf-quotaholder-app/quotaholder_django/quotaholder_app/callpoint.py
| b/snf-quotaholder-app/quotaholder_django/quotaholder_app/callpoint.py | ||
|---|---|---|
| 84 | 84 |
|
| 85 | 85 |
return call_fn(**data) |
| 86 | 86 |
|
| 87 |
def create_entity(self, context={}, create_entity=()):
|
|
| 87 |
def create_entity(self, context=None, create_entity=()):
|
|
| 88 | 88 |
rejected = [] |
| 89 | 89 |
append = rejected.append |
| 90 | 90 |
|
| ... | ... | |
| 107 | 107 |
raise ReturnButFail(rejected) |
| 108 | 108 |
return rejected |
| 109 | 109 |
|
| 110 |
def set_entity_key(self, context={}, set_entity_key=()):
|
|
| 110 |
def set_entity_key(self, context=None, set_entity_key=()):
|
|
| 111 | 111 |
rejected = [] |
| 112 | 112 |
append = rejected.append |
| 113 | 113 |
|
| ... | ... | |
| 125 | 125 |
raise ReturnButFail(rejected) |
| 126 | 126 |
return rejected |
| 127 | 127 |
|
| 128 |
def list_entities(self, context={}, entity=None, key=None):
|
|
| 128 |
def list_entities(self, context=None, entity=None, key=None):
|
|
| 129 | 129 |
try: |
| 130 | 130 |
e = Entity.objects.get(entity=entity, key=key) |
| 131 | 131 |
except Entity.DoesNotExist: |
| ... | ... | |
| 136 | 136 |
entities = [e.entity for e in children] |
| 137 | 137 |
return entities |
| 138 | 138 |
|
| 139 |
def get_entity(self, context={}, get_entity=()):
|
|
| 139 |
def get_entity(self, context=None, get_entity=()):
|
|
| 140 | 140 |
entities = [] |
| 141 | 141 |
append = entities.append |
| 142 | 142 |
|
| ... | ... | |
| 154 | 154 |
|
| 155 | 155 |
return entities |
| 156 | 156 |
|
| 157 |
def get_limits(self, context={}, get_limits=()):
|
|
| 157 |
def get_limits(self, context=None, get_limits=()):
|
|
| 158 | 158 |
limits = [] |
| 159 | 159 |
append = limits.append |
| 160 | 160 |
|
| ... | ... | |
| 169 | 169 |
|
| 170 | 170 |
return limits |
| 171 | 171 |
|
| 172 |
def set_limits(self, context={}, set_limits=()):
|
|
| 172 |
def set_limits(self, context=None, set_limits=()):
|
|
| 173 | 173 |
|
| 174 | 174 |
for (policy, quantity, capacity, |
| 175 | 175 |
import_limit, export_limit) in set_limits: |
| ... | ... | |
| 191 | 191 |
|
| 192 | 192 |
return () |
| 193 | 193 |
|
| 194 |
def get_holding(self, context={}, get_holding=()):
|
|
| 194 |
def get_holding(self, context=None, get_holding=()):
|
|
| 195 | 195 |
holdings = [] |
| 196 | 196 |
append = holdings.append |
| 197 | 197 |
|
| ... | ... | |
| 222 | 222 |
policy=p, flags=flags) |
| 223 | 223 |
return h |
| 224 | 224 |
|
| 225 |
def set_holding(self, context={}, set_holding=()):
|
|
| 225 |
def set_holding(self, context=None, set_holding=()):
|
|
| 226 | 226 |
rejected = [] |
| 227 | 227 |
append = rejected.append |
| 228 | 228 |
|
| ... | ... | |
| 279 | 279 |
h.releasing = released |
| 280 | 280 |
h.save() |
| 281 | 281 |
|
| 282 |
def init_holding(self, context={}, init_holding=()):
|
|
| 282 |
def init_holding(self, context=None, init_holding=()):
|
|
| 283 | 283 |
rejected = [] |
| 284 | 284 |
append = rejected.append |
| 285 | 285 |
|
| ... | ... | |
| 311 | 311 |
raise ReturnButFail(rejected) |
| 312 | 312 |
return rejected |
| 313 | 313 |
|
| 314 |
def reset_holding(self, context={}, reset_holding=()):
|
|
| 314 |
def reset_holding(self, context=None, reset_holding=()):
|
|
| 315 | 315 |
rejected = [] |
| 316 | 316 |
append = rejected.append |
| 317 | 317 |
|
| ... | ... | |
| 377 | 377 |
h.imported += amount |
| 378 | 378 |
h.save() |
| 379 | 379 |
|
| 380 |
def release_holding(self, context={}, release_holding=()):
|
|
| 380 |
def release_holding(self, context=None, release_holding=()):
|
|
| 381 | 381 |
rejected = [] |
| 382 | 382 |
append = rejected.append |
| 383 | 383 |
|
| ... | ... | |
| 408 | 408 |
raise ReturnButFail(rejected) |
| 409 | 409 |
return rejected |
| 410 | 410 |
|
| 411 |
def list_resources(self, context={}, entity=None, key=None):
|
|
| 411 |
def list_resources(self, context=None, entity=None, key=None):
|
|
| 412 | 412 |
try: |
| 413 | 413 |
e = Entity.objects.get(entity=entity) |
| 414 | 414 |
except Entity.DoesNotExist: |
| ... | ... | |
| 423 | 423 |
resources = [h.resource for h in holdings] |
| 424 | 424 |
return resources |
| 425 | 425 |
|
| 426 |
def list_holdings(self, context={}, list_holdings=()):
|
|
| 426 |
def list_holdings(self, context=None, list_holdings=()):
|
|
| 427 | 427 |
rejected = [] |
| 428 | 428 |
reject = rejected.append |
| 429 | 429 |
holdings_list = [] |
| ... | ... | |
| 445 | 445 |
|
| 446 | 446 |
return holdings_list, rejected |
| 447 | 447 |
|
| 448 |
def get_quota(self, context={}, get_quota=()):
|
|
| 448 |
def get_quota(self, context=None, get_quota=()):
|
|
| 449 | 449 |
quotas = [] |
| 450 | 450 |
append = quotas.append |
| 451 | 451 |
|
| ... | ... | |
| 474 | 474 |
|
| 475 | 475 |
return quotas |
| 476 | 476 |
|
| 477 |
def set_quota(self, context={}, set_quota=()):
|
|
| 477 |
def set_quota(self, context=None, set_quota=()):
|
|
| 478 | 478 |
rejected = [] |
| 479 | 479 |
append = rejected.append |
| 480 | 480 |
|
| ... | ... | |
| 534 | 534 |
return rejected |
| 535 | 535 |
|
| 536 | 536 |
def add_quota(self, |
| 537 |
context={}, clientkey=None, serial=None,
|
|
| 537 |
context=None, clientkey=None, serial=None,
|
|
| 538 | 538 |
sub_quota=(), add_quota=()): |
| 539 | 539 |
rejected = [] |
| 540 | 540 |
append = rejected.append |
| ... | ... | |
| 632 | 632 |
CallSerial.objects.create(serial=serial, clientkey=clientkey) |
| 633 | 633 |
return rejected |
| 634 | 634 |
|
| 635 |
def ack_serials(self, context={}, clientkey=None, serials=()):
|
|
| 635 |
def ack_serials(self, context=None, clientkey=None, serials=()):
|
|
| 636 | 636 |
if clientkey is None: |
| 637 | 637 |
return |
| 638 | 638 |
|
| ... | ... | |
| 646 | 646 |
pass |
| 647 | 647 |
return |
| 648 | 648 |
|
| 649 |
def query_serials(self, context={}, clientkey=None, serials=()):
|
|
| 649 |
def query_serials(self, context=None, clientkey=None, serials=()):
|
|
| 650 | 650 |
result = [] |
| 651 | 651 |
append = result.append |
| 652 | 652 |
|
| ... | ... | |
| 667 | 667 |
return result |
| 668 | 668 |
|
| 669 | 669 |
def issue_commission(self, |
| 670 |
context={},
|
|
| 670 |
context=None,
|
|
| 671 | 671 |
clientkey=None, |
| 672 | 672 |
target=None, |
| 673 | 673 |
key=None, |
| ... | ... | |
| 884 | 884 |
ProvisionLog.objects.create(**kwargs) |
| 885 | 885 |
|
| 886 | 886 |
def accept_commission(self, |
| 887 |
context={}, clientkey=None,
|
|
| 887 |
context=None, clientkey=None,
|
|
| 888 | 888 |
serials=(), reason=''): |
| 889 | 889 |
log_time = now() |
| 890 | 890 |
|
| ... | ... | |
| 930 | 930 |
return |
| 931 | 931 |
|
| 932 | 932 |
def reject_commission(self, |
| 933 |
context={}, clientkey=None,
|
|
| 933 |
context=None, clientkey=None,
|
|
| 934 | 934 |
serials=(), reason=''): |
| 935 | 935 |
log_time = now() |
| 936 | 936 |
|
| ... | ... | |
| 975 | 975 |
|
| 976 | 976 |
return |
| 977 | 977 |
|
| 978 |
def get_pending_commissions(self, context={}, clientkey=None):
|
|
| 978 |
def get_pending_commissions(self, context=None, clientkey=None):
|
|
| 979 | 979 |
pending = Commission.objects.filter(clientkey=clientkey) |
| 980 | 980 |
pending_list = pending.values_list('serial', flat=True)
|
| 981 | 981 |
return pending_list |
| 982 | 982 |
|
| 983 | 983 |
def resolve_pending_commissions(self, |
| 984 |
context={}, clientkey=None,
|
|
| 984 |
context=None, clientkey=None,
|
|
| 985 | 985 |
max_serial=None, accept_set=()): |
| 986 | 986 |
accept_set = set(accept_set) |
| 987 | 987 |
pending = self.get_pending_commissions(context=context, |
| ... | ... | |
| 1002 | 1002 |
|
| 1003 | 1003 |
return |
| 1004 | 1004 |
|
| 1005 |
def release_entity(self, context={}, release_entity=()):
|
|
| 1005 |
def release_entity(self, context=None, release_entity=()):
|
|
| 1006 | 1006 |
rejected = [] |
| 1007 | 1007 |
append = rejected.append |
| 1008 | 1008 |
for entity, key in release_entity: |
| ... | ... | |
| 1026 | 1026 |
raise ReturnButFail(rejected) |
| 1027 | 1027 |
return rejected |
| 1028 | 1028 |
|
| 1029 |
def get_timeline(self, context={}, after="", before="Z", get_timeline=()):
|
|
| 1029 |
def get_timeline(self, context=None, after="", before="Z", get_timeline=()):
|
|
| 1030 | 1030 |
entity_set = set() |
| 1031 | 1031 |
e_add = entity_set.add |
| 1032 | 1032 |
resource_set = set() |
Also available in: Unified diff