Skip to content

Commit

Permalink
update
Browse files Browse the repository at this point in the history
  • Loading branch information
admpub committed Sep 11, 2024
1 parent 4376aa9 commit 5f535d7
Show file tree
Hide file tree
Showing 29 changed files with 211 additions and 212 deletions.
2 changes: 1 addition & 1 deletion application/handler/_service_rpc.go
Original file line number Diff line number Diff line change
Expand Up @@ -11,8 +11,8 @@ import (
"github.com/webx-top/db"
"github.com/webx-top/echo"

"github.com/admpub/nging/v5/application/model"
rpc "github.com/coscms/rpcxx"
"github.com/coscms/webcore/model"

_ "github.com/nging-plugins/frpmanager/application/library/frp/rpcservice"
)
Expand Down
24 changes: 12 additions & 12 deletions application/handler/account.go
Original file line number Diff line number Diff line change
Expand Up @@ -21,25 +21,25 @@ package handler
import (
"time"

"github.com/coscms/webcore/library/backend"
"github.com/coscms/webcore/library/common"
"github.com/webx-top/db"
"github.com/webx-top/echo"
"github.com/webx-top/echo/code"
"github.com/webx-top/echo/formfilter"

"github.com/admpub/nging/v5/application/handler"

"github.com/nging-plugins/frpmanager/application/model"
)

func AccountIndex(ctx echo.Context) error {
m := model.NewFrpUser(ctx)
cond := db.NewCompounds()
list := []*model.FrpUserAndServer{}
_, err := handler.PagingWithLister(ctx, handler.NewLister(m, &list, func(r db.Result) db.Result {
_, err := common.PagingWithLister(ctx, common.NewLister(m, &list, func(r db.Result) db.Result {
return r.OrderBy(`-id`)
}, cond.And()))
ctx.Set(`listData`, list)
return ctx.Render(`frp/account`, handler.Err(ctx, err))
return ctx.Render(`frp/account`, common.Err(ctx, err))
}

func accountFormFilter(opts ...formfilter.Options) echo.FormDataFilter {
Expand All @@ -53,7 +53,7 @@ func accountFormFilter(opts ...formfilter.Options) echo.FormDataFilter {
func AccountAdd(ctx echo.Context) error {
var err error
m := model.NewFrpUser(ctx)
user := handler.User(ctx)
user := backend.User(ctx)
if ctx.IsPost() {
if ctx.Form(`confirmPassword`) != ctx.Form(`password`) {
err = ctx.E(`两次输入的密码之间不匹配,请输入一样的密码`)
Expand All @@ -66,8 +66,8 @@ func AccountAdd(ctx echo.Context) error {
m.Uid = user.Id
_, err = m.Add()
if err == nil {
handler.SendOk(ctx, ctx.T(`操作成功`))
return ctx.Redirect(handler.URLFor(`/frp/account`))
common.SendOk(ctx, ctx.T(`操作成功`))
return ctx.Redirect(backend.URLFor(`/frp/account`))
}
}
} else {
Expand Down Expand Up @@ -124,8 +124,8 @@ func AccountEdit(ctx echo.Context) error {
m.Id = id
err = m.Edit(nil, db.Cond{`id`: id})
if err == nil {
handler.SendOk(ctx, ctx.T(`操作成功`))
return ctx.Redirect(handler.URLFor(`/frp/account`))
common.SendOk(ctx, ctx.T(`操作成功`))
return ctx.Redirect(backend.URLFor(`/frp/account`))
}
}
} else {
Expand Down Expand Up @@ -155,10 +155,10 @@ func AccountDelete(ctx echo.Context) error {
m := model.NewFrpUser(ctx)
err := m.Delete(nil, db.Cond{`id`: id})
if err == nil {
handler.SendOk(ctx, ctx.T(`操作成功`))
common.SendOk(ctx, ctx.T(`操作成功`))
} else {
handler.SendFail(ctx, err.Error())
common.SendFail(ctx, err.Error())
}

return ctx.Redirect(handler.URLFor(`/frp/account`))
return ctx.Redirect(backend.URLFor(`/frp/account`))
}
2 changes: 1 addition & 1 deletion application/handler/addon.go
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@ import (
"github.com/webx-top/com"
"github.com/webx-top/echo"

"github.com/admpub/nging/v5/application/library/common"
"github.com/coscms/webcore/library/common"
)

var regexNumEnd = regexp.MustCompile(`_[\d]+$`)
Expand Down
30 changes: 15 additions & 15 deletions application/handler/client.go
Original file line number Diff line number Diff line change
Expand Up @@ -32,9 +32,9 @@ import (
"github.com/webx-top/echo/code"
"github.com/webx-top/echo/formfilter"

"github.com/admpub/nging/v5/application/handler"
"github.com/admpub/nging/v5/application/library/common"
"github.com/admpub/nging/v5/application/library/config"
"github.com/coscms/webcore/library/backend"
"github.com/coscms/webcore/library/common"
"github.com/coscms/webcore/library/config"

"github.com/nging-plugins/frpmanager/application/dbschema"
"github.com/nging-plugins/frpmanager/application/library/cmder"
Expand All @@ -54,7 +54,7 @@ func ClientIndex(ctx echo.Context) error {
cond.AddKV(`name`, db.Like(`%`+q+`%`))
}
var clientAndGroup []*model.FrpClientAndGroup
_, err := handler.PagingWithLister(ctx, handler.NewLister(m, &clientAndGroup, func(r db.Result) db.Result {
_, err := common.PagingWithLister(ctx, common.NewLister(m, &clientAndGroup, func(r db.Result) db.Result {
return r.OrderBy(`-id`)
}, cond.And()))
for k, u := range clientAndGroup {
Expand All @@ -68,7 +68,7 @@ func ClientIndex(ctx echo.Context) error {
ctx.Set(`groupList`, groupList)
ctx.Set(`groupId`, groupId)
ctx.Set(`isRunning`, config.FromCLI().CmdHasGroup(`frpclient`))
return ctx.Render(`frp/client_index`, handler.Err(ctx, err))
return ctx.Render(`frp/client_index`, common.Err(ctx, err))
}

func clientFormFilter(opts ...formfilter.Options) echo.FormDataFilter {
Expand All @@ -78,7 +78,7 @@ func clientFormFilter(opts ...formfilter.Options) echo.FormDataFilter {

func ClientAdd(ctx echo.Context) error {
m := model.NewFrpClient(ctx)
user := handler.User(ctx)
user := backend.User(ctx)
cm, err := cmder.GetClient()
if err != nil {
return err
Expand All @@ -103,11 +103,11 @@ func ClientAdd(ctx echo.Context) error {
err = cm.StartBy(m.NgingFrpClient.Id)
}
if err != nil {
handler.SendOk(ctx, ctx.T(`保存成功。但启动失败: %v`, err.Error()))
common.SendOk(ctx, ctx.T(`保存成功。但启动失败: %v`, err.Error()))
} else {
handler.SendOk(ctx, ctx.T(`操作成功`))
common.SendOk(ctx, ctx.T(`操作成功`))
}
return ctx.Redirect(handler.URLFor(`/frp/client_index`))
return ctx.Redirect(backend.URLFor(`/frp/client_index`))
}
}
} else {
Expand Down Expand Up @@ -177,11 +177,11 @@ func ClientEdit(ctx echo.Context) error {
opType = ctx.T(`关闭失败`)
}
if err != nil {
handler.SendOk(ctx, ctx.T(`保存成功。但%s: %v`, opType, err.Error()))
common.SendOk(ctx, ctx.T(`保存成功。但%s: %v`, opType, err.Error()))
} else {
handler.SendOk(ctx, ctx.T(`操作成功`))
common.SendOk(ctx, ctx.T(`操作成功`))
}
return ctx.Redirect(handler.URLFor(`/frp/client_index`))
return ctx.Redirect(backend.URLFor(`/frp/client_index`))
}
}
} else if ctx.IsAjax() {
Expand Down Expand Up @@ -296,12 +296,12 @@ func ClientDelete(ctx echo.Context) error {
err = utils.SaveConfigFile(&dbschema.NgingFrpClient{Disabled: `Y`, Id: id})
}
if err == nil {
handler.SendOk(ctx, ctx.T(`操作成功`))
common.SendOk(ctx, ctx.T(`操作成功`))
} else {
handler.SendFail(ctx, err.Error())
common.SendFail(ctx, err.Error())
}

return ctx.Redirect(handler.URLFor(`/frp/client_index`))
return ctx.Redirect(backend.URLFor(`/frp/client_index`))
}

func ClientLog(ctx echo.Context) error {
Expand Down
22 changes: 11 additions & 11 deletions application/handler/group.go
Original file line number Diff line number Diff line change
Expand Up @@ -19,18 +19,18 @@
package handler

import (
"github.com/coscms/webcore/library/backend"
"github.com/coscms/webcore/library/common"
"github.com/webx-top/db"
"github.com/webx-top/echo"

"github.com/admpub/nging/v5/application/handler"

"github.com/nging-plugins/frpmanager/application/model"
)

func GroupIndex(ctx echo.Context) error {
m := model.NewFrpGroup(ctx)
_, err := handler.PagingWithLister(ctx, m)
ret := handler.Err(ctx, err)
_, err := common.PagingWithLister(ctx, m)
ret := common.Err(ctx, err)
ctx.Set(`listData`, m.Objects())
return ctx.Render(`frp/group_index`, ret)
}
Expand All @@ -52,8 +52,8 @@ func GroupAdd(ctx echo.Context) error {
if err == nil {
_, err = m.Insert()
if err == nil {
handler.SendOk(ctx, ctx.T(`操作成功`))
return ctx.Redirect(handler.URLFor(`/frp/group_index`))
common.SendOk(ctx, ctx.T(`操作成功`))
return ctx.Redirect(backend.URLFor(`/frp/group_index`))
}
}
} else {
Expand Down Expand Up @@ -92,8 +92,8 @@ func GroupEdit(ctx echo.Context) error {
m.Id = id
err = m.Update(nil, db.Cond{`id`: id})
if err == nil {
handler.SendOk(ctx, ctx.T(`操作成功`))
return ctx.Redirect(handler.URLFor(`/frp/group_index`))
common.SendOk(ctx, ctx.T(`操作成功`))
return ctx.Redirect(backend.URLFor(`/frp/group_index`))
}
}
} else if err == nil {
Expand All @@ -109,10 +109,10 @@ func GroupDelete(ctx echo.Context) error {
m := model.NewFrpGroup(ctx)
err := m.Delete(nil, db.Cond{`id`: id})
if err == nil {
handler.SendOk(ctx, ctx.T(`操作成功`))
common.SendOk(ctx, ctx.T(`操作成功`))
} else {
handler.SendFail(ctx, err.Error())
common.SendFail(ctx, err.Error())
}

return ctx.Redirect(handler.URLFor(`/frp/group_index`))
return ctx.Redirect(backend.URLFor(`/frp/group_index`))
}
9 changes: 4 additions & 5 deletions application/handler/init.go
Original file line number Diff line number Diff line change
Expand Up @@ -21,11 +21,10 @@ package handler
import (
"github.com/webx-top/echo"

"github.com/admpub/nging/v5/application/handler"
"github.com/admpub/nging/v5/application/registry/perm"
"github.com/coscms/webcore/registry/perm"

ngingdbschema "github.com/admpub/nging/v5/application/dbschema"
"github.com/admpub/nging/v5/application/library/route"
ngingdbschema "github.com/coscms/webcore/dbschema"
"github.com/coscms/webcore/library/route"
_ "github.com/nging-plugins/frpmanager/application/handler/plugins/multiuser"
"github.com/nging-plugins/frpmanager/application/handler/proxy"
)
Expand All @@ -47,7 +46,7 @@ func RegisterRoute(r *route.Collection) {
}

func registerRoute(g echo.RouteRegister) {
metaHandler := handler.IRegister().MetaHandler
metaHandler := route.IRegister().MetaHandler
g.Route(`GET,POST`, `/server_index`, ServerIndex)
g.Route(`GET,POST`, `/server_add`, ServerAdd)
g.Route(`GET,POST`, `/server_edit`, ServerEdit)
Expand Down
2 changes: 1 addition & 1 deletion application/handler/navigate.go
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
package handler

import "github.com/admpub/nging/v5/application/registry/navigate"
import "github.com/coscms/webcore/registry/navigate"

var LeftNavigate = &navigate.Item{
Display: true,
Expand Down
10 changes: 5 additions & 5 deletions application/handler/plugins/multiuser/init.go
Original file line number Diff line number Diff line change
Expand Up @@ -7,10 +7,10 @@ import (
"github.com/admpub/log"
"github.com/webx-top/echo"

"github.com/admpub/nging/v5/application/cmd/bootconfig"
"github.com/admpub/nging/v5/application/handler"
"github.com/admpub/nging/v5/application/library/common"
"github.com/admpub/nging/v5/application/library/config"
"github.com/coscms/webcore/cmd/bootconfig"
"github.com/coscms/webcore/library/common"
"github.com/coscms/webcore/library/config"
"github.com/coscms/webcore/library/route"
"github.com/nging-plugins/frpmanager/application/library/frp"
)

Expand Down Expand Up @@ -50,7 +50,7 @@ func init() {
}()
return nil
})
handler.Register(func(g echo.RouteRegister) {
route.Register(func(g echo.RouteRegister) {
g.Post(`/frp_login`, Login)
})
}
2 changes: 1 addition & 1 deletion application/handler/proxy/proxy.go
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,7 @@ import (
"github.com/webx-top/echo/code"
mw "github.com/webx-top/echo/middleware"

"github.com/admpub/nging/v5/application/library/config"
"github.com/coscms/webcore/library/config"
"github.com/nging-plugins/frpmanager/application/model"
)

Expand Down
30 changes: 15 additions & 15 deletions application/handler/server.go
Original file line number Diff line number Diff line change
Expand Up @@ -30,9 +30,9 @@ import (
"github.com/webx-top/echo/formfilter"
"github.com/webx-top/echo/param"

"github.com/admpub/nging/v5/application/handler"
"github.com/admpub/nging/v5/application/library/common"
"github.com/admpub/nging/v5/application/library/config"
"github.com/coscms/webcore/library/backend"
"github.com/coscms/webcore/library/common"
"github.com/coscms/webcore/library/config"

"github.com/nging-plugins/frpmanager/application/dbschema"
"github.com/nging-plugins/frpmanager/application/library/cmder"
Expand All @@ -50,7 +50,7 @@ func ServerIndex(ctx echo.Context) error {
}
common.SelectPageCond(ctx, &cond)
var serverAndGroup []*model.FrpServerAndGroup
_, err := handler.PagingWithLister(ctx, handler.NewLister(m, &serverAndGroup, func(r db.Result) db.Result {
_, err := common.PagingWithLister(ctx, common.NewLister(m, &serverAndGroup, func(r db.Result) db.Result {
return r.OrderBy(`-id`)
}, cond.And()))
for k, u := range serverAndGroup {
Expand All @@ -64,7 +64,7 @@ func ServerIndex(ctx echo.Context) error {
ctx.Set(`groupList`, groupList)
ctx.Set(`groupId`, groupId)
ctx.Set(`isRunning`, config.FromCLI().CmdHasGroup(`frpserver`))
return ctx.Render(`frp/server_index`, handler.Err(ctx, err))
return ctx.Render(`frp/server_index`, common.Err(ctx, err))
}

func serverFormFilter(opts ...formfilter.Options) echo.FormDataFilter {
Expand All @@ -80,7 +80,7 @@ func ServerAdd(ctx echo.Context) error {
return err
}
m := model.NewFrpServer(ctx)
user := handler.User(ctx)
user := backend.User(ctx)
if ctx.IsPost() {
err = ctx.MustBind(m.NgingFrpServer, serverFormFilter())
if err == nil {
Expand All @@ -94,11 +94,11 @@ func ServerAdd(ctx echo.Context) error {
err = cm.StartBy(m.NgingFrpServer.Id)
}
if err != nil {
handler.SendOk(ctx, ctx.T(`保存成功。但启动失败: %v`, err.Error()))
common.SendOk(ctx, ctx.T(`保存成功。但启动失败: %v`, err.Error()))
} else {
handler.SendOk(ctx, ctx.T(`操作成功`))
common.SendOk(ctx, ctx.T(`操作成功`))
}
return ctx.Redirect(handler.URLFor(`/frp/server_index`))
return ctx.Redirect(backend.URLFor(`/frp/server_index`))
}
}
} else {
Expand Down Expand Up @@ -171,11 +171,11 @@ func ServerEdit(ctx echo.Context) error {
opType = ctx.T(`关闭失败`)
}
if err != nil {
handler.SendOk(ctx, ctx.T(`保存成功。但%s: %v`, opType, err.Error()))
common.SendOk(ctx, ctx.T(`保存成功。但%s: %v`, opType, err.Error()))
} else {
handler.SendOk(ctx, ctx.T(`操作成功`))
common.SendOk(ctx, ctx.T(`操作成功`))
}
return ctx.Redirect(handler.URLFor(`/frp/server_index`))
return ctx.Redirect(backend.URLFor(`/frp/server_index`))
}
}
} else if ctx.IsAjax() {
Expand Down Expand Up @@ -253,12 +253,12 @@ func ServerDelete(ctx echo.Context) error {
err = utils.SaveConfigFile(&dbschema.NgingFrpServer{Disabled: `Y`, Id: id})
}
if err == nil {
handler.SendOk(ctx, ctx.T(`操作成功`))
common.SendOk(ctx, ctx.T(`操作成功`))
} else {
handler.SendFail(ctx, err.Error())
common.SendFail(ctx, err.Error())
}

return ctx.Redirect(handler.URLFor(`/frp/server_index`))
return ctx.Redirect(backend.URLFor(`/frp/server_index`))
}

func ServerLog(ctx echo.Context) error {
Expand Down
2 changes: 1 addition & 1 deletion application/handler/service_client.go
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,7 @@ import (
"github.com/admpub/log"
"github.com/webx-top/echo"

"github.com/admpub/nging/v5/application/library/writer"
"github.com/coscms/webcore/library/writer"
"github.com/nging-plugins/frpmanager/application/library/cmder"
)

Expand Down
Loading

0 comments on commit 5f535d7

Please sign in to comment.