1 /* ircd_client.c - NextIRCd
2 * Copyright (C) 2012-2013 Philipp Kreil (pk910)
4 * This program is free software: you can redistribute it and/or modify
5 * it under the terms of the GNU General Public License as published by
6 * the Free Software Foundation, either version 3 of the License, or
7 * (at your option) any later version.
9 * This program is distributed in the hope that it will be useful,
10 * but WITHOUT ANY WARRANTY; without even the implied warranty of
11 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
12 * GNU General Public License for more details.
14 * You should have received a copy of the GNU General Public License
15 * along with this program. If not, see <http://www.gnu.org/licenses/>.
19 #include "IOHandler/IOSockets.h"
21 typedef int cmd_client_t(struct Client *client, char *argv[], int argc);
22 typedef int cmd_auth_t(struct Auth *auth, char *argv[], int argc);
23 typedef int cmd_server_t(struct Server *server, char *argv[], int argc);
25 static struct ServerMsg parse_static_srvmsg;
27 #define PARSE_CLIFLAG_OPONLY 0x01
29 //include all commands
39 cmd_client_t *function;
40 unsigned int min_argc : 8;
41 unsigned int max_argc : 8;
42 unsigned int flags : 8;
46 unsigned int min_argc : 8;
47 unsigned int max_argc : 8;
48 unsigned int flags : 8;
51 cmd_server_t *function;
52 unsigned int min_argc : 8;
53 unsigned int max_argc : 8;
54 unsigned int flags : 8;
57 } parse_command_list {
58 {{"PING", "P"}, /* Ping Command */
59 {NULL, 0, 1, 0}, /* Client */
60 {NULL, 0, 1, 0}, /* Unauthed */
61 {NULL, 0, 1, 0} /* Server */
63 {{"PASS", NULL}, /* PASS Command */
64 {NULL, 0, 1, 0}, /* Client */
65 {NULL, 0, 1, 0}, /* Unauthed */
66 {NULL, 0, 1, 0} /* Server */
68 {{"NICK", "N"}, /* Nick Command */
69 {cmd_nick_cli, 0, 1, 0}, /* Client */
70 {cmd_nick_auth, 0, 1, 0}, /* Unauthed */
71 {NULL, 0, 1, 0} /* Server */
73 {{"USER", "U"}, /* User Command */
74 {NULL, 0, 1, 0}, /* Client */
75 {NULL, 0, 1, 0}, /* Unauthed */
76 {NULL, 0, 1, 0} /* Server */
79 {{NULL, NULL},{NULL, 0, 0, 0},{NULL, 0, 0, 0},{NULL, 0, 0, 0}}
82 static char *parse_irc_token(char **data) {
86 for(i = 0; *data[i]; i++) {
96 static char **parse_irc_params(char *data, int *argc, int maxargs) {
101 char **argv = calloc(maxargs, sizeof(*argv));
103 //skip leading spaces
107 //the rest is a single parameter
108 argv[*argc++] = line + 1;
111 argv[*argc++] = line;
114 while (*line != ' ' && *line)
120 /* Client Data Format
121 * <TOKEN> <arg1> <arg2>
123 void parse_client_data(struct Client *client, char *data) {
124 char *token = parse_irc_token(&data);
127 for(i = 0; (parse_command_list[i].tokens.client || parse_command_list[i].tokens.server); i++) {
128 if(stricmp(parse_command_list[i].tokens.client, token)) {
133 if(found && !parse_command_list[i].client.function) {
134 // reply 462 You may not reregister
137 char **argv = parse_irc_params(data, &argc, parse_command_list[i].client.max_argc);
138 if(argc < parse_command_list[i].client.min_argc) {
139 // reply 461 Not enough parameters
141 int ret = parse_command_list[i].client.function(client, argv, argc);
149 // reply 421 Unknown command
153 void parse_unauth_data(struct Auth *auth, char *data) {
154 char *token = parse_irc_token(&data);
157 for(i = 0; (parse_command_list[i].tokens.client || parse_command_list[i].tokens.server); i++) {
158 if(stricmp(parse_command_list[i].tokens.client, token)) {
163 if(found && !parse_command_list[i].auth.function) {
164 // reply 451 Register first.
167 char **argv = parse_irc_params(data, &argc, parse_command_list[i].auth.max_argc);
168 if(argc < parse_command_list[i].auth.min_argc) {
169 // reply 461 Not enough parameters
171 int ret = parse_command_list[i].auth.function(auth, argv, argc);
179 // reply 421 Unknown command
183 /* Unicast Multicast Broadcast
184 * <src-srvnum> 4 Bytes <source> 4 Bytes <source> 4 Bytes
185 * <length> 2 Bytes <length> 2 Bytes <length> 2 Bytes
186 * <flags> 1 Byte <flags> 1 Byte <flags> 1 Byte
187 * <token> x Bytes <token> x Bytes <token> x Bytes
188 * " " 1 Byte " " 1 Byte " " 1 Byte
189 * <dst-srvnum> 4 Bytes <servers> 1 Byte <ttl> 1 Byte
190 * <dst-srv01> 4 Bytes
191 * <dst-srv02> 4 Bytes
192 * <args> <args> <args>
194 void parse_server_data(struct Server *server, struct IOSocketBuffer *buffer) {
195 struct ServerMsg *srvmsg = &parse_static_srvmsg;
196 unsigned char *buf = (unsigned char *)buffer->buffer;
197 unsigned int buflen, require_more = 0;
200 while(buffer->bufpos >= 9 && !require_more) { //require at least 9 Bytes
201 srvmsg->source.srvnum = ((buf[0] << 24) | (buf[1] << 16) | (buf[2] << 8) | buf[3]);
202 srvmsg->resolved_source = 0;
203 srvmsg->msglen = ((buf[4] << 8) | buf[5]);
204 srvmsg->msgflags = buf[6];
205 srvmsg->msgtype = (buf[6] & SERVERMSG_TYPEMASK);
207 if(buffer->bufpos < srvmsg->msglen) {
212 for(i = 0; buffer->bufpos > i+7; i++) {
213 if(buf[i+7] == ' ') {
214 if(i >= MAXSERVERTOKENLEN)
215 srvmsg->token[MAXSERVERTOKENLEN] = '\0';
217 srvmsg->token[i] = '\0';
220 if(i >= MAXSERVERTOKENLEN)
222 srvmsg->token[i] = buf[i+7];
224 if(buf[i+7] != ' ') {
229 buflen = buffer->bufpos - (i+8);
231 switch(srvmsg->msgtype) {
232 case SERVERMSG_TYPE_UNICAST:
237 srvmsg->destinations = malloc(sizeof(struct ServerMsgDstMap));
238 srvmsg->destinations->dstcount = 1;
239 srvmsg->destinations->dst[0].destination.srvnum = ((buf[0] << 24) | (buf[1] << 16) | (buf[2] << 8) | buf[3]);
240 srvmsg->destinations->dst[0].destination.resolved_destination = 0;
242 case SERVERMSG_TYPE_MULTICAST:
247 unsigned int srvcount = buf[0];
250 if(buflen < (srvcount * 4)) {
254 srvmsg->destinations = malloc(sizeof(struct ServerMsgDstMap) + (sizeof(struct ServerMsgDestination) * (srvcount - 1)));
255 srvmsg->destinations->dstcount = srvcount;
256 for(i = 0; i < srvcount; i++) {
257 srvmsg->destinations->dst[i].destination.srvnum = ((buf[0] << 24) | (buf[1] << 16) | (buf[2] << 8) | buf[3]);
258 srvmsg->destinations->dst[i].destination.resolved_destination = 0;
263 case SERVERMSG_TYPE_BROADCAST:
268 srvmsg->destinations = NULL;
269 srvmsg->msgttl = buf[0];
275 goto parse_server_data_finish;
278 srvmsg->arglen = srvmsg->msglen - (buf - buffer->buffer);
282 for(i = 0; (parse_command_list[i].tokens.client || parse_command_list[i].tokens.server); i++) {
283 if(stricmp(parse_command_list[i].tokens.server, srvmsg->token)) {
289 goto parse_server_data_finish;
291 //exec command function
294 parse_server_data_finish:
295 if(srvmsg->destinations)
296 free(srvmsg->destinations);
298 if(srvmsg->msglen > buffer->bufpos) {
299 memmove(buffer->buffer, buffer->buffer + srvmsg->msglen, srvmsg->msglen - buffer->bufpos);
300 buffer->bufpos -= srvmsg->msglen;