114 lines
3.8 KiB
TypeScript
114 lines
3.8 KiB
TypeScript
import { path } from "../server/deps.ts";
|
|
import { HttpServer } from "../server/http_server.ts";
|
|
import clientAssetBundle from "../dist/client_asset_bundle.json" assert {
|
|
type: "json",
|
|
};
|
|
import plugAssetBundle from "../dist/plug_asset_bundle.json" assert {
|
|
type: "json",
|
|
};
|
|
import { AssetBundle, AssetJson } from "../plugos/asset_bundle/bundle.ts";
|
|
import { AssetBundlePlugSpacePrimitives } from "../common/spaces/asset_bundle_space_primitives.ts";
|
|
import { DiskSpacePrimitives } from "../common/spaces/disk_space_primitives.ts";
|
|
import { SpacePrimitives } from "../common/spaces/space_primitives.ts";
|
|
import { S3SpacePrimitives } from "../server/spaces/s3_space_primitives.ts";
|
|
import { Authenticator } from "../server/auth.ts";
|
|
import { JSONKVStore } from "../plugos/lib/kv_store.json_file.ts";
|
|
import { sleep } from "../common/async_util.ts";
|
|
|
|
export async function serveCommand(
|
|
options: any,
|
|
folder?: string,
|
|
) {
|
|
const hostname = options.hostname || Deno.env.get("SB_HOSTNAME") ||
|
|
"127.0.0.1";
|
|
const port = options.port ||
|
|
(Deno.env.get("SB_PORT") && +Deno.env.get("SB_PORT")!) || 3000;
|
|
const maxFileSizeMB = options.maxFileSizeMB || 20;
|
|
|
|
if (!folder) {
|
|
folder = Deno.env.get("SB_FOLDER");
|
|
if (!folder) {
|
|
console.error(
|
|
"No folder specified. Please pass a folder as an argument or set SB_FOLDER environment variable.",
|
|
);
|
|
Deno.exit(1);
|
|
}
|
|
}
|
|
|
|
console.log(
|
|
"Going to start SilverBullet binding to",
|
|
`${hostname}:${port}`,
|
|
);
|
|
if (hostname === "127.0.0.1") {
|
|
console.log(
|
|
`NOTE: SilverBullet will only be available locally (via http://localhost:${port}).
|
|
To allow outside connections, pass -L 0.0.0.0 as a flag, and put a TLS terminator on top.`,
|
|
);
|
|
}
|
|
let spacePrimitives: SpacePrimitives | undefined;
|
|
if (folder === "s3://") {
|
|
spacePrimitives = new S3SpacePrimitives({
|
|
accessKey: Deno.env.get("AWS_ACCESS_KEY_ID")!,
|
|
secretKey: Deno.env.get("AWS_SECRET_ACCESS_KEY")!,
|
|
endPoint: Deno.env.get("AWS_ENDPOINT")!,
|
|
region: Deno.env.get("AWS_REGION")!,
|
|
bucket: Deno.env.get("AWS_BUCKET")!,
|
|
});
|
|
console.log("Running in S3 mode");
|
|
} else {
|
|
// Regular disk mode
|
|
folder = path.resolve(Deno.cwd(), folder);
|
|
spacePrimitives = new DiskSpacePrimitives(folder);
|
|
}
|
|
spacePrimitives = new AssetBundlePlugSpacePrimitives(
|
|
spacePrimitives,
|
|
new AssetBundle(plugAssetBundle as AssetJson),
|
|
);
|
|
|
|
const authStore = new JSONKVStore();
|
|
const authenticator = new Authenticator(authStore);
|
|
|
|
const flagUser = options.user ?? Deno.env.get("SB_USER");
|
|
if (flagUser) {
|
|
// If explicitly added via env/parameter, add on the fly
|
|
const [username, password] = flagUser.split(":");
|
|
await authenticator.register(username, password, ["admin"], "");
|
|
}
|
|
|
|
if (options.auth) {
|
|
// Load auth file
|
|
const authFile: string = options.auth;
|
|
console.log("Loading authentication credentials from", authFile);
|
|
await authStore.load(authFile);
|
|
(async () => {
|
|
// Asynchronously kick off file watcher
|
|
for await (const _event of Deno.watchFs(options.auth)) {
|
|
console.log("Authentication file changed, reloading...");
|
|
await authStore.load(authFile);
|
|
}
|
|
})().catch(console.error);
|
|
}
|
|
|
|
const envAuth = Deno.env.get("SB_AUTH");
|
|
if (envAuth) {
|
|
console.log("Loading authentication from SB_AUTH");
|
|
authStore.loadString(envAuth);
|
|
}
|
|
|
|
const httpServer = new HttpServer(spacePrimitives!, {
|
|
hostname,
|
|
port: port,
|
|
pagesPath: folder!,
|
|
clientAssetBundle: new AssetBundle(clientAssetBundle as AssetJson),
|
|
authenticator,
|
|
keyFile: options.key,
|
|
certFile: options.cert,
|
|
maxFileSizeMB: +maxFileSizeMB,
|
|
});
|
|
await httpServer.start();
|
|
// Wait in an infinite loop (to keep the HTTP server running, only cancelable via Ctrl+C or other signal)
|
|
while (true) {
|
|
sleep(1000);
|
|
}
|
|
}
|