jenkins/sap-jenkins-library
1
0
Fork 0
mirror of https://github.com/SAP/jenkins-library.git synced 2024-12-12 10:55:20 +02:00
Code Issues Releases Activity
d0f7400122
sap-jenkins-library/cmd/abapAddonAssemblyKitReserveNextPackages_test.go

422 lines
14 KiB
Go
Raw Normal View History

AAKaaS: 7 reserve next package (#2046) * adding my steps * messy step * Update abapEnvironmentAssembly.go * clean up * change yaml * corrections * Update cloudFoundryDeploy.go * update * delete simulation step * remove simulate * Update PiperGoUtils.groovy * Update PiperGoUtils.groovy * Update CommonStepsTest.groovy * add docu * Update abapEnvironmentAssembly.md * changes due to PR * Update .gitignore * b * CV list * Update abapEnvironmentAssembly.go * testing with simulation * Update abapEnvironmentAssembly.go * remove simulation * renaming * Update mkdocs.yml * moving service key to yaml and fixing code climate * Update abapEnvironmentAssemblePackages.go * Update abapEnvironmentAssemblePackages.go * Update abapEnvironmentAssemblePackages.go * Update abapEnvironmentAssemblePackages.go * change input * Update abapEnvironmentAssemblePackages.go * change json tag * fixed error handling * documentation * Update abapEnvironmentAssemblePackages.md * Update abapEnvironmentAssemblePackages.md * fixing code climate issues * fixing code climate issues * Update abapEnvironmentAssemblePackages.yaml * fixing code climate issues * Update abapEnvironmentAssemblePackages.yaml * adding unittests * adding unittests and improved logging * yaml -> json * change scope of cfServiceKeyName * correct indentation * Update CommonStepsTest.groovy * maintain correct step order * AAKaaS register package * AAKaaS register package #2 * Update documentation/docs/steps/abapAddonAssemblyKitPublishTargetVector.md Co-authored-by: Daniel Mieg <56156797+DanielMieg@users.noreply.github.com> * AAKaaS register package #3 * AAKaaS release package * Update abapAddonAssemblyKitReleasePackages.go * AAKaas release package #2 * AAKaaS reserve * AAKaaS reserve #2 Co-authored-by: rosemarieB <45030247+rosemarieB@users.noreply.github.com> Co-authored-by: Daniel Mieg <56156797+DanielMieg@users.noreply.github.com> Co-authored-by: Christopher Fenner <26137398+CCFenner@users.noreply.github.com>
2020-09-18 17:27:04 +02:00
package cmd
import (
"encoding/json"
"testing"
"time"
"github.com/SAP/jenkins-library/pkg/abap/aakaas"
abapbuild "github.com/SAP/jenkins-library/pkg/abap/build"
"github.com/SAP/jenkins-library/pkg/abaputils"
"github.com/pkg/errors"
"github.com/stretchr/testify/assert"
)
func TestReserveNextPackagesStep(t *testing.T) {
var config abapAddonAssemblyKitReserveNextPackagesOptions
var cpe abapAddonAssemblyKitReserveNextPackagesCommonPipelineEnvironment
timeout := time.Duration(5 * time.Second)
pollInterval := time.Duration(1 * time.Second)
t.Run("step success", func(t *testing.T) {
addonDescriptor := abaputils.AddonDescriptor{
Repositories: []abaputils.Repository{
{
Name: "/DRNMSPC/COMP01",
VersionYAML: "1.0.0.",
},
{
Name: "/DRNMSPC/COMP02",
VersionYAML: "1.0.0.",
},
},
}
adoDesc, _ := json.Marshal(addonDescriptor)
config.AddonDescriptor = string(adoDesc)
client := &abaputils.ClientMock{
BodyList: []string{responseReserveNextPackageReleased, responseReserveNextPackagePlanned, responseReserveNextPackagePostReleased, "myToken", responseReserveNextPackagePostPlanned, "myToken"},
}
err := runAbapAddonAssemblyKitReserveNextPackages(&config, nil, client, &cpe, timeout, pollInterval)
assert.NoError(t, err, "Did not expect error")
var addonDescriptorFinal abaputils.AddonDescriptor
json.Unmarshal([]byte(cpe.abap.addonDescriptor), &addonDescriptorFinal)
assert.Equal(t, "P", addonDescriptorFinal.Repositories[0].Status)
assert.Equal(t, "R", addonDescriptorFinal.Repositories[1].Status)
})
t.Run("step error - invalid input", func(t *testing.T) {
addonDescriptor := abaputils.AddonDescriptor{
Repositories: []abaputils.Repository{
{
Name: "/DRNMSPC/COMP01",
},
},
}
adoDesc, _ := json.Marshal(addonDescriptor)
config.AddonDescriptor = string(adoDesc)
client := &abaputils.ClientMock{}
err := runAbapAddonAssemblyKitReserveNextPackages(&config, nil, client, &cpe, timeout, pollInterval)
assert.Error(t, err, "Did expect error")
})
t.Run("step error - timeout", func(t *testing.T) {
addonDescriptor := abaputils.AddonDescriptor{
Repositories: []abaputils.Repository{
{
Name: "/DRNMSPC/COMP01",
VersionYAML: "1.0.0.",
},
},
}
adoDesc, _ := json.Marshal(addonDescriptor)
config.AddonDescriptor = string(adoDesc)
client := &abaputils.ClientMock{
BodyList: []string{responseReserveNextPackageCreationTriggered, responseReserveNextPackagePostPlanned, "myToken"},
}
timeout := time.Duration(1 * time.Second)
err := runAbapAddonAssemblyKitReserveNextPackages(&config, nil, client, &cpe, timeout, pollInterval)
assert.Error(t, err, "Did expect error")
})
}
// ********************* Test init *******************
func TestInitPackage(t *testing.T) {
t.Run("test init", func(t *testing.T) {
conn := new(abapbuild.Connector)
conn.Client = &abaputils.ClientMock{}
repo := abaputils.Repository{
Name: "/DRNMSPC/COMP01",
VersionYAML: "1.0.0",
}
var p aakaas.Package
p.InitPackage(repo, *conn)
assert.Equal(t, "/DRNMSPC/COMP01", p.ComponentName)
assert.Equal(t, "1.0.0", p.VersionYAML)
})
}
// ********************* Test copyFieldsToRepositories *******************
func TestCopyFieldsToRepositoriesPackage(t *testing.T) {
t.Run("test copyFieldsToRepositories", func(t *testing.T) {
pckgWR := []aakaas.PackageWithRepository{
{
Package: aakaas.Package{
ComponentName: "/DRNMSPC/COMP01",
VersionYAML: "1.0.0",
PackageName: "SAPK-001AAINDRNMSPC",
Type: "AOI",
Status: aakaas.PackageStatusPlanned,
Namespace: "/DRNMSPC/",
},
Repo: abaputils.Repository{
Name: "/DRNMSPC/COMP01",
VersionYAML: "1.0.0",
},
},
}
repos := copyFieldsToRepositories(pckgWR)
assert.Equal(t, "SAPK-001AAINDRNMSPC", repos[0].PackageName)
assert.Equal(t, "AOI", repos[0].PackageType)
assert.Equal(t, string(aakaas.PackageStatusPlanned), repos[0].Status)
assert.Equal(t, "/DRNMSPC/", repos[0].Namespace)
})
}
// ********************* Test reserveNext *******************
func TestReserveNextPackage(t *testing.T) {
t.Run("test reserveNext - success", func(t *testing.T) {
client := abaputils.ClientMock{
Body: responseReserveNextPackagePostPlanned,
}
p := testPackageSetup("/DRNMSPC/COMP01", "1.0.0", client)
err := p.ReserveNext()
assert.NoError(t, err)
assert.Equal(t, "SAPK-001AAINDRNMSPC", p.PackageName)
assert.Equal(t, "AOI", p.Type)
assert.Equal(t, aakaas.PackageStatusPlanned, p.Status)
})
t.Run("test reserveNext - missing versionYAML", func(t *testing.T) {
client := abaputils.ClientMock{}
p := testPackageSetup("/DRNMSPC/COMP01", "", client)
err := p.ReserveNext()
assert.Error(t, err)
assert.Equal(t, "", p.PackageName)
assert.Equal(t, "", p.Type)
assert.Equal(t, aakaas.PackageStatus(""), p.Status)
})
t.Run("test reserveNext - error from call", func(t *testing.T) {
client := abaputils.ClientMock{
Body: "ErrorBody",
Error: errors.New("Failure during reserve next"),
}
p := testPackageSetup("/DRNMSPC/COMP01", "1.0.0", client)
err := p.ReserveNext()
assert.Error(t, err)
assert.Equal(t, "", p.PackageName)
assert.Equal(t, "", p.Type)
assert.Equal(t, aakaas.PackageStatus(""), p.Status)
})
}
// ********************* Test reservePackages *******************
func TestReservePackages(t *testing.T) {
t.Run("test reservePackages - success", func(t *testing.T) {
client := abaputils.ClientMock{
Body: responseReserveNextPackagePostPlanned,
}
repositories, conn := testRepositoriesSetup("/DRNMSPC/COMP01", "1.0.0", client)
repos, err := reservePackages(repositories, conn)
assert.NoError(t, err)
assert.Equal(t, "/DRNMSPC/COMP01", repos[0].Package.ComponentName)
assert.Equal(t, "1.0.0", repos[0].Package.VersionYAML)
assert.Equal(t, aakaas.PackageStatusPlanned, repos[0].Package.Status)
})
t.Run("test reservePackages - error from call", func(t *testing.T) {
client := abaputils.ClientMock{
Body: "ErrorBody",
Error: errors.New("Failure during reserve next"),
}
repositories, conn := testRepositoriesSetup("/DRNMSPC/COMP01", "1.0.0", client)
_, err := reservePackages(repositories, conn)
assert.Error(t, err)
})
}
// ********************* Test pollReserveNextPackages *******************
func TestPollReserveNextPackages(t *testing.T) {
timeout := time.Duration(5 * time.Second)
pollInterval := time.Duration(1 * time.Second)
t.Run("test pollReserveNextPackages - testing loop", func(t *testing.T) {
client := abaputils.ClientMock{
BodyList: []string{responseReserveNextPackagePlanned, responseReserveNextPackageCreationTriggered},
}
pckgWR := testPollPackagesSetup(client)
err := pollReserveNextPackages(pckgWR, timeout, pollInterval)
assert.NoError(t, err)
assert.Equal(t, aakaas.PackageStatusPlanned, pckgWR[0].Package.Status)
assert.Equal(t, "/DRNMSPC/", pckgWR[0].Package.Namespace)
})
t.Run("test pollReserveNextPackages - status locked", func(t *testing.T) {
client := abaputils.ClientMock{
Body: responseReserveNextPackageLocked,
}
pckgWR := testPollPackagesSetup(client)
err := pollReserveNextPackages(pckgWR, timeout, pollInterval)
assert.Error(t, err)
assert.Equal(t, aakaas.PackageStatusLocked, pckgWR[0].Package.Status)
})
t.Run("test pollReserveNextPackages - status released", func(t *testing.T) {
client := abaputils.ClientMock{
Body: responseReserveNextPackageReleased,
}
pckgWR := testPollPackagesSetup(client)
err := pollReserveNextPackages(pckgWR, timeout, pollInterval)
assert.NoError(t, err)
assert.Equal(t, aakaas.PackageStatusReleased, pckgWR[0].Package.Status)
})
t.Run("test pollReserveNextPackages - unknow status", func(t *testing.T) {
client := abaputils.ClientMock{
Body: responseReserveNextPackageUnknownState,
}
pckgWR := testPollPackagesSetup(client)
err := pollReserveNextPackages(pckgWR, timeout, pollInterval)
assert.Error(t, err)
assert.Equal(t, aakaas.PackageStatus("X"), pckgWR[0].Package.Status)
})
t.Run("test pollReserveNextPackages - timeout", func(t *testing.T) {
client := abaputils.ClientMock{
Body: "ErrorBody",
Error: errors.New("Failure during reserve next"),
}
pckgWR := testPollPackagesSetup(client)
timeout := time.Duration(2 * time.Second)
err := pollReserveNextPackages(pckgWR, timeout, pollInterval)
assert.Error(t, err)
})
}
// ********************* Setup functions *******************
func testPollPackagesSetup(client abaputils.ClientMock) []aakaas.PackageWithRepository {
conn := new(abapbuild.Connector)
conn.Client = &client
conn.Header = make(map[string][]string)
pckgWR := []aakaas.PackageWithRepository{
{
Package: aakaas.Package{
Connector: *conn,
ComponentName: "/DRNMSPC/COMP01",
VersionYAML: "1.0.0",
PackageName: "SAPK-001AAINDRNMSPC",
Type: "AOI",
},
Repo: abaputils.Repository{},
},
}
return pckgWR
}
func testRepositoriesSetup(componentName string, versionYAML string, client abaputils.ClientMock) ([]abaputils.Repository, abapbuild.Connector) {
conn := new(abapbuild.Connector)
conn.Client = &client
conn.Header = make(map[string][]string)
repositories := []abaputils.Repository{
{
Name: componentName,
VersionYAML: versionYAML,
},
}
return repositories, *conn
}
func testPackageSetup(componentName string, versionYAML string, client abaputils.ClientMock) aakaas.Package {
conn := new(abapbuild.Connector)
conn.Client = &client
conn.Header = make(map[string][]string)
p := aakaas.Package{
Connector: *conn,
ComponentName: componentName,
VersionYAML: versionYAML,
}
return p
}
// ********************* Testdata *******************
var responseReserveNextPackagePostPlanned = `{
"d": {
"DeterminePackageForScv": {
"__metadata": {
"type": "SSDA.AAS_ODATA_PACKAGE_SRV.PackageExtended"
},
"Name": "SAPK-001AAINDRNMSPC",
"Type": "AOI",
"ScName": "/DRNMSPC/COMP01",
"ScVersion": "0001",
"SpLevel": "0000",
"PatchLevel": "0000",
"Predecessor": "",
"PredecessorCommitId": "",
"Status": "P"
}
}
}`
var responseReserveNextPackagePostReleased = `{
"d": {
"DeterminePackageForScv": {
"__metadata": {
"type": "SSDA.AAS_ODATA_PACKAGE_SRV.PackageExtended"
},
"Name": "SAPK-001AAINDRNMSPC",
"Type": "AOI",
"ScName": "/DRNMSPC/COMP02",
"ScVersion": "0001",
"SpLevel": "0000",
"PatchLevel": "0000",
"Predecessor": "",
"PredecessorCommitId": "",
"Status": "R"
}
}
}`
var responseReserveNextPackageCreationTriggered = `{
"d": {
"__metadata": {
"id": "https://W7Q.DMZWDF.SAP.CORP:443/odata/aas_ocs_package/OcsPackageSet('SAPK-001AAINDRNMSPC')",
"uri": "https://W7Q.DMZWDF.SAP.CORP:443/odata/aas_ocs_package/OcsPackageSet('SAPK-001AAINDRNMSPC')",
"type": "SSDA.AAS_ODATA_PACKAGE_SRV.OcsPackage"
},
"Name": "SAPK-001AAINDRNMSPC",
"Type": "AOI",
"Component": "/DRNMSPC/COMP01",
"Release": "0001",
"Level": "0000",
"Status": "C",
"Operation": "",
"Namespace": "/DRNMSPC/",
"Vendorid": "0000203069"
}
}`
var responseReserveNextPackageLocked = `{
"d": {
"__metadata": {
"id": "https://W7Q.DMZWDF.SAP.CORP:443/odata/aas_ocs_package/OcsPackageSet('SAPK-001AAINDRNMSPC')",
"uri": "https://W7Q.DMZWDF.SAP.CORP:443/odata/aas_ocs_package/OcsPackageSet('SAPK-001AAINDRNMSPC')",
"type": "SSDA.AAS_ODATA_PACKAGE_SRV.OcsPackage"
},
"Name": "SAPK-001AAINDRNMSPC",
"Type": "AOI",
"Component": "/DRNMSPC/COMP01",
"Release": "0001",
"Level": "0000",
"Status": "L",
"Operation": "",
"Namespace": "/DRNMSPC/",
"Vendorid": "0000203069"
}
}`
var responseReserveNextPackagePlanned = `{
"d": {
"__metadata": {
"id": "https://W7Q.DMZWDF.SAP.CORP:443/odata/aas_ocs_package/OcsPackageSet('SAPK-001AAINDRNMSPC')",
"uri": "https://W7Q.DMZWDF.SAP.CORP:443/odata/aas_ocs_package/OcsPackageSet('SAPK-001AAINDRNMSPC')",
"type": "SSDA.AAS_ODATA_PACKAGE_SRV.OcsPackage"
},
"Name": "SAPK-001AAINDRNMSPC",
"Type": "AOI",
"Component": "/DRNMSPC/COMP01",
"Release": "0001",
"Level": "0000",
"Status": "P",
"Operation": "",
"Namespace": "/DRNMSPC/",
"Vendorid": "0000203069"
}
}`
var responseReserveNextPackageReleased = `{
"d": {
"__metadata": {
"id": "https://W7Q.DMZWDF.SAP.CORP:443/odata/aas_ocs_package/OcsPackageSet('SAPK-001AAINDRNMSPC')",
"uri": "https://W7Q.DMZWDF.SAP.CORP:443/odata/aas_ocs_package/OcsPackageSet('SAPK-001AAINDRNMSPC')",
"type": "SSDA.AAS_ODATA_PACKAGE_SRV.OcsPackage"
},
"Name": "SAPK-001AAINDRNMSPC",
"Type": "AOI",
"Component": "/DRNMSPC/COMP01",
"Release": "0001",
"Level": "0000",
"Status": "R",
"Operation": "",
"Namespace": "/DRNMSPC/",
"Vendorid": "0000203069"
}
}`
var responseReserveNextPackageUnknownState = `{
"d": {
"__metadata": {
"id": "https://W7Q.DMZWDF.SAP.CORP:443/odata/aas_ocs_package/OcsPackageSet('SAPK-001AAINDRNMSPC')",
"uri": "https://W7Q.DMZWDF.SAP.CORP:443/odata/aas_ocs_package/OcsPackageSet('SAPK-001AAINDRNMSPC')",
"type": "SSDA.AAS_ODATA_PACKAGE_SRV.OcsPackage"
},
"Name": "SAPK-001AAINDRNMSPC",
"Type": "AOI",
"Component": "/DRNMSPC/COMP01",
"Release": "0001",
"Level": "0000",
"Status": "X",
"Operation": "",
"Namespace": "/DRNMSPC/",
"Vendorid": "0000203069"
}
}`
Reference in New Issue Copy Permalink