class.go

package tc

import (
	"fmt"

	"github.com/florianl/go-tc/internal/unix"
	"github.com/mdlayher/netlink"
)

// Class represents the class part of rtnetlink
type Class struct {
	Tc
}

// Class allows to read and alter classes
func (tc *Tc) Class() *Class {
	return &Class{*tc}
}

// Add creats a new class
func (c *Class) Add(info *Object) error {
	if info == nil {
		return ErrNoArg
	}
	options, err := validateClassObject(unix.RTM_NEWTCLASS, info)
	if err != nil {
		return err
	}
	return c.action(unix.RTM_NEWTCLASS, netlink.Create|netlink.Excl, &info.Msg, options)
}

// Replace add/remove a class. If the node does not exist yet it is created
func (c *Class) Replace(info *Object) error {
	if info == nil {
		return ErrNoArg
	}
	options, err := validateClassObject(unix.RTM_NEWTCLASS, info)
	if err != nil {
		return err
	}
	return c.action(unix.RTM_NEWTCLASS, netlink.Create, &info.Msg, options)
}

// Delete removes a class
func (c *Class) Delete(info *Object) error {
	if info == nil {
		return ErrNoArg
	}
	options, err := validateClassObject(unix.RTM_DELTCLASS, info)
	if err != nil {
		return err
	}
	return c.action(unix.RTM_DELTCLASS, netlink.HeaderFlags(0), &info.Msg, options)
}

// Get fetches all classes
func (c *Class) Get(i *Msg) ([]Object, error) {
	if i == nil {
		return []Object{}, ErrNoArg
	}
	return c.get(unix.RTM_GETTCLASS, i)
}

func validateClassObject(action int, info *Object) ([]tcOption, error) {
	options := []tcOption{}
	if info.Ifindex == 0 {
		return options, ErrInvalidDev
	}

	// TODO: improve logic and check combinations
	var data []byte
	var err error
	switch info.Kind {
	case "hfsc":
		data, err = marshalHfsc(info.Hfsc)
	case "qfq":
		data, err = marshalQfq(info.Qfq)
	case "htb":
		data, err = marshalHtb(info.Htb)
	case "dsmark":
		data, err = marshalDsmark(info.Dsmark)
	default:
		if !isDelAction(action) {
			return options, fmt.Errorf("%s: %w", info.Kind, ErrNotImplemented)
		}
	}
	if err != nil {
		return options, err
	}
	if len(data) < 1 && !isDelAction(action) {
		return options, ErrNoArg
	}
	options = append(options, tcOption{Interpretation: vtBytes, Type: tcaOptions, Data: data})
	if !isDelAction(action) {
		options = append(options, tcOption{Interpretation: vtString, Type: tcaKind, Data: info.Kind})
	}
	return options, nil
}