Initial commit

Author: Kartatz

src/cpython/kai/__init__.py

@@ -1,5 +1,5 @@
 from .exceptions import *
-from .types import *
+from ._types import *
 
 __all__ = [
 	"KaiError",
@@ -32,6 +32,7 @@
 	"M3U8KeyFormatVersions",
 	"M3U8Key",
 	"M3U8Segment",
+	"M3U8Segments",
 	"M3U8Map",
 	"M3U8AllowCache",
 	"M3U8DateRange",
@@ -41,7 +42,9 @@
 	"M3U8SessionData",
 	"M3U8Start",
 	"M3U8Media",
-	"M3U8VariantStream"
+	"M3U8VariantStream",
+	"M3U8Resolution",
+	"M3U8ByteRange"
 ]
 
 __locals = locals()

src/cpython/kai/__kai.py

@@ -1,3 +1,5 @@
+import sys
+sys.path.append('/storage/emulated/0/Kai/src/cpython')
 from _kai import (
 	m3u8stream_init,
 	m3u8stream_load,
@@ -59,4 +61,9 @@ def load_file(self, filename, base_url = None):
 
 stream = M3U8Stream()
 a=stream.load("/storage/emulated/0/cq3l8ci23aks73akgsug/master.m3u8")
-print(a.__dict__)
+import sys
+for item in a.stream.iter():
+	pass
+	#print(repr(item))
+print(sys.getrefcount(a.stream))
+print(a)

src/cpython/kai/_types/__init__.py

@@ -11,6 +11,7 @@
 	M3U8KeyFormatVersions,
 	M3U8Key,
 	M3U8Segment,
+	M3U8Segments,
 	M3U8Map,
 	M3U8AllowCache,
 	M3U8DateRange,
@@ -24,7 +25,8 @@
 )
 
 from .m3u8 import (
-	M3U8Resolution
+	M3U8Resolution,
+	M3U8ByteRange
 )
 
 
@@ -41,6 +43,7 @@
 	"M3U8KeyFormatVersions",
 	"M3U8Key",
 	"M3U8Segment",
+	"M3U8Segments",
 	"M3U8Map",
 	"M3U8AllowCache",
 	"M3U8DateRange",
@@ -51,5 +54,6 @@
 	"M3U8Start",
 	"M3U8Media",
 	"M3U8VariantStream",
-	"M3U8Resolution"
+	"M3U8Resolution",
+	"M3U8ByteRange"
 ]

src/cpython/kai/_types/base.py

@@ -0,0 +1,178 @@
+import typing
+import inspect
+import json
+import enum
+
+
+# https://github.com/pyrogram/pyrogram/blob/v1.1.0/pyrogram/types/object.py#L26
+class MetaClass(type, metaclass=type("", (type,), {"__str__": lambda _: "~hi"})):
+
+	def __str__(self):
+		return f"<class 'kai.{self.__name__}'>"
+
+
+# https://github.com/pyrogram/pyrogram/blob/v1.1.0/pyrogram/types/object.py#L31
+class BaseClass(metaclass = MetaClass):
+	
+	def __str__(self):
+		return json.dumps(
+			self,
+			indent = 4,
+			default = self._serializer_callback,
+			ensure_ascii = False
+		)
+
+
+class Dict(BaseClass):
+	
+	def __iter__(self):
+		iterables = {}
+		
+		code = self.__init__.__code__
+		arguments = inspect.getargs(code).args
+		
+		arguments.remove("self")
+		
+		for argument in arguments:
+			attribute = getattr(self, argument)
+			
+			if isinstance(attribute, List):
+				iterables.update(
+					{
+						argument: list(attribute)
+					}
+				)
+			elif isinstance(attribute, Dict):
+				iterables.update(
+					{
+						argument: dict(attribute)
+					}
+				)
+			elif isinstance(attribute, enum.Enum):
+				iterables.update(
+					{
+						argument: str(attribute)
+					}
+				)
+			else:
+				iterables.update(
+					{
+						argument: attribute
+					}
+				)
+			
+			#print(iterables)
+		
+		yield from iterables.items()
+	
+	def __getitem__(self, item):
+		return getattr(self, item)
+	
+	def __setitem__(self, key, value):
+		setattr(self, key, value)
+	
+	def __delitem__(self, item):
+		delattr(self, item)
+	
+	def __repr__(self):
+		code = self.__init__.__code__
+		arguments = inspect.getargs(code).args
+		
+		arguments.remove("self")
+		
+		data = []
+		
+		for argument in arguments:
+			attribute = getattr(self, argument)
+			
+			if isinstance(attribute, List):
+				data.append(f"{argument} = {attribute.__class__.__name__}({repr(attribute.base_list)})")
+			else:
+				data.append(f"{argument} = {repr(attribute)}")
+		
+		class_name = self.__class__.__name__
+		representation = ", ".join(data)
+		
+		return f"kai.{class_name}({representation})"
+	
+	@staticmethod
+	def _serializer_callback(obj):
+		serialized_object = {}
+		
+		code = obj.__init__.__code__
+		arguments = inspect.getargs(code).args
+		
+		arguments.remove("self")
+		
+		for argument in arguments:
+			attribute = getattr(obj, argument)
+			
+			if isinstance(attribute, List):
+				serialized_object.update(
+					{
+						argument: list(attribute)
+					}
+				)
+			elif isinstance(attribute, enum.Enum):
+				serialized_object.update(
+					{
+						argument: str(attribute)
+					}
+				)
+			else:
+				serialized_object.update(
+					{
+						argument: attribute
+					}
+				)
+		
+		return serialized_object
+
+class List(BaseClass):
+	
+	def __init__(self, base_list = None):
+		self.base_list = [] if base_list is None else base_list
+	
+	def __iter__(self):
+		iterable = []
+		
+		for item in self.base_list:
+			if isinstance(item, Dict):
+				iterable.append(dict(item))
+			elif isinstance(item, (str, int, float, bool, type(None))):
+				iterable.append(item)
+			else:
+				raise TypeError
+		
+		return iter(iterable)
+
+	def __getitem__(self, item):
+		return self.base_list[item]
+	
+	def __len__(self):
+		return len(self.base_list)
+	
+	def append(self, item):
+		self.base_list.append(item)
+	
+	def iter(self):
+		return iter(self.base_list)
+	
+	def list(self):
+		return list(self.base_list)
+	
+	def __repr__(self):
+		class_name = self.__class__.__name__
+		representation = repr(self.base_list)
+		
+		return f"kai.{class_name}({representation})"
+	
+	@staticmethod
+	def _serializer_callback(obj):
+		if isinstance(obj, List):
+			return getattr(obj, "base_list")
+		
+		if isinstance(obj, Dict):
+			return dict(obj)
+		
+		raise TypeError

src/cpython/kai/_types/m3u8.py

@@ -3,3 +3,9 @@ class M3U8Resolution:
 	def __init__(self, width, height):
 		self.width = width
 		self.height = height
+
+class M3U8ByteRange:
+	
+	def __init__(self, length, offset):
+		self.length = length
+		self.offset = offset