dns

type Answer struct {
	Name string     `json:"name"`
	Type RecordType `json:"type"`
	TTL  uint       `json:"ttl"`
	Data string     `json:"data"`
}

type DNS interface {
	// Lookup performs a DNS lookup for the given hostname and returns a valid IP address for the A record.
	Lookup(ctx context.Context, hostname string) (bool, *net.IP, error)
}

type DNSAction interface {
	// GetID returns the unique ID of the DNS action
	GetID() string
	// GetReply returns the reply of the DNS action
	GetReply() string
	// SetReply sets the reply of the DNS action
	SetReply(string)
}

type DNSAddAction struct {
	DNSBaseAction
	Name    string        `json:"name"`
	Type    string        `json:"type,omitempty"`
	Value   string        `json:"value,omitempty"`
	TTL     time.Duration `json:"ttl,omitempty"`
	Expires time.Duration `json:"expires,omitempty"`
	TLSCert string        `json:"tls_cert,omitempty"`
}

type DNSBaseAction struct {
	ID     string `json:"id"`
	Action string `json:"action"`
	Reply  string `json:"reply,omitempty"`
}

type DNSCert struct {
	Certificate []byte    `json:"certificate"`
	PrivateKey  []byte    `json:"private_key"`
	Expires     time.Time `json:"expires"`
}

type DNSCertAction struct {
	DNSBaseAction
	Name string `json:"name"`
}

type DNSCertResponse struct {
	DNSResponse[DNSCert]
}

type DNSDeleteAction struct {
	DNSBaseAction
	Name string `json:"name"`
}

type DNSRecordType string

type DNSResponse[T any] struct {
	ID      string `json:"id"`
	Success bool   `json:"success"`
	Error   string `json:"error,omitempty"`
	Data    *T     `json:"data,omitempty"`
}

type Dns struct {
	// contains filtered or unexported fields
}

type Message struct {
	Payload []byte
}

type RecordType uint8

type Result struct {
	Status StatusType `json:"Status"`
	Answer []Answer   `json:"Answer"`
}

type StatusType uint8

type Subscriber interface {
	// Close closes the subscriber
	Close() error
	// Channel returns a channel of messages
	Channel() <-chan *Message
}

type Transport interface {
	Subscribe(ctx context.Context, channel string) Subscriber
	Publish(ctx context.Context, channel string, payload []byte) error
}

type WithConfig func(config *dnsConfig)