Merge pull request #3 from MarkusLuan/update2

Update2 - Exibindo retorno de vídeo e o tempo restante do stream

Author: MarkusLuan

instagram/__init__.py

@@ -30,8 +30,11 @@ def atualizarCSRFToken(token):
 from .login import LoginMgr
 from .comentario import ComentarioMgr
 from .stream import Stream
+from .midia import Midia
 from .model.usuario import Usuario
 
+Midia = Midia(getSession)
+
 def getJoinRequests(self, stream, last_joinRequest):
     session = getSession()
 

instagram/constants.py

@@ -6,6 +6,8 @@ class Constants:
     """
 
     APP_VERSION = '76.0.0.15.395'
+    WIN_VERSION = "10.0"
+    CHROME_VERSION = "83.0.4103.106"
 
     ANDROID_VERSION = 24
     ANDROID_RELEASE = '7.0'

instagram/midia.py

@@ -0,0 +1,53 @@
+from .constants import Constants
+import os
+
+class Midia:
+    def __init__(self, getSession):
+        self.__getSession = getSession
+
+    def info(self, stream_id):
+        self.__session = self.__getSession()
+
+        usuario = self.__session.cookies["ds_user"]
+
+        req = self.__session.get("https://i.instagram.com/api/v1/live/%s/info" % stream_id)
+        res = req.json()
+        url = res["dash_playback_url"]
+
+        req = self.__session.get(url)
+        res = url + "\n"
+        res += req.text
+        return res
+
+    def __lerMidia(self, url):
+        url = "https://instagram.fnat1-1.fna.fbcdn.net/hvideo-" + url
+        req = self.__session.get(url, stream=True, headers={
+            'Accept': '*/*'
+        })
+        req.raise_for_status()
+        return req.content
+
+    def midia(self, url, stream_id, iniciado):
+        self.__session = self.__getSession()
+        
+        initFile = os.path.expandvars("%temp%\\")
+        initFile += ".midia_" + stream_id + "-init." + url[-3:]
+        content = bytes()
+
+        # Se o arquivo solicitado não for o init, retorne os bytes
+        # Se o arquivo solicitado for o init e não tiver sido baixado, faça o download e retorne os bytes
+        if not url[-8:].startswith("init"):
+            content = self.__lerMidia(url)
+        elif not os.path.isfile(initFile):
+            content = self.__lerMidia(url)
+
+            f = open(initFile, "wb")
+            f.write(content)
+            f.close()
+            return content
+        elif not iniciado: # Se o arquivo solicitado for o init e tiver sido baixado, leia e retorne os bytes
+            f = open(initFile, "rb")
+            content = f.read()
+            f.close()
+
+        return content 

instagram/stream.py

@@ -1,6 +1,7 @@
 from .constants import Constants
 import requests
 from flask import request
+from datetime import datetime
 
 class Stream():
     def __init__(self, getSession, criarStream=True):
@@ -9,13 +10,15 @@ def __init__(self, getSession, criarStream=True):
         self.url = None
         self.key = None
         self.iniciado = False
+        self.startTime = None
         self.__cookies = {}
 
         if not criarStream:
             self.id = request.cookies.get("stream_id")
             self.url = request.cookies.get("stream_url")
             self.key = request.cookies.get("stream_key")
             self.iniciado = request.cookies.get("stream_status")
+            self.startTime = request.cookies.get("stream_startTime")
 
             self.iniciado = (self.iniciado == "iniciado")
 
@@ -76,6 +79,7 @@ def iniciar(self):
         self.__cookies.update({"csrf_token": token})
 
         self.iniciado = True
+        self.startTime = int(datetime.now().timestamp())
 
     def encerrar(self):
         self.__session = self.__getSession()

main.py

@@ -7,12 +7,14 @@
 from login import Login
 from stream import Stream
 from comentario import Comentario
+from midia import Midia
 
 app = Flask(__name__)
 
 login = Login(app)
 stream = Stream(app, login)
 comentario = Comentario(app, login, stream)
+midia = Midia(app, stream)
 
 @app.route("/")
 def index():

midia.py

@@ -0,0 +1,112 @@
+import instagram
+from flask import request, redirect, render_template, make_response, Response, stream_with_context
+import xmltodict
+
+class Midia:
+    def __init__(self, app, stream):
+        self.__stream = stream
+        self.rotas(app)
+
+    def __info(self):
+        stream = self.__stream.value
+
+        #Recebendo informações dos videos e audios e a url principal
+        videoInfo = instagram.Midia.info(stream.id)
+
+        #Separando url
+        url = videoInfo[:videoInfo.index("\n")]
+        videoInfo = videoInfo.replace(url + "\n", "")
+
+        #Tratando mpd
+        url = url[:url.rindex("/")]
+        url = url[:url.rindex("/")+1]
+        url = url.replace("https://instagram.fnat1-1.fna.fbcdn.net/hvideo-", "")
+        videoInfo = videoInfo.replace("../", url)
+
+        videoInfo = xmltodict.parse(videoInfo)
+
+        root = videoInfo["MPD"]["Period"]["AdaptationSet"]
+        v = root[0]["Representation"]
+        a = root[1]["Representation"]
+
+        v_type = v["@mimeType"]
+        a_type = a["@mimeType"]
+
+        v = v["SegmentTemplate"]
+        a = a["SegmentTemplate"]
+
+        v_url = v["@media"].replace("../", "")
+        a_url = a["@media"].replace("../", "")
+
+        v = v["SegmentTimeline"]["S"]
+        a = a["SegmentTimeline"]["S"]
+
+        videos = [{
+            "duration": 0,
+            "url": v_url.replace("$Time$", "init"),
+            "mime_type": v_type
+        }]
+
+        audios = [{
+            "duration": 0,
+            "url": a_url.replace("$Time$", "init"),
+            "mime_type": v_type
+        }]
+
+        for _v in v:
+            videos.append({
+                "duration": _v["@d"],
+                "url": v_url.replace("$Time$", _v["@t"]),
+                "mime_type": v_type
+            })
+
+        for _a in a:
+            audios.append({
+                "duration": _a["@d"],
+                "url": a_url.replace("$Time$", _a["@t"]),
+                "mime_type": v_type
+            })
+
+        midia = {
+            "videos": videos,
+            "audios": audios
+        }
+
+        return midia
+
+    def __midia(self, url, iniciado):
+        stream = self.__stream.value
+        return instagram.Midia.midia(url, stream.id, iniciado)
+    
+    def rotas(self, app):
+        def getMidiaContent(k, iniciado=False):
+            midia = self.__info()
+            content = bytes()
+
+            for m in midia[k]:
+                content += self.__midia(m["url"], iniciado)
+                iniciado = True
+            return content
+            
+        def genMidia(k):
+            iniciado = False
+            with app.app_context():
+                while self.__stream.value is not None:
+                    content = getMidiaContent(k)
+                    iniciado = True
+                    yield content
+
+
+        @app.route("/midia/video")
+        def getVideo():
+            return Response(stream_with_context(genMidia("videos")))
+
+        @app.route("/midia/audio")
+        def getAudio():
+            return make_response(
+                getMidiaContent("audios"),
+                200,
+                {
+                    "content-type": "audio/mp4"
+                }
+            )

readme.md

@@ -26,6 +26,8 @@ Para encerrar o servidor basta aperta *"ctrl" + "c"* no cmd ou terminal.
 - Ver os comentários em tempo real
 - Comentar
 - Ocultar/Exibir comentários
+- Exibir retorno do vídeo
+- Exibindo tempo restante para o limite de 1 hora no Instagram
 
 ### Script Baseado Nestes Repositórios
 - [Instagram-PHP-API](https://github.com/cosenary/Instagram-PHP-API)

requeriments.txt

@@ -1,11 +1,16 @@
 certifi==2020.4.5.1
 chardet==3.0.4
 click==7.1.2
+decorator==4.4.2
 Flask==1.1.2
 idna==2.9
+install==1.3.3
 itsdangerous==1.1.0
 Jinja2==2.11.2
 MarkupSafe==1.1.1
+numpy==1.19.0
 requests==2.23.0
+tqdm==4.47.0
 urllib3==1.25.9
 Werkzeug==1.0.1
+xmltodict==0.12.0

static/css/index.css

@@ -32,6 +32,8 @@ input[type="text"]{
 #comentarios{
     height: 400px;
     overflow-y: auto;
+    border-left: solid 1px;
+    padding-left: 17px;
 }
 
 #comentarios div{
@@ -59,6 +61,22 @@ input[type="text"]{
     top: -6px;
 }
 
+#player{
+    float: left;
+    margin: 15px;
+    margin-right: 71px;
+}
+
+#div_tRestante{
+    background-color: #983a3a;
+    width: 120px;
+    color: #FFFFFF;
+    text-align: center;
+    border-radius: 10px;
+    padding: 8px;
+    margin-left: 47px;
+}
+
 @keyframes
 comentario_anim{
     from{

static/js/stream.js

@@ -23,4 +23,21 @@ function getInfo(){
             setTimeout(getInfo, 1500);
         }
     });
-}
+}
+
+function atualizarTRestante(){
+    setInterval(function(){
+        var now = new Date().getTime();
+        var dif = startTime - now;
+        dif = new Date(dif);
+        dif.setHours(0);
+
+        var options = {
+            "hour": "numeric",
+            "minute": "numeric",
+            "second": "numeric"
+        };
+        document.getElementById("tRestante").innerText = dif.toLocaleString("pt-BR", options);
+    }, 1000);
+}
+