feat(server): Add coreSupport to Asset (#1246)

Co-authored-by: tomokazu tantaka <t.tantaka@eukarya.io>

server/e2e/gql_asset_test.go

@@ -0,0 +1,166 @@
+package e2e
+
+import (
+	"net/http"
+	"os"
+	"testing"
+
+	"github.com/gavv/httpexpect/v2"
+	"github.com/reearth/reearth/server/internal/app/config"
+)
+
+func TestGetAssets(t *testing.T) {
+	c := &config.Config{
+		Origins: []string{"https://example.com"},
+		AuthSrv: config.AuthSrvConfig{
+			Disabled: true,
+		},
+	}
+	e := StartServer(t, c, true, baseSeeder)
+
+	teamId := wID.String()
+
+	res := createAsset(t, e, "test.png", true, teamId)
+	res.Object().Value("data").Object().Value("createAsset").Object().Value("asset").Object().
+		ValueEqual("teamId", teamId).
+		ValueEqual("name", "test.png").
+		ValueEqual("coreSupport", true)
+
+	res = createAsset(t, e, "test.png", false, teamId)
+	res.Object().Value("data").Object().Value("createAsset").Object().Value("asset").Object().
+		ValueEqual("teamId", teamId).
+		ValueEqual("name", "test.png").
+		ValueEqual("coreSupport", false)
+
+	res = createAsset(t, e, "test.csv", true, teamId)
+	res.Object().Value("data").Object().Value("createAsset").Object().Value("asset").Object().
+		ValueEqual("teamId", teamId).
+		ValueEqual("name", "test.csv").
+		ValueEqual("coreSupport", true)
+
+	res = createAsset(t, e, "test.csv", false, teamId)
+	res.Object().Value("data").Object().Value("createAsset").Object().Value("asset").Object().
+		ValueEqual("teamId", teamId).
+		ValueEqual("name", "test.csv").
+		ValueEqual("coreSupport", false)
+
+	res = getAssets(e, teamId)
+	assets := res.Object().Value("data").Object().Value("assets").Object().Value("nodes").Array().Iter()
+	for _, a := range assets {
+		a.Object().ValueEqual("coreSupport", true) // coreSupport true only
+	}
+
+}
+
+const CreateAssetMutation = `mutation CreateAsset($teamId: ID!, $file: Upload!, $coreSupport: Boolean!) {
+  createAsset(input: {teamId: $teamId, file: $file, coreSupport: $coreSupport}) {
+    asset {
+      id
+      teamId
+      name
+      size
+      url
+      contentType
+	  coreSupport
+      __typename
+    }
+    __typename
+  }
+}`
+
+func createAsset(t *testing.T, e *httpexpect.Expect, filePath string, coreSupport bool, teamId string) *httpexpect.Value {
+	file, err := os.Open(filePath)
+	if err != nil {
+		t.Fatalf("failed to open file: %v", err)
+	}
+	defer func() {
+		if cerr := file.Close(); cerr != nil && err == nil {
+			err = cerr
+		}
+	}()
+	requestBody := map[string]interface{}{
+		"operationName": "CreateAsset",
+		"variables": map[string]interface{}{
+			"teamId":      teamId,
+			"coreSupport": coreSupport,
+			"file":        nil,
+		},
+		"query": CreateAssetMutation,
+	}
+	return e.POST("/api/graphql").
+		WithHeader("Origin", "https://example.com").
+		WithHeader("authorization", "Bearer test").
+		WithHeader("X-Reearth-Debug-User", uID.String()).
+		WithMultipart().
+		WithFormField("operations", toJSONString(requestBody)).
+		WithFormField("map", `{"0": ["variables.file"]}`).
+		WithFile("0", filePath).
+		Expect().
+		Status(http.StatusOK).
+		JSON()
+}
+
+const GetAssetsQuery = `query GetAssets($teamId: ID!, $pagination: Pagination, $keyword: String, $sort: AssetSort) {
+	assets(teamId: $teamId, pagination: $pagination, keyword: $keyword, sort: $sort) {
+	  edges {
+		cursor
+		node {
+		  id
+		  teamId
+		  name
+		  size
+		  url
+		  createdAt
+		  contentType
+		  coreSupport
+		  __typename
+		}
+		__typename
+	  }
+	  nodes {
+		id
+		teamId
+		name
+		size
+		url
+		createdAt
+		contentType
+		coreSupport
+		__typename
+	  }
+	  pageInfo {
+		endCursor
+		hasNextPage
+		hasPreviousPage
+		startCursor
+		__typename
+	  }
+	  totalCount
+	  __typename
+	}
+  }`
+
+func getAssets(e *httpexpect.Expect, teamId string) *httpexpect.Value {
+	requestBody := GraphQLRequest{
+		OperationName: "GetAssets",
+		Query:         GetAssetsQuery,
+		Variables: map[string]any{
+			"teamId": teamId,
+			"pagination": map[string]any{
+				"first": 20,
+			},
+			"sort": map[string]string{
+				"direction": "DESC",
+				"field":     "DATE",
+			},
+		},
+	}
+	return e.POST("/api/graphql").
+		WithHeader("Origin", "https://example.com").
+		WithHeader("X-Reearth-Debug-User", uID.String()).
+		WithHeader("Content-Type", "application/json").
+		WithJSON(requestBody).
+		Expect().
+		Status(http.StatusOK).
+		JSON()
+}

server/e2e/test.csv

@@ -0,0 +1,2 @@
+title,lat,lng,size,sizex10,height,color,show,data,url
+龍安寺,35.03449434,135.7182635,10,100,1000,#3d86fc,TRUE,Oct.1,https://upload.wikimedia.org/wikipedia/commons/thumb/9/9b/RyoanJi-Dry_garden.jpg/800px-RyoanJi-Dry_garden.jpg

server/gql/asset.graphql

@@ -7,6 +7,7 @@ type Asset implements Node {
   url: String!
   contentType: String!
   team: Team
+  coreSupport: Boolean!
 }
 
 enum AssetSortField {
@@ -19,6 +20,7 @@ enum AssetSortField {
 
 input CreateAssetInput {
   teamId: ID!
+  coreSupport: Boolean!
   file: Upload!
 }
 
@@ -55,11 +57,16 @@ type AssetEdge {
   node: Asset
 }
 
-extend type Query{
-  assets(teamId: ID!, pagination: Pagination, keyword: String, sort: AssetSort): AssetConnection!
+extend type Query {
+  assets(
+    teamId: ID!
+    pagination: Pagination
+    keyword: String
+    sort: AssetSort
+  ): AssetConnection!
 }
 
 extend type Mutation {
   createAsset(input: CreateAssetInput!): CreateAssetPayload
   removeAsset(input: RemoveAssetInput!): RemoveAssetPayload
-}
+}

server/internal/adapter/gql/gqlmodel/convert_asset.go

@@ -17,6 +17,7 @@ func ToAsset(a *asset.Asset) *Asset {
 		Size:        a.Size(),
 		URL:         a.URL(),
 		ContentType: a.ContentType(),
+		CoreSupport: a.CoreSupport(),
 	}
 }