Skip to content

Commit 050d767

Browse files
anik120anik120
committed
(rukpak) extend bundle renderer to accept config opts
Introduce BundleConfig that contains InstallConfig and DeploymentConfig.
1 parent dff07d5 commit 050d767

File tree

4 files changed

+275
-3
lines changed

4 files changed

+275
-3
lines changed

‎internal/operator-controller/rukpak/convert/helm.go‎

Lines changed: 19 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -18,6 +18,24 @@ type BundleToHelmChartConverter struct {
1818
}
1919

2020
func (r *BundleToHelmChartConverter) ToHelmChart(bundle source.BundleSource, installNamespace string, watchNamespace string) (*chart.Chart, error) {
21+
bundleConfig := &render.BundleConfig{}
22+
if watchNamespace != "" && watchNamespace != installNamespace {
23+
bundleConfig.InstallMode = &render.InstallModeConfig{
24+
InstallMode: render.InstallModeSingleNamespace,
25+
SingleNamespaceInstallMode: &render.SingleNamespaceInstallModeConfig{
26+
WatchNamespace: watchNamespace,
27+
},
28+
}
29+
} else if watchNamespace == installNamespace {
30+
bundleConfig.InstallMode = &render.InstallModeConfig{
31+
InstallMode: render.InstallModeOwnNamespace,
32+
}
33+
}
34+
// If watchNamespace is empty, leave bundleConfig.InstallMode as nil (defaults to AllNamespaces)
35+
return r.ToHelmChartWithConfig(bundle, installNamespace, bundleConfig)
36+
}
37+
38+
func (r *BundleToHelmChartConverter) ToHelmChartWithConfig(bundle source.BundleSource, installNamespace string, config *render.BundleConfig) (*chart.Chart, error) {
2139
rv1, err := bundle.GetBundle()
2240
if err != nil {
2341
return nil, err
@@ -41,7 +59,7 @@ func (r *BundleToHelmChartConverter) ToHelmChart(bundle source.BundleSource, ins
4159

4260
objs, err := r.BundleRenderer.Render(
4361
rv1, installNamespace,
44-
render.WithTargetNamespaces(watchNamespace),
62+
render.WithBundleConfig(config),
4563
render.WithCertificateProvider(r.CertificateProvider),
4664
)
4765

‎internal/operator-controller/rukpak/convert/helm_test.go‎

Lines changed: 47 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -192,3 +192,50 @@ func Test_BundleToHelmChartConverter_ToHelmChart_Success(t *testing.T) {
192192
t.Log("Check Chart templates have the same number of resources generated by the renderer")
193193
require.Len(t, chart.Templates, 1)
194194
}
195+
196+
func Test_BundleToHelmChartConverter_ToHelmChartWithConfig_Success(t *testing.T) {
197+
converter := convert.BundleToHelmChartConverter{
198+
BundleRenderer: render.BundleRenderer{
199+
ResourceGenerators: []render.ResourceGenerator{
200+
func(rv1 *bundle.RegistryV1, opts render.Options) ([]client.Object, error) {
201+
// Verify that bundle config is passed correctly
202+
require.NotNil(t, opts.BundleConfig)
203+
require.NotNil(t, opts.BundleConfig.InstallMode)
204+
require.Equal(t, render.InstallModeSingleNamespace, opts.BundleConfig.InstallMode.InstallMode)
205+
require.NotNil(t, opts.BundleConfig.InstallMode.SingleNamespaceInstallMode)
206+
require.Equal(t, "test-watch-namespace", opts.BundleConfig.InstallMode.SingleNamespaceInstallMode.WatchNamespace)
207+
return []client.Object{&corev1.Service{}}, nil
208+
},
209+
},
210+
},
211+
}
212+
213+
b := source.FromBundle(
214+
bundle.RegistryV1{
215+
CSV: MakeCSV(
216+
WithInstallModeSupportFor(v1alpha1.InstallModeTypeSingleNamespace),
217+
WithAnnotations(map[string]string{"foo": "bar"}),
218+
),
219+
},
220+
)
221+
222+
config := &render.BundleConfig{
223+
InstallMode: &render.InstallModeConfig{
224+
InstallMode: render.InstallModeSingleNamespace,
225+
SingleNamespaceInstallMode: &render.SingleNamespaceInstallModeConfig{
226+
WatchNamespace: "test-watch-namespace",
227+
},
228+
},
229+
}
230+
231+
chart, err := converter.ToHelmChartWithConfig(b, "install-namespace", config)
232+
require.NoError(t, err)
233+
require.NotNil(t, chart)
234+
require.NotNil(t, chart.Metadata)
235+
236+
t.Log("Check Chart metadata contains CSV annotations")
237+
require.Equal(t, map[string]string{"foo": "bar"}, chart.Metadata.Annotations)
238+
239+
t.Log("Check Chart templates have the same number of resources generated by the renderer")
240+
require.Len(t, chart.Templates, 1)
241+
}

‎internal/operator-controller/rukpak/render/render.go‎

Lines changed: 93 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -56,11 +56,39 @@ func (r ResourceGenerators) ResourceGenerator() ResourceGenerator {
5656

5757
type UniqueNameGenerator func(string, interface{}) (string, error)
5858

59+
const (
60+
InstallModeAllNamespaces = "AllNamespaces"
61+
InstallModeSingleNamespace = "SingleNamespace"
62+
InstallModeOwnNamespace = "OwnNamespace"
63+
)
64+
65+
// BundleConfig represents configuration options for bundle rendering
66+
type BundleConfig struct {
67+
// InstallMode contains install mode specific configuration
68+
InstallMode *InstallModeConfig
69+
}
70+
71+
// InstallModeConfig is a union type for install mode specific configuration
72+
type InstallModeConfig struct {
73+
// InstallMode must be one of "AllNamespaces", "SingleNamespace", or "OwnNamespace"
74+
InstallMode string
75+
76+
// SingleNamespaceInstallMode is required when InstallMode == "SingleNamespace"
77+
SingleNamespaceInstallMode *SingleNamespaceInstallModeConfig
78+
}
79+
80+
// SingleNamespaceInstallModeConfig contains configuration for SingleNamespace install mode
81+
type SingleNamespaceInstallModeConfig struct {
82+
// WatchNamespace is the namespace to watch (required)
83+
WatchNamespace string
84+
}
85+
5986
type Options struct {
6087
InstallNamespace string
6188
TargetNamespaces []string
6289
UniqueNameGenerator UniqueNameGenerator
6390
CertificateProvider CertificateProvider
91+
BundleConfig *BundleConfig
6492
}
6593

6694
func (o *Options) apply(opts ...Option) *Options {
@@ -83,6 +111,14 @@ func (o *Options) validate(rv1 *bundle.RegistryV1) (*Options, []error) {
83111
if err := validateTargetNamespaces(rv1, o.InstallNamespace, o.TargetNamespaces); err != nil {
84112
errs = append(errs, fmt.Errorf("invalid target namespaces %v: %w", o.TargetNamespaces, err))
85113
}
114+
115+
// Validate bundle configuration
116+
if o.BundleConfig != nil {
117+
if configErrs := validateBundleConfig(o.BundleConfig); len(configErrs) > 0 {
118+
errs = append(errs, configErrs...)
119+
}
120+
}
121+
86122
return o, errs
87123
}
88124

@@ -106,6 +142,12 @@ func WithCertificateProvider(provider CertificateProvider) Option {
106142
}
107143
}
108144

145+
func WithBundleConfig(config *BundleConfig) Option {
146+
return func(o *Options) {
147+
o.BundleConfig = config
148+
}
149+
}
150+
109151
type BundleRenderer struct {
110152
BundleValidator BundleValidator
111153
ResourceGenerators []ResourceGenerator
@@ -118,13 +160,27 @@ func (r BundleRenderer) Render(rv1 bundle.RegistryV1, installNamespace string, o
118160
}
119161

120162
// generate bundle objects
121-
genOpts, errs := (&Options{
163+
genOpts := (&Options{
122164
// default options
123165
InstallNamespace: installNamespace,
124166
TargetNamespaces: []string{metav1.NamespaceAll},
125167
UniqueNameGenerator: DefaultUniqueNameGenerator,
126168
CertificateProvider: nil,
127-
}).apply(opts...).validate(&rv1)
169+
}).apply(opts...)
170+
171+
if genOpts.BundleConfig != nil && genOpts.BundleConfig.InstallMode != nil {
172+
switch genOpts.BundleConfig.InstallMode.InstallMode {
173+
case InstallModeSingleNamespace:
174+
if genOpts.BundleConfig.InstallMode.SingleNamespaceInstallMode != nil {
175+
genOpts.TargetNamespaces = []string{genOpts.BundleConfig.InstallMode.SingleNamespaceInstallMode.WatchNamespace}
176+
}
177+
case InstallModeOwnNamespace:
178+
genOpts.TargetNamespaces = []string{installNamespace}
179+
case InstallModeAllNamespaces:
180+
genOpts.TargetNamespaces = []string{metav1.NamespaceAll}
181+
}
182+
}
183+
genOpts, errs := genOpts.validate(&rv1)
128184

129185
if len(errs) > 0 {
130186
return nil, fmt.Errorf("invalid option(s): %w", errors.Join(errs...))
@@ -175,3 +231,38 @@ func validateTargetNamespaces(rv1 *bundle.RegistryV1, installNamespace string, t
175231
}
176232
return fmt.Errorf("supported install modes %v do not support target namespaces %v", sets.List[string](supportedInstallModes), targetNamespaces)
177233
}
234+
235+
// validateBundleConfig validates that the bundle configuration is internally consistent and complete
236+
func validateBundleConfig(config *BundleConfig) []error {
237+
var errs []error
238+
239+
if config.InstallMode == nil {
240+
return errs
241+
}
242+
243+
switch config.InstallMode.InstallMode {
244+
case InstallModeAllNamespaces:
245+
// AllNamespaces mode should not have SingleNamespace configuration
246+
if config.InstallMode.SingleNamespaceInstallMode != nil {
247+
errs = append(errs, fmt.Errorf("singleNamespaceInstallMode configuration should not be provided when installMode is AllNamespaces"))
248+
}
249+
case InstallModeSingleNamespace:
250+
// SingleNamespace mode requires SingleNamespace configuration
251+
if config.InstallMode.SingleNamespaceInstallMode == nil {
252+
errs = append(errs, fmt.Errorf("singleNamespaceInstallMode configuration is required when installMode is SingleNamespace"))
253+
} else if config.InstallMode.SingleNamespaceInstallMode.WatchNamespace == "" {
254+
errs = append(errs, fmt.Errorf("watchNamespace is required in singleNamespaceInstallMode configuration"))
255+
}
256+
case InstallModeOwnNamespace:
257+
// OwnNamespace mode should not have SingleNamespace configuration
258+
if config.InstallMode.SingleNamespaceInstallMode != nil {
259+
errs = append(errs, fmt.Errorf("singleNamespaceInstallMode configuration should not be provided when installMode is OwnNamespace"))
260+
}
261+
default:
262+
// Invalid install mode string
263+
errs = append(errs, fmt.Errorf("invalid installMode %q, must be one of: %s, %s, %s",
264+
config.InstallMode, InstallModeAllNamespaces, InstallModeSingleNamespace, InstallModeOwnNamespace))
265+
}
266+
267+
return errs
268+
}

‎internal/operator-controller/rukpak/render/render_test.go‎

Lines changed: 116 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -267,3 +267,119 @@ func Test_BundleValidatorCallsAllValidationFnsInOrder(t *testing.T) {
267267
require.NoError(t, val.Validate(nil))
268268
require.Equal(t, "hi", actual)
269269
}
270+
271+
func Test_BundleRenderer_ValidatesBundleConfig(t *testing.T) {
272+
for _, tc := range []struct {
273+
name string
274+
config *render.BundleConfig
275+
expectedErr string
276+
}{
277+
{
278+
name: "No config provided - should pass",
279+
config: &render.BundleConfig{},
280+
expectedErr: "",
281+
},
282+
{
283+
name: "AllNamespaces mode - valid config",
284+
config: &render.BundleConfig{
285+
InstallMode: &render.InstallModeConfig{
286+
InstallMode: render.InstallModeAllNamespaces,
287+
},
288+
},
289+
expectedErr: "",
290+
},
291+
{
292+
name: "AllNamespaces mode - rejects SingleNamespace config",
293+
config: &render.BundleConfig{
294+
InstallMode: &render.InstallModeConfig{
295+
InstallMode: render.InstallModeAllNamespaces,
296+
SingleNamespaceInstallMode: &render.SingleNamespaceInstallModeConfig{
297+
WatchNamespace: "test-namespace",
298+
},
299+
},
300+
},
301+
expectedErr: "singleNamespaceInstallMode configuration should not be provided when installMode is AllNamespaces",
302+
},
303+
{
304+
name: "SingleNamespace mode - valid config",
305+
config: &render.BundleConfig{
306+
InstallMode: &render.InstallModeConfig{
307+
InstallMode: render.InstallModeSingleNamespace,
308+
SingleNamespaceInstallMode: &render.SingleNamespaceInstallModeConfig{
309+
WatchNamespace: "test-namespace",
310+
},
311+
},
312+
},
313+
expectedErr: "",
314+
},
315+
{
316+
name: "SingleNamespace mode - missing config",
317+
config: &render.BundleConfig{
318+
InstallMode: &render.InstallModeConfig{
319+
InstallMode: render.InstallModeSingleNamespace,
320+
},
321+
},
322+
expectedErr: "singleNamespaceInstallMode configuration is required when installMode is SingleNamespace",
323+
},
324+
{
325+
name: "SingleNamespace mode - empty watchNamespace",
326+
config: &render.BundleConfig{
327+
InstallMode: &render.InstallModeConfig{
328+
InstallMode: render.InstallModeSingleNamespace,
329+
SingleNamespaceInstallMode: &render.SingleNamespaceInstallModeConfig{
330+
WatchNamespace: "",
331+
},
332+
},
333+
},
334+
expectedErr: "watchNamespace is required in singleNamespaceInstallMode configuration",
335+
},
336+
{
337+
name: "OwnNamespace mode - valid config",
338+
config: &render.BundleConfig{
339+
InstallMode: &render.InstallModeConfig{
340+
InstallMode: render.InstallModeOwnNamespace,
341+
},
342+
},
343+
expectedErr: "",
344+
},
345+
{
346+
name: "OwnNamespace mode - rejects SingleNamespace config",
347+
config: &render.BundleConfig{
348+
InstallMode: &render.InstallModeConfig{
349+
InstallMode: render.InstallModeOwnNamespace,
350+
SingleNamespaceInstallMode: &render.SingleNamespaceInstallModeConfig{
351+
WatchNamespace: "test-namespace",
352+
},
353+
},
354+
},
355+
expectedErr: "singleNamespaceInstallMode configuration should not be provided when installMode is OwnNamespace",
356+
},
357+
{
358+
name: "Invalid install mode",
359+
config: &render.BundleConfig{
360+
InstallMode: &render.InstallModeConfig{
361+
InstallMode: "InvalidMode",
362+
},
363+
},
364+
expectedErr: "invalid installMode \"InvalidMode\"",
365+
},
366+
} {
367+
t.Run(tc.name, func(t *testing.T) {
368+
renderer := render.BundleRenderer{}
369+
_, err := renderer.Render(
370+
bundle.RegistryV1{
371+
CSV: MakeCSV(WithInstallModeSupportFor(v1alpha1.InstallModeTypeAllNamespaces, v1alpha1.InstallModeTypeSingleNamespace, v1alpha1.InstallModeTypeOwnNamespace)),
372+
},
373+
"install-namespace",
374+
render.WithBundleConfig(tc.config),
375+
)
376+
377+
if tc.expectedErr == "" {
378+
require.NoError(t, err)
379+
} else {
380+
require.Error(t, err)
381+
require.Contains(t, err.Error(), tc.expectedErr)
382+
}
383+
})
384+
}
385+
}

0 commit comments

Comments
 (0)