125 lines
2.6 KiB
Go
125 lines
2.6 KiB
Go
package main
|
|
|
|
import (
|
|
"bytes"
|
|
"fmt"
|
|
"io/ioutil"
|
|
"os"
|
|
"strings"
|
|
"text/template"
|
|
)
|
|
|
|
type deleteInfo struct {
|
|
baseType string
|
|
targetType string
|
|
path string
|
|
}
|
|
|
|
var deleteFuncs = map[string][]*deleteInfo{
|
|
"scopes": {
|
|
{
|
|
"Scope",
|
|
"Scope",
|
|
"scopes",
|
|
},
|
|
},
|
|
"authtokens": {
|
|
{
|
|
"AuthToken",
|
|
"AuthToken",
|
|
"auth-tokens",
|
|
},
|
|
},
|
|
"groups": {
|
|
{
|
|
"Group",
|
|
"Group",
|
|
"groups",
|
|
},
|
|
},
|
|
"users": {
|
|
{
|
|
"User",
|
|
"User",
|
|
"users",
|
|
},
|
|
},
|
|
"roles": {
|
|
{
|
|
"Role",
|
|
"Role",
|
|
"roles",
|
|
},
|
|
},
|
|
}
|
|
|
|
func writeDeleteFuncs() {
|
|
for outPkg, funcs := range deleteFuncs {
|
|
outFile := os.Getenv("GEN_BASEPATH") + fmt.Sprintf("/api/%s/delete.gen.go", outPkg)
|
|
outBuf := bytes.NewBuffer([]byte(fmt.Sprintf(
|
|
`// Code generated by "make api"; DO NOT EDIT.
|
|
package %s
|
|
`, outPkg)))
|
|
for _, deleteInfo := range funcs {
|
|
deleteFuncTemplate.Execute(outBuf, struct {
|
|
BaseType string
|
|
TargetType string
|
|
TargetName string
|
|
Path string
|
|
}{
|
|
BaseType: deleteInfo.baseType,
|
|
TargetType: deleteInfo.targetType,
|
|
TargetName: strings.Split(deleteInfo.targetType, ".")[strings.Count(deleteInfo.targetType, ".")],
|
|
Path: deleteInfo.path,
|
|
})
|
|
}
|
|
if err := ioutil.WriteFile(outFile, outBuf.Bytes(), 0644); err != nil {
|
|
fmt.Printf("error writing file %q: %v\n", outFile, err)
|
|
os.Exit(1)
|
|
}
|
|
}
|
|
}
|
|
|
|
var deleteFuncTemplate = template.Must(template.New("").Parse(
|
|
`
|
|
// Delete{{ .TargetName }} returns true iff the {{ .TargetType }} existed when the delete attempt was made.
|
|
func (s {{ .BaseType }}) Delete{{ .TargetName }}(ctx context.Context, id string) (bool, *api.Error, error) {
|
|
if id == "" {
|
|
return false, nil, fmt.Errorf("empty id provided to Delete{{ .TargetName }} request")
|
|
}
|
|
|
|
if s.Client == nil {
|
|
return false, nil, fmt.Errorf("nil client in Delete{{ .TargetName }} request")
|
|
}
|
|
|
|
var opts []api.Option
|
|
if s.Scope.Id != "" {
|
|
// If it's explicitly set here, override anything that might be in the
|
|
// client
|
|
opts = append(opts, api.WithScopeId(s.Scope.Id))
|
|
}
|
|
|
|
req, err := s.Client.NewRequest(ctx, "DELETE", fmt.Sprintf("%s/%s", "{{ .Path }}", id), nil, opts...)
|
|
if err != nil {
|
|
return false, nil, fmt.Errorf("error creating Delete{{ .TargetName }} request: %w", err)
|
|
}
|
|
|
|
resp, err := s.Client.Do(req)
|
|
if err != nil {
|
|
return false, nil, fmt.Errorf("error performing client request during Delete{{ .TargetName }} call: %w", err)
|
|
}
|
|
|
|
type deleteResponse struct {
|
|
Existed bool
|
|
}
|
|
target := &deleteResponse{}
|
|
|
|
apiErr, err := resp.Decode(target)
|
|
if err != nil {
|
|
return false, nil, fmt.Errorf("error decoding Delete{{ .TargetName }} repsonse: %w", err)
|
|
}
|
|
|
|
return target.Existed, apiErr, nil
|
|
}
|
|
`))
|