@@ -534,12 +534,7 @@ func (p *Server) UploadModuleFiles(ctx context.Context, moduleFiles []byte) erro
534534
535535dataUp ,chunks := sdkproto .BytesToDataUpload (sdkproto .DataUploadType_UPLOAD_TYPE_MODULE_FILES ,moduleFiles )
536536
537- err = stream .Send (& proto.UploadFileRequest {Type :& proto.UploadFileRequest_DataUpload {DataUpload :& proto.DataUpload {
538- UploadType :proto .DataUploadType (dataUp .UploadType ),
539- DataHash :dataUp .DataHash ,
540- FileSize :dataUp .FileSize ,
541- Chunks :dataUp .Chunks ,
542- }}})
537+ err = stream .Send (& proto.UploadFileRequest {Type :& proto.UploadFileRequest_DataUpload {DataUpload :dataUp }})
543538if err != nil {
544539if retryable (err ) {// Do not retry
545540return nil ,xerrors .Errorf ("send data upload: %s" ,err .Error ())
@@ -548,11 +543,7 @@ func (p *Server) UploadModuleFiles(ctx context.Context, moduleFiles []byte) erro
548543}
549544
550545for i ,chunk := range chunks {
551- err = stream .Send (& proto.UploadFileRequest {Type :& proto.UploadFileRequest_ChunkPiece {ChunkPiece :& proto.ChunkPiece {
552- Data :chunk .Data ,
553- FullDataHash :chunk .FullDataHash ,
554- PieceIndex :chunk .PieceIndex ,
555- }}})
546+ err = stream .Send (& proto.UploadFileRequest {Type :& proto.UploadFileRequest_ChunkPiece {ChunkPiece :chunk }})
556547if err != nil {
557548if retryable (err ) {// Do not retry
558549return nil ,xerrors .Errorf ("send chunk piece: %s" ,err .Error ())