blob: fb2569645c1f1fbefd279bfc2231f84ea2cb3732 [file] [log] [blame]
// Copyright 2018 The Fuchsia Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
import 'package:fidl/fidl.dart';
import 'package:fidl_fuchsia_modular/fidl_async.dart' as fidl_modular;
import 'package:fidl_fuchsia_sys/fidl_async.dart' as fidl_sys;
import 'package:fuchsia_logger/logger.dart';
import '../internal/_component_context.dart';
/// Connect to the service specified by [serviceProxy] and implemented by the
/// agent with [agentUrl]. Optionally, provide a [componentContextProxy] which
/// will be used to connect to the agent.
/// The agent will be launched if it's not already running.
void connectToAgentService<T>(String agentUrl, AsyncProxy<T> serviceProxy,
{fidl_modular.ComponentContextProxy componentContextProxy}) {
if (agentUrl == null || agentUrl.isEmpty) {
throw Exception(
'agentUrl must not be null or empty in call to connectToAgentService');
if (serviceProxy == null) {
throw Exception(
'serviceProxy must not be null in call to connectToAgentService');
final serviceProviderProxy = fidl_sys.ServiceProviderProxy();
final agentControllerProxy = fidl_modular.AgentControllerProxy();
// Creates an interface request and binds one of the channels. Binding this
// channel prior to connecting to the agent allows the developer to make
// proxy calls without awaiting for the connection to actually establish.
final serviceProxyRequest = serviceProxy.ctrl.request();
componentContextProxy ??= getComponentContext();
// Connect to the agent with componentContextProxy.
.then((_) {
final serviceName = serviceProxy.ctrl.$serviceName;
// Connect to the service.
if (serviceName == null) {
throw Exception("${serviceProxy.ctrl.$interfaceName}'s "
'proxyServiceController.\$serviceName must not be null. Check the FIDL '
'file for a missing [Discoverable]');
.connectToService(serviceName, serviceProxyRequest.passChannel())
.then((_) {
// Close agent controller when the service proxy is closed.
serviceProxy.ctrl.whenClosed.then((_) {'Service proxy [${serviceProxy.ctrl.$serviceName}] is closed. '
'Closing the associated AgentControllerProxy.');
// Close all unnecessary bindings.
}).catchError((e) {
throw e;