Skip to content

phsl / new-api

Go to a project
Commit da8917a1 by CaIon
Options

refactor: initialize channel cache after channel operations to ensure data consistency

parent 9660b22c
Showing with 9 additions and 4 deletions
controller/channel.go
...@@ -528,6 +528,7 @@ func DeleteChannel(c *gin.Context) { ...@@ -528,6 +528,7 @@ func DeleteChannel(c *gin.Context) {
common.ApiError(c, err) common.ApiError(c, err)
return return
} }
model.InitChannelCache()
c.JSON(http.StatusOK, gin.H{ c.JSON(http.StatusOK, gin.H{
"success": true, "success": true,
"message": "", "message": "",
...@@ -541,6 +542,7 @@ func DeleteDisabledChannel(c *gin.Context) { ...@@ -541,6 +542,7 @@ func DeleteDisabledChannel(c *gin.Context) {
common.ApiError(c, err) common.ApiError(c, err)
return return
} }
model.InitChannelCache()
c.JSON(http.StatusOK, gin.H{ c.JSON(http.StatusOK, gin.H{
"success": true, "success": true,
"message": "", "message": "",
...@@ -574,6 +576,7 @@ func DisableTagChannels(c *gin.Context) { ...@@ -574,6 +576,7 @@ func DisableTagChannels(c *gin.Context) {
common.ApiError(c, err) common.ApiError(c, err)
return return
} }
model.InitChannelCache()
c.JSON(http.StatusOK, gin.H{ c.JSON(http.StatusOK, gin.H{
"success": true, "success": true,
"message": "", "message": "",
...@@ -596,6 +599,7 @@ func EnableTagChannels(c *gin.Context) { ...@@ -596,6 +599,7 @@ func EnableTagChannels(c *gin.Context) {
common.ApiError(c, err) common.ApiError(c, err)
return return
} }
model.InitChannelCache()
c.JSON(http.StatusOK, gin.H{ c.JSON(http.StatusOK, gin.H{
"success": true, "success": true,
"message": "", "message": "",
...@@ -625,6 +629,7 @@ func EditTagChannels(c *gin.Context) { ...@@ -625,6 +629,7 @@ func EditTagChannels(c *gin.Context) {
common.ApiError(c, err) common.ApiError(c, err)
return return
} }
model.InitChannelCache()
c.JSON(http.StatusOK, gin.H{ c.JSON(http.StatusOK, gin.H{
"success": true, "success": true,
"message": "", "message": "",
...@@ -652,6 +657,7 @@ func DeleteChannelBatch(c *gin.Context) { ...@@ -652,6 +657,7 @@ func DeleteChannelBatch(c *gin.Context) {
common.ApiError(c, err) common.ApiError(c, err)
return return
} }
model.InitChannelCache()
c.JSON(http.StatusOK, gin.H{ c.JSON(http.StatusOK, gin.H{
"success": true, "success": true,
"message": "", "message": "",
...@@ -703,9 +709,7 @@ func UpdateChannel(c *gin.Context) { ...@@ -703,9 +709,7 @@ func UpdateChannel(c *gin.Context) {
common.ApiError(c, err) common.ApiError(c, err)
return return
} }
if common.MemoryCacheEnabled { model.InitChannelCache()
model.InitChannelCache()
}
channel.Key = "" channel.Key = ""
c.JSON(http.StatusOK, gin.H{ c.JSON(http.StatusOK, gin.H{
"success": true, "success": true,
...@@ -811,6 +815,7 @@ func BatchSetChannelTag(c *gin.Context) { ...@@ -811,6 +815,7 @@ func BatchSetChannelTag(c *gin.Context) {
common.ApiError(c, err) common.ApiError(c, err)
return return
} }
model.InitChannelCache()
c.JSON(http.StatusOK, gin.H{ c.JSON(http.StatusOK, gin.H{
"success": true, "success": true,
"message": "", "message": "",
...@@ -905,7 +910,7 @@ func CopyChannel(c *gin.Context) { ...@@ -905,7 +910,7 @@ func CopyChannel(c *gin.Context) {
c.JSON(http.StatusOK, gin.H{"success": false, "message": err.Error()}) c.JSON(http.StatusOK, gin.H{"success": false, "message": err.Error()})
return return
} }
model.InitChannelCache()
// success // success
c.JSON(http.StatusOK, gin.H{"success": true, "message": "", "data": gin.H{"id": clone.Id}}) c.JSON(http.StatusOK, gin.H{"success": true, "message": "", "data": gin.H{"id": clone.Id}})
} }
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or sign in to comment