8336879a4374131dddcc51dc4c52f80b8940ac99
[tpg/acess2.git] / Usermode / Applications / irc_src / main.c
1 /*\r
2  * Acess2 IRC Client\r
3  */\r
4 #include <acess/sys.h>\r
5 #include <stdlib.h>\r
6 #include <stdio.h>\r
7 #include <string.h>\r
8 #include <net.h>\r
9 #include <readline.h>\r
10 #include <acess/devices/pty.h>\r
11 \r
12 // === TYPES ===\r
13 typedef struct sServer {\r
14         struct sServer  *Next;\r
15          int    FD;\r
16         char    InBuf[BUFSIZ+1];\r
17          int    ReadPos;\r
18         char    Name[];\r
19 } tServer;\r
20 \r
21 typedef struct sMessage\r
22 {\r
23         struct sMessage *Next;\r
24         time_t  Timestamp;\r
25         tServer *Server;\r
26          int    Type;\r
27         char    *Source;        // Pointer into `Data`\r
28         char    Data[];\r
29 }       tMessage;\r
30 \r
31 typedef struct sWindow\r
32 {\r
33         struct sWindow  *Next;\r
34         tMessage        *Messages;\r
35         tServer *Server;        //!< Canoical server (can be NULL)\r
36          int    ActivityLevel;\r
37         char    Name[]; // Channel name / remote user\r
38 }       tWindow;\r
39 \r
40 enum eMessageTypes\r
41 {\r
42         MSG_TYPE_NULL,\r
43         MSG_TYPE_SERVER,        // Server message\r
44         \r
45         MSG_TYPE_NOTICE,        // NOTICE command\r
46         MSG_TYPE_JOIN,  // JOIN command\r
47         MSG_TYPE_PART,  // PART command\r
48         MSG_TYPE_QUIT,  // QUIT command\r
49         \r
50         MSG_TYPE_STANDARD,      // Standard line\r
51         MSG_TYPE_ACTION,        // /me\r
52         \r
53         MSG_TYPE_UNK\r
54 };\r
55 \r
56 // === PROTOTYPES ===\r
57  int    ParseArguments(int argc, const char *argv[]);\r
58  int    ParseUserCommand(char *String);\r
59 // --- \r
60 tServer *Server_Connect(const char *Name, const char *AddressString, short PortNumber);\r
61 tMessage        *Message_AppendF(tServer *Server, int Type, const char *Source, const char *Dest, const char *Message, ...);\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
64 void    Redraw_Screen(void);\r
65 \r
66  int    ProcessIncoming(tServer *Server);\r
67 // --- Helpers\r
68 void    SetCursorPos(int Row, int Col);\r
69  int    writef(int FD, const char *Format, ...);\r
70  int    OpenTCP(const char *AddressString, short PortNumber);\r
71 char    *GetValue(char *Str, int *Ofs);\r
72 static inline int       isdigit(int ch);\r
73 \r
74 // === GLOBALS ===\r
75 char    *gsUsername = "user";\r
76 char    *gsHostname = "acess";\r
77 char    *gsRealName = "Acess2 IRC Client";\r
78 char    *gsNickname = "acess";\r
79 tServer *gpServers;\r
80 tWindow gWindow_Status = {\r
81         NULL, NULL, NULL,       // No next, empty list, no server\r
82         0, {""} // No activity, empty name (rendered as status)\r
83 };\r
84 tWindow *gpWindows = &gWindow_Status;\r
85 tWindow *gpCurrentWindow = &gWindow_Status;\r
86  int    giTerminal_Width = 80;\r
87  int    giTerminal_Height = 25;\r
88 \r
89 // ==== CODE ====\r
90 void ExitHandler(void)\r
91 {\r
92         printf("\x1B[?1047l");\r
93         printf("Quit\n");\r
94 }\r
95 \r
96 int main(int argc, const char *argv[], const char *envp[])\r
97 {\r
98          int    tmp;\r
99         tReadline       *readline_info;\r
100         \r
101         // Parse Command line\r
102         if( (tmp = ParseArguments(argc, argv)) )        return tmp;\r
103         \r
104         atexit(ExitHandler);\r
105         \r
106         {\r
107                 struct ptydims  dims;\r
108                 if( _SysIOCtl(1, PTY_IOCTL_GETDIMS, &dims) ) {\r
109                         perror("Can't get terminal dimensions");\r
110                         return 1;\r
111                 }\r
112                 \r
113                 giTerminal_Width = dims.W;\r
114                 giTerminal_Height = dims.H;\r
115         }\r
116         \r
117         printf("\x1B[?1047h");\r
118         printf("\x1B[%i;%ir", 0, giTerminal_Height-1);\r
119         \r
120         SetCursorPos(giTerminal_Height-1, 0);\r
121         printf("[(status)] ");\r
122         \r
123         // HACK: Static server entry\r
124         // UCC (University [of Western Australia] Computer Club) IRC Server\r
125         gWindow_Status.Server = Server_Connect( "UCC", "130.95.13.18", 6667 );\r
126         // Freenode (#osdev)\r
127 //      gWindow_Status.Server = Server_Connect( "Freenode", "89.16.176.16", 6667 );\r
128 //      gWindow_Status.Server = Server_Connect( "Host", "10.0.2.2", 6667 );\r
129         // Local server\r
130 //      gWindow_Status.Server = Server_Connect( "BitlBee", "192.168.1.39", 6667 );\r
131         \r
132         if( !gWindow_Status.Server )\r
133                 return -1;\r
134         \r
135         SetCursorPos(giTerminal_Height-1, 0);\r
136         printf("[(status)] ");\r
137         fflush(stdout);\r
138         readline_info = Readline_Init(1);\r
139         \r
140         for( ;; )\r
141         {\r
142                 fd_set  readfds, errorfds;\r
143                  int    rv, maxFD = 0;\r
144                 tServer *srv;\r
145                 \r
146                 FD_ZERO(&readfds);\r
147                 FD_ZERO(&errorfds);\r
148                 FD_SET(0, &readfds);    // stdin\r
149                 \r
150                 // Fill server FDs in fd_set\r
151                 for( srv = gpServers; srv; srv = srv->Next )\r
152                 {\r
153                         FD_SET(srv->FD, &readfds);\r
154                         FD_SET(srv->FD, &errorfds);\r
155                         if( srv->FD > maxFD )\r
156                                 maxFD = srv->FD;\r
157                 }\r
158                 \r
159                 rv = _SysSelect(maxFD+1, &readfds, 0, &errorfds, NULL, 0);\r
160                 if( rv == -1 )  break;\r
161                 \r
162                 if(FD_ISSET(0, &readfds))\r
163                 {\r
164                         // User input\r
165                         char    *cmd = Readline_NonBlock(readline_info);\r
166                         if( cmd )\r
167                         {\r
168                                 if( cmd[0] )\r
169                                 {\r
170                                         ParseUserCommand(cmd);\r
171                                 }\r
172                                 free(cmd);\r
173                                 // Prompt\r
174                                 SetCursorPos(giTerminal_Height-1, 0);\r
175                                 printf("\x1B[K");       // Clear line\r
176                                 if( gpCurrentWindow->Name[0] )\r
177                                         printf("[%s:%s] ", gpCurrentWindow->Server->Name, gpCurrentWindow->Name);\r
178                                 else\r
179                                         printf("[(status)] ");\r
180                                 fflush(stdout);\r
181                         }\r
182                 }\r
183                 \r
184                 // Server response\r
185                 for( srv = gpServers; srv; srv = srv->Next )\r
186                 {\r
187                         if(FD_ISSET(srv->FD, &readfds))\r
188                         {\r
189                                 if( ProcessIncoming(srv) != 0 ) {\r
190                                         // Oops, error\r
191                                         break;\r
192                                 }\r
193                         }\r
194                         \r
195                         if(FD_ISSET(srv->FD, &errorfds))\r
196                         {\r
197                                 break;\r
198                         }\r
199                 }\r
200                 \r
201                 // Oops, an error\r
202                 if( srv )       break;\r
203         }\r
204         \r
205         {\r
206                 tServer *srv;\r
207                 for( srv = gpServers; srv; srv = srv->Next )\r
208                         _SysClose(srv->FD);\r
209         }\r
210         return 0;\r
211 }\r
212 \r
213 /**\r
214  * \todo Actually implement correctly :)\r
215  */\r
216 int ParseArguments(int argc, const char *argv[])\r
217 {\r
218         return 0;\r
219 }\r
220 \r
221 \r
222 void Cmd_join(char *ArgString)\r
223 {\r
224          int    pos=0;\r
225         char    *channel_name = GetValue(ArgString, &pos);\r
226         \r
227         if( gpCurrentWindow->Server )\r
228         {\r
229                 writef(gpCurrentWindow->Server->FD, "JOIN :%s\n", channel_name);\r
230         }\r
231 }\r
232 \r
233 void Cmd_quit(char *ArgString)\r
234 {\r
235         const char *quit_message = ArgString;\r
236         if( quit_message == NULL || quit_message[0] == '\0' )\r
237                 quit_message = "/quit - Acess2 IRC Client";\r
238         \r
239         for( tServer *srv = gpServers; srv; srv = srv->Next )\r
240         {\r
241                 writef(srv->FD, "QUIT :%s\n", quit_message);\r
242         }\r
243         \r
244         exit(0);\r
245 }\r
246 \r
247 void Cmd_window(char *ArgString)\r
248 {\r
249          int    pos = 0;\r
250         char    *window_id = GetValue(ArgString, &pos);\r
251          int    window_num = atoi(window_id);\r
252         \r
253         if( window_num > 0 )\r
254         {\r
255                 tWindow *win;\r
256                 window_num --;  // Move to base 0\r
257                 // Get `window_num`th window\r
258                 for( win = gpWindows; win && window_num--; win = win->Next );\r
259                 if( win ) {\r
260                         gpCurrentWindow = win;\r
261                         Redraw_Screen();\r
262                 }\r
263                 // Otherwise, silently ignore\r
264         }\r
265         else\r
266         {\r
267                 window_num = 1;\r
268                 for( tWindow *win = gpWindows; win; win = win->Next, window_num ++ )\r
269                 {\r
270                         if( win->Name[0] ) {\r
271                                 Message_AppendF(NULL, MSG_TYPE_SERVER, "client", "",\r
272                                         "%i: %s/%s", window_num, win->Server->Name, win->Name);\r
273                         }\r
274                         else {\r
275                                 Message_AppendF(NULL, MSG_TYPE_SERVER, "client", "",\r
276                                         "%i: (status)", window_num);\r
277                         }\r
278                 }\r
279         }\r
280 }\r
281 \r
282 const struct {\r
283         const char *Name;\r
284         void    (*Fcn)(char *ArgString);\r
285 } caCommands[] = {\r
286         {"join", Cmd_join},\r
287         {"quit", Cmd_quit},\r
288         {"window", Cmd_window},\r
289         {"win",    Cmd_window},\r
290         {"w",      Cmd_window},\r
291 };\r
292 const int ciNumCommands = sizeof(caCommands)/sizeof(caCommands[0]);\r
293 \r
294 /**\r
295  * \brief Handle a line from the prompt\r
296  */\r
297 int ParseUserCommand(char *String)\r
298 {\r
299         if( String[0] == '/' )\r
300         {\r
301                 char    *command;\r
302                  int    pos = 0;\r
303                 \r
304                 command = GetValue(String, &pos)+1;\r
305 \r
306                 // TODO: Prefix matches\r
307                  int    cmdIdx = -1;\r
308                 for( int i = 0; i < ciNumCommands; i ++ )\r
309                 {\r
310                         if( strcmp(command, caCommands[i].Name) == 0 ) {\r
311                                 cmdIdx = i;\r
312                                 break;\r
313                         }\r
314                 }\r
315                 if( cmdIdx != -1 ) {\r
316                         caCommands[cmdIdx].Fcn(String+pos);\r
317                 }\r
318                 else\r
319                 {\r
320                         Message_AppendF(NULL, MSG_TYPE_SERVER, "client", "", "Unknown command %s", command);\r
321                 }\r
322         }\r
323         else\r
324         {\r
325                 // Message\r
326                 // - Only send if server is valid and window name is non-empty\r
327                 if( gpCurrentWindow->Server && gpCurrentWindow->Name[0] )\r
328                 {\r
329                         Message_Append(gpCurrentWindow->Server, MSG_TYPE_STANDARD,\r
330                                 gsNickname, gpCurrentWindow->Name, String);\r
331                         writef(gpCurrentWindow->Server->FD,\r
332                                 "PRIVMSG %s :%s\n", gpCurrentWindow->Name,\r
333                                 String\r
334                                 );\r
335                 }\r
336         }\r
337         \r
338         return 0;\r
339 }\r
340 \r
341 /**\r
342  * \brief Connect to a server\r
343  */\r
344 tServer *Server_Connect(const char *Name, const char *AddressString, short PortNumber)\r
345 {\r
346         tServer *ret;\r
347         \r
348         ret = calloc(1, sizeof(tServer) + strlen(Name) + 1);\r
349         \r
350         strcpy(ret->Name, Name);\r
351         \r
352         // Connect to the remove server\r
353         ret->FD = OpenTCP( AddressString, PortNumber );\r
354         if( ret->FD == -1 ) {\r
355                 fprintf(stderr, "%s: Unable to create socket\n", Name);\r
356                 return NULL;\r
357         }\r
358         \r
359         // Append to open list\r
360         ret->Next = gpServers;\r
361         gpServers = ret;\r
362         \r
363         // Read some initial data\r
364         Message_Append(NULL, MSG_TYPE_SERVER, Name, "", "Connection opened");\r
365         ProcessIncoming(ret);\r
366         \r
367         // Identify\r
368         writef(ret->FD, "USER %s %s %s : %s\n", gsUsername, gsHostname, AddressString, gsRealName);\r
369         writef(ret->FD, "NICK %s\n", gsNickname);\r
370         Message_Append(NULL, MSG_TYPE_SERVER, Name, "", "Identified");\r
371         //printf("%s: Identified\n", Name);\r
372         \r
373         return ret;\r
374 }\r
375 \r
376 tMessage *Message_AppendF(tServer *Server, int Type, const char *Source, const char *Dest, const char *Message, ...)\r
377 {\r
378         va_list args;\r
379          int    len;\r
380         va_start(args, Message);\r
381         len = vsnprintf(NULL, 0, Message, args);\r
382         {\r
383                 char    buf[len+1];\r
384                 vsnprintf(buf, len+1, Message, args);\r
385                 return Message_Append(Server, Type, Source, Dest, buf);\r
386         }\r
387 }\r
388 \r
389 tMessage *Message_Append(tServer *Server, int Type, const char *Source, const char *Dest, const char *Message)\r
390 {\r
391         tWindow *win = NULL;\r
392          int    msgLen = strlen(Message);\r
393         \r
394         // Server==NULL indicates an internal message\r
395         if( Server == NULL || Source[0] == '\0' )\r
396         {\r
397                 win = &gWindow_Status;\r
398         }\r
399         // Determine if it's a channel or PM\r
400         else if( Dest[0] == '#' || Dest[0] == '&' )     // TODO: Better determining here\r
401         {\r
402                 for(win = gpWindows; win; win = win->Next)\r
403                 {\r
404                         if( win->Server == Server && strcmp(win->Name, Dest) == 0 )\r
405                         {\r
406                                 break;\r
407                         }\r
408                 }\r
409                 if( !win ) {\r
410                         win = Window_Create(Server, Dest);\r
411                 }\r
412         }\r
413         #if 0\r
414         else if( strcmp(Dest, Server->Nick) != 0 )\r
415         {\r
416                 // Umm... message for someone who isn't us?\r
417                 win = &gWindow_Status;  // Stick it in the status window, just in case\r
418         }\r
419         #endif\r
420         // Server message?\r
421         else if( strchr(Source, '.') )  // TODO: And again, less hack please\r
422         {\r
423                 #if 1\r
424                 for(win = gpWindows; win; win = win->Next)\r
425                 {\r
426                         if( win->Server == Server && strcmp(win->Name, Source) == 0 )\r
427                         {\r
428                                 break;\r
429                         }\r
430                 }\r
431                 #endif\r
432                 if( !win ) {\r
433                         win = &gWindow_Status;\r
434                 }\r
435                 \r
436         }\r
437         // Private message\r
438         else\r
439         {\r
440                 for(win = gpWindows; win; win = win->Next)\r
441                 {\r
442                         if( win->Server == Server && strcmp(win->Name, Source) == 0 )\r
443                         {\r
444                                 break;\r
445                         }\r
446                 }\r
447                 if( !win ) {\r
448                         win = Window_Create(Server, Dest);\r
449                 }\r
450         }\r
451 \r
452         // Create message cache \r
453         _SysDebug("Win (%s) msg: <%s> %s", win->Name, Source, Message);\r
454         tMessage        *ret;\r
455         ret = malloc( sizeof(tMessage) + msgLen + 1 + strlen(Source) + 1 );\r
456         ret->Source = ret->Data + msgLen + 1;\r
457         strcpy(ret->Source, Source);\r
458         strcpy(ret->Data, Message);\r
459         ret->Type = Type;\r
460         ret->Server = Server;\r
461         \r
462         // Append to window message list\r
463         ret->Next = win->Messages;\r
464         win->Messages = ret;\r
465         \r
466         // Print now if current window\r
467         if( win == gpCurrentWindow )\r
468         {\r
469                 printf("\x1b[s");\r
470                 SetCursorPos(giTerminal_Height-2, 0);\r
471                  int    prefixlen = strlen(Source) + 3;\r
472                  int    avail = giTerminal_Width - prefixlen;\r
473                  int    msglen = strlen(Message);\r
474                 printf("\x1B[T");       // Scroll down 1 (free space below)\r
475                 printf("[%s] %.*s\n", Source, avail, Message);\r
476                 while( msglen > avail ) {\r
477                         msglen -= avail;\r
478                         Message += avail;\r
479                         printf("\x1B[T");\r
480                         SetCursorPos(giTerminal_Height-2, prefixlen);\r
481                         printf("%.*s\n", avail, Message);\r
482                 }\r
483                 printf("\x1b[u");\r
484         }\r
485         \r
486         return ret;\r
487 }\r
488 \r
489 tWindow *Window_Create(tServer *Server, const char *Name)\r
490 {\r
491         tWindow *ret, *prev = NULL;\r
492          int    num = 1;\r
493         \r
494         // Get the end of the list\r
495         // TODO: Cache this instead\r
496         for( ret = gpCurrentWindow; ret; prev = ret, ret = ret->Next )\r
497                 num ++;\r
498         \r
499         ret = malloc(sizeof(tWindow) + strlen(Name) + 1);\r
500         ret->Messages = NULL;\r
501         ret->Server = Server;\r
502         ret->ActivityLevel = 1;\r
503         strcpy(ret->Name, Name);\r
504         \r
505         if( prev ) {\r
506                 ret->Next = prev->Next;\r
507                 prev->Next = ret;\r
508         }\r
509         else {  // Shouldn't happen really\r
510                 ret->Next = gpWindows;\r
511                 gpWindows = ret;\r
512         }\r
513         \r
514 //      printf("Win %i %s:%s created\n", num, Server->Name, Name);\r
515         \r
516         return ret;\r
517 }\r
518 \r
519 void Redraw_Screen(void)\r
520 {\r
521          int    y = 0;\r
522         tMessage        *msg;\r
523 \r
524         printf("\x1B[2J");      // Clear screen\r
525         printf("\x1B[0;0H");    // Reset cursor\r
526 \r
527         msg = gpCurrentWindow->Messages;\r
528         \r
529         // TODO: Title bar?\r
530 \r
531         // Note: This renders from the bottom up\r
532         for( y = giTerminal_Height - 1; y -- && msg; msg = msg->Next)\r
533         {\r
534                  int    msglen = strlen(msg->Data);\r
535                  int    prefix_len = 3 + strlen(msg->Source);\r
536                  int    line_avail = giTerminal_Width - prefix_len;\r
537                  int    i = 0, done = 0;\r
538                 \r
539                 y -= msglen / line_avail;       // Extra lines (y-- above handles the 1 line case)\r
540                 SetCursorPos(y, 0);\r
541                 printf("[%s] ", msg->Source);\r
542                 \r
543                 while(done < msglen) {\r
544                         done += printf("%.*s", line_avail, msg->Data+done);\r
545                         i ++;\r
546                         SetCursorPos(y+i, prefix_len);\r
547                 }\r
548         }\r
549 \r
550         // Bottom line is rendered by the prompt\r
551 }\r
552 \r
553 void Cmd_PRIVMSG(tServer *Server, const char *Dest, const char *Src, const char *Message)\r
554 {\r
555         Message_Append(Server, MSG_TYPE_STANDARD, Dest, Src, Message);\r
556         //printf("<%s:%s:%s> %s\n", Server->Name, Dest, Src, Message);\r
557 }\r
558 \r
559 /**\r
560  */\r
561 void ParseServerLine(tServer *Server, char *Line)\r
562 {\r
563          int    pos = 0;\r
564         char    *ident, *cmd;\r
565 \r
566 //      _SysDebug("[%s] %s", Server->Name, Line);       \r
567         \r
568         // Message?\r
569         if( *Line == ':' )\r
570         {\r
571                 pos ++;\r
572                 ident = GetValue(Line, &pos);   // Ident (user or server)\r
573                 cmd = GetValue(Line, &pos);\r
574                 \r
575                 // Numeric command\r
576                 if( isdigit(cmd[0]) && isdigit(cmd[1]) && isdigit(cmd[2]) )\r
577                 {\r
578                         char    *user, *message;\r
579                          int    num;\r
580                         num  = (cmd[0] - '0') * 100;\r
581                         num += (cmd[1] - '0') * 10;\r
582                         num += (cmd[2] - '0') * 1;\r
583                         \r
584                         user = GetValue(Line, &pos);\r
585                         \r
586                         if( Line[pos] == ':' ) {\r
587                                 message = Line + pos + 1;\r
588                         }\r
589                         else {\r
590                                 message = GetValue(Line, &pos);\r
591                         }\r
592                         \r
593                         switch(num)\r
594                         {\r
595                         case 332:       // Topic\r
596                                 user = message; // Channel\r
597                                 message = Line + pos + 1;       // Topic\r
598                                 Message_AppendF(Server, MSG_TYPE_SERVER, user, user, "Topic: %s", message);\r
599                                 break;\r
600                         case 333:       // Topic set by\r
601                                 user = message; // Channel\r
602                                 message = GetValue(Line, &pos); // User\r
603                                 GetValue(Line, &pos);   // Timestamp\r
604                                 Message_AppendF(Server, MSG_TYPE_SERVER, user, user, "Set by %s", message);\r
605                                 break;\r
606                         case 353:       // /NAMES list\r
607                                 // <user> = <channel> :list\r
608                                 // '=' was eaten in and set to message\r
609                                 user = GetValue(Line, &pos);    // Actually channel\r
610                                 message = Line + pos + 1;       // List\r
611                                 Message_AppendF(Server, MSG_TYPE_SERVER, user, user, "Names: %s", message);\r
612                                 break;\r
613                         case 366:       // end of /NAMES list\r
614                                 // <user> <channel> :msg\r
615                                 user = message;\r
616                                 message = Line + pos + 1;\r
617                                 Message_Append(Server, MSG_TYPE_SERVER, user, user, message);\r
618                                 break;\r
619                         case 372:       // MOTD Data\r
620                         case 375:       // MOTD Start\r
621                         case 376:       // MOTD End\r
622                                 \r
623                         default:\r
624                                 //printf("[%s] %i %s\n", Server->Name, num, message);\r
625                                 Message_Append(Server, MSG_TYPE_SERVER, ident, user, message);\r
626                                 break;\r
627                         }\r
628                 }\r
629                 else if( strcmp(cmd, "NOTICE") == 0 )\r
630                 {\r
631                         char    *class, *message;\r
632                         \r
633                         class = GetValue(Line, &pos);\r
634                         _SysDebug("NOTICE class='%s'", class);\r
635                         \r
636                         if( Line[pos] == ':' ) {\r
637                                 message = Line + pos + 1;\r
638                         }\r
639                         else {\r
640                                 message = GetValue(Line, &pos);\r
641                         }\r
642                         \r
643                         //printf("[%s] NOTICE %s: %s\n", Server->Name, ident, message);\r
644                         char *ident_bang = strchr(ident, '!');\r
645                         if( ident_bang ) {\r
646                                 *ident_bang = '\0';\r
647                         }\r
648                         Message_Append(Server, MSG_TYPE_NOTICE, ident, "", message);\r
649                 }\r
650                 else if( strcmp(cmd, "PRIVMSG") == 0 )\r
651                 {\r
652                         char    *dest, *message;\r
653                         dest = GetValue(Line, &pos);\r
654                         \r
655                         if( Line[pos] == ':' ) {\r
656                                 message = Line + pos + 1;\r
657                         }\r
658                         else {\r
659                                 message = GetValue(Line, &pos);\r
660                         }\r
661 \r
662                         // TODO: Catch when the privmsg is addressed to the user\r
663 \r
664 //                      Cmd_PRIVMSG(Server, dest, ident, message);\r
665                         char *ident_bang = strchr(ident, '!');\r
666                         if( ident_bang ) {\r
667                                 *ident_bang = '\0';\r
668                         }\r
669                         Message_Append(Server, MSG_TYPE_STANDARD, ident, dest, message);\r
670                 }\r
671                 else if( strcmp(cmd, "JOIN" ) == 0 )\r
672                 {\r
673                         char    *channel;\r
674                         channel = Line + pos + 1;\r
675                         Window_Create(Server, channel);\r
676                 }\r
677                 else\r
678                 {\r
679                         Message_AppendF(Server, MSG_TYPE_SERVER, "", "", "Unknown message %s (%s)\n", cmd, Line+pos);\r
680                 }\r
681         }\r
682         else {          \r
683                 cmd = GetValue(Line, &pos);\r
684                 \r
685                 if( strcmp(cmd, "PING") == 0 ) {\r
686                         writef(Server->FD, "PONG %s\n", gsHostname);\r
687                         \r
688                 }\r
689                 else {\r
690                         // Command to client\r
691                         Message_AppendF(NULL, MSG_TYPE_UNK, "", "", "Client Command: %s", Line);\r
692                 }\r
693         }\r
694 }\r
695 \r
696 /**\r
697  * \brief Process incoming lines from the server\r
698  */\r
699 int ProcessIncoming(tServer *Server)\r
700 {       \r
701         char    *ptr, *newline;\r
702          int    len;\r
703         \r
704         // While there is data in the buffer, read it into user memory and \r
705         // process it line by line\r
706         // ioctl#8 on a TCP client gets the number of bytes in the recieve buffer\r
707         // - Used to avoid blocking\r
708         #if NON_BLOCK_READ\r
709         while( (len = _SysIOCtl(Server->FD, 8, NULL)) > 0 )\r
710         {\r
711         #endif\r
712                 // Read data\r
713                 len = _SysRead(Server->FD, &Server->InBuf[Server->ReadPos], BUFSIZ - Server->ReadPos);\r
714                 if( len == -1 ) {\r
715                         return -1;\r
716                 }\r
717                 Server->InBuf[Server->ReadPos + len] = '\0';\r
718                 \r
719                 // Break into lines\r
720                 ptr = Server->InBuf;\r
721                 while( (newline = strchr(ptr, '\n')) )\r
722                 {\r
723                         *newline = '\0';\r
724                         if( newline[-1] == '\r' )       newline[-1] = '\0';\r
725                         ParseServerLine(Server, ptr);\r
726                         ptr = newline + 1;\r
727                 }\r
728                 \r
729                 // Handle incomplete lines\r
730                 if( ptr - Server->InBuf < len + Server->ReadPos ) {\r
731                         // Update the read position\r
732                         // InBuf ReadPos    ptr          ReadPos+len\r
733                         // | old | new used | new unused |\r
734                         Server->ReadPos = len + Server->ReadPos - (ptr - Server->InBuf);\r
735                         // Copy stuff back (moving "new unused" to the start of the buffer)\r
736                         memcpy(Server->InBuf, ptr, Server->ReadPos);\r
737                 }\r
738                 else {\r
739                         Server->ReadPos = 0;\r
740                 }\r
741         #if NON_BLOCK_READ\r
742         }\r
743         #endif\r
744         \r
745         return 0;\r
746 }\r
747 \r
748 /**\r
749  * \brief Write a formatted string to a file descriptor\r
750  * \r
751  */\r
752 int writef(int FD, const char *Format, ...)\r
753 {\r
754         va_list args;\r
755          int    len;\r
756         \r
757         va_start(args, Format);\r
758         len = vsnprintf(NULL, 0, Format, args);\r
759         va_end(args);\r
760         \r
761         {\r
762                 char    buf[len+1];\r
763                 va_start(args, Format);\r
764                 vsnprintf(buf, len+1, Format, args);\r
765                 va_end(args);\r
766                 \r
767                 return _SysWrite(FD, buf, len);\r
768         }\r
769 }\r
770 \r
771 /**\r
772  * \brief Initialise a TCP connection to \a AddressString on port \a PortNumber\r
773  */\r
774 int OpenTCP(const char *AddressString, short PortNumber)\r
775 {\r
776          int    fd, addrType;\r
777         char    addrBuffer[8];\r
778         \r
779         // Parse IP Address\r
780         addrType = Net_ParseAddress(AddressString, addrBuffer);\r
781         if( addrType == 0 ) {\r
782                 fprintf(stderr, "Unable to parse '%s' as an IP address\n", AddressString);\r
783                 _SysDebug("Unable to parse '%s' as an IP address\n", AddressString);\r
784                 return -1;\r
785         }\r
786         \r
787         // Finds the interface for the destination address\r
788         fd = Net_OpenSocket(addrType, addrBuffer, "tcpc");\r
789         if( fd == -1 ) {\r
790                 fprintf(stderr, "Unable to open TCP Client to '%s'\n", AddressString);\r
791                 _SysDebug("Unable to open TCP client to '%s'\n", AddressString);\r
792                 return -1;\r
793         }\r
794         \r
795         // Set remote port and address\r
796 //      printf("Setting port and remote address\n");\r
797         _SysIOCtl(fd, 5, &PortNumber);\r
798         _SysIOCtl(fd, 6, addrBuffer);\r
799         \r
800         // Connect\r
801 //      printf("Initiating connection\n");\r
802         if( _SysIOCtl(fd, 7, NULL) == 0 ) {\r
803                 // Shouldn't happen :(\r
804                 fprintf(stderr, "Unable to start connection\n");\r
805                 return -1;\r
806         }\r
807         \r
808         // Return descriptor\r
809         return fd;\r
810 }\r
811 \r
812 /**\r
813  * \brief Read a space-separated value from a string\r
814  */\r
815 char *GetValue(char *Src, int *Ofs)\r
816 {\r
817          int    pos = *Ofs;\r
818         char    *ret = Src + pos;\r
819         char    *end;\r
820         \r
821         if( !Src )      return NULL;\r
822         \r
823         while( *ret == ' ' )    ret ++;\r
824         \r
825         end = strchr(ret, ' ');\r
826         if( end ) {\r
827                 *end = '\0';\r
828         }\r
829         else {\r
830                 end = ret + strlen(ret) - 1;\r
831         }\r
832         \r
833         end ++ ;\r
834         while( *ret == ' ' )    end ++;\r
835         *Ofs = end - Src;\r
836         \r
837         return ret;\r
838 }\r
839 \r
840 void SetCursorPos(int Row, int Col)\r
841 {\r
842         printf("\x1B[%i;%iH", Col, Row);\r
843 }\r
844 \r
845 static inline int isdigit(int ch)\r
846 {\r
847         return '0' <= ch && ch < '9';\r
848 }\r

UCC git Repository :: git.ucc.asn.au