Function postAgentMetadata

extensions/cli/src/util/metadata.ts:125–182

(
  agentId: string,
  metadata: Record<string, any>,
)

 * @param metadata - Arbitrary metadata object to post
 */
export async function postAgentMetadata(
  agentId: string,
  metadata: Record<string, any>,
): Promise<void> {
  const endpoint = `agents/${agentId}/metadata`;
  const fullUrl = new URL(endpoint, env.apiBase).toString();

  if (!agentId) {
    logger.debug("No agent ID provided, skipping metadata update");
    return;
  }

  if (!metadata || Object.keys(metadata).length === 0) {
    logger.debug("Empty metadata object, skipping metadata update");
    return;
  }

  const startTime = Date.now();
  logger.info(`[metadata] POST ${fullUrl}`, {
    agentId,
    metadataKeys: Object.keys(metadata),
  });
  logger.info("[metadata] Request body", { metadata });

  try {
    const response = await post(endpoint, { metadata });
    const duration = Date.now() - startTime;

    if (response.ok) {
      logger.info(
        `[metadata] Success: ${response.status} (${duration}ms) ${fullUrl}`,
      );
    } else {
      logger.warn(
        `[metadata] Unexpected response: ${response.status} (${duration}ms) ${fullUrl}`,
      );
    }
  } catch (error) {
    const duration = Date.now() - startTime;
    // Non-critical: Log but don't fail the entire agent execution
    if (error instanceof AuthenticationRequiredError) {
      logger.info(
        `[metadata] Auth required (skipping) (${duration}ms) ${fullUrl}`,
      );
    } else if (error instanceof ApiRequestError) {
      logger.warn(
        `[metadata] Failed: ${error.status} ${error.statusText} (${duration}ms) ${fullUrl}`,
        { response: error.response },
      );
    } else {
      const errorMessage =
        error instanceof Error ? error.message : String(error);
      logger.warn(
        `[metadata] Error: ${errorMessage} (${duration}ms) ${fullUrl}`,
      );
    }
  }
}