/*
 * Copyright (C) 2020-present ScyllaDB
 */

/*
 * SPDX-License-Identifier: LicenseRef-ScyllaDB-Source-Available-1.0
 */

#pragma once

#include <array>
#include <cstdint>
#include <seastar/core/metrics_registration.hh>
#include "enum_set.hh"

namespace cdc {

class stats final {
    seastar::metrics::metric_groups _metrics;

public:
    enum class part_type {
        STATIC_ROW,
        CLUSTERING_ROW,
        MAP,
        SET,
        LIST,
        UDT,
        RANGE_TOMBSTONE,
        PARTITION_DELETE,
        ROW_DELETE,

        MAX
    };

    using part_type_set = enum_set<super_enum<part_type,
        part_type::STATIC_ROW,
        part_type::CLUSTERING_ROW,
        part_type::MAP,
        part_type::SET,
        part_type::LIST,
        part_type::UDT,
        part_type::RANGE_TOMBSTONE,
        part_type::PARTITION_DELETE,
        part_type::ROW_DELETE
    >>;

    struct parts_touched_stats final {
        std::array<uint64_t, (size_t)part_type::MAX> count = {};

        inline void apply(part_type_set parts_set) {
            for (part_type idx : parts_set) {
                count[(size_t)idx]++;
            }
        }

        void register_metrics(seastar::metrics::metric_groups& metrics, std::string_view suffix);
    };

    struct counters final {
        uint64_t unsplit_count = 0;
        uint64_t split_count = 0;
        uint64_t preimage_selects = 0;
        uint64_t with_preimage_count = 0;
        uint64_t with_postimage_count = 0;

        parts_touched_stats touches;
    };

    counters counters_total;
    counters counters_failed;

    stats();
};

// Contains the details on what happened during a CDC operation.
struct operation_details final {
    stats::part_type_set touched_parts;
    bool was_split = false;
    bool had_preimage = false;
    bool had_postimage = false;
};

// This object tracks the lifetime of write handlers related to one CDC operation. After all
// write handlers for the operation finish, CDC metrics are updated.
class operation_result_tracker final {
    stats& _stats;
    operation_details _details;
    bool _failed;

public:
    operation_result_tracker(stats& stats, operation_details details)
        : _stats(stats)
        , _details(details)
        , _failed(false)
    {}
    ~operation_result_tracker();

    void on_mutation_failed() {
        _failed = true;
    }
};

}