apply.go 4.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188
  1. package stack
  2. import (
  3. "context"
  4. "fmt"
  5. "strings"
  6. "github.com/fatih/color"
  7. api "github.com/porter-dev/porter/api/client"
  8. "github.com/porter-dev/porter/api/types"
  9. "github.com/porter-dev/porter/cli/cmd/config"
  10. switchboardTypes "github.com/porter-dev/switchboard/pkg/types"
  11. "gopkg.in/yaml.v2"
  12. )
  13. type StackConf struct {
  14. apiClient *api.Client
  15. rawBytes []byte
  16. parsed *PorterStackYAML
  17. stackName string
  18. projectID, clusterID uint
  19. }
  20. func CreateV1BuildResources(client *api.Client, raw []byte, stackName string, projectID uint, clusterID uint) (*switchboardTypes.ResourceGroup, error) {
  21. v1File := &switchboardTypes.ResourceGroup{
  22. Version: "v1",
  23. Resources: []*switchboardTypes.Resource{
  24. {
  25. Name: "get-env",
  26. Driver: "os-env",
  27. },
  28. },
  29. }
  30. stackConf, err := createStackConf(client, raw, stackName, projectID, clusterID)
  31. if err != nil {
  32. return nil, err
  33. }
  34. var bi, pi *switchboardTypes.Resource
  35. if stackConf.parsed.Build != nil {
  36. bi, pi, err = createV1BuildResourcesFromPorterYaml(stackConf)
  37. if err != nil {
  38. color.New(color.FgRed).Printf("Could not build using values specified in porter.yaml (%s), attempting to load stack build settings instead \n", err.Error())
  39. bi, pi, err = createV1BuildResourcesFromDB(client, stackConf)
  40. if err != nil {
  41. return nil, err
  42. }
  43. }
  44. } else {
  45. color.New(color.FgYellow).Printf("No build values specified in porter.yaml, attempting to load stack build settings instead \n")
  46. bi, pi, err = createV1BuildResourcesFromDB(client, stackConf)
  47. if err != nil {
  48. return nil, err
  49. }
  50. }
  51. v1File.Resources = append(v1File.Resources, bi, pi)
  52. return v1File, nil
  53. }
  54. func createStackConf(client *api.Client, raw []byte, stackName string, projectID uint, clusterID uint) (*StackConf, error) {
  55. var parsed *PorterStackYAML
  56. if raw == nil {
  57. parsed = createDefaultPorterYaml()
  58. } else {
  59. parsed = &PorterStackYAML{}
  60. err := yaml.Unmarshal(raw, parsed)
  61. if err != nil {
  62. errMsg := composePreviewMessage("error parsing porter.yaml", Error)
  63. return nil, fmt.Errorf("%s: %w", errMsg, err)
  64. }
  65. }
  66. err := config.ValidateCLIEnvironment()
  67. if err != nil {
  68. errMsg := composePreviewMessage("porter CLI is not configured correctly", Error)
  69. return nil, fmt.Errorf("%s: %w", errMsg, err)
  70. }
  71. return &StackConf{
  72. apiClient: client,
  73. rawBytes: raw,
  74. parsed: parsed,
  75. stackName: stackName,
  76. projectID: projectID,
  77. clusterID: clusterID,
  78. }, nil
  79. }
  80. func createV1BuildResourcesFromPorterYaml(stackConf *StackConf) (*switchboardTypes.Resource, *switchboardTypes.Resource, error) {
  81. bi, err := stackConf.parsed.Build.getV1BuildImage(stackConf.parsed.Env)
  82. if err != nil {
  83. return nil, nil, err
  84. }
  85. pi, err := stackConf.parsed.Build.getV1PushImage()
  86. if err != nil {
  87. return nil, nil, err
  88. }
  89. return bi, pi, nil
  90. }
  91. func createV1BuildResourcesFromDB(client *api.Client, stackConf *StackConf) (*switchboardTypes.Resource, *switchboardTypes.Resource, error) {
  92. res, err := client.GetPorterApp(context.Background(), stackConf.projectID, stackConf.clusterID, stackConf.stackName)
  93. if err != nil {
  94. return nil, nil, fmt.Errorf("unable to read build info from DB: %w", err)
  95. }
  96. if res == nil {
  97. return nil, nil, fmt.Errorf("stack %s not found", stackConf.stackName)
  98. }
  99. build := convertToBuild(res)
  100. bi, err := build.getV1BuildImage(stackConf.parsed.Env)
  101. if err != nil {
  102. return nil, nil, err
  103. }
  104. pi, err := build.getV1PushImage()
  105. if err != nil {
  106. return nil, nil, err
  107. }
  108. return bi, pi, nil
  109. }
  110. func convertToBuild(porterApp *types.PorterApp) Build {
  111. var context *string
  112. if porterApp.BuildContext != "" {
  113. context = &porterApp.BuildContext
  114. }
  115. var method *string
  116. var m string
  117. if porterApp.RepoName == "" {
  118. m = "registry"
  119. method = &m
  120. } else if porterApp.Dockerfile == "" {
  121. m = "pack"
  122. method = &m
  123. } else {
  124. m = "docker"
  125. method = &m
  126. }
  127. var builder *string
  128. if porterApp.Builder != "" {
  129. builder = &porterApp.Builder
  130. }
  131. var buildpacks []*string
  132. if porterApp.Buildpacks != "" {
  133. bpSlice := strings.Split(porterApp.Buildpacks, ",")
  134. buildpacks = make([]*string, len(bpSlice))
  135. for i, bp := range bpSlice {
  136. buildpacks[i] = &bp
  137. }
  138. }
  139. var dockerfile *string
  140. if porterApp.Dockerfile != "" {
  141. dockerfile = &porterApp.Dockerfile
  142. }
  143. var image *string
  144. if porterApp.ImageRepoURI != "" {
  145. image = &porterApp.ImageRepoURI
  146. }
  147. return Build{
  148. Context: context,
  149. Method: method,
  150. Builder: builder,
  151. Buildpacks: buildpacks,
  152. Dockerfile: dockerfile,
  153. Image: image,
  154. }
  155. }
  156. func createDefaultPorterYaml() *PorterStackYAML {
  157. return &PorterStackYAML{
  158. Apps: nil,
  159. }
  160. }