lavalink_rs/
lib.rs

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
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
#![allow(clippy::type_complexity)]
#![allow(rustdoc::bare_urls)]

#[cfg(not(feature = "python"))]
#[macro_use]
extern crate tracing;

#[cfg(feature = "python")]
#[macro_use]
extern crate log;

#[cfg(feature = "python")]
#[macro_use]
extern crate macro_rules_attribute;

#[macro_use]
extern crate serde;

#[cfg(feature = "_rustls-tls")]
pub(crate) type HttpsConnector =
    hyper_rustls::HttpsConnector<hyper_util::client::legacy::connect::HttpConnector>;

#[cfg(feature = "_native-tls")]
pub(crate) type HttpsConnector =
    hyper_tls::HttpsConnector<hyper_util::client::legacy::connect::HttpConnector>;

/// The main client, where everything gets done.
pub mod client;
/// Every possible error that the library can return.
pub mod error;
/// The REST API.
pub mod http;
/// Mappings of objects received or sent from or to the API.
pub mod model;
/// A Lavalink server connection.
pub mod node;
/// Player related methods.
pub mod player_context;
/// Re-exports of all the most common types.
pub mod prelude;
/// Macros that abstract annoying stuff.
#[cfg(feature = "macros")]
pub mod macros {
    /// A macro that transforms `async` functions (and closures) into plain functions, whose return
    /// type is a boxed [`Future`].
    ///
    /// [`Future`]: std::future::Future
    pub use macros_dep::hook;
}

#[cfg(feature = "macros")]
/// A macro that transforms `async` functions (and closures) into plain functions, whose return
/// type is a boxed [`Future`].
///
/// [`Future`]: std::future::Future
pub use macros::hook;

#[cfg(feature = "python")]
use pyo3::{prelude::*, types::PyDict, wrap_pymodule};

#[cfg(feature = "python")]
mod python;

#[cfg(feature = "python")]
#[pymodule]
fn lavalink_rs(py: Python<'_>, m: &Bound<'_, PyModule>) -> PyResult<()> {
    let handle = pyo3_log::Logger::new(py, pyo3_log::Caching::LoggersAndLevels)?
        .filter(log::LevelFilter::Trace)
        .install()
        .expect("Someone installed a logger before lavalink_rs.");

    // Some time in the future when logging changes, reset the caches:
    handle.reset();

    m.add_class::<client::LavalinkClient>()?;
    m.add_class::<player_context::PlayerContext>()?;

    m.add_class::<python::event::EventHandler>()?;
    m.add_class::<python::http::Http>()?;
    m.add_class::<python::node::Node>()?;
    m.add_class::<node::NodeBuilder>()?;
    m.add_class::<python::model::client::NodeDistributionStrategyPy>()?;
    m.add_class::<player_context::TrackInQueue>()?;
    m.add_class::<player_context::QueueRef>()?;

    m.add_class::<model::UserId>()?;
    m.add_class::<model::ChannelId>()?;
    m.add_class::<model::GuildId>()?;

    m.add_wrapped(wrap_pymodule!(python::model::model))?;

    let sys = PyModule::import(py, "sys")?;
    let raw_modules = sys.getattr("modules")?;
    let sys_modules: &Bound<'_, PyDict> = raw_modules.downcast()?;
    sys_modules.set_item("lavalink_rs.model", m.getattr("model")?)?;

    Ok(())
}