refactor(server): transfer repos to plateauapi

server/datacatalog/datacatalogv2/datacatalogv2adapter/type.go

@@ -496,7 +496,7 @@ func cityFrom(d datacatalogv2.DataCatalogItem) *plateauapi.City {
 
 func citygmlFrom(d datacatalogv2.DataCatalogItem) *plateauapi.CityGMLDataset {
 	id, code := cityIDFrom(d), cityCodeFrom(d)
-	if id == nil || code == nil || d.CityGMLURL == "" || d.Spec == "" || len(d.CityGMLFeatureTypes) == 0 {
+	if id == nil || code == nil || d.CityGMLURL == "" || d.MaxLODURL == "" || d.Spec == "" || len(d.CityGMLFeatureTypes) == 0 {
 		return nil
 	}
 
@@ -514,7 +514,6 @@ func citygmlFrom(d datacatalogv2.DataCatalogItem) *plateauapi.CityGMLDataset {
 		Admin: map[string]any{
 			"maxlod": d.MaxLODURL,
 		},
-		// Items: items,
 	}
 }
 

server/datacatalog/datacatalogv3/repos.go

@@ -0,0 +1,77 @@
+package datacatalogv3
+
+import (
+	"context"
+	"fmt"
+	"sort"
+	"time"
+
+	"github.com/eukarya-inc/reearth-plateauview/server/datacatalog/plateauapi"
+	cms "github.com/reearth/reearth-cms-api/go"
+	"github.com/reearth/reearthx/log"
+	"github.com/reearth/reearthx/util"
+)
+
+var stagesForAdmin = []string{string(stageBeta)}
+
+type Repos struct {
+	cms *util.SyncMap[string, *CMS]
+	*plateauapi.Repos
+}
+
+func NewRepos() *Repos {
+	r := &Repos{
+		cms: util.NewSyncMap[string, *CMS](),
+	}
+	r.Repos = plateauapi.NewRepos(r.update)
+	return r
+}
+
+func (r *Repos) Prepare(ctx context.Context, project string, year int, cms cms.Interface) error {
+	if _, ok := r.cms.Load(project); ok {
+		return nil
+	}
+
+	r.setCMS(project, year, cms)
+	_, err := r.Update(ctx, project)
+	return err
+}
+
+func (r *Repos) update(ctx context.Context, project string) (*plateauapi.ReposUpdateResult, error) {
+	cms, ok := r.cms.Load(project)
+	if !ok {
+		return nil, fmt.Errorf("cms is not initialized for %s", project)
+	}
+
+	updated := r.UpdatedAt(project)
+	var updatedStr string
+	if !updated.IsZero() {
+		updatedStr = updated.Format(time.RFC3339)
+	}
+	log.Infofc(ctx, "datacatalogv3: updating repo %s: last_update=%s", project, updatedStr)
+
+	data, err := cms.GetAll(ctx, project)
+	if err != nil {
+		return nil, err
+	}
+
+	c, warning := data.Into()
+	sort.Strings(warning)
+
+	repo := plateauapi.NewInMemoryRepo(c)
+
+	adminRepo := plateauapi.NewInMemoryRepo(c)
+	adminRepo.SetAdmin(true)
+	adminRepo.SetIncludedStages(stagesForAdmin...)
+
+	return &plateauapi.ReposUpdateResult{
+		Repo:      repo,
+		AdminRepo: adminRepo,
+		Warnings:  warning,
+	}, nil
+}
+
+func (r *Repos) setCMS(project string, year int, cms cms.Interface) {
+	c := NewCMS(cms, year)
+	r.cms.Store(project, c)
+}