[Flutter] 만보기 2 데이터 서버 전송

pedometer | Flutter package

A Pedometer and Step Detection package for Android and iOS. Step count is streamed as the platform updates it.

https://pub.dev/packages/pedometer

1. 만보기 라이브러리 viewmodel 만들기

import 'dart:async';
import 'package:flutter_riverpod/flutter_riverpod.dart';
import 'package:pedometer/pedometer.dart';
import '../../../../_core/constants/http.dart';
import '../../activity/viewmodel/walking_detail.viewmodel.dart';

class StepCountState {
  final int currentSteps;
  final String calories;
  final String totalSteps;

  StepCountState({required this.currentSteps, required this.calories, required this.totalSteps});
}

class StepCountViewModel extends StateNotifier<StepCountState> {
  late StreamSubscription<StepCount> _stepCountStream;
  Timer? _timer;
  Timer? _midnightTimer;
  final read;

  StepCountViewModel(this.read)
      : super(StepCountState(currentSteps: 0, calories: '0 kcal', totalSteps: '0')) {
    initialize();
  }

  void initialize() {
    _loadSteps();
    _initializePedometer();
    _startTimer();
    _resetStepsAtMidnight(); // 자정에 리셋 타이머 시작
  }

  void _initializePedometer() {
    _stepCountStream = Pedometer.stepCountStream.listen(
      _onStepCount,
      onError: _onStepCountError,
    );
  }

  void _onStepCount(StepCount event) {
    int steps = event.steps;
    _updateState(steps);
    _saveSteps(steps);
  }

  void _onStepCountError(dynamic error) {
    print("Step Count Error: $error");
  }

  void _saveSteps(int steps) async {
    await secureStorage.write(key: 'current_steps', value: steps.toString());
  }

  Future<void> _loadSteps() async {
    String? storedSteps = await secureStorage.read(key: 'current_steps');
    int steps = int.tryParse(storedSteps ?? '0') ?? 0;
    _updateState(steps);
  }

  void _startTimer() {
    _timer = Timer.periodic(Duration(seconds: 10), (Timer timer) {
      _sendCurrentStepsToServer();
    });
  }

  void _sendCurrentStepsToServer() async {
    String? stepsString = await secureStorage.read(key: 'current_steps');
    int steps = int.tryParse(stepsString ?? '0') ?? 0;
    read(WalkingDetailProvider.notifier).sendStepsToServer(steps);
  }

  Duration _timeUntilMidnight() {
    final now = DateTime.now();
    final tomorrow = DateTime(now.year, now.month, now.day + 1);
    return tomorrow.difference(now);
  }

// 자정에 데이터 초기화. 
  void _resetStepsAtMidnight() {
    _midnightTimer = Timer(_timeUntilMidnight(), () async {
      state = StepCountState(currentSteps: 0, calories: '0 kcal', totalSteps: '0');
      await secureStorage.delete(key: 'current_steps');
      _resetStepsAtMidnight();
    });
  }

  void _updateState(int steps) {
    state = StepCountState(
      currentSteps: steps,
      calories: (steps * 0.04).toStringAsFixed(0) + ' kcal', // 칼로리 계산 임의로 함
      totalSteps: steps.toString(),
    );
  }

  @override
  void dispose() {
    _stepCountStream.cancel();
    _timer?.cancel();
    _midnightTimer?.cancel();
    super.dispose();
  }
}

final StepCountProvider = StateNotifierProvider<StepCountViewModel, StepCountState>((ref) {
  return StepCountViewModel(ref.read);
});

  Future<void> sendStepsToServer(int steps) async {
     await ActivityRepository().fetchSendWalking(steps);
  }

  Future<ResponseDTO> fetchSendWalking(int steps) async {
    StepDTO stepDTO = StepDTO(steps);
    final response =
        await dio.put("/api/activities/walking-update", data: stepDTO);
    ResponseDTO responseDTO = ResponseDTO.fromJson(response.data);


    return responseDTO;
  }

class StepDTO {
  int walking;

  StepDTO(this.walking);

  Map<String, dynamic> toJson() {
    return {"walking": this.walking};
  }
}