services/location/src/org/chromium/services/location/LocationApplicationDelegate.java

// Copyright 2015 The Chromium Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.

package org.chromium.services.location;

import android.content.Context;
import android.os.HandlerThread;
import android.util.Log;

import com.google.android.gms.common.ConnectionResult;
import com.google.android.gms.common.api.GoogleApiClient;
import com.google.android.gms.location.LocationServices;

import org.chromium.mojo.application.ApplicationConnection;
import org.chromium.mojo.application.ApplicationDelegate;
import org.chromium.mojo.application.ServiceFactoryBinder;
import org.chromium.mojo.bindings.InterfaceRequest;
import org.chromium.mojo.system.Core;
import org.chromium.mojom.mojo.LocationService;
import org.chromium.mojom.mojo.Shell;

/**
 * Android service application implementing the LocationService interface using Google play services
 * API.
 */
public class LocationApplicationDelegate implements ApplicationDelegate {
    private static final String TAG = "LocationServiceApp";

    private final GoogleApiClient mGoogleApiClient;
    private final Core mCore;

    /**
     * Thread to get callbacks from google play services api.
     */
    private final HandlerThread mHandlerThread = new HandlerThread("LocationThread");

    public LocationApplicationDelegate(Context context, Core core) {
        // TODO(alhaad): Create a test mode which uses mock locations instead of real locations.
        mGoogleApiClient = new GoogleApiClient.Builder(context).addApi(LocationServices.API)
                .build();
        mCore = core;
    }

    /**
     * @see ApplicationDelegate#initialize(Shell, String[], String)
     */
    @Override
    public void initialize(Shell shell, String[] args, String url) {
        ConnectionResult connectionResult = mGoogleApiClient.blockingConnect();
        if (!connectionResult.isSuccess()) {
            Log.e(TAG, "Could not connect to Google play services. ConnectionResult: "
                    + connectionResult.toString());
            mCore.getCurrentRunLoop().quit();
            return;
        }
        mHandlerThread.start();
    }

    /**
     * @see ApplicationDelegate#configureIncomingConnection(ApplicationConnection)
     */
    @Override
    public boolean configureIncomingConnection(ApplicationConnection connection) {
        connection.addService(new ServiceFactoryBinder<LocationService>() {
            @Override
            public void bind(InterfaceRequest<LocationService> request) {
                LocationService.MANAGER.bind(
                        new LocationServiceImpl(mGoogleApiClient, mHandlerThread.getLooper(),
                                mCore.getCurrentRunLoop()),
                        request);
            }

            @Override
            public String getInterfaceName() {
                return LocationService.MANAGER.getName();
            }
        });
        return true;
    }

    /**
     * @see ApplicationDelegate#quit()
     */
    @Override
    public void quit() {
        mGoogleApiClient.disconnect();
        mHandlerThread.quitSafely();
        try {
            mHandlerThread.join();
        } catch (InterruptedException e) {
            Log.e(TAG, e.getMessage(), e);
        }
    }
}