aboutsummaryrefslogtreecommitdiff
path: root/plugin/pkg/variables/variables.go
diff options
context:
space:
mode:
Diffstat (limited to 'plugin/pkg/variables/variables.go')
-rw-r--r--plugin/pkg/variables/variables.go104
1 files changed, 0 insertions, 104 deletions
diff --git a/plugin/pkg/variables/variables.go b/plugin/pkg/variables/variables.go
deleted file mode 100644
index 8e1cdbe77..000000000
--- a/plugin/pkg/variables/variables.go
+++ /dev/null
@@ -1,104 +0,0 @@
-package variables
-
-import (
- "encoding/binary"
- "fmt"
- "net"
- "strconv"
-
- "github.com/coredns/coredns/request"
-)
-
-const (
- queryName = "qname"
- queryType = "qtype"
- clientIP = "client_ip"
- clientPort = "client_port"
- protocol = "protocol"
- serverIP = "server_ip"
- serverPort = "server_port"
-)
-
-// All is a list of available variables provided by GetMetadataValue
-var All = []string{queryName, queryType, clientIP, clientPort, protocol, serverIP, serverPort}
-
-// GetValue calculates and returns the data specified by the variable name.
-// Supported varNames are listed in allProvidedVars.
-func GetValue(state request.Request, varName string) ([]byte, error) {
- switch varName {
- case queryName:
- return []byte(state.QName()), nil
-
- case queryType:
- return uint16ToWire(state.QType()), nil
-
- case clientIP:
- return ipToWire(state.Family(), state.IP())
-
- case clientPort:
- return portToWire(state.Port())
-
- case protocol:
- return []byte(state.Proto()), nil
-
- case serverIP:
- ip, _, err := net.SplitHostPort(state.W.LocalAddr().String())
- if err != nil {
- ip = state.W.RemoteAddr().String()
- }
- return ipToWire(state.Family(), ip)
-
- case serverPort:
- _, port, err := net.SplitHostPort(state.W.LocalAddr().String())
- if err != nil {
- port = "0"
- }
- return portToWire(port)
- }
-
- return nil, fmt.Errorf("unable to extract data for variable %s", varName)
-}
-
-// uint16ToWire writes unit16 to wire/binary format
-func uint16ToWire(data uint16) []byte {
- buf := make([]byte, 2)
- binary.BigEndian.PutUint16(buf, uint16(data))
- return buf
-}
-
-// ipToWire writes IP address to wire/binary format, 4 or 16 bytes depends on IPV4 or IPV6.
-func ipToWire(family int, ipAddr string) ([]byte, error) {
-
- switch family {
- case 1:
- return net.ParseIP(ipAddr).To4(), nil
- case 2:
- return net.ParseIP(ipAddr).To16(), nil
- }
- return nil, fmt.Errorf("invalid IP address family (i.e. version) %d", family)
-}
-
-// portToWire writes port to wire/binary format, 2 bytes
-func portToWire(portStr string) ([]byte, error) {
-
- port, err := strconv.ParseUint(portStr, 10, 16)
- if err != nil {
- return nil, err
- }
- return uint16ToWire(uint16(port)), nil
-}
-
-// Family returns the family of the transport, 1 for IPv4 and 2 for IPv6.
-func family(ip net.Addr) int {
- var a net.IP
- if i, ok := ip.(*net.UDPAddr); ok {
- a = i.IP
- }
- if i, ok := ip.(*net.TCPAddr); ok {
- a = i.IP
- }
- if a.To4() != nil {
- return 1
- }
- return 2
-}