Offline support – Alpha (#196)

* Textile background sync and queue logic

* Add file pinning to textile synchronization

* Format

* Update mocks

* Remove unused code

* Task queue optimizations and reduce amount of logs

* Fix max parallel tasks

* Add queue dedupe in task queue

* Add task queue tests

* Fix race condition

core/space/services/services_fs.go

@@ -103,23 +103,11 @@ func (s *Space) ToggleBucketBackup(ctx context.Context, bucketName string, bucke
 		return err
 	}
 
-	b, err := s.tc.GetBucket(ctx, bucketName, nil)
+	_, err = s.tc.GetBucket(ctx, bucketName, nil)
 	if err != nil {
 		return err
 	}
 
-	if bucketBackup == true {
-		_, err = s.tc.BackupBucket(ctx, b)
-		if err != nil {
-			return err
-		}
-	} else {
-		_, err = s.tc.UnbackupBucket(ctx, b)
-		if err != nil {
-			return err
-		}
-	}
-
 	return nil
 }
 
@@ -663,15 +651,6 @@ func (s *Space) addFile(ctx context.Context, sourcePath string, targetPath strin
 		return domain.AddItemResult{}, err
 	}
 
-	if s.tc.IsBucketBackup(ctx, b.Slug()) && !s.tc.IsMirrorFile(ctx, targetPathBucket, b.Slug()) {
-		f.Seek(0, io.SeekStart)
-
-		err = s.tc.BackupFileWithReader(ctx, b, targetPathBucket, f)
-		if err != nil {
-			return domain.AddItemResult{}, err
-		}
-	}
-
 	fi, err := f.Stat()
 	var fileSize int64 = 0
 	if err == nil {

core/space/space_test.go

@@ -394,11 +394,6 @@ func TestService_AddItems_FilesOnly(t *testing.T) {
 		"Slug",
 	).Return("personal")
 
-	textileClient.On(
-		"IsBucketBackup",
-		mock.Anything, mock.Anything,
-	).Return(false)
-
 	mockPath.On("String").Return("hash")
 
 	for _, f := range testSourcePaths {
@@ -475,11 +470,6 @@ func TestService_AddItems_Folder(t *testing.T) {
 		"Slug",
 	).Return("personal")
 
-	textileClient.On(
-		"IsBucketBackup",
-		mock.Anything, mock.Anything,
-	).Return(false)
-
 	ch, res, err := sv.AddItems(context.Background(), testSourcePaths, bucketPath, "")
 
 	assert.Nil(t, err)