gistfile1.txt

private func processQueueIfNeeded() async {
    guard !isProcessing else { return }
    isProcessing = true
    defer { isProcessing = false }

    while let nextJob = fetchNextOutstandingJobSnapshot() {
        do {
            try withJob(nextJob.id) { _, job in
                job.state = .uploading
                job.attempts += 1
                job.lastError = nil
                job.updatedAt = .now
            }

            try await submitLevel4Tweet(text: nextJob.text)
            try withJob(nextJob.id) { context, job in context.delete(job) }

        } catch {
            try? withJob(nextJob.id) { _, job in
                job.state = .failed
                job.lastError = error.localizedDescription
                job.updatedAt = .now
            }
        }
    }
}