Janady13/missionmatch / internal/platform/samawards/normalize.go

Source identity

Field	Recorded value
Source type	GitHub source
Original record	Janady13/missionmatch / internal/platform/samawards/normalize.go
Date	Not specified in source
Repository	Janady13/missionmatch
Revision	720d47fae476b0d38477ae4401697d372b1ea2bc
Branch	feature/opportunity-to-outcome
Path or archive member	internal/platform/samawards/normalize.go
Original SHA-256	6437107da182504daf6fbfd3ee6dcdf8318b4e03c98a7bf0129f90018edde3eb
Git blob SHA	669c2108d3b3a578fad70186c3c03d7ad03bdafc
Reading-copy SHA-256	6437107da182504daf6fbfd3ee6dcdf8318b4e03c98a7bf0129f90018edde3eb

Original source ↗

Every recorded occurrence

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

Recovered source transcript

Download complete source text ↓171 lines · 6.1 KB

package samawards

import (
	"encoding/json"
	"strings"
	"time"

	"github.com/shopspring/decimal"
)

// Award is the flat, app facing shape of a SAM contract award. It uses only Go native types. Optional
// money and dates are pointers (nil = absent), never a fabricated zero. The recipient is the incumbent.
type Award struct {
	UniqueKey        string // piid plus modification plus transaction, the upsert key for a contract action
	PIID             string
	AwardeeName      string // the incumbent
	AwardeeUEI       string
	TotalValue       *decimal.Decimal // base and all options value (the contract ceiling)
	ObligatedValue   *decimal.Decimal // this action's obligation
	Department       string
	Subtier          string
	NAICSCode        string
	NAICSDescription string
	Description      string
	SetAside         string
	DateSigned       *time.Time
	POPStart         *time.Time
	POPEnd           *time.Time
	Raw              json.RawMessage
}

// awardRecord mirrors the nested shape of one awardSummary element. Only the fields the app uses are
// decoded; everything else is ignored. The dollars are json.Number so both an integer and a float form
// parse exactly into a decimal.
type awardRecord struct {
	ContractID struct {
		PIID               string `json:"piid"`
		ModificationNumber string `json:"modificationNumber"`
		TransactionNumber  string `json:"transactionNumber"`
		Subtier            struct {
			Name string `json:"name"`
		} `json:"subtier"`
	} `json:"contractId"`
	AwardDetails struct {
		AwardeeData struct {
			AwardeeHeader struct {
				AwardeeName string `json:"awardeeName"`
			} `json:"awardeeHeader"`
			AwardeeUEIInformation struct {
				UniqueEntityID string `json:"uniqueEntityId"`
			} `json:"awardeeUEIInformation"`
		} `json:"awardeeData"`
		Dollars struct {
			ActionObligation       NumericText `json:"actionObligation"`
			BaseAndAllOptionsValue NumericText `json:"baseAndAllOptionsValue"`
		} `json:"dollars"`
		Dates struct {
			DateSigned                   string `json:"dateSigned"`
			PeriodOfPerformanceStartDate string `json:"periodOfPerformanceStartDate"`
			CurrentCompletionDate        string `json:"currentCompletionDate"`
		} `json:"dates"`
	} `json:"awardDetails"`
	CoreData struct {
		FederalOrganization struct {
			ContractingInformation struct {
				ContractingDepartment struct {
					Name string `json:"name"`
				} `json:"contractingDepartment"`
			} `json:"contractingInformation"`
		} `json:"federalOrganization"`
		ProductOrServiceInformation struct {
			PrincipalNaics []struct {
				Code        string `json:"code"`
				Description string `json:"description"`
			} `json:"principalNaics"`
		} `json:"productOrServiceInformation"`
		PreferencePrograms struct {
			TypeOfSetAside struct {
				Name string `json:"name"`
			} `json:"typeOfSetAside"`
		} `json:"preferencePrograms"`
		ContractData struct {
			DescriptionOfContractRequirement string `json:"descriptionOfContractRequirement"`
		} `json:"contractData"`
	} `json:"coreData"`
}

// Normalize maps one raw award record to an Award. It returns false when the record has no PIID (an
// upsert key cannot be formed), so the caller skips it rather than writing a keyless row.
func Normalize(raw json.RawMessage) (Award, bool) {
	var r awardRecord
	if err := json.Unmarshal(raw, &r); err != nil {
		return Award{}, false
	}
	piid := strings.TrimSpace(r.ContractID.PIID)
	if piid == "" {
		return Award{}, false
	}
	a := Award{
		UniqueKey:      actionKey(piid, r.ContractID.ModificationNumber, r.ContractID.TransactionNumber),
		PIID:           piid,
		AwardeeName:    strings.TrimSpace(r.AwardDetails.AwardeeData.AwardeeHeader.AwardeeName),
		AwardeeUEI:     strings.TrimSpace(r.AwardDetails.AwardeeData.AwardeeUEIInformation.UniqueEntityID),
		TotalValue:     decimalFromNumber(r.AwardDetails.Dollars.BaseAndAllOptionsValue),
		ObligatedValue: decimalFromNumber(r.AwardDetails.Dollars.ActionObligation),
		Department:     strings.TrimSpace(r.CoreData.FederalOrganization.ContractingInformation.ContractingDepartment.Name),
		Subtier:        strings.TrimSpace(r.ContractID.Subtier.Name),
		Description:    strings.TrimSpace(r.CoreData.ContractData.DescriptionOfContractRequirement),
		SetAside:       strings.TrimSpace(r.CoreData.PreferencePrograms.TypeOfSetAside.Name),
		DateSigned:     parseFlexDate(r.AwardDetails.Dates.DateSigned),
		POPStart:       parseFlexDate(r.AwardDetails.Dates.PeriodOfPerformanceStartDate),
		POPEnd:         parseFlexDate(r.AwardDetails.Dates.CurrentCompletionDate),
		Raw:            raw,
	}
	if len(r.CoreData.ProductOrServiceInformation.PrincipalNaics) > 0 {
		a.NAICSCode = strings.TrimSpace(r.CoreData.ProductOrServiceInformation.PrincipalNaics[0].Code)
		a.NAICSDescription = strings.TrimSpace(r.CoreData.ProductOrServiceInformation.PrincipalNaics[0].Description)
	}
	return a, true
}

// actionKey is the unique key for a contract action: a PIID plus its modification and transaction
// numbers identify one action uniquely, so a base award and its modifications are distinct rows.
func actionKey(piid, mod, txn string) string {
	parts := []string{piid}
	if m := strings.TrimSpace(mod); m != "" {
		parts = append(parts, m)
	}
	if t := strings.TrimSpace(txn); t != "" {
		parts = append(parts, t)
	}
	return strings.Join(parts, "|")
}

// decimalFromNumber parses a numeric text value to a decimal, returning nil for an empty or unparseable
// value so an absent dollar figure stays absent rather than becoming a fabricated zero.
func decimalFromNumber(n NumericText) *decimal.Decimal {
	s := strings.TrimSpace(string(n))
	if s == "" {
		return nil
	}
	d, err := decimal.NewFromString(s)
	if err != nil {
		return nil
	}
	return &d
}

// parseFlexDate parses the several date shapes the API returns: dateSigned is RFC3339 with a Z, while the
// period of performance dates are space separated with milliseconds and no zone.
func parseFlexDate(s string) *time.Time {
	s = strings.TrimSpace(s)
	if s == "" {
		return nil
	}
	layouts := []string{
		time.RFC3339,
		"2006-01-02 15:04:05.000",
		"2006-01-02 15:04:05.000000",
		"2006-01-02 15:04:05",
		"2006-01-02T15:04:05",
		"2006-01-02",
	}
	for _, layout := range layouts {
		if t, err := time.Parse(layout, s); err == nil {
			return &t
		}
	}
	return nil
}