Function runExtraction

pkg/unpackerr/folder_recursion_test.go:79–122

(t *testing.T, archivePath string, disableRecursion bool)

}

func runExtraction(t *testing.T, archivePath string, disableRecursion bool) *xtractr.Response {
	t.Helper()

	cfg := &FolderConfig{DisableRecursion: disableRecursion, ExtractISOs: false}
	exclude := folderExcludeSuffixes(archivePath, cfg)

	queue := xtractr.NewQueue(&xtractr.Config{
		Parallel: 1,
		Suffix:   suffix,
		FileMode: defaultFileMode,
		DirMode:  defaultDirMode,
	})

	t.Cleanup(func() { queue.Stop() })

	callbacks := make(chan *xtractr.Response, updateChanBuf)

	_, err := queue.Extract(&xtractr.Xtract{
		Name:             archivePath,
		Filter:           xtractr.Filter{Path: archivePath, ExcludeSuffix: exclude},
		TempFolder:       true,
		DeleteOrig:       false,
		CBChannel:        callbacks,
		DisableRecursion: disableRecursion,
		LogFile:          false,
	})
	if err != nil {
		t.Fatalf("queue.Extract returned error: %v", err)
	}

	timeout := time.NewTimer(90 * time.Second)
	defer timeout.Stop()

	for {
		select {
		case resp := <-callbacks:
			if resp.Done {
				return resp
			}
		case <-timeout.C:
			t.Fatal("timed out waiting for folder extraction callback")
		}
	}
}

func makeNestedZipFixture(t *testing.T) string {
	t.Helper()