Rork Max のネイティブアプリに歩数と睡眠を読み込む — HealthKit 連携で「数字に頼らない」癒し系アプリを作る

import HealthKit
 
final class HealthStore {
    let store = HKHealthStore()
 
    // 読み取りたい型と書き込みたい型を分けて定義する
    private let readTypes: Set<HKObjectType> = [
        HKQuantityType(.stepCount),
        HKQuantityType(.heartRate),
        HKCategoryType(.sleepAnalysis)
    ]
    private let writeTypes: Set<HKSampleType> = [
        HKCategoryType(.mindfulSession)
    ]
 
    func requestAuthorization() async throws {
        guard HKHealthStore.isHealthDataAvailable() else {
            throw HealthError.unavailable   // iPad など非対応端末で必ず確認する
        }
        try await store.requestAuthorization(toShare: writeTypes, read: readTypes)
    }
}
 
enum HealthError: Error { case unavailable, denied, noData }

extension HealthStore {
    func todayStepCount() async throws -> Int {
        let type = HKQuantityType(.stepCount)
        let start = Calendar.current.startOfDay(for: Date())
        let predicate = HKQuery.predicateForSamples(withStart: start, end: Date())
 
        return try await withCheckedThrowingContinuation { continuation in
            let query = HKStatisticsQuery(
                quantityType: type,
                quantitySamplePredicate: predicate,
                options: .cumulativeSum
            ) { _, stats, error in
                if let error { continuation.resume(throwing: error); return }
                let steps = stats?.sumQuantity()?.doubleValue(for: .count()) ?? 0
                continuation.resume(returning: Int(steps))
            }
            self.store.execute(query)
        }
    }
}

extension HealthStore {
    func startStepObserver(onUpdate: @escaping () -> Void) {
        let type = HKQuantityType(.stepCount)
 
        let observer = HKObserverQuery(sampleType: type, predicate: nil) { _, completion, error in
            if error == nil { onUpdate() }
            completion()   // ← これを呼ばないと iOS が更新を止めてしまう
        }
        store.execute(observer)
 
        store.enableBackgroundDelivery(for: type, frequency: .hourly) { success, error in
            if let error { print("background delivery failed: \(error)") }
        }
    }
}

extension HealthStore {
    func saveMindfulSession(start: Date, end: Date) async throws {
        let type = HKCategoryType(.mindfulSession)
        let sample = HKCategorySample(
            type: type,
            value: HKCategoryValue.notApplicable.rawValue,
            start: start,
            end: end
        )
        try await store.save(sample)
    }
}