import com.mapbox.services.android.telemetry.location.LocationEngine; //导入依赖的package包/类
@Before
public void setup() throws IOException {
  MockitoAnnotations.initMocks(this);
  navigation = new MapboxNavigation(mock(Context.class), ACCESS_TOKEN, mock(NavigationTelemetry.class),
    mock(LocationEngine.class));
  navigationEventDispatcher = navigation.getEventDispatcher();

  Gson gson = new GsonBuilder()
    .registerTypeAdapterFactory(DirectionsAdapterFactory.create()).create();
  String body = loadJsonFixture(PRECISION_6);
  DirectionsResponse response = gson.fromJson(body, DirectionsResponse.class);
  route = response.routes().get(0);
  routeProgress = RouteProgress.builder()
    .stepDistanceRemaining(100)
    .legDistanceRemaining(100)
    .distanceRemaining(100)
    .directionsRoute(route)
    .stepIndex(0)
    .legIndex(0)
    .build();
}
 

import com.mapbox.services.android.telemetry.location.LocationEngine; //导入依赖的package包/类
@Override
public void onMapReady(final MapboxMap mapboxMap) {
  LocationEngine locationEngine = new LostLocationEngine(this);
  locationLayerPlugin = new LocationLayerPlugin(mapView, mapboxMap, locationEngine);
  locationLayerPlugin.setLocationLayerEnabled(LocationLayerMode.COMPASS);
  locationLayerPlugin.addCompassListener(new CompassListener() {
    @Override
    public void onCompassChanged(float userHeading) {
      CameraPosition cameraPosition = new CameraPosition.Builder().bearing(userHeading).build();
      mapboxMap.easeCamera(CameraUpdateFactory.newCameraPosition(cameraPosition));
    }

    @Override
    public void onCompassAccuracyChange(int compassStatus) {
      System.out.println(compassStatus);
    }
  });
}
 

import com.mapbox.services.android.telemetry.location.LocationEngine; //导入依赖的package包/类
/**
 * Activates a new {@link MockLocationEngine} with the given
 * {@link DirectionsRoute}.
 *
 * @param route to be mocked
 */
private void activateMockLocationEngine(DirectionsRoute route) {
  LocationEngine locationEngine = new MockLocationEngine(1000, 30, false);
  ((MockLocationEngine) locationEngine).setRoute(route);
  locationEngine.activate();
  this.locationEngine.setValue(locationEngine);
}
 

import com.mapbox.services.android.telemetry.location.LocationEngine; //导入依赖的package包/类
void initialize(@NonNull Context context, @NonNull String accessToken,
                MapboxNavigation navigation, LocationEngine locationEngine) {

  if (!isInitialized) {
    // Initial session state
    navigationSessionState = SessionState.builder().build();

    // Setup the location engine
    updateLocationEngine(locationEngine);

    validateAccessToken(accessToken);

    // Setup the listeners
    initEventDispatcherListeners(navigation);

    MapboxNavigationOptions options = navigation.options();
    // Set sdkIdentifier based on if from UI or not
    String sdkIdentifier = updateSdkIdentifier(options);
    // Enable extra logging in debug mode
    MapboxTelemetry.getInstance().setDebugLoggingEnabled(options.isDebugLoggingEnabled());

    updateUserAgent(context, accessToken, sdkIdentifier);

    // Get the current vendorId
    vendorId = obtainVendorId(context);

    NavigationMetricsWrapper.sdkIdentifier = sdkIdentifier;
    NavigationMetricsWrapper.turnstileEvent();
    // TODO This should be removed when we figure out a solution in NavigationTelemetry
    // Force pushing a TYPE_MAP_LOAD event to ensure that the Nav turnstile event is sent
    MapboxTelemetry.getInstance().pushEvent(MapboxEvent.buildMapLoadEvent());

    isInitialized = true;
  }
}
 

import com.mapbox.services.android.telemetry.location.LocationEngine; //导入依赖的package包/类
/**
 * Called during {@link NavigationTelemetry#initialize(Context, String, MapboxNavigation, LocationEngine)}
 * and any time {@link MapboxNavigation} gets an updated location engine.
 * <p>
 * Removes the current location engine listener if it exists, then
 * sets up the new one / updates the location engine name.
 *
 * @param locationEngine to be used to update
 */
void updateLocationEngine(LocationEngine locationEngine) {
  // Remove listener from previous engine
  if (navigationLocationEngine != null) {
    navigationLocationEngine.removeLocationEngineListener(this);
  }

  // Store the new engine and setup a new listener
  if (locationEngine != null) {
    navigationLocationEngine = locationEngine;
    navigationLocationEngine.addLocationEngineListener(this);
    String locationEngineName = locationEngine.getClass().getName();
    navigationSessionState.toBuilder().locationEngineName(locationEngineName);
  }
}
 

import com.mapbox.services.android.telemetry.location.LocationEngine; //导入依赖的package包/类
MapboxNavigation(@NonNull Context context, @NonNull String accessToken,
                 @NonNull MapboxNavigationOptions options, NavigationTelemetry navigationTelemetry,
                 LocationEngine locationEngine) {
  this.accessToken = accessToken;
  this.context = context;
  this.options = options;
  this.navigationTelemetry = navigationTelemetry;
  this.locationEngine = locationEngine;
  initialize();
}
 

import com.mapbox.services.android.telemetry.location.LocationEngine; //导入依赖的package包/类
private LocationEngine obtainLocationEngine() {
  if (locationEngine == null) {
    return new LostLocationEngine(context);
  }

  return locationEngine;
}
 

import com.mapbox.services.android.telemetry.location.LocationEngine; //导入依赖的package包/类
@Test
public void sanityTest() {
  assertNotNull("should not be null", navigation);
  MapboxNavigationOptions options = MapboxNavigationOptions.builder().build();
  MapboxNavigation navigationWithOptions = new MapboxNavigation(mock(Context.class),
    ACCESS_TOKEN, options, mock(NavigationTelemetry.class), mock(LocationEngine.class));
  assertNotNull("should not be null", navigationWithOptions);
}
 

import com.mapbox.services.android.telemetry.location.LocationEngine; //导入依赖的package包/类
@Test
public void defaultMilestones_onInitializationDoNotGetAdded() throws Exception {
  MapboxNavigationOptions options = MapboxNavigationOptions.builder().defaultMilestonesEnabled(false).build();
  MapboxNavigation navigationWithOptions = new MapboxNavigation(mock(Context.class),
    ACCESS_TOKEN, options, mock(NavigationTelemetry.class), mock(LocationEngine.class));
  assertEquals(0, navigationWithOptions.getMilestones().size());
}
 

import com.mapbox.services.android.telemetry.location.LocationEngine; //导入依赖的package包/类
@Test
public void addMilestone_milestoneOnlyGetsAddedOnce() throws Exception {
  MapboxNavigationOptions options = MapboxNavigationOptions.builder().defaultMilestonesEnabled(false).build();
  MapboxNavigation navigationWithOptions = new MapboxNavigation(mock(Context.class),
    ACCESS_TOKEN, options, mock(NavigationTelemetry.class), mock(LocationEngine.class));
  Milestone milestone = new StepMilestone.Builder().build();
  navigationWithOptions.addMilestone(milestone);
  navigationWithOptions.addMilestone(milestone);
  assertEquals(1, navigationWithOptions.getMilestones().size());
}
 

import com.mapbox.services.android.telemetry.location.LocationEngine; //导入依赖的package包/类
@Test
public void removeMilestone_milestoneDidGetRemoved() throws Exception {
  MapboxNavigationOptions options = MapboxNavigationOptions.builder().defaultMilestonesEnabled(false).build();
  MapboxNavigation navigationWithOptions = new MapboxNavigation(mock(Context.class),
    ACCESS_TOKEN, options, mock(NavigationTelemetry.class), mock(LocationEngine.class));
  Milestone milestone = new StepMilestone.Builder().build();
  navigationWithOptions.addMilestone(milestone);
  assertEquals(1, navigationWithOptions.getMilestones().size());
  navigationWithOptions.removeMilestone(milestone);
  assertEquals(0, navigationWithOptions.getMilestones().size());
}
 

import com.mapbox.services.android.telemetry.location.LocationEngine; //导入依赖的package包/类
@Test
public void removeMilestone_milestoneDoesNotExist() throws Exception {
  MapboxNavigationOptions options = MapboxNavigationOptions.builder().defaultMilestonesEnabled(false).build();
  MapboxNavigation navigationWithOptions = new MapboxNavigation(mock(Context.class),
    ACCESS_TOKEN, options, mock(NavigationTelemetry.class), mock(LocationEngine.class));
  Milestone milestone = new StepMilestone.Builder().build();
  navigationWithOptions.addMilestone(new StepMilestone.Builder().build());
  navigationWithOptions.removeMilestone(milestone);
  assertEquals(1, navigationWithOptions.getMilestones().size());
}
 

import com.mapbox.services.android.telemetry.location.LocationEngine; //导入依赖的package包/类
@Test
public void removeMilestone_nullRemovesAllMilestones() throws Exception {
  MapboxNavigationOptions options = MapboxNavigationOptions.builder().defaultMilestonesEnabled(false).build();
  MapboxNavigation navigationWithOptions = new MapboxNavigation(mock(Context.class),
    ACCESS_TOKEN, options, mock(NavigationTelemetry.class), mock(LocationEngine.class));
  navigationWithOptions.addMilestone(new StepMilestone.Builder().build());
  navigationWithOptions.addMilestone(new StepMilestone.Builder().build());
  navigationWithOptions.addMilestone(new StepMilestone.Builder().build());
  navigationWithOptions.addMilestone(new StepMilestone.Builder().build());
  assertEquals(4, navigationWithOptions.getMilestones().size());
  navigationWithOptions.removeMilestone(null);
  assertEquals(0, navigationWithOptions.getMilestones().size());
}
 

import com.mapbox.services.android.telemetry.location.LocationEngine; //导入依赖的package包/类
@Test
public void removeMilestone_correctMilestoneWithIdentifierGetsRemoved() throws Exception {
  MapboxNavigationOptions options = MapboxNavigationOptions.builder().defaultMilestonesEnabled(false).build();
  MapboxNavigation navigationWithOptions = new MapboxNavigation(mock(Context.class),
    ACCESS_TOKEN, options, mock(NavigationTelemetry.class), mock(LocationEngine.class));
  Milestone milestone = new StepMilestone.Builder().setIdentifier(5678).build();
  navigationWithOptions.addMilestone(milestone);
  assertEquals(1, navigationWithOptions.getMilestones().size());
  navigationWithOptions.removeMilestone(5678);
  assertEquals(0, navigationWithOptions.getMilestones().size());
}
 

import com.mapbox.services.android.telemetry.location.LocationEngine; //导入依赖的package包/类
@Test
public void removeMilestone_noMilestoneWithIdentifierFound() throws Exception {
  MapboxNavigationOptions options = MapboxNavigationOptions.builder().defaultMilestonesEnabled(false).build();
  MapboxNavigation navigationWithOptions = new MapboxNavigation(mock(Context.class),
    ACCESS_TOKEN, options, mock(NavigationTelemetry.class), mock(LocationEngine.class));
  navigationWithOptions.addMilestone(new StepMilestone.Builder().build());
  assertEquals(1, navigationWithOptions.getMilestones().size());
  navigationWithOptions.removeMilestone(5678);
  assertEquals(1, navigationWithOptions.getMilestones().size());
}
 

import com.mapbox.services.android.telemetry.location.LocationEngine; //导入依赖的package包/类
@Test
public void getLocationEngine_returnsCorrectLocationEngine() throws Exception {
  LocationEngine locationEngine = mock(LocationEngine.class);
  LocationEngine locationEngine2 = mock(LocationEngine.class);
  navigation.setLocationEngine(locationEngine);
  assertNotSame(locationEngine2, navigation.getLocationEngine());
  assertEquals(locationEngine, navigation.getLocationEngine());
}
 

import com.mapbox.services.android.telemetry.location.LocationEngine; //导入依赖的package包/类
public static synchronized LocationEngine getLocationEngine(Context context) {
  if (instance == null) {
    instance = new GoogleLocationEngine(context.getApplicationContext());
  }

  return instance;
}
 

import com.mapbox.services.android.telemetry.location.LocationEngine; //导入依赖的package包/类
/**
 * Construct a {@code LocationLayerPlugin}
 *
 * @param mapView        the MapView to apply the My Location layer plugin to
 * @param mapboxMap      the MapboxMap to apply the My Location layer plugin with
 * @param locationEngine the {@link LocationEngine} this plugin should use to update
 * @param styleRes       customize the user location icons inside your apps {@code style.xml}
 * @since 0.1.0
 */
public LocationLayerPlugin(@NonNull MapView mapView, @NonNull MapboxMap mapboxMap,
                           @Nullable LocationEngine locationEngine, @StyleRes int styleRes) {
  this.locationEngine = locationEngine;
  this.mapboxMap = mapboxMap;
  this.mapView = mapView;
  this.styleRes = styleRes;
  mapView.addOnMapChangedListener(this);
  initialize();
}
 

import com.mapbox.services.android.telemetry.location.LocationEngine; //导入依赖的package包/类
/**
 * The {@link LocationEngine} the plugin will use to update it's position. If {@code null} is
 * passed in, all updates will occur through the
 * {@link LocationLayerPlugin#forceLocationUpdate(Location)} method.
 *
 * @param locationEngine a {@link LocationEngine} this plugin should use to handle updates
 * @since 0.1.0
 */
@SuppressWarnings( {"MissingPermission"})
public void setLocationEngine(@Nullable LocationEngine locationEngine) {
  if (locationEngine != null) {
    this.locationEngine = locationEngine;
    setLocationLayerEnabled(locationLayerMode);
  } else if (this.locationEngine != null) {
    this.locationEngine.removeLocationEngineListener(this);
    this.locationEngine = null;
  }
}
 

import com.mapbox.services.android.telemetry.location.LocationEngine; //导入依赖的package包/类
void updateLocationEngine(LocationEngine locationEngine) {
  navigation.setLocationEngine(locationEngine);
}