Function createCloseEntityHandler

actions/setup/js/close_entity_helpers.cjs:265–455

* Create a message-level close-entity handler function. * * Centralises the common close-flow pipeline: * 1. Max-count gating * 2. Comment body resolution (item.body → config.comment fallback) * 3. Content sanitization * 4. Target repository / entity number resolution (via callbacks.re

(config, entityConfig, callbacks, githubClient)

 * @returns {import('./types/handler-factory').MessageHandlerFunction} Message handler function
 */
function createCloseEntityHandler(config, entityConfig, callbacks, githubClient) {
  const requiredLabels = config.required_labels || [];
  const requiredTitlePrefix = config.required_title_prefix || "";
  const maxCount = config.max || 10;
  const comment = config.comment || "";
  const isStaged = isStagedMode(config);
  const { defaultTargetRepo, allowedRepos } = resolveTargetRepoConfig(config);
  const allowBody = config.allow_body !== false; // default true; false only when explicitly set to false

  let processedCount = 0;

  return async function handleCloseEntity(message, resolvedTemporaryIds) {
    // 1. Max-count gating
    if (processedCount >= maxCount) {
      core.warning(`Skipping ${entityConfig.itemType}: max count of ${maxCount} reached`);
      return { success: false, error: `Max count of ${maxCount} reached` };
    }
    processedCount++;

    const item = message;

    // Log message structure for debugging (avoid logging body content)
    const logFields = { has_body: !!item.body, body_length: item.body ? item.body.length : 0 };
    if (item[entityConfig.numberField] !== undefined) {
      logFields[entityConfig.numberField] = item[entityConfig.numberField];
    }
    if (item.repo !== undefined) {
      logFields.has_repo = true;
    }
    core.info(`Processing ${entityConfig.itemType} message: ${JSON.stringify(logFields)}`);

    // 2. Comment body resolution
    /** @type {string|undefined} */
    let commentToPost;
    /** @type {string} */
    let commentSource = "unknown";

    if (!allowBody) {
      // allow-body: false — drop any body the agent provided and skip the comment
      if (typeof item.body === "string" && item.body.trim() !== "") {
        core.warning(`${entityConfig.itemType}: allow-body is false — dropping non-empty body (length=${item.body.length}) and closing without a comment`);
      } else {
        core.info(`${entityConfig.itemType}: allow-body is false — closing without a comment`);
      }
      commentToPost = undefined;
    } else if (typeof item.body === "string" && item.body.trim() !== "") {
      commentToPost = item.body;
      commentSource = "item.body";
    } else if (typeof comment === "string" && comment.trim() !== "") {
      commentToPost = comment;
      commentSource = "config.comment";
    } else {
      core.warning("No comment body provided in message and no default comment configured");
      return { success: false, error: "No comment body provided" };
    }

    if (commentToPost !== undefined) {
      core.info(`Comment body determined: length=${commentToPost.length}, source=${commentSource}`);