144 lines
3.5 KiB
TypeScript
144 lines
3.5 KiB
TypeScript
import { PageMeta } from "../types";
|
|
import { Plug } from "../../plugos/plug";
|
|
import { SpacePrimitives } from "./space_primitives";
|
|
|
|
export class HttpSpacePrimitives implements SpacePrimitives {
|
|
pageUrl: string;
|
|
private plugUrl: string;
|
|
|
|
constructor(url: string) {
|
|
console.log("UR", url);
|
|
this.pageUrl = url + "/fs";
|
|
this.plugUrl = url + "/plug";
|
|
}
|
|
|
|
public async fetchPageList(): Promise<{
|
|
pages: Set<PageMeta>;
|
|
nowTimestamp: number;
|
|
}> {
|
|
let req = await fetch(this.pageUrl, {
|
|
method: "GET",
|
|
});
|
|
|
|
let result = new Set<PageMeta>();
|
|
((await req.json()) as any[]).forEach((meta: any) => {
|
|
const pageName = meta.name;
|
|
result.add({
|
|
name: pageName,
|
|
lastModified: meta.lastModified,
|
|
});
|
|
});
|
|
|
|
return {
|
|
pages: result,
|
|
nowTimestamp: +req.headers.get("Now-Timestamp")!,
|
|
};
|
|
}
|
|
|
|
async readPage(name: string): Promise<{ text: string; meta: PageMeta }> {
|
|
let res = await fetch(`${this.pageUrl}/${name}`, {
|
|
method: "GET",
|
|
});
|
|
if (res.headers.get("X-Status") === "404") {
|
|
throw new Error(`Page not found`);
|
|
}
|
|
return {
|
|
text: await res.text(),
|
|
meta: this.responseToMeta(name, res),
|
|
};
|
|
}
|
|
|
|
async writePage(
|
|
name: string,
|
|
text: string,
|
|
selfUpdate?: boolean,
|
|
lastModified?: number
|
|
): Promise<PageMeta> {
|
|
// TODO: lastModified ignored for now
|
|
let res = await fetch(`${this.pageUrl}/${name}`, {
|
|
method: "PUT",
|
|
body: text,
|
|
headers: lastModified
|
|
? {
|
|
"Last-Modified": "" + lastModified,
|
|
}
|
|
: undefined,
|
|
});
|
|
const newMeta = this.responseToMeta(name, res);
|
|
return newMeta;
|
|
}
|
|
|
|
async deletePage(name: string): Promise<void> {
|
|
let req = await fetch(`${this.pageUrl}/${name}`, {
|
|
method: "DELETE",
|
|
});
|
|
if (req.status !== 200) {
|
|
throw Error(`Failed to delete page: ${req.statusText}`);
|
|
}
|
|
}
|
|
|
|
async proxySyscall(plug: Plug<any>, name: string, args: any[]): Promise<any> {
|
|
let req = await fetch(`${this.plugUrl}/${plug.name}/syscall/${name}`, {
|
|
method: "POST",
|
|
headers: {
|
|
"Content-type": "application/json",
|
|
},
|
|
body: JSON.stringify(args),
|
|
});
|
|
if (req.status !== 200) {
|
|
let error = await req.text();
|
|
throw Error(error);
|
|
}
|
|
if (req.headers.get("Content-length") === "0") {
|
|
return;
|
|
}
|
|
return await req.json();
|
|
}
|
|
|
|
async invokeFunction(
|
|
plug: Plug<any>,
|
|
env: string,
|
|
name: string,
|
|
args: any[]
|
|
): Promise<any> {
|
|
// Invoke locally
|
|
if (!env || env === "client") {
|
|
return plug.invoke(name, args);
|
|
}
|
|
// Or dispatch to server
|
|
let req = await fetch(`${this.plugUrl}/${plug.name}/function/${name}`, {
|
|
method: "POST",
|
|
headers: {
|
|
"Content-type": "application/json",
|
|
},
|
|
body: JSON.stringify(args),
|
|
});
|
|
if (req.status !== 200) {
|
|
let error = await req.text();
|
|
throw Error(error);
|
|
}
|
|
if (req.headers.get("Content-length") === "0") {
|
|
return;
|
|
}
|
|
return await req.json();
|
|
}
|
|
|
|
async getPageMeta(name: string): Promise<PageMeta> {
|
|
let res = await fetch(`${this.pageUrl}/${name}`, {
|
|
method: "OPTIONS",
|
|
});
|
|
if (res.headers.get("X-Status") === "404") {
|
|
throw new Error(`Page not found`);
|
|
}
|
|
return this.responseToMeta(name, res);
|
|
}
|
|
|
|
private responseToMeta(name: string, res: Response): PageMeta {
|
|
const meta = {
|
|
name,
|
|
lastModified: +(res.headers.get("Last-Modified") || "0"),
|
|
};
|
|
return meta;
|
|
}
|
|
}
|