1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
|
function filterQueryString(obj) {
return Object.keys(obj)
.map(k => `filter[${k}]=${encodeURIComponent(obj[k])}`)
.join('&');
}
const getOptionsQuery = (optionsObject = {}) =>
Object.keys(optionsObject)
.filter(k => typeof optionsObject[k] !== 'undefined')
.map(k => `${k}=${encodeURIComponent(optionsObject[k])}`)
.join('&');
const relatedResourceUrl = ({ parent, relationship }) => {
const builtUrl = `${parent.type}/${parent.id}/${relationship}`;
if (
parent.relationships
&& Object.keys(parent.relationships).includes(relationship)
) {
return parent.relationships[relationship].links?.related ?? builtUrl;
}
return builtUrl;
};
const extractData = response => response.data;
const extractErrorResponse = error => {
if (error && error.response) {
throw error.response;
} else {
throw error;
}
};
class Resource {
constructor({ name, httpClient }) {
this.name = name;
this.api = httpClient;
}
all({ options = {} } = {}) {
let url;
if (options.url) {
({ url } = options);
} else {
url = `${this.name}?${getOptionsQuery(options)}`;
}
return this.api.get(url).then(extractData).catch(extractErrorResponse);
}
find({ id, options } = {}) {
const url = `${this.name}/${id}?${getOptionsQuery(options)}`;
return this.api.get(url).then(extractData).catch(extractErrorResponse);
}
where({ filter, options } = {}) {
const queryString = filterQueryString(filter);
return this.api
.get(`${this.name}?${queryString}&${getOptionsQuery(options)}`)
.then(extractData)
.catch(extractErrorResponse);
}
related({ parent, relationship = this.name, options }) {
const baseUrl = relatedResourceUrl({ parent, relationship });
const url = `${baseUrl}?${getOptionsQuery(options)}`;
return this.api.get(url).then(extractData).catch(extractErrorResponse);
}
create(partialRecord) {
const record = Object.assign({}, partialRecord, { type: this.name });
const requestData = { data: record };
return this.api
.post(`${this.name}`, requestData)
.then(extractData)
.catch(extractErrorResponse);
}
createRelated(partialRecord) {
const record = Object.assign({}, partialRecord, { type: this.name });
const requestData = { data: record };
return this.api
.post(`${this.name}`, requestData)
.then(extractData)
.catch(extractErrorResponse);
}
updateRelationships(parent, relationship, records) {
// https://jsonapi.org/format/#crud-updating-to-many-relationships
const requestData = { data: records };
return this.api
.patch(
`${parent.type}/${parent.id}/relationships/${relationship}`,
requestData,
)
.then(extractData)
.catch(extractErrorResponse);
}
createRelationships(parent, relationship, records) {
// https://jsonapi.org/format/#crud-updating-to-many-relationships
const requestData = { data: records };
return this.api
.post(
`${parent.type}/${parent.id}/relationships/${relationship}`,
requestData,
)
.then(extractData)
.catch(extractErrorResponse);
}
removeRelationships(parent, relationship, records) {
// https://jsonapi.org/format/#crud-updating-to-many-relationships
const requestData = { data: records };
return this.api
.delete(
`${parent.type}/${parent.id}/relationships/${relationship}`,
requestData,
)
.then(extractData)
.catch(extractErrorResponse);
}
update(record) {
// http://jsonapi.org/faq/#wheres-put
const requestData = { data: record };
return this.api
.patch(`${this.name}/${record.id}`, requestData)
.then(extractData)
.catch(extractErrorResponse);
}
delete({ id }) {
return this.api.delete(`${this.name}/${id}`).catch(extractErrorResponse);
}
}
export default Resource;
|
