cmd/dynamo-browse
1
0
Fork 0
Code Issues Pull requests Actions Packages Projects Releases 5 Wiki Activity

Added RS first #2

Merged
lmika merged 3 commits from feature/rs-first into main 2025-10-24 06:48:28 +00:00
Conversation 0 Commits 3 Files changed 5 +10 -9
2 changed files with 10 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files
Showing only changes of commit b8ec434b5d - Show all commits

11
internal/common/ui/commandctrl/cmdpacks/modpb_test.go
View file

@ -1,8 +1,9 @@
package cmdpacks_test package cmdpacks_test
import ( import (
"github.com/stretchr/testify/assert"
"testing" "testing"
"github.com/stretchr/testify/assert"
) )
func TestModPB_Copy(t *testing.T) { func TestModPB_Copy(t *testing.T) {
@ -10,8 +11,8 @@ func TestModPB_Copy(t *testing.T) {
svc := newService(t) svc := newService(t)
_, err := svc.CommandController.ExecuteAndWait(t.Context(), ` _, err := svc.CommandController.ExecuteAndWait(t.Context(), `
$items = @resultset.Items items = @resultset.Items
$skItems = $items | map { |i| $i.sk } | lists:uniq skItems = $items | map { |i| $i.sk } | lists:uniq
pb:copy ($skItems | strs:join "\n") pb:copy ($skItems | strs:join "\n")
`) `)
assert.NoError(t, err) assert.NoError(t, err)
@ -23,8 +24,8 @@ func TestModPB_Copy(t *testing.T) {
svc := newService(t) svc := newService(t)
_, err := svc.CommandController.ExecuteAndWait(t.Context(), ` _, err := svc.CommandController.ExecuteAndWait(t.Context(), `
$items = @resultset.Items items = @resultset.Items
$skItems = $items | map { |i| $i.alpha } | filter !nil | lists:uniq skItems = $items | map { |i| $i.alpha } | filter !nil | lists:uniq
pb:copy ($skItems | strs:join "\n") pb:copy ($skItems | strs:join "\n")
`) `)
assert.NoError(t, err) assert.NoError(t, err)

8
internal/common/ui/commandctrl/cmdpacks/modrs_test.go
View file

@ -71,7 +71,7 @@ func TestModRS_Union(t *testing.T) {
svc := newService(t, withDefaultLimit(2)) svc := newService(t, withDefaultLimit(2))
rsProxy, err := svc.CommandController.ExecuteAndWait(t.Context(), ` rsProxy, err := svc.CommandController.ExecuteAndWait(t.Context(), `
$mr = rs:union @resultset (rs:next-page @resultset) mr = rs:union @resultset (rs:next-page @resultset)
assert (eq (len $mr.Items) 3) "expected len == 3" assert (eq (len $mr.Items) 3) "expected len == 3"
assert (eq $mr.Items.(0).pk "abc") "expected 0.pk" assert (eq $mr.Items.(0).pk "abc") "expected 0.pk"
@ -162,14 +162,14 @@ func TestModRS_First(t *testing.T) {
{ {
descr: "returns the first item in sorted order", descr: "returns the first item in sorted order",
cmd: ` cmd: `
$rs = rs:query 'pk="abc"' -table service-test-data rs = rs:query 'pk="abc"' -table service-test-data
assert (eq $rs.First.pk "abc") "expected First.pk == abc" assert (eq $rs.First.pk "abc") "expected First.pk == abc"
assert (eq $rs.First.sk "111") "expected First.sk == 111" assert (eq $rs.First.sk "111") "expected First.sk == 111"
`, `,
}, { }, {
descr: "returns the first item in single item", descr: "returns the first item in single item",
cmd: ` cmd: `
$rs = rs:query 'pk="abc" and sk="222"' -table service-test-data rs = rs:query 'pk="abc" and sk="222"' -table service-test-data
assert (eq $rs.First.pk "abc") "expected First.pk == abc" assert (eq $rs.First.pk "abc") "expected First.pk == abc"
assert (eq $rs.First.sk "222") "expected First.sk == 222" assert (eq $rs.First.sk "222") "expected First.sk == 222"
assert (eq $rs.First.beta 1231) "expected First.beta == 1231" assert (eq $rs.First.beta 1231) "expected First.beta == 1231"
@ -177,7 +177,7 @@ func TestModRS_First(t *testing.T) {
}, { }, {
descr: "returns the first item in empty result", descr: "returns the first item in empty result",
cmd: ` cmd: `
$rs = rs:query 'pk="zzz"' -table service-test-data rs = rs:query 'pk="zzz"' -table service-test-data
assert (eq $rs.First ()) "expected First to be nil" assert (eq $rs.First ()) "expected First to be nil"
`, `,
}, },