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
#![allow(dead_code, non_upper_case_globals, non_camel_case_types)]
#[macro_use]
extern crate steam_language_gen_derive;
use enum_dispatch::enum_dispatch;
use serde::Serialize;
use crate::generated::headers::{ExtendedMessageHeader, StandardMessageHeader};
use steam_protobuf::steam::steammessages_base::CMsgProtoBufHeader;
use steam_protobuf::Message;
pub mod generated;
#[cfg(feature = "generator")]
pub mod generator;
#[cfg(feature = "generator")]
pub mod parser;
#[enum_dispatch(HasJobId)]
#[derive(Clone, Debug, PartialEq, Serialize)]
pub enum MessageHeaderWrapper {
Std(StandardMessageHeader),
Proto(CMsgProtoBufHeader),
Ext(ExtendedMessageHeader),
}
pub trait SerializableBytes: Send {
fn to_bytes(&self) -> Vec<u8>;
}
impl<T> SerializableBytes for T
where
T: Message,
{
fn to_bytes(&self) -> Vec<u8> {
self.write_to_bytes().unwrap()
}
}
impl SerializableBytes for MessageHeaderWrapper {
fn to_bytes(&self) -> Vec<u8> {
match self {
MessageHeaderWrapper::Std(hdr) => hdr.to_bytes(),
MessageHeaderWrapper::Ext(hdr) => hdr.to_bytes(),
MessageHeaderWrapper::Proto(hdr) => hdr.write_to_bytes().expect("Error writing protobuf"),
}
}
}
pub trait DeserializableBytes {
fn from_bytes(packet_data: &[u8]) -> Self;
}
#[enum_dispatch]
pub trait HasJobId {
fn set_target(&mut self, new_target: u64);
fn set_source(&mut self, new_source: u64);
fn source(&self) -> u64;
fn target(&self) -> u64;
}
pub trait MessageHeaderExt {
fn create() -> Self;
fn split_from_bytes(data: &[u8]) -> (&[u8], &[u8]);
}
pub trait MessageBodyExt {
fn split_from_bytes(data: &[u8]) -> (&[u8], &[u8]);
}
#[derive(Debug, Clone, PartialEq, Eq)]
pub enum Element {
File,
Head,
Type,
Member,
}
#[derive(PartialEq, Eq)]
pub struct Token<'a> {
value: String,
default: Option<&'a str>,
}
impl<'a> Token<'a> {
fn get_value(&self) -> &str {
&self.value
}
fn get_default(&self) -> Option<&'a str> {
self.default
}
}