Add support for adding/updating usergroup tags

proto/user/usergroup_messages.proto

@@ -73,14 +73,14 @@ message UserGroupUpdateRequest {
   optional string group_email = 9;
   optional string owner_id = 10;
   repeated Link links = 11;
+  repeated Tag tags = 12;
 
   //optional StreetAddress address = 8;
   //optional string owner_id = 7; // required
 
   // repeated User followers = 9;
   // repeated UserGroup members = 10;
   // repeated UserGroup memberOfGroups = 11;
-  // repeated Tag tags = 13;
 
   // Privacy privacy = 15;
   // repeated RelatedUserGroup recommended_artists = 16;

server/usergroup.go

@@ -95,6 +95,67 @@ func (s *Server) AddUserGroup(ctx context.Context, usergroup *pbUser.UserGroupCr
 		GroupEmail:  usergroup.GroupEmail,
 	}
 
+	if usergroup.Tags != nil {
+		tags := make([]model.Tag, len(usergroup.Tags))
+		names := make([]string, len(usergroup.Tags))
+
+		for i := range usergroup.Tags {
+			tag := model.Tag{
+				Name: usergroup.Tags[i].Name,
+				Type: "genre",
+			}
+			tag.ID = uuid.Must(uuid.NewRandom())
+			names[i] = tag.Name
+			tags[i] = tag
+		}
+
+		existing := []model.Tag{}
+
+		// find existing tags
+		err := s.db.NewSelect().
+			Model(&existing).
+			Where("type = ? AND name IN (?)", "genre", bun.In(names)).
+			Scan(ctx)
+
+		if err != nil {
+			return nil, err
+		}
+
+		var result []uuid.UUID
+		var insert []model.Tag
+
+		for l := range tags {
+			var seen uuid.UUID
+
+			for e := range existing {
+				if existing[e].Name == tags[l].Name {
+					seen = existing[e].ID
+					break
+				}
+			}
+
+			if seen == uuid.Nil {
+				insert = append(insert, tags[l])
+				result = append(result, tags[l].ID)
+			} else {
+				result = append(result, seen)
+			}
+		}
+
+		if len(insert) > 0 {
+			_, err := s.db.
+				NewInsert().
+				Model(&insert).
+				Exec(ctx)
+
+			if err != nil {
+				return nil, err
+			}
+		}
+
+		newUserGroup.Tags = result
+	}
+
 	if usergroup.Links != nil {
 		uris := make([]string, len(usergroup.Links))
 		links := make([]model.Link, len(usergroup.Links))
@@ -213,6 +274,67 @@ func (s *Server) UpdateUserGroup(ctx context.Context, UserGroupUpdateRequest *pb
 		updatedUserGroupValues["banner"] = *UserGroupUpdateRequest.Banner
 	}
 
+	if UserGroupUpdateRequest.Tags != nil {
+		tags := make([]model.Tag, len(UserGroupUpdateRequest.Tags))
+		names := make([]string, len(UserGroupUpdateRequest.Tags))
+
+		for i := range UserGroupUpdateRequest.Tags {
+			tag := model.Tag{
+				Name: UserGroupUpdateRequest.Tags[i].Name,
+				Type: "genre",
+			}
+			tag.ID = uuid.Must(uuid.NewRandom())
+			names[i] = tag.Name
+			tags[i] = tag
+		}
+
+		existing := []model.Tag{}
+
+		// find existing tags
+		err := s.db.NewSelect().
+			Model(&existing).
+			Where("type = ? AND name IN (?)", "genre", bun.In(names)).
+			Scan(ctx)
+
+		if err != nil {
+			return nil, err
+		}
+
+		var result []uuid.UUID
+		var insert []model.Tag
+
+		for l := range tags {
+			var seen uuid.UUID
+
+			for e := range existing {
+				if existing[e].Name == tags[l].Name {
+					seen = existing[e].ID
+					break
+				}
+			}
+
+			if seen == uuid.Nil {
+				insert = append(insert, tags[l])
+				result = append(result, tags[l].ID)
+			} else {
+				result = append(result, seen)
+			}
+		}
+
+		if len(insert) > 0 {
+			_, err := s.db.
+				NewInsert().
+				Model(&insert).
+				Exec(ctx)
+
+			if err != nil {
+				return nil, err
+			}
+		}
+
+		updatedUserGroupValues["tags"] = result
+	}
+
 	if UserGroupUpdateRequest.Links != nil {
 		links := make([]model.Link, len(UserGroupUpdateRequest.Links))
 		uris := make([]string, len(UserGroupUpdateRequest.Links))

third_party/OpenAPI/user/user.swagger.json

@@ -741,6 +741,12 @@
           "items": {
             "$ref": "#/definitions/userLink"
           }
+        },
+        "tags": {
+          "type": "array",
+          "items": {
+            "$ref": "#/definitions/userTag"
+          }
         }
       }
     },