codegame 0.7.0

CodeGame framework
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
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121

use super::*;

struct Stream {
    reader: Box<dyn BufRead + Send>,
    writer: Box<dyn Write + Send>,
}

pub struct StreamPlayer<G: Game> {
    stream: Option<Stream>,
    phantom_data: PhantomData<G>,
}

impl<G: Game> StreamPlayer<G> {
    pub fn new(reader: Box<dyn BufRead + Send>, writer: Box<dyn Write + Send>) -> Self {
        Self {
            stream: Some(Stream { reader, writer }),
            phantom_data: PhantomData,
        }
    }
}

impl<G: Game> Drop for StreamPlayer<G> {
    fn drop(&mut self) {
        if let Some(stream) = &mut self.stream {
            let mut try_write_finish = || {
                ServerMessage::<G>::Finish {}.write_to(&mut stream.writer)?;
                stream.writer.flush()
            };
            if let Err(e) = try_write_finish() {
                warn!("{}", e);
            }
        }
    }
}

impl<G: Game> Player<G> for StreamPlayer<G> {
    fn get_action(
        &mut self,
        player_view: &G::PlayerView,
        debug_interface: Option<&PlayerDebugInterface<G>>,
    ) -> Result<G::Action, PlayerError> {
        let stream = self.stream.as_mut().expect("Called get_action after error");
        let mut get_action = move || {
            ServerMessage::<G>::GetAction {
                player_view: player_view.clone(), // TODO: dont clone
                debug_available: debug_interface.is_some(),
            }
            .write_to(&mut stream.writer)?;
            stream.writer.flush()?;
            loop {
                match ClientMessage::<G>::read_from(&mut stream.reader)? {
                    ClientMessage::ActionMessage { action } => return Ok(action),
                    ClientMessage::RequestDebugState {} => {
                        if let Some(debug_interface) = debug_interface {
                            debug_interface.state().write_to(&mut stream.writer)?;
                            stream.writer.flush()?;
                        } else {
                            return Err(PlayerError::IOError(std::io::Error::new(
                                std::io::ErrorKind::Other,
                                "Requested debug state with no debug interface available",
                            )));
                        }
                    }
                    ClientMessage::DebugMessage { command } => {
                        if let Some(debug_interface) = debug_interface {
                            debug_interface.send(command);
                        }
                    }
                    ClientMessage::DebugUpdateDone {} => {
                        return Err(PlayerError::IOError(std::io::Error::new(
                            std::io::ErrorKind::Other,
                            "Unexpected debug update done message in get_action",
                        )));
                    }
                }
            }
        };
        let result = get_action();
        if result.is_err() {
            self.stream = None;
        }
        result
    }
    fn debug_update(
        &mut self,
        player_view: &G::PlayerView,
        debug_interface: &PlayerDebugInterface<G>,
    ) -> Result<(), PlayerError> {
        let stream = self.stream.as_mut().expect("Called get_action after error");
        let mut debug_update = move || {
            ServerMessage::<G>::DebugUpdate {
                player_view: player_view.clone(), // TODO: do not clone
            }
            .write_to(&mut stream.writer)?;
            stream.writer.flush()?;
            loop {
                match ClientMessage::<G>::read_from(&mut stream.reader)? {
                    ClientMessage::ActionMessage { .. } => {
                        return Err(PlayerError::IOError(std::io::Error::new(
                            std::io::ErrorKind::Other,
                            "Unexpected action message in debug update",
                        )));
                    }
                    ClientMessage::RequestDebugState {} => {
                        debug_interface.state().write_to(&mut stream.writer)?;
                        stream.writer.flush()?;
                    }
                    ClientMessage::DebugMessage { command } => {
                        debug_interface.send(command);
                    }
                    ClientMessage::DebugUpdateDone {} => return Ok(()),
                }
            }
        };
        let result = debug_update();
        if result.is_err() {
            self.stream = None;
        }
        result
    }
}