mirror of
https://github.com/coder/coder.git
synced 2025-07-06 15:41:45 +00:00
* feat: HA tailnet coordinator * fixup! feat: HA tailnet coordinator * fixup! feat: HA tailnet coordinator * remove printlns * close all connections on coordinator * impelement high availability feature * fixup! impelement high availability feature * fixup! impelement high availability feature * fixup! impelement high availability feature * fixup! impelement high availability feature * Add replicas * Add DERP meshing to arbitrary addresses * Move packages to highavailability folder * Move coordinator to high availability package * Add flags for HA * Rename to replicasync * Denest packages for replicas * Add test for multiple replicas * Fix coordination test * Add HA to the helm chart * Rename function pointer * Add warnings for HA * Add the ability to block endpoints * Add flag to disable P2P connections * Wow, I made the tests pass * Add replicas endpoint * Ensure close kills replica * Update sql * Add database latency to high availability * Pipe TLS to DERP mesh * Fix DERP mesh with TLS * Add tests for TLS * Fix replica sync TLS * Fix RootCA for replica meshing * Remove ID from replicasync * Fix getting certificates for meshing * Remove excessive locking * Fix linting * Store mesh key in the database * Fix replica key for tests * Fix types gen * Fix unlocking unlocked * Fix race in tests * Update enterprise/derpmesh/derpmesh.go Co-authored-by: Colin Adler <colin1adler@gmail.com> * Rename to syncReplicas * Reuse http client * Delete old replicas on a CRON * Fix race condition in connection tests * Fix linting * Fix nil type * Move pubsub to in-memory for twenty test * Add comment for configuration tweaking * Fix leak with transport * Fix close leak in derpmesh * Fix race when creating server * Remove handler update * Skip test on Windows * Fix DERP mesh test * Wrap HTTP handler replacement in mutex * Fix error message for relay * Fix API handler for normal tests * Fix speedtest * Fix replica resend * Fix derpmesh send * Ping async * Increase wait time of template version jobd * Fix race when closing replica sync * Add name to client * Log the derpmap being used * Don't connect if DERP is empty * Improve agent coordinator logging * Fix lock in coordinator * Fix relay addr * Fix race when updating durations * Fix client publish race * Run pubsub loop in a queue * Store agent nodes in order * Fix coordinator locking * Check for closed pipe Co-authored-by: Colin Adler <colin1adler@gmail.com>
187 lines
5.6 KiB
Go
187 lines
5.6 KiB
Go
package coderd_test
|
|
|
|
import (
|
|
"context"
|
|
"encoding/json"
|
|
"net/http"
|
|
"testing"
|
|
|
|
"github.com/stretchr/testify/assert"
|
|
"github.com/stretchr/testify/require"
|
|
"golang.org/x/xerrors"
|
|
|
|
"github.com/coder/coder/coderd/coderdtest"
|
|
"github.com/coder/coder/codersdk"
|
|
"github.com/coder/coder/enterprise/coderd/coderdenttest"
|
|
"github.com/coder/coder/enterprise/coderd/license"
|
|
"github.com/coder/coder/testutil"
|
|
)
|
|
|
|
func TestPostLicense(t *testing.T) {
|
|
t.Parallel()
|
|
|
|
t.Run("Success", func(t *testing.T) {
|
|
t.Parallel()
|
|
client := coderdenttest.New(t, nil)
|
|
_ = coderdtest.CreateFirstUser(t, client)
|
|
respLic := coderdenttest.AddLicense(t, client, coderdenttest.LicenseOptions{
|
|
AccountType: license.AccountTypeSalesforce,
|
|
AccountID: "testing",
|
|
AuditLog: true,
|
|
})
|
|
assert.GreaterOrEqual(t, respLic.ID, int32(0))
|
|
// just a couple spot checks for sanity
|
|
assert.Equal(t, "testing", respLic.Claims["account_id"])
|
|
features, ok := respLic.Claims["features"].(map[string]interface{})
|
|
require.True(t, ok)
|
|
assert.Equal(t, json.Number("1"), features[codersdk.FeatureAuditLog])
|
|
})
|
|
|
|
t.Run("Unauthorized", func(t *testing.T) {
|
|
t.Parallel()
|
|
client := coderdenttest.New(t, nil)
|
|
_, err := client.AddLicense(context.Background(), codersdk.AddLicenseRequest{
|
|
License: "content",
|
|
})
|
|
errResp := &codersdk.Error{}
|
|
if xerrors.As(err, &errResp) {
|
|
assert.Equal(t, 401, errResp.StatusCode())
|
|
} else {
|
|
t.Error("expected to get error status 401")
|
|
}
|
|
})
|
|
|
|
t.Run("Corrupted", func(t *testing.T) {
|
|
t.Parallel()
|
|
client := coderdenttest.New(t, nil)
|
|
_ = coderdtest.CreateFirstUser(t, client)
|
|
coderdenttest.AddLicense(t, client, coderdenttest.LicenseOptions{})
|
|
_, err := client.AddLicense(context.Background(), codersdk.AddLicenseRequest{
|
|
License: "invalid",
|
|
})
|
|
errResp := &codersdk.Error{}
|
|
if xerrors.As(err, &errResp) {
|
|
assert.Equal(t, 400, errResp.StatusCode())
|
|
} else {
|
|
t.Error("expected to get error status 400")
|
|
}
|
|
})
|
|
}
|
|
|
|
func TestGetLicense(t *testing.T) {
|
|
t.Parallel()
|
|
t.Run("Success", func(t *testing.T) {
|
|
t.Parallel()
|
|
client := coderdenttest.New(t, nil)
|
|
_ = coderdtest.CreateFirstUser(t, client)
|
|
ctx, cancel := context.WithTimeout(context.Background(), testutil.WaitLong)
|
|
defer cancel()
|
|
|
|
coderdenttest.AddLicense(t, client, coderdenttest.LicenseOptions{
|
|
AccountID: "testing",
|
|
AuditLog: true,
|
|
SCIM: true,
|
|
BrowserOnly: true,
|
|
TemplateRBAC: true,
|
|
})
|
|
|
|
coderdenttest.AddLicense(t, client, coderdenttest.LicenseOptions{
|
|
AccountID: "testing2",
|
|
AuditLog: true,
|
|
SCIM: true,
|
|
BrowserOnly: true,
|
|
Trial: true,
|
|
UserLimit: 200,
|
|
TemplateRBAC: false,
|
|
})
|
|
|
|
licenses, err := client.Licenses(ctx)
|
|
require.NoError(t, err)
|
|
require.Len(t, licenses, 2)
|
|
assert.Equal(t, int32(1), licenses[0].ID)
|
|
assert.Equal(t, "testing", licenses[0].Claims["account_id"])
|
|
assert.Equal(t, map[string]interface{}{
|
|
codersdk.FeatureUserLimit: json.Number("0"),
|
|
codersdk.FeatureAuditLog: json.Number("1"),
|
|
codersdk.FeatureSCIM: json.Number("1"),
|
|
codersdk.FeatureBrowserOnly: json.Number("1"),
|
|
codersdk.FeatureWorkspaceQuota: json.Number("0"),
|
|
codersdk.FeatureHighAvailability: json.Number("0"),
|
|
codersdk.FeatureTemplateRBAC: json.Number("1"),
|
|
}, licenses[0].Claims["features"])
|
|
assert.Equal(t, int32(2), licenses[1].ID)
|
|
assert.Equal(t, "testing2", licenses[1].Claims["account_id"])
|
|
assert.Equal(t, true, licenses[1].Claims["trial"])
|
|
assert.Equal(t, map[string]interface{}{
|
|
codersdk.FeatureUserLimit: json.Number("200"),
|
|
codersdk.FeatureAuditLog: json.Number("1"),
|
|
codersdk.FeatureSCIM: json.Number("1"),
|
|
codersdk.FeatureBrowserOnly: json.Number("1"),
|
|
codersdk.FeatureWorkspaceQuota: json.Number("0"),
|
|
codersdk.FeatureHighAvailability: json.Number("0"),
|
|
codersdk.FeatureTemplateRBAC: json.Number("0"),
|
|
}, licenses[1].Claims["features"])
|
|
})
|
|
}
|
|
|
|
func TestDeleteLicense(t *testing.T) {
|
|
t.Parallel()
|
|
t.Run("Empty", func(t *testing.T) {
|
|
t.Parallel()
|
|
client := coderdenttest.New(t, nil)
|
|
_ = coderdtest.CreateFirstUser(t, client)
|
|
ctx, cancel := context.WithTimeout(context.Background(), testutil.WaitLong)
|
|
defer cancel()
|
|
|
|
err := client.DeleteLicense(ctx, 1)
|
|
errResp := &codersdk.Error{}
|
|
if xerrors.As(err, &errResp) {
|
|
assert.Equal(t, 404, errResp.StatusCode())
|
|
} else {
|
|
t.Error("expected to get error status 404")
|
|
}
|
|
})
|
|
|
|
t.Run("BadID", func(t *testing.T) {
|
|
t.Parallel()
|
|
client := coderdenttest.New(t, nil)
|
|
_ = coderdtest.CreateFirstUser(t, client)
|
|
ctx, cancel := context.WithTimeout(context.Background(), testutil.WaitLong)
|
|
defer cancel()
|
|
|
|
resp, err := client.Request(ctx, http.MethodDelete, "/api/v2/licenses/drivers", nil)
|
|
require.NoError(t, err)
|
|
assert.Equal(t, http.StatusNotFound, resp.StatusCode)
|
|
require.NoError(t, resp.Body.Close())
|
|
})
|
|
|
|
t.Run("Success", func(t *testing.T) {
|
|
t.Parallel()
|
|
client := coderdenttest.New(t, nil)
|
|
_ = coderdtest.CreateFirstUser(t, client)
|
|
ctx, cancel := context.WithTimeout(context.Background(), testutil.WaitLong)
|
|
defer cancel()
|
|
|
|
coderdenttest.AddLicense(t, client, coderdenttest.LicenseOptions{
|
|
AccountID: "testing",
|
|
AuditLog: true,
|
|
})
|
|
coderdenttest.AddLicense(t, client, coderdenttest.LicenseOptions{
|
|
AccountID: "testing2",
|
|
AuditLog: true,
|
|
UserLimit: 200,
|
|
})
|
|
|
|
licenses, err := client.Licenses(ctx)
|
|
require.NoError(t, err)
|
|
assert.Len(t, licenses, 2)
|
|
for _, l := range licenses {
|
|
err = client.DeleteLicense(ctx, l.ID)
|
|
require.NoError(t, err)
|
|
}
|
|
licenses, err = client.Licenses(ctx)
|
|
require.NoError(t, err)
|
|
assert.Len(t, licenses, 0)
|
|
})
|
|
}
|