39 lines
899 B
Go
Executable File
39 lines
899 B
Go
Executable File
package router
|
|
|
|
import (
|
|
"github.com/gin-gonic/gin"
|
|
"io.wdd.message_pusher/cmii"
|
|
"net/http"
|
|
)
|
|
|
|
func ImageSyncRouter(r *gin.Engine) {
|
|
octopusGroup := r.Group("/image")
|
|
{
|
|
octopusGroup.POST("/sync", ImageSync)
|
|
}
|
|
}
|
|
|
|
// ImageSync godoc
|
|
// @Summary 镜像同步消息
|
|
// @Schemes
|
|
// @Description response to cmii update notification
|
|
// @Tags ImageSync
|
|
// @Accept json
|
|
// @Produce json
|
|
// @Param body body cmii.ImageSyncMessage true "请求体"
|
|
// @Success 200 {object} pusher.Message
|
|
// @Router /image/sync [post]
|
|
func ImageSync(c *gin.Context) {
|
|
// 获取请求中的参数
|
|
var imageSyncMessage cmii.ImageSyncMessage
|
|
if err := c.ShouldBindJSON(&imageSyncMessage); err != nil {
|
|
c.JSON(http.StatusBadRequest, gin.H{"error": "Invalid request body"})
|
|
return
|
|
}
|
|
// 处理请求
|
|
upgradeMessage := imageSyncMessage.PublishMessage()
|
|
|
|
// *pusher.Message
|
|
c.JSON(http.StatusOK, upgradeMessage)
|
|
}
|