Function createUpdateHandlerFactory

actions/setup/js/update_handler_factory.cjs:118–320

* Creates a handler factory function with common update logic * This factory encapsulates the shared control flow: * - Configuration defaults (target, max count) * - Max count enforcement * - Target resolution * - Empty update validation * - Success/error response shaping * * @param {UpdateH

(handlerConfig)

 * @returns {HandlerFactoryFunction} Handler factory function
 */
function createUpdateHandlerFactory(handlerConfig) {
  const { itemType, itemTypeName, supportsPR, resolveItemNumber, buildUpdateData, executeUpdate, formatSuccessResult, additionalConfig = {}, itemFilter = null, captureExecutionMetadata = null } = handlerConfig;

  /**
   * Main handler factory
   * @type {HandlerFactoryFunction}
   */
  return async function main(config = {}) {
    // Extract configuration with defaults
    const updateTarget = config.target || "triggering";
    const maxCount = config.max || 10;

    // Create an authenticated GitHub client. Uses config["github-token"] when set
    // (for cross-repository operations), otherwise falls back to the step-level github.
    const githubClient = await createAuthenticatedGitHubClient(config);

    // Resolve default target repo and allowed repos for cross-repository routing.
    // If no target-repo is configured, defaults to the current repository.
    const { defaultTargetRepo, allowedRepos } = resolveTargetRepoConfig(config);

    // Check if we're in staged mode
    const isStaged = isStagedMode(config);

    const configParts = [
      `max=${maxCount}`,
      `target=${updateTarget}`,
      ...Object.entries(additionalConfig)
        .filter(([key]) => config[key] !== undefined)
        .map(([key]) => `${key}=${config[key]}`),
    ];

    core.info(`Update ${itemTypeName} configuration: ${configParts.join(", ")}`);

    // Track state
    let processedCount = 0;

    /**
     * Message handler function
     * @param {Object} message - The update message
     * @param {Object} resolvedTemporaryIds - Resolved temporary IDs
     * @returns {Promise<Object>} Result
     */
    return async function handleUpdate(message, resolvedTemporaryIds) {
      // Check max limit
      if (processedCount >= maxCount) {
        core.warning(`Skipping ${itemType}: max count of ${maxCount} reached`);
        return {
          success: false,
          error: `Max count of ${maxCount} reached`,
        };
      }

      processedCount++;

      const item = message;

      // Resolve cross-repo target: always validate the target repository against the
      // allowed repos and use it as the effective context. When item.repo is set it