Function SlaveRPCSignRequired

middleware/cluster.go:50–75

()

}

func SlaveRPCSignRequired() gin.HandlerFunc {
	return func(c *gin.Context) {
		nodeId := cluster.NodeIdFromContext(c)
		if nodeId == 0 {
			c.JSON(200, serializer.ParamErr(c, "Unknown node ID", nil))
			c.Abort()
			return
		}

		np, err := dependency.FromContext(c).NodePool(c)
		if err != nil {
			c.JSON(200, serializer.NewError(serializer.CodeInternalSetting, "Failed to get node pool", err))
			c.Abort()
			return
		}

		slaveNode, err := np.Get(c, types.NodeCapabilityNone, nodeId)
		if slaveNode == nil || slaveNode.IsMaster() {
			c.JSON(200, serializer.ParamErr(c, "Unknown node ID", err))
			c.Abort()
			return
		}

		SignRequired(slaveNode.AuthInstance())(c)
	}
}