jedi 0.2.0

Jedi is the Juggernaut Electronic Data Interchange package. This library provides a data exchange layer extended through the holy crate.
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
88
89
90
91
92
93
94
95
96

use std::fs;
use tonic_build;

fn main() {
  if std::env::var("BUILD_PROTO").is_err() {
    println!("cargo:warning=Skipping protobuf compilation (BUILD_PROTO not set)");
    return;
  }

  println!("[JEDI] Building the protobufs.");
  let out_dir = "src/proto";

  fs::create_dir_all(out_dir).unwrap();

  tonic_build
    ::configure()
    .build_client(true)
    .build_server(true)
    .out_dir(out_dir)
    // Redis
    .type_attribute("redis.RedisCommand", "#[derive(serde::Serialize, serde::Deserialize)]")
    .type_attribute("redis.RedisCommand.command", "#[derive(serde::Serialize, serde::Deserialize)]")
    .type_attribute("redis.SetCommand", "#[derive(serde::Serialize, serde::Deserialize)]")
    .type_attribute("redis.GetCommand", "#[derive(serde::Serialize, serde::Deserialize)]")
    .type_attribute("redis.DelCommand", "#[derive(serde::Serialize, serde::Deserialize)]")
    .type_attribute("redis.RedisResponse", "#[derive(serde::Serialize, serde::Deserialize)]")
    .type_attribute("redis.RedisEvent", "#[derive(serde::Serialize, serde::Deserialize)]")
    .type_attribute("redis.RedisEventObject", "#[derive(serde::Serialize, serde::Deserialize)]")
    .type_attribute(
      "redis.RedisEventObject.object",
      "#[derive(serde::Serialize, serde::Deserialize)]"
    )
    .type_attribute("redis.WatchCommand", "#[derive(serde::Serialize, serde::Deserialize)]")
    .type_attribute("redis.UnwatchCommand", "#[derive(serde::Serialize, serde::Deserialize)]")

    .type_attribute("redis.RedisKeyUpdate", "#[derive(serde::Serialize, serde::Deserialize)]")
    .type_attribute("redis.RedisKeyUpdate.state", "#[derive(serde::Serialize, serde::Deserialize)]")
    .type_attribute("redis.RedisWsMessage", "#[derive(serde::Serialize, serde::Deserialize)]")
    .type_attribute(
      "redis.RedisWsMessage.message",
      "#[derive(serde::Serialize, serde::Deserialize)]"
    )
    .type_attribute("redis.Ping", "#[derive(serde::Serialize, serde::Deserialize)]")
    .type_attribute("redis.Pong", "#[derive(serde::Serialize, serde::Deserialize)]")
    .type_attribute("redis.ErrorMessage", "#[derive(serde::Serialize, serde::Deserialize)]")

    // Redis Stream Types
    .type_attribute("redis.RedisStream", "#[derive(serde::Serialize, serde::Deserialize)]")
    .type_attribute("redis.RedisStream.payload", "#[derive(serde::Serialize, serde::Deserialize)]")
    .type_attribute("redis.XAddPayload", "#[derive(serde::Serialize, serde::Deserialize)]")
    .type_attribute("redis.XReadPayload", "#[derive(serde::Serialize, serde::Deserialize)]")
    .type_attribute("redis.XReadResponse", "#[derive(serde::Serialize, serde::Deserialize)]")
    .type_attribute("redis.StreamReadRequest", "#[derive(serde::Serialize, serde::Deserialize)]")
    .type_attribute("redis.StreamMessages", "#[derive(serde::Serialize, serde::Deserialize)]")
    .type_attribute("redis.StreamEntry", "#[derive(serde::Serialize, serde::Deserialize)]")
    .type_attribute("redis.Field", "#[derive(serde::Serialize, serde::Deserialize)]")

    // Groq
    .type_attribute("groq.GroqMessage", "#[derive(serde::Serialize, serde::Deserialize)]")
    .type_attribute("groq.GroqMessageContent", "#[derive(serde::Serialize, serde::Deserialize)]")
    .type_attribute("groq.GroqChoice", "#[derive(serde::Serialize, serde::Deserialize)]")
    .type_attribute("groq.GroqUsage", "#[derive(serde::Serialize, serde::Deserialize)]")

    .bytes([".jedi"])
    // Jedi
    .type_attribute("jedi.MessageKind", "#[derive(serde::Serialize, serde::Deserialize)]")
    .type_attribute("jedi.PayloadFormat", "#[derive(serde::Serialize, serde::Deserialize)]")
    .type_attribute("jedi.JediEnvelope", "#[derive(serde::Serialize, serde::Deserialize)]")
    .type_attribute("jedi.FlexEnvelope", "#[derive(serde::Serialize, serde::Deserialize)]")
    .type_attribute("jedi.FlagEnvelope", "#[derive(serde::Serialize, serde::Deserialize)]")
    .type_attribute("jedi.RawEnvelope", "#[derive(serde::Serialize, serde::Deserialize)]")
    .type_attribute("jedi.JediMessage", "#[derive(serde::Serialize, serde::Deserialize)]")
    .type_attribute("jedi.JediMessage.envelope", "#[derive(serde::Serialize, serde::Deserialize)]")

    // Twitch
    .type_attribute("twitch.TwitchEventObject", "#[derive(serde::Serialize, serde::Deserialize)]")
    .type_attribute("twitch.TwitchChatMessage", "#[derive(serde::Serialize, serde::Deserialize)]")
    .type_attribute("twitch.TwitchJoinEvent", "#[derive(serde::Serialize, serde::Deserialize)]")
    .type_attribute("twitch.TwitchPartEvent", "#[derive(serde::Serialize, serde::Deserialize)]")
    .type_attribute("twitch.TwitchNoticeEvent", "#[derive(serde::Serialize, serde::Deserialize)]")
    .type_attribute("twitch.TwitchModerationEvent", "#[derive(serde::Serialize, serde::Deserialize)]")
    .type_attribute("twitch.TwitchSubEvent", "#[derive(serde::Serialize, serde::Deserialize)]")
    .type_attribute("twitch.TwitchRaidEvent", "#[derive(serde::Serialize, serde::Deserialize)]")
    .type_attribute("twitch.TwitchCheerEvent", "#[derive(serde::Serialize, serde::Deserialize)]")
    .type_attribute("twitch.TwitchRedemptionEvent", "#[derive(serde::Serialize, serde::Deserialize)]")
    .type_attribute("twitch.TwitchPing", "#[derive(serde::Serialize, serde::Deserialize)]")
    .type_attribute("twitch.TwitchPong", "#[derive(serde::Serialize, serde::Deserialize)]")
    .type_attribute("twitch.TwitchSender", "#[derive(serde::Serialize, serde::Deserialize)]")
    .type_attribute("twitch.TwitchEventObject.object", "#[derive(serde::Serialize, serde::Deserialize)]")


    // .type_attribute(".", "#[derive(serde::Serialize, serde::Deserialize)]")
    // .field_attribute("status.StatusMessage.type", "#[bitflags]")
    .compile_protos(&["proto/redis.proto", "proto/groq.proto", "proto/jedi.proto", "proto/twitch.proto"], &["proto"])
    .expect("Failed to compile Protobuf files");
}