submissions: temporary migration endpoint

pkg/service/maps.go

@@ -2,10 +2,11 @@ package service
 
 import (
 	"context"
+	"time"
 
 	"git.itzana.me/strafesnet/go-grpc/maps"
-	"git.itzana.me/strafesnet/maps-service/pkg/model"
 	"git.itzana.me/strafesnet/maps-service/pkg/datastore"
+	"git.itzana.me/strafesnet/maps-service/pkg/model"
 )
 
 // Optional map used to update an object
@@ -80,6 +81,35 @@ func (update MapFilter) SetSubmitter(submitter uint64) {
 	datastore.OptionalMap(update).Add("submitter", submitter)
 }
 
+func (svc *Service) TEMP_DoMapsMigration(ctx context.Context) (error) {
+	// get all maps
+	maps, err := svc.maps.List(ctx, &maps.ListRequest{})
+	if err != nil {
+		return err
+	}
+	// create all maps
+	for _, item := range maps.Maps {
+		migrated := model.Map{
+			ID:           item.ID,
+			DisplayName:  item.DisplayName,
+			Creator:      item.Creator,
+			GameID:       item.GameID,
+			Date:         time.Unix(item.Date, 0),
+			// CreatedAt:    time.Time{},
+			// UpdatedAt:    time.Time{},
+			// Submitter:    0,
+			// Thumbnail:    0,
+			// AssetVersion: 0,
+			// LoadCount:    0,
+			// Modes:        0,
+		}
+		_, err := svc.db.Maps().Create(ctx, migrated)
+		if err != nil {
+			return err
+		}
+	}
+	return nil
+}
 func (svc *Service) CreateMap(ctx context.Context, item model.Map) (int64, error) {
 	// 2 jobs:
 	// create map on maps-service

pkg/web_api/maps.go

@@ -9,6 +9,29 @@ import (
 	"git.itzana.me/strafesnet/maps-service/pkg/service"
 )
 
+// MigrateMaps implements migrateMaps operation.
+//
+// Perform maps migration.
+//
+// POST /migrate
+func (svc *Service) MigrateMaps(ctx context.Context) (error) {
+	userInfo, ok := ctx.Value("UserInfo").(UserInfoHandle)
+	if !ok {
+		return ErrUserInfo
+	}
+
+	has_role, err := userInfo.HasRoleSubmissionRelease()
+	if err != nil {
+		return err
+	}
+
+	if !has_role {
+		return ErrPermissionDeniedNeedRoleSubmissionRelease
+	}
+
+	return svc.inner.TEMP_DoMapsMigration(ctx)
+}
+
 // ListMaps implements listMaps operation.
 //
 // Get list of maps.