mirror of
https://github.com/clusterio/clusterio.git
synced 2026-11-11 15:04:52 +09:00
Danielv123
49a0b27d29
Revoking a host now unassigns its instances instead of being refused while it has any, and removes its system metrics. Approving and revoking no longer force a save. Hosts are saved by autosave and on exit like everything else, which also removes the approving state from pairing requests. The approval code and link are logged as warnings so they show up in the systemd service, which only prints warnings and above. The pairing limits are now the controller.host_pairing_timeout and controller.host_pairing_max_pending config values, 0 removes the limit. Subscribers take an optional permitted function, used for the pairing requests instead of overrides in a subclass.
60 lines
2.1 KiB
JavaScript
60 lines
2.1 KiB
JavaScript
import assert from "node:assert/strict";
|
|
import events from "node:events";
|
|
|
|
import * as lib from "@clusterio/lib";
|
|
import { MockConnector, MockControl } from "../mock.js";
|
|
import "../setup_logging.js";
|
|
|
|
import { HostPairingSubscriber } from "../../packages/web_ui/src/util/host_pairing.ts";
|
|
|
|
const addr = lib.Address.fromShorthand;
|
|
|
|
describe("web_ui/util/host_pairing", function() {
|
|
describe("class HostPairingSubscriber", function() {
|
|
let mockControl;
|
|
let subscriber;
|
|
|
|
beforeEach(function() {
|
|
mockControl = new MockControl(new MockConnector(addr({ controlId: 0 }), addr("controller")));
|
|
subscriber = new HostPairingSubscriber(mockControl, () => true);
|
|
});
|
|
|
|
function pairing(code, updatedAtMs) {
|
|
return new lib.HostPairingDetails(code, `Host ${code}`, "192.0.2.1", "", updatedAtMs, updatedAtMs);
|
|
}
|
|
|
|
async function settle() {
|
|
await new Promise(resolve => setImmediate(resolve));
|
|
}
|
|
|
|
function sentRequests() {
|
|
return mockControl.connector.sentMessages.filter(message => message.name === "SubscriptionRequest");
|
|
}
|
|
|
|
it("should clear requests when subscribing again after the last unsubscribe", async function() {
|
|
const unsubscribe = subscriber.subscribe(() => {});
|
|
await events.once(mockControl.connector, "send");
|
|
await subscriber._handleEvent(new lib.HostPairingUpdatesEvent([pairing("ABC-DEF", 10)]));
|
|
unsubscribe();
|
|
await new Promise(resolve => setTimeout(resolve));
|
|
mockControl.connector.sentMessages.length = 0;
|
|
|
|
subscriber.subscribe(() => {});
|
|
assert.equal(subscriber.values.size, 0);
|
|
await settle();
|
|
assert.equal(sentRequests().length, 1);
|
|
assert.equal(sentRequests()[0].data.lastRequestTimeMs, -1);
|
|
});
|
|
|
|
it("should keep requests when a page that subscribes replaces another", async function() {
|
|
const unsubscribe = subscriber.subscribe(() => {});
|
|
await events.once(mockControl.connector, "send");
|
|
await subscriber._handleEvent(new lib.HostPairingUpdatesEvent([pairing("ABC-DEF", 10)]));
|
|
unsubscribe();
|
|
subscriber.subscribe(() => {});
|
|
assert.equal(subscriber.values.size, 1);
|
|
assert.equal(subscriber.lastUpdatedMs, 10);
|
|
});
|
|
});
|
|
});
|