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 \r
  11 #define BUFSIZ  1023\r
  12 \r
  13 // === TYPES ===\r
  14 typedef struct sServer {\r
  15         struct sServer  *Next;\r
  16          int    FD;\r
  17         char    InBuf[BUFSIZ+1];\r
  18          int    ReadPos;\r
  19         char    Name[];\r
  20 } tServer;\r
  21 \r
  22 typedef struct sMessage\r
  23 {\r
  24         struct sMessage *Next;\r
  25         time_t  Timestamp;\r
  26         tServer *Server;\r
  27          int    Type;\r
  28         char    *Source;        // Pointer into `Data`\r
  29         char    Data[];\r
  30 }       tMessage;\r
  31 \r
  32 typedef struct sWindow\r
  33 {\r
  34         struct sWindow  *Next;\r
  35         tMessage        *Messages;\r
  36         tServer *Server;        //!< Canoical server (can be NULL)\r
  37          int    ActivityLevel;\r
  38         char    Name[]; // Channel name / remote user\r
  39 }       tWindow;\r
  40 \r
  41 enum eMessageTypes\r
  42 {\r
  43         MSG_TYPE_NULL,\r
  44         MSG_TYPE_SERVER,        // Server message\r
  45         \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
  50         \r
  51         MSG_TYPE_STANDARD,      // Standard line\r
  52         MSG_TYPE_ACTION,        // /me\r
  53         \r
  54         MSG_TYPE_UNK\r
  55 };\r
  56 \r
  57 // === PROTOTYPES ===\r
  58  int    ParseArguments(int argc, const char *argv[]);\r
  59  int    ParseUserCommand(char *String);\r
  60 // --- \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
  64 \r
  65  int    ProcessIncoming(tServer *Server);\r
  66 // --- Helpers\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
  72 \r
  73 // === GLOBALS ===\r
  74 char    *gsUsername = "user";\r
  75 char    *gsHostname = "acess";\r
  76 char    *gsRealName = "Acess2 IRC Client";\r
  77 char    *gsNickname = "acess";\r
  78 tServer *gpServers;\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
  82 };\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
  87 \r
  88 // ==== CODE ====\r
  89 void ExitHandler(void)\r
  90 {\r
  91         printf("\x1B[?1047l");\r
  92 }\r
  93 \r
  94 int main(int argc, const char *argv[], const char *envp[])\r
  95 {\r
  96          int    tmp;\r
  97         tReadline       *readline_info;\r
  98         \r
  99         // Parse Command line\r
 100         if( (tmp = ParseArguments(argc, argv)) )        return tmp;\r
 101         \r
 102         atexit(ExitHandler);\r
 103         \r
 104         giTerminal_Width = ioctl(1, 5, NULL);   // getset_width\r
 105         giTerminal_Height = ioctl(1, 6, NULL);  // getset_height\r
 106         \r
 107         printf("\x1B[?1047h");\r
 108         printf("\x1B[%i;%ir", 0, giTerminal_Height-1);\r
 109         \r
 110         // HACK: Static server entry\r
 111         // UCC (University [of Western Australia] Computer Club) IRC Server\r
 112         gWindow_Status.Server = Server_Connect( "UCC", "130.95.13.18", 6667 );\r
 113         \r
 114         if( !gWindow_Status.Server )\r
 115                 return -1;\r
 116         \r
 117         readline_info = Readline_Init(1);\r
 118         \r
 119         SetCursorPos(giTerminal_Height-1, 0);\r
 120         printf("[(status)] ");\r
 121         \r
 122         for( ;; )\r
 123         {\r
 124                 fd_set  readfds, errorfds;\r
 125                  int    rv, maxFD = 0;\r
 126                 tServer *srv;\r
 127                 \r
 128                 FD_ZERO(&readfds);\r
 129                 FD_ZERO(&errorfds);\r
 130                 FD_SET(0, &readfds);    // stdin\r
 131                 \r
 132                 // Fill server FDs in fd_set\r
 133                 for( srv = gpServers; srv; srv = srv->Next )\r
 134                 {\r
 135                         FD_SET(srv->FD, &readfds);\r
 136                         FD_SET(srv->FD, &errorfds);\r
 137                         if( srv->FD > maxFD )\r
 138                                 maxFD = srv->FD;\r
 139                 }\r
 140                 \r
 141                 rv = select(maxFD+1, &readfds, 0, &errorfds, NULL);\r
 142                 if( rv == -1 )  break;\r
 143                 \r
 144                 if(FD_ISSET(0, &readfds))\r
 145                 {\r
 146                         // User input\r
 147                         char    *cmd = Readline_NonBlock(readline_info);\r
 148                         if( cmd )\r
 149                         {\r
 150                                 if( cmd[0] )\r
 151                                 {\r
 152                                         ParseUserCommand(cmd);\r
 153                                 }\r
 154                                 free(cmd);\r
 155                                 // Prompt\r
 156                                 SetCursorPos(giTerminal_Height-1, 0);\r
 157                                 if( gpCurrentWindow->Name[0] )\r
 158                                         printf("[%s:%s] ", gpCurrentWindow->Server->Name, gpCurrentWindow->Name);\r
 159                                 else\r
 160                                         printf("[(status)] ");\r
 161                         }\r
 162                 }\r
 163                 \r
 164                 // Server response\r
 165                 for( srv = gpServers; srv; srv = srv->Next )\r
 166                 {\r
 167                         if(FD_ISSET(srv->FD, &readfds))\r
 168                         {\r
 169                                 if( ProcessIncoming(srv) != 0 ) {\r
 170                                         // Oops, error\r
 171                                         break;\r
 172                                 }\r
 173                         }\r
 174                         \r
 175                         if(FD_ISSET(srv->FD, &errorfds))\r
 176                         {\r
 177                                 break;\r
 178                         }\r
 179                 }\r
 180                 \r
 181                 // Oops, an error\r
 182                 if( srv )       break;\r
 183         }\r
 184         \r
 185         {\r
 186                 tServer *srv;\r
 187                 for( srv = gpServers; srv; srv = srv->Next )\r
 188                         close(srv->FD);\r
 189         }\r
 190         return 0;\r
 191 }\r
 192 \r
 193 /**\r
 194  * \todo Actually implement correctly :)\r
 195  */\r
 196 int ParseArguments(int argc, const char *argv[])\r
 197 {\r
 198         return 0;\r
 199 }\r
 200 \r
 201 int ParseUserCommand(char *String)\r
 202 {\r
 203         if( String[0] == '/' )\r
 204         {\r
 205                 char    *command;\r
 206                  int    pos = 0;\r
 207                 \r
 208                 command = GetValue(String, &pos);\r
 209                 \r
 210                 if( strcmp(command, "/join") == 0 )\r
 211                 {\r
 212                         char    *channel_name = GetValue(String, &pos);\r
 213                         \r
 214                         if( gpCurrentWindow->Server )\r
 215                         {\r
 216                                 writef(gpCurrentWindow->Server->FD, "JOIN :%s\n",  channel_name);\r
 217                         }\r
 218                 }\r
 219                 else if( strcmp(command, "/quit") == 0 )\r
 220                 {\r
 221                         char    *quit_message = GetValue(String, &pos);\r
 222                         tServer *srv;\r
 223                         \r
 224                         if( quit_message == NULL || quit_message[0] == '\0' )\r
 225                                 quit_message = "/quit - Acess2 IRC Client";\r
 226                         \r
 227                         for( srv = gpServers; srv; srv = srv->Next )\r
 228                         {\r
 229                                 writef(srv->FD, "QUIT :%s\n", quit_message);\r
 230                         }\r
 231                         \r
 232                         exit(0);\r
 233                 }\r
 234                 else if( strcmp(command, "/window") == 0 || strcmp(command, "/win") == 0 || strcmp(command, "/w") == 0 )\r
 235                 {\r
 236                         char    *window_id = GetValue(String, &pos);\r
 237                          int    window_num = atoi(window_id);\r
 238                         \r
 239                         if( window_num > 0 )\r
 240                         {\r
 241                                 tWindow *win;\r
 242                                 window_num --;  // Move to base 0\r
 243                                 // Get `window_num`th window\r
 244                                 for( win = gpWindows; win && window_num--; win = win->Next );\r
 245                                 if( win ) {\r
 246                                         gpCurrentWindow = win;\r
 247                                 }\r
 248                                 // Otherwise, silently ignore\r
 249                         }\r
 250                         else\r
 251                         {\r
 252                                 tWindow *win;\r
 253                                 window_num = 1;\r
 254                                 for( win = gpWindows; win; win = win->Next, window_num ++ )\r
 255                                 {\r
 256                                         char tmp[snprintf(NULL, 1000, "%i: %s/%s", window_num, win->Server->Name, win->Name)+1];\r
 257                                         snprintf(tmp, 1000, "%i: %s/%s", window_num, win->Server->Name, win->Name);\r
 258                                         Message_Append(NULL, MSG_TYPE_SERVER, "client", "", tmp);\r
 259                                 }\r
 260                         }\r
 261                 }\r
 262                 else\r
 263                 {\r
 264                          int    len = snprintf(NULL, 0, "Unknown command %s", command);\r
 265                         char    buf[len+1];\r
 266                         snprintf(buf, len+1, "Unknown command %s", command);\r
 267                         Message_Append(NULL, MSG_TYPE_SERVER, "client", "", buf);\r
 268                 }\r
 269         }\r
 270         else\r
 271         {\r
 272                 // Message\r
 273                 // - Only send if server is valid and window name is non-empty\r
 274                 if( gpCurrentWindow->Server && gpCurrentWindow->Name[0] )\r
 275                 {\r
 276                         writef(gpCurrentWindow->Server->FD,\r
 277                                 "PRIVMSG %s :%s\n", gpCurrentWindow->Name,\r
 278                                 String\r
 279                                 );\r
 280                 }\r
 281         }\r
 282         \r
 283         return 0;\r
 284 }\r
 285 \r
 286 /**\r
 287  * \brief Connect to a server\r
 288  */\r
 289 tServer *Server_Connect(const char *Name, const char *AddressString, short PortNumber)\r
 290 {\r
 291         tServer *ret;\r
 292         \r
 293         ret = calloc(1, sizeof(tServer) + strlen(Name) + 1);\r
 294         \r
 295         strcpy(ret->Name, Name);\r
 296         \r
 297         // Connect to the remove server\r
 298         ret->FD = OpenTCP( AddressString, PortNumber );\r
 299         if( ret->FD == -1 ) {\r
 300                 fprintf(stderr, "%s: Unable to create socket\n", Name);\r
 301                 return NULL;\r
 302         }\r
 303         \r
 304         // Append to open list\r
 305         ret->Next = gpServers;\r
 306         gpServers = ret;\r
 307         \r
 308         // Read some initial data\r
 309         printf("%s: Connection opened\n", Name);\r
 310         ProcessIncoming(ret);\r
 311         \r
 312         // Identify\r
 313         writef(ret->FD, "USER %s %s %s : %s\n", gsUsername, gsHostname, AddressString, gsRealName);\r
 314         writef(ret->FD, "NICK %s\n", gsNickname);\r
 315         printf("%s: Identified\n", Name);\r
 316         \r
 317         return ret;\r
 318 }\r
 319 \r
 320 tMessage *Message_Append(tServer *Server, int Type, const char *Source, const char *Dest, const char *Message)\r
 321 {\r
 322         tMessage        *ret;\r
 323         tWindow *win = NULL;\r
 324          int    msgLen = strlen(Message);\r
 325         \r
 326         // NULL servers are internal messages\r
 327         if( Server == NULL )\r
 328         {\r
 329                 win = &gWindow_Status;\r
 330         }\r
 331         // Determine if it's a channel or PM message\r
 332         else if( Dest[0] == '#' || Dest[0] == '&' )     // TODO: Better determining here\r
 333         {\r
 334                 tWindow *prev = NULL;\r
 335                 for(win = gpWindows; win; prev = win, win = win->Next)\r
 336                 {\r
 337                         if( win->Server == Server && strcmp(win->Name, Dest) == 0 )\r
 338                         {\r
 339                                 break;\r
 340                         }\r
 341                 }\r
 342                 if( !win ) {\r
 343                         win = Window_Create(Server, Dest);\r
 344                 }\r
 345         }\r
 346         #if 0\r
 347         else if( strcmp(Dest, Server->Nick) != 0 )\r
 348         {\r
 349                 // Umm... message for someone who isn't us?\r
 350                 win = &gWindow_Status;  // Stick it in the status window, just in case\r
 351         }\r
 352         #endif\r
 353         // Server message?\r
 354         else if( strchr(Source, '.') )  // TODO: And again, less hack please\r
 355         {\r
 356                 #if 1\r
 357                 for(win = gpWindows; win; win = win->Next)\r
 358                 {\r
 359                         if( win->Server == Server && strcmp(win->Name, Source) == 0 )\r
 360                         {\r
 361                                 break;\r
 362                         }\r
 363                 }\r
 364                 #endif\r
 365                 if( !win ) {\r
 366                         win = &gWindow_Status;\r
 367                 }\r
 368                 \r
 369         }\r
 370         // Private message\r
 371         else\r
 372         {\r
 373                 for(win = gpWindows; win; win = win->Next)\r
 374                 {\r
 375                         if( win->Server == Server && strcmp(win->Name, Source) == 0 )\r
 376                         {\r
 377                                 break;\r
 378                         }\r
 379                 }\r
 380                 if( !win ) {\r
 381                         win = Window_Create(Server, Dest);\r
 382                 }\r
 383         }\r
 384         \r
 385         ret = malloc( sizeof(tMessage) + msgLen + 1 + strlen(Source) + 1 );\r
 386         ret->Source = ret->Data + msgLen + 1;\r
 387         strcpy(ret->Source, Source);\r
 388         strcpy(ret->Data, Message);\r
 389         ret->Type = Type;\r
 390         ret->Server = Server;\r
 391         \r
 392         // TODO: Append to window message list\r
 393         ret->Next = win->Messages;\r
 394         win->Messages = ret;\r
 395         \r
 396         //TODO: Set location\r
 397         \r
 398         #if 1\r
 399         if( win == gpCurrentWindow ) {\r
 400                 int pos = SetCursorPos(giTerminal_Height-2, 0);\r
 401                 printf("\x1B[S");       // Scroll up 1\r
 402                 printf("[%s] %s\n", Source, Message);\r
 403                 SetCursorPos(-1, pos);\r
 404         }\r
 405         #else\r
 406         if(win->Name[0])\r
 407                 printf("%s/%s [%s] %s\n", win->Server->Name, win->Name, Source, Message);\r
 408         else\r
 409                 printf("(status) [%s] %s\n", Source, Message);\r
 410         #endif\r
 411         \r
 412         return ret;\r
 413 }\r
 414 \r
 415 tWindow *Window_Create(tServer *Server, const char *Name)\r
 416 {\r
 417         tWindow *ret, *prev = NULL;\r
 418          int    num = 1;\r
 419         \r
 420         // Get the end of the list\r
 421         // TODO: Cache this instead\r
 422         for( ret = gpCurrentWindow; ret; prev = ret, ret = ret->Next )\r
 423                 num ++;\r
 424         \r
 425         ret = malloc(sizeof(tWindow) + strlen(Name) + 1);\r
 426         ret->Messages = NULL;\r
 427         ret->Server = Server;\r
 428         ret->ActivityLevel = 1;\r
 429         strcpy(ret->Name, Name);\r
 430         \r
 431         if( prev ) {\r
 432                 ret->Next = prev->Next;\r
 433                 prev->Next = ret;\r
 434         }\r
 435         else {  // Shouldn't happen really\r
 436                 ret->Next = gpWindows;\r
 437                 gpWindows = ret;\r
 438         }\r
 439         \r
 440 //      printf("Win %i %s:%s created\n", num, Server->Name, Name);\r
 441         \r
 442         return ret;\r
 443 }\r
 444 \r
 445 void Cmd_PRIVMSG(tServer *Server, const char *Dest, const char *Src, const char *Message)\r
 446 {\r
 447         Message_Append(Server, MSG_TYPE_STANDARD, Dest, Src, Message);\r
 448         //printf("<%s:%s:%s> %s\n", Server->Name, Dest, Src, Message);\r
 449 }\r
 450 \r
 451 /**\r
 452  */\r
 453 void ParseServerLine(tServer *Server, char *Line)\r
 454 {\r
 455          int    pos = 0;\r
 456         char    *ident, *cmd;\r
 457         \r
 458         // Message?\r
 459         if( *Line == ':' )\r
 460         {\r
 461                 ident = GetValue(Line, &pos);   // Ident (user or server)\r
 462                 cmd = GetValue(Line, &pos);\r
 463                 \r
 464                 // Numeric command\r
 465                 if( isdigit(cmd[0]) && isdigit(cmd[1]) && isdigit(cmd[2]) )\r
 466                 {\r
 467                         char    *user, *message;\r
 468                          int    num;\r
 469                         num  = (cmd[0] - '0') * 100;\r
 470                         num += (cmd[1] - '0') * 10;\r
 471                         num += (cmd[2] - '0') * 1;\r
 472                         \r
 473                         user = GetValue(Line, &pos);\r
 474                         \r
 475                         if( Line[pos] == ':' ) {\r
 476                                 message = Line + pos + 1;\r
 477                         }\r
 478                         else {\r
 479                                 message = GetValue(Line, &pos);\r
 480                         }\r
 481                         \r
 482                         switch(num)\r
 483                         {\r
 484                         default:\r
 485                                 //printf("[%s] %i %s\n", Server->Name, num, message);\r
 486                                 Message_Append(Server, MSG_TYPE_SERVER, ident, user, message);\r
 487                                 break;\r
 488                         }\r
 489                 }\r
 490                 else if( strcmp(cmd, "NOTICE") == 0 )\r
 491                 {\r
 492                         char    *class, *message;\r
 493                         \r
 494                         class = GetValue(Line, &pos);\r
 495                         \r
 496                         if( Line[pos] == ':' ) {\r
 497                                 message = Line + pos + 1;\r
 498                         }\r
 499                         else {\r
 500                                 message = GetValue(Line, &pos);\r
 501                         }\r
 502                         \r
 503                         //printf("[%s] NOTICE %s: %s\n", Server->Name, ident, message);\r
 504                         Message_Append(Server, MSG_TYPE_NOTICE, ident, "", message);\r
 505                 }\r
 506                 else if( strcmp(cmd, "PRIVMSG") == 0 )\r
 507                 {\r
 508                         char    *dest, *message;\r
 509                         dest = GetValue(Line, &pos);\r
 510                         \r
 511                         if( Line[pos] == ':' ) {\r
 512                                 message = Line + pos + 1;\r
 513                         }\r
 514                         else {\r
 515                                 message = GetValue(Line, &pos);\r
 516                         }\r
 517                         Cmd_PRIVMSG(Server, dest, ident, message);\r
 518                         Message_Append(Server, MSG_TYPE_STANDARD, ident, dest, message);\r
 519                 }\r
 520                 else if( strcmp(cmd, "JOIN" ) == 0 )\r
 521                 {\r
 522                         char    *channel;\r
 523                         channel = GetValue(Line, &pos) + 1;\r
 524                         Window_Create(Server, channel);\r
 525                 }\r
 526                 else\r
 527                 {\r
 528                         printf("Unknown message %s (%s)\n", cmd, Line+pos);\r
 529                 }\r
 530         }\r
 531         else {\r
 532                 \r
 533                 // Command to client\r
 534                 printf("Client Command: %s", Line);\r
 535         }\r
 536 }\r
 537 \r
 538 /**\r
 539  * \brief Process incoming lines from the server\r
 540  */\r
 541 int ProcessIncoming(tServer *Server)\r
 542 {       \r
 543         char    *ptr, *newline;\r
 544          int    len;\r
 545         \r
 546         // While there is data in the buffer, read it into user memory and \r
 547         // process it line by line\r
 548         // ioctl#8 on a TCP client gets the number of bytes in the recieve buffer\r
 549         // - Used to avoid blocking\r
 550         #if NON_BLOCK_READ\r
 551         while( (len = ioctl(Server->FD, 8, NULL)) > 0 )\r
 552         {\r
 553         #endif\r
 554                 // Read data\r
 555                 len = read(Server->FD, BUFSIZ - Server->ReadPos, &Server->InBuf[Server->ReadPos]);\r
 556                 if( len == -1 ) {\r
 557                         return -1;\r
 558                 }\r
 559                 Server->InBuf[Server->ReadPos + len] = '\0';\r
 560                 \r
 561                 // Break into lines\r
 562                 ptr = Server->InBuf;\r
 563                 while( (newline = strchr(ptr, '\n')) )\r
 564                 {\r
 565                         *newline = '\0';\r
 566                         if( newline[-1] == '\r' )       newline[-1] = '\0';\r
 567                         ParseServerLine(Server, ptr);\r
 568                         ptr = newline + 1;\r
 569                 }\r
 570                 \r
 571                 // Handle incomplete lines\r
 572                 if( ptr - Server->InBuf < len + Server->ReadPos ) {\r
 573                         // Update the read position\r
 574                         // InBuf ReadPos    ptr          ReadPos+len\r
 575                         // | old | new used | new unused |\r
 576                         Server->ReadPos = len + Server->ReadPos - (ptr - Server->InBuf);\r
 577                         // Copy stuff back (moving "new unused" to the start of the buffer)\r
 578                         memcpy(Server->InBuf, ptr, Server->ReadPos);\r
 579                 }\r
 580                 else {\r
 581                         Server->ReadPos = 0;\r
 582                 }\r
 583         #if NON_BLOCK_READ\r
 584         }\r
 585         #endif\r
 586         \r
 587         return 0;\r
 588 }\r
 589 \r
 590 /**\r
 591  * \brief Write a formatted string to a file descriptor\r
 592  * \r
 593  */\r
 594 int writef(int FD, const char *Format, ...)\r
 595 {\r
 596         va_list args;\r
 597          int    len;\r
 598         \r
 599         va_start(args, Format);\r
 600         len = vsnprintf(NULL, 1000, Format, args);\r
 601         va_end(args);\r
 602         \r
 603         {\r
 604                 char    buf[len+1];\r
 605                 va_start(args, Format);\r
 606                 vsnprintf(buf, len+1, Format, args);\r
 607                 va_end(args);\r
 608                 \r
 609                 return write(FD, len, buf);\r
 610         }\r
 611 }\r
 612 \r
 613 /**\r
 614  * \brief Initialise a TCP connection to \a AddressString on port \a PortNumber\r
 615  */\r
 616 int OpenTCP(const char *AddressString, short PortNumber)\r
 617 {\r
 618          int    fd, addrType;\r
 619         char    *iface;\r
 620         char    addrBuffer[8];\r
 621         \r
 622         // Parse IP Address\r
 623         addrType = Net_ParseAddress(AddressString, addrBuffer);\r
 624         if( addrType == 0 ) {\r
 625                 fprintf(stderr, "Unable to parse '%s' as an IP address\n", AddressString);\r
 626                 return -1;\r
 627         }\r
 628         \r
 629         // Finds the interface for the destination address\r
 630         iface = Net_GetInterface(addrType, addrBuffer);\r
 631         if( iface == NULL ) {\r
 632                 fprintf(stderr, "Unable to find a route to '%s'\n", AddressString);\r
 633                 return -1;\r
 634         }\r
 635         \r
 636         printf("iface = '%s'\n", iface);\r
 637         \r
 638         // Open client socket\r
 639         // TODO: Move this out to libnet?\r
 640         {\r
 641                  int    len = snprintf(NULL, 100, "/Devices/ip/%s/tcpc", iface);\r
 642                 char    path[len+1];\r
 643                 snprintf(path, 100, "/Devices/ip/%s/tcpc", iface);\r
 644                 fd = open(path, OPENFLAG_READ|OPENFLAG_WRITE);\r
 645         }\r
 646         \r
 647         free(iface);\r
 648         \r
 649         if( fd == -1 ) {\r
 650                 fprintf(stderr, "Unable to open TCP Client for reading\n");\r
 651                 return -1;\r
 652         }\r
 653         \r
 654         // Set remote port and address\r
 655         printf("Setting port and remote address\n");\r
 656         ioctl(fd, 5, &PortNumber);\r
 657         ioctl(fd, 6, addrBuffer);\r
 658         \r
 659         // Connect\r
 660         printf("Initiating connection\n");\r
 661         if( ioctl(fd, 7, NULL) == 0 ) {\r
 662                 // Shouldn't happen :(\r
 663                 fprintf(stderr, "Unable to start connection\n");\r
 664                 return -1;\r
 665         }\r
 666         \r
 667         // Return descriptor\r
 668         return fd;\r
 669 }\r
 670 \r
 671 /**\r
 672  * \brief Read a space-separated value from a string\r
 673  */\r
 674 char *GetValue(char *Src, int *Ofs)\r
 675 {\r
 676          int    pos = *Ofs;\r
 677         char    *ret = Src + pos;\r
 678         char    *end;\r
 679         \r
 680         if( !Src )      return NULL;\r
 681         \r
 682         while( *ret == ' ' )    ret ++;\r
 683         \r
 684         end = strchr(ret, ' ');\r
 685         if( end ) {\r
 686                 *end = '\0';\r
 687         }\r
 688         else {\r
 689                 end = ret + strlen(ret) - 1;\r
 690         }\r
 691         \r
 692         end ++ ;\r
 693         while( *ret == ' ' )    end ++;\r
 694         *Ofs = end - Src;\r
 695         \r
 696         return ret;\r
 697 }\r
 698 \r
 699 int SetCursorPos(int Row, int Col)\r
 700 {\r
 701         if( Row == -1 ) {\r
 702                 Row = Col / giTerminal_Width;\r
 703                 Col = Col % giTerminal_Width;\r
 704         }\r
 705         printf("\x1B[%i;%iH", Col, Row);\r
 706         return ioctl(1, 9, NULL);       // Ugh, constants\r
 707 }\r
 708 \r
 709 static inline int isdigit(int ch)\r
 710 {\r
 711         return '0' <= ch && ch < '9';\r
 712 }\r