Skip to content

Commit d0311d9

Browse files
committed
RHINENG-19806: update repo based tests
1 parent 868b97e commit d0311d9

2 files changed

Lines changed: 26 additions & 35 deletions

File tree

platform/vmaas.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -203,9 +203,9 @@ func reposHandler(c *gin.Context) {
203203
"pages": 1,
204204
"latest_repo_change": "2222-04-16 20:07:55.214266+00",
205205
"repository_list": {
206-
"repo1": [],
206+
"repo1": [{"updated_package_names": ["kernel", "firefox"]}],
207207
"repo2": [],
208-
"repo3": [{"updated_package_names": ["kernel", "firefox"]}]
208+
"repo3": []
209209
}}`
210210
c.Data(http.StatusOK, gin.MIMEJSON, []byte(data))
211211
}

tasks/vmaas_sync/repo_based_test.go

Lines changed: 24 additions & 33 deletions
Original file line numberDiff line numberDiff line change
@@ -72,73 +72,64 @@ func TestGetRepoOnlyBasedInventoryIDs(t *testing.T) {
7272
utils.SkipWithoutDB(t)
7373
core.SetupTestEnvironment()
7474

75-
repos := []string{"repo1", "repo2"}
76-
inventoryAIDs, err := getRepoBasedInventoryIDs(nil, repos)
75+
// some systems have repo, some have package
76+
// but none have both
77+
repos := []string{"repo3"}
78+
packages := []string{"curl", "bash"}
79+
inventoryAIDs, err := getRepoBasedInventoryIDs(repos, packages)
7780
assert.Nil(t, err)
78-
assert.Equal(t, []mqueue.EvalData{
79-
{InventoryID: "00000000-0000-0000-0000-000000000002", RhAccountID: 1, OrgID: &orgID1},
80-
{InventoryID: "00000000-0000-0000-0000-000000000003", RhAccountID: 1, OrgID: &orgID1},
81-
{InventoryID: "00000000-0000-0000-0000-000000000017", RhAccountID: 1, OrgID: &orgID1}},
82-
inventoryAIDs)
81+
assert.Empty(t, inventoryAIDs)
8382
}
8483

8584
func TestGetRepoPackageBasedInventoryIDs(t *testing.T) {
8685
utils.SkipWithoutDB(t)
8786
core.SetupTestEnvironment()
8887

89-
repos := [][]string{{"repo1", "not_installed_pkg"}, {"repo2", "not_installed_pkg"}, {"repo2", "kernel"}}
90-
inventoryAIDs, err := getRepoBasedInventoryIDs(repos, nil)
88+
// systems have both repo and package
89+
repos := []string{"not_exists_repo", "repo2"}
90+
packages := []string{"not_installed_pkg", "kernel"}
91+
inventoryAIDs, err := getRepoBasedInventoryIDs(repos, packages)
9192
assert.Nil(t, err)
9293
assert.Equal(t, []mqueue.EvalData{
9394
// "kernel" in "repo2"
9495
{InventoryID: "00000000-0000-0000-0000-000000000002", RhAccountID: 1, OrgID: &orgID1}},
95-
// 00000000-0000-0000-0000-000000000017 does not have "not_installed_pkg" in "repo1"
9696
inventoryAIDs)
9797

98-
repos = [][]string{{"repo1", "not_installed_pkg"}, {"repo2", "not_installed_pkg"}}
98+
repos = []string{"not_installed_pkg"}
9999
inventoryAIDs, err = getRepoBasedInventoryIDs(repos, nil)
100100
assert.Nil(t, err)
101101
assert.Len(t, inventoryAIDs, 0)
102102
}
103103

104-
func TestGetRepoBasedInventoryIDs(t *testing.T) {
104+
func TestGetRepoBasedInventoryIDsEmpty(t *testing.T) {
105105
utils.SkipWithoutDB(t)
106106
core.SetupTestEnvironment()
107107

108-
repos := []string{"repo1"}
109-
repoPackages := [][]string{{"repo1", "not_installed_pkg"}, {"repo2", "not_installed_pkg"}, {"repo2", "kernel"}}
110-
inventoryAIDs, err := getRepoBasedInventoryIDs(repoPackages, repos)
108+
repos := []string{}
109+
packages := []string{}
110+
inventoryIDs, err := getRepoBasedInventoryIDs(repos, packages)
111111
assert.Nil(t, err)
112-
assert.Equal(t, []mqueue.EvalData{
113-
// from repoPackages
114-
{InventoryID: "00000000-0000-0000-0000-000000000002", RhAccountID: 1, OrgID: &orgID1},
115-
// systems added from repos
116-
{InventoryID: "00000000-0000-0000-0000-000000000003", RhAccountID: 1, OrgID: &orgID1},
117-
{InventoryID: "00000000-0000-0000-0000-000000000017", RhAccountID: 1, OrgID: &orgID1}},
118-
inventoryAIDs)
112+
assert.Equal(t, 0, len(inventoryIDs))
119113
}
120114

121-
func TestGetRepoBasedInventoryIDsEmpty(t *testing.T) {
122-
utils.SkipWithoutDB(t)
115+
func TestGetUpdatedRepos(t *testing.T) {
123116
core.SetupTestEnvironment()
117+
Configure()
124118

125-
repos := []string{}
126-
repoPackages := [][]string{}
127-
inventoryIDs, err := getRepoBasedInventoryIDs(repoPackages, repos)
119+
repos, err := getUpdatedRepos(time.Now())
128120
assert.Nil(t, err)
129-
assert.Equal(t, 0, len(inventoryIDs))
121+
assert.Equal(t, 3, len(repos))
130122
}
131123

132-
func TestGetUpdatedRepos(t *testing.T) {
124+
func TestGetUpdatedReposWithPackages(t *testing.T) {
133125
core.SetupTestEnvironment()
134126
Configure()
135127

136128
modifiedSince := time.Now().Format(types.Rfc3339NoTz)
137-
thirdParty := true
138-
repoPackages, repoNoPackages, _, err := getUpdatedRepos(time.Now(), &modifiedSince, &thirdParty)
129+
repos, packages, _, err := getUpdatedReposWithPackages(time.Now(), &modifiedSince)
139130
assert.Nil(t, err)
140-
assert.Equal(t, 2, len(repoPackages[0]))
141-
assert.Equal(t, 2, len(repoNoPackages))
131+
assert.Equal(t, 1, len(repos))
132+
assert.Equal(t, 2, len(packages))
142133
}
143134

144135
func resetLastEvalTimestamp(t *testing.T) {

0 commit comments

Comments
 (0)