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 { 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 { 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}) }