Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Generic Multipart reader/writer implementaion #53

Merged
merged 19 commits into from
Mar 11, 2024
Merged

Generic Multipart reader/writer implementaion #53

Changes from 1 commit
Commits
Show all changes
19 commits
Select commit Hold shift + click to select a range
9f2f40f
update deps
sverdlov93 Mar 6, 2024
4b1d373
update deps
sverdlov93 Mar 7, 2024
65f07f3
update deps
sverdlov93 Mar 7, 2024
2ef0724
update deps
sverdlov93 Mar 7, 2024
82ca55f
update deps
sverdlov93 Mar 10, 2024
ecb92b8
update deps
sverdlov93 Mar 10, 2024
c255659
update deps
sverdlov93 Mar 10, 2024
7910788
update deps
sverdlov93 Mar 10, 2024
b1899de
update deps
sverdlov93 Mar 10, 2024
f2deb38
update deps
sverdlov93 Mar 10, 2024
ec736de
update deps
sverdlov93 Mar 10, 2024
3b757f1
update deps
sverdlov93 Mar 10, 2024
ccec754
update deps
sverdlov93 Mar 10, 2024
303dc5b
update deps
sverdlov93 Mar 10, 2024
7712d46
update deps
sverdlov93 Mar 10, 2024
579e7a5
update deps
sverdlov93 Mar 11, 2024
46a363c
update deps
sverdlov93 Mar 11, 2024
d7cdb15
update deps
sverdlov93 Mar 11, 2024
d53e18b
Merge branch 'dev' into stream
sverdlov93 Mar 11, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
update deps
  • Loading branch information
@sverdlov93
sverdlov93 committed Mar 10, 2024
commit f2deb38e19f95fc6b14d8f3567c56f9b9b110885
14 changes: 8 additions & 6 deletions http/filestream/filestream_test.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -17,9 +17,8 @@ import (

var targetDir string

func TestReadFilesFromStream(t *testing.T) {
func TestWriteFilesToStreamAndReadFilesFromStream(t *testing.T) {
sourceDir := t.TempDir()

// Create 2 file to be transferred via our multipart stream
file1 := filepath.Join(sourceDir, "test1.txt")
file2 := filepath.Join(sourceDir, "test2.txt")
Expand All @@ -42,19 +41,22 @@ func TestReadFilesFromStream(t *testing.T) {
assert.NoError(t, ReadFilesFromStream(multipartReader, fileHandlerWithHashValidation))

// Validate file 1 transferred successfully
content, err := os.ReadFile(filepath.Join(targetDir, "test1.txt"))
file1 = filepath.Join(targetDir, "test1.txt")
assert.FileExists(t, file1)
content, err := os.ReadFile(file1)
assert.NoError(t, err)
assert.Equal(t, file1Content, content)

// Validate file 2 transferred successfully
content, err = os.ReadFile(filepath.Join(targetDir, "test2.txt"))
file2 = filepath.Join(targetDir, "test2.txt")
assert.FileExists(t, file2)
content, err = os.ReadFile(file2)
assert.NoError(t, err)
assert.Equal(t, file2Content, content)

}

func simpleFileHandler(fileName string) (fileWriter io.Writer, err error) {
return os.Create(filepath.Join(targetDir, fileName))
return os.OpenFile(filepath.Join(targetDir, fileName), os.O_RDWR|os.O_CREATE, 0777)
}

func fileHandlerWithHashValidation(fileName string) (fileWriter io.Writer, err error) {
Expand Down
Loading