src/inet.c

   1 /* File: inet.c */
   2
   3 #include "angband.h"
   4
   5 #ifdef WORLD_SCORE
   6
   7 #include <stdio.h>
   8 #include <stdarg.h>
   9 #include <ctype.h>
  10
  11 #if defined(WINDOWS)
  12 #include <winsock.h>
  13 #elif defined(MACINTOSH)
  14 #include <OpenTransport.h>
  15 #include <OpenTptInternet.h>
  16 #else
  17 #include <sys/types.h>
  18 #include <sys/socket.h>
  19 #include <netinet/in.h>
  20 #include <netdb.h>
  21 #include <sys/time.h>
  22
  23 #include <setjmp.h>
  24 #include <signal.h>
  25 #endif
  26
  27 #include <stdlib.h>
  28
  29 static cptr errstr;
  30 static char     *proxy;
  31 static int      proxy_port;
  32
  33 #ifdef MACINTOSH
  34 static InetSvcRef inet_services = nil;
  35 static EndpointRef ep           = kOTInvalidEndpointRef;
  36 #endif
  37
  38 #if 0 /* ¤È¤ê¤¢¤¨¤º¸½ºß¤Ï»È¤ï¤Ê¤¤¡£by Habu*/
  39 static char     *homeurl;
  40
  41 void
  42 set_homeurl(char *s)
  43 {
  44         if(homeurl)
  45                 free(homeurl);
  46
  47         homeurl = malloc(strlen(s) + 1);
  48         strcpy(homeurl, s);
  49 }
  50
  51 char *
  52 get_homeurl()
  53 {
  54         if(homeurl)
  55                 return homeurl;
  56         else
  57                 return "";
  58 }
  59
  60
  61 char *
  62 get_proxy()
  63 {
  64         static char buf[BUFSIZ];
  65
  66         if(proxy && proxy[0]){
  67 #ifndef WINDOWS
  68                 snprintf(buf, sizeof(buf), "%s:%d", proxy, proxy_port);
  69 #else
  70                 _snprintf(buf, sizeof(buf), "%s:%d", proxy, proxy_port);
  71 #endif
  72                 buf[sizeof(buf)-1] = '\0';
  73                 return buf;
  74         }
  75         else
  76                 return "";
  77 }
  78
  79 char *
  80 get_proxy_host()
  81 {
  82         return proxy;
  83 }
  84
  85 int
  86 get_proxy_port()
  87 {
  88         return proxy_port;
  89 }
  90
  91 int soc_read(int sd, char *buf, size_t sz)
  92 {
  93 #ifndef WINDOWS
  94         return read(sd, buf, sz);
  95 #else
  96         return recv(sd, buf, sz, 0);
  97 #endif
  98 }
  99
 100 #endif /* if 0 */
 101
 102 /* ¥×¥í¥¥·¥µ¡¼¥Ð¤Î¥¢¥É¥ì¥¹¤ò¤ò¥Õ¥¡¥¤¥ë¤«¤éÆÉ¤ó¤ÇÀßÄê¤¹¤ë */
 103 void set_proxy(char *default_url, int default_port)
 104 {
 105         char buf[1024];
 106         size_t len;
 107         FILE *fp;
 108         char *s;
 109
 110 #ifdef MACINTOSH
 111         int i;
 112         char tmp[8];
 113 #endif
 114
 115         path_build(buf, sizeof(buf), ANGBAND_DIR_PREF, "proxy.prf");
 116
 117         /* ¥Õ¥¡¥¤¥ë¤«¤éÀßÄê¤òÆÉ¤à¡£ */
 118         fp = my_fopen(buf, "r");
 119
 120         if (!fp)
 121         {
 122                 /* ¥Õ¥¡¥¤¥ë¤¬Â¸ºß¤·¤Ê¤¤¾ì¹ç¤Ï¥Ç¥Õ¥©¥ë¥È¤òÀßÄê */
 123                 proxy = default_url;
 124                 proxy_port = default_port;
 125                 return;
 126         }
 127
 128         while (my_fgets(fp, buf, sizeof(buf))==0)
 129         {
 130                 if (buf[0] != '#' && buf[0] != '\0') break;
 131         }
 132
 133         my_fclose(fp);
 134
 135         /* ¥Ý¥¤¥ó¥¿¤òÍÑ°Õ¡£ */
 136         s = buf;
 137
 138         /* "http://" ¤«¤é»Ï¤Þ¤Ã¤Æ¤¤¤ë¾ì¹ç¤Ï¤½¤ÎÉôÊ¬¤ò¥«¥Ã¥È¤¹¤ë¡£ */
 139 #if defined(WINDOWS)
 140         if (!strnicmp(s, "http://", 7))
 141         {
 142                 s += 7;
 143         }
 144 #elif defined(MACINTOSH)
 145         strncpy( tmp , s , 7 );
 146         for ( i = 0 ; i < 7 ; i++ )
 147         {
 148                 if ( isalpha(tmp[i]) )
 149                         tmp[i]= tolower(tmp[i]);
 150         }
 151         if (!strncmp(s, "http://", 7))
 152         {
 153                 s += 7;
 154         }
 155 #else
 156         if (!strncasecmp(s, "http://", 7))
 157         {
 158                 s += 7;
 159         }
 160 #endif
 161
 162         /* Ê¸»úÎó¤ÎÄ¹¤µ¤òÄ´¤Ù¡¢É¬Í×¤Ê¥á¥â¥ê¤ò³ÎÊÝ */
 163         len = strlen(s);
 164         proxy = malloc(len + 1);
 165
 166         /* ¥Ý¡¼¥ÈÈÖ¹æ¤¬¤¢¤ë¤«¤É¤¦¤«¤òÄ´¤Ù¡¢¤¢¤ì¤Ðproxy_port¤ËÀßÄê¡£ */
 167         --len;
 168         while (len > 0 && isdigit(s[len]))
 169                 --len;
 170         if (len > 0 && s[len] == ':' && s[len + 1] != '\0')
 171         {
 172                 s[len] = '\0';
 173                 strcpy(proxy, s);
 174                 proxy_port = atoi(s + (len + 1));
 175         }
 176         else
 177         {
 178                 strcpy(proxy, s);
 179                 proxy_port = default_port;
 180         }
 181
 182         /* ¥×¥í¥¥·¤Î¥¢¥É¥ì¥¹¤òproxy¤Ë¥³¥Ô¡¼ */
 183         strcpy(proxy, s);
 184
 185         if (proxy_port == 0)
 186                 proxy_port = 80;
 187 }
 188
 189 /* ¥½¥±¥Ã¥È¤Ë¥Ð¥Ã¥Õ¥¡¤ÎÆâÍÆ¤ò½ñ¤¹þ¤à */
 190 int soc_write(int sd, char *buf, size_t sz)
 191 {
 192 #ifndef MACINTOSH
 193 #ifndef WINDOWS
 194         write(sd, buf, sz);
 195 #else
 196         int nleft, nwritten;
 197
 198         nleft = sz;
 199
 200         while (nleft > 0) {
 201                 nwritten = send(sd, buf, nleft, 0);
 202                 if (nwritten <= 0)
 203                         return (nwritten);
 204                 nleft -= nwritten;
 205                 buf += nwritten;
 206         }
 207 #endif
 208 #else /* !MACINTOSH */
 209
 210         OTResult bytesSent;
 211
 212         OTSnd(ep, (void *) buf, sz, 0);
 213
 214 #endif
 215         return sz;
 216 }
 217
 218 #if 0 /* ¤ª¤½¤é¤¯»È¤ï¤Ê¤¤ */
 219 int soc_write_str(int sd, char *buf)
 220 {
 221         return soc_write(sd, buf, strlen(buf));
 222 }
 223 #endif
 224
 225 #if !defined(WINDOWS) && !defined(MACINTOSH)
 226 static sigjmp_buf       env;
 227 static void (*sig_int_saved)(int);
 228 static void (*sig_alm_saved)(int);
 229 #endif
 230
 231 static void restore_signal(void)
 232 {
 233 #if !defined(WINDOWS) && !defined(MACINTOSH)
 234         struct itimerval        val0;
 235
 236         /* itimer¥ê¥»¥Ã¥ÈÍÑ */
 237         val0.it_interval.tv_sec = 0;
 238         val0.it_interval.tv_usec = 0;
 239         val0.it_value.tv_sec = 0;
 240         val0.it_value.tv_usec = 0;
 241
 242         /* ¥¢¥é¡¼¥à²ò½ü */
 243         setitimer(ITIMER_REAL, &val0, NULL);
 244         signal(SIGALRM, sig_alm_saved);
 245         signal(SIGINT, sig_int_saved);
 246 #endif
 247 }
 248
 249
 250 #if !defined(WINDOWS) && !defined(MACINTOSH)
 251 static void interrupt_report(int sig)
 252 {
 253         restore_signal();
 254         siglongjmp(env, sig);
 255 }
 256 #endif
 257
 258
 259 /* ¥µ¡¼¥Ð¤Ë¥³¥Í¥¯¥È¤¹¤ë´Ø¿ô¡£ */
 260 int connect_server(int timeout, const char *host, int port)
 261 #ifndef MACINTOSH
 262 {
 263         int                     sd;
 264         struct sockaddr_in      to;
 265         struct hostent  *hp;
 266
 267 #ifndef WINDOWS
 268         struct itimerval        val;
 269         int                     ret;
 270
 271         /* itimerÀßÄêÍÑ */
 272         val.it_interval.tv_sec = 0;
 273         val.it_interval.tv_usec = 0;
 274         val.it_value.tv_sec = timeout;
 275         val.it_value.tv_usec = 0;
 276
 277         /* ¥¿¥¤¥à¥¢¥¦¥È¡¢¤â¤·¤¯¤ÏÃæÃÇ¤·¤¿»þ¤Î½èÍý¡£ */
 278         if ((ret = sigsetjmp(env,1)) != 0)
 279         {
 280 #ifdef JP
 281                 if (ret == SIGALRM)
 282                         errstr = "¥¨¥é¡¼: ¥¿¥¤¥à¥¢¥¦¥È";
 283                 else
 284                         errstr = "¥¨¥é¡¼: ¥¤¥ó¥¿¥é¥×¥È";
 285 #else
 286                 if (ret == SIGALRM)
 287                         errstr = "Error : time out";
 288                 else
 289                         errstr = "Error : interupted";
 290 #endif
 291                 return -1;
 292         }
 293         sig_int_saved = signal(SIGINT, interrupt_report);
 294         sig_alm_saved = signal(SIGALRM, interrupt_report);
 295
 296         /* ¥¿¥¤¥à¥¢¥¦¥È¤Î»þ´Ö¤òÀßÄê */
 297         setitimer(ITIMER_REAL, &val, NULL);
 298 #else
 299         /* Unused in Windows */
 300         (void)timeout;
 301 #endif
 302
 303         /* ¥×¥í¥¥·¤¬ÀßÄê¤µ¤ì¤Æ¤¤¤ì¤Ð¥×¥í¥¥·¤Ë·Ò¤° */
 304         if (proxy && proxy[0])
 305         {
 306                 if ((hp = gethostbyname(proxy)) == NULL)
 307                 {
 308 #ifdef JP
 309                         errstr = "¥¨¥é¡¼: ¥×¥í¥¥·¤Î¥¢¥É¥ì¥¹¤¬ÉÔÀµ¤Ç¤¹";
 310 #else
 311                         errstr = "Error : wrong proxy addres";
 312 #endif
 313
 314                         restore_signal();
 315
 316                         return -1;
 317                 }
 318         }
 319         else if ((hp = gethostbyname(host)) == NULL)
 320         {
 321 #ifdef JP
 322                 errstr = "¥¨¥é¡¼: ¥µ¡¼¥Ð¤Î¥¢¥É¥ì¥¹¤¬ÉÔÀµ¤Ç¤¹";
 323 #else
 324                 errstr = "Error : wrong server adress";
 325 #endif
 326
 327                 restore_signal();
 328
 329                 return -1;
 330         }
 331
 332         memset(&to, 0, sizeof(to));
 333         memcpy(&to.sin_addr, hp->h_addr_list[0], hp->h_length);
 334
 335         to.sin_family = AF_INET;
 336
 337         if(proxy && proxy[0] && proxy_port)
 338                 to.sin_port = htons((unsigned short int)proxy_port);
 339         else
 340                 to.sin_port = htons((unsigned short int)port);
 341
 342 #ifndef WINDOWS
 343         if ((sd = socket(PF_INET, SOCK_STREAM, 0)) < 0)
 344 #else
 345         if  ((sd = socket(PF_INET, SOCK_STREAM, 0)) == INVALID_SOCKET)
 346 #endif
 347         {
 348 #ifdef JP
 349                 errstr = "¥¨¥é¡¼: ¥½¥±¥Ã¥È¤òÀ¸À®¤Ç¤¤Þ¤»¤ó";
 350 #else
 351                 errstr = "Error : cannot create socket.";
 352 #endif
 353                 restore_signal();
 354                 return -1;
 355         }
 356
 357         if (connect(sd, (struct sockaddr *)&to, sizeof(to)) < 0)
 358         {
 359 #ifdef JP
 360                 errstr = "¥¨¥é¡¼: ¥µ¡¼¥Ð¤ËÀÜÂ³¤Ç¤¤Þ¤»¤ó";
 361 #else
 362                 errstr = "Error : failed to connect server";
 363 #endif
 364                 restore_signal();
 365 #ifndef WINDOWS
 366                 close(sd);
 367 #else
 368                 closesocket(sd);
 369 #endif
 370                 return -1;
 371         }
 372
 373         restore_signal();
 374
 375         return sd;
 376 }
 377
 378 #else /* !MACINTOSH */
 379
 380         /* ¥µ¡¼¥Ð¤Ë¥³¥Í¥¯¥È¤¹¤ë´Ø¿ô¡£ Mac */
 381 {
 382         OSStatus err;
 383         InetHostInfo    response;
 384         InetHost                host_addr;
 385         InetAddress     inAddr;
 386         TCall                   sndCall;
 387         Boolean                 bind    = false;
 388
 389         memset(&response, 0, sizeof(response));
 390
 391 #if TARGET_API_MAC_CARBON
 392         inet_services = OTOpenInternetServicesInContext(kDefaultInternetServicesPath, 0, &err, NULL);
 393 #else
 394         inet_services = OTOpenInternetServices(kDefaultInternetServicesPath, 0, &err);
 395 #endif
 396
 397         if (err == noErr) {
 398
 399                 if (proxy && proxy[0])
 400                 {
 401                         err = OTInetStringToAddress(inet_services, proxy, &response);
 402                 }
 403                 else
 404                 {
 405                         err = OTInetStringToAddress(inet_services, (char *)host, &response);
 406                 }
 407
 408                 if (err == noErr)
 409                 {
 410                         host_addr = response.addrs[0];
 411                 }
 412                 else
 413                 {
 414                         errstr = "error: bad score server!\n";
 415                 }
 416
 417 #if TARGET_API_MAC_CARBON
 418                 ep = (void *)OTOpenEndpointInContext(OTCreateConfiguration(kTCPName), 0, nil, &err, NULL);
 419 #else
 420                 ep = (void *)OTOpenEndpoint(OTCreateConfiguration(kTCPName), 0, nil, &err);
 421 #endif
 422
 423                 if (err == noErr)
 424                 {
 425                         err = OTBind(ep, nil, nil);
 426                         bind = (err == noErr);
 427                 }
 428                 if (err == noErr)
 429                 {
 430                         if (proxy && proxy[0] && proxy_port)
 431                                 OTInitInetAddress(&inAddr, proxy_port, host_addr);
 432                         else
 433                                 OTInitInetAddress(&inAddr, port, host_addr);
 434
 435                         sndCall.addr.len        = sizeof(InetAddress);
 436                         sndCall.addr.buf        = (unsigned char*) &inAddr;
 437                         sndCall.opt.buf         = nil;        /* no connection options */
 438                         sndCall.opt.len         = 0;
 439                         sndCall.udata.buf       = nil;        /* no connection data */
 440                         sndCall.udata.len       = 0;
 441                         sndCall.sequence        = 0;          /* ignored by OTConnect */
 442
 443                         err = OTConnect(ep, &sndCall, NULL);
 444
 445                         if (err != noErr)
 446                         {
 447                                 errstr = "error: cannot connect score server!\n";
 448                         }
 449                 }
 450         }
 451
 452         if ( err != noErr )
 453         {
 454                 if ( bind )
 455                 {
 456                         OTUnbind(ep);
 457                 }
 458                 /* Clean up. */
 459                 if (ep != kOTInvalidEndpointRef)
 460                 {
 461                         OTCloseProvider(ep);
 462                         ep = nil;
 463                 }
 464                 if (inet_services != nil)
 465                 {
 466                         OTCloseProvider(inet_services);
 467                         inet_services = nil;
 468                 }
 469
 470                 return -1;
 471         }
 472
 473         return 1;
 474 }
 475 #endif
 476
 477
 478 int disconnect_server(int sd)
 479 {
 480 #if defined(WINDOWS)
 481         return closesocket(sd);
 482 #elif defined(MACINTOSH)
 483         if (ep != kOTInvalidEndpointRef)
 484         {
 485                 OTCloseProvider(ep);
 486         }
 487
 488         if (inet_services != nil)
 489         {
 490                 OTCloseProvider(inet_services);
 491         }
 492 #else
 493         return close(sd);
 494 #endif
 495 }
 496
 497 cptr soc_err()
 498 {
 499         return errstr;
 500 }
 501
 502 #endif /* WORLD_SCORE */