implementation 'com.huawei.hms:hwid:5.0.3.301'

/**
 * Start AuthService and request the scope parameters
 */
private fun startAuthService() {
    HuaweiIdAuthParamsHelper(HuaweiIdAuthParams.DEFAULT_AUTH_REQUEST_PARAM)
        .setUid()
        .setProfile()
        .setMobileNumber()
        .setEmail()
        .setIdToken()
        .setAccessToken()
        .setAuthorizationCode()
        .setScopeList(scopes)
        .createParams()
    startActivityForResult(service.signInIntent, AppConstants.LOGIN_AUTH_CODE)
}

/**
*Check authentication is successful or not.
*/
override fun onActivityResult(requestCode: Int, resultCode: Int, @Nullable data: Intent?) {
    super.onActivityResult(requestCode, resultCode, data)
    if (resultCode == RESULT_OK)
        when (requestCode) {
            AppConstants.LOGIN_AUTH_CODE -> {
                AGConnectAuth.getInstance().signOut()
                val authHuaweiIdTask: Task<AuthHuaweiId> =
                    HuaweiIdAuthManager.parseAuthResultFromIntent(data)
                if (authHuaweiIdTask.isSuccessful) {
                    huaweiAccount = authHuaweiIdTask.result
                    Log.d(
                        TAG,
                        AppConstants.LOGIN_GET_ACCESS_TOKEN
                    )
                    val credential =                     HwIdAuthProvider.credentialWithToken(huaweiAccount?.accessToken)
                    agConnectAuth.signIn(credential)
                        ?.addOnSuccessListener {
                            it.user.displayName
                            it.user.email
                            it.user.uid
                            it.user.providerInfo
                            mCloudDBZoneWrapper
                                .setmUiCallBack(this)
                            mCloudDBZoneWrapper
                                .openCloudDBZoneV2()
                        }
                        ?.addOnFailureListener {
                            Log.e(TAG, AppConstants.LOGIN_FAILED)
                        }
                } else {
                    Log.e(
                        TAG,
                        AppConstants.LOGIN_FAILED
                    )
                }
            }

implementation 'com.huawei.hms:maps:5.0.5.301'

MapsInitializer.setApiKey(AppConstants.API_KEY)
mMapView.onCreate(mapViewBundle)
mMapView.getMapAsync(this)

/**
*To load Map View
*/
Override fun onMapReady(huaweiMap: HuaweiMap) {
     latLng1 = LatLng(Utils.curentLatitude, Utils.currentLongitude)
     latLng2 = lat?.let { lng?.let { it1 -> LatLng(it, it1) } }
     hMap = huaweiMap
     hMap?.isMyLocationEnabled = true
     val build = CameraPosition.Builder().target(latLng1).zoom(3f).tilt(45f).build()
     val cameraUpdate = CameraUpdateFactory.newCameraPosition(build)
     hMap?.apply {
         animateCamera(cameraUpdate)
         moveCamera(cameraUpdate)
     }
     addOriginMarker(latLng1!!)
     latLng2?.let { addDestinationMarker(it) }
     removePolylines()
     hMap?.moveCamera(CameraUpdateFactory.newLatLngZoom(latLng1, 10f))
     mMarkerOrigin?.showInfoWindow()
     hMap?.apply {
         moveCamera(CameraUpdateFactory.newLatLngZoom(latLng2, 10f))
         resetMinMaxZoomPreference()
     }
     mMarkerDestination?.showInfoWindow()
     
 }

/**
* This method shows a marker for Consumer location on Map.
*/
private fun addOriginMarker(latLng: LatLng) {
     if (null != mMarkerOrigin) {
         mMarkerOrigin?.remove()
     }
     val address = getCompleteAddressString(Utils.curentLatitude, Utils.currentLongitude)
     mMarkerOrigin = hMap?.addMarker(
         MarkerOptions().position(latLng)
             .anchorMarker(0.5f, 0.9f)
             .title("Current Location")
             .snippet(address)
     )
 }

implementation 'com.huawei.hms:location:5.0.4.300'

/**
*This method shows a marker for Service Provider location on HMS Map
*/
private fun addDestinationMarker(latLng: LatLng) {
     if (null != mMarkerDestination) {
         mMarkerDestination?.remove()
     }
     mMarkerDestination = hMap?.addMarker(
         MarkerOptions().position(latLng).anchorMarker(0.5f, 0.9f).title(storeName)
             .snippet(storeAddress)
     )
 }

<uses-permission android:name="android.permission.INTERNET" />
<uses-permission android:name="android.permission.ACCESS_COARSE_LOCATION"/>
<uses-permission android:name="android.permission.ACCESS_FINE_LOCATION"/>
<uses-permission android:name="android.permission.ACCESS_BACKGROUND_LOCATION" />

/**
*This method fetches location updates
*/
private fun startLocationUpdates() {
     fusedLocationClient.requestLocationUpdates(locationRequest, locationCallback, null)
 }

private val locationCallback = object : LocationCallback() {
     override fun onLocationResult(locationResult: LocationResult?) {
         locationResult ?: return
         for (location in locationResult.locations) {
             setLocationData(location)
         }
     }
 }

 /**
* To set location data.
*/
private fun setLocationData(location: Location) {
     value = LocationModel(longitude = location.longitude, latitude = location.latitude)
 }

/**
* To fetch last location information
*/
override fun onActive() {
     super.onActive()
     fusedLocationClient.lastLocation
         .addOnSuccessListener { location: Location? ->
             location?.also {
                 setLocationData(it)
             }
         }
     startLocationUpdates()
 }

implementation 'com.huawei.hms:identity:5.1.0.300'

/**
* To fetch user address from Identity kit
*/
 
private fun getUserAddress() {
     val task = Address.getAddressClient(this@MainActivity).getUserAddress(UserAddressRequest())
     task.addOnSuccessListener {
         Log.i(TAG, AppConstants.LOGIN_USER_DATA_SUCCESS)
         try {
             startActivityForResult(it)
         } catch (ex: IntentSender.SendIntentException) {
             Log.d(TAG, "SendIntentException")
         }
     }.addOnFailureListener {
         Log.i(TAG, AppConstants.LOGIN_USER_DATA_FAILED)
     }
 }

/**
* To fetch user address result.
*/
private fun startActivityForResult(result: GetUserAddressResult) {
     val status = result.status
     if (result.returnCode == 0 && status.hasResolution()) {
         Log.i(TAG, AppConstants.LOGIN_RESULT_RES)
         status.startResolutionForResult(
             this@MainActivity, AppConstants.LOGIN_GET_ADDRESS_REQUESTCODE
         )
     } else {
         Log.i(TAG, AppConstants.LOGIN_RESULT_RES_FAILED)
         Utils.showToast(this@MainActivity, getString(R.string.msg_failed_user_resolution))
     }
 }

/**
* To read user address result.
*/
override fun onActivityResult(requestCode: Int, resultCode: Int, data: Intent?) {
     super.onActivityResult(requestCode, resultCode, data)
     when(requestCode) {
         AppConstants.LOGIN_GET_ADDRESS_REQUESTCODE -> {
             onGetAddressResult(resultCode, data)
             fragmentCommunicator?.passDataToFragment(data)
         }
     }
 }

implementation 'com.huawei.hms:site:5.0.2.300'

searchService = SearchServiceFactory.create(this, Utils.getApiKey())

/**
*To fetch nearby stores based on user's current location
*/
intent.let {
     val request = NearbySearchRequest().apply {
         queryString=it.getStringExtra(AppConstants.REQUEST_QUERY).toString()
         setQuery(queryString)
         setLocation(
             Coordinate(
                 it.getDoubleExtra(AppConstants.SERVICE_LAT_KEY, 0.0),
                 it.getDoubleExtra(AppConstants.SERVICE_LNG_KEY, 0.0)
             )
         )
     }
     imageString = it.getStringExtra(AppConstants.PROVIDER_IMAGE_KEY).toString()
     searchService?.nearbySearch(request, searchResultListener)
 }

implementation 'com.huawei.agconnect:agconnect=database:1.2.3.301'

compileOptions {
sourceCompatibility = 1.8
targetCompatibility = 1.8
}

/**
* To initialize AGConnectCloudDB
*/
public static void initAGConnectCloudDB(Context context) { 
    AGConnectCloudDB.initialize(context); 
}

mCloudDB = AGConnectCloudDB.getInstance(); 
mCloudDB.createObjectType(ObjectTypeInfoHelper.getObjectTypeInfo());

/**
* This method is used to open Cloud DB zone.
*/
public void openCloudDBZoneV2() {
     mConfig = new CloudDBZoneConfig(AppConstants.URBAN_HOME_SERVICES,
 CloudDBZoneConfig.CloudDBZoneSyncProperty.CLOUDDBZONE_CLOUD_CACHE, CloudDBZoneConfig.CloudDBZoneAccessProperty.CLOUDDBZONE_PUBLIC);
     mConfig.setPersistenceEnabled(true);
     Task<CloudDBZone> openDBZoneTask = mCloudDB.openCloudDBZone2(mConfig, true);
     openDBZoneTask.addOnSuccessListener(cloudDBZone -> {
         Log.w(TAG, "open clouddbzone success");
         mCloudDBZone = cloudDBZone;
         // Add subscription after opening cloudDBZone success
         mUiCallBack.onInitCloud();
         addSubscription();
     }).addOnFailureListener(e ->
             Log.w(TAG, "open clouddbzone failed for"));
 }

/**
* This method is used to insert data into Cloud DB.
*/
public void insertDbZoneInfo(T objectInfo) {
     if (mCloudDBZone == null) {
         Log.w(TAG, "CloudDBZone is null, try re-open it");
         return;
     }
     Task<Integer> upsertTask = mCloudDBZone.executeUpsert(objectInfo);
     upsertTask.addOnSuccessListener(cloudDBZoneResult -> {
         mUiCallBack.onInsertSuccess(cloudDBZoneResult);
     }).addOnFailureListener(e -> {
         mUiCallBack.updateUiOnError("Insert table info failed");
     });
 }

/**
* This listener is used to get snapshot
*/
private OnSnapshotListener<T> mSnapshotListener = (cloudDBZoneSnapshot, e) -> {
     if (e != null) {
         Log.w(TAG, "onSnapshot" );
         return;
     }
     CloudDBZoneObjectList<T> snapshotObjects = cloudDBZoneSnapshot.getSnapshotObjects();
     List<T> dbZoneList = new ArrayList<>();
     try {
         if (snapshotObjects != null) {
             while (snapshotObjects.hasNext()) {
                 T objectInfo = snapshotObjects.next();
                 dbZoneList.add(objectInfo);
             }
         }
         mUiCallBack.onSubscribe(dbZoneList);
     } catch (AGConnectCloudDBException snapshotException) {
         Log.w(TAG, "onSnapshot:(getObject)");
     } finally {
         cloudDBZoneSnapshot.release();
     }
 };

/**
* This method is used to query all data from Cloud DB.
*/
public void queryAllData(CloudDBZoneQuery<T> query) {
     if (mCloudDBZone == null) {
         Log.w(TAG, "CloudDBZone is null, try re-open it");
         return;
     }
     Task<CloudDBZoneSnapshot<T>> queryTask = mCloudDBZone.executeQuery(query,
             CloudDBZoneQuery.CloudDBZoneQueryPolicy.POLICY_QUERY_FROM_CLOUD_ONLY);
     queryTask.addOnSuccessListener(new OnSuccessListener<CloudDBZoneSnapshot<T>>() {
         @Override
         public void onSuccess(CloudDBZoneSnapshot<T> snapshot) {
             processQueryResult(snapshot);
         }
     }).addOnFailureListener(new OnFailureListener() {
         @Override
         public void onFailure(Exception e) {
             mUiCallBack.updateUiOnError("Query failed");
         }
     });
 }

/**
* This method is used delete table data on Cloud DB.
*/
 public void deleteTableData(List<T> tableObject) {
         if (mCloudDBZone == null) {
             Log.w(TAG, "CloudDBZone is null, try re-open it");
             return;
         }
         Task<Integer> deleteTask = mCloudDBZone.executeDelete(tableObject);
         if (deleteTask.getException() != null) {
             mUiCallBack.updateUiOnError("Delete service type table failed");
             return;
         }
         mUiCallBack.onDelete(tableObject);
     }
 }

/**
* This method is used to edit Service details.
*/
override fun editService(listObject: ServiceType) {
     val intent = Intent(this, AddServiceActivity::class.java)
     intent.apply {
         putExtra(AppConstants.CATEGORY_NAME, listObject.cat_name)
         putExtra(AppConstants.PROVIDER_PH_NUM, listObject.phone_number.toString())
         putExtra(AppConstants.PROVIDER_MAIL_ID, listObject.email_id)
         putExtra(AppConstants.PROVIDER_COUNTRY, listObject.country)
         putExtra(AppConstants.PROVIDER_ID, listObject.id)
         putExtra(AppConstants.PROVIDER_NAME, listObject.service_provider_name)
         putExtra(AppConstants.PROVIDER_CITY, listObject.city)
         putExtra(AppConstants.PROVIDER_STATE, listObject.state)
     }
     startActivity(intent)
 }