4 #include <acess/sys.h>
\r
9 #include <readline.h>
\r
12 typedef struct sServer {
\r
13 struct sServer *Next;
\r
15 char InBuf[BUFSIZ+1];
\r
20 typedef struct sMessage
\r
22 struct sMessage *Next;
\r
26 char *Source; // Pointer into `Data`
\r
30 typedef struct sWindow
\r
32 struct sWindow *Next;
\r
34 tServer *Server; //!< Canoical server (can be NULL)
\r
36 char Name[]; // Channel name / remote user
\r
42 MSG_TYPE_SERVER, // Server message
\r
44 MSG_TYPE_NOTICE, // NOTICE command
\r
45 MSG_TYPE_JOIN, // JOIN command
\r
46 MSG_TYPE_PART, // PART command
\r
47 MSG_TYPE_QUIT, // QUIT command
\r
49 MSG_TYPE_STANDARD, // Standard line
\r
50 MSG_TYPE_ACTION, // /me
\r
55 // === PROTOTYPES ===
\r
56 int ParseArguments(int argc, const char *argv[]);
\r
57 int ParseUserCommand(char *String);
\r
59 tServer *Server_Connect(const char *Name, const char *AddressString, short PortNumber);
\r
60 tMessage *Message_AppendF(tServer *Server, int Type, const char *Source, const char *Dest, const char *Message, ...);
\r
61 tMessage *Message_Append(tServer *Server, int Type, const char *Source, const char *Dest, const char *Message);
\r
62 tWindow *Window_Create(tServer *Server, const char *Name);
\r
63 void Redraw_Screen(void);
\r
65 int ProcessIncoming(tServer *Server);
\r
67 int SetCursorPos(int Row, int Col);
\r
68 int writef(int FD, const char *Format, ...);
\r
69 int OpenTCP(const char *AddressString, short PortNumber);
\r
70 char *GetValue(char *Str, int *Ofs);
\r
71 static inline int isdigit(int ch);
\r
74 char *gsUsername = "user";
\r
75 char *gsHostname = "acess";
\r
76 char *gsRealName = "Acess2 IRC Client";
\r
77 char *gsNickname = "acess";
\r
79 tWindow gWindow_Status = {
\r
80 NULL, NULL, NULL, // No next, empty list, no server
\r
81 0, {""} // No activity, empty name (rendered as status)
\r
83 tWindow *gpWindows = &gWindow_Status;
\r
84 tWindow *gpCurrentWindow = &gWindow_Status;
\r
85 int giTerminal_Width = 80;
\r
86 int giTerminal_Height = 25;
\r
89 void ExitHandler(void)
\r
91 printf("\x1B[?1047l");
\r
95 int main(int argc, const char *argv[], const char *envp[])
\r
98 tReadline *readline_info;
\r
100 // Parse Command line
\r
101 if( (tmp = ParseArguments(argc, argv)) ) return tmp;
\r
103 atexit(ExitHandler);
\r
105 giTerminal_Width = _SysIOCtl(1, 5, NULL); // getset_width
\r
106 giTerminal_Height = _SysIOCtl(1, 6, NULL); // getset_height
\r
108 printf("\x1B[?1047h");
\r
109 printf("\x1B[%i;%ir", 0, giTerminal_Height-1);
\r
111 SetCursorPos(giTerminal_Height-1, 0);
\r
112 printf("[(status)] ");
\r
114 // HACK: Static server entry
\r
115 // UCC (University [of Western Australia] Computer Club) IRC Server
\r
116 gWindow_Status.Server = Server_Connect( "UCC", "130.95.13.18", 6667 );
\r
117 // Freenode (#osdev)
\r
118 // gWindow_Status.Server = Server_Connect( "Freenode", "89.16.176.16", 6667 );
\r
119 // gWindow_Status.Server = Server_Connect( "Host", "10.0.2.2", 6667 );
\r
121 // gWindow_Status.Server = Server_Connect( "BitlBee", "192.168.1.39", 6667 );
\r
123 if( !gWindow_Status.Server )
\r
126 SetCursorPos(giTerminal_Height-1, 0);
\r
127 printf("[(status)] ");
\r
128 readline_info = Readline_Init(1);
\r
132 fd_set readfds, errorfds;
\r
137 FD_ZERO(&errorfds);
\r
138 FD_SET(0, &readfds); // stdin
\r
140 // Fill server FDs in fd_set
\r
141 for( srv = gpServers; srv; srv = srv->Next )
\r
143 FD_SET(srv->FD, &readfds);
\r
144 FD_SET(srv->FD, &errorfds);
\r
145 if( srv->FD > maxFD )
\r
149 rv = select(maxFD+1, &readfds, 0, &errorfds, NULL);
\r
150 if( rv == -1 ) break;
\r
152 if(FD_ISSET(0, &readfds))
\r
155 char *cmd = Readline_NonBlock(readline_info);
\r
160 ParseUserCommand(cmd);
\r
164 SetCursorPos(giTerminal_Height-1, 0);
\r
165 printf("\x1B[K"); // Clear line
\r
166 if( gpCurrentWindow->Name[0] )
\r
167 printf("[%s:%s] ", gpCurrentWindow->Server->Name, gpCurrentWindow->Name);
\r
169 printf("[(status)] ");
\r
174 for( srv = gpServers; srv; srv = srv->Next )
\r
176 if(FD_ISSET(srv->FD, &readfds))
\r
178 if( ProcessIncoming(srv) != 0 ) {
\r
184 if(FD_ISSET(srv->FD, &errorfds))
\r
196 for( srv = gpServers; srv; srv = srv->Next )
\r
197 _SysClose(srv->FD);
\r
203 * \todo Actually implement correctly :)
\r
205 int ParseArguments(int argc, const char *argv[])
\r
211 void Cmd_join(char *ArgString)
\r
214 char *channel_name = GetValue(ArgString, &pos);
\r
216 if( gpCurrentWindow->Server )
\r
218 writef(gpCurrentWindow->Server->FD, "JOIN :%s\n", channel_name);
\r
222 void Cmd_quit(char *ArgString)
\r
224 const char *quit_message = ArgString;
\r
225 if( quit_message == NULL || quit_message[0] == '\0' )
\r
226 quit_message = "/quit - Acess2 IRC Client";
\r
228 for( tServer *srv = gpServers; srv; srv = srv->Next )
\r
230 writef(srv->FD, "QUIT :%s\n", quit_message);
\r
236 void Cmd_window(char *ArgString)
\r
239 char *window_id = GetValue(ArgString, &pos);
\r
240 int window_num = atoi(window_id);
\r
242 if( window_num > 0 )
\r
245 window_num --; // Move to base 0
\r
246 // Get `window_num`th window
\r
247 for( win = gpWindows; win && window_num--; win = win->Next );
\r
249 gpCurrentWindow = win;
\r
252 // Otherwise, silently ignore
\r
257 for( tWindow *win = gpWindows; win; win = win->Next, window_num ++ )
\r
259 if( win->Name[0] ) {
\r
260 Message_AppendF(NULL, MSG_TYPE_SERVER, "client", "",
\r
261 "%i: %s/%s", window_num, win->Server->Name, win->Name);
\r
264 Message_AppendF(NULL, MSG_TYPE_SERVER, "client", "",
\r
265 "%i: (status)", window_num);
\r
273 void (*Fcn)(char *ArgString);
\r
275 {"join", Cmd_join},
\r
276 {"quit", Cmd_quit},
\r
277 {"window", Cmd_window},
\r
278 {"win", Cmd_window},
\r
281 const int ciNumCommands = sizeof(caCommands)/sizeof(caCommands[0]);
\r
284 * \brief Handle a line from the prompt
\r
286 int ParseUserCommand(char *String)
\r
288 if( String[0] == '/' )
\r
293 command = GetValue(String, &pos)+1;
\r
295 // TODO: Prefix matches
\r
297 for( int i = 0; i < ciNumCommands; i ++ )
\r
299 if( strcmp(command, caCommands[i].Name) == 0 ) {
\r
304 if( cmdIdx != -1 ) {
\r
305 caCommands[cmdIdx].Fcn(String+pos);
\r
309 Message_AppendF(NULL, MSG_TYPE_SERVER, "client", "", "Unknown command %s", command);
\r
315 // - Only send if server is valid and window name is non-empty
\r
316 if( gpCurrentWindow->Server && gpCurrentWindow->Name[0] )
\r
318 Message_Append(gpCurrentWindow->Server, MSG_TYPE_STANDARD,
\r
319 gsNickname, gpCurrentWindow->Name, String);
\r
320 writef(gpCurrentWindow->Server->FD,
\r
321 "PRIVMSG %s :%s\n", gpCurrentWindow->Name,
\r
331 * \brief Connect to a server
\r
333 tServer *Server_Connect(const char *Name, const char *AddressString, short PortNumber)
\r
337 ret = calloc(1, sizeof(tServer) + strlen(Name) + 1);
\r
339 strcpy(ret->Name, Name);
\r
341 // Connect to the remove server
\r
342 ret->FD = OpenTCP( AddressString, PortNumber );
\r
343 if( ret->FD == -1 ) {
\r
344 fprintf(stderr, "%s: Unable to create socket\n", Name);
\r
348 // Append to open list
\r
349 ret->Next = gpServers;
\r
352 // Read some initial data
\r
353 Message_Append(NULL, MSG_TYPE_SERVER, Name, "", "Connection opened");
\r
354 ProcessIncoming(ret);
\r
357 writef(ret->FD, "USER %s %s %s : %s\n", gsUsername, gsHostname, AddressString, gsRealName);
\r
358 writef(ret->FD, "NICK %s\n", gsNickname);
\r
359 Message_Append(NULL, MSG_TYPE_SERVER, Name, "", "Identified");
\r
360 //printf("%s: Identified\n", Name);
\r
365 tMessage *Message_AppendF(tServer *Server, int Type, const char *Source, const char *Dest, const char *Message, ...)
\r
369 va_start(args, Message);
\r
370 len = vsnprintf(NULL, 0, Message, args);
\r
373 vsnprintf(buf, len+1, Message, args);
\r
374 return Message_Append(Server, Type, Source, Dest, buf);
\r
378 tMessage *Message_Append(tServer *Server, int Type, const char *Source, const char *Dest, const char *Message)
\r
381 tWindow *win = NULL;
\r
382 int msgLen = strlen(Message);
\r
384 // NULL servers are internal messages
\r
385 if( Server == NULL || Source[0] == '\0' )
\r
387 win = &gWindow_Status;
\r
389 // Determine if it's a channel or PM message
\r
390 else if( Dest[0] == '#' || Dest[0] == '&' ) // TODO: Better determining here
\r
392 for(win = gpWindows; win; win = win->Next)
\r
394 if( win->Server == Server && strcmp(win->Name, Dest) == 0 )
\r
400 win = Window_Create(Server, Dest);
\r
404 else if( strcmp(Dest, Server->Nick) != 0 )
\r
406 // Umm... message for someone who isn't us?
\r
407 win = &gWindow_Status; // Stick it in the status window, just in case
\r
411 else if( strchr(Source, '.') ) // TODO: And again, less hack please
\r
414 for(win = gpWindows; win; win = win->Next)
\r
416 if( win->Server == Server && strcmp(win->Name, Source) == 0 )
\r
423 win = &gWindow_Status;
\r
430 for(win = gpWindows; win; win = win->Next)
\r
432 if( win->Server == Server && strcmp(win->Name, Source) == 0 )
\r
438 win = Window_Create(Server, Dest);
\r
442 ret = malloc( sizeof(tMessage) + msgLen + 1 + strlen(Source) + 1 );
\r
443 ret->Source = ret->Data + msgLen + 1;
\r
444 strcpy(ret->Source, Source);
\r
445 strcpy(ret->Data, Message);
\r
447 ret->Server = Server;
\r
449 // TODO: Append to window message list
\r
450 ret->Next = win->Messages;
\r
451 win->Messages = ret;
\r
453 //TODO: Set location
\r
456 int pos = SetCursorPos(giTerminal_Height-2, 0);
\r
457 if( win == gpCurrentWindow ) {
\r
458 int prefixlen = strlen(Source) + 3;
\r
459 int avail = giTerminal_Width - prefixlen;
\r
460 int msglen = strlen(Message);
\r
461 printf("\x1B[T"); // Scroll down 1 (free space below)
\r
462 printf("[%s] %.*s\n", Source, avail, Message);
\r
463 while( msglen > avail ) {
\r
467 SetCursorPos(giTerminal_Height-2, prefixlen);
\r
468 printf("%.*s\n", avail, Message);
\r
471 SetCursorPos(-1, pos);
\r
477 tWindow *Window_Create(tServer *Server, const char *Name)
\r
479 tWindow *ret, *prev = NULL;
\r
482 // Get the end of the list
\r
483 // TODO: Cache this instead
\r
484 for( ret = gpCurrentWindow; ret; prev = ret, ret = ret->Next )
\r
487 ret = malloc(sizeof(tWindow) + strlen(Name) + 1);
\r
488 ret->Messages = NULL;
\r
489 ret->Server = Server;
\r
490 ret->ActivityLevel = 1;
\r
491 strcpy(ret->Name, Name);
\r
494 ret->Next = prev->Next;
\r
497 else { // Shouldn't happen really
\r
498 ret->Next = gpWindows;
\r
502 // printf("Win %i %s:%s created\n", num, Server->Name, Name);
\r
507 void Redraw_Screen(void)
\r
512 printf("\x1B[2J"); // Clear screen
\r
513 printf("\x1B[0;0H"); // Reset cursor
\r
515 msg = gpCurrentWindow->Messages;
\r
517 // TODO: Title bar?
\r
519 // Note: This renders from the bottom up
\r
520 for( y = giTerminal_Height - 1; y -- && msg; msg = msg->Next)
\r
522 int msglen = strlen(msg->Data);
\r
523 int prefix_len = 3 + strlen(msg->Source);
\r
524 int line_avail = giTerminal_Width - prefix_len;
\r
525 int i = 0, done = 0;
\r
527 y -= msglen / line_avail; // Extra lines (y-- above handles the 1 line case)
\r
528 SetCursorPos(y, 0);
\r
529 printf("[%s] ", msg->Source);
\r
531 while(done < msglen) {
\r
532 done += printf("%.*s", line_avail, msg->Data+done);
\r
534 SetCursorPos(y+i, prefix_len);
\r
538 // Bottom line is rendered by the prompt
\r
541 void Cmd_PRIVMSG(tServer *Server, const char *Dest, const char *Src, const char *Message)
\r
543 Message_Append(Server, MSG_TYPE_STANDARD, Dest, Src, Message);
\r
544 //printf("<%s:%s:%s> %s\n", Server->Name, Dest, Src, Message);
\r
549 void ParseServerLine(tServer *Server, char *Line)
\r
554 _SysDebug("[%s] %s", Server->Name, Line);
\r
560 ident = GetValue(Line, &pos); // Ident (user or server)
\r
561 cmd = GetValue(Line, &pos);
\r
564 if( isdigit(cmd[0]) && isdigit(cmd[1]) && isdigit(cmd[2]) )
\r
566 char *user, *message;
\r
568 num = (cmd[0] - '0') * 100;
\r
569 num += (cmd[1] - '0') * 10;
\r
570 num += (cmd[2] - '0') * 1;
\r
572 user = GetValue(Line, &pos);
\r
574 if( Line[pos] == ':' ) {
\r
575 message = Line + pos + 1;
\r
578 message = GetValue(Line, &pos);
\r
584 user = message; // Channel
\r
585 message = Line + pos + 1; // Topic
\r
586 Message_AppendF(Server, MSG_TYPE_SERVER, user, user, "Topic: %s", message);
\r
588 case 333: // Topic set by
\r
589 user = message; // Channel
\r
590 message = GetValue(Line, &pos); // User
\r
591 GetValue(Line, &pos); // Timestamp
\r
592 Message_AppendF(Server, MSG_TYPE_SERVER, user, user, "Set by %s", message);
\r
594 case 353: // /NAMES list
\r
595 // <user> = <channel> :list
\r
596 // '=' was eaten in and set to message
\r
597 user = GetValue(Line, &pos); // Actually channel
\r
598 message = Line + pos + 1; // List
\r
599 Message_AppendF(Server, MSG_TYPE_SERVER, user, user, "Names: %s", message);
\r
601 case 366: // end of /NAMES list
\r
602 // <user> <channel> :msg
\r
604 message = Line + pos + 1;
\r
605 Message_Append(Server, MSG_TYPE_SERVER, user, user, message);
\r
607 case 372: // MOTD Data
\r
608 case 375: // MOTD Start
\r
609 case 376: // MOTD End
\r
612 //printf("[%s] %i %s\n", Server->Name, num, message);
\r
613 Message_Append(Server, MSG_TYPE_SERVER, ident, user, message);
\r
617 else if( strcmp(cmd, "NOTICE") == 0 )
\r
619 char *class, *message;
\r
621 class = GetValue(Line, &pos);
\r
622 _SysDebug("NOTICE class='%s'", class);
\r
624 if( Line[pos] == ':' ) {
\r
625 message = Line + pos + 1;
\r
628 message = GetValue(Line, &pos);
\r
631 //printf("[%s] NOTICE %s: %s\n", Server->Name, ident, message);
\r
632 char *ident_bang = strchr(ident, '!');
\r
634 *ident_bang = '\0';
\r
636 Message_Append(Server, MSG_TYPE_NOTICE, ident, "", message);
\r
638 else if( strcmp(cmd, "PRIVMSG") == 0 )
\r
640 char *dest, *message;
\r
641 dest = GetValue(Line, &pos);
\r
643 if( Line[pos] == ':' ) {
\r
644 message = Line + pos + 1;
\r
647 message = GetValue(Line, &pos);
\r
650 // TODO: Catch when the privmsg is addressed to the user
\r
652 // Cmd_PRIVMSG(Server, dest, ident, message);
\r
653 char *ident_bang = strchr(ident, '!');
\r
655 *ident_bang = '\0';
\r
657 Message_Append(Server, MSG_TYPE_STANDARD, ident, dest, message);
\r
659 else if( strcmp(cmd, "JOIN" ) == 0 )
\r
662 channel = Line + pos + 1;
\r
663 Window_Create(Server, channel);
\r
667 Message_AppendF(Server, MSG_TYPE_SERVER, "", "", "Unknown message %s (%s)\n", cmd, Line+pos);
\r
671 cmd = GetValue(Line, &pos);
\r
673 if( strcmp(cmd, "PING") == 0 ) {
\r
674 writef(Server->FD, "PONG %s\n", gsHostname);
\r
678 // Command to client
\r
679 Message_AppendF(NULL, MSG_TYPE_UNK, "", "", "Client Command: %s", Line);
\r
685 * \brief Process incoming lines from the server
\r
687 int ProcessIncoming(tServer *Server)
\r
689 char *ptr, *newline;
\r
692 // While there is data in the buffer, read it into user memory and
\r
693 // process it line by line
\r
694 // ioctl#8 on a TCP client gets the number of bytes in the recieve buffer
\r
695 // - Used to avoid blocking
\r
697 while( (len = _SysIOCtl(Server->FD, 8, NULL)) > 0 )
\r
701 len = _SysRead(Server->FD, &Server->InBuf[Server->ReadPos], BUFSIZ - Server->ReadPos);
\r
705 Server->InBuf[Server->ReadPos + len] = '\0';
\r
707 // Break into lines
\r
708 ptr = Server->InBuf;
\r
709 while( (newline = strchr(ptr, '\n')) )
\r
712 if( newline[-1] == '\r' ) newline[-1] = '\0';
\r
713 ParseServerLine(Server, ptr);
\r
717 // Handle incomplete lines
\r
718 if( ptr - Server->InBuf < len + Server->ReadPos ) {
\r
719 // Update the read position
\r
720 // InBuf ReadPos ptr ReadPos+len
\r
721 // | old | new used | new unused |
\r
722 Server->ReadPos = len + Server->ReadPos - (ptr - Server->InBuf);
\r
723 // Copy stuff back (moving "new unused" to the start of the buffer)
\r
724 memcpy(Server->InBuf, ptr, Server->ReadPos);
\r
727 Server->ReadPos = 0;
\r
737 * \brief Write a formatted string to a file descriptor
\r
740 int writef(int FD, const char *Format, ...)
\r
745 va_start(args, Format);
\r
746 len = vsnprintf(NULL, 0, Format, args);
\r
751 va_start(args, Format);
\r
752 vsnprintf(buf, len+1, Format, args);
\r
755 return _SysWrite(FD, buf, len);
\r
760 * \brief Initialise a TCP connection to \a AddressString on port \a PortNumber
\r
762 int OpenTCP(const char *AddressString, short PortNumber)
\r
765 char addrBuffer[8];
\r
767 // Parse IP Address
\r
768 addrType = Net_ParseAddress(AddressString, addrBuffer);
\r
769 if( addrType == 0 ) {
\r
770 fprintf(stderr, "Unable to parse '%s' as an IP address\n", AddressString);
\r
771 _SysDebug("Unable to parse '%s' as an IP address\n", AddressString);
\r
775 // Finds the interface for the destination address
\r
776 fd = Net_OpenSocket(addrType, addrBuffer, "tcpc");
\r
778 fprintf(stderr, "Unable to open TCP Client to '%s'\n", AddressString);
\r
779 _SysDebug("Unable to open TCP client to '%s'\n", AddressString);
\r
783 // Set remote port and address
\r
784 // printf("Setting port and remote address\n");
\r
785 _SysIOCtl(fd, 5, &PortNumber);
\r
786 _SysIOCtl(fd, 6, addrBuffer);
\r
789 // printf("Initiating connection\n");
\r
790 if( _SysIOCtl(fd, 7, NULL) == 0 ) {
\r
791 // Shouldn't happen :(
\r
792 fprintf(stderr, "Unable to start connection\n");
\r
796 // Return descriptor
\r
801 * \brief Read a space-separated value from a string
\r
803 char *GetValue(char *Src, int *Ofs)
\r
806 char *ret = Src + pos;
\r
809 if( !Src ) return NULL;
\r
811 while( *ret == ' ' ) ret ++;
\r
813 end = strchr(ret, ' ');
\r
818 end = ret + strlen(ret) - 1;
\r
822 while( *ret == ' ' ) end ++;
\r
828 int SetCursorPos(int Row, int Col)
\r
832 Row = Col / giTerminal_Width;
\r
833 Col = Col % giTerminal_Width;
\r
835 rv = _SysIOCtl(1, 9, NULL); // Ugh, constants
\r
836 printf("\x1B[%i;%iH", Col, Row);
\r
840 static inline int isdigit(int ch)
\r
842 return '0' <= ch && ch < '9';
\r