blackhole.go 1.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051
  1. package conf
  2. import (
  3. "encoding/json"
  4. "github.com/xtls/xray-core/common/errors"
  5. "github.com/xtls/xray-core/common/serial"
  6. "github.com/xtls/xray-core/proxy/blackhole"
  7. "google.golang.org/protobuf/proto"
  8. )
  9. type NoneResponse struct{}
  10. func (*NoneResponse) Build() (proto.Message, error) {
  11. return new(blackhole.NoneResponse), nil
  12. }
  13. type HTTPResponse struct{}
  14. func (*HTTPResponse) Build() (proto.Message, error) {
  15. return new(blackhole.HTTPResponse), nil
  16. }
  17. type BlackholeConfig struct {
  18. Response json.RawMessage `json:"response"`
  19. }
  20. func (v *BlackholeConfig) Build() (proto.Message, error) {
  21. config := new(blackhole.Config)
  22. if v.Response != nil {
  23. response, _, err := configLoader.Load(v.Response)
  24. if err != nil {
  25. return nil, errors.New("Config: Failed to parse Blackhole response config.").Base(err)
  26. }
  27. responseSettings, err := response.(Buildable).Build()
  28. if err != nil {
  29. return nil, err
  30. }
  31. config.Response = serial.ToTypedMessage(responseSettings)
  32. }
  33. return config, nil
  34. }
  35. var configLoader = NewJSONConfigLoader(
  36. ConfigCreatorCache{
  37. "none": func() interface{} { return new(NoneResponse) },
  38. "http": func() interface{} { return new(HTTPResponse) },
  39. },
  40. "type",
  41. "")