4 #include <acess/sys.h>
\r
9 #include <readline.h>
\r
14 typedef struct sServer {
\r
15 struct sServer *Next;
\r
17 char InBuf[BUFSIZ+1];
\r
22 typedef struct sMessage
\r
24 struct sMessage *Next;
\r
28 char *Source; // Pointer into `Data`
\r
32 typedef struct sWindow
\r
34 struct sWindow *Next;
\r
36 tServer *Server; //!< Canoical server (can be NULL)
\r
38 char Name[]; // Channel name / remote user
\r
44 MSG_TYPE_SERVER, // Server message
\r
46 MSG_TYPE_NOTICE, // NOTICE command
\r
47 MSG_TYPE_JOIN, // JOIN command
\r
48 MSG_TYPE_PART, // PART command
\r
49 MSG_TYPE_QUIT, // QUIT command
\r
51 MSG_TYPE_STANDARD, // Standard line
\r
52 MSG_TYPE_ACTION, // /me
\r
57 // === PROTOTYPES ===
\r
58 int ParseArguments(int argc, const char *argv[]);
\r
59 int ParseUserCommand(char *String);
\r
61 tServer *Server_Connect(const char *Name, const char *AddressString, short PortNumber);
\r
62 tMessage *Message_Append(tServer *Server, int Type, const char *Source, const char *Dest, const char *Message);
\r
63 tWindow *Window_Create(tServer *Server, const char *Name);
\r
65 int ProcessIncoming(tServer *Server);
\r
67 int writef(int FD, const char *Format, ...);
\r
68 int OpenTCP(const char *AddressString, short PortNumber);
\r
69 char *GetValue(char *Str, int *Ofs);
\r
70 static inline int isdigit(int ch);
\r
73 char *gsUsername = "root";
\r
74 char *gsHostname = "acess";
\r
75 char *gsRealName = "Acess2 IRC Client";
\r
76 char *gsNickname = "acess";
\r
78 tWindow gWindow_Status = {
\r
79 NULL, NULL, NULL, // No next, empty list, no server
\r
80 0, "" // No activity, empty name (rendered as status)
\r
82 tWindow *gpWindows = &gWindow_Status;
\r
83 tWindow *gpCurrentWindow = &gWindow_Status;
\r
86 int main(int argc, const char *argv[], const char *envp[])
\r
89 tReadline *readline_info;
\r
91 // Parse Command line
\r
92 if( (tmp = ParseArguments(argc, argv)) ) return tmp;
\r
94 // HACK: Static server entry
\r
95 // UCC (University [of Western Australia] Computer Club) IRC Server
\r
96 gWindow_Status.Server = Server_Connect( "UCC", "130.95.13.18", 6667 );
\r
98 if( !gWindow_Status.Server )
\r
101 readline_info = Readline_Init(1);
\r
105 fd_set readfds, errorfds;
\r
110 FD_ZERO(&errorfds);
\r
111 FD_SET(0, &readfds); // stdin
\r
113 // Fill server FDs in fd_set
\r
114 for( srv = gpServers; srv; srv = srv->Next )
\r
116 FD_SET(srv->FD, &readfds);
\r
117 FD_SET(srv->FD, &errorfds);
\r
118 if( srv->FD > maxFD )
\r
122 rv = select(maxFD+1, &readfds, 0, &errorfds, NULL);
\r
123 if( rv == -1 ) break;
\r
125 if(FD_ISSET(0, &readfds))
\r
128 char *cmd = Readline_NonBlock(readline_info);
\r
133 ParseUserCommand(cmd);
\r
140 for( srv = gpServers; srv; srv = srv->Next )
\r
142 if(FD_ISSET(srv->FD, &readfds))
\r
144 if( ProcessIncoming(srv) != 0 ) {
\r
150 if(FD_ISSET(srv->FD, &errorfds))
\r
162 for( srv = gpServers; srv; srv = srv->Next )
\r
169 * \todo Actually implement correctly :)
\r
171 int ParseArguments(int argc, const char *argv[])
\r
176 int ParseUserCommand(char *String)
\r
178 if( String[0] == '/' )
\r
183 command = GetValue(String, &pos);
\r
185 if( strcmp(command, "/join") == 0 )
\r
187 char *channel_name = GetValue(String, &pos);
\r
189 if( gpCurrentWindow->Server )
\r
191 writef(gpCurrentWindow->Server->FD, "JOIN %s\n", channel_name);
\r
194 else if( strcmp(command, "/quit") == 0 )
\r
196 char *quit_message = GetValue(String, &pos);
\r
199 if( !quit_message )
\r
200 quit_message = "/quit - Acess2 IRC Client";
\r
202 for( srv = gpServers; srv; srv = srv->Next )
\r
204 writef(srv->FD, "QUIT %s\n", quit_message);
\r
207 else if( strcmp(command, "/window") == 0 || strcmp(command, "/win") == 0 || strcmp(command, "/w") == 0 )
\r
209 char *window_id = GetValue(String, &pos);
\r
210 int window_num = atoi(window_id);
\r
212 if( window_num > 0 )
\r
215 window_num --; // Move to base 0
\r
216 // Get `window_num`th window
\r
217 for( win = gpWindows; win && window_num--; win = win->Next );
\r
219 gpCurrentWindow = win;
\r
221 printf("[%s:%s] ", win->Server->Name, win->Name);
\r
223 printf("[(status)] ", win->Server->Name, win->Name);
\r
225 // Otherwise, silently ignore
\r
230 int len = snprintf(NULL, 0, "Unknown command %s", command);
\r
232 snprintf(buf, len+1, "Unknown command %s", command);
\r
233 Message_Append(NULL, MSG_TYPE_SERVER, "client", "", buf);
\r
239 // - Only send if server is valid and window name is non-empty
\r
240 if( gpCurrentWindow->Server && gpCurrentWindow->Name[0] )
\r
242 writef(gpCurrentWindow->Server->FD,
\r
243 "PRIVMSG %s :%s\n", gpCurrentWindow->Name,
\r
253 * \brief Connect to a server
\r
255 tServer *Server_Connect(const char *Name, const char *AddressString, short PortNumber)
\r
259 ret = calloc(1, sizeof(tServer) + strlen(Name) + 1);
\r
261 strcpy(ret->Name, Name);
\r
263 // Connect to the remove server
\r
264 ret->FD = OpenTCP( AddressString, PortNumber );
\r
265 if( ret->FD == -1 ) {
\r
266 fprintf(stderr, "%s: Unable to create socket\n", Name);
\r
270 // Append to open list
\r
271 ret->Next = gpServers;
\r
274 // Read some initial data
\r
275 printf("%s: Connection opened\n", Name);
\r
276 ProcessIncoming(ret);
\r
279 writef(ret->FD, "USER %s %s %s : %s\n", gsUsername, gsHostname, AddressString, gsRealName);
\r
280 writef(ret->FD, "NICK %s\n", gsNickname);
\r
281 printf("%s: Identified\n", Name);
\r
286 tMessage *Message_Append(tServer *Server, int Type, const char *Source, const char *Dest, const char *Message)
\r
289 tWindow *win = NULL;
\r
290 int msgLen = strlen(Message);
\r
292 // NULL servers are internal messages
\r
293 if( Server == NULL )
\r
295 win = &gWindow_Status;
\r
297 // Determine if it's a channel or PM message
\r
298 else if( Dest[0] == '#' || Dest[0] == '&' ) // TODO: Better determining here
\r
300 tWindow *prev = NULL;
\r
301 for(win = gpWindows; win; prev = win, win = win->Next)
\r
303 if( win->Server == Server && strcmp(win->Name, Dest) == 0 )
\r
309 win = Window_Create(Server, Dest);
\r
313 else if( strcmp(Dest, Server->Nick) != 0 )
\r
315 // Umm... message for someone who isn't us?
\r
316 win = &gWindow_Status; // Stick it in the status window, just in case
\r
320 else if( strchr(Source, '.') ) // TODO: And again, less hack please
\r
323 for(win = gpWindows; win; win = win->Next)
\r
325 if( win->Server == Server && strcmp(win->Name, Source) == 0 )
\r
332 win = &gWindow_Status;
\r
339 for(win = gpWindows; win; win = win->Next)
\r
341 if( win->Server == Server && strcmp(win->Name, Source) == 0 )
\r
347 win = Window_Create(Server, Dest);
\r
351 ret = malloc( sizeof(tMessage) + msgLen + 1 + strlen(Source) + 1 );
\r
352 ret->Source = ret->Data + msgLen + 1;
\r
353 strcpy(ret->Source, Source);
\r
354 strcpy(ret->Data, Message);
\r
356 ret->Server = Server;
\r
358 // TODO: Append to window message list
\r
359 ret->Next = win->Messages;
\r
360 win->Messages = ret;
\r
365 tWindow *Window_Create(tServer *Server, const char *Name)
\r
367 tWindow *ret, *prev = NULL;
\r
370 // Get the end of the list
\r
371 // TODO: Cache this instead
\r
372 for( ret = gpCurrentWindow; ret; prev = ret, ret = ret->Next )
\r
375 ret = malloc(sizeof(tWindow) + strlen(Name) + 1);
\r
376 ret->Messages = NULL;
\r
377 ret->Server = Server;
\r
378 ret->ActivityLevel = 1;
\r
379 strcpy(ret->Name, Name);
\r
382 ret->Next = prev->Next;
\r
385 else { // Shouldn't happen really
\r
386 ret->Next = gpWindows;
\r
390 printf("Win %i %s:%s created\n", num, Server->Name, Name);
\r
395 void Cmd_PRIVMSG(tServer *Server, const char *Dest, const char *Src, const char *Message)
\r
397 printf("<%s:%s:%s> %s\n", Server->Name, Dest, Src, Message);
\r
402 void ParseServerLine(tServer *Server, char *Line)
\r
410 ident = GetValue(Line, &pos); // Ident (user or server)
\r
411 cmd = GetValue(Line, &pos);
\r
414 if( isdigit(cmd[0]) && isdigit(cmd[1]) && isdigit(cmd[2]) )
\r
416 char *user, *message;
\r
418 num = (cmd[0] - '0') * 100;
\r
419 num += (cmd[1] - '0') * 10;
\r
420 num += (cmd[2] - '0') * 1;
\r
422 user = GetValue(Line, &pos);
\r
424 if( Line[pos] == ':' ) {
\r
425 message = Line + pos + 1;
\r
428 message = GetValue(Line, &pos);
\r
434 printf("[%s] %i %s\n", Server->Name, num, message);
\r
435 Message_Append(Server, MSG_TYPE_SERVER, ident, user, message);
\r
439 else if( strcmp(cmd, "NOTICE") == 0 )
\r
441 char *class, *message;
\r
443 class = GetValue(Line, &pos);
\r
445 if( Line[pos] == ':' ) {
\r
446 message = Line + pos + 1;
\r
449 message = GetValue(Line, &pos);
\r
452 printf("[%s] NOTICE %s: %s\n", Server->Name, ident, message);
\r
453 Message_Append(Server, MSG_TYPE_NOTICE, ident, "", message);
\r
455 else if( strcmp(cmd, "PRIVMSG") == 0 )
\r
457 char *dest, *message;
\r
458 dest = GetValue(Line, &pos);
\r
460 if( Line[pos] == ':' ) {
\r
461 message = Line + pos + 1;
\r
464 message = GetValue(Line, &pos);
\r
466 Cmd_PRIVMSG(Server, dest, ident, message);
\r
467 Message_Append(Server, MSG_TYPE_STANDARD, ident, dest, message);
\r
471 printf("Unknown message %s (%s)\n", cmd, Line+pos);
\r
476 // Command to client
\r
477 printf("Client Command: %s", Line);
\r
482 * \brief Process incoming lines from the server
\r
484 int ProcessIncoming(tServer *Server)
\r
486 char *ptr, *newline;
\r
489 // While there is data in the buffer, read it into user memory and
\r
490 // process it line by line
\r
491 // ioctl#8 on a TCP client gets the number of bytes in the recieve buffer
\r
492 // - Used to avoid blocking
\r
494 while( (len = ioctl(Server->FD, 8, NULL)) > 0 )
\r
498 len = read(Server->FD, BUFSIZ - Server->ReadPos, &Server->InBuf[Server->ReadPos]);
\r
502 Server->InBuf[Server->ReadPos + len] = '\0';
\r
504 // Break into lines
\r
505 ptr = Server->InBuf;
\r
506 while( (newline = strchr(ptr, '\n')) )
\r
509 if( newline[-1] == '\r' ) newline[-1] = '\0';
\r
510 ParseServerLine(Server, ptr);
\r
514 // Handle incomplete lines
\r
515 if( ptr - Server->InBuf < len + Server->ReadPos ) {
\r
516 // Update the read position
\r
517 // InBuf ReadPos ptr ReadPos+len
\r
518 // | old | new used | new unused |
\r
519 Server->ReadPos = len + Server->ReadPos - (ptr - Server->InBuf);
\r
520 // Copy stuff back (moving "new unused" to the start of the buffer)
\r
521 memcpy(Server->InBuf, ptr, Server->ReadPos);
\r
524 Server->ReadPos = 0;
\r
534 * \brief Write a formatted string to a file descriptor
\r
537 int writef(int FD, const char *Format, ...)
\r
542 va_start(args, Format);
\r
543 len = vsnprintf(NULL, 1000, Format, args);
\r
548 va_start(args, Format);
\r
549 vsnprintf(buf, len+1, Format, args);
\r
552 return write(FD, len, buf);
\r
557 * \brief Initialise a TCP connection to \a AddressString on port \a PortNumber
\r
559 int OpenTCP(const char *AddressString, short PortNumber)
\r
563 char addrBuffer[8];
\r
565 // Parse IP Address
\r
566 addrType = Net_ParseAddress(AddressString, addrBuffer);
\r
567 if( addrType == 0 ) {
\r
568 fprintf(stderr, "Unable to parse '%s' as an IP address\n", AddressString);
\r
572 // Finds the interface for the destination address
\r
573 iface = Net_GetInterface(addrType, addrBuffer);
\r
574 if( iface == NULL ) {
\r
575 fprintf(stderr, "Unable to find a route to '%s'\n", AddressString);
\r
579 printf("iface = '%s'\n", iface);
\r
581 // Open client socket
\r
582 // TODO: Move this out to libnet?
\r
584 int len = snprintf(NULL, 100, "/Devices/ip/%s/tcpc", iface);
\r
586 snprintf(path, 100, "/Devices/ip/%s/tcpc", iface);
\r
587 fd = open(path, OPENFLAG_READ|OPENFLAG_WRITE);
\r
593 fprintf(stderr, "Unable to open TCP Client for reading\n");
\r
597 // Set remote port and address
\r
598 printf("Setting port and remote address\n");
\r
599 ioctl(fd, 5, &PortNumber);
\r
600 ioctl(fd, 6, addrBuffer);
\r
603 printf("Initiating connection\n");
\r
604 if( ioctl(fd, 7, NULL) == 0 ) {
\r
605 // Shouldn't happen :(
\r
606 fprintf(stderr, "Unable to start connection\n");
\r
610 // Return descriptor
\r
615 * \brief Read a space-separated value from a string
\r
617 char *GetValue(char *Src, int *Ofs)
\r
620 char *ret = Src + pos;
\r
623 if( !Src ) return NULL;
\r
625 while( *ret == ' ' ) ret ++;
\r
627 end = strchr(ret, ' ');
\r
632 end = ret + strlen(ret) - 1;
\r
636 while( *ret == ' ' ) end ++;
\r
642 static inline int isdigit(int ch)
\r
644 return '0' <= ch && ch < '9';
\r