PACKET v1.0.0 - Initial release
App móvil Flutter para capturar contenido multimedia, etiquetarlo con hashes y enviarlo a backends configurables. Features: - Captura de fotos, audio, video y archivos - Sistema de etiquetas con bibliotecas externas (HST) - Packs de etiquetas predefinidos - Cola de reintentos (hasta 20 contenedores) - Soporte GPS - Hash SHA-256 auto-generado por contenedor - Persistencia SQLite local - Múltiples destinos configurables Stack: Flutter 3.38.5, flutter_bloc, sqflite, dio 🤖 Generated with [Claude Code](https://claude.com/claude-code) Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
This commit is contained in:
129
lib/data/repositories/contenedor_repository.dart
Normal file
129
lib/data/repositories/contenedor_repository.dart
Normal file
@@ -0,0 +1,129 @@
|
||||
import 'dart:convert';
|
||||
import 'dart:typed_data';
|
||||
import '../datasources/local_database.dart';
|
||||
import '../datasources/backend_api.dart';
|
||||
import '../../core/constants/app_constants.dart';
|
||||
import '../../core/errors/exceptions.dart';
|
||||
import '../../core/utils/retry_utils.dart';
|
||||
import '../../domain/entities/contenedor.dart';
|
||||
import '../../domain/entities/destino.dart';
|
||||
import '../../domain/entities/pendiente.dart';
|
||||
|
||||
class ContenedorRepository {
|
||||
final BackendApi _api = BackendApi();
|
||||
|
||||
Future<Map<String, dynamic>> enviar(Contenedor contenedor, Destino destino) async {
|
||||
try {
|
||||
final result = await _api.enviarContenedor(contenedor, destino);
|
||||
await _registrarEnvio(contenedor, destino, result);
|
||||
return result;
|
||||
} catch (e) {
|
||||
await _agregarAPendientes(contenedor, destino);
|
||||
rethrow;
|
||||
}
|
||||
}
|
||||
|
||||
Future<void> _registrarEnvio(
|
||||
Contenedor contenedor,
|
||||
Destino destino,
|
||||
Map<String, dynamic> response,
|
||||
) async {
|
||||
final db = await LocalDatabase.database;
|
||||
await db.insert('registro', {
|
||||
'hash': contenedor.hash,
|
||||
'titulo': contenedor.titulo,
|
||||
'hora_envio': DateTime.now().toIso8601String(),
|
||||
'primera_conf': response['received_at'],
|
||||
'ultima_conf': response['received_at'],
|
||||
'destino_id': destino.id,
|
||||
});
|
||||
}
|
||||
|
||||
// Pendientes
|
||||
Future<void> _agregarAPendientes(Contenedor contenedor, Destino destino) async {
|
||||
final count = await getPendientesCount();
|
||||
if (count >= AppConstants.maxPendientes) {
|
||||
throw QueueFullException();
|
||||
}
|
||||
|
||||
final db = await LocalDatabase.database;
|
||||
final contenidoJson = jsonEncode(contenedor.toJson());
|
||||
|
||||
await db.insert('pendientes', {
|
||||
'hash': contenedor.hash,
|
||||
'titulo': contenedor.titulo,
|
||||
'contenido': Uint8List.fromList(utf8.encode(contenidoJson)),
|
||||
'intentos': 1,
|
||||
'ultimo_intento': DateTime.now().toIso8601String(),
|
||||
'proximo_intento': RetryUtils.calculateNextRetry(1).toIso8601String(),
|
||||
'destino_id': destino.id,
|
||||
});
|
||||
}
|
||||
|
||||
Future<int> getPendientesCount() async {
|
||||
final db = await LocalDatabase.database;
|
||||
final result = await db.rawQuery('SELECT COUNT(*) as count FROM pendientes');
|
||||
return result.first['count'] as int;
|
||||
}
|
||||
|
||||
Future<List<Pendiente>> getPendientes() async {
|
||||
final db = await LocalDatabase.database;
|
||||
final results = await db.query('pendientes', orderBy: 'ultimo_intento DESC');
|
||||
return results.map((m) => Pendiente.fromMap(m)).toList();
|
||||
}
|
||||
|
||||
Future<void> reintentar(Pendiente pendiente, Destino destino) async {
|
||||
if (!pendiente.puedeReintentar) return;
|
||||
|
||||
final db = await LocalDatabase.database;
|
||||
final contenidoStr = utf8.decode(pendiente.contenido);
|
||||
final contenidoJson = jsonDecode(contenidoStr) as Map<String, dynamic>;
|
||||
|
||||
// Reconstruct basic contenedor for retry
|
||||
final contenedor = Contenedor(
|
||||
hash: contenidoJson['hash'] as String,
|
||||
titulo: contenidoJson['titulo'] as String?,
|
||||
descripcion: contenidoJson['descripcion'] as String?,
|
||||
etiquetas: (contenidoJson['etiquetas'] as List<dynamic>?)
|
||||
?.map((e) => e as String)
|
||||
.toList() ??
|
||||
[],
|
||||
);
|
||||
|
||||
try {
|
||||
await _api.enviarContenedor(contenedor, destino);
|
||||
await db.delete('pendientes', where: 'hash = ?', whereArgs: [pendiente.hash]);
|
||||
} catch (e) {
|
||||
final nuevoIntento = pendiente.intentos + 1;
|
||||
if (nuevoIntento >= AppConstants.maxReintentos) {
|
||||
// Keep in queue but mark as exhausted
|
||||
await db.update(
|
||||
'pendientes',
|
||||
{
|
||||
'intentos': nuevoIntento,
|
||||
'ultimo_intento': DateTime.now().toIso8601String(),
|
||||
'proximo_intento': null,
|
||||
},
|
||||
where: 'hash = ?',
|
||||
whereArgs: [pendiente.hash],
|
||||
);
|
||||
} else {
|
||||
await db.update(
|
||||
'pendientes',
|
||||
{
|
||||
'intentos': nuevoIntento,
|
||||
'ultimo_intento': DateTime.now().toIso8601String(),
|
||||
'proximo_intento': RetryUtils.calculateNextRetry(nuevoIntento).toIso8601String(),
|
||||
},
|
||||
where: 'hash = ?',
|
||||
whereArgs: [pendiente.hash],
|
||||
);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
Future<void> eliminarPendiente(String hash) async {
|
||||
final db = await LocalDatabase.database;
|
||||
await db.delete('pendientes', where: 'hash = ?', whereArgs: [hash]);
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user