vincent/aptly
1
0
Fork 0
mirror of https://github.com/aptly-dev/aptly.git synced 2026-07-16 12:08:04 +00:00
Code Issues Projects Releases Wiki Activity

Improvement: Remove Magic Numbers in Tests with Tasks

Browse Source 
Replaced 2 with TASK_SUCCEEDED, 3 with TASK_FAILED.

fixes: #1158
This commit is contained in:
Mauro Regli
2023-03-10 13:44:16 +01:00
committed by Benj Fassbind
parent 5b5307cc15
commit 90932cdac5
7 changed files with 111 additions and 103 deletions
Download Patch File Download Diff File Expand all files Collapse all files
system/api_lib.py
+11 -6
View File
@@ -1,17 +1,22 @@
from lib import BaseTest
import time
import json
import random
import string
import os
import inspect import inspect
import json
import os
import random
import shutil import shutil
import string
import time
from lib import BaseTest
try: try:
import requests import requests
except ImportError: except ImportError:
requests = None requests = None
# States for returned tasks from the API
TASK_SUCCEEDED = 2
TASK_FAILED = 3
class APITest(BaseTest): class APITest(BaseTest):
""" """
system/t12_api/mirrors.py
+3 -3
View File
@@ -1,4 +1,4 @@
from api_lib import APITest from api_lib import TASK_SUCCEEDED, APITest
class MirrorsAPITestCreateShow(APITest): class MirrorsAPITestCreateShow(APITest):
@@ -56,7 +56,7 @@ class MirrorsAPITestCreateUpdate(APITest):
mirror_desc["Name"] = self.random_name() mirror_desc["Name"] = self.random_name()
resp = self.put_task("/api/mirrors/" + mirror_name, json=mirror_desc) resp = self.put_task("/api/mirrors/" + mirror_name, json=mirror_desc)
self.check_equal(resp.json()["State"], 2) self.check_equal(resp.json()["State"], TASK_SUCCEEDED)
_id = resp.json()['ID'] _id = resp.json()['ID']
resp = self.get("/api/tasks/" + str(_id) + "/detail") resp = self.get("/api/tasks/" + str(_id) + "/detail")
@@ -90,7 +90,7 @@ class MirrorsAPITestCreateDelete(APITest):
self.check_equal(resp.status_code, 201) self.check_equal(resp.status_code, 201)
resp = self.delete_task("/api/mirrors/" + mirror_name) resp = self.delete_task("/api/mirrors/" + mirror_name)
self.check_equal(resp.json()['State'], 2) self.check_equal(resp.json()['State'], TASK_SUCCEEDED)
class MirrorsAPITestCreateList(APITest): class MirrorsAPITestCreateList(APITest):
system/t12_api/packages.py
+2 -2
View File
@@ -2,7 +2,7 @@ import urllib.error
import urllib.parse import urllib.parse
import urllib.request import urllib.request
from api_lib import APITest from api_lib import TASK_SUCCEEDED, APITest
class PackagesAPITestShow(APITest): class PackagesAPITestShow(APITest):
@@ -19,7 +19,7 @@ class PackagesAPITestShow(APITest):
"pyspi_0.6.1-1.3.dsc", "pyspi_0.6.1-1.3.diff.gz", "pyspi_0.6.1.orig.tar.gz").status_code, 200) "pyspi_0.6.1-1.3.dsc", "pyspi_0.6.1-1.3.diff.gz", "pyspi_0.6.1.orig.tar.gz").status_code, 200)
resp = self.post_task("/api/repos/" + repo_name + "/file/" + d) resp = self.post_task("/api/repos/" + repo_name + "/file/" + d)
self.check_equal(resp.json()['State'], 2) self.check_equal(resp.json()['State'], TASK_SUCCEEDED)
# get information about package # get information about package
pyspi_json = { pyspi_json = {
system/t12_api/publish.py
+38 -38
View File
@@ -1,7 +1,7 @@
import os
import inspect import inspect
import os
from api_lib import APITest from api_lib import TASK_SUCCEEDED, APITest
DefaultSigningOptions = { DefaultSigningOptions = {
"Keyring": os.path.join(os.path.dirname(inspect.getsourcefile(APITest)), "files") + "/aptly.pub", "Keyring": os.path.join(os.path.dirname(inspect.getsourcefile(APITest)), "files") + "/aptly.pub",
@@ -26,7 +26,7 @@ class PublishAPITestRepo(APITest):
"pyspi_0.6.1-1.3.diff.gz", "pyspi_0.6.1.orig.tar.gz", "pyspi_0.6.1-1.3.diff.gz", "pyspi_0.6.1.orig.tar.gz",
"pyspi-0.6.1-1.3.stripped.dsc").status_code, 200) "pyspi-0.6.1-1.3.stripped.dsc").status_code, 200)
self.check_equal(self.post_task("/api/repos/" + repo_name + "/file/" + d).json()['State'], 2) self.check_equal(self.post_task("/api/repos/" + repo_name + "/file/" + d).json()['State'], TASK_SUCCEEDED)
# publishing under prefix, default distribution # publishing under prefix, default distribution
prefix = self.random_name() prefix = self.random_name()
@@ -55,7 +55,7 @@ class PublishAPITestRepo(APITest):
'Storage': '', 'Storage': '',
'Suite': ''} 'Suite': ''}
self.check_equal(resp.json()['State'], 2) self.check_equal(resp.json()['State'], TASK_SUCCEEDED)
all_repos = self.get("/api/publish") all_repos = self.get("/api/publish")
self.check_equal(all_repos.status_code, 200) self.check_equal(all_repos.status_code, 200)
@@ -83,7 +83,7 @@ class PublishAPITestRepo(APITest):
"Architectures": ["i386", "amd64"], "Architectures": ["i386", "amd64"],
} }
) )
self.check_equal(resp.json()['State'], 2) self.check_equal(resp.json()['State'], TASK_SUCCEEDED)
repo2_expected = { repo2_expected = {
'AcquireByHash': False, 'AcquireByHash': False,
'Architectures': ['amd64', 'i386'], 'Architectures': ['amd64', 'i386'],
@@ -137,9 +137,9 @@ class PublishSnapshotAPITest(APITest):
self.check_equal(self.upload("/api/files/" + d, self.check_equal(self.upload("/api/files/" + d,
"libboost-program-options-dev_1.49.0.1_i386.deb").status_code, 200) "libboost-program-options-dev_1.49.0.1_i386.deb").status_code, 200)
self.check_equal(self.post_task("/api/repos/" + repo_name + "/file/" + d).json()['State'], 2) self.check_equal(self.post_task("/api/repos/" + repo_name + "/file/" + d).json()['State'], TASK_SUCCEEDED)
self.check_equal(self.post_task("/api/repos/" + repo_name + '/snapshots', json={'Name': snapshot_name}).json()['State'], 2) self.check_equal(self.post_task("/api/repos/" + repo_name + '/snapshots', json={'Name': snapshot_name}).json()['State'], TASK_SUCCEEDED)
prefix = self.random_name() prefix = self.random_name()
resp = self.post_task( resp = self.post_task(
@@ -156,7 +156,7 @@ class PublishSnapshotAPITest(APITest):
"Label": "fun", "Label": "fun",
} }
) )
self.check_equal(resp.json()['State'], 2) self.check_equal(resp.json()['State'], TASK_SUCCEEDED)
_id = resp.json()['ID'] _id = resp.json()['ID']
resp = self.get("/api/tasks/" + str(_id) + "/detail") resp = self.get("/api/tasks/" + str(_id) + "/detail")
@@ -212,7 +212,7 @@ class PublishUpdateAPITestRepo(APITest):
"pyspi_0.6.1-1.3.dsc", "pyspi_0.6.1-1.3.dsc",
"pyspi_0.6.1-1.3.diff.gz", "pyspi_0.6.1.orig.tar.gz", "pyspi_0.6.1-1.3.diff.gz", "pyspi_0.6.1.orig.tar.gz",
"pyspi-0.6.1-1.3.stripped.dsc").status_code, 200) "pyspi-0.6.1-1.3.stripped.dsc").status_code, 200)
self.check_equal(self.post_task("/api/repos/" + repo_name + "/file/" + d).json()['State'], 2) self.check_equal(self.post_task("/api/repos/" + repo_name + "/file/" + d).json()['State'], TASK_SUCCEEDED)
prefix = self.random_name() prefix = self.random_name()
resp = self.post_task( resp = self.post_task(
@@ -225,7 +225,7 @@ class PublishUpdateAPITestRepo(APITest):
} }
) )
self.check_equal(resp.json()['State'], 2) self.check_equal(resp.json()['State'], TASK_SUCCEEDED)
self.check_not_exists( self.check_not_exists(
"public/" + prefix + "/pool/main/b/boost-defaults/libboost-program-options-dev_1.49.0.1_i386.deb") "public/" + prefix + "/pool/main/b/boost-defaults/libboost-program-options-dev_1.49.0.1_i386.deb")
@@ -235,10 +235,10 @@ class PublishUpdateAPITestRepo(APITest):
d = self.random_name() d = self.random_name()
self.check_equal(self.upload("/api/files/" + d, self.check_equal(self.upload("/api/files/" + d,
"libboost-program-options-dev_1.49.0.1_i386.deb").status_code, 200) "libboost-program-options-dev_1.49.0.1_i386.deb").status_code, 200)
self.check_equal(self.post_task("/api/repos/" + repo_name + "/file/" + d).json()['State'], 2) self.check_equal(self.post_task("/api/repos/" + repo_name + "/file/" + d).json()['State'], TASK_SUCCEEDED)
self.check_equal(self.delete_task("/api/repos/" + repo_name + "/packages/", self.check_equal(self.delete_task("/api/repos/" + repo_name + "/packages/",
json={"PackageRefs": ['Psource pyspi 0.6.1-1.4 f8f1daa806004e89']}).json()['State'], 2) json={"PackageRefs": ['Psource pyspi 0.6.1-1.4 f8f1daa806004e89']}).json()['State'], TASK_SUCCEEDED)
# Update and switch AcquireByHash on. # Update and switch AcquireByHash on.
resp = self.put_task( resp = self.put_task(
@@ -248,7 +248,7 @@ class PublishUpdateAPITestRepo(APITest):
"Signing": DefaultSigningOptions, "Signing": DefaultSigningOptions,
} }
) )
self.check_equal(resp.json()['State'], 2) self.check_equal(resp.json()['State'], TASK_SUCCEEDED)
repo_expected = { repo_expected = {
'AcquireByHash': True, 'AcquireByHash': True,
'Architectures': ['i386', 'source'], 'Architectures': ['i386', 'source'],
@@ -278,7 +278,7 @@ class PublishUpdateAPITestRepo(APITest):
self.check_not_exists( self.check_not_exists(
"public/" + prefix + "/pool/main/p/pyspi/pyspi-0.6.1-1.3.stripped.dsc") "public/" + prefix + "/pool/main/p/pyspi/pyspi-0.6.1-1.3.stripped.dsc")
self.check_equal(self.delete_task("/api/publish/" + prefix + "/wheezy").json()['State'], 2) self.check_equal(self.delete_task("/api/publish/" + prefix + "/wheezy").json()['State'], TASK_SUCCEEDED)
self.check_not_exists("public/" + prefix + "dists/") self.check_not_exists("public/" + prefix + "dists/")
@@ -299,7 +299,7 @@ class PublishUpdateSkipCleanupAPITestRepo(APITest):
"pyspi_0.6.1-1.3.dsc", "pyspi_0.6.1-1.3.dsc",
"pyspi_0.6.1-1.3.diff.gz", "pyspi_0.6.1.orig.tar.gz", "pyspi_0.6.1-1.3.diff.gz", "pyspi_0.6.1.orig.tar.gz",
"pyspi-0.6.1-1.3.stripped.dsc").status_code, 200) "pyspi-0.6.1-1.3.stripped.dsc").status_code, 200)
self.check_equal(self.post_task("/api/repos/" + repo_name + "/file/" + d).json()['State'], 2) self.check_equal(self.post_task("/api/repos/" + repo_name + "/file/" + d).json()['State'], TASK_SUCCEEDED)
prefix = self.random_name() prefix = self.random_name()
resp = self.post_task("/api/publish/" + prefix, resp = self.post_task("/api/publish/" + prefix,
@@ -310,7 +310,7 @@ class PublishUpdateSkipCleanupAPITestRepo(APITest):
"Signing": DefaultSigningOptions, "Signing": DefaultSigningOptions,
}) })
self.check_equal(resp.json()['State'], 2) self.check_equal(resp.json()['State'], TASK_SUCCEEDED)
self.check_not_exists( self.check_not_exists(
"public/" + prefix + "/pool/main/b/boost-defaults/libboost-program-options-dev_1.49.0.1_i386.deb") "public/" + prefix + "/pool/main/b/boost-defaults/libboost-program-options-dev_1.49.0.1_i386.deb")
@@ -328,22 +328,22 @@ class PublishUpdateSkipCleanupAPITestRepo(APITest):
"Signing": DefaultSigningOptions, "Signing": DefaultSigningOptions,
}) })
self.check_equal(resp.json()['State'], 2) self.check_equal(resp.json()['State'], TASK_SUCCEEDED)
d = self.random_name() d = self.random_name()
self.check_equal(self.upload("/api/files/" + d, self.check_equal(self.upload("/api/files/" + d,
"libboost-program-options-dev_1.49.0.1_i386.deb").status_code, 200) "libboost-program-options-dev_1.49.0.1_i386.deb").status_code, 200)
self.check_equal(self.post_task("/api/repos/" + repo_name + "/file/" + d).json()['State'], 2) self.check_equal(self.post_task("/api/repos/" + repo_name + "/file/" + d).json()['State'], TASK_SUCCEEDED)
self.check_equal(self.delete_task("/api/repos/" + repo_name + "/packages/", self.check_equal(self.delete_task("/api/repos/" + repo_name + "/packages/",
json={"PackageRefs": ['Psource pyspi 0.6.1-1.4 f8f1daa806004e89']}).json()['State'], 2) json={"PackageRefs": ['Psource pyspi 0.6.1-1.4 f8f1daa806004e89']}).json()['State'], TASK_SUCCEEDED)
resp = self.put_task("/api/publish/" + prefix + "/wheezy", resp = self.put_task("/api/publish/" + prefix + "/wheezy",
json={ json={
"Signing": DefaultSigningOptions, "Signing": DefaultSigningOptions,
"SkipCleanup": True, "SkipCleanup": True,
}) })
self.check_equal(resp.json()['State'], 2) self.check_equal(resp.json()['State'], TASK_SUCCEEDED)
repo_expected = { repo_expected = {
'AcquireByHash': False, 'AcquireByHash': False,
'Architectures': ['i386', 'source'], 'Architectures': ['i386', 'source'],
@@ -370,7 +370,7 @@ class PublishUpdateSkipCleanupAPITestRepo(APITest):
self.check_exists("public/" + prefix + self.check_exists("public/" + prefix +
"/pool/main/p/pyspi/pyspi-0.6.1-1.3.stripped.dsc") "/pool/main/p/pyspi/pyspi-0.6.1-1.3.stripped.dsc")
self.check_equal(self.delete_task("/api/publish/" + prefix + "/wheezy", params={"SkipCleanup": "1"}).json()['State'], 2) self.check_equal(self.delete_task("/api/publish/" + prefix + "/wheezy", params={"SkipCleanup": "1"}).json()['State'], TASK_SUCCEEDED)
self.check_exists("public/" + prefix + "/pool/main/b/boost-defaults/libboost-program-options-dev_1.49.0.1_i386.deb") self.check_exists("public/" + prefix + "/pool/main/b/boost-defaults/libboost-program-options-dev_1.49.0.1_i386.deb")
self.check_exists("public/" + prefix + "/pool/main/p/pyspi/pyspi-0.6.1-1.3.stripped.dsc") self.check_exists("public/" + prefix + "/pool/main/p/pyspi/pyspi-0.6.1-1.3.stripped.dsc")
@@ -392,10 +392,10 @@ class PublishSwitchAPITestRepo(APITest):
"pyspi_0.6.1-1.3.dsc", "pyspi_0.6.1-1.3.dsc",
"pyspi_0.6.1-1.3.diff.gz", "pyspi_0.6.1.orig.tar.gz", "pyspi_0.6.1-1.3.diff.gz", "pyspi_0.6.1.orig.tar.gz",
"pyspi-0.6.1-1.3.stripped.dsc").status_code, 200) "pyspi-0.6.1-1.3.stripped.dsc").status_code, 200)
self.check_equal(self.post_task("/api/repos/" + repo_name + "/file/" + d).json()['State'], 2) self.check_equal(self.post_task("/api/repos/" + repo_name + "/file/" + d).json()['State'], TASK_SUCCEEDED)
snapshot1_name = self.random_name() snapshot1_name = self.random_name()
self.check_equal(self.post_task("/api/repos/" + repo_name + '/snapshots', json={'Name': snapshot1_name}).json()['State'], 2) self.check_equal(self.post_task("/api/repos/" + repo_name + '/snapshots', json={'Name': snapshot1_name}).json()['State'], TASK_SUCCEEDED)
prefix = self.random_name() prefix = self.random_name()
resp = self.post_task( resp = self.post_task(
@@ -407,7 +407,7 @@ class PublishSwitchAPITestRepo(APITest):
"Signing": DefaultSigningOptions, "Signing": DefaultSigningOptions,
}) })
self.check_equal(resp.json()['State'], 2) self.check_equal(resp.json()['State'], TASK_SUCCEEDED)
repo_expected = { repo_expected = {
'AcquireByHash': False, 'AcquireByHash': False,
'Architectures': ['i386', 'source'], 'Architectures': ['i386', 'source'],
@@ -436,13 +436,13 @@ class PublishSwitchAPITestRepo(APITest):
d = self.random_name() d = self.random_name()
self.check_equal(self.upload("/api/files/" + d, self.check_equal(self.upload("/api/files/" + d,
"libboost-program-options-dev_1.49.0.1_i386.deb").status_code, 200) "libboost-program-options-dev_1.49.0.1_i386.deb").status_code, 200)
self.check_equal(self.post_task("/api/repos/" + repo_name + "/file/" + d).json()['State'], 2) self.check_equal(self.post_task("/api/repos/" + repo_name + "/file/" + d).json()['State'], TASK_SUCCEEDED)
self.check_equal(self.delete_task("/api/repos/" + repo_name + "/packages/", self.check_equal(self.delete_task("/api/repos/" + repo_name + "/packages/",
json={"PackageRefs": ['Psource pyspi 0.6.1-1.4 f8f1daa806004e89']}).json()['State'], 2) json={"PackageRefs": ['Psource pyspi 0.6.1-1.4 f8f1daa806004e89']}).json()['State'], TASK_SUCCEEDED)
snapshot2_name = self.random_name() snapshot2_name = self.random_name()
self.check_equal(self.post_task("/api/repos/" + repo_name + '/snapshots', json={'Name': snapshot2_name}).json()['State'], 2) self.check_equal(self.post_task("/api/repos/" + repo_name + '/snapshots', json={'Name': snapshot2_name}).json()['State'], TASK_SUCCEEDED)
resp = self.put_task( resp = self.put_task(
"/api/publish/" + prefix + "/wheezy", "/api/publish/" + prefix + "/wheezy",
@@ -451,7 +451,7 @@ class PublishSwitchAPITestRepo(APITest):
"Signing": DefaultSigningOptions, "Signing": DefaultSigningOptions,
"SkipContents": True, "SkipContents": True,
}) })
self.check_equal(resp.json()['State'], 2) self.check_equal(resp.json()['State'], TASK_SUCCEEDED)
repo_expected = { repo_expected = {
'AcquireByHash': False, 'AcquireByHash': False,
'Architectures': ['i386', 'source'], 'Architectures': ['i386', 'source'],
@@ -478,7 +478,7 @@ class PublishSwitchAPITestRepo(APITest):
self.check_not_exists( self.check_not_exists(
"public/" + prefix + "/pool/main/p/pyspi/pyspi-0.6.1-1.3.stripped.dsc") "public/" + prefix + "/pool/main/p/pyspi/pyspi-0.6.1-1.3.stripped.dsc")
self.check_equal(self.delete_task("/api/publish/" + prefix + "/wheezy").json()['State'], 2) self.check_equal(self.delete_task("/api/publish/" + prefix + "/wheezy").json()['State'], TASK_SUCCEEDED)
self.check_not_exists("public/" + prefix + "dists/") self.check_not_exists("public/" + prefix + "dists/")
@@ -499,10 +499,10 @@ class PublishSwitchAPISkipCleanupTestRepo(APITest):
"pyspi_0.6.1-1.3.dsc", "pyspi_0.6.1-1.3.dsc",
"pyspi_0.6.1-1.3.diff.gz", "pyspi_0.6.1.orig.tar.gz", "pyspi_0.6.1-1.3.diff.gz", "pyspi_0.6.1.orig.tar.gz",
"pyspi-0.6.1-1.3.stripped.dsc").status_code, 200) "pyspi-0.6.1-1.3.stripped.dsc").status_code, 200)
self.check_equal(self.post_task("/api/repos/" + repo_name + "/file/" + d).json()['State'], 2) self.check_equal(self.post_task("/api/repos/" + repo_name + "/file/" + d).json()['State'], TASK_SUCCEEDED)
snapshot1_name = self.random_name() snapshot1_name = self.random_name()
self.check_equal(self.post_task("/api/repos/" + repo_name + '/snapshots', json={'Name': snapshot1_name}).json()['State'], 2) self.check_equal(self.post_task("/api/repos/" + repo_name + '/snapshots', json={'Name': snapshot1_name}).json()['State'], TASK_SUCCEEDED)
prefix = self.random_name() prefix = self.random_name()
resp = self.post_task("/api/publish/" + prefix, resp = self.post_task("/api/publish/" + prefix,
@@ -513,7 +513,7 @@ class PublishSwitchAPISkipCleanupTestRepo(APITest):
"Signing": DefaultSigningOptions, "Signing": DefaultSigningOptions,
}) })
self.check_equal(resp.json()['State'], 2) self.check_equal(resp.json()['State'], TASK_SUCCEEDED)
repo_expected = { repo_expected = {
'AcquireByHash': False, 'AcquireByHash': False,
'Architectures': ['i386', 'source'], 'Architectures': ['i386', 'source'],
@@ -550,7 +550,7 @@ class PublishSwitchAPISkipCleanupTestRepo(APITest):
"Signing": DefaultSigningOptions, "Signing": DefaultSigningOptions,
}) })
self.check_equal(resp.json()['State'], 2) self.check_equal(resp.json()['State'], TASK_SUCCEEDED)
repo_expected = { repo_expected = {
'AcquireByHash': False, 'AcquireByHash': False,
'Architectures': ['i386', 'source'], 'Architectures': ['i386', 'source'],
@@ -574,13 +574,13 @@ class PublishSwitchAPISkipCleanupTestRepo(APITest):
d = self.random_name() d = self.random_name()
self.check_equal(self.upload("/api/files/" + d, self.check_equal(self.upload("/api/files/" + d,
"libboost-program-options-dev_1.49.0.1_i386.deb").status_code, 200) "libboost-program-options-dev_1.49.0.1_i386.deb").status_code, 200)
self.check_equal(self.post_task("/api/repos/" + repo_name + "/file/" + d).json()['State'], 2) self.check_equal(self.post_task("/api/repos/" + repo_name + "/file/" + d).json()['State'], TASK_SUCCEEDED)
self.check_equal(self.delete_task("/api/repos/" + repo_name + "/packages/", self.check_equal(self.delete_task("/api/repos/" + repo_name + "/packages/",
json={"PackageRefs": ['Psource pyspi 0.6.1-1.4 f8f1daa806004e89']}).json()['State'], 2) json={"PackageRefs": ['Psource pyspi 0.6.1-1.4 f8f1daa806004e89']}).json()['State'], TASK_SUCCEEDED)
snapshot2_name = self.random_name() snapshot2_name = self.random_name()
self.check_equal(self.post_task("/api/repos/" + repo_name + '/snapshots', json={'Name': snapshot2_name}).json()['State'], 2) self.check_equal(self.post_task("/api/repos/" + repo_name + '/snapshots', json={'Name': snapshot2_name}).json()['State'], TASK_SUCCEEDED)
resp = self.put_task("/api/publish/" + prefix + "/wheezy", resp = self.put_task("/api/publish/" + prefix + "/wheezy",
json={ json={
@@ -589,7 +589,7 @@ class PublishSwitchAPISkipCleanupTestRepo(APITest):
"SkipCleanup": True, "SkipCleanup": True,
"SkipContents": True, "SkipContents": True,
}) })
self.check_equal(resp.json()['State'], 2) self.check_equal(resp.json()['State'], TASK_SUCCEEDED)
repo_expected = { repo_expected = {
'AcquireByHash': False, 'AcquireByHash': False,
'Architectures': ['i386', 'source'], 'Architectures': ['i386', 'source'],
@@ -614,6 +614,6 @@ class PublishSwitchAPISkipCleanupTestRepo(APITest):
self.check_exists("public/" + prefix + "/pool/main/b/boost-defaults/libboost-program-options-dev_1.49.0.1_i386.deb") self.check_exists("public/" + prefix + "/pool/main/b/boost-defaults/libboost-program-options-dev_1.49.0.1_i386.deb")
self.check_exists("public/" + prefix + "/pool/main/p/pyspi/pyspi-0.6.1-1.3.stripped.dsc") self.check_exists("public/" + prefix + "/pool/main/p/pyspi/pyspi-0.6.1-1.3.stripped.dsc")
self.check_equal(self.delete_task("/api/publish/" + prefix + "/wheezy", params={"SkipCleanup": "1"}).json()['State'], 2) self.check_equal(self.delete_task("/api/publish/" + prefix + "/wheezy", params={"SkipCleanup": "1"}).json()['State'], TASK_SUCCEEDED)
self.check_exists("public/" + prefix + "/pool/main/b/boost-defaults/libboost-program-options-dev_1.49.0.1_i386.deb") self.check_exists("public/" + prefix + "/pool/main/b/boost-defaults/libboost-program-options-dev_1.49.0.1_i386.deb")
self.check_exists("public/" + prefix + "/pool/main/p/pyspi/pyspi-0.6.1-1.3.stripped.dsc") self.check_exists("public/" + prefix + "/pool/main/p/pyspi/pyspi-0.6.1-1.3.stripped.dsc")
system/t12_api/repos.py
+25 -24
View File
@@ -1,4 +1,5 @@
from api_lib import APITest from api_lib import TASK_FAILED, TASK_SUCCEEDED, APITest
from .publish import DefaultSigningOptions from .publish import DefaultSigningOptions
@@ -40,7 +41,7 @@ class ReposAPITestCreateIndexDelete(APITest):
names = [repo["Name"] for repo in repos] names = [repo["Name"] for repo in repos]
assert repo_name in names assert repo_name in names
self.check_equal(self.delete_task("/api/repos/" + repo_name).json()['State'], 2) self.check_equal(self.delete_task("/api/repos/" + repo_name).json()['State'], TASK_SUCCEEDED)
self.check_equal(self.delete("/api/repos/" + repo_name).status_code, 404) self.check_equal(self.delete("/api/repos/" + repo_name).status_code, 404)
self.check_equal(self.get("/api/repos/" + repo_name).status_code, 404) self.check_equal(self.get("/api/repos/" + repo_name).status_code, 404)
@@ -60,25 +61,25 @@ class ReposAPITestCreateIndexDelete(APITest):
"pyspi_0.6.1-1.3.dsc", "pyspi_0.6.1-1.3.diff.gz", "pyspi_0.6.1.orig.tar.gz").status_code, 200) "pyspi_0.6.1-1.3.dsc", "pyspi_0.6.1-1.3.diff.gz", "pyspi_0.6.1.orig.tar.gz").status_code, 200)
resp = self.post_task("/api/repos/" + repo_name + "/file/" + d) resp = self.post_task("/api/repos/" + repo_name + "/file/" + d)
self.check_equal(resp.json()['State'], 2) self.check_equal(resp.json()['State'], TASK_SUCCEEDED)
self.check_equal(self.post_task("/api/repos/" + repo_name + "/snapshots", json={"Name": repo_name}).json()['State'], 2) self.check_equal(self.post_task("/api/repos/" + repo_name + "/snapshots", json={"Name": repo_name}).json()['State'], TASK_SUCCEEDED)
self.check_equal(self.post_task("/api/publish", self.check_equal(self.post_task("/api/publish",
json={ json={
"SourceKind": "local", "SourceKind": "local",
"Sources": [{"Name": repo_name}], "Sources": [{"Name": repo_name}],
"Signing": DefaultSigningOptions, "Signing": DefaultSigningOptions,
}).json()['State'], 2) }).json()['State'], TASK_SUCCEEDED)
# repo is not deletable while it is published # repo is not deletable while it is published
self.check_equal(self.delete_task("/api/repos/" + repo_name).json()['State'], 3) self.check_equal(self.delete_task("/api/repos/" + repo_name).json()['State'], TASK_FAILED)
self.check_equal(self.delete_task("/api/repos/" + repo_name, params={"force": "1"}).json()['State'], 3) self.check_equal(self.delete_task("/api/repos/" + repo_name, params={"force": "1"}).json()['State'], TASK_FAILED)
# drop published # drop published
self.check_equal(self.delete_task("/api/publish//" + distribution).json()['State'], 2) self.check_equal(self.delete_task("/api/publish//" + distribution).json()['State'], TASK_SUCCEEDED)
self.check_equal(self.delete_task("/api/repos/" + repo_name).json()['State'], 3) self.check_equal(self.delete_task("/api/repos/" + repo_name).json()['State'], TASK_FAILED)
self.check_equal(self.delete_task("/api/repos/" + repo_name, params={"force": "1"}).json()['State'], 2) self.check_equal(self.delete_task("/api/repos/" + repo_name, params={"force": "1"}).json()['State'], TASK_SUCCEEDED)
self.check_equal(self.get("/api/repos/" + repo_name).status_code, 404) self.check_equal(self.get("/api/repos/" + repo_name).status_code, 404)
@@ -96,7 +97,7 @@ class ReposAPITestAdd(APITest):
"pyspi_0.6.1-1.3.dsc", "pyspi_0.6.1-1.3.diff.gz", "pyspi_0.6.1.orig.tar.gz").status_code, 200) "pyspi_0.6.1-1.3.dsc", "pyspi_0.6.1-1.3.diff.gz", "pyspi_0.6.1.orig.tar.gz").status_code, 200)
resp = self.post_task("/api/repos/" + repo_name + "/file/" + d) resp = self.post_task("/api/repos/" + repo_name + "/file/" + d)
self.check_equal(resp.json()['State'], 2) self.check_equal(resp.json()['State'], TASK_SUCCEEDED)
resp = self.get("/api/tasks/" + str(resp.json()['ID']) + "/output") resp = self.get("/api/tasks/" + str(resp.json()['ID']) + "/output")
self.check_equal(resp.status_code, 200) self.check_equal(resp.status_code, 200)
@@ -124,7 +125,7 @@ class ReposAPITestAddNotFullRemove(APITest):
self.check_equal(self.upload("/api/files/" + d, self.check_equal(self.upload("/api/files/" + d,
"pyspi_0.6.1-1.3.dsc", "pyspi_0.6.1-1.3.diff.gz", "pyspi_0.6.1.orig.tar.gz", "aptly.pub").status_code, 200) "pyspi_0.6.1-1.3.dsc", "pyspi_0.6.1-1.3.diff.gz", "pyspi_0.6.1.orig.tar.gz", "aptly.pub").status_code, 200)
self.check_equal(self.post_task("/api/repos/" + repo_name + "/file/" + d).json()['State'], 2) self.check_equal(self.post_task("/api/repos/" + repo_name + "/file/" + d).json()['State'], TASK_SUCCEEDED)
self.check_equal(self.get("/api/repos/" + repo_name + "/packages").json(), ['Psource pyspi 0.6.1-1.3 3a8b37cbd9a3559e']) self.check_equal(self.get("/api/repos/" + repo_name + "/packages").json(), ['Psource pyspi 0.6.1-1.3 3a8b37cbd9a3559e'])
self.check_exists("upload/" + d + "/aptly.pub") self.check_exists("upload/" + d + "/aptly.pub")
@@ -144,7 +145,7 @@ class ReposAPITestAddNoRemove(APITest):
self.check_equal(self.upload("/api/files/" + d, self.check_equal(self.upload("/api/files/" + d,
"pyspi_0.6.1-1.3.dsc", "pyspi_0.6.1-1.3.diff.gz", "pyspi_0.6.1.orig.tar.gz").status_code, 200) "pyspi_0.6.1-1.3.dsc", "pyspi_0.6.1-1.3.diff.gz", "pyspi_0.6.1.orig.tar.gz").status_code, 200)
self.check_equal(self.post_task("/api/repos/" + repo_name + "/file/" + d, params={"noRemove": 1}).json()['State'], 2) self.check_equal(self.post_task("/api/repos/" + repo_name + "/file/" + d, params={"noRemove": 1}).json()['State'], TASK_SUCCEEDED)
self.check_equal(self.get("/api/repos/" + repo_name + "/packages").json(), ['Psource pyspi 0.6.1-1.3 3a8b37cbd9a3559e']) self.check_equal(self.get("/api/repos/" + repo_name + "/packages").json(), ['Psource pyspi 0.6.1-1.3 3a8b37cbd9a3559e'])
self.check_exists("upload/" + d + "/pyspi_0.6.1-1.3.dsc") self.check_exists("upload/" + d + "/pyspi_0.6.1-1.3.dsc")
@@ -164,7 +165,7 @@ class ReposAPITestAddFile(APITest):
"libboost-program-options-dev_1.49.0.1_i386.deb").status_code, 200) "libboost-program-options-dev_1.49.0.1_i386.deb").status_code, 200)
resp = self.post_task("/api/repos/" + repo_name + "/file/" + d + "/libboost-program-options-dev_1.49.0.1_i386.deb") resp = self.post_task("/api/repos/" + repo_name + "/file/" + d + "/libboost-program-options-dev_1.49.0.1_i386.deb")
self.check_equal(resp.json()['State'], 2) self.check_equal(resp.json()['State'], TASK_SUCCEEDED)
resp = self.get("/api/tasks/" + str(resp.json()['ID']) + "/output") resp = self.get("/api/tasks/" + str(resp.json()['ID']) + "/output")
self.check_equal(resp.status_code, 200) self.check_equal(resp.status_code, 200)
@@ -196,7 +197,7 @@ class ReposAPITestInclude(APITest):
self.check_equal(resp.status_code, 200) self.check_equal(resp.status_code, 200)
resp = self.post_task("/api/repos/" + repo_name + "/include/" + d, params={"ignoreSignature": 1}) resp = self.post_task("/api/repos/" + repo_name + "/include/" + d, params={"ignoreSignature": 1})
self.check_equal(resp.json()['State'], 2) self.check_equal(resp.json()['State'], TASK_SUCCEEDED)
resp = self.get("/api/tasks/" + str(resp.json()['ID']) + "/output") resp = self.get("/api/tasks/" + str(resp.json()['ID']) + "/output")
self.check_equal(resp.status_code, 200) self.check_equal(resp.status_code, 200)
@@ -224,7 +225,7 @@ class ReposAPITestShowQuery(APITest):
"libboost-program-options-dev_1.49.0.1_i386.deb", "pyspi_0.6.1-1.3.dsc", "libboost-program-options-dev_1.49.0.1_i386.deb", "pyspi_0.6.1-1.3.dsc",
"pyspi_0.6.1-1.3.diff.gz", "pyspi_0.6.1.orig.tar.gz", "pyspi_0.6.1-1.3.diff.gz", "pyspi_0.6.1.orig.tar.gz",
"pyspi-0.6.1-1.3.stripped.dsc").status_code, 200) "pyspi-0.6.1-1.3.stripped.dsc").status_code, 200)
self.check_equal(self.post_task("/api/repos/" + repo_name + "/file/" + d).json()['State'], 2) self.check_equal(self.post_task("/api/repos/" + repo_name + "/file/" + d).json()['State'], TASK_SUCCEEDED)
self.check_equal(sorted(self.get("/api/repos/" + repo_name + "/packages", params={"q": "pyspi"}).json()), self.check_equal(sorted(self.get("/api/repos/" + repo_name + "/packages", params={"q": "pyspi"}).json()),
['Psource pyspi 0.6.1-1.3 3a8b37cbd9a3559e', 'Psource pyspi 0.6.1-1.4 f8f1daa806004e89']) ['Psource pyspi 0.6.1-1.3 3a8b37cbd9a3559e', 'Psource pyspi 0.6.1-1.4 f8f1daa806004e89'])
@@ -258,12 +259,12 @@ class ReposAPITestAddMultiple(APITest):
"pyspi-0.6.1-1.3.stripped.dsc").status_code, 200) "pyspi-0.6.1-1.3.stripped.dsc").status_code, 200)
self.check_equal(self.post_task("/api/repos/" + repo_name + "/file/" + d + "/pyspi_0.6.1-1.3.dsc", self.check_equal(self.post_task("/api/repos/" + repo_name + "/file/" + d + "/pyspi_0.6.1-1.3.dsc",
params={"noRemove": 1}).json()['State'], 2) params={"noRemove": 1}).json()['State'], TASK_SUCCEEDED)
self.check_equal(sorted(self.get("/api/repos/" + repo_name + "/packages").json()), self.check_equal(sorted(self.get("/api/repos/" + repo_name + "/packages").json()),
['Psource pyspi 0.6.1-1.3 3a8b37cbd9a3559e']) ['Psource pyspi 0.6.1-1.3 3a8b37cbd9a3559e'])
self.check_equal(self.post_task("/api/repos/" + repo_name + "/file/" + d + "/pyspi-0.6.1-1.3.stripped.dsc").json()['State'], 2) self.check_equal(self.post_task("/api/repos/" + repo_name + "/file/" + d + "/pyspi-0.6.1-1.3.stripped.dsc").json()['State'], TASK_SUCCEEDED)
self.check_equal(sorted(self.get("/api/repos/" + repo_name + "/packages").json()), self.check_equal(sorted(self.get("/api/repos/" + repo_name + "/packages").json()),
['Psource pyspi 0.6.1-1.3 3a8b37cbd9a3559e', 'Psource pyspi 0.6.1-1.4 f8f1daa806004e89']) ['Psource pyspi 0.6.1-1.3 3a8b37cbd9a3559e', 'Psource pyspi 0.6.1-1.4 f8f1daa806004e89'])
@@ -285,7 +286,7 @@ class ReposAPITestPackagesAddDelete(APITest):
"pyspi_0.6.1-1.3.diff.gz", "pyspi_0.6.1.orig.tar.gz", "pyspi_0.6.1-1.3.diff.gz", "pyspi_0.6.1.orig.tar.gz",
"pyspi-0.6.1-1.3.stripped.dsc").status_code, 200) "pyspi-0.6.1-1.3.stripped.dsc").status_code, 200)
self.check_equal(self.post_task("/api/repos/" + repo_name + "/file/" + d).json()['State'], 2) self.check_equal(self.post_task("/api/repos/" + repo_name + "/file/" + d).json()['State'], TASK_SUCCEEDED)
self.check_equal(sorted(self.get("/api/repos/" + repo_name + "/packages").json()), self.check_equal(sorted(self.get("/api/repos/" + repo_name + "/packages").json()),
['Pi386 libboost-program-options-dev 1.49.0.1 918d2f433384e378', ['Pi386 libboost-program-options-dev 1.49.0.1 918d2f433384e378',
@@ -293,7 +294,7 @@ class ReposAPITestPackagesAddDelete(APITest):
'Psource pyspi 0.6.1-1.4 f8f1daa806004e89']) 'Psource pyspi 0.6.1-1.4 f8f1daa806004e89'])
self.check_equal(self.post_task("/api/repos/" + repo_name + "/packages/", self.check_equal(self.post_task("/api/repos/" + repo_name + "/packages/",
json={"PackageRefs": ['Psource pyspi 0.6.1-1.4 f8f1daa806004e89']}).json()['State'], 2) json={"PackageRefs": ['Psource pyspi 0.6.1-1.4 f8f1daa806004e89']}).json()['State'], TASK_SUCCEEDED)
self.check_equal(sorted(self.get("/api/repos/" + repo_name + "/packages").json()), self.check_equal(sorted(self.get("/api/repos/" + repo_name + "/packages").json()),
['Pi386 libboost-program-options-dev 1.49.0.1 918d2f433384e378', ['Pi386 libboost-program-options-dev 1.49.0.1 918d2f433384e378',
@@ -302,17 +303,17 @@ class ReposAPITestPackagesAddDelete(APITest):
self.check_equal(self.post_task("/api/repos/" + repo_name + "/packages/", self.check_equal(self.post_task("/api/repos/" + repo_name + "/packages/",
json={"PackageRefs": ['Psource pyspi 0.6.1-1.4 f8f1daa806004e89', json={"PackageRefs": ['Psource pyspi 0.6.1-1.4 f8f1daa806004e89',
'Psource no-such-package 0.6.1-1.4 f8f1daa806004e89']}).json()['State'], 3) 'Psource no-such-package 0.6.1-1.4 f8f1daa806004e89']}).json()['State'], TASK_FAILED)
self.check_equal(self.delete_task("/api/repos/" + repo_name + "/packages/", self.check_equal(self.delete_task("/api/repos/" + repo_name + "/packages/",
json={"PackageRefs": ['Psource pyspi 0.6.1-1.4 f8f1daa806004e89']}).json()['State'], 2) json={"PackageRefs": ['Psource pyspi 0.6.1-1.4 f8f1daa806004e89']}).json()['State'], TASK_SUCCEEDED)
self.check_equal(sorted(self.get("/api/repos/" + repo_name + "/packages").json()), self.check_equal(sorted(self.get("/api/repos/" + repo_name + "/packages").json()),
['Pi386 libboost-program-options-dev 1.49.0.1 918d2f433384e378', ['Pi386 libboost-program-options-dev 1.49.0.1 918d2f433384e378',
'Psource pyspi 0.6.1-1.3 3a8b37cbd9a3559e']) 'Psource pyspi 0.6.1-1.3 3a8b37cbd9a3559e'])
self.check_equal(self.post_task("/api/repos/" + repo_name + "/packages/", self.check_equal(self.post_task("/api/repos/" + repo_name + "/packages/",
json={"PackageRefs": ['Psource pyspi 0.6.1-1.4 f8f1daa806004e89']}).json()['State'], 2) json={"PackageRefs": ['Psource pyspi 0.6.1-1.4 f8f1daa806004e89']}).json()['State'], TASK_SUCCEEDED)
self.check_equal(sorted(self.get("/api/repos/" + repo_name + "/packages").json()), self.check_equal(sorted(self.get("/api/repos/" + repo_name + "/packages").json()),
['Pi386 libboost-program-options-dev 1.49.0.1 918d2f433384e378', ['Pi386 libboost-program-options-dev 1.49.0.1 918d2f433384e378',
@@ -325,7 +326,7 @@ class ReposAPITestPackagesAddDelete(APITest):
self.check_equal(self.post_task("/api/repos/" + repo_name2 + "/packages/", self.check_equal(self.post_task("/api/repos/" + repo_name2 + "/packages/",
json={"PackageRefs": ['Psource pyspi 0.6.1-1.4 f8f1daa806004e89', json={"PackageRefs": ['Psource pyspi 0.6.1-1.4 f8f1daa806004e89',
'Pi386 libboost-program-options-dev 1.49.0.1 918d2f433384e378']}).json()['State'], 2) 'Pi386 libboost-program-options-dev 1.49.0.1 918d2f433384e378']}).json()['State'], TASK_SUCCEEDED)
self.check_equal(sorted(self.get("/api/repos/" + repo_name2 + "/packages").json()), self.check_equal(sorted(self.get("/api/repos/" + repo_name2 + "/packages").json()),
['Pi386 libboost-program-options-dev 1.49.0.1 918d2f433384e378', ['Pi386 libboost-program-options-dev 1.49.0.1 918d2f433384e378',
system/t12_api/snapshots.py
+28 -27
View File
@@ -1,4 +1,5 @@
from api_lib import APITest from api_lib import TASK_FAILED, TASK_SUCCEEDED, APITest
from .publish import DefaultSigningOptions from .publish import DefaultSigningOptions
@@ -13,7 +14,7 @@ class SnapshotsAPITestCreateShowEmpty(APITest):
# create empty snapshot # create empty snapshot
resp = self.post_task("/api/snapshots", json=snapshot_desc) resp = self.post_task("/api/snapshots", json=snapshot_desc)
self.check_equal(resp.json()['State'], 2) self.check_equal(resp.json()['State'], TASK_SUCCEEDED)
self.check_subset(snapshot_desc, self.get("/api/snapshots/" + snapshot_name).json()) self.check_subset(snapshot_desc, self.get("/api/snapshots/" + snapshot_name).json())
self.check_equal(self.get("/api/snapshots/" + snapshot_name).status_code, 200) self.check_equal(self.get("/api/snapshots/" + snapshot_name).status_code, 200)
@@ -26,7 +27,7 @@ class SnapshotsAPITestCreateShowEmpty(APITest):
# create snapshot with duplicate name # create snapshot with duplicate name
resp = self.post_task("/api/snapshots", json=snapshot_desc) resp = self.post_task("/api/snapshots", json=snapshot_desc)
self.check_equal(resp.json()['State'], 3) self.check_equal(resp.json()['State'], TASK_FAILED)
class SnapshotsAPITestCreateFromRefs(APITest): class SnapshotsAPITestCreateFromRefs(APITest):
@@ -47,7 +48,7 @@ class SnapshotsAPITestCreateFromRefs(APITest):
# create empty snapshot # create empty snapshot
empty_snapshot_name = self.random_name() empty_snapshot_name = self.random_name()
resp = self.post_task("/api/snapshots", json={"Name": empty_snapshot_name}) resp = self.post_task("/api/snapshots", json={"Name": empty_snapshot_name})
self.check_equal(resp.json()['State'], 2) self.check_equal(resp.json()['State'], TASK_SUCCEEDED)
self.check_equal( self.check_equal(
self.get("/api/snapshots/" + empty_snapshot_name).json()['Description'], "Created as empty" self.get("/api/snapshots/" + empty_snapshot_name).json()['Description'], "Created as empty"
) )
@@ -58,14 +59,14 @@ class SnapshotsAPITestCreateFromRefs(APITest):
d = self.random_name() d = self.random_name()
self.check_equal(self.upload("/api/files/" + d, self.check_equal(self.upload("/api/files/" + d,
"libboost-program-options-dev_1.49.0.1_i386.deb").status_code, 200) "libboost-program-options-dev_1.49.0.1_i386.deb").status_code, 200)
self.check_equal(self.post_task("/api/repos/" + repo_name + "/file/" + d).json()['State'], 2) self.check_equal(self.post_task("/api/repos/" + repo_name + "/file/" + d).json()['State'], TASK_SUCCEEDED)
# create snapshot with empty snapshot as source and package # create snapshot with empty snapshot as source and package
snapshot = snapshot_desc.copy() snapshot = snapshot_desc.copy()
snapshot['PackageRefs'] = ["Pi386 libboost-program-options-dev 1.49.0.1 918d2f433384e378"] snapshot['PackageRefs'] = ["Pi386 libboost-program-options-dev 1.49.0.1 918d2f433384e378"]
snapshot['SourceSnapshots'] = [empty_snapshot_name] snapshot['SourceSnapshots'] = [empty_snapshot_name]
resp = self.post_task("/api/snapshots", json=snapshot) resp = self.post_task("/api/snapshots", json=snapshot)
self.check_equal(resp.json()['State'], 2) self.check_equal(resp.json()['State'], TASK_SUCCEEDED)
snapshot.pop('SourceSnapshots') snapshot.pop('SourceSnapshots')
snapshot.pop('PackageRefs') snapshot.pop('PackageRefs')
resp = self.get("/api/snapshots/" + snapshot_name) resp = self.get("/api/snapshots/" + snapshot_name)
@@ -81,7 +82,7 @@ class SnapshotsAPITestCreateFromRefs(APITest):
resp = self.post_task("/api/snapshots", json={ resp = self.post_task("/api/snapshots", json={
"Name": self.random_name(), "Name": self.random_name(),
"PackageRefs": ["Pi386 libboost-program-options-dev 1.49.0.1 918d2f433384e378", "Pamd64 no-such-package 1.2 91"]}) "PackageRefs": ["Pi386 libboost-program-options-dev 1.49.0.1 918d2f433384e378", "Pamd64 no-such-package 1.2 91"]})
self.check_equal(resp.json()['State'], 3) self.check_equal(resp.json()['State'], TASK_FAILED)
# list snapshots # list snapshots
resp = self.get("/api/snapshots", params={"sort": "time"}) resp = self.get("/api/snapshots", params={"sort": "time"})
@@ -100,7 +101,7 @@ class SnapshotsAPITestCreateFromRepo(APITest):
self.check_equal(self.post("/api/repos", json={"Name": repo_name}).status_code, 201) self.check_equal(self.post("/api/repos", json={"Name": repo_name}).status_code, 201)
resp = self.post_task("/api/repos/" + repo_name + '/snapshots', json={'Name': snapshot_name}) resp = self.post_task("/api/repos/" + repo_name + '/snapshots', json={'Name': snapshot_name})
self.check_equal(resp.json()['State'], 2) self.check_equal(resp.json()['State'], TASK_SUCCEEDED)
self.check_equal([], self.check_equal([],
self.get("/api/snapshots/" + snapshot_name + "/packages", params={"format": "details"}).json()) self.get("/api/snapshots/" + snapshot_name + "/packages", params={"format": "details"}).json())
@@ -109,10 +110,10 @@ class SnapshotsAPITestCreateFromRepo(APITest):
self.check_equal(self.upload("/api/files/" + d, self.check_equal(self.upload("/api/files/" + d,
"libboost-program-options-dev_1.49.0.1_i386.deb").status_code, 200) "libboost-program-options-dev_1.49.0.1_i386.deb").status_code, 200)
self.check_equal(self.post_task("/api/repos/" + repo_name + "/file/" + d).json()['State'], 2) self.check_equal(self.post_task("/api/repos/" + repo_name + "/file/" + d).json()['State'], TASK_SUCCEEDED)
resp = self.post_task("/api/repos/" + repo_name + '/snapshots', json={'Name': snapshot_name}) resp = self.post_task("/api/repos/" + repo_name + '/snapshots', json={'Name': snapshot_name})
self.check_equal(resp.json()['State'], 2) self.check_equal(resp.json()['State'], TASK_SUCCEEDED)
self.check_equal(self.get("/api/snapshots/" + snapshot_name).status_code, 200) self.check_equal(self.get("/api/snapshots/" + snapshot_name).status_code, 200)
self.check_subset({'Architecture': 'i386', self.check_subset({'Architecture': 'i386',
@@ -130,7 +131,7 @@ class SnapshotsAPITestCreateFromRepo(APITest):
# duplicate snapshot name # duplicate snapshot name
resp = self.post_task("/api/repos/" + repo_name + '/snapshots', json={'Name': snapshot_name}) resp = self.post_task("/api/repos/" + repo_name + '/snapshots', json={'Name': snapshot_name})
self.check_equal(resp.json()['State'], 3) self.check_equal(resp.json()['State'], TASK_FAILED)
class SnapshotsAPITestCreateUpdate(APITest): class SnapshotsAPITestCreateUpdate(APITest):
@@ -143,12 +144,12 @@ class SnapshotsAPITestCreateUpdate(APITest):
'Name': snapshot_name} 'Name': snapshot_name}
resp = self.post_task("/api/snapshots", json=snapshot_desc) resp = self.post_task("/api/snapshots", json=snapshot_desc)
self.check_equal(resp.json()['State'], 2) self.check_equal(resp.json()['State'], TASK_SUCCEEDED)
new_snapshot_name = self.random_name() new_snapshot_name = self.random_name()
resp = self.put_task("/api/snapshots/" + snapshot_name, json={'Name': new_snapshot_name, resp = self.put_task("/api/snapshots/" + snapshot_name, json={'Name': new_snapshot_name,
'Description': 'New description'}) 'Description': 'New description'})
self.check_equal(resp.json()['State'], 2) self.check_equal(resp.json()['State'], TASK_SUCCEEDED)
resp = self.get("/api/snapshots/" + new_snapshot_name) resp = self.get("/api/snapshots/" + new_snapshot_name)
self.check_equal(resp.status_code, 200) self.check_equal(resp.status_code, 200)
@@ -158,7 +159,7 @@ class SnapshotsAPITestCreateUpdate(APITest):
# duplicate name # duplicate name
resp = self.put_task("/api/snapshots/" + new_snapshot_name, json={'Name': new_snapshot_name, resp = self.put_task("/api/snapshots/" + new_snapshot_name, json={'Name': new_snapshot_name,
'Description': 'New description'}) 'Description': 'New description'})
self.check_equal(resp.json()['State'], 3) self.check_equal(resp.json()['State'], TASK_FAILED)
# missing snapshot # missing snapshot
resp = self.put("/api/snapshots/" + snapshot_name, json={}) resp = self.put("/api/snapshots/" + snapshot_name, json={})
@@ -176,24 +177,24 @@ class SnapshotsAPITestCreateDelete(APITest):
# deleting unreferenced snapshot # deleting unreferenced snapshot
resp = self.post_task("/api/snapshots", json=snapshot_desc) resp = self.post_task("/api/snapshots", json=snapshot_desc)
self.check_equal(resp.json()['State'], 2) self.check_equal(resp.json()['State'], TASK_SUCCEEDED)
self.check_equal(self.delete_task("/api/snapshots/" + snapshot_name).json()['State'], 2) self.check_equal(self.delete_task("/api/snapshots/" + snapshot_name).json()['State'], TASK_SUCCEEDED)
self.check_equal(self.get("/api/snapshots/" + snapshot_name).status_code, 404) self.check_equal(self.get("/api/snapshots/" + snapshot_name).status_code, 404)
# deleting referenced snapshot # deleting referenced snapshot
snap1, snap2 = self.random_name(), self.random_name() snap1, snap2 = self.random_name(), self.random_name()
self.check_equal(self.post_task("/api/snapshots", json={"Name": snap1}).json()['State'], 2) self.check_equal(self.post_task("/api/snapshots", json={"Name": snap1}).json()['State'], TASK_SUCCEEDED)
self.check_equal( self.check_equal(
self.post_task( self.post_task(
"/api/snapshots", json={"Name": snap2, "SourceSnapshots": [snap1]} "/api/snapshots", json={"Name": snap2, "SourceSnapshots": [snap1]}
).json()['State'], 2 ).json()['State'], 2
) )
self.check_equal(self.delete_task("/api/snapshots/" + snap1).json()['State'], 3) self.check_equal(self.delete_task("/api/snapshots/" + snap1).json()['State'], TASK_FAILED)
self.check_equal(self.get("/api/snapshots/" + snap1).status_code, 200) self.check_equal(self.get("/api/snapshots/" + snap1).status_code, 200)
self.check_equal(self.delete_task("/api/snapshots/" + snap1, params={"force": "1"}).json()['State'], 2) self.check_equal(self.delete_task("/api/snapshots/" + snap1, params={"force": "1"}).json()['State'], TASK_SUCCEEDED)
self.check_equal(self.get("/api/snapshots/" + snap1).status_code, 404) self.check_equal(self.get("/api/snapshots/" + snap1).status_code, 404)
# deleting published snapshot # deleting published snapshot
@@ -207,10 +208,10 @@ class SnapshotsAPITestCreateDelete(APITest):
"Signing": DefaultSigningOptions, "Signing": DefaultSigningOptions,
} }
) )
self.check_equal(resp.json()['State'], 2) self.check_equal(resp.json()['State'], TASK_SUCCEEDED)
self.check_equal(self.delete_task("/api/snapshots/" + snap2).json()['State'], 3) self.check_equal(self.delete_task("/api/snapshots/" + snap2).json()['State'], TASK_FAILED)
self.check_equal(self.delete_task("/api/snapshots/" + snap2, params={"force": "1"}).json()['State'], 3) self.check_equal(self.delete_task("/api/snapshots/" + snap2, params={"force": "1"}).json()['State'], TASK_FAILED)
class SnapshotsAPITestSearch(APITest): class SnapshotsAPITestSearch(APITest):
@@ -227,10 +228,10 @@ class SnapshotsAPITestSearch(APITest):
self.check_equal(self.upload("/api/files/" + d, self.check_equal(self.upload("/api/files/" + d,
"libboost-program-options-dev_1.49.0.1_i386.deb").status_code, 200) "libboost-program-options-dev_1.49.0.1_i386.deb").status_code, 200)
self.check_equal(self.post_task("/api/repos/" + repo_name + "/file/" + d).json()['State'], 2) self.check_equal(self.post_task("/api/repos/" + repo_name + "/file/" + d).json()['State'], TASK_SUCCEEDED)
resp = self.post_task("/api/repos/" + repo_name + '/snapshots', json={'Name': snapshot_name}) resp = self.post_task("/api/repos/" + repo_name + '/snapshots', json={'Name': snapshot_name})
self.check_equal(resp.json()['State'], 2) self.check_equal(resp.json()['State'], TASK_SUCCEEDED)
resp = self.get("/api/snapshots/" + snapshot_name + "/packages", resp = self.get("/api/snapshots/" + snapshot_name + "/packages",
params={"q": "libboost-program-options-dev", "format": "details"}) params={"q": "libboost-program-options-dev", "format": "details"})
@@ -261,13 +262,13 @@ class SnapshotsAPITestDiff(APITest):
self.check_equal(self.upload("/api/files/" + d, self.check_equal(self.upload("/api/files/" + d,
"libboost-program-options-dev_1.49.0.1_i386.deb").status_code, 200) "libboost-program-options-dev_1.49.0.1_i386.deb").status_code, 200)
self.check_equal(self.post_task("/api/repos/" + repo_name + "/file/" + d).json()['State'], 2) self.check_equal(self.post_task("/api/repos/" + repo_name + "/file/" + d).json()['State'], TASK_SUCCEEDED)
resp = self.post_task("/api/repos/" + repo_name + '/snapshots', json={'Name': snapshots[0]}) resp = self.post_task("/api/repos/" + repo_name + '/snapshots', json={'Name': snapshots[0]})
self.check_equal(resp.json()['State'], 2) self.check_equal(resp.json()['State'], TASK_SUCCEEDED)
resp = self.post_task("/api/snapshots", json={'Name': snapshots[1]}) resp = self.post_task("/api/snapshots", json={'Name': snapshots[1]})
self.check_equal(resp.json()['State'], 2) self.check_equal(resp.json()['State'], TASK_SUCCEEDED)
resp = self.get("/api/snapshots/" + snapshots[0] + "/diff/" + snapshots[1]) resp = self.get("/api/snapshots/" + snapshots[0] + "/diff/" + snapshots[1])
self.check_equal(resp.status_code, 200) self.check_equal(resp.status_code, 200)
system/t12_api/tasks.py
+4 -3
View File
@@ -1,4 +1,5 @@
from api_lib import APITest from api_lib import TASK_SUCCEEDED, APITest
from .publish import DefaultSigningOptions from .publish import DefaultSigningOptions
@@ -49,7 +50,7 @@ class TaskAPITestParallelTasks(APITest):
uri = "/api/tasks/%d/wait" % int(task_id) uri = "/api/tasks/%d/wait" % int(task_id)
resp = self.get(uri) resp = self.get(uri)
self.check_equal(resp.status_code, 200) self.check_equal(resp.status_code, 200)
self.check_equal(resp.json()['State'], 2) self.check_equal(resp.json()['State'], TASK_SUCCEEDED)
def _wait_for_all_tasks(self): def _wait_for_all_tasks(self):
resp = self.get("/api/tasks-wait") resp = self.get("/api/tasks-wait")
@@ -103,4 +104,4 @@ class TaskAPITestParallelTasks(APITest):
for publish_task_id in publish_task_ids: for publish_task_id in publish_task_ids:
resp = self.get("/api/tasks/%d" % publish_task_id) resp = self.get("/api/tasks/%d" % publish_task_id)
self.check_equal(resp.status_code, 200) self.check_equal(resp.status_code, 200)
self.check_equal(resp.json()['State'], 2) self.check_equal(resp.json()['State'], TASK_SUCCEEDED)