game2/server.cpp at master · ejichen/game2 · GitHub

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
#include "Connection.hpp"
#include "Game.hpp"

#include <iostream>
#include <set>
#include <chrono>

int main(int argc, char **argv) {
	if (argc != 2) {
		std::cerr << "Usage:\n\t./server <port>" << std::endl;
		return 1;
	}

	Server server(argv[1]);

	Game state;

	while (1) {
		server.poll([&](Connection *c, Connection::Event evt){
			if (evt == Connection::OnOpen) {
			} else if (evt == Connection::OnClose) {
			} else { assert(evt == Connection::OnRecv);
				while(!(c->recv_buffer.empty())){
				if (*(c->recv_buffer.begin()) == 'h') {
					c->recv_buffer.erase(c->recv_buffer.begin(), c->recv_buffer.begin() + 1);
					std::cout << c << ": Got hello." << std::endl;
				}
				// else if (*(c->recv_buffer.begin()) == 's') {
				// 	if (c->recv_buffer.size() < 1 + sizeof(float)) {
				// 		return; //wait for more data
				// 	} else {
				// 		memcpy(&state.paddle.x, c->recv_buffer.data() + 1, sizeof(float));
				// 		// the update is coming from the first client
				// 		if(c == &server.connections.front()){
				// 			server.connections.back().send_raw("t", 1);
				// 			server.connections.back().send_raw(&state.paddle.x, sizeof(float));
				// 		}
				// 		else if (c == &server.connections.back()){
				// 			server.connections.front().send_raw("t", 1);
				// 			server.connections.front().send_raw(&state.paddle.x, sizeof(float));
				// 		}
				// 		else{
				// 			std::cout << "someone else send the message" << std::endl;
				// 		}
				//
				// 		c->recv_buffer.erase(c->recv_buffer.begin(), c->recv_buffer.begin() + 1 + sizeof(float));
				// 		// c->recv_buffer.clear();
				// 	}
				// }
				else if (*(c->recv_buffer.begin()) == 'c') {
					// change color, update at local and send a new color to both company
					// default the front is red and the back is blue
					if (c->recv_buffer.size() < 1 + sizeof(int)) {
						return; //wait for more data
					} else {
						memcpy(&state.chaned_index, c->recv_buffer.data() + 1, sizeof(int));
						std::cout << "receive data: " << state.chaned_index << std::endl;
						if(c == &server.connections.front()){
							if (state.rod_meshes[state.chaned_index] == 0){
								state.rod_meshes[state.chaned_index] = 1;
								state.chaned_color = 1;
								std::cout << "inside the front, sending color " << state.chaned_color << std::endl;
								server.connections.back().send_raw("i", 1);
								server.connections.back().send_raw(&state.chaned_color, sizeof(int));
								server.connections.back().send_raw(&state.chaned_index, sizeof(int));
								server.connections.front().send_raw("i", 1);
								server.connections.front().send_raw(&state.chaned_color, sizeof(int));
								server.connections.front().send_raw(&state.chaned_index, sizeof(int));

							}
						}
						else if (c == &server.connections.back()){
							if (state.rod_meshes[state.chaned_index] == 0){
								state.rod_meshes[state.chaned_index] = 2;
								state.chaned_color = 2;
								server.connections.back().send_raw("i", 1);
								server.connections.back().send_raw(&state.chaned_color, sizeof(int));
								server.connections.back().send_raw(&state.chaned_index, sizeof(int));
								server.connections.front().send_raw("i", 1);
								server.connections.front().send_raw(&state.chaned_color, sizeof(int));
								server.connections.front().send_raw(&state.chaned_index, sizeof(int));
							}
						}
						else{
							std::cout << "someone else send the message, weird" << std::endl;
						}

						c->recv_buffer.erase(c->recv_buffer.begin(), c->recv_buffer.begin() + 1 + sizeof(int));
						// c->recv_buffer.clear();

					}
				}
			}
		}
		}, 0.01);
		//every second or so, dump the current paddle position:
		static auto then = std::chrono::steady_clock::now();
		auto now = std::chrono::steady_clock::now();
		if (now > then + std::chrono::seconds(1)) {
			then = now;
			std::cout << "Currently connecting. " << std::endl;

		}
	}
}