chore: add list all environment tags storage interface

Signed-off-by: Alessandro Yuichi Okimoto <[email protected]>

pkg/tag/storage/sql/select_all_environment_tags.sql

@@ -0,0 +1,11 @@
+SELECT 
+    env.id AS environment_id,
+    tag.id,
+    tag.name,
+    tag.created_at,
+    tag.updated_at,
+    tag.entity_type,
+    tag.environment_id
+FROM tag
+JOIN environment_v2 env ON tag.environment_id = env.id
+ORDER BY env.id, tag.name;

pkg/tag/storage/tag.go

@@ -36,6 +36,8 @@ var (
 	selectTagSQL string
 	//go:embed sql/select_tags.sql
 	selectTagsSQL string
+	//go:embed sql/select_all_environment_tags.sql
+	selectAllEnvironmentTagsSQL string
 	//go:embed sql/count_tags.sql
 	countTagsSQL string
 	//go:embed sql/delete_tag.sql
@@ -51,6 +53,7 @@ type TagStorage interface {
 		orders []*mysql.Order,
 		limit, offset int,
 	) ([]*proto.Tag, int, int64, error)
+	ListAllEnvironmentTags(ctx context.Context) ([]*proto.EnvironmentTag, error)
 	DeleteTag(ctx context.Context, id, environmentId string) error
 }
 
@@ -151,6 +154,46 @@ func (s *tagStorage) ListTags(
 	return tags, nextOffset, totalCount, nil
 }
 
+func (s *tagStorage) ListAllEnvironmentTags(ctx context.Context) ([]*proto.EnvironmentTag, error) {
+	rows, err := s.qe.QueryContext(ctx, selectAllEnvironmentTagsSQL)
+	if err != nil {
+		return nil, err
+	}
+	defer rows.Close()
+	envTags := map[string][]*proto.Tag{}
+	for rows.Next() {
+		var entityType int32
+		var envID string
+		tag := proto.Tag{}
+		err := rows.Scan(
+			&envID,
+			&tag.Id,
+			&tag.Name,
+			&tag.CreatedAt,
+			&tag.UpdatedAt,
+			&entityType,
+			&tag.EnvironmentId,
+		)
+		if err != nil {
+			return nil, err
+		}
+		tag.EntityType = proto.Tag_EntityType(entityType)
+		envTags[envID] = append(envTags[envID], &tag)
+	}
+	if rows.Err() != nil {
+		return nil, err
+	}
+	environmentTags := make([]*proto.EnvironmentTag, 0, len(envTags))
+	for key, tags := range envTags {
+		envTag := &proto.EnvironmentTag{
+			EnvironmentId: key,
+			Tags:          tags,
+		}
+		environmentTags = append(environmentTags, envTag)
+	}
+	return environmentTags, nil
+}
+
 func (s *tagStorage) DeleteTag(ctx context.Context, id, environmentId string) error {
 	result, err := s.qe.ExecContext(ctx, deleteTagSQL, id)
 	if err != nil {

proto/proto.lock

@@ -33066,6 +33066,22 @@
                 "type": "string"
               }
             ]
+          },
+          {
+            "name": "EnvironmentTag",
+            "fields": [
+              {
+                "id": 1,
+                "name": "environment_id",
+                "type": "string"
+              },
+              {
+                "id": 2,
+                "name": "tags",
+                "type": "Tag",
+                "is_repeated": true
+              }
+            ]
           }
         ],
         "package": {

proto/tag/tag.proto

@@ -30,3 +30,8 @@ message Tag {
   EntityType entity_type = 5;
   string environment_id = 6;
 }
+
+message EnvironmentTag {
+  string environment_id = 1;
+  repeated Tag tags = 2;
+}

ui/web-v2/src/proto/tag/tag_pb.d.ts

@@ -55,3 +55,40 @@ export namespace Tag {
 
   export const EntityType: EntityTypeMap;
 }
+
+export class EnvironmentTag extends jspb.Message {
+  getEnvironmentId(): string;
+  setEnvironmentId(value: string): void;
+
+  clearTagsList(): void;
+  getTagsList(): Array<Tag>;
+  setTagsList(value: Array<Tag>): void;
+  addTags(value?: Tag, index?: number): Tag;
+
+  serializeBinary(): Uint8Array;
+  toObject(includeInstance?: boolean): EnvironmentTag.AsObject;
+  static toObject(
+    includeInstance: boolean,
+    msg: EnvironmentTag
+  ): EnvironmentTag.AsObject;
+  static extensions: { [key: number]: jspb.ExtensionFieldInfo<jspb.Message> };
+  static extensionsBinary: {
+    [key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>;
+  };
+  static serializeBinaryToWriter(
+    message: EnvironmentTag,
+    writer: jspb.BinaryWriter
+  ): void;
+  static deserializeBinary(bytes: Uint8Array): EnvironmentTag;
+  static deserializeBinaryFromReader(
+    message: EnvironmentTag,
+    reader: jspb.BinaryReader
+  ): EnvironmentTag;
+}
+
+export namespace EnvironmentTag {
+  export type AsObject = {
+    environmentId: string;
+    tagsList: Array<Tag.AsObject>;
+  };
+}