Janady13/missionmatch / internal/integration/recruitmatch_integration_test.go

1//go:build integration 2 3package integration 4 5import ( 6 "context" 7 "testing" 8 "time" 9 10 "github.com/shopspring/decimal" 11 12 "github.com/missionworkforce/missionmatch/internal/modules/recruitmatch" 13 "github.com/missionworkforce/missionmatch/internal/platform/tenant" 14) 15 16var recruitAsOf = time.Date(2026, 7, 20, 0, 0, 0, 0, time.UTC) 17 18// TestRecruitDashboardEmptyOrgRendersCompleteView is the day one state of every client the platform 19// onboards. An organization with no candidates, no requirements and no slates must still receive a 20// complete view: zeros, a full funnel, one row per reference clearance level, and the named untracked 21// panels. A crash or a missing panel here is what a new customer would see on their first login. 22func TestRecruitDashboardEmptyOrgRendersCompleteView(t *testing.T) { 23 org := seedOrg(t) 24 ctx := tenant.WithOrg(context.Background(), org.String()) 25 26 v, err := recruitmatch.NewService(appDB).RecruiterDashboard(ctx, recruitAsOf) 27 if err != nil { 28 t.Fatalf("RecruiterDashboard on an empty org: %v", err) 29 } 30 31 if v.OrganizationID != org.String() { 32 t.Errorf("OrganizationID = %q, want %q", v.OrganizationID, org) 33 } 34 if v.AsOf != "2026-07-20" { 35 t.Errorf("AsOf = %q, want 2026-07-20", v.AsOf) 36 } 37 if v.Headline != (recruitmatch.Headline{}) { 38 t.Errorf("empty org headline is nonzero: %+v", v.Headline) 39 } 40 if len(v.Funnel) != 4 { 41 t.Fatalf("funnel has %d stages, want 4 even when empty", len(v.Funnel)) 42 } 43 for _, s := range v.Funnel { 44 if s.Count != 0 || s.Pct != "0.00" { 45 t.Errorf("stage %q = %d (%s), want 0 (0.00)", s.Key, s.Count, s.Pct) 46 } 47 } 48 if v.Decisions.ApproveRate != "0.00" { 49 t.Errorf("approve rate = %q, want 0.00 with no decisions", v.Decisions.ApproveRate) 50 } 51 if len(v.Clearance) == 0 { 52 t.Error("clearance is empty, want one row per reference clearance level so the chart shape is stable") 53 } 54 for _, c := range v.Clearance { 55 if c.Count != 0 || c.Pct != "0.00" { 56 t.Errorf("clearance %q = %d (%s), want 0 (0.00)", c.Code, c.Count, c.Pct) 57 } 58 } 59 if v.TopJobs == nil || v.Recruiters == nil { 60 t.Error("TopJobs and Recruiters must be empty slices, never nil, so the JSON is [] and not null") 61 } 62 if len(v.EmptyPanels) == 0 { 63 t.Error("EmptyPanels is empty, the untracked panels must always be named") 64 } 65} 66 67// TestRecruitDashboardFailsClosedWithoutTenantContext proves the aggregate refuses to run rather than 68// aggregating across the whole database. 69func TestRecruitDashboardFailsClosedWithoutTenantContext(t *testing.T) { 70 if _, err := recruitmatch.NewService(appDB).RecruiterDashboard(context.Background(), recruitAsOf); err == nil { 71 t.Fatal("want an error with no tenant in context, got nil") 72 } 73} 74 75// TestRecruitDashboardIsolatesTenants is the multi client guarantee. missionMATCH is sold to more than 76// one client, so one organization must never observe another's bench through this endpoint. 77func TestRecruitDashboardIsolatesTenants(t *testing.T) { 78 orgA, orgB := seedOrg(t), seedOrg(t) 79 for i := 0; i < 3; i++ { 80 seedCandidate(t, orgA, "secret", "active", true) 81 } 82 for i := 0; i < 7; i++ { 83 seedCandidate(t, orgB, "top_secret", "active", true) 84 } 85 86 svc := recruitmatch.NewService(appDB) 87 va, err := svc.RecruiterDashboard(tenant.WithOrg(context.Background(), orgA.String()), recruitAsOf) 88 if err != nil { 89 t.Fatalf("org A: %v", err) 90 } 91 vb, err := svc.RecruiterDashboard(tenant.WithOrg(context.Background(), orgB.String()), recruitAsOf) 92 if err != nil { 93 t.Fatalf("org B: %v", err) 94 } 95 96 if va.Headline.Identified != 3 { 97 t.Errorf("org A identified = %d, want exactly 3", va.Headline.Identified) 98 } 99 if vb.Headline.Identified != 7 { 100 t.Errorf("org B identified = %d, want exactly 7", vb.Headline.Identified) 101 } 102 if va.OrganizationID == vb.OrganizationID { 103 t.Fatal("both views report the same organization id") 104 } 105 106 // Clearance is the sharpest cross tenant probe: A holds only secret, B only top_secret. If either 107 // view shows the other's level, isolation has failed in a way a total count could mask. 108 for _, c := range va.Clearance { 109 if c.Code == "top_secret" && c.Count != 0 { 110 t.Errorf("org A sees %d top_secret candidates, which belong to org B", c.Count) 111 } 112 } 113 for _, c := range vb.Clearance { 114 if c.Code == "secret" && c.Count != 0 { 115 t.Errorf("org B sees %d secret candidates, which belong to org A", c.Count) 116 } 117 } 118} 119 120// TestRecruitDashboardFunnelIsMonotonicAgainstRealData proves the invariant end to end rather than only 121// in the pure unit tests. The unit tests prove buildFunnel preserves monotonic input; this proves the 122// SQL actually produces monotonic input. 123func TestRecruitDashboardFunnelIsMonotonicAgainstRealData(t *testing.T) { 124 org := seedOrg(t) 125 for i := 0; i < 5; i++ { 126 seedCandidate(t, org, "secret", "active", true) 127 } 128 ctx := tenant.WithOrg(context.Background(), org.String()) 129 130 v, err := recruitmatch.NewService(appDB).RecruiterDashboard(ctx, recruitAsOf) 131 if err != nil { 132 t.Fatalf("RecruiterDashboard: %v", err) 133 } 134 135 h := v.Headline 136 if !(h.Identified >= h.Screened && h.Screened >= h.Submitted && h.Submitted >= h.Approved) { 137 t.Fatalf("funnel counts are not monotonic: identified=%d screened=%d submitted=%d approved=%d", 138 h.Identified, h.Screened, h.Submitted, h.Approved) 139 } 140 141 prev := decimal.NewFromInt(101) 142 for _, s := range v.Funnel { 143 cur, err := decimal.NewFromString(s.Pct) 144 if err != nil { 145 t.Fatalf("stage %q pct %q does not parse: %v", s.Key, s.Pct, err) 146 } 147 if cur.GreaterThan(prev) { 148 t.Fatalf("funnel rose at %q: %s after %s", s.Key, cur, prev) 149 } 150 if cur.GreaterThan(decimal.NewFromInt(100)) { 151 t.Fatalf("stage %q = %s exceeds 100", s.Key, cur) 152 } 153 prev = cur 154 } 155} 156 157// TestRecruitDashboardIsDeterministicForAFixedAsOf proves the view carries no wall clock dependence, so 158// the same asOf over unchanged data yields an identical payload. This is what makes the numbers 159// defensible when someone reruns a report. 160func TestRecruitDashboardIsDeterministicForAFixedAsOf(t *testing.T) { 161 org := seedOrg(t) 162 seedCandidate(t, org, "ts_sci", "active", true) 163 ctx := tenant.WithOrg(context.Background(), org.String()) 164 svc := recruitmatch.NewService(appDB) 165 166 first, err := svc.RecruiterDashboard(ctx, recruitAsOf) 167 if err != nil { 168 t.Fatalf("first call: %v", err) 169 } 170 second, err := svc.RecruiterDashboard(ctx, recruitAsOf) 171 if err != nil { 172 t.Fatalf("second call: %v", err) 173 } 174 175 if first.GeneratedAt != second.GeneratedAt { 176 t.Errorf("GeneratedAt drifted between calls: %q then %q", first.GeneratedAt, second.GeneratedAt) 177 } 178 if first.Headline != second.Headline { 179 t.Errorf("headline drifted: %+v then %+v", first.Headline, second.Headline) 180 } 181 if len(first.Clearance) != len(second.Clearance) { 182 t.Fatalf("clearance length drifted: %d then %d", len(first.Clearance), len(second.Clearance)) 183 } 184 for i := range first.Clearance { 185 if first.Clearance[i] != second.Clearance[i] { 186 t.Errorf("clearance row %d drifted: %+v then %+v", i, first.Clearance[i], second.Clearance[i]) 187 } 188 } 189} 190