refactor: use a dynamic model registration process so we can use build tags to exclude/include
This commit is contained in:
parent
4fe856fd03
commit
bb167ea360
20
db/db.go
20
db/db.go
|
@ -4,13 +4,14 @@ import (
|
||||||
"context"
|
"context"
|
||||||
"fmt"
|
"fmt"
|
||||||
|
|
||||||
|
"git.lumeweb.com/LumeWeb/portal/db/models"
|
||||||
|
|
||||||
"github.com/redis/go-redis/v9"
|
"github.com/redis/go-redis/v9"
|
||||||
|
|
||||||
"go.uber.org/zap"
|
"go.uber.org/zap"
|
||||||
|
|
||||||
"git.lumeweb.com/LumeWeb/portal/config"
|
"git.lumeweb.com/LumeWeb/portal/config"
|
||||||
|
|
||||||
"git.lumeweb.com/LumeWeb/portal/db/models"
|
|
||||||
"github.com/go-gorm/caches/v4"
|
"github.com/go-gorm/caches/v4"
|
||||||
"go.uber.org/fx"
|
"go.uber.org/fx"
|
||||||
"gorm.io/driver/mysql"
|
"gorm.io/driver/mysql"
|
||||||
|
@ -60,22 +61,7 @@ func NewDatabase(lc fx.Lifecycle, params DatabaseParams) *gorm.DB {
|
||||||
|
|
||||||
lc.Append(fx.Hook{
|
lc.Append(fx.Hook{
|
||||||
OnStart: func(ctx context.Context) error {
|
OnStart: func(ctx context.Context) error {
|
||||||
return db.AutoMigrate(
|
return db.AutoMigrate(models.GetModels()...)
|
||||||
&models.APIKey{},
|
|
||||||
&models.Blocklist{},
|
|
||||||
&models.DNSLink{},
|
|
||||||
&models.Download{},
|
|
||||||
&models.EmailVerification{},
|
|
||||||
&models.PasswordReset{},
|
|
||||||
&models.Pin{},
|
|
||||||
&models.PublicKey{},
|
|
||||||
&models.Upload{},
|
|
||||||
&models.User{},
|
|
||||||
&models.S3Upload{},
|
|
||||||
&models.S5Challenge{},
|
|
||||||
&models.TusLock{},
|
|
||||||
&models.TusUpload{},
|
|
||||||
)
|
|
||||||
},
|
},
|
||||||
})
|
})
|
||||||
|
|
||||||
|
|
|
@ -2,6 +2,10 @@ package models
|
||||||
|
|
||||||
import "gorm.io/gorm"
|
import "gorm.io/gorm"
|
||||||
|
|
||||||
|
func init() {
|
||||||
|
registerModel(&APIKey{})
|
||||||
|
}
|
||||||
|
|
||||||
type APIKey struct {
|
type APIKey struct {
|
||||||
gorm.Model
|
gorm.Model
|
||||||
UserID uint
|
UserID uint
|
||||||
|
|
|
@ -1,10 +1,15 @@
|
||||||
package models
|
package models
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"gorm.io/gorm"
|
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
|
"gorm.io/gorm"
|
||||||
)
|
)
|
||||||
|
|
||||||
|
func init() {
|
||||||
|
registerModel(&Blocklist{})
|
||||||
|
}
|
||||||
|
|
||||||
type Blocklist struct {
|
type Blocklist struct {
|
||||||
gorm.Model
|
gorm.Model
|
||||||
IP string
|
IP string
|
||||||
|
|
|
@ -2,6 +2,10 @@ package models
|
||||||
|
|
||||||
import "gorm.io/gorm"
|
import "gorm.io/gorm"
|
||||||
|
|
||||||
|
func init() {
|
||||||
|
registerModel(&DNSLink{})
|
||||||
|
}
|
||||||
|
|
||||||
type DNSLink struct {
|
type DNSLink struct {
|
||||||
gorm.Model
|
gorm.Model
|
||||||
UserID uint `gorm:"uniqueIndex:idx_user_id_upload"`
|
UserID uint `gorm:"uniqueIndex:idx_user_id_upload"`
|
||||||
|
|
|
@ -1,10 +1,15 @@
|
||||||
package models
|
package models
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"gorm.io/gorm"
|
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
|
"gorm.io/gorm"
|
||||||
)
|
)
|
||||||
|
|
||||||
|
func init() {
|
||||||
|
registerModel(&Download{})
|
||||||
|
}
|
||||||
|
|
||||||
type Download struct {
|
type Download struct {
|
||||||
gorm.Model
|
gorm.Model
|
||||||
UserID uint
|
UserID uint
|
||||||
|
|
|
@ -6,6 +6,10 @@ import (
|
||||||
"gorm.io/gorm"
|
"gorm.io/gorm"
|
||||||
)
|
)
|
||||||
|
|
||||||
|
func init() {
|
||||||
|
registerModel(&EmailVerification{})
|
||||||
|
}
|
||||||
|
|
||||||
type EmailVerification struct {
|
type EmailVerification struct {
|
||||||
gorm.Model
|
gorm.Model
|
||||||
|
|
||||||
|
|
|
@ -0,0 +1,11 @@
|
||||||
|
package models
|
||||||
|
|
||||||
|
var registered []interface{}
|
||||||
|
|
||||||
|
func registerModel(model interface{}) {
|
||||||
|
registered = append(registered, model)
|
||||||
|
}
|
||||||
|
|
||||||
|
func GetModels() []interface{} {
|
||||||
|
return registered
|
||||||
|
}
|
|
@ -6,6 +6,10 @@ import (
|
||||||
"gorm.io/gorm"
|
"gorm.io/gorm"
|
||||||
)
|
)
|
||||||
|
|
||||||
|
func init() {
|
||||||
|
registerModel(&PasswordReset{})
|
||||||
|
}
|
||||||
|
|
||||||
type PasswordReset struct {
|
type PasswordReset struct {
|
||||||
gorm.Model
|
gorm.Model
|
||||||
|
|
||||||
|
|
|
@ -2,6 +2,10 @@ package models
|
||||||
|
|
||||||
import "gorm.io/gorm"
|
import "gorm.io/gorm"
|
||||||
|
|
||||||
|
func init() {
|
||||||
|
registerModel(&Pin{})
|
||||||
|
}
|
||||||
|
|
||||||
type Pin struct {
|
type Pin struct {
|
||||||
gorm.Model
|
gorm.Model
|
||||||
UploadID uint
|
UploadID uint
|
||||||
|
|
|
@ -2,6 +2,10 @@ package models
|
||||||
|
|
||||||
import "gorm.io/gorm"
|
import "gorm.io/gorm"
|
||||||
|
|
||||||
|
func init() {
|
||||||
|
registerModel(&PublicKey{})
|
||||||
|
}
|
||||||
|
|
||||||
type PublicKey struct {
|
type PublicKey struct {
|
||||||
gorm.Model
|
gorm.Model
|
||||||
UserID uint
|
UserID uint
|
||||||
|
|
|
@ -2,6 +2,10 @@ package models
|
||||||
|
|
||||||
import "gorm.io/gorm"
|
import "gorm.io/gorm"
|
||||||
|
|
||||||
|
func init() {
|
||||||
|
registerModel(&S3Upload{})
|
||||||
|
}
|
||||||
|
|
||||||
type S3Upload struct {
|
type S3Upload struct {
|
||||||
gorm.Model
|
gorm.Model
|
||||||
UploadID string `gorm:"unique;not null"`
|
UploadID string `gorm:"unique;not null"`
|
||||||
|
|
|
@ -2,6 +2,11 @@ package models
|
||||||
|
|
||||||
import "gorm.io/gorm"
|
import "gorm.io/gorm"
|
||||||
|
|
||||||
|
func init() {
|
||||||
|
registerModel(&S5Challenge{})
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
type S5Challenge struct {
|
type S5Challenge struct {
|
||||||
gorm.Model
|
gorm.Model
|
||||||
Challenge string
|
Challenge string
|
||||||
|
|
|
@ -3,11 +3,17 @@ package models
|
||||||
import (
|
import (
|
||||||
"context"
|
"context"
|
||||||
"errors"
|
"errors"
|
||||||
|
"time"
|
||||||
|
|
||||||
"gorm.io/gorm"
|
"gorm.io/gorm"
|
||||||
"gorm.io/gorm/clause"
|
"gorm.io/gorm/clause"
|
||||||
"time"
|
|
||||||
)
|
)
|
||||||
|
|
||||||
|
func init() {
|
||||||
|
registerModel(&TusLock{})
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
var (
|
var (
|
||||||
ErrTusLockBusy = errors.New("lock is currently held by another process")
|
ErrTusLockBusy = errors.New("lock is currently held by another process")
|
||||||
)
|
)
|
||||||
|
|
|
@ -2,6 +2,11 @@ package models
|
||||||
|
|
||||||
import "gorm.io/gorm"
|
import "gorm.io/gorm"
|
||||||
|
|
||||||
|
func init() {
|
||||||
|
registerModel(&TusUpload{})
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
type TusUpload struct {
|
type TusUpload struct {
|
||||||
gorm.Model
|
gorm.Model
|
||||||
Hash []byte `gorm:"type:binary(32);uniqueIndex:idx_hash_deleted"`
|
Hash []byte `gorm:"type:binary(32);uniqueIndex:idx_hash_deleted"`
|
||||||
|
|
|
@ -2,6 +2,10 @@ package models
|
||||||
|
|
||||||
import "gorm.io/gorm"
|
import "gorm.io/gorm"
|
||||||
|
|
||||||
|
func init() {
|
||||||
|
registerModel(&Upload{})
|
||||||
|
}
|
||||||
|
|
||||||
type Upload struct {
|
type Upload struct {
|
||||||
gorm.Model
|
gorm.Model
|
||||||
UserID uint
|
UserID uint
|
||||||
|
|
|
@ -8,6 +8,10 @@ import (
|
||||||
"gorm.io/gorm"
|
"gorm.io/gorm"
|
||||||
)
|
)
|
||||||
|
|
||||||
|
func init() {
|
||||||
|
registerModel(&User{})
|
||||||
|
}
|
||||||
|
|
||||||
type User struct {
|
type User struct {
|
||||||
gorm.Model
|
gorm.Model
|
||||||
FirstName string
|
FirstName string
|
||||||
|
|
Loading…
Reference in New Issue