{"version":3,"file":"check-artifact-CMPXCqaV.cjs","names":["checkArtifactExistsHandler: CacheRouterHttpHandler","parseTokenFromHeaders","parseHashFromParams","parseTeamFromQuery","createStorageClient","responseError"],"sources":["../src/handlers/check-artifact.ts"],"sourcesContent":["import { createStorageClient } from \"../utils/azure-storage\";\nimport { responseError } from \"../utils/error-utils\";\nimport {\n  parseHashFromParams,\n  parseTeamFromQuery,\n  parseTokenFromHeaders,\n} from \"../utils/validators\";\nimport type { CacheRouterHttpHandler } from \"../utils/types\";\n\nexport const checkArtifactExistsHandler: CacheRouterHttpHandler =\n  (options) => async (request, context) => {\n    const authResult = parseTokenFromHeaders(\n      request.headers,\n      context,\n      options.turboToken\n    );\n    if (authResult !== true) return authResult;\n\n    const hash = parseHashFromParams(request.params, context);\n    if (typeof hash !== \"string\") return hash;\n\n    const team = parseTeamFromQuery(request.query, context);\n    if (typeof team !== \"string\") return team;\n\n    context.info(\"Check artifact by hash\", { team, hash });\n\n    try {\n      const service = await createStorageClient(options);\n      await service.existsCachedArtifactOrThrow(hash, team);\n\n      return { status: 200 };\n    } catch (error) {\n      return responseError(error, context, 404);\n    }\n  };\n"],"mappings":";;;;;AASA,MAAaA,6BACX,CAAC,YAAY,OAAO,SAAS,YAAY;CACvC,MAAM,aAAaC,yCACjB,QAAQ,SACR,SACA,QAAQ,WACT;AACD,KAAI,eAAe,KAAM,QAAO;CAEhC,MAAM,OAAOC,uCAAoB,QAAQ,QAAQ,QAAQ;AACzD,KAAI,OAAO,SAAS,SAAU,QAAO;CAErC,MAAM,OAAOC,sCAAmB,QAAQ,OAAO,QAAQ;AACvD,KAAI,OAAO,SAAS,SAAU,QAAO;CAErC,QAAQ,KAAK,0BAA0B;EAAE;EAAM;CAAM,EAAC;AAEtD,KAAI;EACF,MAAM,UAAU,MAAMC,0CAAoB,QAAQ;EAClD,MAAM,QAAQ,4BAA4B,MAAM,KAAK;AAErD,SAAO,EAAE,QAAQ,IAAK;CACvB,SAAQ,OAAO;AACd,SAAOC,kCAAc,OAAO,SAAS,IAAI;CAC1C;AACF"}