@@ -41,6 +41,8 @@ func TestUploadFileLargeModuleFiles(t *testing.T) {
41
41
42
42
for _ , size := range testSizes {
43
43
t .Run (fmt .Sprintf ("size_%d_bytes" , size ), func (t * testing.T ) {
44
+ t .Parallel ()
45
+
44
46
// Generate test module files data
45
47
moduleData := make ([]byte , size )
46
48
_ , err := crand .Read (moduleData )
@@ -82,6 +84,7 @@ func TestUploadFileLargeModuleFiles(t *testing.T) {
82
84
func TestUploadFileErrorScenarios (t * testing.T ) {
83
85
t .Parallel ()
84
86
87
+ //nolint:dogsled
85
88
server , _ , _ , _ := setup (t , false , & overrides {
86
89
externalAuthConfigs : []* externalauth.Config {{}},
87
90
})
@@ -92,9 +95,10 @@ func TestUploadFileErrorScenarios(t *testing.T) {
92
95
require .NoError (t , err )
93
96
94
97
upload , chunks := sdkproto .BytesToDataUpload (sdkproto .DataUploadType_UPLOAD_TYPE_MODULE_FILES , moduleData )
95
- var _ = upload
96
98
97
99
t .Run ("chunk_before_upload" , func (t * testing.T ) {
100
+ t .Parallel ()
101
+
98
102
stream := newMockUploadStream (nil , chunks [0 ])
99
103
100
104
err := server .UploadFile (stream )
@@ -103,6 +107,8 @@ func TestUploadFileErrorScenarios(t *testing.T) {
103
107
})
104
108
105
109
t .Run ("duplicate_upload" , func (t * testing.T ) {
110
+ t .Parallel ()
111
+
106
112
stream := & mockUploadStream {
107
113
done : make (chan struct {}),
108
114
messages : make (chan * proto.UploadFileRequest , 2 ),
@@ -125,6 +131,9 @@ func TestUploadFileErrorScenarios(t *testing.T) {
125
131
})
126
132
127
133
t .Run ("unsupported_upload_type" , func (t * testing.T ) {
134
+ t .Parallel ()
135
+
136
+ //nolint:govet // Ignore lock copy
128
137
cpy := * upload
129
138
cpy .UploadType = sdkproto .DataUploadType_UPLOAD_TYPE_UNKNOWN // Set to an unsupported type
130
139
stream := newMockUploadStream (& cpy , chunks ... )
@@ -152,15 +161,15 @@ func (m mockUploadStream) Recv() (*proto.UploadFileRequest, error) {
152
161
}
153
162
return msg , nil
154
163
}
155
- func (m * mockUploadStream ) Context () context.Context { panic (errUnimplemented ) }
156
- func (m * mockUploadStream ) MsgSend (msg drpc.Message , enc drpc.Encoding ) error {
164
+ func (* mockUploadStream ) Context () context.Context { panic (errUnimplemented ) }
165
+ func (* mockUploadStream ) MsgSend (msg drpc.Message , enc drpc.Encoding ) error {
157
166
panic (errUnimplemented )
158
167
}
159
- func (m * mockUploadStream ) MsgRecv (msg drpc.Message , enc drpc.Encoding ) error {
168
+ func (* mockUploadStream ) MsgRecv (msg drpc.Message , enc drpc.Encoding ) error {
160
169
panic (errUnimplemented )
161
170
}
162
- func (m * mockUploadStream ) CloseSend () error { panic (errUnimplemented ) }
163
- func (m * mockUploadStream ) Close () error { panic (errUnimplemented ) }
171
+ func (* mockUploadStream ) CloseSend () error { panic (errUnimplemented ) }
172
+ func (* mockUploadStream ) Close () error { panic (errUnimplemented ) }
164
173
func (m * mockUploadStream ) isDone () bool {
165
174
select {
166
175
case <- m .done :
0 commit comments