insertPendingUpload method

Future<void> insertPendingUpload({
  1. required String payload,
  2. required String url,
  3. String? accessToken,
  4. Map<String, String>? customHeaders,
})

Implementation

Future<void> insertPendingUpload({
  required String payload,
  required String url,
  String? accessToken,
  Map<String, String>? customHeaders,
}) async {
  final db = await database;
  final now = DateTime.now();
  await db.insert('pending_uploads', {
    'payload': payload,
    'url': url,
    'access_token': accessToken,
    'custom_headers': customHeaders != null ? jsonEncode(customHeaders) : null,
    'attempts': 0,
    'next_retry_at': now.add(const Duration(minutes: 1)).toIso8601String(),
    'created_at': now.toIso8601String(),
  });
}