1
0
forked from x/icebergs
icebergs/misc.go
2024-05-04 19:20:32 +08:00

206 lines
5.9 KiB
Go

package ice
import (
"strings"
kit "shylinux.com/x/toolkits"
)
func (m *Message) System(arg ...Any) *Message {
return Info.SystemCmd(m, arg...)
}
func (m *Message) AdminCmd(cmd string, arg ...Any) *Message {
return Info.AdminCmd(m, cmd, arg...)
}
func (m *Message) Template(p string, data ...Any) string {
return Info.Template(m, p, data...)
}
func (m *Message) Split(str string, arg ...string) *Message {
m.Set(MSG_APPEND).Set(MSG_RESULT)
field := kit.Select("", arg, 0)
sp, nl := kit.Select(SP, arg, 1), kit.Select(NL, arg, 2)
fields, indexs := kit.Split(field, sp, sp, sp), []int{}
for i, l := range kit.Split(str, nl, nl, nl) {
if strings.HasPrefix(l, "Binary") {
continue
}
if strings.TrimSpace(l) == "" {
continue
}
if i == 0 && (field == "" || field == INDEX) {
if fields = kit.Split(l, sp, sp); field == INDEX {
if strings.HasPrefix(l, SP) || strings.HasPrefix(l, TB) {
indexs = append(indexs, 0)
for _, v := range fields {
indexs = append(indexs, strings.Index(l, v)+len(v))
}
indexs = indexs[0 : len(indexs)-1]
} else {
for _, v := range fields {
indexs = append(indexs, strings.Index(l, v))
}
}
}
kit.For(fields, func(i int, v string) { fields[i] = strings.TrimPrefix(strings.TrimSpace(v), "%") })
continue
}
if len(indexs) > 0 {
for i, v := range indexs {
if v >= len(l) {
m.Push(kit.Select(SP, fields, i), "")
} else if i+1 < len(indexs) && indexs[i+1] < len(l) {
m.Push(kit.Select(SP, fields, i), strings.TrimSpace(l[v:indexs[i+1]]))
} else {
m.Push(kit.Select(SP, fields, i), strings.TrimSpace(l[v:]))
}
}
continue
}
ls := kit.Split(l, sp, sp)
for i, v := range ls {
if i == len(fields)-1 {
m.Push(kit.Select(SP, fields, i), strings.Join(ls[i:], sp))
break
}
m.Push(kit.Select(SP, fields, i), v)
}
}
return m
}
func (m *Message) SplitIndex(str string, arg ...string) *Message {
return m.Split(str, kit.Simple(INDEX, arg)...)
}
func (m *Message) SplitIndexReplace(str string, arg ...string) *Message {
return m.SplitIndex(kit.Replace(str, arg...))
}
func (m *Message) SetAppend(arg ...string) *Message {
kit.If(len(arg) == 0, func() { m.OptionFields("") })
return m.Set(MSG_APPEND, arg...)
}
func (m *Message) SetResult(arg ...string) *Message {
return m.Set(MSG_RESULT, arg...)
}
func (m *Message) PushRecord(value Any, arg ...string) *Message {
if m.FieldsIsDetail() {
return m.PushDetail(value, arg...)
} else {
return m.Push("", value, kit.Split(kit.Join(arg)))
}
}
func (m *Message) PushDetail(value Any, arg ...string) *Message {
switch v := value.(type) {
case string:
value = kit.UnMarshal(v)
}
m.Option(MSG_FIELDS, FIELDS_DETAIL)
return m.Push(FIELDS_DETAIL, value, kit.Split(kit.Join(arg)))
}
func (m *Message) RenameOption(from, to string) *Message {
return m.Options(to, m.Option(from), from, "")
}
func (m *Message) RenameAppend(arg ...string) *Message {
if m.FieldsIsDetail() {
list := m.value(KEY)
kit.For(list, func(k string, i int) {
kit.For(arg, func(from, to string) {
kit.If(k == from, func() { list[i] = to })
})
})
return m
}
kit.For(arg, func(from, to string) {
if from == to {
return
}
defer m.lock.Lock()()
kit.For(m._meta[MSG_APPEND], func(i int, k string) {
if k == from {
m._meta[MSG_APPEND][i], m._meta[to] = to, m._meta[from]
delete(m._meta, from)
}
})
})
return m
}
func (m *Message) RewriteAppend(cb func(value, key string, index int) string) *Message {
m.Table(func(value Maps, index int, head []string) {
for _, key := range head {
v := cb(value[key], key, index)
if m.FieldsIsDetail() {
m.Append(key, v)
} else {
m.index(key, index, v)
}
}
})
return m
}
func (m *Message) ToLowerAppend(arg ...string) *Message {
kit.For(m.value(MSG_APPEND), func(k string) { m.RenameAppend(k, strings.ToLower(k)) })
return m
}
func (m *Message) AppendSimple(key ...string) (res []string) {
if len(key) == 0 {
if m.FieldsIsDetail() {
key = append(key, m.value(KEY)...)
} else {
key = append(key, m.Appendv(MSG_APPEND)...)
}
}
kit.For(kit.Split(kit.Join(key)), func(k string) { res = append(res, k, m.Append(k)) })
return
}
func (m *Message) AppendTrans(cb func(value string, key string, index int) string) *Message {
if m.FieldsIsDetail() {
defer m.lock.Lock()()
for i, v := range m._meta[VALUE] {
k := m._meta[KEY][i]
m._meta[VALUE][i] = cb(v, k, 0)
}
return m
}
defer m.lock.Lock()()
for _, k := range m._meta[MSG_APPEND] {
for i, v := range m._meta[k] {
m._meta[k][i] = cb(v, k, i)
}
}
return m
}
func (m *Message) CmdAppend(arg ...Any) string {
args := kit.Simple(arg...)
field := kit.Slice(args, -1)[0]
return m._command(kit.Slice(args, 0, -1), OptionFields(field)).Append(field)
}
func (m *Message) CmdMap(arg ...string) map[string]map[string]string {
field, list := kit.Slice(arg, -1)[0], map[string]map[string]string{}
m._command(kit.Slice(arg, 0, -1), Maps{MSG_FIELDS: ""}).Table(func(value Maps) { list[value[field]] = value })
return list
}
func (m *Message) Toast(content string, arg ...string) { // title duration
Info.PushNotice(m, "toast", content, arg)
}
func (m *Message) PushStream() *Message { return Info.PushStream(m) }
func (m *Message) ToastSuccess(arg ...string) { m.Toast(SUCCESS, arg...) }
func (m *Message) ToastFailure(arg ...string) { m.Toast(FAILURE, arg...) }
func (m *Message) ToastProcess(arg ...string) func(...string) {
kit.If(len(arg) == 0, func() { arg = append(arg, "", "-1") })
m.Toast(PROCESS, arg...)
return func(arg ...string) { m.ToastSuccess(arg...) }
}
func (m *Message) Trans(en string, zh string) string {
switch strings.ToLower(kit.Select("", kit.Split(m.Option(MSG_LANGUAGE), "_-"), 0)) {
case "zh":
return zh
default:
return en
}
}
func (m *Message) IsEnglish() bool {
return kit.IsIn(strings.ToLower(m.Option(MSG_LANGUAGE)), "en", "en-us")
}
func (m *Message) SpawnSilent(arg ...Any) *Message {
return m.Spawn(Maps{LOG_DISABLE: TRUE})
}