import 'package:flutter_riverpod/flutter_riverpod.dart';

import '../modeller/job.dart';
import '../servisler/job_orkestratoru.dart';

/// Belirli bir segmentin aktif (calisiyor veya kuyruk) job'unu döner.
/// Stream tabanlı — job event'leri ile güncellenir.
final segmentAktifJobProvider =
    StreamProvider.family<Job?, String>((ref, segmentId) async* {
  Job? bul(List<Job> liste) {
    for (final j in liste) {
      final segId = j.params['segmentId'];
      if (segId != segmentId) continue;
      if (j.durum == JobDurum.calisiyor || j.durum == JobDurum.kuyruk) {
        return j;
      }
    }
    return null;
  }

  yield bul(await JobOrkestratoru.ornek.tumJoblar());
  await for (final _ in JobOrkestratoru.ornek.events) {
    yield bul(await JobOrkestratoru.ornek.tumJoblar());
  }
});