Open Source Projects Europe

// Note: if we ever need this to work without cxx11, there is this:

// Note: if we ever need this to work without cxx11, there is this:

// http://www.tutok.sk/fastgl/callback.html

// http://www.tutok.sk/fastgl/callback.html

UpMpd::UpMpd(const string& deviceid, 

UpMpd::UpMpd(const string& deviceid, 

             const unordered_map<string, string>& xmlfiles,

             const unordered_map<string, string>& xmlfiles,

    : UpnpDevice(deviceid, xmlfiles), m_mpdcli(mpdcli), m_mpds(0),

    : UpnpDevice(deviceid, xmlfiles), m_mpdcli(mpdcli), m_mpds(0),

      m_options(opts)

      m_options(opts)

{

{

    // Note: the order is significant here as it will be used when

    // Note: the order is significant here as it will be used when

    // calling the getStatus() methods, and we want AVTransport to

    // calling the getStatus() methods, and we want AVTransport to

    // update the mpd status for OHInfo

    // update the mpd status for OHInfo

    UpMpdRenderCtl *rdctl = new UpMpdRenderCtl(this);

    UpMpdRenderCtl *rdctl = new UpMpdRenderCtl(this);

    m_services.push_back(rdctl);

    m_services.push_back(rdctl);

    m_services.push_back(new UpMpdAVTransport(this));

    m_services.push_back(new UpMpdAVTransport(this));

    m_services.push_back(new UpMpdConMan(this));

    m_services.push_back(new UpMpdConMan(this));

    m_services.push_back(new OHProduct(this));

    m_services.push_back(new OHInfo(this));

    m_services.push_back(new OHTime(this));

    m_services.push_back(new OHVolume(this, rdctl));

    m_services.push_back(new OHPlaylist(this, rdctl));

}

}

UpMpd::~UpMpd()

UpMpd::~UpMpd()

{

{

    for (vector<UpnpService*>::iterator it = m_services.begin();

    for (vector<UpnpService*>::iterator it = m_services.begin();

#define OPT_i     0x200

#define OPT_i     0x200

#define OPT_P     0x400

#define OPT_P     0x400

static const char usage[] = 

static const char usage[] = 

"-c configfile \t configuration file to use\n"

"-c configfile \t configuration file to use\n"

"-p port     \t specify MPD port\n"

"-p port     \t specify MPD port\n"

"-d logfilename\t debug messages to\n"

"-d logfilename\t debug messages to\n"

"-l loglevel\t  log level (0-6)\n"

"-l loglevel\t  log level (0-6)\n"

"-D    \t run as a daemon\n"

"-f friendlyname\t define device displayed name\n"

"-f friendlyname\t define device displayed name\n"

"-q 0|1\t if set, we own the mpd queue, else avoid clearing it whenever we feel like it\n"

"-i iface    \t specify network interface name to be used for UPnP"

"-i iface    \t specify network interface name to be used for UPnP"

"-P upport    \t specify port number to be used for UPnP"

"-P upport    \t specify port number to be used for UPnP"

"  \n\n"

"  \n\n"

            ;

            ;

static void

static void

static string datadir(DATADIR "/");

static string datadir(DATADIR "/");

static string configdir(CONFIGDIR "/");

static string configdir(CONFIGDIR "/");

// Our XML description data. !Keep description.xml first!

// Our XML description data. !Keep description.xml first!

};

};

int main(int argc, char *argv[])

int main(int argc, char *argv[])

{

{

    string mpdhost("localhost");

    string mpdhost("localhost");

    int mpdport = 6600;

    int mpdport = 6600;

    string logfilename;

    string logfilename;

    int loglevel(upnppdebug::Logger::LLINF);

    int loglevel(upnppdebug::Logger::LLINF);

    string configfile;

    string configfile;

    string friendlyname(dfltFriendlyName);

    string friendlyname(dfltFriendlyName);

    bool ownqueue = true;

    bool ownqueue = true;

    string upmpdcliuser("upmpdcli");

    string upmpdcliuser("upmpdcli");

    string pidfilename("/var/run/upmpdcli.pid");

    string pidfilename("/var/run/upmpdcli.pid");

    string iface;

    string iface;

    unsigned short upport = 0;

    unsigned short upport = 0;

    string upnpip;

    string upnpip;

        }

        }

        config.get("mpdpassword", mpdpassword);

        config.get("mpdpassword", mpdpassword);

        if (!(op_flags & OPT_q) && config.get("ownqueue", value)) {

        if (!(op_flags & OPT_q) && config.get("ownqueue", value)) {

            ownqueue = atoi(value.c_str()) != 0;

            ownqueue = atoi(value.c_str()) != 0;

        }

        }

        if (!(op_flags & OPT_i)) {

        if (!(op_flags & OPT_i)) {

            config.get("upnpiface", iface);

            config.get("upnpiface", iface);

            if (iface.empty()) {

            if (iface.empty()) {

                config.get("upnpip", upnpip);

                config.get("upnpip", upnpip);

            }

            }

    // Create unique ID

    // Create unique ID

    string UUID = LibUPnP::makeDevUUID(friendlyname, hwaddr);

    string UUID = LibUPnP::makeDevUUID(friendlyname, hwaddr);

    // Read our XML data to make it available from the virtual directory

    // Read our XML data to make it available from the virtual directory

    string reason;

    string reason;

    unordered_map<string, string> xmlfiles;

    unordered_map<string, string> xmlfiles;

        string filename = path_cat(datadir, xmlfilenames[i]);

        string filename = path_cat(datadir, xmlfilenames[i]);

        string data;

        string data;

        if (!file_to_string(filename, data, &reason)) {

        if (!file_to_string(filename, data, &reason)) {

            LOGFAT("Failed reading " << filename << " : " << reason << endl);

            LOGFAT("Failed reading " << filename << " : " << reason << endl);

            return 1;

            return 1;

        }

        }

        if (i == 0) {

        if (i == 0) {

            // Special for description: set UUID and friendlyname

            // Special for description: set UUID and friendlyname

            data = regsub1("@UUID@", data, UUID);

            data = regsub1("@UUID@", data, UUID);

            data = regsub1("@FRIENDLYNAME@", data, friendlyname);

            data = regsub1("@FRIENDLYNAME@", data, friendlyname);

        }

        }

        xmlfiles[xmlfilenames[i]] = data;

        xmlfiles[xmlfilenames[i]] = data;

    }

    }

    // Initialize the UPnP device object.

    // Initialize the UPnP device object.

    UpMpd device(string("uuid:") + UUID, xmlfiles, &mpdcli,

    // And forever generate state change events.

    // And forever generate state change events.

    LOGDEB("Entering event loop" << endl);

    LOGDEB("Entering event loop" << endl);

    device.eventloop();

    device.eventloop();