-
Notifications
You must be signed in to change notification settings - Fork 40
/
KurtosisPackageIndexerClient.ts
45 lines (40 loc) · 1.58 KB
/
KurtosisPackageIndexerClient.ts
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
import { createPromiseClient, PromiseClient } from "@connectrpc/connect";
import { createConnectTransport } from "@connectrpc/connect-web";
import { asyncResult } from "../../utils";
import { KURTOSIS_PACKAGE_INDEXER_URL } from "../constants";
import { KurtosisPackageIndexer } from "./api/kurtosis_package_indexer_connect";
import { PackageRepository, ReadPackageRequest } from "./api/kurtosis_package_indexer_pb";
export class KurtosisPackageIndexerClient {
private client: PromiseClient<typeof KurtosisPackageIndexer>;
constructor() {
this.client = createPromiseClient(
KurtosisPackageIndexer,
createConnectTransport({ baseUrl: KURTOSIS_PACKAGE_INDEXER_URL }),
);
}
getPackages = async () => {
return asyncResult(() => {
return this.client.getPackages({});
});
};
parsePackageUrl(packageUrl: string) {
const components = packageUrl.replace(/https?:\/\//, "").split("/");
if (components.length < 3) {
throw Error(`Illegal url, invalid number of components: ${packageUrl}`);
}
if (components[1].length < 1 || components[2].length < 1) {
throw Error(`Illegal url, empty components: ${packageUrl}`);
}
return new PackageRepository({
baseUrl: "github.com",
owner: components[1],
name: components[2],
rootPath: components.filter((v, i) => i > 2 && v.length > 0).join("/") + "/",
});
}
readPackage = async (packageUrl: string) => {
return asyncResult(() => {
return this.client.readPackage(new ReadPackageRequest({ repositoryMetadata: this.parsePackageUrl(packageUrl) }));
});
};
}