Merge pull request #116 from datadrivers/feature/add-mail-config-service

feat: add mail config service

Author: anmoel

nexus3/mail_config.go

@@ -0,0 +1,88 @@
+package nexus3
+
+import (
+	"encoding/json"
+	"fmt"
+	"net/http"
+
+	"github.com/datadrivers/go-nexus-client/nexus3/pkg/client"
+	"github.com/datadrivers/go-nexus-client/nexus3/pkg/tools"
+	"github.com/datadrivers/go-nexus-client/nexus3/schema"
+)
+
+const (
+	MailConfigsAPIEndpoint = basePath + "v1/email"
+)
+
+type MailConfigService client.Service
+
+func NewMailConfigService(c *client.Client) *MailConfigService {
+
+	s := &MailConfigService{
+		Client: c,
+	}
+	return s
+}
+
+func (s *MailConfigService) Get() (*schema.MailConfig, error) {
+	body, resp, err := s.Client.Get(MailConfigsAPIEndpoint, nil)
+	if err != nil {
+		return nil, err
+	}
+
+	if resp.StatusCode != http.StatusOK {
+		return nil, fmt.Errorf("%s", string(body))
+	}
+	var mailconfig schema.MailConfig
+	if err := json.Unmarshal(body, &mailconfig); err != nil {
+		return nil, fmt.Errorf("could not unmarschal MailConfig: %v", err)
+	}
+	return &mailconfig, nil
+}
+
+func (s *MailConfigService) Create(mailconfig *schema.MailConfig) error {
+	ioReader, err := tools.JsonMarshalInterfaceToIOReader(mailconfig)
+	if err != nil {
+		return err
+	}
+	body, resp, err := s.Client.Put(MailConfigsAPIEndpoint, ioReader)
+	if err != nil {
+		return err
+	}
+
+	if resp.StatusCode != http.StatusNoContent {
+		return fmt.Errorf("%s", string(body))
+	}
+
+	return nil
+}
+
+func (s *MailConfigService) Update(mailconfig *schema.MailConfig) error {
+	ioReader, err := tools.JsonMarshalInterfaceToIOReader(mailconfig)
+	if err != nil {
+		return err
+	}
+
+	body, resp, err := s.Client.Put(MailConfigsAPIEndpoint, ioReader)
+	if err != nil {
+		return err
+	}
+
+	if resp.StatusCode != http.StatusOK && resp.StatusCode != http.StatusNoContent {
+		return fmt.Errorf("%s", string(body))
+	}
+
+	return nil
+}
+
+func (s *MailConfigService) Delete() error {
+	body, resp, err := s.Client.Delete(MailConfigsAPIEndpoint)
+	if err != nil {
+		return err
+	}
+
+	if resp.StatusCode != http.StatusOK && resp.StatusCode != http.StatusNoContent {
+		return fmt.Errorf("%s", string(body))
+	}
+	return err
+}

nexus3/mail_config_test.go

@@ -0,0 +1,59 @@
+package nexus3
+
+import (
+	"testing"
+
+	"github.com/datadrivers/go-nexus-client/nexus3/schema"
+	"github.com/stretchr/testify/assert"
+)
+
+func testMailConfig(enabled *bool, host string, port int, username *string, password *string, fromAddress string, subjectPrefix *string) *schema.MailConfig {
+	b := new(bool)
+	*b = false
+
+	return &schema.MailConfig{
+		Enabled:                       enabled,
+		Host:                          host,
+		Port:                          port,
+		Username:                      username,
+		Password:                      password,
+		FromAddress:                   fromAddress,
+		SubjectPrefix:                 subjectPrefix,
+		StartTlsEnabled:               b,
+		StartTlsRequired:              b,
+		SslOnConnectEnabled:           b,
+		SslServerIdentityCheckEnabled: b,
+		NexusTrustStoreEnabled:        b,
+	}
+}
+
+func TestMailConfigCreateReadUpdateDelete(t *testing.T) {
+	client := getTestClient()
+
+	enabled := true
+	username := "uname"
+	usernameUpdated := "username"
+	password := "secret"
+	subjectPrefix := "prefix"
+
+	// Create
+	err := client.MailConfig.Create(testMailConfig(&enabled, "example.org", 42, &username, &password, "[email protected]", &subjectPrefix))
+	assert.Nil(t, err)
+
+	// Read
+	readMailConfig, err := client.MailConfig.Get()
+	assert.Nil(t, err)
+	assert.Equal(t, readMailConfig, testMailConfig(&enabled, "example.org", 42, &username, nil, "[email protected]", &subjectPrefix))
+
+	// Update
+	err = client.MailConfig.Update(testMailConfig(&enabled, "example.org", 42, &usernameUpdated, nil, "[email protected]", &subjectPrefix))
+	assert.Nil(t, err)
+
+	// Check updated value
+	readMailConfig, _ = client.MailConfig.Get()
+	assert.Equal(t, readMailConfig, testMailConfig(&enabled, "example.org", 42, &usernameUpdated, nil, "[email protected]", &subjectPrefix))
+
+	// Delete
+	err = client.MailConfig.Delete()
+	assert.Nil(t, err)
+}

nexus3/nexus.go

@@ -24,6 +24,7 @@ type NexusClient struct {
 	RoutingRule *RoutingRuleService
 	Security    *security.SecurityService
 	Script      *ScriptService
+	MailConfig  *MailConfigService
 }
 
 // NewClient returns an instance of client that implements the Client interface
@@ -36,5 +37,6 @@ func NewClient(config client.Config) *NexusClient {
 		RoutingRule: NewRoutingRuleService(client),
 		Security:    security.NewSecurityService(client),
 		Script:      NewScriptService(client),
+		MailConfig:  NewMailConfigService(client),
 	}
 }

nexus3/schema/mail_config.go

@@ -0,0 +1,39 @@
+package schema
+
+type MailConfig struct {
+	// Toogle if mail config is active or not
+	Enabled *bool `json:"enabled,omitempty"`
+
+	// Host
+	Host string `json:"host"`
+
+	// Port
+	Port int `json:"port"`
+
+	// Username
+	Username *string `json:"username,omitempty"`
+
+	// Password
+	Password *string `json:"password,omitempty"`
+
+	// FromAddress
+	FromAddress string `json:"fromAddress"`
+
+	// Subject Prefix
+	SubjectPrefix *string `json:"subjectPrefix,omitempty"`
+
+	// StartTlsEnabled
+	StartTlsEnabled *bool `json:"startTlsEnabled,omitempty"`
+
+	// StartTlsRequired
+	StartTlsRequired *bool `json:"startTlsRequired,omitempty"`
+
+	// sslOnConectEnabled
+	SslOnConnectEnabled *bool `json:"sslOnConnectEnabled,omitempty"`
+
+	// sslServerIdentityCheckEnabled
+	SslServerIdentityCheckEnabled *bool `json:"sslServerIdentityCheckEnabled,omitempty"`
+
+	// nexusTrustStoreEnabled
+	NexusTrustStoreEnabled *bool `json:"nexusTrustStoreEnabled,omitempty"`
+}