You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
365 lines
17 KiB
365 lines
17 KiB
<!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 Classes</font></a>
|
|
| <a href="mainclasses.html">
|
|
<font color="#004faf">Main Classes</font></a>
|
|
| <a href="annotated.html">
|
|
<font color="#004faf">Annotated</font></a>
|
|
| <a href="groups.html">
|
|
<font color="#004faf">Grouped 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 <<a href="qsocket-h.html">ntqsocket.h</a>>
|
|
#include <<a href="qnetworkprotocol-h.html">ntqnetworkprotocol.h</a>>
|
|
|
|
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 <<a href="qurlinfo-h.html">ntqurlinfo.h</a>>
|
|
#include <stdlib.h>
|
|
#include <<a href="qurloperator-h.html">ntqurloperator.h</a>>
|
|
#include <<a href="qstringlist-h.html">ntqstringlist.h</a>>
|
|
#include <<a href="qregexp-h.html">ntqregexp.h</a>>
|
|
|
|
<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="ntqobject.html#connect">connect</a>( commandSocket, TQ_SIGNAL( <a href="ntqsocket.html#hostFound">hostFound</a>() ),
|
|
this, TQ_SLOT( hostFound() ) );
|
|
<a name="x681"></a> <a href="ntqobject.html#connect">connect</a>( commandSocket, TQ_SIGNAL( <a href="ntqsocket.html#connected">connected</a>() ),
|
|
this, TQ_SLOT( connected() ) );
|
|
<a name="x682"></a> <a href="ntqobject.html#connect">connect</a>( commandSocket, TQ_SIGNAL( <a href="ntqsocket.html#connectionClosed">connectionClosed</a>() ),
|
|
this, TQ_SLOT( closed() ) );
|
|
<a name="x687"></a> <a href="ntqobject.html#connect">connect</a>( commandSocket, TQ_SIGNAL( <a href="ntqsocket.html#readyRead">readyRead</a>() ),
|
|
this, TQ_SLOT( readyRead() ) );
|
|
<a name="x683"></a> <a href="ntqobject.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>()->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>()->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-><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-><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-><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-><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-><a href="ntqiodevice.html#isOpen">isOpen</a>() && connectionReady )
|
|
return TRUE;
|
|
|
|
// seems that there is no chance to connect
|
|
if ( commandSocket-><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-><a href="ntqsocket.html#state">state</a>() == TQSocket::Connecting )
|
|
return FALSE;
|
|
|
|
// start connecting
|
|
connectionReady = FALSE;
|
|
<a name="x680"></a> commandSocket-><a href="ntqsocket.html#connectToHost">connectToHost</a>( <a href="ntqnetworkprotocol.html#url">url</a>()->host(),
|
|
<a href="ntqnetworkprotocol.html#url">url</a>()->port() != -1 ? url()->port() : 119 );
|
|
return FALSE;
|
|
}
|
|
|
|
void <a name="f289"></a>Nntp::close()
|
|
{
|
|
// close the command socket
|
|
if ( commandSocket-><a href="ntqiodevice.html#isOpen">isOpen</a>() ) {
|
|
commandSocket-><a href="ntqsocket.html#writeBlock">writeBlock</a>( "quit\r\n", strlen( "quit\r\n" ) );
|
|
<a name="x679"></a> commandSocket-><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>()->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>()->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>()->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-><a href="ntqsocket.html#bytesAvailable">bytesAvailable</a>() + 1 );
|
|
<a name="x685"></a><a name="x671"></a> commandSocket-><a href="ntqsocket.html#readBlock">readBlock</a>( s.<a href="ntqmemarray.html#data">data</a>(), commandSocket-><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-><a href="ntqsocket.html#canReadLine">canReadLine</a>() )
|
|
return;
|
|
|
|
// read one line after the other
|
|
while ( commandSocket-><a href="ntqsocket.html#canReadLine">canReadLine</a>() ) {
|
|
<a name="x686"></a> <a href="ntqstring.html">TQString</a> s = commandSocket-><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>()->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>()->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>()->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-><a href="ntqsocket.html#canReadLine">canReadLine</a>() )
|
|
return;
|
|
|
|
// read an article one line after the other
|
|
while ( commandSocket-><a href="ntqsocket.html#canReadLine">canReadLine</a>() ) {
|
|
<a href="ntqstring.html">TQString</a> s = commandSocket-><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>()->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="ntqobject.html#tr">tr</a>( "Host not found or couldn't connect to: \n" + url()->host() );
|
|
<a href="ntqnetworkprotocol.html#operationInProgress">operationInProgress</a>()->setState( StFailed );
|
|
<a href="ntqnetworkprotocol.html#operationInProgress">operationInProgress</a>()->setProtocolDetail( msg );
|
|
<a href="ntqnetworkprotocol.html#operationInProgress">operationInProgress</a>()->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 © 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>
|