Feat: add release image workflows
Fix: - transaction didn't do shit because of my shit code
This commit is contained in:
@@ -61,7 +61,7 @@ func (self *BunDatabase) UpdateRefreshToken(
|
||||
}
|
||||
|
||||
err := self.db.RunInTx(ctx, nil, func(ctx context.Context, tx bun.Tx) error {
|
||||
err := self.db.NewSelect().
|
||||
err := tx.NewSelect().
|
||||
Model(&ret).
|
||||
WherePK().
|
||||
Scan(ctx)
|
||||
@@ -76,7 +76,7 @@ func (self *BunDatabase) UpdateRefreshToken(
|
||||
return err
|
||||
}
|
||||
|
||||
_, err = self.db.NewUpdate().
|
||||
_, err = tx.NewUpdate().
|
||||
Model((*models.Session)(nil)).
|
||||
Set("refresh_token = ?", ret.RefreshToken).
|
||||
Where("user_id = ?", userId).
|
||||
@@ -176,7 +176,7 @@ func (self *BunDatabase) UpdateAliases(
|
||||
Name: ali,
|
||||
})
|
||||
}
|
||||
_, err := self.db.NewInsert().
|
||||
_, err := tx.NewInsert().
|
||||
Model(&aliases).
|
||||
On("CONFLICT (name) DO NOTHING").
|
||||
Exec(ctx)
|
||||
@@ -191,7 +191,7 @@ func (self *BunDatabase) UpdateAliases(
|
||||
ImageId: imageId,
|
||||
})
|
||||
}
|
||||
_, err = self.db.NewInsert().
|
||||
_, err = tx.NewInsert().
|
||||
Model(&rels).
|
||||
On(`CONFLICT ("alias_id", "image_id") DO NOTHING`).
|
||||
Exec(ctx)
|
||||
@@ -218,14 +218,14 @@ func (self *BunDatabase) DeleteImage(
|
||||
imageId int64,
|
||||
) error {
|
||||
return self.db.RunInTx(ctx, nil, func(ctx context.Context, tx bun.Tx) error {
|
||||
_, err := self.db.NewDelete().
|
||||
_, err := tx.NewDelete().
|
||||
Model((*models.Image)(nil)).
|
||||
Where("id = ?", imageId).
|
||||
Exec(ctx)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
_, err = self.db.NewDelete().
|
||||
_, err = tx.NewDelete().
|
||||
Model((*models.AliasImage)(nil)).
|
||||
Where("image_id = ?", imageId).
|
||||
Exec(ctx)
|
||||
@@ -241,14 +241,14 @@ func (self *BunDatabase) DeleteAlias(
|
||||
aliasId int64,
|
||||
) error {
|
||||
return self.db.RunInTx(ctx, nil, func(ctx context.Context, tx bun.Tx) error {
|
||||
_, err := self.db.NewDelete().
|
||||
_, err := tx.NewDelete().
|
||||
Model((*models.Alias)(nil)).
|
||||
Where("id = ?", aliasId).
|
||||
Exec(ctx)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
_, err = self.db.NewDelete().
|
||||
_, err = tx.NewDelete().
|
||||
Model((*models.AliasImage)(nil)).
|
||||
Where("alias_id = ?", aliasId).
|
||||
Exec(ctx)
|
||||
|
||||
Reference in New Issue
Block a user