cloudsync.cpp

#include "cloudsync.h"

#include <QDir>
#include <QDebug>
#include "qts3.h"

int cloudSyncFilesWork(cloudSyncData_t* data, QStringList &files)
{
    int failed = 0;
    QtS3 s3(data->S3Access,data->S3Secret);
    QStringList headers;
    headers << "Content-Type: image/jpeg";

    for (int i = 0; i < files.size(); i++) {
        qDebug() << "Processing file:" << files.at(i);
        QFile srcFile(data->filesDirName + "/" + files.at(i));
        if (srcFile.open(QIODevice::ReadOnly)) {
            QByteArray fileData = srcFile.readAll();
            srcFile.close();
            QtS3Reply<void> putReply = s3.put(data->S3Bucket.toLocal8Bit() ,files.at(i) ,fileData ,headers);
            if (putReply.isSuccess()) {
                qDebug() << "Put successful deleting local copy";
                srcFile.remove();
            } else {
                qDebug() << "Put failed keep for next time through:" << putReply.anyErrorString();
                failed++;
            }
        } else {
            qDebug() << "Error opening file" << srcFile.fileName();
            failed++;
        }
    }

    return failed;
}

int cloudSyncEmailsWork(cloudSyncData_t* data, QStringList &emails)
{
    int failed = 0;

    for (int i = 0; i < emails.size(); i++) {
        qDebug() << "Processing email:" << emails.at(i);
        QFile file(data->emailDirName + "/" + emails.at(i));
        if (file.open(QIODevice::ReadOnly)) {
            // First we need to create an SmtpClient object
            // We will use the Gmail's smtp server (smtp.gmail.com, port 465, ssl)
//            qDebug() << "emailServer" << data->emailServer;
//            qDebug() << "emailPort" << data->emailPort;
//            qDebug() << "emailUser" << data->emailUser;
//            qDebug() << "emailFrom" << data->emailFrom;
//            qDebug() << "emailDomain" << data->emailDomain;
//            qDebug() << "emailPassword" << data->emailPassword;
//            qDebug() << "emailTransport" << data->emailTransport;

            SmtpClient smtp(data->emailServer, data->emailPort, SmtpClient::TcpConnection);
            if (data->emailTransport == QString("SSL")) {
                smtp.setConnectionType(SmtpClient::SslConnection);
            } else if (data->emailTransport == QString("TLS")) {
                smtp.setConnectionType(SmtpClient::TlsConnection);
            }

            // We need to set the username (your email address) and password
            // for smtp authentification.

            smtp.setUser(data->emailUser);
            smtp.setPassword(data->emailPassword);
            smtp.setName(data->emailDomain);
            smtp.setAuthMethod(SmtpClient::AuthLogin);

            // Now we create a MimeMessage object. This is the email.

            MimeMessage message;

            EmailAddress sender(data->emailUser, data->emailFrom);
            message.setSender(&sender);

            QString rcptTo;
            rcptTo = file.readLine();
            rcptTo.chop(1);

            EmailAddress to(rcptTo, rcptTo);
            message.addRecipient(&to);

            EmailAddress bcc(data->emailUser, data->emailUser);
            message.addBcc(&bcc);

            message.setSubject(data->emailSubject);

            // Now add some text to the email.
            // First we create a MimeText object.

            QString msgText;
            msgText += data->emailPreamble;
            while (!file.atEnd()) {
                QString destFileName = file.readLine();
                msgText += data->S3URL + data->S3Bucket + "/" + destFileName;
            }
            msgText += data->emailPostamble;

            qDebug() << "Message: " << msgText;
            MimeText text(msgText);

            // Now add it to the mail
            message.addPart(&text);

            // Now we can send the mail

            if (!smtp.connectToHost()) {
                qDebug() << "Failed to connect to host!" << endl;
                failed ++;
                goto abort;
            }

            if (!smtp.login()) {
                qDebug() << "Failed to login!" << endl;
                failed ++;
                goto abort;
            }

            if (!smtp.sendMail(message)) {
                qDebug() << "Failed to send mail!" << endl;
                failed ++;
                goto abort;
            }

            smtp.quit();

            qDebug() << "Successfully staged E-Mail";
            file.close();
            file.remove();
        } else {
            qDebug() << "Error opening file" << file.fileName();
            failed ++;
        }
    }

abort:
    return failed;
}

void cloudSyncWork (cloudSyncData_t* data)
{
    //qDebug() << "cloudSyncWork";

    QDir filesDir(data->filesDirName);
    QDir emailDir(data->emailDirName);

    // First process any pending images to send to the cloud
    QStringList files = filesDir.entryList(QDir::Files);
    bool allSunk = true;
    if (cloudSyncFilesWork(data, files)) allSunk = false;

    // If all the files are uploaded send any pending E-Mails
    if (allSunk && !data->emailServer.isEmpty() && !data->emailDomain.isEmpty() && !data->emailUser.isEmpty() && !data->emailFrom.isEmpty() && !data->emailPassword.isEmpty()) {
        files = emailDir.entryList(QDir::Files);
        cloudSyncEmailsWork(data, files);
    }

    data->working = false;
}

cloudSyncThread::cloudSyncThread() :
    QThread()
{
}

void cloudSyncThread::run()
{
    while(1) {
        cloudSyncWork(&data);

        sleep(30);
    }
}