• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    迪恩网络公众号

Python mediauploader.MediaUploader类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Python中yowsup.layers.protocol_media.mediauploader.MediaUploader的典型用法代码示例。如果您正苦于以下问题:Python MediaUploader类的具体用法?Python MediaUploader怎么用?Python MediaUploader使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



在下文中一共展示了MediaUploader类的14个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Python代码示例。

示例1: on_request_upload_result

    def on_request_upload_result(
        self, jid, path, result_request_upload_iq_protocol_entity, request_upload_iq_protocol_entity, caption=None
    ):

        if request_upload_iq_protocol_entity.mediaType == RequestUploadIqProtocolEntity.MEDIA_TYPE_AUDIO:
            do_send_fn = self.do_send_audio
        else:
            do_send_fn = self.do_send_image

        if result_request_upload_iq_protocol_entity.isDuplicate():
            do_send_fn(
                path,
                result_request_upload_iq_protocol_entity.getUrl(),
                jid,
                result_request_upload_iq_protocol_entity.getIp(),
                caption,
            )
        else:
            success_fn = lambda filePath, jid, url: do_send_fn(
                filePath, url, jid, result_request_upload_iq_protocol_entity.getIp(), caption
            )
            mediaUploader = MediaUploader(
                jid,
                self.getOwnJid(),
                path,
                result_request_upload_iq_protocol_entity.getUrl(),
                result_request_upload_iq_protocol_entity.getResumeOffset(),
                success_fn,
                self.on_upload_error,
                self.on_upload_progress,
                async=True,
            )
            mediaUploader.start()
开发者ID:jlmadurga,项目名称:yowsup-celery,代码行数:33,代码来源:layer.py


示例2: onRequestUploadResult

    def onRequestUploadResult(
        self, jid, mediaType, filePath, resultRequestUploadIqProtocolEntity, requestUploadIqProtocolEntity, caption=None
    ):

        if resultRequestUploadIqProtocolEntity.isDuplicate():
            self.doSendMedia(
                mediaType,
                filePath,
                resultRequestUploadIqProtocolEntity.getUrl(),
                jid,
                resultRequestUploadIqProtocolEntity.getIp(),
                caption,
            )
        else:
            successFn = lambda filePath, jid, url: self.doSendMedia(
                mediaType, filePath, url, jid, resultRequestUploadIqProtocolEntity.getIp(), caption
            )
            mediaUploader = MediaUploader(
                jid,
                self.getOwnJid(),
                filePath,
                resultRequestUploadIqProtocolEntity.getUrl(),
                resultRequestUploadIqProtocolEntity.getResumeOffset(),
                successFn,
                self.onUploadError,
                self.onUploadProgress,
                async=False,
            )
            mediaUploader.start()
开发者ID:maruen,项目名称:yowsup,代码行数:29,代码来源:layer.py


示例3: onRequestUploadResultAudio

 def onRequestUploadResultAudio(self, jid, filePath, resultRequestUploadIqProtocolEntity, requestUploadIqProtocolEntity):
     if resultRequestUploadIqProtocolEntity.isDuplicate():
         self.doSendAudio(filePath, resultRequestUploadIqProtocolEntity.getUrl(), "audio", jid,
                          resultRequestUploadIqProtocolEntity.getIp())
     else:
         mediaUploader = MediaUploader(jid, self.getOwnJid(), filePath,
                                   resultRequestUploadIqProtocolEntity.getUrl(),
                                   resultRequestUploadIqProtocolEntity.getResumeOffset(),
                                   self.onUploadSuccessAudio, self.onUploadError, self.onUploadProgress, async=False)
         mediaUploader.start()
开发者ID:chaitanya4b3,项目名称:AutoBot,代码行数:10,代码来源:layer.py


示例4: onRequestUploadResult

 def onRequestUploadResult(self, jid, filePath, resultRequestUploadIqProtocolEntity, requestUploadIqProtocolEntity):
     if resultRequestUploadIqProtocolEntity.isDuplicate():
         self.doSendImage(filePath, resultRequestUploadIqProtocolEntity.getUrl(), jid,
                          resultRequestUploadIqProtocolEntity.getIp())
     else:
         # successFn = lambda filePath, jid, url: self.onUploadSuccess(filePath, jid, url, resultRequestUploadIqProtocolEntity.getIp())
         mediaUploader = MediaUploader(jid, self.getOwnJid(), filePath,
                                   resultRequestUploadIqProtocolEntity.getUrl(),
                                   resultRequestUploadIqProtocolEntity.getResumeOffset(),
                                   self.onUploadSuccess, self.onUploadError, self.onUploadProgress, async=False)
         mediaUploader.start()
开发者ID:sm4rty89,项目名称:yowsup,代码行数:11,代码来源:layer.py


示例5: onRequestUploadResult

 def onRequestUploadResult(self,jid,filePath,resultRequestUploadIqProtocolEntity,requestUploadIqProtocolEntity):
     if resultRequestUploadIqProtocolEntity.isDuplicate():
         if self.MEDIA_TYPE=="image":
             self.doSendImage(filePath,resultRequestUploadIqProtocolEntity.getUrl(),jid,resultRequestUploadIqProtocolEntity.getIp())
         elif self.MEDIA_TYPE=="video":
             self.doSendVideo(filePath,resultRequestUploadIqProtocolEntity.getUrl(),jid,resultRequestUploadIqProtocolEntity.getIp())
         elif self.MEDIA_TYPE=="audio":
             self.doSendAudio(filePath,resultRequestUploadIqProtocolEntity.getUrl(),jid,resultRequestUploadIqProtocolEntity.getIp())
     else:
         mediaUploader=MediaUploader(jid,self.getOwnJid(),filePath,resultRequestUploadIqProtocolEntity.getUrl(),resultRequestUploadIqProtocolEntity.getResumeOffset(),self.onUploadSuccess,self.onUploadError,self.onUploadProgress,async=False)
         mediaUploader.start()
开发者ID:gustavocesarlos,项目名称:trabalhofinalMic,代码行数:11,代码来源:wamedia.py


示例6: __onRequestUploadSuccess

    def __onRequestUploadSuccess(self, resultRequestUploadIqProtocolEntity, requestUploadEntity, builder, success, error = None, progress = None):
        if(resultRequestUploadIqProtocolEntity.isDuplicate()):
            return success(builder.build(resultRequestUploadIqProtocolEntity.getUrl(), resultRequestUploadIqProtocolEntity.getIp()))
        else:
            successFn = lambda path, jid, url: self.__onMediaUploadSuccess(builder, url, resultRequestUploadIqProtocolEntity.getIp(), success)
            errorFn = lambda path, jid, errorText: self.__onMediaUploadError(builder, errorText, error)

            mediaUploader = MediaUploader(builder.jid, self.getOwnJid(), builder.getFilepath(),
                                      resultRequestUploadIqProtocolEntity.getUrl(),
                                      resultRequestUploadIqProtocolEntity.getResumeOffset(),
                                      successFn, errorFn, progress, async=True)
            mediaUploader.start()
开发者ID:Adutchlegend,项目名称:yowsup,代码行数:12,代码来源:interface.py


示例7: _on_upload_request_result

 def _on_upload_request_result(self, jid, file_path, upload_result, request_entity):
     """
         If the file has never been uploaded, will be uploaded and then call the _do_send_file
     """
     if upload_result.isDuplicate():
         self._do_send_file(file_path, upload_result.getUrl(), jid, upload_result.getIp())
     else:
         callback = lambda media_path, jid, url: self._do_send_file(media_path, url, jid, upload_result.getIp())
         mediaUploader = MediaUploader(jid, self.interface_layer.getOwnJid(), file_path,
                                       upload_result.getUrl(),
                                       upload_result.getResumeOffset(),
                                       callback, self._on_error, self._on_upload_progress, async=True)
         mediaUploader.start()
开发者ID:bolshoibooze,项目名称:whatsappcli,代码行数:13,代码来源:media_downloader.py


示例8: _on_upload_result

 def _on_upload_result(self,upload_result, requestUploadIqProtocolEntity, caption=None):
     """
         If the file has never been uploaded, will be uploaded and then call the _do_send_file
     """
     if upload_result.isDuplicate():
         self._do_send_file(self.path, upload_result.getUrl(), self.jid, upload_result.getIp(), caption)
     else:
         callback = lambda file_path, jid, url: self._do_send_file(self.path, url, self.jid, upload_result.getIp(),
                                                                   caption)
         mediaUploader = MediaUploader(self.jid, self.interface_layer.getOwnJid(),self.path,
                                       upload_result.getUrl(),
                                       upload_result.getResumeOffset(),
                                       callback, self._on_error, self._on_upload_progress, async=True)
         mediaUploader.start()
开发者ID:harshul1610,项目名称:whatsapp_sound_bot,代码行数:14,代码来源:media.py


示例9: on_request_upload_result

 def on_request_upload_result(self, jid, file_path, result_entity, request_entity):
     if result_entity.isDuplicate():
         self.send_file(file_path, result_entity.getUrl(), jid, result_entity.getIp())
     else:
         uploader = MediaUploader(
             jid, self.getOwnJid(),
             file_path,
             result_entity.getUrl(),
             result_entity.getResumeOffset(),
             self.on_upload_success,
             self.on_upload_error,
             self.on_upload_progress,
             async=False
         )
         uploader.start()
开发者ID:tax,项目名称:pywhatsapp,代码行数:15,代码来源:whatsapp.py


示例10: onRequestUploadResult

    def onRequestUploadResult(self, jid, filePath, resultRequestUploadIqProtocolEntity, requestUploadIqProtocolEntity, caption = None):

        if requestUploadIqProtocolEntity.mediaType == RequestUploadIqProtocolEntity.MEDIA_TYPE_AUDIO:
            doSendFn = self.doSendAudio
        else:
            doSendFn = self.doSendImage

        if resultRequestUploadIqProtocolEntity.isDuplicate():
            doSendFn(filePath, resultRequestUploadIqProtocolEntity.getUrl(), jid,
                             resultRequestUploadIqProtocolEntity.getIp(), caption)
        else:
            successFn = lambda filePath, jid, url: doSendFn(filePath, url, jid, resultRequestUploadIqProtocolEntity.getIp(), caption)
            mediaUploader = MediaUploader(jid, self.getOwnJid(), filePath,
                                      resultRequestUploadIqProtocolEntity.getUrl(),
                                      resultRequestUploadIqProtocolEntity.getResumeOffset(),
                                      successFn, self.onUploadError, self.onUploadProgress, async=False)
            mediaUploader.start()
开发者ID:Nucleoos,项目名称:yowsup,代码行数:17,代码来源:layer.py


示例11: onRequestUploadResult

 def onRequestUploadResult(self, jid, fpath, successEntity, originalEntity):
     if successEntity.isDuplicate():
         url = successEntity.getUrl()
         ip = successEntity.getIp()
         print "<= WhatsApp: upload duplicate %s, from %s" % (fpath, url)
         self.send_uploaded_media(fpath, jid, url, ip)
     else:
         ownjid = self._yowsup.getOwnJid()
         mediaUploader = MediaUploader(jid, ownjid, fpath,
                                   successEntity.getUrl(),
                                   successEntity.getResumeOffset(),
                                   self.onUploadSuccess,
                                   self.onUploadError,
                                   self.onUploadProgress,
                                   async=False)
         print "<= WhatsApp: start upload %s, into %s" \
                 % (fpath, successEntity.getUrl())
         mediaUploader.start()
开发者ID:vvoid,项目名称:whatsapp-email-bridge,代码行数:18,代码来源:WhatsAppEmailForwarder.py


示例12: onRequestUploadResult

 def onRequestUploadResult(self, resultRequestUploadIqProtocolEntity, requestUploadIqProtocolEntity, jid, path, oup):
     print("Request ok")
     #duplicate image will provide json data not found Exception error
     if resultRequestUploadIqProtocolEntity.isDuplicate():
         self.doSendImage(path,resultRequestUploadIqProtocolEntity.getUrl(),jid,resultRequestUploadIqProtocolEntity.getIp())
         mediaUploader = MediaUploader(jid, self.getOwnJid(), path,
                                   resultRequestUploadIqProtocolEntity.getUrl(),
                                   resultRequestUploadIqProtocolEntity.getResumeOffset(),
                                   self.onUploadSuccess, self.onUploadError, oup)
         print("Duplicate Image found....")
     else:
          #successFn = lambda filePath, jid, url: self.uploadOk(mediaType, filePath, url, jid, resultRequestUploadIqProtocolEntity.getIp(), caption)
          mediaUploader = MediaUploader(jid, self.getOwnJid(), path,
                                   resultRequestUploadIqProtocolEntity.getUrl(),
                                   resultRequestUploadIqProtocolEntity.getResumeOffset(),
                                   self.onUploadSuccess, self.onUploadError, oup)
     mediaUploader.start()
     print("Request ok upload complete")
开发者ID:chaitanya4b3,项目名称:AutoBot,代码行数:18,代码来源:layer.py


示例13: onRequestUploadSuccess

    def onRequestUploadSuccess(self, to, path, result, original, caption):
        if result.isDuplicate():
            # This image is already on WhatsApp servers

            logger.info("The image %s is already on the WhatsApp server" %path)
            self.imageSend(path, result.getUrl(), to, result.getIp(), caption)
        else:
            # We need to upload the image to WhatsApp servers

            # The on success callback
            successFn = lambda filePath, jid, url: self.onUploadSuccess(path, url, to,
                                                                        result.getIp(),
                                                                        caption)

            # create the actual uploader
            mediaUploader = MediaUploader(to, self.getOwnJid(), path,
                                          result.getUrl(),
                                          result.getResumeOffset(),
                                          successFn, 
                                          self.onUploadError, #upload error
                                          self.onUploadProgress, #upload progress
                                          async=False)
            # begin the upload
            mediaUploader.start()
开发者ID:ongair,项目名称:whatsapp,代码行数:24,代码来源:ongair.py


示例14: onRequestUploadResult

	def onRequestUploadResult(self, receiver_jid, imagePath, resultRequestUploadIqProtocolEntity, requestUploadIqProtocolEntity):
		mediaUploader = MediaUploader(self._image_upload_receiver_jid, self.getOwnJid(), imagePath,
									  resultRequestUploadIqProtocolEntity.getUrl(),
									  resultRequestUploadIqProtocolEntity.getResumeOffset(),
									  self.onUploadSuccess, self.onUploadError, self.onUploadProgress)
		mediaUploader.start()
开发者ID:luckydonald,项目名称:tg-wa-brigde,代码行数:6,代码来源:layer.py



注:本文中的yowsup.layers.protocol_media.mediauploader.MediaUploader类示例由纯净天空整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Python stacks.YowStack类代码示例发布时间:2022-05-26
下一篇:
Python tools.StorageTools类代码示例发布时间:2022-05-26
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap