gameServer2/src/protocol/parser.rs
author alfadur
Thu, 21 Jun 2018 17:23:10 -0400
changeset 13419 81e0ed105f5d
parent 13416 cdf69667593b
child 13422 5fb27f94fc3b
permissions -rw-r--r--
implementation of team related messages
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
12133
81df2e1f9ae9 Some parsing using nom
unc0rr
parents:
diff changeset
     1
use nom::*;
81df2e1f9ae9 Some parsing using nom
unc0rr
parents:
diff changeset
     2
13416
cdf69667593b partial room implementation
alfadur
parents: 13119
diff changeset
     3
use std::{
cdf69667593b partial room implementation
alfadur
parents: 13119
diff changeset
     4
    str, str::FromStr,
cdf69667593b partial room implementation
alfadur
parents: 13119
diff changeset
     5
    ops::Range
cdf69667593b partial room implementation
alfadur
parents: 13119
diff changeset
     6
};
cdf69667593b partial room implementation
alfadur
parents: 13119
diff changeset
     7
use super::{
cdf69667593b partial room implementation
alfadur
parents: 13119
diff changeset
     8
    messages::{HWProtocolMessage, HWProtocolMessage::*},
cdf69667593b partial room implementation
alfadur
parents: 13119
diff changeset
     9
    test::gen_proto_msg
cdf69667593b partial room implementation
alfadur
parents: 13119
diff changeset
    10
};
13419
81e0ed105f5d implementation of team related messages
alfadur
parents: 13416
diff changeset
    11
use server::coretypes::{
81e0ed105f5d implementation of team related messages
alfadur
parents: 13416
diff changeset
    12
    HedgehogInfo, TeamInfo
81e0ed105f5d implementation of team related messages
alfadur
parents: 13416
diff changeset
    13
};
13119
1e39b8749072 separated the server logic from all the async io mess.
alfadur
parents: 12142
diff changeset
    14
12133
81df2e1f9ae9 Some parsing using nom
unc0rr
parents:
diff changeset
    15
named!(end_of_message, tag!("\n\n"));
12142
4d7d41be1993 Start refactoring path from getting message from client to reacting to it
unc0rr
parents: 12140
diff changeset
    16
named!(str_line<&[u8],   &str>, map_res!(not_line_ending, str::from_utf8));
4d7d41be1993 Start refactoring path from getting message from client to reacting to it
unc0rr
parents: 12140
diff changeset
    17
named!(  a_line<&[u8], String>, map!(str_line, String::from));
4d7d41be1993 Start refactoring path from getting message from client to reacting to it
unc0rr
parents: 12140
diff changeset
    18
named!( u8_line<&[u8],     u8>, map_res!(str_line, FromStr::from_str));
4d7d41be1993 Start refactoring path from getting message from client to reacting to it
unc0rr
parents: 12140
diff changeset
    19
named!(u32_line<&[u8],    u32>, map_res!(str_line, FromStr::from_str));
4d7d41be1993 Start refactoring path from getting message from client to reacting to it
unc0rr
parents: 12140
diff changeset
    20
named!(opt_param<&[u8], Option<String> >, opt!(map!(flat_map!(preceded!(eol, str_line), non_empty), String::from)));
13419
81e0ed105f5d implementation of team related messages
alfadur
parents: 13416
diff changeset
    21
named!(hog_line<&[u8], HedgehogInfo>,
81e0ed105f5d implementation of team related messages
alfadur
parents: 13416
diff changeset
    22
    do_parse!(name: str_line >> eol >> hat: str_line >>
81e0ed105f5d implementation of team related messages
alfadur
parents: 13416
diff changeset
    23
        (HedgehogInfo{name: name.to_string(), hat: hat.to_string()})));
81e0ed105f5d implementation of team related messages
alfadur
parents: 13416
diff changeset
    24
named!(_8_hogs<&[u8], [HedgehogInfo; 8]>,
81e0ed105f5d implementation of team related messages
alfadur
parents: 13416
diff changeset
    25
    do_parse!(h1: hog_line >> eol >> h2: hog_line >> eol >>
81e0ed105f5d implementation of team related messages
alfadur
parents: 13416
diff changeset
    26
              h3: hog_line >> eol >> h4: hog_line >> eol >>
81e0ed105f5d implementation of team related messages
alfadur
parents: 13416
diff changeset
    27
              h5: hog_line >> eol >> h6: hog_line >> eol >>
81e0ed105f5d implementation of team related messages
alfadur
parents: 13416
diff changeset
    28
              h7: hog_line >> eol >> h8: hog_line >>
81e0ed105f5d implementation of team related messages
alfadur
parents: 13416
diff changeset
    29
              ([h1, h2, h3, h4, h5, h6, h7, h8])));
12134
109e6765b1fc Optional parameters parsing function
unc0rr
parents: 12133
diff changeset
    30
12133
81df2e1f9ae9 Some parsing using nom
unc0rr
parents:
diff changeset
    31
named!(basic_message<&[u8], HWProtocolMessage>, alt!(
12135
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
    32
      do_parse!(tag!("PING") >> (Ping))
12133
81df2e1f9ae9 Some parsing using nom
unc0rr
parents:
diff changeset
    33
    | do_parse!(tag!("PONG") >> (Pong))
81df2e1f9ae9 Some parsing using nom
unc0rr
parents:
diff changeset
    34
    | do_parse!(tag!("LIST") >> (List))
12135
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
    35
    | do_parse!(tag!("BANLIST")        >> (BanList))
12133
81df2e1f9ae9 Some parsing using nom
unc0rr
parents:
diff changeset
    36
    | do_parse!(tag!("GET_SERVER_VAR") >> (GetServerVar))
12135
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
    37
    | do_parse!(tag!("TOGGLE_READY")   >> (ToggleReady))
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
    38
    | do_parse!(tag!("START_GAME")     >> (StartGame))
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
    39
    | do_parse!(tag!("ROUNDFINISHED")  >> (RoundFinished))
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
    40
    | do_parse!(tag!("TOGGLE_RESTRICT_JOINS")  >> (ToggleRestrictJoin))
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
    41
    | do_parse!(tag!("TOGGLE_RESTRICT_TEAMS")  >> (ToggleRestrictTeams))
12133
81df2e1f9ae9 Some parsing using nom
unc0rr
parents:
diff changeset
    42
    | do_parse!(tag!("TOGGLE_REGISTERED_ONLY") >> (ToggleRegisteredOnly))
81df2e1f9ae9 Some parsing using nom
unc0rr
parents:
diff changeset
    43
));
81df2e1f9ae9 Some parsing using nom
unc0rr
parents:
diff changeset
    44
81df2e1f9ae9 Some parsing using nom
unc0rr
parents:
diff changeset
    45
named!(one_param_message<&[u8], HWProtocolMessage>, alt!(
12135
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
    46
      do_parse!(tag!("NICK")    >> eol >> n: a_line >> (Nick(n)))
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
    47
    | do_parse!(tag!("INFO")    >> eol >> n: a_line >> (Info(n)))
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
    48
    | do_parse!(tag!("CHAT")    >> eol >> m: a_line >> (Chat(m)))
13416
cdf69667593b partial room implementation
alfadur
parents: 13119
diff changeset
    49
    | do_parse!(tag!("PART")    >> msg: opt_param   >> (Part(msg)))
12135
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
    50
    | do_parse!(tag!("FOLLOW")  >> eol >> n: a_line >> (Follow(n)))
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
    51
    | do_parse!(tag!("KICK")    >> eol >> n: a_line >> (Kick(n)))
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
    52
    | do_parse!(tag!("UNBAN")   >> eol >> n: a_line >> (Unban(n)))
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
    53
    | do_parse!(tag!("EM")      >> eol >> m: a_line >> (EngineMessage(m)))
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
    54
    | do_parse!(tag!("TEAMCHAT")    >> eol >> m: a_line >> (TeamChat(m)))
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
    55
    | do_parse!(tag!("ROOM_NAME")   >> eol >> n: a_line >> (RoomName(n)))
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
    56
    | do_parse!(tag!("REMOVE_TEAM") >> eol >> n: a_line >> (RemoveTeam(n)))
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
    57
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
    58
    | do_parse!(tag!("PROTO")   >> eol >> d: u32_line >> (Proto(d)))
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
    59
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
    60
    | do_parse!(tag!("QUIT")   >> msg: opt_param >> (Quit(msg)))
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
    61
));
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
    62
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
    63
named!(cmd_message<&[u8], HWProtocolMessage>, preceded!(tag!("CMD\n"), alt!(
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
    64
      do_parse!(tag_no_case!("STATS") >> (Stats))
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
    65
    | do_parse!(tag_no_case!("FIX")   >> (Fix))
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
    66
    | do_parse!(tag_no_case!("UNFIX") >> (Unfix))
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
    67
    | do_parse!(tag_no_case!("RESTART_SERVER") >> eol >> tag!("YES") >> (RestartServer))
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
    68
    | do_parse!(tag_no_case!("REGISTERED_ONLY") >> (ToggleServerRegisteredOnly))
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
    69
    | do_parse!(tag_no_case!("SUPER_POWER")     >> (SuperPower))
13119
1e39b8749072 separated the server logic from all the async io mess.
alfadur
parents: 12142
diff changeset
    70
    | do_parse!(tag_no_case!("PART")     >> m: opt_param >> (Part(m)))
1e39b8749072 separated the server logic from all the async io mess.
alfadur
parents: 12142
diff changeset
    71
    | do_parse!(tag_no_case!("QUIT")     >> m: opt_param >> (Quit(m)))
12135
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
    72
    | do_parse!(tag_no_case!("DELEGATE") >> eol >> n: a_line  >> (Delegate(n)))
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
    73
    | do_parse!(tag_no_case!("SAVEROOM") >> eol >> r: a_line  >> (SaveRoom(r)))
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
    74
    | do_parse!(tag_no_case!("LOADROOM") >> eol >> r: a_line  >> (LoadRoom(r)))
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
    75
    | do_parse!(tag_no_case!("DELETE")   >> eol >> r: a_line  >> (Delete(r)))
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
    76
    | do_parse!(tag_no_case!("GLOBAL")   >> eol >> m: a_line  >> (Global(m)))
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
    77
    | do_parse!(tag_no_case!("WATCH")    >> eol >> i: a_line  >> (Watch(i)))
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
    78
    | do_parse!(tag_no_case!("GREETING") >> eol >> m: a_line  >> (Greeting(m)))
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
    79
    | do_parse!(tag_no_case!("VOTE")     >> eol >> m: a_line  >> (Vote(m)))
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
    80
    | do_parse!(tag_no_case!("FORCE")    >> eol >> m: a_line  >> (ForceVote(m)))
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
    81
    | do_parse!(tag_no_case!("INFO")     >> eol >> n: a_line  >> (Info(n)))
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
    82
    | do_parse!(tag_no_case!("MAXTEAMS") >> eol >> n: u8_line >> (MaxTeams(n)))
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
    83
)));
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
    84
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
    85
named!(complex_message<&[u8], HWProtocolMessage>, alt!(
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
    86
      do_parse!(tag!("PASSWORD")  >> eol >>
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
    87
                    p: a_line     >> eol >>
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
    88
                    s: a_line     >>
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
    89
                    (Password(p, s)))
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
    90
    | do_parse!(tag!("CHECKER")   >> eol >>
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
    91
                    i: u32_line   >> eol >>
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
    92
                    n: a_line     >> eol >>
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
    93
                    p: a_line     >>
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
    94
                    (Checker(i, n, p)))
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
    95
    | do_parse!(tag!("CREATE_ROOM") >> eol >>
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
    96
                    n: a_line       >>
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
    97
                    p: opt_param    >>
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
    98
                    (CreateRoom(n, p)))
13416
cdf69667593b partial room implementation
alfadur
parents: 13119
diff changeset
    99
    | do_parse!(tag!("JOIN_ROOM")   >> eol >>
12135
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
   100
                    n: a_line       >>
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
   101
                    p: opt_param    >>
13416
cdf69667593b partial room implementation
alfadur
parents: 13119
diff changeset
   102
                    (JoinRoom(n, p)))
13419
81e0ed105f5d implementation of team related messages
alfadur
parents: 13416
diff changeset
   103
    | do_parse!(tag!("ADD_TEAM")    >> eol >>
81e0ed105f5d implementation of team related messages
alfadur
parents: 13416
diff changeset
   104
                    name: a_line    >> eol >>
81e0ed105f5d implementation of team related messages
alfadur
parents: 13416
diff changeset
   105
                    color: u8_line  >> eol >>
81e0ed105f5d implementation of team related messages
alfadur
parents: 13416
diff changeset
   106
                    grave: a_line   >> eol >>
81e0ed105f5d implementation of team related messages
alfadur
parents: 13416
diff changeset
   107
                    fort: a_line    >> eol >>
81e0ed105f5d implementation of team related messages
alfadur
parents: 13416
diff changeset
   108
                    voice_pack: a_line >> eol >>
81e0ed105f5d implementation of team related messages
alfadur
parents: 13416
diff changeset
   109
                    flag: a_line    >> eol >>
81e0ed105f5d implementation of team related messages
alfadur
parents: 13416
diff changeset
   110
                    difficulty: u8_line >> eol >>
81e0ed105f5d implementation of team related messages
alfadur
parents: 13416
diff changeset
   111
                    hedgehogs: _8_hogs >>
81e0ed105f5d implementation of team related messages
alfadur
parents: 13416
diff changeset
   112
                    (AddTeam(TeamInfo{
81e0ed105f5d implementation of team related messages
alfadur
parents: 13416
diff changeset
   113
                        name, color, grave, fort,
81e0ed105f5d implementation of team related messages
alfadur
parents: 13416
diff changeset
   114
                        voice_pack, flag, difficulty,
81e0ed105f5d implementation of team related messages
alfadur
parents: 13416
diff changeset
   115
                        hedgehogs, hedgehogs_number: 0
81e0ed105f5d implementation of team related messages
alfadur
parents: 13416
diff changeset
   116
                     })))
81e0ed105f5d implementation of team related messages
alfadur
parents: 13416
diff changeset
   117
    | do_parse!(tag!("HH_NUM")    >> eol >>
81e0ed105f5d implementation of team related messages
alfadur
parents: 13416
diff changeset
   118
                    n: a_line     >> eol >>
81e0ed105f5d implementation of team related messages
alfadur
parents: 13416
diff changeset
   119
                    c: u8_line    >>
81e0ed105f5d implementation of team related messages
alfadur
parents: 13416
diff changeset
   120
                    (SetHedgehogsNumber(n, c)))
81e0ed105f5d implementation of team related messages
alfadur
parents: 13416
diff changeset
   121
    | do_parse!(tag!("TEAM_COLOR")    >> eol >>
81e0ed105f5d implementation of team related messages
alfadur
parents: 13416
diff changeset
   122
                    n: a_line     >> eol >>
81e0ed105f5d implementation of team related messages
alfadur
parents: 13416
diff changeset
   123
                    c: u8_line    >>
81e0ed105f5d implementation of team related messages
alfadur
parents: 13416
diff changeset
   124
                    (SetTeamColor(n, c)))
12135
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
   125
    | do_parse!(tag!("BAN")    >> eol >>
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
   126
                    n: a_line     >> eol >>
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
   127
                    r: a_line     >> eol >>
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
   128
                    t: u32_line   >>
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
   129
                    (Ban(n, r, t)))
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
   130
    | do_parse!(tag!("BAN_IP")    >> eol >>
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
   131
                    n: a_line     >> eol >>
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
   132
                    r: a_line     >> eol >>
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
   133
                    t: u32_line   >>
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
   134
                    (BanIP(n, r, t)))
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
   135
    | do_parse!(tag!("BAN_NICK")    >> eol >>
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
   136
                    n: a_line     >> eol >>
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
   137
                    r: a_line     >> eol >>
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
   138
                    t: u32_line   >>
23ee939ba66a Add more messages to the parser
unc0rr
parents: 12134
diff changeset
   139
                    (BanNick(n, r, t)))
12133
81df2e1f9ae9 Some parsing using nom
unc0rr
parents:
diff changeset
   140
));
81df2e1f9ae9 Some parsing using nom
unc0rr
parents:
diff changeset
   141
12137
193dfdcb0620 - Use logging facilities instead of plain println!
unc0rr
parents: 12136
diff changeset
   142
named!(malformed_message<&[u8], HWProtocolMessage>,
193dfdcb0620 - Use logging facilities instead of plain println!
unc0rr
parents: 12136
diff changeset
   143
    do_parse!(separated_list!(eol, a_line) >> (Malformed)));
193dfdcb0620 - Use logging facilities instead of plain println!
unc0rr
parents: 12136
diff changeset
   144
193dfdcb0620 - Use logging facilities instead of plain println!
unc0rr
parents: 12136
diff changeset
   145
named!(empty_message<&[u8], HWProtocolMessage>,
193dfdcb0620 - Use logging facilities instead of plain println!
unc0rr
parents: 12136
diff changeset
   146
    do_parse!(alt!(end_of_message | eol) >> (Empty)));
193dfdcb0620 - Use logging facilities instead of plain println!
unc0rr
parents: 12136
diff changeset
   147
193dfdcb0620 - Use logging facilities instead of plain println!
unc0rr
parents: 12136
diff changeset
   148
named!(message<&[u8], HWProtocolMessage>, alt!(terminated!(
193dfdcb0620 - Use logging facilities instead of plain println!
unc0rr
parents: 12136
diff changeset
   149
    alt!(
193dfdcb0620 - Use logging facilities instead of plain println!
unc0rr
parents: 12136
diff changeset
   150
          basic_message
193dfdcb0620 - Use logging facilities instead of plain println!
unc0rr
parents: 12136
diff changeset
   151
        | one_param_message
193dfdcb0620 - Use logging facilities instead of plain println!
unc0rr
parents: 12136
diff changeset
   152
        | cmd_message
193dfdcb0620 - Use logging facilities instead of plain println!
unc0rr
parents: 12136
diff changeset
   153
        | complex_message
193dfdcb0620 - Use logging facilities instead of plain println!
unc0rr
parents: 12136
diff changeset
   154
        ), end_of_message
193dfdcb0620 - Use logging facilities instead of plain println!
unc0rr
parents: 12136
diff changeset
   155
    )
12140
7e259e47eb0d Fix malformed messages parsing
unc0rr
parents: 12137
diff changeset
   156
    | terminated!(malformed_message, end_of_message)
12137
193dfdcb0620 - Use logging facilities instead of plain println!
unc0rr
parents: 12136
diff changeset
   157
    | empty_message
193dfdcb0620 - Use logging facilities instead of plain println!
unc0rr
parents: 12136
diff changeset
   158
    )
193dfdcb0620 - Use logging facilities instead of plain println!
unc0rr
parents: 12136
diff changeset
   159
);
12133
81df2e1f9ae9 Some parsing using nom
unc0rr
parents:
diff changeset
   160
12136
e25a82ce2374 - Render messages to string
unc0rr
parents: 12135
diff changeset
   161
named!(pub extract_messages<&[u8], Vec<HWProtocolMessage> >, many0!(complete!(message)));
12133
81df2e1f9ae9 Some parsing using nom
unc0rr
parents:
diff changeset
   162
13119
1e39b8749072 separated the server logic from all the async io mess.
alfadur
parents: 12142
diff changeset
   163
proptest! {
1e39b8749072 separated the server logic from all the async io mess.
alfadur
parents: 12142
diff changeset
   164
    #[test]
1e39b8749072 separated the server logic from all the async io mess.
alfadur
parents: 12142
diff changeset
   165
    fn is_parser_composition_idempotent(ref msg in gen_proto_msg()) {
1e39b8749072 separated the server logic from all the async io mess.
alfadur
parents: 12142
diff changeset
   166
        println!("!! Msg: {:?}, Bytes: {:?} !!", msg, msg.to_raw_protocol().as_bytes());
1e39b8749072 separated the server logic from all the async io mess.
alfadur
parents: 12142
diff changeset
   167
        assert_eq!(message(msg.to_raw_protocol().as_bytes()), IResult::Done(&b""[..], msg.clone()))
1e39b8749072 separated the server logic from all the async io mess.
alfadur
parents: 12142
diff changeset
   168
    }
1e39b8749072 separated the server logic from all the async io mess.
alfadur
parents: 12142
diff changeset
   169
}
1e39b8749072 separated the server logic from all the async io mess.
alfadur
parents: 12142
diff changeset
   170
12133
81df2e1f9ae9 Some parsing using nom
unc0rr
parents:
diff changeset
   171
#[test]
81df2e1f9ae9 Some parsing using nom
unc0rr
parents:
diff changeset
   172
fn parse_test() {
12134
109e6765b1fc Optional parameters parsing function
unc0rr
parents: 12133
diff changeset
   173
    assert_eq!(message(b"PING\n\n"),          IResult::Done(&b""[..], Ping));
109e6765b1fc Optional parameters parsing function
unc0rr
parents: 12133
diff changeset
   174
    assert_eq!(message(b"START_GAME\n\n"),    IResult::Done(&b""[..], StartGame));
12142
4d7d41be1993 Start refactoring path from getting message from client to reacting to it
unc0rr
parents: 12140
diff changeset
   175
    assert_eq!(message(b"NICK\nit's me\n\n"), IResult::Done(&b""[..], Nick("it's me".to_string())));
12134
109e6765b1fc Optional parameters parsing function
unc0rr
parents: 12133
diff changeset
   176
    assert_eq!(message(b"PROTO\n51\n\n"),     IResult::Done(&b""[..], Proto(51)));
12142
4d7d41be1993 Start refactoring path from getting message from client to reacting to it
unc0rr
parents: 12140
diff changeset
   177
    assert_eq!(message(b"QUIT\nbye-bye\n\n"), IResult::Done(&b""[..], Quit(Some("bye-bye".to_string()))));
12134
109e6765b1fc Optional parameters parsing function
unc0rr
parents: 12133
diff changeset
   178
    assert_eq!(message(b"QUIT\n\n"),          IResult::Done(&b""[..], Quit(None)));
12142
4d7d41be1993 Start refactoring path from getting message from client to reacting to it
unc0rr
parents: 12140
diff changeset
   179
    assert_eq!(message(b"CMD\nwatch\ndemo\n\n"), IResult::Done(&b""[..], Watch("demo".to_string())));
4d7d41be1993 Start refactoring path from getting message from client to reacting to it
unc0rr
parents: 12140
diff changeset
   180
    assert_eq!(message(b"BAN\nme\nbad\n77\n\n"), IResult::Done(&b""[..], Ban("me".to_string(), "bad".to_string(), 77)));
12136
e25a82ce2374 - Render messages to string
unc0rr
parents: 12135
diff changeset
   181
13119
1e39b8749072 separated the server logic from all the async io mess.
alfadur
parents: 12142
diff changeset
   182
    assert_eq!(message(b"CMD\nPART\n\n"),      IResult::Done(&b""[..], Part(None)));
1e39b8749072 separated the server logic from all the async io mess.
alfadur
parents: 12142
diff changeset
   183
    assert_eq!(message(b"CMD\nPART\n_msg_\n\n"), IResult::Done(&b""[..], Part(Some("_msg_".to_string()))));
1e39b8749072 separated the server logic from all the async io mess.
alfadur
parents: 12142
diff changeset
   184
12140
7e259e47eb0d Fix malformed messages parsing
unc0rr
parents: 12137
diff changeset
   185
    assert_eq!(extract_messages(b"QUIT\n1\n2\n\n"),    IResult::Done(&b""[..], vec![Malformed]));
7e259e47eb0d Fix malformed messages parsing
unc0rr
parents: 12137
diff changeset
   186
12137
193dfdcb0620 - Use logging facilities instead of plain println!
unc0rr
parents: 12136
diff changeset
   187
    assert_eq!(extract_messages(b"PING\n\nPING\n\nP"), IResult::Done(&b"P"[..], vec![Ping, Ping]));
193dfdcb0620 - Use logging facilities instead of plain println!
unc0rr
parents: 12136
diff changeset
   188
    assert_eq!(extract_messages(b"SING\n\nPING\n\n"),  IResult::Done(&b""[..],  vec![Malformed, Ping]));
193dfdcb0620 - Use logging facilities instead of plain println!
unc0rr
parents: 12136
diff changeset
   189
    assert_eq!(extract_messages(b"\n\n\n\nPING\n\n"),  IResult::Done(&b""[..],  vec![Empty, Empty, Ping]));
193dfdcb0620 - Use logging facilities instead of plain println!
unc0rr
parents: 12136
diff changeset
   190
    assert_eq!(extract_messages(b"\n\n\nPING\n\n"),    IResult::Done(&b""[..],  vec![Empty, Empty, Ping]));
13119
1e39b8749072 separated the server logic from all the async io mess.
alfadur
parents: 12142
diff changeset
   191
}