import Service, { inject as service } from '@ember/service'; import { get } from '@ember/object'; import { typeOf } from '@ember/utils'; import { PRIMARY_KEY, SLUG_KEY } from 'consul-ui/models/token'; import { Promise } from 'rsvp'; import statusFactory from 'consul-ui/utils/acls-status'; import isValidServerErrorFactory from 'consul-ui/utils/http/acl/is-valid-server-error'; const isValidServerError = isValidServerErrorFactory(); const status = statusFactory(isValidServerError, Promise); const MODEL_NAME = 'token'; export default Service.extend({ getModelName: function() { return MODEL_NAME; }, getPrimaryKey: function() { return PRIMARY_KEY; }, getSlugKey: function() { return SLUG_KEY; }, status: function(obj) { return status(obj); }, self: function(secret, dc) { return get(this, 'store') .self(this.getModelName(), { secret: secret, dc: dc, }) .catch(e => { // If we get this 500 RPC error, it means we are a legacy ACL cluster // set AccessorID to null - which for the frontend means legacy mode if (isValidServerError(e)) { return { AccessorID: null, SecretID: secret, }; } return Promise.reject(e); }); }, clone: function(item) { return get(this, 'store').clone(this.getModelName(), get(item, PRIMARY_KEY)); }, findByPolicy: function(id, dc) { return get(this, 'store').query(this.getModelName(), { policy: id, dc: dc, }); }, // TODO: RepositoryService store: service('store'), findAllByDatacenter: function(dc) { return get(this, 'store').query(this.getModelName(), { dc: dc, }); }, findBySlug: function(slug, dc) { return get(this, 'store').queryRecord(this.getModelName(), { id: slug, dc: dc, }); }, create: function(obj) { // TODO: This should probably return a Promise return get(this, 'store').createRecord(this.getModelName(), obj); }, persist: function(item) { return item.save(); }, remove: function(obj) { let item = obj; if (typeof obj.destroyRecord === 'undefined') { item = obj.get('data'); } if (typeOf(item) === 'object') { item = get(this, 'store').peekRecord(this.getModelName(), item[this.getPrimaryKey()]); } return item.destroyRecord().then(item => { return get(this, 'store').unloadRecord(item); }); }, invalidate: function() { get(this, 'store').unloadAll(this.getModelName()); }, });