/
rest.go
120 lines (101 loc) · 4.27 KB
/
rest.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
package rollback
import (
"context"
"fmt"
apierrors "k8s.io/apimachinery/pkg/api/errors"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
"k8s.io/apimachinery/pkg/runtime"
"k8s.io/apimachinery/pkg/util/validation/field"
apirequest "k8s.io/apiserver/pkg/endpoints/request"
"k8s.io/apiserver/pkg/registry/rest"
"k8s.io/client-go/kubernetes"
corev1client "k8s.io/client-go/kubernetes/typed/core/v1"
"k8s.io/kubernetes/pkg/api/legacyscheme"
"github.com/openshift/api/apps"
appsclient "github.com/openshift/client-go/apps/clientset/versioned"
appsclienttyped "github.com/openshift/client-go/apps/clientset/versioned/typed/apps/v1"
appsapi "github.com/openshift/origin/pkg/apps/apis/apps"
"github.com/openshift/origin/pkg/apps/apis/apps/validation"
appsutil "github.com/openshift/origin/pkg/apps/util"
)
// REST provides a rollback generation endpoint. Only the Create method is implemented.
type REST struct {
generator RollbackGenerator
dn appsclienttyped.DeploymentConfigsGetter
rn corev1client.ReplicationControllersGetter
}
var _ rest.Creater = &REST{}
// NewREST safely creates a new REST.
func NewREST(appsclient appsclient.Interface, kc kubernetes.Interface) *REST {
return &REST{
generator: NewRollbackGenerator(),
dn: appsclient.AppsV1(),
rn: kc.CoreV1(),
}
}
// New creates an empty DeploymentConfigRollback resource
func (r *REST) New() runtime.Object {
return &appsapi.DeploymentConfigRollback{}
}
// Create generates a new DeploymentConfig representing a rollback.
func (r *REST) Create(ctx context.Context, obj runtime.Object, createValidation rest.ValidateObjectFunc, options *metav1.CreateOptions) (runtime.Object, error) {
namespace, ok := apirequest.NamespaceFrom(ctx)
if !ok {
return nil, apierrors.NewBadRequest("namespace parameter required.")
}
rollback, ok := obj.(*appsapi.DeploymentConfigRollback)
if !ok {
return nil, apierrors.NewBadRequest(fmt.Sprintf("not a rollback spec: %#v", obj))
}
if errs := validation.ValidateDeploymentConfigRollback(rollback); len(errs) > 0 {
return nil, apierrors.NewInvalid(apps.Kind("DeploymentConfigRollback"), rollback.Name, errs)
}
if err := createValidation(obj); err != nil {
return nil, err
}
from, err := r.dn.DeploymentConfigs(namespace).Get(rollback.Name, metav1.GetOptions{})
if err != nil {
return nil, newInvalidError(rollback, fmt.Sprintf("cannot get deployment config %q: %v", rollback.Name, err))
}
switch from.Status.LatestVersion {
case 0:
return nil, newInvalidError(rollback, "cannot rollback an undeployed config")
case 1:
return nil, newInvalidError(rollback, fmt.Sprintf("no previous deployment exists for %q", appsutil.LabelForDeploymentConfig(from)))
case rollback.Spec.Revision:
return nil, newInvalidError(rollback, fmt.Sprintf("version %d is already the latest", rollback.Spec.Revision))
}
revision := from.Status.LatestVersion - 1
if rollback.Spec.Revision > 0 {
revision = rollback.Spec.Revision
}
// Find the target deployment and decode its config.
name := appsutil.DeploymentNameForConfigVersion(from.Name, revision)
targetDeployment, err := r.rn.ReplicationControllers(namespace).Get(name, metav1.GetOptions{})
if err != nil {
return nil, newInvalidError(rollback, err.Error())
}
to, err := appsutil.DecodeDeploymentConfig(targetDeployment)
if err != nil {
return nil, newInvalidError(rollback, fmt.Sprintf("couldn't decode deployment config from deployment: %v", err))
}
toInternal := &appsapi.DeploymentConfig{}
if err := legacyscheme.Scheme.Convert(to, toInternal, nil); err != nil {
return nil, apierrors.NewInternalError(err)
}
if from.Annotations == nil && len(rollback.UpdatedAnnotations) > 0 {
from.Annotations = make(map[string]string)
}
for key, value := range rollback.UpdatedAnnotations {
from.Annotations[key] = value
}
fromInternal := &appsapi.DeploymentConfig{}
if err := legacyscheme.Scheme.Convert(from, fromInternal, nil); err != nil {
return nil, apierrors.NewInternalError(err)
}
return r.generator.GenerateRollback(fromInternal, toInternal, &rollback.Spec)
}
func newInvalidError(rollback *appsapi.DeploymentConfigRollback, reason string) error {
err := field.Invalid(field.NewPath("name"), rollback.Name, reason)
return apierrors.NewInvalid(apps.Kind("DeploymentConfigRollback"), rollback.Name, field.ErrorList{err})
}