Changeset View
Changeset View
Standalone View
Standalone View
swh/deposit/api/common.py
| Show All 25 Lines | from ..config import ( | ||||
| EM_IRI, | EM_IRI, | ||||
| CONT_FILE_IRI, | CONT_FILE_IRI, | ||||
| ARCHIVE_KEY, | ARCHIVE_KEY, | ||||
| METADATA_KEY, | METADATA_KEY, | ||||
| RAW_METADATA_KEY, | RAW_METADATA_KEY, | ||||
| STATE_IRI, | STATE_IRI, | ||||
| DEPOSIT_STATUS_DEPOSITED, | DEPOSIT_STATUS_DEPOSITED, | ||||
| DEPOSIT_STATUS_PARTIAL, | DEPOSIT_STATUS_PARTIAL, | ||||
| PRIVATE_CHECK_DEPOSIT, | |||||
| DEPOSIT_STATUS_LOAD_SUCCESS, | DEPOSIT_STATUS_LOAD_SUCCESS, | ||||
| ARCHIVE_TYPE, | ARCHIVE_TYPE, | ||||
| METADATA_TYPE, | METADATA_TYPE, | ||||
| ) | ) | ||||
| from ..errors import ( | from ..errors import ( | ||||
| MAX_UPLOAD_SIZE_EXCEEDED, | MAX_UPLOAD_SIZE_EXCEEDED, | ||||
| BAD_REQUEST, | BAD_REQUEST, | ||||
| ERROR_CONTENT, | ERROR_CONTENT, | ||||
| ▲ Show 20 Lines • Show All 147 Lines • ▼ Show 20 Lines | ): | ||||
| deposit = Deposit.objects.get(pk=deposit_id) | deposit = Deposit.objects.get(pk=deposit_id) | ||||
| # update metadata | # update metadata | ||||
| deposit.complete_date = complete_date | deposit.complete_date = complete_date | ||||
| deposit.status = status_type | deposit.status = status_type | ||||
| if self.config["checks"]: | if self.config["checks"]: | ||||
| deposit.save() # needed to have a deposit id | deposit.save() # needed to have a deposit id | ||||
| args = [deposit.collection.name, deposit.id] | |||||
| scheduler = self.scheduler | scheduler = self.scheduler | ||||
| if deposit.status == DEPOSIT_STATUS_DEPOSITED and not deposit.check_task_id: | if deposit.status == DEPOSIT_STATUS_DEPOSITED and not deposit.check_task_id: | ||||
| check_url = request.build_absolute_uri( | |||||
| reverse(PRIVATE_CHECK_DEPOSIT, args=args) | |||||
| ) | |||||
| task = create_oneshot_task_dict( | task = create_oneshot_task_dict( | ||||
| "check-deposit", deposit_check_url=check_url | "check-deposit", | ||||
| collection=deposit.collection.name, | |||||
| deposit_id=deposit.id, | |||||
| ) | ) | ||||
| check_task_id = scheduler.create_tasks([task])[0]["id"] | check_task_id = scheduler.create_tasks([task])[0]["id"] | ||||
| deposit.check_task_id = check_task_id | deposit.check_task_id = check_task_id | ||||
| deposit.save() | deposit.save() | ||||
| return deposit | return deposit | ||||
| ▲ Show 20 Lines • Show All 752 Lines • Show Last 20 Lines | |||||