filter targets by name

api/target.go

@@ -121,22 +121,6 @@ func (t *TargetAPI) Ping() {
 // Get ...
 func (t *TargetAPI) Get() {
 	id := t.getIDFromURL()
-	// list targets
-	if id == 0 {
-		targets, err := dao.GetAllRepTargets()
-		if err != nil {
-			log.Errorf("failed to get all targets: %v", err)
-			t.CustomAbort(http.StatusInternalServerError, http.StatusText(http.StatusInternalServerError))
-		}
-
-		for _, target := range targets {
-			target.Password = ""
-		}
-
-		t.Data["json"] = targets
-		t.ServeJSON()
-		return
-	}
 
 	target, err := dao.GetRepTarget(id)
 	if err != nil {
@@ -148,6 +132,8 @@ func (t *TargetAPI) Get() {
 		t.CustomAbort(http.StatusNotFound, http.StatusText(http.StatusNotFound))
 	}
 
+	// the reason why the password is returned is that when user just wants to
+	// modify other fields of target he does not need to input the password again
 	if len(target.Password) != 0 {
 		pwd, err := utils.ReversibleDecrypt(target.Password)
 		if err != nil {
@@ -161,6 +147,33 @@ func (t *TargetAPI) Get() {
 	t.ServeJSON()
 }
 
+// List ...
+func (t *TargetAPI) List() {
+	name := t.GetString("name")
+	targets, err := dao.FilterRepTargets(name)
+	if err != nil {
+		log.Errorf("failed to filter targets %s: %v", name, err)
+		t.CustomAbort(http.StatusInternalServerError, http.StatusText(http.StatusInternalServerError))
+	}
+
+	for _, target := range targets {
+		if len(target.Password) == 0 {
+			continue
+		}
+
+		str, err := utils.ReversibleDecrypt(target.Password)
+		if err != nil {
+			log.Errorf("failed to decrypt password: %v", err)
+			t.CustomAbort(http.StatusInternalServerError, http.StatusText(http.StatusInternalServerError))
+		}
+		target.Password = str
+	}
+
+	t.Data["json"] = targets
+	t.ServeJSON()
+	return
+}
+
 // Post ...
 func (t *TargetAPI) Post() {
 	target := &models.RepTarget{}

dao/replication_job.go

@@ -54,12 +54,30 @@ func UpdateRepTarget(target models.RepTarget) error {
 // GetAllRepTargets ...
 func GetAllRepTargets() ([]*models.RepTarget, error) {
 	o := GetOrmer()
+
 	qs := o.QueryTable(&models.RepTarget{})
 	var targets []*models.RepTarget
 	_, err := qs.All(&targets)
 	return targets, err
 }
 
+// FilterRepTargets filters targets by name
+func FilterRepTargets(name string) ([]*models.RepTarget, error) {
+	if len(name) == 0 {
+		return GetAllRepTargets()
+	}
+
+	o := GetOrmer()
+
+	var targets []*models.RepTarget
+	sql := "select * from replication_target where name like ?"
+	if _, err := o.Raw(sql, "%"+name+"%").QueryRows(targets); err != nil {
+		return nil, err
+	}
+
+	return targets, nil
+}
+
 // AddRepPolicy ...
 func AddRepPolicy(policy models.RepPolicy) (int64, error) {
 	o := GetOrmer()

ui/router.go

@@ -66,7 +66,8 @@ func initRouters() {
 	beego.Router("/api/jobs/replication/:id([0-9]+)/log", &api.RepJobAPI{}, "get:GetLog")
 	beego.Router("/api/policies/replication", &api.RepPolicyAPI{})
 	beego.Router("/api/policies/replication/:id([0-9]+)/enablement", &api.RepPolicyAPI{}, "put:UpdateEnablement")
-	beego.Router("/api/targets/?:id([0-9]+)", &api.TargetAPI{})
+	beego.Router("/api/targets/", &api.TargetAPI{}, "get:List")
+	beego.Router("/api/targets/:id([0-9]+)", &api.TargetAPI{})
 	beego.Router("/api/targets/ping", &api.TargetAPI{}, "post:Ping")
 
 	//external service that hosted on harbor process: