<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.0 Transitional//EN">
<!-- /home/espenr/tmp/qt-3.3.8-espenr-2499/qt-x11-free-3.3.8/examples/network/networkprotocol/networkprotocol.doc:5 -->
<html>
<head>
<meta http-equiv="Content-Type" content="text/html; charset=ISO-8859-1">
<title>A simple NNTP implementation</title>
<style type="text/css"><!--
fn { margin-left: 1cm; text-indent: -1cm; }
a:link { color: #004faf; text-decoration: none }
a:visited { color: #672967; text-decoration: none }
body { background: #ffffff; color: black; }
--></style>
</head>
<body>

<table border="0" cellpadding="0" cellspacing="0" width="100%">
<tr bgcolor="#E5E5E5">
<td valign=center>
 <a href="index.html">
<font color="#004faf">Home</font></a>
 | <a href="classes.html">
<font color="#004faf">All&nbsp;Classes</font></a>
 | <a href="mainclasses.html">
<font color="#004faf">Main&nbsp;Classes</font></a>
 | <a href="annotated.html">
<font color="#004faf">Annotated</font></a>
 | <a href="groups.html">
<font color="#004faf">Grouped&nbsp;Classes</font></a>
 | <a href="functions.html">
<font color="#004faf">Functions</font></a>
</td>
<td align="right" valign="center"><img src="logo32.png" align="right" width="64" height="32" border="0"></td></tr></table><h1 align=center>A simple NNTP implementation</h1>

 
<p> 
<p> This example shows how to implement your own <a href="ntqnetworkprotocol.html">TQNetworkProtocol</a>. The
protocol that was chosen for this example is NTTP. Please note that this
implementation is very simple since it is designed to be an example. It
should not be used as a real NNTP implemention.
<p> <hr>
<p> Header file (nntp.h):
<p> <pre>/****************************************************************************
** $Id: qt/nntp.h   3.3.8   edited Jan 11 14:37 $
**
** Copyright (C) 1992-2007 Trolltech ASA.  All rights reserved.
**
** This file is part of an example program for TQt.  This example
** program may be used, distributed and modified without limitation.
**
*****************************************************************************/

#ifndef NNTP_H
#define NNTP_H

#include &lt;<a href="qsocket-h.html">ntqsocket.h</a>&gt;
#include &lt;<a href="qnetworkprotocol-h.html">ntqnetworkprotocol.h</a>&gt;

class Nntp : public <a href="ntqnetworkprotocol.html">TQNetworkProtocol</a>
{
    <a href="metaobjects.html#TQ_OBJECT">TQ_OBJECT</a>

public:
    Nntp();
    virtual ~Nntp();
    virtual int supportedOperations() const;

protected:
    virtual void operationListChildren( <a href="qnetworkoperation.html">TQNetworkOperation</a> *op );
    virtual void operationGet( <a href="qnetworkoperation.html">TQNetworkOperation</a> *op );

    <a href="ntqsocket.html">TQSocket</a> *commandSocket;
    bool connectionReady;
    bool readGroups;
    bool readArticle;

private:
    bool checkConnection( <a href="qnetworkoperation.html">TQNetworkOperation</a> *op );
    void close();
    void parseGroups();
    void parseArticle();

protected slots:
    void hostFound();
    void connected();
    void closed();
    void readyRead();
    void error( int );

};

#endif
</pre>

<p> <hr>
<p> Implementation (nntp.cpp):
<p> <pre>/****************************************************************************
** $Id: qt/nntp.cpp   3.3.8   edited Jan 11 14:37 $
**
** Copyright (C) 1992-2007 Trolltech ASA.  All rights reserved.
**
** This file is part of an example program for TQt.  This example
** program may be used, distributed and modified without limitation.
**
*****************************************************************************/

#include "nntp.h"
#include &lt;<a href="qurlinfo-h.html">ntqurlinfo.h</a>&gt;
#include &lt;stdlib.h&gt;
#include &lt;<a href="qurloperator-h.html">ntqurloperator.h</a>&gt;
#include &lt;<a href="qstringlist-h.html">ntqstringlist.h</a>&gt;
#include &lt;<a href="qregexp-h.html">ntqregexp.h</a>&gt;

<a name="f288"></a>Nntp::Nntp()
    : <a href="ntqnetworkprotocol.html">TQNetworkProtocol</a>(), connectionReady( FALSE ),
      readGroups( FALSE ), readArticle( FALSE )
{
    // create the command socket and connect to its signals
    commandSocket = new <a href="ntqsocket.html">TQSocket</a>( this );
<a name="x684"></a>    <a href="tqobject.html#connect">connect</a>( commandSocket, TQ_SIGNAL( <a href="ntqsocket.html#hostFound">hostFound</a>() ),
             this, TQ_SLOT( hostFound() ) );
<a name="x681"></a>    <a href="tqobject.html#connect">connect</a>( commandSocket, TQ_SIGNAL( <a href="ntqsocket.html#connected">connected</a>() ),
             this, TQ_SLOT( connected() ) );
<a name="x682"></a>    <a href="tqobject.html#connect">connect</a>( commandSocket, TQ_SIGNAL( <a href="ntqsocket.html#connectionClosed">connectionClosed</a>() ),
             this, TQ_SLOT( closed() ) );
<a name="x687"></a>    <a href="tqobject.html#connect">connect</a>( commandSocket, TQ_SIGNAL( <a href="ntqsocket.html#readyRead">readyRead</a>() ),
             this, TQ_SLOT( readyRead() ) );
<a name="x683"></a>    <a href="tqobject.html#connect">connect</a>( commandSocket, TQ_SIGNAL( <a href="ntqsocket.html#error">error</a>( int ) ),
             this, TQ_SLOT( error( int ) ) );
}

Nntp::~Nntp()
{
    close();
    delete commandSocket;
}

<a name="x675"></a>void Nntp::<a href="ntqnetworkprotocol.html#operationListChildren">operationListChildren</a>( <a href="qnetworkoperation.html">TQNetworkOperation</a> * )
{
    // create a command
    <a href="ntqstring.html">TQString</a> path = <a href="ntqnetworkprotocol.html#url">url</a>()-&gt;path(), cmd;
<a name="x691"></a>    if ( path.<a href="ntqstring.html#isEmpty">isEmpty</a>() || path == "/" ) {
        // if the path is empty or we are in the root dir,
        // we want to read the list of available newsgroups
        cmd = "list newsgroups\r\n";
    } else if ( <a href="ntqnetworkprotocol.html#url">url</a>()-&gt;isDir() ) {
        // if the path is a directory (in our case a news group)
        // we want to list the articles of this group
<a name="x694"></a>        path = path.<a href="ntqstring.html#replace">replace</a>( "/", "" );
        cmd = "listgroup " + path + "\r\n";
    } else
        return;

    // write the command to the socket
<a name="x693"></a><a name="x692"></a><a name="x689"></a>    commandSocket-&gt;<a href="ntqsocket.html#writeBlock">writeBlock</a>( cmd.<a href="ntqstring.html#latin1">latin1</a>(), cmd.<a href="ntqstring.html#length">length</a>() );
    readGroups = TRUE;
}

<a name="x674"></a>void Nntp::<a href="ntqnetworkprotocol.html#operationGet">operationGet</a>( <a href="qnetworkoperation.html">TQNetworkOperation</a> *op )
{
    // get the dirPath of the URL (this is our news group)
    // and the filename (which is the article we want to read)
<a name="x672"></a>    <a href="ntqurl.html">TQUrl</a> u( op-&gt;<a href="qnetworkoperation.html#arg">arg</a>( 0 ) );
<a name="x696"></a><a name="x695"></a>    <a href="ntqstring.html">TQString</a> dirPath = u.<a href="ntqurl.html#dirPath">dirPath</a>(), file = u.<a href="ntqurl.html#fileName">fileName</a>();
    dirPath = dirPath.<a href="ntqstring.html#replace">replace</a>( "/", "" );

    // go to the group in which the article is
    <a href="ntqstring.html">TQString</a> cmd;
    cmd = "group " + dirPath + "\r\n";
    commandSocket-&gt;<a href="ntqsocket.html#writeBlock">writeBlock</a>( cmd.<a href="ntqstring.html#latin1">latin1</a>(), cmd.<a href="ntqstring.html#length">length</a>() );

    // read the head of the article
    cmd = "article " + file + "\r\n";
    commandSocket-&gt;<a href="ntqsocket.html#writeBlock">writeBlock</a>( cmd.<a href="ntqstring.html#latin1">latin1</a>(), cmd.<a href="ntqstring.html#length">length</a>() );
    readArticle = TRUE;
}

<a name="x673"></a>bool Nntp::<a href="ntqnetworkprotocol.html#checkConnection">checkConnection</a>( <a href="qnetworkoperation.html">TQNetworkOperation</a> * )
{
    // we are connected, return TRUE
<a name="x670"></a>    if ( commandSocket-&gt;<a href="ntqiodevice.html#isOpen">isOpen</a>() &amp;&amp; connectionReady )
        return TRUE;

    // seems that there is no chance to connect
    if ( commandSocket-&gt;<a href="ntqiodevice.html#isOpen">isOpen</a>() )
        return FALSE;

    // don't call connectToHost() if we are already trying to connect
<a name="x688"></a>    if ( commandSocket-&gt;<a href="ntqsocket.html#state">state</a>() == TQSocket::Connecting )
        return FALSE;

    // start connecting
    connectionReady = FALSE;
<a name="x680"></a>    commandSocket-&gt;<a href="ntqsocket.html#connectToHost">connectToHost</a>( <a href="ntqnetworkprotocol.html#url">url</a>()-&gt;host(),
                                  <a href="ntqnetworkprotocol.html#url">url</a>()-&gt;port() != -1 ? url()-&gt;port() : 119 );
    return FALSE;
}

void <a name="f289"></a>Nntp::close()
{
    // close the command socket
    if ( commandSocket-&gt;<a href="ntqiodevice.html#isOpen">isOpen</a>() ) {
        commandSocket-&gt;<a href="ntqsocket.html#writeBlock">writeBlock</a>( "quit\r\n", strlen( "quit\r\n" ) );
<a name="x679"></a>        commandSocket-&gt;<a href="ntqsocket.html#close">close</a>();
    }
}

<a name="x676"></a>int Nntp::<a href="ntqnetworkprotocol.html#supportedOperations">supportedOperations</a>() const
{
    // we only support listing children and getting data
    return OpListChildren | OpGet;
}

void <a name="f290"></a>Nntp::hostFound()
{
    if ( <a href="ntqnetworkprotocol.html#url">url</a>() )
        emit connectionStateChanged( ConHostFound, tr( "Host %1 found" ).arg( <a href="ntqnetworkprotocol.html#url">url</a>()-&gt;host() ) );
    else
        emit connectionStateChanged( ConHostFound, tr( "Host found" ) );
}

void <a name="f291"></a>Nntp::connected()
{
    if ( <a href="ntqnetworkprotocol.html#url">url</a>() )
        emit connectionStateChanged( ConConnected, tr( "Connected to host %1" ).arg( <a href="ntqnetworkprotocol.html#url">url</a>()-&gt;host() ) );
    else
        emit connectionStateChanged( ConConnected, tr( "Connected to host" ) );
}

void <a name="f292"></a>Nntp::closed()
{
    if ( <a href="ntqnetworkprotocol.html#url">url</a>() )
        emit connectionStateChanged( ConClosed, tr( "Connection to %1 closed" ).arg( <a href="ntqnetworkprotocol.html#url">url</a>()-&gt;host() ) );
    else
        emit connectionStateChanged( ConClosed, tr( "Connection closed" ) );
}

void <a name="f293"></a>Nntp::readyRead()
{
    // new data arrived on the command socket

    // of we should read the list of available groups, let's do so
    if ( readGroups ) {
        parseGroups();
        return;
    }

    // of we should read an article, let's do so
    if ( readArticle ) {
        parseArticle();
        return;
    }

    // read the new data from the socket
    <a href="ntqcstring.html">TQCString</a> s;
<a name="x677"></a><a name="x668"></a>    s.<a href="ntqcstring.html#resize">resize</a>( commandSocket-&gt;<a href="ntqsocket.html#bytesAvailable">bytesAvailable</a>() + 1 );
<a name="x685"></a><a name="x671"></a>    commandSocket-&gt;<a href="ntqsocket.html#readBlock">readBlock</a>( s.<a href="ntqmemarray.html#data">data</a>(), commandSocket-&gt;<a href="ntqsocket.html#bytesAvailable">bytesAvailable</a>() );

    if ( !url() )
        return;

    // of the code of the server response was 200, we know that the
    // server is ready to get commands from us now
<a name="x664"></a>    if ( s.<a href="ntqcstring.html#left">left</a>( 3 ) == "200" )
        connectionReady = TRUE;
}

void <a name="f294"></a>Nntp::parseGroups()
{
<a name="x678"></a>    if ( !commandSocket-&gt;<a href="ntqsocket.html#canReadLine">canReadLine</a>() )
        return;

    // read one line after the other
    while ( commandSocket-&gt;<a href="ntqsocket.html#canReadLine">canReadLine</a>() ) {
<a name="x686"></a>        <a href="ntqstring.html">TQString</a> s = commandSocket-&gt;<a href="ntqsocket.html#readLine">readLine</a>();

        // if the  line starts with a dot, all groups or articles have been listed,
        // so we finished processing the listChildren() command
        if ( s[ 0 ] == '.' ) {
            readGroups = FALSE;
            <a href="ntqnetworkprotocol.html#operationInProgress">operationInProgress</a>()-&gt;setState( StDone );
            emit finished( <a href="ntqnetworkprotocol.html#operationInProgress">operationInProgress</a>() );
            return;
        }

        // if the code of the server response is 215 or 211
        // the next line will be the first group or article (depending on what we read).
        // So let others know that we start reading now...
        if ( s.<a href="ntqcstring.html#left">left</a>( 3 ) == "215" || s.<a href="ntqcstring.html#left">left</a>( 3 ) == "211" ) {
            <a href="ntqnetworkprotocol.html#operationInProgress">operationInProgress</a>()-&gt;setState( StInProgress );
            emit start( <a href="ntqnetworkprotocol.html#operationInProgress">operationInProgress</a>() );
            continue;
        }

        // parse the line and create a TQUrlInfo object
        // which describes the child (group or article)
<a name="x663"></a>        bool tab = s.<a href="ntqcstring.html#find">find</a>( '\t' ) != -1;
<a name="x666"></a>        <a href="ntqstring.html">TQString</a> group = s.<a href="ntqcstring.html#mid">mid</a>( 0, s.<a href="ntqcstring.html#find">find</a>( tab ? '\t' : ' ' ) );
        <a href="ntqurlinfo.html">TQUrlInfo</a> inf;
<a name="x700"></a>        inf.<a href="ntqurlinfo.html#setName">setName</a>( group );
        <a href="ntqstring.html">TQString</a> path = <a href="ntqnetworkprotocol.html#url">url</a>()-&gt;path();
<a name="x698"></a>        inf.<a href="ntqurlinfo.html#setDir">setDir</a>( path.<a href="ntqstring.html#isEmpty">isEmpty</a>() || path == "/" );
<a name="x702"></a>        inf.<a href="ntqurlinfo.html#setSymLink">setSymLink</a>( FALSE );
<a name="x699"></a><a name="x697"></a>        inf.<a href="ntqurlinfo.html#setFile">setFile</a>( !inf.<a href="ntqurlinfo.html#isDir">isDir</a>() );
<a name="x703"></a>        inf.<a href="ntqurlinfo.html#setWritable">setWritable</a>( FALSE );
<a name="x701"></a>        inf.<a href="ntqurlinfo.html#setReadable">setReadable</a>( TRUE );

        // let others know about our new child
        emit newChild( inf, operationInProgress() );
    }

}

void <a name="f295"></a>Nntp::parseArticle()
{
    if ( !commandSocket-&gt;<a href="ntqsocket.html#canReadLine">canReadLine</a>() )
        return;

    // read an article one line after the other
    while ( commandSocket-&gt;<a href="ntqsocket.html#canReadLine">canReadLine</a>() ) {
        <a href="ntqstring.html">TQString</a> s = commandSocket-&gt;<a href="ntqsocket.html#readLine">readLine</a>();

        // if the  line starts with a dot, we finished reading something
        if ( s[ 0 ] == '.' ) {
            readArticle = FALSE;
            <a href="ntqnetworkprotocol.html#operationInProgress">operationInProgress</a>()-&gt;setState( StDone );
            emit finished( <a href="ntqnetworkprotocol.html#operationInProgress">operationInProgress</a>() );
            return;
        }

<a name="x669"></a>        if ( s.<a href="ntqcstring.html#right">right</a>( 1 ) == "\n" )
<a name="x667"></a><a name="x665"></a>            s.<a href="ntqcstring.html#remove">remove</a>( s.<a href="ntqcstring.html#length">length</a>() - 1, 1 );

        // emit the new data of the article which we read
<a name="x690"></a>        emit data( TQCString( s.<a href="ntqstring.html#ascii">ascii</a>() ), operationInProgress() );
    }
}

void <a name="f296"></a>Nntp::error( int code )
{
    if ( code == TQSocket::ErrHostNotFound ||
         code == TQSocket::ErrConnectionRefused ) {
        // this signal is called if connecting to the server failed
        if ( <a href="ntqnetworkprotocol.html#operationInProgress">operationInProgress</a>() ) {
            <a href="ntqstring.html">TQString</a> msg = <a href="tqobject.html#tr">tr</a>( "Host not found or couldn't connect to: \n" + url()-&gt;host() );
            <a href="ntqnetworkprotocol.html#operationInProgress">operationInProgress</a>()-&gt;setState( StFailed );
            <a href="ntqnetworkprotocol.html#operationInProgress">operationInProgress</a>()-&gt;setProtocolDetail( msg );
            <a href="ntqnetworkprotocol.html#operationInProgress">operationInProgress</a>()-&gt;setErrorCode( (int)ErrHostNotFound );
            <a href="ntqnetworkprotocol.html#clearOperationQueue">clearOperationQueue</a>();
            emit finished( <a href="ntqnetworkprotocol.html#operationInProgress">operationInProgress</a>() );
        }
    }
}
</pre>

<p>See also <a href="network-examples.html">Network Examples</a>.

<!-- eof -->
<p><address><hr><div align=center>
<table width=100% cellspacing=0 border=0><tr>
<td>Copyright &copy; 2007
<a href="troll.html">Trolltech</a><td align=center><a href="trademarks.html">Trademarks</a>
<td align=right><div align=right>TQt 3.3.8</div>
</table></div></address></body>
</html>