Function getGenesisSyncData

server/controller/http/router/debug.go:231–309

(g *genesis.Genesis, isLocal bool)

}

func getGenesisSyncData(g *genesis.Genesis, isLocal bool) gin.HandlerFunc {
	return gin.HandlerFunc(func(c *gin.Context) {
		orgID, err := routercommon.GetContextOrgID(c)
		if err != nil {
			response.JSON(c, response.SetOptStatus(httpcommon.ORG_ID_INVALID), response.SetError(err))
			return
		}
		dataType := c.Param("type")
		var ret gcommon.GenesisSyncDataResponse

		if isLocal {
			ret, err = service.GetGenesisData(orgID, g)
		} else {
			ret, err = service.GetGenesisSyncData(orgID, g)
		}

		var data interface{}
		switch dataType {
		case "vm":
			data = ret.VMs
		case "vpc":
			data = ret.VPCs
		case "host":
			data = ret.Hosts
		case "lldp":
			data = ret.Lldps
		case "port":
			data = ret.Ports
		case "network":
			data = ret.Networks
		case "ip":
			data = ret.IPLastSeens
		case "vinterface":
			teamIDList := map[uint32]bool{}
			teamIDs, _ := c.GetQueryArray("team_id")
			for _, t := range teamIDs {
				teamID, err := strconv.Atoi(t)
				if err != nil {
					log.Warningf(err.Error())
					continue
				}
				teamIDList[uint32(teamID)] = false
			}

			filterType := c.Query("team_id_filter")
			switch filterType {
			case "":
				data = ret.Vinterfaces
			case "whitelist":
				retVinterfaces := []model.GenesisVinterface{}
				for _, v := range ret.Vinterfaces {
					if _, ok := teamIDList[v.TeamID]; !ok {
						continue
					}
					retVinterfaces = append(retVinterfaces, v)
				}
				data = retVinterfaces
			case "blacklist":