@@ -112,12 +112,7 @@ func TestUploadFileErrorScenarios(t *testing.T) {
112
112
messages :make (chan * proto.UploadFileRequest ,2 ),
113
113
}
114
114
115
- up := & proto.UploadFileRequest {Type :& proto.UploadFileRequest_DataUpload {DataUpload :& proto.DataUpload {
116
- UploadType :proto .DataUploadType (upload .UploadType ),
117
- DataHash :upload .DataHash ,
118
- FileSize :upload .FileSize ,
119
- Chunks :upload .Chunks ,
120
- }}}
115
+ up := & proto.UploadFileRequest {Type :& proto.UploadFileRequest_DataUpload {DataUpload :upload }}
121
116
122
117
// Send it twice
123
118
stream .messages <- up
@@ -184,20 +179,11 @@ func newMockUploadStream(up *sdkproto.DataUpload, chunks ...*sdkproto.ChunkPiece
184
179
messages :make (chan * proto.UploadFileRequest ,1 + len (chunks )),
185
180
}
186
181
if up != nil {
187
- stream .messages <- & proto.UploadFileRequest {Type :& proto.UploadFileRequest_DataUpload {DataUpload :& proto.DataUpload {
188
- UploadType :proto .DataUploadType (up .UploadType ),
189
- DataHash :up .DataHash ,
190
- FileSize :up .FileSize ,
191
- Chunks :up .Chunks ,
192
- }}}
182
+ stream .messages <- & proto.UploadFileRequest {Type :& proto.UploadFileRequest_DataUpload {DataUpload :up }}
193
183
}
194
184
195
185
for _ ,chunk := range chunks {
196
- stream .messages <- & proto.UploadFileRequest {Type :& proto.UploadFileRequest_ChunkPiece {ChunkPiece :& proto.ChunkPiece {
197
- Data :chunk .Data ,
198
- FullDataHash :chunk .FullDataHash ,
199
- PieceIndex :chunk .PieceIndex ,
200
- }}}
186
+ stream .messages <- & proto.UploadFileRequest {Type :& proto.UploadFileRequest_ChunkPiece {ChunkPiece :chunk }}
201
187
}
202
188
close (stream .messages )
203
189
return stream