forked from x/icebergs
79 lines
3.0 KiB
Go
79 lines
3.0 KiB
Go
package web
|
|
|
|
import (
|
|
"strings"
|
|
|
|
ice "shylinux.com/x/icebergs"
|
|
"shylinux.com/x/icebergs/base/aaa"
|
|
"shylinux.com/x/icebergs/base/cli"
|
|
"shylinux.com/x/icebergs/base/ctx"
|
|
"shylinux.com/x/icebergs/base/gdb"
|
|
"shylinux.com/x/icebergs/base/mdb"
|
|
"shylinux.com/x/icebergs/base/web/html"
|
|
kit "shylinux.com/x/toolkits"
|
|
)
|
|
|
|
func _stream_subkey(m *ice.Message, arg ...string) *ice.Message {
|
|
kit.If(len(arg) == 0, func() { arg = append(arg, kit.Hashs(kit.Fields(m.Option(ice.MSG_SPACE), m.Option(ice.MSG_INDEX)))) })
|
|
return m.Options(mdb.SUBKEY, kit.Keys(mdb.HASH, arg[0]), ice.MSG_FIELDS, mdb.Config(m, mdb.FIELDS))
|
|
}
|
|
|
|
const (
|
|
PUSH = "push"
|
|
)
|
|
const STREAM = "stream"
|
|
|
|
func init() {
|
|
Index.MergeCommands(ice.Commands{
|
|
STREAM: {Name: "stream hash daemon auto", Help: "推送流", Actions: ice.MergeActions(ice.Actions{
|
|
ONLINE: {Hand: func(m *ice.Message, arg ...string) {
|
|
if m.Option(ice.MSG_DAEMON) == "" {
|
|
return
|
|
}
|
|
mdb.HashCreate(m, SPACE, m.Option(ice.MSG_SPACE), ctx.INDEX, m.Option(ice.MSG_INDEX), mdb.SHORT, cli.DAEMON, mdb.FIELD, mdb.Config(m, mdb.FIELDS))
|
|
mdb.HashCreate(_stream_subkey(m), ParseUA(m))
|
|
mdb.HashSelect(m)
|
|
}},
|
|
PUSH: {Role: aaa.VOID, Hand: func(m *ice.Message, arg ...string) {
|
|
m.Options(ice.MSG_SPACE, arg[0], ice.MSG_INDEX, arg[1])
|
|
mdb.HashSelect(_stream_subkey(m)).Table(func(value ice.Maps) {
|
|
if !kit.IsIn(value[cli.DAEMON], strings.TrimPrefix(m.Option(ice.MSG_DAEMON), "ops."), m.Option(ice.MSG_DAEMON0)) {
|
|
m.Options(mdb.SUBKEY, "").Cmd(SPACE, value[cli.DAEMON], arg[2:])
|
|
}
|
|
})
|
|
}},
|
|
PORTAL_CLOSE: {Hand: func(m *ice.Message, arg ...string) {
|
|
mdb.HashSelect(m).Table(func(value ice.Maps) {
|
|
mdb.HashSelect(_stream_subkey(m, value[mdb.HASH]).Spawn()).Table(func(value ice.Maps) {
|
|
if strings.HasPrefix(value[cli.DAEMON], m.Option(mdb.NAME)) {
|
|
mdb.HashRemove(m, mdb.HASH, kit.Hashs(value[cli.DAEMON]))
|
|
}
|
|
})
|
|
})
|
|
}},
|
|
}, gdb.EventsAction(PORTAL_CLOSE), mdb.ClearOnExitHashAction(), mdb.HashAction(
|
|
mdb.SHORT, "space,index", mdb.FIELD, "time,hash,space,index",
|
|
mdb.FIELDS, "time,daemon,userrole,username,usernick,avatar,icons,agent,system,ip,ua",
|
|
)), Hand: func(m *ice.Message, arg ...string) {
|
|
if len(arg) == 0 {
|
|
mdb.HashSelect(m)
|
|
} else {
|
|
mdb.HashSelect(_stream_subkey(m, arg[0]), arg[1:]...)
|
|
}
|
|
}},
|
|
})
|
|
}
|
|
func StreamPush(m *ice.Message, arg ...string) {
|
|
AdminCmd(m, STREAM, PUSH, m.Option(ice.MSG_USERPOD), m.ShortKey(), arg)
|
|
}
|
|
func StreamPushRefresh(m *ice.Message, arg ...string) {
|
|
StreamPush(m.Spawn(ice.Maps{"space.noecho": ice.TRUE}), kit.Simple(html.REFRESH, arg)...)
|
|
if strings.Contains(m.Option(ice.MSG_USERPOD), ".") {
|
|
AdminCmd(m.Spawn(ice.Maps{"space.noecho": ice.TRUE}), SPACE, ice.DEV, STREAM, PUSH, m.Option(ice.MSG_USERPOD), m.ShortKey(), kit.Simple(html.REFRESH, arg))
|
|
}
|
|
}
|
|
func StreamPushRefreshConfirm(m *ice.Message, arg ...string) {
|
|
kit.If(len(arg) == 0, func() { arg = append(arg, m.Trans("refresh for new data ", "刷新列表，查看最新数据 ")) })
|
|
StreamPushRefresh(m, kit.Simple(html.CONFIRM, arg)...)
|
|
}
|