import { assert, describe, it } from "@effect/vitest";import { SshHttpBridgeError } from "@t3tools/ssh/errors";import * as Effect from "effect/Effect";import * as Layer from "effect/Layer";import * as Schema from "effect/Schema";import { HttpClient, HttpClientRequest, HttpClientResponse } from "effect/unstable/http"; import * as DesktopSshRemoteApi from "./DesktopSshRemoteApi.ts"; const isSshHttpBridgeError = Schema.is(SshHttpBridgeError); function jsonResponse(request: HttpClientRequest.HttpClientRequest, body: unknown, status = 200) { return HttpClientResponse.fromWeb( request, new Response(JSON.stringify(body), { status, headers: { "content-type": "application/json" }, }), );} function makeLayer( handler: ( request: HttpClientRequest.HttpClientRequest, ) => Effect.Effect<HttpClientResponse.HttpClientResponse>,) { return DesktopSshRemoteApi.layer.pipe( Layer.provide( Layer.succeed( HttpClient.HttpClient, HttpClient.make((request) => handler(request)), ), ), );} describe("DesktopSshRemoteApi", () => { it.effect("fetches and decodes the remote environment descriptor", () => { const requestUrls: string[] = []; const layer = makeLayer((request) => Effect.sync(() => { requestUrls.push(request.url); return jsonResponse(request, { environmentId: "remote-env", label: "Remote Devbox", platform: { os: "linux", arch: "x64" }, serverVersion: "1.2.3", capabilities: { repositoryIdentity: true }, }); }), ); return Effect.gen(function* () { const remoteApi = yield* DesktopSshRemoteApi.DesktopSshRemoteApi; const descriptor = yield* remoteApi.fetchEnvironmentDescriptor({ httpBaseUrl: "http://127.0.0.1:41773/", }); assert.equal(descriptor.label, "Remote Devbox"); assert.deepEqual(requestUrls, ["http://127.0.0.1:41773/.well-known/t3/environment"]); }).pipe(Effect.provide(layer)); }); it.effect("wraps schema decode failures in a typed remote api error", () => { const layer = makeLayer((request) => Effect.succeed(jsonResponse(request, { environmentId: "remote-env" })), ); return Effect.gen(function* () { const remoteApi = yield* DesktopSshRemoteApi.DesktopSshRemoteApi; const error = yield* remoteApi .fetchEnvironmentDescriptor({ httpBaseUrl: "http://127.0.0.1:41773/", }) .pipe(Effect.flip); assert.instanceOf(error, DesktopSshRemoteApi.DesktopSshRemoteApiError); assert.equal(error.operation, "fetch-environment-descriptor"); assert.equal(isSshHttpBridgeError(error.cause), false); }).pipe(Effect.provide(layer)); });});
import { assert, describe, it } from "@effect/vitest";
import { SshHttpBridgeError } from "@t3tools/ssh/errors";
import * as Effect from "effect/Effect";
import * as Layer from "effect/Layer";
import * as Schema from "effect/Schema";
import { HttpClient, HttpClientRequest, HttpClientResponse } from "effect/unstable/http";
import * as DesktopSshRemoteApi from "./DesktopSshRemoteApi.ts";
const isSshHttpBridgeError = Schema.is(SshHttpBridgeError);
function jsonResponse(request: HttpClientRequest.HttpClientRequest, body: unknown, status = 200) {
return HttpClientResponse.fromWeb(
request,
new Response(JSON.stringify(body), {
status,
headers: { "content-type": "application/json" },
}),
);
}
function makeLayer(
handler: (
request: HttpClientRequest.HttpClientRequest,
) => Effect.Effect<HttpClientResponse.HttpClientResponse>,
) {
return DesktopSshRemoteApi.layer.pipe(
Layer.provide(
Layer.succeed(
HttpClient.HttpClient,
HttpClient.make((request) => handler(request)),
),
),
);
}
describe("DesktopSshRemoteApi", () => {
it.effect("fetches and decodes the remote environment descriptor", () => {
const requestUrls: string[] = [];
const layer = makeLayer((request) =>
Effect.sync(() => {
requestUrls.push(request.url);
return jsonResponse(request, {
environmentId: "remote-env",
label: "Remote Devbox",
platform: { os: "linux", arch: "x64" },
serverVersion: "1.2.3",
capabilities: { repositoryIdentity: true },
});
}),
);
return Effect.gen(function* () {
const remoteApi = yield* DesktopSshRemoteApi.DesktopSshRemoteApi;
const descriptor = yield* remoteApi.fetchEnvironmentDescriptor({
httpBaseUrl: "http://127.0.0.1:41773/",
});
assert.equal(descriptor.label, "Remote Devbox");
assert.deepEqual(requestUrls, ["http://127.0.0.1:41773/.well-known/t3/environment"]);
}).pipe(Effect.provide(layer));
});
it.effect("wraps schema decode failures in a typed remote api error", () => {
const layer = makeLayer((request) =>
Effect.succeed(jsonResponse(request, { environmentId: "remote-env" })),
);
return Effect.gen(function* () {
const remoteApi = yield* DesktopSshRemoteApi.DesktopSshRemoteApi;
const error = yield* remoteApi
.fetchEnvironmentDescriptor({
httpBaseUrl: "http://127.0.0.1:41773/",
})
.pipe(Effect.flip);
assert.instanceOf(error, DesktopSshRemoteApi.DesktopSshRemoteApiError);
assert.equal(error.operation, "fetch-environment-descriptor");
assert.equal(isSshHttpBridgeError(error.cause), false);
}).pipe(Effect.provide(layer));
});
});