Remove tweets which vanished on refresh

Signed-off-by: Knut Ahlers <knut@ahlers.me>

frontend/app.js

@@ -28,20 +28,7 @@ new Vue({
     deleteTweet(tweet) {
       axios
         .delete(`/api/${tweet.id}`)
-        .then(() => {
+        .then(() => this.removeTweet(tweet.id))
-          const tweets = []
-
-          for (const i in this.tweets) {
-            const t = this.tweets[i]
-            if (t.id === tweet.id) {
-              continue
-            }
-
-            tweets.push(t)
-          }
-
-          this.tweets = tweets
-        })
         .catch(err => console.log(err))
     },
 
@@ -71,6 +58,10 @@ new Vue({
       axios
         .put(`/api/${tweet.id}/refresh`)
         .then(res => {
+          if (res.data.gone) {
+            return this.removeTweet(tweet.id)
+          }
+
           if (res.data.length === 0) {
             return
           }
@@ -82,8 +73,10 @@ new Vue({
 
     refresh(forceReload = false) {
       let apiURL = '/api/page' // By default query page 1
+      let append = false
       if (this.tweets.length > 0 && !forceReload) {
         apiURL = `/api/since?id=${this.tweets[0].id}`
+        append = true
       }
 
       axios
@@ -93,13 +86,28 @@ new Vue({
             return
           }
 
-          this.upsertTweets(resp.data)
+          this.upsertTweets(resp.data, append)
         })
         .catch(err => {
           console.log(err)
         })
     },
 
+    removeTweet(id) {
+      const tweets = []
+
+      for (const i in this.tweets) {
+        const t = this.tweets[i]
+        if (t.id === id) {
+          continue
+        }
+
+        tweets.push(t)
+      }
+
+      this.tweets = tweets
+    },
+
     triggerForceFetch() {
       axios
         .put('/api/force-reload')
@@ -110,8 +118,8 @@ new Vue({
         .catch(err => console.log(err))
     },
 
-    upsertTweets(data) {
+    upsertTweets(data, append = true) {
-      let tweets = this.tweets
+      let tweets = append ? this.tweets : []
 
       for (const idx in data) {
         const tweet = data[idx]

http.go

@@ -124,7 +124,9 @@ func handleTweetRefresh(w http.ResponseWriter, r *http.Request) {
 			if err = tweetStore.DeleteTweetByID(uint64(tweetID)); err != nil {
 				log.WithError(err).Error("Unable to delete tweet")
 				http.Error(w, "Something went wrong", http.StatusInternalServerError)
+				return
 			}
+			jsonResponse(w, map[string]bool{"gone": true})
 			return
 		}
 
@@ -151,9 +153,13 @@ func handleTweetRefresh(w http.ResponseWriter, r *http.Request) {
 
 // tweetResponse is a generic wrapper to return a list of tweets through JSON
 func tweetResponse(w http.ResponseWriter, tweets []tweet) {
+	jsonResponse(w, tweets)
+}
+
+func jsonResponse(w http.ResponseWriter, data interface{}) {
 	w.Header().Set("Content-Type", "application/json")
 	w.Header().Set("Cache-Control", "no-cache")
 	w.WriteHeader(http.StatusOK)
 
-	json.NewEncoder(w).Encode(tweets)
+	json.NewEncoder(w).Encode(data)
 }