package allowsources

import (
	"encoding/binary"
	"fmt"

	"golang.org/x/sys/unix"

	"github.com/projectcalico/calico/felix/bpf/maps"
	"github.com/projectcalico/calico/felix/ip"
)

const (
	KeySize = 12
)

var DummyValue = []byte{1, 0, 0, 0}

// uint32 prefixLen
// uint32 ifindex
// uint32 addr BE
type AllowSourcesEntry [KeySize]byte

var MapParameters = maps.MapParameters{
	Type:       "lpm_trie",
	KeySize:    KeySize,
	ValueSize:  4,
	MaxEntries: 1024 * 1024,
	Name:       "cali_v4_sprefix",
	Flags:      unix.BPF_F_NO_PREALLOC,
}

func Map() maps.Map {
	return maps.NewPinnedMap(MapParameters)
}

type AllowSourcesEntryInterface interface {
	Addr() ip.Addr
	PrefixLen() int
	IfIndex() int
	AsBytes() []byte
}

func (e AllowSourcesEntry) Addr() ip.Addr {
	var addr ip.V4Addr
	copy(addr[:], e[8:12])
	return addr
}

func (e AllowSourcesEntry) PrefixLen() int {
	return int(binary.LittleEndian.Uint32(e[:4]))
}

func (e AllowSourcesEntry) IfIndex() int {
	return int(binary.LittleEndian.Uint32(e[4:8]))
}

func (e AllowSourcesEntry) AsBytes() []byte {
	return e[:]
}

func (e AllowSourcesEntry) String() string {
	return fmt.Sprintf("%11s prefix %d (ifindex=%d)", e.Addr(), e.PrefixLen(), e.IfIndex())
}

func NewKey(cidr ip.CIDR, ifindex int) AllowSourcesEntry {
	var entry AllowSourcesEntry
	prefixLen := cidr.Prefix() + 32 // accounting for exact match field ifindex

	binary.LittleEndian.PutUint32(entry[:4], uint32(prefixLen))
	binary.LittleEndian.PutUint32(entry[4:8], uint32(ifindex))
	binary.BigEndian.PutUint32(entry[8:12], cidr.Addr().(ip.V4Addr).AsUint32())
	return entry
}

func NewKeyFromString(cidrString string, ifindex int) (AllowSourcesEntry, error) {
	cidr, err := ip.CIDRFromString(cidrString)
	if err != nil {
		return AllowSourcesEntry{}, err
	}
	return NewKey(cidr, ifindex), nil
}

type MapMem map[AllowSourcesEntry]struct{}

func MapMemIter(m MapMem) func(k, v []byte) {
	ks := len(AllowSourcesEntry{})

	return func(k, v []byte) {
		var key AllowSourcesEntry
		copy(key[:ks], k[:ks])

		m[key] = struct{}{}
	}
}

func (m MapMem) String() string {
	var out string

	for entry := range m {
		out += entry.String() + "\n"
	}

	return out
}