2005-11-24 Carl Worth <cworth@cworth.org>
[ttt] / src / ttt-server.c
1 /* ttt-server.c - tic-tac-toe game server
2  *
3  * Copyright © 2005 Carl Worth
4  *
5  * This program is free software; you can redistribute it and/or modify
6  * it under the terms of the GNU General Public License as published by
7  * the Free Software Foundation; either version 2, or (at your option)
8  * any later version.
9  *
10  * This program is distributed in the hope that it will be useful,
11  * but WITHOUT ANY WARRANTY; without even the implied warranty of
12  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
13  * GNU General Public License for more details.
14  *
15  * You should have received a copy of the GNU General Public License
16  * along with this program; if not, write to the Free Software Foundation,
17  * Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
18  *
19  * Author: Carl Worth <cworth@cworth.org>
20  */
21
22 #include "ttt-server.h"
23
24 #include "ttt-args.h"
25 #include "ttt-client.h"
26 #include "ttt-error.h"
27 #include "ttt-socket.h"
28
29 struct _ttt_server {
30     pthread_mutex_t mutex;
31
32     const char *host;
33     const char *port;
34
35     ttt_client_t **clients;
36     int clients_size;
37     int num_clients;
38 };
39
40 static void
41 ttt_server_init (ttt_server_t *server, const char *host, const char *port)
42 {
43     pthread_mutex_init (&server->mutex, NULL);
44
45     server->host = host;
46     server->port = port;
47
48     server->clients = NULL;
49     server->clients_size = 0;
50     server->num_clients = 0;
51 }
52
53 /* Exported: See ttt-server.h for documentation. */
54 ttt_error_t
55 ttt_server_register_client (ttt_server_t *server, ttt_client_t *client)
56 {
57     int i;
58     ttt_error_t error = TTT_ERROR_NONE;
59     const char *name;
60
61     pthread_mutex_lock (&server->mutex);
62
63     name = ttt_client_get_name (client);
64
65     assert (name != NULL);
66
67     if (name[0] == '\0')
68         return TTT_ERROR_INVALIDNAME;
69
70     for (i = 0; i < server->num_clients; i++) {
71         if (strcmp (ttt_client_get_name (server->clients[i]), name) == 0) {
72             error = TTT_ERROR_INVALIDNAME;
73             goto CLEANUP_LOCK;
74         }
75     }
76
77     printf ("Client %s has joined.\n", name);
78
79     server->num_clients++;
80
81     if (server->num_clients > server->clients_size) {
82         if (server->clients_size == 0)
83             server->clients_size = 1;
84         else
85             server->clients_size *= 2;
86
87         server->clients = xrealloc (server->clients,
88                                     server->clients_size * sizeof (ttt_client_t *));
89     }
90
91     server->clients [server->num_clients - 1] = client;
92
93  CLEANUP_LOCK:
94     pthread_mutex_unlock (&server->mutex);
95
96     return error;
97 }
98
99 /* Exported: See ttt-server.h for documentation. */
100 void
101 ttt_server_unregister_client (ttt_server_t *server, ttt_client_t *client)
102 {
103     int i;
104
105     pthread_mutex_lock (&server->mutex);
106
107     for (i = 0; i < server->num_clients; i++)
108         if (server->clients[i] == client)
109             break;
110
111     assert (i < server->num_clients);
112
113     printf ("Client %s has left.\n", ttt_client_get_name (client));
114
115     memmove (&server->clients[i], &server->clients[i+1],
116              (server->num_clients - i - 1) * sizeof (ttt_client_t *));
117
118     server->num_clients--;
119
120     pthread_mutex_unlock (&server->mutex);
121 }
122
123 void
124 ttt_server_broadcast (ttt_server_t *server, const char *message)
125 {
126     int i;
127
128     pthread_mutex_lock (&server->mutex);
129
130     for (i = 0; i < server->num_clients; i++)
131         ttt_client_send (server->clients[i], message);
132
133     pthread_mutex_unlock (&server->mutex);
134 }
135
136 /* Exported: See ttt-server.h for documentation. */
137 const char*
138 ttt_server_get_host (ttt_server_t *server)
139 {
140     return server->host;
141 }
142
143 /* Exported: See ttt-server.h for documentation. */
144 const char*
145 ttt_server_get_port (ttt_server_t *server)
146 {
147     return server->port;
148 }
149
150 static const char *WELCOME_MESSAGE = 
151 "Welcome to ttt-server. So far, this program is still a demonstration\n"
152 "TCP/IP server, acting something like a rather braindead chat server.\n"
153 "The server is currently listening on:\n"
154 "\n     %s:%s\n"
155 "\nTo test this, simply connect one or more clients to that host and port.\n"
156 "For example:\n"
157 "\n     telnet %s %s\n"
158 "\nOnce you have connected a client, the server will send each line of text\n"
159 "it receives to all connected clients. The server reports client joins and\n"
160 "departures on stdout.\n"
161 "\nNote that to terminate the telnet client you type Control-], then\n"
162 "<Enter>, then \"close\" (and <Enter>) at the \"telnet> \" prompt.\n"
163 "\nHave fun!\n"
164 "-Carl\n"
165 "\nPS. At this point we're ready to leave the demonstration phase and to\n"
166 "begin implementing TTTP (tic-tac-toe protocol) as well as fixing the\n"
167 "protocol specifcation. We don't need a custom client to move forward on\n"
168 "the server (that is one of the ideas behind using a telnet-compatible\n"
169 "protocol), but a custom client would still be a fine project for a\n"
170 "motivated beginning programmer.\n\n";
171
172 static void
173 _ttt_server_accept (void *closure, int client_socket)
174 {
175     ttt_server_t *server = closure;
176
177     ttt_client_new (server, client_socket);
178 }
179
180 int 
181 main (int argc, char **argv)
182 {
183     ttt_args_t args;
184     ttt_server_t server;
185     int socket;
186
187     ttt_args_parse (&args, argc, argv);
188
189     if (args.log_file)
190         xfreopen (args.log_file, "a", stderr);
191
192     socket = ttt_socket_create_server (args.host, args.port);
193
194     printf (WELCOME_MESSAGE, args.host, args.port, args.host, args.port);
195
196     ttt_server_init (&server, args.host, args.port);
197
198     while (1)
199         ttt_socket_accept (socket, _ttt_server_accept, &server);
200
201     /* We only reach here if something bad happened. */
202     return 1;
203 }