mirror of
https://github.com/rcourtman/Pulse.git
synced 2026-04-28 03:20:11 +00:00
Prefer org header over cookie
This commit is contained in:
parent
d06c749c1a
commit
8300ec8460
1 changed files with 71 additions and 0 deletions
71
internal/api/tenant_org_header_precedence_test.go
Normal file
71
internal/api/tenant_org_header_precedence_test.go
Normal file
|
|
@ -0,0 +1,71 @@
|
|||
package api
|
||||
|
||||
import (
|
||||
"net/http"
|
||||
"net/http/httptest"
|
||||
"testing"
|
||||
"time"
|
||||
|
||||
"github.com/rcourtman/pulse-go-rewrite/internal/config"
|
||||
"github.com/rcourtman/pulse-go-rewrite/internal/models"
|
||||
internalauth "github.com/rcourtman/pulse-go-rewrite/pkg/auth"
|
||||
)
|
||||
|
||||
func TestTenantMiddlewarePrefersHeaderOverCookie(t *testing.T) {
|
||||
defer SetMultiTenantEnabled(false)
|
||||
SetMultiTenantEnabled(true)
|
||||
t.Setenv("PULSE_DEV", "true")
|
||||
|
||||
dataDir := t.TempDir()
|
||||
hashed, err := internalauth.HashPassword("Password!1")
|
||||
if err != nil {
|
||||
t.Fatalf("hash password: %v", err)
|
||||
}
|
||||
|
||||
cfg := &config.Config{
|
||||
DataPath: dataDir,
|
||||
ConfigPath: dataDir,
|
||||
AuthUser: "admin",
|
||||
AuthPass: hashed,
|
||||
}
|
||||
|
||||
orgA := &models.Organization{
|
||||
ID: "org-a",
|
||||
DisplayName: "Org A",
|
||||
OwnerUserID: "alice",
|
||||
Members: []models.OrganizationMember{
|
||||
{UserID: "alice", Role: models.OrgRoleOwner, AddedAt: time.Now()},
|
||||
},
|
||||
}
|
||||
orgB := &models.Organization{
|
||||
ID: "org-b",
|
||||
DisplayName: "Org B",
|
||||
OwnerUserID: "charlie",
|
||||
Members: []models.OrganizationMember{
|
||||
{UserID: "charlie", Role: models.OrgRoleOwner, AddedAt: time.Now()},
|
||||
},
|
||||
}
|
||||
mtp := config.NewMultiTenantPersistence(dataDir)
|
||||
if err := mtp.SaveOrganization(orgA); err != nil {
|
||||
t.Fatalf("save organization A: %v", err)
|
||||
}
|
||||
if err := mtp.SaveOrganization(orgB); err != nil {
|
||||
t.Fatalf("save organization B: %v", err)
|
||||
}
|
||||
|
||||
router := NewRouter(cfg, nil, nil, nil, nil, "1.0.0")
|
||||
|
||||
sessionToken := "header-precedence-token"
|
||||
GetSessionStore().CreateSession(sessionToken, time.Hour, "agent", "127.0.0.1", "alice")
|
||||
|
||||
req := httptest.NewRequest(http.MethodGet, "/api/config", nil)
|
||||
req.Header.Set("X-Pulse-Org-ID", "org-a")
|
||||
req.AddCookie(&http.Cookie{Name: "pulse_session", Value: sessionToken})
|
||||
req.AddCookie(&http.Cookie{Name: "pulse_org_id", Value: "org-b"})
|
||||
rec := httptest.NewRecorder()
|
||||
router.Handler().ServeHTTP(rec, req)
|
||||
|
||||
if rec.Code != http.StatusOK {
|
||||
t.Fatalf("expected 200 when header org is allowed, got %d", rec.Code)
|
||||
}
|
||||
}
|
||||
Loading…
Add table
Add a link
Reference in a new issue