throw on error so the net time the command runes the requests will be…

Sources/App/Commands/StackoverflowCommand.swift

@@ -1,4 +1,5 @@
 import Vapor
+import FluentPostgreSQL
 
 final class StackoverflowCommand: Command {
     var arguments: [CommandArgument] {
@@ -40,7 +41,18 @@ final class StackoverflowCommand: Command {
         guard let postingQuestion = questions.popLast()
             else { return .done(on:context.container) }
         return try webhookService.postContent(postingQuestion.link).flatMap { _ in
-            return try self.postNewQuestions(questions, context: context)
+            return try self.postNewQuestions(questions, context: context).catchFlatMap { err in
+                if let err = err as? DiscordError {
+                    return self.deleteUnpostedQuestion(err.link, context: context)
+                }
+                return .done(on: context.container)
+            }
+        }
+    }
+
+    private func deleteUnpostedQuestion(_ link: String, context: CommandContext) -> Future<Void>{
+        return context.container.withPooledConnection(to: .psql) { (conn) -> EventLoopFuture<Void> in
+             return StackOverflowQuestion.query(on: conn).filter(\.link == link).delete()
         }
     }
 }

Sources/App/Services/DiscordWebhookService.swift

@@ -1,19 +1,30 @@
 import Vapor
 
+struct DiscordError: Error {
+    let link: String
+}
+
 // Read more about discord webhooks here
 // https://discordapp.com/developers/docs/resources/webhook#execute-webhook
 struct DiscordWebhookService: Service {
     let client: Client
     let webhookUrl: String
     let logger: Logger
     let jsonEncoder: DataEncoder
-
+    
     func postContent(_ content: String) throws -> Future<Void> {
-        let content = DiscordWebhookPayload(content: content)
+        let payload = DiscordWebhookPayload(content: content)
         return client.post(webhookUrl, headers: HTTPHeaders()) { (req) in
-            req.http.body = try jsonEncoder.encode(content).convertToHTTPBody()
-        }.map(to: Void.self) { _ in
-            self.logger.info("Posted: \(content) response")
+            req.http.body = try jsonEncoder.encode(payload).convertToHTTPBody()
+        }.map(to: Void.self) { resp in
+            let code = resp.http.status.code
+            if code >= 200 && code < 300 {
+                self.logger.info("Posted: \(content) response")
+            } else if code == 429 {
+                throw DiscordError(link: content)
+            } else {
+                self.logger.error("Unhandled code receviced in DiscordWebhookService.postContent")
+            }
         }
     }
 }