V2bX/node/task.go

package node

import (
	"github.com/Yuzuki616/V2bX/common/task"
	vCore "github.com/Yuzuki616/V2bX/core"
	"github.com/Yuzuki616/V2bX/limiter"
	"log"
	"time"
)

func (c *Controller) initTask() {
	// fetch node info task
	c.nodeInfoMonitorPeriodic = &task.Task{
		Interval: c.nodeInfo.PullInterval,
		Execute:  c.nodeInfoMonitor,
	}
	// fetch user list task
	c.userReportPeriodic = &task.Task{
		Interval: c.nodeInfo.PushInterval,
		Execute:  c.reportUserTrafficTask,
	}
	log.Printf("[%s] Start monitor node status", c.Tag)
	// delay to start nodeInfoMonitor
	_ = c.nodeInfoMonitorPeriodic.Start(false)
	log.Printf("[%s] Start report node status", c.Tag)
	_ = c.userReportPeriodic.Start(false)
	if c.nodeInfo.Tls {
		switch c.CertConfig.CertMode {
		case "reality", "none", "":
		default:
			c.renewCertPeriodic = &task.Task{
				Interval: time.Hour * 24,
				Execute:  c.reportUserTrafficTask,
			}
			log.Printf("[%s] Start renew cert", c.Tag)
			// delay to start renewCert
			_ = c.renewCertPeriodic.Start(true)
		}
	}
}

func (c *Controller) nodeInfoMonitor() (err error) {
	// get node info
	newNodeInfo, err := c.apiClient.GetNodeInfo()
	if err != nil {
		log.Printf("[%s] Get node info error: %s", c.Tag, err)
		return nil
	}
	// get user info
	newUserInfo, err := c.apiClient.GetUserList()
	if err != nil {
		log.Printf("[%s] Get user list error: %s", c.Tag, err)
		return nil
	}
	if newNodeInfo != nil {
		// nodeInfo changed
		// Remove old tag
		log.Printf("[%s] Node changed, reload...", c.Tag)
		err = c.server.DelNode(c.Tag)
		if err != nil {
			log.Printf("[%s] Del node error: %s", c.Tag, err)
			return nil
		}
		// Remove Old limiter
		limiter.DeleteLimiter(c.Tag)
		// Add new Limiter
		c.Tag = c.buildNodeTag()
		l := limiter.AddLimiter(c.Tag, &c.LimitConfig, newUserInfo)
		// check cert
		if newNodeInfo.Tls || newNodeInfo.Type == "hysteria" {
			err = c.requestCert()
			if err != nil {
				log.Printf("[%s] Request cert error: %s", c.Tag, err)
			}
		}
		// add new node
		err = c.server.AddNode(c.Tag, newNodeInfo, c.ControllerConfig)
		if err != nil {
			log.Printf("[%s] Add node error: %s", c.Tag, err)
			return nil
		}
		_, err = c.server.AddUsers(&vCore.AddUsersParams{
			Tag:      c.Tag,
			Config:   c.ControllerConfig,
			UserInfo: newUserInfo,
			NodeInfo: newNodeInfo,
		})
		if err != nil {
			log.Printf("[%s] Add users error: %s", c.Tag, err)
			return nil
		}
		err = l.UpdateRule(newNodeInfo.Rules)
		if err != nil {
			log.Printf("[%s] Update Rule error: %s", c.Tag, err)
		}
		// Check interval
		if c.nodeInfoMonitorPeriodic.Interval != newNodeInfo.PullInterval &&
			newNodeInfo.PullInterval != 0 {
			c.nodeInfoMonitorPeriodic.Interval = newNodeInfo.PullInterval
			c.nodeInfoMonitorPeriodic.Close()
			_ = c.nodeInfoMonitorPeriodic.Start(false)
		}
		if c.userReportPeriodic.Interval != newNodeInfo.PushInterval &&
			newNodeInfo.PushInterval != 0 {
			c.userReportPeriodic.Interval = newNodeInfo.PullInterval
			c.userReportPeriodic.Close()
			_ = c.userReportPeriodic.Start(false)
		}
		c.nodeInfo = newNodeInfo
		c.userList = newUserInfo
		log.Printf("[%s] Added %d new users", c.Tag, len(newUserInfo))
		// exit
		return nil
	}

	// node no changed, check users
	deleted, added := compareUserList(c.userList, newUserInfo)
	if len(deleted) > 0 {
		// have deleted users
		err = c.server.DelUsers(deleted, c.Tag)
		if err != nil {
			log.Printf("[%s] Del users error: %s", c.Tag, err)
		}
	}
	if len(added) > 0 {
		// have added users
		_, err = c.server.AddUsers(&vCore.AddUsersParams{
			Tag:      c.Tag,
			Config:   c.ControllerConfig,
			UserInfo: added,
			NodeInfo: c.nodeInfo,
		})
		if err != nil {
			log.Printf("[%s] Add users error: %s", c.Tag, err)
		}
	}
	if len(added) > 0 || len(deleted) > 0 {
		// update Limiter
		err = limiter.UpdateLimiter(c.Tag, added, deleted)
		if err != nil {
			log.Printf("[%s] Update limiter error: %s", c.Tag, err)
		}
	}
	c.userList = newUserInfo
	log.Printf("[%s] %d user deleted, %d user added", c.Tag,
		len(deleted), len(added))
	return nil
}