@mgruel
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
export function nominatimSearch(params: {
q?: string;
street?: string;
city?: string;
county?: string;
state?: string;
country?: string;
postalcode?: string;
} = {}) {
return me.fetchJSON(
"https://nominatim.openstreetmap.org/search?" +
new URLSearchParams({
format: "json",
...params,
}),
);
}
// Forked from @stevekrouse.nominatimSearch
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
type UserParams = {
username: string;
};
type ValParams = {
username: string;
valName: string;
token?: string;
};
type Params = UserParams | ValParams;
type UserResult = {
id: string;
username: string;
bio: string;
profileImageUrl: string;
};
type ValResult = {
id: string;
author: {
id: string;
username: string;
};
name: string;
code: string;
public: boolean;
privacy: "public" | "private";
version: number;
runEndAt: string;
runStartAt: string;
logs: any[];
output: object;
error: object | null;
readme: string | null;
likeCount: number;
referenceCount: number;
};
type Result<T> = T extends ValParams ? ValResult
: T extends UserParams ? UserResult
: never;
function alias<P extends Params>(params: P): Promise<Result<P>> {
const username = params.username;
let url = `https://api.val.town/v1/alias/${username}`;
if ("valName" in params) {
url = url + `/${params.valName}`;
}
const headers: HeadersInit = {};
if ("valName" in params && params.token) {
headers.Authorization = `Bearer ${params.token}`;
}
return me.fetchJSON<Result<P>>(url, { headers });
}
1
2
export const delay = async (ms: number) =>
new Promise((resolve) => setTimeout(resolve, ms));
1
2
3
4
5
let eurToUsd = (async () => {
const rate = await me.exchangeCurrency("usd");
//
return rate;
})();
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
// map an object to an object
// Usage
// keep keys the same:
// @mgruel.objectMap({ a: 1 }, (key, value) => value + 1)
// change keys:
// @mgruel.objectMap({ a: 1 }, (key, value) => [key + "2", value + 1])
const objectMap = async <
T extends object = object,
R extends any | [
string,
any,
] = any,
>(
obj: T,
fn: (key: string, value: T[keyof T]) => Promise<R>,
): Promise<Record<string, R>> =>
Object.fromEntries(
await Promise.all(
Object.entries(obj).map(async ([k, v]) => {
const res = await fn(k, v);
if (Array.isArray(res) && res.length === 2) {
return res;
}
else {
return [k, res];
}
}),
),
);
// forked from @stevekrouse.objectMap
1
2
3
4
5
6
7
8
9
export const fetchAndParseXML = async <T extends any = any>(
url: string | URL,
options?: RequestInit,
): Promise<T> => {
const { XMLParser } = await import("npm:fast-xml-parser");
const parser = new XMLParser();
const xmlString = await me.fetchText(url, options);
return parser.parse(xmlString) as T;
};
1
2
3
4
5
6
7
8
export const fetchText = (
url: string | URL,
options?: RequestInit,
): Promise<string> =>
fetch(url, {
redirect: "follow",
...options,
}).then((r) => r.text());
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
type PaginatedData<T> = {
data: T[];
links: {
prev?: string;
self: string;
next?: string;
};
};
export const pageApi = async <T extends any = any>(
url: string,
{ offset = 0, limit = 25 }: {
offset?: number;
limit?: number;
} = { offset: 0, limit: 25 },
options?: RequestInit,
) => {
let result: T[] = [];
let nextUrl = new URL(url);
nextUrl.searchParams.set("offset", `${offset}`);
nextUrl.searchParams.set("limit", `${limit}`);
while (nextUrl) {
const { data, links } = await me.fetchJSON<PaginatedData<T>>(
nextUrl,
options,
);
result = result.concat(data ?? []);
if ((data ?? []).length < limit) {
nextUrl = undefined;
}
else {
nextUrl = new URL(links.self);
const currOffset = parseInt(nextUrl.searchParams.get("offset"), 10);
nextUrl.searchParams.set("offset", `${currOffset + limit}`);
}
}
return result;
};
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
type PaginatedData<T> = {
data: T[];
links: {
prev?: string;
self: string;
next?: string;
};
};
export const paginateAPI = async <T extends any = any>(
url: string,
options?: RequestInit,
) => {
let result: T[] = [];
let nextUrl = url;
while (nextUrl) {
const { data, links } = await me.fetchJSON<PaginatedData<T>>(
nextUrl,
options,
);
result = result.concat(data ?? []);
nextUrl = links?.next;
}
return result;
};
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
type User = {
id: string;
username: string;
bio?: string | null;
profileImageUrl?: string | null;
};
type Val = {
id: string;
author: User;
name: string;
code: string;
privacy: string;
public: boolean;
version: number;
runStartAt: string;
runEndAt: string;
};
const fetchVals = (async () => {
const threshold = 90;
const opts = {
headers: {
Authorization: `Bearer ${@me.secrets.valtown}`,
},
};
const me = await me.fetchJSON<User>(
"https://api.val.town/v1/me",
opts,
);
const vals = await me.pageApi<Val>(
`https://api.val.town/v1/users/${me.id}/vals`,
{
offset: 0,
limit: 100,
},
opts,
);
console.log({
numOfVals: vals.length,
});
return vals;
// urls.forEach((u) => console.log(u));
// const publicVals = vals.filter((val) => val.public);
// const privateVals = vals.filter((val) => !val.public);
// return res;
})();
{"numOfVals":22}