Skip to content

Commit 04c1bcd

Browse files
authored
Revert "feat(v3): add support for local registry templates" (#2678)
Revert "feat(v3): add support for local registry templates (#2672)" This reverts commit 129dc03.
1 parent 1a47019 commit 04c1bcd

File tree

10 files changed

+11
-515
lines changed

10 files changed

+11
-515
lines changed

api/controllers/app/install/controller.go

Lines changed: 2 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -47,7 +47,6 @@ type InstallController struct {
4747
clusterID string
4848
airgapBundle string
4949
privateCACertConfigMapName string
50-
registrySettings *types.RegistrySettings
5150
}
5251

5352
type InstallControllerOption func(*InstallController)
@@ -124,12 +123,6 @@ func WithAirgapBundle(airgapBundle string) InstallControllerOption {
124123
}
125124
}
126125

127-
func WithRegistrySettings(registrySettings *types.RegistrySettings) InstallControllerOption {
128-
return func(c *InstallController) {
129-
c.registrySettings = registrySettings
130-
}
131-
}
132-
133126
func WithPrivateCACertConfigMapName(configMapName string) InstallControllerOption {
134127
return func(c *InstallController) {
135128
c.privateCACertConfigMapName = configMapName
@@ -191,21 +184,13 @@ func NewInstallController(opts ...InstallControllerOption) (*InstallController,
191184
}
192185

193186
if controller.appReleaseManager == nil {
194-
var appReleaseManagerOpts []appreleasemanager.AppReleaseManagerOption
195-
appReleaseManagerOpts = append(appReleaseManagerOpts,
187+
appReleaseManager, err := appreleasemanager.NewAppReleaseManager(
188+
*controller.releaseData.AppConfig,
196189
appreleasemanager.WithLogger(controller.logger),
197190
appreleasemanager.WithReleaseData(controller.releaseData),
198191
appreleasemanager.WithLicense(license),
199192
appreleasemanager.WithPrivateCACertConfigMapName(controller.privateCACertConfigMapName),
200193
)
201-
202-
// Add registry settings if available
203-
appReleaseManagerOpts = append(appReleaseManagerOpts, appreleasemanager.WithRegistrySettings(controller.registrySettings))
204-
205-
appReleaseManager, err := appreleasemanager.NewAppReleaseManager(
206-
*controller.releaseData.AppConfig,
207-
appReleaseManagerOpts...,
208-
)
209194
if err != nil {
210195
return nil, fmt.Errorf("create app release manager: %w", err)
211196
}

api/controllers/linux/install/controller.go

Lines changed: 1 addition & 22 deletions
Original file line numberDiff line numberDiff line change
@@ -21,9 +21,7 @@ import (
2121
"github.com/replicatedhq/embedded-cluster/pkg/metrics"
2222
"github.com/replicatedhq/embedded-cluster/pkg/release"
2323
"github.com/replicatedhq/embedded-cluster/pkg/runtimeconfig"
24-
kotsv1beta1 "github.com/replicatedhq/kotskinds/apis/kots/v1beta1"
2524
"github.com/sirupsen/logrus"
26-
"sigs.k8s.io/yaml"
2725
)
2826

2927
type Controller interface {
@@ -256,8 +254,7 @@ func NewInstallController(opts ...InstallControllerOption) (*InstallController,
256254

257255
// Initialize the app controller with the state machine first
258256
if controller.InstallController == nil {
259-
var appControllerOpts []appcontroller.InstallControllerOption
260-
appControllerOpts = append(appControllerOpts,
257+
appInstallController, err := appcontroller.NewInstallController(
261258
appcontroller.WithStateMachine(controller.stateMachine),
262259
appcontroller.WithLogger(controller.logger),
263260
appcontroller.WithStore(controller.store),
@@ -268,24 +265,6 @@ func NewInstallController(opts ...InstallControllerOption) (*InstallController,
268265
appcontroller.WithAirgapBundle(controller.airgapBundle),
269266
appcontroller.WithPrivateCACertConfigMapName(adminconsole.PrivateCASConfigMapName), // Linux installations use the ConfigMap
270267
)
271-
272-
// Detect registry settings and pass to app controller
273-
var license *kotsv1beta1.License
274-
if controller.license != nil {
275-
// Parse license from bytes
276-
var parsedLicense kotsv1beta1.License
277-
if err := yaml.Unmarshal(controller.license, &parsedLicense); err != nil {
278-
return nil, fmt.Errorf("failed to parse license data: %w", err)
279-
}
280-
license = &parsedLicense
281-
}
282-
registrySettings, err := controller.detectRegistrySettings(license)
283-
if err != nil {
284-
return nil, fmt.Errorf("failed to detect registry settings: %w", err)
285-
}
286-
appControllerOpts = append(appControllerOpts, appcontroller.WithRegistrySettings(registrySettings))
287-
288-
appInstallController, err := appcontroller.NewInstallController(appControllerOpts...)
289268
if err != nil {
290269
return nil, fmt.Errorf("create app install controller: %w", err)
291270
}

api/controllers/linux/install/registry.go

Lines changed: 0 additions & 55 deletions
This file was deleted.

api/controllers/linux/install/registry_test.go

Lines changed: 0 additions & 112 deletions
This file was deleted.

api/internal/managers/app/release/manager.go

Lines changed: 2 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,6 @@ type appReleaseManager struct {
2626
license *kotsv1beta1.License
2727
logger logrus.FieldLogger
2828
privateCACertConfigMapName string
29-
registrySettings *types.RegistrySettings
3029
}
3130

3231
type AppReleaseManagerOption func(*appReleaseManager)
@@ -55,12 +54,6 @@ func WithLicense(license *kotsv1beta1.License) AppReleaseManagerOption {
5554
}
5655
}
5756

58-
func WithRegistrySettings(registrySettings *types.RegistrySettings) AppReleaseManagerOption {
59-
return func(m *appReleaseManager) {
60-
m.registrySettings = registrySettings
61-
}
62-
}
63-
6457
func WithPrivateCACertConfigMapName(configMapName string) AppReleaseManagerOption {
6558
return func(m *appReleaseManager) {
6659
m.privateCACertConfigMapName = configMapName
@@ -86,17 +79,12 @@ func NewAppReleaseManager(config kotsv1beta1.Config, opts ...AppReleaseManagerOp
8679
}
8780

8881
if manager.templateEngine == nil {
89-
var templateOpts []template.EngineOption
90-
templateOpts = append(templateOpts,
82+
manager.templateEngine = template.NewEngine(
83+
&manager.rawConfig,
9184
template.WithLicense(manager.license),
9285
template.WithReleaseData(manager.releaseData),
9386
template.WithPrivateCACertConfigMapName(manager.privateCACertConfigMapName),
9487
)
95-
96-
// Add registry settings if available
97-
templateOpts = append(templateOpts, template.WithRegistrySettings(manager.registrySettings))
98-
99-
manager.templateEngine = template.NewEngine(&manager.rawConfig, templateOpts...)
10088
}
10189

10290
return manager, nil

api/pkg/template/engine.go

Lines changed: 0 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -28,9 +28,6 @@ type Engine struct {
2828
license *kotsv1beta1.License
2929
releaseData *release.ReleaseData
3030

31-
// Registry settings for template functions
32-
registrySettings *types.RegistrySettings
33-
3431
// Internal state
3532
configValues types.AppConfigValues
3633
prevConfigValues types.AppConfigValues
@@ -64,12 +61,6 @@ func WithReleaseData(releaseData *release.ReleaseData) EngineOption {
6461
}
6562
}
6663

67-
func WithRegistrySettings(registrySettings *types.RegistrySettings) EngineOption {
68-
return func(e *Engine) {
69-
e.registrySettings = registrySettings
70-
}
71-
}
72-
7364
func WithPrivateCACertConfigMapName(configMapName string) EngineOption {
7465
return func(e *Engine) {
7566
e.privateCACertConfigMapName = configMapName

api/pkg/template/execute.go

Lines changed: 6 additions & 49 deletions
Original file line numberDiff line numberDiff line change
@@ -168,13 +168,12 @@ func (e *Engine) getFuncMap() template.FuncMap {
168168
"HumanSize": e.humanSize,
169169
"YamlEscape": e.yamlEscape,
170170

171-
// Registry template functions
172-
"HasLocalRegistry": e.hasLocalRegistry,
173-
"LocalRegistryHost": e.localRegistryHost,
174-
"LocalRegistryNamespace": e.localRegistryNamespace,
175-
"LocalRegistryAddress": e.localRegistryAddress,
176-
"LocalImageName": func() string { return "" }, // TODO: implement later
177-
"ImagePullSecretName": e.imagePullSecretName,
171+
// TODO: implement
172+
"HasLocalRegistry": func() bool { return false },
173+
"LocalRegistryHost": func() string { return "" },
174+
"LocalRegistryNamespace": func() string { return "" },
175+
"LocalImageName": func() string { return "" },
176+
"ImagePullSecretName": func() string { return "" },
178177
}
179178
}
180179

@@ -190,45 +189,3 @@ func (e *Engine) recordDependency(dependency string) {
190189
}
191190
}
192191
}
193-
194-
// Registry template functions
195-
196-
// hasLocalRegistry returns true when local registry is available
197-
func (e *Engine) hasLocalRegistry() bool {
198-
if e.registrySettings == nil {
199-
return false
200-
}
201-
return e.registrySettings.HasLocalRegistry
202-
}
203-
204-
// localRegistryHost returns the registry host with port
205-
func (e *Engine) localRegistryHost() string {
206-
if e.registrySettings == nil {
207-
return ""
208-
}
209-
return e.registrySettings.Host
210-
}
211-
212-
// localRegistryNamespace returns the namespace for the local registry
213-
func (e *Engine) localRegistryNamespace() string {
214-
if e.registrySettings == nil {
215-
return ""
216-
}
217-
return e.registrySettings.Namespace
218-
}
219-
220-
// localRegistryAddress returns the full registry address with namespace prefix
221-
func (e *Engine) localRegistryAddress() string {
222-
if e.registrySettings == nil {
223-
return ""
224-
}
225-
return e.registrySettings.Address
226-
}
227-
228-
// imagePullSecretName returns standardized secret name pattern
229-
func (e *Engine) imagePullSecretName() string {
230-
if e.registrySettings == nil {
231-
return ""
232-
}
233-
return e.registrySettings.ImagePullSecretName
234-
}

0 commit comments

Comments
 (0)