Skip to content

new_stuff.md

Latest commit

 

History

History
194 lines (153 loc) · 4.58 KB

new_stuff.md

File metadata and controls

194 lines (153 loc) · 4.58 KB

New Cool Stuff

  • New stuff in threefive
a@fumatica:~/threefive$ pypy3
Python 3.7.10 (7.3.5+dfsg-2, Jun 03 2021, 20:39:46)
[PyPy 7.3.5 with GCC 10.2.1 20210110] on linux
Type "help", "copyright", "credits" or "license" for more information.
>>>> from threefive import Segment, Stream, decode, smoke

threefive.Segment class

  • Requires threefive version 2.3.02+
>>>> help(Segment)

class Segment(builtins.object)
 |  Segment(seg_uri, key_uri=None, iv=None)
 |  
 |  The Segment class is used to process
 |  hls mpegts segments for segment start time
 |  and SCTE35 cues.
 |  local and http(s) segments are supported
 |  aes encoded segments are decrypted.
 |  Segment.start is the first timestamp found
 |  in the segment.
 |  Segment.cues is a list of 
 |  SCTE35 cues found in the segment.
 |  
 |  Methods defined here:
 |  
 |  __init__(self, seg_uri, key_uri=None, iv=None)
 |  
 |  add_cue(self, cue)
 |      add_cue is passed to a Stream instance
 |      to collect SCTE35 cues.
 |  
 |  decode(self)
 |      decode a mpegts hls segment for start time
 |      and scte35 cues.
 |  
 |  ----------------------------------------------------------------------
 |   Example:
 |
 |      from threefive import Segment
 |  
 |      >>>> uri = "https://example.com/1.ts"
 |      >>>> seg = Segment(uri)
 |      >>>> seg.decode()
 |      >>>> seg.start
 |      89715.976944
 |      >>>> [cue.encode() for cue in cues]
 |      ['/DARAAAAAAAAAP/wAAAAAHpPv/8=', '/DAvAAAAAAAAAP/wFAUAAAKWf+//4WoauH4BTFYgAAEAAAAKAAhDVUVJAAAAAOv1oqc=']
 |  
 |      # For aes encrypted files
 |  
 |      >>>> key = "https://example.com/aes.key"
 |      >>>> IV=0x998C575D24F514AEC84EDC5CABCCDB81   # IV is a Hex Literal or Int.  not Hex String
 |      >>>> uri = "https://example.com/aes-1.ts"
 |  
 |      >>>> seg = Segment(uri,key_uri=key, iv=IV)
 |      >>>> seg.decode()
 |      >>>> seg.start
 |      89715.976944
 |      >>>> {cue.packet_data.pcr:cue.encode() for cue in seg.cues}
 |     
 |     { 89718.451333: '/DARAAAAAAAAAP/wAAAAAHpPv/8=',
 |     89730.281789: '/DAvAAAAAAAAAP/wFAUAAAKWf+//4WoauH4BTFYgAAEAAAAKAAhDVUVJAAAAAOv1oqc='}

threefive.Stream.strip_scte35()

Folks have been asking for a way to strip out SCTE-35 Cues in realtime.

>>>> help(Stream.strip_scte35)


Help on function strip_scte35 in module threefive.stream:

strip_scte35(self, func=show_cue_stder)

   Stream.strip_scte35 works just likle Stream.decode_proxy,
        MPEGTS packets, ( Except the SCTE-35 packets) ,
        are written to stdout after being parsed.
        SCTE-35 cues are printed to stderr

Example:

  • make strip.py like this:
import sys
from threefive import Stream


def do():
    arg = sys.argv[1]
    Stream(arg).strip_scte35()

if __name__ == "__main__":
    do()

Use:

pypy3 strip.py ../mpegts/udp.livetv.ts | mplayer - 
# make sure to use '>>' or stripped.ts will only be the last packet.

pypy3 strip.py ../mpegts/udp.livetv.ts >> stripped.ts

threefive.smoke()

A quick sanity check for threefive

>>>> help(smoke)
Help on function smoke in module threefive.smoketest:

smoke(tests=None)
    calls threefive.decode using the values in tests.
    The format for tests:
    { "test_name" : value to pass to threefive.decode}
    
    example:
    
     my_tests ={
    "Base64": "/DAvAAAAAAAA///wBQb+dGKQoAAZAhdDVUVJSAAAjn+fCAgAAAAALKChijUCAKnMZ1g=",
    "Bytes": b"\xfc0\x11\x00\x00\x00\x00\x00\x00\x00\xff\xff\xff\x00\x00\x00O%3\x96",
    }
    
    import threefive
    threefive.smoke_test(my_tests)

threefive.smoke() runs ten tests that verify core functionality.

ten_tests = {
    "Base64": "/DAvAAAAAAAA///wBQb+dGKQoAAZAhdDVUVJSAAAjn+fCAgAAAAALKChijUCAKnMZ1g=",
    "Bytes": b"\xfc0\x11\x00\x00\x00\x00\x00\x00\x00\xff\xff\xff\x00\x00\x00O%3\x96",
    "Hex String": "0XFC301100000000000000FFFFFF0000004F253396",
    "Hex Literal": 0xFC301100000000000000FFFFFF0000004F253396,
    "Integer": 1439737590925997869941740173214217318917816529814,
    "HTTP/HTTPS Streams": "https://futzu.com/xaa.ts",
    
    # "Bad" tests are expected to fail.
    
    "Bad Base64 ": "/DAvAf45AA",
    "Bad File": "/you/me/fake.file",
    "Bad Integer": -0.345,
    " Bad String": "your momma",
}

threefive.smoke() takes about 10 seconds to run.

>>>> from threefive import smoke
>>>> smoke()

this is what you want as the output,

  • six ✔
  • four ✘
Smoke Test

Base64  ✔
Bytes  ✔
Hex String  ✔
Hex Literal  ✔
Integer  ✔
HTTP/HTTPS Streams  ✔
Bad Base64   ✘
Bad File  ✘
Bad Integer  ✘
 Bad String  ✘