job_test.go

package offline

import (
	"context"
	"encoding/json"
	"github.com/tidwall/gjson"
	"strconv"
	"testing"
)

func TestNewJob(t *testing.T) {

	ctx := context.Background()

	job_type := "testing"

	instructions := map[string]interface{}{
		"name": "testing",
		"id":   1234,
	}

	enc_instructions, err := json.Marshal(instructions)

	if err != nil {
		t.Fatalf("Failed to marshal instructions, %v", err)
	}

	str_instructions := string(enc_instructions)

	j, err := NewJob(ctx, "testing", job_type, str_instructions)

	if err != nil {
		t.Fatalf("Failed to create new job, %v", err)
	}

	if j.Status != Pending {
		t.Fatalf("Unexpected status: %v", j.Status)
	}

	if j.Type != job_type {
		t.Fatalf("Invalid job type. Expected '%s' but got '%s'", job_type, j.Type)
	}

}

func TestJobStatusResponse(t *testing.T) {

	ctx := context.Background()

	j, err := NewJob(ctx, "testing", "testing", "testing")

	if err != nil {
		t.Fatalf("Failed to create new job, %v", err)
	}

	j.Id = 1592265428804046848

	s := j.AsStatusResponse()

	s_id, err := strconv.ParseInt(s.JobId, 10, 64)

	if err != nil {
		t.Fatalf("Failed to parse job status ID, %v", err)
	}

	if s_id != j.Id {
		t.Fatalf("Invalid job status ID, %d", s_id)
	}

	enc_s, err := json.Marshal(s)

	if err != nil {
		t.Fatalf("Failed to marshal job status, %v", err)
	}

	id_rsp := gjson.GetBytes(enc_s, "job_id")

	if id_rsp.Int() != j.Id {
		t.Fatalf("Invalid job status ID (encoded), %d", id_rsp.Int())
	}
}