---

freedb_remote.cxx

#include <freedb/freedb.hxx>

FreedbRemote::FreedbRemote(string servername = "freedb.freedb.org")
    :   _sockfd(-1)
{
    connect(servername);
}

FreedbRemote::~FreedbRemote()
{
    disconnect();
}

void FreedbRemote::sendCommand(string command) const
{
    command += "\n";
    int retval = send(_sockfd, command.data(), command.length(), 0);
}

string FreedbRemote::getResponseLine(bool stripcr = true) const
{
    string response;
    char buf;
    int retval;

    while (buf != '\n')
    {
        retval = recv(_sockfd, (void *)&buf, 1, 0);

        if (buf != '\r' || stripcr == false)
        {
            response += buf;
        }
    }

    return(response);
}

void FreedbRemote::connect(string servername = "freedb.freedb.org")
{
    struct sockaddr_in saddr;
    struct hostent* dns;
    int addrlen = sizeof(struct sockaddr);

    _sockfd = socket(PF_INET, SOCK_STREAM, 0);

    if (_sockfd == (-1))
    {
        Error err;

        err.errcode = errno;
        err.errmsg = strerror(errno);

        throw err;
    }

    dns = gethostbyname(servername.c_str());

    if (dns == NULL)
    {
        Error err;

        switch (h_errno)
        {
            case HOST_NOT_FOUND:
                err.errmsg = "Host not found";
            break;

            case NO_ADDRESS:
                err.errmsg = "Host has no IP-Adress";
            break;

            case NO_RECOVERY:
                err.errmsg = "Permanent DNS server error";
            break;

            case TRY_AGAIN:
                err.errmsg = "Temporary DNS server error";
            break;

            default:
                err.errmsg = "Unknown error";
        }

        throw err;
    }

    saddr.sin_family = AF_INET;
    saddr.sin_port = htons(CDDBP_PORT);
    saddr.sin_addr = *((struct in_addr *)dns->h_addr_list[0]);


    int retval = ::connect(_sockfd, (struct sockaddr *)&saddr, addrlen);
    if (retval == (-1))
    {
        //assert(errno != EISCONN);
        Error err;

        err.errcode = errno;
        err.errmsg = strerror(errno);

        throw err;
    }


    /* socket is connected */
    string response = getResponseLine();

    if (response.substr(0, 2) != "20")
    {
        Error err;
        err.errcode = stoi(response.substr(0, 3));

        switch (err.errcode)
        {
            case 432:
                err.errmsg = "Permission denied";
            break;

            case 433:
                err.errmsg = "Too many users";
            break;

            case 434:
                err.errmsg = "System load too high";
            break;

            default:
                err.errmsg = "Unknown error";
        }

        err.extinfo = response;

        throw err;
    }

    cout << response;

    _greeting = response;
}

void FreedbRemote::disconnect()
{
    if (_sockfd != -1)
        {
        sendCommand("quit");

        int retval = close(_sockfd);
        if (retval == (-1))
        {
            Error err;
            err.errcode = errno;
            err.errmsg = strerror(errno);
            throw err;
        }
    }
}

void FreedbRemote::doHandshake(string username, string clientname, string version) const
{
    char* hn = new char[256];
    int retval = gethostname(hn, 256);
    if (retval == (-1))
    {
        Error err;
        err.errcode = errno;
        err.errmsg = strerror(errno);
        throw err;
    }

    /* send handshake */
    string hostname = hn;
    string handshake = "cddb hello " + username + " " + hostname + " " + clientname + " " + version;

    sendCommand(handshake);

    /* get response */
    string response = getResponseLine();

    if (response.substr(0, 2) != "20")
    {
        Error err;
        err.errcode = stoi(response.substr(0, 3));

        switch (err.errcode)
        {
            case 431:
                err.errmsg = "Handshake not successful";
            break;

            case 402:
                err.errmsg = "Already shook hands";
            break;

            default:
                err.errmsg = "Unknown error";
        }

        err.extinfo = response;

        throw err;
    }
}

ServerInfo FreedbRemote::parseServerInfoLine(string line)
{
    ServerInfo info;
    int lastpos = 0, currentpos;

    if (line[0] == '\n')
    {
        line = line.substr(1, line.length() - 1);
    }

    //site hostname
    currentpos = line.find(" ", lastpos);
    info.site = line.substr(lastpos, currentpos);
    lastpos = currentpos + 1;

    //port
    currentpos = line.find(" ", lastpos);
    info.port = stoi(line.substr(lastpos, currentpos));
    lastpos = currentpos + 1 ;

    //latitude
    currentpos = line.find(" ", lastpos);
    string latitude = line.substr(lastpos, currentpos);
    lastpos = currentpos + 1 ;
    info.latitude.compassdirection = latitude.substr(0, 1);
    info.latitude.degrees = stoi(latitude.substr(1, 3));
    info.latitude.minutes = stoi(latitude.substr(5, 2));

    //longitude
    currentpos = line.find(" ", lastpos);
    string longitude = line.substr(lastpos, currentpos);
    lastpos = currentpos + 1 ;
    info.longitude.compassdirection = longitude.substr(0, 1);
    info.longitude.degrees = stoi(longitude.substr(1, 3));
    info.longitude.minutes = stoi(longitude.substr(5, 2));

    //description
    info.description = line.substr(lastpos, line.length() - lastpos);

    return(info);
}


vector<ServerInfo> FreedbRemote::getServerList() const
{
    vector<ServerInfo> servers;

    sendCommand("sites");

    string response = getResponseLine();

    if (response.substr(0, 1) != "2")
    {
        Error err;
        err.errcode = stoi(response.substr(0, 3));

        switch (err.errcode)
        {
            case 401:
                err.errmsg = "No site information available";
            break;

            default:
                err.errmsg = "Unknown error";
        }

        err.extinfo = response;

        throw err;
    }

    char buf;
    bool newline = false;
    int lines = 0, retval;

    response = "";

    while (1)
    {
        retval = recv(_sockfd, (void *)&buf, 1, 0);

        if (buf == '.' && newline == true)
        {
            break;
        }

        if (buf == '\n')
        {
            newline = true;
            lines++;

            servers.push_back(parseServerInfoLine(response));

            response = "";
        }
        else
        {
            newline = false;
        }

        if (buf != '\r')
        {
            response += buf;
        }
    }

    return(servers);
}


vector<string> FreedbRemote::getCategories() const
{
    vector<string> categories;

    sendCommand("lscat");

    string response = getResponseLine();

    if (response.substr(0, 3) != "210")
    {
        Error err;
        err.errcode = stoi(response.substr(0, 3));

        switch (err.errcode)
        {
            default:
                err.errmsg = "Unknown error";
        }

        err.extinfo = response;

        throw err;
    }

    char buf;
    bool newline = false;
    int lines = 0, retval;

    response = "";

    while (1)
    {
        retval = recv(_sockfd, (void *)&buf, 1, 0);

        if (buf == '.' && newline == true)
        {
            break;
        }

        if (buf == '\n')
        {
            newline = true;
            lines++;

            categories.push_back(response);

            response = "";
        }
        else
        {
            newline = false;
        }

        if (buf != '\r')
        {
            response += buf;
        }
    }

    return(categories);
}


vector<SearchResult> FreedbRemote::search() const
{
}

---