Janady13/missionmatch / internal/modules/opportunities/amendment_view.go

1package opportunities 2 3import ( 4 "context" 5 "fmt" 6 "strings" 7 8 "github.com/google/uuid" 9 "github.com/jackc/pgx/v5" 10) 11 12// THE AMENDMENT VIEW, the read side of directive Section 4 item 11 and the screen Gate C names. Everything 13// needed to answer one question a capture team asks under time pressure: the source changed, so what does that 14// do to the requirements we already approved? 15// 16// IT IS DELIBERATELY THREE THINGS IN ONE RESPONSE. A version list alone says a change happened. An alert list 17// alone says somebody was told. Neither says whether an APPROVED requirement is affected, which is the only 18// part with money attached. Splitting these across three round trips invites a screen that renders two of them 19// and quietly omits the third. 20// 21// NOTHING HERE MUTATES. The impact is reported as a FLAG for a named human to act on, never applied. That is 22// acceptance item 11 and it is the line this whole phase is built around. 23 24type OpportunityVersion struct { 25 VersionNumber int `json:"version_number"` 26 AmendmentNumber string `json:"amendment_number"` 27 SourceVersionLabel string `json:"source_version_label"` 28 SourcePayloadHash string `json:"source_payload_hash"` 29 FetchedAt string `json:"fetched_at"` 30 IsCurrent bool `json:"is_current"` 31} 32 33type AmendmentAlert struct { 34 ID string `json:"id"` 35 AlertType string `json:"alert_type"` 36 Severity string `json:"severity"` 37 Title string `json:"title"` 38 Detail string `json:"detail"` 39 Status string `json:"status"` 40 CreatedAt string `json:"created_at"` 41} 42 43// AffectedRequirement is an approved requirement whose lineage runs back through this opportunity's scope. It 44// carries the draft and scope item it came from so a reviewer can walk from a flag to the cited span. 45type AffectedRequirement struct { 46 RequirementID string `json:"requirement_id"` 47 DraftID string `json:"draft_id"` 48 LaborCategory string `json:"labor_category"` 49 ClearanceLevel string `json:"clearance_level"` 50 Quantity int `json:"quantity"` 51 SourceScopeItemID string `json:"source_scope_item_id"` 52 SourceScopeTitle string `json:"source_scope_title"` 53} 54 55type AmendmentView struct { 56 Versions []OpportunityVersion `json:"versions"` 57 Alerts []AmendmentAlert `json:"alerts"` 58 AffectedRequirements []AffectedRequirement `json:"affected_requirements"` 59} 60 61// AmendmentViewFor assembles the whole amendment picture for one opportunity. 62func (s *Service) AmendmentViewFor(ctx context.Context, opportunityID string) (AmendmentView, error) { 63 out := AmendmentView{ 64 Versions: []OpportunityVersion{}, 65 Alerts: []AmendmentAlert{}, 66 AffectedRequirements: []AffectedRequirement{}, 67 } 68 if !s.db.Ready() { 69 return out, ErrNoDatabase 70 } 71 oid, err := uuid.Parse(strings.TrimSpace(opportunityID)) 72 if err != nil { 73 return out, fmt.Errorf("%w: opportunity id must be a uuid", ErrInvalidInput) 74 } 75 76 err = s.db.RunInTenantTx(ctx, func(ctx context.Context, tx pgx.Tx) error { 77 vRows, vErr := tx.Query(ctx, ` 78 SELECT version_number, amendment_number, source_version_label, 79 COALESCE(source_payload_hash,''), fetched_at::text, is_current 80 FROM opportunity_versions 81 WHERE opportunity_id = $1 82 ORDER BY version_number`, oid) 83 if vErr != nil { 84 return vErr 85 } 86 for vRows.Next() { 87 var v OpportunityVersion 88 if sErr := vRows.Scan(&v.VersionNumber, &v.AmendmentNumber, &v.SourceVersionLabel, 89 &v.SourcePayloadHash, &v.FetchedAt, &v.IsCurrent); sErr != nil { 90 vRows.Close() 91 return sErr 92 } 93 out.Versions = append(out.Versions, v) 94 } 95 vRows.Close() 96 if rErr := vRows.Err(); rErr != nil { 97 return rErr 98 } 99 100 // The amendment and deadline alert kinds, which are the two migration 0075 added to the vocabulary. 101 aRows, aErr := tx.Query(ctx, ` 102 SELECT id::text, alert_type, severity, title, detail, status, created_at::text 103 FROM alerts 104 WHERE subject_type = 'opportunity' AND subject_id = $1 105 AND alert_type IN ('opportunity_amendment','opportunity_deadline') 106 ORDER BY created_at DESC`, oid) 107 if aErr != nil { 108 return aErr 109 } 110 for aRows.Next() { 111 var a AmendmentAlert 112 if sErr := aRows.Scan(&a.ID, &a.AlertType, &a.Severity, &a.Title, &a.Detail, 113 &a.Status, &a.CreatedAt); sErr != nil { 114 aRows.Close() 115 return sErr 116 } 117 out.Alerts = append(out.Alerts, a) 118 } 119 aRows.Close() 120 if rErr := aRows.Err(); rErr != nil { 121 return rErr 122 } 123 124 // THE PART THAT MATTERS. An approved requirement is reachable from this opportunity only through a 125 // promoted draft, and the draft records the scope item it was derived from. That chain is the lineage 126 // acceptance item 11 depends on, so it is followed rather than guessed at from titles. 127 rRows, rErr := tx.Query(ctx, ` 128 SELECT d.approved_requirement_id::text, d.id::text, d.labor_category, d.clearance_level, d.quantity, 129 COALESCE(d.source_scope_item_id::text,''), COALESCE(si.title,'') 130 FROM requirement_drafts d 131 LEFT JOIN opportunity_scope_items si ON si.id = d.source_scope_item_id 132 WHERE d.opportunity_id = $1 133 AND d.review_status = 'approved' 134 AND d.approved_requirement_id IS NOT NULL 135 ORDER BY d.labor_category`, oid) 136 if rErr != nil { 137 return rErr 138 } 139 for rRows.Next() { 140 var a AffectedRequirement 141 if sErr := rRows.Scan(&a.RequirementID, &a.DraftID, &a.LaborCategory, &a.ClearanceLevel, 142 &a.Quantity, &a.SourceScopeItemID, &a.SourceScopeTitle); sErr != nil { 143 rRows.Close() 144 return sErr 145 } 146 out.AffectedRequirements = append(out.AffectedRequirements, a) 147 } 148 rRows.Close() 149 return rRows.Err() 150 }) 151 if err != nil { 152 return AmendmentView{}, err 153 } 154 return out, nil 155} 156