refactor(utils): proxy

This commit is contained in:
iyear 2022-09-07 00:04:58 +08:00
parent 7ab0e1b3e2
commit a3e64b4eea
3 changed files with 8 additions and 4 deletions

View file

@ -25,7 +25,7 @@ func Run(ctx context.Context, ns, proxy string, partSize, threads, limit int, ur
c := telegram.NewClient(consts.AppID, consts.AppHash, telegram.Options{
Resolver: dcs.Plain(dcs.PlainOptions{
Dial: utils.GetDial(proxy).DialContext,
Dial: utils.Proxy.GetDial(proxy).DialContext,
}),
Device: consts.Device,
SessionStorage: storage.NewSession(kvd, false),

View file

@ -25,7 +25,7 @@ func Run(ctx context.Context, ns, proxy string) error {
c := telegram.NewClient(consts.AppID, consts.AppHash, telegram.Options{
Resolver: dcs.Plain(dcs.PlainOptions{
Dial: utils.GetDial(proxy).DialContext,
Dial: utils.Proxy.GetDial(proxy).DialContext,
}),
Device: consts.Device,
SessionStorage: storage.NewSession(kvd, true),

View file

@ -5,8 +5,12 @@ import (
"net/url"
)
func GetDial(p string) proxy.ContextDialer {
u, err := url.Parse(p)
type _proxy struct{}
var Proxy = _proxy{}
func (p _proxy) GetDial(_url string) proxy.ContextDialer {
u, err := url.Parse(_url)
if err != nil {
return proxy.Direct
}