public_git/kubernetes-operator
1
0
Fork 0
mirror of https://github.com/jenkinsci/kubernetes-operator.git synced 2026-10-08 17:16:48 +02:00
Code Issues Releases Wiki Activity

#54 Improve business logic

Browse Source
This commit is contained in:
Jakub Al-Khalili
2019-07-22 16:41:00 +02:00
parent 78b4a2d952
commit 4d2cab5109
3 changed files with 21 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/controller/jenkins/groovy/groovy.go
+11 -8
View File
@@ -47,13 +47,6 @@ func (g *Groovy) EnsureSingle(source, name, hash, groovyScript string) (requeue
return false, nil
}
for i, ags := range g.jenkins.Status.AppliedGroovyScripts {
if ags.ConfigurationType == g.configurationType && ags.Name == name && ags.Source == source {
g.jenkins.Status.AppliedGroovyScripts = append(g.jenkins.Status.AppliedGroovyScripts[:i],
g.jenkins.Status.AppliedGroovyScripts[i+1:]...)
}
}
logs, err := g.jenkinsClient.ExecuteScript(groovyScript)
if err != nil {
if _, ok := err.(*jenkinsclient.GroovyScriptExecutionFailed); ok {
@@ -62,12 +55,22 @@ func (g *Groovy) EnsureSingle(source, name, hash, groovyScript string) (requeue
return true, err
}
g.jenkins.Status.AppliedGroovyScripts = append(g.jenkins.Status.AppliedGroovyScripts, v1alpha2.AppliedGroovyScript{
var appliedGroovyScripts []v1alpha2.AppliedGroovyScript
for _, ags := range g.jenkins.Status.AppliedGroovyScripts {
if ags.ConfigurationType != g.configurationType && ags.Source != source && ags.Name != name {
appliedGroovyScripts = append(appliedGroovyScripts, ags)
}
}
appliedGroovyScripts = append(appliedGroovyScripts, v1alpha2.AppliedGroovyScript{
ConfigurationType: g.configurationType,
Source: source,
Name: name,
Hash: hash,
})
g.jenkins.Status.AppliedGroovyScripts = appliedGroovyScripts
return true, g.k8sClient.Update(context.TODO(), g.jenkins)
}
pkg/controller/jenkins/groovy/groovy_test.go
+6 -4
View File
@@ -114,6 +114,7 @@ func TestGroovy_EnsureSingle(t *testing.T) {
assert.Equal(t, groovyScriptName, jenkins.Status.AppliedGroovyScripts[0].Name)
})
t.Run("execute script with new version", func(t *testing.T) {
anotherHash := "hash1"
// given
jenkins := &v1alpha2.Jenkins{
ObjectMeta: metav1.ObjectMeta{
@@ -137,11 +138,11 @@ func TestGroovy_EnsureSingle(t *testing.T) {
groovyClient := New(jenkinsClient, fakeClient, log.Log, jenkins, configurationType, emptyCustomization)
// when
_, err = groovyClient.EnsureSingle(source, groovyScriptName, hash, groovyScript)
requeue, err := groovyClient.EnsureSingle(source, groovyScriptName, hash, groovyScript)
// then
require.NoError(t, err)
assert.True(t, requeue)
err = fakeClient.Get(ctx, types.NamespacedName{Name: jenkins.Name, Namespace: jenkins.Namespace}, jenkins)
require.NoError(t, err)
assert.Equal(t, 1, len(jenkins.Status.AppliedGroovyScripts))
@@ -151,14 +152,15 @@ func TestGroovy_EnsureSingle(t *testing.T) {
assert.Equal(t, groovyScriptName, jenkins.Status.AppliedGroovyScripts[0].Name)
// Update with new hash
_, err = groovyClient.EnsureSingle(source, groovyScriptName, "hash1", groovyScript)
requeue, err = groovyClient.EnsureSingle(source, groovyScriptName, anotherHash, groovyScript)
require.NoError(t, err)
assert.True(t, requeue)
err = fakeClient.Get(ctx, types.NamespacedName{Name: jenkins.Name, Namespace: jenkins.Namespace}, jenkins)
require.NoError(t, err)
assert.Equal(t, 1, len(jenkins.Status.AppliedGroovyScripts))
assert.Equal(t, configurationType, jenkins.Status.AppliedGroovyScripts[0].ConfigurationType)
assert.Equal(t, "hash1", jenkins.Status.AppliedGroovyScripts[0].Hash)
assert.Equal(t, anotherHash, jenkins.Status.AppliedGroovyScripts[0].Hash)
assert.Equal(t, source, jenkins.Status.AppliedGroovyScripts[0].Source)
assert.Equal(t, groovyScriptName, jenkins.Status.AppliedGroovyScripts[0].Name)
})