@@ -21,7 +21,6 @@ import (
21
21
"strings"
22
22
"time"
23
23
24
- "github.com/Masterminds/semver/v3"
25
24
apcmd "github.com/argoproj-labs/argocd-autopilot/cmd/commands"
26
25
"github.com/argoproj-labs/argocd-autopilot/pkg/application"
27
26
"github.com/argoproj-labs/argocd-autopilot/pkg/fs"
@@ -40,8 +39,8 @@ import (
40
39
"github.com/codefresh-io/cli-v2/pkg/store"
41
40
"github.com/codefresh-io/cli-v2/pkg/util"
42
41
apu "github.com/codefresh-io/cli-v2/pkg/util/aputil"
43
- eventsutil "github.com/codefresh-io/cli-v2/pkg/util/events"
44
42
ingressutil "github.com/codefresh-io/cli-v2/pkg/util/ingress"
43
+ eventsutil "github.com/codefresh-io/cli-v2/pkg/util/events"
45
44
wfutil "github.com/codefresh-io/cli-v2/pkg/util/workflow"
46
45
billyUtils "github.com/go-git/go-billy/v5/util"
47
46
"github.com/juju/ansiterm"
@@ -104,8 +103,6 @@ type (
104
103
}
105
104
)
106
105
107
- var versionOfGitSourceByAppProxyRefactor = semver .MustParse ("0.0.319" )
108
-
109
106
func NewGitSourceCommand () * cobra.Command {
110
107
cmd := & cobra.Command {
111
108
Use : "git-source" ,
@@ -208,57 +205,37 @@ func NewGitSourceCreateCommand() *cobra.Command {
208
205
}
209
206
210
207
func RunGitSourceCreate (ctx context.Context , opts * GitSourceCreateOptions ) error {
211
- version , err := getRuntimeVersion (ctx , opts .RuntimeName )
208
+ // upsert git-source repo
209
+
210
+ gsRepo , gsFs , err := opts .GsCloneOpts .GetRepo (ctx )
212
211
if err != nil {
213
- return err
212
+ return fmt . Errorf ( "failed to clone git-source repo: %w" , err )
214
213
}
215
214
216
- if version .LessThan (versionOfGitSourceByAppProxyRefactor ) {
217
-
218
- log .G (ctx ).Infof ("runtime \" %s\" is using a depracated git-source api. Versions %s and up use the app-proxy for this command" , opts .RuntimeName , minAddClusterSupportedVersion )
219
- // upsert git-source repo
220
- gsRepo , gsFs , err := opts .GsCloneOpts .GetRepo (ctx )
221
- if err != nil {
222
- return fmt .Errorf ("failed to clone git-source repo: %w" , err )
223
- }
224
-
225
- if opts .CreateDemoResources {
226
- if err := createDemoResources (ctx , opts , gsRepo , gsFs ); err != nil {
227
- return fmt .Errorf ("failed to create git-source demo resources: %w" , err )
228
- }
229
- } else {
230
- if err := createPlaceholderIfNeeded (ctx , opts , gsRepo , gsFs ); err != nil {
231
- return fmt .Errorf ("failed to create a git-source placeholder: %w" , err )
232
- }
233
- }
234
-
235
- appDef := & runtime.AppDef {
236
- Name : opts .GsName ,
237
- Type : application .AppTypeDirectory ,
238
- URL : opts .GsCloneOpts .Repo ,
239
- }
240
-
241
- appDef .IsInternal = util .StringIndexOf (store .Get ().CFInternalGitSources , appDef .Name ) > - 1
242
-
243
- if err := appDef .CreateApp (ctx , nil , opts .InsCloneOpts , opts .RuntimeName , store .Get ().CFGitSourceType , opts .Include , "" ); err != nil {
244
- return fmt .Errorf ("failed to create git-source application. Err: %w" , err )
215
+ if opts .CreateDemoResources {
216
+ if err := createDemoResources (ctx , opts , gsRepo , gsFs ); err != nil {
217
+ return fmt .Errorf ("failed to create git-source demo resources: %w" , err )
245
218
}
246
219
} else {
247
- appProxy , err := cfConfig .NewClient ().AppProxy (ctx , opts .RuntimeName , store .Get ().InsecureIngressHost )
248
- if err != nil {
249
- return err
220
+ if err := createPlaceholderIfNeeded (ctx , opts , gsRepo , gsFs ); err != nil {
221
+ return fmt .Errorf ("failed to create a git-source placeholder: %w" , err )
250
222
}
223
+ }
251
224
252
- appSpecifier := opts .GsCloneOpts .Repo
253
- isInternal := util .StringIndexOf (store .Get ().CFInternalGitSources , opts .GsName ) > - 1
225
+ appDef := & runtime.AppDef {
226
+ Name : opts .GsName ,
227
+ Type : application .AppTypeDirectory ,
228
+ URL : opts .GsCloneOpts .Repo ,
229
+ }
254
230
255
- err = appProxy . AppProxyGitSources (). Create ( ctx , opts . GsName , appSpecifier , opts . RuntimeName , opts . RuntimeName , isInternal )
256
- if err != nil {
257
- return fmt . Errorf ( "failed to create git-source: %w" , err )
258
- }
231
+ appDef . IsInternal = util . StringIndexOf ( store . Get (). CFInternalGitSources , appDef . Name ) > - 1
232
+
233
+ if err := appDef . CreateApp ( ctx , nil , opts . InsCloneOpts , opts . RuntimeName , store . Get (). CFGitSourceType , opts . Include , "" ); err != nil {
234
+ return fmt . Errorf ( "failed to create git-source application. Err: %w" , err )
259
235
}
260
236
261
237
log .G (ctx ).Infof ("Successfully created git-source: \" %s\" " , opts .GsName )
238
+
262
239
return nil
263
240
}
264
241
@@ -391,7 +368,7 @@ func createCronExampleEventSource() *eventsourcev1alpha1.EventSource {
391
368
Name : store .Get ().CronExampleEventSourceName ,
392
369
},
393
370
Spec : eventsourcev1alpha1.EventSourceSpec {
394
- Template : tpl ,
371
+ Template : tpl ,
395
372
EventBusName : store .Get ().EventBusName ,
396
373
Calendar : map [string ]eventsourcev1alpha1.CalendarEventSource {
397
374
store .Get ().CronExampleEventName : {
@@ -413,7 +390,7 @@ func createCronExampleSensor(triggers []sensorsv1alpha1.Trigger) (*sensorsv1alph
413
390
414
391
tpl := & sensorsv1alpha1.Template {
415
392
ServiceAccountName : "argo-server" ,
416
- Container : & corev1.Container {},
393
+ Container : & corev1.Container {},
417
394
}
418
395
419
396
if store .Get ().SetDefaultResources {
@@ -430,7 +407,7 @@ func createCronExampleSensor(triggers []sensorsv1alpha1.Trigger) (*sensorsv1alph
430
407
},
431
408
Spec : sensorsv1alpha1.SensorSpec {
432
409
EventBusName : "codefresh-eventbus" ,
433
- Template : tpl ,
410
+ Template : tpl ,
434
411
Dependencies : dependencies ,
435
412
Triggers : triggers ,
436
413
},
@@ -603,36 +580,19 @@ func NewGitSourceDeleteCommand() *cobra.Command {
603
580
}
604
581
605
582
func RunGitSourceDelete (ctx context.Context , opts * GitSourceDeleteOptions ) error {
606
- version , err := getRuntimeVersion (ctx , opts .RuntimeName )
607
- if err != nil {
608
- return err
609
- }
610
-
611
- if version .LessThan (versionOfGitSourceByAppProxyRefactor ) {
612
- log .G (ctx ).Infof ("runtime \" %s\" is using a depracated git-source api. Versions %s and up use the app-proxy for this command" , opts .RuntimeName , minAddClusterSupportedVersion )
613
- err = apcmd .RunAppDelete (ctx , & apcmd.AppDeleteOptions {
614
- CloneOpts : opts .InsCloneOpts ,
615
- ProjectName : opts .RuntimeName ,
616
- AppName : opts .GsName ,
617
- Global : false ,
618
- })
619
-
620
- if err != nil {
621
- return fmt .Errorf ("failed to delete the git-source %s. Err: %w" , opts .GsName , err )
622
- }
623
- } else {
624
- appProxy , err := cfConfig .NewClient ().AppProxy (ctx , opts .RuntimeName , store .Get ().InsecureIngressHost )
625
- if err != nil {
626
- return err
627
- }
583
+ err := apcmd .RunAppDelete (ctx , & apcmd.AppDeleteOptions {
584
+ CloneOpts : opts .InsCloneOpts ,
585
+ ProjectName : opts .RuntimeName ,
586
+ AppName : opts .GsName ,
587
+ Global : false ,
588
+ })
628
589
629
- err = appProxy .AppProxyGitSources ().Delete (ctx , opts .GsName )
630
- if err != nil {
631
- return fmt .Errorf ("failed to delete git-source: %w" , err )
632
- }
590
+ if err != nil {
591
+ return fmt .Errorf ("failed to delete the git-source %s. Err: %w" , opts .GsName , err )
633
592
}
634
593
635
594
log .G (ctx ).Infof ("Successfully deleted the git-source: %s" , opts .GsName )
595
+
636
596
return nil
637
597
}
638
598
@@ -702,53 +662,29 @@ func NewGitSourceEditCommand() *cobra.Command {
702
662
func RunGitSourceEdit (ctx context.Context , opts * GitSourceEditOptions ) error {
703
663
repo , fs , err := opts .InsCloneOpts .GetRepo (ctx )
704
664
if err != nil {
705
- return err
665
+ return fmt . Errorf ( "failed to clone the installation repo, attemptint to edit git-source %s. Err: %w" , opts . GsName , err )
706
666
}
707
-
708
- version , err := getRuntimeVersion (ctx , opts .RuntimeName )
667
+ c := & dirConfig {}
668
+ fileName := fs .Join (apstore .Default .AppsDir , opts .GsName , opts .RuntimeName , "config_dir.json" )
669
+ err = fs .ReadJson (fileName , c )
709
670
if err != nil {
710
- return err
671
+ return fmt . Errorf ( "failed to read the %s of git-source: %s. Err: %w" , fileName , opts . GsName , err )
711
672
}
712
673
713
- if version .LessThan (versionOfGitSourceByAppProxyRefactor ) {
714
- log .G (ctx ).Infof ("runtime \" %s\" is using a depracated git-source api. Versions %s and up use the app-proxy for this command" , opts .RuntimeName , minAddClusterSupportedVersion )
715
-
716
- if err != nil {
717
- return fmt .Errorf ("failed to clone the installation repo, attemptint to edit git-source %s. Err: %w" , opts .GsName , err )
718
- }
719
- c := & dirConfig {}
720
- fileName := fs .Join (apstore .Default .AppsDir , opts .GsName , opts .RuntimeName , "config_dir.json" )
721
- err = fs .ReadJson (fileName , c )
722
- if err != nil {
723
- return fmt .Errorf ("failed to read the %s of git-source: %s. Err: %w" , fileName , opts .GsName , err )
724
- }
725
-
726
- c .Config .SrcPath = opts .GsCloneOpts .Path ()
727
- c .Config .SrcRepoURL = opts .GsCloneOpts .URL ()
728
- c .Config .SrcTargetRevision = opts .GsCloneOpts .Revision ()
729
-
730
- err = fs .WriteJson (fileName , c )
731
- if err != nil {
732
- return fmt .Errorf ("failed to write the updated %s of git-source: %s. Err: %w" , fileName , opts .GsName , err )
733
- }
674
+ c .Config .SrcPath = opts .GsCloneOpts .Path ()
675
+ c .Config .SrcRepoURL = opts .GsCloneOpts .URL ()
676
+ c .Config .SrcTargetRevision = opts .GsCloneOpts .Revision ()
734
677
735
- log .G (ctx ).Info ("Pushing updated GitSource to the installation repo" )
736
- if err := apu .PushWithMessage (ctx , repo , fmt .Sprintf ("Persisted an updated git-source \" %s\" " , opts .GsName )); err != nil {
737
- return fmt .Errorf ("failed to persist the updated git-source: %s. Err: %w" , opts .GsName , err )
738
- }
739
- } else {
740
- appProxy , err := cfConfig .NewClient ().AppProxy (ctx , opts .RuntimeName , store .Get ().InsecureIngressHost )
741
- if err != nil {
742
- return err
743
- }
678
+ err = fs .WriteJson (fileName , c )
679
+ if err != nil {
680
+ return fmt .Errorf ("failed to write the updated %s of git-source: %s. Err: %w" , fileName , opts .GsName , err )
681
+ }
744
682
745
- err = appProxy .AppProxyGitSources ().Edit (ctx , opts .GsName , opts .GsCloneOpts .Repo )
746
- if err != nil {
747
- return fmt .Errorf ("failed to edit git-source: %w" , err )
748
- }
683
+ log .G (ctx ).Info ("Pushing updated GitSource to the installation repo" )
684
+ if err := apu .PushWithMessage (ctx , repo , fmt .Sprintf ("Persisted an updated git-source \" %s\" " , opts .GsName )); err != nil {
685
+ return fmt .Errorf ("failed to persist the updated git-source: %s. Err: %w" , opts .GsName , err )
749
686
}
750
687
751
- log .G (ctx ).Infof ("Successfully created git-source: \" %s\" " , opts .GsName )
752
688
return nil
753
689
}
754
690
@@ -909,7 +845,7 @@ func createGithubExampleEventSource(repoURL string, ingressHost string, runtimeN
909
845
},
910
846
Spec : eventsourcev1alpha1.EventSourceSpec {
911
847
EventBusName : store .Get ().EventBusName ,
912
- Template : tpl ,
848
+ Template : tpl ,
913
849
Service : & eventsourcev1alpha1.Service {
914
850
Ports : []corev1.ServicePort {
915
851
{
@@ -1023,7 +959,7 @@ func createGithubExampleSensor() *sensorsv1alpha1.Sensor {
1023
959
}
1024
960
1025
961
tpl := & sensorsv1alpha1.Template {
1026
- Container : & corev1.Container {},
962
+ Container : & corev1.Container {},
1027
963
ServiceAccountName : store .Get ().WorkflowTriggerServiceAccount ,
1028
964
}
1029
965
@@ -1041,7 +977,7 @@ func createGithubExampleSensor() *sensorsv1alpha1.Sensor {
1041
977
},
1042
978
Spec : sensorsv1alpha1.SensorSpec {
1043
979
EventBusName : store .Get ().EventBusName ,
1044
- Template : tpl ,
980
+ Template : tpl ,
1045
981
Dependencies : dependencies ,
1046
982
Triggers : triggers ,
1047
983
},
@@ -1221,16 +1157,3 @@ func unMarshalCustomObject(obj interface{}) (map[string]interface{}, error) {
1221
1157
}
1222
1158
return crd , nil
1223
1159
}
1224
-
1225
- func getRuntimeVersion (ctx context.Context , runtimeName string ) (* semver.Version , error ) {
1226
- rt , err := cfConfig .NewClient ().V2 ().Runtime ().Get (ctx , runtimeName )
1227
- if err != nil {
1228
- return nil , err
1229
- }
1230
-
1231
- if rt .RuntimeVersion == nil {
1232
- return nil , fmt .Errorf ("runtime \" %s\" has no version" , runtimeName )
1233
- }
1234
-
1235
- return semver .MustParse (* rt .RuntimeVersion ), nil
1236
- }
0 commit comments