6 files changed, 273 insertions, 1 deletions

diff --git a/.gitignore b/.gitignore
index 4c1034f..36723a0 100644
--- a/.gitignore
+++ b/.gitignore
@@ -12,4 +12,6 @@ database/development.sqlite
 database/adonis.sqlite
 
 # Uploaded recipes
-recipes/
\ No newline at end of file
+recipes/
+
+.DS_Store
\ No newline at end of file
diff --git a/app/Controllers/Http/UserController.js b/app/Controllers/Http/UserController.js
index 084b023..7c6cece 100644
--- a/app/Controllers/Http/UserController.js
+++ b/app/Controllers/Http/UserController.js
@@ -1,10 +1,39 @@
 'use strict'
 
 const User = use('App/Models/User');
+const Service = use('App/Models/Service');
+const Workspace = use('App/Models/Workspace');
 const {
   validateAll
 } = use('Validator');
+
 const atob = require('atob');
+const btoa = require('btoa');
+const fetch = require('node-fetch');
+const uuid = require('uuid/v4');
+const crypto = require('crypto');
+
+const franzRequest = async (route, method, auth) => {
+  return new Promise(async (resolve, reject) => {
+    const base = 'https://api.franzinfra.com/v1/';
+    const user = 'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_14_6) AppleWebKit/537.36 (KHTML, like Gecko) Ferdi/5.3.0-beta.1 Chrome/69.0.3497.128 Electron/4.2.4 Safari/537.36';
+
+    try {
+      const rawResponse = await fetch(base + route, {
+        method,
+        headers: {
+          'Authorization': 'Bearer ' + auth,
+          'User-Agent': user
+        },
+      });
+      const content = await rawResponse.json();
+
+      resolve(content);
+    } catch (e) {
+      reject();
+    }
+  })
+}
 
 class UserController {
 
@@ -127,6 +156,147 @@ class UserController {
       locale: "en-US"
     });
   }
+
+
+
+  async import({
+    request,
+    response
+  }) {
+    // Validate user input
+    const validation = await validateAll(request.all(), {
+      email: 'required|email|unique:users,email',
+      password: 'required'
+    });
+    if (validation.fails()) {
+      let errorMessage = "There was an error while trying to import your account:\n";
+      for (const message of validation.messages()) {
+        if (message.validation == 'required') {
+          errorMessage += '- Please make sure to supply your ' + message.field + '\n'
+        } else if (message.validation == 'unique') {
+          errorMessage += '- There is already a user with this email.\n'
+        } else {
+          errorMessage += message.message + '\n';
+        }
+      }
+      return response.status(401).send(errorMessage)
+    }
+
+    const {
+      email,
+      password
+    } = request.all()
+
+    const hashedPassword = crypto.createHash('sha256').update(password).digest('base64');
+
+    const base = 'https://api.franzinfra.com/v1/';
+    const userAgent = 'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_14_6) AppleWebKit/537.36 (KHTML, like Gecko) Ferdi/5.3.0-beta.1 Chrome/69.0.3497.128 Electron/4.2.4 Safari/537.36';
+
+    // Try to get an authentication token
+    let token;
+    try {
+      const basicToken = btoa(email + ':' + hashedPassword)
+
+      const rawResponse = await fetch(base + 'auth/login', {
+        method: 'POST',
+        headers: {
+          'Authorization': 'Basic ' + basicToken,
+          'User-Agent': userAgent
+        },
+      });
+      const content = await rawResponse.json();
+
+      if (!content.message || content.message !== 'Successfully logged in') {
+        const errorMessage = 'Could not login into Franz with your supplied credentials. Please check and try again';
+        return response.status(401).send(errorMessage)
+      }
+
+      token = content.token;
+    } catch (e) {
+      return response.status(401).send({
+        "message": "Cannot login to Franz",
+        "error": e
+      })
+    }
+
+    // Get user information
+    let userInf;
+    try {
+      userInf = await franzRequest('me', 'GET', token)
+    } catch (e) {
+      const errorMessage = 'Could not get your user info from Franz. Please check your credentials or try again later.\nError: ' + e;
+      return response.status(401).send(errorMessage)
+    }
+
+    // Create user in DB
+    let user;
+    try {
+      user = await User.create({
+        email: userInf.email,
+        password: hashedPassword,
+        username: userInf.firstname
+      });
+    } catch (e) {
+      const errorMessage = 'Could not create your user in our system.\nError: ' + e;
+      return response.status(401).send(errorMessage)
+    }
+
+    let serviceIdTranslation = {};
+
+    // Import services
+    try {
+      const services = await franzRequest('me/services', 'GET', token)
+
+      for (const service of services) {
+        // Get new, unused uuid
+        let serviceId;
+        do {
+          serviceId = uuid();
+        } while ((await Service.query().where('serviceId', serviceId).fetch()).rows.length > 0)
+
+        await Service.create({
+          userId: user.id,
+          serviceId,
+          name: service.name,
+          recipeId: service.recipeId,
+          settings: JSON.stringify(service)
+        });
+
+        serviceIdTranslation[service.id] = serviceId;
+      }
+    } catch (e) {
+      const errorMessage = 'Could not import your services into our system.\nError: ' + e;
+      return response.status(401).send(errorMessage)
+    }
+
+    // Import workspaces
+    try {
+      const workspaces = await franzRequest('workspace', 'GET', token)
+
+      for (const workspace of workspaces) {
+        let workspaceId;
+        do {
+          workspaceId = uuid();
+        } while ((await Workspace.query().where('workspaceId', workspaceId).fetch()).rows.length > 0)
+
+        const services = workspace.services.map(service => serviceIdTranslation[service])
+
+        await Workspace.create({
+          userId: auth.user.id,
+          workspaceId,
+          name: workspace.name,
+          order: workspace.order,
+          services: JSON.stringify(services),
+          data: JSON.stringify({})
+        });
+      }
+    } catch (e) {
+      const errorMessage = 'Could not import your workspaces into our system.\nError: ' + e;
+      return response.status(401).send(errorMessage)
+    }
+
+    return response.send('Your account has been imported. You can now use your Franz account in Ferdi.')
+  }
 }
 
 module.exports = UserController
diff --git a/package-lock.json b/package-lock.json
index b6ccb17..dfc1308 100644
--- a/package-lock.json
+++ b/package-lock.json
@@ -836,6 +836,11 @@
         "to-regex": "^3.0.1"
       }
     },
+    "btoa": {
+      "version": "1.2.1",
+      "resolved": "https://registry.npmjs.org/btoa/-/btoa-1.2.1.tgz",
+      "integrity": "sha512-SB4/MIGlsiVkMcHmT+pSmIPoNDoHg+7cMzmt3Uxt628MTz2487DKSqK/fuhFBrkuqrYv5UCEnACpF4dTFNKc/g=="
+    },
     "buffer-alloc": {
       "version": "1.2.0",
       "resolved": "https://registry.npmjs.org/buffer-alloc/-/buffer-alloc-1.2.0.tgz",
diff --git a/package.json b/package.json
index 6ae22ed..e63e7de 100644
--- a/package.json
+++ b/package.json
@@ -27,6 +27,7 @@
     "@adonisjs/lucid": "^6.1.3",
     "@adonisjs/validator": "^5.0.6",
     "atob": "^2.1.2",
+    "btoa": "^1.2.1",
     "fs-extra": "^8.1.0",
     "node-fetch": "^2.6.0",
     "pg": "^7.12.1",
diff --git a/public/import.html b/public/import.html
new file mode 100644
index 0000000..9e2592d
--- /dev/null
+++ b/public/import.html
@@ -0,0 +1,92 @@
+<!DOCTYPE html>
+<html lang="en">
+
+<head>
+  <meta charset="UTF-8">
+  <meta name="viewport" content="width=device-width, initial-scale=1.0">
+  <meta http-equiv="X-UA-Compatible" content="ie=edge">
+  <title>Import Franz account</title>
+
+  <link rel="stylesheet" href="css/vanilla.css">
+
+  <style>
+    input {
+      margin-bottom: 1rem;
+      width: 100%;
+      padding: 0.5rem;
+    }
+
+    button {
+      display: flex;
+      overflow: hidden;
+      padding: 12px 12px;
+      cursor: pointer;
+      width: 100%;
+      -webkit-user-select: none;
+      -moz-user-select: none;
+      -ms-user-select: none;
+      user-select: none;
+      transition: all 150ms linear;
+      text-align: center;
+      white-space: nowrap;
+      text-decoration: none !important;
+      text-transform: none;
+      text-transform: capitalize;
+      color: #fff;
+      border: 0 none;
+      border-radius: 4px;
+      font-size: 13px;
+      font-weight: 500;
+      line-height: 1.3;
+      -webkit-appearance: none;
+      -moz-appearance: none;
+      appearance: none;
+      justify-content: center;
+      align-items: center;
+      flex: 0 0 160px;
+      box-shadow: 2px 5px 10px #e4e4e4;
+      color: #FFFFFF;
+      background: #161616;
+    }
+
+    #dropzone {
+      width: 100%;
+      height: 30vh;
+      background-color: #ebebeb;
+
+      display: flex;
+      align-items: center;
+      justify-content: center;
+      text-align: center;
+
+      cursor: pointer;
+    }
+
+    #dropzone p {
+      font-size: 0.85rem;
+    }
+
+    #files {
+        display: none;
+    }
+
+  </style>
+</head>
+
+<body>
+  <h1>Import a Franz account</h1>
+  <p>Please login using your Franz account. We will create a new Ferdi account with the same credentials.</p>
+  <form action="import" method="post">
+    <label for="email">E-Mail address</label><br />
+    <input type="email" name="email" placeholder="joe@example.com" required><br />
+
+    <label for="password">Password</label><br />
+    <input type="password" name="password" placeholder="********" required><br />
+
+    <button type="submit" id="submitbutton">Import Franz account</button>
+  </form>
+
+  <script src="js/new.js"></script>
+</body>
+
+</html>
diff --git a/start/routes.js b/start/routes.js
index 43cbafe..4b82f12 100644
--- a/start/routes.js
+++ b/start/routes.js
@@ -61,6 +61,8 @@ Route.group(() => {
 // Dashboard
 Route.post('new', 'RecipeController.create')
 Route.get('new', ({ response }) => response.redirect('/new.html'))
+Route.post('import', 'UserController.import')
+Route.get('import', ({ response }) => response.redirect('/import.html'))
 
 Route.get('/', () => {
   return {