1package cli
2
3import (
4 "context"
5 "testing"
6 "time"
7
8 "github.com/bnema/gordon/internal/adapters/dto"
9 inmocks "github.com/bnema/gordon/internal/boundaries/in/mocks"
10 "github.com/bnema/gordon/internal/domain"
11 "github.com/stretchr/testify/mock"
12 "github.com/stretchr/testify/require"
13)
14
15func TestLocalControlPlane_GetStatus(t *testing.T) {
16 t.Parallel()
17
18 configSvc := inmocks.NewMockConfigService(t)
19 containerSvc := inmocks.NewMockContainerService(t)
20
21 ctx := context.Background()
22 configSvc.EXPECT().GetRoutes(mock.Anything).Return([]domain.Route{{Domain: "app.local", Image: "repo/app:latest"}})
23 configSvc.EXPECT().GetRegistryDomain().Return("registry.local")
24 configSvc.EXPECT().GetRegistryPort().Return(5000)
25 configSvc.EXPECT().GetServerPort().Return(80)
26 configSvc.EXPECT().IsAutoRouteEnabled().Return(true)
27 configSvc.EXPECT().IsNetworkIsolationEnabled().Return(true)
28 containerSvc.EXPECT().List(mock.Anything).Return(map[string]*domain.Container{
29 "app.local": {ID: "abc123", Status: "running"},
30 })
31
32 cp := &localControlPlane{configSvc: configSvc, containerSvc: containerSvc}
33 status, err := cp.GetStatus(ctx)
34 require.NoError(t, err)
35 require.Equal(t, 1, status.Routes)
36 require.Equal(t, "registry.local", status.RegistryDomain)
37 require.Equal(t, "running", status.ContainerStatus["app.local"])
38}
39
40func TestLocalControlPlane_DeployUsesInternalDeployContext(t *testing.T) {
41 t.Parallel()
42
43 configSvc := inmocks.NewMockConfigService(t)
44 containerSvc := inmocks.NewMockContainerService(t)
45
46 ctx := context.Background()
47 route := &domain.Route{Domain: "app.local", Image: "repo/app:latest"}
48
49 require.False(t, domain.IsInternalDeploy(ctx))
50
51 configSvc.EXPECT().GetRoute(mock.Anything, "app.local").Return(route, nil)
52 containerSvc.EXPECT().Deploy(mock.Anything, *route).RunAndReturn(func(deployCtx context.Context, deployedRoute domain.Route) (*domain.Container, error) {
53 require.True(t, domain.IsInternalDeploy(deployCtx))
54 require.Equal(t, *route, deployedRoute)
55 return &domain.Container{ID: "container-1"}, nil
56 })
57
58 cp := &localControlPlane{configSvc: configSvc, containerSvc: containerSvc}
59 result, err := cp.Deploy(ctx, "app.local")
60 require.NoError(t, err)
61 require.NotNil(t, result)
62 require.Equal(t, "deployed", result.Status)
63 require.Equal(t, "app.local", result.Domain)
64 require.Equal(t, "container-1", result.ContainerID)
65}
66
67func TestLocalControlPlane_Backups(t *testing.T) {
68 t.Parallel()
69
70 backupSvc := inmocks.NewMockBackupService(t)
71 ctx := context.Background()
72
73 now := time.Now().UTC()
74 jobs := []domain.BackupJob{{ID: "b1", Domain: "app.local", DBName: "postgres", Status: domain.BackupStatusCompleted, StartedAt: now}}
75 backupSvc.EXPECT().ListBackups(mock.Anything, "app.local").Return(jobs, nil)
76 backupSvc.EXPECT().Status(mock.Anything).Return(jobs, nil)
77 backupSvc.EXPECT().RunBackup(mock.Anything, "app.local", "postgres").Return(&domain.BackupResult{Job: jobs[0]}, nil)
78 backupSvc.EXPECT().DetectDatabases(mock.Anything, "app.local").Return([]domain.DBInfo{{Type: domain.DBTypePostgreSQL, Name: "postgres", Host: "postgres", Port: 5432}}, nil)
79
80 cp := &localControlPlane{backupSvc: backupSvc}
81
82 list, err := cp.ListBackups(ctx, "app.local")
83 require.NoError(t, err)
84 require.Len(t, list, 1)
85
86 status, err := cp.BackupStatus(ctx)
87 require.NoError(t, err)
88 require.Len(t, status, 1)
89
90 run, err := cp.RunBackup(ctx, "app.local", "postgres")
91 require.NoError(t, err)
92 require.NotNil(t, run.Backup)
93 require.Equal(t, "b1", run.Backup.ID)
94
95 dbs, err := cp.DetectDatabases(ctx, "app.local")
96 require.NoError(t, err)
97 require.Len(t, dbs, 1)
98 require.Equal(t, "postgres", dbs[0].Name)
99}
100
101func TestLocalControlPlane_ListTags(t *testing.T) {
102 t.Parallel()
103
104 registrySvc := inmocks.NewMockRegistryService(t)
105 registrySvc.EXPECT().ListTags(mock.Anything, "repo/app").Return([]string{"v1.0.0", "latest"}, nil)
106
107 cp := &localControlPlane{registrySvc: registrySvc}
108 tags, err := cp.ListTags(context.Background(), "repo/app")
109 require.NoError(t, err)
110 require.Equal(t, []string{"v1.0.0", "latest"}, tags)
111}
112
113func TestLocalControlPlane_RestartWithAttachments(t *testing.T) {
114 t.Parallel()
115
116 containerSvc := inmocks.NewMockContainerService(t)
117 containerSvc.EXPECT().SyncContainers(mock.Anything).Return(nil)
118 containerSvc.EXPECT().Restart(mock.Anything, "app.local", true).Return(nil)
119
120 cp := &localControlPlane{containerSvc: containerSvc}
121 result, err := cp.Restart(context.Background(), "app.local", true)
122 require.NoError(t, err)
123 require.Equal(t, "app.local", result.Domain)
124}
125
126func TestLocalControlPlane_GetTLSStatusWithoutService(t *testing.T) {
127 t.Parallel()
128
129 cp := &localControlPlane{}
130 status, err := cp.GetTLSStatus(context.Background())
131 require.NoError(t, err)
132 require.Equal(t, &dto.TLSStatusResponse{
133 ACMEEnabled: false,
134 SelectionReason: "public TLS service not configured",
135 }, status)
136}
137
138func TestLocalControlPlane_GetContainerLogs(t *testing.T) {
139 t.Parallel()
140
141 logSvc := inmocks.NewMockLogService(t)
142 logSvc.EXPECT().GetContainerLogs(mock.Anything, "app.local", 50).Return([]string{"line1", "line2"}, nil)
143
144 cp := &localControlPlane{logSvc: logSvc}
145 lines, err := cp.GetContainerLogs(context.Background(), "app.local", 50)
146 require.NoError(t, err)
147 require.Equal(t, []string{"line1", "line2"}, lines)
148}