Skip to content

Commit 68a4aa2

Browse files
Paolo CalaoGiuseppe Lumia
Paolo Calao
and
Giuseppe Lumia
authored
Improve resource deletion flow (#66)
Co-authored-by: Giuseppe Lumia <[email protected]>
1 parent 9774541 commit 68a4aa2

File tree

2 files changed

+24
-25
lines changed

2 files changed

+24
-25
lines changed

Diff for: command/device/delete.go

+11-12
Original file line numberDiff line numberDiff line change
@@ -52,26 +52,25 @@ func Delete(params *DeleteParams) error {
5252
return err
5353
}
5454

55+
deviceIDs := []string{}
5556
if params.ID != nil {
56-
// Delete by id
57-
return iotClient.DeviceDelete(*params.ID)
58-
59-
} else if params.Tags != nil {
60-
// Delete by tags
57+
deviceIDs = append(deviceIDs, *params.ID)
58+
}
59+
if params.Tags != nil {
6160
dev, err := iotClient.DeviceList(params.Tags)
6261
if err != nil {
6362
return err
6463
}
6564
for _, d := range dev {
66-
err = iotClient.DeviceDelete(d.Id)
67-
if err != nil {
68-
return err
69-
}
65+
deviceIDs = append(deviceIDs, d.Id)
7066
}
67+
}
7168

72-
} else {
73-
// should not be reachable
74-
return errors.New("provide either '--id' or '--tags' flag")
69+
for _, id := range deviceIDs {
70+
err = iotClient.DeviceDelete(id)
71+
if err != nil {
72+
return err
73+
}
7574
}
7675

7776
return nil

Diff for: command/thing/delete.go

+13-13
Original file line numberDiff line numberDiff line change
@@ -52,25 +52,25 @@ func Delete(params *DeleteParams) error {
5252
return err
5353
}
5454

55+
thingIDs := []string{}
5556
if params.ID != nil {
56-
// Delete by ID
57-
return iotClient.ThingDelete(*params.ID)
58-
59-
} else if params.Tags != nil {
60-
things, err := iotClient.ThingList(nil, nil, false, params.Tags)
57+
thingIDs = append(thingIDs, *params.ID)
58+
}
59+
if params.Tags != nil {
60+
th, err := iotClient.ThingList(nil, nil, false, params.Tags)
6161
if err != nil {
6262
return err
6363
}
64-
for _, t := range things {
65-
err = iotClient.ThingDelete(t.Id)
66-
if err != nil {
67-
return err
68-
}
64+
for _, t := range th {
65+
thingIDs = append(thingIDs, t.Id)
6966
}
67+
}
7068

71-
} else {
72-
// should not be reachable
73-
return errors.New("provide either '--id' or '--tags' flag")
69+
for _, id := range thingIDs {
70+
err = iotClient.ThingDelete(id)
71+
if err != nil {
72+
return err
73+
}
7474
}
7575

7676
return nil

0 commit comments

Comments
 (0)