Method Delete

service/admin/file.go:368–395

(c *gin.Context)

)

func (s *BatchFileService) Delete(c *gin.Context) error {
	dep := dependency.FromContext(c)
	fileClient := dep.FileClient()

	ctx := context.WithValue(c, inventory.LoadFileEntity{}, true)
	files, _, err := fileClient.GetByIDs(ctx, s.IDs, 0)
	if err != nil {
		return serializer.NewError(serializer.CodeDBError, "Failed to get files", err)
	}

	fc, tx, ctx, err := inventory.WithTx(c, fileClient)
	if err != nil {
		return serializer.NewError(serializer.CodeDBError, "Failed to start transaction", err)
	}

	_, diff, err := fc.Delete(ctx, files, nil)
	if err != nil {
		_ = inventory.Rollback(tx)
		return serializer.NewError(serializer.CodeDBError, "Failed to delete files", err)
	}

	tx.AppendStorageDiff(diff)
	if err := inventory.CommitWithStorageDiff(ctx, tx, dep.Logger(), dep.UserClient()); err != nil {
		return serializer.NewError(serializer.CodeDBError, "Failed to commit transaction", err)
	}

	return nil
}

const (
	entityUserCondition   = "entity_user"