Token auth

Author: TheOneRing

src/cmd/CMakeLists.txt

@@ -1,7 +1,7 @@
-# Currently disabled until we implemented app token support
-return()
 add_executable(cmd
     cmd.cpp
+        tokencredentials.cpp
+        tokencredentials.h
 )
 set_target_properties(cmd PROPERTIES OUTPUT_NAME "${APPLICATION_EXECUTABLE}cmd")
 ecm_mark_nongui_executable(cmd)

src/cmd/cmd.cpp

@@ -15,10 +15,10 @@
  */
 
 #include "account.h"
+#include "cmd/tokencredentials.h"
 #include "common/syncjournaldb.h"
 #include "common/version.h"
 #include "configfile.h" // ONLY ACCESS THE STATIC FUNCTIONS!
-#include "httpcredentialstext.h"
 #include "libsync/logger.h"
 #include "libsync/theme.h"
 #include "networkjobs/checkserverjobfactory.h"
@@ -51,9 +51,7 @@ struct CmdOptions
     QUrl server_url;
 
     QString remoteFolder;
-    QString config_directory;
-    QString user;
-    QString password;
+    QByteArray token;
     QString proxy;
     bool silent = false;
     bool trustSSL = false;
@@ -76,7 +74,6 @@ struct SyncCTX
     CmdOptions options;
     bool promptRemoveAllFiles;
     AccountPtr account;
-    QString user;
 };
 
 /* If the selective sync list is different from before, we need to disable the read from db
@@ -192,18 +189,6 @@ void setupCredentials(SyncCTX &ctx)
     // 2. From options
     // 3. From prompt (if interactive)
 
-    const auto &url = ctx.options.target_url;
-    ctx.user = url.userName();
-    QString password = url.password();
-
-    if (!ctx.options.user.isEmpty()) {
-        ctx.user = ctx.options.user;
-    }
-
-    if (!ctx.options.password.isEmpty()) {
-        password = ctx.options.password;
-    }
-
     if (!ctx.options.proxy.isNull()) {
         QString host;
         uint32_t port = 0;
@@ -243,7 +228,7 @@ void setupCredentials(SyncCTX &ctx)
         f.close();
     }
 
-    ctx.account->setCredentials(HttpCredentialsText::create(ctx.options.interactive, ctx.user, password));
+    ctx.account->setCredentials(new TokenCredentials(std::move(ctx.options.token)));
     if (ctx.options.trustSSL) {
         QObject::connect(ctx.account->accessManager(), &QNetworkAccessManager::sslErrors, qApp,
             [](QNetworkReply *reply, const QList<QSslError> &errors) { reply->ignoreSslErrors(errors); });
@@ -284,8 +269,7 @@ CmdOptions parseOptions(const QStringList &app_args)
     auto unsyncedfoldersOption = addOption({ { QStringLiteral("unsyncedfolders") }, QStringLiteral("File containing the list of unsynced remote folders (selective sync)"), QStringLiteral("file") });
 
     auto serverOption = addOption({{QStringLiteral("server")}, QStringLiteral("Use [url] as the location of the server."), QStringLiteral("url")});
-    auto userOption = addOption({ { QStringLiteral("u"), QStringLiteral("user") }, QStringLiteral("Use [name] as the login name"), QStringLiteral("name") });
-    auto passwordOption = addOption({{QStringLiteral("p"), QStringLiteral("password")}, QStringLiteral("Use [pass] as password"), QStringLiteral("password")});
+    auto tokenOption = addOption({{QStringLiteral("t"), QStringLiteral("token")}, QStringLiteral("Access token"), QStringLiteral("token")});
 
     auto nonInterActiveOption = addOption({ { QStringLiteral("non-interactive") }, QStringLiteral("Do not block execution with interaction") });
     auto maxRetriesOption = addOption({ { QStringLiteral("max-sync-retries") }, QStringLiteral("Retries maximum n times (default to 3)"), QStringLiteral("n") });
@@ -347,11 +331,8 @@ CmdOptions parseOptions(const QStringList &app_args)
     } else {
         options.server_url = options.target_url;
     }
-    if (parser.isSet(userOption)) {
-        options.user = parser.value(userOption);
-    }
-    if (parser.isSet(passwordOption)) {
-        options.password = parser.value(passwordOption);
+    if (parser.isSet(tokenOption)) {
+        options.token = parser.value(tokenOption).toUtf8();
     }
     if (parser.isSet(excludeOption)) {
         options.exclude = parser.value(excludeOption);
@@ -417,16 +398,8 @@ int main(int argc, char **argv)
         ctx.options.server_url = ctx.options.server_url.adjusted(QUrl::RemoveUserInfo);
         ctx.options.target_url = ctx.options.target_url.adjusted(QUrl::RemoveUserInfo);
 
-        const QUrl baseUrl = [&ctx] {
-            auto tmp = ctx.options.server_url;
-            // Find the url leading to the dav root
-            QStringList splitted = tmp.path().split(ctx.account->davPath());
-            tmp.setPath(splitted.value(0));
-            return tmp;
-        }();
-
 
-        ctx.account->setUrl(baseUrl);
+        ctx.account->setUrl(ctx.options.server_url);
 
         auto *checkServerJob = CheckServerJobFactory(ctx.account->accessManager()).startJob(ctx.account->url(), qApp);
 
@@ -460,24 +433,9 @@ int main(int argc, char **argv)
                         exit(EXIT_FAILURE);
                     }
 
-                    auto userJob = new JsonApiJob(ctx.account, QStringLiteral("ocs/v1.php/cloud/user"), {}, {}, nullptr);
-                    QObject::connect(userJob, &JsonApiJob::finishedSignal, qApp, [userJob, ctx = ctx]() mutable {
-                        const QJsonObject data = userJob->data().value(QStringLiteral("ocs")).toObject().value(QStringLiteral("data")).toObject();
-                        ctx.account->setDavUser(data.value(QStringLiteral("id")).toString());
-                        ctx.account->setDavDisplayName(data.value(QStringLiteral("display-name")).toString());
-
-                        if (ctx.options.server_url == ctx.options.target_url) {
-                            // guess dav path
-                            if (!ctx.options.target_url.path().contains(ctx.account->davPath())) {
-                                ctx.options.target_url = OCC::Utility::concatUrlPath(ctx.options.target_url, ctx.account->davPath());
-                            }
-                        }
-
-                        // much lower age than the default since this utility is usually made to be run right after a change in the tests
-                        SyncEngine::minimumFileAgeForUpload = std::chrono::seconds(0);
-                        sync(ctx);
-                    });
-                    userJob->start();
+                    // much lower age than the default since this utility is usually made to be run right after a change in the tests
+                    SyncEngine::minimumFileAgeForUpload = std::chrono::seconds(0);
+                    sync(ctx);
                 });
                 capabilitiesJob->start();
             } else {

src/libsync/creds/abstractcredentials.h

@@ -44,7 +44,6 @@ class OPENCLOUD_SYNC_EXPORT AbstractCredentials : public QObject
      */
     virtual void setAccount(Account *account);
 
-    virtual QString authType() const = 0;
     virtual AccessManager *createAM() const = 0;
 
     /** Whether there are credentials that can be used for a connection attempt. */

src/libsync/creds/httpcredentials.cpp

@@ -80,16 +80,6 @@ HttpCredentials::HttpCredentials(const QString &accessToken)
 {
 }
 
-QString HttpCredentials::authType() const
-{
-    return QStringLiteral("http");
-}
-
-void HttpCredentials::setAccount(Account *account)
-{
-    AbstractCredentials::setAccount(account);
-}
-
 AccessManager *HttpCredentials::createAM() const
 {
     AccessManager *am = new HttpCredentialsAccessManager(this);

src/libsync/creds/httpcredentials.h

@@ -53,7 +53,6 @@ class OPENCLOUD_SYNC_EXPORT HttpCredentials : public AbstractCredentials
 
     explicit HttpCredentials(const QString &accessToken);
 
-    QString authType() const override;
     AccessManager *createAM() const override;
     bool ready() const override;
     void fetchFromKeychain() override;
@@ -67,7 +66,6 @@ class OPENCLOUD_SYNC_EXPORT HttpCredentials : public AbstractCredentials
      */
     bool refreshAccessToken();
 
-    void setAccount(Account *account) override;
 
 protected:
     HttpCredentials() = default;

test/testutils/syncenginetestutils.h

@@ -508,7 +508,6 @@ class FakeCredentials : public OCC::AbstractCredentials
     {
     }
 
-    QString authType() const override { return QStringLiteral("test"); }
     OCC::AccessManager *createAM() const override { return _am; }
     bool ready() const override { return true; }
     void fetchFromKeychain() override { }