Class: NchanTools::Subscriber::MultiparMixedClient::MultipartMixedParser

Inherits:
Object
  • Object
show all
Defined in:
lib/nchan_tools/pubsub.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(multipart_header) ⇒ MultipartMixedParser

Returns a new instance of MultipartMixedParser.

Raises:



1303
1304
1305
1306
1307
1308
1309
1310
1311
1312
 
# File 'lib/nchan_tools/pubsub.rb', line 1303

def initialize(multipart_header)
  matches=/^multipart\/mixed; boundary=(?<boundary>.*)/.match multipart_header
  raise SubscriberError, "malformed Content-Type multipart/mixed header" unless matches[:boundary]
  @bound = matches[:boundary]
  @buf = ""
  @preambled = false
  @headered = nil
  @headers = {}
  @ninished = nil
end

Instance Attribute Details

#bound ⇒ Object

Returns the value of attribute bound.



1302
1303
1304
 
# File 'lib/nchan_tools/pubsub.rb', line 1302

def bound
  @bound
end

#buf ⇒ Object

Returns the value of attribute buf.



1302
1303
1304
 
# File 'lib/nchan_tools/pubsub.rb', line 1302

def buf
  @buf
end

#finished ⇒ Object

Returns the value of attribute finished.



1302
1303
1304
 
# File 'lib/nchan_tools/pubsub.rb', line 1302

def finished
  @finished
end

Instance Method Details

#<<(chunk) ⇒ Object 



1321
1322
1323
1324
1325
1326
1327
1328
1329
1330
1331
1332
1333
1334
1335
1336
1337
1338
1339
1340
1341
1342
1343
1344
1345
1346
1347
1348
1349
1350
1351
1352
1353
1354
1355
1356
1357
 
# File 'lib/nchan_tools/pubsub.rb', line 1321

def <<(chunk)
  @buf << chunk
  #puts @buf
  repeat = true
  while repeat do
    if !@preambled && @buf.slice!(/^--#{Regexp.escape @bound}/)
      @finished = nil
      @preambled = true
      @headered = nil
    end
    if @preambled && @buf.slice!(/^(\r\n(.*?))?\r\n\r\n/m)
      @headered = true
      ($~[2]).each_line do |l|
        if l.match(/(?<name>[^:]+):\s(?<val>[^\r\n]*)/)
          @headers[$~[:name]]=$~[:val]
        end
      end
    else
      repeat = false
    end
    
    if @headered && @buf.slice!(/^(.*?)\r\n--#{Regexp.escape @bound}/m)
      @on_part.call @headers, $~[1]
      @headered = nil
      @headers.clear
      repeat = true
    else
      repeat = false
    end
    
    if (@preambled && !@headered && @buf.slice!(/^--\r\n/)) ||
      (!@preambled && @buf.slice!(/^--#{Regexp.escape @bound}--\r\n/))
      @on_finish.call
      repeat = false
    end
  end
end

#on_finish(&block) ⇒ Object 



1317
1318
1319
 
# File 'lib/nchan_tools/pubsub.rb', line 1317

def on_finish(&block)
  @on_finish = block
end

#on_part(&block) ⇒ Object 



1314
1315
1316
 
# File 'lib/nchan_tools/pubsub.rb', line 1314

def on_part(&block)
  @on_part = block
end