job_test.go

package client

import (
	. "github.com/onsi/ginkgo"
	. "github.com/onsi/gomega"

	"encoding/json"
	"net/http"
)

var _ = Describe("Jobs", func() {
	var (
		jobInput      JobInput
		job           Job
		jobJSONOutput string
	)
	BeforeEach(func() {
		jobJSONOutput = `{
			"id":"5iNcv6pMWYVCZhRL",
			"source":"http://flv.io/KailuaBeach.mp4",
			"destination":"http://AKIAII3C6HP:4wooQI51NXIN5ELJNTq@snickers-media.s3.amazonaws.com/outputs/",
			"preset":{
				"name":"mp4_240p",
				"description":"Encodes video in H264/MP4 @ 240p",
				"container":"mp4",
				"rateControl":"vbr",
				"video":{
					"width":"426",
					"height":"240",
					"codec":"h264",
					"bitrate":"1000000",
					"gopSize":"90",
					"gopMode":"fixed",
					"profile":"main",
					"profileLevel":"3.1",
					"interlaceMode":"progressive"
				},
				"audio":{
					"codec":"aac",
					"bitrate":"64000"
				}
			},
			"status":"created",
			"progress":""
		}`

		json.Unmarshal([]byte(jobJSONOutput), &job)

		jobInput = JobInput{
			Source:      "http://flv.io/KailuaBeach.mp4",
			Destination: "http://AKIAII3C6HP:4wooQI51NXIN5ELJNTq@snickers-media.s3.amazonaws.com/outputs/",
			PresetName:  "mp4_240p",
		}
	})

	It("should return a list of jobs", func() {
		expectedJobs := []Job{
			job,
		}
		server := StartFakeServer(http.StatusOK, "["+jobJSONOutput+"]")
		defer server.Close()
		client, _ := NewClient(server.URL)
		respJob, err := client.GetJobs()
		Expect(respJob).To(Equal(expectedJobs))
		Expect(err).NotTo(HaveOccurred())
	})

	It("should fail to retrieve a list of jobs", func() {
		apiError := &APIError{
			Status: http.StatusBadRequest,
			Errors: "Failed to retrieve a list of jobs",
		}
		server := StartFakeServer(http.StatusBadRequest, "Failed to retrieve a list of jobs")
		defer server.Close()
		client, _ := NewClient(server.URL)
		_, err := client.GetJobs()
		Expect(err).To(HaveOccurred())
		Expect(err).To(Equal(apiError))
	})

	It("should return a given job details", func() {
		server := StartFakeServer(http.StatusOK, jobJSONOutput)
		defer server.Close()
		client, _ := NewClient(server.URL)
		respJob, err := client.GetJob("5iNcv6pMWYVCZhRL")
		Expect(respJob).To(Equal(&job))
		Expect(err).NotTo(HaveOccurred())
	})

	It("should fail to retrieve a given job details", func() {
		apiError := &APIError{
			Status: http.StatusBadRequest,
			Errors: "Failed to retrieve job details",
		}
		server := StartFakeServer(http.StatusBadRequest, "Failed to retrieve job details")
		defer server.Close()
		client, _ := NewClient(server.URL)
		_, err := client.GetJob("5iNcv6pMWYVCZhRL")
		Expect(err).To(HaveOccurred())
		Expect(err).To(Equal(apiError))
	})

	It("should start a job given a job id", func() {
		server := StartFakeServer(http.StatusOK, "")
		defer server.Close()
		client, _ := NewClient(server.URL)
		_, err := client.StartJob("5iNcv6pMWYVCZhRL")
		Expect(err).NotTo(HaveOccurred())
	})

	It("should fail to start a job", func() {
		apiError := &APIError{
			Status: http.StatusBadRequest,
			Errors: "Failed to start a job",
		}
		server := StartFakeServer(http.StatusBadRequest, "Failed to start a job")
		defer server.Close()
		client, _ := NewClient(server.URL)
		_, err := client.StartJob("5iNcv6pMWYVCZhRL")
		Expect(err).To(HaveOccurred())
		Expect(err).To(Equal(apiError))
	})

	It("should create a job", func() {
		server := StartFakeServer(http.StatusOK, jobJSONOutput)
		defer server.Close()
		client, _ := NewClient(server.URL)
		respJob, err := client.CreateJob(jobInput)
		Expect(respJob).To(Equal(&job))
		Expect(err).NotTo(HaveOccurred())
	})

	It("should fail to create a job", func() {
		apiError := &APIError{
			Status: http.StatusBadRequest,
			Errors: "Failed to create a job",
		}
		server := StartFakeServer(http.StatusBadRequest, "Failed to create a job")
		defer server.Close()
		client, _ := NewClient(server.URL)
		_, err := client.CreateJob(jobInput)
		Expect(err).To(HaveOccurred())
		Expect(err).To(Equal(apiError))
	})

})