Skip to content

Commit 46cc2b5

Browse files
committed
Remove the recursive delete of triggers as they are not longer supported.
1 parent 2e9b278 commit 46cc2b5

File tree

3 files changed

+10
-69
lines changed

3 files changed

+10
-69
lines changed

common/common.go

+2-38
Original file line numberDiff line numberDiff line change
@@ -609,11 +609,10 @@ func GetFuncYamlVersion(oldFF map[string]interface{}) int {
609609
}
610610

611611
// UserConfirmedMultiResourceDeletion will prompt the user for confirmation to delete all the the resources
612-
func UserConfirmedMultiResourceDeletion(aps []*modelsv2.App, fns []*modelsv2.Fn, trs []*modelsv2.Trigger) bool {
612+
func UserConfirmedMultiResourceDeletion(aps []*modelsv2.App, fns []*modelsv2.Fn) bool {
613613

614614
apsLen := len(aps)
615615
fnsLen := len(fns)
616-
trsLen := len(trs)
617616

618617
fmt.Println("You are about to delete the following resources:")
619618
if apsLen > 0 {
@@ -622,9 +621,7 @@ func UserConfirmedMultiResourceDeletion(aps []*modelsv2.App, fns []*modelsv2.Fn,
622621
if fnsLen > 0 {
623622
fmt.Println(" Functions: ", fnsLen)
624623
}
625-
if trsLen > 0 {
626-
fmt.Println(" Triggers: ", trsLen)
627-
}
624+
628625
fmt.Println("This operation cannot be undone")
629626
fmt.Printf("Do you wish to proceed? Y/N: ")
630627
reader := bufio.NewReader(os.Stdin)
@@ -643,22 +640,6 @@ func UserConfirmedMultiResourceDeletion(aps []*modelsv2.App, fns []*modelsv2.Fn,
643640
return true
644641
}
645642

646-
// ListFnsAndTriggersInApp lists all the functions associated with an app and all the triggers associated with each of those functions
647-
func ListFnsAndTriggersInApp(c *cli.Context, client *fnclient.Fn, app *modelsv2.App) ([]*modelsv2.Fn, []*modelsv2.Trigger, error) {
648-
fns, err := ListFnsInApp(c, client, app)
649-
if err != nil {
650-
return nil, nil, err
651-
}
652-
var trs []*modelsv2.Trigger
653-
for _, fn := range fns {
654-
t, err := ListTriggersInFunc(c, client, fn)
655-
if err != nil {
656-
return nil, nil, err
657-
}
658-
trs = append(trs, t...)
659-
}
660-
return fns, trs, nil
661-
}
662643

663644
//DeleteFunctions deletes all the functions provided to it. if provided nil it is a no-op
664645
func DeleteFunctions(c *cli.Context, client *fnclient.Fn, fns []*modelsv2.Fn) error {
@@ -677,23 +658,6 @@ func DeleteFunctions(c *cli.Context, client *fnclient.Fn, fns []*modelsv2.Fn) er
677658
return nil
678659
}
679660

680-
//DeleteTriggers deletes all the triggers provided to it. if provided nil it is a no-op
681-
func DeleteTriggers(c *cli.Context, client *fnclient.Fn, triggers []*modelsv2.Trigger) error {
682-
if triggers == nil {
683-
return nil
684-
}
685-
for _, t := range triggers {
686-
params := apitriggers.NewDeleteTriggerParams()
687-
params.TriggerID = t.ID
688-
_, err := client.Triggers.DeleteTrigger(params)
689-
if err != nil {
690-
return fmt.Errorf("Failed to Delete trigger %s: %s", t.Name, err)
691-
}
692-
fmt.Println("Trigger ", t.Name, " deleted")
693-
}
694-
return nil
695-
}
696-
697661
//ListFnsInApp gets all the functions associated with an app
698662
func ListFnsInApp(c *cli.Context, client *fnclient.Fn, app *modelsv2.App) ([]*modelsv2.Fn, error) {
699663
params := &apifns.ListFnsParams{

objects/app/apps.go

+8-6
Original file line numberDiff line numberDiff line change
@@ -319,24 +319,26 @@ func (a *appsCmd) delete(c *cli.Context) error {
319319

320320
//recursive delete of sub-objects
321321
if c.Bool("recursive") {
322-
fns, triggers, err := common.ListFnsAndTriggersInApp(c, a.client, app)
322+
323+
fns, err := common.ListFnsInApp(c, a.client, app)
323324
if err != nil {
324325
return fmt.Errorf("Failed to get associated objects: %s", err)
325326
}
326327

328+
//fns, triggers, err := common.ListFnsAndTriggersInApp(c, a.client, app)
329+
//if err != nil {
330+
// return fmt.Errorf("Failed to get associated objects: %s", err)
331+
//}
332+
327333
//Forced deletion
328334
var shouldContinue bool
329335
if c.Bool("force") {
330336
shouldContinue = true
331337
} else {
332-
shouldContinue = common.UserConfirmedMultiResourceDeletion([]*modelsv2.App{app}, fns, triggers)
338+
shouldContinue = common.UserConfirmedMultiResourceDeletion([]*modelsv2.App{app}, fns)
333339
}
334340

335341
if shouldContinue {
336-
err := common.DeleteTriggers(c, a.client, triggers)
337-
if err != nil {
338-
return fmt.Errorf("Failed to delete associated objects: %s", err)
339-
}
340342
err = common.DeleteFunctions(c, a.client, fns)
341343
if err != nil {
342344
return fmt.Errorf("Failed to delete associated objects: %s", err)

objects/fn/fns.go

-25
Original file line numberDiff line numberDiff line change
@@ -551,31 +551,6 @@ func (f *fnsCmd) delete(c *cli.Context) error {
551551
return err
552552
}
553553

554-
//recursive delete of sub-objects
555-
if c.Bool("recursive") {
556-
triggers, err := common.ListTriggersInFunc(c, f.client, fn)
557-
if err != nil {
558-
return fmt.Errorf("Failed to get associated objects: %s", err)
559-
}
560-
561-
//Forced delete
562-
var shouldContinue bool
563-
if c.Bool("force") {
564-
shouldContinue = true
565-
} else {
566-
shouldContinue = common.UserConfirmedMultiResourceDeletion(nil, []*modelsv2.Fn{fn}, triggers)
567-
}
568-
569-
if shouldContinue {
570-
err := common.DeleteTriggers(c, f.client, triggers)
571-
if err != nil {
572-
return fmt.Errorf("Failed to delete associated objects: %s", err)
573-
}
574-
} else {
575-
return nil
576-
}
577-
}
578-
579554
params := apifns.NewDeleteFnParams()
580555
params.FnID = fn.ID
581556
_, err = f.client.Fns.DeleteFn(params)

0 commit comments

Comments
 (0)