3 files changed, 142 insertions, 71 deletions
diff --git a/noncore/todayplugins/stockticker/stocktickerlib/stocktickerlib.pro b/noncore/todayplugins/stockticker/stocktickerlib/stocktickerlib.pro index 4b7b177..13c846b 100644 --- a/noncore/todayplugins/stockticker/stocktickerlib/stocktickerlib.pro +++ b/noncore/todayplugins/stockticker/stocktickerlib/stocktickerlib.pro @@ -11,17 +11,17 @@ SOURCES = stocktickerplugin.cpp stocktickerpluginimpl.cpp stocktickerpluginwidge ../libstocks/csv.c \ ../libstocks/currency.c \ ../libstocks/history.c \ ../libstocks/http.c \ ../libstocks/lists.c \ ../libstocks/stocks.c INCLUDEPATH += $(OPIEDIR)/include \ ../ ../library DEPENDPATH += $(OPIEDIR)/include \ ../ ../library -LIBS+= -lqpe -lopie +LIBS+= -lqpe -lopie -lpthread TMAKE_CFLAGS += -D__UNIX__ DESTDIR = $(OPIEDIR)/plugins/today TARGET = todaystocktickerplugin diff --git a/noncore/todayplugins/stockticker/stocktickerlib/stocktickerpluginwidget.cpp b/noncore/todayplugins/stockticker/stocktickerlib/stocktickerpluginwidget.cpp index 8830472..572a720 100644 --- a/noncore/todayplugins/stockticker/stocktickerlib/stocktickerpluginwidget.cpp +++ b/noncore/todayplugins/stockticker/stocktickerlib/stocktickerpluginwidget.cpp @@ -5,86 +5,60 @@ * email : llornkcor@handhelds.org * */ /*************************************************************************** * * * This program is free software; you can redistribute it and/or modify * * it under the terms of the GNU General Public License as published by * * the Free Software Foundation; either version 2 of the License, or * * (at your option) any later version. * * * ***************************************************************************/ +#include <qsocket.h> #include <qvaluelist.h> #include <qtl.h> #include <qstring.h> #include <qstringlist.h> #include <qobject.h> #include <qlayout.h> #include <qlineedit.h> #include <qregexp.h> #include <qtimer.h> +#include <qmessagebox.h> #include <qpe/config.h> #include <qpe/timestring.h> #include <qpe/qcopenvelope_qws.h> +#include <qpe/network.h> #include <opie/oticker.h> -//#include "ticker.h" extern "C" { #include "libstocks/stocks.h" } -#include "stocktickerpluginwidget.h" - -StockTickerPluginWidget::StockTickerPluginWidget( QWidget *parent, const char* name) - : QWidget(parent, name ) { - init(); - startTimer(1000); -} - -StockTickerPluginWidget::~StockTickerPluginWidget() { -} +#include <pthread.h> -void StockTickerPluginWidget::init() { - - QHBoxLayout* layout = new QHBoxLayout( this ); - - stocktickerTicker = new OTicker(this); - stocktickerTicker->setMinimumHeight(15); - connect( stocktickerTicker, SIGNAL( mousePressed()), this, SLOT( doStocks() )); - - layout->addWidget( stocktickerTicker); - -} - -void StockTickerPluginWidget::doStocks() { - Config cfg( "stockticker"); - cfg.setGroup( "Symbols" ); - QString symbollist; - symbollist = cfg.readEntry("Symbols", ""); - symbollist.replace(QRegExp(" "),"+");//seperated by + -// qDebug(symbollist); +#include "stocktickerpluginwidget.h" - getStocks( symbollist.latin1()); - - stocktickerTicker->setText( output ); -} +QString output; +OTicker *stocktickerTicker; -void StockTickerPluginWidget::getStocks( const char *blah) { +void getStocks( const QString *blah) { +// stocktickerTicker->setText( "Downloading stock data."); stock *stocks_quotes=NULL; stock *stocks_tmp; - + qDebug("%s", blah->latin1()); QString tempString; output = ""; libstocks_return_code error; Config cfg( "stockticker"); cfg.setGroup( "Fields" ); bool dotimeCheck, dodateCheck, dosymbolCheck, donameCheck; bool docurrentPriceCheck, dolastPriceCheck, doopenPriceCheck; bool dominPriceCheck, domaxPriceCheck, dovariationCheck, dovolumeCheck; dotimeCheck=dodateCheck=dosymbolCheck=donameCheck= docurrentPriceCheck=dolastPriceCheck=doopenPriceCheck=dominPriceCheck=domaxPriceCheck=dovariationCheck=dovolumeCheck=false; @@ -92,26 +66,47 @@ void StockTickerPluginWidget::getStocks( const char *blah) { dotimeCheck=cfg.readBoolEntry("timeCheck",1); dodateCheck=cfg.readBoolEntry("dateCheck",1); dosymbolCheck=cfg.readBoolEntry("symbolCheck",1); donameCheck=cfg.readBoolEntry("nameCheck",1); docurrentPriceCheck=cfg.readBoolEntry("currentPriceCheck",1); dolastPriceCheck=cfg.readBoolEntry("lastPriceCheck",1); doopenPriceCheck=cfg.readBoolEntry("openPriceCheck",1); dominPriceCheck=cfg.readBoolEntry("minPriceCheck",1); domaxPriceCheck=cfg.readBoolEntry("maxPriceCheck",1); dovariationCheck=cfg.readBoolEntry("variationCheck",1); dovolumeCheck=cfg.readBoolEntry("volumeCheck",1); - DefProxy(); - char *stock_liste = (char *)blah; +// DefProxy(); + { + char *proxy; + libstocks_return_code error; + + /* Proxy support */ + /* Checks for "http_proxy" environment variable */ + proxy = getenv("http_proxy"); + if(proxy) { + /* printf("proxy set\n"); */ + error = set_proxy(proxy); + if (error) { + printf("Proxy error (%d)\n", error); + QString tempString; + tempString.sprintf("Proxy error (%d)\n", error); + output = tempString; + return; +// exit(1); + } + } + } + char *stock_liste = (char *)blah->latin1(); +// char *stock_liste = (char *)blah; /* Get the stocks and process errors */ error = get_stocks( stock_liste, &stocks_quotes); if (error) { printf("Error in getting stocks (%d)\n", error); tempString.sprintf("Error in getting stocks (%d)\n", error); output =tempString; return; // exit(1); } stocks_tmp = stocks_quotes; @@ -208,47 +203,127 @@ void StockTickerPluginWidget::getStocks( const char *blah) { output +=tempString; // printf("----------------------------------------\n\n"); tempString.sprintf("||==++==|"); output +=tempString; /* Simple function which help to browse in the stocks list */ stocks_tmp = next_stock(stocks_tmp); } /* frees stocks */ free_stocks(stocks_quotes); + stocktickerTicker->setText( output ); } -void StockTickerPluginWidget::DefProxy(void) { - char *proxy; - libstocks_return_code error; +StockTickerPluginWidget::StockTickerPluginWidget( QWidget *parent, const char* name) + : QWidget(parent, name ) { + init(); + startTimer(1000); +// checkConnection(); +} - /* Proxy support */ - /* Checks for "http_proxy" environment variable */ - proxy = getenv("http_proxy"); - if(proxy) { - /* printf("proxy set\n"); */ - error = set_proxy(proxy); - if (error) { -// printf("Proxy error (%d)\n", error); - QString tempString; - tempString.sprintf("Proxy error (%d)\n", error); - output = tempString; - return; -// exit(1); - } +StockTickerPluginWidget::~StockTickerPluginWidget() { +} + +void StockTickerPluginWidget::init() { + + QHBoxLayout* layout = new QHBoxLayout( this ); + stocktickerTicker = new OTicker(this); + stocktickerTicker->setMinimumHeight(15); + connect( stocktickerTicker, SIGNAL( mousePressed()), this, SLOT( checkConnection() )); + layout->addWidget( stocktickerTicker); + wasError = true; +} + +void StockTickerPluginWidget::doStocks() { + Config cfg( "stockticker"); + cfg.setGroup( "Symbols" ); + QString symbollist; + symbollist = cfg.readEntry("Symbols", ""); + symbollist.replace(QRegExp(" "),"+");//seperated by + + +// qDebug(symbollist); + if (!symbollist.isEmpty()) { + pthread_t thread1; + pthread_create(&thread1,NULL, (void * (*)(void *))getStocks, &symbollist); } +// pthread_join(thread1,NULL); +// getStocks( symbollist.latin1() ); +} + +void StockTickerPluginWidget::DefProxy(void) { +// char *proxy; +// libstocks_return_code error; + +// /* Proxy support */ +// /* Checks for "http_proxy" environment variable */ +// proxy = getenv("http_proxy"); +// if(proxy) { +// /* printf("proxy set\n"); */ +// error = set_proxy(proxy); +// if (error) { +// // printf("Proxy error (%d)\n", error); +// QString tempString; +// tempString.sprintf("Proxy error (%d)\n", error); +// output = tempString; +// return; +// // exit(1); +// } +// } +} + +void StockTickerPluginWidget::timerEvent( QTimerEvent *e ) { + killTimer(e->timerId()); + checkConnection(); +} + +void StockTickerPluginWidget::checkConnection() { +// qDebug("checking connection"); +// Sock = new QSocket( this ); + +// if( wasError) +// stocktickerTicker->setText("Checking connection"); + +// if(Sock->state() == QSocket::Idle) { +// Sock->connectToHost("finance.yahoo.com", 80); +// connect( Sock, SIGNAL( error(int) ), SLOT(socketError(int)) ); +// connect( Sock, SIGNAL( hostFound() ), SLOT(isConnected()) ); +// } else { +// qDebug("State is not Idle"); + isConnected(); +// } } -void StockTickerPluginWidget::timerEvent( QTimerEvent *e ) { - killTimer(e->timerId()); +void StockTickerPluginWidget::isConnected() { +// qDebug("We connect, so ok to grab stocks"); doStocks(); + Config cfg( "stockticker"); - cfg.setGroup("Timer"); - timerDelay= cfg.readNumEntry("Delay",0); + cfg.setGroup("Timer"); + timerDelay= cfg.readNumEntry("Delay",0); if(timerDelay > 0) startTimer(timerDelay*60000); qDebug("timer set for %d",(timerDelay*60000)/60000); - + wasError = false; + +// Sock->close(); +} + +void StockTickerPluginWidget::socketError(int errcode) { + switch(errcode) { + case QSocket::ErrConnectionRefused: + output = tr("Connection refused."); + break; + case QSocket::ErrHostNotFound: + output = tr("Could not find server."); + break; + case QSocket::ErrSocketRead : + output = tr("Socket read error."); + break; + }; + stocktickerTicker->setText( output ); + wasError = true; +// Sock->close(); + } diff --git a/noncore/todayplugins/stockticker/stocktickerlib/stocktickerpluginwidget.h b/noncore/todayplugins/stockticker/stocktickerlib/stocktickerpluginwidget.h index 26472fa..c8de806 100644 --- a/noncore/todayplugins/stockticker/stocktickerlib/stocktickerpluginwidget.h +++ b/noncore/todayplugins/stockticker/stocktickerlib/stocktickerpluginwidget.h @@ -9,57 +9,53 @@ * * * This program is free software; you can redistribute it and/or modify * * it under the terms of the GNU General Public License as published by * * the Free Software Foundation; either version 2 of the License, or * * (at your option) any later version. * * * ***************************************************************************/ #ifndef STOCKTICKERL_PLUGIN_WIDGET_H #define STOCKTICKERL_PLUGIN_WIDGET_H +#include <qsocket.h> #include <qstring.h> #include <qwidget.h> #include <qlineedit.h> #include <opie/tododb.h> #include <opie/oclickablelabel.h> #include <opie/oticker.h> #include <sys/types.h> #include <sys/uio.h> #include <unistd.h> #include <stdio.h> #include <stdlib.h> #include <string.h> -//#include "ticker.h" - -/* extern "C" { */ -/* #include "stocks.h" */ -/* } */ - class QTimer; class StockTickerPluginWidget : public QWidget { Q_OBJECT public: StockTickerPluginWidget( QWidget *parent, const char *name ); ~StockTickerPluginWidget(); - QString output; protected slots: void doStocks(); - + void isConnected(); + void socketError(int); + void checkConnection(); private: - OTicker *stocktickerTicker; + bool wasError; + QSocket *Sock; void timerEvent( QTimerEvent * ); void init(); - void getStocks( const char *stock_liste); void DefProxy(void); int timerDelay; }; #endif |