Skip to content

Commit

Permalink
use kube
Browse files Browse the repository at this point in the history
Signed-off-by: Sam Batschelet <sam.batschelet@avalabs.org>
  • Loading branch information
hexfusion committed Jun 23, 2023
1 parent 17fbccc commit 370bc57
Showing 1 changed file with 11 additions and 8 deletions.
19 changes: 11 additions & 8 deletions vms/rpcchainvm/runtime/podman/client_test.go
Original file line number Diff line number Diff line change
@@ -1,11 +1,15 @@
package podman

import (
"bytes"
"context"
"fmt"
"testing"

"github.com/containers/podman/v4/pkg/bindings"
"github.com/containers/podman/v4/pkg/bindings/kube"
"gopkg.in/yaml.v2"

"github.com/stretchr/testify/require"
v1 "k8s.io/api/core/v1"
"k8s.io/client-go/kubernetes/scheme"
Expand Down Expand Up @@ -44,23 +48,22 @@ func TestSchedulePod(t *testing.T) {
},
)

podBytes, err := yaml.Marshal(&pod)
require.NoError(err)

fmt.Printf("%#v\n", pod)

socket, err := getSocketPath()
require.NoError(err)

fmt.Printf("%#v\n", socket)
ctx, err := bindings.NewConnection(context.Background(), socket)
require.NoError(err)

rawImage := pod.Spec.Containers[0].Image
client := NewClient()
images, err := client.Pull(ctx, rawImage)
report, err := kube.PlayWithBody(ctx, bytes.NewReader(podBytes), &kube.PlayOptions{})
require.NoError(err)
require.Equal(1, len(images))

id, err := client.Start(ctx, rawImage)
require.NoError(err)
fmt.Printf("%#v\n", report)


err = client.Stop(ctx, id)
require.NoError(err)
}

0 comments on commit 370bc57

Please sign in to comment.