@@ -10,22 +10,94 @@ import (
1010 "strings"
1111
1212 "github.com/dio/sh"
13+ "helm.sh/helm/v3/pkg/chart"
14+ "helm.sh/helm/v3/pkg/chartutil"
1315)
1416
1517var FORCED = len (os .Getenv ("FORCED" )) > 0
1618var GH_TOKEN = os .Getenv ("GH_TOKEN" )
1719var GPG_PASSPHRASE = os .Getenv ("GPG_PASSPHRASE" )
1820var GPG_TRUSTEE = "[email protected] "
21+ var ENV_MAP = map [string ]string {
22+ "GH_TOKEN" : GH_TOKEN ,
23+ "TZ" : "UTC" ,
24+ }
1925
2026// PackIstio packs a versioned Istio Helm chart, for example: 1.16.6-tetrate-v0.
2127func PackIstio (ctx context.Context ) error {
28+ // Export keyring.
29+ ring , pass , err := exportSecretKey (ctx )
30+ if err != nil {
31+ return err
32+ }
33+
2234 dir := filepath .Join ("charts" , "istio" )
2335 versions , err := os .ReadDir (dir )
2436 if err != nil {
2537 return err
2638 }
2739 for _ , version := range versions {
28- if err := packVersioned (ctx , version .Name ()); err != nil {
40+ if err := packVersionedIstio (ctx , version .Name (), ring , pass ); err != nil {
41+ return err
42+ }
43+ }
44+ return nil
45+ }
46+
47+ func PackAddons (ctx context.Context ) error {
48+ // Export keyring.
49+ ring , pass , err := exportSecretKey (ctx )
50+ if err != nil {
51+ return err
52+ }
53+
54+ dir := filepath .Join ("charts" , "addons" )
55+ entries , err := os .ReadDir (dir )
56+ if err != nil {
57+ return err
58+ }
59+ for _ , entry := range entries {
60+ if err := packChart (ctx , dir , entry .Name (), ring , pass ); err != nil {
61+ return err
62+ }
63+ }
64+ return nil
65+ }
66+
67+ func PackDemos (ctx context.Context ) error {
68+ // Export keyring.
69+ ring , pass , err := exportSecretKey (ctx )
70+ if err != nil {
71+ return err
72+ }
73+
74+ dir := filepath .Join ("charts" , "demos" )
75+ entries , err := os .ReadDir (dir )
76+ if err != nil {
77+ return err
78+ }
79+ for _ , entry := range entries {
80+ if err := packChart (ctx , dir , entry .Name (), ring , pass ); err != nil {
81+ return err
82+ }
83+ }
84+ return nil
85+ }
86+
87+ func PackSystem (ctx context.Context ) error {
88+ // Export keyring.
89+ ring , pass , err := exportSecretKey (ctx )
90+ if err != nil {
91+ return err
92+ }
93+
94+ dir := filepath .Join ("charts" , "system" )
95+ entries , err := os .ReadDir (dir )
96+ if err != nil {
97+ return err
98+ }
99+ for _ , entry := range entries {
100+ if err := packChart (ctx , dir , entry .Name (), ring , pass ); err != nil {
29101 return err
30102 }
31103 }
@@ -51,32 +123,70 @@ func Index(ctx context.Context, url string) error {
51123 if _ , err := os .Stat (publishedIndexYAML ); err == nil {
52124 args = append (args , "--merge" , publishedIndexYAML )
53125 }
54- if err := sh .Run (ctx , "helm" , args ... ); err != nil {
126+ if err := sh .RunWithV (ctx , ENV_MAP , "helm" , args ... ); err != nil {
55127 return err
56128 }
57129 b , err := os .ReadFile (indexYAML )
58130 if err != nil {
59131 return err
60132 }
61- sanitized := strings .ReplaceAll (string (b ), "istio-/" , "istio-" )
133+
134+ // TODO(dio): Remove this hack. We should call the modified "helm repo index" function.
135+ sanitized := strings .ReplaceAll (string (b ), "download/1." , "download/istio-1." )
136+ _ = os .MkdirAll ("gh-pages" , os .ModePerm )
62137 return os .WriteFile (publishedIndexYAML , []byte (sanitized ), os .ModePerm )
63138}
64139
65- func packVersioned (ctx context.Context , version string ) error {
66- // Export keyring.
67- ring , pass , err := exportSecretKey (ctx )
140+ func packChart (ctx context.Context , dir , name , ring , pass string ) error {
141+ charts , err := chartYAMLs (dir , "Chart.yaml" , "*/Chart.yaml" , "*/*/Chart.yaml" , "*/*/*/Chart.yaml" , "*/*/*/*/Chart.yaml" )
68142 if err != nil {
69143 return err
70144 }
145+ for _ , chart := range charts {
146+ metadata , err := chartutil .LoadChartfile (filepath .Join (chart ))
147+ if err != nil {
148+ return err
149+ }
150+
151+ if err := resolveDeps (ctx , filepath .Dir (chart ), metadata ); err != nil {
152+ return err
153+ }
154+
155+ tag := metadata .Name + "-" + metadata .Version
156+
157+ // If already published, skip it unless FORCED.
158+ err = sh .RunWithV (ctx , ENV_MAP , "gh" , "release" , "view" , tag , "-R" , "tetratelabs/legacy-charts" )
159+ released := err == nil
160+ if released && ! FORCED {
161+ fmt .Printf ("%s is already published\n " , tag )
162+ return nil
163+ }
71164
72- e := map [string ]string {
73- "GH_TOKEN" : GH_TOKEN ,
165+ dst := filepath .Join ("dist" , metadata .Name + "-" + metadata .Version )
166+ _ = os .MkdirAll (dst , os .ModePerm )
167+
168+ if err := sh .RunWithV (ctx ,
169+ ENV_MAP ,
170+ "helm" ,
171+ "package" ,
172+ filepath .Dir (chart ),
173+ "--destination" , dst ,
174+ "--sign" ,
175+ "--keyring" , ring ,
176+ "--key" , GPG_TRUSTEE ,
177+ "--passphrase-file" , pass ,
178+ ); err != nil {
179+ return err
180+ }
74181 }
182+ return nil
183+ }
75184
185+ func packVersionedIstio (ctx context.Context , version , ring , pass string ) error {
76186 tag := "istio-" + version
77187
78188 // If already published, skip it unless FORCED.
79- err = sh .RunWithV (ctx , e , "gh" , "release" , "view" , tag , "-R" , "tetratelabs/legacy-charts" )
189+ err : =sh .RunWithV (ctx , ENV_MAP , "gh" , "release" , "view" , tag , "-R" , "tetratelabs/legacy-charts" )
80190 released := err == nil
81191 if released && ! FORCED {
82192 fmt .Printf ("%s is already published\n " , tag )
@@ -92,7 +202,8 @@ func packVersioned(ctx context.Context, version string) error {
92202 return err
93203 }
94204 for _ , chart := range charts {
95- if err := sh .Run (ctx ,
205+ if err := sh .RunWithV (ctx ,
206+ ENV_MAP ,
96207 "helm" ,
97208 "package" ,
98209 filepath .Dir (chart ),
@@ -117,9 +228,9 @@ func packVersioned(ctx context.Context, version string) error {
117228 }
118229
119230 if released {
120- return sh .RunWithV (ctx , e , "gh" , append ([]string {"release" , "upload" , tag , "--clobber" , "-R" , "tetratelabs/legacy-charts" }, files ... )... )
231+ return sh .RunWithV (ctx , ENV_MAP , "gh" , append ([]string {"release" , "upload" , tag , "--clobber" , "-R" , "tetratelabs/legacy-charts" }, files ... )... )
121232 }
122- return sh .RunWithV (ctx , e , "gh" , append ([]string {"release" , "create" , tag , "-n" , tag , "-t" , tag , "-R" , "tetratelabs/legacy-charts" }, files ... )... )
233+ return sh .RunWithV (ctx , ENV_MAP , "gh" , append ([]string {"release" , "create" , tag , "-n" , tag , "-t" , tag , "-R" , "tetratelabs/legacy-charts" }, files ... )... )
123234}
124235
125236func chartYAMLs (build string , patterns ... string ) ([]string , error ) {
@@ -155,3 +266,18 @@ func exportSecretKey(ctx context.Context) (string, string, error) {
155266 "--passphrase" , GPG_PASSPHRASE ,
156267 "--export-secret-key" , GPG_TRUSTEE )
157268}
269+
270+ func resolveDeps (ctx context.Context , chart string , metadata * chart.Metadata ) error {
271+ if len (metadata .Dependencies ) == 0 {
272+ return nil
273+ }
274+
275+ for _ , dep := range metadata .Dependencies {
276+ if err := sh .RunWithV (ctx , ENV_MAP , "helm" , "repo" , "add" , dep .Name , dep .Repository , "--force-update" ); err != nil {
277+ return err
278+ }
279+ }
280+
281+ // Run helm dependency build for that chart. This step also does fetching updates.
282+ return sh .RunWithV (ctx , ENV_MAP , "helm" , "dependency" , "build" , chart )
283+ }
0 commit comments