From 444813b3e25d840a6223afd14bd2e3387bb108b8 Mon Sep 17 00:00:00 2001
From: handongxun <handongxun@dcloud.io>
Date: Tue, 25 Jan 2022 15:50:58 +0800
Subject: [PATCH] vue live-pusher

---
 .../service/api/context/live-pusher.js        |  53 ++++++-
 .../view/components/live-pusher/index.vue     | 149 ++++++++++++++++++
 2 files changed, 198 insertions(+), 4 deletions(-)
 create mode 100644 src/platforms/app-plus/view/components/live-pusher/index.vue

diff --git a/src/platforms/app-plus/service/api/context/live-pusher.js b/src/platforms/app-plus/service/api/context/live-pusher.js
index e698820b0..7ef794946 100644
--- a/src/platforms/app-plus/service/api/context/live-pusher.js
+++ b/src/platforms/app-plus/service/api/context/live-pusher.js
@@ -1,7 +1,52 @@
 import {
-  createLivePusherContext as createLivePusher
-} from 'uni-platforms/app-plus-nvue/service/api/context/live-pusher'
+  callback
+} from 'uni-shared'
 
-export function createLivePusherContext (id, vm) {
-  return createLivePusher(id, vm)
+function operateLivePusher (livePusherId, pageVm, type, data) {
+  const pageId = pageVm.$page.id
+  UniServiceJSBridge.publishHandler(pageId + '-live-pusher-' + livePusherId, {
+    livePusherId,
+    type,
+    data
+  }, pageId)
+}
+
+UniServiceJSBridge.subscribe('onLivePusherMethodCallback', ({
+  callbackId,
+  data
+}) => {
+  callback.invoke(callbackId, data)
+})
+
+const methods = ['preview',
+  'start',
+  'stop',
+  'pause',
+  'resume',
+  'switchCamera',
+  'snapshot']
+
+export class LivePusherContext {
+  constructor (id, pageVm) {
+    this.id = id
+    this.pageVm = pageVm
+  }
+
+  on (name, callback) {
+    operateLivePusher(this.id, this.pageVm, 'on', {
+      name,
+      callback
+    })
+  }
+}
+
+methods.forEach(function (method) {
+  LivePusherContext.prototype[method] = callback.warp(function (options, callbackId) {
+    options.callbackId = callbackId
+    operateLivePusher(this.id, this.pageVm, method, options)
+  })
+})
+
+export function createLivePusherContext (id, context) {
+  return new LivePusherContext(id, context)
 }
diff --git a/src/platforms/app-plus/view/components/live-pusher/index.vue b/src/platforms/app-plus/view/components/live-pusher/index.vue
new file mode 100644
index 000000000..71d6b1391
--- /dev/null
+++ b/src/platforms/app-plus/view/components/live-pusher/index.vue
@@ -0,0 +1,149 @@
+<template>
+  <uni-live-pusher v-on="$listeners">
+    <div
+      ref="container"
+      class="uni-live-pusher-container"
+    />
+    <div class="uni-live-pusher-slot">
+      <slot />
+    </div>
+  </uni-live-pusher>
+</template>
+<script>
+import {
+  subscriber
+} from 'uni-mixins'
+import native from '../../mixins/native'
+
+const methods = [
+  'preview',
+  'start',
+  'stop',
+  'pause',
+  'resume',
+  'switchCamera',
+  'snapshot'
+]
+
+const events = [
+  'statechange',
+  'netstatus',
+  'error'
+]
+
+const attrs = [
+  'url',
+  'mode',
+  'muted'
+]
+
+export default {
+  name: 'LivePusher',
+  mixins: [subscriber, native],
+  props: {
+    id: {
+      type: String,
+      default: ''
+    },
+    url: {
+      type: String,
+      default: ''
+    },
+    mode: {
+      type: String,
+      default: 'SD'
+    },
+    muted: {
+      type: [Boolean, String],
+      default: false
+    }
+  },
+  computed: {
+    attrs () {
+      const obj = {}
+      attrs.forEach(key => {
+        let val = this.$props[key]
+        val = key === 'src' ? this.$getRealPath(val) : val
+        obj[key.replace(/[A-Z]/g, str => '-' + str.toLowerCase())] = val
+      })
+      return obj
+    }
+  },
+  mounted () {
+    this._onParentReady(() => {
+      const livePusher = this.livePusher = new plus.video.LivePusher('livePusher' + Date.now(), Object.assign({}, this.attrs, this.position))
+      plus.webview.currentWebview().append(livePusher)
+      this.$watch('attrs', () => {
+        this.livePusher && this.livePusher.setStyles(this.attrs)
+      }, { deep: true })
+      this.$watch('position', () => {
+        this.livePusher && this.livePusher.setStyles(this.position)
+      }, { deep: true })
+      this.$watch('hidden', (val) => {
+        const livePusher = this.livePusher
+        if (livePusher) {
+          // livePusher[val ? 'hide' : 'show']()
+          // iOS 隐藏状态设置 setStyles 不生效
+          if (!val) {
+            livePusher.setStyles(this.position)
+          }
+        }
+      })
+      events.forEach(key => {
+        livePusher.addEventListener(key, (e) => {
+          this.$trigger(key, {}, { ...e.detail })
+        })
+      })
+    })
+  },
+  beforeDestroy () {
+    this.livePusher && this.livePusher.close()
+    delete this.livePusher
+  },
+  methods: {
+    _handleSubscribe ({
+      type,
+      data = {}
+    }) {
+      console.log('_handleSubscribe type::' + type)
+      if (methods.includes(type)) {
+        this.livePusher && this.livePusher[type](data)
+      }
+    }
+  }
+}
+</script>
+
+<style>
+uni-live-pusher {
+  width: 300px;
+  height: 225px;
+  display: inline-block;
+  line-height: 0;
+  overflow: hidden;
+  position: relative;
+}
+
+uni-live-pusher[hidden] {
+  display: none;
+}
+
+.uni-live-pusher-container {
+  width: 100%;
+  height: 100%;
+  position: absolute;
+  top: 0;
+  left: 0;
+  overflow: hidden;
+  background-color: black;
+}
+
+.uni-live-pusher-slot {
+  position: absolute;
+  top: 0;
+  width: 100%;
+  height: 100%;
+  overflow: hidden;
+  pointer-events: none;
+}
+</style>
-- 
GitLab