harmony_rust_sdk 0.3.1

Rust library to work with the Harmony chat protocol.
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
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

fn main() {
    #[allow(unused_mut)]
    let mut builder = tonic_build::configure();
    #[cfg(not(feature = "gen_server"))]
    {
        builder = builder.build_server(false);
    }
    #[cfg(not(feature = "gen_client"))]
    {
        builder = builder.build_client(false);
    }

    let mut protos = Vec::with_capacity(12);

    #[cfg(feature = "gen_harmonytypes")]
    protos.push("harmonytypes/v1/types.proto");

    #[cfg(feature = "gen_auth")]
    protos.push("auth/v1/auth.proto");

    #[cfg(feature = "gen_mediaproxy")]
    protos.push("mediaproxy/v1/mediaproxy.proto");

    #[cfg(feature = "gen_chat")]
    {
        let mut chat_protos = vec![
            "chat/v1/chat.proto",
            "chat/v1/messages.proto",
            "chat/v1/channels.proto",
            "chat/v1/emotes.proto",
            "chat/v1/guilds.proto",
            "chat/v1/permissions.proto",
            "chat/v1/profile.proto",
            "chat/v1/streaming.proto",
        ];
        protos.append(&mut chat_protos);
    }

    #[cfg(feature = "gen_voice")]
    protos.push("voice/v1/voice.proto");

    builder.compile(&protos, &["protocol"]).expect(
        "Protobuf code generation failed! Are you sure you have `protoc` installed?\n
        If so, please also set the PROTOC and PROTOC_INCLUDE as mentioned in the README.",
    );

    #[cfg(any(
        all(feature = "gen_client", feature = "gen_voice"),
        feature = "gen_chat"
    ))]
    let out_dir = std::path::PathBuf::from(
        std::env::var_os("OUT_DIR")
            .expect("Failed to get OUT_DIR! Something must be horribly wrong."),
    );

    #[cfg(all(feature = "gen_client", feature = "gen_voice"))]
    {
        // Patch voice generated code (only for client)
        // We patch this because two methods with the same name are generated and prost
        // doesnt check this.
        let voice_gen_path = out_dir.join("protocol.voice.v1.rs");
        let voice_gen = std::fs::read_to_string(&voice_gen_path).expect("Failed to read from voice service generated code, are you sure you have correct permissions?");
        let patched_voice_gen = voice_gen.replace(
            "pub async fn connect<D>(dst: D)",
            "pub async fn _connect<D>(dst: D)",
        );
        std::fs::write(voice_gen_path, patched_voice_gen).expect("Failed to write to voice service generated code, are you sure you have correct permissions?");
    }

    #[cfg(feature = "gen_chat")]
    {
        // Patch chat message event
        // We patch these because of enum variant size differences, since they will be sent more than any other
        // event (its a realtime chat platform, so) this should help.
        let chat_gen_path = out_dir.join("protocol.chat.v1.rs");
        let chat_gen = std::fs::read_to_string(&chat_gen_path).expect("Failed to read from chat service generated code, are you sure you have correct permissions?");
        let mut patched_chat_gen = chat_gen.replace(
            "SentMessage(MessageSent),",
            "SentMessage(Box<MessageSent>),",
        );
        patched_chat_gen = patched_chat_gen.replace(
            "EditedMessage(MessageUpdated),",
            "EditedMessage(Box<MessageUpdated>),",
        );
        std::fs::write(&chat_gen_path, patched_chat_gen).expect("Failed to read from chat service generated code, are you sure you have correct permissions?");
    }
}