/* Project : miniupnp

* Author : Thomas Bernard

* This software is subject to the conditions detailed in the

* LICENCE file provided in this distribution. */

#include <stdio.h>

#include <stdlib.h>

#include <string.h>

#include <time.h>

#include <winsock2.h>

#define snprintf _snprintf

#endif

#include "miniwget.h"

#include "miniupnpc.h"

#include "upnpcommands.h"

#include "upnperrors.h"

* returns NULL if not */

const char * protofix(const char * proto)

{

static const char proto_tcp[4] = { 'T', 'C', 'P', 0};

static const char proto_udp[4] = { 'U', 'D', 'P', 0};

int i, b;

for(i=0, b=1; i<4; i++)

|| (proto[i] == (proto_tcp[i] | 32)) );

if(b)

return proto_tcp;

for(i=0, b=1; i<4; i++)

b = b && ( (proto[i] == proto_udp[i])

|| (proto[i] == (proto_udp[i] | 32)) );

char status[64];

char lastconnerr[64];

unsigned int uptime;

unsigned int brUp, brDown;

time_t timenow, timestarted;

int r;

printf("Connection Type : %s\n", connectionType);

else

timenow = time(NULL);

timestarted = timenow - uptime;

printf(" Time started : %s", ctime(&timestarted));

}

r = UPNP_GetExternalIPAddress(urls->controlURL,

data->first.servicetype,

externalIPAddress);

printf("ExternalIPAddress = %s\n", externalIPAddress);

}

static void GetConnectionStatus(struct UPNPUrls * urls,

struct IGDdatas * data)

{

unsigned int bytessent, bytesreceived, packetsreceived, packetssent;

char enabled[6];

char rHost[64];

char duration[16];

/*unsigned int num=0;

UPNP_GetPortMappingNumberOfEntries(urls->controlURL, data->servicetype, &num);

printf("PortMappingNumberOfEntries : %u\n", num);*/

do {

snprintf(index, 6, "%d", i);

rHost[0] = '\0'; enabled[0] = '\0';

duration[0] = '\0'; desc[0] = '\0';

extPort[0] = '\0'; intPort[0] = '\0'; intClient[0] = '\0';

r = UPNP_GetGenericPortMappingEntry(urls->controlURL,

"65535",

"TCP",

"1000",

&pdata);

if(r == UPNPCOMMAND_SUCCESS)

{

for(pm = pdata.head.lh_first; pm != NULL; pm = pm->entries.le_next)

{

printf("%2d %s %5hu->%s:%-5hu '%s' '%s' %u\n",

i, pm->protocol, pm->externalPort, pm->internalClient,

pm->internalPort,

pm->description, pm->remoteHost,

{

printf("GetListOfPortMappings() returned %d (%s)\n",

r, strupnperror(r));

}

}

* 1 - get connection type

* 2 - get extenal ip address

* 3 - Add port mapping

* 4 - get this port mapping from the IGD */

static void SetRedirectAndTest(struct UPNPUrls * urls,

struct IGDdatas * data,

const char * iaddr,

const char * iport,

const char * eport,

const char * proto,

{

char externalIPAddress[40];

char intClient[40];

char intPort[6];

char duration[16];

int r;

proto = protofix(proto);

if(!proto)

{

fprintf(stderr, "invalid protocol\n");

return;

}

UPNP_GetExternalIPAddress(urls->controlURL,

data->first.servicetype,

externalIPAddress);

if(externalIPAddress[0])

printf("ExternalIPAddress = %s\n", externalIPAddress);

else

printf("GetExternalIPAddress failed.\n");

r = UPNP_AddPortMapping(urls->controlURL, data->first.servicetype,

if(r!=UPNPCOMMAND_SUCCESS)

printf("AddPortMapping(%s, %s, %s) failed with code %d (%s)\n",

eport, iport, iaddr, r, strupnperror(r));

r = UPNP_GetSpecificPortMappingEntry(urls->controlURL,

data->first.servicetype,

intClient, intPort, NULL/*desc*/,

NULL/*enabled*/, duration);

if(r!=UPNPCOMMAND_SUCCESS)

printf("GetSpecificPortMappingEntry() failed with code %d (%s)\n",

r, strupnperror(r));

if(intClient[0]) {

printf("InternalIP:Port = %s:%s\n", intClient, intPort);

printf("external %s:%s %s is redirected to internal %s:%s (duration=%s)\n",

externalIPAddress, eport, proto, intClient, intPort, duration);

}

}

unsigned int bytessent, bytesreceived, packetsreceived, packetssent;

int firewallEnabled = 0, inboundPinholeAllowed = 0;

UPNP_GetFirewallStatus(urls->controlURL_6FC, data->IPv6FC.servicetype, &firewallEnabled, &inboundPinholeAllowed);

printf("FirewallEnabled: %d & Inbound Pinhole Allowed: %d\n", firewallEnabled, inboundPinholeAllowed);

printf("GetFirewallStatus:\n Firewall Enabled: %s\n Inbound Pinhole Allowed: %s\n", (firewallEnabled)? "Yes":"No", (inboundPinholeAllowed)? "Yes":"No");

bytessent = UPNP_GetTotalBytesSent(urls->controlURL_CIF, data->CIF.servicetype);

bytesreceived = UPNP_GetTotalBytesReceived(urls->controlURL_CIF, data->CIF.servicetype);

packetssent = UPNP_GetTotalPacketsSent(urls->controlURL_CIF, data->CIF.servicetype);

packetsreceived = UPNP_GetTotalPacketsReceived(urls->controlURL_CIF, data->CIF.servicetype);

printf("Bytes: Sent: %8u\tRecv: %8u\n", bytessent, bytesreceived);

printf("Packets: Sent: %8u\tRecv: %8u\n", packetssent, packetsreceived);

}

* 1 - Add pinhole

* 2 - Check if pinhole is working from the IGD side */

static void SetPinholeAndTest(struct UPNPUrls * urls, struct IGDdatas * data,

const char * remoteaddr, const char * eport,

const char * intaddr, const char * iport,

const char * proto, const char * lease_time)

{

char uniqueID[8];

int r;

if(!intaddr || !remoteaddr || !iport || !eport || !proto || !lease_time)

{

fprintf(stderr, "Wrong arguments\n");

return;

}

{

r = UPNP_AddPinhole(urls->controlURL_6FC, data->IPv6FC.servicetype, remoteaddr, eport, intaddr, iport, proto, lease_time, uniqueID);

if(r!=UPNPCOMMAND_SUCCESS)

printf("AddPinhole([%s]:%s -> [%s]:%s) failed with code %d (%s)\n",

else

{

/*r = UPNP_CheckPinholeWorking(urls->controlURL_6FC, data->servicetype_6FC, uniqueID, &isWorking);

if(r!=UPNPCOMMAND_SUCCESS)

printf("CheckPinholeWorking() failed with code %d (%s)\n", r, strupnperror(r));

printf("CheckPinholeWorking: Pinhole ID = %s / IsWorking = %s\n", uniqueID, (isWorking)? "Yes":"No");*/

}

}

printf("UpdatePinhole: Pinhole ID = %s with Lease Time: %s\n", uniqueID, lease_time);

if(r!=UPNPCOMMAND_SUCCESS)

printf("UpdatePinhole: ID (%s) failed with code %d (%s)\n", uniqueID, r, strupnperror(r));

}

}

* Get pinhole timeout

*/

static void GetPinholeOutboundTimeout(struct UPNPUrls * urls, struct IGDdatas * data,

const char * remoteaddr, const char * eport,

const char * intaddr, const char * iport,

const char * proto)

const char * rootdescurl = 0;

const char * multicastif = 0;

const char * minissdpdpath = 0;

int retcode = 0;

int error = 0;

int ipv6 = 0;

WSADATA wsaData;

int nResult = WSAStartup(MAKEWORD(2,2), &wsaData);

if(nResult != NO_ERROR)

{

fprintf(stderr, "WSAStartup() failed.\n");

return -1;

}

#endif

printf("Go to http://miniupnp.free.fr/ or http://miniupnp.tuxfamily.org/\n"

"for more information.\n");

/* command line processing */

for(i=1; i<argc; i++)

{

if(argv[i][0] == '-')

{

if(argv[i][1] == 'u')

rootdescurl = argv[++i];

else if(argv[i][1] == 'm')

multicastif = argv[++i];

else if(argv[i][1] == 'p')

minissdpdpath = argv[++i];

else if(argv[i][1] == '6')

ipv6 = 1;

else

{

command = argv[i][1];

i++;

commandargv = argv + i;

commandargc = argc - i;

fprintf(stderr, " \t%s [options] -D uniqueID\n\t\tDelete Pinhole (for IGD:2 only)\n", argv[0]);

fprintf(stderr, " \t%s [options] -S\n\t\tGet Firewall status (for IGD:2 only)\n", argv[0]);

fprintf(stderr, " \t%s [options] -G remote_ip remote_port internal_ip internal_port protocol\n\t\tGet Outbound Pinhole Timeout (for IGD:2 only)\n", argv[0]);

fprintf(stderr, " \t%s [options] -P\n\t\tGet Presentation url\n", argv[0]);

fprintf(stderr, "\nprotocol is UDP or TCP\n");

fprintf(stderr, "Options:\n");

fprintf(stderr, " -6 : use ip v6 instead of ip v4.\n");

fprintf(stderr, " -u url : bypass discovery process by providing the XML root description url.\n");

fprintf(stderr, " -p path : use this path for MiniSSDPd socket.\n");

return 1;

}

if( rootdescurl

|| (devlist = upnpDiscover(2000, multicastif, minissdpdpath,

NewListRedirections(&urls, &data);

break;

case 'a':

SetRedirectAndTest(&urls, &data,

commandargv[0], commandargv[1],

commandargv[2], commandargv[3],

break;

case 'd':

for(i=0; i<commandargc; i+=2)

{

RemoveRedirect(&urls, &data, commandargv[i], commandargv[i+1]);

}

case 'r':

for(i=0; i<commandargc; i+=2)

{

/*printf("port %s protocol %s\n", argv[i], argv[i+1]);*/

SetRedirectAndTest(&urls, &data,

lanaddr, commandargv[i],

}

break;

case 'A':

SetPinholeAndTest(&urls, &data,

commandargv[0], commandargv[1],

commandargv[2], commandargv[3],