feat: enable GetMaskedSyncers()

This commit is contained in:
Yang Luo 2024-01-18 20:59:27 +08:00
parent a681c267b3
commit b8db07db4d
2 changed files with 23 additions and 10 deletions

View File

@ -40,7 +40,7 @@ func (c *ApiController) GetSyncers() {
organization := c.Input().Get("organization") organization := c.Input().Get("organization")
if limit == "" || page == "" { if limit == "" || page == "" {
syncers, err := object.GetOrganizationSyncers(owner, organization) syncers, err := object.GetMaskedSyncers(object.GetOrganizationSyncers(owner, organization))
if err != nil { if err != nil {
c.ResponseError(err.Error()) c.ResponseError(err.Error())
return return
@ -56,7 +56,7 @@ func (c *ApiController) GetSyncers() {
} }
paginator := pagination.SetPaginator(c.Ctx, limit, count) paginator := pagination.SetPaginator(c.Ctx, limit, count)
syncers, err := object.GetPaginationSyncers(owner, organization, paginator.Offset(), limit, field, value, sortField, sortOrder) syncers, err := object.GetMaskedSyncers(object.GetPaginationSyncers(owner, organization, paginator.Offset(), limit, field, value, sortField, sortOrder))
if err != nil { if err != nil {
c.ResponseError(err.Error()) c.ResponseError(err.Error())
return return
@ -76,7 +76,7 @@ func (c *ApiController) GetSyncers() {
func (c *ApiController) GetSyncer() { func (c *ApiController) GetSyncer() {
id := c.Input().Get("id") id := c.Input().Get("id")
syncer, err := object.GetSyncer(id) syncer, err := object.GetMaskedSyncer(object.GetSyncer(id))
if err != nil { if err != nil {
c.ResponseError(err.Error()) c.ResponseError(err.Error())
return return

View File

@ -116,22 +116,35 @@ func GetSyncer(id string) (*Syncer, error) {
return getSyncer(owner, name) return getSyncer(owner, name)
} }
func GetMaskedSyncer(syncer *Syncer) *Syncer { func GetMaskedSyncer(syncer *Syncer, errs ...error) (*Syncer, error) {
if len(errs) > 0 && errs[0] != nil {
return nil, errs[0]
}
if syncer == nil { if syncer == nil {
return nil return nil, nil
} }
if syncer.Password != "" { if syncer.Password != "" {
syncer.Password = "***" syncer.Password = "***"
} }
return syncer return syncer, nil
} }
func GetMaskedSyncers(syncers []*Syncer) []*Syncer { func GetMaskedSyncers(syncers []*Syncer, errs ...error) ([]*Syncer, error) {
for _, syncer := range syncers { if len(errs) > 0 && errs[0] != nil {
syncer = GetMaskedSyncer(syncer) return nil, errs[0]
} }
return syncers
var err error
for _, syncer := range syncers {
syncer, err = GetMaskedSyncer(syncer)
if err != nil {
return nil, err
}
}
return syncers, nil
} }
func UpdateSyncer(id string, syncer *Syncer) (bool, error) { func UpdateSyncer(id string, syncer *Syncer) (bool, error) {