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((unsigned char)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         int nleft, nwritten;
 194
 195         nleft = sz;
 196
 197         while (nleft > 0) {
 198                 nwritten = send(sd, buf, nleft, 0);
 199                 if (nwritten <= 0)
 200                         return (nwritten);
 201                 nleft -= nwritten;
 202                 buf += nwritten;
 203         }
 204 #else /* !MACINTOSH */
 205
 206         OTResult bytesSent;
 207
 208         OTSnd(ep, (void *) buf, sz, 0);
 209
 210 #endif
 211         return sz;
 212 }
 213
 214 #if 0 /* おそらく使わない */
 215 int soc_write_str(int sd, char *buf)
 216 {
 217         return soc_write(sd, buf, strlen(buf));
 218 }
 219 #endif
 220
 221 #if !defined(WINDOWS) && !defined(MACINTOSH)
 222 static sigjmp_buf       env;
 223 static void (*sig_int_saved)(int);
 224 static void (*sig_alm_saved)(int);
 225 #endif
 226
 227 static void restore_signal(void)
 228 {
 229 #if !defined(WINDOWS) && !defined(MACINTOSH)
 230         struct itimerval        val0;
 231
 232         /* itimerリセット用 */
 233         val0.it_interval.tv_sec = 0;
 234         val0.it_interval.tv_usec = 0;
 235         val0.it_value.tv_sec = 0;
 236         val0.it_value.tv_usec = 0;
 237
 238         /* アラーム解除 */
 239         setitimer(ITIMER_REAL, &val0, NULL);
 240         signal(SIGALRM, sig_alm_saved);
 241         signal(SIGINT, sig_int_saved);
 242 #endif
 243 }
 244
 245
 246 #if !defined(WINDOWS) && !defined(MACINTOSH)
 247 static void interrupt_report(int sig)
 248 {
 249         restore_signal();
 250         siglongjmp(env, sig);
 251 }
 252 #endif
 253
 254
 255 /* サーバにコネクトする関数。 */
 256 int connect_server(int timeout, const char *host, int port)
 257 #ifndef MACINTOSH
 258 {
 259         int                     sd;
 260         struct sockaddr_in      to;
 261         struct hostent  *hp;
 262
 263 #ifndef WINDOWS
 264         struct itimerval        val;
 265         int                     ret;
 266
 267         /* itimer設定用 */
 268         val.it_interval.tv_sec = 0;
 269         val.it_interval.tv_usec = 0;
 270         val.it_value.tv_sec = timeout;
 271         val.it_value.tv_usec = 0;
 272
 273         /* タイムアウト、もしくは中断した時の処理。 */
 274         if ((ret = sigsetjmp(env,1)) != 0)
 275         {
 276 #ifdef JP
 277                 if (ret == SIGALRM)
 278                         errstr = "エラー: タイムアウト";
 279                 else
 280                         errstr = "エラー: インタラプト";
 281 #else
 282                 if (ret == SIGALRM)
 283                         errstr = "Error : time out";
 284                 else
 285                         errstr = "Error : interupted";
 286 #endif
 287                 return -1;
 288         }
 289         sig_int_saved = signal(SIGINT, interrupt_report);
 290         sig_alm_saved = signal(SIGALRM, interrupt_report);
 291
 292         /* タイムアウトの時間を設定 */
 293         setitimer(ITIMER_REAL, &val, NULL);
 294 #else
 295         /* Unused in Windows */
 296         (void)timeout;
 297 #endif
 298
 299         /* プロキシが設定されていればプロキシに繋ぐ */
 300         if (proxy && proxy[0])
 301         {
 302                 if ((hp = gethostbyname(proxy)) == NULL)
 303                 {
 304 #ifdef JP
 305                         errstr = "エラー: プロキシのアドレスが不正です";
 306 #else
 307                         errstr = "Error : wrong proxy addres";
 308 #endif
 309
 310                         restore_signal();
 311
 312                         return -1;
 313                 }
 314         }
 315         else if ((hp = gethostbyname(host)) == NULL)
 316         {
 317 #ifdef JP
 318                 errstr = "エラー: サーバのアドレスが不正です";
 319 #else
 320                 errstr = "Error : wrong server adress";
 321 #endif
 322
 323                 restore_signal();
 324
 325                 return -1;
 326         }
 327
 328         memset(&to, 0, sizeof(to));
 329         memcpy(&to.sin_addr, hp->h_addr_list[0], hp->h_length);
 330
 331         to.sin_family = AF_INET;
 332
 333         if(proxy && proxy[0] && proxy_port)
 334                 to.sin_port = htons((unsigned short int)proxy_port);
 335         else
 336                 to.sin_port = htons((unsigned short int)port);
 337
 338 #ifndef WINDOWS
 339         if ((sd = socket(PF_INET, SOCK_STREAM, 0)) < 0)
 340 #else
 341         if  ((sd = socket(PF_INET, SOCK_STREAM, 0)) == INVALID_SOCKET)
 342 #endif
 343         {
 344 #ifdef JP
 345                 errstr = "エラー: ソケットを生成できません";
 346 #else
 347                 errstr = "Error : cannot create socket.";
 348 #endif
 349                 restore_signal();
 350                 return -1;
 351         }
 352
 353         if (connect(sd, (struct sockaddr *)&to, sizeof(to)) < 0)
 354         {
 355 #ifdef JP
 356                 errstr = "エラー: サーバに接続できません";
 357 #else
 358                 errstr = "Error : failed to connect server";
 359 #endif
 360                 restore_signal();
 361 #ifndef WINDOWS
 362                 close(sd);
 363 #else
 364                 closesocket(sd);
 365 #endif
 366                 return -1;
 367         }
 368
 369         restore_signal();
 370
 371         return sd;
 372 }
 373
 374 #else /* !MACINTOSH */
 375
 376         /* サーバにコネクトする関数。 Mac */
 377 {
 378         OSStatus err;
 379         InetHostInfo    response;
 380         InetHost                host_addr;
 381         InetAddress     inAddr;
 382         TCall                   sndCall;
 383         Boolean                 bind    = false;
 384
 385         memset(&response, 0, sizeof(response));
 386
 387 #if TARGET_API_MAC_CARBON
 388         inet_services = OTOpenInternetServicesInContext(kDefaultInternetServicesPath, 0, &err, NULL);
 389 #else
 390         inet_services = OTOpenInternetServices(kDefaultInternetServicesPath, 0, &err);
 391 #endif
 392
 393         if (err == noErr) {
 394
 395                 if (proxy && proxy[0])
 396                 {
 397                         err = OTInetStringToAddress(inet_services, proxy, &response);
 398                 }
 399                 else
 400                 {
 401                         err = OTInetStringToAddress(inet_services, (char *)host, &response);
 402                 }
 403
 404                 if (err == noErr)
 405                 {
 406                         host_addr = response.addrs[0];
 407                 }
 408                 else
 409                 {
 410                         errstr = "error: bad score server!\n";
 411                 }
 412
 413 #if TARGET_API_MAC_CARBON
 414                 ep = (void *)OTOpenEndpointInContext(OTCreateConfiguration(kTCPName), 0, nil, &err, NULL);
 415 #else
 416                 ep = (void *)OTOpenEndpoint(OTCreateConfiguration(kTCPName), 0, nil, &err);
 417 #endif
 418
 419                 if (err == noErr)
 420                 {
 421                         err = OTBind(ep, nil, nil);
 422                         bind = (err == noErr);
 423                 }
 424                 if (err == noErr)
 425                 {
 426                         if (proxy && proxy[0] && proxy_port)
 427                                 OTInitInetAddress(&inAddr, proxy_port, host_addr);
 428                         else
 429                                 OTInitInetAddress(&inAddr, port, host_addr);
 430
 431                         sndCall.addr.len        = sizeof(InetAddress);
 432                         sndCall.addr.buf        = (unsigned char*) &inAddr;
 433                         sndCall.opt.buf         = nil;        /* no connection options */
 434                         sndCall.opt.len         = 0;
 435                         sndCall.udata.buf       = nil;        /* no connection data */
 436                         sndCall.udata.len       = 0;
 437                         sndCall.sequence        = 0;          /* ignored by OTConnect */
 438
 439                         err = OTConnect(ep, &sndCall, NULL);
 440
 441                         if (err != noErr)
 442                         {
 443                                 errstr = "error: cannot connect score server!\n";
 444                         }
 445                 }
 446         }
 447
 448         if ( err != noErr )
 449         {
 450                 if ( bind )
 451                 {
 452                         OTUnbind(ep);
 453                 }
 454                 /* Clean up. */
 455                 if (ep != kOTInvalidEndpointRef)
 456                 {
 457                         OTCloseProvider(ep);
 458                         ep = nil;
 459                 }
 460                 if (inet_services != nil)
 461                 {
 462                         OTCloseProvider(inet_services);
 463                         inet_services = nil;
 464                 }
 465
 466                 return -1;
 467         }
 468
 469         return 1;
 470 }
 471 #endif
 472
 473
 474 int disconnect_server(int sd)
 475 {
 476 #if defined(WINDOWS)
 477         return closesocket(sd);
 478 #elif defined(MACINTOSH)
 479         if (ep != kOTInvalidEndpointRef)
 480         {
 481                 OTCloseProvider(ep);
 482         }
 483
 484         if (inet_services != nil)
 485         {
 486                 OTCloseProvider(inet_services);
 487         }
 488 #else
 489         return close(sd);
 490 #endif
 491 }
 492
 493 cptr soc_err()
 494 {
 495         return errstr;
 496 }
 497
 498 #endif /* WORLD_SCORE */