feat(private-containers): private registries

sdl/_testdata/v2.1-credentials-error.yaml

@@ -0,0 +1,48 @@
+---
+version: "2.1"
+services:
+  web:
+    image: nginx
+    expose:
+      - port: 80
+        accept:
+          - ahostname.com
+        to:
+          - global: true
+      - port: 12345
+        to:
+          - global: true
+        proto: udp
+    credentials:
+      username: "foo"
+      password: "foo"
+profiles:
+  compute:
+    web:
+      resources:
+        cpu:
+          units: "100m"
+        memory:
+          size: "128Mi"
+        storage:
+          size: "1Gi"
+  placement:
+    westcoast:
+      attributes:
+        region: us-west
+      signedBy:
+        anyOf:
+          - 1
+          - 2
+        allOf:
+          - 3
+          - 4
+      pricing:
+        web:
+          denom: uakt
+          amount: 50
+deployment:
+  web:
+    westcoast:
+      profile: web
+      count: 2

sdl/_testdata/v2.1-credentials.yaml

@@ -0,0 +1,49 @@
+---
+version: "2.1"
+services:
+  web:
+    image: nginx
+    expose:
+      - port: 80
+        accept:
+          - ahostname.com
+        to:
+          - global: true
+      - port: 12345
+        to:
+          - global: true
+        proto: udp
+    credentials:
+      host: "https://test.com/v1"
+      username: "foo"
+      password: "foo"
+profiles:
+  compute:
+    web:
+      resources:
+        cpu:
+          units: "100m"
+        memory:
+          size: "128Mi"
+        storage:
+          size: "1Gi"
+  placement:
+    westcoast:
+      attributes:
+        region: us-west
+      signedBy:
+        anyOf:
+          - 1
+          - 2
+        allOf:
+          - 3
+          - 4
+      pricing:
+        web:
+          denom: uakt
+          amount: 50
+deployment:
+  web:
+    westcoast:
+      profile: web
+      count: 2

sdl/groupBuilder_v2.go

@@ -114,6 +114,14 @@ func (sdl *v2) buildGroups() error {
 				msvc.Params = params
 			}
 
+			if svc.Credentials != nil {
+				msvc.Credentials = &manifest.ServiceImageCredentials{
+					Host:     svc.Credentials.Host,
+					Username: svc.Credentials.Username,
+					Password: svc.Credentials.Password,
+				}
+			}
+
 			group.mgroup.Services = append(group.mgroup.Services, msvc)
 		}
 	}

sdl/groupBuilder_v2_1.go

@@ -2,6 +2,7 @@ package sdl
 
 import (
 	"sort"
+	"strings"
 
 	manifest "github.com/akash-network/akash-api/go/manifest/v2beta2"
 	dtypes "github.com/akash-network/akash-api/go/node/deployment/v1beta3"
@@ -123,6 +124,15 @@ func (sdl *v2_1) buildGroups() error {
 				msvc.Params = params
 			}
 
+			if svc.Credentials != nil {
+				msvc.Credentials = &manifest.ServiceImageCredentials{
+					Host:     strings.TrimSpace(svc.Credentials.Host),
+					Email:    strings.TrimSpace(svc.Credentials.Email),
+					Username: strings.TrimSpace(svc.Credentials.Username),
+					Password: strings.TrimSpace(svc.Credentials.Password),
+				}
+			}
+
 			group.mgroup.Services = append(group.mgroup.Services, msvc)
 		}
 	}

sdl/v2.go

@@ -7,6 +7,7 @@ import (
 	"regexp"
 	"sort"
 	"strconv"
+	"strings"
 
 	"gopkg.in/yaml.v3"
 
@@ -42,6 +43,9 @@ var (
 	errUnknownNextCase               = errors.New("next case is unknown")
 	errHTTPOptionNotAllowed          = errors.New("http option not allowed")
 	errSDLInvalid                    = errors.New("SDL invalid")
+	errCredentialNoHost              = errors.New("Service Credentials missing Host")
+	errCredentialNoUsername          = errors.New("Service Credentials missing Username")
+	errCredentialNoPassword          = errors.New("Service Credentials missing Password")
 )
 
 var endpointNameValidationRegex = regexp.MustCompile(`^[[:lower:]]+[[:lower:]-_\d]+$`)
@@ -167,12 +171,33 @@ type v2ServiceParams struct {
 
 type v2Service struct {
 	Image        string
-	Command      []string         `yaml:",omitempty"`
-	Args         []string         `yaml:",omitempty"`
-	Env          []string         `yaml:",omitempty"`
-	Expose       v2Exposes        `yaml:",omitempty"`
-	Dependencies []v2Dependency   `yaml:",omitempty"`
-	Params       *v2ServiceParams `yaml:",omitempty"`
+	Command      []string              `yaml:",omitempty"`
+	Args         []string              `yaml:",omitempty"`
+	Env          []string              `yaml:",omitempty"`
+	Expose       v2Exposes             `yaml:",omitempty"`
+	Dependencies []v2Dependency        `yaml:",omitempty"`
+	Params       *v2ServiceParams      `yaml:",omitempty"`
+	Credentials  *v2ServiceCredentials `yaml:",omitempty"`
+}
+
+type v2ServiceCredentials struct {
+	Host     string `yaml:",omitempty"`
+	Email    string `yaml:",omitempty"`
+	Username string `yaml:",omitempty"`
+	Password string `yaml:",omitempty"`
+}
+
+func (c v2ServiceCredentials) validate() error {
+	if strings.TrimSpace(c.Host) == "" {
+		return errCredentialNoHost
+	}
+	if strings.TrimSpace(c.Username) == "" {
+		return errCredentialNoUsername
+	}
+	if strings.TrimSpace(c.Password) == "" {
+		return errCredentialNoPassword
+	}
+	return nil
 }
 
 type v2ServiceDeployment struct {
@@ -328,6 +353,18 @@ func (sdl *v2) validate() error {
 				)
 			}
 
+			if svc.Credentials != nil {
+				if err := svc.Credentials.validate(); err != nil {
+					return fmt.Errorf(
+						"%w: %v.%v: %v",
+						errSDLInvalid,
+						svcName,
+						placementName,
+						err,
+					)
+				}
+			}
+
 			for _, serviceExpose := range svc.Expose {
 				for _, to := range serviceExpose.To {
 					// Check to see if an IP endpoint is also specified

sdl/v2_1.go

@@ -155,6 +155,18 @@ func (sdl *v2_1) validate() error {
 				)
 			}
 
+			if svc.Credentials != nil {
+				if err := svc.Credentials.validate(); err != nil {
+					return fmt.Errorf(
+						"%w: %v.%v: %v",
+						errSDLInvalid,
+						svcName,
+						placementName,
+						err,
+					)
+				}
+			}
+
 			for _, serviceExpose := range svc.Expose {
 				for _, to := range serviceExpose.To {
 					// Check to see if an IP endpoint is also specified

sdl/v2_1_test.go

@@ -330,6 +330,38 @@ func Test_V2_1_Parse_simple(t *testing.T) {
 			},
 		},
 	}, mani.GetGroups()[0])
+
+	assert.Nil(t, mani.GetGroups()[0].Services[0].Credentials)
+
+}
+
+func Test_V2_1_Parse_credentials(t *testing.T) {
+	sdl, err := ReadFile("./_testdata/v2.1-credentials.yaml")
+	require.NoError(t, err)
+
+	mani, err := sdl.Manifest()
+	require.NoError(t, err)
+
+	assert.Len(t, mani.GetGroups(), 1)
+
+	grp := mani.GetGroups()[0]
+	assert.Len(t, grp.Services, 1)
+
+	svc := grp.Services[0]
+
+	assert.NotNil(t, svc)
+
+	creds := svc.Credentials
+	assert.NotNil(t, creds)
+
+	assert.Equal(t, "https://test.com/v1", creds.Host)
+	assert.Equal(t, "foo", creds.Username)
+	assert.Equal(t, "foo", creds.Password)
+}
+
+func Test_V2_1_Parse_credentials_error(t *testing.T) {
+	_, err := ReadFile("./_testdata/v2.1-credentials-error.yaml")
+	require.Error(t, err)
 }
 
 func Test_v2_1_Parse_ProfileNameNotServiceName(t *testing.T) {