drillbits · October 16, 2018 02:16 · Dec 22, 2014 · Oct 20, 2014 · Oct 20, 2014 · Oct 20, 2014
diff --git a/SCTE35 Decoder b/SCTE35 Decoder
@@ -32,6 +32,7 @@ THE SOFTWARE.
 import bitstring
 from datetime import timedelta
 
+
 class MixinDictRepr(object):
     def __repr__(self, *args, **kwargs):
         return repr(self.__dict__)
@@ -49,7 +50,7 @@ class SCTE35_SpliceInfoSection(MixinDictRepr):
             raise SCTE35_SpliceInfoSectionException("%d valid. Should be 0xfc" %
                                                     table_id)
 
-class MPEG_Time(int):
+class MPEG_Time(long):
     """ Relative time represented by 90kHz clock """
 
     @property
@@ -203,6 +204,7 @@ class SCTE35_Parser(object):
 if __name__ == "__main__":
     import base64
     import argparse
+    import pprint
 
     description = """ Parse SCTE-35 markers from Base64 Strings.
 Example String: "/DAlAAAAAAAAAP/wFAUAAAABf+/+LRQrAP4BI9MIAAEBAQAAfxV6SQ==" """
@@ -219,4 +221,4 @@ Example String: "/DAlAAAAAAAAAP/wFAUAAAABf+/+LRQrAP4BI9MIAAEBAQAAfxV6SQ==" """
 
     print "Parsing Complete"
 
-    print splice_info_section
+    pprint.pprint(vars(splice_info_section))
diff --git a/SCTE35 Decoder b/SCTE35 Decoder
@@ -1,3 +1,34 @@
+#!/usr/bin/python
+'''
+
+SCTE-35 Decoder
+
+
+The MIT License (MIT)
+
+Copyright (c) 2014 Al McCormack
+
+Permission is hereby granted, free of charge, to any person obtaining a copy
+of this software and associated documentation files (the "Software"), to deal
+in the Software without restriction, including without limitation the rights
+to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+copies of the Software, and to permit persons to whom the Software is
+furnished to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in
+all copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
+THE SOFTWARE.
+
+'''
+
+
 import bitstring
 from datetime import timedelta
 

diff --git a/SCTE35 Decoder b/SCTE35 Decoder
@@ -171,8 +171,18 @@ class SCTE35_Parser(object):
 
 if __name__ == "__main__":
     import base64
-    rawb64_input = r'/DAlAAAAAAAAAP/wFAUAAAABf+/+LRQrAP4BI9MIAAEBAQAAfxV6SQ=='
-    myinput = base64.standard_b64decode(rawb64_input)
+    import argparse
+
+    description = """ Parse SCTE-35 markers from Base64 Strings.
+Example String: "/DAlAAAAAAAAAP/wFAUAAAABf+/+LRQrAP4BI9MIAAEBAQAAfxV6SQ==" """
+
+    parser = argparse.ArgumentParser(description=description)
+    parser.add_argument('base64_scte35', metavar='SCTE35_Marker',
+                   help='Base64 encoded SCTE-35 marker')
+
+    args = parser.parse_args()
+
+    myinput = base64.standard_b64decode(args.base64_scte35)
 
     splice_info_section = SCTE35_Parser().parse(myinput)
 

diff --git a/SCTE35 Decoder b/SCTE35 Decoder
@@ -1,8 +1,5 @@
-import base64
 import bitstring
-import datetime
 from datetime import timedelta
-from calendar import month
 
 class MixinDictRepr(object):
     def __repr__(self, *args, **kwargs):
@@ -20,30 +17,28 @@ class SCTE35_SpliceInfoSection(MixinDictRepr):
         if table_id != 0xfc:
             raise SCTE35_SpliceInfoSectionException("%d valid. Should be 0xfc" %
                                                     table_id)
+
+class MPEG_Time(int):
+    """ Relative time represented by 90kHz clock """
+
+    @property
+    def seconds(self):
+        return self / 90000.0
 
+    @property
+    def timedelta(self):
+        return timedelta(seconds=self.seconds)
+
+    def __repr__(self, *args, **kwargs):
+        return "%d (seconds: %f, time: %s)" % (self, self.seconds, self.timedelta)
+
 class SCTE35_SpliceInsert(MixinDictRepr):
 
     class Splice_Time(MixinDictRepr):
         def __init__(self):
             self.time_specified_flag =  None
             self.pts_time = None
-
-        def get_pts_time_seconds(self):
-            if not isinstance(self.pts_time, long):
-                return None
-
-            return self.pts_time / 90000.0
-
-        def get_pts_time_timedelta(self):
-            seconds = self.get_pts_time_seconds()
-
-            if seconds is None:
-                return None
-
-            return timedelta(seconds=seconds)
-
-
-
+
     class Component(MixinDictRepr):
         def __init__(self, tag):
             self.tag = tag
@@ -109,7 +104,7 @@ class SCTE35_Parser(object):
         if splice_time.time_specified_flag:
             # Reserved for 6 bits
             bitarray.pos += 6
-            splice_time.pts_time = bitarray.read("uint:33")
+            splice_time.pts_time = MPEG_Time(bitarray.read("uint:33"))
         else:
             bitarray.pos += 7
 
@@ -119,7 +114,7 @@ class SCTE35_Parser(object):
         break_duration = SCTE35_SpliceInsert.BreakDuration()
         break_duration.auto_return = bitarray.read("bool")
         bitarray.pos += 6
-        break_duration.duration = bitarray.read("uint:33")
+        break_duration.duration = MPEG_Time(bitarray.read("uint:33"))
         return break_duration
 
     def __parse_splice_insert(self, bitarray):
@@ -175,14 +170,12 @@ class SCTE35_Parser(object):
         return results
 
 if __name__ == "__main__":
+    import base64
     rawb64_input = r'/DAlAAAAAAAAAP/wFAUAAAABf+/+LRQrAP4BI9MIAAEBAQAAfxV6SQ=='
     myinput = base64.standard_b64decode(rawb64_input)
 
     splice_info_section = SCTE35_Parser().parse(myinput)
 
     print "Parsing Complete"
 
-    print splice_info_section
-
-    print "Relative PTS Splice Time in Seconds: %f " % splice_info_section.splice_command.splice_time.get_pts_time_seconds()
-    print "Relative PTS Splice Time in HH:MM:SS.S: %s" % splice_info_section.splice_command.splice_time.get_pts_time_timedelta()
+    print splice_info_section
diff --git a/SCTE35 Decoder b/SCTE35 Decoder
@@ -1,5 +1,8 @@
 import base64
 import bitstring
+import datetime
+from datetime import timedelta
+from calendar import month
 
 class MixinDictRepr(object):
     def __repr__(self, *args, **kwargs):
@@ -22,7 +25,24 @@ class SCTE35_SpliceInsert(MixinDictRepr):
 
     class Splice_Time(MixinDictRepr):
         def __init__(self):
-            pass
+            self.time_specified_flag =  None
+            self.pts_time = None
+
+        def get_pts_time_seconds(self):
+            if not isinstance(self.pts_time, long):
+                return None
+
+            return self.pts_time / 90000.0
+
+        def get_pts_time_timedelta(self):
+            seconds = self.get_pts_time_seconds()
+
+            if seconds is None:
+                return None
+
+            return timedelta(seconds=seconds)
+
+
 
     class Component(MixinDictRepr):
         def __init__(self, tag):
@@ -162,4 +182,7 @@ if __name__ == "__main__":
 
     print "Parsing Complete"
 
-    print splice_info_section
+    print splice_info_section
+
+    print "Relative PTS Splice Time in Seconds: %f " % splice_info_section.splice_command.splice_time.get_pts_time_seconds()
+    print "Relative PTS Splice Time in HH:MM:SS.S: %s" % splice_info_section.splice_command.splice_time.get_pts_time_timedelta()
diff --git a/SCTE35 Decoder b/SCTE35 Decoder
@@ -0,0 +1,165 @@
+import base64
+import bitstring
+
+class MixinDictRepr(object):
+    def __repr__(self, *args, **kwargs):
+        return repr(self.__dict__)
+
+class SCTE35_ParseException(Exception):
+    pass
+
+class SCTE35_SpliceInfoSectionException(Exception):
+    pass
+
+class SCTE35_SpliceInfoSection(MixinDictRepr):
+
+    def __init__(self, table_id):
+        if table_id != 0xfc:
+            raise SCTE35_SpliceInfoSectionException("%d valid. Should be 0xfc" %
+                                                    table_id)
+
+class SCTE35_SpliceInsert(MixinDictRepr):
+
+    class Splice_Time(MixinDictRepr):
+        def __init__(self):
+            pass
+
+    class Component(MixinDictRepr):
+        def __init__(self, tag):
+            self.tag = tag
+            self.splice_time = None
+
+    class BreakDuration(MixinDictRepr):
+        def __init__(self):
+            self.auto_return = None
+            self.duration = None
+
+    def __init__(self, splice_id):
+        self.splice_id = splice_id
+        self.components = []
+
+
+class SCTE35_SpliceDescriptor(MixinDictRepr):
+    pass
+
+
+class SCTE35_Parser(object):
+
+    def parse(self, input_bytes):
+        input_bitarray = bitstring.BitString(bytes=input_bytes)
+
+        table_id = input_bitarray.read("uint:8")
+        splice_info_section = SCTE35_SpliceInfoSection(table_id)
+
+        splice_info_section.section_syntax_indicator = input_bitarray.read("bool")
+        splice_info_section.private = input_bitarray.read("bool")
+        #private
+        input_bitarray.pos += 2
+        splice_info_section.section_length = input_bitarray.read("uint:12")
+        splice_info_section.protocol_version = input_bitarray.read("uint:8")
+        splice_info_section.encrypted_packet = input_bitarray.read("bool")
+        splice_info_section.encryption_algorithm = input_bitarray.read("uint:6")
+        splice_info_section.pts_adjustment = input_bitarray.read("uint:33")
+        splice_info_section.cw_index = input_bitarray.read("uint:8")
+        splice_info_section.tier = input_bitarray.read("hex:12")
+        splice_info_section.splice_command_length = input_bitarray.read("uint:12")
+
+        splice_info_section.splice_command_type = input_bitarray.read("uint:8")
+
+        # splice command type parsing
+        if splice_info_section.splice_command_type == 5:
+            splice_info_section.splice_command = self.__parse_splice_insert(input_bitarray)
+        else:
+            raise SCTE35_SpliceInfoSectionException("splice_command_type: %d not yet supported" % splice_info_section.splice_command_type)
+
+        splice_info_section.splice_descriptor_loop_length = input_bitarray.read("uint:16")
+        splice_info_section.splice_descriptors = None
+
+        if splice_info_section.splice_descriptor_loop_length > 0:
+            splice_info_section.splice_descriptors = \
+             self.__parse_splice_descriptors(input_bitarray, 
+                                             splice_info_section.splice_descriptor_loop_length)
+
+        return splice_info_section
+
+    def __parse_splice_time(self, bitarray):
+        splice_time = SCTE35_SpliceInsert.Splice_Time()
+        splice_time.time_specified_flag = bitarray.read("bool")
+
+        if splice_time.time_specified_flag:
+            # Reserved for 6 bits
+            bitarray.pos += 6
+            splice_time.pts_time = bitarray.read("uint:33")
+        else:
+            bitarray.pos += 7
+
+        return splice_time
+
+    def __parse_break_duration(self, bitarray):
+        break_duration = SCTE35_SpliceInsert.BreakDuration()
+        break_duration.auto_return = bitarray.read("bool")
+        bitarray.pos += 6
+        break_duration.duration = bitarray.read("uint:33")
+        return break_duration
+
+    def __parse_splice_insert(self, bitarray):
+        splice_event_id = bitarray.read("uint:32")
+        ssi = SCTE35_SpliceInsert(splice_event_id)
+
+        ssi.splice_event_cancel_indicator = bitarray.read("bool")
+        bitarray.pos += 7
+
+        if not ssi.splice_event_cancel_indicator:
+            ssi.out_of_network_indicator = bitarray.read("bool")
+            ssi.program_splice_flag = bitarray.read("bool")
+            ssi.duration_flag = bitarray.read("bool")
+            ssi.splice_immediate_flag = bitarray.read("bool")
+            # Next 4 bits are reserved
+            bitarray.pos += 4
+
+            if ssi.program_splice_flag and not ssi.splice_immediate_flag:
+                ssi.splice_time = self.__parse_splice_time(bitarray)
+
+            if not ssi.program_splice_flag:
+                ssi.component_count = bitarray.read("uint:8")
+
+                for i in xrange(0, ssi.component_count):
+                    component = SCTE35_SpliceInsert.Component(bitarray.read("uint:8"))
+                    if ssi.splice_immediate_flag:
+                        component.splice_time = self.__parse_splice_time(bitarray)
+                    ssi.components.append(component)
+
+
+            if ssi.duration_flag:
+                ssi.break_duration = self.__parse_break_duration(bitarray)
+
+            ssi.unique_program_id = bitarray.read("uint:16")
+            ssi.avail_num = bitarray.read("uint:8")
+            ssi.avails_expected = bitarray.read("uint:8")
+            return ssi
+
+    def __parse_splice_descriptors(self, bitarray, length):
+
+        results = []
+
+        while length > 6:        
+            splice_desc = SCTE35_SpliceDescriptor();
+
+            splice_desc.splice_descriptor_tag = bitarray.read("uint:8")
+            splice_desc.descriptor_length = bitarray.read("uint:8")
+            splice_desc.identifier = bitarray.read("uint:32")
+
+            length -= 6
+
+            results.append( splice_desc )
+        return results
+
+if __name__ == "__main__":
+    rawb64_input = r'/DAlAAAAAAAAAP/wFAUAAAABf+/+LRQrAP4BI9MIAAEBAQAAfxV6SQ=='
+    myinput = base64.standard_b64decode(rawb64_input)
+
+    splice_info_section = SCTE35_Parser().parse(myinput)
+
+    print "Parsing Complete"
+
+    print splice_info_section
No results found