diff options
Diffstat (limited to 'plugins/webinterface/php_interface.cpp')
| -rw-r--r-- | plugins/webinterface/php_interface.cpp | 486 |
1 files changed, 486 insertions, 0 deletions
diff --git a/plugins/webinterface/php_interface.cpp b/plugins/webinterface/php_interface.cpp new file mode 100644 index 0000000..8ee7d0b --- /dev/null +++ b/plugins/webinterface/php_interface.cpp @@ -0,0 +1,486 @@ + /*************************************************************************** + * Copyright (C) 2006 by Diego R. Brogna * + * [email protected] * + * * + * 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. * + * * + * This program is distributed in the hope that it will be useful, * + * but WITHOUT ANY WARRANTY; without even the implied warranty of * + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * + * GNU General Public License for more details. * + * * + * You should have received a copy of the GNU General Public License * + * along with this program; if not, write to the * + * Free Software Foundation, Inc., * + * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA. * + ***************************************************************************/ + +#include <kio/global.h> +#include <kglobal.h> +#include <klocale.h> + +#include <net/socketmonitor.h> +#include <torrent/choker.h> +#include <torrent/udptrackersocket.h> +#include <kademlia/dhtbase.h> +#include <torrent/server.h> +#include <util/log.h> +#include <interfaces/functions.h> + +#include "php_interface.h" + +using namespace bt; + +namespace kt +{ + extern QString DataDir(); + + using bt::FIRST_PRIORITY; + using bt::NORMAL_PRIORITY; + using bt::LAST_PRIORITY; + using bt::EXCLUDED; + + + QString BytesToString2(Uint64 bytes,int precision = 2) + { + KLocale* loc = KGlobal::locale(); + if (bytes >= 1024 * 1024 * 1024) + return QString("%1 GB").arg(loc->formatNumber(bytes / TO_GIG,precision < 0 ? 2 : precision)); + else if (bytes >= 1024*1024) + return QString("%1 MB").arg(loc->formatNumber(bytes / TO_MEG,precision < 0 ? 1 : precision)); + else if (bytes >= 1024) + return QString("%1 KB").arg(loc->formatNumber(bytes / TO_KB,precision < 0 ? 1 : precision)); + else + return QString("%1 B").arg(bytes); + } + + QString KBytesPerSecToString2(double speed,int precision = 2) + { + KLocale* loc = KGlobal::locale(); + return QString("%1 KB/s").arg(loc->formatNumber(speed,precision)); + } + + /************************ + *PhpCodeGenerator * + ************************/ + PhpCodeGenerator::PhpCodeGenerator(CoreInterface *c) + { + core=c; + } + + /*Generate php code + * function downloadStatus() + * { + * return array( ... ); + * } + */ + void PhpCodeGenerator::downloadStatus(QTextStream & out) + { + TorrentStats stats; + //Priority file_priority; + QString status; + out << "function downloadStatus()\n{\nreturn array("; + + QPtrList<TorrentInterface>::iterator i= core->getQueueManager()->begin(); + for(int k=0; i != core->getQueueManager()->end(); i++, k++) + { + if (k > 0) + out << ",\n"; + + stats=(*i)->getStats(); + out << QString("\n%1 => array(").arg(k); + + out << QString("\"imported_bytes\" => %1,\n").arg(stats.imported_bytes); + out << QString("\"bytes_downloaded\" => \"%1\",\n").arg(BytesToString2(stats.bytes_downloaded)); + out << QString("\"bytes_uploaded\" => \"%1\",\n").arg(BytesToString2(stats.bytes_uploaded)); + out << QString("\"bytes_left\" => %1,\n").arg(stats.bytes_left); + out << QString("\"bytes_left_to_download\" => %1,\n").arg(stats.bytes_left_to_download); + out << QString("\"total_bytes\" => \"%1\",\n").arg(BytesToString2(stats.total_bytes)); + out << QString("\"total_bytes_to_download\" => %1,\n").arg(stats.total_bytes_to_download); + out << QString("\"download_rate\" => \"%1\",\n").arg(KBytesPerSecToString2(stats.download_rate / 1024.0)); + out << QString("\"upload_rate\" => \"%1\",\n").arg(KBytesPerSecToString2(stats.upload_rate / 1024.0)); + out << QString("\"num_peers\" => %1,\n").arg(stats.num_peers); + out << QString("\"num_chunks_downloading\" => %1,\n").arg(stats.num_chunks_downloading); + out << QString("\"total_chunks\" => %1,\n").arg(stats.total_chunks); + out << QString("\"num_chunks_downloaded\" => %1,\n").arg(stats.num_chunks_downloaded); + out << QString("\"num_chunks_excluded\" => %1,\n").arg(stats.num_chunks_excluded); + out << QString("\"chunk_size\" => %1,\n").arg(stats.chunk_size); + out << QString("\"seeders_total\" => %1,\n").arg(stats.seeders_total); + out << QString("\"seeders_connected_to\" => %1,\n").arg(stats.seeders_connected_to); + out << QString("\"leechers_total\" => %1,\n").arg(stats.leechers_total); + out << QString("\"leechers_connected_to\" => %1,\n").arg(stats.leechers_connected_to); + out << QString("\"status\" => %1,\n").arg(stats.status); + out << QString("\"running\" => %1,\n").arg(stats.running); + out << QString("\"trackerstatus\" => \"%1\",\n").arg(stats.trackerstatus.replace("\\", "\\\\").replace("\"", "\\\"").replace("$", "\\$")); + out << QString("\"session_bytes_downloaded\" => %1,\n").arg(stats.session_bytes_downloaded); + out << QString("\"session_bytes_uploaded\" => %1,\n").arg(stats.session_bytes_uploaded); + out << QString("\"trk_bytes_downloaded\" => %1,\n").arg(stats.trk_bytes_downloaded); + out << QString("\"trk_bytes_uploaded\" => %1,\n").arg(stats.trk_bytes_uploaded); + out << QString("\"torrent_name\" => \"%1\",\n").arg(stats.torrent_name.replace("\\", "\\\\").replace("\"", "\\\"").replace("$", "\\$")); + out << QString("\"output_path\" => \"%1\",\n").arg(stats.output_path.replace("\\", "\\\\").replace("\"", "\\\"").replace("$", "\\$")); + out << QString("\"stopped_by_error\" => \"%1\",\n").arg(stats.stopped_by_error); + out << QString("\"completed\" => \"%1\",\n").arg(stats.completed); + out << QString("\"user_controlled\" => \"%1\",\n").arg(stats.user_controlled); + out << QString("\"max_share_ratio\" => %1,\n").arg(stats.max_share_ratio); + out << QString("\"priv_torrent\" => \"%1\",\n").arg(stats.priv_torrent); + out << QString("\"num_files\" => \"%1\",\n").arg((*i)->getNumFiles()); + out << QString("\"files\" => array("); + out << flush; + if (stats.multi_file_torrent) + { + //for loop to add each file+status to "files" array + for (Uint32 j = 0;j < (*i)->getNumFiles();j++) + { + if (j > 0) + out << ",\n"; + + TorrentFileInterface & file = (*i)->getTorrentFile(j); + out << QString("\"%1\" => array(\n").arg(j); + out << QString("\"name\" => \"%1\",\n").arg(file.getPath()); + out << QString("\"size\" => \"%1\",\n").arg(KIO::convertSize(file.getSize())); + out << QString("\"perc_done\" => \"%1\",\n").arg(file.getDownloadPercentage()); + out << QString("\"status\" => \"%1\"\n").arg(file.getPriority()); + out << QString(")\n"); + out << flush; + } + } + + out << ")\n"; + out << ")\n"; + } + + out << ");\n}\n"; + } + + /*Generate php code + * function globalStatus() + * { + * return array( ... ); + * } + */ + void PhpCodeGenerator::globalInfo(QTextStream & out) + { + out << "function globalInfo()\n{\nreturn array("; + CurrentStats stats=core->getStats(); + + out << QString("\"download_speed\" => \"%1\",").arg(KBytesPerSecToString2(stats.download_speed / 1024.0)); + out << QString("\"upload_speed\" => \"%1\",").arg(KBytesPerSecToString2(stats.upload_speed / 1024.0)); + out << QString("\"bytes_downloaded\" => \"%1\",").arg(stats.bytes_downloaded); + out << QString("\"bytes_uploaded\" => \"%1\",").arg(stats.bytes_uploaded); + out << QString("\"max_download_speed\" => \"%1\",").arg(core->getMaxDownloadSpeed()); + out << QString("\"max_upload_speed\" => \"%1\",").arg(core->getMaxUploadSpeed()); + out << QString("\"max_downloads\" => \"%1\",").arg(Settings::maxDownloads()); + out << QString("\"max_seeds\"=> \"%1\",").arg(Settings::maxSeeds()); + out << QString("\"dht_support\" => \"%1\",").arg(Settings::dhtSupport()); + out << QString("\"use_encryption\" => \"%1\"").arg(Settings::useEncryption()); + out << ");\n}\n"; + } + + + /************************ + *PhpActionExec * + ************************/ + PhpActionExec::PhpActionExec(CoreInterface *c) + { + core=c; + } + + bool PhpActionExec::exec(KURL & url,bool & shutdown) + { + bool ret = false; + shutdown = false; + int separator_loc; + QString parse; + QString torrent_num; + QString file_num; + KURL redirected_url; + redirected_url.setPath(url.path()); + + const QMap<QString, QString> & params = url.queryItems(); + QMap<QString, QString>::ConstIterator it; + + for ( it = params.begin(); it != params.end(); ++it ) + { + // Out(SYS_WEB| LOG_DEBUG) << "exec " << it.key().latin1() << endl; + switch(it.key()[0]) + { + case 'd': + if(it.key()=="dht") + { + if(it.data()=="start") + { + Settings::setDhtSupport(true); + } + else + { + Settings::setDhtSupport(false); + } + + dht::DHTBase & ht = Globals::instance().getDHT(); + if (Settings::dhtSupport() && !ht.isRunning()) + { + ht.start(kt::DataDir() + "dht_table",kt::DataDir() + "dht_key",Settings::dhtPort()); + ret = true; + } + else if (!Settings::dhtSupport() && ht.isRunning()) + { + ht.stop(); + ret = true; + } + else if (Settings::dhtSupport() && ht.getPort() != Settings::dhtPort()) + { + ht.stop(); + ht.start(kt::DataDir() + "dht_table",kt::DataDir() + "dht_key",Settings::dhtPort()); + ret = true; + } + } + break; + case 'e': + if(it.key()=="encription") + { + if(it.data()=="start") + { + Settings::setUseEncryption(true); + } + else + { + Settings::setUseEncryption(false); + } + + if (Settings::useEncryption()) + { + Globals::instance().getServer().enableEncryption(Settings::allowUnencryptedConnections()); + } + else + { + Globals::instance().getServer().disableEncryption(); + } + ret = true; + } + break; + case 'f': + //parse argument into torrent number and file number + separator_loc=it.data().find('-'); + parse=it.data(); + torrent_num.append(parse.left(separator_loc)); + file_num.append(parse.right(parse.length()-(separator_loc+1))); + + if(it.key()=="file_lp") + { + QPtrList<TorrentInterface>::iterator i= core->getQueueManager()->begin(); + for(int k=0; i != core->getQueueManager()->end(); i++, k++) + { + if(torrent_num.toInt()==k) + { + TorrentFileInterface & file = (*i)->getTorrentFile(file_num.toInt()); + file.setPriority(LAST_PRIORITY); + ret = true; + break; + } + } + } + else if(it.key()=="file_np") + { + QPtrList<TorrentInterface>::iterator i= core->getQueueManager()->begin(); + for(int k=0; i != core->getQueueManager()->end(); i++, k++) + { + if(torrent_num.toInt()==k) + { + TorrentFileInterface & file = (*i)->getTorrentFile(file_num.toInt()); + file.setPriority(NORMAL_PRIORITY); + ret = true; + break; + } + } + } + else if(it.key()=="file_hp") + { + QPtrList<TorrentInterface>::iterator i= core->getQueueManager()->begin(); + for(int k=0; i != core->getQueueManager()->end(); i++, k++) + { + if(torrent_num.toInt()==k) + { + TorrentFileInterface & file = (*i)->getTorrentFile(file_num.toInt()); + file.setPriority(FIRST_PRIORITY); + ret = true; + break; + } + } + } + else if(it.key()=="file_stop") + { + QPtrList<TorrentInterface>::iterator i= core->getQueueManager()->begin(); + for(int k=0; i != core->getQueueManager()->end(); i++, k++) + { + if(torrent_num.toInt()==k) + { + TorrentFileInterface & file = (*i)->getTorrentFile(file_num.toInt()); + file.setPriority(ONLY_SEED_PRIORITY); + ret = true; + break; + } + } + } + break; + case 'g': + if(it.key()=="global_connection") + { + Settings::setMaxTotalConnections(it.data().toInt()); + PeerManager::setMaxTotalConnections(Settings::maxTotalConnections()); + ret = true; + } + break; + case 'l': + if(it.key()=="load_torrent" && it.data().length() > 0) + { + core->loadSilently(KURL::decode_string(it.data())); + ret = true; + } + break; + case 'm': + if(it.key()=="maximum_downloads") + { + core->setMaxDownloads(it.data().toInt()); + Settings::setMaxDownloads(it.data().toInt()); + ret = true; + } + else if(it.key()=="maximum_seeds") + { + core->setMaxSeeds(it.data().toInt()); + Settings::setMaxSeeds(it.data().toInt()); + ret = true; + } + else if(it.key()=="maximum_connection_per_torrent") + { + PeerManager::setMaxConnections(it.data().toInt()); + Settings::setMaxConnections(it.data().toInt()); + ret = true; + } + else if(it.key()=="maximum_upload_rate") + { + Settings::setMaxUploadRate(it.data().toInt()); + core->setMaxUploadSpeed(Settings::maxUploadRate()); + net::SocketMonitor::setUploadCap( Settings::maxUploadRate() * 1024); + ret = true; + } + else if(it.key()=="maximum_download_rate") + { + Settings::setMaxDownloadRate(it.data().toInt()); + core->setMaxDownloadSpeed(Settings::maxDownloadRate()); + net::SocketMonitor::setDownloadCap(Settings::maxDownloadRate()*1024); + ret = true; + } + else if(it.key()=="maximum_share_ratio") + { + Settings::setMaxRatio(it.data().toInt()); + ret = true; + } + break; + case 'n': + if(it.key()=="number_of_upload_slots") + { + Settings::setNumUploadSlots(it.data().toInt()); + Choker::setNumUploadSlots(Settings::numUploadSlots()); + ret = true; + } + break; + case 'p': + if(it.key()=="port") + { + Settings::setPort(it.data().toInt()); + core->changePort(Settings::port()); + } + else if(it.key()=="port_udp_tracker") + { + Settings::setUdpTrackerPort(it.data().toInt()); + UDPTrackerSocket::setPort(Settings::udpTrackerPort()); + ret = true; + } + break; + case 'q': + if(it.key()=="quit" && !it.data().isEmpty()) + { + shutdown = true; + ret = true; + } + break; + case 'r': + if(it.key()=="remove") + { + QPtrList<TorrentInterface>::iterator i= core->getQueueManager()->begin(); + for(int k=0; i != core->getQueueManager()->end(); i++, k++) + { + if(it.data().toInt()==k) + { + core->remove((*i), false); + ret = true; + break; + } + } + } + break; + case 's': + if(it.key()=="stopall" && !it.data().isEmpty()) + { + core->stopAll(3); + } + else if(it.key()=="startall" && !it.data().isEmpty()) + { + core->startAll(3); + } + else if(it.key()=="stop") + { + QPtrList<TorrentInterface>::iterator i= core->getQueueManager()->begin(); + for(int k=0; i != core->getQueueManager()->end(); i++, k++) + { + if(it.data().toInt()==k) + { + (*i)->stop(true); + ret = true; + break; + } + } + } + else if(it.key()=="start") + { + QPtrList<TorrentInterface>::iterator i= core->getQueueManager()->begin(); + for(int k=0; i != core->getQueueManager()->end(); i++, k++) + { + if(it.data().toInt()==k) + { + (*i)->start(); + ret = true; + break; + } + } + } + break; + + default: + // add unknown query items to the redirected url + // we don't add the keys above, because if the user presses refresh + // the same action will be taken again + redirected_url.addQueryItem(it.key(),it.data()); + break; + } + Settings::writeConfig(); + } + + if (ret) + url = redirected_url; + + return ret; + } + + /************************ + *PhpInterface * + ************************/ + PhpInterface::PhpInterface(CoreInterface *c):PhpCodeGenerator(c), PhpActionExec(c) + { + + } + +} |