mstar/linstrom
1
0
Fork 0
Code Issues 27 Pull requests Projects Releases Packages 1 Wiki Activity Actions

More activity stuff
Some checks failed
/ docker (push) Failing after 2m51s
Details

Browse source
This commit is contained in:
Melody Becker 2025-05-05 17:33:34 +02:00
parent 12c9e17c4b
commit dff031397e
14 changed files with 710 additions and 253 deletions
Download patch file Download diff file Expand all files Collapse all files

68
storage-new/dbgen/activitystreams_activities.gen.go
View file

@ -23,7 +23,7 @@ func newActivitystreamsActivity(db *gorm.DB, opts ...gen.DOOption) activitystrea
_activitystreamsActivity := activitystreamsActivity{}
_activitystreamsActivity.activitystreamsActivityDo.UseDB(db, opts...)
_activitystreamsActivity.activitystreamsActivityDo.UseModel(&models.ActivitystreamsActivity{})
_activitystreamsActivity.activitystreamsActivityDo.UseModel(&models.Activity{})
tableName := _activitystreamsActivity.activitystreamsActivityDo.TableName()
_activitystreamsActivity.ALL = field.NewAsterisk(tableName)
@ -129,17 +129,17 @@ type IActivitystreamsActivityDo interface {
Count() (count int64, err error)
Scopes(funcs ...func(gen.Dao) gen.Dao) IActivitystreamsActivityDo
Unscoped() IActivitystreamsActivityDo
Create(values ...*models.ActivitystreamsActivity) error
CreateInBatches(values []*models.ActivitystreamsActivity, batchSize int) error
Save(values ...*models.ActivitystreamsActivity) error
First() (*models.ActivitystreamsActivity, error)
Take() (*models.ActivitystreamsActivity, error)
Last() (*models.ActivitystreamsActivity, error)
Find() ([]*models.ActivitystreamsActivity, error)
FindInBatch(batchSize int, fc func(tx gen.Dao, batch int) error) (results []*models.ActivitystreamsActivity, err error)
FindInBatches(result *[]*models.ActivitystreamsActivity, batchSize int, fc func(tx gen.Dao, batch int) error) error
Create(values ...*models.Activity) error
CreateInBatches(values []*models.Activity, batchSize int) error
Save(values ...*models.Activity) error
First() (*models.Activity, error)
Take() (*models.Activity, error)
Last() (*models.Activity, error)
Find() ([]*models.Activity, error)
FindInBatch(batchSize int, fc func(tx gen.Dao, batch int) error) (results []*models.Activity, err error)
FindInBatches(result *[]*models.Activity, batchSize int, fc func(tx gen.Dao, batch int) error) error
Pluck(column field.Expr, dest interface{}) error
Delete(...*models.ActivitystreamsActivity) (info gen.ResultInfo, err error)
Delete(...*models.Activity) (info gen.ResultInfo, err error)
Update(column field.Expr, value interface{}) (info gen.ResultInfo, err error)
UpdateSimple(columns ...field.AssignExpr) (info gen.ResultInfo, err error)
Updates(value interface{}) (info gen.ResultInfo, err error)
@ -151,9 +151,9 @@ type IActivitystreamsActivityDo interface {
Assign(attrs ...field.AssignExpr) IActivitystreamsActivityDo
Joins(fields ...field.RelationField) IActivitystreamsActivityDo
Preload(fields ...field.RelationField) IActivitystreamsActivityDo
FirstOrInit() (*models.ActivitystreamsActivity, error)
FirstOrCreate() (*models.ActivitystreamsActivity, error)
FindByPage(offset int, limit int) (result []*models.ActivitystreamsActivity, count int64, err error)
FirstOrInit() (*models.Activity, error)
FirstOrCreate() (*models.Activity, error)
FindByPage(offset int, limit int) (result []*models.Activity, count int64, err error)
ScanByPage(result interface{}, offset int, limit int) (count int64, err error)
Rows() (*sql.Rows, error)
Row() *sql.Row
@ -255,57 +255,57 @@ func (a activitystreamsActivityDo) Unscoped() IActivitystreamsActivityDo {
return a.withDO(a.DO.Unscoped())
}
func (a activitystreamsActivityDo) Create(values ...*models.ActivitystreamsActivity) error {
func (a activitystreamsActivityDo) Create(values ...*models.Activity) error {
if len(values) == 0 {
return nil
}
return a.DO.Create(values)
}
func (a activitystreamsActivityDo) CreateInBatches(values []*models.ActivitystreamsActivity, batchSize int) error {
func (a activitystreamsActivityDo) CreateInBatches(values []*models.Activity, batchSize int) error {
return a.DO.CreateInBatches(values, batchSize)
}
// Save : !!! underlying implementation is different with GORM
// The method is equivalent to executing the statement: db.Clauses(clause.OnConflict{UpdateAll: true}).Create(values)
func (a activitystreamsActivityDo) Save(values ...*models.ActivitystreamsActivity) error {
func (a activitystreamsActivityDo) Save(values ...*models.Activity) error {
if len(values) == 0 {
return nil
}
return a.DO.Save(values)
}
func (a activitystreamsActivityDo) First() (*models.ActivitystreamsActivity, error) {
func (a activitystreamsActivityDo) First() (*models.Activity, error) {
if result, err := a.DO.First(); err != nil {
return nil, err
} else {
return result.(*models.ActivitystreamsActivity), nil
return result.(*models.Activity), nil
}
}
func (a activitystreamsActivityDo) Take() (*models.ActivitystreamsActivity, error) {
func (a activitystreamsActivityDo) Take() (*models.Activity, error) {
if result, err := a.DO.Take(); err != nil {
return nil, err
} else {
return result.(*models.ActivitystreamsActivity), nil
return result.(*models.Activity), nil
}
}
func (a activitystreamsActivityDo) Last() (*models.ActivitystreamsActivity, error) {
func (a activitystreamsActivityDo) Last() (*models.Activity, error) {
if result, err := a.DO.Last(); err != nil {
return nil, err
} else {
return result.(*models.ActivitystreamsActivity), nil
return result.(*models.Activity), nil
}
}
func (a activitystreamsActivityDo) Find() ([]*models.ActivitystreamsActivity, error) {
func (a activitystreamsActivityDo) Find() ([]*models.Activity, error) {
result, err := a.DO.Find()
return result.([]*models.ActivitystreamsActivity), err
return result.([]*models.Activity), err
}
func (a activitystreamsActivityDo) FindInBatch(batchSize int, fc func(tx gen.Dao, batch int) error) (results []*models.ActivitystreamsActivity, err error) {
buf := make([]*models.ActivitystreamsActivity, 0, batchSize)
func (a activitystreamsActivityDo) FindInBatch(batchSize int, fc func(tx gen.Dao, batch int) error) (results []*models.Activity, err error) {
buf := make([]*models.Activity, 0, batchSize)
err = a.DO.FindInBatches(&buf, batchSize, func(tx gen.Dao, batch int) error {
defer func() { results = append(results, buf...) }()
return fc(tx, batch)
@ -313,7 +313,7 @@ func (a activitystreamsActivityDo) FindInBatch(batchSize int, fc func(tx gen.Dao
return results, err
}
func (a activitystreamsActivityDo) FindInBatches(result *[]*models.ActivitystreamsActivity, batchSize int, fc func(tx gen.Dao, batch int) error) error {
func (a activitystreamsActivityDo) FindInBatches(result *[]*models.Activity, batchSize int, fc func(tx gen.Dao, batch int) error) error {
return a.DO.FindInBatches(result, batchSize, fc)
}
@ -339,23 +339,23 @@ func (a activitystreamsActivityDo) Preload(fields ...field.RelationField) IActiv
return &a
}
func (a activitystreamsActivityDo) FirstOrInit() (*models.ActivitystreamsActivity, error) {
func (a activitystreamsActivityDo) FirstOrInit() (*models.Activity, error) {
if result, err := a.DO.FirstOrInit(); err != nil {
return nil, err
} else {
return result.(*models.ActivitystreamsActivity), nil
return result.(*models.Activity), nil
}
}
func (a activitystreamsActivityDo) FirstOrCreate() (*models.ActivitystreamsActivity, error) {
func (a activitystreamsActivityDo) FirstOrCreate() (*models.Activity, error) {
if result, err := a.DO.FirstOrCreate(); err != nil {
return nil, err
} else {
return result.(*models.ActivitystreamsActivity), nil
return result.(*models.Activity), nil
}
}
func (a activitystreamsActivityDo) FindByPage(offset int, limit int) (result []*models.ActivitystreamsActivity, count int64, err error) {
func (a activitystreamsActivityDo) FindByPage(offset int, limit int) (result []*models.Activity, count int64, err error) {
result, err = a.Offset(offset).Limit(limit).Find()
if err != nil {
return
@ -384,7 +384,7 @@ func (a activitystreamsActivityDo) Scan(result interface{}) (err error) {
return a.DO.Scan(result)
}
func (a activitystreamsActivityDo) Delete(models ...*models.ActivitystreamsActivity) (result gen.ResultInfo, err error) {
func (a activitystreamsActivityDo) Delete(models ...*models.Activity) (result gen.ResultInfo, err error) {
return a.DO.Delete(models)
}