@@ -112,7 +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 {& proto.DataUpload {
115
+ up := & proto.UploadFileRequest {Type : & proto.UploadFileRequest_DataUpload {DataUpload : & proto.DataUpload {
116
116
UploadType : proto .DataUploadType (upload .UploadType ),
117
117
DataHash : upload .DataHash ,
118
118
FileSize : upload .FileSize ,
@@ -184,7 +184,7 @@ func newMockUploadStream(up *sdkproto.DataUpload, chunks ...*sdkproto.ChunkPiece
184
184
messages : make (chan * proto.UploadFileRequest , 1 + len (chunks )),
185
185
}
186
186
if up != nil {
187
- stream .messages <- & proto.UploadFileRequest {Type : & proto.UploadFileRequest_DataUpload {& proto.DataUpload {
187
+ stream .messages <- & proto.UploadFileRequest {Type : & proto.UploadFileRequest_DataUpload {DataUpload : & proto.DataUpload {
188
188
UploadType : proto .DataUploadType (up .UploadType ),
189
189
DataHash : up .DataHash ,
190
190
FileSize : up .FileSize ,
@@ -193,7 +193,7 @@ func newMockUploadStream(up *sdkproto.DataUpload, chunks ...*sdkproto.ChunkPiece
193
193
}
194
194
195
195
for _ , chunk := range chunks {
196
- stream .messages <- & proto.UploadFileRequest {Type : & proto.UploadFileRequest_ChunkPiece {& proto.ChunkPiece {
196
+ stream .messages <- & proto.UploadFileRequest {Type : & proto.UploadFileRequest_ChunkPiece {ChunkPiece : & proto.ChunkPiece {
197
197
Data : chunk .Data ,
198
198
FullDataHash : chunk .FullDataHash ,
199
199
PieceIndex : chunk .PieceIndex ,
0 commit comments