From 88d8ee593c87ba58ed4fc24d752e274138c24ada Mon Sep 17 00:00:00 2001
From: Fang_Zhijian <klxf@vip.qq.com>
Date: Tue, 21 May 2024 17:56:55 +0800
Subject: [PATCH] update
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

1. 新增粉丝牌限制
2. 修复大航海等级限制
3. 本地设置数据升级机制
---
 src/App.vue          | 117 ++++++++++++++++++++++++++++++++++++++-----
 src/socket/coyote.ts |   9 ++++
 src/socket/index.ts  |  42 ++++++++++++++--
 3 files changed, 151 insertions(+), 17 deletions(-)

diff --git a/src/App.vue b/src/App.vue
index 5ff28ef..93cef71 100644
--- a/src/App.vue
+++ b/src/App.vue
@@ -1,7 +1,7 @@
 <script setup lang="ts">
 // This starter template is using Vue 3 <script setup> SFCs
 // Check out https://v3.vuejs.org/api/sfc-script-setup.html#sfc-script-setup
-import { ref, watch } from "vue"
+import {computed, ref, watch} from "vue"
 import axios from "axios"
 import { Notyf } from 'notyf'
 import { createSocket, destroySocket } from "./socket/index"
@@ -10,6 +10,7 @@ import {
   closeCoyoteSocket,
   addOrIncrease,
   sendWaveData,
+  coyoteState,
   qrcodeSrc,
   qrcodeShow,
   channelAStrength,
@@ -30,19 +31,51 @@ const api = axios.create({
 
 //读取本地储存数据
 let settings = ref()
+const settings_text = localStorage.getItem('settings')
+const settings_version = 1
+let showUpgrade = ref(false)
 if (window.localStorage.getItem("settings")) {
-  settings.value = JSON.parse(window.localStorage.getItem("settings") || '{}');
+  settings.value = JSON.parse(window.localStorage.getItem("settings") || '{}')
+  if (settings.value.version != settings_version) {
+    // 如果版本不一致，则提示是否修复
+    showUpgrade.value = true
+  }
   // console.log(settings.value)
 } else {
   // 如果没有，使用默认值并且保存
   settings.value = {
+    version: 1,
     waveData: waveData,
     strengthData: strengthData,
-    guardLevel: 0
+    guardLevel: 0,
+    fansMedal: false
   };
   window.localStorage.setItem('settings', JSON.stringify(settings.value));
 }
 
+const upgradeSettings = () => {
+  // 目前结构没变化，所以补全不存在的项就行了
+  const old_settings = JSON.parse(window.localStorage.getItem("settings") || '{}')
+  const old_waveData = old_settings?.waveData ? old_settings.waveData : waveData
+  const old_strengthData = old_settings?.strengthData ? old_settings.strengthData : strengthData
+  const old_guardLevel = old_settings?.guardLevel ? old_settings.guardLevel : "0"
+  const old_fansMedal = old_settings?.fansMedal ? old_settings.fansMedal : false
+
+  settings.value = {
+    version: settings_version,
+    waveData: old_waveData,
+    strengthData: old_strengthData,
+    guardLevel: old_guardLevel,
+    fansMedal: old_fansMedal
+  }
+
+  window.localStorage.setItem('settings', JSON.stringify(settings.value));
+
+  console.log(settings.value)
+
+  showUpgrade.value = false
+  notyf.success("升级成功")
+}
 
 // 替换你的主播身份码
 const codeId = ref("")
@@ -62,6 +95,9 @@ const waveTestData = ref("")
 // 显示设置窗口
 const showSettings = ref(false)
 
+// 连接状态
+const gameState = ref(false)
+
 const selectedGift = ref('')
 const selectedWave = ref('')
 const relations = ref(Object.entries(giftData).map(([key, value]) => ({ gift: key, wave: settings.value.waveData[key] })))
@@ -72,6 +108,10 @@ watch(selectedGift, (newGift) => {
   selectedWave.value = waveData[newGift]
 })
 
+const fansMedal = computed({
+  get: () => settings.value.fansMedal,
+  set: (value) => { settings.value.fansMedal = value === 'true' }
+});
 
 /**
  * 测试请求鉴权接口
@@ -127,6 +167,7 @@ const gameStart = () => {
             heartBeatThis(game_info.game_id)
           }, 20000)
           handleCreateSocket()
+          gameState.value = true
         } else {
           console.log("-----游戏开始失败-----")
           console.log("原因：", data)
@@ -160,6 +201,7 @@ const gameEnd = () => {
           handleDestroySocket()
           console.log("-----心跳关闭成功-----")
           notyf.success({ message: "游戏关闭成功" })
+          gameState.value = false
         } else {
           console.log("-----游戏关闭失败-----")
           console.log("原因：", data)
@@ -251,6 +293,24 @@ const addRelationAndSave = () => {
   // 保存设置
   saveSettings();
 }
+
+/**
+ * 将数字大航海等级转换为文字
+ */
+const guardLevelText = computed(() => {
+  switch (settings.value.guardLevel) {
+    case "0":
+      return "观众";
+    case "1":
+      return "舰长";
+    case "2":
+      return "提督";
+    case "3":
+      return "总督";
+    default:
+      return "未知";
+  }
+})
 </script>
 
 <template>
@@ -267,15 +327,42 @@ const addRelationAndSave = () => {
     </div>
   </div>
 
+
+  <div class="settings-window" v-show="showUpgrade">
+    <h2>【重要】设置结构现已更新，请确认执行升级操作</h2>
+    <p>
+      目前设置数据储存结构版本为<input class="tag" v-model="settings_version" size="1" disabled>，你设备上储存的设置数据的结构版本为<input class="tag" v-model="settings.version" size="1" disabled>。
+    </p>
+    <p>
+      为了可以安全使用 BLive Coyote 需将你设备上储存的设置数据进行升级，这通常可以自动进行，如果出现意外请联系开发者。
+    </p>
+    <hr />
+    <p>【注意】请先复制下面的全部内容，以确保在升级失败时可以恢复</p>
+    <textarea v-model="settings_text" style="width: 100%; height: 64px;"></textarea>
+    <div class="form">
+      <button @click="upgradeSettings">尝试执行升级</button>
+    </div>
+  </div>
+
   <div class="settings-window" v-show="showSettings">
     <button @click="showSettings = false" style="float: right">关</button>
     <button @click="saveSettings" style="float: right">存</button>
     <div>
       <h2>大航海</h2>
       <p>
-        大航海等级达到
-        <input v-model="settings.guardLevel">
-        才可互动
+        身份至低为
+        <select v-model="settings.guardLevel">
+          <option value="0">观众</option>
+          <option value="1">舰长</option>
+          <option value="2">提督</option>
+          <option value="3">总督</option>
+        </select>
+        且
+        <select v-model="fansMedal">
+          <option value="true">需要</option>
+          <option value="false">不需要</option>
+        </select>
+        佩戴粉丝牌才可互动
       </p>
 
       <h2>强度规则</h2>
@@ -360,7 +447,13 @@ const addRelationAndSave = () => {
 
     <h2>游戏玩法</h2>
     <h3>大航海</h3>
-    <p>等级达到 <input class="tag" v-model="settings.guardLevel" size="1" disabled> 才可互动</p>
+    <p>
+      身份至低为
+      <input class="tag" v-model="guardLevelText" size="1" disabled>
+      且
+      <span class="tag">{{ settings["fansMedal"] ? "需要" : "不需要" }}</span>
+      佩戴粉丝牌才可互动
+    </p>
     <h3>强度控制</h3>
     <p>
       赠送
@@ -381,7 +474,7 @@ const addRelationAndSave = () => {
       <div v-for="relation in relations" :key="relation.gift">
         <div v-if="relation && relation.wave">
           <img :src="'/img/' + relation.gift + '.png'" width="24" :alt="giftData[relation.gift]">
-          <input class="tag" v-model="giftData[relation.gift]" disabled>
+          <input class="tag" v-model="giftData[relation.gift]" size="8" disabled>
         </div>
       </div>
     </div>
@@ -397,10 +490,10 @@ const addRelationAndSave = () => {
       <input type="password" placeholder="填写主播身份码" v-model="codeId"/>
       <label>app_id</label>
       <input type="text" placeholder="填写 app_id" v-model="appId" />
-      <button @click="gameStart">游戏开始</button>
-      <button @click="gameEnd">游戏结束</button>
-      <button @click="createCoyoteSocket">连接郊狼</button>
-      <button @click="closeCoyoteSocket">断开郊狼</button>
+      <button @click="gameStart" v-show="!gameState">游戏开始</button>
+      <button @click="gameEnd" v-show="gameState">游戏结束</button>
+      <button @click="createCoyoteSocket" v-show="!coyoteState">连接郊狼</button>
+      <button @click="closeCoyoteSocket" v-show="coyoteState">断开郊狼</button>
     </div>
 
     <hr />
diff --git a/src/socket/coyote.ts b/src/socket/coyote.ts
index 2e78f01..5d65043 100644
--- a/src/socket/coyote.ts
+++ b/src/socket/coyote.ts
@@ -11,6 +11,8 @@ let softBStrength = ref(0);        // B通道软上限
 let followAStrength = ref(false);  //跟随A通道软上限
 let followBStrength = ref(false);  //跟随B通道软上限
 
+const coyoteState = ref(false)
+
 let connectionId = ""; // 从接口获取的连接标识符
 let targetWSId = ""; // 发送目标
 let fangdou = 500; //500毫秒防抖
@@ -73,6 +75,7 @@ function createCoyoteSocket() {
                     console.log("收到targetId: " + msg.targetId + ", msg: " + msg.message);
                     qrcodeShow.value = false
                     notyf.success({message: "郊狼连接成功"})
+                    coyoteState.value = true
                 }
                 break
             case 'break':
@@ -80,6 +83,7 @@ function createCoyoteSocket() {
                     return
                 console.log("收到断开连接指令")
                 notyf.error({ message: "收到断开连接指令" })
+                coyoteState.value = false
                 //location.reload();
                 break
             case 'error':
@@ -87,6 +91,7 @@ function createCoyoteSocket() {
                     return
                 console.log("对方已断开，code：" + msg.message)
                 notyf.error({ message: "对方已断开（" + msg.message + "）" })
+                coyoteState.value = false
                 break
             case 'msg':
                 const result: { type: string; numbers: number[] }[] = []
@@ -126,11 +131,13 @@ function createCoyoteSocket() {
     wsConn.onerror = function (event) {
         console.log("WebSocket连接出错")
         notyf.error({ message: "WebSocket连接出错" })
+        coyoteState.value = false
     }
 
     wsConn.onclose = function (event) {
         console.log("WebSocket连接已关闭")
         notyf.error({ message: "WebSocket连接已关闭" })
+        coyoteState.value = false
     }
 }
 
@@ -205,6 +212,7 @@ function closeCoyoteSocket() {
     }
     wsConn = null
     notyf.success( {message: "郊狼连接已断开"} )
+    coyoteState.value = false
 }
 
 
@@ -215,6 +223,7 @@ export {
     sendWaveData,
     addOrIncrease,
     clearAB,
+    coyoteState,
     qrcodeSrc,
     qrcodeShow,
     channelAStrength,
diff --git a/src/socket/index.ts b/src/socket/index.ts
index 8eb1911..16180da 100644
--- a/src/socket/index.ts
+++ b/src/socket/index.ts
@@ -8,15 +8,19 @@ let ws: DanmakuWebSocket
 const notyf = new Notyf({ duration: 4000 })
 
 interface SettingsType {
+    version: number;
     strengthData: typeof strengthData;
     waveData: typeof waveData;
     guardLevel: number;
+    fansMedal: boolean;
 }
 
 let settings: Ref<SettingsType> = ref({
+    version: 1,
     waveData: waveData,
     strengthData: strengthData,
-    guardLevel: 0
+    guardLevel: 0,
+    fansMedal: false
 });
 
 if (window.localStorage.getItem("settings")) {
@@ -25,12 +29,33 @@ if (window.localStorage.getItem("settings")) {
 } else {
     // 如果没有，使用默认值
     settings.value = {
+        version: 1,
         waveData: waveData,
         strengthData: strengthData,
-        guardLevel: 0
+        guardLevel: 0,
+        fansMedal: false
     };
 }
 
+/**
+ * 转换大航海等级
+ * @description 由于B站返回的大航海等级是（1-总督，2-提督，3-舰长）所以要转换一下方便处理
+ * @param guardLevel
+ */
+const transformGuardLevel = (guardLevel: number) => {
+    if (guardLevel == 0) {
+        return 0
+    } else if (guardLevel == 1) {
+        return 3
+    } else if (guardLevel == 2) {
+        return 2
+    } else if (guardLevel == 3) {
+        return 1
+    } else {
+        return 0
+    }
+}
+
 /**
  * 创建socket长连接
  * @param authBody
@@ -57,9 +82,16 @@ function createSocket(authBody: string, wssLinks: string[]) {
 
             settings = window.localStorage.getItem("settings") ? ref(JSON.parse(window.localStorage.getItem("settings") || '{}')) : null
 
-            if (res.cmd == "LIVE_OPEN_PLATFORM_SEND_GIFT" && res.data.guard_level >= settings.value.guardLevel) {
+            // 粉丝勋章
+            let execute_1 = settings.value.fansMedal ? !!res.data.fans_medal_wearing_status : true
+
+            // 大航海
+            let execute_2 = transformGuardLevel(res.data.guard_level) >= settings.value.guardLevel
+
+
+            if (res.cmd == "LIVE_OPEN_PLATFORM_SEND_GIFT" && execute_1 && execute_2) {
                 if (settings && res.data.gift_id.toString() === settings.value.strengthData[0]) {
-                    // 牛哇牛哇：加强度1
+                    // 加强度1
                     try {
                         console.log("开始操作")
                         addOrIncrease(2, 1, 1)
@@ -72,7 +104,7 @@ function createSocket(authBody: string, wssLinks: string[]) {
                         notyf.error("强度操作失败！")
                     }
                 } else if (settings && res.data.gift_id.toString() === settings.value.strengthData[1]) {
-                    // 小花花：减强度1
+                    // 减强度1
                     try {
                         addOrIncrease(1, 1, 1)
                         addOrIncrease(1, 2, 1)