global

package
v0.9.37-fix1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 6, 2021 License: AGPL-3.0 Imports: 35 Imported by: 8

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	IMAGE_PATH     = path.Join("data", "images")
	IMAGE_PATH_OLD = path.Join("data", "image")
	VOICE_PATH     = path.Join("data", "voices")
	VOICE_PATH_OLD = path.Join("data", "record")
	VIDEO_PATH     = path.Join("data", "videos")
	CACHE_PATH     = path.Join("data", "cache")

	HEADER_AMR  = []byte("#!AMR")
	HEADER_SILK = []byte("\x02#!SILK_V3")

	ErrSyntax = errors.New("syntax error")
)
View Source 
var (
	Proxy string

	ErrOverSize = errors.New("oversize")
)
View Source 
var DefaultConfigWithComments = `` /* 3629-byte string literal not displayed */

Functions

func BootFilter added in v0.9.25 

func BootFilter()

func Check 

func Check(err error)

func DelFile added in v0.9.27 

func DelFile(path string) bool

func DownloadFile added in v0.9.37 

func DownloadFile(url, path string, limit int64) error

func DownloadFileMultiThreading added in v0.9.37 

func DownloadFileMultiThreading(url, path string, limit int64, threadCount int, headers map[string]string) error

func Encoder added in v0.9.28 

func Encoder(data []byte) ([]byte, error)

func EnsureBool added in v0.9.20 

func EnsureBool(p interface{}, defaultVal bool) bool

func FindFile added in v0.9.26 

func FindFile(f, cache, PATH string) (data []byte, err error)

func GetBytes 

func GetBytes(url string) ([]byte, error)

func GetSliderTicket added in v0.9.37 

func GetSliderTicket(raw, id string) (string, error)

func InitCodec added in v0.9.28 

func InitCodec()

func InitLimiter added in v0.9.25 

func InitLimiter(r float64, b int)

func IsAMRorSILK added in v0.9.20 

func IsAMRorSILK(b []byte) bool

func NeteaseMusicSongInfo added in v0.9.22 

func NeteaseMusicSongInfo(id string) (gjson.Result, error)

func PathExists 

func PathExists(path string) bool

func QQMusicSongInfo added in v0.9.21 

func QQMusicSongInfo(id string) (gjson.Result, error)

func RateLimit added in v0.9.25 

func RateLimit(ctx context.Context)

func ReadAddrFile added in v0.9.31 

func ReadAddrFile(path string) []*net.TCPAddr

func ReadAllText 

func ReadAllText(path string) string

func SplitUrl added in v0.9.35 

func SplitUrl(s string) []string

func UpdateFromStream added in v0.9.37 

func UpdateFromStream(updateWith io.Reader) (err error, errRecover error)

UpdateFromStream copy form getlantern/go-update

func VersionNameCompare added in v0.9.30 

func VersionNameCompare(current, remote string) bool

VersionNameCompare 检查版本名是否需要更新, 仅适用于 go-cqhttp 的版本命名规则 例: v0.9.29-fix2 == v0.9.29-fix2 -> false v0.9.29-fix1 < v0.9.29-fix2 -> true v0.9.29-fix2 > v0.9.29-fix1 -> false v0.9.29-fix2 < v0.9.30 -> true

func WriteAllText 

func WriteAllText(path, text string) error

Types

type AndOperator added in v0.9.21 

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

func (*AndOperator) Eval added in v0.9.21 

func (andOperator *AndOperator) Eval(payload MSG) bool

type CQHttpApiConfig 

type CQHttpApiConfig struct {
	Host                         string `json:"host"`
	Port                         uint16 `json:"port"`
	UseHttp                      bool   `json:"use_http"`
	WSHost                       string `json:"ws_host"`
	WSPort                       uint16 `json:"ws_port"`
	UseWS                        bool   `json:"use_ws"`
	WSReverseUrl                 string `json:"ws_reverse_url"`
	WSReverseApiUrl              string `json:"ws_reverse_api_url"`
	WSReverseEventUrl            string `json:"ws_reverse_event_url"`
	WSReverseReconnectInterval   uint16 `json:"ws_reverse_reconnect_interval"`
	WSReverseReconnectOnCode1000 bool   `json:"ws_reverse_reconnect_on_code_1000"`
	UseWsReverse                 bool   `json:"use_ws_reverse"`
	PostUrl                      string `json:"post_url"`
	AccessToken                  string `json:"access_token"`
	Secret                       string `json:"secret"`
	PostMessageFormat            string `json:"post_message_format"`
}

type ContainsOperator added in v0.9.21 

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

func (*ContainsOperator) Eval added in v0.9.21 

func (op *ContainsOperator) Eval(payload MSG) bool

type EqualOperator added in v0.9.21 

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

func (*EqualOperator) Eval added in v0.9.21 

func (op *EqualOperator) Eval(payload MSG) bool

type Filter added in v0.9.21 

type Filter interface {
	Eval(payload MSG) bool
}
var EventFilter Filter = nil

func Generate added in v0.9.25 

func Generate(opName string, argument gjson.Result) Filter

type GoCQHttpConfig 

type GoCQHttpConfig struct {
	Enabled  bool              `json:"enabled"`
	Host     string            `json:"host"`
	Port     uint16            `json:"port"`
	Timeout  int32             `json:"timeout"`
	PostUrls map[string]string `json:"post_urls"`
}

type GoCQReverseWebsocketConfig added in v0.9.2 

type GoCQReverseWebsocketConfig struct {
	Enabled                  bool   `json:"enabled"`
	ReverseUrl               string `json:"reverse_url"`
	ReverseApiUrl            string `json:"reverse_api_url"`
	ReverseEventUrl          string `json:"reverse_event_url"`
	ReverseReconnectInterval uint16 `json:"reverse_reconnect_interval"`
}

type GoCQWebsocketConfig 

type GoCQWebsocketConfig struct {
	Enabled bool   `json:"enabled"`
	Host    string `json:"host"`
	Port    uint16 `json:"port"`
}

type GoCqWebUi added in v0.9.27 

type GoCqWebUi struct {
	Enabled   bool   `json:"enabled"`
	Host      string `json:"host"`
	WebUiPort uint64 `json:"web_ui_port"`
	WebInput  bool   `json:"web_input"`
}

type InOperator added in v0.9.21 

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

func (*InOperator) Eval added in v0.9.21 

func (op *InOperator) Eval(payload MSG) bool

type JsonConfig 

type JsonConfig struct {
	Uin               int64  `json:"uin"`
	Password          string `json:"password"`
	EncryptPassword   bool   `json:"encrypt_password"`
	PasswordEncrypted string `json:"password_encrypted"`
	EnableDB          bool   `json:"enable_db"`
	AccessToken       string `json:"access_token"`
	ReLogin           struct {
		Enabled         bool `json:"enabled"`
		ReLoginDelay    int  `json:"relogin_delay"`
		MaxReloginTimes uint `json:"max_relogin_times"`
	} `json:"relogin"`
	RateLimit struct {
		Enabled    bool    `json:"enabled"`
		Frequency  float64 `json:"frequency"`
		BucketSize int     `json:"bucket_size"`
	} `json:"_rate_limit"`
	IgnoreInvalidCQCode bool                          `json:"ignore_invalid_cqcode"`
	ForceFragmented     bool                          `json:"force_fragmented"`
	FixUrl              bool                          `json:"fix_url"`
	ProxyRewrite        string                        `json:"proxy_rewrite"`
	HeartbeatInterval   time.Duration                 `json:"heartbeat_interval"`
	HttpConfig          *GoCQHttpConfig               `json:"http_config"`
	WSConfig            *GoCQWebsocketConfig          `json:"ws_config"`
	ReverseServers      []*GoCQReverseWebsocketConfig `json:"ws_reverse_servers"`
	PostMessageFormat   string                        `json:"post_message_format"`
	UseSSOAddress       bool                          `json:"use_sso_address"`
	Debug               bool                          `json:"debug"`
	LogLevel            string                        `json:"log_level"`
	WebUi               *GoCqWebUi                    `json:"web_ui"`
}

func DefaultConfig 

func DefaultConfig() *JsonConfig

func Load 

func Load(p string) *JsonConfig

func (*JsonConfig) Save 

func (c *JsonConfig) Save(p string) error

type MSG added in v0.9.34 

type MSG map[string]interface{}

func (MSG) Get added in v0.9.34 

func (m MSG) Get(s string) MSG

func (MSG) String added in v0.9.34 

func (m MSG) String() string

type NotEqualOperator added in v0.9.21 

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

func (*NotEqualOperator) Eval added in v0.9.21 

func (op *NotEqualOperator) Eval(payload MSG) bool

type NotOperator added in v0.9.21 

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

func (*NotOperator) Eval added in v0.9.21 

func (op *NotOperator) Eval(payload MSG) bool

type OrOperator added in v0.9.21 

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

func (*OrOperator) Eval added in v0.9.21 

func (op *OrOperator) Eval(payload MSG) bool

type RegexOperator added in v0.9.21 

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

func (*RegexOperator) Eval added in v0.9.21 

func (op *RegexOperator) Eval(payload MSG) bool

type WriteCounter added in v0.9.31 

type WriteCounter struct {
	Total uint64
}

func (WriteCounter) PrintProgress added in v0.9.31 

func (wc WriteCounter) PrintProgress()

func (*WriteCounter) Write added in v0.9.31 

func (wc *WriteCounter) Write(p []byte) (int, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.