@@ -187,52 +187,4 @@ SelectStream.prototype = {
187187} ;
188188sysUtil . inherits ( SelectStream , Transform ) ;
189189
190- SelectStream . parseBody = function ( chunk ) {
191- var header = { } ;
192- var result = { records :[ ] } ;
193- while ( chunk . length ) {
194- var totalLength = chunk . readInt32BE ( 0 ) ;
195- var headerLength = chunk . readInt32BE ( 4 ) ;
196- var payloadRestLength = totalLength - headerLength - 16 ;
197- var offset = 0 ;
198- var content ;
199- chunk = chunk . slice ( 12 ) ;
200- // 获取 Message 的 header 信息
201- while ( offset < headerLength ) {
202- var headerNameLength = chunk [ offset ] * 1 ;
203- var headerName = chunk . toString (
204- 'ascii' ,
205- offset + 1 ,
206- offset + 1 + headerNameLength ,
207- ) ;
208- var headerValueLength = chunk . readInt16BE ( offset + headerNameLength + 2 ) ;
209- var headerValue = chunk . toString (
210- 'ascii' ,
211- offset + headerNameLength + 4 ,
212- offset + headerNameLength + 4 + headerValueLength ,
213- ) ;
214- header [ headerName ] = headerValue ;
215- offset += headerNameLength + 4 + headerValueLength ;
216- }
217- if ( header [ ':event-type' ] === 'Records' ) {
218- content = chunk . slice ( offset , offset + payloadRestLength ) ;
219- result . records . push ( content ) ;
220- } else if ( header [ ':event-type' ] === 'Stats' ) {
221- content = chunk . slice ( offset , offset + payloadRestLength ) ;
222- result . stats = util . xml2json ( content . toString ( ) ) . Stats ;
223- } else if ( header [ ':event-type' ] === 'error' ) {
224- var errCode = header [ ':error-code' ] ;
225- var errMessage = header [ ':error-message' ] ;
226- var err = new Error ( errMessage ) ;
227- err . message = errMessage ;
228- err . name = err . code = errCode ;
229- result . error = err ;
230- } else if ( [ 'Progress' , 'Continuation' , 'End' ] . includes ( header [ ':event-type' ] ) ) {
231- // do nothing
232- }
233- chunk = chunk . slice ( offset + payloadRestLength + 4 ) ;
234- }
235- return result ;
236- } ;
237-
238190module . exports = SelectStream ;
0 commit comments