1void put_bucket_replication(Client &client) {
2    // Note: replication requires different source and destination buckets
3    // Using a different bucket name as destination
4    std::string g_bucket = "test";
5    std::string dst_bucket = g_bucket + "-dst";
6
7    // minimal replication rule with required fields
8    ReplicationRule rule;
9    rule.id = "test-replication";
10    rule.status = "enabled";
11    rule.resource.push_back(g_bucket + "/");
12    rule.destination.bucket = dst_bucket;  // must be different from source bucket
13    rule.replicate_deletes = "enabled";    // required field
14
15    PutBucketReplicationRequest request(g_bucket, rule);
16    PutBucketReplicationResponse response;
17    client.put_bucket_replication(request, &response);
18}

1void get_bucket_replication(Client &client) {
2    std::string g_bucket = "test";
3    GetBucketReplicationRequest request(g_bucket, "test-replication");
4    GetBucketReplicationResponse response;
5    client.get_bucket_replication(request, &response);
6    if (response.is_ok()) {
7        const ReplicationRule &rule = response.replication_rule();
8        std::cout << "id: " << rule.id << std::endl;
9        std::cout << "status: " << rule.status << std::endl;
10        std::cout << "dest bucket: " << rule.destination.bucket << std::endl;
11        std::cout << "dest region: " << rule.dest_region << std::endl;
12    } else if (response.status_code() == 404) {
13        std::cout << "No replication configured for this bucket" << std::endl;
14    }
15}

1void delete_bucket_replication(Client &client) {
2    std::string g_bucket = "test";
3    DeleteBucketReplicationRequest request(g_bucket, "test-replication");
4    DeleteBucketReplicationResponse response;
5    client.delete_bucket_replication(request, &response);
6}

1void get_bucket_replication_progress(Client &client) {
2    std::string g_bucket = "test";
3    GetBucketReplicationProgressRequest request(g_bucket, "test-replication");
4    GetBucketReplicationProgressResponse response;
5    client.get_bucket_replication_progress(request, &response);
6    if (response.is_ok()) {
7        const ReplicationProgressInfo &progress = response.replication_progress();
8        std::cout << "status: " << progress.status << std::endl;
9        std::cout << "historyReplicationPercent: " << progress.history_replication_percent << std::endl;
10        std::cout << "latestReplicationTime: " << progress.latest_replication_time << std::endl;
11    }
12}

1void list_bucket_replication(Client &client) {
2    std::string g_bucket = "test";
3    ListBucketReplicationRequest request(g_bucket);
4    ListBucketReplicationResponse response;
5    client.list_bucket_replication(request, &response);
6    if (response.is_ok()) {
7        const std::vector<ReplicationRule> &rules = response.replication_rules();
8        std::cout << "rule count: " << rules.size() << std::endl;
9        for (size_t i = 0; i < rules.size(); ++i) {
10            std::cout << "  rule[" << i << "]: " << rules[i].id
11                      << ", status: " << rules[i].status
12                      << ", dest: " << rules[i].destination.bucket << std::endl;
13        }
14    }
15}