1.0.0 - Primeira versão funcional from MarkusLuan/markus

1.0.0 - Primeira versão funcional

Author: MarkusLuan

comentario.py

@@ -0,0 +1,51 @@
+import instagram
+from flask import request, redirect, render_template
+import json
+
+class Comentario:
+    def __init__(self, app, login, stream):
+        self.__login = login
+        self.__stream = stream
+        self.rotas(app)
+
+    def rotas(self, app):
+        @app.route("/comentarios", methods=["GET"])
+        def getComentarios():
+            lastComent = request.args.get("lastComent")
+
+            ComentarioMgr = instagram.ComentarioMgr(instagram.getSession)
+
+            comentarios = ComentarioMgr.getComentarios(self.__stream.value, lastComent)
+            if (len(comentarios) > 0):
+                if (len(comentarios["comentarios"]) > 0):
+                    print("Novos comentários")
+
+            return json.dumps(comentarios)
+
+        @app.route("/comentarios/enviar", methods=["POST"])
+        def enviarComentario():
+            comentario = request.form.get("comentario")
+            if comentario is None:
+                raise Exception("Erro: Comentário Invalido!")
+
+            ComentarioMgr = instagram.ComentarioMgr(instagram.getSession)
+            comentario = ComentarioMgr.comentar(self.__stream.value, comentario)
+            return json.dumps(comentario)
+
+        @app.route("/comentarios/alternar", methods=["POST"])
+        def alternarComentario():
+            ocultar = request.form.get("ocultar")
+            if ocultar is None:
+                raise Exception("Erro: Comentário Invalido!")
+
+            ocultar = (ocultar!="false")
+
+            ComentarioMgr = instagram.ComentarioMgr(instagram.getSession)
+            
+            if ocultar:
+                ComentarioMgr.ocultarComentarios(self.__stream.value)
+                print("Comentarios desativados!")
+            else:
+                ComentarioMgr.exibirComentarios(self.__stream.value)
+                print("Exibindo comentarios!")
+            return str(ocultar)

instagram/__init__.py

@@ -1,50 +1,74 @@
-from .stream import Stream
+from .constants import Constants
 import requests
+from flask import request
 
-#https://i.instagram.com/api/v1/live/" + live_id+ "/get_comment/?last_comment_ts=0
-#https://i.instagram.com/api/v1/live/" + live_id+ "/get_final_viewer_list/
+def getSession():
+    session = requests.Session()
+    session.headers = {
+        "user-agent" : Constants.USER_AGENT,
+        "Referer" : "https://i.instagram.com/"
+    }
 
-URL = "https://www.instagram.com/"
-USER_AGENT = "Mozilla/5.0 (Linux; Android 7.0; Moto C Plus; wv) AppleWebKit/537.36 (KHTML, like Gecko) Version/4.0 Chrome/80.0.3987.99 Mobile Safari/537.36 Instagram 139.0.0.33.121 Android (24/7.0; 294dpi; 720x1280; moto; Moto C Plus; Moto C Plus; qcom; pt_BR)"
+    def atualizarCSRFToken(token):
+        if token is None:
+            return
+        
+        session.headers.update({"X-CSRFToken": token})
+        return token
 
-session = requests.Session()
-session.headers = {
-    "user-agent" : USER_AGENT,
-    "Referer" : URL
-}
+    session.atualizarCSRFToken = atualizarCSRFToken
+    session.atualizarCSRFToken(request.cookies.get("csrf_token"))
+    
+    cookies = request.cookies.to_dict()
+    for c in cookies:
+        if c.startswith("i."):
+            cookie = requests.cookies.create_cookie(c[2:], cookies[c], domain=".instagram.com")
+            session.cookies.set_cookie(cookie)
 
-def atualizarCSRFToken(session, token):
-    session.headers.update({"X-CSRFToken": token})
+    return session
 
-def fazerLogin(usuario, senha):
-    print("Fazendo login no instagram @%s...." % usuario)
+from .login import LoginMgr
+from .comentario import ComentarioMgr
+from .stream import Stream
+from .model.usuario import Usuario
 
-    req = session.get(URL)
-    atualizarCSRFToken(session, req.cookies["csrftoken"])
+def getJoinRequests(self, stream, last_joinRequest):
+    session = getSession()
 
-    req = session.post(URL + "accounts/login/ajax/", data={
-        "username": usuario,
-        "password": senha
+    req = session.get("https://i.instagram.com/api/v1/live/" + stream.id+ "/get_join_request_counts/", data={
+        "last_seen_ts": last_joinRequest,
+        "last_fetch_ts": last_joinRequest
     })
     res = req.json()
-    atualizarCSRFToken(session, req.cookies["csrftoken"])
 
-    if res["status"] != "ok" or res["authenticated"] != True:
-        raise Exception("Erro no login: %s" % res)
+    joinRequests = []
+    j_dt_envio = res["fetch_ts"]
+    if (j_dt_envio is None) or (int(j_dt_envio) <= int(last_joinRequest)):
+        return joinRequests
+    
+    if res["users"]:
+        for j in res["users"]:
+            u_id = j["pk"]
+            u_nome = j["username"]
+            u_img = j["profile_pic_url"]
 
-    print("Logado com sucesso!")
-    print()
+            usuario = Usuario(u_id, u_nome, u_img)
+            joinRequests.append(usuario.toJson())
+    
+    return joinRequests
 
-def getJoinRequests():
-    req = session.get("https://i.instagram.com/api/v1/live/" + live_id+ "/get_join_request_counts/", data={
-        "last_total_count": 0,
-        "last_seen_ts": 0,
-        "last_fetch_ts": 0
-    })
+def getStream(criarStream=True):
+    try:
+        stream = Stream(getSession, criarStream)
+        return stream
+    except Exception as e:
+        print(e)
+        return None
+
+def getInfo(stream):
+    session = getSession()
+
+    req = session.post("https://i.instagram.com/api/v1/live/" + stream.id + "/heartbeat_and_get_viewer_count/")
     res = req.json()
-    print(res)
-    print()
 
-def getStream():
-    stream = Stream(session)
-    return stream
+    return res

instagram/comentario.py

@@ -0,0 +1,96 @@
+from flask import request
+
+from .model.usuario import Usuario
+from .model.comentario import Comentario
+from .constants import Constants
+
+class ComentarioMgr:
+    def __init__(self, getSession):
+        self.__session = None
+        self.__getSession = getSession
+
+    def getComentarios(self, stream, last_comment):
+        self.__session = self.__getSession()
+        self.__session.headers.update({"X-CSRFToken": request.cookies.get("csrf_token")})
+
+        req = self.__session.get("https://i.instagram.com/api/v1/live/" + stream.id+ "/get_comment/", data={
+            "last_comment_ts" : last_comment
+        })
+        res = req.json()
+
+        if res["status"] != "ok":
+            return []
+
+        ativo = not bool(res["comment_muted"])
+        comentarios = []
+        
+        if ativo and res["comments"] is not None:
+            for c in res["comments"]:
+                c_id = c["pk"]
+                c_dt_envio = c["created_at"]
+                c_texto = c["text"]
+                
+                u = c["user"]
+                u_id = u["pk"]
+                u_nome = u["username"]
+                u_img = u["profile_pic_url"]
+
+                if (int(c_dt_envio) <= int(last_comment)):
+                    continue
+
+                usuario = Usuario(u_id, u_nome, u_img)
+                comentario = Comentario(c_id, c_dt_envio, c_texto, usuario)
+                
+                comentarios.append(comentario.toJson())
+
+        if ativo and res["system_comments"] is not None:
+            for c in res["system_comments"]:
+                c_id = c["pk"]
+                c_dt_envio = c["created_at"]
+                c_texto = c["text"].replace("joined", "entrou")
+                
+                u = c["user"]
+                u_img = u["profile_pic_url"]
+
+                if (int(c_dt_envio) <= int(last_comment)):
+                    continue
+
+                usuario = Usuario("", "", u_img)
+                comentario = Comentario(c_id, c_dt_envio, c_texto, usuario)
+                
+                comentarios.append(comentario.toJson())
+
+        return {
+            "comentarios": comentarios,
+            "ativo": ativo
+        }
+
+    def ocultarComentarios(self, stream):
+        self.__session = self.__getSession()
+        self.__session.headers.update({"X-CSRFToken": request.cookies.get("csrf_token")})
+
+        req = self.__session.post("https://i.instagram.com/api/v1/live/" + stream.id + "/mute_comment/")
+        res = req.json()
+        return res
+
+    def exibirComentarios(self, stream):
+        self.__session = self.__getSession()
+        self.__session.headers.update({"X-CSRFToken": request.cookies.get("csrf_token")})
+
+        req = self.__session.post("https://i.instagram.com/api/v1/live/" + stream.id + "/unmute_comment/")
+        res = req.json()
+        return res
+
+    def comentar(self, stream, texto):
+        self.__session = self.__getSession()
+        self.__session.headers.update({"X-CSRFToken": request.cookies.get("csrf_token")})
+
+        req = self.__session.post("https://i.instagram.com/api/v1/live/" + stream.id + "/comment/", data={
+            "comment_text": texto,
+            "live_or_vod": 1,
+            "offset_to_video_start": 0,
+            "idempotence_token": Constants.DEVICE
+        })
+        res = req.json()
+
+        return res

instagram/constants.py

@@ -0,0 +1,40 @@
+import uuid
+
+class Constants:
+    """Baseado no código da api privada do instagram
+       https://github.com/ping/instagram_private_api/tree/master/instagram_private_api
+    """
+
+    APP_VERSION = '76.0.0.15.395'
+
+    ANDROID_VERSION = 24
+    ANDROID_RELEASE = '7.0'
+    PHONE_MANUFACTURER = 'motorola'
+    PHONE_DEVICE = 'Moto C Plus'
+    PHONE_MODEL = 'panell_23_dl'
+    PHONE_DPI = '240dpi'
+    PHONE_RESOLUTION = '720x1280'
+    PHONE_CHIPSET = 'mt6737'
+    VERSION_CODE = '138226743'
+
+    USER_AGENT_FORMAT = \
+        "Mozilla/5.0 (Linux; Android {android_release}; {device}; wv) " \
+        "AppleWebKit/537.36 (KHTML, like Gecko) Version/4.0 " \
+        "Chrome/80.0.3987.99 Mobile Safari/537.36 " \
+        "Instagram {app_version} Android ({android_version:d}/{android_release}; " \
+        "{dpi}; {resolution}; {brand}; {device}; {model}; {chipset}; en_US; {version_code})"
+
+    USER_AGENT = USER_AGENT_FORMAT.format(**{
+        'app_version': APP_VERSION,
+        'android_version': ANDROID_VERSION,
+        'android_release': ANDROID_RELEASE,
+        'brand': PHONE_MANUFACTURER,
+        'device': PHONE_DEVICE,
+        'model': PHONE_MODEL,
+        'dpi': PHONE_DPI,
+        'resolution': PHONE_RESOLUTION,
+        'chipset': PHONE_CHIPSET,
+        'version_code': VERSION_CODE})
+
+    DEVICE = uuid.uuid1()
+    ANDROID_DEVICE = "android:%s" % DEVICE