Added enhanced request query building

This commit is contained in:
2022-01-24 13:50:22 +01:00
parent 78fbd0234c
commit cbf5b814fc
3 changed files with 58 additions and 13 deletions

View File

@@ -8,6 +8,21 @@ async function unknownResponse(resp) {
return new Error(`Server sent unknown error: ${await resp.text()} (${resp.status})`); return new Error(`Server sent unknown error: ${await resp.text()} (${resp.status})`);
} }
} }
function buildQuery(options) {
let query;
options.forEach(element => {
if (element[1] !== undefined) {
if (element[1] instanceof Date) {
element[1] = element[1].getSeconds();
}
else if (element[1] instanceof Array) {
element[1] = JSON.stringify(element[1]);
}
query.push(`${element[0]}&${element[1]}`);
}
});
return query.join("=");
}
async function login(username, password) { async function login(username, password) {
let result = await fetch(`${prefix}/api/login`, { let result = await fetch(`${prefix}/api/login`, {
method: "POST", method: "POST",
@@ -23,7 +38,8 @@ async function login(username, password) {
} }
} }
async function authors(name, limit) { async function authors(name, limit) {
let result = await fetch(`${prefix}/api/authors?name=${name}&limit=${limit}`); let query = [["name", name], ["limit", limit]];
let result = await fetch(`${prefix}/api/authors?${buildQuery(query)}`);
if (result.status == 200) { if (result.status == 200) {
return await result.json(); return await result.json();
} }
@@ -32,7 +48,8 @@ async function authors(name, limit) {
} }
} }
async function tags(name, limit) { async function tags(name, limit) {
let result = await fetch(`${prefix}/api/tags?name=${name}&limit=${limit}`); let query = [["name", name], ["limit", limit]];
let result = await fetch(`${prefix}/api/tags?${buildQuery(query)}`);
if (result.status == 200) { if (result.status == 200) {
return await result.json(); return await result.json();
} }
@@ -41,7 +58,8 @@ async function tags(name, limit) {
} }
} }
async function recent(limit = 20) { async function recent(limit = 20) {
let result = await fetch(`${prefix}/api/recent?limit=${limit}`); let query = [["limit", limit]];
let result = await fetch(`${prefix}/api/recent?limit=${buildQuery(query)}`);
if (result.status == 200) { if (result.status == 200) {
return await result.json(); return await result.json();
} }
@@ -49,8 +67,9 @@ async function recent(limit = 20) {
throw await unknownResponse(result); throw await unknownResponse(result);
} }
} }
async function search(query) { async function search(q) {
let result = await fetch(`${prefix}/api/search?q=${query.query}&from=${query.from.getSeconds()}&to=${query.to.getSeconds()}&authors=${JSON.stringify(query.authors)}&tags=${JSON.stringify(query.tags)}&limit=${query.limit}`); let query = [["q", q.query], ["from", q.from], ["to", q.to], ["authors", q.authors], ["tags", q.tags], ["limit", q.limit]];
let result = await fetch(`${prefix}/api/search?${buildQuery(query)}`);
if (result.status == 200) { if (result.status == 200) {
return await result.json(); return await result.json();
} }
@@ -110,7 +129,8 @@ async function deleteArticle(id) {
} }
} }
async function getAssets(name, limit = 20) { async function getAssets(name, limit = 20) {
let result = await fetch(`${prefix}/api/assets?q=${name}&limit=${limit}`, { let query = [["q", name], ["limit", limit]];
let result = await fetch(`${prefix}/api/assets?${buildQuery(query)}`, {
method: "GET", method: "GET",
}); });
switch (result.status) { switch (result.status) {

File diff suppressed because one or more lines are too long

View File

@@ -10,6 +10,21 @@ async function unknownResponse(resp: Response): Promise<Error> {
} }
} }
function buildQuery(options: any[][]): string {
let query: string[]
options.forEach(element => {
if (element[1] !== undefined) {
if (element[1] instanceof Date) {
element[1] = element[1].getSeconds()
} else if (element[1] instanceof Array) {
element[1] = JSON.stringify(element[1])
}
query.push(`${element[0]}&${element[1]}`)
}
});
return query.join("=")
}
interface Author { interface Author {
id: number, id: number,
name: string, name: string,
@@ -50,7 +65,9 @@ async function login(username: string, password: string): Promise<void> {
} }
async function authors(name?: string, limit?: number): Promise<Author[]> { async function authors(name?: string, limit?: number): Promise<Author[]> {
let result = await fetch(`${prefix}/api/authors?name=${name}&limit=${limit}`) let query = [["name", name], ["limit", limit]]
let result = await fetch(`${prefix}/api/authors?${buildQuery(query)}`)
if (result.status == 200) { if (result.status == 200) {
return await result.json() return await result.json()
} else { } else {
@@ -59,7 +76,9 @@ async function authors(name?: string, limit?: number): Promise<Author[]> {
} }
async function tags(name?: string, limit?: number): Promise<string[]> { async function tags(name?: string, limit?: number): Promise<string[]> {
let result = await fetch(`${prefix}/api/tags?name=${name}&limit=${limit}`) let query = [["name", name], ["limit", limit]]
let result = await fetch(`${prefix}/api/tags?${buildQuery(query)}`)
if (result.status == 200) { if (result.status == 200) {
return await result.json() return await result.json()
} else { } else {
@@ -68,7 +87,9 @@ async function tags(name?: string, limit?: number): Promise<string[]> {
} }
async function recent(limit: number = 20): Promise<ArticleSummary[]> { async function recent(limit: number = 20): Promise<ArticleSummary[]> {
let result = await fetch(`${prefix}/api/recent?limit=${limit}`) let query = [["limit", limit]]
let result = await fetch(`${prefix}/api/recent?limit=${buildQuery(query)}`)
if (result.status == 200) { if (result.status == 200) {
return await result.json() return await result.json()
} else { } else {
@@ -85,8 +106,10 @@ interface SearchQuery {
limit?: number limit?: number
} }
async function search(query: SearchQuery): Promise<ArticleSummary[]> { async function search(q: SearchQuery): Promise<ArticleSummary[]> {
let result = await fetch(`${prefix}/api/search?q=${query.query}&from=${query.from.getSeconds()}&to=${query.to.getSeconds()}&authors=${JSON.stringify(query.authors)}&tags=${JSON.stringify(query.tags)}&limit=${query.limit}`) let query = [["q", q.query], ["from", q.from], ["to", q.to], ["authors", q.authors], ["tags", q.tags], ["limit", q.limit]]
let result = await fetch(`${prefix}/api/search?${buildQuery(query)}`)
if (result.status == 200) { if (result.status == 200) {
return await result.json() return await result.json()
} else { } else {
@@ -171,7 +194,9 @@ async function deleteArticle(id: number): Promise<void> {
} }
async function getAssets(name?: string, limit: number = 20): Promise<Asset[]> { async function getAssets(name?: string, limit: number = 20): Promise<Asset[]> {
let result = await fetch(`${prefix}/api/assets?q=${name}&limit=${limit}`, { let query = [["q", name], ["limit", limit]]
let result = await fetch(`${prefix}/api/assets?${buildQuery(query)}`, {
method: "GET", method: "GET",
}) })
switch (result.status) { switch (result.status) {