1package cli
2
3import (
4 "context"
5 "testing"
6 "time"
7
8 inmocks "github.com/bnema/gordon/internal/boundaries/in/mocks"
9 "github.com/bnema/gordon/internal/domain"
10 "github.com/stretchr/testify/mock"
11 "github.com/stretchr/testify/require"
12)
13
14func TestLocalControlPlane_GetStatus(t *testing.T) {
15 t.Parallel()
16
17 configSvc := inmocks.NewMockConfigService(t)
18 containerSvc := inmocks.NewMockContainerService(t)
19
20 ctx := context.Background()
21 configSvc.EXPECT().GetRoutes(mock.Anything).Return([]domain.Route{{Domain: "app.local", Image: "repo/app:latest"}})
22 configSvc.EXPECT().GetRegistryDomain().Return("registry.local")
23 configSvc.EXPECT().GetRegistryPort().Return(5000)
24 configSvc.EXPECT().GetServerPort().Return(80)
25 configSvc.EXPECT().IsAutoRouteEnabled().Return(true)
26 configSvc.EXPECT().IsNetworkIsolationEnabled().Return(true)
27 containerSvc.EXPECT().List(mock.Anything).Return(map[string]*domain.Container{
28 "app.local": {ID: "abc123", Status: "running"},
29 })
30
31 cp := &localControlPlane{configSvc: configSvc, containerSvc: containerSvc}
32 status, err := cp.GetStatus(ctx)
33 require.NoError(t, err)
34 require.Equal(t, 1, status.Routes)
35 require.Equal(t, "registry.local", status.RegistryDomain)
36 require.Equal(t, "running", status.ContainerStatus["app.local"])
37}
38
39func TestLocalControlPlane_Backups(t *testing.T) {
40 t.Parallel()
41
42 backupSvc := inmocks.NewMockBackupService(t)
43 ctx := context.Background()
44
45 now := time.Now().UTC()
46 jobs := []domain.BackupJob{{ID: "b1", Domain: "app.local", DBName: "postgres", Status: domain.BackupStatusCompleted, StartedAt: now}}
47 backupSvc.EXPECT().ListBackups(mock.Anything, "app.local").Return(jobs, nil)
48 backupSvc.EXPECT().Status(mock.Anything).Return(jobs, nil)
49 backupSvc.EXPECT().RunBackup(mock.Anything, "app.local", "postgres").Return(&domain.BackupResult{Job: jobs[0]}, nil)
50 backupSvc.EXPECT().DetectDatabases(mock.Anything, "app.local").Return([]domain.DBInfo{{Type: domain.DBTypePostgreSQL, Name: "postgres", Host: "postgres", Port: 5432}}, nil)
51
52 cp := &localControlPlane{backupSvc: backupSvc}
53
54 list, err := cp.ListBackups(ctx, "app.local")
55 require.NoError(t, err)
56 require.Len(t, list, 1)
57
58 status, err := cp.BackupStatus(ctx)
59 require.NoError(t, err)
60 require.Len(t, status, 1)
61
62 run, err := cp.RunBackup(ctx, "app.local", "postgres")
63 require.NoError(t, err)
64 require.NotNil(t, run.Backup)
65 require.Equal(t, "b1", run.Backup.ID)
66
67 dbs, err := cp.DetectDatabases(ctx, "app.local")
68 require.NoError(t, err)
69 require.Len(t, dbs, 1)
70 require.Equal(t, "postgres", dbs[0].Name)
71}
72
73func TestLocalControlPlane_ListTags(t *testing.T) {
74 t.Parallel()
75
76 registrySvc := inmocks.NewMockRegistryService(t)
77 registrySvc.EXPECT().ListTags(mock.Anything, "repo/app").Return([]string{"v1.0.0", "latest"}, nil)
78
79 cp := &localControlPlane{registrySvc: registrySvc}
80 tags, err := cp.ListTags(context.Background(), "repo/app")
81 require.NoError(t, err)
82 require.Equal(t, []string{"v1.0.0", "latest"}, tags)
83}
84
85func TestLocalControlPlane_RestartWithAttachments(t *testing.T) {
86 t.Parallel()
87
88 containerSvc := inmocks.NewMockContainerService(t)
89 containerSvc.EXPECT().SyncContainers(mock.Anything).Return(nil)
90 containerSvc.EXPECT().Restart(mock.Anything, "app.local", true).Return(nil)
91
92 cp := &localControlPlane{containerSvc: containerSvc}
93 result, err := cp.Restart(context.Background(), "app.local", true)
94 require.NoError(t, err)
95 require.Equal(t, "app.local", result.Domain)
96}
97
98func TestLocalControlPlane_GetContainerLogs(t *testing.T) {
99 t.Parallel()
100
101 logSvc := inmocks.NewMockLogService(t)
102 logSvc.EXPECT().GetContainerLogs(mock.Anything, "app.local", 50).Return([]string{"line1", "line2"}, nil)
103
104 cp := &localControlPlane{logSvc: logSvc}
105 lines, err := cp.GetContainerLogs(context.Background(), "app.local", 50)
106 require.NoError(t, err)
107 require.Equal(t, []string{"line1", "line2"}, lines)
108}