fix(cli): add V2 asset support for logs and check-run-data retrieval [AI-61]

packages/cli/e2e/__tests__/checks-empty-account.spec.ts

@@ -3,8 +3,8 @@ import { describe, it, expect } from 'vitest'
 
 import { runChecklyCli } from '../run-checkly'
 
-const apiKey: string | undefined = config.get('emptyApiKey')
-const accountId: string | undefined = config.get('emptyAccountId')
+const apiKey: string | undefined = config.has('emptyApiKey') ? config.get('emptyApiKey') : undefined
+const accountId: string | undefined = config.has('emptyAccountId') ? config.get('emptyAccountId') : undefined
 
 describe.skipIf(!apiKey || !accountId)('checks commands on empty account', () => {
   it('should show "No checks found." for checks list', async () => {

packages/cli/src/rest/assets.ts

@@ -1,3 +1,4 @@
+import axios from 'axios'
 import type { AxiosInstance } from 'axios'
 
 // eslint-disable-next-line no-restricted-syntax
@@ -103,6 +104,8 @@ export default class Assets {
       case AssetType.LOG: {
         if (isCheckResultAssetsV1(asset) && asset.logPath) {
           key = asset.logPath
+        } else if (isCheckResultAssetsV2(asset)) {
+          return this.getAssetsV2(assetType, asset)
         } else if (isCheckResultAssetsV3(asset) && asset.logPath) {
           key = asset.clickHouseId
         }
@@ -111,6 +114,8 @@ export default class Assets {
       case AssetType.CHECK_RUN_DATA: {
         if (isCheckResultAssetsV1(asset) && asset.checkRunDataPath) {
           key = asset.checkRunDataPath
+        } else if (isCheckResultAssetsV2(asset)) {
+          return this.getAssetsV2(assetType, asset)
         } else if (isCheckResultAssetsV3(asset)) {
           key = asset.clickHouseId
           break
@@ -126,6 +131,22 @@ export default class Assets {
     return response.data
   }
 
+  private async getAssetsV2 (assetType: AssetType, asset: CheckResultAssetsV2): Promise<any> {
+    const entryName = assetType === AssetType.LOG ? 'logs.txt' : 'check-run-data.json'
+    const entry = asset.entries.find(e => e.name === entryName)
+    if (!entry) {
+      return
+    }
+
+    const presignedUrl = await this.getAssetsLink(asset.region, asset.key)
+    const response = await axios.get(presignedUrl, {
+      headers: { Range: `bytes=${entry.start}-${entry.end}` },
+      responseType: 'text',
+    })
+
+    return JSON.parse(response.data)
+  }
+
   async getAssetsLink (region: string, key: string): Promise<any> {
     const response = await this.api.get<string>(
       `/next/assets/${AssetType.CHECK_RUN_DATA}/${region}/${encodeURIComponent(key)}/redirect?link=true`)