@@ -50,7 +50,6 @@ func rdbACLCustomMultiResultMarshalerFunc(i interface{}, opt *human.MarshalOpt)
50
50
case * rdbACLCustomResult :
51
51
finalMessage := ""
52
52
for _ , result := range results {
53
-
54
53
aclResult := result .(* rdbACLCustomResult )
55
54
messageStr , err := aclResult .Success .MarshalHuman ()
56
55
if err != nil {
@@ -224,7 +223,6 @@ func aclDeleteBuilder(c *core.Command) *core.Command {
224
223
Message : message ,
225
224
},
226
225
}, nil
227
-
228
226
}
229
227
230
228
c .WaitFunc = func (ctx context.Context , argsI , respI interface {}) (interface {}, error ) {
@@ -248,52 +246,26 @@ func aclDeleteBuilder(c *core.Command) *core.Command {
248
246
}
249
247
250
248
func aclSetBuilder (c * core.Command ) * core.Command {
251
- c .ArgsType = reflect .TypeOf (rdbACLCustomArgs {})
252
- c .ArgSpecs = core.ArgSpecs {
253
- {
254
- Name : "acl-rule-ips" ,
255
- Short : "IP addresses defined in the ACL rules of the Database Instance" ,
256
- Required : true ,
257
- Positional : true ,
258
- },
259
- {
260
- Name : "instance-id" ,
261
- Short : "ID of the Database Instance" ,
262
- Required : true ,
263
- Positional : false ,
264
- },
265
- core .RegionArgSpec (),
266
- }
267
-
268
249
c .Run = func (ctx context.Context , argsI interface {}) (i interface {}, e error ) {
269
- args := argsI .(* rdbACLCustomArgs )
250
+ args := argsI .(* rdb. SetInstanceACLRulesRequest )
270
251
client := core .ExtractClient (ctx )
271
252
api := rdb .NewAPI (client )
272
253
273
- rule , err := api .SetInstanceACLRules (& rdb.SetInstanceACLRulesRequest {
274
- Region : args .Region ,
275
- InstanceID : args .InstanceID ,
276
- Rules : []* rdb.ACLRuleRequest {
277
- {
278
- IP : args .ACLRuleIPs ,
279
- Description : fmt .Sprintf ("Allow %s" , args .ACLRuleIPs .String ()),
280
- },
281
- },
282
- }, scw .WithContext (ctx ))
254
+ rule , err := api .SetInstanceACLRules (args , scw .WithContext (ctx ))
283
255
if err != nil {
284
256
return nil , fmt .Errorf ("failed to set ACL rule: %w" , err )
285
257
}
286
258
287
259
return & rdbACLCustomResult {
288
260
Rules : rule .Rules ,
289
261
Success : core.SuccessResult {
290
- Message : fmt . Sprintf ( "ACL rules successfully set" ) ,
262
+ Message : "ACL rules successfully set" ,
291
263
},
292
264
}, nil
293
265
}
294
266
295
267
c .WaitFunc = func (ctx context.Context , argsI , respI interface {}) (interface {}, error ) {
296
- args := argsI .(* rdbACLCustomArgs )
268
+ args := argsI .(* rdb. SetInstanceACLRulesRequest )
297
269
api := rdb .NewAPI (core .ExtractClient (ctx ))
298
270
299
271
_ , err := api .WaitForInstance (& rdb.WaitForInstanceRequest {
0 commit comments