anyproto/anytype-heart
1
0
Fork 0
mirror of https://github.com/anyproto/anytype-heart.git synced 2025-06-09 17:44:59 +09:00
Code Activity

GO-4810: add noProgress param in export request to avoid progress and notifications events

Browse source 
Signed-off-by: AnastasiaShemyakinskaya <shem98a@mail.ru>
This commit is contained in:
AnastasiaShemyakinskaya 2025-01-08 22:09:14 +01:00
parent 332c1d3715
commit 5bbb3a28fb
No known key found for this signature in database
GPG key ID: CCD60ED83B103281
11 changed files with 1374 additions and 1189 deletions
Download patch file Download diff file Expand all files Collapse all files

10
util/builtinobjects/builtinobjects.go
View file

@ -180,7 +180,9 @@ func (b *builtinObjects) CreateObjectsForExperience(ctx context.Context, spaceID
if pErr := progress.Cancel(); pErr != nil {
log.Errorf("failed to cancel progress %s: %v", progress.Id(), pErr)
}
progress.FinishWithNotification(b.provideNotification(spaceID, progress, err, title), err)
if notificationProgress, ok := progress.(process.Notificationable); ok {
notificationProgress.FinishWithNotification(b.provideNotification(spaceID, progress, err, title), err)
}
if errors.Is(err, uri.ErrFilepathNotSupported) {
return fmt.Errorf("invalid path to file: '%s'", url)
}
@ -194,7 +196,9 @@ func (b *builtinObjects) CreateObjectsForExperience(ctx context.Context, spaceID
}
importErr := b.importArchive(ctx, spaceID, path, title, pb.RpcObjectImportRequestPbParams_EXPERIENCE, progress, isNewSpace)
progress.FinishWithNotification(b.provideNotification(spaceID, progress, importErr, title), importErr)
if notificationProgress, ok := progress.(process.Notificationable); ok {
notificationProgress.FinishWithNotification(b.provideNotification(spaceID, progress, importErr, title), importErr)
}
if importErr != nil {
log.Errorf("failed to send notification: %v", importErr)
@ -493,7 +497,7 @@ func (b *builtinObjects) downloadZipToFile(url string, progress process.Progress
return path, nil
}
func (b *builtinObjects) setupProgress() (process.Notificationable, error) {
func (b *builtinObjects) setupProgress() (process.Progress, error) {
progress := process.NewNotificationProcess(&pb.ModelProcessMessageOfImport{Import: &pb.ModelProcessImport{}}, b.notifications)
if err := b.progress.Add(progress); err != nil {
return nil, fmt.Errorf("failed to add progress bar: %w", err)