crons_integration_test.go

// Copyright (c) 2015 Ableton AG, Berlin. All rights reserved.
//
// Use of this source code is governed by a BSD-style
// license that can be found in the LICENSE file.

// +build integration

package travis

import (
	"context"
	"net/http"
	"testing"
	"time"
)

func TestCronService_Integration_ListByRepoId(t *testing.T) {
	// Create a cron by repository id
	createdCron, res, err := integrationClient.Crons.CreateByRepoId(
		context.TODO(),
		integrationRepoId,
		"master",
		&CronBody{Interval: CronIntervalMonthly, DontRunIfRecentBuildExists: true},
	)

	if err != nil {
		t.Fatalf("Cron.CreateByRepoId unexpected error occured: %s", err)
	}

	if res.StatusCode != http.StatusOK {
		t.Fatalf("Cron.CreateByRepoId invalid http status: %s", res.Status)
	}

	time.Sleep(2 * time.Second)

	// Find crons
	opt := CronsOption{Limit: 5, Include: []string{"cron.repository", "cron.branch"}}
	crons, res, err := integrationClient.Crons.ListByRepoId(context.TODO(), integrationRepoId, &opt)

	if err != nil {
		t.Fatalf("Cron.ListByRepoId unexpected error occured: %s", err)
	}

	if res.StatusCode != http.StatusOK {
		t.Fatalf("Cron.ListByRepoId invalid http status: %s", res.Status)
	}

	if got, want := len(crons), 1; got != want {
		t.Fatalf("Cron.ListByRepoId returns invalid number of items: want %d, got %d", want, got)
	}

	if got, want := *crons[0].Id, *createdCron.Id; got != want {
		t.Fatalf("Cron.ListByRepoId returns invalid item id: want %d, got %d", want, got)
	}

	if !crons[0].Repository.IsStandard() {
		t.Fatal("Cron.ListByRepoId returns minimal repository")
	}

	if !crons[0].Branch.IsStandard() {
		t.Fatal("Cron.ListByRepoId returns minimal branch")
	}

	time.Sleep(2 * time.Second)

	// Delete a cron
	res, err = integrationClient.Crons.Delete(context.TODO(), *createdCron.Id)

	if err != nil {
		t.Fatalf("Cron.Delete unexpected error occured: %s", err)
	}

	if res.StatusCode != http.StatusNoContent {
		t.Fatalf("Cron.Delete invalid http status: %s", res.Status)
	}
}

func TestCronService_Integration_ListByRepoSlug(t *testing.T) {
	// Create a cron by repository id
	createdCron, res, err := integrationClient.Crons.CreateByRepoId(
		context.TODO(),
		integrationRepoId,
		"master",
		&CronBody{Interval: CronIntervalMonthly, DontRunIfRecentBuildExists: true},
	)

	if err != nil {
		t.Fatalf("Cron.CreateByRepoId unexpected error occured: %s", err)
	}

	if res.StatusCode != http.StatusOK {
		t.Fatalf("Cron.CreateByRepoId invalid http status: %s", res.Status)
	}

	time.Sleep(2 * time.Second)

	// Find crons
	opt := CronsOption{Limit: 5, Include: []string{"cron.repository", "cron.branch"}}
	crons, res, err := integrationClient.Crons.ListByRepoSlug(context.TODO(), integrationRepoSlug, &opt)

	if err != nil {
		t.Fatalf("Cron.ListByRepoSlug unexpected error occured: %s", err)
	}

	if res.StatusCode != http.StatusOK {
		t.Fatalf("Cron.ListByRepoSlug invalid http status: %s", res.Status)
	}

	if got, want := len(crons), 1; got != want {
		t.Fatalf("Cron.ListByRepoSlug returns invalid number of items: want %d, got %d", want, got)
	}

	if got, want := *crons[0].Id, *createdCron.Id; got != want {
		t.Fatalf("Cron.ListByRepoSlug returns invalid item id: want %d, got %d", want, got)
	}

	if !crons[0].Repository.IsStandard() {
		t.Fatal("Cron.ListByRepoSlug returns minimal repository")
	}

	if !crons[0].Branch.IsStandard() {
		t.Fatal("Cron.ListByRepoSlug returns minimal branch")
	}

	time.Sleep(2 * time.Second)

	// Delete a cron
	res, err = integrationClient.Crons.Delete(context.TODO(), *createdCron.Id)

	if err != nil {
		t.Fatalf("Cron.Delete unexpected error occured: %s", err)
	}

	if res.StatusCode != http.StatusNoContent {
		t.Fatalf("Cron.Delete invalid http status: %s", res.Status)
	}
}

func TestCronsService_Integration_CreateAndFindAndDeleteCron(t *testing.T) {
	// Create a cron by repository id
	body := CronBody{Interval: CronIntervalMonthly, DontRunIfRecentBuildExists: true}
	createdCron, res, err := integrationClient.Crons.CreateByRepoId(context.TODO(), integrationRepoId, "master", &body)

	if err != nil {
		t.Fatalf("Cron.CreateByRepoId unexpected error occured: %s", err)
	}

	if res.StatusCode != http.StatusOK {
		t.Fatalf("Cron.CreateByRepoId invalid http status: %s", res.Status)
	}

	if got, want := *createdCron.Interval, CronIntervalMonthly; got != want {
		t.Errorf("Cron.CreateByRepoId unexpected cron interval returned: want %s got %s", want, got)
	}

	if got, want := *createdCron.DontRunIfRecentBuildExists, true; got != want {
		t.Errorf("Cron.CreateByRepoId unexpected cron DontRunIfRecentBuildExists returned: want %v got %v", want, got)
	}

	time.Sleep(2 * time.Second)

	// Delete a cron
	res, err = integrationClient.Crons.Delete(context.TODO(), *createdCron.Id)

	if err != nil {
		t.Fatalf("Cron.Delete unexpected error occured: %s", err)
	}

	if res.StatusCode != http.StatusNoContent {
		t.Fatalf("Cron.Delete invalid http status: %s", res.Status)
	}

	time.Sleep(2 * time.Second)

	// Create a cron by repository slug
	createdCron, res, err = integrationClient.Crons.CreateByRepoSlug(context.TODO(), integrationRepoSlug, "master", &body)

	if err != nil {
		t.Fatalf("Cron.CreateByRepoSlug unexpected error occured: %s", err)
	}

	if res.StatusCode != http.StatusOK {
		t.Fatalf("Cron.CreateByRepoSlug invalid http status: %s", res.Status)
	}

	if got, want := *createdCron.Interval, CronIntervalMonthly; got != want {
		t.Errorf("Cron.CreateByRepoSlug unexpected cron interval returned: want %s got %s", want, got)
	}

	if got, want := *createdCron.DontRunIfRecentBuildExists, true; got != want {
		t.Errorf("Cron.CreateByRepoSlug unexpected cron DontRunIfRecentBuildExists returned: want %v got %v", want, got)
	}

	time.Sleep(2 * time.Second)

	// Find a cron
	opt := CronOption{Include: []string{"cron.repository", "cron.branch"}}
	findCron, res, err := integrationClient.Crons.Find(context.TODO(), *createdCron.Id, &opt)

	if err != nil {
		t.Fatalf("Cron.Find unexpected error occured: %s", err)
	}

	if res.StatusCode != http.StatusOK {
		t.Fatalf("Cron.Find invalid http status: %s", res.Status)
	}

	if got, want := *findCron.Id, *createdCron.Id; got != want {
		t.Errorf("Cron.Find unexpected cron interval returned: want %d got %d", want, got)
	}

	if got, want := *findCron.Interval, CronIntervalMonthly; got != want {
		t.Errorf("Cron.Find unexpected cron interval returned: want %s got %s", want, got)
	}

	if got, want := *findCron.DontRunIfRecentBuildExists, true; got != want {
		t.Errorf("Cron.Find unexpected cron DontRunIfRecentBuildExists returned: want %v got %v", want, got)
	}

	if !findCron.Repository.IsStandard() {
		t.Error("Cron.Find returns minimal repository")
	}

	if !findCron.Branch.IsStandard() {
		t.Error("Cron.Find returns minimal branch")
	}

	time.Sleep(2 * time.Second)

	// Find a cron by repository id
	findCron, res, err = integrationClient.Crons.FindByRepoId(context.TODO(), integrationRepoId, "master", &opt)

	if err != nil {
		t.Fatalf("Cron.FindByRepoId unexpected error occured: %s", err)
	}

	if res.StatusCode != http.StatusOK {
		t.Fatalf("Cron.FindByRepoId invalid http status: %s", res.Status)
	}

	if got, want := *findCron.Id, *createdCron.Id; got != want {
		t.Errorf("Cron.FindByRepoId unexpected cron interval returned: want %d got %d", want, got)
	}

	if got, want := *findCron.Interval, CronIntervalMonthly; got != want {
		t.Errorf("Cron.FindByRepoId unexpected cron interval returned: want %s got %s", want, got)
	}

	if got, want := *findCron.DontRunIfRecentBuildExists, true; got != want {
		t.Errorf("Cron.FindByRepoId unexpected cron DontRunIfRecentBuildExists returned: want %v got %v", want, got)
	}

	if !findCron.Repository.IsStandard() {
		t.Error("Cron.FindByRepoId returns minimal repository")
	}

	if !findCron.Branch.IsStandard() {
		t.Error("Cron.FindByRepoId returns minimal branch")
	}

	time.Sleep(2 * time.Second)

	// Find a cron by repository slug
	findCron, res, err = integrationClient.Crons.FindByRepoSlug(context.TODO(), integrationRepoSlug, "master", &opt)

	if err != nil {
		t.Fatalf("Cron.FindByRepoSlug unexpected error occured: %s", err)
	}

	if res.StatusCode != http.StatusOK {
		t.Fatalf("Cron.FindByRepoSlug invalid http status: %s", res.Status)
	}

	if got, want := *findCron.Id, *createdCron.Id; got != want {
		t.Errorf("Cron.FindByRepoSlug unexpected cron interval returned: want %d got %d", want, got)
	}

	if got, want := *findCron.Interval, CronIntervalMonthly; got != want {
		t.Errorf("Cron.FindByRepoSlug unexpected cron interval returned: want %s got %s", want, got)
	}

	if got, want := *findCron.DontRunIfRecentBuildExists, true; got != want {
		t.Errorf("Cron.FindByRepoSlug unexpected cron DontRunIfRecentBuildExists returned: want %v got %v", want, got)
	}

	if !findCron.Repository.IsStandard() {
		t.Error("Cron.FindByRepoSlug returns minimal repository")
	}

	if !findCron.Branch.IsStandard() {
		t.Error("Cron.FindByRepoSlug returns minimal branch")
	}

	time.Sleep(2 * time.Second)

	// Delete a cron
	res, err = integrationClient.Crons.Delete(context.TODO(), *createdCron.Id)

	if err != nil {
		t.Fatalf("Cron.Delete unexpected error occured: %s", err)
	}

	if res.StatusCode != http.StatusNoContent {
		t.Fatalf("Cron.Delete invalid http status: %s", res.Status)
	}
}