Function TestUploadSentinel

internal/backup_fetch_test.go:198–216

(t *testing.T)

}

func TestUploadSentinel(t *testing.T) {
	mockCtrl := gomock.NewController(t)
	folder := mocks.NewMockFolder(mockCtrl)
	defer mockCtrl.Finish()

	uploaderProv := mock_internal.NewMockUploader(mockCtrl)
	uploaderProv.EXPECT().PushStream(gomock.Any(), gomock.Any()).Return("test_file_name", nil)
	uploaderProv.EXPECT().Folder().Return(folder)

	sentinel := streamSentinelDto{StartLocalTime: utility.TimeNowCrossPlatformLocal()}
	fileName, err := uploaderProv.PushStream(context.Background(), bytes.NewReader(getByteSampleArray(51)))
	if err != nil {
		t.Errorf("Error pushing stream: %v", err)
	}
	folder.EXPECT().PutObject(gomock.Any(), gomock.Any()).Return(nil)
	uploadDto := internal.UploadSentinel(uploaderProv, &sentinel, fileName)

	assert.NoError(t, uploadDto)
}