diff --git a/lib/runtime/gateway_runtime_protocol.dart b/lib/runtime/gateway_runtime_protocol.dart index b3a66bb1..432b1a8e 100644 --- a/lib/runtime/gateway_runtime_protocol.dart +++ b/lib/runtime/gateway_runtime_protocol.dart @@ -18,7 +18,7 @@ import 'gateway_runtime_errors.dart'; import 'gateway_runtime_helpers.dart'; import 'gateway_runtime_core.dart'; -const kGatewayProtocolVersion = 3; +const kGatewayProtocolVersion = 4; const kDefaultOperatorConnectScopes = [ 'operator.admin', 'operator.read', diff --git a/test/runtime/gateway_runtime_bridge_skills_test.dart b/test/runtime/gateway_runtime_bridge_skills_test.dart index a2272db2..bd80d942 100644 --- a/test/runtime/gateway_runtime_bridge_skills_test.dart +++ b/test/runtime/gateway_runtime_bridge_skills_test.dart @@ -6,6 +6,7 @@ import 'package:xworkmate/runtime/device_identity_store.dart'; import 'package:xworkmate/runtime/gateway_acp_client.dart'; import 'package:xworkmate/runtime/gateway_runtime.dart'; import 'package:xworkmate/runtime/runtime_controllers.dart'; +import 'package:xworkmate/runtime/runtime_models.dart'; import 'package:xworkmate/runtime/secure_config_store.dart'; void main() { @@ -129,9 +130,10 @@ void main() { endpointResolver: () => Uri.parse('http://127.0.0.1:${server.port}'), authorizationResolver: (_) async => 'bridge-token', ); + final identityStore = DeviceIdentityStore(store); final runtime = GatewayRuntime( store: store, - identityStore: DeviceIdentityStore(store), + identityStore: identityStore, sessionClient: GatewayAcpRuntimeSessionClient(client: acpClient), ); await runtime.initialize(); @@ -142,6 +144,18 @@ void main() { await tempDir.delete(recursive: true); }); + final directConnectParams = await runtime.buildConnectParamsInternal( + runtime, + profile: GatewayConnectionProfile.defaults(), + identity: await identityStore.loadOrCreate(), + nonce: 'nonce', + authToken: 'bridge-token', + authDeviceToken: '', + authPassword: '', + ); + expect(directConnectParams['minProtocol'], kGatewayProtocolVersion); + expect(directConnectParams['maxProtocol'], kGatewayProtocolVersion); + final controller = SkillsController(runtime); await controller.refresh(agentId: 'main');