51 lines
1.4 KiB
Dart
51 lines
1.4 KiB
Dart
import 'dart:async';
|
|
|
|
import 'package:cloud_firestore/cloud_firestore.dart';
|
|
import 'package:fcs/domain/constants.dart';
|
|
import 'package:fcs/domain/entities/market.dart';
|
|
import 'package:fcs/helpers/firebase_helper.dart';
|
|
import 'package:fcs/pages/main/model/base_model.dart';
|
|
import 'package:logging/logging.dart';
|
|
|
|
class MarketModel extends BaseModel {
|
|
final log = Logger('MarketModel');
|
|
StreamSubscription<QuerySnapshot>? listener;
|
|
List<Market> markets = [];
|
|
|
|
MarketModel() {
|
|
_loadMarkets();
|
|
}
|
|
|
|
Future<void> _loadMarkets() async {
|
|
try {
|
|
if (listener != null) listener!.cancel();
|
|
|
|
listener = FirebaseFirestore.instance
|
|
.collection("/$config_collection/$setting_doc_id/$markets_collection")
|
|
.snapshots()
|
|
.listen((QuerySnapshot snapshot) {
|
|
markets.clear();
|
|
markets = snapshot.docs.map((documentSnapshot) {
|
|
var user = Market.fromMap(
|
|
documentSnapshot.data() as Map<String, dynamic>,
|
|
documentSnapshot.id);
|
|
return user;
|
|
}).toList();
|
|
notifyListeners();
|
|
});
|
|
} catch (e) {
|
|
log.warning("Error!! $e");
|
|
}
|
|
}
|
|
|
|
Future<void> addMarket(String marketName) async {
|
|
await request("/markets", "POST",
|
|
payload: {"name": marketName}, token: await getToken());
|
|
}
|
|
|
|
Future<void> deleteMarket(String id) async {
|
|
await request("/markets", "DELETE",
|
|
payload: {"id": id}, token: await getToken());
|
|
}
|
|
}
|