Annotation of embedaddon/miniupnpd/upnpsoap.c, revision 1.1
1.1 ! misho 1: /* $Id: upnpsoap.c,v 1.66 2011/01/01 20:17:44 nanard Exp $ */
! 2: /* MiniUPnP project
! 3: * http://miniupnp.free.fr/ or http://miniupnp.tuxfamily.org/
! 4: * (c) 2006-2011 Thomas Bernard
! 5: * This software is subject to the conditions detailed
! 6: * in the LICENCE file provided within the distribution */
! 7:
! 8: #include <stdio.h>
! 9: #include <stdlib.h>
! 10: #include <string.h>
! 11: #include <sys/socket.h>
! 12: #include <unistd.h>
! 13: #include <syslog.h>
! 14: #include <sys/types.h>
! 15: #include <arpa/inet.h>
! 16: #include <netinet/in.h>
! 17: #include <netdb.h>
! 18:
! 19: #include "config.h"
! 20: #include "upnpglobalvars.h"
! 21: #include "upnphttp.h"
! 22: #include "upnpsoap.h"
! 23: #include "upnpreplyparse.h"
! 24: #include "upnpredirect.h"
! 25: #include "getifaddr.h"
! 26: #include "getifstats.h"
! 27:
! 28: static void
! 29: BuildSendAndCloseSoapResp(struct upnphttp * h,
! 30: const char * body, int bodylen)
! 31: {
! 32: static const char beforebody[] =
! 33: "<?xml version=\"1.0\"?>\r\n"
! 34: "<s:Envelope xmlns:s=\"http://schemas.xmlsoap.org/soap/envelope/\" "
! 35: "s:encodingStyle=\"http://schemas.xmlsoap.org/soap/encoding/\">"
! 36: "<s:Body>";
! 37:
! 38: static const char afterbody[] =
! 39: "</s:Body>"
! 40: "</s:Envelope>\r\n";
! 41:
! 42: BuildHeader_upnphttp(h, 200, "OK", sizeof(beforebody) - 1
! 43: + sizeof(afterbody) - 1 + bodylen );
! 44:
! 45: memcpy(h->res_buf + h->res_buflen, beforebody, sizeof(beforebody) - 1);
! 46: h->res_buflen += sizeof(beforebody) - 1;
! 47:
! 48: memcpy(h->res_buf + h->res_buflen, body, bodylen);
! 49: h->res_buflen += bodylen;
! 50:
! 51: memcpy(h->res_buf + h->res_buflen, afterbody, sizeof(afterbody) - 1);
! 52: h->res_buflen += sizeof(afterbody) - 1;
! 53:
! 54: SendResp_upnphttp(h);
! 55: CloseSocket_upnphttp(h);
! 56: }
! 57:
! 58: static void
! 59: GetConnectionTypeInfo(struct upnphttp * h, const char * action)
! 60: {
! 61: static const char resp[] =
! 62: "<u:GetConnectionTypeInfoResponse "
! 63: "xmlns:u=\"urn:schemas-upnp-org:service:WANIPConnection:1\">"
! 64: "<NewConnectionType>IP_Routed</NewConnectionType>"
! 65: "<NewPossibleConnectionTypes>IP_Routed</NewPossibleConnectionTypes>"
! 66: "</u:GetConnectionTypeInfoResponse>";
! 67: BuildSendAndCloseSoapResp(h, resp, sizeof(resp)-1);
! 68: }
! 69:
! 70: static void
! 71: GetTotalBytesSent(struct upnphttp * h, const char * action)
! 72: {
! 73: int r;
! 74:
! 75: static const char resp[] =
! 76: "<u:%sResponse "
! 77: "xmlns:u=\"%s\">"
! 78: "<NewTotalBytesSent>%lu</NewTotalBytesSent>"
! 79: "</u:%sResponse>";
! 80:
! 81: char body[512];
! 82: int bodylen;
! 83: struct ifdata data;
! 84:
! 85: r = getifstats(ext_if_name, &data);
! 86: bodylen = snprintf(body, sizeof(body), resp,
! 87: action, "urn:schemas-upnp-org:service:WANCommonInterfaceConfig:1",
! 88: r<0?0:data.obytes, action);
! 89: BuildSendAndCloseSoapResp(h, body, bodylen);
! 90: }
! 91:
! 92: static void
! 93: GetTotalBytesReceived(struct upnphttp * h, const char * action)
! 94: {
! 95: int r;
! 96:
! 97: static const char resp[] =
! 98: "<u:%sResponse "
! 99: "xmlns:u=\"%s\">"
! 100: "<NewTotalBytesReceived>%lu</NewTotalBytesReceived>"
! 101: "</u:%sResponse>";
! 102:
! 103: char body[512];
! 104: int bodylen;
! 105: struct ifdata data;
! 106:
! 107: r = getifstats(ext_if_name, &data);
! 108: bodylen = snprintf(body, sizeof(body), resp,
! 109: action, "urn:schemas-upnp-org:service:WANCommonInterfaceConfig:1",
! 110: r<0?0:data.ibytes, action);
! 111: BuildSendAndCloseSoapResp(h, body, bodylen);
! 112: }
! 113:
! 114: static void
! 115: GetTotalPacketsSent(struct upnphttp * h, const char * action)
! 116: {
! 117: int r;
! 118:
! 119: static const char resp[] =
! 120: "<u:%sResponse "
! 121: "xmlns:u=\"%s\">"
! 122: "<NewTotalPacketsSent>%lu</NewTotalPacketsSent>"
! 123: "</u:%sResponse>";
! 124:
! 125: char body[512];
! 126: int bodylen;
! 127: struct ifdata data;
! 128:
! 129: r = getifstats(ext_if_name, &data);
! 130: bodylen = snprintf(body, sizeof(body), resp,
! 131: action, "urn:schemas-upnp-org:service:WANCommonInterfaceConfig:1",
! 132: r<0?0:data.opackets, action);
! 133: BuildSendAndCloseSoapResp(h, body, bodylen);
! 134: }
! 135:
! 136: static void
! 137: GetTotalPacketsReceived(struct upnphttp * h, const char * action)
! 138: {
! 139: int r;
! 140:
! 141: static const char resp[] =
! 142: "<u:%sResponse "
! 143: "xmlns:u=\"%s\">"
! 144: "<NewTotalPacketsReceived>%lu</NewTotalPacketsReceived>"
! 145: "</u:%sResponse>";
! 146:
! 147: char body[512];
! 148: int bodylen;
! 149: struct ifdata data;
! 150:
! 151: r = getifstats(ext_if_name, &data);
! 152: bodylen = snprintf(body, sizeof(body), resp,
! 153: action, "urn:schemas-upnp-org:service:WANCommonInterfaceConfig:1",
! 154: r<0?0:data.ipackets, action);
! 155: BuildSendAndCloseSoapResp(h, body, bodylen);
! 156: }
! 157:
! 158: static void
! 159: GetCommonLinkProperties(struct upnphttp * h, const char * action)
! 160: {
! 161: /* WANAccessType : set depending on the hardware :
! 162: * DSL, POTS (plain old Telephone service), Cable, Ethernet */
! 163: static const char resp[] =
! 164: "<u:%sResponse "
! 165: "xmlns:u=\"%s\">"
! 166: /*"<NewWANAccessType>DSL</NewWANAccessType>"*/
! 167: "<NewWANAccessType>Cable</NewWANAccessType>"
! 168: "<NewLayer1UpstreamMaxBitRate>%lu</NewLayer1UpstreamMaxBitRate>"
! 169: "<NewLayer1DownstreamMaxBitRate>%lu</NewLayer1DownstreamMaxBitRate>"
! 170: "<NewPhysicalLinkStatus>%s</NewPhysicalLinkStatus>"
! 171: "</u:%sResponse>";
! 172:
! 173: char body[2048];
! 174: int bodylen;
! 175: struct ifdata data;
! 176: const char * status = "Up"; /* Up, Down (Required),
! 177: * Initializing, Unavailable (Optional) */
! 178: char ext_ip_addr[INET_ADDRSTRLEN];
! 179:
! 180: if((downstream_bitrate == 0) || (upstream_bitrate == 0))
! 181: {
! 182: if(getifstats(ext_if_name, &data) >= 0)
! 183: {
! 184: if(downstream_bitrate == 0) downstream_bitrate = data.baudrate;
! 185: if(upstream_bitrate == 0) upstream_bitrate = data.baudrate;
! 186: }
! 187: }
! 188: if(getifaddr(ext_if_name, ext_ip_addr, INET_ADDRSTRLEN) < 0) {
! 189: status = "Down";
! 190: }
! 191: bodylen = snprintf(body, sizeof(body), resp,
! 192: action, "urn:schemas-upnp-org:service:WANCommonInterfaceConfig:1",
! 193: upstream_bitrate, downstream_bitrate,
! 194: status, action);
! 195: BuildSendAndCloseSoapResp(h, body, bodylen);
! 196: }
! 197:
! 198: static void
! 199: GetStatusInfo(struct upnphttp * h, const char * action)
! 200: {
! 201: static const char resp[] =
! 202: "<u:%sResponse "
! 203: "xmlns:u=\"%s\">"
! 204: "<NewConnectionStatus>%s</NewConnectionStatus>"
! 205: "<NewLastConnectionError>ERROR_NONE</NewLastConnectionError>"
! 206: "<NewUptime>%ld</NewUptime>"
! 207: "</u:%sResponse>";
! 208:
! 209: char body[512];
! 210: int bodylen;
! 211: time_t uptime;
! 212: const char * status = "Connected";
! 213: /* ConnectionStatus possible values :
! 214: * Unconfigured, Connecting, Connected, PendingDisconnect,
! 215: * Disconnecting, Disconnected */
! 216: char ext_ip_addr[INET_ADDRSTRLEN];
! 217:
! 218: if(getifaddr(ext_if_name, ext_ip_addr, INET_ADDRSTRLEN) < 0) {
! 219: status = "Disconnected";
! 220: }
! 221: uptime = (time(NULL) - startup_time);
! 222: bodylen = snprintf(body, sizeof(body), resp,
! 223: action, "urn:schemas-upnp-org:service:WANIPConnection:1",
! 224: status, (long)uptime, action);
! 225: BuildSendAndCloseSoapResp(h, body, bodylen);
! 226: }
! 227:
! 228: static void
! 229: GetNATRSIPStatus(struct upnphttp * h, const char * action)
! 230: {
! 231: static const char resp[] =
! 232: "<u:GetNATRSIPStatusResponse "
! 233: "xmlns:u=\"urn:schemas-upnp-org:service:WANIPConnection:1\">"
! 234: "<NewRSIPAvailable>0</NewRSIPAvailable>"
! 235: "<NewNATEnabled>1</NewNATEnabled>"
! 236: "</u:GetNATRSIPStatusResponse>";
! 237: /* 2.2.9. RSIPAvailable
! 238: * This variable indicates if Realm-specific IP (RSIP) is available
! 239: * as a feature on the InternetGatewayDevice. RSIP is being defined
! 240: * in the NAT working group in the IETF to allow host-NATing using
! 241: * a standard set of message exchanges. It also allows end-to-end
! 242: * applications that otherwise break if NAT is introduced
! 243: * (e.g. IPsec-based VPNs).
! 244: * A gateway that does not support RSIP should set this variable to 0. */
! 245: BuildSendAndCloseSoapResp(h, resp, sizeof(resp)-1);
! 246: }
! 247:
! 248: static void
! 249: GetExternalIPAddress(struct upnphttp * h, const char * action)
! 250: {
! 251: static const char resp[] =
! 252: "<u:%sResponse "
! 253: "xmlns:u=\"%s\">"
! 254: "<NewExternalIPAddress>%s</NewExternalIPAddress>"
! 255: "</u:%sResponse>";
! 256:
! 257: char body[512];
! 258: int bodylen;
! 259: char ext_ip_addr[INET_ADDRSTRLEN];
! 260:
! 261: #ifndef MULTIPLE_EXTERNAL_IP
! 262: if(use_ext_ip_addr)
! 263: {
! 264: strncpy(ext_ip_addr, use_ext_ip_addr, INET_ADDRSTRLEN);
! 265: }
! 266: else if(getifaddr(ext_if_name, ext_ip_addr, INET_ADDRSTRLEN) < 0)
! 267: {
! 268: syslog(LOG_ERR, "Failed to get ip address for interface %s",
! 269: ext_if_name);
! 270: strncpy(ext_ip_addr, "0.0.0.0", INET_ADDRSTRLEN);
! 271: }
! 272: #else
! 273: int i;
! 274: strncpy(ext_ip_addr, "0.0.0.0", INET_ADDRSTRLEN);
! 275: for(i = 0; i<n_lan_addr; i++)
! 276: {
! 277: if( (h->clientaddr.s_addr & lan_addr[i].mask.s_addr)
! 278: == (lan_addr[i].addr.s_addr & lan_addr[i].mask.s_addr))
! 279: {
! 280: strncpy(ext_ip_addr, lan_addr[i].ext_ip_str, INET_ADDRSTRLEN);
! 281: break;
! 282: }
! 283: }
! 284: #endif
! 285: bodylen = snprintf(body, sizeof(body), resp,
! 286: action, "urn:schemas-upnp-org:service:WANIPConnection:1",
! 287: ext_ip_addr, action);
! 288: BuildSendAndCloseSoapResp(h, body, bodylen);
! 289: }
! 290:
! 291: static void
! 292: AddPortMapping(struct upnphttp * h, const char * action)
! 293: {
! 294: int r;
! 295:
! 296: static const char resp[] =
! 297: "<u:AddPortMappingResponse "
! 298: "xmlns:u=\"urn:schemas-upnp-org:service:WANIPConnection:1\"/>";
! 299:
! 300: struct NameValueParserData data;
! 301: char * int_ip, * int_port, * ext_port, * protocol, * desc;
! 302: char * leaseduration;
! 303: unsigned short iport, eport;
! 304:
! 305: struct hostent *hp; /* getbyhostname() */
! 306: char ** ptr; /* getbyhostname() */
! 307: struct in_addr result_ip;/*unsigned char result_ip[16];*/ /* inet_pton() */
! 308:
! 309: ParseNameValue(h->req_buf + h->req_contentoff, h->req_contentlen, &data);
! 310: int_ip = GetValueFromNameValueList(&data, "NewInternalClient");
! 311:
! 312: if (!int_ip)
! 313: {
! 314: ClearNameValueList(&data);
! 315: SoapError(h, 402, "Invalid Args");
! 316: return;
! 317: }
! 318:
! 319: /* if ip not valid assume hostname and convert */
! 320: if (inet_pton(AF_INET, int_ip, &result_ip) <= 0)
! 321: {
! 322: hp = gethostbyname(int_ip);
! 323: if(hp && hp->h_addrtype == AF_INET)
! 324: {
! 325: for(ptr = hp->h_addr_list; ptr && *ptr; ptr++)
! 326: {
! 327: int_ip = inet_ntoa(*((struct in_addr *) *ptr));
! 328: result_ip = *((struct in_addr *) *ptr);
! 329: /* TODO : deal with more than one ip per hostname */
! 330: break;
! 331: }
! 332: }
! 333: else
! 334: {
! 335: syslog(LOG_ERR, "Failed to convert hostname '%s' to ip address", int_ip);
! 336: ClearNameValueList(&data);
! 337: SoapError(h, 402, "Invalid Args");
! 338: return;
! 339: }
! 340: }
! 341:
! 342: /* check if NewInternalAddress is the client address */
! 343: if(GETFLAG(SECUREMODEMASK))
! 344: {
! 345: if(h->clientaddr.s_addr != result_ip.s_addr)
! 346: {
! 347: syslog(LOG_INFO, "Client %s tried to redirect port to %s",
! 348: inet_ntoa(h->clientaddr), int_ip);
! 349: ClearNameValueList(&data);
! 350: SoapError(h, 718, "ConflictInMappingEntry");
! 351: return;
! 352: }
! 353: }
! 354:
! 355: int_port = GetValueFromNameValueList(&data, "NewInternalPort");
! 356: ext_port = GetValueFromNameValueList(&data, "NewExternalPort");
! 357: protocol = GetValueFromNameValueList(&data, "NewProtocol");
! 358: desc = GetValueFromNameValueList(&data, "NewPortMappingDescription");
! 359: leaseduration = GetValueFromNameValueList(&data, "NewLeaseDuration");
! 360:
! 361: if (!int_port || !ext_port || !protocol)
! 362: {
! 363: ClearNameValueList(&data);
! 364: SoapError(h, 402, "Invalid Args");
! 365: return;
! 366: }
! 367:
! 368: eport = (unsigned short)atoi(ext_port);
! 369: iport = (unsigned short)atoi(int_port);
! 370:
! 371: if(leaseduration && atoi(leaseduration)) {
! 372: /* at the moment, lease duration is always infinite */
! 373: syslog(LOG_WARNING, "NewLeaseDuration=%s not supported, ignored. (ip=%s, desc='%s')", leaseduration, int_ip, desc);
! 374: }
! 375:
! 376: syslog(LOG_INFO, "%s: ext port %hu to %s:%hu protocol %s for: %s",
! 377: action, eport, int_ip, iport, protocol, desc);
! 378:
! 379: r = upnp_redirect(eport, int_ip, iport, protocol, desc);
! 380:
! 381: ClearNameValueList(&data);
! 382:
! 383: /* possible error codes for AddPortMapping :
! 384: * 402 - Invalid Args
! 385: * 501 - Action Failed
! 386: * 715 - Wildcard not permited in SrcAddr
! 387: * 716 - Wildcard not permited in ExtPort
! 388: * 718 - ConflictInMappingEntry
! 389: * 724 - SamePortValuesRequired
! 390: * 725 - OnlyPermanentLeasesSupported
! 391: The NAT implementation only supports permanent lease times on
! 392: port mappings
! 393: * 726 - RemoteHostOnlySupportsWildcard
! 394: RemoteHost must be a wildcard and cannot be a specific IP
! 395: address or DNS name
! 396: * 727 - ExternalPortOnlySupportsWildcard
! 397: ExternalPort must be a wildcard and cannot be a specific port
! 398: value
! 399: * 728 - NoPortMapsAvailable
! 400: There are not enough free prots available to complete the mapping
! 401: (added in IGD v2) */
! 402: switch(r)
! 403: {
! 404: case 0: /* success */
! 405: BuildSendAndCloseSoapResp(h, resp, sizeof(resp)-1);
! 406: break;
! 407: case -2: /* already redirected */
! 408: case -3: /* not permitted */
! 409: SoapError(h, 718, "ConflictInMappingEntry");
! 410: break;
! 411: default:
! 412: SoapError(h, 501, "ActionFailed");
! 413: }
! 414: }
! 415:
! 416: /* AddAnyPortMapping was added in WANIPConnection v2 */
! 417: static void
! 418: AddAnyPortMapping(struct upnphttp * h, const char * action)
! 419: {
! 420: int r;
! 421: static const char resp[] =
! 422: "<u:%sResponse "
! 423: "xmlns:u=\"%s\">"
! 424: "<NewReservedPort>%hu</NewReservedPort>"
! 425: "</u:%sResponse>";
! 426:
! 427: char body[512];
! 428: int bodylen;
! 429:
! 430: struct NameValueParserData data;
! 431: const char * int_ip, * int_port, * ext_port, * protocol, * desc;
! 432: const char * r_host;
! 433: unsigned short iport, eport;
! 434: unsigned int leaseduration;
! 435:
! 436: struct hostent *hp; /* getbyhostname() */
! 437: char ** ptr; /* getbyhostname() */
! 438: struct in_addr result_ip;/*unsigned char result_ip[16];*/ /* inet_pton() */
! 439:
! 440: ParseNameValue(h->req_buf + h->req_contentoff, h->req_contentlen, &data);
! 441: r_host = GetValueFromNameValueList(&data, "NewRemoteHost");
! 442: ext_port = GetValueFromNameValueList(&data, "NewExternalPort");
! 443: protocol = GetValueFromNameValueList(&data, "NewProtocol");
! 444: int_port = GetValueFromNameValueList(&data, "NewInternalPort");
! 445: int_ip = GetValueFromNameValueList(&data, "NewInternalClient");
! 446: /* NewEnabled */
! 447: desc = GetValueFromNameValueList(&data, "NewPortMappingDescription");
! 448: leaseduration = atoi(GetValueFromNameValueList(&data, "NewLeaseDuration"));
! 449: if(leaseduration == 0)
! 450: leaseduration = 604800;
! 451:
! 452: eport = (unsigned short)atoi(ext_port);
! 453: iport = (unsigned short)atoi(int_port);
! 454:
! 455: if (!int_ip)
! 456: {
! 457: ClearNameValueList(&data);
! 458: SoapError(h, 402, "Invalid Args");
! 459: return;
! 460: }
! 461:
! 462: /* if ip not valid assume hostname and convert */
! 463: if (inet_pton(AF_INET, int_ip, &result_ip) <= 0)
! 464: {
! 465: hp = gethostbyname(int_ip);
! 466: if(hp && hp->h_addrtype == AF_INET)
! 467: {
! 468: for(ptr = hp->h_addr_list; ptr && *ptr; ptr++)
! 469: {
! 470: int_ip = inet_ntoa(*((struct in_addr *) *ptr));
! 471: result_ip = *((struct in_addr *) *ptr);
! 472: /* TODO : deal with more than one ip per hostname */
! 473: break;
! 474: }
! 475: }
! 476: else
! 477: {
! 478: syslog(LOG_ERR, "Failed to convert hostname '%s' to ip address", int_ip);
! 479: ClearNameValueList(&data);
! 480: SoapError(h, 402, "Invalid Args");
! 481: return;
! 482: }
! 483: }
! 484:
! 485: /* check if NewInternalAddress is the client address */
! 486: if(GETFLAG(SECUREMODEMASK))
! 487: {
! 488: if(h->clientaddr.s_addr != result_ip.s_addr)
! 489: {
! 490: syslog(LOG_INFO, "Client %s tried to redirect port to %s",
! 491: inet_ntoa(h->clientaddr), int_ip);
! 492: ClearNameValueList(&data);
! 493: SoapError(h, 606, "Action not authorized");
! 494: return;
! 495: }
! 496: }
! 497:
! 498: /* TODO : accept a different external port */
! 499: r = upnp_redirect(eport, int_ip, iport, protocol, desc);
! 500:
! 501: ClearNameValueList(&data);
! 502:
! 503: switch(r)
! 504: {
! 505: case 0: /* success */
! 506: bodylen = snprintf(body, sizeof(body), resp,
! 507: action, "urn:schemas-upnp-org:service:WANIPConnection:2",
! 508: eport, action);
! 509: BuildSendAndCloseSoapResp(h, body, bodylen);
! 510: break;
! 511: case -2: /* already redirected */
! 512: SoapError(h, 718, "ConflictInMappingEntry");
! 513: break;
! 514: case -3: /* not permitted */
! 515: SoapError(h, 606, "Action not authorized");
! 516: break;
! 517: default:
! 518: SoapError(h, 501, "ActionFailed");
! 519: }
! 520: }
! 521:
! 522: static void
! 523: GetSpecificPortMappingEntry(struct upnphttp * h, const char * action)
! 524: {
! 525: int r;
! 526:
! 527: static const char resp[] =
! 528: "<u:%sResponse "
! 529: "xmlns:u=\"%s\">"
! 530: "<NewInternalPort>%u</NewInternalPort>"
! 531: "<NewInternalClient>%s</NewInternalClient>"
! 532: "<NewEnabled>1</NewEnabled>"
! 533: "<NewPortMappingDescription>%s</NewPortMappingDescription>"
! 534: "<NewLeaseDuration>0</NewLeaseDuration>"
! 535: "</u:%sResponse>";
! 536:
! 537: char body[1024];
! 538: int bodylen;
! 539: struct NameValueParserData data;
! 540: const char * r_host, * ext_port, * protocol;
! 541: unsigned short eport, iport;
! 542: char int_ip[32];
! 543: char desc[64];
! 544:
! 545: ParseNameValue(h->req_buf + h->req_contentoff, h->req_contentlen, &data);
! 546: r_host = GetValueFromNameValueList(&data, "NewRemoteHost");
! 547: ext_port = GetValueFromNameValueList(&data, "NewExternalPort");
! 548: protocol = GetValueFromNameValueList(&data, "NewProtocol");
! 549:
! 550: if(!ext_port || !protocol)
! 551: {
! 552: ClearNameValueList(&data);
! 553: SoapError(h, 402, "Invalid Args");
! 554: return;
! 555: }
! 556:
! 557: eport = (unsigned short)atoi(ext_port);
! 558:
! 559: r = upnp_get_redirection_infos(eport, protocol, &iport,
! 560: int_ip, sizeof(int_ip),
! 561: desc, sizeof(desc));
! 562:
! 563: if(r < 0)
! 564: {
! 565: SoapError(h, 714, "NoSuchEntryInArray");
! 566: }
! 567: else
! 568: {
! 569: syslog(LOG_INFO, "%s: rhost='%s' %s %s found => %s:%u desc='%s'",
! 570: action,
! 571: r_host, ext_port, protocol, int_ip, (unsigned int)iport, desc);
! 572: bodylen = snprintf(body, sizeof(body), resp,
! 573: action, "urn:schemas-upnp-org:service:WANIPConnection:1",
! 574: (unsigned int)iport, int_ip, desc,
! 575: action);
! 576: BuildSendAndCloseSoapResp(h, body, bodylen);
! 577: }
! 578:
! 579: ClearNameValueList(&data);
! 580: }
! 581:
! 582: static void
! 583: DeletePortMapping(struct upnphttp * h, const char * action)
! 584: {
! 585: int r;
! 586:
! 587: static const char resp[] =
! 588: "<u:DeletePortMappingResponse "
! 589: "xmlns:u=\"urn:schemas-upnp-org:service:WANIPConnection:1\">"
! 590: "</u:DeletePortMappingResponse>";
! 591:
! 592: struct NameValueParserData data;
! 593: const char * r_host, * ext_port, * protocol;
! 594: unsigned short eport;
! 595:
! 596: ParseNameValue(h->req_buf + h->req_contentoff, h->req_contentlen, &data);
! 597: r_host = GetValueFromNameValueList(&data, "NewRemoteHost");
! 598: ext_port = GetValueFromNameValueList(&data, "NewExternalPort");
! 599: protocol = GetValueFromNameValueList(&data, "NewProtocol");
! 600:
! 601: if(!ext_port || !protocol)
! 602: {
! 603: ClearNameValueList(&data);
! 604: SoapError(h, 402, "Invalid Args");
! 605: return;
! 606: }
! 607:
! 608: eport = (unsigned short)atoi(ext_port);
! 609:
! 610: /* TODO : if in secure mode, check the IP */
! 611:
! 612: syslog(LOG_INFO, "%s: external port: %hu, protocol: %s",
! 613: action, eport, protocol);
! 614:
! 615: r = upnp_delete_redirection(eport, protocol);
! 616:
! 617: if(r < 0)
! 618: {
! 619: SoapError(h, 714, "NoSuchEntryInArray");
! 620: }
! 621: else
! 622: {
! 623: BuildSendAndCloseSoapResp(h, resp, sizeof(resp)-1);
! 624: }
! 625:
! 626: ClearNameValueList(&data);
! 627: }
! 628:
! 629: /* DeletePortMappingRange was added in IGD spec v2 */
! 630: static void
! 631: DeletePortMappingRange(struct upnphttp * h, const char * action)
! 632: {
! 633: static const char resp[] =
! 634: "<u:DeletePortMappingRangeResponse "
! 635: "xmlns:u=\"urn:schemas-upnp-org:service:WANIPConnection:2\">"
! 636: "</u:DeletePortMappingRangeResponse>";
! 637: struct NameValueParserData data;
! 638: const char * protocol;
! 639: unsigned short startport, endport;
! 640: int manage;
! 641:
! 642: ParseNameValue(h->req_buf + h->req_contentoff, h->req_contentlen, &data);
! 643: startport = (unsigned short)atoi(GetValueFromNameValueList(&data, "NewStartPort"));
! 644: endport = (unsigned short)atoi(GetValueFromNameValueList(&data, "NewEndPort"));
! 645: protocol = GetValueFromNameValueList(&data, "NewProtocol");
! 646: manage = atoi(GetValueFromNameValueList(&data, "NewManage"));
! 647:
! 648: /* TODO : implement the method ! */
! 649:
! 650: /* possible errors :
! 651: 606 - Action not authorized
! 652: 730 - PortMappingNotFound
! 653: 733 - InconsistentParameter
! 654: */
! 655: BuildSendAndCloseSoapResp(h, resp, sizeof(resp)-1);
! 656:
! 657: ClearNameValueList(&data);
! 658: }
! 659:
! 660: static void
! 661: GetGenericPortMappingEntry(struct upnphttp * h, const char * action)
! 662: {
! 663: int r;
! 664:
! 665: static const char resp[] =
! 666: "<u:%sResponse "
! 667: "xmlns:u=\"%s\">"
! 668: "<NewRemoteHost></NewRemoteHost>"
! 669: "<NewExternalPort>%u</NewExternalPort>"
! 670: "<NewProtocol>%s</NewProtocol>"
! 671: "<NewInternalPort>%u</NewInternalPort>"
! 672: "<NewInternalClient>%s</NewInternalClient>"
! 673: "<NewEnabled>1</NewEnabled>"
! 674: "<NewPortMappingDescription>%s</NewPortMappingDescription>"
! 675: "<NewLeaseDuration>0</NewLeaseDuration>"
! 676: "</u:%sResponse>";
! 677:
! 678: int index = 0;
! 679: unsigned short eport, iport;
! 680: const char * m_index;
! 681: char protocol[4], iaddr[32];
! 682: char desc[64];
! 683: struct NameValueParserData data;
! 684:
! 685: ParseNameValue(h->req_buf + h->req_contentoff, h->req_contentlen, &data);
! 686: m_index = GetValueFromNameValueList(&data, "NewPortMappingIndex");
! 687:
! 688: if(!m_index)
! 689: {
! 690: ClearNameValueList(&data);
! 691: SoapError(h, 402, "Invalid Args");
! 692: return;
! 693: }
! 694:
! 695: index = (int)atoi(m_index);
! 696:
! 697: syslog(LOG_INFO, "%s: index=%d", action, index);
! 698:
! 699: r = upnp_get_redirection_infos_by_index(index, &eport, protocol, &iport,
! 700: iaddr, sizeof(iaddr),
! 701: desc, sizeof(desc));
! 702:
! 703: if(r < 0)
! 704: {
! 705: SoapError(h, 713, "SpecifiedArrayIndexInvalid");
! 706: }
! 707: else
! 708: {
! 709: int bodylen;
! 710: char body[2048];
! 711: bodylen = snprintf(body, sizeof(body), resp,
! 712: action, "urn:schemas-upnp-org:service:WANIPConnection:1",
! 713: (unsigned int)eport, protocol, (unsigned int)iport, iaddr, desc,
! 714: action);
! 715: BuildSendAndCloseSoapResp(h, body, bodylen);
! 716: }
! 717:
! 718: ClearNameValueList(&data);
! 719: }
! 720:
! 721: /* GetListOfPortMappings was added in the IGD v2 specification */
! 722: static void
! 723: GetListOfPortMappings(struct upnphttp * h, const char * action)
! 724: {
! 725: static const char resp[] =
! 726: "<u:%sResponse "
! 727: "xmlns:u=\"%s\">"
! 728: "<NewPortListing><![CDATA[%s]]</NewPortListing>"
! 729: "</u:%sResponse>";
! 730:
! 731: char body[512];
! 732: int bodylen;
! 733:
! 734: struct NameValueParserData data;
! 735: unsigned short startport, endport;
! 736: const char * protocol;
! 737: int manage;
! 738: int number;
! 739:
! 740: ParseNameValue(h->req_buf + h->req_contentoff, h->req_contentlen, &data);
! 741: startport = (unsigned short)atoi(GetValueFromNameValueList(&data, "NewStartPort"));
! 742: endport = (unsigned short)atoi(GetValueFromNameValueList(&data, "NewEndPort"));
! 743: protocol = GetValueFromNameValueList(&data, "NewProtocol");
! 744: manage = atoi(GetValueFromNameValueList(&data, "NewManage"));
! 745: number = atoi(GetValueFromNameValueList(&data, "NewNumberOfPorts"));
! 746:
! 747: /*
! 748: TODO : build the PortMappingList xml document :
! 749:
! 750: <p:PortMappingList xmlns:p="urn:schemas-upnp-org:gw:WANIPConnection"
! 751: xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
! 752: xsi:schemaLocation="urn:schemas-upnp-org:gw:WANIPConnection
! 753: http://www.upnp.org/schemas/gw/WANIPConnection-v2.xsd">
! 754: <p:PortMappingEntry>
! 755: <p:NewRemoteHost>202.233.2.1</p:NewRemoteHost>
! 756: <p:NewExternalPort>2345</p:NewExternalPort>
! 757: <p:NewProtocol>TCP</p:NewProtocol>
! 758: <p:NewInternalPort>2345</p:NewInternalPort>
! 759: <p:NewInternalClient>192.168.1.137</p:NewInternalClient>
! 760: <p:NewEnabled>1</p:NewEnabled>
! 761: <p:NewDescription>dooom</p:NewDescription>
! 762: <p:NewLeaseTime>345</p:NewLeaseTime>
! 763: </p:PortMappingEntry>
! 764: </p:PortMappingList>
! 765: */
! 766: bodylen = snprintf(body, sizeof(body), resp,
! 767: action, "urn:schemas-upnp-org:service:WANIPConnection:2",
! 768: "", action);
! 769: BuildSendAndCloseSoapResp(h, body, bodylen);
! 770:
! 771: ClearNameValueList(&data);
! 772: }
! 773:
! 774: #ifdef ENABLE_L3F_SERVICE
! 775: static void
! 776: SetDefaultConnectionService(struct upnphttp * h, const char * action)
! 777: {
! 778: static const char resp[] =
! 779: "<u:SetDefaultConnectionServiceResponse "
! 780: "xmlns:u=\"urn:schemas-upnp-org:service:Layer3Forwarding:1\">"
! 781: "</u:SetDefaultConnectionServiceResponse>";
! 782: struct NameValueParserData data;
! 783: char * p;
! 784: ParseNameValue(h->req_buf + h->req_contentoff, h->req_contentlen, &data);
! 785: p = GetValueFromNameValueList(&data, "NewDefaultConnectionService");
! 786: if(p) {
! 787: syslog(LOG_INFO, "%s(%s) : Ignored", action, p);
! 788: }
! 789: ClearNameValueList(&data);
! 790: BuildSendAndCloseSoapResp(h, resp, sizeof(resp)-1);
! 791: }
! 792:
! 793: static void
! 794: GetDefaultConnectionService(struct upnphttp * h, const char * action)
! 795: {
! 796: static const char resp[] =
! 797: "<u:%sResponse "
! 798: "xmlns:u=\"urn:schemas-upnp-org:service:Layer3Forwarding:1\">"
! 799: "<NewDefaultConnectionService>%s:WANConnectionDevice:1,"
! 800: "urn:upnp-org:serviceId:WANIPConn1</NewDefaultConnectionService>"
! 801: "</u:%sResponse>";
! 802: /* example from UPnP_IGD_Layer3Forwarding 1.0.pdf :
! 803: * uuid:44f5824f-c57d-418c-a131-f22b34e14111:WANConnectionDevice:1,
! 804: * urn:upnp-org:serviceId:WANPPPConn1 */
! 805: char body[1024];
! 806: int bodylen;
! 807:
! 808: bodylen = snprintf(body, sizeof(body), resp,
! 809: action, uuidvalue, action);
! 810: BuildSendAndCloseSoapResp(h, body, bodylen);
! 811: }
! 812: #endif
! 813:
! 814: /* Added for compliance with WANIPConnection v2 */
! 815: static void
! 816: SetConnectionType(struct upnphttp * h, const char * action)
! 817: {
! 818: const char * connection_type;
! 819: struct NameValueParserData data;
! 820:
! 821: ParseNameValue(h->req_buf + h->req_contentoff, h->req_contentlen, &data);
! 822: connection_type = GetValueFromNameValueList(&data, "NewConnectionType");
! 823: /* Unconfigured, IP_Routed, IP_Bridged */
! 824: ClearNameValueList(&data);
! 825: /* always return a ReadOnly error */
! 826: SoapError(h, 731, "ReadOnly");
! 827: }
! 828:
! 829: /* Added for compliance with WANIPConnection v2 */
! 830: static void
! 831: RequestConnection(struct upnphttp * h, const char * action)
! 832: {
! 833: SoapError(h, 606, "Action not authorized");
! 834: }
! 835:
! 836: /* Added for compliance with WANIPConnection v2 */
! 837: static void
! 838: ForceTermination(struct upnphttp * h, const char * action)
! 839: {
! 840: SoapError(h, 606, "Action not authorized");
! 841: }
! 842:
! 843: /*
! 844: If a control point calls QueryStateVariable on a state variable that is not
! 845: buffered in memory within (or otherwise available from) the service,
! 846: the service must return a SOAP fault with an errorCode of 404 Invalid Var.
! 847:
! 848: QueryStateVariable remains useful as a limited test tool but may not be
! 849: part of some future versions of UPnP.
! 850: */
! 851: static void
! 852: QueryStateVariable(struct upnphttp * h, const char * action)
! 853: {
! 854: static const char resp[] =
! 855: "<u:%sResponse "
! 856: "xmlns:u=\"%s\">"
! 857: "<return>%s</return>"
! 858: "</u:%sResponse>";
! 859:
! 860: char body[512];
! 861: int bodylen;
! 862: struct NameValueParserData data;
! 863: const char * var_name;
! 864:
! 865: ParseNameValue(h->req_buf + h->req_contentoff, h->req_contentlen, &data);
! 866: /*var_name = GetValueFromNameValueList(&data, "QueryStateVariable"); */
! 867: /*var_name = GetValueFromNameValueListIgnoreNS(&data, "varName");*/
! 868: var_name = GetValueFromNameValueList(&data, "varName");
! 869:
! 870: /*syslog(LOG_INFO, "QueryStateVariable(%.40s)", var_name); */
! 871:
! 872: if(!var_name)
! 873: {
! 874: SoapError(h, 402, "Invalid Args");
! 875: }
! 876: else if(strcmp(var_name, "ConnectionStatus") == 0)
! 877: {
! 878: const char * status = "Connected";
! 879: char ext_ip_addr[INET_ADDRSTRLEN];
! 880: if(getifaddr(ext_if_name, ext_ip_addr, INET_ADDRSTRLEN) < 0) {
! 881: status = "Disconnected";
! 882: }
! 883: bodylen = snprintf(body, sizeof(body), resp,
! 884: action, "urn:schemas-upnp-org:control-1-0",
! 885: status, action);
! 886: BuildSendAndCloseSoapResp(h, body, bodylen);
! 887: }
! 888: #if 0
! 889: /* not usefull */
! 890: else if(strcmp(var_name, "ConnectionType") == 0)
! 891: {
! 892: bodylen = snprintf(body, sizeof(body), resp, "IP_Routed");
! 893: BuildSendAndCloseSoapResp(h, body, bodylen);
! 894: }
! 895: else if(strcmp(var_name, "LastConnectionError") == 0)
! 896: {
! 897: bodylen = snprintf(body, sizeof(body), resp, "ERROR_NONE");
! 898: BuildSendAndCloseSoapResp(h, body, bodylen);
! 899: }
! 900: #endif
! 901: else if(strcmp(var_name, "PortMappingNumberOfEntries") == 0)
! 902: {
! 903: char strn[10];
! 904: snprintf(strn, sizeof(strn), "%i",
! 905: upnp_get_portmapping_number_of_entries());
! 906: bodylen = snprintf(body, sizeof(body), resp,
! 907: action, "urn:schemas-upnp-org:control-1-0",
! 908: strn, action);
! 909: BuildSendAndCloseSoapResp(h, body, bodylen);
! 910: }
! 911: else
! 912: {
! 913: syslog(LOG_NOTICE, "%s: Unknown: %s", action, var_name?var_name:"");
! 914: SoapError(h, 404, "Invalid Var");
! 915: }
! 916:
! 917: ClearNameValueList(&data);
! 918: }
! 919:
! 920: /* Windows XP as client send the following requests :
! 921: * GetConnectionTypeInfo
! 922: * GetNATRSIPStatus
! 923: * ? GetTotalBytesSent - WANCommonInterfaceConfig
! 924: * ? GetTotalBytesReceived - idem
! 925: * ? GetTotalPacketsSent - idem
! 926: * ? GetTotalPacketsReceived - idem
! 927: * GetCommonLinkProperties - idem
! 928: * GetStatusInfo - WANIPConnection
! 929: * GetExternalIPAddress
! 930: * QueryStateVariable / ConnectionStatus!
! 931: */
! 932: static const struct
! 933: {
! 934: const char * methodName;
! 935: void (*methodImpl)(struct upnphttp *, const char *);
! 936: }
! 937: soapMethods[] =
! 938: {
! 939: { "GetConnectionTypeInfo", GetConnectionTypeInfo },
! 940: { "GetNATRSIPStatus", GetNATRSIPStatus},
! 941: { "GetExternalIPAddress", GetExternalIPAddress},
! 942: { "AddPortMapping", AddPortMapping},
! 943: { "DeletePortMapping", DeletePortMapping},
! 944: { "GetGenericPortMappingEntry", GetGenericPortMappingEntry},
! 945: { "GetSpecificPortMappingEntry", GetSpecificPortMappingEntry},
! 946: { "QueryStateVariable", QueryStateVariable},
! 947: { "GetTotalBytesSent", GetTotalBytesSent},
! 948: { "GetTotalBytesReceived", GetTotalBytesReceived},
! 949: { "GetTotalPacketsSent", GetTotalPacketsSent},
! 950: { "GetTotalPacketsReceived", GetTotalPacketsReceived},
! 951: { "GetCommonLinkProperties", GetCommonLinkProperties},
! 952: { "GetStatusInfo", GetStatusInfo},
! 953: /* Required in WANIPConnection:2 */
! 954: { "SetConnectionType", SetConnectionType},
! 955: { "RequestConnection", RequestConnection},
! 956: { "ForceTermination", ForceTermination},
! 957: { "AddAnyPortMapping", AddAnyPortMapping},
! 958: { "DeletePortMappingRange", DeletePortMappingRange},
! 959: { "GetListOfPortMappings", GetListOfPortMappings},
! 960: #ifdef ENABLE_L3F_SERVICE
! 961: { "SetDefaultConnectionService", SetDefaultConnectionService},
! 962: { "GetDefaultConnectionService", GetDefaultConnectionService},
! 963: #endif
! 964: { 0, 0 }
! 965: };
! 966:
! 967: void
! 968: ExecuteSoapAction(struct upnphttp * h, const char * action, int n)
! 969: {
! 970: char * p;
! 971: char * p2;
! 972: int i, len, methodlen;
! 973:
! 974: i = 0;
! 975: p = strchr(action, '#');
! 976:
! 977: if(p)
! 978: {
! 979: p++;
! 980: p2 = strchr(p, '"');
! 981: if(p2)
! 982: methodlen = p2 - p;
! 983: else
! 984: methodlen = n - (p - action);
! 985: /*syslog(LOG_DEBUG, "SoapMethod: %.*s", methodlen, p);*/
! 986: while(soapMethods[i].methodName)
! 987: {
! 988: len = strlen(soapMethods[i].methodName);
! 989: if(strncmp(p, soapMethods[i].methodName, len) == 0)
! 990: {
! 991: soapMethods[i].methodImpl(h, soapMethods[i].methodName);
! 992: return;
! 993: }
! 994: i++;
! 995: }
! 996:
! 997: syslog(LOG_NOTICE, "SoapMethod: Unknown: %.*s", methodlen, p);
! 998: }
! 999:
! 1000: SoapError(h, 401, "Invalid Action");
! 1001: }
! 1002:
! 1003: /* Standard Errors:
! 1004: *
! 1005: * errorCode errorDescription Description
! 1006: * -------- ---------------- -----------
! 1007: * 401 Invalid Action No action by that name at this service.
! 1008: * 402 Invalid Args Could be any of the following: not enough in args,
! 1009: * too many in args, no in arg by that name,
! 1010: * one or more in args are of the wrong data type.
! 1011: * 403 Out of Sync Out of synchronization.
! 1012: * 501 Action Failed May be returned in current state of service
! 1013: * prevents invoking that action.
! 1014: * 600-699 TBD Common action errors. Defined by UPnP Forum
! 1015: * Technical Committee.
! 1016: * 700-799 TBD Action-specific errors for standard actions.
! 1017: * Defined by UPnP Forum working committee.
! 1018: * 800-899 TBD Action-specific errors for non-standard actions.
! 1019: * Defined by UPnP vendor.
! 1020: */
! 1021: void
! 1022: SoapError(struct upnphttp * h, int errCode, const char * errDesc)
! 1023: {
! 1024: static const char resp[] =
! 1025: "<s:Envelope "
! 1026: "xmlns:s=\"http://schemas.xmlsoap.org/soap/envelope/\" "
! 1027: "s:encodingStyle=\"http://schemas.xmlsoap.org/soap/encoding/\">"
! 1028: "<s:Body>"
! 1029: "<s:Fault>"
! 1030: "<faultcode>s:Client</faultcode>"
! 1031: "<faultstring>UPnPError</faultstring>"
! 1032: "<detail>"
! 1033: "<UPnPError xmlns=\"urn:schemas-upnp-org:control-1-0\">"
! 1034: "<errorCode>%d</errorCode>"
! 1035: "<errorDescription>%s</errorDescription>"
! 1036: "</UPnPError>"
! 1037: "</detail>"
! 1038: "</s:Fault>"
! 1039: "</s:Body>"
! 1040: "</s:Envelope>";
! 1041:
! 1042: char body[2048];
! 1043: int bodylen;
! 1044:
! 1045: syslog(LOG_INFO, "Returning UPnPError %d: %s", errCode, errDesc);
! 1046: bodylen = snprintf(body, sizeof(body), resp, errCode, errDesc);
! 1047: BuildResp2_upnphttp(h, 500, "Internal Server Error", body, bodylen);
! 1048: SendResp_upnphttp(h);
! 1049: CloseSocket_upnphttp(h);
! 1050: }
! 1051:
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>
![[BACK]](/icons/cvsweb/back.gif){kind=icon}
Return to upnpsoap.c CVS log ![[TXT]](/icons/cvsweb/text.gif){kind=icon}
![[DIR]](/icons/cvsweb/dir.gif){kind=icon}
Up to [ELWIX - Embedded LightWeight unIX -] / embedaddon / miniupnpd