package workflow

import (
	"testing"

	"github.com/microsoft/durabletask-go/api"
	"github.com/stretchr/testify/assert"
)

func TestConvertMetadata(t *testing.T) {
	t.Run("convert metadata", func(t *testing.T) {
		rawMetadata := &api.OrchestrationMetadata{
			InstanceID: api.InstanceID("test"),
		}
		metadata := convertMetadata(rawMetadata)
		assert.NotEmpty(t, metadata)
	})
}

func TestCallChildWorkflowOptions(t *testing.T) {
	t.Run("child workflow input - valid", func(t *testing.T) {
		opts := returnCallChildWorkflowOptions(ChildWorkflowInput("test"))
		assert.Equal(t, "\"test\"", opts.rawInput.GetValue())
	})

	t.Run("child workflow raw input - valid", func(t *testing.T) {
		opts := returnCallChildWorkflowOptions(ChildWorkflowRawInput("test"))
		assert.Equal(t, "test", opts.rawInput.GetValue())
	})

	t.Run("child workflow instance id - valid", func(t *testing.T) {
		opts := returnCallChildWorkflowOptions(ChildWorkflowInstanceID("test"))
		assert.Equal(t, "test", opts.instanceID)
	})

	t.Run("child workflow input - invalid", func(t *testing.T) {
		opts := returnCallChildWorkflowOptions(ChildWorkflowInput(make(chan int)))
		assert.Empty(t, opts.rawInput.GetValue())
	})
}

func returnCallChildWorkflowOptions(opts ...callChildWorkflowOption) callChildWorkflowOptions {
	options := new(callChildWorkflowOptions)
	for _, configure := range opts {
		if err := configure(options); err != nil {
			return *options
		}
	}
	return *options
}

func TestNewTaskSlice(t *testing.T) {
	tasks := NewTaskSlice(10)
	assert.Len(t, tasks, 10)
}