chapaty 1.3.2

An event-driven Rust engine for building and evaluating quantitative trading agents. Features a Gym-style API for algorithmic backtesting and reinforcement learning.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52

fn main() -> Result<(), Box<dyn std::error::Error>> {
    // MAINTAINER NOTE:
    // This build script is disabled by default to allow users to build the crate
    // without needing `protoc` installed or the external `chapaty-bq-export-proto`
    // repo.
    //
    // The generated Rust code is committed to `src/proto_gen`.
    //
    // To regenerate the protobuf bindings (after updating .proto files), run:
    //     CHAPATY_GEN_PROTOS=1 cargo build
    //
    // Then commit the changes in `src/proto_gen`.
    if std::env::var("CHAPATY_GEN_PROTOS").is_err() {
        return Ok(());
    }

    let proto_root_path = std::fs::canonicalize("../chapaty-bq-export-proto/proto")?;
    let proto_root = proto_root_path.to_str().ok_or("Invalid path")?.to_owned();

    let proto_files = [
        format!("{proto_root}/chapaty/bq_exporter/v1/service.proto"),
        format!("{proto_root}/chapaty/data/v1/common.proto"),
        format!("{proto_root}/chapaty/data/v1/economic_calendar.proto"),
        format!("{proto_root}/chapaty/data/v1/ohlcv_future.proto"),
        format!("{proto_root}/chapaty/data/v1/ohlcv_spot.proto"),
        format!("{proto_root}/chapaty/data/v1/tpo_future.proto"),
        format!("{proto_root}/chapaty/data/v1/tpo_spot.proto"),
        format!("{proto_root}/chapaty/data/v1/trades_spot.proto"),
        format!("{proto_root}/chapaty/data/v1/volume_profile_spot.proto"),
    ];

    for proto_file in &proto_files {
        println!("cargo:rerun-if-changed={proto_file}");
    }

    tonic_prost_build::configure()
        .build_client(true)
        .build_server(false)
        .out_dir("src/proto_gen")
        .compile_protos(&proto_files, &[proto_root])?;

    match std::process::Command::new("cargo")
        .args(["fmt", "--", "src/proto_gen/*.rs"])
        .status()
    {
        Ok(status) if status.success() => {}
        Ok(status) => println!("cargo:warning=rustfmt on generated protos exited with {status}"),
        Err(e) => println!("cargo:warning=failed to run rustfmt on generated protos: {e}"),
    }

    Ok(())
}