// Copyright 2024 RISC Zero, Inc.
//
// 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 std::{
    hint::black_box,
    path::PathBuf,
    time::{Duration, Instant},
};

use clap::{Parser, Subcommand};
use enum_iterator::Sequence;
use risc0_zkp::{hal::tracker, MAX_CYCLES_PO2};
use risc0_zkvm::{
    get_prover_server, ExecutorEnv, ExecutorImpl, ProverOpts, ReceiptKind, VerifierContext,
    RECURSION_PO2,
};
use serde::Serialize;
use serde_with::{serde_as, DurationNanoSeconds};
use tabled::{settings::Style, Table, Tabled};

/// Pre-compiled program that simply loops `count: u32` times (read from stdin).
const LOOP_ELF: &[u8] = include_bytes!("loop.bin");

/// Powers-of-two for cycles, paired with the number of loop iterations used to
/// achieve that many cycles.
const CYCLES_PO2_ITERS: &[(u32, u32)] = &[
    (15, 1),               // 15, 32K
    (16, 1024 * 8),        // 16, 64K
    (17, 1024 * 32),       // 17, 128K
    (18, 1024 * 64),       // 18, 256K
    (19, 1024 * 128),      // 19, 512K
    (20, 1024 * 256),      // 20, 1M
    (21, 1024 * 256 * 3),  // 21, 2M
    (22, 1024 * 256 * 7),  // 22, 4M
    (23, 1024 * 256 * 15), // 23, 8M
    (24, 1024 * 256 * 31), // 24, 16M
];

const MIN_CYCLES_PO2: usize = CYCLES_PO2_ITERS[0].0 as usize;

const ITERATIONS_1M_CYCLES: u32 = 1024 * 512 - 10;

#[serde_as]
#[derive(Debug, Serialize, Tabled)]
struct PerformanceData {
    name: String,
    hashfn: String,

    /// Cycles per second.
    #[tabled(display_with = "display::hertz")]
    throughput: f64,

    #[serde_as(as = "DurationNanoSeconds")]
    #[tabled(display_with = "display::duration")]
    duration: Duration,

    /// Either user execution cycle count or the total cycle count.
    ///
    /// When this is the total cycle count, it includes overhead associated with
    /// continuations and padding up to the nearest power of 2.
    #[tabled(display_with = "display::cycles")]
    cycles: u64,

    #[tabled(display_with = "display::bytes")]
    ram: u64,

    #[tabled(display_with = "display::bytes")]
    seal: u64,
}

#[derive(Parser)]
struct Args {
    #[command(subcommand)]
    command: Option<Command>,

    /// Output result to a JSON file.
    #[arg(long, short)]
    json: Option<PathBuf>,

    /// Select max size for composite runs
    #[arg(long, default_value_t = 20, value_parser = po2_in_range)]
    max_po2: usize,
}

fn po2_in_range(s: &str) -> Result<usize, String> {
    let po2: usize = s.parse().map_err(|_| format!("`{s}` must be an integer"))?;
    if (MIN_CYCLES_PO2..=MAX_CYCLES_PO2).contains(&po2) {
        Ok(po2)
    } else {
        Err(format!(
            "po2 must be in range: {MIN_CYCLES_PO2}-{MAX_CYCLES_PO2}",
        ))
    }
}

#[derive(Eq, PartialEq, Subcommand, Sequence)]
enum Command {
    Execute,
    Composite,
    Lift,
    Join,
    Succinct,
    Identity,
    #[cfg(all(target_arch = "x86_64", feature = "docker"))]
    StarkToSnark,
    #[cfg(all(target_arch = "x86_64", feature = "docker"))]
    Groth16,
}

#[derive(Default)]
struct Datasheet {
    results: Vec<PerformanceData>,
}

impl Datasheet {
    pub fn run(&mut self, args: Args) {
        self.warmup();

        if let Some(ref cmd) = args.command {
            self.run_cmd(cmd, &args);
        } else {
            for cmd in enum_iterator::all::<Command>() {
                self.run_cmd(&cmd, &args);
            }
        }

        let mut table = Table::new(&self.results);
        table.with(Style::modern());
        println!("{table}");

        if let Some(path) = args.json {
            if let Some(parent) = path.parent() {
                std::fs::create_dir_all(parent).unwrap();
            }
            let json = serde_json::to_string_pretty(&self.results).unwrap();
            std::fs::write(path, json).unwrap();
        }
    }

    fn run_cmd(&mut self, cmd: &Command, args: &Args) {
        match cmd {
            Command::Execute => self.execute(),
            Command::Composite => self.composite(args),
            Command::Lift => self.lift(),
            Command::Join => self.join(),
            Command::Succinct => self.succinct(),
            Command::Identity => self.identity_p254(),
            #[cfg(all(target_arch = "x86_64", feature = "docker"))]
            Command::StarkToSnark => self.stark2snark(),
            #[cfg(all(target_arch = "x86_64", feature = "docker"))]
            Command::Groth16 => self.groth16(),
        }
    }

    fn execute(&mut self) {
        let env = ExecutorEnv::builder()
            .write_slice(&ITERATIONS_1M_CYCLES.to_le_bytes())
            .build()
            .unwrap();

        let mut exec = ExecutorImpl::from_elf(env, LOOP_ELF).unwrap();

        let start = Instant::now();
        let session = exec.run().unwrap();
        let duration = start.elapsed();
        assert_eq!(session.user_cycles, (1 << 20) - 1);

        let throughput = (session.user_cycles as f64) / duration.as_secs_f64();
        self.results.push(PerformanceData {
            name: "execute".into(),
            hashfn: "N/A".into(),
            cycles: session.user_cycles,
            duration,
            ram: 0,
            seal: 0,
            throughput,
        });
    }

    fn composite(&mut self, args: &Args) {
        for hashfn in ["sha-256", "poseidon2"] {
            let opts = ProverOpts::all_po2s().with_hashfn(hashfn.to_string());
            let prover = get_prover_server(&opts).unwrap();

            for (po2, iterations) in CYCLES_PO2_ITERS
                .iter()
                .take(args.max_po2 - MIN_CYCLES_PO2 + 1)
            {
                let expected = 1 << po2;
                println!("rv32im/{hashfn}: {expected}");

                let env = ExecutorEnv::builder()
                    .segment_limit_po2(args.max_po2 as u32)
                    .write_slice(&iterations.to_le_bytes())
                    .build()
                    .unwrap();

                tracker().lock().unwrap().reset();

                let start = Instant::now();
                let info = black_box(prover.prove(env, LOOP_ELF).unwrap());
                let duration = start.elapsed();

                let ram = tracker().lock().unwrap().peak as u64;
                assert_eq!(info.stats.total_cycles, expected);
                let throughput = (info.stats.total_cycles as f64) / duration.as_secs_f64();
                let seal = info.receipt.inner.composite().unwrap().seal_size() as u64;

                self.results.push(PerformanceData {
                    name: "rv32im".into(),
                    hashfn: hashfn.into(),
                    cycles: info.stats.total_cycles,
                    duration,
                    ram,
                    seal,
                    throughput,
                });
            }
        }
    }

    fn lift(&mut self) {
        println!("lift");

        let opts = ProverOpts::all_po2s();
        let prover = get_prover_server(&opts).unwrap();
        let ctx = VerifierContext::all_po2s();

        let env = ExecutorEnv::builder()
            .write_slice(&0u32.to_le_bytes())
            .build()
            .unwrap();

        let mut exec = ExecutorImpl::from_elf(env, LOOP_ELF).unwrap();
        let session = exec.run().unwrap();
        let segment = session.segments[0].resolve().unwrap();
        let receipt = prover.prove_segment(&ctx, &segment).unwrap();

        tracker().lock().unwrap().reset();

        let start = Instant::now();
        let receipt = black_box(prover.lift(&receipt).unwrap());
        let duration = start.elapsed();

        let ram = tracker().lock().unwrap().peak as u64;
        let cycles = 1 << RECURSION_PO2;
        let throughput = (cycles as f64) / duration.as_secs_f64();
        let seal = receipt.seal_size() as u64;

        self.results.push(PerformanceData {
            name: "lift".into(),
            hashfn: opts.hashfn,
            cycles,
            duration,
            ram,
            seal,
            throughput,
        });
    }

    fn join(&mut self) {
        println!("join");

        let opts = ProverOpts::all_po2s();
        let prover = get_prover_server(&opts).unwrap();
        let ctx = VerifierContext::all_po2s();

        let (po2, iters) = CYCLES_PO2_ITERS[1];

        let env = ExecutorEnv::builder()
            .write_slice(&iters.to_le_bytes())
            .segment_limit_po2(po2 - 1)
            .build()
            .unwrap();
        let mut exec = ExecutorImpl::from_elf(env, LOOP_ELF).unwrap();
        let session = exec.run().unwrap();
        assert!(
            session.segments.len() >= 2,
            "cycles: {}",
            session.total_cycles
        );

        let receipt = prover.prove_session(&ctx, &session).unwrap().receipt;
        let composite = receipt.inner.composite().unwrap();
        let left = prover.lift(&composite.segments[0]).unwrap();
        let right = prover.lift(&composite.segments[1]).unwrap();

        tracker().lock().unwrap().reset();

        let start = Instant::now();
        let receipt = black_box(prover.join(&left, &right).unwrap());
        let duration = start.elapsed();

        let ram = tracker().lock().unwrap().peak as u64;
        let cycles = 1 << RECURSION_PO2;
        let throughput = (cycles as f64) / duration.as_secs_f64();
        let seal = receipt.seal_size() as u64;

        self.results.push(PerformanceData {
            name: "join".into(),
            hashfn: opts.hashfn,
            cycles,
            duration,
            ram,
            seal,
            throughput,
        });
    }

    fn succinct(&mut self) {
        println!("succinct");

        let opts = ProverOpts::all_po2s().with_receipt_kind(ReceiptKind::Succinct);
        let prover = get_prover_server(&opts).unwrap();

        let iterations: u32 = 64 * 1024;
        let env = ExecutorEnv::builder()
            .write_slice(&iterations.to_le_bytes())
            .build()
            .unwrap();

        tracker().lock().unwrap().reset();

        let start = Instant::now();
        let info = prover.prove(env, LOOP_ELF).unwrap();
        let duration = start.elapsed();

        let ram = tracker().lock().unwrap().peak as u64;
        let throughput = (info.stats.total_cycles as f64) / duration.as_secs_f64();
        let seal = info.receipt.inner.succinct().unwrap().seal_size() as u64;

        self.results.push(PerformanceData {
            name: "succinct".into(),
            hashfn: opts.hashfn,
            cycles: info.stats.total_cycles,
            duration,
            ram,
            seal,
            throughput,
        });
    }

    fn identity_p254(&mut self) {
        println!("identity_p254");

        let opts = ProverOpts::all_po2s().with_receipt_kind(ReceiptKind::Succinct);
        let prover = get_prover_server(&opts).unwrap();

        let env = ExecutorEnv::builder()
            .write_slice(&0u32.to_le_bytes())
            .build()
            .unwrap();

        let info = prover.prove(env, LOOP_ELF).unwrap();
        let succinct_receipt = info.receipt.inner.succinct().unwrap();

        tracker().lock().unwrap().reset();

        let start = Instant::now();
        let receipt = black_box(risc0_zkvm::recursion::identity_p254(succinct_receipt).unwrap());
        let duration = start.elapsed();

        let ram = tracker().lock().unwrap().peak as u64;
        let cycles = 1 << RECURSION_PO2;
        let throughput = (cycles as f64) / duration.as_secs_f64();
        let seal = receipt.seal_size() as u64;

        self.results.push(PerformanceData {
            name: "identity_p254".into(),
            hashfn: opts.hashfn,
            cycles,
            duration,
            ram,
            seal,
            throughput,
        });
    }

    #[cfg(all(target_arch = "x86_64", feature = "docker"))]
    fn stark2snark(&mut self) {
        println!("stark2snark");

        let opts = ProverOpts::all_po2s().with_receipt_kind(ReceiptKind::Succinct);
        let prover = get_prover_server(&opts).unwrap();

        let env = ExecutorEnv::builder()
            .write_slice(&0u32.to_le_bytes())
            .build()
            .unwrap();

        let info = prover.prove(env, LOOP_ELF).unwrap();
        let succinct_receipt = info.receipt.inner.succinct().unwrap();
        let receipt = risc0_zkvm::recursion::identity_p254(&succinct_receipt).unwrap();
        let seal_bytes = receipt.get_seal_bytes();

        let start = Instant::now();
        let seal = black_box(risc0_zkvm::stark_to_snark(&seal_bytes).unwrap());
        let duration = start.elapsed();

        let cycles = 1 << RECURSION_PO2;
        let throughput = (cycles as f64) / duration.as_secs_f64();
        let encoded = bincode::serialize(&seal).unwrap();

        self.results.push(PerformanceData {
            name: "stark2snark".into(),
            hashfn: opts.hashfn,
            cycles,
            duration,
            ram: 0,
            seal: encoded.len() as u64,
            throughput,
        });
    }

    #[cfg(all(target_arch = "x86_64", feature = "docker"))]
    fn groth16(&mut self) {
        println!("groth16");

        let opts = ProverOpts::all_po2s().with_receipt_kind(ReceiptKind::Groth16);
        let prover = get_prover_server(&opts).unwrap();

        let iterations: u32 = 64 * 1024;
        let env = ExecutorEnv::builder()
            .write_slice(&iterations.to_le_bytes())
            .build()
            .unwrap();

        tracker().lock().unwrap().reset();

        let start = Instant::now();
        let info = prover.prove(env, LOOP_ELF).unwrap();
        let duration = start.elapsed();

        let ram = tracker().lock().unwrap().peak as u64;
        let throughput = (info.stats.total_cycles as f64) / duration.as_secs_f64();
        let seal = info.receipt.inner.groth16().unwrap().seal.len() as u64;

        self.results.push(PerformanceData {
            name: "groth16".into(),
            hashfn: opts.hashfn,
            cycles: info.stats.total_cycles,
            duration,
            ram,
            seal,
            throughput,
        });
    }

    fn warmup(&self) {
        #[cfg(any(feature = "cuda", feature = "metal"))]
        {
            println!("warmup");

            let opts = ProverOpts::all_po2s().with_receipt_kind(ReceiptKind::Succinct);
            let prover = get_prover_server(&opts).unwrap();

            let env = ExecutorEnv::builder()
                .write_slice(&0u32.to_le_bytes())
                .build()
                .unwrap();
            prover.prove(env, LOOP_ELF).unwrap();
        }
    }
}

fn main() {
    Datasheet::default().run(Args::parse());
}

/// Utilities to make data human-readable for displaying in a table.
mod display {
    use std::time::Duration;

    use human_repr::{HumanCount, HumanDuration};

    pub fn bytes(bytes: &u64) -> String {
        if *bytes == 0 {
            return "N/A".into();
        }
        bytes.human_count_bytes().to_string()
    }

    pub fn cycles(cycles: &u64) -> String {
        cycles.human_count_bare().to_string()
    }

    pub fn duration(duration: &Duration) -> String {
        duration.human_duration().to_string()
    }

    pub fn hertz(hertz: &f64) -> String {
        hertz.human_count("Hz").to_string()
    }
}