mirror of
https://github.com/hanzoai/forge.git
synced 2026-10-30 15:00:39 +00:00
zeekayandHanzo Dev
aa87442fdd
Source files keep their SPDX-License-Identifier and Hanzo copyright line; the Gitea, Gogs and LFS Test Server copyrights they used to repeat now live once in NOTICE, alongside LICENSE. The header lint accepts any copyright line above the SPDX line, so it no longer demands an upstream one. Co-authored-by: Hanzo Dev <[email protected]>
92 lines
2.1 KiB
Go
92 lines
2.1 KiB
Go
// Copyright 2026 Hanzo AI, Inc. All rights reserved.
|
|
// SPDX-License-Identifier: MIT
|
|
|
|
package v1_15
|
|
|
|
import (
|
|
"strings"
|
|
|
|
"github.com/hanzoai/git/models/db"
|
|
)
|
|
|
|
func AddPrimaryEmail2EmailAddress(x db.EngineMigration) error {
|
|
type User struct {
|
|
ID int64 `xorm:"pk autoincr"`
|
|
Email string `xorm:"NOT NULL"`
|
|
IsActive bool `xorm:"INDEX"` // Activate primary email
|
|
}
|
|
|
|
type EmailAddress1 struct {
|
|
ID int64 `xorm:"pk autoincr"`
|
|
UID int64 `xorm:"INDEX NOT NULL"`
|
|
Email string `xorm:"UNIQUE NOT NULL"`
|
|
LowerEmail string
|
|
IsActivated bool
|
|
IsPrimary bool `xorm:"DEFAULT(false) NOT NULL"`
|
|
}
|
|
|
|
// Add lower_email and is_primary columns
|
|
if err := x.Table("email_address").Sync(new(EmailAddress1)); err != nil {
|
|
return err
|
|
}
|
|
|
|
if _, err := x.Exec("UPDATE email_address SET lower_email=LOWER(email), is_primary=?", false); err != nil {
|
|
return err
|
|
}
|
|
|
|
type EmailAddress struct {
|
|
ID int64 `xorm:"pk autoincr"`
|
|
UID int64 `xorm:"INDEX NOT NULL"`
|
|
Email string `xorm:"UNIQUE NOT NULL"`
|
|
LowerEmail string `xorm:"UNIQUE NOT NULL"`
|
|
IsActivated bool
|
|
IsPrimary bool `xorm:"DEFAULT(false) NOT NULL"`
|
|
}
|
|
|
|
// change lower_email as unique
|
|
if err := x.Sync(new(EmailAddress)); err != nil {
|
|
return err
|
|
}
|
|
|
|
sess := x.NewSession()
|
|
defer sess.Close()
|
|
|
|
const batchSize = 100
|
|
|
|
for start := 0; ; start += batchSize {
|
|
users := make([]*User, 0, batchSize)
|
|
if err := sess.Limit(batchSize, start).Find(&users); err != nil {
|
|
return err
|
|
}
|
|
if len(users) == 0 {
|
|
break
|
|
}
|
|
|
|
for _, user := range users {
|
|
exist, err := sess.Where("email=?", user.Email).Table("email_address").Exist()
|
|
if err != nil {
|
|
return err
|
|
}
|
|
if !exist {
|
|
if _, err := sess.Insert(&EmailAddress{
|
|
UID: user.ID,
|
|
Email: user.Email,
|
|
LowerEmail: strings.ToLower(user.Email),
|
|
IsActivated: user.IsActive,
|
|
IsPrimary: true,
|
|
}); err != nil {
|
|
return err
|
|
}
|
|
} else {
|
|
if _, err := sess.Where("email=?", user.Email).Cols("is_primary").Update(&EmailAddress{
|
|
IsPrimary: true,
|
|
}); err != nil {
|
|
return err
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
return nil
|
|
}
|