Skip to content

better error handeling if hc request comes when app is in background #17

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
armanso wants to merge 1 commit into
base: health-10.2.0
Choose a base branch
from
Open

better error handeling if hc request comes when app is in background #17

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
354 changes: 179 additions & 175 deletions packages/health/android/src/main/kotlin/cachet/plugins/health/HealthPlugin.kt
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2969,210 +2969,214 @@ class HealthPlugin(private var channel: MethodChannel? = null) :
val healthConnectData = mutableListOf<Map<String, Any?>>()

scope.launch {
MapToHCType[dataType]?.let { classType ->
val records = mutableListOf<Record>()

val granted = healthConnectClient.permissionController.getGrantedPermissions()
if (!granted.contains(HealthPermission.getReadPermission(classType))) {
Log.d("Health Plugin", "No Permission granted for $dataType")
return@let
}

// Set up the initial request to read health records with specified
// parameters
var request =
ReadRecordsRequest(
recordType = classType,
// Define the maximum amount of data
// that HealthConnect can return
// in a single request
timeRangeFilter =
TimeRangeFilter.between(
startTime,
endTime
),
)

var response = healthConnectClient.readRecords(request)
var pageToken = response.pageToken
try {
MapToHCType[dataType]?.let { classType ->
val records = mutableListOf<Record>()

// Add the records from the initial response to the records list
records.addAll(response.records)
val granted = healthConnectClient.permissionController.getGrantedPermissions()
if (!granted.contains(HealthPermission.getReadPermission(classType))) {
Log.d("Health Plugin", "No Permission granted for $dataType")
return@let
}

// Continue making requests and fetching records while there is a
// page token
while (!pageToken.isNullOrEmpty()) {
request =
// Set up the initial request to read health records with specified
// parameters
var request =
ReadRecordsRequest(
recordType = classType,
// Define the maximum amount of data
// that HealthConnect can return
// in a single request
timeRangeFilter =
TimeRangeFilter.between(
startTime,
endTime
),
pageToken = pageToken
TimeRangeFilter.between(
startTime,
endTime
),
)
response = healthConnectClient.readRecords(request)

pageToken = response.pageToken
var response = healthConnectClient.readRecords(request)
var pageToken = response.pageToken

// Add the records from the initial response to the records list
records.addAll(response.records)
}

// Workout needs distance and total calories burned too
if (dataType == WORKOUT) {
for (rec in records) {
val record = rec as ExerciseSessionRecord
val distanceRequest =
healthConnectClient.readRecords(
ReadRecordsRequest(
recordType =
DistanceRecord::class,
timeRangeFilter =
// Continue making requests and fetching records while there is a
// page token
while (!pageToken.isNullOrEmpty()) {
request =
ReadRecordsRequest(
recordType = classType,
timeRangeFilter =
TimeRangeFilter.between(
record.startTime,
record.endTime,
startTime,
endTime
),
),
pageToken = pageToken
)
var totalDistance = 0.0
for (distanceRec in distanceRequest.records) {
totalDistance +=
distanceRec.distance
.inMeters
}
response = healthConnectClient.readRecords(request)

val energyBurnedRequest =
healthConnectClient.readRecords(
ReadRecordsRequest(
recordType =
TotalCaloriesBurnedRecord::class,
timeRangeFilter =
TimeRangeFilter.between(
record.startTime,
record.endTime,
pageToken = response.pageToken
records.addAll(response.records)
}

// Workout needs distance and total calories burned too
if (dataType == WORKOUT) {
for (rec in records) {
val record = rec as ExerciseSessionRecord
val distanceRequest =
healthConnectClient.readRecords(
ReadRecordsRequest(
recordType =
DistanceRecord::class,
timeRangeFilter =
TimeRangeFilter.between(
record.startTime,
record.endTime,
),
),
),
)
var totalEnergyBurned = 0.0
for (energyBurnedRec in
energyBurnedRequest.records) {
totalEnergyBurned +=
energyBurnedRec.energy
.inKilocalories
}
)
var totalDistance = 0.0
for (distanceRec in distanceRequest.records) {
totalDistance +=
distanceRec.distance
.inMeters
}

val stepRequest =
healthConnectClient.readRecords(
ReadRecordsRequest(
recordType =
StepsRecord::class,
timeRangeFilter =
TimeRangeFilter.between(
record.startTime,
record.endTime
val energyBurnedRequest =
healthConnectClient.readRecords(
ReadRecordsRequest(
recordType =
TotalCaloriesBurnedRecord::class,
timeRangeFilter =
TimeRangeFilter.between(
record.startTime,
record.endTime,
),
),
)
var totalEnergyBurned = 0.0
for (energyBurnedRec in
energyBurnedRequest.records) {
totalEnergyBurned +=
energyBurnedRec.energy
.inKilocalories
}

val stepRequest =
healthConnectClient.readRecords(
ReadRecordsRequest(
recordType =
StepsRecord::class,
timeRangeFilter =
TimeRangeFilter.between(
record.startTime,
record.endTime
),
),
)
var totalSteps = 0.0
for (stepRec in stepRequest.records) {
totalSteps += stepRec.count
}

// val metadata = (rec as Record).metadata
// Add final datapoint
healthConnectData.add(
// mapOf(
mapOf<String, Any?>(
"workoutActivityType" to
(workoutTypeMapHealthConnect
.filterValues {
it ==
record.exerciseType
}
.keys
.firstOrNull()
?: "OTHER"),
"totalDistance" to
if (totalDistance ==
0.0
)
null
else
totalDistance,
"totalDistanceUnit" to
"METER",
"totalEnergyBurned" to
if (totalEnergyBurned ==
0.0
)
null
else
totalEnergyBurned,
"totalEnergyBurnedUnit" to
"KILOCALORIE",
"totalSteps" to
if (totalSteps ==
0.0
)
null
else
totalSteps,
"totalStepsUnit" to
"COUNT",
"unit" to "MINUTES",
"date_from" to
rec.startTime
.toEpochMilli(),
"date_to" to
rec.endTime.toEpochMilli(),
"source_id" to "",
"source_name" to
record.metadata
.dataOrigin
.packageName,
),
)
var totalSteps = 0.0
for (stepRec in stepRequest.records) {
totalSteps += stepRec.count
}

// val metadata = (rec as Record).metadata
// Add final datapoint
healthConnectData.add(
// mapOf(
mapOf<String, Any?>(
"workoutActivityType" to
(workoutTypeMapHealthConnect
.filterValues {
it ==
record.exerciseType
}
.keys
.firstOrNull()
?: "OTHER"),
"totalDistance" to
if (totalDistance ==
0.0
)
null
else
totalDistance,
"totalDistanceUnit" to
"METER",
"totalEnergyBurned" to
if (totalEnergyBurned ==
0.0
// Filter sleep stages for requested stage
} else if (classType == SleepSessionRecord::class) {
for (rec in response.records) {
if (rec is SleepSessionRecord) {
if (dataType == SLEEP_SESSION) {
healthConnectData.addAll(
convertRecord(
rec,
dataType
)
null
else
totalEnergyBurned,
"totalEnergyBurnedUnit" to
"KILOCALORIE",
"totalSteps" to
if (totalSteps ==
0.0
)
null
else
totalSteps,
"totalStepsUnit" to
"COUNT",
"unit" to "MINUTES",
"date_from" to
rec.startTime
.toEpochMilli(),
"date_to" to
rec.endTime.toEpochMilli(),
"source_id" to "",
"source_name" to
record.metadata
.dataOrigin
.packageName,
),
)
}
// Filter sleep stages for requested stage
} else if (classType == SleepSessionRecord::class) {
for (rec in response.records) {
if (rec is SleepSessionRecord) {
if (dataType == SLEEP_SESSION) {
healthConnectData.addAll(
convertRecord(
rec,
dataType
)
)
} else {
for (recStage in rec.stages) {
if (dataType ==
MapSleepStageToType[
recStage.stage]
) {
healthConnectData
.addAll(
convertRecordStage(
recStage,
dataType,
rec.metadata.dataOrigin
.packageName
} else {
for (recStage in rec.stages) {
if (dataType ==
MapSleepStageToType[
recStage.stage]
) {
healthConnectData
.addAll(
convertRecordStage(
recStage,
dataType,
rec.metadata.dataOrigin
.packageName
)
)
)
}
}
}
}
}
}
} else {
for (rec in records) {
healthConnectData.addAll(
convertRecord(rec, dataType)
)
} else {
for (rec in records) {
healthConnectData.addAll(
convertRecord(rec, dataType)
)
}
}
}
}

} catch (e: Exception) {
Log.e("FLUTTER_HEALTH", e.toString())
}
Handler(context!!.mainLooper).run { result.success(healthConnectData) }
}
}
Expand Down
Loading