UI: add filesystem browsing for allocations

ui/app/adapters/allocation.js

@@ -11,8 +11,41 @@ export default Watchable.extend({
       data: taskName && { TaskName: taskName },
     });
   },
+
+  ls(model, path) {
+    return this.token
+      .authorizedRequest(`/v1/client/fs/ls/${model.id}?path=${encodeURIComponent(path)}`)
+      .then(handleFSResponse);
+  },
+
+  stat(model, path) {
+    return this.token
+      .authorizedRequest(
+        `/v1/client/fs/stat/${model.id}?path=${encodeURIComponent(path)}`
+      )
+      .then(handleFSResponse);
+  },
 });
 
+async function handleFSResponse(response) {
+  if (response.ok) {
+    return response.json();
+  } else {
+    const body = await response.text();
+
+    // TODO update this if/when endpoint returns 404 as expected
+    const statusIs500 = response.status === 500;
+    const bodyIncludes404Text = body.includes('no such file or directory');
+
+    const translatedCode = statusIs500 && bodyIncludes404Text ? 404 : response.status;
+
+    throw {
+      code: translatedCode,
+      toString: () => body,
+    };
+  }
+}
+
 function adapterAction(path, verb = 'POST') {
   return function(allocation) {
     const url = addToPath(this.urlForFindRecord(allocation.id, 'allocation'), path);

ui/app/components/allocation-subnav.js

@@ -0,0 +1,14 @@
+import Component from '@ember/component';
+import { inject as service } from '@ember/service';
+import { equal, or } from '@ember/object/computed';
+
+export default Component.extend({
+  router: service(),
+
+  tagName: '',
+
+  fsIsActive: equal('router.currentRouteName', 'allocations.allocation.fs'),
+  fsRootIsActive: equal('router.currentRouteName', 'allocations.allocation.fs-root'),
+
+  filesLinkActive: or('fsIsActive', 'fsRootIsActive'),
+});

ui/app/components/fs-breadcrumbs.js → ui/app/components/fs/breadcrumbs.js

@@ -8,6 +8,7 @@ export default Component.extend({
 
   'data-test-fs-breadcrumbs': true,
 
+  allocation: null,
   task: null,
   path: null,
 

ui/app/components/fs/browser.js

@@ -0,0 +1,57 @@
+import Component from '@ember/component';
+import { computed } from '@ember/object';
+import { filterBy } from '@ember/object/computed';
+
+export default Component.extend({
+  tagName: '',
+
+  model: null,
+
+  allocation: computed('model', function() {
+    if (this.model.allocation) {
+      return this.model.allocation;
+    } else {
+      return this.model;
+    }
+  }),
+
+  task: computed('model', function() {
+    if (this.model.allocation) {
+      return this.model;
+    }
+  }),
+
+  type: computed('task', function() {
+    if (this.task) {
+      return 'task';
+    } else {
+      return 'allocation';
+    }
+  }),
+
+  directories: filterBy('directoryEntries', 'IsDir'),
+  files: filterBy('directoryEntries', 'IsDir', false),
+
+  sortedDirectoryEntries: computed(
+    'directoryEntries.[]',
+    'sortProperty',
+    'sortDescending',
+    function() {
+      const sortProperty = this.sortProperty;
+
+      const directorySortProperty = sortProperty === 'Size' ? 'Name' : sortProperty;
+
+      const sortedDirectories = this.directories.sortBy(directorySortProperty);
+      const sortedFiles = this.files.sortBy(sortProperty);
+
+      const sortedDirectoryEntries = sortedDirectories.concat(sortedFiles);
+
+      if (this.sortDescending) {
+        return sortedDirectoryEntries.reverse();
+      } else {
+        return sortedDirectoryEntries;
+      }
+    }
+  ),
+
+});

ui/app/components/fs-directory-entry.js → ui/app/components/fs/directory-entry.js

@@ -5,6 +5,9 @@ import { isEmpty } from '@ember/utils';
 export default Component.extend({
   tagName: '',
 
+  allocation: null,
+  task: null,
+
   pathToEntry: computed('path', 'entry.Name', function() {
     const pathWithNoLeadingSlash = this.get('path').replace(/^\//, '');
     const name = encodeURIComponent(this.get('entry.Name'));

ui/app/components/task-file.js → ui/app/components/fs/file.js

@@ -49,7 +49,8 @@ export default Component.extend({
   isStreaming: false,
 
   catUrl: computed('allocation.id', 'task.name', 'file', function() {
-    const encodedPath = encodeURIComponent(`${this.task.name}/${this.file}`);
+    const taskUrlPrefix = this.task ? `${this.task.name}/` : '';
+    const encodedPath = encodeURIComponent(`${taskUrlPrefix}${this.file}`);
     return `/v1/client/fs/cat/${this.allocation.id}?path=${encodedPath}`;
   }),
 
@@ -79,7 +80,8 @@ export default Component.extend({
 
   fileParams: computed('task.name', 'file', 'mode', function() {
     // The Log class handles encoding query params
-    const path = `${this.task.name}/${this.file}`;
+    const taskUrlPrefix = this.task ? `${this.task.name}/` : '';
+    const path = `${taskUrlPrefix}${this.file}`;
 
     switch (this.mode) {
       case 'head':

ui/app/components/fs/link.js

@@ -0,0 +1,8 @@
+import Component from '@ember/component';
+
+export default Component.extend({
+  tagName: '',
+
+  allocation: null,
+  task: null,
+});

ui/app/controllers/allocations/allocation/fs-root.js

@@ -0,0 +1,3 @@
+import FSController from './fs';
+
+export default FSController.extend();

ui/app/controllers/allocations/allocation/fs.js

@@ -0,0 +1,28 @@
+import Controller from '@ember/controller';
+import { computed } from '@ember/object';
+
+export default Controller.extend({
+  queryParams: {
+    sortProperty: 'sort',
+    sortDescending: 'desc',
+  },
+
+  sortProperty: 'Name',
+  sortDescending: false,
+
+  path: null,
+  allocation: null,
+  directoryEntries: null,
+  isFile: null,
+  stat: null,
+
+  pathWithLeadingSlash: computed('path', function() {
+    const path = this.path;
+
+    if (path.startsWith('/')) {
+      return path;
+    } else {
+      return `/${path}`;
+    }
+  }),
+});

ui/app/controllers/allocations/allocation/task/fs.js

@@ -1,6 +1,5 @@
 import Controller from '@ember/controller';
 import { computed } from '@ember/object';
-import { filterBy } from '@ember/object/computed';
 
 export default Controller.extend({
   queryParams: {
@@ -17,9 +16,6 @@ export default Controller.extend({
   isFile: null,
   stat: null,
 
-  directories: filterBy('directoryEntries', 'IsDir'),
-  files: filterBy('directoryEntries', 'IsDir', false),
-
   pathWithLeadingSlash: computed('path', function() {
     const path = this.path;
 
@@ -29,26 +25,4 @@ export default Controller.extend({
       return `/${path}`;
     }
   }),
-
-  sortedDirectoryEntries: computed(
-    'directoryEntries.[]',
-    'sortProperty',
-    'sortDescending',
-    function() {
-      const sortProperty = this.sortProperty;
-
-      const directorySortProperty = sortProperty === 'Size' ? 'Name' : sortProperty;
-
-      const sortedDirectories = this.directories.sortBy(directorySortProperty);
-      const sortedFiles = this.files.sortBy(sortProperty);
-
-      const sortedDirectoryEntries = sortedDirectories.concat(sortedFiles);
-
-      if (this.sortDescending) {
-        return sortedDirectoryEntries.reverse();
-      } else {
-        return sortedDirectoryEntries;
-      }
-    }
-  ),
 });

ui/app/models/allocation.js

@@ -125,4 +125,12 @@ export default Model.extend({
   restart(taskName) {
     return this.store.adapterFor('allocation').restart(this, taskName);
   },
+
+  ls(path) {
+    return this.store.adapterFor('allocation').ls(this, path);
+  },
+
+  stat(path) {
+    return this.store.adapterFor('allocation').stat(this, path);
+  },
 });

ui/app/models/task-state.js

@@ -51,12 +51,4 @@ export default Fragment.extend({
   restart() {
     return this.allocation.restart(this.name);
   },
-
-  ls(path) {
-    return this.store.adapterFor('task-state').ls(this, path);
-  },
-
-  stat(path) {
-    return this.store.adapterFor('task-state').stat(this, path);
-  },
 });

ui/app/router.js

@@ -47,6 +47,9 @@ Router.map(function() {
 
   this.route('allocations', function() {
     this.route('allocation', { path: '/:allocation_id' }, function() {
+      this.route('fs-root', { path: '/fs' });
+      this.route('fs', { path: '/fs/*path' });
+
       this.route('task', { path: '/:name' }, function() {
         this.route('logs');
         this.route('fs-root', { path: '/fs' });

ui/app/routes/allocations/allocation/fs-root.js

@@ -0,0 +1,5 @@
+import FSRoute from './fs';
+
+export default FSRoute.extend({
+  templateName: 'allocations/allocation/fs',
+});

ui/app/routes/allocations/allocation/fs.js

@@ -0,0 +1,42 @@
+import Route from '@ember/routing/route';
+import RSVP from 'rsvp';
+import notifyError from 'nomad-ui/utils/notify-error';
+
+export default Route.extend({
+  model({ path = '/' }) {
+    const decodedPath = decodeURIComponent(path);
+    const allocation = this.modelFor('allocations.allocation');
+
+    if (!allocation.isRunning) {
+      return {
+        path: decodedPath,
+        allocation,
+      };
+    }
+
+    return RSVP.all([allocation.stat(decodedPath), allocation.get('node')])
+      .then(([statJson]) => {
+        if (statJson.IsDir) {
+          return RSVP.hash({
+            path: decodedPath,
+            allocation,
+            directoryEntries: allocation.ls(decodedPath).catch(notifyError(this)),
+            isFile: false,
+          });
+        } else {
+          return {
+            path: decodedPath,
+            allocation,
+            isFile: true,
+            stat: statJson,
+          };
+        }
+      })
+      .catch(notifyError(this));
+  },
+
+  setupController(controller, { path, allocation, directoryEntries, isFile, stat } = {}) {
+    this._super(...arguments);
+    controller.setProperties({ path, allocation, directoryEntries, isFile, stat });
+  },
+});

ui/app/routes/allocations/allocation/task/fs.js

@@ -6,6 +6,7 @@ export default Route.extend({
   model({ path = '/' }) {
     const decodedPath = decodeURIComponent(path);
     const task = this.modelFor('allocations.allocation.task');
+    const allocation = task.allocation;
 
     const pathWithTaskName = `${task.name}${decodedPath.startsWith('/') ? '' : '/'}${decodedPath}`;
 
@@ -16,13 +17,13 @@ export default Route.extend({
       };
     }
 
-    return RSVP.all([task.stat(pathWithTaskName), task.get('allocation.node')])
+    return RSVP.all([allocation.stat(pathWithTaskName), task.get('allocation.node')])
       .then(([statJson]) => {
         if (statJson.IsDir) {
           return RSVP.hash({
             path: decodedPath,
             task,
-            directoryEntries: task.ls(pathWithTaskName).catch(notifyError(this)),
+            directoryEntries: allocation.ls(pathWithTaskName).catch(notifyError(this)),
             isFile: false,
           });
         } else {

ui/app/templates/allocations/allocation/fs.hbs

@@ -0,0 +1,10 @@
+{{title pathWithLeadingSlash " -  Allocation " allocation.shortId " filesystem"}}
+{{allocation-subnav allocation=allocation}}
+{{fs/browser
+  model=allocation
+  path=path
+  stat=stat
+  isFile=isFile
+  directoryEntries=directoryEntries
+  sortProperty=sortProperty
+  sortDescending=sortDescending}}