Download NHK English news podcast automatically. This application requires mpod mother board. See also http://mbed.org/users/geodenx/notebook/mpod/

Dependencies:   BlinkLed HTTPClient EthernetInterface FatFileSystemCpp MSCFileSystem mbed-rtos mbed

Download NHK English news podcast automatically. This application requires mpod mother board. See also http://mbed.org/users/geodenx/notebook/mpod/

main.cpp

Committer:
togayan
Date:
2012-08-19
Revision:
3:07562878d3c3
Parent:
2:0da3a4508b46
Child:
4:ab3092d15121

File content as of revision 3:07562878d3c3:

#include "mbed.h"
#include "MSCFileSystem.h"
#include "EthernetInterface.h"
#include "HTTPClient.h"
#include "HTTPFile.h"
#include "BlinkLed.h"
#include "tinyxml2.h"

using namespace tinyxml2;

int GetFile(const char *path, const char *url);

EthernetInterface eth;
HTTPClient http;
MSCFileSystem usb("usb");
BlinkLed led1(LED1, 0.02);
BlinkLed led2(LED2, 0.2);
BlinkLed ethGreen(p26, 0.02);
BlinkLed ethYellow(p25, 0.2);
DigitalOut fsusb30s(p9);
Timer timer;

const char* rssUrl = "http://www3.nhk.or.jp/rj/podcast/rss/english.xml";
const char* rssPath = "/usb/english.xml";
const char* mp3Path = "/usb/english.mp3";

int main()
{
    printf("\n\n================================\n");
    printf("mpod NHK English news Downloader\n");
    printf("================================\n\n");
    
    // FSUSB30 switches to HSD1 (mbed)
    printf("USB host was switched to HSD1(mbed).\n\n");
    fsusb30s = 0; // HSD1
    
    // Network setup
    printf("Setup EtherNet with DHCP.\n");
    eth.init(); //Use DHCP
    eth.connect();
    
    // Obtain original lastBuildDate
    char lastBuildDateOriginal[128] = {0};
    {
        XMLDocument docOriginal;
        if(XML_SUCCESS != docOriginal.LoadFile(rssPath))
        {
            strcpy(lastBuildDateOriginal, "No original english.xml in USB memory");
        }
        else
        {
            XMLElement* lastBuildDateOriginalElement = docOriginal.FirstChildElement("rss")->FirstChildElement("channel")->FirstChildElement("lastBuildDate");
            if(NULL == lastBuildDateOriginalElement)
            {
                strcpy(lastBuildDateOriginal, "No \"lastBuildDate\" element in original RSS");
            }
            else
            {
                strcpy(lastBuildDateOriginal, lastBuildDateOriginalElement->GetText());
            }
        }
    }
    printf("\nlastBuildDate (original): %s\n", lastBuildDateOriginal);
    
    // Download RSS
    GetFile(rssPath, rssUrl);
    
    // Obtain current lastBuildDate 
    char lastBuildDateCurrent[128] = {0};
    char mp3Url[256] = {0};
    char mp3Length[32] = {0};
    {
        XMLDocument docCurrent;
        if(XML_SUCCESS != docCurrent.LoadFile(rssPath))
        {
            fsusb30s = 1; // HSD2
            error("No current english.xml in USB memory.\n");
        }
        
        XMLElement* lastBuildDateCurrentElement = docCurrent.FirstChildElement("rss")->FirstChildElement("channel")->FirstChildElement("lastBuildDate");
        if(NULL == lastBuildDateCurrentElement)
        {
            fsusb30s = 1; // HSD2
            error("No \"lastBuildDate\" element in current RSS.\n");
        }
        strcpy(lastBuildDateCurrent, lastBuildDateCurrentElement->GetText());
        
        XMLElement* enclosureElement = docCurrent.FirstChildElement("rss")->FirstChildElement("channel")->FirstChildElement("item")->FirstChildElement("enclosure");
        if(NULL == enclosureElement)
        {
            fsusb30s = 1; // HSD2
            error("No \"enclosure\" element in current RSS.\n");
        }
        strcpy(mp3Url, enclosureElement->Attribute("url"));
        strcpy(mp3Length, enclosureElement->Attribute("length"));
    }
    printf("\nlastBuildDate (current) : %s\n", lastBuildDateCurrent);
    
    // Determine the necessity of downloading new MP3.
    bool flgDownloadMp3 = false;
    if ( strcmp(lastBuildDateOriginal, lastBuildDateCurrent) == 0 )
    {
        printf("lastBuildDate (original) == lastBuildDate (current)\n");
        FILE* mp3fp = fopen(mp3Path, "r"); // check an existance of english.mp3
        if (mp3fp != NULL)
        {
            fseek(mp3fp, 0, SEEK_END); // seek to end of file
            if (ftell(mp3fp) != atol(mp3Length))
            {
                printf("MP3 file size is invalid.\n");
                flgDownloadMp3 = true;
            }
            fclose(mp3fp);
        }
        else
        {
            printf("However, no enlish.mp3 in USB memory\n");
            flgDownloadMp3 = true;
        }
    }
    else
    {
        printf("lastBuildDate (original) != lastBuildDate (current)\n");
        flgDownloadMp3 = true;
    }
    
    // Download new MP3
    if(flgDownloadMp3 == true)
    {
        GetFile(mp3Path, mp3Url);
    }
    
    // Wait for the completion of writing to USB Mass Storage Device.
    wait(1);
    
    // FSUSB30 switches to HSD2 (External Device)
    printf("\nUSB host was switched to HSD2(External Device).\n");
    fsusb30s = 1; // HSD2

    // blink LED
    led1.startBlink();
    ethGreen.startBlink();
    
    while(true){}
}

int GetFile(const char *path, const char *url)
{
    led2.startBlink();
    ethYellow.startBlink();
    printf("\nGetting %s\n", url);
    
    timer.stop();
    timer.reset();
    timer.start();
    
    HTTPFile file(path);
    HTTPResult retGet = http.get(url, &file);
    if (retGet != HTTP_OK)
    {
        fsusb30s = 1; // HSD2
        error("Error in http.get in GetFile(): %d\n", retGet);
    }
    file.clear();
    
    timer.stop();
    printf("timer.read_ms(): %d\n", timer.read_ms());
    
    led2.finishBlink();
    ethYellow.finishBlink();
    return (0);
}