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_Backups(t *testing.T) {
41 t.Parallel()
42
43 backupSvc := inmocks.NewMockBackupService(t)
44 ctx := context.Background()
45
46 now := time.Now().UTC()
47 jobs := []domain.BackupJob{{ID: "b1", Domain: "app.local", DBName: "postgres", Status: domain.BackupStatusCompleted, StartedAt: now}}
48 backupSvc.EXPECT().ListBackups(mock.Anything, "app.local").Return(jobs, nil)
49 backupSvc.EXPECT().Status(mock.Anything).Return(jobs, nil)
50 backupSvc.EXPECT().RunBackup(mock.Anything, "app.local", "postgres").Return(&domain.BackupResult{Job: jobs[0]}, nil)
51 backupSvc.EXPECT().DetectDatabases(mock.Anything, "app.local").Return([]domain.DBInfo{{Type: domain.DBTypePostgreSQL, Name: "postgres", Host: "postgres", Port: 5432}}, nil)
52
53 cp := &localControlPlane{backupSvc: backupSvc}
54
55 list, err := cp.ListBackups(ctx, "app.local")
56 require.NoError(t, err)
57 require.Len(t, list, 1)
58
59 status, err := cp.BackupStatus(ctx)
60 require.NoError(t, err)
61 require.Len(t, status, 1)
62
63 run, err := cp.RunBackup(ctx, "app.local", "postgres")
64 require.NoError(t, err)
65 require.NotNil(t, run.Backup)
66 require.Equal(t, "b1", run.Backup.ID)
67
68 dbs, err := cp.DetectDatabases(ctx, "app.local")
69 require.NoError(t, err)
70 require.Len(t, dbs, 1)
71 require.Equal(t, "postgres", dbs[0].Name)
72}
73
74func TestLocalControlPlane_ListTags(t *testing.T) {
75 t.Parallel()
76
77 registrySvc := inmocks.NewMockRegistryService(t)
78 registrySvc.EXPECT().ListTags(mock.Anything, "repo/app").Return([]string{"v1.0.0", "latest"}, nil)
79
80 cp := &localControlPlane{registrySvc: registrySvc}
81 tags, err := cp.ListTags(context.Background(), "repo/app")
82 require.NoError(t, err)
83 require.Equal(t, []string{"v1.0.0", "latest"}, tags)
84}
85
86func TestLocalControlPlane_RestartWithAttachments(t *testing.T) {
87 t.Parallel()
88
89 containerSvc := inmocks.NewMockContainerService(t)
90 containerSvc.EXPECT().SyncContainers(mock.Anything).Return(nil)
91 containerSvc.EXPECT().Restart(mock.Anything, "app.local", true).Return(nil)
92
93 cp := &localControlPlane{containerSvc: containerSvc}
94 result, err := cp.Restart(context.Background(), "app.local", true)
95 require.NoError(t, err)
96 require.Equal(t, "app.local", result.Domain)
97}
98
99func TestLocalControlPlane_GetTLSStatusWithoutService(t *testing.T) {
100 t.Parallel()
101
102 cp := &localControlPlane{}
103 status, err := cp.GetTLSStatus(context.Background())
104 require.NoError(t, err)
105 require.Equal(t, &dto.TLSStatusResponse{
106 ACMEEnabled: false,
107 SelectionReason: "public TLS service not configured",
108 }, status)
109}
110
111func TestLocalControlPlane_GetContainerLogs(t *testing.T) {
112 t.Parallel()
113
114 logSvc := inmocks.NewMockLogService(t)
115 logSvc.EXPECT().GetContainerLogs(mock.Anything, "app.local", 50).Return([]string{"line1", "line2"}, nil)
116
117 cp := &localControlPlane{logSvc: logSvc}
118 lines, err := cp.GetContainerLogs(context.Background(), "app.local", 50)
119 require.NoError(t, err)
120 require.Equal(t, []string{"line1", "line2"}, lines)
121}