diff --git a/.oxfmtrc.json b/.oxfmtrc.json
new file mode 100644
index 0000000..26e8662
--- /dev/null
+++ b/.oxfmtrc.json
@@ -0,0 +1,10 @@
+{
+ "$schema": "./node_modules/oxfmt/configuration_schema.json",
+ "endOfLine": "lf",
+ "experimentalSortImports": {},
+ "experimentalTailwindcss": {},
+ "ignorePatterns": [],
+ "printWidth": 100,
+ "tabWidth": 2,
+ "useTabs": false
+}
diff --git a/.oxlintrc.json b/.oxlintrc.json
new file mode 100644
index 0000000..f8d1670
--- /dev/null
+++ b/.oxlintrc.json
@@ -0,0 +1,144 @@
+{
+ "$schema": "./node_modules/oxlint/configuration_schema.json",
+ "plugins": ["unicorn", "typescript", "oxc"],
+ "categories": {},
+ "rules": {
+ "constructor-super": "warn",
+ "for-direction": "warn",
+ "no-async-promise-executor": "warn",
+ "no-caller": "warn",
+ "no-class-assign": "warn",
+ "no-compare-neg-zero": "warn",
+ "no-cond-assign": "warn",
+ "no-const-assign": "warn",
+ "no-constant-binary-expression": "warn",
+ "no-constant-condition": "warn",
+ "no-control-regex": "warn",
+ "no-debugger": "warn",
+ "no-delete-var": "warn",
+ "no-dupe-class-members": "warn",
+ "no-dupe-else-if": "warn",
+ "no-dupe-keys": "warn",
+ "no-duplicate-case": "warn",
+ "no-empty-character-class": "warn",
+ "no-empty-pattern": "warn",
+ "no-empty-static-block": "warn",
+ "no-eval": "warn",
+ "no-ex-assign": "warn",
+ "no-extra-boolean-cast": "warn",
+ "no-func-assign": "warn",
+ "no-global-assign": "warn",
+ "no-import-assign": "warn",
+ "no-invalid-regexp": "warn",
+ "no-irregular-whitespace": "warn",
+ "no-loss-of-precision": "warn",
+ "no-new-native-nonconstructor": "warn",
+ "no-nonoctal-decimal-escape": "warn",
+ "no-obj-calls": "warn",
+ "no-self-assign": "warn",
+ "no-setter-return": "warn",
+ "no-shadow-restricted-names": "warn",
+ "no-sparse-arrays": "warn",
+ "no-this-before-super": "warn",
+ "no-unassigned-vars": "warn",
+ "no-unsafe-finally": "warn",
+ "no-unsafe-negation": "warn",
+ "no-unsafe-optional-chaining": "warn",
+ "no-unused-expressions": "warn",
+ "no-unused-labels": "warn",
+ "no-unused-private-class-members": "warn",
+ "no-unused-vars": "warn",
+ "no-useless-backreference": "warn",
+ "no-useless-catch": "warn",
+ "no-useless-escape": "warn",
+ "no-useless-rename": "warn",
+ "no-with": "warn",
+ "require-yield": "warn",
+ "use-isnan": "warn",
+ "valid-typeof": "warn",
+ "oxc/bad-array-method-on-arguments": "warn",
+ "oxc/bad-char-at-comparison": "warn",
+ "oxc/bad-comparison-sequence": "warn",
+ "oxc/bad-min-max-func": "warn",
+ "oxc/bad-object-literal-comparison": "warn",
+ "oxc/bad-replace-all-arg": "warn",
+ "oxc/const-comparisons": "warn",
+ "oxc/double-comparisons": "warn",
+ "oxc/erasing-op": "warn",
+ "oxc/missing-throw": "warn",
+ "oxc/number-arg-out-of-range": "warn",
+ "oxc/only-used-in-recursion": "warn",
+ "oxc/uninvoked-array-callback": "warn",
+ "typescript/await-thenable": "warn",
+ "typescript/no-array-delete": "warn",
+ "typescript/no-base-to-string": "warn",
+ "typescript/no-duplicate-enum-values": "warn",
+ "typescript/no-duplicate-type-constituents": "warn",
+ "typescript/no-extra-non-null-assertion": "warn",
+ "typescript/no-floating-promises": "warn",
+ "typescript/no-for-in-array": "warn",
+ "typescript/no-implied-eval": "warn",
+ "typescript/no-meaningless-void-operator": "warn",
+ "typescript/no-misused-new": "warn",
+ "typescript/no-misused-spread": "warn",
+ "typescript/no-non-null-asserted-optional-chain": "warn",
+ "typescript/no-redundant-type-constituents": "warn",
+ "typescript/no-this-alias": "warn",
+ "typescript/no-unnecessary-parameter-property-assignment": "warn",
+ "typescript/no-unsafe-declaration-merging": "warn",
+ "typescript/no-unsafe-unary-minus": "warn",
+ "typescript/no-useless-empty-export": "warn",
+ "typescript/no-wrapper-object-types": "warn",
+ "typescript/prefer-as-const": "warn",
+ "typescript/require-array-sort-compare": "warn",
+ "typescript/restrict-template-expressions": "warn",
+ "typescript/triple-slash-reference": "warn",
+ "typescript/unbound-method": "warn",
+ "unicorn/no-await-in-promise-methods": "warn",
+ "unicorn/no-empty-file": "warn",
+ "unicorn/no-invalid-fetch-options": "warn",
+ "unicorn/no-invalid-remove-event-listener": "warn",
+ "unicorn/no-new-array": "warn",
+ "unicorn/no-single-promise-in-promise-methods": "warn",
+ "unicorn/no-thenable": "warn",
+ "unicorn/no-unnecessary-await": "warn",
+ "unicorn/no-useless-fallback-in-spread": "warn",
+ "unicorn/no-useless-length-check": "warn",
+ "unicorn/no-useless-spread": "warn",
+ "unicorn/prefer-set-size": "warn",
+ "unicorn/prefer-string-starts-ends-with": "warn"
+ },
+ "settings": {
+ "jsx-a11y": {
+ "polymorphicPropName": null,
+ "components": {},
+ "attributes": {}
+ },
+ "next": {
+ "rootDir": []
+ },
+ "react": {
+ "formComponents": [],
+ "linkComponents": [],
+ "version": null
+ },
+ "jsdoc": {
+ "ignorePrivate": false,
+ "ignoreInternal": false,
+ "ignoreReplacesDocs": true,
+ "overrideReplacesDocs": true,
+ "augmentsExtendsReplacesDocs": false,
+ "implementsReplacesDocs": false,
+ "exemptDestructuredRootsFromChecks": false,
+ "tagNamePreference": {}
+ },
+ "vitest": {
+ "typecheck": false
+ }
+ },
+ "env": {
+ "builtin": true
+ },
+ "globals": {},
+ "ignorePatterns": []
+}
diff --git a/app/entry.server.tsx b/app/entry.server.tsx
index be7066c..89102f6 100644
--- a/app/entry.server.tsx
+++ b/app/entry.server.tsx
@@ -1,67 +1,65 @@
-import { PassThrough } from 'node:stream';
-import { createReadableStreamFromReadable } from '@react-router/node';
-import { isbot } from 'isbot';
-import type { RenderToPipeableStreamOptions } from 'react-dom/server';
-import { renderToPipeableStream } from 'react-dom/server';
-import type { AppLoadContext, EntryContext } from 'react-router';
-import { ServerRouter } from 'react-router';
+import type { RenderToPipeableStreamOptions } from "react-dom/server";
+import type { AppLoadContext, EntryContext } from "react-router";
+
+import { createReadableStreamFromReadable } from "@react-router/node";
+import { isbot } from "isbot";
+import { PassThrough } from "node:stream";
+import { renderToPipeableStream } from "react-dom/server";
+import { ServerRouter } from "react-router";
export const streamTimeout = 5_000;
export default function handleRequest(
- request: Request,
- responseStatusCode: number,
- responseHeaders: Headers,
- routerContext: EntryContext,
- loadContext: AppLoadContext,
+ request: Request,
+ responseStatusCode: number,
+ responseHeaders: Headers,
+ routerContext: EntryContext,
+ _loadContext: AppLoadContext,
) {
- return new Promise((resolve, reject) => {
- let shellRendered = false;
- const userAgent = request.headers.get('user-agent');
+ return new Promise((resolve, reject) => {
+ let shellRendered = false;
+ const userAgent = request.headers.get("user-agent");
- // Ensure requests from bots and SPA Mode renders wait for all content to load before responding
- // https://react.dev/reference/react-dom/server/renderToPipeableStream#waiting-for-all-content-to-load-for-crawlers-and-static-generation
- const readyOption: keyof RenderToPipeableStreamOptions =
- (userAgent && isbot(userAgent)) || routerContext.isSpaMode
- ? 'onAllReady'
- : 'onShellReady';
+ // Ensure requests from bots and SPA Mode renders wait for all content to load before responding
+ // https://react.dev/reference/react-dom/server/renderToPipeableStream#waiting-for-all-content-to-load-for-crawlers-and-static-generation
+ const readyOption: keyof RenderToPipeableStreamOptions =
+ (userAgent && isbot(userAgent)) || routerContext.isSpaMode ? "onAllReady" : "onShellReady";
- const { pipe, abort } = renderToPipeableStream(
- ,
- {
- [readyOption]() {
- shellRendered = true;
- const body = new PassThrough();
- const stream = createReadableStreamFromReadable(body);
+ const { pipe, abort } = renderToPipeableStream(
+ ,
+ {
+ [readyOption]() {
+ shellRendered = true;
+ const body = new PassThrough();
+ const stream = createReadableStreamFromReadable(body);
- responseHeaders.set('Content-Type', 'text/html');
+ responseHeaders.set("Content-Type", "text/html");
- resolve(
- new Response(stream, {
- headers: responseHeaders,
- status: responseStatusCode,
- }),
- );
+ resolve(
+ new Response(stream, {
+ headers: responseHeaders,
+ status: responseStatusCode,
+ }),
+ );
- pipe(body);
- },
- onShellError(error: unknown) {
- reject(error);
- },
- onError(error: unknown) {
- // biome-ignore lint/style/noParameterAssign: Lazy
- responseStatusCode = 500;
- // Log streaming rendering errors from inside the shell. Don't log
- // errors encountered during initial shell rendering since they'll
- // reject and get logged in handleDocumentRequest.
- if (shellRendered) {
- console.error(error);
- }
- },
- },
- );
+ pipe(body);
+ },
+ onShellError(error: unknown) {
+ reject(error);
+ },
+ onError(error: unknown) {
+ responseStatusCode = 500;
+ // Log streaming rendering errors from inside the shell. Don't log
+ // errors encountered during initial shell rendering since they'll
+ // reject and get logged in handleDocumentRequest.
+ if (shellRendered) {
+ console.error(error);
+ }
+ },
+ },
+ );
- // Abort the rendering stream after the `streamTimeout` so it has tine to
- // flush down the rejected boundaries
- setTimeout(abort, streamTimeout + 1000);
- });
+ // Abort the rendering stream after the `streamTimeout` so it has tine to
+ // flush down the rejected boundaries
+ setTimeout(abort, streamTimeout + 1000);
+ });
}
diff --git a/app/routes/ssh/console.tsx b/app/routes/ssh/console.tsx
index f5f030a..b68c223 100644
--- a/app/routes/ssh/console.tsx
+++ b/app/routes/ssh/console.tsx
@@ -1,293 +1,276 @@
-/** biome-ignore-all lint/correctness/noNestedComponentDefinitions: Wtf? */
+import { faker } from "@faker-js/faker";
+import { eq } from "drizzle-orm";
+import { Loader2 } from "lucide-react";
+import { useEffect, useState } from "react";
+import { data, type ShouldRevalidateFunction, useSubmit } from "react-router";
+import { ExternalScriptsHandle } from "remix-utils/external-scripts";
-import { faker } from '@faker-js/faker';
-import { eq } from 'drizzle-orm';
-import { Loader2 } from 'lucide-react';
-import { useEffect, useState } from 'react';
-import { data, type ShouldRevalidateFunction, useSubmit } from 'react-router';
-import { ExternalScriptsHandle } from 'remix-utils/external-scripts';
-import { EphemeralNodeInsert, ephemeralNodes } from '~/server/db/schema';
-import { useLiveData } from '~/utils/live-data';
-import type { Route } from './+types/console';
-import UserPrompt from './user-prompt';
-import XTerm from './xterm.client';
+import { EphemeralNodeInsert, ephemeralNodes } from "~/server/db/schema";
+import { useLiveData } from "~/utils/live-data";
+
+import type { Route } from "./+types/console";
+
+import UserPrompt from "./user-prompt";
+import XTerm from "./xterm.client";
export const shouldRevalidate: ShouldRevalidateFunction = () => {
- return false;
+ return false;
};
export async function loader({ request, context }: Route.LoaderArgs) {
- const origin = new URL(request.url).origin;
- const assets = ['/wasm_exec.js', '/hp_ssh.wasm'];
- const missing: string[] = [];
+ const origin = new URL(request.url).origin;
+ const assets = ["/wasm_exec.js", "/hp_ssh.wasm"];
+ const missing: string[] = [];
- for (const file of assets) {
- const res = await fetch(`${origin}${file}`, { method: 'HEAD' });
- if (!res.ok) missing.push(file);
- }
+ for (const file of assets) {
+ const res = await fetch(`${origin}${file}`, { method: "HEAD" });
+ if (!res.ok) missing.push(file);
+ }
- if (missing.length > 0) {
- throw data('WebSSH is not configured in this build.', 405);
- }
+ if (missing.length > 0) {
+ throw data("WebSSH is not configured in this build.", 405);
+ }
- if (!context.agents?.agentID()) {
- throw data(
- 'WebSSH is only available with the Headplane agent integration',
- 400,
- );
- }
+ if (!context.agents?.agentID()) {
+ throw data("WebSSH is only available with the Headplane agent integration", 400);
+ }
- const session = await context.sessions.auth(request);
- if (session.user.subject === 'unknown-non-oauth') {
- throw data('Only OAuth users are allowed to use WebSSH', 403);
- }
+ const session = await context.sessions.auth(request);
+ if (session.user.subject === "unknown-non-oauth") {
+ throw data("Only OAuth users are allowed to use WebSSH", 403);
+ }
- const api = context.hsApi.getRuntimeClient(session.api_key);
- const users = await api.getUsers();
+ const api = context.hsApi.getRuntimeClient(session.api_key);
+ const users = await api.getUsers();
- // MARK: This assumes that a user has authenticated with Headscale first
- // Since the only way to enforce permissions via ACLs is to generate a
- // pre-authkey which REQUIRES a user ID, meaning the user has to have
- // authenticated with Headscale first.
- const lookup = users.find((u) => {
- const subject = u.providerId?.split('/').pop();
- if (!subject) {
- return false;
- }
- return subject === session.user.subject;
- });
+ // MARK: This assumes that a user has authenticated with Headscale first
+ // Since the only way to enforce permissions via ACLs is to generate a
+ // pre-authkey which REQUIRES a user ID, meaning the user has to have
+ // authenticated with Headscale first.
+ const lookup = users.find((u) => {
+ const subject = u.providerId?.split("/").pop();
+ if (!subject) {
+ return false;
+ }
+ return subject === session.user.subject;
+ });
- if (!lookup) {
- throw data(
- `User with subject ${session.user.subject} not found within Headscale`,
- 404,
- );
- }
+ if (!lookup) {
+ throw data(`User with subject ${session.user.subject} not found within Headscale`, 404);
+ }
- const preAuthKey = await api.createPreAuthKey(
- lookup.id,
- true, // ephemeral
- false, // reusable
- new Date(Date.now() + 60 * 1000), // expiration: 1 minute
- null, // aclTags
- );
+ const preAuthKey = await api.createPreAuthKey(
+ lookup.id,
+ true, // ephemeral
+ false, // reusable
+ new Date(Date.now() + 60 * 1000), // expiration: 1 minute
+ null, // aclTags
+ );
- // TODO: Enable config to enforce generate_authkeys capability
- // For now, any user is capable of WebSSH connections
- // const check = await context.sessions.check(
- // request,
- // Capabilities.generate_authkeys,
- // );
+ // TODO: Enable config to enforce generate_authkeys capability
+ // For now, any user is capable of WebSSH connections
+ // const check = await context.sessions.check(
+ // request,
+ // Capabilities.generate_authkeys,
+ // );
- const qp = new URL(request.url).searchParams;
- const username = qp.get('username') || undefined;
- const hostname = qp.get('hostname') || undefined;
- if (!hostname) {
- throw data('Missing required parameter: hostname', 400);
- }
+ const qp = new URL(request.url).searchParams;
+ const username = qp.get("username") || undefined;
+ const hostname = qp.get("hostname") || undefined;
+ if (!hostname) {
+ throw data("Missing required parameter: hostname", 400);
+ }
- if (!username) {
- return {
- ipnDetails: undefined,
- sshDetails: {
- username,
- hostname,
- },
- };
- }
+ if (!username) {
+ return {
+ ipnDetails: undefined,
+ sshDetails: {
+ username,
+ hostname,
+ },
+ };
+ }
- // We're making a request to /key?v=116 to check the CORS headers
- const u = context.config.headscale.public_url ?? context.config.headscale.url;
- // const res = await fetch(`${u}/key?v=116`, {
- // method: 'GET',
- // });
+ // We're making a request to /key?v=116 to check the CORS headers
+ const u = context.config.headscale.public_url ?? context.config.headscale.url;
+ // const res = await fetch(`${u}/key?v=116`, {
+ // method: 'GET',
+ // });
- // const corsOrigin = res.headers.get('Access-Control-Allow-Origin');
- // const corsMethods = res.headers.get('Access-Control-Allow-Methods');
- // const corsHeaders = res.headers.get('Access-Control-Allow-Headers');
- // console.log(corsOrigin, corsMethods, corsHeaders);
+ // const corsOrigin = res.headers.get('Access-Control-Allow-Origin');
+ // const corsMethods = res.headers.get('Access-Control-Allow-Methods');
+ // const corsHeaders = res.headers.get('Access-Control-Allow-Headers');
+ // console.log(corsOrigin, corsMethods, corsHeaders);
- // if (!corsOrigin || !corsMethods || !corsHeaders) {
- // throw data(
- // 'Headscale server does not have the required CORS headers for WebSSH',
- // 500,
- // );
- // }
+ // if (!corsOrigin || !corsMethods || !corsHeaders) {
+ // throw data(
+ // 'Headscale server does not have the required CORS headers for WebSSH',
+ // 500,
+ // );
+ // }
- const nodes = await api.getNodes();
- const lookupNode = nodes.find((n) => n.givenName === hostname);
- if (!lookupNode) {
- throw data(`Node with hostname ${hostname} not found`, 404);
- }
+ const nodes = await api.getNodes();
+ const lookupNode = nodes.find((n) => n.givenName === hostname);
+ if (!lookupNode) {
+ throw data(`Node with hostname ${hostname} not found`, 404);
+ }
- // Last thing is keeping track of the ephemeral node in the database
- // because Headscale doesn't automatically delete ephemeral nodes???
- const [_ephemeralNode] = await context.db
- .insert(ephemeralNodes)
- .values({
- auth_key: preAuthKey.key,
- } satisfies EphemeralNodeInsert)
- .returning();
+ // Last thing is keeping track of the ephemeral node in the database
+ // because Headscale doesn't automatically delete ephemeral nodes???
+ const [_ephemeralNode] = await context.db
+ .insert(ephemeralNodes)
+ .values({
+ auth_key: preAuthKey.key,
+ } satisfies EphemeralNodeInsert)
+ .returning();
- return {
- ipnDetails: {
- PreAuthKey: preAuthKey.key,
- Hostname: generateHostname(username),
- ControlURL: u,
- },
+ return {
+ ipnDetails: {
+ PreAuthKey: preAuthKey.key,
+ Hostname: generateHostname(username),
+ ControlURL: u,
+ },
- sshDetails: {
- username,
- hostname,
- },
- };
+ sshDetails: {
+ username,
+ hostname,
+ },
+ };
}
function generateHostname(username: string) {
- const adjective = faker.word.adjective({
- length: {
- min: 3,
- max: 6,
- },
- });
+ const adjective = faker.word.adjective({
+ length: {
+ min: 3,
+ max: 6,
+ },
+ });
- const noun = faker.word.noun({
- length: {
- min: 3,
- max: 6,
- },
- });
+ const noun = faker.word.noun({
+ length: {
+ min: 3,
+ max: 6,
+ },
+ });
- return `ssh-${adjective}-${noun}-${username}`;
+ return `ssh-${adjective}-${noun}-${username}`;
}
export async function action({ request, context }: Route.ActionArgs) {
- await context.sessions.auth(request);
- if (!context.agents?.agentID()) {
- throw data(
- 'WebSSH is only available with the Headplane agent integration',
- 400,
- );
- }
+ await context.sessions.auth(request);
+ if (!context.agents?.agentID()) {
+ throw data("WebSSH is only available with the Headplane agent integration", 400);
+ }
- const form = await request.formData();
- const nodeKey = form.get('node_key');
- const authKey = form.get('auth_key');
+ const form = await request.formData();
+ const nodeKey = form.get("node_key");
+ const authKey = form.get("auth_key");
- if (nodeKey === null || typeof nodeKey !== 'string') {
- throw data('Missing node_key', 400);
- }
+ if (nodeKey === null || typeof nodeKey !== "string") {
+ throw data("Missing node_key", 400);
+ }
- if (authKey === null || typeof authKey !== 'string') {
- throw data('Missing auth_key', 400);
- }
+ if (authKey === null || typeof authKey !== "string") {
+ throw data("Missing auth_key", 400);
+ }
- await context.db
- .update(ephemeralNodes)
- .set({
- node_key: nodeKey,
- })
- .where(eq(ephemeralNodes.auth_key, authKey));
+ await context.db
+ .update(ephemeralNodes)
+ .set({
+ node_key: nodeKey,
+ })
+ .where(eq(ephemeralNodes.auth_key, authKey));
}
export const links: Route.LinksFunction = () => [
- {
- rel: 'preload',
- href: '/hp_ssh.wasm',
- as: 'fetch',
- type: 'application/wasm',
- crossOrigin: 'anonymous',
- },
+ {
+ rel: "preload",
+ href: "/hp_ssh.wasm",
+ as: "fetch",
+ type: "application/wasm",
+ crossOrigin: "anonymous",
+ },
];
export const handle: ExternalScriptsHandle = {
- scripts: [
- {
- src: '/wasm_exec.js',
- crossOrigin: 'anonymous',
- preload: true,
- },
- ],
+ scripts: [
+ {
+ src: "/wasm_exec.js",
+ crossOrigin: "anonymous",
+ preload: true,
+ },
+ ],
};
-export default function Page({
- loaderData: { ipnDetails, sshDetails },
-}: Route.ComponentProps) {
- const submit = useSubmit();
- const { pause } = useLiveData();
+export default function Page({ loaderData: { ipnDetails, sshDetails } }: Route.ComponentProps) {
+ const submit = useSubmit();
+ const { pause } = useLiveData();
- const [ipn, setIpn] = useState(null);
- const [nodeKey, setNodeKey] = useState(null);
+ const [ipn, setIpn] = useState(null);
+ const [nodeKey, setNodeKey] = useState(null);
- useEffect(() => {
- if (!ipnDetails) {
- return;
- }
+ useEffect(() => {
+ if (!ipnDetails) {
+ return;
+ }
- pause();
- const go = new Go(); // Go is defined by wasm_exec.js
- WebAssembly.instantiateStreaming(
- fetch('/hp_ssh.wasm'),
- go.importObject,
- ).then((value) => {
- go.run(value.instance);
- const handle = TsWasmNet(ipnDetails, {
- NotifyState: (state) => {
- console.log('State changed:', state);
- if (state === 'Running') {
- setIpn(handle);
- }
- },
- NotifyNetMap: (netmap) => {
- // Only set NodeKey if it is not already set and then
- // also dispatch that to the backend to track the
- // ephemeral node.
- //
- // We open an SSE connection to the backend
- // so that when the connection is closed,
- // the backend can delete the ephemeral node.
- if (nodeKey === null) {
- setNodeKey(netmap.NodeKey);
- submit(
- {
- node_key: netmap.NodeKey,
- auth_key: ipnDetails.PreAuthKey,
- },
- { method: 'POST' },
- );
- }
- },
- NotifyBrowseToURL: (url) => {
- console.log('Browse to URL:', url);
- },
- NotifyPanicRecover: (message) => {
- console.error('Panic recover:', message);
- },
- });
+ pause();
+ const go = new Go(); // Go is defined by wasm_exec.js
+ WebAssembly.instantiateStreaming(fetch("/hp_ssh.wasm"), go.importObject).then((value) => {
+ go.run(value.instance);
+ const handle = TsWasmNet(ipnDetails, {
+ NotifyState: (state) => {
+ console.log("State changed:", state);
+ if (state === "Running") {
+ setIpn(handle);
+ }
+ },
+ NotifyNetMap: (netmap) => {
+ // Only set NodeKey if it is not already set and then
+ // also dispatch that to the backend to track the
+ // ephemeral node.
+ //
+ // We open an SSE connection to the backend
+ // so that when the connection is closed,
+ // the backend can delete the ephemeral node.
+ if (nodeKey === null) {
+ setNodeKey(netmap.NodeKey);
+ submit(
+ {
+ node_key: netmap.NodeKey,
+ auth_key: ipnDetails.PreAuthKey,
+ },
+ { method: "POST" },
+ );
+ }
+ },
+ NotifyBrowseToURL: (url) => {
+ console.log("Browse to URL:", url);
+ },
+ NotifyPanicRecover: (message) => {
+ console.error("Panic recover:", message);
+ },
+ });
- handle.Start();
- });
- }, []);
+ handle.Start();
+ });
+ }, []);
- if (!sshDetails.username) {
- return ;
- }
+ if (!sshDetails.username) {
+ return ;
+ }
- return (
-
- {ipn === null ? (
-
-
-
- ) : (
-
-
-
- )}
-
+ {ipn === null ? (
+
+
+
+ ) : (
+
+
+
+ )}
+