feat(FileStore): CreateTemp accepts pattern used for file name

filestore/filestore.go

@@ -65,8 +65,13 @@ func (fs fileStore) Delete(p Path) error {
 	return os.Remove(full)
 }
 
-func (fs fileStore) CreateTemp() (File, error) {
-	f, err := ioutil.TempFile(fs.base, "fstmp")
+func (fs fileStore) CreateTemp(pattern string) (File, error) {
+	if pattern == "" {
+		pattern = "fstmp"
+	} else {
+		pattern = fmt.Sprintf("fstmp_%s", pattern)
+	}
+	f, err := ioutil.TempFile(fs.base, pattern)
 	if err != nil {
 		return nil, err
 	}

filestore/filestore_test.go

@@ -133,8 +133,9 @@ func Test_CreateFile(t *testing.T) {
 func Test_CreateTempFile(t *testing.T) {
 	store, err := NewLocalFileStore(baseDir)
 	require.NoError(t, err)
-	file, err := store.CreateTemp()
+	file, err := store.CreateTemp("pattern")
 	require.NoError(t, err)
+	require.Contains(t, file.Path(), "fstmp_pattern")
 	defer func() {
 		err := store.Delete(file.Path())
 		require.NoError(t, err)

filestore/types.go

@@ -32,5 +32,5 @@ type FileStore interface {
 	Store(p Path, f File) (Path, error)
 	Delete(p Path) error
 
-	CreateTemp() (File, error)
+	CreateTemp(pattern string) (File, error)
 }

shared_testutil/test_filestore.go

@@ -98,7 +98,7 @@ func (fs *TestFileStore) Delete(p filestore.Path) error {
 }
 
 // CreateTemp will create a temporary file from the provided set of temporary files
-func (fs *TestFileStore) CreateTemp() (filestore.File, error) {
+func (fs *TestFileStore) CreateTemp(pattern string) (filestore.File, error) {
 	if len(fs.availableTempFiles) == 0 {
 		return nil, TestErrTempFile
 	}

storagemarket/impl/provider.go

@@ -293,7 +293,7 @@ func (p *Provider) ImportDataForDeal(ctx context.Context, propCid cid.Cid, data
 		return xerrors.Errorf("failed getting deal %s: %w", propCid, err)
 	}
 
-	tempfi, err := p.fs.CreateTemp()
+	tempfi, err := p.fs.CreateTemp(propCid.String())
 	if err != nil {
 		return xerrors.Errorf("failed to create temp file for data import: %w", err)
 	}

storagemarket/impl/providerutils/providerutils.go

@@ -86,7 +86,7 @@ func GeneratePieceCommitmentWithMetadata(
 	payloadCid cid.Cid,
 	selector ipld.Node,
 	storeID *multistore.StoreID) (cid.Cid, abi.UnpaddedPieceSize, filestore.Path, error) {
-	metadataFile, err := fileStore.CreateTemp()
+	metadataFile, err := fileStore.CreateTemp(payloadCid.String())
 	if err != nil {
 		return cid.Cid{}, 0, "", err
 	}