gistfile1.txt

func postTweet(
    text: String,
    strategy _: RetryStrategy,
    retryOptions _: RetryOptions
) async throws {
    await engine.enqueue(text: text)
}

func enqueue(text: String) async {
    let context = ModelContext(container)
    let job = PersistedUploadJob(text: text, state: .pending)
    context.insert(job)

    do {
        try context.save()
    } catch {
        print("Failed to persist job: \(error.localizedDescription)")
    }

    await processQueueIfNeeded()
}