Merge branch 'dev' of https://github.com/cbodonnell/frp into dev
This commit is contained in:
commit
cb2e1cfffa
@ -143,7 +143,7 @@ Note that `local_port` (listened on client) and `remote_port` (exposed on server
|
|||||||
|
|
||||||
`./frpc -c ./frpc.ini`
|
`./frpc -c ./frpc.ini`
|
||||||
|
|
||||||
5. From another machine, SSH to server B like this (assuming that username is `test`):
|
5. From another machine, SSH to server B via server A like this (assuming that username is `test`):
|
||||||
|
|
||||||
`ssh -oPort=6000 test@x.x.x.x`
|
`ssh -oPort=6000 test@x.x.x.x`
|
||||||
|
|
||||||
|
11
Release.md
11
Release.md
@ -1,9 +1,4 @@
|
|||||||
### New
|
### Fix
|
||||||
|
|
||||||
* Add `oidc_scope` parameter to frpc when `authentication_method = oidc`.
|
* Server Plugin send incorrect op name for NewWorkConn.
|
||||||
* Support quic protocol between frpc and frps.
|
* QUIC stream leak.
|
||||||
|
|
||||||
|
|
||||||
### Improve
|
|
||||||
|
|
||||||
* Upgrade oidc and oauth2 package which is forward compatible.
|
|
||||||
|
@ -211,7 +211,7 @@ func (m *Manager) NewWorkConn(content *NewWorkConnContent) (*NewWorkConnContent,
|
|||||||
ctx = NewReqidContext(ctx, reqid)
|
ctx = NewReqidContext(ctx, reqid)
|
||||||
|
|
||||||
for _, p := range m.newWorkConnPlugins {
|
for _, p := range m.newWorkConnPlugins {
|
||||||
res, retContent, err = p.Handle(ctx, OpPing, *content)
|
res, retContent, err = p.Handle(ctx, OpNewWorkConn, *content)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
xl.Warn("send NewWorkConn request to plugin [%s] error: %v", p.Name(), err)
|
xl.Warn("send NewWorkConn request to plugin [%s] error: %v", p.Name(), err)
|
||||||
return nil, errors.New("send NewWorkConn request to plugin error")
|
return nil, errors.New("send NewWorkConn request to plugin error")
|
||||||
|
@ -211,3 +211,8 @@ func (conn *wrapQuicStream) RemoteAddr() net.Addr {
|
|||||||
}
|
}
|
||||||
return (*net.TCPAddr)(nil)
|
return (*net.TCPAddr)(nil)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (conn *wrapQuicStream) Close() error {
|
||||||
|
conn.Stream.CancelRead(0)
|
||||||
|
return conn.Stream.Close()
|
||||||
|
}
|
||||||
|
@ -44,9 +44,9 @@ func RandIDWithLen(idLen int) (id string, err error) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func GetAuthKey(token string, timestamp int64) (key string) {
|
func GetAuthKey(token string, timestamp int64) (key string) {
|
||||||
token += fmt.Sprintf("%d", timestamp)
|
|
||||||
md5Ctx := md5.New()
|
md5Ctx := md5.New()
|
||||||
md5Ctx.Write([]byte(token))
|
md5Ctx.Write([]byte(token))
|
||||||
|
md5Ctx.Write([]byte(strconv.FormatInt(timestamp, 10)))
|
||||||
data := md5Ctx.Sum(nil)
|
data := md5Ctx.Sum(nil)
|
||||||
return hex.EncodeToString(data)
|
return hex.EncodeToString(data)
|
||||||
}
|
}
|
||||||
|
@ -19,7 +19,7 @@ import (
|
|||||||
"strings"
|
"strings"
|
||||||
)
|
)
|
||||||
|
|
||||||
var version = "0.46.0"
|
var version = "0.46.1"
|
||||||
|
|
||||||
func Full() string {
|
func Full() string {
|
||||||
return version
|
return version
|
||||||
|
Loading…
Reference in New Issue
Block a user