mirror at 20220620151948

Author: acoshift

api/api.go

@@ -13,6 +13,7 @@ type Interface interface {
 	PullSecret() PullSecret
 	WorkloadIdentity() WorkloadIdentity
 	ServiceAccount() ServiceAccount
+	Email() Email
 	Collector() Collector
 	Deployer() Deployer
 }

api/client/client.go

@@ -105,6 +105,10 @@ func (c *Client) WorkloadIdentity() api.WorkloadIdentity {
 	return workloadIdentityClient{c}
 }
 
+func (c *Client) Email() api.Email {
+	return emailClient{c}
+}
+
 func (c *Client) Collector() api.Collector {
 	return collectorClient{c}
 }

api/client/domain.go

@@ -45,3 +45,12 @@ func (c domainClient) Delete(ctx context.Context, m *api.DomainDelete) (*api.Emp
 	}
 	return &res, nil
 }
+
+func (c domainClient) PurgeCache(ctx context.Context, m *api.DomainGet) (*api.Empty, error) {
+	var res api.Empty
+	err := c.inv.invoke(ctx, "domain.purgeCache", m, &res)
+	if err != nil {
+		return nil, err
+	}
+	return &res, nil
+}

api/client/email.go

@@ -0,0 +1,20 @@
+package client
+
+import (
+	"context"
+
+	"github.com/deploys-app/deploys/api"
+)
+
+type emailClient struct {
+	inv invoker
+}
+
+func (c emailClient) Send(ctx context.Context, m *api.EmailSend) (*api.Empty, error) {
+	var res api.Empty
+	err := c.inv.invoke(ctx, "email.send", m, &res)
+	if err != nil {
+		return nil, err
+	}
+	return &res, nil
+}

api/constraint.go

@@ -25,4 +25,5 @@ const (
 const (
 	DeploymentMinReplicas = 1
 	DeploymentMaxReplicas = 20
+	DiskMaxSize           = 100
 )

api/disk.go

@@ -39,7 +39,7 @@ func (m *DiskCreate) Valid() error {
 		v.Mustf(cnt >= MinNameLength && cnt <= MaxNameLength, "name must have length between %d-%d characters", MinNameLength, MaxNameLength)
 	}
 	v.Must(m.Size >= 1, "minimum disk size 1 Gi")
-	v.Must(m.Size <= 20, "maximum disk size 20 Gi")
+	v.Mustf(m.Size <= DiskMaxSize, "maximum disk size %d Gi", DiskMaxSize)
 
 	return WrapValidate(v)
 }

api/domain.go

@@ -14,13 +14,14 @@ type Domain interface {
 	Get(ctx context.Context, m *DomainGet) (*DomainItem, error)
 	List(ctx context.Context, m *DomainList) (*DomainListResult, error)
 	Delete(ctx context.Context, m *DomainDelete) (*Empty, error)
+	PurgeCache(ctx context.Context, m *DomainGet) (*Empty, error)
 }
 
 type DomainCreate struct {
 	Project  string     `json:"project" yaml:"project"`
 	Location string     `json:"location" yaml:"location"`
 	Domain   string     `json:"domain" yaml:"domain"`
-	Plan     DomainPlan `json:"plan" yaml:"plan"`
+	Type     DomainType `json:"type" yaml:"type"`
 }
 
 func (m *DomainCreate) Valid() error {
@@ -35,16 +36,14 @@ func (m *DomainCreate) Valid() error {
 }
 
 type DomainGet struct {
-	Project  string `json:"project" yaml:"project"`
-	Location string `json:"location" yaml:"location"`
-	Domain   string `json:"domain" yaml:"domain"`
+	Project string `json:"project" yaml:"project"`
+	Domain  string `json:"domain" yaml:"domain"`
 }
 
 func (m *DomainGet) Valid() error {
 	v := validator.New()
 
 	v.Must(m.Project != "", "project required")
-	v.Must(m.Location != "", "location required")
 	v.Must(govalidator.IsDNSName(m.Domain), "domain invalid")
 
 	return WrapValidate(v)
@@ -84,25 +83,51 @@ type DomainItem struct {
 	Project      string             `json:"project" yaml:"project"`
 	Location     string             `json:"location" yaml:"location"`
 	Domain       string             `json:"domain" yaml:"domain"`
-	Plan         DomainPlan         `json:"plan" yaml:"plan"`
+	Type         DomainType         `json:"type" yaml:"type"`
 	Verification DomainVerification `json:"verification" yaml:"verification"`
+	DNSConfig    DomainDNSConfig    `json:"dnsConfig" yaml:"dnsConfig"`
+	Status       DomainStatus       `json:"status" yaml:"status"`
 	CreatedAt    time.Time          `json:"createdAt" yaml:"createdAt"`
+	CreatedBy    string             `json:"createdBy" yaml:"createdBy"`
 }
 
 type DomainVerification struct {
+	Ownership DomainVerificationOwnership `json:"ownership"`
+	SSL       DomainVerificationSSL       `json:"ssl"`
+}
+
+type DomainVerificationOwnership struct {
+	Type   string   `json:"type"`
+	Name   string   `json:"name"`
+	Value  string   `json:"value"`
+	Errors []string `json:"errors"`
+}
+
+type DomainVerificationSSL struct {
+	Records []DomainVerificationSSLRecord `json:"records"`
+	Errors  []string                      `json:"errors"`
+}
+
+type DomainVerificationSSLRecord struct {
+	TxtName  string `json:"txtName"`
+	TxtValue string `json:"txtValue"`
+}
+
+type DomainDNSConfig struct {
+	IPv4  []string `json:"ipv4" yaml:"ipv4"`
+	IPv6  []string `json:"ipv6" yaml:"ipv6"`
+	CName []string `json:"cname" yaml:"cname"`
 }
 
 type DomainDelete struct {
-	Project  string `json:"project" yaml:"project"`
-	Location string `json:"location" yaml:"location"`
-	Domain   string `json:"domain" yaml:"domain"`
+	Project string `json:"project" yaml:"project"`
+	Domain  string `json:"domain" yaml:"domain"`
 }
 
 func (m *DomainDelete) Valid() error {
 	v := validator.New()
 
 	v.Must(m.Project != "", "project required")
-	v.Must(m.Location != "", "location required")
 	v.Must(govalidator.IsDNSName(m.Domain), "domain invalid")
 
 	return WrapValidate(v)

api/domainplan.go

@@ -0,0 +1,58 @@
+package api
+
+import "encoding/json"
+
+//go:generate stringer -type=DomainStatus -linecomment
+type DomainStatus int
+
+const (
+	DomainStatusPending DomainStatus = iota // pending
+	DomainStatusSuccess                     // success
+	DomainStatusError                       // error
+	DomainStatusVerify                      // verify
+)
+
+var allDomainStatus = []DomainStatus{
+	DomainStatusPending,
+	DomainStatusSuccess,
+	DomainStatusError,
+	DomainStatusVerify,
+}
+
+func parseDomainStatus(s string) DomainStatus {
+	for _, x := range allDomainStatus {
+		if x.String() == s {
+			return x
+		}
+	}
+	return DomainStatusPending
+}
+
+func (s DomainStatus) MarshalJSON() ([]byte, error) {
+	return json.Marshal(s.String())
+}
+
+func (s *DomainStatus) UnmarshalJSON(b []byte) error {
+	var t string
+	err := json.Unmarshal(b, &t)
+	if err != nil {
+		return err
+	}
+
+	*s = parseDomainStatus(t)
+	return nil
+}
+
+func (s DomainStatus) MarshalYAML() (interface{}, error) {
+	return s.String(), nil
+}
+
+func (s *DomainStatus) UnmarshalYAML(unmarshal func(interface{}) error) error {
+	var t string
+	err := unmarshal(&t)
+	if err != nil {
+		return err
+	}
+	*s = parseDomainStatus(t)
+	return nil
+}