Hunter0x7c7
2022-08-11 b8230139fb40edea387617b6accd8371e37eda58
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
package blackhole
 
import (
    "github.com/v2fly/v2ray-core/v5/common"
    "github.com/v2fly/v2ray-core/v5/common/buf"
    "github.com/v2fly/v2ray-core/v5/common/serial"
)
 
const (
    http403response = `HTTP/1.1 403 Forbidden
Connection: close
Cache-Control: max-age=3600, public
Content-Length: 0
 
 
`
)
 
// ResponseConfig is the configuration for blackhole responses.
type ResponseConfig interface {
    // WriteTo writes predefined response to the give buffer.
    WriteTo(buf.Writer) int32
}
 
// WriteTo implements ResponseConfig.WriteTo().
func (*NoneResponse) WriteTo(buf.Writer) int32 { return 0 }
 
// WriteTo implements ResponseConfig.WriteTo().
func (*HTTPResponse) WriteTo(writer buf.Writer) int32 {
    b := buf.New()
    common.Must2(b.WriteString(http403response))
    n := b.Len()
    writer.WriteMultiBuffer(buf.MultiBuffer{b})
    return n
}
 
// GetInternalResponse converts response settings from proto to internal data structure.
func (c *Config) GetInternalResponse() (ResponseConfig, error) {
    if c.GetResponse() == nil {
        return new(NoneResponse), nil
    }
 
    config, err := serial.GetInstanceOf(c.GetResponse())
    if err != nil {
        return nil, err
    }
    return config.(ResponseConfig), nil
}