@@ -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.317" )
108
-
109
106
func NewGitSourceCommand () * cobra.Command {
110
107
cmd := & cobra.Command {
111
108
Use : "git-source" ,
@@ -208,56 +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
- appProxy , err := cfConfig .NewClient ().AppProxy (ctx , opts .RuntimeName , store .Get ().InsecureIngressHost )
218
- if err != nil {
219
- return err
220
- }
221
-
222
- appSpecifier := opts .GsCloneOpts .Repo
223
- isInternal := util .StringIndexOf (store .Get ().CFInternalGitSources , opts .GsName ) > - 1
224
-
225
- err = appProxy .AppProxyGitSources ().Create (ctx , opts .GsName , appSpecifier , opts .RuntimeName , opts .RuntimeName , isInternal )
226
- if err != nil {
227
- return fmt .Errorf ("failed to create git-source: %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 )
228
218
}
229
219
} else {
230
- 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 )
231
- // upsert git-source repo
232
- gsRepo , gsFs , err := opts .GsCloneOpts .GetRepo (ctx )
233
- if err != nil {
234
- return fmt .Errorf ("failed to clone git-source repo: %w" , err )
235
- }
236
-
237
- if opts .CreateDemoResources {
238
- if err := createDemoResources (ctx , opts , gsRepo , gsFs ); err != nil {
239
- return fmt .Errorf ("failed to create git-source demo resources: %w" , err )
240
- }
241
- } else {
242
- if err := createPlaceholderIfNeeded (ctx , opts , gsRepo , gsFs ); err != nil {
243
- return fmt .Errorf ("failed to create a git-source placeholder: %w" , err )
244
- }
220
+ if err := createPlaceholderIfNeeded (ctx , opts , gsRepo , gsFs ); err != nil {
221
+ return fmt .Errorf ("failed to create a git-source placeholder: %w" , err )
245
222
}
223
+ }
246
224
247
- appDef := & runtime.AppDef {
248
- Name : opts .GsName ,
249
- Type : application .AppTypeDirectory ,
250
- URL : opts .GsCloneOpts .Repo ,
251
- }
225
+ appDef := & runtime.AppDef {
226
+ Name : opts .GsName ,
227
+ Type : application .AppTypeDirectory ,
228
+ URL : opts .GsCloneOpts .Repo ,
229
+ }
252
230
253
- appDef .IsInternal = util .StringIndexOf (store .Get ().CFInternalGitSources , appDef .Name ) > - 1
231
+ appDef .IsInternal = util .StringIndexOf (store .Get ().CFInternalGitSources , appDef .Name ) > - 1
254
232
255
- if err := appDef .CreateApp (ctx , nil , opts .InsCloneOpts , opts .RuntimeName , store .Get ().CFGitSourceType , opts .Include , "" ); err != nil {
256
- return fmt .Errorf ("failed to create git-source application. Err: %w" , err )
257
- }
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 )
258
235
}
259
236
260
237
log .G (ctx ).Infof ("Successfully created git-source: \" %s\" " , opts .GsName )
238
+
261
239
return nil
262
240
}
263
241
@@ -390,7 +368,7 @@ func createCronExampleEventSource() *eventsourcev1alpha1.EventSource {
390
368
Name : store .Get ().CronExampleEventSourceName ,
391
369
},
392
370
Spec : eventsourcev1alpha1.EventSourceSpec {
393
- Template : tpl ,
371
+ Template : tpl ,
394
372
EventBusName : store .Get ().EventBusName ,
395
373
Calendar : map [string ]eventsourcev1alpha1.CalendarEventSource {
396
374
store .Get ().CronExampleEventName : {
@@ -412,7 +390,7 @@ func createCronExampleSensor(triggers []sensorsv1alpha1.Trigger) (*sensorsv1alph
412
390
413
391
tpl := & sensorsv1alpha1.Template {
414
392
ServiceAccountName : "argo-server" ,
415
- Container : & corev1.Container {},
393
+ Container : & corev1.Container {},
416
394
}
417
395
418
396
if store .Get ().SetDefaultResources {
@@ -429,7 +407,7 @@ func createCronExampleSensor(triggers []sensorsv1alpha1.Trigger) (*sensorsv1alph
429
407
},
430
408
Spec : sensorsv1alpha1.SensorSpec {
431
409
EventBusName : "codefresh-eventbus" ,
432
- Template : tpl ,
410
+ Template : tpl ,
433
411
Dependencies : dependencies ,
434
412
Triggers : triggers ,
435
413
},
@@ -602,36 +580,19 @@ func NewGitSourceDeleteCommand() *cobra.Command {
602
580
}
603
581
604
582
func RunGitSourceDelete (ctx context.Context , opts * GitSourceDeleteOptions ) error {
605
- version , err := getRuntimeVersion (ctx , opts .RuntimeName )
606
- if err != nil {
607
- return err
608
- }
609
-
610
- if ! version .LessThan (versionOfGitSourceByAppProxyRefactor ) {
611
- appProxy , err := cfConfig .NewClient ().AppProxy (ctx , opts .RuntimeName , store .Get ().InsecureIngressHost )
612
- if err != nil {
613
- return err
614
- }
615
-
616
- err = appProxy .AppProxyGitSources ().Delete (ctx , opts .GsName )
617
- if err != nil {
618
- return fmt .Errorf ("failed to delete git-source: %w" , err )
619
- }
620
- } else {
621
- 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 )
622
- err = apcmd .RunAppDelete (ctx , & apcmd.AppDeleteOptions {
623
- CloneOpts : opts .InsCloneOpts ,
624
- ProjectName : opts .RuntimeName ,
625
- AppName : opts .GsName ,
626
- Global : false ,
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
- if err != nil {
630
- return fmt .Errorf ("failed to delete the git-source %s. Err: %w" , opts .GsName , err )
631
- }
590
+ if err != nil {
591
+ return fmt .Errorf ("failed to delete the git-source %s. Err: %w" , opts .GsName , err )
632
592
}
633
593
634
594
log .G (ctx ).Infof ("Successfully deleted the git-source: %s" , opts .GsName )
595
+
635
596
return nil
636
597
}
637
598
@@ -701,53 +662,29 @@ func NewGitSourceEditCommand() *cobra.Command {
701
662
func RunGitSourceEdit (ctx context.Context , opts * GitSourceEditOptions ) error {
702
663
repo , fs , err := opts .InsCloneOpts .GetRepo (ctx )
703
664
if err != nil {
704
- return err
665
+ return fmt . Errorf ( "failed to clone the installation repo, attemptint to edit git-source %s. Err: %w" , opts . GsName , err )
705
666
}
706
-
707
- 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 )
708
670
if err != nil {
709
- return err
671
+ return fmt . Errorf ( "failed to read the %s of git-source: %s. Err: %w" , fileName , opts . GsName , err )
710
672
}
711
673
712
- if ! version .LessThan (versionOfGitSourceByAppProxyRefactor ) {
713
- appProxy , err := cfConfig .NewClient ().AppProxy (ctx , opts .RuntimeName , store .Get ().InsecureIngressHost )
714
- if err != nil {
715
- return err
716
- }
717
-
718
- err = appProxy .AppProxyGitSources ().Edit (ctx , opts .GsName , opts .GsCloneOpts .Repo )
719
- if err != nil {
720
- return fmt .Errorf ("failed to edit git-source: %w" , err )
721
- }
722
- } else {
723
- 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 )
724
-
725
- if err != nil {
726
- return fmt .Errorf ("failed to clone the installation repo, attemptint to edit git-source %s. Err: %w" , opts .GsName , err )
727
- }
728
- c := & dirConfig {}
729
- fileName := fs .Join (apstore .Default .AppsDir , opts .GsName , opts .RuntimeName , "config_dir.json" )
730
- err = fs .ReadJson (fileName , c )
731
- if err != nil {
732
- return fmt .Errorf ("failed to read the %s of git-source: %s. Err: %w" , fileName , opts .GsName , err )
733
- }
734
-
735
- c .Config .SrcPath = opts .GsCloneOpts .Path ()
736
- c .Config .SrcRepoURL = opts .GsCloneOpts .URL ()
737
- c .Config .SrcTargetRevision = opts .GsCloneOpts .Revision ()
674
+ c .Config .SrcPath = opts .GsCloneOpts .Path ()
675
+ c .Config .SrcRepoURL = opts .GsCloneOpts .URL ()
676
+ c .Config .SrcTargetRevision = opts .GsCloneOpts .Revision ()
738
677
739
- err = fs .WriteJson (fileName , c )
740
- if err != nil {
741
- return fmt .Errorf ("failed to write the updated %s of git-source: %s. Err: %w" , fileName , opts .GsName , err )
742
- }
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
+ }
743
682
744
- log .G (ctx ).Info ("Pushing updated GitSource to the installation repo" )
745
- if err := apu .PushWithMessage (ctx , repo , fmt .Sprintf ("Persisted an updated git-source \" %s\" " , opts .GsName )); err != nil {
746
- return fmt .Errorf ("failed to persist the updated git-source: %s. Err: %w" , opts .GsName , err )
747
- }
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 )
748
686
}
749
687
750
- log .G (ctx ).Infof ("Successfully created git-source: \" %s\" " , opts .GsName )
751
688
return nil
752
689
}
753
690
@@ -908,7 +845,7 @@ func createGithubExampleEventSource(repoURL string, ingressHost string, runtimeN
908
845
},
909
846
Spec : eventsourcev1alpha1.EventSourceSpec {
910
847
EventBusName : store .Get ().EventBusName ,
911
- Template : tpl ,
848
+ Template : tpl ,
912
849
Service : & eventsourcev1alpha1.Service {
913
850
Ports : []corev1.ServicePort {
914
851
{
@@ -1022,7 +959,7 @@ func createGithubExampleSensor() *sensorsv1alpha1.Sensor {
1022
959
}
1023
960
1024
961
tpl := & sensorsv1alpha1.Template {
1025
- Container : & corev1.Container {},
962
+ Container : & corev1.Container {},
1026
963
ServiceAccountName : store .Get ().WorkflowTriggerServiceAccount ,
1027
964
}
1028
965
@@ -1040,7 +977,7 @@ func createGithubExampleSensor() *sensorsv1alpha1.Sensor {
1040
977
},
1041
978
Spec : sensorsv1alpha1.SensorSpec {
1042
979
EventBusName : store .Get ().EventBusName ,
1043
- Template : tpl ,
980
+ Template : tpl ,
1044
981
Dependencies : dependencies ,
1045
982
Triggers : triggers ,
1046
983
},
@@ -1220,16 +1157,3 @@ func unMarshalCustomObject(obj interface{}) (map[string]interface{}, error) {
1220
1157
}
1221
1158
return crd , nil
1222
1159
}
1223
-
1224
- func getRuntimeVersion (ctx context.Context , runtimeName string ) (* semver.Version , error ) {
1225
- rt , err := cfConfig .NewClient ().V2 ().Runtime ().Get (ctx , runtimeName )
1226
- if err != nil {
1227
- return nil , err
1228
- }
1229
-
1230
- if rt .RuntimeVersion == nil {
1231
- return nil , fmt .Errorf ("runtime \" %s\" has no version" , runtimeName )
1232
- }
1233
-
1234
- return semver .MustParse (* rt .RuntimeVersion ), nil
1235
- }
0 commit comments