rabbitmqadmin 2.31.0

// Copyright (C) 2023-2026 RabbitMQ Core Team (teamrabbitmq@gmail.com)
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.

use predicates::prelude::*;
use std::error::Error;

use crate::test_helpers::*;

#[test]
fn list_exchanges() -> Result<(), Box<dyn Error>> {
    let vh1 = "rabbitmqadmin.exchange_vhost_1";
    let vh2 = "rabbitmqadmin.exchange_vhost_2";

    let x1 = "new_exchange_1";
    let x2 = "new_exchange_2";

    delete_vhost(vh1).expect("failed to delete a virtual host");
    delete_vhost(vh2).expect("failed to delete a virtual host");

    run_succeeds(["declare", "vhost", "--name", vh1]);

    run_succeeds(["declare", "vhost", "--name", vh2]);

    run_succeeds(["-V", vh1, "declare", "exchange", "--name", x1]);

    run_succeeds(["-V", vh2, "declare", "exchange", "--name", x2]);

    run_succeeds(["-V", vh1, "list", "exchanges"]).stdout(
        output_includes("amq.direct")
            .and(output_includes("amq.fanout"))
            .and(output_includes(x1))
            .and(output_includes(x2).not()),
    );

    run_succeeds([
        "-V",
        vh1,
        "delete",
        "exchange",
        "--name",
        x1,
        "--idempotently",
    ]);

    run_succeeds(["-V", vh1, "list", "exchanges"]).stdout(
        output_includes("amq.direct")
            .and(output_includes("amq.topic"))
            .and(output_includes(x1).not()),
    );

    run_succeeds(["-V", vh2, "list", "exchanges"]).stdout(
        output_includes("amq.direct")
            .and(output_includes("amq.headers"))
            .and(output_includes(x2))
            .and(output_includes(x1).not()),
    );

    delete_vhost(vh1).expect("failed to delete a virtual host");
    delete_vhost(vh2).expect("failed to delete a virtual host");

    Ok(())
}

#[test]
fn exchanges_list() -> Result<(), Box<dyn Error>> {
    let vh1 = "rabbitmqadmin.exchange_vhost_3";
    let vh2 = "rabbitmqadmin.exchange_vhost_4";

    let x1 = "new_exchange_1";
    let x2 = "new_exchange_2";

    delete_vhost(vh1).expect("failed to delete a virtual host");
    delete_vhost(vh2).expect("failed to delete a virtual host");

    run_succeeds(["vhosts", "declare", "--name", vh1]);

    run_succeeds(["vhosts", "declare", "--name", vh2]);

    run_succeeds(["-V", vh1, "exchanges", "declare", "--name", x1]);

    run_succeeds(["-V", vh2, "exchanges", "declare", "--name", x2]);

    run_succeeds(["-V", vh1, "exchanges", "list"]).stdout(
        output_includes("amq.direct")
            .and(output_includes("amq.fanout"))
            .and(output_includes(x1))
            .and(output_includes(x2).not()),
    );

    run_succeeds([
        "-V",
        vh1,
        "exchanges",
        "delete",
        "--name",
        x1,
        "--idempotently",
    ]);

    run_succeeds(["-V", vh1, "exchanges", "list"]).stdout(
        output_includes("amq.direct")
            .and(output_includes("amq.topic"))
            .and(output_includes(x1).not()),
    );

    run_succeeds(["-V", vh2, "exchanges", "list"]).stdout(
        output_includes("amq.direct")
            .and(output_includes("amq.headers"))
            .and(output_includes(x2))
            .and(output_includes(x1).not()),
    );

    delete_vhost(vh1).expect("failed to delete a virtual host");
    delete_vhost(vh2).expect("failed to delete a virtual host");

    Ok(())
}

#[test]
fn delete_an_existing_exchange_using_original_command_group() -> Result<(), Box<dyn Error>> {
    let vh = "rabbitmqadmin.exchanges.test1";
    let x = "exchange_1_to_delete";

    create_vhost(vh)?;

    run_succeeds(["-V", vh, "declare", "exchange", "--name", x]);

    run_succeeds(["-V", vh, "list", "exchanges"]).stdout(output_includes(x));

    run_succeeds(["-V", vh, "delete", "exchange", "--name", x]);

    run_succeeds(["-V", vh, "list", "exchanges"]).stdout(output_includes(x).not());

    delete_vhost(vh)?;

    Ok(())
}

#[test]
fn delete_an_existing_exchange_using_exchanges_command_group() -> Result<(), Box<dyn Error>> {
    let vh = "rabbitmqadmin.exchanges.test2";
    let x = "exchange_1_to_delete";

    create_vhost(vh)?;

    run_succeeds(["-V", vh, "exchanges", "declare", "--name", x]);

    run_succeeds(["-V", vh, "exchanges", "list"]).stdout(output_includes(x));

    run_succeeds(["-V", vh, "exchanges", "delete", "--name", x]);

    run_succeeds(["-V", vh, "exchanges", "list"]).stdout(output_includes(x).not());

    delete_vhost(vh)?;

    Ok(())
}

#[test]
fn delete_a_non_existing_exchange() -> Result<(), Box<dyn Error>> {
    let vh = "rabbitmqadmin.exchanges.test3";

    create_vhost(vh)?;

    run_succeeds([
        "--vhost",
        vh,
        "exchanges",
        "delete",
        "--name",
        "7s98df7s79df-non-existent",
        "--idempotently",
    ]);

    run_fails([
        "--vhost",
        vh,
        "exchanges",
        "delete",
        "--name",
        "7s98df7s79df-non-existent",
    ])
    .stderr(output_includes("Not Found"));

    delete_vhost(vh)?;

    Ok(())
}

#[test]
fn test_exchanges_bind_and_unbind() -> Result<(), Box<dyn Error>> {
    let vh1 = "rabbitmqadmin.exchanges_bind_vhost_3";
    let vh2 = "rabbitmqadmin.exchanges_bind_vhost_4";
    let q1 = "new_queue_1";
    let q2 = "new_queue_2";

    delete_vhost(vh1).expect("failed to delete a virtual host");
    delete_vhost(vh2).expect("failed to delete a virtual host");

    run_succeeds(["vhosts", "declare", "--name", vh1]);

    run_succeeds(["vhosts", "declare", "--name", vh2]);

    run_succeeds([
        "-V", vh1, "queues", "declare", "--name", q1, "--type", "classic",
    ]);

    run_succeeds([
        "-V", vh2, "queues", "declare", "--name", q2, "--type", "quorum",
    ]);

    run_succeeds([
        "-V",
        vh1,
        "exchanges",
        "bind",
        "--source",
        "amq.direct",
        "--destination-type",
        "queue",
        "--destination",
        q1,
        "--routing-key",
        "routing_key_queue",
    ]);

    run_succeeds([
        "-V",
        vh1,
        "exchanges",
        "bind",
        "--source",
        "amq.direct",
        "--destination-type",
        "exchange",
        "--destination",
        "amq.topic",
        "--routing-key",
        "routing_key_exchange",
    ]);

    await_queue_metric_emission();

    run_succeeds(["-V", vh2, "list", "bindings"]).stdout(
        output_includes("new_queue_1")
            .and(output_includes("routing_key_queue"))
            .and(output_includes("routing_key_exchange")),
    );

    run_succeeds([
        "-V",
        vh1,
        "exchanges",
        "unbind",
        "--source",
        "amq.direct",
        "--destination-type",
        "queue",
        "--destination",
        q1,
        "--routing-key",
        "routing_key_queue",
    ]);

    run_succeeds(["-V", vh1, "list", "bindings"]).stdout(
        output_includes("new_queue_1")
            .not()
            .and(output_includes("routing_key_queue"))
            .not()
            .and(output_includes("routing_key_exchange")),
    );

    delete_vhost(vh1).expect("failed to delete a virtual host");
    delete_vhost(vh2).expect("failed to delete a virtual host");

    Ok(())
}