source: trunk/libtransmission/upnp.c @ 4142

/*
 * This file Copyright (C) 2007 Charles Kerr <charles@rebelbase.com>
 *
 * This file is licensed by the GPL version 2.  Works owned by the
 * Transmission project are granted a special exemption to clause 2(b)
 * so that the bulk of its code can remain under the MIT license. 
 * This exemption does not extend to derived works not owned by
 * the Transmission project.
 *
 * $Id: upnp.c 4142 2007-12-13 02:48:30Z charles $
 */

#include <assert.h>
#include <errno.h>
#include <stdio.h> /* snprintf */
#include <string.h> /* strerror */

#include <miniupnp/miniwget.h>
#include <miniupnp/miniupnpc.h>
#include <miniupnp/upnpcommands.h>

#include "transmission.h"
#include "internal.h"
#include "shared.h"
#include "utils.h"
#include "upnp.h"

#define KEY "Port Mapping (UPNP): "

typedef enum
{
    TR_UPNP_IDLE,
    TR_UPNP_ERR,
    TR_UPNP_DISCOVER,
    TR_UPNP_MAP,
    TR_UPNP_UNMAP
}
tr_upnp_state;

struct tr_upnp
{
    struct UPNPUrls urls;
    struct IGDdatas data;
    int port;
    char lanaddr[16];
    unsigned int isMapped;
    unsigned int hasDiscovered : 1;
    tr_upnp_state state;
};

/**
***
**/

tr_upnp*
tr_upnpInit( void )
{
    tr_upnp * ret = tr_new0( tr_upnp, 1 );
    ret->port = -1;
    return ret;
}

void
tr_upnpClose( tr_upnp * handle )
{
    assert( !handle->isMapped );
    assert( ( handle->state == TR_UPNP_IDLE ) || ( handle->state == TR_UPNP_ERR ) );

    if( handle->hasDiscovered )
        FreeUPNPUrls( &handle->urls );
    tr_free( handle );
}

/**
***
**/

int
tr_upnpPulse( tr_upnp * handle, int port, int isEnabled )
{
    int ret;

    if( handle->state == TR_UPNP_IDLE )
    {
        if( !handle->hasDiscovered )
            handle->state = TR_UPNP_DISCOVER;
    }

    if( handle->state == TR_UPNP_DISCOVER )
    {
        struct UPNPDev * devlist;
        errno = 0;
        devlist = upnpDiscover( 2000, NULL );
        if( devlist == NULL ) {
            tr_err( KEY "upnpDiscover returned NULL (errno %d - %s)", errno, strerror(errno) );
        }
        errno = 0;
        if( UPNP_GetValidIGD( devlist, &handle->urls, &handle->data, handle->lanaddr, sizeof(handle->lanaddr))) {
            tr_inf( KEY "found Internet Gateway Device '%s'", handle->urls.controlURL );
            tr_inf( KEY "local LAN IP Address is '%s'", handle->lanaddr );
            handle->state = TR_UPNP_IDLE;
            handle->hasDiscovered = 1;
        } else {
            handle->state = TR_UPNP_ERR;
            tr_err( KEY "UPNP_GetValidIGD failed.  (errno %d - %s)", errno, strerror(errno) );
        }
        freeUPNPDevlist( devlist );
    }

    if( handle->state == TR_UPNP_IDLE )
    {
        if( handle->isMapped && ( !isEnabled || ( handle->port != port ) ) )
            handle->state = TR_UPNP_UNMAP;
    }

    if( handle->state == TR_UPNP_UNMAP )
    {
        char portStr[16];
        snprintf( portStr, sizeof(portStr), "%d", handle->port );
        UPNP_DeletePortMapping( handle->urls.controlURL,
                                handle->data.servicetype,
                                portStr, "TCP" );
        tr_dbg( KEY "stopping port forwarding of '%s', service '%s'",
                handle->urls.controlURL, handle->data.servicetype );
        handle->isMapped = 0;
        handle->state = TR_UPNP_IDLE;
        handle->port = -1;
    }

    if( handle->state == TR_UPNP_IDLE )
    {
        if( isEnabled && !handle->isMapped )
            handle->state = TR_UPNP_MAP;
    }

    if( handle->state == TR_UPNP_MAP )
    {
        char portStr[16];
        snprintf( portStr, sizeof(portStr), "%d", port );
        errno = 0;
        handle->isMapped = ( handle->urls.controlURL != NULL ) && 
                           ( handle->data.servicetype != NULL ) &&
                           ( UPNP_AddPortMapping( handle->urls.controlURL,
                                                  handle->data.servicetype,
                                                  portStr, portStr, handle->lanaddr,
                                                  "Transmission", "TCP" ) );
        tr_inf( KEY "port forwarding via '%s', service '%s'.  (local address: %s:%d)",
                handle->urls.controlURL, handle->data.servicetype, handle->lanaddr, handle->port );
        if( handle->isMapped ) {
            tr_inf( KEY "port forwarding successful!" );
            handle->port = port;
            handle->state = TR_UPNP_IDLE;
        } else {
            tr_err( KEY "port forwarding failed (errno %d - %s)", errno, strerror(errno) );
            handle->port = -1;
            handle->state = TR_UPNP_ERR;
        }
    }

    if( handle->state == TR_UPNP_ERR )
        ret = TR_NAT_TRAVERSAL_ERROR;
    else if( ( handle->state == TR_UPNP_IDLE ) && handle->isMapped )
        ret = TR_NAT_TRAVERSAL_MAPPED;
    else if( ( handle->state == TR_UPNP_IDLE ) && !handle->isMapped )
        ret = TR_NAT_TRAVERSAL_UNMAPPED;
    else if( handle->state == TR_UPNP_MAP )
        ret = TR_NAT_TRAVERSAL_MAPPING;
    else if( handle->state == TR_UPNP_UNMAP )
        ret = TR_NAT_TRAVERSAL_UNMAPPING;
    return ret;
}