Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
16 changes: 12 additions & 4 deletions pkg/pipelines/down.go
Original file line number Diff line number Diff line change
Expand Up @@ -6,14 +6,15 @@ import (
"os"
"path/filepath"

"github.com/windsorcli/cli/pkg/di"
"github.com/windsorcli/cli/pkg/composer/blueprint"
envvars "github.com/windsorcli/cli/pkg/context/env"
"github.com/windsorcli/cli/pkg/context/shell"
"github.com/windsorcli/cli/pkg/di"
"github.com/windsorcli/cli/pkg/provisioner/kubernetes"
k8sclient "github.com/windsorcli/cli/pkg/provisioner/kubernetes/client"
terraforminfra "github.com/windsorcli/cli/pkg/provisioner/terraform"
"github.com/windsorcli/cli/pkg/composer/blueprint"
"github.com/windsorcli/cli/pkg/context/shell"
"github.com/windsorcli/cli/pkg/workstation/network"
"github.com/windsorcli/cli/pkg/workstation/services"
"github.com/windsorcli/cli/pkg/workstation/virt"
)

Expand Down Expand Up @@ -103,7 +104,14 @@ func (p *DownPipeline) Initialize(injector di.Injector, ctx context.Context) err
}

if p.networkManager != nil {
if err := p.networkManager.Initialize(); err != nil {
resolvedServices, _ := p.injector.ResolveAll(new(services.Service))
serviceList := make([]services.Service, 0, len(resolvedServices))
for _, svc := range resolvedServices {
if s, ok := svc.(services.Service); ok {
serviceList = append(serviceList, s)
}
}
if err := p.networkManager.Initialize(serviceList); err != nil {
return fmt.Errorf("failed to initialize network manager: %w", err)
}
}
Expand Down
9 changes: 5 additions & 4 deletions pkg/pipelines/down_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -8,13 +8,14 @@ import (
"testing"

blueprintv1alpha1 "github.com/windsorcli/cli/api/v1alpha1"
"github.com/windsorcli/cli/pkg/composer/blueprint"
"github.com/windsorcli/cli/pkg/context/config"
envvars "github.com/windsorcli/cli/pkg/context/env"
"github.com/windsorcli/cli/pkg/context/shell"
"github.com/windsorcli/cli/pkg/provisioner/kubernetes"
terraforminfra "github.com/windsorcli/cli/pkg/provisioner/terraform"
"github.com/windsorcli/cli/pkg/composer/blueprint"
"github.com/windsorcli/cli/pkg/context/shell"
"github.com/windsorcli/cli/pkg/workstation/network"
"github.com/windsorcli/cli/pkg/workstation/services"
"github.com/windsorcli/cli/pkg/workstation/virt"
)

Expand Down Expand Up @@ -84,7 +85,7 @@ contexts:

// Setup network manager mock
mockNetworkManager := network.NewMockNetworkManager()
mockNetworkManager.InitializeFunc = func() error { return nil }
mockNetworkManager.InitializeFunc = func([]services.Service) error { return nil }
baseMocks.Injector.Register("networkManager", mockNetworkManager)

// Setup stack mock
Expand Down Expand Up @@ -382,7 +383,7 @@ func TestDownPipeline_Initialize(t *testing.T) {
mocks := setupDownMocks(t)

// Set up a failing network manager mock
mocks.NetworkManager.InitializeFunc = func() error {
mocks.NetworkManager.InitializeFunc = func([]services.Service) error {
return fmt.Errorf("network manager initialization failed")
}

Expand Down
2 changes: 1 addition & 1 deletion pkg/pipelines/init.go
Original file line number Diff line number Diff line change
Expand Up @@ -198,7 +198,7 @@ func (p *InitPipeline) Initialize(injector di.Injector, ctx context.Context) err
}

if p.networkManager != nil {
if err := p.networkManager.Initialize(); err != nil {
if err := p.networkManager.Initialize(p.services); err != nil {
return fmt.Errorf("failed to initialize network manager: %w", err)
}
}
Expand Down
14 changes: 11 additions & 3 deletions pkg/pipelines/up.go
Original file line number Diff line number Diff line change
Expand Up @@ -5,12 +5,13 @@ import (
"fmt"
"os"

"github.com/windsorcli/cli/pkg/di"
envvars "github.com/windsorcli/cli/pkg/context/env"
"github.com/windsorcli/cli/pkg/context/shell"
"github.com/windsorcli/cli/pkg/context/tools"
"github.com/windsorcli/cli/pkg/di"
terraforminfra "github.com/windsorcli/cli/pkg/provisioner/terraform"
"github.com/windsorcli/cli/pkg/context/shell"
"github.com/windsorcli/cli/pkg/workstation/network"
"github.com/windsorcli/cli/pkg/workstation/services"
"github.com/windsorcli/cli/pkg/workstation/virt"
)

Expand Down Expand Up @@ -105,7 +106,14 @@ func (p *UpPipeline) Initialize(injector di.Injector, ctx context.Context) error
}

if p.networkManager != nil {
if err := p.networkManager.Initialize(); err != nil {
resolvedServices, _ := p.injector.ResolveAll(new(services.Service))
serviceList := make([]services.Service, 0, len(resolvedServices))
for _, svc := range resolvedServices {
if s, ok := svc.(services.Service); ok {
serviceList = append(serviceList, s)
}
}
if err := p.networkManager.Initialize(serviceList); err != nil {
return fmt.Errorf("failed to initialize network manager: %w", err)
}
}
Expand Down
7 changes: 4 additions & 3 deletions pkg/pipelines/up_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -8,10 +8,11 @@ import (
blueprintv1alpha1 "github.com/windsorcli/cli/api/v1alpha1"
"github.com/windsorcli/cli/pkg/context/config"
envvars "github.com/windsorcli/cli/pkg/context/env"
"github.com/windsorcli/cli/pkg/context/shell"
"github.com/windsorcli/cli/pkg/context/tools"
terraforminfra "github.com/windsorcli/cli/pkg/provisioner/terraform"
"github.com/windsorcli/cli/pkg/context/shell"
"github.com/windsorcli/cli/pkg/workstation/network"
"github.com/windsorcli/cli/pkg/workstation/services"
"github.com/windsorcli/cli/pkg/workstation/virt"
)

Expand Down Expand Up @@ -87,7 +88,7 @@ contexts:

// Setup network manager mock
mockNetworkManager := network.NewMockNetworkManager()
mockNetworkManager.InitializeFunc = func() error { return nil }
mockNetworkManager.InitializeFunc = func([]services.Service) error { return nil }
mockNetworkManager.ConfigureGuestFunc = func() error { return nil }
mockNetworkManager.ConfigureHostRouteFunc = func() error { return nil }
mockNetworkManager.ConfigureDNSFunc = func() error { return nil }
Expand Down Expand Up @@ -206,7 +207,7 @@ func TestUpPipeline_Initialize(t *testing.T) {
{
name: "ReturnsErrorWhenNetworkManagerInitializeFails",
setupMock: func(mocks *UpMocks) {
mocks.NetworkManager.InitializeFunc = func() error {
mocks.NetworkManager.InitializeFunc = func([]services.Service) error {
return fmt.Errorf("network manager failed")
}
},
Expand Down
2 changes: 1 addition & 1 deletion pkg/project/project.go
Original file line number Diff line number Diff line change
Expand Up @@ -137,7 +137,7 @@ func (p *Project) Configure(flagOverrides map[string]any) error {
// if any step fails.
func (p *Project) Initialize(overwrite bool) error {
if p.Workstation != nil && p.Workstation.NetworkManager != nil {
if err := p.Workstation.NetworkManager.Initialize(); err != nil {
if err := p.Workstation.NetworkManager.Initialize(p.Workstation.Services); err != nil {
return fmt.Errorf("failed to initialize network manager: %w", err)
}
}
Expand Down
5 changes: 3 additions & 2 deletions pkg/workstation/network/colima_network.go
Original file line number Diff line number Diff line change
Expand Up @@ -9,6 +9,7 @@ import (
"github.com/windsorcli/cli/pkg/di"
"github.com/windsorcli/cli/pkg/context/shell"
"github.com/windsorcli/cli/pkg/context/shell/ssh"
"github.com/windsorcli/cli/pkg/workstation/services"
)

// The ColimaNetworkManager is a specialized network manager for Colima-based environments.
Expand Down Expand Up @@ -47,8 +48,8 @@ func NewColimaNetworkManager(injector di.Injector) *ColimaNetworkManager {

// Initialize sets up the ColimaNetworkManager by resolving dependencies for
// sshClient, shell, and secureShell from the injector.
func (n *ColimaNetworkManager) Initialize() error {
if err := n.BaseNetworkManager.Initialize(); err != nil {
func (n *ColimaNetworkManager) Initialize(services []services.Service) error {
if err := n.BaseNetworkManager.Initialize(services); err != nil {
return err
}

Expand Down
26 changes: 14 additions & 12 deletions pkg/workstation/network/colima_network_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -5,6 +5,8 @@ import (
"net"
"strings"
"testing"

"github.com/windsorcli/cli/pkg/workstation/services"
)

// =============================================================================
Expand All @@ -26,7 +28,7 @@ func TestColimaNetworkManager_Initialize(t *testing.T) {
mocks.Injector.Register("secureShell", "invalid")

// When initializing the network manager
err := manager.Initialize()
err := manager.Initialize([]services.Service{})

// Then an error should occur
if err == nil {
Expand All @@ -45,7 +47,7 @@ func TestColimaNetworkManager_Initialize(t *testing.T) {
mocks.Injector.Register("sshClient", "invalid")

// When initializing the network manager
err := manager.Initialize()
err := manager.Initialize([]services.Service{})

// Then an error should occur
if err == nil {
Expand All @@ -64,7 +66,7 @@ func TestColimaNetworkManager_Initialize(t *testing.T) {
mocks.Injector.Register("networkInterfaceProvider", "invalid")

// When initializing the network manager
err := manager.Initialize()
err := manager.Initialize([]services.Service{})

// Then an error should occur
if err == nil {
Expand All @@ -84,7 +86,7 @@ func TestColimaNetworkManager_ConfigureGuest(t *testing.T) {
mocks := setupMocks(t)
manager := NewColimaNetworkManager(mocks.Injector)
manager.shims = mocks.Shims
manager.Initialize()
manager.Initialize([]services.Service{})
return manager, mocks
}

Expand Down Expand Up @@ -148,7 +150,7 @@ func TestColimaNetworkManager_ConfigureGuest(t *testing.T) {
}

// When initializing the network manager
err := manager.Initialize()
err := manager.Initialize([]services.Service{})
if err != nil {
t.Fatalf("expected no error during initialization, got %v", err)
}
Expand All @@ -174,7 +176,7 @@ func TestColimaNetworkManager_ConfigureGuest(t *testing.T) {
}

// When initializing the network manager
err := manager.Initialize()
err := manager.Initialize([]services.Service{})
if err != nil {
t.Fatalf("expected no error during initialization, got %v", err)
}
Expand Down Expand Up @@ -203,7 +205,7 @@ func TestColimaNetworkManager_ConfigureGuest(t *testing.T) {
}

// When initializing the network manager
err := manager.Initialize()
err := manager.Initialize([]services.Service{})
if err != nil {
t.Fatalf("expected no error during initialization, got %v", err)
}
Expand Down Expand Up @@ -232,7 +234,7 @@ func TestColimaNetworkManager_ConfigureGuest(t *testing.T) {
}

// When initializing the network manager
err := manager.Initialize()
err := manager.Initialize([]services.Service{})
if err != nil {
t.Fatalf("expected no error during initialization, got %v", err)
}
Expand Down Expand Up @@ -267,7 +269,7 @@ func TestColimaNetworkManager_ConfigureGuest(t *testing.T) {
}

// When initializing the network manager
err := manager.Initialize()
err := manager.Initialize([]services.Service{})
if err != nil {
t.Fatalf("expected no error during initialization, got %v", err)
}
Expand All @@ -293,7 +295,7 @@ func TestColimaNetworkManager_ConfigureGuest(t *testing.T) {
}

// When initializing the network manager
err := manager.Initialize()
err := manager.Initialize([]services.Service{})
if err != nil {
t.Fatalf("expected no error during initialization, got %v", err)
}
Expand Down Expand Up @@ -322,7 +324,7 @@ func TestColimaNetworkManager_ConfigureGuest(t *testing.T) {
}

// When initializing the network manager
err := manager.Initialize()
err := manager.Initialize([]services.Service{})
if err != nil {
t.Fatalf("expected no error during initialization, got %v", err)
}
Expand All @@ -345,7 +347,7 @@ func TestColimaNetworkManager_getHostIP(t *testing.T) {
t.Helper()
mocks := setupMocks(t)
manager := NewColimaNetworkManager(mocks.Injector)
manager.Initialize()
manager.Initialize([]services.Service{})
return manager, mocks
}

Expand Down
6 changes: 4 additions & 2 deletions pkg/workstation/network/darwin_network_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -7,6 +7,8 @@ import (
"fmt"
"os"
"testing"

"github.com/windsorcli/cli/pkg/workstation/services"
)

// =============================================================================
Expand All @@ -19,7 +21,7 @@ func TestDarwinNetworkManager_ConfigureHostRoute(t *testing.T) {
mocks := setupMocks(t)
manager := NewBaseNetworkManager(mocks.Injector)
manager.shims = mocks.Shims
manager.Initialize()
manager.Initialize([]services.Service{})
return manager, mocks
}

Expand Down Expand Up @@ -167,7 +169,7 @@ func TestDarwinNetworkManager_ConfigureDNS(t *testing.T) {
mocks := setupMocks(t)
manager := NewBaseNetworkManager(mocks.Injector)
manager.shims = mocks.Shims
manager.Initialize()
manager.Initialize([]services.Service{})
return manager, mocks
}

Expand Down
6 changes: 4 additions & 2 deletions pkg/workstation/network/linux_network_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -8,6 +8,8 @@ import (
"os"
"strings"
"testing"

"github.com/windsorcli/cli/pkg/workstation/services"
)

// =============================================================================
Expand All @@ -20,7 +22,7 @@ func TestLinuxNetworkManager_ConfigureHostRoute(t *testing.T) {
mocks := setupMocks(t)
manager := NewBaseNetworkManager(mocks.Injector)
manager.shims = mocks.Shims
manager.Initialize()
manager.Initialize([]services.Service{})
return manager, mocks
}

Expand Down Expand Up @@ -169,7 +171,7 @@ func TestLinuxNetworkManager_ConfigureDNS(t *testing.T) {
mocks := setupMocks(t)
manager := NewBaseNetworkManager(mocks.Injector)
manager.shims = mocks.Shims
manager.Initialize()
manager.Initialize([]services.Service{})
return manager, mocks
}

Expand Down
12 changes: 8 additions & 4 deletions pkg/workstation/network/mock_network.go
Original file line number Diff line number Diff line change
@@ -1,6 +1,10 @@
package network

import "net"
import (
"net"

"github.com/windsorcli/cli/pkg/workstation/services"
)

// The MockNetworkManager is a test implementation of the NetworkManager interface.
// It provides mock implementations of network management functions for testing,
Expand All @@ -14,7 +18,7 @@ import "net"
// MockNetworkManager is a struct that simulates a network manager for testing purposes.
type MockNetworkManager struct {
NetworkManager
InitializeFunc func() error
InitializeFunc func([]services.Service) error
ConfigureHostRouteFunc func() error
ConfigureGuestFunc func() error
ConfigureDNSFunc func() error
Expand All @@ -34,9 +38,9 @@ func NewMockNetworkManager() *MockNetworkManager {
// =============================================================================

// Initialize calls the custom InitializeFunc if provided.
func (m *MockNetworkManager) Initialize() error {
func (m *MockNetworkManager) Initialize(services []services.Service) error {
if m.InitializeFunc != nil {
return m.InitializeFunc()
return m.InitializeFunc(services)
}
return nil
}
Expand Down
Loading
Loading