Compare commits

..

18 Commits

10 changed files with 470 additions and 255 deletions

View File

@ -2,6 +2,7 @@ QT += core gui
QT += KItemViews QT += KItemViews
QT += KCompletion QT += KCompletion
QT += widgets QT += widgets
QT += network
LIBS += -lqt5keychain LIBS += -lqt5keychain

View File

@ -2,7 +2,7 @@
Name: rsyncui Name: rsyncui
Summary: Client for rsync server Summary: Client for rsync server
Version: 2.12.5 Version: 2.13.2
Release: %mkrel 1 Release: %mkrel 1
License: GPLv3 License: GPLv3
Group: Networking/Remote access Group: Networking/Remote access

View File

@ -52,7 +52,7 @@ void MainWindow::download()
{ {
info(DEBUGMACRO, "Adding user to server (user@server"); info(DEBUGMACRO, "Adding user to server (user@server");
this->downloading.user = this->connexion.user; this->downloading.user = this->connexion.user;
server = this->connexion.user + "@" + this->downloading.server; server = this->connexion.user + "@" + "[" + this->downloading.server + "]";
env.insert("RSYNC_PASSWORD", this->downloading.password); // Add an environment variable env.insert("RSYNC_PASSWORD", this->downloading.password); // Add an environment variable
this->downloading.process->setProcessEnvironment(env); this->downloading.process->setProcessEnvironment(env);
} }
@ -64,7 +64,7 @@ void MainWindow::download()
param << "--bwlimit=" + QString::number(this->connexion.bandwidthLimit) + bwUnitChar[this->connexion.bandwidthLimitUnit]; param << "--bwlimit=" + QString::number(this->connexion.bandwidthLimit) + bwUnitChar[this->connexion.bandwidthLimitUnit];
} }
ipversion = validateServer(server); ipversion = validateServer(&server);
if (downloading.ipversion == 4 || downloading.ipversion == 6) if (downloading.ipversion == 4 || downloading.ipversion == 6)
{ {
@ -74,7 +74,7 @@ void MainWindow::download()
param << "--port" << QString::number(this->downloading.port).trimmed(); param << "--port" << QString::number(this->downloading.port).trimmed();
param << "-aXP"; param << "-aXP";
param << "[" + server + "]::" + this->downloading.service.trimmed() + "/" + this->downloading.path.trimmed() << this->downloading.savePath.trimmed() + "/"; param << "[" + server + "]::" + this->downloading.service.trimmed() + "/" + preparePath(this->downloading.path) << preparePath(this->downloading.savePath) + "/";
info(DEBUGMACRO, cmd + " " + param.join(" ")); info(DEBUGMACRO, cmd + " " + param.join(" "));
@ -102,6 +102,7 @@ void MainWindow::readRsyncOutput()
{ {
list.clear(); list.clear();
line = QString::fromUtf8(this->downloading.process->readLine()); line = QString::fromUtf8(this->downloading.process->readLine());
info(DEBUGMACRO, "downloading progress : " + line);
if (line.isEmpty()) if (line.isEmpty())
{ {
break; break;

View File

@ -1,6 +1,7 @@
#include "mainwindow.h" #include "mainwindow.h"
#include "tools.h" #include "tools.h"
#include <QTranslator> #include <QTranslator>
#include <QHostInfo>
int main(int argc, char *argv[]) int main(int argc, char *argv[])
{ {
@ -29,5 +30,6 @@ int main(int argc, char *argv[])
MainWindow w; MainWindow w;
info(DEBUGMACRO, "RsyncUI begining"); info(DEBUGMACRO, "RsyncUI begining");
w.show(); w.show();
return a.exec(); return a.exec();
} }

View File

@ -7,12 +7,9 @@
#include "tools.h" #include "tools.h"
#include "password.h" #include "password.h"
#include <kcombobox.h> #include <kcombobox.h>
#include <signal.h>
/* #include <QTextStream>
#include <klineedit.h> #include <QHostInfo>
#include <khistorycombobox.h>
#include <kcompletion.h>
*/
using namespace std; using namespace std;
@ -323,7 +320,7 @@ void MainWindow::populateTree()
info(DEBUGMACRO, "Validating server"); info(DEBUGMACRO, "Validating server");
// validating server's address // validating server's address
this->connexion.ipversion = validateServer(this->connexion.server); this->connexion.ipversion = validateServer(&this->connexion.server);
if (this->connexion.ipversion != 0) if (this->connexion.ipversion != 0)
{ {
// server is validated, scanning directory // server is validated, scanning directory
@ -350,18 +347,22 @@ void MainWindow::populateList(QString server, uint port)
info(DEBUGMACRO, "populateList() => Populating list of services"); info(DEBUGMACRO, "populateList() => Populating list of services");
info(DEBUGMACRO, "port: " + QString::number(port) + " - server: " + server); info(DEBUGMACRO, "port: " + QString::number(port) + " - server: " + server);
if (server.isEmpty()) if (server.isEmpty())
{ {
ui->listWidget->clear(); ui->listWidget->clear();
ui->treeWidget->clear(); ui->treeWidget->clear();
return; return;
} }
if ((server != this->connexion.server))
if (server != this->connexion.server)
{ {
// Determine version of Ip Protocol // Determine version of Ip Protocol
info(DEBUGMACRO, "Server changed"); info(DEBUGMACRO, "Server changed");
this->connexion.ipversion = validateServer(&server);
this->connexion.server = server; this->connexion.server = server;
if (port != false) if (port != false)
{ {
this->connexion.port = port; this->connexion.port = port;
@ -370,13 +371,14 @@ void MainWindow::populateList(QString server, uint port)
QGuiApplication::setOverrideCursor(Qt::WaitCursor); QGuiApplication::setOverrideCursor(Qt::WaitCursor);
// verify if server is in history // verify if server is in history
this->settings.beginGroup("connexion/server"); this->settings.beginGroup("connexion/Servers");
if (this->settings.contains(server)) if (this->settings.contains(server))
{ {
this->settings.beginGroup(server);
info(DEBUGMACRO, "Server configuration exists in settings"); info(DEBUGMACRO, "Server configuration exists in settings");
// server is in history => setting port value // server is in history => setting port value
port = this->settings.value(server).toUInt(); port = this->settings.value("port").toUInt();
this->connexion.ipversion = this->settings.value("ipversion").toUInt(); this->connexion.ipversion = this->settings.value("ipversion").toUInt();
ui->portEdit->setText(QString::number(port)); ui->portEdit->setText(QString::number(port));
this->connexion.port = port; this->connexion.port = port;
@ -384,8 +386,10 @@ void MainWindow::populateList(QString server, uint port)
ok = true; ok = true;
//display list of services //display list of services
//listServices(); // TODO clear in listServices //listServices(); // TODO clear in listServices
this->settings.endGroup();
} }
this->settings.endGroup(); this->settings.endGroup();
this->settings.endGroup();
} }
if (port != this->connexion.port) if (port != this->connexion.port)
{ {
@ -400,8 +404,8 @@ void MainWindow::populateList(QString server, uint port)
{ {
if (this->connexion.ipversion == 0) if (this->connexion.ipversion == 0)
{ {
this->connexion.ipversion = validateServer(server); this->connexion.ipversion = validateServer(&server);
info(DEBUGMACRO, QString::number(this->connexion.ipversion)); info(DEBUGMACRO, "IP version : " + QString::number(this->connexion.ipversion));
} }
if (this->connexion.ipversion != 0) if (this->connexion.ipversion != 0)
@ -411,17 +415,27 @@ void MainWindow::populateList(QString server, uint port)
info(DEBUGMACRO,"Saving server configuration in settings"); info(DEBUGMACRO,"Saving server configuration in settings");
// storing serverURL and port in settings // storing serverURL and port in settings
this->settings.setValue(server, port); this->settings.beginGroup("connnexion");
this->settings.setValue(server, this->connexion.ipversion); this->settings.beginGroup("Servers");
this->settings.beginGroup(server);
this->settings.setValue("port", port);
this->settings.setValue("ipversion", this->connexion.ipversion);
this->settings.endGroup();
this->settings.endGroup();
this->settings.endGroup();
this->settings.sync(); this->settings.sync();
this->downloading.server = server; this->downloading.server = server;
this->downloading.port = port;
this->downloading.ipversion = this->connexion.ipversion; this->downloading.ipversion = this->connexion.ipversion;
// storing in history of combobox // storing in history of combobox
ui->khistorycombobox->addToHistory(server); ui->khistorycombobox->addToHistory(server);
// load and display rsync services of the rsync server // load and display rsync services of the rsync server
}else
{
info(DEBUGMACRO, "ERROR : Unknown IP version");
} }
}else }else
{ {
@ -429,7 +443,8 @@ void MainWindow::populateList(QString server, uint port)
} }
listServices(); listServices();
this->settings.beginGroup("Hidden/" + server); this->settings.beginGroup("Hidden");
this->settings.beginGroup(server);
hidden = this->settings.allKeys(); hidden = this->settings.allKeys();
if (hidden.count() > 0) if (hidden.count() > 0)
{ {
@ -444,6 +459,7 @@ void MainWindow::populateList(QString server, uint port)
} }
} }
this->settings.endGroup(); this->settings.endGroup();
this->settings.endGroup();
// clearing listview // clearing listview
ui->treeWidget->clear(); ui->treeWidget->clear();
QGuiApplication::restoreOverrideCursor(); //setting cursor to default QGuiApplication::restoreOverrideCursor(); //setting cursor to default
@ -471,7 +487,7 @@ bool MainWindow::testServerPresence(QString service, bool askPassword)
{ {
param << "-" + QString::number(this->connexion.ipversion); param << "-" + QString::number(this->connexion.ipversion);
} }
param << "--contimeout=10" << "-nq" << "--port=" + QString::number(this->connexion.port) << + "[" + this->connexion.server + "]::" + service; param << "--contimeout=10" << "-nq" << "--port=" + QString::number(this->connexion.port) << + "[" + this->connexion.server + "]::" + preparePath(service);
myProcess = new QProcess(this); myProcess = new QProcess(this);
myProcess->setProcessChannelMode(QProcess::MergedChannels); myProcess->setProcessChannelMode(QProcess::MergedChannels);
myProcess->start(cmd, param); myProcess->start(cmd, param);
@ -509,7 +525,7 @@ bool MainWindow::testServerPresence(QString service, bool askPassword)
//list services of the rsync server //list services of the rsync server
void MainWindow::listServices() void MainWindow::listServices()
{ {
QString cmd; QString cmd = "/usr/bin/rsync";
QStringList param; QStringList param;
QString line; QString line;
QString errorRsync; QString errorRsync;
@ -524,7 +540,6 @@ void MainWindow::listServices()
// clearing listwidget // clearing listwidget
ui->listWidget->clear(); ui->listWidget->clear();
cmd = "/usr/bin/rsync";
if (this->connexion.ipversion == 0) if (this->connexion.ipversion == 0)
{ {
this->connexion.ipversion = whatIpVersion(this->connexion.server); this->connexion.ipversion = whatIpVersion(this->connexion.server);
@ -538,7 +553,12 @@ void MainWindow::listServices()
{ {
param << "-" + QString::number(this->connexion.ipversion).trimmed(); param << "-" + QString::number(this->connexion.ipversion).trimmed();
server = "[" + this->connexion.server + "]"; server = "[" + this->connexion.server + "]";
}else
{
error(tr("Error : Unknown IP version"));
return;
} }
param << "--contimeout=20" << "--port=" + QString::number(this->connexion.port) << server + "::"; param << "--contimeout=20" << "--port=" + QString::number(this->connexion.port) << server + "::";
myProcess = new QProcess(this); myProcess = new QProcess(this);
@ -583,7 +603,7 @@ void MainWindow::listServices()
// connect to rsync server to get list of files // connect to rsync server to get list of files
bool MainWindow::scanDir(Connexion * connexion, QTreeWidgetItem *parent, QString path) bool MainWindow::scanDir(Connexion * connexion, QTreeWidgetItem *parent, QString path)
{ {
QString cmd; QString cmd = "rsync";
QStringList param; QStringList param;
QStringList sizeA; QStringList sizeA;
QString line; QString line;
@ -593,6 +613,7 @@ bool MainWindow::scanDir(Connexion * connexion, QTreeWidgetItem *parent, QString
QString fileType; QString fileType;
QString date; QString date;
QString dirName = ""; QString dirName = "";
QString user;
QProcess * myProcess; QProcess * myProcess;
QProcessEnvironment env = QProcessEnvironment::systemEnvironment(); QProcessEnvironment env = QProcessEnvironment::systemEnvironment();
bool isDir = false; bool isDir = false;
@ -603,9 +624,12 @@ bool MainWindow::scanDir(Connexion * connexion, QTreeWidgetItem *parent, QString
static uint looping; static uint looping;
QStringList dirs; QStringList dirs;
QString server = connexion->server; QString server = connexion->server;
bool ret = false;
info(DEBUGMACRO, "scandir() => connect to rsync server to get list of files"); info(DEBUGMACRO, "scandir() => connect to rsync server to get list of files");
ui->listWidget->setCursor(Qt::WaitCursor);
myProcess = new QProcess(this); myProcess = new QProcess(this);
myProcess->setProcessChannelMode(QProcess::MergedChannels); myProcess->setProcessChannelMode(QProcess::MergedChannels);
@ -615,24 +639,26 @@ bool MainWindow::scanDir(Connexion * connexion, QTreeWidgetItem *parent, QString
} }
if (nChild == 0) if (nChild == 0)
{ {
if (!connexion->user.isEmpty())
{
server.prepend(connexion->user + "@");
env.insert("RSYNC_PASSWORD", connexion->password); // Add an environment variable
}else
{
server.prepend("anonymous@");
env.insert("RSYNC_PASSWORD", "anonymous"); // Add an environment variable
}
myProcess->setProcessEnvironment(env); myProcess->setProcessEnvironment(env);
info(DEBUGMACRO, "ipversion => " + QString::number(connexion->ipversion)); info(DEBUGMACRO, "ipversion => " + QString::number(connexion->ipversion));
cmd = "rsync";
if(this->connexion.ipversion == 4 || this->connexion.ipversion == 6) if(this->connexion.ipversion == 4 || this->connexion.ipversion == 6)
{ {
param << "-" + QString::number(connexion->ipversion).trimmed(); param << "-" + QString::number(connexion->ipversion).trimmed();
} }
param << "--contimeout=20" << "--port=" + QString::number(connexion->port) << "[" + server + "]::" + path;
if (!connexion->user.isEmpty())
{
user = connexion->user + "@";
env.insert("RSYNC_PASSWORD", connexion->password); // Add an environment variable
}else
{
user = "anonymous@";
env.insert("RSYNC_PASSWORD", "anonymous"); // Add an environment variable
}
param << "--contimeout=20" << "--port=" + QString::number(connexion->port) << user + "[" + server + "]::" + preparePath(path) ;
info(DEBUGMACRO, cmd + " " + param.join(" ")); info(DEBUGMACRO, cmd + " " + param.join(" "));
@ -733,37 +759,59 @@ bool MainWindow::scanDir(Connexion * connexion, QTreeWidgetItem *parent, QString
}while(readOk); }while(readOk);
// buffer empty go to waiting new datas // buffer empty go to waiting new datas
testRsyncReturn(this, myProcess); ret = testRsyncReturn(this, myProcess);
myProcess->close(); myProcess->close();
} }
return false; ui->listWidget->setCursor(Qt::ArrowCursor);
return ret;
} }
// validate address server // validate address server
uint MainWindow::validateServer(QString server) uint MainWindow::validateServer(QString *server)
{ {
QString cmd; QString cmd;
QStringList param; QStringList param;
QString line; QString line;
QProcess * myProcess; QProcess * myProcess;
QStringList responseList; QStringList responseList;
QFile fileHandle("/etc/hosts");
uint ipversion; uint ipversion = 0;
int answerFound = 0; int answerFound = 0;
int queryPos = 0; int queryPos = 0;
QHostAddress serverAddress;
info(DEBUGMACRO, "ValidateServer() => Validating server address"); info(DEBUGMACRO, "ValidateServer() => Validating server address");
ipversion = whatIpVersion(server); //if (ipversion == 0) // not an Ip address, perhaps a server name
//{
if (ipversion == 0) // not an Ip address, perhaps a server name serverAddress = searchHosts(*server);
if (!serverAddress.isNull())
{ {
server->clear();
server->append(serverAddress.toString());
info(DEBUGMACRO, "Server address : " + *server);
}else
{
if (!serverAddress.setAddress(*server))
{
info(DEBUGMACRO, "Digging server name"); info(DEBUGMACRO, "Digging server name");
cmd = "dig"; cmd = "dig";
param << "-t A"; // IP V4 query param << server->trimmed() ;
param << "-t AAAA"; // IP V6 query if (ipversion == IPV4)
param << server.trimmed() ; {
param << "A"; // IP V4 query
}else if (ipversion == IPV6)
{
param << "AAAA"; // IP V6 query
}else
{
error("Protocol is not IPV4 or IPV6 !!");
}
info(DEBUGMACRO, cmd + " " + param.join(" ")); info(DEBUGMACRO, cmd + " " + param.join(" "));
@ -797,12 +845,11 @@ uint MainWindow::validateServer(QString server)
info(DEBUGMACRO, "line is:\n" + line); info(DEBUGMACRO, "line is:\n" + line);
responseList = line.split(QRegExp("\\s+")); responseList = line.split(QRegExp("\\s+"));
info(DEBUGMACRO, "ip Address is => " + responseList.at(4)); info(DEBUGMACRO, "ip Address is => " + responseList.at(4));
if(responseList.at(3) == "A") if (serverAddress.setAddress(responseList.at(4)))
{ {
return 4; //error ("Address " + responseList.at(4) + " is bad");
}else if(responseList.at(3) == "AAAA") server->clear();
{ server->append(serverAddress.toString());
return 6;
} }
} }
} }
@ -811,23 +858,30 @@ uint MainWindow::validateServer(QString server)
} }
myProcess->close(); myProcess->close();
} }
info(DEBUGMACRO, "Returning ip version: " + QString::number(ipversion));
return ipversion;
return 0;
} }
info(DEBUGMACRO, "Returning ip version: " + QString::number(ipversion));
//ipversion = whatIpVersion(*server);
ipversion = serverAddress.protocol();
return (ipversion==IPV4?4:6);
}
// slot activated when button connection is clicked // slot activated when button connection is clicked
void MainWindow::on_connectButton_clicked() void MainWindow::on_connectButton_clicked()
{ {
QString server; QString server;
uint port; uint port;
//uint ipversion;
info(DEBUGMACRO, "on_connectButton_clicked() => Connexion button clicked"); info(DEBUGMACRO, "on_connectButton_clicked() => Connexion button clicked");
port = ui->portEdit->text().toUInt(); port = ui->portEdit->text().toUInt();
if (port > 0 and port < 65535) if (port > 0 and port < 65535)
{ {
server = ui->khistorycombobox->currentText(); server = ui->khistorycombobox->currentText();
//ipversion = validateServer(&server);
populateList(server, port); populateList(server, port);
}else }else
{ {
@ -874,7 +928,8 @@ void MainWindow::addTreeItem(QString name, QString fileSize, QString fullsize, Q
}else }else
{ {
// item is a file // item is a file
this->settings.beginGroup("Downloaded/"); this->settings.beginGroup("Downloaded");
//TODO add to settings
this->settings.endGroup(); this->settings.endGroup();
treeItem->setText(1,type); treeItem->setText(1,type);
} }
@ -999,11 +1054,13 @@ void MainWindow::on_treeWidget_itemClicked(QTreeWidgetItem *item, bool downloadD
QString str; QString str;
QMessageBox::StandardButton reply; QMessageBox::StandardButton reply;
int sizeFromRsync; int sizeFromRsync;
bool ret = false;
info(DEBUGMACRO, "on_treeWidget_itemClicked() => Slot activated when a file is clicked in the treeview"); info(DEBUGMACRO, "on_treeWidget_itemClicked() => Slot activated when a file is clicked in the treeview");
if (this->treeviewClicked == true) if (this->treeviewClicked == true)
{ {
info(DEBUGMACRO, "double click ignored");
return; return;
} }
@ -1040,7 +1097,7 @@ void MainWindow::on_treeWidget_itemClicked(QTreeWidgetItem *item, bool downloadD
}else }else
{ {
this->downloading.savePath = this->settings.value(str).toString(); this->downloading.savePath = this->settings.value(str).toString();
info(DEBUGMACRO, "saving folder" + this->downloading.savePath); info(DEBUGMACRO, "saving folder : " + this->downloading.savePath);
} }
// Item is a file // Item is a file
@ -1120,13 +1177,20 @@ void MainWindow::on_treeWidget_itemClicked(QTreeWidgetItem *item, bool downloadD
if (item->isExpanded() == false) if (item->isExpanded() == false)
{ {
info(DEBUGMACRO, "Item is not expanded"); info(DEBUGMACRO, "Item is not expanded");
while (this->rescan) //if (this->rescan)
{ //{
info(DEBUGMACRO, "Re-scanning path: " + this->connexion.service + "/" + path +"/"); info(DEBUGMACRO, "Re-scanning path: " + this->connexion.service + "/" + path +"/");
scanDir(&this->connexion, item, this->connexion.service + "/" + path +"/"); ret = scanDir(&this->connexion, item, this->connexion.service + "/" + path +"/");
if(!ret)
{
item->setExpanded(true); item->setExpanded(true);
} }
//}
}else
{
item->setExpanded(false);
} }
} }
if (config.autosaveCheckbox->checkState() == Qt::Checked) if (config.autosaveCheckbox->checkState() == Qt::Checked)
@ -1237,7 +1301,7 @@ void MainWindow::downloadFinished(int exitCode, QProcess::ExitStatus exitStatus)
pos = path.lastIndexOf(" => "); pos = path.lastIndexOf(" => ");
this->downloading.server = path.midRef(pos+4).toString(); this->downloading.server = path.midRef(pos+4).toString();
path.resize(pos); path.resize(pos);
this->downloading.port = this->settings.value("connexion/server/" + this->downloading.server).toInt(); this->downloading.port = this->settings.value("connexion/Servers/" + this->downloading.server + "/port").toInt();
this->downloading.path = path; this->downloading.path = path;
//getUserPassword(true); //getUserPassword(true);
@ -1331,7 +1395,7 @@ void MainWindow::loadSettings()
// loading connexion settings // loading connexion settings
// loading servers history // loading servers history
info(DEBUGMACRO, "Restoring server combobox history"); info(DEBUGMACRO, "Restoring server combobox history");
this->settings.beginGroup("connexion/server"); this->settings.beginGroup("connexion/Servers");
QStringList servers = this->settings.allKeys(); QStringList servers = this->settings.allKeys();
this->settings.endGroup(); this->settings.endGroup();
ui->khistorycombobox->insertItems(1,this->settings.value("kHistoryComboBox").toStringList()); ui->khistorycombobox->insertItems(1,this->settings.value("kHistoryComboBox").toStringList());
@ -1498,7 +1562,7 @@ void MainWindow::loadDownloadList()
path.resize(pos); path.resize(pos);
pos = path.lastIndexOf(" => "); pos = path.lastIndexOf(" => ");
this->downloading.server = path.midRef(pos+4).toString(); this->downloading.server = path.midRef(pos+4).toString();
this->downloading.port = this->settings.value("connexion/server/" + this->downloading.server).toInt(); this->downloading.port = this->settings.value("connexion/Servers/" + this->downloading.server+ "/port").toInt();
path.resize(pos); path.resize(pos);
this->downloading.path = path; this->downloading.path = path;
str = "Folder/" + this->downloading.server + "/" + this->downloading.service; str = "Folder/" + this->downloading.server + "/" + this->downloading.service;
@ -1582,3 +1646,69 @@ void MainWindow::on_actionHiddenService_triggered()
preparePopulateTree(); preparePopulateTree();
} }
} }
void MainWindow::on_treeWidget_itemDoubleClicked(QTreeWidgetItem *item, int column)
{
(void) item;
(void) column;
}
void MainWindow::on_treeWidget_doubleClicked(const QModelIndex &index)
{
(void) index;
}
void MainWindow::on_actionPause_downloads_triggered()
{
quint64 processID = this->downloading.process->processId();
QString fileStr = "/proc/" + QString::number(processID) + "/task/" + QString::number(processID) + "/children";
static QMessageBox msgBox;
//msgBox = new QMessageBox(this);
msgBox.setIcon( QMessageBox::Warning );
msgBox.setText("Download suspended");
//QPushButton *btnCancel = msgBox->addButton( "Cancel", QMessageBox::RejectRole );
//msgBox.setAttribute(Qt::WA_DeleteOnClose); // delete pointer after close
msgBox.setModal(false);
info (DEBUGMACRO, "downloading state : " + QString::fromUtf8((this->downloading.paused==0)?"running":"paused"));
info (DEBUGMACRO, "Downloading process ID : " + QString::number(processID));
info (DEBUGMACRO, fileStr);
QFile file(fileStr);
if(!file.open(QIODevice::ReadOnly))
{
QMessageBox::information(0, "error", file.errorString());
}
QTextStream in(&file);
QString children = in.readLine();
info (DEBUGMACRO, "Child process is : " + children);
if (this->downloading.paused)
{
info(DEBUGMACRO, "resuming Download");
if (kill(children.toLongLong(), SIGCONT))
{
info(DEBUGMACRO, "resuming failed : " + QString::number(errno));
}
if (msgBox.isVisible())
{
msgBox.close();
}
this->downloading.paused = false;
}else
{
info(DEBUGMACRO, "pausing Download");
if (kill(children.toLongLong(), SIGTSTP))
{
info(DEBUGMACRO, "resuming failed : " + QString::number(errno));
}
msgBox.show();
this->downloading.paused = true;
}
}

View File

@ -66,6 +66,7 @@ class Connexion
uint port = 873; uint port = 873;
bool quit = false; bool quit = false;
void clear(); void clear();
bool paused = false;
}; };
class Downloading class Downloading
@ -81,6 +82,8 @@ class Downloading
int port = 873; int port = 873;
QProcess * process = nullptr; QProcess * process = nullptr;
bool quit = false; bool quit = false;
bool paused = false;
void clear(); void clear();
}; };
@ -117,8 +120,8 @@ class MainWindow : public QMainWindow
QSystemTrayIcon * trayIcon; QSystemTrayIcon * trayIcon;
QString icon = "/usr/share/icons/RsyncUI.png"; QString icon = "/usr/share/icons/RsyncUI.png";
bool rescan = false; bool rescan = false;
bool stopDlAsked; bool stopDlAsked = false;
bool treeviewClicked; bool treeviewClicked = false;
bool initialization = true; bool initialization = true;
bool exiting = false; bool exiting = false;
@ -154,7 +157,7 @@ class MainWindow : public QMainWindow
void populateTree(); void populateTree();
void populateList(QString server, uint port); void populateList(QString server, uint port);
void listServices(); void listServices();
uint validateServer(QString server); uint validateServer(QString * server);
void addTreeItem(QString name, QString fileSize, QString fullsize, QString type, QString date, bool isDir, QString dirName, QTreeWidgetItem *parent); void addTreeItem(QString name, QString fileSize, QString fullsize, QString type, QString date, bool isDir, QString dirName, QTreeWidgetItem *parent);
bool scanDir(Connexion * connexion, QTreeWidgetItem *parent = NULL, QString path = "" ); bool scanDir(Connexion * connexion, QTreeWidgetItem *parent = NULL, QString path = "" );
void startDownloading(); void startDownloading();
@ -219,6 +222,12 @@ class MainWindow : public QMainWindow
//void on_treeWidget_itemDoubleClicked(QTreeWidgetItem *item, int column); //void on_treeWidget_itemDoubleClicked(QTreeWidgetItem *item, int column);
void on_treeWidget_itemDoubleClicked(QTreeWidgetItem *item, int column);
void on_treeWidget_doubleClicked(const QModelIndex &index);
void on_actionPause_downloads_triggered();
signals: signals:
void stopDownloading(QProcess *); void stopDownloading(QProcess *);
void progressSignal(int); void progressSignal(int);

View File

@ -407,6 +407,7 @@
<addaction name="actionAbout"/> <addaction name="actionAbout"/>
<addaction name="actionAbout_Qt"/> <addaction name="actionAbout_Qt"/>
<addaction name="actionExit"/> <addaction name="actionExit"/>
<addaction name="actionPause_downloads"/>
</widget> </widget>
<action name="DefaultSaveFolder"> <action name="DefaultSaveFolder">
<property name="icon"> <property name="icon">
@ -479,6 +480,20 @@
<string>hidden service</string> <string>hidden service</string>
</property> </property>
</action> </action>
<action name="actionPause_downloads">
<property name="icon">
<iconset theme="media-playback-pause"/>
</property>
<property name="text">
<string>Stop/resume downloads</string>
</property>
<property name="toolTip">
<string>Stop/resume downloading </string>
</property>
<property name="shortcut">
<string>P</string>
</property>
</action>
</widget> </widget>
<customwidgets> <customwidgets>
<customwidget> <customwidget>

View File

@ -1,6 +1,8 @@
#include "mainwindow.h" #include "mainwindow.h"
#include "tools.h" #include "tools.h"
#include "password.h" #include "password.h"
#include <QTextStream>
#include <QHostAddress>
using namespace std; using namespace std;
@ -53,15 +55,31 @@ QString getFileType(QString filename)
return returnValue; return returnValue;
} }
QString preparePath(QString path)
{
return path.trimmed().replace(' ', "\ ");
}
int whatIpVersion(QString ipAddress) int whatIpVersion(QString ipAddress)
{ {
QStringList fieldList; QStringList fieldList;
ulong field; // ulong field;
uint i; // uint i;
uint ipversion;
QHostAddress serverAddress;
info(DEBUGMACRO, "ipVersion of server at " + ipAddress); info(DEBUGMACRO, "ipVersion of server at " + ipAddress);
fieldList = ipAddress.split(":"); if (!serverAddress.setAddress(ipAddress))
{
error ("Address " + ipAddress + " is bad");
}
ipversion = serverAddress.protocol();
return (ipversion==IPV4?4:6);
/*fieldList = ipAddress.split(":");
if (fieldList.count() == 8) if (fieldList.count() == 8)
{ {
for (i=0;i<8;i++) for (i=0;i<8;i++)
@ -88,8 +106,41 @@ int whatIpVersion(QString ipAddress)
} }
info(DEBUGMACRO, "Address is ip V4"); info(DEBUGMACRO, "Address is ip V4");
return 4; return 4;
}*/
} }
return 0;
QHostAddress searchHosts(QString server)
{
QString line = "";
QStringList hosts;
QFile fileHandle("/etc/hosts");
QHostAddress serverAddress;
info(DEBUGMACRO, "reading /etc/hosts");
if (!fileHandle.open(QIODevice::ReadOnly))
{
QMessageBox::information(0,MainWindow::tr("Error"), fileHandle.errorString());
}else
{
QTextStream in(&fileHandle);
while(!in.atEnd())
{
line = in.readLine();
hosts = line.split(QRegularExpression("\\s+"));
if (hosts.contains(server))
{
//if (!serverAddress.isNull()) // and serverAddress.protocol() == QAbstractSocket::IPv4Protocol)
//{
if (!serverAddress.setAddress(hosts.first()))
{
error("Error setting address " + hosts.first());
}
//}
}
}
}
return serverAddress;
} }
void warning(QString message) void warning(QString message)

View File

@ -3,6 +3,10 @@
#define DEBUGMACRO QString(__FILE__) + "->" + QString(Q_FUNC_INFO) + ": " + QString::number(__LINE__) + " -" #define DEBUGMACRO QString(__FILE__) + "->" + QString(Q_FUNC_INFO) + ": " + QString::number(__LINE__) + " -"
#define IPV4 0
#define IPV6 1
#include <QHostAddress>
#include <string> #include <string>
#include <vector> #include <vector>
#include <array> #include <array>
@ -22,5 +26,7 @@ int whatIpVersion(QString server);
void warning(QString message); void warning(QString message);
void error(QString message); void error(QString message);
void info(QString debugHeader, QString message); void info(QString debugHeader, QString message);
QString preparePath(QString path);
QHostAddress searchHosts(QString server);
#endif // TOOLS_H #endif // TOOLS_H

View File

@ -3,6 +3,6 @@
#include <QString> #include <QString>
QString version = "2.12.5"; QString version = "2.13.2";
#endif // VERSION_H #endif // VERSION_H