job_api_test.go

package intercom

import (
	"io/ioutil"
	"testing"
)

func TestJobAPISaveUser(t *testing.T) {
	http := TestJobHTTPClient{t: t, expectedURI: "/bulk/users", fixtureFilename: "fixtures/job.json"}
	api := JobAPI{httpClient: &http}
	user := User{UserID: "1234"}
	job := JobRequest{Items: []*JobItem{NewUserJobItem(&user, JOB_POST)}, bulkType: "users"}
	http.f = func(job *JobRequest) {
		if job.Items[0].DataType != "user" {
			t.Errorf("job item was of wrong data type, expected %s, was %s", "user", job.Items[0].DataType)
		}
		if job.Items[0].Data.(requestUser).UserID != "1234" {
			t.Errorf("wrong user id sent")
		}
	}
	savedJob, _ := api.save(&job)
	if savedJob.ID != "job_5ca1ab1eca11ab1e" {
		t.Errorf("Did not respond with correct job")
	}
}

func TestJobAPISaveEvent(t *testing.T) {
	http := TestJobHTTPClient{t: t, expectedURI: "/bulk/events", fixtureFilename: "fixtures/job.json"}
	api := JobAPI{httpClient: &http}
	event := Event{UserID: "1234"}
	job := JobRequest{Items: []*JobItem{NewEventJobItem(&event)}, bulkType: "events"}
	http.f = func(job *JobRequest) {
		if job.Items[0].DataType != "event" {
			t.Errorf("job item was of wrong data type, expected %s, was %s", "event", job.Items[0].DataType)
		}
		if job.Items[0].Data.(*Event).UserID != "1234" {
			t.Errorf("wrong user id sent")
		}
	}
	savedJob, _ := api.save(&job)
	if savedJob.ID != "job_5ca1ab1eca11ab1e" {
		t.Errorf("Did not respond with correct job")
	}
}

type TestJobHTTPClient struct {
	TestHTTPClient
	t               *testing.T
	f               func(job *JobRequest)
	fixtureFilename string
	expectedURI     string
}

func (t *TestJobHTTPClient) Post(uri string, body interface{}) ([]byte, error) {
	if t.expectedURI != uri {
		t.t.Errorf("Wrong endpoint called")
	}
	if t.f != nil {
		t.f(body.(*JobRequest))
	}
	return ioutil.ReadFile(t.fixtureFilename)
}