await this.page.locator(`[data-test="log-search-expand-${fieldName}-field-btn"]`).hover();
    await this.page.waitForTimeout(300);
}

async clickAddFieldToTableButton(fieldName) {
    await this.page.locator(`[data-test="log-search-index-list-add-${fieldName}-field-btn"]`).click();
    await this.page.waitForTimeout(1000);
}

async clickRemoveFieldFromTableButton(fieldName) {
    await this.page.locator(`[data-test="log-search-index-list-remove-${fieldName}-field-btn"]`).click();
    await this.page.waitForTimeout(1000);
}

const orgId = process.env["ORGNAME"];
const streamName = "e2e_automate";
const basicAuthCredentials = Buffer.from(
  `${process.env["ZO_ROOT_USER_EMAIL"]}:${process.env["ZO_ROOT_USER_PASSWORD"]}`
).toString('base64');

const headers = {
  "Authorization": `Basic ${basicAuthCredentials}`,
  "Content-Type": "application/json",
};

try {
  const response = await page.evaluate(async ({ url, headers, orgId, streamName, logsdata }) => {
    const fetchResponse = await fetch(`${url}/api/${orgId}/${streamName}/_json`, {
      method: 'POST',
      headers: headers,
      body: JSON.stringify(logsdata)
    });
    if (!fetchResponse.ok) {
      throw new Error(`HTTP error! status: ${fetchResponse.status}`);
    }
    return await fetchResponse.json();
  }, {
    url: process.env.INGESTION_URL,
    headers: headers,
    orgId: orgId,
    streamName: streamName,
    logsdata: logsdata
  });
  console.log('Ingestion response:', response);
  return response;
} catch (error) {
  console.error('Ingestion failed:', error);
  throw error;
}

  // Refresh the page
  await page.reload();
  await page.waitForLoadState('domcontentloaded');
  await page.waitForTimeout(2000);
  testLogger.info('Page refreshed');

  // Verify field is still visible in table after refresh
  await pageManager.logsPage.expectFieldInTableHeader(fieldName);
  testLogger.info('Field persistence after page refresh verified successfully');
});