import { HUAWEI_CCE_AUTH_TOKEN } from './constants.js';
import { logInfo, logError, logHttpRequest, logHttpResponse } from '../../utils/logs.js';
import { HuaweiListPodsResponseSchema, HuaweiListPodsResponse } from '../../schemas/huawei/index.js';
export async function HuaweiListPods(
region: string,
cluster_id: string,
): Promise<HuaweiListPodsResponse> {
logInfo(`HuaweiListPods called with region=${region}, cluster_id=${cluster_id}`);
if (!HUAWEI_CCE_AUTH_TOKEN) {
logError('HUAWEI_CCE_AUTH_TOKEN is missing');
throw new Error('HUAWEI_CCE_AUTH_TOKEN is missing');
}
let url = `https://${cluster_id}.cce.${region}.myhuaweicloud.com/api/v1/pods`;
logHttpRequest('GET', url, { 'x-auth-token': HUAWEI_CCE_AUTH_TOKEN });
try {
const response = await fetch(url, {
method: 'GET',
headers: {
"x-auth-token": `${HUAWEI_CCE_AUTH_TOKEN}`
}
});
const respBody = await response.json();
logHttpResponse(response.status, undefined, respBody, undefined);
if (!response.ok) {
logError(`Huawei CCE API error: ${response.statusText}`);
throw new Error(`Huawei CCE API error: ${response.statusText},${response.statusText}`);
}
logInfo('HuaweiListPods succeeded');
return HuaweiListPodsResponseSchema.parse(respBody);
} catch (error) {
logError(`HuaweiListPods error: ${error}`);
throw error;
}
}