@@ -17,18 +17,18 @@ import kotlinx.coroutines.ensureActive
17
17
import kotlinx.coroutines.isActive
18
18
import kotlinx.coroutines.time.withTimeout
19
19
import kotlinx.coroutines.withContext
20
- import software.amazon.awssdk.services.codewhisperer.model.ArtifactType
21
- import software.amazon.awssdk.services.codewhisperer.model.CodeScanFindingsSchema
22
- import software.amazon.awssdk.services.codewhisperer.model.CodeScanStatus
23
- import software.amazon.awssdk.services.codewhisperer.model.CodeWhispererException
24
- import software.amazon.awssdk.services.codewhisperer.model.CreateCodeScanRequest
25
- import software.amazon.awssdk.services.codewhisperer.model.CreateCodeScanResponse
26
- import software.amazon.awssdk.services.codewhisperer.model.GetCodeScanRequest
27
- import software.amazon.awssdk.services.codewhisperer.model.GetCodeScanResponse
28
- import software.amazon.awssdk.services.codewhisperer.model.ListCodeScanFindingsRequest
29
- import software.amazon.awssdk.services.codewhisperer.model.ListCodeScanFindingsResponse
20
+ import software.amazon.awssdk.services.codewhispererruntime.model.ArtifactType
21
+ import software.amazon.awssdk.services.codewhispererruntime.model.CodeAnalysisFindingsSchema
22
+ import software.amazon.awssdk.services.codewhispererruntime.model.CodeAnalysisStatus
23
+ import software.amazon.awssdk.services.codewhispererruntime.model.CodeWhispererRuntimeException
30
24
import software.amazon.awssdk.services.codewhispererruntime.model.CreateUploadUrlResponse
25
+ import software.amazon.awssdk.services.codewhispererruntime.model.GetCodeAnalysisRequest
26
+ import software.amazon.awssdk.services.codewhispererruntime.model.GetCodeAnalysisResponse
27
+ import software.amazon.awssdk.services.codewhispererruntime.model.ListCodeAnalysisFindingsRequest
28
+ import software.amazon.awssdk.services.codewhispererruntime.model.ListCodeAnalysisFindingsResponse
31
29
import software.amazon.awssdk.services.codewhispererruntime.model.Reference
30
+ import software.amazon.awssdk.services.codewhispererruntime.model.StartCodeAnalysisRequest
31
+ import software.amazon.awssdk.services.codewhispererruntime.model.StartCodeAnalysisResponse
32
32
import software.aws.toolkits.core.utils.Waiters.waitUntil
33
33
import software.aws.toolkits.core.utils.debug
34
34
import software.aws.toolkits.core.utils.getLogger
@@ -145,7 +145,7 @@ class CodeWhispererCodeScanSession(val sessionContext: CodeScanSessionContext) {
145
145
}
146
146
}
147
147
var codeScanStatus = createCodeScanResponse.status()
148
- if (codeScanStatus == CodeScanStatus .FAILED ) {
148
+ if (codeScanStatus == CodeAnalysisStatus .FAILED ) {
149
149
if (isProjectScope()) {
150
150
LOG .debug {
151
151
" CodeWhisperer service error occurred. Something went wrong when creating a code review: $createCodeScanResponse " +
@@ -165,7 +165,7 @@ class CodeWhispererCodeScanSession(val sessionContext: CodeScanSessionContext) {
165
165
166
166
// 5. Keep polling the API GetCodeScan to wait for results for a given timeout period.
167
167
waitUntil(
168
- succeedOn = { codeScanStatus == CodeScanStatus .COMPLETED },
168
+ succeedOn = { codeScanStatus == CodeAnalysisStatus .COMPLETED },
169
169
maxDuration = Duration .ofSeconds(sessionContext.sessionConfig.overallJobTimeoutInSeconds())
170
170
) {
171
171
currentCoroutineContext.ensureActive()
@@ -182,7 +182,7 @@ class CodeWhispererCodeScanSession(val sessionContext: CodeScanSessionContext) {
182
182
}
183
183
}
184
184
delay(CODE_SCAN_POLLING_INTERVAL_IN_SECONDS * TOTAL_MILLIS_IN_SECOND )
185
- if (codeScanStatus == CodeScanStatus .FAILED ) {
185
+ if (codeScanStatus == CodeAnalysisStatus .FAILED ) {
186
186
if (isProjectScope()) {
187
187
LOG .debug {
188
188
" CodeWhisperer service error occurred. Something went wrong fetching results for code review: $getCodeScanResponse " +
@@ -205,12 +205,12 @@ class CodeWhispererCodeScanSession(val sessionContext: CodeScanSessionContext) {
205
205
)
206
206
207
207
val documents = mutableListOf<String >()
208
- documents.add(listCodeScanFindingsResponse.codeScanFindings ())
208
+ documents.add(listCodeScanFindingsResponse.codeAnalysisFindings ())
209
209
// coroutineContext helps to actively cancel the bigger projects quickly
210
210
withContext(currentCoroutineContext) {
211
211
while (listCodeScanFindingsResponse.nextToken() != null && currentCoroutineContext.isActive) {
212
212
listCodeScanFindingsResponse = listCodeScanFindings(jobId, listCodeScanFindingsResponse.nextToken())
213
- documents.add(listCodeScanFindingsResponse.codeScanFindings ())
213
+ documents.add(listCodeScanFindingsResponse.codeAnalysisFindings ())
214
214
}
215
215
}
216
216
@@ -224,7 +224,7 @@ class CodeWhispererCodeScanSession(val sessionContext: CodeScanSessionContext) {
224
224
codeScanResponseContext = codeScanResponseContext.copy(reason = " Succeeded" )
225
225
return CodeScanResponse .Success (issues, codeScanResponseContext)
226
226
} catch (e: Exception ) {
227
- val exception = e as ? CodeWhispererException
227
+ val exception = e as ? CodeWhispererRuntimeException
228
228
val awsError = exception?.awsErrorDetails()
229
229
230
230
if (awsError != null ) {
@@ -248,7 +248,7 @@ class CodeWhispererCodeScanSession(val sessionContext: CodeScanSessionContext) {
248
248
}
249
249
}
250
250
251
- fun createCodeScan (language : String , codeScanName : String ): CreateCodeScanResponse {
251
+ fun createCodeScan (language : String , codeScanName : String ): StartCodeAnalysisResponse {
252
252
val artifactsMap = mapOf (
253
253
ArtifactType .SOURCE_CODE to urlResponse[ArtifactType .SOURCE_CODE ]?.uploadId(),
254
254
ArtifactType .BUILT_JARS to urlResponse[ArtifactType .BUILT_JARS ]?.uploadId()
@@ -262,7 +262,7 @@ class CodeWhispererCodeScanSession(val sessionContext: CodeScanSessionContext) {
262
262
263
263
try {
264
264
return clientAdaptor.createCodeScan(
265
- CreateCodeScanRequest .builder()
265
+ StartCodeAnalysisRequest .builder()
266
266
.clientToken(clientToken.toString())
267
267
.programmingLanguage { it.languageName(language) }
268
268
.artifacts(artifactsMap)
@@ -277,9 +277,9 @@ class CodeWhispererCodeScanSession(val sessionContext: CodeScanSessionContext) {
277
277
}
278
278
}
279
279
280
- fun getCodeScan (jobId : String ): GetCodeScanResponse = try {
280
+ fun getCodeScan (jobId : String ): GetCodeAnalysisResponse = try {
281
281
clientAdaptor.getCodeScan(
282
- GetCodeScanRequest .builder()
282
+ GetCodeAnalysisRequest .builder()
283
283
.jobId(jobId)
284
284
.build()
285
285
)
@@ -289,11 +289,11 @@ class CodeWhispererCodeScanSession(val sessionContext: CodeScanSessionContext) {
289
289
throw codeScanServerException(" GetCodeReviewException: $errorMessage " )
290
290
}
291
291
292
- fun listCodeScanFindings (jobId : String , nextToken : String? ): ListCodeScanFindingsResponse = try {
292
+ fun listCodeScanFindings (jobId : String , nextToken : String? ): ListCodeAnalysisFindingsResponse = try {
293
293
clientAdaptor.listCodeScanFindings(
294
- ListCodeScanFindingsRequest .builder()
294
+ ListCodeAnalysisFindingsRequest .builder()
295
295
.jobId(jobId)
296
- .codeScanFindingsSchema( CodeScanFindingsSchema . CODESCAN_FINDINGS_1_0 )
296
+ .codeAnalysisFindingsSchema( CodeAnalysisFindingsSchema . CODEANALYSIS_FINDINGS_1_0 )
297
297
.nextToken(nextToken)
298
298
.build()
299
299
)
0 commit comments