swf configs

Author: Jesse Michael

swf_client_config.go

@@ -0,0 +1,25 @@
+package remoteconfig
+
+type SimpleWorkflowClientConfig struct {
+	Region     *AWSRegion `json:"region,omitempty"`
+	Endpoint   *string    `json:"endpoint,omitempty" remoteconfig:"optional"`
+	DisableSSL *bool      `json:"disable_ssl,omit" remoteconfig:"optional"`
+}
+
+func (s SimpleWorkflowClientConfig) GetRegion() AWSRegion {
+	return *s.Region
+}
+
+func (s SimpleWorkflowClientConfig) GetEndpoint() string {
+	if s.Endpoint != nil {
+		return *s.Endpoint
+	}
+	return ""
+}
+
+func (s SimpleWorkflowClientConfig) GetDisableSSL() bool {
+	if s.DisableSSL != nil {
+		return *s.DisableSSL
+	}
+	return false
+}

swf_client_config_test.go

@@ -0,0 +1,139 @@
+package remoteconfig
+
+import (
+	"errors"
+	"testing"
+
+	"github.com/stretchr/testify/assert"
+	"github.com/stretchr/testify/suite"
+)
+
+const (
+	VALID_SWF_CLIENT_REGION      AWSRegion = AWS_REGION_US_EAST_1
+	VALID_SWF_CLIENT_ENDPOINT    string    = "http://localhost:8000/swf"
+	VALID_SWF_CLIENT_DISABLE_SSL bool      = true
+)
+
+type SimpleWorkflowClientConfigSuite struct {
+	suite.Suite
+}
+
+func TestSimpleWorkflowClientConfigSuite(t *testing.T) {
+	suite.Run(t, new(SimpleWorkflowClientConfigSuite))
+}
+
+func (s *SimpleWorkflowClientConfigSuite) SetupSuite() {
+}
+
+func (s *SimpleWorkflowClientConfigSuite) SetupTest() {
+}
+
+func (s *SimpleWorkflowClientConfigSuite) TestValidate() {
+	region := VALID_SWF_CLIENT_REGION
+	endpoint := VALID_SWF_CLIENT_ENDPOINT
+
+	c := &SimpleWorkflowClientConfig{
+		Region:   &region,
+		Endpoint: &endpoint,
+	}
+
+	err := validateConfigWithReflection(c)
+	assert.Nil(s.T(), err)
+}
+
+func (s *SimpleWorkflowClientConfigSuite) TestValidateWithoutEndpoint() {
+	region := VALID_SWF_CLIENT_REGION
+
+	c := &SimpleWorkflowClientConfig{
+		Region: &region,
+	}
+
+	err := validateConfigWithReflection(c)
+	assert.Nil(s.T(), err)
+}
+
+func (s *SimpleWorkflowClientConfigSuite) TestValidateErrorEmptyEndpoint() {
+	region := VALID_SWF_CLIENT_REGION
+	endpoint := ""
+
+	c := &SimpleWorkflowClientConfig{
+		Region:   &region,
+		Endpoint: &endpoint,
+	}
+
+	err := validateConfigWithReflection(c)
+	assert.NotNil(s.T(), err)
+	assert.Equal(s.T(), errors.New("String Field: Endpoint, contains an empty string"), err)
+}
+
+func (s *SimpleWorkflowClientConfigSuite) TestValidateErrorRegion() {
+	region := AWSRegion("")
+
+	c := &SimpleWorkflowClientConfig{
+		Region: &region,
+	}
+
+	err := validateConfigWithReflection(c)
+	assert.NotNil(s.T(), err)
+	assert.Equal(s.T(), errors.New("Validater Field: Region, failed to validate with error, Region cannot be empty"), err)
+}
+
+func (s *SimpleWorkflowClientConfigSuite) TestGetRegion() {
+	region := VALID_SWF_CLIENT_REGION
+
+	c := &SimpleWorkflowClientConfig{
+		Region: &region,
+	}
+
+	assert.Equal(s.T(), VALID_SWF_CLIENT_REGION, c.GetRegion())
+}
+
+func (s *SimpleWorkflowClientConfigSuite) TestGetEndpoint() {
+	region := VALID_SWF_CLIENT_REGION
+	endpoint := VALID_SWF_CLIENT_ENDPOINT
+
+	c := &SimpleWorkflowClientConfig{
+		Region:   &region,
+		Endpoint: &endpoint,
+	}
+
+	assert.Equal(s.T(), VALID_SWF_CLIENT_ENDPOINT, c.GetEndpoint())
+}
+
+func (s *SimpleWorkflowClientConfigSuite) TestGetEndpointNotSet() {
+	region := VALID_SWF_CLIENT_REGION
+
+	c := &SimpleWorkflowClientConfig{
+		Region:   &region,
+		Endpoint: nil,
+	}
+
+	assert.Equal(s.T(), "", c.GetEndpoint())
+}
+
+func (s *SimpleWorkflowClientConfigSuite) TestGetDisableSSL() {
+	region := VALID_SWF_CLIENT_REGION
+	endpoint := VALID_SWF_CLIENT_ENDPOINT
+	disableSSL := VALID_SWF_CLIENT_DISABLE_SSL
+
+	c := &SimpleWorkflowClientConfig{
+		Region:     &region,
+		Endpoint:   &endpoint,
+		DisableSSL: &disableSSL,
+	}
+
+	assert.Equal(s.T(), VALID_SWF_CLIENT_DISABLE_SSL, c.GetDisableSSL())
+}
+
+func (s *SimpleWorkflowClientConfigSuite) TestGetDisableSSLNotSet() {
+	region := VALID_SWF_CLIENT_REGION
+	endpoint := VALID_SWF_CLIENT_ENDPOINT
+
+	c := &SimpleWorkflowClientConfig{
+		Region:     &region,
+		Endpoint:   &endpoint,
+		DisableSSL: nil,
+	}
+
+	assert.Equal(s.T(), false, c.GetDisableSSL())
+}

swf_workflow_config.go

@@ -0,0 +1,19 @@
+package remoteconfig
+
+type SimpleWorkflowConfig struct {
+	Domain       *string       `json:"domain"`
+	WorkflowType *WorkflowType `json:"workflow_type"`
+}
+
+func (s SimpleWorkflowConfig) GetDomain() string {
+	return *s.Domain
+}
+
+func (s SimpleWorkflowConfig) GetWorkflowType() WorkflowType {
+	return *s.WorkflowType
+}
+
+type WorkflowType struct {
+	Name    *string `json:"name"`
+	Version *string `json:"version"`
+}

swf_workflow_config_test.go

@@ -0,0 +1,104 @@
+package remoteconfig
+
+import (
+	"errors"
+	"testing"
+
+	"github.com/stretchr/testify/assert"
+	"github.com/stretchr/testify/suite"
+)
+
+const (
+	VALID_SWF_WORKFLOW_DOMAIN       string = "testDomain"
+	VALID_SWF_WORKFLOW_TYPE_NAME    string = "testWorkflow"
+	VALID_SWF_WORKFLOW_TYPE_VERSION string = "1.0"
+)
+
+type SimpleWorkflowConfigSuite struct {
+	suite.Suite
+}
+
+func TestSimpleWorkflowConfigSuite(t *testing.T) {
+	suite.Run(t, new(SimpleWorkflowConfigSuite))
+}
+
+func (s *SimpleWorkflowConfigSuite) SetupSuite() {
+}
+
+func (s *SimpleWorkflowConfigSuite) SetupTest() {
+}
+
+func (s *SimpleWorkflowConfigSuite) TestValidate() {
+	domain := VALID_SWF_WORKFLOW_DOMAIN
+	name := VALID_SWF_WORKFLOW_TYPE_NAME
+	version := VALID_SWF_WORKFLOW_TYPE_VERSION
+	workflowType := WorkflowType{Name: &name, Version: &version}
+
+	c := &SimpleWorkflowConfig{
+		Domain:       &domain,
+		WorkflowType: &workflowType,
+	}
+
+	err := validateConfigWithReflection(c)
+	assert.Nil(s.T(), err)
+}
+
+func (s *SimpleWorkflowConfigSuite) TestValidateErrorDomain() {
+	domain := ""
+	name := VALID_SWF_WORKFLOW_TYPE_NAME
+	version := VALID_SWF_WORKFLOW_TYPE_VERSION
+	workflowType := WorkflowType{Name: &name, Version: &version}
+
+	c := &SimpleWorkflowConfig{
+		Domain:       &domain,
+		WorkflowType: &workflowType,
+	}
+
+	err := validateConfigWithReflection(c)
+	assert.NotNil(s.T(), err)
+	assert.Equal(s.T(), errors.New("String Field: Domain, contains an empty string"), err)
+}
+
+func (s *SimpleWorkflowConfigSuite) TestGetDomain() {
+	domain := VALID_SWF_WORKFLOW_DOMAIN
+	name := VALID_SWF_WORKFLOW_TYPE_NAME
+	version := VALID_SWF_WORKFLOW_TYPE_VERSION
+	workflowType := WorkflowType{Name: &name, Version: &version}
+
+	c := &SimpleWorkflowConfig{
+		Domain:       &domain,
+		WorkflowType: &workflowType,
+	}
+
+	assert.Equal(s.T(), VALID_SWF_WORKFLOW_DOMAIN, c.GetDomain())
+}
+
+func (s *SimpleWorkflowConfigSuite) TestValidateErrorWorkflowType() {
+	domain := VALID_SWF_WORKFLOW_DOMAIN
+	name := ""
+	version := ""
+	workflowType := WorkflowType{Name: &name, Version: &version}
+
+	c := &SimpleWorkflowConfig{
+		Domain:       &domain,
+		WorkflowType: &workflowType,
+	}
+
+	err := validateConfigWithReflection(c)
+	assert.NotNil(s.T(), err)
+	assert.Equal(s.T(), errors.New("Sub Field of WorkflowType, failed to validate with error, String Field: Name, contains an empty string"), err)
+}
+
+func (s *SimpleWorkflowConfigSuite) TestGetWorkflowType() {
+	domain := VALID_SWF_WORKFLOW_DOMAIN
+	name := VALID_SWF_WORKFLOW_TYPE_NAME
+	version := VALID_SWF_WORKFLOW_TYPE_VERSION
+	workflowType := WorkflowType{Name: &name, Version: &version}
+
+	c := &SimpleWorkflowConfig{
+		Domain:       &domain,
+		WorkflowType: &workflowType,
+	}
+
+	assert.Equal(s.T(), workflowType, c.GetWorkflowType())
+}