stream_test.go

package p4

import (
	"fmt"
	"testing"

	. "github.com/smartystreets/goconvey/convey"
)

func TestStream_Streams(t *testing.T) {
	var (
		si      *StreamInfo
		streams []*StreamInfo
		stream  = "//DM99.ZGame.Project/Development/ZGame_ArtDev"
	)
	conn, err := setup(t)
	Convey("test Stream functions", t, func() {
		So(err, ShouldBeNil)

		Convey("List streams", func() {
			streams, err = conn.Streams()
			So(err, ShouldBeNil)
			So(len(streams), ShouldBeGreaterThanOrEqualTo, 0)
		})

		Convey("Get stream info", func() {
			si, err = conn.Stream(stream)
			So(err, ShouldBeNil)
			So(si.Stream, ShouldEqual, stream)
		})

		//Convey("Get non-exist stream info", func() {
		//	si, err = conn.Stream(stream + "/abc")
		//	So(err, ShouldNotBeNil)
		//})

		Convey("Delete stream", func() {
			message, err := conn.DeleteStream(stream, true)
			So(err, ShouldBeNil)
			So(message, ShouldEqual, fmt.Sprintf("Stream %s deleted.", stream))
		})

		Convey("Create stream", func() {
			var (
				name       = "ZGame_ArtDev"
				parent     = "//DM99.ZGame.Project/Main/ZGame_Mainline"
				streamType = "development"
			)
			message, err := conn.CreateStream(name, streamType, parent, stream, true)
			So(err, ShouldBeNil)
			So(message, ShouldEqual, fmt.Sprintf("Stream %s saved.", stream))
		})

		Convey("Create stream mainline", func() {
			var (
				name       = "ZGame_Mainline2"
				mainline   = "//DM02.Elrond.Project/Main/Mainline2"
				streamType = "mainline"
			)
			// allsubmit unlocked toparent fromparent mergedown
			message, err := conn.CreateStream(name, streamType, "", mainline, false)
			So(err, ShouldBeNil)
			So(message, ShouldEqual, fmt.Sprintf("Stream %s saved.", mainline))
		})

		Convey("Create stream with invalid stream type", func() {
			var (
				name       = "ZGame_ArtDev"
				parent     = "//DM99.ZGame.Project/Main/ZGame_Mainline"
				streamType = "abc"
			)
			_, err := conn.CreateStream(name, streamType, parent, stream, true)
			So(err, ShouldNotBeNil)
		})
	})
}

func TestStream_DeleteStream(t *testing.T) {
	var (
		message string
		stream  = "//DM99.ZGame.Project/Development/ZGame_June"
	)
	conn, err := setup(t)
	Convey("test DeleteStream functions", t, func() {
		So(err, ShouldBeNil)

		Convey("Delete stream", func() {
			message, err = conn.DeleteStream(stream, false)
			So(err, ShouldBeNil)
			So(message, ShouldEqual, fmt.Sprintf("Stream %s deleted.", stream))
		})
	})
}

func TestStream_CreateVirtualStream(t *testing.T) {
	var (
		message    string
		stream     = "//DM99.ZGame.Project/Virtual/ZGame_Virtual"
		name       = "ZGame_ArtDev"
		parent     = "//DM99.ZGame.Project/Main/ZGame_Mainline"
		streamType = "development"
	)
	conn, err := setup(t)
	Convey("test CreateStream functions", t, func() {
		So(err, ShouldBeNil)

		Convey("Delete stream", func() {
			message, err = conn.DeleteStream(stream, true)
			So(err, ShouldBeNil)
			So(message, ShouldEqual, fmt.Sprintf("Stream %s deleted.", stream))
		})

		Convey("Create stream", func() {
			message, err = conn.CreateStream(name, streamType, parent, stream, true, WithOptions([]int{AllSubmit, UnLocked, ToParent, FromParent, MergeDown}))
			So(err, ShouldBeNil)
			So(message, ShouldEqual, fmt.Sprintf("Stream %s saved.", stream))
		})
	})
}

func TestStream_ImportStream(t *testing.T) {
	var (
		si *StreamInfo

		stream = "//DM99.ZGame.Project/Main/ZGame_Mainline"
	)
	conn, err := setup(t)
	Convey("test Get Stream functions", t, func() {
		So(err, ShouldBeNil)

		Convey("Get stream info", func() {
			si, err = conn.Stream(stream)
			So(err, ShouldBeNil)
			So(si.Stream, ShouldEqual, stream)
		})
	})
}