diff options
author | Emanoil Kotsev <[email protected]> | 2018-11-12 21:18:37 +0100 |
---|---|---|
committer | Emanoil Kotsev <[email protected]> | 2023-01-14 03:44:08 +0000 |
commit | e274309d9293777aaaecebccaa29a339a05bd4f9 (patch) | |
tree | a00349c31b90cdedaa6e351dfe93950b55903dce /src/tdeioclient | |
parent | 63c233987977aa48b701edeb47079a6153359fbe (diff) | |
download | tdebluez-e274309d9293777aaaecebccaa29a339a05bd4f9.tar.gz tdebluez-e274309d9293777aaaecebccaa29a339a05bd4f9.zip |
Based on KDE3 bluez4 version a TDE bluez5 version was created
Signed-off-by: Emanoil Kotsev <[email protected]>
Diffstat (limited to 'src/tdeioclient')
-rw-r--r-- | src/tdeioclient/CMakeLists.txt | 40 | ||||
-rw-r--r-- | src/tdeioclient/commandhandler.cpp | 407 | ||||
-rw-r--r-- | src/tdeioclient/commandhandler.h | 60 | ||||
-rw-r--r-- | src/tdeioclient/main.cpp | 73 |
4 files changed, 580 insertions, 0 deletions
diff --git a/src/tdeioclient/CMakeLists.txt b/src/tdeioclient/CMakeLists.txt new file mode 100644 index 0000000..19cc86d --- /dev/null +++ b/src/tdeioclient/CMakeLists.txt @@ -0,0 +1,40 @@ +################################################# +# +# (C) 2018 Emanoil Kotsev +# deloptes (AT) gmail.com +# +# Improvements and feedback are welcome +# +# This file is released under GPL >= 2 +# +################################################# + +project (tdeioclient) + +include_directories( + ${CMAKE_CURRENT_BINARY_DIR} + ${CMAKE_BINARY_DIR} + ${CMAKE_SOURCE_DIR} + ${CMAKE_SOURCE_DIR}/src/libtdebluez + ${CMAKE_SOURCE_DIR}/src/tdeioclient + ${CMAKE_BINARY_DIR}/src + ${CMAKE_BINARY_DIR}/src/tdeioclient + ${TDE_INCLUDE_DIR} + ${TQT_INCLUDE_DIRS} + ${DBUS_INCLUDE_DIRS} + ${DBUS_TQT_INCLUDE_DIRS} +) + +link_directories( + ${TQT_LIBRARY_DIRS} +) + +##### tdeioclient (tdeinit) ###################### + +tde_add_executable ( tdeioclient AUTOMOC + SOURCES + commandhandler.cpp main.cpp + LINK + ${DBUS_TQT_LIBRARIES} tdecore-shared tdebluez-shared tdeio-shared + DESTINATION ${BIN_INSTALL_DIR} +) diff --git a/src/tdeioclient/commandhandler.cpp b/src/tdeioclient/commandhandler.cpp new file mode 100644 index 0000000..4a24716 --- /dev/null +++ b/src/tdeioclient/commandhandler.cpp @@ -0,0 +1,407 @@ +/*************************************************************************** + * Copyright (C) 2004 by Fred Schaettgen <[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. * + ***************************************************************************/ +#include "commandhandler.h" +#include <tdecmdlineargs.h> +#include <tdeapplication.h> +#include <tdelocale.h> +#include <iostream> +#include <kdebug.h> +#include <tqdatetime.h> +#include <tqtimer.h> +#include <tdeio/job.h> + +CommandHandler::CommandHandler(TDECmdLineArgs *a) +{ + this->iterate = false; + this->args = a; + returnValue = 0; + if (args->count() < 2) + { + exitPrintUsage(i18n("Arguments missing.")); + } + origCommand = args->arg(0); + for (int n = 1; n < args->count() - 1; ++n) + { + sources.append(args->arg(n)); + } + target = args->arg(args->count() - 1); + targets = sources; + targets.append(target); + + if (args->isSet("outfile")) + { + outFile.setName(args->getOption("outfile")); + outFile.open(IO_WriteOnly); + } + else + { + // Open stdout + outFile.open(IO_WriteOnly, 1); + } + + if (args->isSet("infile")) + { + inFile.setName(args->getOption("infile")); + inFile.open(IO_ReadOnly); + } + else + { + // Open stdin + inFile.open(IO_ReadOnly, 0); + } + + showProgressWindow = args->isSet("progresswindow"); + overwrite = args->isSet("overwrite"); +} + +CommandHandler::~CommandHandler() +{ +} + +void CommandHandler::start() +{ + if (origCommand == "ls") + { + command = "ls"; + list(target); + } + else if (origCommand == "get" || origCommand == "cat" || origCommand == "read") + { + command = "get"; + get(target); + } + else if (origCommand == "put" || origCommand == "write") + { + command = "put"; + put(target); + } + else if (origCommand == "mkdir") + { + command = "mkdir"; + mkdir(target); + } + else if (origCommand == "rmdir") + { + command = "rmdir"; + rmdir(target); + } + else if (origCommand == "rm" || origCommand == "del") + { + command = "del"; + del(targets); + } + else if (origCommand == "cp" || origCommand == "copy") + { + command = "copy"; + copy(sources, target); + } + else + { + command = origCommand; + exitPrintUsage(i18n("unknown command: %1").arg(command)); + } +} + +void CommandHandler::commonConnect(TDEIO::Job* job) +{ + connect(job, SIGNAL(infoMessage(TDEIO::Job*,const TQString&)), + this, SLOT(slotInfoMessage(TDEIO::Job*,const TQString&))); + connect(job, SIGNAL(percent (TDEIO::Job*, unsigned long)), + this, SLOT(slotPercent(TDEIO::Job*, unsigned long))); + connect(job, SIGNAL(result(TDEIO::Job*)), this, SLOT(slotFinished(TDEIO::Job*))); +} + +KURL::List CommandHandler::urlList(const TQStringList& sources) +{ + KURL::List ret; + for (size_t n = 0; n < sources.size(); ++n) + { + ret.append(KURL(sources[n])); + } + return ret; +} + +// Commands --------------------------------------------------- + +void CommandHandler::list(const TQString& target) +{ + bool showHidden = true; + TDEIO::ListJob* job = TDEIO::listDir(KURL(target), showProgressWindow, showHidden); + this->job = job; + commonConnect(job); + connect(job, SIGNAL(entries(TDEIO::Job*, const TDEIO::UDSEntryList&)), + this, SLOT(slotEntries(TDEIO::Job*, const TDEIO::UDSEntryList&))); +} + +void CommandHandler::get(const TQString& target) +{ + bool reload = false; + TDEIO::TransferJob* job = TDEIO::get(KURL(target), reload, showProgressWindow); + this->job = job; + commonConnect(job); + connect(job, SIGNAL(data(TDEIO::Job*,const TQByteArray&)), + this, SLOT(slotData(TDEIO::Job*,const TQByteArray&))); +} + +void CommandHandler::put(const TQString& target) +{ + int permissions = -1; + bool resume = false; + TDEIO::TransferJob* job = TDEIO::put(KURL(target), permissions, + overwrite, resume, showProgressWindow); + this->job = job; + commonConnect(job); + connect(job, SIGNAL(dataReq(TDEIO::Job*,TQByteArray&)), + this, SLOT(slotDataReq(TDEIO::Job*,TQByteArray&))); +} + +void CommandHandler::mkdir(const TQString& target) +{ + int permissions = -1; + TDEIO::SimpleJob* job = TDEIO::mkdir(KURL(target), permissions); + this->job = job; + commonConnect(job); +} + +void CommandHandler::rmdir(const TQString& target) +{ + TDEIO::SimpleJob* job = TDEIO::rmdir(KURL(target)); + this->job = job; + commonConnect(job); +} + +void CommandHandler::del(const TQStringList& targets) +{ + bool shred = false; + TDEIO::DeleteJob* job = TDEIO::del(urlList(targets), shred, showProgressWindow); + this->job = job; + commonConnect(job); +} + +void CommandHandler::copy(const TQStringList& sources, const TQString& target) +{ + TDEIO::CopyJob *job = TDEIO::copy(urlList(sources), KURL(target), + showProgressWindow); + this->job = job; + commonConnect(job); +} + +// Signal handlers -------------------------------------------- + +void CommandHandler::slotEntries(TDEIO::Job* /*job*/, const TDEIO::UDSEntryList& list) +{ + if (command == "ls") + { + for (size_t n = 0; n < list.size(); ++n) + { + TDEIO::UDSEntry entry = list[n]; + + TQDateTime date = TQDateTime::currentDateTime(); + TQString user = "n/a"; + TQString iconName = "unknown"; + TQString group = "n/a"; + TQString extra = "n/a"; + TQString name = "n/a"; + TQDateTime mTime = TQDateTime::currentDateTime(); + TQDateTime aTime = TQDateTime::currentDateTime(); + TQDateTime cTime = TQDateTime::currentDateTime(); + int fileType = 0; + TQString linkDest = "n/a"; + TQString url = "n/a"; + TQString mimeType = "n/a"; + TQString guessedMimeType = "n/a"; + TQString xmlProperties = "n/a"; + long long size = -1; + int access = 0; + + for (size_t m = 0; m < entry.size(); ++m) + { + TDEIO::UDSAtom atom = entry[m]; + switch (atom.m_uds) + { + case TDEIO::UDS_TIME: + date.setTime_t(atom.m_long); + break; + case TDEIO::UDS_SIZE: + size = atom.m_long; + break; + case TDEIO::UDS_USER: + user = atom.m_str; + break; + case TDEIO::UDS_ICON_NAME: + iconName = atom.m_str; + break; + case TDEIO::UDS_GROUP: + group = atom.m_str; + break; + case TDEIO::UDS_EXTRA: + extra = atom.m_str; + break; + case TDEIO::UDS_NAME: + name = atom.m_str; + break; + case TDEIO::UDS_ACCESS: + access = atom.m_long; + break; + case TDEIO::UDS_MODIFICATION_TIME: + mTime.setTime_t(atom.m_long); + break; + case TDEIO::UDS_ACCESS_TIME: + aTime.setTime_t(atom.m_long); + break; + case TDEIO::UDS_CREATION_TIME: + cTime.setTime_t(atom.m_long); + break; + case TDEIO::UDS_FILE_TYPE: + fileType = atom.m_long; + break; + case TDEIO::UDS_LINK_DEST: + linkDest = atom.m_str; + break; + case TDEIO::UDS_URL: + url = atom.m_str; + break; + case TDEIO::UDS_MIME_TYPE: + mimeType = atom.m_str; + break; + case TDEIO::UDS_GUESSED_MIME_TYPE: + guessedMimeType = atom.m_str; + break; + case TDEIO::UDS_XML_PROPERTIES: + xmlProperties = atom.m_str; + break; + }; + } + + if (args->isSet("access")) + { + std::cout << TQString::number(access, 8).local8Bit() << " "; + } + if (args->isSet("filetype")) + { + std::cout << TQString::number(fileType).rightJustify(4).local8Bit() << " "; + } + if (args->isSet("user")) + { + std::cout << user.rightJustify(8).local8Bit() << " "; + } + if (args->isSet("group")) + { + std::cout << group.rightJustify(8).local8Bit() << " "; + } + if (args->isSet("size")) + { + std::cout << TQString::number(size).rightJustify(9).local8Bit() << " "; + } + if (args->isSet("date")) + { + std::cout << date.toString("yyyy-MM-dd hh:mm:ss").local8Bit() << " "; + } + if (args->isSet("mtime")) + { + std::cout << mTime.toString("yyyy-MM-dd hh:mm:ss").local8Bit() << " "; + } + if (args->isSet("atime")) + { + std::cout << aTime.toString("yyyy-MM-dd hh:mm:ss").local8Bit() << " "; + } + if (args->isSet("ctime")) + { + std::cout << cTime.toString("yyyy-MM-dd hh:mm:ss").local8Bit() << " "; + } + if (args->isSet("iconName")) + { + std::cout << iconName.local8Bit() << " "; + } + if (args->isSet("mimetype")) + { + std::cout << mimeType.local8Bit() << " "; + } + if (args->isSet("guessedmimetype")) + { + std::cout << guessedMimeType.local8Bit() << " "; + } + if (args->isSet("linkdest")) + { + std::cout << linkDest.local8Bit() << " "; + } + if (args->isSet("url")) + { + std::cout << url.local8Bit() << " "; + } + if (args->isSet("name")) + { + std::cout << name.local8Bit() << " "; + } + if (args->isSet("xmlproperties")) + { + std::cout << xmlProperties.local8Bit() << " "; + } + if (args->isSet("extra")) + { + std::cout << extra.local8Bit() << " "; + } + std::cout << std::endl; + } + } +} + +void CommandHandler::slotData(TDEIO::Job* /*job*/, const TQByteArray &data) +{ + outFile.writeBlock(data); +} + +void CommandHandler::slotDataReq(TDEIO::Job* /*job*/, TQByteArray &data) +{ + data.resize(65536); + data.resize(inFile.readBlock(data.data(), data.size())); +} + +void CommandHandler::slotInfoMessage(TDEIO::Job* /*job*/, const TQString& msg) +{ + if (msg != lastMessage && args->isSet("messages")) + { + std::cerr << " >" << msg.local8Bit() << std::endl; + lastMessage = msg; + } +} + +void CommandHandler::slotPercent(TDEIO::Job* /*job*/, unsigned long /*percent*/) +{ + +} + +void CommandHandler::slotFinished(TDEIO::Job* job) +{ + if (job->error() != 0) + { + std::cerr << job->errorString().local8Bit() << std::endl; + iterate = false; + } + else + { + if (iterate) + { + start(); + } + } + + if (!iterate) + { + TDEApplication::kApplication()->exit(job->error()); + } +} + +void CommandHandler::exitPrintUsage(const TQString& message) +{ + std::cout << message.local8Bit() << std::endl; + TDECmdLineArgs::usage(); +} + +#include "commandhandler.moc" diff --git a/src/tdeioclient/commandhandler.h b/src/tdeioclient/commandhandler.h new file mode 100644 index 0000000..29fb552 --- /dev/null +++ b/src/tdeioclient/commandhandler.h @@ -0,0 +1,60 @@ +//-*-c++-*- +/*************************************************************************** + * Copyright (C) 2004 by Fred Schaettgen <[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. * + ***************************************************************************/ +#ifndef COMMANDHANDLER_H +#define COMMANDHANDLER_H + +#include <tqobject.h> +#include <tqstringlist.h> +#include <tdeio/jobclasses.h> +#include <tqfile.h> +#include <kurl.h> + +class TDECmdLineArgs; +namespace TDEIO { class Job; } + +class CommandHandler : public TQObject +{ + Q_OBJECT + +public: + CommandHandler(TDECmdLineArgs *args); + ~CommandHandler(); + void start(); + +private: + KURL::List urlList(const TQStringList& list); + void exitPrintUsage(const TQString& message); + void list(const TQString& target); + void get(const TQString& target); + void put(const TQString& target); + void mkdir(const TQString& target); + void rmdir(const TQString& target); + void del(const TQStringList& targets); + void copy(const TQStringList& sources, const TQString& target); + void commonConnect(TDEIO::Job* job); + + TQString command, origCommand, target, lastMessage; + TQStringList targets, sources; + TDEIO::Job* job; + int returnValue; + TDECmdLineArgs *args; + TQFile outFile, inFile; + bool showProgressWindow, overwrite, iterate; + +private slots: + void slotFinished(TDEIO::Job *job); + void slotEntries(TDEIO::Job* job, const TDEIO::UDSEntryList& list); + void slotData(TDEIO::Job *, const TQByteArray &data); + void slotDataReq(TDEIO::Job *, TQByteArray &data); + void slotInfoMessage(TDEIO::Job* job,const TQString& msg); + void slotPercent(TDEIO::Job* job, unsigned long percent); +}; + +#endif diff --git a/src/tdeioclient/main.cpp b/src/tdeioclient/main.cpp new file mode 100644 index 0000000..59762b7 --- /dev/null +++ b/src/tdeioclient/main.cpp @@ -0,0 +1,73 @@ +//-*-c++-*- +/*************************************************************************** + * Copyright (C) 2003 by Fred Schaettgen * + * [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. * + ***************************************************************************/ + +#include <tdeapplication.h> +#include <tdeaboutdata.h> +#include <tdecmdlineargs.h> +#include <tdelocale.h> +#include <kurl.h> +#include <tqwidget.h> + +#include "commandhandler.h" + +static const char description[] = + I18N_NOOP("TDEIO command line client for tdebluez"); + +//FIXME static const char* version = TDEBluetoothConfig::version; + +static const char* version = "0.0.1"; + +static TDECmdLineOptions options[] = +{ + {"d", 0, 0}, {"date", I18N_NOOP("List date"), 0}, + {"u", 0, 0}, {"user", I18N_NOOP("List user"), 0}, + {"i", 0, 0}, {"iconName", I18N_NOOP("List icon name"), 0}, + {"g", 0, 0}, {"group", I18N_NOOP("List group"), 0}, + {"extra", I18N_NOOP("List extra"), 0}, + {"noname", I18N_NOOP("Do not list name"), 0}, + {"p", 0, 0}, {"access", I18N_NOOP("List access permissions"), 0}, + {"m", 0, 0}, {"mtime", I18N_NOOP("List modification time"), 0}, + {"a", 0, 0}, {"atime", I18N_NOOP("List access time"), 0}, + {"c", 0, 0}, {"ctime", I18N_NOOP("List creation time"), 0}, + {"f", 0, 0}, {"filetype", I18N_NOOP("List file type"), 0}, + {"D", 0, 0}, {"linkdest", I18N_NOOP("List link destination"), 0}, + {"U", 0, 0}, {"url", I18N_NOOP("List URL"), 0}, + {"M", 0, 0}, {"mimetype", I18N_NOOP("List mime type"), 0}, + {"G", 0, 0}, {"guessedmimetype", I18N_NOOP("List guessed mime type"), 0}, + {"X", 0, 0}, {"xmlproperties", I18N_NOOP("List XML properties"), 0}, + {"s", 0, 0}, {"size", I18N_NOOP("List size"), 0}, + {"outfile [filename]", I18N_NOOP("Output file. Defaults to stdout"), 0}, + {"infile [filename]", I18N_NOOP("Input file. Defaults to stdin"), 0}, + {"progresswindow", I18N_NOOP("Show a progress window"), 0}, + {"nooverwrite", I18N_NOOP("Ask (graphically) before overwriting files"), 0}, + {"messages", I18N_NOOP("Show messages from the tdeioslave"), 0}, + {"+[cmd]", I18N_NOOP("Command (ls, cat, put, cp, rm, mv, mkdir, rmdir)"), 0 }, + TDECmdLineLastOption +}; + +int main(int argc, char **argv) +{ + TDEAboutData about("tdeioclient", + I18N_NOOP("tdeio client"), + version, description, + TDEAboutData::License_GPL, + "(C) 2004 Fred Schaettgen", 0, 0, + "[email protected]"); + about.addAuthor("Emanoil Kotsev", I18N_NOOP("Bluez5 and port to TDE"), "[email protected]"); + TDECmdLineArgs::init(argc, argv, &about); + TDECmdLineArgs::addCmdLineOptions(options); + TDECmdLineArgs *args = TDECmdLineArgs::parsedArgs(); + TDEApplication app; + + CommandHandler commandHandler(args); + commandHandler.start(); + return app.exec(); +} |