Janady13/missionmatch / internal/modules/commandcenter/service_upcoming.go

Source identity

Field	Recorded value
Source type	GitHub source
Original record	Janady13/missionmatch / internal/modules/commandcenter/service_upcoming.go
Date	Not specified in source
Repository	Janady13/missionmatch
Revision	720d47fae476b0d38477ae4401697d372b1ea2bc
Branch	feature/opportunity-to-outcome
Path or archive member	internal/modules/commandcenter/service_upcoming.go
Original SHA-256	ef324990e8088c81d5851266a9f8416d55ad1382b3c561eec1e431afc0f0b986
Git blob SHA	3f81b3fcab3edf1180ddbae10aadc6920aadd803
Reading-copy SHA-256	ef324990e8088c81d5851266a9f8416d55ad1382b3c561eec1e431afc0f0b986

Original source ↗

Every recorded occurrence

These 33 records contain identical original source bytes. Their paths and revisions remain part of the archive.

Original record	Branch or archive	Revision / identifier	Original location
Janady13/missionmatch / internal/modules/commandcenter/service_upcoming.go	feature/opportunity-to-outcome	720d47fae476b0d38477ae4401697d372b1ea2bc	Open original
Janady13/missionmatch / internal/modules/commandcenter/service_upcoming.go	per-tenant-routing	9bde0f9a74b89d01980fa658e5253acda7528d0c	Open original
Janady13/missionmatch / internal/modules/commandcenter/service_upcoming.go	collision-deconfliction	4ee5a09972608ed89f8377c6665542d5f450f0a6	Open original
Janady13/missionmatch / internal/modules/commandcenter/service_upcoming.go	ws6-retrieval	6c56e29231ec05735927fa265c97d517499dfeaf	Open original
Janady13/missionmatch / internal/modules/commandcenter/service_upcoming.go	workstream-a-shared-core	e0de03ac3a1ec826bd15d0e048e3b02baa23eeff	Open original
Janady13/missionmatch / internal/modules/commandcenter/service_upcoming.go	m5-price-to-win	41000ad30fff4129fdaf5ec84e15ba14c27d4890	Open original
Janady13/missionmatch / internal/modules/commandcenter/service_upcoming.go	workstream-c-slatematch	5cd60c918301b46ecd6ed3e03e20c395da0062e2	Open original
Janady13/missionmatch / internal/modules/commandcenter/service_upcoming.go	ws1-ontology-sync	b596f449a32a1016fbd403c36505cc00a1ac9ee6	Open original
Janady13/missionmatch / internal/modules/commandcenter/service_upcoming.go	master	1e9249840a4302ec82e123b9c9cb6f75badea3e4	Open original
Janady13/missionmatch / internal/modules/commandcenter/service_upcoming.go	ws8-teaching-loop	c823f0fb6bb2aba0f39001eb6de96f4000d9321f	Open original
Janady13/missionmatch / internal/modules/commandcenter/service_upcoming.go	w3-ai-staffing-recommendations	43d56387270ef4da4cabd794d97ca6a49909bc7d	Open original
Janady13/missionmatch / internal/modules/commandcenter/service_upcoming.go	mag-substrate	b82c7100a492dec67dfd1eda6b3f53def859be35	Open original
Janady13/missionmatch / internal/modules/commandcenter/service_upcoming.go	ws3-clearance	4b8e7ce594c068621867f9c9deed0ec64ae6c553	Open original
Janady13/missionmatch / internal/modules/commandcenter/service_upcoming.go	workstream-d-command-center	255e7d1d420abf5e277d0cd8c9b14f6f72b6acb9	Open original
Janady13/missionmatch / internal/modules/commandcenter/service_upcoming.go	phase2-eval-fairness	d361af254701975fe239927656ababb56374655e	Open original
Janady13/missionmatch / internal/modules/commandcenter/service_upcoming.go	workstream-e-dataflow-deploy	433815a042f9741411e60fa553fe72143e9b10db	Open original
Janady13/missionmatch / internal/modules/commandcenter/service_upcoming.go	ruthless-debug-sweep	b7d742f8f032984be3817efffa3eb8b13b651c1f	Open original
Janady13/missionmatch / internal/modules/commandcenter/service_upcoming.go	time-to-fill-survival	b66e1e505863d4f17741a4b9ede73509e45bd6c6	Open original
Janady13/missionmatch / internal/modules/commandcenter/service_upcoming.go	ai-intelligence-layer	5d5ddff70393a197c5f54a45280bb5dd42b24755	Open original
Janady13/missionmatch / internal/modules/commandcenter/service_upcoming.go	graphrag-foundation	b0ddeb9f633fd138d09309d1a17b7d13bc3a67f7	Open original
Janady13/missionmatch / internal/modules/commandcenter/service_upcoming.go	deploy-and-ops	bdacd9d0b4d5998d25fc74bf4007f4c3ec538c7a	Open original
Janady13/missionmatch / internal/modules/commandcenter/service_upcoming.go	ws9-bench-ingestion	f585a9ef32fa554663ce1fba9a414a54b6e49cf0	Open original
Janady13/missionmatch / internal/modules/commandcenter/service_upcoming.go	ws2-alias-relationship	e4dada4601c6eb101830f9d223a9655dfa120616	Open original
Janady13/missionmatch / internal/modules/commandcenter/service_upcoming.go	presentation-readiness	eb574acaa29d71ce4d0f852572e87c275c79fdb7	Open original
Janady13/missionmatch / internal/modules/commandcenter/service_upcoming.go	vendor-intelligence	fe9796a19c261951d3f2565206c0c1b5ac294465	Open original
Janady13/missionmatch / internal/modules/commandcenter/service_upcoming.go	workstream-b-screenmatch	09015496d565a172bcaa15cfe9a8e4b072b13df0	Open original
Janady13/missionmatch / internal/modules/commandcenter/service_upcoming.go	ws7-federal-signal	6a9f6ce9cfb13345ffb47770d4960e7c2d9c17c2	Open original
Janady13/missionmatch / internal/modules/commandcenter/service_upcoming.go	workstream-e-commercial-stubs	4437da660539284a400ee380b9b427a300c369ee	Open original
Janady13/missionmatch / internal/modules/commandcenter/service_upcoming.go	ai-brain-live	aac32fc49c878cc5bca099459307611562d0bac1	Open original
Janady13/missionmatch / internal/modules/commandcenter/service_upcoming.go	workstream-d-missionmatch	3be46ba89edb737182075a2b320509b42dc916f8	Open original
Janady13/missionmatch / internal/modules/commandcenter/service_upcoming.go	phase2-connectors	e038d4c687aec16f8bd9bc4d907eea14d91f8704	Open original
Janady13/missionmatch / internal/modules/commandcenter/service_upcoming.go	feature/aioe-upgrade	2178e7298d0e5d9af83afa12402fd587f0ba6ed8	Open original
Janady13/missionmatch / internal/modules/commandcenter/service_upcoming.go	capture-readiness	bae6af7cb2997e819174a9e9cfff5e16067a1975	Open original

Recovered source transcript

Download complete source text ↓150 lines · 6.3 KB

package commandcenter

import (
	"context"
	"fmt"

	"github.com/jackc/pgx/v5"
	"github.com/shopspring/decimal"
)

// upcomingForecastLimit caps the Upcoming Opportunities panel.
const upcomingForecastLimit = 12

// planningNote is the standing label on every forecast row, so the panel always reads as planning data.
const planningNote = "Planning data subject to change"

// upcomingOpportunities builds the Upcoming Opportunities panel from the global forecast catalog
// (record_kind forecast) and grounds each row in REAL signals from the org's own bench: the count of
// available, effectively cleared candidates in the forecast's place of performance, and the engine
// backed coverage of the org's comparable requirements for the same agency (reusing the eligibility in
// cc_qual, the same hard gates the engine uses, so there is no parallel scoring path). Forecasts are
// planning data and never alter the current readiness or Revenue at Risk numbers. The forecast catalog
// is public reference data; it is read here inside the tenant transaction only so the bench counts
// beside it stay RLS scoped to the caller's org.
func (s *Service) upcomingOpportunities(ctx context.Context, tx pgx.Tx) ([]UpcomingOpportunity, error) {
	rows, err := tx.Query(ctx, `
		SELECT id::text, title, agency, COALESCE(naics,''), COALESCE(pop_state,''),
		       COALESCE(set_aside,''), estimated_value,
		       COALESCE(to_char(estimated_award_date,'YYYY-MM-DD'),''), COALESCE(incumbent_name,'')
		FROM opportunity_records
		WHERE record_kind='forecast'
		ORDER BY estimated_award_date NULLS LAST, title, id
		LIMIT $1`, upcomingForecastLimit)
	if err != nil {
		return nil, fmt.Errorf("upcoming forecasts: %w", err)
	}
	type fc struct {
		id, title, agency, naics, state, setAside, awardDate, incumbent string
		value                                                           *decimal.Decimal
	}
	var forecasts []fc
	for rows.Next() {
		var f fc
		if err := rows.Scan(&f.id, &f.title, &f.agency, &f.naics, &f.state, &f.setAside, &f.value, &f.awardDate, &f.incumbent); err != nil {
			rows.Close()
			return nil, err
		}
		forecasts = append(forecasts, f)
	}
	rows.Close()
	if err := rows.Err(); err != nil {
		return nil, err
	}

	out := make([]UpcomingOpportunity, 0, len(forecasts))
	for _, f := range forecasts {
		u := UpcomingOpportunity{
			RecordID: f.id, Title: f.title, Agency: f.agency, NAICS: f.naics,
			PlaceOfPerformance: f.state, State: f.state, SetAside: f.setAside,
			EstimatedAwardDate: f.awardDate, IncumbentName: f.incumbent,
			PlanningNote: planningNote, Adoptable: true,
		}
		if f.value != nil {
			vs := f.value.StringFixed(2)
			u.EstimatedValue = &vs
		}

		// Real signal: available, effectively cleared candidates whose location names the state. The
		// state code is matched on a word boundary so HI does not match CHICAGO.
		if err := tx.QueryRow(ctx, `
			SELECT count(*) FROM cc_cand
			WHERE available AND effective AND lvl>=2
			  AND ($1='' OR location ~* ('\m'||$1||'\M'))`, f.state).Scan(&u.AvailableClearedInState); err != nil {
			return nil, fmt.Errorf("upcoming bench count: %w", err)
		}

		// Engine backed estimate: coverage of the org's comparable open requirements for this agency
		// (cc_qual is the same eligibility the engine gates on, so no new scoring path). The agency match
		// is a substring both directions so DEPT OF DEFENSE and Department of Defense align.
		if f.agency != "" {
			if err := tx.QueryRow(ctx, `
				SELECT count(*), count(*) FILTER (WHERE COALESCE(q.n,0)>0)
				FROM cc_active_req ar
				JOIN requirements r ON r.id = ar.id
				LEFT JOIN cc_qual q ON q.req_id = ar.id
				WHERE r.customer_agency IS NOT NULL AND r.customer_agency <> ''
				  AND (upper(r.customer_agency) LIKE '%'||upper($1)||'%' OR upper($1) LIKE '%'||upper(r.customer_agency)||'%')`,
				f.agency).Scan(&u.ComparableRequirements, &u.ComparableCovered); err != nil {
				return nil, fmt.Errorf("upcoming comparable coverage: %w", err)
			}
		}
		u.FitNote = upcomingFitNote(u)
		out = append(out, u)
	}
	return out, nil
}

// incumbentLandscapeLimit caps the incumbent context panel.
const incumbentLandscapeLimit = 12

// incumbentLandscape surfaces the incumbent and award context from the contract award feed (SAM Contract
// Awards and the USASpending fallback): who holds the largest contracts in the org's domain, so a matched
// candidate is read next to the incumbent they would compete against on a recompete. All figures are real
// award data with their provenance (value_source). The award catalog is public reference data, read here
// inside the tenant transaction only for one round trip.
func (s *Service) incumbentLandscape(ctx context.Context, tx pgx.Tx) ([]IncumbentRef, error) {
	rows, err := tx.Query(ctx, `
		SELECT id::text, incumbent_name, COALESCE(incumbent_uei,''), agency, COALESCE(naics,''),
		       estimated_value, COALESCE(value_source,''),
		       COALESCE(to_char(award_date,'YYYY-MM-DD'),''), source_name
		FROM opportunity_records
		WHERE record_kind='contract_award' AND incumbent_name <> ''
		ORDER BY estimated_value DESC NULLS LAST, id
		LIMIT $1`, incumbentLandscapeLimit)
	if err != nil {
		return nil, fmt.Errorf("incumbent landscape: %w", err)
	}
	defer rows.Close()
	out := []IncumbentRef{}
	for rows.Next() {
		var r IncumbentRef
		var value *decimal.Decimal
		if err := rows.Scan(&r.RecordID, &r.Incumbent, &r.IncumbentUEI, &r.Agency, &r.NAICS, &value, &r.ValueSource, &r.AwardDate, &r.Source); err != nil {
			return nil, err
		}
		if value != nil {
			vs := value.StringFixed(2)
			r.Value = &vs
		}
		out = append(out, r)
	}
	return out, rows.Err()
}

// upcomingFitNote builds the clearly labeled, honest fit line. It never asserts a precise match against a
// bare forecast (a forecast carries no skills); it states the real bench presence and, when the org has
// comparable requirements, the engine backed coverage of those, labeled as an estimate.
func upcomingFitNote(u UpcomingOpportunity) string {
	where := u.State
	if where == "" {
		where = "the place of performance"
	}
	base := fmt.Sprintf("%d available cleared in %s", u.AvailableClearedInState, where)
	if u.ComparableRequirements > 0 {
		return fmt.Sprintf("%s. Estimated from your %d %s requirement(s): %d currently covered.",
			base, u.ComparableRequirements, u.Agency, u.ComparableCovered)
	}
	return base + ". No comparable requirement yet; adopt it to score the bench against it."
}