Compare commits
2 Commits
3022d8de9f
...
04811015b6
| Author | SHA1 | Date | |
|---|---|---|---|
|
04811015b6 | ||
|
|
f104390141 |
87
lib/core/database/database_handler.dart
Normal file
87
lib/core/database/database_handler.dart
Normal file
@ -0,0 +1,87 @@
|
||||
import 'dart:async';
|
||||
import 'package:sqflite/sqflite.dart';
|
||||
import 'package:path/path.dart';
|
||||
|
||||
class DatabaseHelper {
|
||||
static DatabaseHelper? _instance;
|
||||
static Database? _database;
|
||||
|
||||
DatabaseHelper._internal();
|
||||
|
||||
static DatabaseHelper get instance {
|
||||
_instance ??= DatabaseHelper._internal();
|
||||
return _instance!;
|
||||
}
|
||||
|
||||
Future<Database> get database async {
|
||||
_database ??= await _initDatabase();
|
||||
return _database!;
|
||||
}
|
||||
|
||||
Future<Database> _initDatabase() async {
|
||||
String path = join(await getDatabasesPath(), 'pos_database.db');
|
||||
|
||||
return await openDatabase(
|
||||
path,
|
||||
version: 1,
|
||||
onCreate: _onCreate,
|
||||
onUpgrade: _onUpgrade,
|
||||
);
|
||||
}
|
||||
|
||||
Future<void> _onCreate(Database db, int version) async {
|
||||
// Products table
|
||||
await db.execute('''
|
||||
CREATE TABLE products (
|
||||
id TEXT PRIMARY KEY,
|
||||
organization_id TEXT,
|
||||
category_id TEXT,
|
||||
sku TEXT,
|
||||
name TEXT,
|
||||
description TEXT,
|
||||
price INTEGER,
|
||||
cost INTEGER,
|
||||
business_type TEXT,
|
||||
image_url TEXT,
|
||||
printer_type TEXT,
|
||||
metadata TEXT,
|
||||
is_active INTEGER,
|
||||
created_at TEXT,
|
||||
updated_at TEXT
|
||||
)
|
||||
''');
|
||||
|
||||
// Product Variants table
|
||||
await db.execute('''
|
||||
CREATE TABLE product_variants (
|
||||
id TEXT PRIMARY KEY,
|
||||
product_id TEXT,
|
||||
name TEXT,
|
||||
price_modifier INTEGER,
|
||||
cost INTEGER,
|
||||
metadata TEXT,
|
||||
created_at TEXT,
|
||||
updated_at TEXT,
|
||||
FOREIGN KEY (product_id) REFERENCES products (id) ON DELETE CASCADE
|
||||
)
|
||||
''');
|
||||
|
||||
// Create indexes for better performance
|
||||
await db.execute(
|
||||
'CREATE INDEX idx_products_category_id ON products(category_id)');
|
||||
await db.execute('CREATE INDEX idx_products_name ON products(name)');
|
||||
await db.execute('CREATE INDEX idx_products_sku ON products(sku)');
|
||||
await db.execute(
|
||||
'CREATE INDEX idx_products_description ON products(description)');
|
||||
}
|
||||
|
||||
Future<void> _onUpgrade(Database db, int oldVersion, int newVersion) async {
|
||||
// Handle database upgrades here
|
||||
}
|
||||
|
||||
Future<void> close() async {
|
||||
final db = await database;
|
||||
await db.close();
|
||||
_database = null;
|
||||
}
|
||||
}
|
||||
29
lib/core/database/migration_handler.dart
Normal file
29
lib/core/database/migration_handler.dart
Normal file
@ -0,0 +1,29 @@
|
||||
import 'package:sqflite/sqflite.dart';
|
||||
|
||||
class DatabaseMigrationHandler {
|
||||
static Future<void> migrate(
|
||||
Database db, int oldVersion, int newVersion) async {
|
||||
if (oldVersion < 2) {
|
||||
// Add indexes for better performance
|
||||
await db.execute(
|
||||
'CREATE INDEX IF NOT EXISTS idx_products_name_search ON products(name)');
|
||||
await db.execute(
|
||||
'CREATE INDEX IF NOT EXISTS idx_products_sku_search ON products(sku)');
|
||||
}
|
||||
|
||||
if (oldVersion < 3) {
|
||||
// Add full text search support
|
||||
await db.execute(
|
||||
'CREATE VIRTUAL TABLE products_fts USING fts5(name, sku, description, content=products, content_rowid=rowid)');
|
||||
await db.execute(
|
||||
'INSERT INTO products_fts SELECT name, sku, description FROM products');
|
||||
}
|
||||
|
||||
if (oldVersion < 4) {
|
||||
// Add sync tracking
|
||||
await db.execute('ALTER TABLE products ADD COLUMN last_sync_at TEXT');
|
||||
await db.execute(
|
||||
'ALTER TABLE products ADD COLUMN sync_version INTEGER DEFAULT 1');
|
||||
}
|
||||
}
|
||||
}
|
||||
53
lib/core/error/database_error_handler.dart
Normal file
53
lib/core/error/database_error_handler.dart
Normal file
@ -0,0 +1,53 @@
|
||||
import 'dart:developer';
|
||||
import 'dart:io';
|
||||
|
||||
import 'package:sqflite/sqflite.dart';
|
||||
|
||||
class DatabaseErrorHandler {
|
||||
static Future<T> executeWithRetry<T>(
|
||||
Future<T> Function() operation, {
|
||||
int maxRetries = 3,
|
||||
Duration delay = const Duration(milliseconds: 500),
|
||||
}) async {
|
||||
int attempts = 0;
|
||||
|
||||
while (attempts < maxRetries) {
|
||||
try {
|
||||
return await operation();
|
||||
} catch (e) {
|
||||
attempts++;
|
||||
|
||||
if (attempts >= maxRetries) {
|
||||
rethrow;
|
||||
}
|
||||
|
||||
log('Database operation failed (attempt $attempts/$maxRetries): $e');
|
||||
await Future.delayed(delay * attempts);
|
||||
}
|
||||
}
|
||||
|
||||
throw Exception('Max retries exceeded');
|
||||
}
|
||||
|
||||
static bool isDatabaseCorrupted(dynamic error) {
|
||||
final errorString = error.toString().toLowerCase();
|
||||
return errorString.contains('corrupt') ||
|
||||
errorString.contains('malformed') ||
|
||||
errorString.contains('no such table');
|
||||
}
|
||||
|
||||
static Future<void> handleDatabaseCorruption() async {
|
||||
try {
|
||||
// Delete corrupted database
|
||||
final dbPath = await getDatabasesPath();
|
||||
final file = File('$dbPath/pos_database.db');
|
||||
if (await file.exists()) {
|
||||
await file.delete();
|
||||
}
|
||||
|
||||
log('Corrupted database deleted, will be recreated');
|
||||
} catch (e) {
|
||||
log('Error handling database corruption: $e');
|
||||
}
|
||||
}
|
||||
}
|
||||
64
lib/core/performance/database_monitor.dart
Normal file
64
lib/core/performance/database_monitor.dart
Normal file
@ -0,0 +1,64 @@
|
||||
import 'dart:developer';
|
||||
|
||||
class DatabasePerformanceMonitor {
|
||||
static final Map<String, List<int>> _queryTimes = {};
|
||||
|
||||
static Future<T> monitorQuery<T>(
|
||||
String queryName,
|
||||
Future<T> Function() query,
|
||||
) async {
|
||||
final stopwatch = Stopwatch()..start();
|
||||
|
||||
try {
|
||||
final result = await query();
|
||||
stopwatch.stop();
|
||||
|
||||
_recordQueryTime(queryName, stopwatch.elapsedMilliseconds);
|
||||
|
||||
return result;
|
||||
} catch (e) {
|
||||
stopwatch.stop();
|
||||
log('Query "$queryName" failed after ${stopwatch.elapsedMilliseconds}ms: $e');
|
||||
rethrow;
|
||||
}
|
||||
}
|
||||
|
||||
static void _recordQueryTime(String queryName, int milliseconds) {
|
||||
if (!_queryTimes.containsKey(queryName)) {
|
||||
_queryTimes[queryName] = [];
|
||||
}
|
||||
|
||||
_queryTimes[queryName]!.add(milliseconds);
|
||||
|
||||
// Keep only last 100 entries
|
||||
if (_queryTimes[queryName]!.length > 100) {
|
||||
_queryTimes[queryName]!.removeAt(0);
|
||||
}
|
||||
|
||||
// Log slow queries
|
||||
if (milliseconds > 1000) {
|
||||
log('Slow query detected: "$queryName" took ${milliseconds}ms');
|
||||
}
|
||||
}
|
||||
|
||||
static Map<String, dynamic> getPerformanceStats() {
|
||||
final stats = <String, dynamic>{};
|
||||
|
||||
_queryTimes.forEach((queryName, times) {
|
||||
if (times.isNotEmpty) {
|
||||
final avgTime = times.reduce((a, b) => a + b) / times.length;
|
||||
final maxTime = times.reduce((a, b) => a > b ? a : b);
|
||||
final minTime = times.reduce((a, b) => a < b ? a : b);
|
||||
|
||||
stats[queryName] = {
|
||||
'average_ms': avgTime.round(),
|
||||
'max_ms': maxTime,
|
||||
'min_ms': minTime,
|
||||
'total_queries': times.length,
|
||||
};
|
||||
}
|
||||
});
|
||||
|
||||
return stats;
|
||||
}
|
||||
}
|
||||
496
lib/data/datasources/product/product_local_datasource.dart
Normal file
496
lib/data/datasources/product/product_local_datasource.dart
Normal file
@ -0,0 +1,496 @@
|
||||
import 'dart:convert';
|
||||
import 'dart:developer';
|
||||
import 'dart:io';
|
||||
import 'package:enaklo_pos/core/database/database_handler.dart';
|
||||
import 'package:enaklo_pos/data/models/response/product_response_model.dart';
|
||||
import 'package:sqflite/sqflite.dart';
|
||||
import 'package:path/path.dart' as p;
|
||||
|
||||
class ProductLocalDatasource {
|
||||
static ProductLocalDatasource? _instance;
|
||||
|
||||
ProductLocalDatasource._internal();
|
||||
|
||||
static ProductLocalDatasource get instance {
|
||||
_instance ??= ProductLocalDatasource._internal();
|
||||
return _instance!;
|
||||
}
|
||||
|
||||
Future<Database> get _db async => await DatabaseHelper.instance.database;
|
||||
|
||||
// ========================================
|
||||
// CACHING SYSTEM
|
||||
// ========================================
|
||||
final Map<String, List<Product>> _queryCache = {};
|
||||
final Duration _cacheExpiry = Duration(minutes: 5);
|
||||
final Map<String, DateTime> _cacheTimestamps = {};
|
||||
|
||||
// ========================================
|
||||
// ENHANCED BATCH SAVE
|
||||
// ========================================
|
||||
Future<void> saveProductsBatch(List<Product> products,
|
||||
{bool clearFirst = false}) async {
|
||||
final db = await _db;
|
||||
|
||||
try {
|
||||
await db.transaction((txn) async {
|
||||
if (clearFirst) {
|
||||
log('🗑️ Clearing existing products...');
|
||||
await txn.delete('product_variants');
|
||||
await txn.delete('products');
|
||||
}
|
||||
|
||||
log('đź’ľ Batch saving ${products.length} products...');
|
||||
|
||||
// âś… BATCH INSERT PRODUCTS - Much faster than individual inserts
|
||||
final batch = txn.batch();
|
||||
for (final product in products) {
|
||||
batch.insert(
|
||||
'products',
|
||||
_productToMap(product),
|
||||
conflictAlgorithm: ConflictAlgorithm.replace,
|
||||
);
|
||||
}
|
||||
await batch.commit(noResult: true);
|
||||
|
||||
// âś… BATCH INSERT VARIANTS
|
||||
final variantBatch = txn.batch();
|
||||
for (final product in products) {
|
||||
if (product.variants?.isNotEmpty == true) {
|
||||
// Delete existing variants in batch
|
||||
variantBatch.delete(
|
||||
'product_variants',
|
||||
where: 'product_id = ?',
|
||||
whereArgs: [product.id],
|
||||
);
|
||||
|
||||
// Insert new variants
|
||||
for (final variant in product.variants!) {
|
||||
variantBatch.insert(
|
||||
'product_variants',
|
||||
_variantToMap(variant),
|
||||
conflictAlgorithm: ConflictAlgorithm.replace,
|
||||
);
|
||||
}
|
||||
}
|
||||
}
|
||||
await variantBatch.commit(noResult: true);
|
||||
});
|
||||
|
||||
// Clear cache after update
|
||||
clearCache();
|
||||
log('âś… Successfully batch saved ${products.length} products');
|
||||
} catch (e) {
|
||||
log('❌ Error batch saving products: $e');
|
||||
rethrow;
|
||||
}
|
||||
}
|
||||
|
||||
// ========================================
|
||||
// CACHED QUERY - HIGH PERFORMANCE
|
||||
// ========================================
|
||||
Future<List<Product>> getCachedProducts({
|
||||
int page = 1,
|
||||
int limit = 10,
|
||||
String? categoryId,
|
||||
String? search,
|
||||
}) async {
|
||||
final cacheKey = _generateCacheKey(page, limit, categoryId, search);
|
||||
final now = DateTime.now();
|
||||
|
||||
// âś… CHECK CACHE FIRST
|
||||
if (_queryCache.containsKey(cacheKey) &&
|
||||
_cacheTimestamps.containsKey(cacheKey)) {
|
||||
final cacheTime = _cacheTimestamps[cacheKey]!;
|
||||
if (now.difference(cacheTime) < _cacheExpiry) {
|
||||
log('🚀 Cache HIT: $cacheKey (${_queryCache[cacheKey]!.length} products)');
|
||||
return _queryCache[cacheKey]!; // Return from cache - SUPER FAST
|
||||
}
|
||||
}
|
||||
|
||||
log('đź“€ Cache MISS: $cacheKey, querying database...');
|
||||
|
||||
// Cache miss, query database
|
||||
final products = await getProducts(
|
||||
page: page,
|
||||
limit: limit,
|
||||
categoryId: categoryId,
|
||||
search: search,
|
||||
);
|
||||
|
||||
// âś… STORE IN CACHE for next time
|
||||
_queryCache[cacheKey] = products;
|
||||
_cacheTimestamps[cacheKey] = now;
|
||||
|
||||
log('đź’ľ Cached ${products.length} products for key: $cacheKey');
|
||||
return products;
|
||||
}
|
||||
|
||||
// ========================================
|
||||
// REGULAR GET PRODUCTS (No Cache)
|
||||
// ========================================
|
||||
Future<List<Product>> getProducts({
|
||||
int page = 1,
|
||||
int limit = 10,
|
||||
String? categoryId,
|
||||
String? search,
|
||||
}) async {
|
||||
final db = await _db;
|
||||
|
||||
try {
|
||||
String query = 'SELECT * FROM products WHERE 1=1';
|
||||
List<dynamic> whereArgs = [];
|
||||
|
||||
if (categoryId != null && categoryId.isNotEmpty) {
|
||||
query += ' AND category_id = ?';
|
||||
whereArgs.add(categoryId);
|
||||
}
|
||||
|
||||
if (search != null && search.isNotEmpty) {
|
||||
query += ' AND (name LIKE ? OR sku LIKE ? OR description LIKE ?)';
|
||||
whereArgs.add('%$search%');
|
||||
whereArgs.add('%$search%');
|
||||
whereArgs.add('%$search%');
|
||||
}
|
||||
|
||||
query += ' ORDER BY created_at DESC';
|
||||
|
||||
if (limit > 0) {
|
||||
query += ' LIMIT ?';
|
||||
whereArgs.add(limit);
|
||||
|
||||
if (page > 1) {
|
||||
query += ' OFFSET ?';
|
||||
whereArgs.add((page - 1) * limit);
|
||||
}
|
||||
}
|
||||
|
||||
final List<Map<String, dynamic>> maps =
|
||||
await db.rawQuery(query, whereArgs);
|
||||
|
||||
List<Product> products = [];
|
||||
for (final map in maps) {
|
||||
final variants = await _getProductVariants(db, map['id']);
|
||||
final product = _mapToProduct(map, variants);
|
||||
products.add(product);
|
||||
}
|
||||
|
||||
log('đź“Š Retrieved ${products.length} products from database');
|
||||
return products;
|
||||
} catch (e) {
|
||||
log('❌ Error getting products: $e');
|
||||
return [];
|
||||
}
|
||||
}
|
||||
|
||||
// ========================================
|
||||
// OPTIMIZED SEARCH with RANKING
|
||||
// ========================================
|
||||
Future<List<Product>> searchProductsOptimized(String query) async {
|
||||
final db = await _db;
|
||||
|
||||
try {
|
||||
log('🔍 Optimized search for: "$query"');
|
||||
|
||||
// âś… Smart query with prioritization
|
||||
final List<Map<String, dynamic>> maps = await db.rawQuery('''
|
||||
SELECT * FROM products
|
||||
WHERE name LIKE ? OR sku LIKE ? OR description LIKE ?
|
||||
ORDER BY
|
||||
CASE
|
||||
WHEN name LIKE ? THEN 1 -- Highest priority: name match
|
||||
WHEN sku LIKE ? THEN 2 -- Second priority: SKU match
|
||||
ELSE 3 -- Lowest priority: description
|
||||
END,
|
||||
name ASC
|
||||
LIMIT 50
|
||||
''', [
|
||||
'%$query%', '%$query%', '%$query%',
|
||||
'$query%', '$query%' // Prioritize results that start with query
|
||||
]);
|
||||
|
||||
List<Product> products = [];
|
||||
for (final map in maps) {
|
||||
final variants = await _getProductVariants(db, map['id']);
|
||||
products.add(_mapToProduct(map, variants));
|
||||
}
|
||||
|
||||
log('🎯 Optimized search found ${products.length} results');
|
||||
return products;
|
||||
} catch (e) {
|
||||
log('❌ Error in optimized search: $e');
|
||||
return [];
|
||||
}
|
||||
}
|
||||
|
||||
// ========================================
|
||||
// DATABASE ANALYTICS & MONITORING
|
||||
// ========================================
|
||||
Future<Map<String, dynamic>> getDatabaseStats() async {
|
||||
final db = await _db;
|
||||
|
||||
try {
|
||||
final productCount = Sqflite.firstIntValue(
|
||||
await db.rawQuery('SELECT COUNT(*) FROM products')) ??
|
||||
0;
|
||||
|
||||
final variantCount = Sqflite.firstIntValue(
|
||||
await db.rawQuery('SELECT COUNT(*) FROM product_variants')) ??
|
||||
0;
|
||||
|
||||
final categoryCount = Sqflite.firstIntValue(await db.rawQuery(
|
||||
'SELECT COUNT(DISTINCT category_id) FROM products WHERE category_id IS NOT NULL')) ??
|
||||
0;
|
||||
|
||||
final dbSize = await _getDatabaseSize();
|
||||
|
||||
final stats = {
|
||||
'total_products': productCount,
|
||||
'total_variants': variantCount,
|
||||
'total_categories': categoryCount,
|
||||
'database_size_mb': dbSize,
|
||||
'cache_entries': _queryCache.length,
|
||||
'cache_size_mb': _getCacheSize(),
|
||||
};
|
||||
|
||||
log('đź“Š Database Stats: $stats');
|
||||
return stats;
|
||||
} catch (e) {
|
||||
log('❌ Error getting database stats: $e');
|
||||
return {};
|
||||
}
|
||||
}
|
||||
|
||||
Future<double> _getDatabaseSize() async {
|
||||
try {
|
||||
final dbPath = p.join(await getDatabasesPath(), 'pos_database.db');
|
||||
final file = File(dbPath);
|
||||
if (await file.exists()) {
|
||||
final size = await file.length();
|
||||
return size / (1024 * 1024); // Convert to MB
|
||||
}
|
||||
} catch (e) {
|
||||
log('Error getting database size: $e');
|
||||
}
|
||||
return 0.0;
|
||||
}
|
||||
|
||||
double _getCacheSize() {
|
||||
double totalSize = 0;
|
||||
_queryCache.forEach((key, products) {
|
||||
totalSize += products.length * 0.001; // Rough estimate in MB
|
||||
});
|
||||
return totalSize;
|
||||
}
|
||||
|
||||
// ========================================
|
||||
// CACHE MANAGEMENT
|
||||
// ========================================
|
||||
String _generateCacheKey(
|
||||
int page, int limit, String? categoryId, String? search) {
|
||||
return 'products_${page}_${limit}_${categoryId ?? 'null'}_${search ?? 'null'}';
|
||||
}
|
||||
|
||||
void clearCache() {
|
||||
final count = _queryCache.length;
|
||||
_queryCache.clear();
|
||||
_cacheTimestamps.clear();
|
||||
log('🧹 Cache cleared: $count entries removed');
|
||||
}
|
||||
|
||||
void clearExpiredCache() {
|
||||
final now = DateTime.now();
|
||||
final expiredKeys = <String>[];
|
||||
|
||||
_cacheTimestamps.forEach((key, timestamp) {
|
||||
if (now.difference(timestamp) > _cacheExpiry) {
|
||||
expiredKeys.add(key);
|
||||
}
|
||||
});
|
||||
|
||||
for (final key in expiredKeys) {
|
||||
_queryCache.remove(key);
|
||||
_cacheTimestamps.remove(key);
|
||||
}
|
||||
|
||||
if (expiredKeys.isNotEmpty) {
|
||||
log('⏰ Expired cache cleared: ${expiredKeys.length} entries');
|
||||
}
|
||||
}
|
||||
|
||||
// ========================================
|
||||
// OTHER METHODS (Same as basic but with enhanced logging)
|
||||
// ========================================
|
||||
|
||||
Future<Product?> getProductById(String id) async {
|
||||
final db = await _db;
|
||||
|
||||
try {
|
||||
final List<Map<String, dynamic>> maps = await db.query(
|
||||
'products',
|
||||
where: 'id = ?',
|
||||
whereArgs: [id],
|
||||
);
|
||||
|
||||
if (maps.isEmpty) {
|
||||
log('❌ Product not found: $id');
|
||||
return null;
|
||||
}
|
||||
|
||||
final variants = await _getProductVariants(db, id);
|
||||
final product = _mapToProduct(maps.first, variants);
|
||||
log('âś… Product found: ${product.name}');
|
||||
return product;
|
||||
} catch (e) {
|
||||
log('❌ Error getting product by ID: $e');
|
||||
return null;
|
||||
}
|
||||
}
|
||||
|
||||
Future<int> getTotalCount({String? categoryId, String? search}) async {
|
||||
final db = await _db;
|
||||
|
||||
try {
|
||||
String query = 'SELECT COUNT(*) FROM products WHERE 1=1';
|
||||
List<dynamic> whereArgs = [];
|
||||
|
||||
if (categoryId != null && categoryId.isNotEmpty) {
|
||||
query += ' AND category_id = ?';
|
||||
whereArgs.add(categoryId);
|
||||
}
|
||||
|
||||
if (search != null && search.isNotEmpty) {
|
||||
query += ' AND (name LIKE ? OR sku LIKE ? OR description LIKE ?)';
|
||||
whereArgs.add('%$search%');
|
||||
whereArgs.add('%$search%');
|
||||
whereArgs.add('%$search%');
|
||||
}
|
||||
|
||||
final result = await db.rawQuery(query, whereArgs);
|
||||
final count = Sqflite.firstIntValue(result) ?? 0;
|
||||
log('đź“Š Total count: $count (categoryId: $categoryId, search: $search)');
|
||||
return count;
|
||||
} catch (e) {
|
||||
log('❌ Error getting total count: $e');
|
||||
return 0;
|
||||
}
|
||||
}
|
||||
|
||||
Future<bool> hasProducts() async {
|
||||
final count = await getTotalCount();
|
||||
final hasData = count > 0;
|
||||
log('🔍 Has products: $hasData ($count products)');
|
||||
return hasData;
|
||||
}
|
||||
|
||||
Future<void> clearAllProducts() async {
|
||||
final db = await _db;
|
||||
|
||||
try {
|
||||
await db.transaction((txn) async {
|
||||
await txn.delete('product_variants');
|
||||
await txn.delete('products');
|
||||
});
|
||||
clearCache();
|
||||
log('🗑️ All products cleared from local DB');
|
||||
} catch (e) {
|
||||
log('❌ Error clearing products: $e');
|
||||
rethrow;
|
||||
}
|
||||
}
|
||||
|
||||
// ========================================
|
||||
// HELPER METHODS
|
||||
// ========================================
|
||||
|
||||
Future<List<ProductVariant>> _getProductVariants(
|
||||
Database db, String productId) async {
|
||||
try {
|
||||
final List<Map<String, dynamic>> maps = await db.query(
|
||||
'product_variants',
|
||||
where: 'product_id = ?',
|
||||
whereArgs: [productId],
|
||||
orderBy: 'name ASC',
|
||||
);
|
||||
|
||||
return maps.map((map) => _mapToVariant(map)).toList();
|
||||
} catch (e) {
|
||||
log('❌ Error getting variants for product $productId: $e');
|
||||
return [];
|
||||
}
|
||||
}
|
||||
|
||||
Map<String, dynamic> _productToMap(Product product) {
|
||||
return {
|
||||
'id': product.id,
|
||||
'organization_id': product.organizationId,
|
||||
'category_id': product.categoryId,
|
||||
'sku': product.sku,
|
||||
'name': product.name,
|
||||
'description': product.description,
|
||||
'price': product.price,
|
||||
'cost': product.cost,
|
||||
'business_type': product.businessType,
|
||||
'image_url': product.imageUrl,
|
||||
'printer_type': product.printerType,
|
||||
'metadata':
|
||||
product.metadata != null ? json.encode(product.metadata) : null,
|
||||
'is_active': product.isActive == true ? 1 : 0,
|
||||
'created_at': product.createdAt?.toIso8601String(),
|
||||
'updated_at': product.updatedAt?.toIso8601String(),
|
||||
};
|
||||
}
|
||||
|
||||
Map<String, dynamic> _variantToMap(ProductVariant variant) {
|
||||
return {
|
||||
'id': variant.id,
|
||||
'product_id': variant.productId,
|
||||
'name': variant.name,
|
||||
'price_modifier': variant.priceModifier,
|
||||
'cost': variant.cost,
|
||||
'metadata':
|
||||
variant.metadata != null ? json.encode(variant.metadata) : null,
|
||||
'created_at': variant.createdAt?.toIso8601String(),
|
||||
'updated_at': variant.updatedAt?.toIso8601String(),
|
||||
};
|
||||
}
|
||||
|
||||
Product _mapToProduct(
|
||||
Map<String, dynamic> map, List<ProductVariant> variants) {
|
||||
return Product(
|
||||
id: map['id'],
|
||||
organizationId: map['organization_id'],
|
||||
categoryId: map['category_id'],
|
||||
sku: map['sku'],
|
||||
name: map['name'],
|
||||
description: map['description'],
|
||||
price: map['price'],
|
||||
cost: map['cost'],
|
||||
businessType: map['business_type'],
|
||||
imageUrl: map['image_url'],
|
||||
printerType: map['printer_type'],
|
||||
metadata: map['metadata'] != null ? json.decode(map['metadata']) : null,
|
||||
isActive: map['is_active'] == 1,
|
||||
createdAt:
|
||||
map['created_at'] != null ? DateTime.parse(map['created_at']) : null,
|
||||
updatedAt:
|
||||
map['updated_at'] != null ? DateTime.parse(map['updated_at']) : null,
|
||||
variants: variants,
|
||||
);
|
||||
}
|
||||
|
||||
ProductVariant _mapToVariant(Map<String, dynamic> map) {
|
||||
return ProductVariant(
|
||||
id: map['id'],
|
||||
productId: map['product_id'],
|
||||
name: map['name'],
|
||||
priceModifier: map['price_modifier'],
|
||||
cost: map['cost'],
|
||||
metadata: map['metadata'] != null ? json.decode(map['metadata']) : null,
|
||||
createdAt:
|
||||
map['created_at'] != null ? DateTime.parse(map['created_at']) : null,
|
||||
updatedAt:
|
||||
map['updated_at'] != null ? DateTime.parse(map['updated_at']) : null,
|
||||
);
|
||||
}
|
||||
}
|
||||
145
lib/data/repositories/product/product_repository.dart
Normal file
145
lib/data/repositories/product/product_repository.dart
Normal file
@ -0,0 +1,145 @@
|
||||
import 'dart:developer';
|
||||
import 'package:dartz/dartz.dart';
|
||||
import 'package:enaklo_pos/data/datasources/product/product_local_datasource.dart';
|
||||
import 'package:enaklo_pos/data/models/response/product_response_model.dart';
|
||||
|
||||
class ProductRepository {
|
||||
static ProductRepository? _instance;
|
||||
|
||||
final ProductLocalDatasource _localDatasource;
|
||||
|
||||
ProductRepository._internal()
|
||||
: _localDatasource = ProductLocalDatasource.instance;
|
||||
|
||||
static ProductRepository get instance {
|
||||
_instance ??= ProductRepository._internal();
|
||||
return _instance!;
|
||||
}
|
||||
|
||||
// ========================================
|
||||
// PURE LOCAL DATABASE OPERATIONS
|
||||
// ========================================
|
||||
Future<Either<String, ProductResponseModel>> getProducts({
|
||||
int page = 1,
|
||||
int limit = 10,
|
||||
String? categoryId,
|
||||
String? search,
|
||||
bool forceRefresh = false, // Ignored - kept for compatibility
|
||||
}) async {
|
||||
try {
|
||||
log('📱 Getting products from local database - page: $page, categoryId: $categoryId, search: $search');
|
||||
|
||||
// Clean expired cache for optimal performance
|
||||
_localDatasource.clearExpiredCache();
|
||||
|
||||
// Use cached query for maximum performance
|
||||
final cachedProducts = await _localDatasource.getCachedProducts(
|
||||
page: page,
|
||||
limit: limit,
|
||||
categoryId: categoryId,
|
||||
search: search,
|
||||
);
|
||||
|
||||
final totalCount = await _localDatasource.getTotalCount(
|
||||
categoryId: categoryId,
|
||||
search: search,
|
||||
);
|
||||
|
||||
final productData = ProductData(
|
||||
products: cachedProducts,
|
||||
totalCount: totalCount,
|
||||
page: page,
|
||||
limit: limit,
|
||||
totalPages: totalCount > 0 ? (totalCount / limit).ceil() : 0,
|
||||
);
|
||||
|
||||
final response = ProductResponseModel(
|
||||
success: true,
|
||||
data: productData,
|
||||
errors: null,
|
||||
);
|
||||
|
||||
log('âś… Returned ${cachedProducts.length} local products (${totalCount} total)');
|
||||
return Right(response);
|
||||
} catch (e) {
|
||||
log('❌ Error getting local products: $e');
|
||||
return Left('Gagal memuat produk dari database lokal: $e');
|
||||
}
|
||||
}
|
||||
|
||||
// ========================================
|
||||
// OPTIMIZED LOCAL SEARCH
|
||||
// ========================================
|
||||
Future<Either<String, List<Product>>> searchProductsOptimized(
|
||||
String query) async {
|
||||
try {
|
||||
log('🔍 Local optimized search for: "$query"');
|
||||
|
||||
final products = await _localDatasource.searchProductsOptimized(query);
|
||||
|
||||
log('âś… Local search completed: ${products.length} results');
|
||||
return Right(products);
|
||||
} catch (e) {
|
||||
log('❌ Error in local search: $e');
|
||||
return Left('Pencarian lokal gagal: $e');
|
||||
}
|
||||
}
|
||||
|
||||
// ========================================
|
||||
// LOCAL DATABASE OPERATIONS
|
||||
// ========================================
|
||||
|
||||
// Refresh just cleans cache and reloads from local
|
||||
Future<Either<String, ProductResponseModel>> refreshProducts({
|
||||
String? categoryId,
|
||||
String? search,
|
||||
}) async {
|
||||
log('🔄 Refreshing local products...');
|
||||
|
||||
// Clear cache for fresh local data
|
||||
clearCache();
|
||||
|
||||
return await getProducts(
|
||||
page: 1,
|
||||
limit: 10,
|
||||
categoryId: categoryId,
|
||||
search: search,
|
||||
);
|
||||
}
|
||||
|
||||
Future<Product?> getProductById(String id) async {
|
||||
log('🔍 Getting product by ID from local: $id');
|
||||
return await _localDatasource.getProductById(id);
|
||||
}
|
||||
|
||||
Future<bool> hasLocalProducts() async {
|
||||
final hasProducts = await _localDatasource.hasProducts();
|
||||
log('đź“Š Has local products: $hasProducts');
|
||||
return hasProducts;
|
||||
}
|
||||
|
||||
Future<Map<String, dynamic>> getDatabaseStats() async {
|
||||
final stats = await _localDatasource.getDatabaseStats();
|
||||
log('đź“Š Database stats: $stats');
|
||||
return stats;
|
||||
}
|
||||
|
||||
void clearCache() {
|
||||
log('🧹 Clearing local cache');
|
||||
_localDatasource.clearCache();
|
||||
}
|
||||
|
||||
// Helper method to check if local database is populated
|
||||
Future<bool> isLocalDatabaseReady() async {
|
||||
try {
|
||||
final stats = await getDatabaseStats();
|
||||
final productCount = stats['total_products'] ?? 0;
|
||||
final isReady = productCount > 0;
|
||||
log('🔍 Local database ready: $isReady ($productCount products)');
|
||||
return isReady;
|
||||
} catch (e) {
|
||||
log('❌ Error checking database readiness: $e');
|
||||
return false;
|
||||
}
|
||||
}
|
||||
}
|
||||
79
lib/data/services/sync_manager.dart
Normal file
79
lib/data/services/sync_manager.dart
Normal file
@ -0,0 +1,79 @@
|
||||
import 'dart:async';
|
||||
import 'dart:developer';
|
||||
import 'package:connectivity_plus/connectivity_plus.dart';
|
||||
import 'package:enaklo_pos/data/repositories/product/product_repository.dart';
|
||||
|
||||
class SyncManager {
|
||||
final ProductRepository _productRepository;
|
||||
final Connectivity _connectivity = Connectivity();
|
||||
|
||||
Timer? _syncTimer;
|
||||
bool _isSyncing = false;
|
||||
StreamSubscription<List<ConnectivityResult>>? _connectivitySubscription;
|
||||
|
||||
SyncManager(this._productRepository) {
|
||||
_startPeriodicSync();
|
||||
_listenToConnectivityChanges();
|
||||
}
|
||||
|
||||
void _startPeriodicSync() {
|
||||
// Sync setiap 5 menit jika ada koneksi
|
||||
_syncTimer = Timer.periodic(Duration(minutes: 5), (timer) {
|
||||
_performBackgroundSync();
|
||||
});
|
||||
}
|
||||
|
||||
void _listenToConnectivityChanges() {
|
||||
_connectivitySubscription = _connectivity.onConnectivityChanged.listen(
|
||||
(List<ConnectivityResult> results) {
|
||||
// Check if any connection is available
|
||||
final hasConnection =
|
||||
results.any((result) => result != ConnectivityResult.none);
|
||||
|
||||
if (hasConnection) {
|
||||
log('Connection restored, starting background sync');
|
||||
_performBackgroundSync();
|
||||
} else {
|
||||
log('Connection lost');
|
||||
}
|
||||
},
|
||||
);
|
||||
}
|
||||
|
||||
Future<void> _performBackgroundSync() async {
|
||||
if (_isSyncing) return;
|
||||
|
||||
// Check current connectivity before syncing
|
||||
final connectivityResults = await _connectivity.checkConnectivity();
|
||||
final hasConnection =
|
||||
connectivityResults.any((result) => result != ConnectivityResult.none);
|
||||
|
||||
if (!hasConnection) {
|
||||
log('No internet connection, skipping sync');
|
||||
return;
|
||||
}
|
||||
|
||||
try {
|
||||
_isSyncing = true;
|
||||
log('Starting background sync');
|
||||
|
||||
await _productRepository.refreshProducts();
|
||||
|
||||
log('Background sync completed');
|
||||
} catch (e) {
|
||||
log('Background sync failed: $e');
|
||||
} finally {
|
||||
_isSyncing = false;
|
||||
}
|
||||
}
|
||||
|
||||
// Public method untuk manual sync
|
||||
Future<void> performManualSync() async {
|
||||
await _performBackgroundSync();
|
||||
}
|
||||
|
||||
void dispose() {
|
||||
_syncTimer?.cancel();
|
||||
_connectivitySubscription?.cancel();
|
||||
}
|
||||
}
|
||||
@ -11,6 +11,7 @@ import 'package:enaklo_pos/data/datasources/table_remote_datasource.dart';
|
||||
import 'package:enaklo_pos/data/datasources/user_remote_datasource.dart';
|
||||
import 'package:enaklo_pos/presentation/customer/bloc/customer_form/customer_form_bloc.dart';
|
||||
import 'package:enaklo_pos/presentation/customer/bloc/customer_loader/customer_loader_bloc.dart';
|
||||
import 'package:enaklo_pos/presentation/data_sync/bloc/data_sync_bloc.dart';
|
||||
import 'package:enaklo_pos/presentation/home/bloc/category_loader/category_loader_bloc.dart';
|
||||
import 'package:enaklo_pos/presentation/home/bloc/current_outlet/current_outlet_bloc.dart';
|
||||
import 'package:enaklo_pos/presentation/home/bloc/order_form/order_form_bloc.dart';
|
||||
@ -261,7 +262,7 @@ class _MyAppState extends State<MyApp> {
|
||||
create: (context) => AddOrderItemsBloc(OrderRemoteDatasource()),
|
||||
),
|
||||
BlocProvider(
|
||||
create: (context) => ProductLoaderBloc(ProductRemoteDatasource()),
|
||||
create: (context) => ProductLoaderBloc(),
|
||||
),
|
||||
BlocProvider(
|
||||
create: (context) => OrderFormBloc(OrderRemoteDatasource()),
|
||||
@ -314,6 +315,9 @@ class _MyAppState extends State<MyApp> {
|
||||
BlocProvider(
|
||||
create: (context) => CategoryReportBloc(AnalyticRemoteDatasource()),
|
||||
),
|
||||
BlocProvider(
|
||||
create: (context) => DataSyncBloc(),
|
||||
),
|
||||
],
|
||||
child: MaterialApp(
|
||||
navigatorKey: AuthInterceptor.navigatorKey,
|
||||
|
||||
@ -1,3 +1,4 @@
|
||||
import 'package:enaklo_pos/presentation/data_sync/pages/data_sync_page.dart';
|
||||
import 'package:flutter/material.dart';
|
||||
import 'package:flutter_bloc/flutter_bloc.dart';
|
||||
import 'package:enaklo_pos/data/datasources/auth_local_datasource.dart';
|
||||
@ -9,7 +10,6 @@ import '../../core/components/buttons.dart';
|
||||
import '../../core/components/custom_text_field.dart';
|
||||
import '../../core/components/spaces.dart';
|
||||
import '../../core/constants/colors.dart';
|
||||
import '../home/pages/dashboard_page.dart';
|
||||
import 'bloc/login/login_bloc.dart';
|
||||
|
||||
class LoginPage extends StatefulWidget {
|
||||
@ -104,7 +104,7 @@ class _LoginPageState extends State<LoginPage> {
|
||||
Navigator.pushReplacement(
|
||||
context,
|
||||
MaterialPageRoute(
|
||||
builder: (context) => const DashboardPage(),
|
||||
builder: (context) => const DataSyncPage(),
|
||||
),
|
||||
);
|
||||
},
|
||||
|
||||
185
lib/presentation/data_sync/bloc/data_sync_bloc.dart
Normal file
185
lib/presentation/data_sync/bloc/data_sync_bloc.dart
Normal file
@ -0,0 +1,185 @@
|
||||
import 'dart:async';
|
||||
import 'dart:developer';
|
||||
import 'package:bloc/bloc.dart';
|
||||
import 'package:enaklo_pos/data/datasources/product/product_local_datasource.dart';
|
||||
import 'package:freezed_annotation/freezed_annotation.dart';
|
||||
import '../../../data/datasources/product_remote_datasource.dart';
|
||||
|
||||
part 'data_sync_event.dart';
|
||||
part 'data_sync_state.dart';
|
||||
part 'data_sync_bloc.freezed.dart';
|
||||
|
||||
enum SyncStep { products, categories, variants, completed }
|
||||
|
||||
class SyncStats {
|
||||
final int totalProducts;
|
||||
final int totalCategories;
|
||||
final int totalVariants;
|
||||
final double databaseSizeMB;
|
||||
|
||||
SyncStats({
|
||||
required this.totalProducts,
|
||||
required this.totalCategories,
|
||||
required this.totalVariants,
|
||||
required this.databaseSizeMB,
|
||||
});
|
||||
}
|
||||
|
||||
class DataSyncBloc extends Bloc<DataSyncEvent, DataSyncState> {
|
||||
final ProductRemoteDatasource _remoteDatasource = ProductRemoteDatasource();
|
||||
final ProductLocalDatasource _localDatasource =
|
||||
ProductLocalDatasource.instance;
|
||||
|
||||
Timer? _progressTimer;
|
||||
bool _isCancelled = false;
|
||||
|
||||
DataSyncBloc() : super(const DataSyncState.initial()) {
|
||||
on<_StartSync>(_onStartSync);
|
||||
on<_CancelSync>(_onCancelSync);
|
||||
}
|
||||
|
||||
@override
|
||||
Future<void> close() {
|
||||
_progressTimer?.cancel();
|
||||
return super.close();
|
||||
}
|
||||
|
||||
Future<void> _onStartSync(
|
||||
_StartSync event,
|
||||
Emitter<DataSyncState> emit,
|
||||
) async {
|
||||
log('🔄 Starting data sync...');
|
||||
_isCancelled = false;
|
||||
|
||||
try {
|
||||
// Step 1: Clear existing local data
|
||||
emit(const DataSyncState.syncing(
|
||||
SyncStep.products, 0.1, 'Membersihkan data lama...'));
|
||||
await _localDatasource.clearAllProducts();
|
||||
|
||||
if (_isCancelled) return;
|
||||
|
||||
// Step 2: Sync products
|
||||
await _syncProducts(emit);
|
||||
|
||||
if (_isCancelled) return;
|
||||
|
||||
// Step 3: Generate final stats
|
||||
emit(const DataSyncState.syncing(
|
||||
SyncStep.completed, 0.9, 'Menyelesaikan sinkronisasi...'));
|
||||
|
||||
final stats = await _generateSyncStats();
|
||||
|
||||
emit(DataSyncState.completed(stats));
|
||||
log('âś… Sync completed successfully');
|
||||
} catch (e) {
|
||||
log('❌ Sync failed: $e');
|
||||
emit(DataSyncState.error('Gagal sinkronisasi: $e'));
|
||||
}
|
||||
}
|
||||
|
||||
Future<void> _syncProducts(Emitter<DataSyncState> emit) async {
|
||||
log('📦 Syncing products...');
|
||||
|
||||
int page = 1;
|
||||
int totalSynced = 0;
|
||||
int? totalCount;
|
||||
int? totalPages;
|
||||
bool shouldContinue = true;
|
||||
|
||||
while (!_isCancelled && shouldContinue) {
|
||||
// Calculate accurate progress based on total count
|
||||
double progress = 0.2;
|
||||
if (totalCount != null && (totalCount ?? 0) > 0) {
|
||||
progress = 0.2 + (totalSynced / (totalCount ?? 0)) * 0.6;
|
||||
}
|
||||
|
||||
emit(DataSyncState.syncing(
|
||||
SyncStep.products,
|
||||
progress,
|
||||
totalCount != null
|
||||
? 'Mengunduh produk... ($totalSynced dari $totalCount)'
|
||||
: 'Mengunduh produk... ($totalSynced produk)',
|
||||
));
|
||||
|
||||
final result = await _remoteDatasource.getProducts(
|
||||
page: page,
|
||||
limit: 50, // Bigger batch for sync
|
||||
);
|
||||
|
||||
await result.fold(
|
||||
(failure) async {
|
||||
throw Exception(failure);
|
||||
},
|
||||
(response) async {
|
||||
final products = response.data?.products ?? [];
|
||||
final responseData = response.data;
|
||||
|
||||
// Get pagination info from first response
|
||||
if (page == 1 && responseData != null) {
|
||||
totalCount = responseData.totalCount;
|
||||
totalPages = responseData.totalPages;
|
||||
log('đź“Š Total products to sync: $totalCount (${totalPages} pages)');
|
||||
}
|
||||
|
||||
if (products.isEmpty) {
|
||||
shouldContinue = false;
|
||||
return;
|
||||
}
|
||||
|
||||
// Save to local database in batches
|
||||
await _localDatasource.saveProductsBatch(products);
|
||||
|
||||
totalSynced += products.length;
|
||||
page++;
|
||||
|
||||
log('📦 Synced page ${page - 1}: ${products.length} products (Total: $totalSynced)');
|
||||
|
||||
// Check if we reached the end using pagination info
|
||||
if (totalPages != null && page > (totalPages ?? 0)) {
|
||||
shouldContinue = false;
|
||||
return;
|
||||
}
|
||||
|
||||
// Fallback check if pagination info not available
|
||||
if (products.length < 50) {
|
||||
shouldContinue = false;
|
||||
return;
|
||||
}
|
||||
|
||||
// Small delay to prevent overwhelming the server
|
||||
await Future.delayed(Duration(milliseconds: 100));
|
||||
},
|
||||
);
|
||||
}
|
||||
|
||||
emit(DataSyncState.syncing(
|
||||
SyncStep.completed,
|
||||
0.8,
|
||||
'Produk berhasil diunduh ($totalSynced dari ${totalCount ?? totalSynced})',
|
||||
));
|
||||
|
||||
log('âś… Products sync completed: $totalSynced products synced');
|
||||
}
|
||||
|
||||
Future<SyncStats> _generateSyncStats() async {
|
||||
final dbStats = await _localDatasource.getDatabaseStats();
|
||||
|
||||
return SyncStats(
|
||||
totalProducts: dbStats['total_products'] ?? 0,
|
||||
totalCategories: dbStats['total_categories'] ?? 0,
|
||||
totalVariants: dbStats['total_variants'] ?? 0,
|
||||
databaseSizeMB: dbStats['database_size_mb'] ?? 0.0,
|
||||
);
|
||||
}
|
||||
|
||||
Future<void> _onCancelSync(
|
||||
_CancelSync event,
|
||||
Emitter<DataSyncState> emit,
|
||||
) async {
|
||||
log('⏹️ Cancelling sync...');
|
||||
_isCancelled = true;
|
||||
_progressTimer?.cancel();
|
||||
emit(const DataSyncState.initial());
|
||||
}
|
||||
}
|
||||
962
lib/presentation/data_sync/bloc/data_sync_bloc.freezed.dart
Normal file
962
lib/presentation/data_sync/bloc/data_sync_bloc.freezed.dart
Normal file
@ -0,0 +1,962 @@
|
||||
// coverage:ignore-file
|
||||
// GENERATED CODE - DO NOT MODIFY BY HAND
|
||||
// ignore_for_file: type=lint
|
||||
// ignore_for_file: unused_element, deprecated_member_use, deprecated_member_use_from_same_package, use_function_type_syntax_for_parameters, unnecessary_const, avoid_init_to_null, invalid_override_different_default_values_named, prefer_expression_function_bodies, annotate_overrides, invalid_annotation_target, unnecessary_question_mark
|
||||
|
||||
part of 'data_sync_bloc.dart';
|
||||
|
||||
// **************************************************************************
|
||||
// FreezedGenerator
|
||||
// **************************************************************************
|
||||
|
||||
T _$identity<T>(T value) => value;
|
||||
|
||||
final _privateConstructorUsedError = UnsupportedError(
|
||||
'It seems like you constructed your class using `MyClass._()`. This constructor is only meant to be used by freezed and you are not supposed to need it nor use it.\nPlease check the documentation here for more information: https://github.com/rrousselGit/freezed#adding-getters-and-methods-to-our-models');
|
||||
|
||||
/// @nodoc
|
||||
mixin _$DataSyncEvent {
|
||||
@optionalTypeArgs
|
||||
TResult when<TResult extends Object?>({
|
||||
required TResult Function() startSync,
|
||||
required TResult Function() cancelSync,
|
||||
}) =>
|
||||
throw _privateConstructorUsedError;
|
||||
@optionalTypeArgs
|
||||
TResult? whenOrNull<TResult extends Object?>({
|
||||
TResult? Function()? startSync,
|
||||
TResult? Function()? cancelSync,
|
||||
}) =>
|
||||
throw _privateConstructorUsedError;
|
||||
@optionalTypeArgs
|
||||
TResult maybeWhen<TResult extends Object?>({
|
||||
TResult Function()? startSync,
|
||||
TResult Function()? cancelSync,
|
||||
required TResult orElse(),
|
||||
}) =>
|
||||
throw _privateConstructorUsedError;
|
||||
@optionalTypeArgs
|
||||
TResult map<TResult extends Object?>({
|
||||
required TResult Function(_StartSync value) startSync,
|
||||
required TResult Function(_CancelSync value) cancelSync,
|
||||
}) =>
|
||||
throw _privateConstructorUsedError;
|
||||
@optionalTypeArgs
|
||||
TResult? mapOrNull<TResult extends Object?>({
|
||||
TResult? Function(_StartSync value)? startSync,
|
||||
TResult? Function(_CancelSync value)? cancelSync,
|
||||
}) =>
|
||||
throw _privateConstructorUsedError;
|
||||
@optionalTypeArgs
|
||||
TResult maybeMap<TResult extends Object?>({
|
||||
TResult Function(_StartSync value)? startSync,
|
||||
TResult Function(_CancelSync value)? cancelSync,
|
||||
required TResult orElse(),
|
||||
}) =>
|
||||
throw _privateConstructorUsedError;
|
||||
}
|
||||
|
||||
/// @nodoc
|
||||
abstract class $DataSyncEventCopyWith<$Res> {
|
||||
factory $DataSyncEventCopyWith(
|
||||
DataSyncEvent value, $Res Function(DataSyncEvent) then) =
|
||||
_$DataSyncEventCopyWithImpl<$Res, DataSyncEvent>;
|
||||
}
|
||||
|
||||
/// @nodoc
|
||||
class _$DataSyncEventCopyWithImpl<$Res, $Val extends DataSyncEvent>
|
||||
implements $DataSyncEventCopyWith<$Res> {
|
||||
_$DataSyncEventCopyWithImpl(this._value, this._then);
|
||||
|
||||
// ignore: unused_field
|
||||
final $Val _value;
|
||||
// ignore: unused_field
|
||||
final $Res Function($Val) _then;
|
||||
|
||||
/// Create a copy of DataSyncEvent
|
||||
/// with the given fields replaced by the non-null parameter values.
|
||||
}
|
||||
|
||||
/// @nodoc
|
||||
abstract class _$$StartSyncImplCopyWith<$Res> {
|
||||
factory _$$StartSyncImplCopyWith(
|
||||
_$StartSyncImpl value, $Res Function(_$StartSyncImpl) then) =
|
||||
__$$StartSyncImplCopyWithImpl<$Res>;
|
||||
}
|
||||
|
||||
/// @nodoc
|
||||
class __$$StartSyncImplCopyWithImpl<$Res>
|
||||
extends _$DataSyncEventCopyWithImpl<$Res, _$StartSyncImpl>
|
||||
implements _$$StartSyncImplCopyWith<$Res> {
|
||||
__$$StartSyncImplCopyWithImpl(
|
||||
_$StartSyncImpl _value, $Res Function(_$StartSyncImpl) _then)
|
||||
: super(_value, _then);
|
||||
|
||||
/// Create a copy of DataSyncEvent
|
||||
/// with the given fields replaced by the non-null parameter values.
|
||||
}
|
||||
|
||||
/// @nodoc
|
||||
|
||||
class _$StartSyncImpl implements _StartSync {
|
||||
const _$StartSyncImpl();
|
||||
|
||||
@override
|
||||
String toString() {
|
||||
return 'DataSyncEvent.startSync()';
|
||||
}
|
||||
|
||||
@override
|
||||
bool operator ==(Object other) {
|
||||
return identical(this, other) ||
|
||||
(other.runtimeType == runtimeType && other is _$StartSyncImpl);
|
||||
}
|
||||
|
||||
@override
|
||||
int get hashCode => runtimeType.hashCode;
|
||||
|
||||
@override
|
||||
@optionalTypeArgs
|
||||
TResult when<TResult extends Object?>({
|
||||
required TResult Function() startSync,
|
||||
required TResult Function() cancelSync,
|
||||
}) {
|
||||
return startSync();
|
||||
}
|
||||
|
||||
@override
|
||||
@optionalTypeArgs
|
||||
TResult? whenOrNull<TResult extends Object?>({
|
||||
TResult? Function()? startSync,
|
||||
TResult? Function()? cancelSync,
|
||||
}) {
|
||||
return startSync?.call();
|
||||
}
|
||||
|
||||
@override
|
||||
@optionalTypeArgs
|
||||
TResult maybeWhen<TResult extends Object?>({
|
||||
TResult Function()? startSync,
|
||||
TResult Function()? cancelSync,
|
||||
required TResult orElse(),
|
||||
}) {
|
||||
if (startSync != null) {
|
||||
return startSync();
|
||||
}
|
||||
return orElse();
|
||||
}
|
||||
|
||||
@override
|
||||
@optionalTypeArgs
|
||||
TResult map<TResult extends Object?>({
|
||||
required TResult Function(_StartSync value) startSync,
|
||||
required TResult Function(_CancelSync value) cancelSync,
|
||||
}) {
|
||||
return startSync(this);
|
||||
}
|
||||
|
||||
@override
|
||||
@optionalTypeArgs
|
||||
TResult? mapOrNull<TResult extends Object?>({
|
||||
TResult? Function(_StartSync value)? startSync,
|
||||
TResult? Function(_CancelSync value)? cancelSync,
|
||||
}) {
|
||||
return startSync?.call(this);
|
||||
}
|
||||
|
||||
@override
|
||||
@optionalTypeArgs
|
||||
TResult maybeMap<TResult extends Object?>({
|
||||
TResult Function(_StartSync value)? startSync,
|
||||
TResult Function(_CancelSync value)? cancelSync,
|
||||
required TResult orElse(),
|
||||
}) {
|
||||
if (startSync != null) {
|
||||
return startSync(this);
|
||||
}
|
||||
return orElse();
|
||||
}
|
||||
}
|
||||
|
||||
abstract class _StartSync implements DataSyncEvent {
|
||||
const factory _StartSync() = _$StartSyncImpl;
|
||||
}
|
||||
|
||||
/// @nodoc
|
||||
abstract class _$$CancelSyncImplCopyWith<$Res> {
|
||||
factory _$$CancelSyncImplCopyWith(
|
||||
_$CancelSyncImpl value, $Res Function(_$CancelSyncImpl) then) =
|
||||
__$$CancelSyncImplCopyWithImpl<$Res>;
|
||||
}
|
||||
|
||||
/// @nodoc
|
||||
class __$$CancelSyncImplCopyWithImpl<$Res>
|
||||
extends _$DataSyncEventCopyWithImpl<$Res, _$CancelSyncImpl>
|
||||
implements _$$CancelSyncImplCopyWith<$Res> {
|
||||
__$$CancelSyncImplCopyWithImpl(
|
||||
_$CancelSyncImpl _value, $Res Function(_$CancelSyncImpl) _then)
|
||||
: super(_value, _then);
|
||||
|
||||
/// Create a copy of DataSyncEvent
|
||||
/// with the given fields replaced by the non-null parameter values.
|
||||
}
|
||||
|
||||
/// @nodoc
|
||||
|
||||
class _$CancelSyncImpl implements _CancelSync {
|
||||
const _$CancelSyncImpl();
|
||||
|
||||
@override
|
||||
String toString() {
|
||||
return 'DataSyncEvent.cancelSync()';
|
||||
}
|
||||
|
||||
@override
|
||||
bool operator ==(Object other) {
|
||||
return identical(this, other) ||
|
||||
(other.runtimeType == runtimeType && other is _$CancelSyncImpl);
|
||||
}
|
||||
|
||||
@override
|
||||
int get hashCode => runtimeType.hashCode;
|
||||
|
||||
@override
|
||||
@optionalTypeArgs
|
||||
TResult when<TResult extends Object?>({
|
||||
required TResult Function() startSync,
|
||||
required TResult Function() cancelSync,
|
||||
}) {
|
||||
return cancelSync();
|
||||
}
|
||||
|
||||
@override
|
||||
@optionalTypeArgs
|
||||
TResult? whenOrNull<TResult extends Object?>({
|
||||
TResult? Function()? startSync,
|
||||
TResult? Function()? cancelSync,
|
||||
}) {
|
||||
return cancelSync?.call();
|
||||
}
|
||||
|
||||
@override
|
||||
@optionalTypeArgs
|
||||
TResult maybeWhen<TResult extends Object?>({
|
||||
TResult Function()? startSync,
|
||||
TResult Function()? cancelSync,
|
||||
required TResult orElse(),
|
||||
}) {
|
||||
if (cancelSync != null) {
|
||||
return cancelSync();
|
||||
}
|
||||
return orElse();
|
||||
}
|
||||
|
||||
@override
|
||||
@optionalTypeArgs
|
||||
TResult map<TResult extends Object?>({
|
||||
required TResult Function(_StartSync value) startSync,
|
||||
required TResult Function(_CancelSync value) cancelSync,
|
||||
}) {
|
||||
return cancelSync(this);
|
||||
}
|
||||
|
||||
@override
|
||||
@optionalTypeArgs
|
||||
TResult? mapOrNull<TResult extends Object?>({
|
||||
TResult? Function(_StartSync value)? startSync,
|
||||
TResult? Function(_CancelSync value)? cancelSync,
|
||||
}) {
|
||||
return cancelSync?.call(this);
|
||||
}
|
||||
|
||||
@override
|
||||
@optionalTypeArgs
|
||||
TResult maybeMap<TResult extends Object?>({
|
||||
TResult Function(_StartSync value)? startSync,
|
||||
TResult Function(_CancelSync value)? cancelSync,
|
||||
required TResult orElse(),
|
||||
}) {
|
||||
if (cancelSync != null) {
|
||||
return cancelSync(this);
|
||||
}
|
||||
return orElse();
|
||||
}
|
||||
}
|
||||
|
||||
abstract class _CancelSync implements DataSyncEvent {
|
||||
const factory _CancelSync() = _$CancelSyncImpl;
|
||||
}
|
||||
|
||||
/// @nodoc
|
||||
mixin _$DataSyncState {
|
||||
@optionalTypeArgs
|
||||
TResult when<TResult extends Object?>({
|
||||
required TResult Function() initial,
|
||||
required TResult Function(SyncStep step, double progress, String message)
|
||||
syncing,
|
||||
required TResult Function(SyncStats stats) completed,
|
||||
required TResult Function(String message) error,
|
||||
}) =>
|
||||
throw _privateConstructorUsedError;
|
||||
@optionalTypeArgs
|
||||
TResult? whenOrNull<TResult extends Object?>({
|
||||
TResult? Function()? initial,
|
||||
TResult? Function(SyncStep step, double progress, String message)? syncing,
|
||||
TResult? Function(SyncStats stats)? completed,
|
||||
TResult? Function(String message)? error,
|
||||
}) =>
|
||||
throw _privateConstructorUsedError;
|
||||
@optionalTypeArgs
|
||||
TResult maybeWhen<TResult extends Object?>({
|
||||
TResult Function()? initial,
|
||||
TResult Function(SyncStep step, double progress, String message)? syncing,
|
||||
TResult Function(SyncStats stats)? completed,
|
||||
TResult Function(String message)? error,
|
||||
required TResult orElse(),
|
||||
}) =>
|
||||
throw _privateConstructorUsedError;
|
||||
@optionalTypeArgs
|
||||
TResult map<TResult extends Object?>({
|
||||
required TResult Function(_Initial value) initial,
|
||||
required TResult Function(_Syncing value) syncing,
|
||||
required TResult Function(_Completed value) completed,
|
||||
required TResult Function(_Error value) error,
|
||||
}) =>
|
||||
throw _privateConstructorUsedError;
|
||||
@optionalTypeArgs
|
||||
TResult? mapOrNull<TResult extends Object?>({
|
||||
TResult? Function(_Initial value)? initial,
|
||||
TResult? Function(_Syncing value)? syncing,
|
||||
TResult? Function(_Completed value)? completed,
|
||||
TResult? Function(_Error value)? error,
|
||||
}) =>
|
||||
throw _privateConstructorUsedError;
|
||||
@optionalTypeArgs
|
||||
TResult maybeMap<TResult extends Object?>({
|
||||
TResult Function(_Initial value)? initial,
|
||||
TResult Function(_Syncing value)? syncing,
|
||||
TResult Function(_Completed value)? completed,
|
||||
TResult Function(_Error value)? error,
|
||||
required TResult orElse(),
|
||||
}) =>
|
||||
throw _privateConstructorUsedError;
|
||||
}
|
||||
|
||||
/// @nodoc
|
||||
abstract class $DataSyncStateCopyWith<$Res> {
|
||||
factory $DataSyncStateCopyWith(
|
||||
DataSyncState value, $Res Function(DataSyncState) then) =
|
||||
_$DataSyncStateCopyWithImpl<$Res, DataSyncState>;
|
||||
}
|
||||
|
||||
/// @nodoc
|
||||
class _$DataSyncStateCopyWithImpl<$Res, $Val extends DataSyncState>
|
||||
implements $DataSyncStateCopyWith<$Res> {
|
||||
_$DataSyncStateCopyWithImpl(this._value, this._then);
|
||||
|
||||
// ignore: unused_field
|
||||
final $Val _value;
|
||||
// ignore: unused_field
|
||||
final $Res Function($Val) _then;
|
||||
|
||||
/// Create a copy of DataSyncState
|
||||
/// with the given fields replaced by the non-null parameter values.
|
||||
}
|
||||
|
||||
/// @nodoc
|
||||
abstract class _$$InitialImplCopyWith<$Res> {
|
||||
factory _$$InitialImplCopyWith(
|
||||
_$InitialImpl value, $Res Function(_$InitialImpl) then) =
|
||||
__$$InitialImplCopyWithImpl<$Res>;
|
||||
}
|
||||
|
||||
/// @nodoc
|
||||
class __$$InitialImplCopyWithImpl<$Res>
|
||||
extends _$DataSyncStateCopyWithImpl<$Res, _$InitialImpl>
|
||||
implements _$$InitialImplCopyWith<$Res> {
|
||||
__$$InitialImplCopyWithImpl(
|
||||
_$InitialImpl _value, $Res Function(_$InitialImpl) _then)
|
||||
: super(_value, _then);
|
||||
|
||||
/// Create a copy of DataSyncState
|
||||
/// with the given fields replaced by the non-null parameter values.
|
||||
}
|
||||
|
||||
/// @nodoc
|
||||
|
||||
class _$InitialImpl implements _Initial {
|
||||
const _$InitialImpl();
|
||||
|
||||
@override
|
||||
String toString() {
|
||||
return 'DataSyncState.initial()';
|
||||
}
|
||||
|
||||
@override
|
||||
bool operator ==(Object other) {
|
||||
return identical(this, other) ||
|
||||
(other.runtimeType == runtimeType && other is _$InitialImpl);
|
||||
}
|
||||
|
||||
@override
|
||||
int get hashCode => runtimeType.hashCode;
|
||||
|
||||
@override
|
||||
@optionalTypeArgs
|
||||
TResult when<TResult extends Object?>({
|
||||
required TResult Function() initial,
|
||||
required TResult Function(SyncStep step, double progress, String message)
|
||||
syncing,
|
||||
required TResult Function(SyncStats stats) completed,
|
||||
required TResult Function(String message) error,
|
||||
}) {
|
||||
return initial();
|
||||
}
|
||||
|
||||
@override
|
||||
@optionalTypeArgs
|
||||
TResult? whenOrNull<TResult extends Object?>({
|
||||
TResult? Function()? initial,
|
||||
TResult? Function(SyncStep step, double progress, String message)? syncing,
|
||||
TResult? Function(SyncStats stats)? completed,
|
||||
TResult? Function(String message)? error,
|
||||
}) {
|
||||
return initial?.call();
|
||||
}
|
||||
|
||||
@override
|
||||
@optionalTypeArgs
|
||||
TResult maybeWhen<TResult extends Object?>({
|
||||
TResult Function()? initial,
|
||||
TResult Function(SyncStep step, double progress, String message)? syncing,
|
||||
TResult Function(SyncStats stats)? completed,
|
||||
TResult Function(String message)? error,
|
||||
required TResult orElse(),
|
||||
}) {
|
||||
if (initial != null) {
|
||||
return initial();
|
||||
}
|
||||
return orElse();
|
||||
}
|
||||
|
||||
@override
|
||||
@optionalTypeArgs
|
||||
TResult map<TResult extends Object?>({
|
||||
required TResult Function(_Initial value) initial,
|
||||
required TResult Function(_Syncing value) syncing,
|
||||
required TResult Function(_Completed value) completed,
|
||||
required TResult Function(_Error value) error,
|
||||
}) {
|
||||
return initial(this);
|
||||
}
|
||||
|
||||
@override
|
||||
@optionalTypeArgs
|
||||
TResult? mapOrNull<TResult extends Object?>({
|
||||
TResult? Function(_Initial value)? initial,
|
||||
TResult? Function(_Syncing value)? syncing,
|
||||
TResult? Function(_Completed value)? completed,
|
||||
TResult? Function(_Error value)? error,
|
||||
}) {
|
||||
return initial?.call(this);
|
||||
}
|
||||
|
||||
@override
|
||||
@optionalTypeArgs
|
||||
TResult maybeMap<TResult extends Object?>({
|
||||
TResult Function(_Initial value)? initial,
|
||||
TResult Function(_Syncing value)? syncing,
|
||||
TResult Function(_Completed value)? completed,
|
||||
TResult Function(_Error value)? error,
|
||||
required TResult orElse(),
|
||||
}) {
|
||||
if (initial != null) {
|
||||
return initial(this);
|
||||
}
|
||||
return orElse();
|
||||
}
|
||||
}
|
||||
|
||||
abstract class _Initial implements DataSyncState {
|
||||
const factory _Initial() = _$InitialImpl;
|
||||
}
|
||||
|
||||
/// @nodoc
|
||||
abstract class _$$SyncingImplCopyWith<$Res> {
|
||||
factory _$$SyncingImplCopyWith(
|
||||
_$SyncingImpl value, $Res Function(_$SyncingImpl) then) =
|
||||
__$$SyncingImplCopyWithImpl<$Res>;
|
||||
@useResult
|
||||
$Res call({SyncStep step, double progress, String message});
|
||||
}
|
||||
|
||||
/// @nodoc
|
||||
class __$$SyncingImplCopyWithImpl<$Res>
|
||||
extends _$DataSyncStateCopyWithImpl<$Res, _$SyncingImpl>
|
||||
implements _$$SyncingImplCopyWith<$Res> {
|
||||
__$$SyncingImplCopyWithImpl(
|
||||
_$SyncingImpl _value, $Res Function(_$SyncingImpl) _then)
|
||||
: super(_value, _then);
|
||||
|
||||
/// Create a copy of DataSyncState
|
||||
/// with the given fields replaced by the non-null parameter values.
|
||||
@pragma('vm:prefer-inline')
|
||||
@override
|
||||
$Res call({
|
||||
Object? step = null,
|
||||
Object? progress = null,
|
||||
Object? message = null,
|
||||
}) {
|
||||
return _then(_$SyncingImpl(
|
||||
null == step
|
||||
? _value.step
|
||||
: step // ignore: cast_nullable_to_non_nullable
|
||||
as SyncStep,
|
||||
null == progress
|
||||
? _value.progress
|
||||
: progress // ignore: cast_nullable_to_non_nullable
|
||||
as double,
|
||||
null == message
|
||||
? _value.message
|
||||
: message // ignore: cast_nullable_to_non_nullable
|
||||
as String,
|
||||
));
|
||||
}
|
||||
}
|
||||
|
||||
/// @nodoc
|
||||
|
||||
class _$SyncingImpl implements _Syncing {
|
||||
const _$SyncingImpl(this.step, this.progress, this.message);
|
||||
|
||||
@override
|
||||
final SyncStep step;
|
||||
@override
|
||||
final double progress;
|
||||
@override
|
||||
final String message;
|
||||
|
||||
@override
|
||||
String toString() {
|
||||
return 'DataSyncState.syncing(step: $step, progress: $progress, message: $message)';
|
||||
}
|
||||
|
||||
@override
|
||||
bool operator ==(Object other) {
|
||||
return identical(this, other) ||
|
||||
(other.runtimeType == runtimeType &&
|
||||
other is _$SyncingImpl &&
|
||||
(identical(other.step, step) || other.step == step) &&
|
||||
(identical(other.progress, progress) ||
|
||||
other.progress == progress) &&
|
||||
(identical(other.message, message) || other.message == message));
|
||||
}
|
||||
|
||||
@override
|
||||
int get hashCode => Object.hash(runtimeType, step, progress, message);
|
||||
|
||||
/// Create a copy of DataSyncState
|
||||
/// with the given fields replaced by the non-null parameter values.
|
||||
@JsonKey(includeFromJson: false, includeToJson: false)
|
||||
@override
|
||||
@pragma('vm:prefer-inline')
|
||||
_$$SyncingImplCopyWith<_$SyncingImpl> get copyWith =>
|
||||
__$$SyncingImplCopyWithImpl<_$SyncingImpl>(this, _$identity);
|
||||
|
||||
@override
|
||||
@optionalTypeArgs
|
||||
TResult when<TResult extends Object?>({
|
||||
required TResult Function() initial,
|
||||
required TResult Function(SyncStep step, double progress, String message)
|
||||
syncing,
|
||||
required TResult Function(SyncStats stats) completed,
|
||||
required TResult Function(String message) error,
|
||||
}) {
|
||||
return syncing(step, progress, message);
|
||||
}
|
||||
|
||||
@override
|
||||
@optionalTypeArgs
|
||||
TResult? whenOrNull<TResult extends Object?>({
|
||||
TResult? Function()? initial,
|
||||
TResult? Function(SyncStep step, double progress, String message)? syncing,
|
||||
TResult? Function(SyncStats stats)? completed,
|
||||
TResult? Function(String message)? error,
|
||||
}) {
|
||||
return syncing?.call(step, progress, message);
|
||||
}
|
||||
|
||||
@override
|
||||
@optionalTypeArgs
|
||||
TResult maybeWhen<TResult extends Object?>({
|
||||
TResult Function()? initial,
|
||||
TResult Function(SyncStep step, double progress, String message)? syncing,
|
||||
TResult Function(SyncStats stats)? completed,
|
||||
TResult Function(String message)? error,
|
||||
required TResult orElse(),
|
||||
}) {
|
||||
if (syncing != null) {
|
||||
return syncing(step, progress, message);
|
||||
}
|
||||
return orElse();
|
||||
}
|
||||
|
||||
@override
|
||||
@optionalTypeArgs
|
||||
TResult map<TResult extends Object?>({
|
||||
required TResult Function(_Initial value) initial,
|
||||
required TResult Function(_Syncing value) syncing,
|
||||
required TResult Function(_Completed value) completed,
|
||||
required TResult Function(_Error value) error,
|
||||
}) {
|
||||
return syncing(this);
|
||||
}
|
||||
|
||||
@override
|
||||
@optionalTypeArgs
|
||||
TResult? mapOrNull<TResult extends Object?>({
|
||||
TResult? Function(_Initial value)? initial,
|
||||
TResult? Function(_Syncing value)? syncing,
|
||||
TResult? Function(_Completed value)? completed,
|
||||
TResult? Function(_Error value)? error,
|
||||
}) {
|
||||
return syncing?.call(this);
|
||||
}
|
||||
|
||||
@override
|
||||
@optionalTypeArgs
|
||||
TResult maybeMap<TResult extends Object?>({
|
||||
TResult Function(_Initial value)? initial,
|
||||
TResult Function(_Syncing value)? syncing,
|
||||
TResult Function(_Completed value)? completed,
|
||||
TResult Function(_Error value)? error,
|
||||
required TResult orElse(),
|
||||
}) {
|
||||
if (syncing != null) {
|
||||
return syncing(this);
|
||||
}
|
||||
return orElse();
|
||||
}
|
||||
}
|
||||
|
||||
abstract class _Syncing implements DataSyncState {
|
||||
const factory _Syncing(
|
||||
final SyncStep step, final double progress, final String message) =
|
||||
_$SyncingImpl;
|
||||
|
||||
SyncStep get step;
|
||||
double get progress;
|
||||
String get message;
|
||||
|
||||
/// Create a copy of DataSyncState
|
||||
/// with the given fields replaced by the non-null parameter values.
|
||||
@JsonKey(includeFromJson: false, includeToJson: false)
|
||||
_$$SyncingImplCopyWith<_$SyncingImpl> get copyWith =>
|
||||
throw _privateConstructorUsedError;
|
||||
}
|
||||
|
||||
/// @nodoc
|
||||
abstract class _$$CompletedImplCopyWith<$Res> {
|
||||
factory _$$CompletedImplCopyWith(
|
||||
_$CompletedImpl value, $Res Function(_$CompletedImpl) then) =
|
||||
__$$CompletedImplCopyWithImpl<$Res>;
|
||||
@useResult
|
||||
$Res call({SyncStats stats});
|
||||
}
|
||||
|
||||
/// @nodoc
|
||||
class __$$CompletedImplCopyWithImpl<$Res>
|
||||
extends _$DataSyncStateCopyWithImpl<$Res, _$CompletedImpl>
|
||||
implements _$$CompletedImplCopyWith<$Res> {
|
||||
__$$CompletedImplCopyWithImpl(
|
||||
_$CompletedImpl _value, $Res Function(_$CompletedImpl) _then)
|
||||
: super(_value, _then);
|
||||
|
||||
/// Create a copy of DataSyncState
|
||||
/// with the given fields replaced by the non-null parameter values.
|
||||
@pragma('vm:prefer-inline')
|
||||
@override
|
||||
$Res call({
|
||||
Object? stats = null,
|
||||
}) {
|
||||
return _then(_$CompletedImpl(
|
||||
null == stats
|
||||
? _value.stats
|
||||
: stats // ignore: cast_nullable_to_non_nullable
|
||||
as SyncStats,
|
||||
));
|
||||
}
|
||||
}
|
||||
|
||||
/// @nodoc
|
||||
|
||||
class _$CompletedImpl implements _Completed {
|
||||
const _$CompletedImpl(this.stats);
|
||||
|
||||
@override
|
||||
final SyncStats stats;
|
||||
|
||||
@override
|
||||
String toString() {
|
||||
return 'DataSyncState.completed(stats: $stats)';
|
||||
}
|
||||
|
||||
@override
|
||||
bool operator ==(Object other) {
|
||||
return identical(this, other) ||
|
||||
(other.runtimeType == runtimeType &&
|
||||
other is _$CompletedImpl &&
|
||||
(identical(other.stats, stats) || other.stats == stats));
|
||||
}
|
||||
|
||||
@override
|
||||
int get hashCode => Object.hash(runtimeType, stats);
|
||||
|
||||
/// Create a copy of DataSyncState
|
||||
/// with the given fields replaced by the non-null parameter values.
|
||||
@JsonKey(includeFromJson: false, includeToJson: false)
|
||||
@override
|
||||
@pragma('vm:prefer-inline')
|
||||
_$$CompletedImplCopyWith<_$CompletedImpl> get copyWith =>
|
||||
__$$CompletedImplCopyWithImpl<_$CompletedImpl>(this, _$identity);
|
||||
|
||||
@override
|
||||
@optionalTypeArgs
|
||||
TResult when<TResult extends Object?>({
|
||||
required TResult Function() initial,
|
||||
required TResult Function(SyncStep step, double progress, String message)
|
||||
syncing,
|
||||
required TResult Function(SyncStats stats) completed,
|
||||
required TResult Function(String message) error,
|
||||
}) {
|
||||
return completed(stats);
|
||||
}
|
||||
|
||||
@override
|
||||
@optionalTypeArgs
|
||||
TResult? whenOrNull<TResult extends Object?>({
|
||||
TResult? Function()? initial,
|
||||
TResult? Function(SyncStep step, double progress, String message)? syncing,
|
||||
TResult? Function(SyncStats stats)? completed,
|
||||
TResult? Function(String message)? error,
|
||||
}) {
|
||||
return completed?.call(stats);
|
||||
}
|
||||
|
||||
@override
|
||||
@optionalTypeArgs
|
||||
TResult maybeWhen<TResult extends Object?>({
|
||||
TResult Function()? initial,
|
||||
TResult Function(SyncStep step, double progress, String message)? syncing,
|
||||
TResult Function(SyncStats stats)? completed,
|
||||
TResult Function(String message)? error,
|
||||
required TResult orElse(),
|
||||
}) {
|
||||
if (completed != null) {
|
||||
return completed(stats);
|
||||
}
|
||||
return orElse();
|
||||
}
|
||||
|
||||
@override
|
||||
@optionalTypeArgs
|
||||
TResult map<TResult extends Object?>({
|
||||
required TResult Function(_Initial value) initial,
|
||||
required TResult Function(_Syncing value) syncing,
|
||||
required TResult Function(_Completed value) completed,
|
||||
required TResult Function(_Error value) error,
|
||||
}) {
|
||||
return completed(this);
|
||||
}
|
||||
|
||||
@override
|
||||
@optionalTypeArgs
|
||||
TResult? mapOrNull<TResult extends Object?>({
|
||||
TResult? Function(_Initial value)? initial,
|
||||
TResult? Function(_Syncing value)? syncing,
|
||||
TResult? Function(_Completed value)? completed,
|
||||
TResult? Function(_Error value)? error,
|
||||
}) {
|
||||
return completed?.call(this);
|
||||
}
|
||||
|
||||
@override
|
||||
@optionalTypeArgs
|
||||
TResult maybeMap<TResult extends Object?>({
|
||||
TResult Function(_Initial value)? initial,
|
||||
TResult Function(_Syncing value)? syncing,
|
||||
TResult Function(_Completed value)? completed,
|
||||
TResult Function(_Error value)? error,
|
||||
required TResult orElse(),
|
||||
}) {
|
||||
if (completed != null) {
|
||||
return completed(this);
|
||||
}
|
||||
return orElse();
|
||||
}
|
||||
}
|
||||
|
||||
abstract class _Completed implements DataSyncState {
|
||||
const factory _Completed(final SyncStats stats) = _$CompletedImpl;
|
||||
|
||||
SyncStats get stats;
|
||||
|
||||
/// Create a copy of DataSyncState
|
||||
/// with the given fields replaced by the non-null parameter values.
|
||||
@JsonKey(includeFromJson: false, includeToJson: false)
|
||||
_$$CompletedImplCopyWith<_$CompletedImpl> get copyWith =>
|
||||
throw _privateConstructorUsedError;
|
||||
}
|
||||
|
||||
/// @nodoc
|
||||
abstract class _$$ErrorImplCopyWith<$Res> {
|
||||
factory _$$ErrorImplCopyWith(
|
||||
_$ErrorImpl value, $Res Function(_$ErrorImpl) then) =
|
||||
__$$ErrorImplCopyWithImpl<$Res>;
|
||||
@useResult
|
||||
$Res call({String message});
|
||||
}
|
||||
|
||||
/// @nodoc
|
||||
class __$$ErrorImplCopyWithImpl<$Res>
|
||||
extends _$DataSyncStateCopyWithImpl<$Res, _$ErrorImpl>
|
||||
implements _$$ErrorImplCopyWith<$Res> {
|
||||
__$$ErrorImplCopyWithImpl(
|
||||
_$ErrorImpl _value, $Res Function(_$ErrorImpl) _then)
|
||||
: super(_value, _then);
|
||||
|
||||
/// Create a copy of DataSyncState
|
||||
/// with the given fields replaced by the non-null parameter values.
|
||||
@pragma('vm:prefer-inline')
|
||||
@override
|
||||
$Res call({
|
||||
Object? message = null,
|
||||
}) {
|
||||
return _then(_$ErrorImpl(
|
||||
null == message
|
||||
? _value.message
|
||||
: message // ignore: cast_nullable_to_non_nullable
|
||||
as String,
|
||||
));
|
||||
}
|
||||
}
|
||||
|
||||
/// @nodoc
|
||||
|
||||
class _$ErrorImpl implements _Error {
|
||||
const _$ErrorImpl(this.message);
|
||||
|
||||
@override
|
||||
final String message;
|
||||
|
||||
@override
|
||||
String toString() {
|
||||
return 'DataSyncState.error(message: $message)';
|
||||
}
|
||||
|
||||
@override
|
||||
bool operator ==(Object other) {
|
||||
return identical(this, other) ||
|
||||
(other.runtimeType == runtimeType &&
|
||||
other is _$ErrorImpl &&
|
||||
(identical(other.message, message) || other.message == message));
|
||||
}
|
||||
|
||||
@override
|
||||
int get hashCode => Object.hash(runtimeType, message);
|
||||
|
||||
/// Create a copy of DataSyncState
|
||||
/// with the given fields replaced by the non-null parameter values.
|
||||
@JsonKey(includeFromJson: false, includeToJson: false)
|
||||
@override
|
||||
@pragma('vm:prefer-inline')
|
||||
_$$ErrorImplCopyWith<_$ErrorImpl> get copyWith =>
|
||||
__$$ErrorImplCopyWithImpl<_$ErrorImpl>(this, _$identity);
|
||||
|
||||
@override
|
||||
@optionalTypeArgs
|
||||
TResult when<TResult extends Object?>({
|
||||
required TResult Function() initial,
|
||||
required TResult Function(SyncStep step, double progress, String message)
|
||||
syncing,
|
||||
required TResult Function(SyncStats stats) completed,
|
||||
required TResult Function(String message) error,
|
||||
}) {
|
||||
return error(message);
|
||||
}
|
||||
|
||||
@override
|
||||
@optionalTypeArgs
|
||||
TResult? whenOrNull<TResult extends Object?>({
|
||||
TResult? Function()? initial,
|
||||
TResult? Function(SyncStep step, double progress, String message)? syncing,
|
||||
TResult? Function(SyncStats stats)? completed,
|
||||
TResult? Function(String message)? error,
|
||||
}) {
|
||||
return error?.call(message);
|
||||
}
|
||||
|
||||
@override
|
||||
@optionalTypeArgs
|
||||
TResult maybeWhen<TResult extends Object?>({
|
||||
TResult Function()? initial,
|
||||
TResult Function(SyncStep step, double progress, String message)? syncing,
|
||||
TResult Function(SyncStats stats)? completed,
|
||||
TResult Function(String message)? error,
|
||||
required TResult orElse(),
|
||||
}) {
|
||||
if (error != null) {
|
||||
return error(message);
|
||||
}
|
||||
return orElse();
|
||||
}
|
||||
|
||||
@override
|
||||
@optionalTypeArgs
|
||||
TResult map<TResult extends Object?>({
|
||||
required TResult Function(_Initial value) initial,
|
||||
required TResult Function(_Syncing value) syncing,
|
||||
required TResult Function(_Completed value) completed,
|
||||
required TResult Function(_Error value) error,
|
||||
}) {
|
||||
return error(this);
|
||||
}
|
||||
|
||||
@override
|
||||
@optionalTypeArgs
|
||||
TResult? mapOrNull<TResult extends Object?>({
|
||||
TResult? Function(_Initial value)? initial,
|
||||
TResult? Function(_Syncing value)? syncing,
|
||||
TResult? Function(_Completed value)? completed,
|
||||
TResult? Function(_Error value)? error,
|
||||
}) {
|
||||
return error?.call(this);
|
||||
}
|
||||
|
||||
@override
|
||||
@optionalTypeArgs
|
||||
TResult maybeMap<TResult extends Object?>({
|
||||
TResult Function(_Initial value)? initial,
|
||||
TResult Function(_Syncing value)? syncing,
|
||||
TResult Function(_Completed value)? completed,
|
||||
TResult Function(_Error value)? error,
|
||||
required TResult orElse(),
|
||||
}) {
|
||||
if (error != null) {
|
||||
return error(this);
|
||||
}
|
||||
return orElse();
|
||||
}
|
||||
}
|
||||
|
||||
abstract class _Error implements DataSyncState {
|
||||
const factory _Error(final String message) = _$ErrorImpl;
|
||||
|
||||
String get message;
|
||||
|
||||
/// Create a copy of DataSyncState
|
||||
/// with the given fields replaced by the non-null parameter values.
|
||||
@JsonKey(includeFromJson: false, includeToJson: false)
|
||||
_$$ErrorImplCopyWith<_$ErrorImpl> get copyWith =>
|
||||
throw _privateConstructorUsedError;
|
||||
}
|
||||
7
lib/presentation/data_sync/bloc/data_sync_event.dart
Normal file
7
lib/presentation/data_sync/bloc/data_sync_event.dart
Normal file
@ -0,0 +1,7 @@
|
||||
part of 'data_sync_bloc.dart';
|
||||
|
||||
@freezed
|
||||
class DataSyncEvent with _$DataSyncEvent {
|
||||
const factory DataSyncEvent.startSync() = _StartSync;
|
||||
const factory DataSyncEvent.cancelSync() = _CancelSync;
|
||||
}
|
||||
13
lib/presentation/data_sync/bloc/data_sync_state.dart
Normal file
13
lib/presentation/data_sync/bloc/data_sync_state.dart
Normal file
@ -0,0 +1,13 @@
|
||||
part of 'data_sync_bloc.dart';
|
||||
|
||||
@freezed
|
||||
class DataSyncState with _$DataSyncState {
|
||||
const factory DataSyncState.initial() = _Initial;
|
||||
const factory DataSyncState.syncing(
|
||||
SyncStep step,
|
||||
double progress,
|
||||
String message,
|
||||
) = _Syncing;
|
||||
const factory DataSyncState.completed(SyncStats stats) = _Completed;
|
||||
const factory DataSyncState.error(String message) = _Error;
|
||||
}
|
||||
791
lib/presentation/data_sync/pages/data_sync_page.dart
Normal file
791
lib/presentation/data_sync/pages/data_sync_page.dart
Normal file
@ -0,0 +1,791 @@
|
||||
import 'dart:async';
|
||||
import 'package:enaklo_pos/core/extensions/build_context_ext.dart';
|
||||
import 'package:enaklo_pos/presentation/home/pages/dashboard_page.dart';
|
||||
import 'package:flutter/material.dart';
|
||||
import 'package:flutter_bloc/flutter_bloc.dart';
|
||||
import '../../../core/components/buttons.dart';
|
||||
import '../../../core/constants/colors.dart';
|
||||
import '../bloc/data_sync_bloc.dart';
|
||||
|
||||
class DataSyncPage extends StatefulWidget {
|
||||
const DataSyncPage({super.key});
|
||||
|
||||
@override
|
||||
State<DataSyncPage> createState() => _DataSyncPageState();
|
||||
}
|
||||
|
||||
class _DataSyncPageState extends State<DataSyncPage>
|
||||
with TickerProviderStateMixin {
|
||||
late AnimationController _animationController;
|
||||
late Animation<double> _progressAnimation;
|
||||
|
||||
@override
|
||||
void initState() {
|
||||
super.initState();
|
||||
_animationController = AnimationController(
|
||||
duration: Duration(milliseconds: 500),
|
||||
vsync: this,
|
||||
);
|
||||
_progressAnimation = Tween<double>(
|
||||
begin: 0.0,
|
||||
end: 1.0,
|
||||
).animate(CurvedAnimation(
|
||||
parent: _animationController,
|
||||
curve: Curves.easeInOut,
|
||||
));
|
||||
|
||||
// Auto start sync
|
||||
WidgetsBinding.instance.addPostFrameCallback((_) {
|
||||
context.read<DataSyncBloc>().add(const DataSyncEvent.startSync());
|
||||
});
|
||||
}
|
||||
|
||||
@override
|
||||
void dispose() {
|
||||
_animationController.dispose();
|
||||
super.dispose();
|
||||
}
|
||||
|
||||
@override
|
||||
Widget build(BuildContext context) {
|
||||
final mediaQuery = MediaQuery.of(context);
|
||||
final isLandscape = mediaQuery.orientation == Orientation.landscape;
|
||||
final screenHeight = mediaQuery.size.height;
|
||||
final screenWidth = mediaQuery.size.width;
|
||||
|
||||
return Scaffold(
|
||||
backgroundColor: Colors.grey.shade50,
|
||||
body: SafeArea(
|
||||
child: BlocConsumer<DataSyncBloc, DataSyncState>(
|
||||
listener: (context, state) {
|
||||
state.maybeWhen(
|
||||
orElse: () {},
|
||||
syncing: (step, progress, message) {
|
||||
_animationController.animateTo(progress);
|
||||
},
|
||||
completed: (stats) {
|
||||
_animationController.animateTo(1.0);
|
||||
// Navigate to home after delay
|
||||
Future.delayed(Duration(seconds: 2), () {
|
||||
context.pushReplacement(DashboardPage());
|
||||
});
|
||||
},
|
||||
error: (message) {
|
||||
_animationController.stop();
|
||||
},
|
||||
);
|
||||
},
|
||||
builder: (context, state) {
|
||||
if (isLandscape) {
|
||||
return _buildLandscapeLayout(state, screenWidth, screenHeight);
|
||||
} else {
|
||||
return _buildPortraitLayout(state, screenHeight);
|
||||
}
|
||||
},
|
||||
),
|
||||
),
|
||||
);
|
||||
}
|
||||
|
||||
// Portrait layout (original)
|
||||
Widget _buildPortraitLayout(DataSyncState state, double screenHeight) {
|
||||
return Padding(
|
||||
padding: EdgeInsets.all(24),
|
||||
child: Column(
|
||||
children: [
|
||||
SizedBox(height: screenHeight * 0.08), // Responsive spacing
|
||||
|
||||
// Header
|
||||
_buildHeader(false),
|
||||
|
||||
SizedBox(height: screenHeight * 0.08),
|
||||
|
||||
// Sync progress
|
||||
Expanded(
|
||||
child: state.when(
|
||||
initial: () => _buildInitialState(false),
|
||||
syncing: (step, progress, message) =>
|
||||
_buildSyncingState(step, progress, message, false),
|
||||
completed: (stats) => _buildCompletedState(stats, false),
|
||||
error: (message) => _buildErrorState(message, false),
|
||||
),
|
||||
),
|
||||
|
||||
SizedBox(height: 20),
|
||||
|
||||
// Actions
|
||||
_buildActions(state),
|
||||
],
|
||||
),
|
||||
);
|
||||
}
|
||||
|
||||
// Landscape layout (side by side)
|
||||
Widget _buildLandscapeLayout(
|
||||
DataSyncState state, double screenWidth, double screenHeight) {
|
||||
return Padding(
|
||||
padding: EdgeInsets.symmetric(horizontal: 32, vertical: 16),
|
||||
child: Row(
|
||||
children: [
|
||||
// Left side - Header and info
|
||||
Expanded(
|
||||
flex: 2,
|
||||
child: Column(
|
||||
mainAxisAlignment: MainAxisAlignment.center,
|
||||
children: [
|
||||
_buildHeader(true),
|
||||
SizedBox(height: 20),
|
||||
_buildActions(state),
|
||||
],
|
||||
),
|
||||
),
|
||||
|
||||
SizedBox(width: 40),
|
||||
|
||||
// Right side - Sync progress
|
||||
Expanded(
|
||||
flex: 3,
|
||||
child: Container(
|
||||
height: screenHeight * 0.8,
|
||||
child: state.when(
|
||||
initial: () => _buildInitialState(true),
|
||||
syncing: (step, progress, message) =>
|
||||
_buildSyncingState(step, progress, message, true),
|
||||
completed: (stats) => _buildCompletedState(stats, true),
|
||||
error: (message) => _buildErrorState(message, true),
|
||||
),
|
||||
),
|
||||
),
|
||||
],
|
||||
),
|
||||
);
|
||||
}
|
||||
|
||||
Widget _buildHeader(bool isLandscape) {
|
||||
return Column(
|
||||
children: [
|
||||
Container(
|
||||
width: isLandscape ? 60 : 80,
|
||||
height: isLandscape ? 60 : 80,
|
||||
decoration: BoxDecoration(
|
||||
color: AppColors.primary.withOpacity(0.1),
|
||||
borderRadius: BorderRadius.circular(isLandscape ? 15 : 20),
|
||||
),
|
||||
child: Icon(
|
||||
Icons.sync,
|
||||
size: isLandscape ? 30 : 40,
|
||||
color: AppColors.primary,
|
||||
),
|
||||
),
|
||||
SizedBox(height: isLandscape ? 12 : 20),
|
||||
Text(
|
||||
'Sinkronisasi Data',
|
||||
style: TextStyle(
|
||||
fontSize: isLandscape ? 20 : 24,
|
||||
fontWeight: FontWeight.bold,
|
||||
color: Colors.grey.shade800,
|
||||
),
|
||||
),
|
||||
SizedBox(height: isLandscape ? 4 : 8),
|
||||
Text(
|
||||
'Mengunduh data terbaru ke perangkat',
|
||||
style: TextStyle(
|
||||
fontSize: isLandscape ? 14 : 16,
|
||||
color: Colors.grey.shade600,
|
||||
),
|
||||
textAlign: TextAlign.center,
|
||||
),
|
||||
],
|
||||
);
|
||||
}
|
||||
|
||||
Widget _buildInitialState(bool isLandscape) {
|
||||
return Column(
|
||||
mainAxisAlignment: MainAxisAlignment.center,
|
||||
children: [
|
||||
Icon(
|
||||
Icons.download_rounded,
|
||||
size: isLandscape ? 48 : 64,
|
||||
color: Colors.grey.shade400,
|
||||
),
|
||||
SizedBox(height: isLandscape ? 12 : 20),
|
||||
Text(
|
||||
'Siap untuk sinkronisasi',
|
||||
style: TextStyle(
|
||||
fontSize: isLandscape ? 16 : 18,
|
||||
fontWeight: FontWeight.w500,
|
||||
),
|
||||
),
|
||||
SizedBox(height: isLandscape ? 4 : 8),
|
||||
Text(
|
||||
'Tekan tombol mulai untuk mengunduh data',
|
||||
style: TextStyle(
|
||||
fontSize: isLandscape ? 12 : 14,
|
||||
color: Colors.grey.shade600,
|
||||
),
|
||||
textAlign: TextAlign.center,
|
||||
),
|
||||
],
|
||||
);
|
||||
}
|
||||
|
||||
Widget _buildSyncingState(
|
||||
SyncStep step, double progress, String message, bool isLandscape) {
|
||||
return SingleChildScrollView(
|
||||
child: Column(
|
||||
mainAxisAlignment: MainAxisAlignment.center,
|
||||
children: [
|
||||
// Progress circle
|
||||
Stack(
|
||||
alignment: Alignment.center,
|
||||
children: [
|
||||
SizedBox(
|
||||
width: isLandscape ? 100 : 120,
|
||||
height: isLandscape ? 100 : 120,
|
||||
child: AnimatedBuilder(
|
||||
animation: _progressAnimation,
|
||||
builder: (context, child) {
|
||||
return CircularProgressIndicator(
|
||||
value: _progressAnimation.value,
|
||||
strokeWidth: isLandscape ? 6 : 8,
|
||||
backgroundColor: Colors.grey.shade200,
|
||||
valueColor:
|
||||
AlwaysStoppedAnimation<Color>(AppColors.primary),
|
||||
);
|
||||
},
|
||||
),
|
||||
),
|
||||
Column(
|
||||
children: [
|
||||
Icon(
|
||||
_getSyncIcon(step),
|
||||
size: isLandscape ? 24 : 32,
|
||||
color: AppColors.primary,
|
||||
),
|
||||
SizedBox(height: 2),
|
||||
AnimatedBuilder(
|
||||
animation: _progressAnimation,
|
||||
builder: (context, child) {
|
||||
return Text(
|
||||
'${(_progressAnimation.value * 100).toInt()}%',
|
||||
style: TextStyle(
|
||||
fontSize: isLandscape ? 14 : 16,
|
||||
fontWeight: FontWeight.bold,
|
||||
color: AppColors.primary,
|
||||
),
|
||||
);
|
||||
},
|
||||
),
|
||||
],
|
||||
),
|
||||
],
|
||||
),
|
||||
|
||||
SizedBox(height: isLandscape ? 20 : 30),
|
||||
|
||||
// Step indicator
|
||||
_buildStepIndicator(step, isLandscape),
|
||||
|
||||
SizedBox(height: isLandscape ? 12 : 20),
|
||||
|
||||
// Current message
|
||||
Container(
|
||||
padding: EdgeInsets.symmetric(
|
||||
horizontal: isLandscape ? 16 : 20,
|
||||
vertical: isLandscape ? 8 : 12),
|
||||
decoration: BoxDecoration(
|
||||
color: Colors.blue.shade50,
|
||||
borderRadius: BorderRadius.circular(8),
|
||||
),
|
||||
child: Text(
|
||||
message,
|
||||
style: TextStyle(
|
||||
color: Colors.blue.shade700,
|
||||
fontSize: isLandscape ? 12 : 14,
|
||||
fontWeight: FontWeight.w500,
|
||||
),
|
||||
textAlign: TextAlign.center,
|
||||
),
|
||||
),
|
||||
|
||||
SizedBox(height: isLandscape ? 12 : 20),
|
||||
|
||||
// Sync details
|
||||
_buildSyncDetails(step, progress, isLandscape),
|
||||
],
|
||||
),
|
||||
);
|
||||
}
|
||||
|
||||
Widget _buildStepIndicator(SyncStep currentStep, bool isLandscape) {
|
||||
final steps = [
|
||||
('Produk', SyncStep.products, Icons.inventory_2),
|
||||
('Kategori', SyncStep.categories, Icons.category),
|
||||
('Variant', SyncStep.variants, Icons.tune),
|
||||
('Selesai', SyncStep.completed, Icons.check_circle),
|
||||
];
|
||||
|
||||
if (isLandscape) {
|
||||
// Vertical layout for landscape
|
||||
return Column(
|
||||
children: steps.map((stepData) {
|
||||
final (label, step, icon) = stepData;
|
||||
final isActive = step == currentStep;
|
||||
final isCompleted = step.index < currentStep.index;
|
||||
|
||||
return Container(
|
||||
margin: EdgeInsets.symmetric(vertical: 2),
|
||||
padding: EdgeInsets.symmetric(horizontal: 8, vertical: 4),
|
||||
decoration: BoxDecoration(
|
||||
color: isActive
|
||||
? AppColors.primary.withOpacity(0.1)
|
||||
: isCompleted
|
||||
? Colors.green.shade50
|
||||
: Colors.grey.shade100,
|
||||
borderRadius: BorderRadius.circular(6),
|
||||
),
|
||||
child: Row(
|
||||
mainAxisSize: MainAxisSize.min,
|
||||
children: [
|
||||
Icon(
|
||||
isCompleted ? Icons.check : icon,
|
||||
size: 12,
|
||||
color: isActive
|
||||
? AppColors.primary
|
||||
: isCompleted
|
||||
? Colors.green.shade600
|
||||
: Colors.grey.shade500,
|
||||
),
|
||||
SizedBox(width: 4),
|
||||
Text(
|
||||
label,
|
||||
style: TextStyle(
|
||||
fontSize: 10,
|
||||
fontWeight: isActive ? FontWeight.w600 : FontWeight.normal,
|
||||
color: isActive
|
||||
? AppColors.primary
|
||||
: isCompleted
|
||||
? Colors.green.shade600
|
||||
: Colors.grey.shade600,
|
||||
),
|
||||
),
|
||||
],
|
||||
),
|
||||
);
|
||||
}).toList(),
|
||||
);
|
||||
} else {
|
||||
// Horizontal layout for portrait
|
||||
return Row(
|
||||
mainAxisAlignment: MainAxisAlignment.center,
|
||||
children: steps.map((stepData) {
|
||||
final (label, step, icon) = stepData;
|
||||
final isActive = step == currentStep;
|
||||
final isCompleted = step.index < currentStep.index;
|
||||
|
||||
return Container(
|
||||
margin: EdgeInsets.symmetric(horizontal: 4),
|
||||
padding: EdgeInsets.symmetric(horizontal: 8, vertical: 4),
|
||||
decoration: BoxDecoration(
|
||||
color: isActive
|
||||
? AppColors.primary.withOpacity(0.1)
|
||||
: isCompleted
|
||||
? Colors.green.shade50
|
||||
: Colors.grey.shade100,
|
||||
borderRadius: BorderRadius.circular(6),
|
||||
),
|
||||
child: Row(
|
||||
mainAxisSize: MainAxisSize.min,
|
||||
children: [
|
||||
Icon(
|
||||
isCompleted ? Icons.check : icon,
|
||||
size: 14,
|
||||
color: isActive
|
||||
? AppColors.primary
|
||||
: isCompleted
|
||||
? Colors.green.shade600
|
||||
: Colors.grey.shade500,
|
||||
),
|
||||
SizedBox(width: 4),
|
||||
Text(
|
||||
label,
|
||||
style: TextStyle(
|
||||
fontSize: 11,
|
||||
fontWeight: isActive ? FontWeight.w600 : FontWeight.normal,
|
||||
color: isActive
|
||||
? AppColors.primary
|
||||
: isCompleted
|
||||
? Colors.green.shade600
|
||||
: Colors.grey.shade600,
|
||||
),
|
||||
),
|
||||
],
|
||||
),
|
||||
);
|
||||
}).toList(),
|
||||
);
|
||||
}
|
||||
}
|
||||
|
||||
Widget _buildSyncDetails(SyncStep step, double progress, bool isLandscape) {
|
||||
return Container(
|
||||
padding: EdgeInsets.all(isLandscape ? 12 : 16),
|
||||
decoration: BoxDecoration(
|
||||
color: Colors.white,
|
||||
borderRadius: BorderRadius.circular(8),
|
||||
border: Border.all(color: Colors.grey.shade200),
|
||||
),
|
||||
child: Column(
|
||||
children: [
|
||||
Row(
|
||||
mainAxisAlignment: MainAxisAlignment.spaceBetween,
|
||||
children: [
|
||||
Text(
|
||||
'Status:',
|
||||
style: TextStyle(
|
||||
fontSize: isLandscape ? 12 : 14,
|
||||
fontWeight: FontWeight.w500,
|
||||
color: Colors.grey.shade700,
|
||||
),
|
||||
),
|
||||
Text(
|
||||
_getStepLabel(step),
|
||||
style: TextStyle(
|
||||
fontSize: isLandscape ? 12 : 14,
|
||||
fontWeight: FontWeight.w600,
|
||||
color: AppColors.primary,
|
||||
),
|
||||
),
|
||||
],
|
||||
),
|
||||
SizedBox(height: isLandscape ? 6 : 8),
|
||||
Row(
|
||||
mainAxisAlignment: MainAxisAlignment.spaceBetween,
|
||||
children: [
|
||||
Text(
|
||||
'Progress:',
|
||||
style: TextStyle(
|
||||
fontSize: isLandscape ? 12 : 14,
|
||||
fontWeight: FontWeight.w500,
|
||||
color: Colors.grey.shade700,
|
||||
),
|
||||
),
|
||||
Text(
|
||||
'${(progress * 100).toInt()}%',
|
||||
style: TextStyle(
|
||||
fontSize: isLandscape ? 12 : 14,
|
||||
fontWeight: FontWeight.w600,
|
||||
color: AppColors.primary,
|
||||
),
|
||||
),
|
||||
],
|
||||
),
|
||||
],
|
||||
),
|
||||
);
|
||||
}
|
||||
|
||||
Widget _buildCompletedState(SyncStats stats, bool isLandscape) {
|
||||
return SingleChildScrollView(
|
||||
child: Column(
|
||||
mainAxisAlignment: MainAxisAlignment.center,
|
||||
children: [
|
||||
// Success icon
|
||||
Container(
|
||||
width: isLandscape ? 80 : 100,
|
||||
height: isLandscape ? 80 : 100,
|
||||
decoration: BoxDecoration(
|
||||
color: Colors.green.shade50,
|
||||
borderRadius: BorderRadius.circular(isLandscape ? 40 : 50),
|
||||
),
|
||||
child: Icon(
|
||||
Icons.check_circle,
|
||||
size: isLandscape ? 48 : 60,
|
||||
color: Colors.green.shade600,
|
||||
),
|
||||
),
|
||||
|
||||
SizedBox(height: isLandscape ? 20 : 30),
|
||||
|
||||
Text(
|
||||
'Sinkronisasi Berhasil!',
|
||||
style: TextStyle(
|
||||
fontSize: isLandscape ? 18 : 22,
|
||||
fontWeight: FontWeight.bold,
|
||||
color: Colors.green.shade700,
|
||||
),
|
||||
),
|
||||
|
||||
SizedBox(height: isLandscape ? 8 : 16),
|
||||
|
||||
Text(
|
||||
'Data berhasil diunduh ke perangkat',
|
||||
style: TextStyle(
|
||||
fontSize: isLandscape ? 14 : 16,
|
||||
color: Colors.grey.shade600,
|
||||
),
|
||||
),
|
||||
|
||||
SizedBox(height: isLandscape ? 20 : 30),
|
||||
|
||||
// Stats cards
|
||||
Container(
|
||||
padding: EdgeInsets.all(isLandscape ? 16 : 20),
|
||||
decoration: BoxDecoration(
|
||||
color: Colors.white,
|
||||
borderRadius: BorderRadius.circular(12),
|
||||
border: Border.all(color: Colors.grey.shade200),
|
||||
),
|
||||
child: Column(
|
||||
children: [
|
||||
Text(
|
||||
'Data yang Diunduh',
|
||||
style: TextStyle(
|
||||
fontSize: isLandscape ? 14 : 16,
|
||||
fontWeight: FontWeight.w600,
|
||||
color: Colors.grey.shade700,
|
||||
),
|
||||
),
|
||||
SizedBox(height: isLandscape ? 12 : 16),
|
||||
if (isLandscape)
|
||||
// Vertical layout for landscape
|
||||
Column(
|
||||
children: [
|
||||
_buildStatItem('Produk', '${stats.totalProducts}',
|
||||
Icons.inventory_2, Colors.blue, isLandscape),
|
||||
SizedBox(height: 8),
|
||||
_buildStatItem('Kategori', '${stats.totalCategories}',
|
||||
Icons.category, Colors.green, isLandscape),
|
||||
SizedBox(height: 8),
|
||||
_buildStatItem('Variant', '${stats.totalVariants}',
|
||||
Icons.tune, Colors.orange, isLandscape),
|
||||
],
|
||||
)
|
||||
else
|
||||
// Horizontal layout for portrait
|
||||
Row(
|
||||
mainAxisAlignment: MainAxisAlignment.spaceAround,
|
||||
children: [
|
||||
_buildStatItem('Produk', '${stats.totalProducts}',
|
||||
Icons.inventory_2, Colors.blue, isLandscape),
|
||||
_buildStatItem('Kategori', '${stats.totalCategories}',
|
||||
Icons.category, Colors.green, isLandscape),
|
||||
_buildStatItem('Variant', '${stats.totalVariants}',
|
||||
Icons.tune, Colors.orange, isLandscape),
|
||||
],
|
||||
),
|
||||
],
|
||||
),
|
||||
),
|
||||
|
||||
SizedBox(height: isLandscape ? 12 : 20),
|
||||
|
||||
Container(
|
||||
padding: EdgeInsets.symmetric(horizontal: 16, vertical: 8),
|
||||
decoration: BoxDecoration(
|
||||
color: Colors.grey.shade100,
|
||||
borderRadius: BorderRadius.circular(6),
|
||||
),
|
||||
child: Text(
|
||||
'Mengalihkan ke halaman utama...',
|
||||
style: TextStyle(
|
||||
color: Colors.grey.shade600,
|
||||
fontSize: isLandscape ? 10 : 12,
|
||||
),
|
||||
),
|
||||
),
|
||||
],
|
||||
),
|
||||
);
|
||||
}
|
||||
|
||||
Widget _buildErrorState(String message, bool isLandscape) {
|
||||
return Column(
|
||||
mainAxisAlignment: MainAxisAlignment.center,
|
||||
children: [
|
||||
Icon(
|
||||
Icons.error_outline,
|
||||
size: isLandscape ? 48 : 64,
|
||||
color: Colors.red.shade400,
|
||||
),
|
||||
SizedBox(height: isLandscape ? 12 : 20),
|
||||
Text(
|
||||
'Sinkronisasi Gagal',
|
||||
style: TextStyle(
|
||||
fontSize: isLandscape ? 16 : 20,
|
||||
fontWeight: FontWeight.bold,
|
||||
color: Colors.red.shade600,
|
||||
),
|
||||
),
|
||||
SizedBox(height: isLandscape ? 8 : 12),
|
||||
Container(
|
||||
padding: EdgeInsets.all(isLandscape ? 12 : 16),
|
||||
decoration: BoxDecoration(
|
||||
color: Colors.red.shade50,
|
||||
borderRadius: BorderRadius.circular(8),
|
||||
),
|
||||
child: Text(
|
||||
message,
|
||||
style: TextStyle(
|
||||
fontSize: isLandscape ? 12 : 14,
|
||||
color: Colors.red.shade700,
|
||||
),
|
||||
textAlign: TextAlign.center,
|
||||
),
|
||||
),
|
||||
SizedBox(height: isLandscape ? 12 : 20),
|
||||
Text(
|
||||
'Periksa koneksi internet dan coba lagi',
|
||||
style: TextStyle(
|
||||
fontSize: isLandscape ? 12 : 14,
|
||||
color: Colors.grey.shade600,
|
||||
),
|
||||
textAlign: TextAlign.center,
|
||||
),
|
||||
],
|
||||
);
|
||||
}
|
||||
|
||||
Widget _buildStatItem(String label, String value, IconData icon, Color color,
|
||||
bool isLandscape) {
|
||||
if (isLandscape) {
|
||||
// Horizontal layout for landscape
|
||||
return Container(
|
||||
padding: EdgeInsets.symmetric(horizontal: 12, vertical: 8),
|
||||
decoration: BoxDecoration(
|
||||
color: color.withOpacity(0.1),
|
||||
borderRadius: BorderRadius.circular(8),
|
||||
),
|
||||
child: Row(
|
||||
mainAxisSize: MainAxisSize.min,
|
||||
children: [
|
||||
Icon(icon, size: 20, color: color),
|
||||
SizedBox(width: 8),
|
||||
Column(
|
||||
crossAxisAlignment: CrossAxisAlignment.start,
|
||||
children: [
|
||||
Text(
|
||||
value,
|
||||
style: TextStyle(
|
||||
fontSize: 16,
|
||||
fontWeight: FontWeight.bold,
|
||||
color: color,
|
||||
),
|
||||
),
|
||||
Text(
|
||||
label,
|
||||
style: TextStyle(
|
||||
fontSize: 10,
|
||||
color: Colors.grey.shade600,
|
||||
),
|
||||
),
|
||||
],
|
||||
),
|
||||
],
|
||||
),
|
||||
);
|
||||
} else {
|
||||
// Vertical layout for portrait
|
||||
return Column(
|
||||
children: [
|
||||
Container(
|
||||
padding: EdgeInsets.all(12),
|
||||
decoration: BoxDecoration(
|
||||
color: color.withOpacity(0.1),
|
||||
borderRadius: BorderRadius.circular(8),
|
||||
),
|
||||
child: Icon(icon, size: 24, color: color),
|
||||
),
|
||||
SizedBox(height: 8),
|
||||
Text(
|
||||
value,
|
||||
style: TextStyle(
|
||||
fontSize: 18,
|
||||
fontWeight: FontWeight.bold,
|
||||
color: color,
|
||||
),
|
||||
),
|
||||
Text(
|
||||
label,
|
||||
style: TextStyle(
|
||||
fontSize: 12,
|
||||
color: Colors.grey.shade600,
|
||||
),
|
||||
),
|
||||
],
|
||||
);
|
||||
}
|
||||
}
|
||||
|
||||
Widget _buildActions(DataSyncState state) {
|
||||
return state.when(
|
||||
initial: () => Button.filled(
|
||||
onPressed: () {
|
||||
context.read<DataSyncBloc>().add(const DataSyncEvent.startSync());
|
||||
},
|
||||
label: 'Mulai Sinkronisasi',
|
||||
),
|
||||
syncing: (step, progress, message) => Button.outlined(
|
||||
onPressed: () {
|
||||
context.read<DataSyncBloc>().add(const DataSyncEvent.cancelSync());
|
||||
},
|
||||
label: 'Batalkan',
|
||||
),
|
||||
completed: (stats) => Button.filled(
|
||||
onPressed: () {
|
||||
context.pushReplacement(DashboardPage());
|
||||
},
|
||||
label: 'Lanjutkan ke Aplikasi',
|
||||
),
|
||||
error: (message) => Row(
|
||||
children: [
|
||||
Expanded(
|
||||
child: Button.outlined(
|
||||
onPressed: () {
|
||||
context.pushReplacement(DashboardPage());
|
||||
},
|
||||
label: 'Lewati',
|
||||
),
|
||||
),
|
||||
SizedBox(width: 16),
|
||||
Expanded(
|
||||
child: Button.filled(
|
||||
onPressed: () {
|
||||
context
|
||||
.read<DataSyncBloc>()
|
||||
.add(const DataSyncEvent.startSync());
|
||||
},
|
||||
label: 'Coba Lagi',
|
||||
),
|
||||
),
|
||||
],
|
||||
),
|
||||
);
|
||||
}
|
||||
|
||||
IconData _getSyncIcon(SyncStep step) {
|
||||
switch (step) {
|
||||
case SyncStep.products:
|
||||
return Icons.inventory_2;
|
||||
case SyncStep.categories:
|
||||
return Icons.category;
|
||||
case SyncStep.variants:
|
||||
return Icons.tune;
|
||||
case SyncStep.completed:
|
||||
return Icons.check_circle;
|
||||
}
|
||||
}
|
||||
|
||||
String _getStepLabel(SyncStep step) {
|
||||
switch (step) {
|
||||
case SyncStep.products:
|
||||
return 'Mengunduh Produk';
|
||||
case SyncStep.categories:
|
||||
return 'Mengunduh Kategori';
|
||||
case SyncStep.variants:
|
||||
return 'Mengunduh Variant';
|
||||
case SyncStep.completed:
|
||||
return 'Selesai';
|
||||
}
|
||||
}
|
||||
}
|
||||
@ -1,8 +1,8 @@
|
||||
import 'dart:async';
|
||||
|
||||
import 'package:bloc/bloc.dart';
|
||||
import 'package:enaklo_pos/data/datasources/product_remote_datasource.dart';
|
||||
import 'dart:developer';
|
||||
import 'package:enaklo_pos/data/models/response/product_response_model.dart';
|
||||
import 'package:enaklo_pos/data/repositories/product/product_repository.dart';
|
||||
import 'package:flutter_bloc/flutter_bloc.dart';
|
||||
import 'package:freezed_annotation/freezed_annotation.dart';
|
||||
|
||||
part 'product_loader_event.dart';
|
||||
@ -10,102 +10,114 @@ part 'product_loader_state.dart';
|
||||
part 'product_loader_bloc.freezed.dart';
|
||||
|
||||
class ProductLoaderBloc extends Bloc<ProductLoaderEvent, ProductLoaderState> {
|
||||
final ProductRemoteDatasource _productRemoteDatasource;
|
||||
final ProductRepository _productRepository = ProductRepository.instance;
|
||||
|
||||
// Debouncing untuk mencegah multiple load more calls
|
||||
Timer? _loadMoreDebounce;
|
||||
Timer? _searchDebounce;
|
||||
bool _isLoadingMore = false;
|
||||
|
||||
ProductLoaderBloc(this._productRemoteDatasource)
|
||||
: super(ProductLoaderState.initial()) {
|
||||
ProductLoaderBloc() : super(const ProductLoaderState.initial()) {
|
||||
on<_GetProduct>(_onGetProduct);
|
||||
on<_LoadMore>(_onLoadMore);
|
||||
on<_Refresh>(_onRefresh);
|
||||
on<_SearchProduct>(_onSearchProduct);
|
||||
on<_GetDatabaseStats>(_onGetDatabaseStats);
|
||||
on<_ClearCache>(_onClearCache);
|
||||
}
|
||||
|
||||
@override
|
||||
Future<void> close() {
|
||||
_loadMoreDebounce?.cancel();
|
||||
_searchDebounce?.cancel();
|
||||
return super.close();
|
||||
}
|
||||
|
||||
// Debounce transformer untuk load more
|
||||
// EventTransformer<T> _debounceTransformer<T>() {
|
||||
// return (events, mapper) {
|
||||
// return events
|
||||
// .debounceTime(const Duration(milliseconds: 300))
|
||||
// .asyncExpand(mapper);
|
||||
// };
|
||||
// }
|
||||
|
||||
// Initial load
|
||||
// Pure local product loading
|
||||
Future<void> _onGetProduct(
|
||||
_GetProduct event,
|
||||
Emitter<ProductLoaderState> emit,
|
||||
) async {
|
||||
emit(const _Loading());
|
||||
_isLoadingMore = false; // Reset loading state
|
||||
emit(const ProductLoaderState.loading());
|
||||
_isLoadingMore = false;
|
||||
|
||||
final result = await _productRemoteDatasource.getProducts(
|
||||
log('📱 Loading local products - categoryId: ${event.categoryId}');
|
||||
|
||||
// Check if local database is ready
|
||||
final isReady = await _productRepository.isLocalDatabaseReady();
|
||||
if (!isReady) {
|
||||
emit(const ProductLoaderState.error(
|
||||
'Database lokal belum siap. Silakan lakukan sinkronisasi data terlebih dahulu.'));
|
||||
return;
|
||||
}
|
||||
|
||||
final result = await _productRepository.getProducts(
|
||||
page: 1,
|
||||
limit: 10,
|
||||
categoryId: event.categoryId,
|
||||
search: event.search,
|
||||
);
|
||||
|
||||
await result.fold(
|
||||
(failure) async => emit(_Error(failure)),
|
||||
(failure) async {
|
||||
log('❌ Error loading local products: $failure');
|
||||
emit(ProductLoaderState.error(failure));
|
||||
},
|
||||
(response) async {
|
||||
final products = response.data?.products ?? [];
|
||||
final hasReachedMax = products.length < 10;
|
||||
final totalPages = response.data?.totalPages ?? 1;
|
||||
final hasReachedMax = products.length < 10 || 1 >= totalPages;
|
||||
|
||||
emit(_Loaded(
|
||||
log('âś… Local products loaded: ${products.length}, hasReachedMax: $hasReachedMax, totalPages: $totalPages');
|
||||
|
||||
emit(ProductLoaderState.loaded(
|
||||
products: products,
|
||||
hasReachedMax: hasReachedMax,
|
||||
currentPage: 1,
|
||||
isLoadingMore: false,
|
||||
categoryId: event.categoryId,
|
||||
searchQuery: event.search,
|
||||
));
|
||||
},
|
||||
);
|
||||
}
|
||||
|
||||
// Load more with enhanced debouncing
|
||||
// Pure local load more
|
||||
Future<void> _onLoadMore(
|
||||
_LoadMore event,
|
||||
Emitter<ProductLoaderState> emit,
|
||||
) async {
|
||||
final currentState = state;
|
||||
|
||||
// Enhanced validation
|
||||
if (currentState is! _Loaded ||
|
||||
currentState.hasReachedMax ||
|
||||
_isLoadingMore ||
|
||||
currentState.isLoadingMore) {
|
||||
log('⏹️ Load more blocked - state: ${currentState.runtimeType}, isLoadingMore: $_isLoadingMore');
|
||||
return;
|
||||
}
|
||||
|
||||
_isLoadingMore = true;
|
||||
|
||||
// Emit loading more state
|
||||
emit(currentState.copyWith(isLoadingMore: true));
|
||||
|
||||
final nextPage = currentState.currentPage + 1;
|
||||
log('đź“„ Loading more local products - page: $nextPage');
|
||||
|
||||
try {
|
||||
final result = await _productRemoteDatasource.getProducts(
|
||||
final result = await _productRepository.getProducts(
|
||||
page: nextPage,
|
||||
limit: 10,
|
||||
categoryId: event.categoryId,
|
||||
categoryId: currentState.categoryId,
|
||||
search: currentState.searchQuery,
|
||||
);
|
||||
|
||||
await result.fold(
|
||||
(failure) async {
|
||||
// On error, revert loading state but don't show error
|
||||
// Just silently fail and allow retry
|
||||
log('❌ Error loading more local products: $failure');
|
||||
emit(currentState.copyWith(isLoadingMore: false));
|
||||
_isLoadingMore = false;
|
||||
},
|
||||
(response) async {
|
||||
final newProducts = response.data?.products ?? [];
|
||||
final totalPages = response.data?.totalPages ?? 1;
|
||||
|
||||
// Prevent duplicate products
|
||||
final currentProductIds =
|
||||
@ -117,32 +129,130 @@ class ProductLoaderBloc extends Bloc<ProductLoaderEvent, ProductLoaderState> {
|
||||
final allProducts = List<Product>.from(currentState.products)
|
||||
..addAll(filteredNewProducts);
|
||||
|
||||
final hasReachedMax = newProducts.length < 10;
|
||||
final hasReachedMax =
|
||||
newProducts.length < 10 || nextPage >= totalPages;
|
||||
|
||||
emit(_Loaded(
|
||||
log('âś… More local products loaded: ${filteredNewProducts.length} new, total: ${allProducts.length}');
|
||||
|
||||
emit(ProductLoaderState.loaded(
|
||||
products: allProducts,
|
||||
hasReachedMax: hasReachedMax,
|
||||
currentPage: nextPage,
|
||||
isLoadingMore: false,
|
||||
categoryId: currentState.categoryId,
|
||||
searchQuery: currentState.searchQuery,
|
||||
));
|
||||
|
||||
_isLoadingMore = false;
|
||||
},
|
||||
);
|
||||
} catch (e) {
|
||||
// Handle unexpected errors
|
||||
log('❌ Exception loading more local products: $e');
|
||||
emit(currentState.copyWith(isLoadingMore: false));
|
||||
} finally {
|
||||
_isLoadingMore = false;
|
||||
}
|
||||
}
|
||||
|
||||
// Refresh data
|
||||
// Pure local refresh
|
||||
Future<void> _onRefresh(
|
||||
_Refresh event,
|
||||
Emitter<ProductLoaderState> emit,
|
||||
) async {
|
||||
final currentState = state;
|
||||
String? categoryId;
|
||||
String? searchQuery;
|
||||
|
||||
if (currentState is _Loaded) {
|
||||
categoryId = currentState.categoryId;
|
||||
searchQuery = currentState.searchQuery;
|
||||
}
|
||||
|
||||
_isLoadingMore = false;
|
||||
_loadMoreDebounce?.cancel();
|
||||
add(const _GetProduct());
|
||||
_searchDebounce?.cancel();
|
||||
|
||||
log('🔄 Refreshing local products');
|
||||
|
||||
// Clear local cache
|
||||
_productRepository.clearCache();
|
||||
|
||||
add(ProductLoaderEvent.getProduct(
|
||||
categoryId: categoryId,
|
||||
search: searchQuery,
|
||||
));
|
||||
}
|
||||
|
||||
// Fast local search (no debouncing needed for local data)
|
||||
Future<void> _onSearchProduct(
|
||||
_SearchProduct event,
|
||||
Emitter<ProductLoaderState> emit,
|
||||
) async {
|
||||
// Cancel previous search
|
||||
_searchDebounce?.cancel();
|
||||
|
||||
// Minimal debounce for local search (much faster)
|
||||
_searchDebounce = Timer(Duration(milliseconds: 150), () async {
|
||||
emit(const ProductLoaderState.loading());
|
||||
_isLoadingMore = false;
|
||||
|
||||
log('🔍 Local search: "${event.query}"');
|
||||
|
||||
final result = await _productRepository.getProducts(
|
||||
page: 1,
|
||||
limit: 20, // More results for search
|
||||
categoryId: event.categoryId,
|
||||
search: event.query,
|
||||
);
|
||||
|
||||
await result.fold(
|
||||
(failure) async {
|
||||
log('❌ Local search error: $failure');
|
||||
emit(ProductLoaderState.error(failure));
|
||||
},
|
||||
(response) async {
|
||||
final products = response.data?.products ?? [];
|
||||
final totalPages = response.data?.totalPages ?? 1;
|
||||
final hasReachedMax = products.length < 20 || 1 >= totalPages;
|
||||
|
||||
log('âś… Local search results: ${products.length} products found');
|
||||
|
||||
emit(ProductLoaderState.loaded(
|
||||
products: products,
|
||||
hasReachedMax: hasReachedMax,
|
||||
currentPage: 1,
|
||||
isLoadingMore: false,
|
||||
categoryId: event.categoryId,
|
||||
searchQuery: event.query,
|
||||
));
|
||||
},
|
||||
);
|
||||
});
|
||||
}
|
||||
|
||||
// Get local database statistics
|
||||
Future<void> _onGetDatabaseStats(
|
||||
_GetDatabaseStats event,
|
||||
Emitter<ProductLoaderState> emit,
|
||||
) async {
|
||||
try {
|
||||
final stats = await _productRepository.getDatabaseStats();
|
||||
log('đź“Š Local database stats retrieved: $stats');
|
||||
|
||||
// You can emit a special state here if needed for UI updates
|
||||
// For now, just log the stats
|
||||
} catch (e) {
|
||||
log('❌ Error getting local database stats: $e');
|
||||
}
|
||||
}
|
||||
|
||||
// Clear local cache
|
||||
Future<void> _onClearCache(
|
||||
_ClearCache event,
|
||||
Emitter<ProductLoaderState> emit,
|
||||
) async {
|
||||
log('🧹 Manually clearing local cache');
|
||||
_productRepository.clearCache();
|
||||
|
||||
// Refresh current data after cache clear
|
||||
add(const ProductLoaderEvent.refresh());
|
||||
}
|
||||
}
|
||||
|
||||
File diff suppressed because it is too large
Load Diff
@ -2,9 +2,25 @@ part of 'product_loader_bloc.dart';
|
||||
|
||||
@freezed
|
||||
class ProductLoaderEvent with _$ProductLoaderEvent {
|
||||
const factory ProductLoaderEvent.getProduct(
|
||||
{String? categoryId, String? search}) = _GetProduct;
|
||||
const factory ProductLoaderEvent.loadMore(
|
||||
{String? categoryId, String? search}) = _LoadMore;
|
||||
const factory ProductLoaderEvent.getProduct({
|
||||
String? categoryId,
|
||||
String? search, // Added search parameter
|
||||
bool? forceRefresh, // Kept for compatibility but ignored
|
||||
}) = _GetProduct;
|
||||
|
||||
const factory ProductLoaderEvent.loadMore({
|
||||
String? categoryId,
|
||||
String? search,
|
||||
}) = _LoadMore;
|
||||
|
||||
const factory ProductLoaderEvent.refresh() = _Refresh;
|
||||
|
||||
const factory ProductLoaderEvent.searchProduct({
|
||||
String? query,
|
||||
String? categoryId,
|
||||
}) = _SearchProduct;
|
||||
|
||||
const factory ProductLoaderEvent.getDatabaseStats() = _GetDatabaseStats;
|
||||
|
||||
const factory ProductLoaderEvent.clearCache() = _ClearCache;
|
||||
}
|
||||
|
||||
@ -9,6 +9,8 @@ class ProductLoaderState with _$ProductLoaderState {
|
||||
required bool hasReachedMax,
|
||||
required int currentPage,
|
||||
required bool isLoadingMore,
|
||||
String? categoryId,
|
||||
String? searchQuery,
|
||||
}) = _Loaded;
|
||||
const factory ProductLoaderState.error(String message) = _Error;
|
||||
}
|
||||
|
||||
File diff suppressed because it is too large
Load Diff
@ -1030,7 +1030,7 @@ packages:
|
||||
source: hosted
|
||||
version: "2.1.1"
|
||||
path:
|
||||
dependency: transitive
|
||||
dependency: "direct main"
|
||||
description:
|
||||
name: path
|
||||
sha256: "75cca69d1490965be98c73ceaea117e8a04dd21217b37b292c9ddbec0d955bc5"
|
||||
|
||||
@ -69,6 +69,7 @@ dependencies:
|
||||
syncfusion_flutter_datepicker: ^30.2.5
|
||||
firebase_core: ^4.1.0
|
||||
firebase_crashlytics: ^5.0.1
|
||||
path: ^1.9.1
|
||||
# imin_printer: ^0.6.10
|
||||
|
||||
dev_dependencies:
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user