import { useCoHostState, CoHostLayoutTemplate } from "tuikit-atomicx-vue3";

// 获取 CoHostState 实例
const { requestHostConnection } = useCoHostState();

// 用户点击“连线”按钮，并选择了主播 B (targetLiveId)
const inviteHostB = async (targetLiveId: string) => {
  try {
    await requestHostConnection({
      liveId: targetLiveId, // 目标主播 B 的房间 ID
      layoutTemplate: CoHostLayoutTemplate.Grid, // 选择一个布局模版
      timeout: 30, // 邀请超时时间(秒)
      extensionInfo: '', // 可选扩展信息
    });
    console.log("连线邀请已发送，等待对方处理...");
  } catch (error) {
    console.error("邀请发送失败", error);
    // 可以在这里进行 Toast 提示
  }
};


import { useCoHostState, CoHostEvent } from "tuikit-atomicx-vue3";
import { onMounted, onUnmounted } from 'vue';

const { subscribeEvent, unsubscribeEvent } = useCoHostState();

const onAccepted = (eventInfo: any) => {
    console.log(`主播 ${eventInfo.invitee.userName} 同意了您的连线邀请`);
};

const onRejected = (eventInfo: any) => {
    console.log(`主播 ${eventInfo.invitee.userName} 拒绝了您的连线邀请`);
};

const onTimeout = (eventInfo: any) => {
    console.log('邀请超时，对方未回应');
};

onMounted(() => {
    subscribeEvent(CoHostEvent.onCoHostRequestAccepted, onAccepted);
    subscribeEvent(CoHostEvent.onCoHostRequestRejected, onRejected);
    subscribeEvent(CoHostEvent.onCoHostRequestTimeout, onTimeout);
});

onUnmounted(() => {
    unsubscribeEvent(CoHostEvent.onCoHostRequestAccepted, onAccepted);
    unsubscribeEvent(CoHostEvent.onCoHostRequestRejected, onRejected);
    unsubscribeEvent(CoHostEvent.onCoHostRequestTimeout, onTimeout);
});

import { useCoHostState, CoHostEvent } from "tuikit-atomicx-vue3";
import { onMounted, onUnmounted } from 'vue';

const { subscribeEvent, unsubscribeEvent } = useCoHostState();

const onRequestReceived = (eventInfo: any) => {
    const { inviter } = eventInfo;
    console.log(`收到主播 ${inviter.userName} 的连线邀请`);
    // 可以在这里弹出 Dialog 询问用户是否接受
};

onMounted(() => {
    subscribeEvent(CoHostEvent.onCoHostRequestReceived, onRequestReceived);
});

onUnmounted(() => {
    unsubscribeEvent(CoHostEvent.onCoHostRequestReceived, onRequestReceived);
});

import { useCoHostState } from "tuikit-atomicx-vue3";

// 获取 CoHostState 实例
const { acceptHostConnection, rejectHostConnection, applicant } = useCoHostState();

// 接受邀请
const acceptInvitation = async () => {
    if (applicant.value) {
        try {
            // 传入发起方的 liveId (roomId)
            await acceptHostConnection({ liveId: applicant.value.liveId });
            console.log('已接受连线');
        } catch (error) {
            console.error('接受连线失败', error);
        }
    }
 };

// 拒绝邀请
const rejectInvitation = async () => {
    if (applicant.value) {
        try {
            await rejectHostConnection({ liveId: applicant.value.liveId });
            console.log('已拒绝连线');
        } catch (error) {
            console.error('拒绝连线失败', error);
        }
    }
 };

import { useCoHostState, CoHostStatus } from "tuikit-atomicx-vue3";

// 获取 CoHostState 实例
const { exitHostConnection, coHostStatus } = useCoHostState();

// 点击“结束PK”按钮的处理函数
const stopPK = async () => {
  // 判断当前是否处于连线状态
  if (coHostStatus.value === CoHostStatus.Connected) {
    try {
      await exitHostConnection();
      console.log('已退出连线');
      // 在此处执行 UI 布局重置等业务逻辑
    } catch (error) {
      console.error('退出连线失败:', error);
    }
  }
};

import { useCoHostState, CoHostEvent } from "tuikit-atomicx-vue3";
import { onMounted, onUnmounted } from 'vue';

const { subscribeEvent, unsubscribeEvent } = useCoHostState();

const onUserLeft = (eventInfo: any) => {
    const { userInfo } = eventInfo;
    console.log(`主播 ${userInfo.userName} 已断开连线`);
    
    // 在此处恢复单主播布局，清除对方画面
};

onMounted(() => {
    // 订阅用户离开事件
    subscribeEvent(CoHostEvent.onCoHostUserLeft, onUserLeft);
});

onUnmounted(() => {
    unsubscribeEvent(CoHostEvent.onCoHostUserLeft, onUserLeft);
});