import { inject as service } from '@ember/service'; import Adapter from 'ember-data/adapter'; import AdapterError from '@ember-data/adapter/error'; import { AbortError, TimeoutError, ServerError, UnauthorizedError, ForbiddenError, NotFoundError, ConflictError, InvalidError, } from 'ember-data/adapters/errors'; // TODO These are now exactly the same, apart from the fact that one uses // `serialized, unserialized` and the other just `query` // they could actually be one function now, but would be nice to think about // the naming of things (serialized vs query etc) const read = function(adapter, modelName, type, query = {}) { return adapter.rpc( function(adapter, request, query) { return adapter[`requestFor${type}`](request, query); }, function(serializer, respond, query) { return serializer[`respondFor${type}`](respond, query); }, query, modelName ); }; const write = function(adapter, modelName, type, snapshot) { return adapter.rpc( function(adapter, request, serialized, unserialized) { return adapter[`requestFor${type}`](request, serialized, unserialized); }, function(serializer, respond, serialized, unserialized) { return serializer[`respondFor${type}`](respond, serialized, unserialized); }, snapshot, modelName ); }; export default Adapter.extend({ client: service('client/http'), rpc: function(req, resp, obj, modelName) { const client = this.client; const store = this.store; const adapter = this; let unserialized, serialized; const serializer = store.serializerFor(modelName); // workable way to decide whether this is a snapshot // essentially 'is attributable'. // Snapshot is private so we can't do instanceof here // and using obj.constructor.name gets changed/minified // during compilation so you can't rely on it // checking for `attributes` being a function is more // reliable as that is the thing we need to call if (typeof obj.attributes === 'function') { unserialized = obj.attributes(); serialized = serializer.serialize(obj, {}); } else { unserialized = obj; serialized = unserialized; } return client .request(function(request) { return req(adapter, request, serialized, unserialized); }) .catch(function(e) { return adapter.error(e); }) .then(function(respond) { // TODO: When HTTPAdapter:responder changes, this will also need to change return resp(serializer, respond, serialized, unserialized); }); // TODO: Potentially add specific serializer errors here // .catch(function(e) { // return Promise.reject(e); // }); }, error: function(err) { const errors = [ { status: `${err.statusCode}`, title: 'The backend responded with an error', detail: err.message, }, ]; let error; const detailedMessage = ''; try { switch (err.statusCode) { case 0: error = new AbortError(); error.errors[0].status = '0'; break; case 401: error = new UnauthorizedError(errors, detailedMessage); break; case 403: error = new ForbiddenError(errors, detailedMessage); break; case 404: error = new NotFoundError(errors, detailedMessage); break; case 408: error = new TimeoutError(); break; case 409: error = new ConflictError(errors, detailedMessage); break; case 422: error = new InvalidError(errors); //payload.errors break; default: if (err.statusCode >= 500) { error = new ServerError(errors, detailedMessage); } else { error = new AdapterError(errors, detailedMessage); } } } catch (e) { error = e; } // TODO: This comes originates from ember-data // This can be confusing if you need to use this with Promise.reject // Consider changing this to return the error and then // throw from the call site instead throw error; }, query: function(store, type, query) { return read(this, type.modelName, 'Query', query); }, queryRecord: function(store, type, query) { return read(this, type.modelName, 'QueryRecord', query); }, findAll: function(store, type) { return read(this, type.modelName, 'FindAll'); }, createRecord: function(store, type, snapshot) { return write(this, type.modelName, 'CreateRecord', snapshot); }, updateRecord: function(store, type, snapshot) { return write(this, type.modelName, 'UpdateRecord', snapshot); }, deleteRecord: function(store, type, snapshot) { return write(this, type.modelName, 'DeleteRecord', snapshot); }, });