0
点赞
收藏
分享

微信扫一扫

抖音弹幕,点赞,关注 protocol 分析

爱奔跑的读书者 2022-05-04 阅读 96

返回效果

 代码分析

import time

from . import message_pb2
from .base import Base

#普通弹幕
class ChatMessage(Base):
    def __init__(self):
        self.instance = message_pb2.ChatMessage()

    def format_content(self):
        return self.user().nickname + ': ' + self.instance.content

    def __str__(self):
        return time.strftime("%Y-%m-%d %H:%M:%S", time.localtime()) + '【发言】' + self.format_content()
#用户点赞
class LikeMessage(Base):
    def __init__(self):
        self.instance = message_pb2.LikeMessage()
    def format_content(self):
        return self.user().nickname
    def __str__(self):
        return time.strftime("%Y-%m-%d %H:%M:%S", time.localtime()) + '【点赞】' + self.format_content()
#礼物
class SocialMessage(Base):
    def __init__(self):
        self.instance = message_pb2.SocialMessage()
    def format_content(self):
        return self.user().nickname
    def __str__(self):
        return time.strftime("%Y-%m-%d %H:%M:%S", time.localtime()) + '【关注】' + self.format_content()
# -*- coding: utf-8 -*-
import uuid
import live_url as liveUrl

from playwright.sync_api import sync_playwright as playwright
from messages import message_pb2
from messages.chat import ChatMessage
from messages.chat import LikeMessage
from messages.chat import SocialMessage

def filterResponse(response):
    if 'https://live.douyin.com/webcast/im/fetch/' in response.url:
        responsResult = message_pb2.Response()
        responsResult.ParseFromString(response.body())
        for message in responsResult.messages:
            if message.method == 'WebcastChatMessage':
                chat_message = ChatMessage()
                chat_message.set_payload(message.payload)
                print(chat_message)
            if message.method == 'WebcastLikeMessage':
                chat_message = LikeMessage()
                chat_message.set_payload(message.payload)
                print(chat_message)
            if message.method == 'WebcastSocialMessage':
                chat_message = SocialMessage()
                chat_message.set_payload(message.payload)
                print(chat_message)
举报

相关推荐

Redis实现点赞取消点赞

0 条评论