liubin/icebergs
1
0
Fork 0
forked from x/icebergs
Code Pull Requests Activity

add some

Browse Source
This commit is contained in:
IT 老营长 @云轩领航-创始人 2024-02-22 09:20:01 +08:00
parent eb1e42295d
commit bfb9f99734
2 changed files with 13 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
core/chat/script.js
View File

@ -10,18 +10,21 @@ Volcanos(chat.ONIMPORT, {
Volcanos(chat.ONACTION, {
record: function(event, can, msg) { can.misc.sessionStorage(can, SCRIPT_ZONE, msg.Option(mdb.ZONE)), can.user.toastSuccess(can, msg.Option(mdb.ZONE)), can.Update(event) },
stop: function(event, can, msg) { can.misc.sessionStorage(can, SCRIPT_ZONE, ""), can.Update(event) },
play: function(event, can) { var begin = new Date().getTime(); can.core.Next(can._msg.Table(), function(value, next, index, list, data) {
play: function(event, can) { var last = 0, count = 0, begin = new Date().getTime(); can.core.Next(can._msg.Table(), function(value, next, index, list, data) {
var ls = can.core.Split(value.style||""); data = data||{}, data.list = data.list||[]; var fork
if (data.skip > 0) { return next({skip: data.skip-1}) }
if (data.done === 0) { return } if (data.done > 0) { data.done -= 1 } data.list.push(value)
if (ls && ls.length > 0 && ls[0] == "fork") { data.done = parseInt(ls[1]), fork = {skip: parseInt(ls[1])} }
can.user.toastProcess(can, `${can.core.Keys(value.space, value.index)} ${value.play} ${index}/${can._msg.Length()}`, "", index*100/list.length)
var tr = can.page.Select(can, can._output, html.TR)[1]; can.onmotion.select(can, tr.parentNode, html.TR, index)
can.Status(cli.STEP, index), can.Status(cli.COST, can.base.Duration(new Date().getTime()-begin))
value.status == mdb.DISABLE? next(data): can.onaction.preview({}, can, can.request({}, value), next, data)
if (index >= last) { last = index, can.user.toastProcess(can, `${can.core.Keys(value.space, value.index)} ${value.play} ${index}/${can._msg.Length()}`, "", index*100/list.length) }
var tr = can.page.Select(can, can._output, html.TR)[index+1]; tr.onclick = function(event) { tr._sub && can.onmotion.scrollIntoView(can, tr._sub._target) }
can.page.Select(can, can._output, html.TR, function(tr, i) { i-1 == index && can.onappend.style(can, value.status == mdb.DISABLE? "done": "select", tr) })
can.Status(cli.STEP, ++count), can.Status(cli.COST, can.base.Duration(new Date().getTime()-begin))
value.status == mdb.DISABLE? next(data): can.onaction.preview({}, can, can.request({}, value), function(data) {
can.page.Select(can, can._output, html.TR, function(tr, i) { i-1 == index && can.onappend.style(can, "done", tr) }), next(data)
}, data, tr)
if (fork) { next(fork) }
}, function(list) { can.Status(cli.STEP, list.length), can.Status(cli.COST, can.base.Duration(new Date().getTime()-begin)), can.user.toastSuccess(can) }) },
preview: function(event, can, msg, next, data) {
preview: function(event, can, msg, next, data, tr) {
can.onappend.plugin(can, {space: msg.Option(web.SPACE), index: msg.Option(ctx.INDEX), style: msg.Option(ctx.STYLE)}, function(sub) { var done = false
function action(skip) { sub.Update(sub.request({}, {_handle: ice.TRUE}), [ctx.ACTION, msg.Option(cli.PLAY)], function(msg) {
sub.onimport._process(sub, msg) || msg.Length() == 0 && msg.Result() == "" || can.onappend._output(sub, msg), next && next(data)
@ -33,7 +36,9 @@ Volcanos(chat.ONACTION, {
}
sub.onexport.output = function() { can.page.style(can, sub._output, html.HEIGHT, "", html.MAX_HEIGHT, "")
if (done) { return } done = true, action(true)
}, msg.Option(ctx.STYLE) == html.HIDE || can.onmotion.delay(can, function() { can.onmotion.scrollIntoView(can, sub._target) }, 300)
}
tr._sub = sub
// msg.Option(ctx.STYLE) == html.HIDE || can.onmotion.delay(can, function() { can.onmotion.scrollIntoView(can, sub._target) }, 300)
})
},
})

2
exec.go
View File

@ -163,7 +163,7 @@ func (m *Message) _command(arg ...Any) *Message {
}
}
}
if count := kit.Int(m.Option(MSG_COUNT, kit.Format(kit.Int(m.Option(MSG_COUNT))+1))); m.Warn(count > 300, ErrTooDeepCount) {
if count := kit.Int(m.Option(MSG_COUNT, kit.Format(kit.Int(m.Option(MSG_COUNT))+1))); m.Warn(count > 3000, ErrTooDeepCount) {
panic(count)
}
list := kit.Simple(args...)