@@ -97,61 +97,59 @@ export async function saveOSPSBaselineInsightsToDB(
9797 const redisCache = new RedisCache ( `osps-baseline-insights` , svc . redis , svc . log )
9898 const result = await redisCache . get ( key )
9999 const parsedResult : ISecurityInsightsPrivateerResult = JSON . parse ( result )
100- const evaluationSuite = parsedResult . evaluation_suites . find ( ( s ) => s . catalog_id === CATALOG_ID )
100+ const evaluationSuite = parsedResult [ 'evaluation-suites' ] . find (
101+ ( s ) => s [ 'catalog-id' ] === CATALOG_ID ,
102+ )
101103
102104 const qx = pgpQx ( svc . postgres . writer . connection ( ) )
103105
104106 await addEvaluationSuite ( qx , {
105107 repo : repo . repoUrl ,
106108 insightsProjectId : repo . insightsProjectId ,
107109 insightsProjectSlug : repo . insightsProjectSlug ,
108- catalogId : evaluationSuite . catalog_id ,
110+ catalogId : evaluationSuite [ 'catalog-id' ] ,
109111 name : evaluationSuite . name ,
110112 result : evaluationSuite . result ,
111- corruptedState : evaluationSuite . corrupted_state ,
113+ corruptedState : evaluationSuite [ 'corrupted-state' ] ,
112114 } )
113115
114- const suite = await findEvaluationSuite ( qx , repo . repoUrl , evaluationSuite . catalog_id )
116+ const suite = await findEvaluationSuite ( qx , repo . repoUrl , evaluationSuite [ 'catalog-id' ] )
115117
116- for ( const evaluation of evaluationSuite . control_evaluations ) {
118+ for ( const evaluation of evaluationSuite [ 'control-evaluations' ] . evaluations ) {
119+ const controlId = evaluation . control [ 'entry-id' ]
117120 await addSuiteControlEvaluation ( qx , {
118- controlId : evaluation [ 'control-id' ] ,
121+ controlId,
119122 name : evaluation . name ,
120- corruptedState : evaluation [ 'corrupted-state' ] ,
123+ corruptedState : false ,
121124 message : evaluation . message ,
122125 repo : repo . repoUrl ,
123126 insightsProjectId : repo . insightsProjectId ,
124127 insightsProjectSlug : repo . insightsProjectSlug ,
125- remediationGuide : evaluation [ 'remediation-guide' ] || '' ,
128+ remediationGuide : '' ,
126129 result : evaluation . result ,
127130 securityInsightsEvaluationSuiteId : suite . id ,
128131 } )
129132
130- const controlEvaluation = await findSuiteControlEvaluation (
131- qx ,
132- repo . repoUrl ,
133- evaluation [ 'control-id' ] ,
134- suite . id ,
135- )
136- for ( const assessment of evaluation . assessments ) {
133+ const controlEvaluation = await findSuiteControlEvaluation ( qx , repo . repoUrl , controlId , suite . id )
134+ for ( const assessment of evaluation [ 'assessment-logs' ] ) {
137135 await addControlEvaluationAssessment ( qx , {
138136 applicability : assessment . applicability ,
139137 description : assessment . description ,
140138 message : assessment . message ,
141139 repo : repo . repoUrl ,
142140 insightsProjectId : repo . insightsProjectId ,
143141 insightsProjectSlug : repo . insightsProjectSlug ,
144- requirementId : assessment [ 'requirement -id'] ,
142+ requirementId : assessment . requirement [ 'entry -id'] ,
145143 result : assessment . result ,
146- runDuration : assessment [ 'run-duration' ] || '' ,
144+ runDuration : '' ,
147145 steps : assessment . steps ,
148146 stepsExecuted : assessment [ 'steps-executed' ] || 0 ,
149147 securityInsightsEvaluationId : controlEvaluation . id ,
150148 recommendation : assessment . recommendation ,
151149 start : assessment . start ,
152150 end : assessment . end ,
153- value : assessment . value ,
154- changes : assessment . changes ,
151+ value : null ,
152+ changes : null ,
155153 } )
156154 }
157155 }
0 commit comments