10 #include <acess/devices/pty.h>
13 typedef struct sServer {
21 typedef struct sMessage
23 struct sMessage *Next;
27 char *Source; // Pointer into `Data`
31 typedef struct sWindow
35 tServer *Server; //!< Canonical server (can be NULL)
37 char Name[]; // Channel name / remote user
43 MSG_TYPE_SERVER, // Server message
45 MSG_TYPE_NOTICE, // NOTICE command
46 MSG_TYPE_JOIN, // JOIN command
47 MSG_TYPE_PART, // PART command
48 MSG_TYPE_QUIT, // QUIT command
50 MSG_TYPE_STANDARD, // Standard line
51 MSG_TYPE_ACTION, // /me
57 int ParseArguments(int argc, const char *argv[]);
58 int ParseUserCommand(char *String);
60 tServer *Server_Connect(const char *Name, const char *AddressString, short PortNumber);
61 tMessage *Message_AppendF(tServer *Server, int Type, const char *Source, const char *Dest, const char *Message, ...);
62 tMessage *Message_Append(tServer *Server, int Type, const char *Source, const char *Dest, const char *Message);
63 tWindow *Window_Create(tServer *Server, const char *Name);
64 void Redraw_Screen(void);
66 int ProcessIncoming(tServer *Server);
68 void SetCursorPos(int Row, int Col);
69 int writef(int FD, const char *Format, ...);
70 int OpenTCP(const char *AddressString, short PortNumber);
71 char *GetValue(char *Str, int *Ofs);
72 static inline int isdigit(int ch);
75 char *gsUsername = "user";
76 char *gsHostname = "acess";
77 char *gsRealName = "Acess2 IRC Client";
78 char *gsNickname = "acess";
80 tWindow gWindow_Status = {
81 NULL, NULL, NULL, // No next, empty list, no server
82 0, {""} // No activity, empty name (rendered as status)
84 tWindow *gpWindows = &gWindow_Status;
85 tWindow *gpCurrentWindow = &gWindow_Status;
86 int giTerminal_Width = 80;
87 int giTerminal_Height = 25;
90 void ExitHandler(void)
92 printf("\x1B[?1047l");
96 int main(int argc, const char *argv[], const char *envp[])
99 tReadline *readline_info;
101 // Parse Command line
102 if( (tmp = ParseArguments(argc, argv)) ) return tmp;
106 if( _SysIOCtl(1, DRV_IOCTL_TYPE, NULL) != DRV_TYPE_TERMINAL ) {
107 fprintf(stderr, "note: assuming 80x25, can't get terminal dimensions\n");
108 giTerminal_Width = 80;
109 giTerminal_Height = 25;
113 _SysIOCtl(1, PTY_IOCTL_GETDIMS, &dims);
114 giTerminal_Width = dims.W;
115 giTerminal_Height = dims.H;
118 printf("\x1B[?1047h");
119 printf("\x1B[%i;%ir", 0, giTerminal_Height-1);
121 SetCursorPos(giTerminal_Height-1, 0);
122 printf("[(status)] ");
124 // HACK: Static server entry
125 // UCC (University [of Western Australia] Computer Club) IRC Server
126 gWindow_Status.Server = Server_Connect( "UCC", "130.95.13.18", 6667 );
128 // gWindow_Status.Server = Server_Connect( "Freenode", "89.16.176.16", 6667 );
129 // gWindow_Status.Server = Server_Connect( "Host", "10.0.2.2", 6667 );
131 // gWindow_Status.Server = Server_Connect( "BitlBee", "192.168.1.39", 6667 );
133 if( !gWindow_Status.Server )
136 SetCursorPos(giTerminal_Height-1, 0);
137 printf("[(status)] ");
139 readline_info = Readline_Init(1);
143 fd_set readfds, errorfds;
149 FD_SET(0, &readfds); // stdin
153 // Fill server FDs in fd_set
154 for( srv = gpServers; srv; srv = srv->Next )
156 FD_SET(srv->FD, &readfds);
157 FD_SET(srv->FD, &errorfds);
158 if( srv->FD > maxFD )
162 rv = _SysSelect(maxFD+1, &readfds, 0, &errorfds, NULL, 0);
163 if( rv == -1 ) break;
165 if(FD_ISSET(0, &readfds))
168 char *cmd = Readline_NonBlock(readline_info);
173 ParseUserCommand(cmd);
177 SetCursorPos(giTerminal_Height-1, 0);
178 printf("\x1B[2K"); // Clear line
179 if( gpCurrentWindow->Name[0] )
180 printf("[%s:%s] ", gpCurrentWindow->Server->Name, gpCurrentWindow->Name);
182 printf("[(status)] ");
187 for( srv = gpServers; srv; srv = srv->Next )
189 if(FD_ISSET(srv->FD, &readfds))
191 if( ProcessIncoming(srv) != 0 ) {
197 if(FD_ISSET(srv->FD, &errorfds))
209 for( srv = gpServers; srv; srv = srv->Next )
216 * \todo Actually implement correctly :)
218 int ParseArguments(int argc, const char *argv[])
224 void Cmd_join(char *ArgString)
227 char *channel_name = GetValue(ArgString, &pos);
229 if( gpCurrentWindow->Server )
231 gpCurrentWindow = Window_Create(gpCurrentWindow->Server, channel_name);
233 writef(gpCurrentWindow->Server->FD, "JOIN :%s\n", channel_name);
237 void Cmd_quit(char *ArgString)
239 const char *quit_message = ArgString;
240 if( quit_message == NULL || quit_message[0] == '\0' )
241 quit_message = "/quit - Acess2 IRC Client";
243 for( tServer *srv = gpServers; srv; srv = srv->Next )
245 writef(srv->FD, "QUIT :%s\n", quit_message);
251 void Cmd_window(char *ArgString)
254 char *window_id = GetValue(ArgString, &pos);
255 int window_num = atoi(window_id);
260 window_num --; // Move to base 0
261 // Get `window_num`th window
262 for( win = gpWindows; win && window_num--; win = win->Next );
264 gpCurrentWindow = win;
267 // Otherwise, silently ignore
272 for( tWindow *win = gpWindows; win; win = win->Next, window_num ++ )
275 Message_AppendF(NULL, MSG_TYPE_SERVER, "client", "",
276 "%i: %s/%s", window_num, win->Server->Name, win->Name);
279 Message_AppendF(NULL, MSG_TYPE_SERVER, "client", "",
280 "%i: (status)", window_num);
288 void (*Fcn)(char *ArgString);
292 {"window", Cmd_window},
296 const int ciNumCommands = sizeof(caCommands)/sizeof(caCommands[0]);
299 * \brief Handle a line from the prompt
301 int ParseUserCommand(char *String)
303 if( String[0] == '/' )
308 command = GetValue(String, &pos)+1;
310 // TODO: Prefix matches
312 for( int i = 0; i < ciNumCommands; i ++ )
314 if( strcmp(command, caCommands[i].Name) == 0 ) {
320 caCommands[cmdIdx].Fcn(String+pos);
324 Message_AppendF(NULL, MSG_TYPE_SERVER, "client", "", "Unknown command %s", command);
330 // - Only send if server is valid and window name is non-empty
331 if( gpCurrentWindow->Server && gpCurrentWindow->Name[0] )
333 Message_Append(gpCurrentWindow->Server, MSG_TYPE_STANDARD,
334 gsNickname, gpCurrentWindow->Name, String);
335 writef(gpCurrentWindow->Server->FD,
336 "PRIVMSG %s :%s\n", gpCurrentWindow->Name,
346 * \brief Connect to a server
348 tServer *Server_Connect(const char *Name, const char *AddressString, short PortNumber)
352 ret = calloc(1, sizeof(tServer) + strlen(Name) + 1);
354 strcpy(ret->Name, Name);
356 // Connect to the remove server
357 ret->FD = OpenTCP( AddressString, PortNumber );
358 if( ret->FD == -1 ) {
359 fprintf(stderr, "%s: Unable to create socket\n", Name);
363 // Append to open list
364 ret->Next = gpServers;
367 // Read some initial data
368 Message_Append(NULL, MSG_TYPE_SERVER, Name, "", "Connection opened");
369 ProcessIncoming(ret);
372 writef(ret->FD, "USER %s %s %s : %s\n", gsUsername, gsHostname, AddressString, gsRealName);
373 writef(ret->FD, "NICK %s\n", gsNickname);
374 Message_Append(NULL, MSG_TYPE_SERVER, Name, "", "Identified");
375 //printf("%s: Identified\n", Name);
380 tMessage *Message_AppendF(tServer *Server, int Type, const char *Source, const char *Dest, const char *Message, ...)
384 va_start(args, Message);
385 len = vsnprintf(NULL, 0, Message, args);
388 vsnprintf(buf, len+1, Message, args);
389 return Message_Append(Server, Type, Source, Dest, buf);
393 tMessage *Message_Append(tServer *Server, int Type, const char *Source, const char *Dest, const char *Message)
396 int msgLen = strlen(Message);
398 // Server==NULL indicates an internal message
399 if( Server == NULL || Source[0] == '\0' )
401 win = &gWindow_Status;
403 // Determine if it's a channel or PM
404 else if( Dest[0] == '#' || Dest[0] == '&' ) // TODO: Better determining here
406 for(win = gpWindows; win; win = win->Next)
408 if( win->Server == Server && strcmp(win->Name, Dest) == 0 )
414 //win = Window_Create(Server, Dest);
415 win = &gWindow_Status; // Stick it in the status window, just in case
419 else if( strcmp(Dest, Server->Nick) != 0 )
421 // Umm... message for someone who isn't us?
422 win = &gWindow_Status; // Stick it in the status window, just in case
426 else if( strchr(Source, '.') ) // TODO: And again, less hack please
429 for(win = gpWindows; win; win = win->Next)
431 if( win->Server == Server && strcmp(win->Name, Source) == 0 )
438 win = &gWindow_Status;
441 // Set source to the server name (instead of the hostname)
442 Source = Server->Name;
447 for(win = gpWindows; win; win = win->Next)
449 if( win->Server == Server && strcmp(win->Name, Source) == 0 )
455 win = Window_Create(Server, Dest);
459 // Create message cache
460 _SysDebug("Win (%s) msg: <%s> %s", win->Name, Source, Message);
462 ret = malloc( sizeof(tMessage) + msgLen + 1 + strlen(Source) + 1 );
463 ret->Source = ret->Data + msgLen + 1;
464 strcpy(ret->Source, Source);
465 strcpy(ret->Data, Message);
467 ret->Server = Server;
469 // Append to window message list
470 ret->Next = win->Messages;
473 // Print now if current window
474 if( win == gpCurrentWindow )
477 printf("\x1b""D"); // Scroll down 1 (free space below)
478 SetCursorPos(giTerminal_Height-2, 0);
479 int prefixlen = strlen(Source) + 3;
480 int avail = giTerminal_Width - prefixlen;
481 int msglen = strlen(Message);
482 printf("[%s] %.*s", Source, avail, Message);
483 while( msglen > avail ) {
487 SetCursorPos(giTerminal_Height-2, prefixlen);
488 printf("%.*s", avail, Message);
496 tWindow *Window_Create(tServer *Server, const char *Name)
498 tWindow *ret, *prev = NULL;
501 // Get the end of the list
502 // TODO: Cache this instead
503 for( ret = gpCurrentWindow; ret; prev = ret, ret = ret->Next )
506 ret = malloc(sizeof(tWindow) + strlen(Name) + 1);
507 ret->Messages = NULL;
508 ret->Server = Server;
509 ret->ActivityLevel = 1;
510 strcpy(ret->Name, Name);
513 ret->Next = prev->Next;
516 else { // Shouldn't happen really
517 ret->Next = gpWindows;
521 // printf("Win %i %s:%s created\n", num, Server->Name, Name);
526 void Redraw_Screen(void)
531 printf("\x1B[2J"); // Clear screen
532 printf("\x1B[0;0H"); // Reset cursor
534 msg = gpCurrentWindow->Messages;
538 // Note: This renders from the bottom up
539 for( y = giTerminal_Height - 1; y -- && msg; msg = msg->Next)
541 int msglen = strlen(msg->Data);
542 int prefix_len = 3 + strlen(msg->Source);
543 int line_avail = giTerminal_Width - prefix_len;
546 y -= msglen / line_avail; // Extra lines (y-- above handles the 1 line case)
548 printf("[%s] ", msg->Source);
550 while(done < msglen) {
551 done += printf("%.*s", line_avail, msg->Data+done);
553 SetCursorPos(y+i, prefix_len);
557 // Bottom line is rendered by the prompt
560 void Cmd_PRIVMSG(tServer *Server, const char *Dest, const char *Src, const char *Message)
562 Message_Append(Server, MSG_TYPE_STANDARD, Dest, Src, Message);
563 //printf("<%s:%s:%s> %s\n", Server->Name, Dest, Src, Message);
568 void ParseServerLine(tServer *Server, char *Line)
573 _SysDebug("[%s] %s", Server->Name, Line);
579 ident = GetValue(Line, &pos); // Ident (user or server)
580 cmd = GetValue(Line, &pos);
583 if( isdigit(cmd[0]) && isdigit(cmd[1]) && isdigit(cmd[2]) )
585 char *user, *message;
587 num = (cmd[0] - '0') * 100;
588 num += (cmd[1] - '0') * 10;
589 num += (cmd[2] - '0') * 1;
591 user = GetValue(Line, &pos);
593 if( Line[pos] == ':' ) {
594 message = Line + pos + 1;
597 message = GetValue(Line, &pos);
603 user = message; // Channel
604 message = Line + pos + 1; // Topic
605 Message_AppendF(Server, MSG_TYPE_SERVER, user, user, "Topic: %s", message);
607 case 333: // Topic set by
608 user = message; // Channel
609 message = GetValue(Line, &pos); // User
610 GetValue(Line, &pos); // Timestamp
611 Message_AppendF(Server, MSG_TYPE_SERVER, user, user, "Set by %s", message);
613 case 353: // /NAMES list
614 // <user> = <channel> :list
615 // '=' was eaten in and set to message
616 user = GetValue(Line, &pos); // Actually channel
617 message = Line + pos + 1; // List
618 Message_AppendF(Server, MSG_TYPE_SERVER, user, user, "Names: %s", message);
620 case 366: // end of /NAMES list
621 // <user> <channel> :msg
623 message = Line + pos + 1;
624 Message_Append(Server, MSG_TYPE_SERVER, user, user, message);
626 case 372: // MOTD Data
627 case 375: // MOTD Start
628 case 376: // MOTD End
631 //printf("[%s] %i %s\n", Server->Name, num, message);
632 Message_Append(Server, MSG_TYPE_SERVER, ident, user, message);
636 else if( strcmp(cmd, "NOTICE") == 0 )
638 char *class, *message;
640 class = GetValue(Line, &pos);
641 _SysDebug("NOTICE class='%s'", class);
643 if( Line[pos] == ':' ) {
644 message = Line + pos + 1;
647 message = GetValue(Line, &pos);
650 //printf("[%s] NOTICE %s: %s\n", Server->Name, ident, message);
651 char *ident_bang = strchr(ident, '!');
655 Message_Append(Server, MSG_TYPE_NOTICE, ident, "", message);
657 else if( strcmp(cmd, "PRIVMSG") == 0 )
659 char *dest, *message;
660 dest = GetValue(Line, &pos);
662 if( Line[pos] == ':' ) {
663 message = Line + pos + 1;
666 message = GetValue(Line, &pos);
669 // TODO: Catch when the privmsg is addressed to the user
671 // Cmd_PRIVMSG(Server, dest, ident, message);
672 char *ident_bang = strchr(ident, '!');
676 Message_Append(Server, MSG_TYPE_STANDARD, ident, dest, message);
678 else if( strcmp(cmd, "JOIN" ) == 0 )
681 channel = Line + pos + 1;
683 Message_AppendF(Server, MSG_TYPE_JOIN, "", channel, "%s has joined", ident);
684 //Window_Create(Server, channel);
686 else if( strcmp(cmd, "PART" ) == 0 )
689 channel = Line + pos + 1;
691 Message_AppendF(Server, MSG_TYPE_PART, "", channel, "%s has left", ident);
692 //Window_Create(Server, channel);
696 Message_AppendF(Server, MSG_TYPE_SERVER, "", "", "Unknown message %s (%s)", cmd, Line+pos);
700 cmd = GetValue(Line, &pos);
702 if( strcmp(cmd, "PING") == 0 ) {
703 writef(Server->FD, "PONG %s\n", gsHostname);
708 Message_AppendF(NULL, MSG_TYPE_UNK, "", "", "Client Command: %s", Line);
714 * \brief Process incoming lines from the server
716 int ProcessIncoming(tServer *Server)
721 // While there is data in the buffer, read it into user memory and
722 // process it line by line
723 // ioctl#8 on a TCP client gets the number of bytes in the recieve buffer
724 // - Used to avoid blocking
726 while( (len = _SysIOCtl(Server->FD, 8, NULL)) > 0 )
730 len = _SysRead(Server->FD, &Server->InBuf[Server->ReadPos], BUFSIZ - Server->ReadPos);
734 Server->InBuf[Server->ReadPos + len] = '\0';
738 while( (newline = strchr(ptr, '\n')) )
741 if( newline[-1] == '\r' ) newline[-1] = '\0';
742 ParseServerLine(Server, ptr);
746 // Handle incomplete lines
747 if( ptr - Server->InBuf < len + Server->ReadPos ) {
748 // Update the read position
749 // InBuf ReadPos ptr ReadPos+len
750 // | old | new used | new unused |
751 Server->ReadPos = len + Server->ReadPos - (ptr - Server->InBuf);
752 // Copy stuff back (moving "new unused" to the start of the buffer)
753 memcpy(Server->InBuf, ptr, Server->ReadPos);
766 * \brief Write a formatted string to a file descriptor
769 int writef(int FD, const char *Format, ...)
774 va_start(args, Format);
775 len = vsnprintf(NULL, 0, Format, args);
780 va_start(args, Format);
781 vsnprintf(buf, len+1, Format, args);
784 return _SysWrite(FD, buf, len);
789 * \brief Initialise a TCP connection to \a AddressString on port \a PortNumber
791 int OpenTCP(const char *AddressString, short PortNumber)
797 addrType = Net_ParseAddress(AddressString, addrBuffer);
798 if( addrType == 0 ) {
799 fprintf(stderr, "Unable to parse '%s' as an IP address\n", AddressString);
800 _SysDebug("Unable to parse '%s' as an IP address\n", AddressString);
804 // Finds the interface for the destination address
805 fd = Net_OpenSocket(addrType, addrBuffer, "tcpc");
807 fprintf(stderr, "Unable to open TCP Client to '%s'\n", AddressString);
808 _SysDebug("Unable to open TCP client to '%s'\n", AddressString);
812 // Set remote port and address
813 // printf("Setting port and remote address\n");
814 _SysIOCtl(fd, 5, &PortNumber);
815 _SysIOCtl(fd, 6, addrBuffer);
818 // printf("Initiating connection\n");
819 if( _SysIOCtl(fd, 7, NULL) == 0 ) {
820 // Shouldn't happen :(
821 fprintf(stderr, "Unable to start connection\n");
830 * \brief Read a space-separated value from a string
832 char *GetValue(char *Src, int *Ofs)
835 char *ret = Src + pos;
838 if( !Src ) return NULL;
840 while( *ret == ' ' ) ret ++;
842 end = strchr(ret, ' ');
847 end = ret + strlen(ret) - 1;
851 while( *ret == ' ' ) end ++;
857 void SetCursorPos(int Row, int Col)
859 printf("\x1B[%i;%iH", Row, Col);
862 static inline int isdigit(int ch)
864 return '0' <= ch && ch < '9';