53 lines
1.5 KiB
JavaScript
53 lines
1.5 KiB
JavaScript
import Watchable from './watchable';
|
|
import addToPath from 'nomad-ui/utils/add-to-path';
|
|
|
|
export default class AllocationAdapter extends Watchable {
|
|
stop = adapterAction('/stop');
|
|
|
|
restart(allocation, taskName) {
|
|
const prefix = `${this.host || '/'}${this.urlPrefix()}`;
|
|
const url = `${prefix}/client/allocation/${allocation.id}/restart`;
|
|
return this.ajax(url, 'PUT', {
|
|
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);
|
|
return this.ajax(url, verb);
|
|
};
|
|
}
|