import json
	import re
	import sys
	from collections.abc import Callable, Mapping
	from functools import partial
	from typing import TYPE_CHECKING, Any
	from xml.dom.minidom import parseString
	
	import pcs.lib.pacemaker.live as lib_pacemaker
	import pcs.lib.resource_agent as lib_ra
	from pcs import constraint, utils
	from pcs.cli.cluster_property.output import PropertyConfigurationFacade
	from pcs.cli.common.errors import CmdLineInputError
	from pcs.cli.common.output import format_wrap_for_terminal
	from pcs.cli.common.parse_args import (
	    FUTURE_OPTION,
	    FUTURE_OPTION_DEPRECATION_WARNING,
	    OUTPUT_FORMAT_VALUE_CMD,
	    OUTPUT_FORMAT_VALUE_JSON,
	    OUTPUT_FORMAT_VALUE_TEXT,
	    Argv,
	    InputModifiers,
	    KeyValueParser,
	    get_rule_str,
	    group_by_keywords,
	    wait_to_timeout,
	)
	from pcs.cli.common.tools import print_to_stderr, timeout_to_seconds_legacy
	from pcs.cli.nvset import filter_out_expired_nvset, nvset_dto_list_to_lines
	from pcs.cli.reports.output import deprecation_warning, error, warn
	from pcs.cli.reports.processor import (
	    ReportProcessorToConsole,
	    report_and_exit_on_error,
	)
	from pcs.cli.resource.common import check_is_not_stonith
	from pcs.cli.resource.output import (
	    operation_defaults_to_cmd,
	    resource_agent_metadata_to_text,
	    resource_defaults_to_cmd,
	)
	from pcs.cli.resource.parse_args import (
	    parse_bundle_create_options,
	    parse_bundle_reset_options,
	    parse_bundle_update_options,
	    parse_clone,
	    parse_create,
	)
	from pcs.cli.resource_agent import find_single_agent
	from pcs.common import const, pacemaker, reports
	from pcs.common.interface import dto
	from pcs.common.pacemaker.defaults import CibDefaultsDto
	from pcs.common.pacemaker.resource.operations import (
	    OCF_CHECK_LEVEL_INSTANCE_ATTRIBUTE_NAME,
	)
	from pcs.lib.cib import const as cib_const
	from pcs.lib.cib.resource import guest_node, operations, primitive
	from pcs.lib.cib.tools import get_resources
	from pcs.lib.commands.resource import (
	    _get_nodes_to_validate_against,
	    _validate_guest_change,
	)
	from pcs.lib.errors import LibraryError
	from pcs.lib.pacemaker.values import is_true, validate_id
	from pcs.settings import (
	    pacemaker_wait_timeout_status as PACEMAKER_WAIT_TIMEOUT_STATUS,
	)
	
	if TYPE_CHECKING:
	    from pcs.common.resource_agent.dto import ResourceAgentNameDto
	
	RESOURCE_RELOCATE_CONSTRAINT_PREFIX = "pcs-relocate-"
	
	
	def _detect_guest_change(
	    meta_attributes: Mapping[str, str], allow_not_suitable_command: bool
	) -> None:
	    """
	    Commandline options:
	      * -f - CIB file
	    """
	    if not guest_node.is_node_name_in_options(meta_attributes):
	        return
	
	    env = utils.get_lib_env()
	    cib = env.get_cib()
	    (
	        existing_nodes_names,
	        existing_nodes_addrs,
	        report_list,
	    ) = _get_nodes_to_validate_against(env, cib)
	    if env.report_processor.report_list(
	        report_list
	        + _validate_guest_change(
	            cib,
	            existing_nodes_names,
	            existing_nodes_addrs,
	            meta_attributes,
	            allow_not_suitable_command,
	            detect_remove=True,
	        )
	    ).has_errors:
	        raise LibraryError()
	
	
	def resource_utilization_cmd(
	    lib: Any, argv: Argv, modifiers: InputModifiers
	) -> None:
	    """
	    Options:
	      * -f - CIB file
	    """
	    modifiers.ensure_only_supported("-f")
	    resource_id = None
	    if argv:
	        resource_id = argv.pop(0)
	        check_is_not_stonith(lib, [resource_id])
	    utils.print_warning_if_utilization_attrs_has_no_effect(
	        PropertyConfigurationFacade.from_properties_dtos(
	            lib.cluster_property.get_properties(),
	            lib.cluster_property.get_properties_metadata(),
	        )
	    )
	    if not resource_id:
	        print_resources_utilization()
	        return
	    if argv:
	        set_resource_utilization(resource_id, argv)
	    else:
	        print_resource_utilization(resource_id)
	
	
	def _defaults_set_create_cmd(
	    lib_command: Callable[..., Any], argv: Argv, modifiers: InputModifiers
	) -> None:
	    modifiers.ensure_only_supported("-f", "--force")
	
	    groups = group_by_keywords(
	        argv, {"meta", "rule"}, implicit_first_keyword="options"
	    )
	    groups.ensure_unique_keywords()
	    force_flags = set()
	    if modifiers.get("--force"):
	        force_flags.add(reports.codes.FORCE)
	
	    lib_command(
	        KeyValueParser(groups.get_args_flat("meta")).get_unique(),
	        KeyValueParser(groups.get_args_flat("options")).get_unique(),
	        nvset_rule=get_rule_str(groups.get_args_flat("rule")),
	        force_flags=force_flags,
	    )
	
	
	def resource_defaults_set_create_cmd(
	    lib: Any, argv: Argv, modifiers: InputModifiers
	) -> None:
	    """
	    Options:
	      * -f - CIB file
	      * --force - allow unknown options
	    """
	    return _defaults_set_create_cmd(
	        lib.cib_options.resource_defaults_create, argv, modifiers
	    )
	
	
	def resource_op_defaults_set_create_cmd(
	    lib: Any, argv: Argv, modifiers: InputModifiers
	) -> None:
	    """
	    Options:
	      * -f - CIB file
	      * --force - allow unknown options
	    """
	    return _defaults_set_create_cmd(
	        lib.cib_options.operation_defaults_create, argv, modifiers
	    )
	
	
	def _filter_defaults(
	    cib_defaults_dto: CibDefaultsDto, include_expired: bool
	) -> CibDefaultsDto:
	    return CibDefaultsDto(
	        instance_attributes=(
	            cib_defaults_dto.instance_attributes
	            if include_expired
	            else filter_out_expired_nvset(cib_defaults_dto.instance_attributes)
	        ),
	        meta_attributes=(
	            cib_defaults_dto.meta_attributes
	            if include_expired
	            else filter_out_expired_nvset(cib_defaults_dto.meta_attributes)
	        ),
	    )
	
	
	def _defaults_config_cmd(
	    lib_command: Callable[[bool], CibDefaultsDto],
	    defaults_to_cmd: Callable[[CibDefaultsDto], list[list[str]]],
	    argv: Argv,
	    modifiers: InputModifiers,
	) -> None:
	    """
	    Options:
	      * -f - CIB file
	      * --all - display all nvsets including the ones with expired rules
	      * --full - verbose output
	      * --no-expire-check -- disable evaluating whether rules are expired
	      * --output-format - supported formats: text, cmd, json
	    """
	    if argv:
	        raise CmdLineInputError()
	    modifiers.ensure_only_supported(
	        "-f",
	        "--all",
	        "--full",
	        "--no-expire-check",
	        output_format_supported=True,
	    )
	    modifiers.ensure_not_mutually_exclusive("--all", "--no-expire-check")
	    output_format = modifiers.get_output_format()
	    if (
	        modifiers.is_specified("--full")
	        and output_format != OUTPUT_FORMAT_VALUE_TEXT
	    ):
	        raise CmdLineInputError(
	            f"option '--full' is not compatible with '{output_format}' output format."
	        )
	    cib_defaults_dto = _filter_defaults(
	        lib_command(not modifiers.get("--no-expire-check")),
	        bool(modifiers.get("--all")),
	    )
	    if output_format == OUTPUT_FORMAT_VALUE_CMD:
	        output = ";\n".join(
	            " \\\n".join(cmd) for cmd in defaults_to_cmd(cib_defaults_dto)
	        )
	    elif output_format == OUTPUT_FORMAT_VALUE_JSON:
	        output = json.dumps(dto.to_dict(cib_defaults_dto))
	    else:
	        output = "\n".join(
	            nvset_dto_list_to_lines(
	                cib_defaults_dto.meta_attributes,
	                nvset_label="Meta Attrs",
	                with_ids=bool(modifiers.get("--full")),
	            )
	        )
	    if output:
	        print(output)
	
	
	def resource_defaults_config_cmd(
	    lib: Any, argv: Argv, modifiers: InputModifiers
	) -> None:
	    """
	    Options:
	      * -f - CIB file
	      * --full - verbose output
	    """
	    return _defaults_config_cmd(
	        lib.cib_options.resource_defaults_config,
	        resource_defaults_to_cmd,
	        argv,
	        modifiers,
	    )
	
	
	def resource_op_defaults_config_cmd(
	    lib: Any, argv: Argv, modifiers: InputModifiers
	) -> None:
	    """
	    Options:
	      * -f - CIB file
	      * --full - verbose output
	    """
	    return _defaults_config_cmd(
	        lib.cib_options.operation_defaults_config,
	        operation_defaults_to_cmd,
	        argv,
	        modifiers,
	    )
	
	
	def _defaults_set_remove_cmd(
	    lib_command: Callable[..., Any], argv: Argv, modifiers: InputModifiers
	) -> None:
	    """
	    Options:
	      * -f - CIB file
	    """
	    modifiers.ensure_only_supported("-f")
	    lib_command(argv)
	
	
	def resource_defaults_set_remove_cmd(
	    lib: Any, argv: Argv, modifiers: InputModifiers
	) -> None:
	    """
	    Options:
	      * -f - CIB file
	    """
	    return _defaults_set_remove_cmd(
	        lib.cib_options.resource_defaults_remove, argv, modifiers
	    )
	
	
	def resource_op_defaults_set_remove_cmd(
	    lib: Any, argv: Argv, modifiers: InputModifiers
	) -> None:
	    """
	    Options:
	      * -f - CIB file
	    """
	    return _defaults_set_remove_cmd(
	        lib.cib_options.operation_defaults_remove, argv, modifiers
	    )
	
	
	def _defaults_set_update_cmd(
	    lib_command: Callable[..., Any], argv: Argv, modifiers: InputModifiers
	) -> None:
	    """
	    Options:
	      * -f - CIB file
	    """
	    modifiers.ensure_only_supported("-f")
	    if not argv:
	        raise CmdLineInputError()
	
	    set_id = argv[0]
	    groups = group_by_keywords(argv[1:], {"meta"})
	    groups.ensure_unique_keywords()
	    lib_command(
	        set_id, KeyValueParser(groups.get_args_flat("meta")).get_unique()
	    )
	
	
	def resource_defaults_set_update_cmd(
	    lib: Any, argv: Argv, modifiers: InputModifiers
	) -> None:
	    """
	    Options:
	      * -f - CIB file
	    """
	    return _defaults_set_update_cmd(
	        lib.cib_options.resource_defaults_update, argv, modifiers
	    )
	
	
	def resource_op_defaults_set_update_cmd(
	    lib: Any, argv: Argv, modifiers: InputModifiers
	) -> None:
	    """
	    Options:
	      * -f - CIB file
	    """
	    return _defaults_set_update_cmd(
	        lib.cib_options.operation_defaults_update, argv, modifiers
	    )
	
	
	def resource_defaults_update_cmd(
	    lib: Any,
	    argv: Argv,
	    modifiers: InputModifiers,
	) -> None:
	    """
	    Options:
	      * -f - CIB file
	    """
	    del modifiers
	    return lib.cib_options.resource_defaults_update(
	        None, KeyValueParser(argv).get_unique()
	    )
	
	
	def resource_op_defaults_update_cmd(
	    lib: Any,
	    argv: Argv,
	    modifiers: InputModifiers,
	) -> None:
	    """
	    Options:
	      * -f - CIB file
	    """
	    del modifiers
	    return lib.cib_options.operation_defaults_update(
	        None, KeyValueParser(argv).get_unique()
	    )
	
	
	def op_add_cmd(lib: Any, argv: Argv, modifiers: InputModifiers) -> None:
	    """
	    Options:
	      * -f - CIB file
	      * --force - allow unknown options
	    """
	    if not argv:
	        raise CmdLineInputError()
	    check_is_not_stonith(lib, [argv[0]], "pcs stonith op add")
	    resource_op_add(lib.env.report_processor, argv, modifiers)
	
	
	def resource_op_add(
	    report_processor: ReportProcessorToConsole,
	    argv: Argv,
	    modifiers: InputModifiers,
	) -> None:
	    """
	    Commandline options:
	      * -f - CIB file
	      * --force - allow unknown options
	    """
	    modifiers.ensure_only_supported("-f", "--force")
	    if not argv:
	        raise CmdLineInputError()
	    res_id = argv.pop(0)
	
	    # Check if we need to upgrade cib schema.
	    # To do that, argv must be parsed, which is duplication of parsing in
	    # resource_operation_add. But we need to upgrade the cib first before
	    # calling that function. Hopefully, this will be fixed in the new pcs
	    # architecture.
	
	    # argv[0] is an operation name
	    dom = None
	    op_properties = utils.convert_args_to_tuples(argv[1:])
	    for key, value in op_properties:
	        if key == "on-fail" and value == "demote":
	            dom = utils.cluster_upgrade_to_version(
	                const.PCMK_ON_FAIL_DEMOTE_CIB_VERSION
	            )
	            break
	    if dom is None:
	        dom = utils.get_cib_dom()
	
	    res_el = utils.dom_get_resource(dom, res_id)
	    if not res_el:
	        utils.err("Unable to find resource: %s" % res_id)
	
	    agent_name = _get_resource_agent_name_from_rsc_el(res_el)
	    try:
	        agent_facade = _get_resource_agent_facade(agent_name)
	    except lib_ra.ResourceAgentError as e:
	        if bool(modifiers.get("--force")):
	            severity = reports.ReportItemSeverity.warning()
	            agent_facade = _get_void_resource_agent_facade(agent_name)
	        else:
	            severity = reports.ReportItemSeverity.error(reports.codes.FORCE)
	        report_and_exit_on_error(
	            report_processor,
	            [lib_ra.resource_agent_error_to_report_item(e, severity)],
	        )
	
	    allowed_operation_name_list = [
	        op.name for op in agent_facade.metadata.actions
	    ]
	    utils.replace_cib_configuration(
	        resource_operation_add(
	            report_processor,
	            dom,
	            res_id,
	            argv,
	            allowed_operation_name_list=allowed_operation_name_list,
	        )
	    )
	
	
	def op_delete_cmd(lib: Any, argv: Argv, modifiers: InputModifiers) -> None:
	    """
	    Options:
	      * -f - CIB file
	    """
	    modifiers.ensure_only_supported("-f")
	    if not argv:
	        raise CmdLineInputError()
	    resource_id = argv.pop(0)
	    check_is_not_stonith(lib, [resource_id], "pcs stonith op delete")
	    resource_operation_remove(resource_id, argv)
	
	
	def parse_resource_options(
	    argv: Argv,
	) -> tuple[list[str], list[list[str]], list[str]]:
	    """
	    Commandline options: no options
	    """
	    ra_values = []
	    op_values: list[list[str]] = []
	    meta_values = []
	    op_args = False
	    meta_args = False
	    for arg in argv:
	        if arg == "op":
	            op_args = True
	            meta_args = False
	            op_values.append([])
	        elif arg == "meta":
	            meta_args = True
	            op_args = False
	        elif op_args:
	            if arg == "op":
	                op_values.append([])
	            elif "=" not in arg and op_values[-1]:
	                op_values.append([])
	                op_values[-1].append(arg)
	            else:
	                op_values[-1].append(arg)
	        elif meta_args:
	            if "=" in arg:
	                meta_values.append(arg)
	        else:
	            ra_values.append(arg)
	    return ra_values, op_values, meta_values
	
	
	def resource_list_available(
	    lib: Any, argv: Argv, modifiers: InputModifiers
	) -> None:
	    """
	    Options:
	      * --nodesc - don't display description
	    """
	    modifiers.ensure_only_supported("--nodesc")
	    if len(argv) > 1:
	        raise CmdLineInputError()
	
	    search = argv[0] if argv else None
	    agent_list = lib.resource_agent.list_agents(
	        not modifiers.get("--nodesc"), search
	    )
	
	    if not agent_list:
	        if search:
	            utils.err("No resource agents matching the filter.")
	        utils.err(
	            "No resource agents available. Do you have resource agents installed?"
	        )
	
	    for agent_info in agent_list:
	        name = agent_info["name"]
	        shortdesc = agent_info["shortdesc"]
	        if shortdesc:
	            normalized_desc = " ".join(shortdesc.split())
	            print(
	                "\n".join(
	                    format_wrap_for_terminal(f"{name} - {normalized_desc}")
	                )
	            )
	        else:
	            print(name)
	
	
	def resource_list_options(
	    lib: Any, argv: Argv, modifiers: InputModifiers
	) -> None:
	    """
	    Options:
	      * --full - show advanced
	    """
	    modifiers.ensure_only_supported("--full")
	    if len(argv) != 1:
	        raise CmdLineInputError()
	
	    agent_name_str = argv[0]
	    agent_name: ResourceAgentNameDto
	    if ":" in agent_name_str:
	        agent_name = lib.resource_agent.get_structured_agent_name(
	            agent_name_str
	        )
	    else:
	        agent_name = find_single_agent(
	            lib.resource_agent.get_agents_list().names, agent_name_str
	        )
	    if agent_name.standard == "stonith":
	        error(
	            reports.messages.CommandArgumentTypeMismatch(
	                "stonith / fence agents"
	            ).message
	            + " Please use 'pcs stonith describe' instead."
	        )
	    print(
	        "\n".join(
	            resource_agent_metadata_to_text(
	                lib.resource_agent.get_agent_metadata(agent_name),
	                lib.resource_agent.get_agent_default_operations(
	                    agent_name
	                ).operations,
	                verbose=modifiers.is_specified("--full"),
	            )
	        )
	    )
	
	
	def resource_create(lib: Any, argv: Argv, modifiers: InputModifiers) -> None:  # noqa: PLR0912 PLR0915
	    """
	    Options:
	      * --agent-validation - use agent self validation of instance attributes
	      * --force - allow not existing agent, invalid operations or invalid
	        instance attributes, allow not suitable command
	      * --disabled - created resource will be disabled
	      * --no-default-ops - do not add default operations
	      * --wait
	      * -f - CIB file
	      * --future - no longer has any effect, only prints a deprecation warning
	    """
	    modifiers.ensure_only_supported(
	        "--agent-validation",
	        "--force",
	        "--disabled",
	        "--no-default-ops",
	        "--wait",
	        "-f",
	        FUTURE_OPTION,
	        hint_syntax_changed="1.0",
	    )
	    modifiers.ensure_not_mutually_exclusive("-f", "--wait")
	    wait_timeout = wait_to_timeout(modifiers.get("--wait"))
	    if wait_timeout >= 0:
	        # deprecated in the first version of 0.12
	        deprecation_warning(reports.messages.ResourceWaitDeprecated().message)
	    if modifiers.is_specified(FUTURE_OPTION):
	        deprecation_warning(FUTURE_OPTION_DEPRECATION_WARNING)
	
	    if len(argv) < 2:
	        raise CmdLineInputError()
	
	    ra_id = argv[0]
	    ra_type = argv[1]
	
	    parts = parse_create(argv[2:])
	
	    defined_options = set()
	    if parts.bundle_id:
	        defined_options.add("bundle")
	    if parts.clone:
	        defined_options.add("clone")
	    if parts.promotable:
	        defined_options.add("promotable")
	    if parts.group:
	        defined_options.add("group")
	    if len(defined_options) > 1:
	        raise CmdLineInputError(
	            "you can specify only one of clone, promotable, bundle or group"
	        )
	
	    if parts.group:
	        if parts.group.after_resource and parts.group.before_resource:
	            raise CmdLineInputError(
	                "you cannot specify both 'before' and 'after'"
	            )
	
	    if parts.promotable and "promotable" in parts.promotable.meta_attrs:
	        raise CmdLineInputError(
	            "you cannot specify both promotable option and promotable keyword"
	        )
	
	    settings = dict(
	        allow_absent_agent=modifiers.get("--force"),
	        allow_invalid_operation=modifiers.get("--force"),
	        allow_invalid_instance_attributes=modifiers.get("--force"),
	        ensure_disabled=modifiers.get("--disabled"),
	        use_default_operations=not modifiers.get("--no-default-ops"),
	        allow_not_suitable_command=modifiers.get("--force"),
	        enable_agent_self_validation=modifiers.get("--agent-validation"),
	    )
	
	    if parts.clone:
	        lib.resource.create_as_clone(
	            ra_id,
	            ra_type,
	            parts.primitive.operations,
	            parts.primitive.meta_attrs,
	            parts.primitive.instance_attrs,
	            parts.clone.meta_attrs,
	            clone_id=parts.clone.clone_id,
	            allow_incompatible_clone_meta_attributes=modifiers.get("--force"),
	            **settings,
	        )
	    elif parts.promotable:
	        lib.resource.create_as_clone(
	            ra_id,
	            ra_type,
	            parts.primitive.operations,
	            parts.primitive.meta_attrs,
	            parts.primitive.instance_attrs,
	            dict(**parts.promotable.meta_attrs, promotable="true"),
	            clone_id=parts.promotable.clone_id,
	            allow_incompatible_clone_meta_attributes=modifiers.get("--force"),
	            **settings,
	        )
	    elif parts.bundle_id:
	        settings["allow_not_accessible_resource"] = modifiers.get("--force")
	        lib.resource.create_into_bundle(
	            ra_id,
	            ra_type,
	            parts.primitive.operations,
	            parts.primitive.meta_attrs,
	            parts.primitive.instance_attrs,
	            parts.bundle_id,
	            **settings,
	        )
	    elif parts.group:
	        adjacent_resource_id = None
	        put_after_adjacent = False
	        if parts.group.after_resource:
	            adjacent_resource_id = parts.group.after_resource
	            put_after_adjacent = True
	        if parts.group.before_resource:
	            adjacent_resource_id = parts.group.before_resource
	            put_after_adjacent = False
	
	        lib.resource.create_in_group(
	            ra_id,
	            ra_type,
	            parts.group.group_id,
	            parts.primitive.operations,
	            parts.primitive.meta_attrs,
	            parts.primitive.instance_attrs,
	            adjacent_resource_id=adjacent_resource_id,
	            put_after_adjacent=put_after_adjacent,
	            **settings,
	        )
	    else:
	        lib.resource.create(
	            ra_id,
	            ra_type,
	            parts.primitive.operations,
	            parts.primitive.meta_attrs,
	            parts.primitive.instance_attrs,
	            **settings,
	        )
	
	    if wait_timeout >= 0:
	        lib.cluster.wait_for_pcmk_idle(wait_timeout)
	
	
	def _parse_resource_move_ban(
	    argv: Argv,
	) -> tuple[str, str | None, str | None]:
	    resource_id = argv.pop(0)
	    node = None
	    lifetime = None
	    while argv:
	        arg = argv.pop(0)
	        if arg.startswith("lifetime="):
	            if lifetime:
	                raise CmdLineInputError()
	            lifetime = arg.split("=")[1]
	            if lifetime and lifetime[0] in list("0123456789"):
	                lifetime = "P" + lifetime
	        elif not node:
	            node = arg
	        else:
	            raise CmdLineInputError()
	    return resource_id, node, lifetime
	
	
	def resource_move_with_constraint(
	    lib: Any, argv: Argv, modifiers: InputModifiers
	) -> None:
	    """
	    Options:
	      * -f - CIB file
	      * --promoted
	      * --wait
	    """
	    modifiers.ensure_only_supported("-f", "--promoted", "--wait")
	
	    if not argv:
	        raise CmdLineInputError("must specify a resource to move")
	    if len(argv) > 3:
	        raise CmdLineInputError()
	    resource_id, node, lifetime = _parse_resource_move_ban(argv)
	
	    lib.resource.move(
	        resource_id,
	        node=node,
	        master=modifiers.is_specified("--promoted"),
	        lifetime=lifetime,
	        wait=modifiers.get("--wait"),
	    )
	
	
	def resource_move(lib: Any, argv: Argv, modifiers: InputModifiers) -> None:
	    """
	    Options:
	      * --promoted
	      * --strict
	      * --wait
	    """
	    modifiers.ensure_only_supported(
	        "--promoted", "--strict", "--wait", hint_syntax_changed="0.12"
	    )
	
	    if not argv:
	        raise CmdLineInputError("must specify a resource to move")
	    resource_id = argv.pop(0)
	    node = None
	    if argv:
	        node = argv.pop(0)
	    if argv:
	        raise CmdLineInputError()
	
	    lib.resource.move_autoclean(
	        resource_id,
	        node=node,
	        master=modifiers.is_specified("--promoted"),
	        wait_timeout=wait_to_timeout(modifiers.get("--wait")),
	        strict=modifiers.get("--strict"),
	    )
	
	
	def resource_ban(lib: Any, argv: Argv, modifiers: InputModifiers) -> None:
	    """
	    Options:
	      * -f - CIB file
	      * --promoted
	      * --wait
	    """
	    modifiers.ensure_only_supported("-f", "--promoted", "--wait")
	
	    if not argv:
	        raise CmdLineInputError("must specify a resource to ban")
	    if len(argv) > 3:
	        raise CmdLineInputError()
	    resource_id, node, lifetime = _parse_resource_move_ban(argv)
	
	    lib.resource.ban(
	        resource_id,
	        node=node,
	        master=modifiers.is_specified("--promoted"),
	        lifetime=lifetime,
	        wait=modifiers.get("--wait"),
	    )
	
	
	def resource_unmove_unban(
	    lib: Any, argv: Argv, modifiers: InputModifiers
	) -> None:
	    """
	    Options:
	      * -f - CIB file
	      * --promoted
	      * --wait
	    """
	    modifiers.ensure_only_supported("-f", "--expired", "--promoted", "--wait")
	
	    if not argv:
	        raise CmdLineInputError("must specify a resource to clear")
	    if len(argv) > 2:
	        raise CmdLineInputError()
	    resource_id = argv.pop(0)
	    node = argv.pop(0) if argv else None
	
	    lib.resource.unmove_unban(
	        resource_id,
	        node=node,
	        master=modifiers.is_specified("--promoted"),
	        expired=modifiers.is_specified("--expired"),
	        wait=modifiers.get("--wait"),
	    )
	
	
	def resource_standards(lib: Any, argv: Argv, modifiers: InputModifiers) -> None:
	    """
	    Options: no options
	    """
	    modifiers.ensure_only_supported()
	    if argv:
	        raise CmdLineInputError()
	
	    standards = lib.resource_agent.list_standards()
	
	    if standards:
	        print("\n".join(standards))
	    else:
	        utils.err("No standards found")
	
	
	def resource_providers(lib: Any, argv: Argv, modifiers: InputModifiers) -> None:
	    """
	    Options: no options
	    """
	    modifiers.ensure_only_supported()
	    if argv:
	        raise CmdLineInputError()
	
	    providers = lib.resource_agent.list_ocf_providers()
	
	    if providers:
	        print("\n".join(providers))
	    else:
	        utils.err("No OCF providers found")
	
	
	def resource_agents(lib: Any, argv: Argv, modifiers: InputModifiers) -> None:
	    """
	    Options: no options
	    """
	    modifiers.ensure_only_supported()
	    if len(argv) > 1:
	        raise CmdLineInputError()
	
	    standard = argv[0] if argv else None
	
	    agents = lib.resource_agent.list_agents_for_standard_and_provider(standard)
	
	    if agents:
	        print("\n".join(agents))
	    else:
	        utils.err(
	            "No agents found{0}".format(
	                " for {0}".format(argv[0]) if argv else ""
	            )
	        )
	
	
	def update_cmd(lib: Any, argv: Argv, modifiers: InputModifiers) -> None:
	    """
	    Options:
	      * -f - CIB file
	      * --agent-validation - use agent self validation of instance attributes
	      * --wait
	      * --force - allow invalid options, do not fail if not possible to get
	        agent metadata, allow not suitable command
	    """
	    if not argv:
	        raise CmdLineInputError()
	    check_is_not_stonith(lib, [argv[0]], "pcs stonith update")
	    resource_update(lib.env.report_processor, argv, modifiers)
	
	
	# Update a resource, removing any args that are empty and adding/updating
	# args that are not empty
	def resource_update(  # noqa: PLR0912, PLR0915
	    report_processor: ReportProcessorToConsole,
	    args: Argv,
	    modifiers: InputModifiers,
	) -> None:
	    """
	    Commandline options:
	      * -f - CIB file
	      * --agent-validation - use agent self validation of instance attributes
	      * --wait
	      * --force - allow invalid options, do not fail if not possible to get
	        agent metadata, allow not suitable command
	    """
	    modifiers.ensure_only_supported(
	        "-f", "--wait", "--force", "--agent-validation"
	    )
	    if len(args) < 2:
	        raise CmdLineInputError()
	    res_id = args.pop(0)
	
	    # Extract operation arguments
	    ra_values, op_values, meta_values = parse_resource_options(args)
	
	    wait = False
	    wait_timeout = None
	    if modifiers.is_specified("--wait"):
	        # deprecated in the first version of 0.12
	        report_processor.report(
	            reports.ReportItem.deprecation(
	                reports.messages.ResourceWaitDeprecated()
	            )
	        )
	        wait_timeout = utils.validate_wait_get_timeout()
	        wait = True
	
	    # Check if we need to upgrade cib schema.
	    # To do that, argv must be parsed, which is duplication of parsing below.
	    # But we need to upgrade the cib first before calling that function.
	    # Hopefully, this will be fixed in the new pcs architecture.
	
	    cib_upgraded = False
	    for op_argv in op_values:
	        if cib_upgraded:
	            break
	        if len(op_argv) < 2:
	            continue
	        # argv[0] is an operation name
	        op_vars = utils.convert_args_to_tuples(op_argv[1:])
	        for key, value in op_vars:
	            if key == "on-fail" and value == "demote":
	                utils.cluster_upgrade_to_version(
	                    const.PCMK_ON_FAIL_DEMOTE_CIB_VERSION
	                )
	                cib_upgraded = True
	                break
	
	    cib_xml = utils.get_cib()
	    dom = utils.get_cib_dom(cib_xml=cib_xml)
	
	    resource = utils.dom_get_resource(dom, res_id)
	    if not resource:
	        clone = utils.dom_get_clone(dom, res_id)
	        master = utils.dom_get_master(dom, res_id)
	        if clone or master:
	            if master:
	                clone = transform_master_to_clone(master)
	            clone_child = utils.dom_elem_get_clone_ms_resource(clone)
	            if clone_child:
	                child_id = clone_child.getAttribute("id")
	                new_args = ["meta"] + ra_values + meta_values
	                for op_args in op_values:
	                    if op_args:
	                        new_args += ["op"] + op_args
	                return resource_update_clone(
	                    report_processor,
	                    dom,
	                    clone,
	                    child_id,
	                    new_args,
	                    wait,
	                    wait_timeout,
	                )
	        utils.err("Unable to find resource: %s" % res_id)
	
	    params = utils.convert_args_to_tuples(ra_values)
	
	    agent_name = _get_resource_agent_name_from_rsc_el(resource)
	    try:
	        agent_facade = _get_resource_agent_facade(agent_name)
	        allowed_operation_name_list = [
	            op.name for op in agent_facade.metadata.actions
	        ]
	        report_list = primitive.validate_resource_instance_attributes_update(
	            utils.cmd_runner(),
	            agent_facade,
	            dict(params),
	            res_id,
	            get_resources(lib_pacemaker.get_cib(cib_xml)),
	            force=bool(modifiers.get("--force")),
	            enable_agent_self_validation=bool(
	                modifiers.get("--agent-validation")
	            ),
	        )
	        if report_list:
	            report_and_exit_on_error(report_processor, report_list)
	    except lib_ra.ResourceAgentError as e:
	        report_and_exit_on_error(
	            report_processor,
	            [
	                lib_ra.resource_agent_error_to_report_item(
	                    e,
	                    reports.get_severity(
	                        reports.codes.FORCE, bool(modifiers.get("--force"))
	                    ),
	                )
	            ],
	        )
	        # If --force is not specified, report_and_exit_on_error raises, and the
	        # command ends. Otherwise we continue with a void agent facade.
	        agent_facade = _get_void_resource_agent_facade(agent_name)
	        allowed_operation_name_list = [
	            op.name for op in agent_facade.metadata.actions
	        ]
	
	    utils.dom_update_instance_attr(resource, params)
	
	    remote_node_name = utils.dom_get_resource_remote_node_name(resource)
	
	    # The "remote-node" meta attribute makes sense (and causes creation of
	    # inner pacemaker resource) only for primitive. The meta attribute
	    # "remote-node" has no special meaning for clone/master. So there is no
	    # need for checking this attribute in clone/master.
	    #
	    # It is ok to not to check it until this point in this function:
	    # 1) Only master/clone element is updated if the parameter "res_id" is an id
	    # of the clone/master element. In that case another function is called and
	    # the code path does not reach this point.
	    # 2) No persistent changes happened until this line if the parameter
	    # "res_id" is an id of the primitive.
	    meta_options = KeyValueParser(meta_values).get_unique()
	    if remote_node_name != guest_node.get_guest_option_value(meta_options):
	        _detect_guest_change(
	            meta_options,
	            bool(modifiers.get("--force")),
	        )
	
	    # TODO: validation should be added after migrating the command to the new
	    # architecture
	    if any(meta_options.values()):
	        command = "stonith" if agent_name.is_stonith else "resource"
	        warn(
	            "Meta attributes are not validated by this command. For "
	            f"validation, please use 'pcs {command} meta' instead."
	        )
	
	    utils.dom_update_meta_attr(
	        resource, utils.convert_args_to_tuples(meta_values)
	    )
	
	    operations_el = resource.getElementsByTagName("operations")
	    if not operations_el:
	        operations_el = dom.createElement("operations")
	        resource.appendChild(operations_el)
	    else:
	        operations_el = operations_el[0]
	
	    get_role = partial(
	        pacemaker.role.get_value_for_cib,
	        is_latest_supported=utils.isCibVersionSatisfied(
	            dom, const.PCMK_NEW_ROLES_CIB_VERSION
	        ),
	    )
	    for op_argv in op_values:
	        if not op_argv:
	            continue
	
	        op_name = op_argv[0]
	        if op_name.find("=") != -1:
	            utils.err(
	                "%s does not appear to be a valid operation action" % op_name
	            )
	
	        if len(op_argv) < 2:
	            continue
	
	        op_role = ""
	        op_vars = utils.convert_args_to_tuples(op_argv[1:])
	
	        for key, value in op_vars:
	            if key == "role":
	                op_role = get_role(value)
	                break
	
	        updating_op = None
	        updating_op_before = None
	        for existing_op in operations_el.getElementsByTagName("op"):
	            if updating_op:
	                updating_op_before = existing_op
	                break
	            existing_op_name = existing_op.getAttribute("name")
	            existing_op_role = get_role(existing_op.getAttribute("role"))
	            if existing_op_role == op_role and existing_op_name == op_name:
	                updating_op = existing_op
	                continue
	
	        if updating_op:
	            updating_op.parentNode.removeChild(updating_op)
	        dom = resource_operation_add(
	            report_processor,
	            dom,
	            res_id,
	            op_argv,
	            validate_strict=False,
	            before_op=updating_op_before,
	            allowed_operation_name_list=allowed_operation_name_list,
	        )
	
	    utils.replace_cib_configuration(dom)
	
	    if (
	        remote_node_name
	        and remote_node_name
	        != utils.dom_get_resource_remote_node_name(resource)
	    ):
	        # if the resource was a remote node and it is not anymore, (or its name
	        # changed) we need to tell pacemaker about it
	        output, retval = utils.run(
	            ["crm_node", "--force", "--remove", remote_node_name]
	        )
	
	    if modifiers.is_specified("--wait"):
	        args = ["crm_resource", "--wait"]
	        if wait_timeout:
	            args.extend(["--timeout=%s" % wait_timeout])
	        output, retval = utils.run(args)
	        running_on = utils.resource_running_on(res_id)
	        if retval == 0:
	            print_to_stderr(running_on["message"])
	        else:
	            msg = []
	            if retval == PACEMAKER_WAIT_TIMEOUT_STATUS:
	                msg.append("waiting timeout")
	            msg.append(running_on["message"])
	            if retval != 0 and output:
	                msg.append("\n" + output)
	            utils.err("\n".join(msg).strip())
	    return None
	
	
	def resource_update_clone(
	    report_processor, dom, clone, res_id, args, wait, wait_timeout
	):
	    """
	    Commandline options:
	      * -f - CIB file
	    """
	    dom, dummy_clone_id = resource_clone_create(
	        report_processor, dom, [res_id] + args, update_existing=True
	    )
	
	    utils.replace_cib_configuration(dom)
	
	    if wait:
	        args = ["crm_resource", "--wait"]
	        if wait_timeout:
	            args.extend(["--timeout=%s" % wait_timeout])
	        output, retval = utils.run(args)
	        running_on = utils.resource_running_on(clone.getAttribute("id"))
	        if retval == 0:
	            print_to_stderr(running_on["message"])
	        else:
	            msg = []
	            if retval == PACEMAKER_WAIT_TIMEOUT_STATUS:
	                msg.append("waiting timeout")
	            msg.append(running_on["message"])
	            if retval != 0 and output:
	                msg.append("\n" + output)
	            utils.err("\n".join(msg).strip())
	
	    return dom
	
	
	def transform_master_to_clone(master_element):
	    # create a new clone element with the same id
	    dom = master_element.ownerDocument
	    clone_element = dom.createElement("clone")
	    clone_element.setAttribute("id", master_element.getAttribute("id"))
	    # place it next to the master element
	    master_element.parentNode.insertBefore(clone_element, master_element)
	    # move all master's children to the clone
	    while master_element.firstChild:
	        clone_element.appendChild(master_element.firstChild)
	    # remove the master
	    master_element.parentNode.removeChild(master_element)
	    # set meta to make the clone promotable
	    utils.dom_update_meta_attr(clone_element, [("promotable", "true")])
	    return clone_element
	
	
	def resource_operation_add(  # noqa: PLR0912, PLR0915
	    report_processor,
	    dom,
	    res_id,
	    argv,
	    validate_strict=True,
	    before_op=None,
	    allowed_operation_name_list=None,
	):
	    """
	    Commandline options:
	      * --force
	    """
	    if not argv:
	        raise CmdLineInputError()
	
	    res_el = utils.dom_get_resource(dom, res_id)
	    if not res_el:
	        utils.err("Unable to find resource: %s" % res_id)
	
	    op_name = argv.pop(0)
	    op_properties = utils.convert_args_to_tuples(argv)
	
	    if "=" in op_name:
	        utils.err("%s does not appear to be a valid operation action" % op_name)
	
	    op_dict = dict(op_properties)
	    if "name" in op_dict and op_dict["name"] != op_name:
	        raise CmdLineInputError(
	            "duplicate option 'name' with different values "
	            f"'{op_name}' and '{op_dict['name']}'"
	        )
	    op_dict["name"] = op_name
	
	    normalized = operations.operations_to_normalized([op_dict])
	    report_list = operations.validate_operation_list(
	        normalized,
	        allowed_operation_name_list or [],
	        allow_invalid="--force" in utils.pcs_options,
	    )
	    if report_list:
	        report_and_exit_on_error(report_processor, report_list)
	
	    new_role_names_supported = utils.isCibVersionSatisfied(
	        dom, const.PCMK_NEW_ROLES_CIB_VERSION
	    )
	    op_normalized = operations.normalized_to_operations(
	        normalized, new_role_names_supported
	    )[0]
	    op_properties = sorted(op_normalized.items())
	
	    interval = None
	    for key, val in op_properties:
	        if key == "interval":
	            interval = val
	            break
	    if not interval:
	        interval = "60s" if op_name == "monitor" else "0s"
	        op_properties.append(("interval", interval))
	
	    generate_id = True
	    for name, value in op_properties:
	        if name == "id":
	            op_id = value
	            generate_id = False
	            id_valid, id_error = utils.validate_xml_id(value, "operation id")
	            if not id_valid:
	                utils.err(id_error)
	            if utils.does_id_exist(dom, value):
	                utils.err(
	                    "id '%s' is already in use, please specify another one"
	                    % value
	                )
	    if generate_id:
	        op_id = "%s-%s-interval-%s" % (res_id, op_name, interval)
	        op_id = utils.find_unique_id(dom, op_id)
	
	    op_el = dom.createElement("op")
	    op_el.setAttribute("id", op_id)
	    for key, val in op_properties:
	        if key == OCF_CHECK_LEVEL_INSTANCE_ATTRIBUTE_NAME:
	            attrib_el = dom.createElement("instance_attributes")
	            attrib_el.setAttribute(
	                "id", utils.find_unique_id(dom, "params-" + op_id)
	            )
	            op_el.appendChild(attrib_el)
	            nvpair_el = dom.createElement("nvpair")
	            nvpair_el.setAttribute("name", key)
	            nvpair_el.setAttribute("value", val)
	            nvpair_el.setAttribute(
	                "id", utils.find_unique_id(dom, "-".join((op_id, key, val)))
	            )
	            attrib_el.appendChild(nvpair_el)
	        else:
	            op_el.setAttribute(key, val)
	
	    operations_el = res_el.getElementsByTagName("operations")
	    if not operations_el:
	        operations_el = dom.createElement("operations")
	        res_el.appendChild(operations_el)
	    else:
	        operations_el = operations_el[0]
	        duplicate_op_list = utils.operation_exists(operations_el, op_el)
	        if duplicate_op_list:
	            utils.err(
	                "operation %s with interval %ss already specified for %s:\n%s"
	                % (
	                    op_el.getAttribute("name"),
	                    timeout_to_seconds_legacy(op_el.getAttribute("interval")),
	                    res_id,
	                    "\n".join(
	                        [operation_to_string(op) for op in duplicate_op_list]
	                    ),
	                )
	            )
	        if validate_strict and "--force" not in utils.pcs_options:
	            duplicate_op_list = utils.operation_exists_by_name(
	                operations_el, op_el
	            )
	            if duplicate_op_list:
	                msg = (
	                    "operation {action} already specified for {res}"
	                    + ", use --force to override:\n{op}"
	                )
	                utils.err(
	                    msg.format(
	                        action=op_el.getAttribute("name"),
	                        res=res_id,
	                        op="\n".join(
	                            [
	                                operation_to_string(op)
	                                for op in duplicate_op_list
	                            ]
	                        ),
	                    )
	                )
	
	    operations_el.insertBefore(op_el, before_op)
	    return dom
	
	
	def resource_operation_remove(res_id: str, argv: Argv) -> None:  # noqa: PLR0912
	    """
	    Commandline options:
	      * -f - CIB file
	    """
	    # if no args, then we're removing an operation id
	
	    # Do not ever remove an operations element, even if it is empty. There may
	    # be ACLs set in pacemaker which allow "write" for op elements (adding,
	    # changing and removing) but not operations elements. In such a case,
	    # removing an operations element would cause the whole change to be
	    # rejected by pacemaker with a "permission denied" message.
	    # https://bugzilla.redhat.com/show_bug.cgi?id=1642514
	
	    dom = utils.get_cib_dom()
	    if not argv:
	        for operation in dom.getElementsByTagName("op"):
	            if operation.getAttribute("id") == res_id:
	                parent = operation.parentNode
	                parent.removeChild(operation)
	                utils.replace_cib_configuration(dom)
	                return
	        utils.err("unable to find operation id: %s" % res_id)
	
	    original_argv = " ".join(argv)
	
	    op_name = argv.pop(0)
	    resource_el = None
	
	    for resource in dom.getElementsByTagName("primitive"):
	        if resource.getAttribute("id") == res_id:
	            resource_el = resource
	            break
	
	    if not resource_el:
	        utils.err("Unable to find resource: %s" % res_id)
	        # return to let mypy know that resource_el is not None anymore
	        return
	
	    remove_all = False
	    if not argv:
	        remove_all = True
	
	    op_properties = utils.convert_args_to_tuples(argv)
	    op_properties.append(("name", op_name))
	    found_match = False
	    for op in resource_el.getElementsByTagName("op"):
	        temp_properties = []
	        for attr_name in op.attributes.keys():  # noqa: SIM118, attributes is not a dict
	            if attr_name == "id":
	                continue
	            temp_properties.append(
	                (attr_name, op.attributes.get(attr_name).nodeValue)
	            )
	
	        if remove_all and op.attributes["name"].value == op_name:
	            found_match = True
	            parent = op.parentNode
	            parent.removeChild(op)
	        elif not set(op_properties) ^ set(temp_properties):
	            found_match = True
	            parent = op.parentNode
	            parent.removeChild(op)
	            break
	
	    if not found_match:
	        utils.err("Unable to find operation matching: %s" % original_argv)
	
	    utils.replace_cib_configuration(dom)
	
	
	def resource_group_rm_cmd(
	    lib: Any, argv: Argv, modifiers: InputModifiers
	) -> None:
	    """
	    Options:
	      * --wait
	      * -f - CIB file
	    """
	    modifiers.ensure_only_supported("--wait", "-f")
	    if not argv:
	        raise CmdLineInputError()
	    group_name = argv.pop(0)
	    resource_ids = argv
	
	    cib_dom = resource_group_rm(utils.get_cib_dom(), group_name, resource_ids)
	
	    if modifiers.is_specified("--wait"):
	        # deprecated in the first version of 0.12
	        lib.env.report_processor.report(
	            reports.ReportItem.deprecation(
	                reports.messages.ResourceWaitDeprecated()
	            )
	        )
	        wait_timeout = utils.validate_wait_get_timeout()
	
	    utils.replace_cib_configuration(cib_dom)
	
	    if modifiers.is_specified("--wait"):
	        args = ["crm_resource", "--wait"]
	        if wait_timeout:
	            args.extend(["--timeout=%s" % wait_timeout])
	        output, retval = utils.run(args)
	        if retval != 0:
	            msg = []
	            if retval == PACEMAKER_WAIT_TIMEOUT_STATUS:
	                msg.append("waiting timeout")
	            if output:
	                msg.append("\n" + output)
	            utils.err("\n".join(msg).strip())
	
	
	def resource_group_add_cmd(
	    lib: Any, argv: Argv, modifiers: InputModifiers
	) -> None:
	    """
	    Options:
	      * --wait
	      * -f - CIB file
	      * --after - place a resource in a group after the specified resource in
	        the group
	      * --before - place a resource in a group before the specified resource in
	        the group
	    """
	    modifiers.ensure_only_supported("--wait", "-f", "--after", "--before")
	    if len(argv) < 2:
	        raise CmdLineInputError()
	
	    group_name = argv.pop(0)
	    resource_names = argv
	    adjacent_name = None
	    after_adjacent = True
	    if modifiers.is_specified("--after") and modifiers.is_specified("--before"):
	        raise CmdLineInputError("you cannot specify both --before and --after")
	    if modifiers.is_specified("--after"):
	        adjacent_name = modifiers.get("--after")
	        after_adjacent = True
	    elif modifiers.is_specified("--before"):
	        adjacent_name = modifiers.get("--before")
	        after_adjacent = False
	
	    lib.resource.group_add(
	        group_name,
	        resource_names,
	        adjacent_resource_id=adjacent_name,
	        put_after_adjacent=after_adjacent,
	        wait=modifiers.get("--wait"),
	    )
	
	
	def resource_clone(
	    lib: Any, argv: Argv, modifiers: InputModifiers, promotable: bool = False
	) -> None:
	    """
	    Options:
	      * --wait
	      * -f - CIB file
	      * --force - allow to clone stonith resource
	    """
	    modifiers.ensure_only_supported("-f", "--force", "--wait")
	    if not argv:
	        raise CmdLineInputError()
	
	    res = argv[0]
	    check_is_not_stonith(lib, [res])
	    cib_dom = utils.get_cib_dom()
	
	    if modifiers.is_specified("--wait"):
	        # deprecated in the first version of 0.12
	        lib.env.report_processor.report(
	            reports.ReportItem.deprecation(
	                reports.messages.ResourceWaitDeprecated()
	            )
	        )
	        wait_timeout = utils.validate_wait_get_timeout()
	
	    force_flags = set()
	    if modifiers.get("--force"):
	        force_flags.add(reports.codes.FORCE)
	
	    cib_dom, clone_id = resource_clone_create(
	        lib.env.report_processor,
	        cib_dom,
	        argv,
	        promotable=promotable,
	        force_flags=force_flags,
	    )
	    cib_dom = constraint.constraint_resource_update(res, cib_dom)
	    utils.replace_cib_configuration(cib_dom)
	
	    if modifiers.is_specified("--wait"):
	        args = ["crm_resource", "--wait"]
	        if wait_timeout:
	            args.extend(["--timeout=%s" % wait_timeout])
	        output, retval = utils.run(args)
	        running_on = utils.resource_running_on(clone_id)
	        if retval == 0:
	            print_to_stderr(running_on["message"])
	        else:
	            msg = []
	            if retval == PACEMAKER_WAIT_TIMEOUT_STATUS:
	                msg.append("waiting timeout")
	            msg.append(running_on["message"])
	            if output:
	                msg.append("\n" + output)
	            utils.err("\n".join(msg).strip())
	
	
	def _resource_is_ocf(resource_el) -> bool:
	    return resource_el.getAttribute("class") == "ocf"
	
	
	def _get_resource_agent_name_from_rsc_el(
	    resource_el,
	) -> lib_ra.ResourceAgentName:
	    return lib_ra.ResourceAgentName(
	        resource_el.getAttribute("class"),
	        resource_el.getAttribute("provider"),
	        resource_el.getAttribute("type"),
	    )
	
	
	def _get_resource_agent_facade(
	    resource_agent: lib_ra.ResourceAgentName,
	) -> lib_ra.ResourceAgentFacade:
	    return lib_ra.ResourceAgentFacadeFactory(
	        utils.cmd_runner(), utils.get_report_processor()
	    ).facade_from_parsed_name(resource_agent)
	
	
	def _get_void_resource_agent_facade(
	    resource_agent: lib_ra.ResourceAgentName,
	) -> lib_ra.ResourceAgentFacade:
	    return lib_ra.ResourceAgentFacadeFactory(
	        utils.cmd_runner(), utils.get_report_processor()
	    ).void_facade_from_parsed_name(resource_agent)
	
	
	def resource_clone_create(  # noqa: PLR0912
	    report_processor,
	    cib_dom,
	    argv,
	    update_existing=False,
	    promotable=False,
	    force_flags=(),
	):
	    """
	    Commandline options:
	      * --force - allow to clone stonith resource
	    """
	    name = argv.pop(0)
	
	    resources_el = cib_dom.getElementsByTagName("resources")[0]
	    element = utils.dom_get_resource(resources_el, name) or utils.dom_get_group(
	        resources_el, name
	    )
	    if not element:
	        utils.err("unable to find group or resource: %s" % name)
	
	    if element.parentNode.tagName == "bundle":
	        utils.err("cannot clone bundle resource")
	
	    if not update_existing:
	        if utils.dom_get_resource_clone(
	            cib_dom, name
	        ) or utils.dom_get_resource_masterslave(cib_dom, name):
	            utils.err("%s is already a clone resource" % name)
	
	        if utils.dom_get_group_clone(
	            cib_dom, name
	        ) or utils.dom_get_group_masterslave(cib_dom, name):
	            utils.err("cannot clone a group that has already been cloned")
	    else:
	        if element.parentNode.tagName != "clone":
	            utils.err("%s is not currently a clone" % name)
	        clone = element.parentNode
	
	    # If element is currently in a group and it's the last member, we get rid
	    # of the group
	    if (
	        element.parentNode.tagName == "group"
	        and element.parentNode.getElementsByTagName("primitive").length <= 1
	    ):
	        element.parentNode.parentNode.removeChild(element.parentNode)
	
	    if element.getAttribute("class") == "stonith":
	        report_and_exit_on_error(
	            report_processor,
	            [
	                reports.ReportItem(
	                    severity=reports.item.get_severity(
	                        reports.codes.FORCE,
	                        is_forced=reports.codes.FORCE in force_flags,
	                    ),
	                    message=reports.messages.CloningStonithResourcesHasNoEffect(
	                        [name]
	                    ),
	                )
	            ],
	        )
	
	    parts = parse_clone(argv, promotable=promotable)
	    _check_clone_incompatible_options_child(
	        element,
	        parts.meta_attrs,
	        report_processor,
	        force=reports.codes.FORCE in force_flags,
	    )
	
	    if not update_existing:
	        clone_id = parts.clone_id
	        if clone_id is not None:
	            report_list = []
	            validate_id(clone_id, reporter=report_list)
	            if report_list:
	                raise CmdLineInputError("invalid id '{}'".format(clone_id))
	            if utils.does_id_exist(cib_dom, clone_id):
	                raise CmdLineInputError(
	                    "id '{}' already exists".format(clone_id),
	                )
	        else:
	            clone_id = utils.find_unique_id(cib_dom, name + "-clone")
	        clone = cib_dom.createElement("clone")
	        clone.setAttribute("id", clone_id)
	        clone.appendChild(element)
	        resources_el.appendChild(clone)
	
	    # TODO: validation should be added after migrating the command to the new
	    # architecture
	    if any(
	        value
	        for name, value in parts.meta_attrs.items()
	        if name != "promotable" or not promotable
	    ):
	        warn(
	            reports.messages.MetaAttrsNotValidatedUnsupportedType(
	                [cib_const.TAG_RESOURCE_CLONE]
	            ).message
	        )
	    utils.dom_update_meta_attr(clone, sorted(parts.meta_attrs.items()))
	
	    return cib_dom, clone.getAttribute("id")
	
	
	def _check_clone_incompatible_options_child(
	    child_el,
	    clone_meta_attrs: Mapping[str, str],
	    report_processor,
	    force: bool = False,
	):
	    report_list = []
	    if child_el.tagName == "primitive":
	        report_list = _check_clone_incompatible_options_primitive(
	            child_el, clone_meta_attrs, force=force
	        )
	    elif child_el.tagName == "group":
	        group_id = child_el.getAttribute("id")
	        for primitive_el in utils.get_group_children_el_from_el(child_el):
	            report_list.extend(
	                _check_clone_incompatible_options_primitive(
	                    primitive_el,
	                    clone_meta_attrs,
	                    group_id=group_id,
	                    force=force,
	                )
	            )
	    if report_list:
	        report_and_exit_on_error(report_processor, report_list)
	
	
	def _check_clone_incompatible_options_primitive(
	    primitive_el,
	    clone_meta_attrs: Mapping[str, str],
	    group_id: str | None = None,
	    force: bool = False,
	) -> reports.ReportItemList:
	    resource_agent_name = _get_resource_agent_name_from_rsc_el(primitive_el)
	    primitive_id = primitive_el.getAttribute("id")
	    if not _resource_is_ocf(primitive_el):
	        for incompatible_attribute in ("globally-unique", "promotable"):
	            if is_true(clone_meta_attrs.get(incompatible_attribute, "0")):
	                return [
	                    reports.ReportItem.error(
	                        reports.messages.ResourceCloneIncompatibleMetaAttributes(
	                            incompatible_attribute,
	                            resource_agent_name.to_dto(),
	                            resource_id=primitive_id,
	                            group_id=group_id,
	                        )
	                    )
	                ]
	    else:
	        try:
	            resource_agent_facade = _get_resource_agent_facade(
	                resource_agent_name
	            )
	        except lib_ra.ResourceAgentError as e:
	            return [
	                lib_ra.resource_agent_error_to_report_item(
	                    e, reports.get_severity(reports.codes.FORCE, force)
	                )
	            ]
	        if resource_agent_facade.metadata.ocf_version == "1.1" and (
	            is_true(clone_meta_attrs.get("promotable", "0"))
	            and not resource_agent_facade.metadata.provides_promotability
	        ):
	            return [
	                reports.ReportItem(
	                    reports.get_severity(reports.codes.FORCE, force),
	                    reports.messages.ResourceCloneIncompatibleMetaAttributes(
	                        "promotable",
	                        resource_agent_name.to_dto(),
	                        resource_id=primitive_id,
	                        group_id=group_id,
	                    ),
	                )
	            ]
	    return []
	
	
	def resource_clone_master_remove(
	    lib: Any, argv: Argv, modifiers: InputModifiers
	) -> None:
	    """
	    Options:
	      * -f - CIB file
	      * --wait
	    """
	    modifiers.ensure_only_supported("-f", "--wait")
	    if len(argv) != 1:
	        raise CmdLineInputError()
	
	    name = argv.pop()
	    dom = utils.get_cib_dom()
	    resources_el = dom.documentElement.getElementsByTagName("resources")[0]
	
	    # get the resource no matter if user entered a clone or a cloned resource
	    resource = (
	        utils.dom_get_resource(resources_el, name)
	        or utils.dom_get_group(resources_el, name)
	        or utils.dom_get_clone_ms_resource(resources_el, name)
	    )
	    if not resource:
	        utils.err("could not find resource: %s" % name)
	    resource_id = resource.getAttribute("id")
	    clone = utils.dom_get_resource_clone_ms_parent(resources_el, resource_id)
	    if not clone:
	        utils.err("'%s' is not a clone resource" % name)
	
	    if modifiers.is_specified("--wait"):
	        # deprecated in the first version of 0.12
	        lib.env.report_processor.report(
	            reports.ReportItem.deprecation(
	                reports.messages.ResourceWaitDeprecated()
	            )
	        )
	        wait_timeout = utils.validate_wait_get_timeout()
	
	    # if user requested uncloning a resource contained in a cloned group
	    # remove the resource from the group and leave the clone itself alone
	    # unless the resource is the last one in the group
	    clone_child = utils.dom_get_clone_ms_resource(
	        resources_el, clone.getAttribute("id")
	    )
	    if (
	        clone_child.tagName == "group"
	        and resource.tagName != "group"
	        and len(clone_child.getElementsByTagName("primitive")) > 1
	    ):
	        resource_group_rm(dom, clone_child.getAttribute("id"), [resource_id])
	    else:
	        remove_resource_references(dom, clone.getAttribute("id"))
	        clone.parentNode.appendChild(resource)
	        clone.parentNode.removeChild(clone)
	    utils.replace_cib_configuration(dom)
	
	    if modifiers.is_specified("--wait"):
	        args = ["crm_resource", "--wait"]
	        if wait_timeout:
	            args.extend(["--timeout=%s" % wait_timeout])
	        output, retval = utils.run(args)
	        running_on = utils.resource_running_on(resource_id)
	        if retval == 0:
	            print_to_stderr(running_on["message"])
	        else:
	            msg = []
	            if retval == PACEMAKER_WAIT_TIMEOUT_STATUS:
	                msg.append("waiting timeout")
	            msg.append(running_on["message"])
	            if output:
	                msg.append("\n" + output)
	            utils.err("\n".join(msg).strip())
	
	
	def stonith_level_rm_device(cib_dom, stn_id):
	    """
	    Commandline options: no options
	    """
	    topology_el_list = cib_dom.getElementsByTagName("fencing-topology")
	    if not topology_el_list:
	        return cib_dom
	    topology_el = topology_el_list[0]
	    for level_el in topology_el.getElementsByTagName("fencing-level"):
	        device_list = level_el.getAttribute("devices").split(",")
	        if stn_id in device_list:
	            new_device_list = [dev for dev in device_list if dev != stn_id]
	            if new_device_list:
	                level_el.setAttribute("devices", ",".join(new_device_list))
	            else:
	                level_el.parentNode.removeChild(level_el)
	    if not topology_el.getElementsByTagName("fencing-level"):
	        topology_el.parentNode.removeChild(topology_el)
	    return cib_dom
	
	
	def remove_resource_references(
	    dom, resource_id, output=False, constraints_element=None
	):
	    """
	    Commandline options: no options
	    NOTE: -f - will be used only if dom will be None
	    """
	    for obj_ref in dom.getElementsByTagName("obj_ref"):
	        if obj_ref.getAttribute("id") == resource_id:
	            tag = obj_ref.parentNode
	            tag.removeChild(obj_ref)
	            if tag.getElementsByTagName("obj_ref").length == 0:
	                remove_resource_references(
	                    dom,
	                    tag.getAttribute("id"),
	                    output=output,
	                )
	                tag.parentNode.removeChild(tag)
	    constraint.remove_constraints_containing(
	        resource_id, output, constraints_element, dom
	    )
	    stonith_level_rm_device(dom, resource_id)
	
	    for permission in dom.getElementsByTagName("acl_permission"):
	        if permission.getAttribute("reference") == resource_id:
	            permission.parentNode.removeChild(permission)
	
	    return dom
	
	
	# This removes a resource from a group, but keeps it in the config
	def resource_group_rm(cib_dom, group_name, resource_ids):
	    """
	    Commandline options: no options
	    """
	    dom = cib_dom.getElementsByTagName("configuration")[0]
	
	    all_resources = len(resource_ids) == 0
	
	    group_match = utils.dom_get_group(dom, group_name)
	    if not group_match:
	        utils.err("Group '%s' does not exist" % group_name)
	
	    resources_to_move = []
	    if all_resources:
	        resources_to_move.extend(
	            list(group_match.getElementsByTagName("primitive"))
	        )
	    else:
	        for resource_id in resource_ids:
	            resource = utils.dom_get_resource(group_match, resource_id)
	            if resource:
	                resources_to_move.append(resource)
	            else:
	                utils.err(
	                    "Resource '%s' does not exist in group '%s'"
	                    % (resource_id, group_name)
	                )
	
	    # If the group is in a clone, we don't delete the clone as there may be
	    # constraints associated with it which the user may want to keep. However,
	    # there may be several resources in the group. In that case there is no way
	    # to figure out which one of them should stay in the clone. So we forbid
	    # removing all resources from a cloned group unless there is just one
	    # resource.
	    # This creates an inconsistency:
	    # - consider a cloned group with two resources
	    # - move one resource from the group - it becomes a primitive
	    # - move the last resource from the group - it stays in the clone
	    # So far there has been no request to change this behavior. Unless there is
	    # a request / reason to change it, we'll keep it that way.
	    is_cloned_group = group_match.parentNode.tagName in ["clone", "master"]
	    res_in_group = len(group_match.getElementsByTagName("primitive"))
	    if (
	        is_cloned_group
	        and res_in_group > 1
	        and len(resources_to_move) == res_in_group
	    ):
	        utils.err("Cannot remove all resources from a cloned group")
	    target_node = group_match.parentNode
	    if is_cloned_group and res_in_group > 1:
	        target_node = dom.getElementsByTagName("resources")[0]
	    for resource in resources_to_move:
	        resource.parentNode.removeChild(resource)
	        target_node.appendChild(resource)
	
	    if not group_match.getElementsByTagName("primitive"):
	        group_match.parentNode.removeChild(group_match)
	        remove_resource_references(dom, group_name, output=True)
	
	    return cib_dom
	
	
	def resource_group_list(
	    lib: Any, argv: Argv, modifiers: InputModifiers
	) -> None:
	    """
	    Options:
	      * -f - CIB file
	    """
	    del lib
	    modifiers.ensure_only_supported("-f")
	    if argv:
	        raise CmdLineInputError()
	    group_xpath = "//group"
	    group_xml = utils.get_cib_xpath(group_xpath)
	
	    # If no groups exist, we silently return
	    if group_xml == "":
	        return
	

	    element = parseString(group_xml).documentElement
	    # If there is more than one group returned it's wrapped in an xpath-query
	    # element
	    # Ignoring mypy errors in this very old code. So far, nobody reported a bug
	    # related to these lines.
	    if element.tagName == "xpath-query":  # type: ignore
	        elements = element.getElementsByTagName("group")  # type: ignore
	    else:
	        elements = [element]
	
	    for e in elements:
	        line_parts = [e.getAttribute("id") + ":"]
	        line_parts.extend(
	            resource.getAttribute("id")
	            for resource in e.getElementsByTagName("primitive")
	        )
	        print(" ".join(line_parts))
	
	
	def resource_status(  # noqa: PLR0912, PLR0915
	    lib: Any, argv: Argv, modifiers: InputModifiers, stonith: bool = False
	) -> None:
	    """
	    Options:
	      * -f - CIB file
	      * --hide-inactive - print only active resources
	    """
	    del lib
	    modifiers.ensure_only_supported("-f", "--hide-inactive")
	    if len(argv) > 2:
	        raise CmdLineInputError()
	
	    monitor_command = ["crm_mon", "--one-shot"]
	    if not modifiers.get("--hide-inactive"):
	        monitor_command.append("--inactive")
	
	    resource_or_tag_id = None
	    node = None
	    crm_mon_err_msg = "unable to get cluster status from crm_mon\n"
	    if argv:
	        for arg in argv[:]:
	            if "=" not in arg:
	                resource_or_tag_id = arg
	                crm_mon_err_msg = f"unable to get status of '{resource_or_tag_id}' from crm_mon\n"
	                monitor_command.extend(
	                    [
	                        "--include",
	                        "none,resources",
	                        "--resource",
	                        resource_or_tag_id,
	                    ]
	                )
	                argv.remove(arg)
	                break
	        parser = KeyValueParser(argv)
	        parser.check_allowed_keys({"node"})
	        node = parser.get_unique().get("node")
	        if node == "":
	            utils.err("missing value of 'node' option")
	        if node:
	            monitor_command.extend(["--node", node])
	
	    output, retval = utils.run(monitor_command)
	    if retval != 0:
	        utils.err(crm_mon_err_msg + output.rstrip())
	    preg = re.compile(r".*(stonith:.*)")
	    resources_header = False
	    in_resources = False
	    has_resources = False
	    no_resources_line = (
	        "NO stonith devices configured"
	        if stonith
	        else "NO resources configured"
	    )
	    no_active_resources_msg = "No active resources"
	    for line in output.split("\n"):
	        if line in (
	            "  * No active resources",  # pacemaker >= 2.0.3 with --hide-inactive
	            "No active resources",  # pacemaker < 2.0.3 with --hide-inactive
	        ):
	            print(no_active_resources_msg)
	            return
	        if line in (
	            "  * No resources",  # pacemaker >= 2.0.3
	            "No resources",  # pacemaker < 2.0.3
	        ):
	            if resource_or_tag_id and not node:
	                utils.err(
	                    f"resource or tag id '{resource_or_tag_id}' not found"
	                )
	            if not node:
	                print(no_resources_line)
	            else:
	                print(no_active_resources_msg)
	            return
	        if line in (
	            "Full List of Resources:",  # pacemaker >= 2.0.3
	            "Active Resources:",  # pacemaker >= 2.0.3 with  --hide-inactive
	        ):
	            in_resources = True
	            continue
	        if line in (
	            "Full list of resources:",  # pacemaker < 2.0.3
	            "Active resources:",  # pacemaker < 2.0.3 with --hide-inactive
	        ):
	            resources_header = True
	            continue
	        if line == "":
	            if resources_header:
	                resources_header = False
	                in_resources = True
	            elif in_resources:
	                if not has_resources:
	                    print(no_resources_line)
	                return
	            continue
	        if in_resources:
	            if resource_or_tag_id:
	                has_resources = True
	                print(line)
	                continue
	            if (
	                not preg.match(line)
	                and not stonith
	                or preg.match(line)
	                and stonith
	            ):
	                has_resources = True
	                print(line)
	
	
	def resource_disable_cmd(
	    lib: Any, argv: Argv, modifiers: InputModifiers
	) -> None:
	    """
	    Options:
	      * -f - CIB file
	      * --brief - show brief output of --simulate
	      * --safe - only disable if no other resource gets stopped or demoted
	      * --simulate - do not push the CIB, print its effects
	      * --no-strict - allow disable if other resource is affected
	      * --wait
	    """
	    if not argv:
	        raise CmdLineInputError("You must specify resource(s) to disable")
	    check_is_not_stonith(lib, argv, "pcs stonith disable")
	    resource_disable_common(lib, argv, modifiers)
	
	
	def resource_disable_common(
	    lib: Any, argv: Argv, modifiers: InputModifiers
	) -> None:
	    """
	    Commandline options:
	      * -f - CIB file
	      * --force - allow to disable the last stonith resource in the cluster
	      * --brief - show brief output of --simulate
	      * --safe - only disable if no other resource gets stopped or demoted
	      * --simulate - do not push the CIB, print its effects
	      * --no-strict - allow disable if other resource is affected
	      * --wait
	    """
	    modifiers.ensure_only_supported(
	        "-f",
	        "--force",
	        "--brief",
	        "--safe",
	        "--simulate",
	        "--no-strict",
	        "--wait",
	    )
	    modifiers.ensure_not_mutually_exclusive("-f", "--simulate", "--wait")
	    modifiers.ensure_not_incompatible("--simulate", {"-f", "--safe", "--wait"})
	    modifiers.ensure_not_incompatible("--safe", {"-f", "--simulate"})
	    modifiers.ensure_not_incompatible("--no-strict", {"-f"})
	
	    if not argv:
	        raise CmdLineInputError("You must specify resource(s) to disable")
	
	    if modifiers.get("--simulate"):
	        result = lib.resource.disable_simulate(
	            argv, not modifiers.get("--no-strict")
	        )
	        if modifiers.get("--brief"):
	            # if the result is empty, printing it would produce a new line,
	            # which is not wanted
	            if result["other_affected_resource_list"]:
	                print("\n".join(result["other_affected_resource_list"]))
	            return
	        print(result["plaintext_simulated_status"])
	        return
	    if modifiers.get("--safe") or modifiers.get("--no-strict"):
	        if modifiers.get("--brief"):
	            # Brief mode skips simulation output by setting the report processor
	            # to ignore info reports which contain crm_simulate output and
	            # resource status in this command
	            lib.env.report_processor.suppress_reports_of_severity(
	                [reports.ReportItemSeverity.INFO]
	            )
	        lib.resource.disable_safe(
	            argv,
	            not modifiers.get("--no-strict"),
	            modifiers.get("--wait"),
	        )
	        return
	    if modifiers.get("--brief"):
	        raise CmdLineInputError(
	            "'--brief' cannot be used without '--simulate' or '--safe'"
	        )
	    force_flags = set()
	    if modifiers.get("--force"):
	        force_flags.add(reports.codes.FORCE)
	    lib.resource.disable(argv, modifiers.get("--wait"), force_flags)
	
	
	def resource_safe_disable_cmd(
	    lib: Any, argv: Argv, modifiers: InputModifiers
	) -> None:
	    """
	    Options:
	      * --brief - show brief output of --simulate
	      * --force - skip checks for safe resource disable
	      * --no-strict - allow disable if other resource is affected
	      * --simulate - do not push the CIB, print its effects
	      * --wait
	    """
	    modifiers.ensure_only_supported(
	        "--brief", "--force", "--no-strict", "--simulate", "--wait"
	    )
	    modifiers.ensure_not_incompatible("--force", {"--no-strict", "--simulate"})
	    custom_options = {}
	    if modifiers.get("--force"):
	        warn(
	            "option '--force' is specified therefore checks for disabling "
	            "resource safely will be skipped"
	        )
	    elif not modifiers.get("--simulate"):
	        custom_options["--safe"] = True
	    resource_disable_cmd(
	        lib,
	        argv,
	        modifiers.get_subset(
	            "--wait", "--no-strict", "--simulate", "--brief", **custom_options
	        ),
	    )
	
	
	def resource_enable_cmd(
	    lib: Any, argv: Argv, modifiers: InputModifiers
	) -> None:
	    """
	    Options:
	      * --wait
	      * -f - CIB file
	    """
	    modifiers.ensure_only_supported("--wait", "-f")
	    if not argv:
	        raise CmdLineInputError("You must specify resource(s) to enable")
	    resources = argv
	    check_is_not_stonith(lib, resources, "pcs stonith enable")
	    lib.resource.enable(resources, modifiers.get("--wait"))
	
	
	def resource_restart_cmd(
	    lib: Any, argv: Argv, modifiers: InputModifiers
	) -> None:
	    """
	    Options:
	      * --wait
	    """
	    modifiers.ensure_only_supported("--wait")
	
	    if not argv:
	        raise CmdLineInputError(
	            "You must specify a resource to restart",
	            show_both_usage_and_message=True,
	        )
	    resource = argv.pop(0)
	    node = argv.pop(0) if argv else None
	    if argv:
	        raise CmdLineInputError()
	
	    timeout = (
	        modifiers.get("--wait") if modifiers.is_specified("--wait") else None
	    )
	
	    lib.resource.restart(resource, node, timeout)
	
	    print_to_stderr(f"{resource} successfully restarted")
	
	
	def resource_force_action(  # noqa: PLR0912
	    lib: Any, argv: Argv, modifiers: InputModifiers, action: str
	) -> None:
	    """
	    Options:
	      * --force
	      * --full - more verbose output
	    """
	    modifiers.ensure_only_supported("--force", "--full")
	    action_command = {
	        "debug-start": "--force-start",
	        "debug-stop": "--force-stop",
	        "debug-promote": "--force-promote",
	        "debug-demote": "--force-demote",
	        "debug-monitor": "--force-check",
	    }
	
	    if action not in action_command:
	        raise CmdLineInputError()
	    if not argv:
	        utils.err("You must specify a resource to {0}".format(action))
	    if len(argv) != 1:
	        raise CmdLineInputError()
	
	    resource = argv[0]
	    check_is_not_stonith(lib, [resource])
	    dom = utils.get_cib_dom()
	
	    if not (
	        utils.dom_get_any_resource(dom, resource)
	        or utils.dom_get_bundle(dom, resource)
	    ):
	        utils.err(
	            "unable to find a resource/clone/group/bundle: {0}".format(resource)
	        )
	    bundle_el = utils.dom_get_bundle(dom, resource)
	    if bundle_el:
	        bundle_resource = utils.dom_get_resource_bundle(bundle_el)
	        if bundle_resource:
	            utils.err(
	                "unable to {0} a bundle, try the bundle's resource: {1}".format(
	                    action, bundle_resource.getAttribute("id")
	                )
	            )
	        else:
	            utils.err("unable to {0} a bundle".format(action))
	    if utils.dom_get_group(dom, resource):
	        group_resources = utils.get_group_children(resource)
	        utils.err(
	            (
	                "unable to {0} a group, try one of the group's resource(s) ({1})"
	            ).format(action, ",".join(group_resources))
	        )
	    if utils.dom_get_clone(dom, resource) or utils.dom_get_master(
	        dom, resource
	    ):
	        clone_resource = utils.dom_get_clone_ms_resource(dom, resource)
	        utils.err(
	            "unable to {0} a clone, try the clone's resource: {1}".format(
	                action, clone_resource.getAttribute("id")
	            )
	        )
	
	    args = ["crm_resource", "-r", resource, action_command[action]]
	    if modifiers.get("--full"):
	        # set --verbose twice to get a reasonable amount of debug messages
	        args.extend(["--verbose"] * 2)
	    if modifiers.get("--force"):
	        args.append("--force")
	    output, retval = utils.run(args)
	
	    if "doesn't support group resources" in output:
	        utils.err("groups are not supported")
	        sys.exit(retval)
	    if "doesn't support stonith resources" in output:
	        utils.err("stonith devices are not supported")
	        sys.exit(retval)
	
	    print(output.rstrip())
	    sys.exit(retval)
	
	
	def resource_manage_cmd(
	    lib: Any, argv: Argv, modifiers: InputModifiers
	) -> None:
	    """
	    Options:
	      * -f - CIB file
	      * --monitor - enable monitor operation of specified resources
	    """
	    modifiers.ensure_only_supported("-f", "--monitor")
	    if not argv:
	        raise CmdLineInputError("You must specify resource(s) to manage")
	    resources = argv
	    check_is_not_stonith(lib, resources)
	    lib.resource.manage(resources, with_monitor=modifiers.get("--monitor"))
	
	
	def resource_unmanage_cmd(
	    lib: Any, argv: Argv, modifiers: InputModifiers
	) -> None:
	    """
	    Options:
	      * -f - CIB file
	      * --monitor - bisable monitor operation of specified resources
	    """
	    modifiers.ensure_only_supported("-f", "--monitor")
	    if not argv:
	        raise CmdLineInputError("You must specify resource(s) to unmanage")
	    resources = argv
	    check_is_not_stonith(lib, resources)
	    lib.resource.unmanage(resources, with_monitor=modifiers.get("--monitor"))
	
	
	def resource_failcount_show(
	    lib: Any, argv: Argv, modifiers: InputModifiers
	) -> None:
	    """
	    Options:
	      * --full
	      * -f - CIB file
	    """
	    modifiers.ensure_only_supported("-f", "--full")
	
	    resource = argv.pop(0) if argv and "=" not in argv[0] else None
	    parser = KeyValueParser(argv)
	    parser.check_allowed_keys({"node", "operation", "interval"})
	    parsed_options = parser.get_unique()
	
	    node = parsed_options.get("node")
	    operation = parsed_options.get("operation")
	    interval = parsed_options.get("interval")
	    result_lines = []
	    failures_data = lib.resource.get_failcounts(
	        resource=resource, node=node, operation=operation, interval=interval
	    )
	
	    if not failures_data:
	        result_lines.append(
	            __headline_resource_failures(
	                True, resource, node, operation, interval
	            )
	        )
	        print("\n".join(result_lines))
	        return
	
	    resource_list = sorted({fail["resource"] for fail in failures_data})
	    for current_resource in resource_list:
	        result_lines.append(
	            __headline_resource_failures(
	                False, current_resource, node, operation, interval
	            )
	        )
	        resource_failures = [
	            fail
	            for fail in failures_data
	            if fail["resource"] == current_resource
	        ]
	        node_list = sorted({fail["node"] for fail in resource_failures})
	        for current_node in node_list:
	            node_failures = [
	                fail
	                for fail in resource_failures
	                if fail["node"] == current_node
	            ]
	            if modifiers.get("--full"):
	                result_lines.append(f"  {current_node}:")
	                operation_list = sorted(
	                    {fail["operation"] for fail in node_failures}
	                )
	                for current_operation in operation_list:
	                    operation_failures = [
	                        fail
	                        for fail in node_failures
	                        if fail["operation"] == current_operation
	                    ]
	                    interval_list = sorted(
	                        {fail["interval"] for fail in operation_failures},
	                        # pacemaker's definition of infinity
	                        key=lambda x: 1000000 if x == "INFINITY" else x,
	                    )
	                    for current_interval in interval_list:
	                        interval_failures = [
	                            fail
	                            for fail in operation_failures
	                            if fail["interval"] == current_interval
	                        ]
	                        failcount, dummy_last_failure = __aggregate_failures(
	                            interval_failures
	                        )
	                        result_lines.append(
	                            f"    {current_operation} {current_interval}ms: {failcount}"
	                        )
	            else:
	                failcount, dummy_last_failure = __aggregate_failures(
	                    node_failures
	                )
	                result_lines.append(f"  {current_node}: {failcount}")
	    print("\n".join(result_lines))
	
	
	def __aggregate_failures(failure_list):
	    """
	    Commandline options: no options
	    """
	    last_failure = 0
	    fail_count = 0
	    for failure in failure_list:
	        # infinity is a maximal value and cannot be increased
	        if fail_count != "INFINITY":
	            if failure["fail_count"] == "INFINITY":
	                fail_count = failure["fail_count"]
	            else:
	                fail_count += failure["fail_count"]
	        last_failure = max(last_failure, failure["last_failure"])
	    return fail_count, last_failure
	
	
	def __headline_resource_failures(empty, resource, node, operation, interval):
	    """
	    Commandline options: no options
	    """
	    headline_parts = []
	    if empty:
	        headline_parts.append("No failcounts")
	    else:
	        headline_parts.append("Failcounts")
	    if operation:
	        headline_parts.append("for operation '{operation}'")
	        if interval:
	            headline_parts.append("with interval '{interval}'")
	    if resource:
	        headline_parts.append("of" if operation else "for")
	        headline_parts.append("resource '{resource}'")
	    if node:
	        headline_parts.append("on node '{node}'")
	    return " ".join(headline_parts).format(
	        node=node, resource=resource, operation=operation, interval=interval
	    )
	
	
	def operation_to_string(op_el):
	    """
	    Commandline options: no options
	    """
	    parts = []
	    parts.append(op_el.getAttribute("name"))
	    for name, value in sorted(op_el.attributes.items()):
	        if name in ["id", "name"]:
	            continue
	        parts.append(name + "=" + value)
	    parts.extend(
	        f"{nvpair.getAttribute('name')}={nvpair.getAttribute('value')}"
	        for nvpair in op_el.getElementsByTagName("nvpair")
	    )
	    parts.append("(" + op_el.getAttribute("id") + ")")
	    return " ".join(parts)
	
	
	def resource_cleanup(lib: Any, argv: Argv, modifiers: InputModifiers) -> None:
	    """
	    Options: no options
	    """
	    del lib
	    modifiers.ensure_only_supported("--strict")
	    resource = argv.pop(0) if argv and "=" not in argv[0] else None
	    parser = KeyValueParser(argv)
	    parser.check_allowed_keys({"node", "operation", "interval"})
	    parsed_options = parser.get_unique()
	
	    print_to_stderr(
	        lib_pacemaker.resource_cleanup(
	            utils.cmd_runner(),
	            resource=resource,
	            node=parsed_options.get("node"),
	            operation=parsed_options.get("operation"),
	            interval=parsed_options.get("interval"),
	            strict=bool(modifiers.get("--strict")),
	        )
	    )
	
	
	def resource_refresh(lib: Any, argv: Argv, modifiers: InputModifiers) -> None:
	    """
	    Options:
	      * --force - do refresh even though it may be time consuming
	    """
	    del lib
	    modifiers.ensure_only_supported(
	        "--force",
	        "--strict",
	        hint_syntax_changed=(
	            "0.11" if modifiers.is_specified("--full") else None
	        ),
	    )
	    resource = argv.pop(0) if argv and "=" not in argv[0] else None
	    parser = KeyValueParser(argv)
	    parser.check_allowed_keys({"node"})
	    parsed_options = parser.get_unique()
	    print_to_stderr(
	        lib_pacemaker.resource_refresh(
	            utils.cmd_runner(),
	            resource=resource,
	            node=parsed_options.get("node"),
	            strict=bool(modifiers.get("--strict")),
	            force=bool(modifiers.get("--force")),
	        )
	    )
	
	
	def resource_relocate_show_cmd(
	    lib: Any, argv: Argv, modifiers: InputModifiers
	) -> None:
	    """
	    Options: no options
	    """
	    del lib
	    modifiers.ensure_only_supported()
	    if argv:
	        raise CmdLineInputError()
	    resource_relocate_show(utils.get_cib_dom())
	
	
	def resource_relocate_dry_run_cmd(
	    lib: Any, argv: Argv, modifiers: InputModifiers
	) -> None:
	    """
	    Options:
	      * -f - CIB file
	    """
	    modifiers.ensure_only_supported("-f")
	    if argv:
	        check_is_not_stonith(lib, argv)
	    resource_relocate_run(utils.get_cib_dom(), argv, dry=True)
	
	
	def resource_relocate_run_cmd(
	    lib: Any, argv: Argv, modifiers: InputModifiers
	) -> None:
	    """
	    Options: no options
	    """
	    modifiers.ensure_only_supported()
	    if argv:
	        check_is_not_stonith(lib, argv)
	    resource_relocate_run(utils.get_cib_dom(), argv, dry=False)
	
	
	def resource_relocate_clear_cmd(
	    lib: Any, argv: Argv, modifiers: InputModifiers
	) -> None:
	    """
	    Options:
	      * -f - CIB file
	    """
	    del lib
	    modifiers.ensure_only_supported("-f")
	    if argv:
	        raise CmdLineInputError()
	    utils.replace_cib_configuration(
	        resource_relocate_clear(utils.get_cib_dom())
	    )
	
	
	def resource_relocate_set_stickiness(cib_dom, resources=None):
	    """
	    Commandline options: no options
	    """
	    resources = [] if resources is None else resources
	    cib_dom = cib_dom.cloneNode(True)  # do not change the original cib
	    resources_found = set()
	    updated_resources = set()
	    # set stickiness=0
	    for tagname in ("master", "clone", "group", "primitive"):
	        for res_el in cib_dom.getElementsByTagName(tagname):
	            if resources and res_el.getAttribute("id") not in resources:
	                continue
	            resources_found.add(res_el.getAttribute("id"))
	            res_and_children = (
	                [res_el]
	                + res_el.getElementsByTagName("group")
	                + res_el.getElementsByTagName("primitive")
	            )
	            updated_resources.update(
	                [el.getAttribute("id") for el in res_and_children]
	            )
	            for res_or_child in res_and_children:
	                meta_attributes = utils.dom_prepare_child_element(
	                    res_or_child,
	                    "meta_attributes",
	                    res_or_child.getAttribute("id") + "-meta_attributes",
	                )
	                utils.dom_update_nv_pair(
	                    meta_attributes,
	                    "resource-stickiness",
	                    "0",
	                    meta_attributes.getAttribute("id") + "-",
	                )
	    # resources don't exist
	    if resources:
	        resources_not_found = set(resources) - resources_found
	        if resources_not_found:
	            for res_id in resources_not_found:
	                utils.err(
	                    "unable to find a resource/clone/group: {0}".format(res_id),
	                    False,
	                )
	            sys.exit(1)
	    return cib_dom, updated_resources
	
	
	def resource_relocate_get_locations(cib_dom, resources=None):
	    """
	    Commandline options:
	      * --force - allow constraint on any resource, may not have any effective
	        as an invalid constraint is ignored anyway
	    """
	    resources = [] if resources is None else resources
	    updated_cib, updated_resources = resource_relocate_set_stickiness(
	        cib_dom, resources
	    )
	    dummy_simout, transitions, new_cib = utils.simulate_cib(updated_cib)
	    operation_list = utils.get_operations_from_transitions(transitions)
	    locations = utils.get_resources_location_from_operations(
	        new_cib, operation_list
	    )
	    # filter out non-requested resources
	    if not resources:
	        return list(locations.values())
	    return [
	        val
	        for val in locations.values()
	        if val["id"] in updated_resources
	        or val["id_for_constraint"] in updated_resources
	    ]
	
	
	def resource_relocate_show(cib_dom):
	    """
	    Commandline options: no options
	    """
	    updated_cib, dummy_updated_resources = resource_relocate_set_stickiness(
	        cib_dom
	    )
	    simout, dummy_transitions, dummy_new_cib = utils.simulate_cib(updated_cib)
	    in_status = False
	    in_status_resources = False
	    in_transitions = False
	    for line in simout.split("\n"):
	        if line.strip() == "Current cluster status:":
	            in_status = True
	            in_status_resources = False
	            in_transitions = False
	        elif line.strip() == "Transition Summary:":
	            in_status = False
	            in_status_resources = False
	            in_transitions = True
	            print()
	        elif line.strip() == "":
	            if in_status:
	                in_status = False
	                in_status_resources = True
	                in_transitions = False
	            else:
	                in_status = False
	                in_status_resources = False
	                in_transitions = False
	        if in_status or in_status_resources or in_transitions:
	            print(line)
	
	
	def resource_relocate_location_to_str(location):
	    """
	    Commandline options: no options
	    """
	    message = (
	        "Creating location constraint: {res} prefers {node}=INFINITY{role}"
	    )
	    if "start_on_node" in location:
	        return message.format(
	            res=location["id_for_constraint"],
	            node=location["start_on_node"],
	            role="",
	        )
	    if "promote_on_node" in location:
	        return message.format(
	            res=location["id_for_constraint"],
	            node=location["promote_on_node"],
	            role=f" role={const.PCMK_ROLE_PROMOTED}",
	        )
	    return ""
	
	
	def resource_relocate_run(cib_dom, resources=None, dry=True):  # noqa: PLR0912
	    """
	    Commandline options:
	      * -f - CIB file, explicitly forbids -f if dry is False
	      * --force - allow constraint on any resource, may not have any effective
	        as an invalid copnstraint is ignored anyway
	    """
	    resources = [] if resources is None else resources
	    was_error = False
	    anything_changed = False
	    if not dry and utils.usefile:
	        utils.err("This command cannot be used with -f")
	
	    # create constraints
	    cib_dom, constraint_el = constraint.getCurrentConstraints(cib_dom)
	    for location in resource_relocate_get_locations(cib_dom, resources):
	        if not ("start_on_node" in location or "promote_on_node" in location):
	            continue
	        anything_changed = True
	        print_to_stderr(resource_relocate_location_to_str(location))
	        constraint_id = utils.find_unique_id(
	            cib_dom,
	            RESOURCE_RELOCATE_CONSTRAINT_PREFIX + location["id_for_constraint"],
	        )
	        new_constraint = cib_dom.createElement("rsc_location")
	        new_constraint.setAttribute("id", constraint_id)
	        new_constraint.setAttribute("rsc", location["id_for_constraint"])
	        new_constraint.setAttribute("score", "INFINITY")
	        if "promote_on_node" in location:
	            new_constraint.setAttribute("node", location["promote_on_node"])
	            new_constraint.setAttribute(
	                "role",
	                pacemaker.role.get_value_for_cib(
	                    const.PCMK_ROLE_PROMOTED,
	                    utils.isCibVersionSatisfied(
	                        cib_dom, const.PCMK_NEW_ROLES_CIB_VERSION
	                    ),
	                ),
	            )
	        elif "start_on_node" in location:
	            new_constraint.setAttribute("node", location["start_on_node"])
	        constraint_el.appendChild(new_constraint)
	    if not anything_changed:
	        return
	    if not dry:
	        utils.replace_cib_configuration(cib_dom)
	
	    # wait for resources to move
	    print_to_stderr("\nWaiting for resources to move...\n")
	    if not dry:
	        output, retval = utils.run(["crm_resource", "--wait"])
	        if retval != 0:
	            was_error = True
	            if retval == PACEMAKER_WAIT_TIMEOUT_STATUS:
	                utils.err("waiting timeout", False)
	            else:
	                utils.err(output, False)
	
	    # remove constraints
	    resource_relocate_clear(cib_dom)
	    if not dry:
	        utils.replace_cib_configuration(cib_dom)
	
	    if was_error:
	        sys.exit(1)
	
	
	def resource_relocate_clear(cib_dom):
	    """
	    Commandline options: no options
	    """
	    for constraint_el in cib_dom.getElementsByTagName("constraints"):
	        for location_el in constraint_el.getElementsByTagName("rsc_location"):
	            location_id = location_el.getAttribute("id")
	            if location_id.startswith(RESOURCE_RELOCATE_CONSTRAINT_PREFIX):
	                print_to_stderr("Removing constraint {0}".format(location_id))
	                location_el.parentNode.removeChild(location_el)
	    return cib_dom
	
	
	def set_resource_utilization(resource_id: str, argv: Argv) -> None:
	    """
	    Commandline options:
	      * -f - CIB file
	    """
	    cib = utils.get_cib_dom()
	    resource_el = utils.dom_get_resource(cib, resource_id)
	    if resource_el is None:
	        utils.err("Unable to find a resource: {0}".format(resource_id))
	    utils.dom_update_utilization(resource_el, KeyValueParser(argv).get_unique())
	    utils.replace_cib_configuration(cib)
	
	
	def print_resource_utilization(resource_id: str) -> None:
	    """
	    Commandline options:
	      * -f - CIB file
	    """
	    cib = utils.get_cib_dom()
	    resource_el = utils.dom_get_resource(cib, resource_id)
	    if resource_el is None:
	        utils.err("Unable to find a resource: {0}".format(resource_id))
	    utilization = utils.get_utilization_str(resource_el)
	
	    print("Resource Utilization:")
	    print(" {0}: {1}".format(resource_id, utilization))
	
	
	def print_resources_utilization() -> None:
	    """
	    Commandline options:
	      * -f - CIB file
	    """
	    cib = utils.get_cib_dom()
	    utilization = {}
	    for resource_el in cib.getElementsByTagName("primitive"):
	        utilization_str = utils.get_utilization_str(resource_el)
	        if utilization_str:
	            utilization[resource_el.getAttribute("id")] = utilization_str
	
	    print("Resource Utilization:")
	    for resource in sorted(utilization):
	        print(" {0}: {1}".format(resource, utilization[resource]))
	
	
	def resource_bundle_create_cmd(
	    lib: Any, argv: Argv, modifiers: InputModifiers
	) -> None:
	    """
	    Options:
	      * --force - allow unknown options
	      * --disabled - create as a stopped bundle
	      * --wait
	      * -f - CIB file
	    """
	    modifiers.ensure_only_supported("--force", "--disabled", "--wait", "-f")
	    if not argv:
	        raise CmdLineInputError()
	
	    bundle_id = argv[0]
	    parts = parse_bundle_create_options(argv[1:])
	    lib.resource.bundle_create(
	        bundle_id,
	        parts.container_type,
	        container_options=parts.container,
	        network_options=parts.network,
	        port_map=parts.port_map,
	        storage_map=parts.storage_map,
	        meta_attributes=parts.meta_attrs,
	        force_options=modifiers.get("--force"),
	        ensure_disabled=modifiers.get("--disabled"),
	        wait=modifiers.get("--wait"),
	    )
	
	
	def resource_bundle_reset_cmd(
	    lib: Any, argv: Argv, modifiers: InputModifiers
	) -> None:
	    """
	    Options:
	      * --force - allow unknown options
	      * --disabled - create as a stopped bundle
	      * --wait
	      * -f - CIB file
	    """
	    modifiers.ensure_only_supported("--force", "--disabled", "--wait", "-f")
	    if not argv:
	        raise CmdLineInputError()
	
	    bundle_id = argv[0]
	    parts = parse_bundle_reset_options(argv[1:])
	    lib.resource.bundle_reset(
	        bundle_id,
	        container_options=parts.container,
	        network_options=parts.network,
	        port_map=parts.port_map,
	        storage_map=parts.storage_map,
	        meta_attributes=parts.meta_attrs,
	        force_options=modifiers.get("--force"),
	        ensure_disabled=modifiers.get("--disabled"),
	        wait=modifiers.get("--wait"),
	    )
	
	
	def resource_bundle_update_cmd(
	    lib: Any, argv: Argv, modifiers: InputModifiers
	) -> None:
	    """
	    Options:
	      * --force - allow unknown options
	      * --wait
	      * -f - CIB file
	    """
	    modifiers.ensure_only_supported("--force", "--wait", "-f")
	    if not argv:
	        raise CmdLineInputError()
	
	    bundle_id = argv[0]
	    parts = parse_bundle_update_options(argv[1:])
	    lib.resource.bundle_update(
	        bundle_id,
	        container_options=parts.container,
	        network_options=parts.network,
	        port_map_add=parts.port_map_add,
	        port_map_remove=parts.port_map_remove,
	        storage_map_add=parts.storage_map_add,
	        storage_map_remove=parts.storage_map_remove,
	        meta_attributes=parts.meta_attrs,
	        force_options=modifiers.get("--force"),
	        wait=modifiers.get("--wait"),
	    )