47 lines
2.0 KiB
Dart
47 lines
2.0 KiB
Dart
|
import 'dart:typed_data';
|
||
|
|
|
||
|
|
import 'package:get/get.dart';
|
||
|
|
import 'package:http/http.dart' as http;
|
||
|
|
import 'package:supabase_flutter/supabase_flutter.dart';
|
||
|
|
|
||
|
|
import '../models/measured_record.dart';
|
||
|
|
|
||
|
|
/// Mérési felvételek (lövések) élő lekérdezése a PC-szoftver által
|
||
|
|
/// feltöltött táblából. SZÁNDÉKOSAN nincs helyi tükör/gyorsítótár — ez
|
||
|
|
/// folyamatosan érkező, élő adat, mindig a jelenlegi állapotot mutatja.
|
||
|
|
class MeasuredDataService extends GetxService {
|
||
|
|
static MeasuredDataService get to => Get.find();
|
||
|
|
|
||
|
|
SupabaseClient get _client => Supabase.instance.client;
|
||
|
|
|
||
|
|
/// TODO: erősítsd meg a valós bucket-nevet, ha eltér ettől.
|
||
|
|
static const _bucket = 'terepi_seged-measure-images';
|
||
|
|
|
||
|
|
/// Élő, folyamatosan frissülő stream — a Supabase Realtime-on keresztül,
|
||
|
|
/// pontosan úgy, ahogy korábban a Firestore .snapshots() működött. Új
|
||
|
|
/// felvétel a PC-szoftverből AZONNAL megjelenik, frissítés nélkül.
|
||
|
|
Stream<List<MeasuredRecord>> watchRecords(String projectId) {
|
||
|
|
return _client
|
||
|
|
.from('terepi_seged_measure_records')
|
||
|
|
.stream(primaryKey: ['id'])
|
||
|
|
.eq('project_id', projectId)
|
||
|
|
.order('measured_at', ascending: false)
|
||
|
|
.map((rows) => rows.map((r) => MeasuredRecord.fromMap(r)).toList());
|
||
|
|
}
|
||
|
|
|
||
|
|
/// A felvételhez tartozó kép betöltése — elsőbbséget adva az image_url-nek
|
||
|
|
/// (ha a PC-szoftver már kész, letölthető URL-t is küld), egyébként a
|
||
|
|
/// Storage-ból, image_path alapján.
|
||
|
|
Future<Uint8List?> loadImage(MeasuredRecord record) async {
|
||
|
|
if (record.imageUrl != null && record.imageUrl!.isNotEmpty) {
|
||
|
|
final resp = await http.get(Uri.parse(record.imageUrl!));
|
||
|
|
if (resp.statusCode == 200) return resp.bodyBytes;
|
||
|
|
throw Exception('Kép letöltése sikertelen (${resp.statusCode})');
|
||
|
|
}
|
||
|
|
if (record.imagePath != null && record.imagePath!.isNotEmpty) {
|
||
|
|
return _client.storage.from(_bucket).download(record.imagePath!);
|
||
|
|
}
|
||
|
|
return null;
|
||
|
|
}
|
||
|
|
}
|