manager.py

# -*- coding: utf-8 -*-
# manager

import threading
import time
import twitcasting.connection
import datetime
import wx
import globalVars
import simpleDialog
import pathlib
import twitcasting.twitcasting
import re
import constants
import soundPlayer.player
from soundPlayer.constants import *
import soundPlayer.fxPlayer
import pyperclip
import webbrowser
import sys
from copy import deepcopy
import os
import traceback
from logging import getLogger

evtComment = 0
evtLiveInfo = 1
evtCountDown = 2
evtTyping = 3
evtPlaystatus = 4
evtError = 5

first = 0
update = 1

commentTimerInterval = 3000
liveInfoTimerInterval = 5000
countDownTimerInterval = 1000
typingTimerInterval = 5000
playstatusTimerInterval = 500
errorCheckTimerInterval = 1000

historyData = pathlib.Path(constants.HISTORY_FILE_NAME)
favoritesData = pathlib.Path(constants.FAVORITES_FILE_NAME)

# mainViewAccess
block = 0
def mainViewAccess(func):
	def wrapper(*args, **kwargs):
		global block
		block += 1
		ret = func(*args, **kwargs)
		block -= 1
		return ret
	return wrapper

class manager:
	def __init__(self, MainView):
		self.log = getLogger("%s.%s" %(constants.LOG_PREFIX, "manager"))
		self.MainView = MainView
		self.evtHandler = wx.EvtHandler()
		self.evtHandler.Bind(wx.EVT_TIMER, self.timer)
		if historyData.exists() == False:
			historyData.touch()
		self.history = historyData.read_text().split("\n")
		if len(self.history) == 1 and self.history[0] == "":
			del self.history[0]
		if favoritesData.exists() == False:
			favoritesData.touch()
		self.favorites = favoritesData.read_text().split("\n")
		if len(self.favorites) == 1 and self.favorites[0] == "":
			del self.favorites[0]
		self.myAccount = []
		for i in globalVars.app.accountManager.tokens:
			self.myAccount.append(i["user"])
		self.timers = []
		self.livePlayer = None
		self.fxPlayer = None
		self.played = False
		self.changeMenuState(False)
		if globalVars.app.config.getboolean("fx", "playStartupSound", False) == True:
			self.playFx(globalVars.app.config["fx"]["startupSound"])
		self.playStatusTimer = wx.Timer(self.evtHandler, evtPlaystatus)
		self.timers.append(self.playStatusTimer)
	
	def connect(self, userId):
		userId = userId.replace("http://twitcasting.tv/", "")
		userId = userId.replace("https://twitcasting.tv/", "")
		if "/" in userId:
			userId = userId[0:userId.find("/")]
		if globalVars.app.accountManager.hasDefaultAccount() == False:
			if len(globalVars.app.accountManager.tokens) == 0:
				simpleDialog.errorDialog(_("アカウントが登録されていません。ライブに接続する前に、設定メニューのアカウントマネージャからアカウントの登録を行ってください。"))
			else:
				simpleDialog.errorDialog(_("通信用アカウントが設定されていません。ライブに接続する前に、設定メニューのアカウントマネージャから通信用アカウントの設定を行ってください。"))
			self.MainView.createStartScreen()
			return
		self.connection = twitcasting.connection.connection(userId)
		self.errorCheckTimer = wx.Timer(self.evtHandler, evtError)
		self.timers.append(self.errorCheckTimer)
		self.errorCheckTimer.Start(errorCheckTimerInterval)
		if self.connection.connected == False:
			simpleDialog.errorDialog(_("接続に失敗しました。"))
			self.MainView.createStartScreen()
			return
		self.MainView.createMainView()
		self.changeMenuState(True)
		globalVars.app.say(userId)
		if userId not in self.history:
			self.history.insert(0, userId.lower())
		elif userId in self.history:
			del self.history[self.history.index(userId)]
			self.history.insert(0, userId.lower())
		historyMax = globalVars.app.config.getint("general", "historyMax", 10)
		if historyMax >= 0 and len(self.history) > historyMax:
			del self.history[historyMax:]
		try:
			historyData.write_text("\n".join(self.history))
		except Exception as e:
			simpleDialog.errorDialog(_("履歴データの保存に失敗しました。以下のファイルへのアクセスが可能であることを確認してください。") + "\n" + os.path.abspath(constants.HISTORY_FILE_NAME))
			traceback.print_exc()
			self.log.warning("Failed to write history data. detail:" + traceback.format_exc())
		try:
			self.elapsedTime = self.connection.movieInfo["movie"]["duration"]
		except:
			self.elapsedTime = 0
		self.countDownTimer = wx.Timer(self.evtHandler, evtCountDown)
		self.timers.append(self.countDownTimer)
		initialCommentCount = globalVars.app.config.getint("general", "initialCommentCount", 50)
		self.initialComments = self.connection.getInitialComment(initialCommentCount)
		self.addComments(self.initialComments, first)
		self.commentTimer = wx.Timer(self.evtHandler, evtComment)
		self.timers.append(self.commentTimer)
		self.commentTimer.Start(commentTimerInterval)
		self.liveInfoTimer = wx.Timer(self.evtHandler, evtLiveInfo)
		self.timers.append(self.liveInfoTimer)
		self.liveInfoTimer.Start(liveInfoTimerInterval)
		self.createLiveInfoList(first)
		if self.connection.isLive == True:
			globalVars.app.say(_("接続。現在配信中。"))
			self.resetTimer()
			self.countDownTimer.Start(countDownTimerInterval)
			globalVars.app.say(_("タイマー開始。"))
			try:
				globalVars.app.say(_("残り時間：%s") %self.formatTime(self.remainingTime).strftime("%H:%M:%S"))
			except:
				globalVars.app.say(_("配信時間が４時間を超えているため、タイマーを使用できません。"))
		else:
			self.resetTimer()
			globalVars.app.say(_("接続。現在オフライン。"))
		if self.hasEnoughCoins(self.connection.coins) == True:
			globalVars.app.say(_("完走に必用なコインが集まっています。"))
		self.oldCoins = self.connection.coins
		self.oldCategory = self.connection.categoryName
		self.oldViewers = self.connection.viewers
		self.oldIsLive = self.connection.isLive
		self.oldMovieId = self.connection.movieId
		self.oldSubtitle = self.connection.subtitle
		self.oldItem = self.connection.item
		self.createItemList(first)
		self.typingTimer = wx.Timer(self.evtHandler, evtTyping)
		self.timers.append(self.typingTimer)
		self.typingTimer.Start(typingTimerInterval)
		titlebar = globalVars.app.config.getint("general", "titlebar", 1, 0, 2)
		if titlebar == constants.TB_USER:
			self.MainView.hFrame.SetTitle("%s - %s" %(self.connection.userId, constants.APP_NAME))
		if globalVars.app.config.getboolean("livePlay", "autoPlay", False) == True and self.connection.movieInfo["movie"]["hls_url"] != None:
			self.play()
		if globalVars.app.config.getboolean("general", "openlivewindow", False) == True:
			self.openLiveWindow()
		self.connection.start()
		self.itemOperation = ItemOperation(self)
		self.itemOperation.start()
		self.items = []

	def disconnect(self):
		self.connection.running = False
		self.itemOperation.running = False
		if self.livePlayer != None:
			self.stop()
			self.livePlayer.exit()
		self.livePlayer = None
		for i in self.timers:
			i.Stop()
		self.MainView.Clear()
		self.MainView.hFrame.SetTitle(constants.APP_NAME)
		self.MainView.createStartScreen()
		self.changeMenuState(False)
		self.connection.connected = False

	@mainViewAccess
	def getNewComments(self):
		limit = len(self.connection.comments) - self.MainView.commentList.GetItemCount()
		result = self.connection.comments[:limit]
		result.reverse()
		return result

	@mainViewAccess
	def addComments(self, commentList, mode):
		for commentObject in commentList:
			commentData = self.getCommentdata(commentObject)
			self.MainView.commentList.InsertItem(0	, "")
			self.MainView.commentList.SetItem(0, 0, commentData["dispname"])
			self.MainView.commentList.SetItem(0, 1, commentData["message"])
			self.MainView.commentList.SetItem(0, 2, commentData["time"])
			self.MainView.commentList.SetItem(0, 3, commentData["user"])
			self.MainView.commentList.Focus(self.MainView.commentList.GetFocusedItem() + 1)
			sels = self.MainView.commentList.getItemSelections()
			for i in sels:
				self.MainView.commentList.Select(i, 0)
			for i in sels:
				self.MainView.commentList.Select(i + 1, 1)
			itemLimit = 100000
			if self.MainView.commentList.GetItemCount() > itemLimit:
				self.MainView.commentList.DeleteItem(itemLimit)
			if mode == update:
				if globalVars.app.config.getboolean("autoReadingOptions", "readReceivedComments", True) == True:
					if globalVars.app.config.getboolean("autoReadingOptions", "readMyComment", True) == False:
						for i in self.myAccount:
							if commentObject["from_user"]["id"] == i["id"]:
								self.playCommentReceivedSoundIfSkipped()
								return
					for i in self.myAccount:
						if commentObject["from_user"]["id"] == i["id"]:
							readMentions = globalVars.app.config.getint("autoReadingOptions", "readMentions_myLive", 1)
					else:
						readMentions = globalVars.app.config.getint("autoReadingOptions", "readMentions_otherLive", 1)
					if readMentions == 2:
						mentionMe = False
						for i in self.myAccount:
							if "@%s " %(i["screen_id"]) in commentData["message"]:
								mentionMe = True
						if mentionMe == False and "@" in commentObject["message"]:
							self.playCommentReceivedSoundIfSkipped()
							return
					elif readMentions == 0:
						if "@" in commentObject["message"]:
							self.play()
							return
					self.readComment(commentData)
		if globalVars.app.config.getboolean("fx", "playCommentReceivedSound", True) == True and mode == update and len(commentList) != 0:
			self.playFx(globalVars.app.config["fx"]["commentReceivedSound"])

	def getCommentdata(self, commentObject):
		commentData = {
			"dispname": commentObject["from_user"]["name"],
			"message": commentObject["message"],
			"time": datetime.datetime.fromtimestamp(commentObject["created"]).strftime("%H:%M:%S"),
			"user": commentObject["from_user"]["screen_id"]
		}
		for i in globalVars.app.config.items("nameReplace"):
			if i[0] == commentData["user"]:
				commentData["dispname"] = i[1]
		for i in globalVars.app.config.items("commentReplaceBasic"):
			commentData["message"] = commentData["message"].replace(i[0], i[1])
		for i in globalVars.app.config.items("commentReplaceReg"):
			commentData["message"] = re.sub(i[0], i[1], commentData["message"])
		urls = list(commentObject["urls"])
		domains = re.finditer("(https?://[^/]+/)", commentData["message"])
		for url in urls:
			for domain in domains:
				if len(globalVars.app.config["commentReplaceSpecial"]["url"]) != 0:
					commentData["message"] = re.sub(url.group(), globalVars.app.config["commentReplaceSpecial"]["url"], commentData["message"])
				if globalVars.app.config.getboolean("commentReplaceSpecial", "deleteProtcolName", False) == True:
					commentData["message"] = commentData["message"].replace("http://", "")
					commentData["message"] = commentData["message"].replace("https://", "")
				if globalVars.app.config.getboolean("commentReplaceSpecial", "onlyDomain", False) == True:
					commentData["message"] = commentData["message"].replace(url.group(), domain.group())
		return commentData

	def readComment(self, commentData, speech = True):
		announceText = globalVars.app.config["autoReadingOptions"]["receivedCommentsAnnouncement"]
		announceText = announceText.replace("$dispname", commentData["dispname"])
		announceText = announceText.replace("$message", commentData["message"])
		announceText = announceText.replace("$time", commentData["time"])
		announceText = announceText.replace("$user", commentData["user"])
		if speech == False:
			return announceText
		globalVars.app.say(announceText)

	@mainViewAccess
	def createLiveInfoList(self, mode):
		result = [
			_("タイトル：%s") %(self.connection.movieInfo["movie"]["title"]),
			_("テロップ：%s") %(self.connection.movieInfo["movie"]["subtitle"]),
			_("閲覧者数：現在%(current)d人、合計%(total)d人") %{"current": self.connection.movieInfo["movie"]["current_view_count"], "total": self.connection.movieInfo["movie"]["total_view_count"]},
			_("カテゴリ：%s") %(self.connection.categoryName),
			_("コメント：%d件") %(self.connection.movieInfo["movie"]["comment_count"]),
			self.connection.movieInfo["broadcaster"]["screen_id"]
		]
		if self.connection.movieInfo["movie"]["is_live"] == True:
			result.insert(0, _("現在配信中"))
		else:
			result.insert(0, _("オフライン"))
		try:
			result.insert(1, _("経過時間：%s") %(self.formatTime(self.elapsedTime).strftime("%H:%M:%S")))
			result.insert(2, _("残り時間：%s") %(self.formatTime(self.remainingTime).strftime("%H:%M:%S")))
		except:
			result.insert(2, _("残り時間：無制限"))
		if self.connection.movieInfo["movie"]["is_collabo"] == True:
			result.insert(-1, _("コラボ可能"))
		else:
			result.insert(-1, _("コラボ不可"))
		for i in range(0, len(result)):
			result[i] = result[i].replace("None", _("なし"))
		if mode == first:
			for i in range(0, len(result)):
				self.MainView.liveInfo.Insert(result[i], i)
		elif mode == update:
			for i in range(0, len(result)):
				bool = result[i] == self.MainView.liveInfo.GetString(i)
				if bool == False:
					self.MainView.liveInfo.SetString(i, result[i])

	@mainViewAccess
	def createItemList(self, mode):
		result = []
		for i in self.connection.item:
			result.append(i["name"] + ":" + str(i["count"]))
		result.sort()
		mp = None
		for i in range(len(result)):
			if result[i][0:2] == "MP":
				mp = i
				break
		if type(mp) == int:
			result[mp], result[-1] = result[-1], result[mp]
		if mode == update:
			cursor = self.MainView.itemList.GetSelection()
			self.MainView.itemList.Clear()
		for i in range(0, len(result)):
			self.MainView.itemList.Insert(result[i], i)
		if mode == update and cursor != wx.NOT_FOUND and self.MainView.itemList.GetCount() - 1 >= cursor:
			self.MainView.itemList.SetSelection(cursor)

	def postComment(self, commentBody, idx):
		if self.connection.movieId == None:
			simpleDialog.errorDialog(_("コメント投稿に失敗しました。次にこのユーザがライブを行うまで、コメントを投稿できません。"))
			return False
		commentBody = commentBody.strip()
		if len(commentBody) == 0:
			simpleDialog.errorDialog(_("コメントが入力されていません。"))
			return False
		elif len(commentBody) > 140:
			simpleDialog.errorDialog(_("１４０字を超えるコメントは投稿できません。現在%s文字のコメントが入力されています。") %(str(len(commentBody))))
			return False
		result = self.connection.postComment(commentBody, idx)
		if "error" in result:
			if result["error"]["code"] == 1001 and "comment" in result["error"]["details"] and "length" in result["error"]["details"]["comment"] :
				simpleDialog.errorDialog(_("コメント文字数が１４０字を超えているため、コメントを投稿できません。"))
				return False
			elif result["error"]["code"] == 404:
				simpleDialog.errorDialog(_("コメント投稿に失敗しました。次にこのユーザがライブを行うまで、コメントを投稿できません。"))
				return False
			else:
				simpleDialog.errorDialog(_("エラーが発生しました。詳細：%s") %(str(result)))
				return False
		else:
			if globalVars.app.config.getboolean("fx", "playCommentPostedSound", True) == True:
				self.playFx(globalVars.app.config["fx"]["commentPostedSound"])
			return True

	def formatTime(self, second):
		if second<0:
			raise ValueError("second must be larger than 0.")
		time = datetime.time(hour = int(second / 3600), minute = int(second % 3600 / 60), second = int(second % 3600 % 60))
		return time

	@mainViewAccess
	def deleteComment(self):
		tmp = len(self.connection.comments) - self.MainView.commentList.GetItemCount()
		selected = self.MainView.commentList.getItemSelections()
		selected.reverse()
		success = 0
		fail = 0
		for i in selected:
			lstidx = i + tmp
			result = self.connection.deleteComment(self.connection.comments[lstidx])
			if result == False:
				fail += 1
			else:
				success += 1
				del self.connection.comments[lstidx]
				self.MainView.commentList.DeleteItem(i)
		if success == 0:
			simpleDialog.errorDialog(_("コメントの削除に失敗しました。これらのコメントを削除する権限がありません。"))
		elif success > 0 and fail > 0:
			simpleDialog.errorDialog(_("%d個のコメントを削除できませんでした。これらのコメントを削除する権限がありません。") %fail)

	@mainViewAccess
	def copyComment(self):
		selections = self.MainView.commentList.getItemSelections()
		tmplst = deepcopy(self.connection.comments)
		if len(tmplst) > self.MainView.commentList.GetItemCount():
			tmplst = tmplst[-1 * self.MainView.commentList.GetItemCount():]
		items = [self.readComment(self.getCommentdata(tmplst[i]), False) for i in selections]
		pyperclip.copy("\n\n".join(items))

	def resetTimer(self, speech = False):
		if speech == True:
			globalVars.app.say(_("タイマーリセット。"))
		timerType = globalVars.app.config.getint("general", "timerType", 0)
		if self.connection.isLive == False:
			self.elapsedTime = 0
			self.remainingTime = 0
			return
		tmp = 1800 - (self.elapsedTime % 1800)
		if timerType == 0:
			totalTime = self.elapsedTime + tmp
		else:
			totalTime = self.elapsedTime + tmp + (int(self.connection.coins / 5) * 1800)
		if totalTime > 14400:
			totalTime = 14400
		self.elapsedTime = self.elapsedTime + 1
		self.remainingTime = totalTime - self.elapsedTime
		if timerType == 2:
			if self.remainingTime > 1800 and int(self.remainingTime % 1800) == 180:
				self.sayRemainingTime()
				if self.remainingTime >= 1800:
					globalVars.app.say(_("コインが%d枚あるので延長可能です。") %(self.connection.coins))
			return
		announceTime = [900, 600, 300, 180, 60, 30, 10]
		for i in announceTime:
			if self.remainingTime % 1800 == i:
				self.sayRemainingTime()
				if self.remainingTime >= 1800 and timerType != 0:
					globalVars.app.say(_("コインが%d枚あるので延長可能です。") %(self.connection.coins))
		if self.remainingTime > 0 and self.remainingTime % 1800 == 0:
			globalVars.app.say(_("30分が経過しました。"))

	def clearHistory(self):
		self.history.clear()
		try:
			historyData.write_text("\n".join(self.history))
		except Exception as e:
			simpleDialog.errorDialog(_("履歴データの保存に失敗しました。以下のファイルへのアクセスが可能であることを確認してください。") + "\n" + os.path.abspath(constants.HISTORY_FILE_NAME))
			traceback.print_exc()
			self.log.warning("Failed to write history data. detail:" + traceback.format_exc())

	def addFavorites(self):
		self.favorites.insert(0, self.connection.userId.lower())
		self.favorites.sort()
		try:
			favoritesData.write_text("\n".join(self.favorites))
		except Exception as e:
			simpleDialog.errorDialog(_("お気に入りデータの保存に失敗しました。以下のファイルへのアクセスが可能であることを確認してください。") + "\n" + os.path.abspath(constants.FAVORITES_FILE_NAME))
			traceback.print_exc()
			self.log.warning("Failed to write favorites data. detail:" + traceback.format_exc())

	def deleteFavorites(self, index):
		del self.favorites[index]
		self.favorites.sort()
		try:
			favoritesData.write_text("\n".join(self.favorites))
		except Exception as e:
			simpleDialog.errorDialog(_("お気に入りデータの保存に失敗しました。以下のファイルへのアクセスが可能であることを確認してください。") + "\n" + os.path.abspath(constants.FAVORITES_FILE_NAME))
			traceback.print_exc()
			self.log.warning("Failed to write favorites data. detail:" + traceback.format_exc())

	def clearFavorites(self):
		self.favorites.clear()
		try:
			favoritesData.write_text("\n".join(self.favorites))
		except Exception as e:
			simpleDialog.errorDialog(_("お気に入りデータの保存に失敗しました。以下のファイルへのアクセスが可能であることを確認してください。") + "\n" + os.path.abspath(constants.FAVORITES_FILE_NAME))
			traceback.print_exc()
			self.log.warning("Failed to write favorites data. detail:" + traceback.format_exc())

	def sayRemainingTime(self):
		if globalVars.app.config.getboolean("fx", "playTimersound") == True:
			self.playFx(globalVars.app.config["fx"]["timerSound"])
		remainingTime = self.formatTime(self.remainingTime % 1800)
		if remainingTime.minute == 0:
			string = _("残り%s秒です。") %(str(remainingTime.second))
		elif remainingTime.second == 0:
			string = _("残り%s分です。") %(str(remainingTime.minute))
		else:
			string = _("残り%(minutes)s分%(seconds)s秒です。") %{"minutes": str(remainingTime.minute), "seconds": str(remainingTime.second)}
		globalVars.app.say(string)

	def timer(self, event):
		timer = event.GetTimer()
		id = timer.GetId()
		if id == evtComment:
			self.checkComment()
		elif id == evtLiveInfo:
			self.checkIsLive()
			self.checkSubtitle()
			self.checkCategory()
			self.checkMovieId()
			self.checkViewers()
			self.createLiveInfoList(update)
			self.createItemList(update)
			self.checkCoins()
		elif id == evtCountDown:
			self.resetTimer()
			try:
				self.MainView.liveInfo.SetString(1, _("経過時間：%s") %(self.formatTime(self.elapsedTime).strftime("%H:%M:%S")))
				self.MainView.liveInfo.SetString(2, _("残り時間：%s") %(self.formatTime(self.remainingTime).strftime("%H:%M:%S")))
				titlebar = globalVars.app.config.getint("general", "titlebar", 1, 0, 2)
				if titlebar == constants.TB_TIME:
					t = self.formatTime(self.remainingTime)
					map = {"hour": t.hour, "minute": t.minute, "second": t.second}
					if t.hour > 0:
						disp = _("残り%(hour)d時間%(minute)d分%(second)d秒") %map
					elif t.minute > 0:
						disp = _("残り%(minute)d分%(second)d秒") %map
					else:
						disp = _("残り%(second)d秒") %map
					self.MainView.hFrame.SetTitle(disp + " - " + constants.APP_NAME)
			except:
				self.MainView.liveInfo.SetString(2, _("残り時間：無制限"))
		elif id == evtTyping:
			if self.connection.typingUser != "":
				if globalVars.app.config.getboolean("autoReadingOptions", "readTypingUser", False) == True:
					globalVars.app.say(_("%sさんが入力中") %(typingUser))
				if globalVars.app.config.getboolean("fx", "playTypingSound", True) == True:
					self.playFx(globalVars.app.config["fx"]["typingSound"])
		elif id == evtPlaystatus:
			if self.livePlayer.getStatus() != PLAYER_STATUS_PLAYING and self.livePlayer.getStatus() != PLAYER_STATUS_LOADING:
				self.stop()
		elif id == evtError:
			self.checkError()

	def checkComment(self):
		newComments = self.getNewComments()
		self.addComments(newComments, update)

	def checkIsLive(self):
		self.newIsLive = self.connection.isLive
		if self.oldIsLive == True and self.newIsLive == False:
			globalVars.app.say(_("ライブ終了。"))
			self.countDownTimer.Stop()
			titlebar = globalVars.app.config.getint("general", "titlebar", 1, 0, 2)
			if titlebar == constants.TB_TIME:
				self.MainView.hFrame.SetTitle("%s" %constants.APP_NAME)
			self.resetTimer()
			self.commentTimer.Stop()
			if self.livePlayer != None and self.livePlayer.getStatus() == PLAYER_STATUS_PLAYING:
				self.played = True
				self.stop()
		elif self.oldIsLive == False and self.newIsLive == True:
			globalVars.app.say(_("ライブ開始。"))
			if self.played == True:
				self.play()
			self.countDownTimer.Start(countDownTimerInterval)
			self.commentTimer.Start(commentTimerInterval)
		self.oldIsLive = self.newIsLive

	def checkSubtitle(self):
		self.newSubtitle = self.connection.subtitle
		if self.newSubtitle != self.oldSubtitle and self.connection.isLive == True:
			if self.newSubtitle == None:
				globalVars.app.say(_("テロップ削除"))
			else:
				globalVars.app.say(_("テロップ変更。"))
				globalVars.app.say(self.newSubtitle)
			if globalVars.app.config.getboolean("fx", "playothersound", True) == True:
				self.playFx(globalVars.app.config["fx"]["othersound"])
		self.oldSubtitle = self.newSubtitle

	def checkCategory(self):
		self.newCategory = self.connection.categoryName
		if self.newCategory != self.oldCategory and self.connection.isLive == True:
			globalVars.app.say(_("カテゴリ変更：%s") %self.newCategory)
			if globalVars.app.config.getboolean("fx", "playothersound", True) == True:
				self.playFx(globalVars.app.config["fx"]["othersound"])
		self.oldCategory = self.newCategory

	def checkMovieId(self):
		self.newMovieId = self.connection.movieId
		if self.newMovieId != self.oldMovieId:
			if self.connection.isLive == True:
				globalVars.app.say(_("次のライブが開始されました。"))
				self.elapsedTime = self.connection.movieInfo["movie"]["duration"]
				if self.livePlayer != None and self.livePlayer.getStatus() == PLAYER_STATUS_PLAYING:
					self.stop()
					self.play()
		self.oldMovieId = self.newMovieId

	def checkViewers(self):
		self.newViewers = self.connection.viewers
		if self.newViewers != self.oldViewers and self.connection.isLive == True:
			if self.newViewers > self.oldViewers:
				if globalVars.app.config.getboolean("fx", "playviewersincreasedsound", True) == True:
					self.playFx(globalVars.app.config["fx"]["viewersincreasedSound"])
				if globalVars.app.config.getboolean("autoReadingOptions", "readviewersincreased", True) == True:
					viewersInfo = globalVars.app.config["autoReadingOptions"]["viewersincreasedAnnouncement"]
					viewersInfo = viewersInfo.replace("$viewers", str(self.newViewers))
					globalVars.app.say(viewersInfo)
			elif self.newViewers < self.oldViewers:
				if globalVars.app.config.getboolean("fx", "playviewersdecreasedsound", True) == True:
					self.playFx(globalVars.app.config["fx"]["viewersdecreasedSound"])
				if globalVars.app.config.getboolean("autoReadingOptions", "readviewersdecreased", True) == True:
					viewersInfo = globalVars.app.config["autoReadingOptions"]["viewersDecreasedAnnouncement"]
					viewersInfo = viewersInfo.replace("$viewers", str(self.newViewers))
					globalVars.app.say(viewersInfo)
		self.oldViewers = self.newViewers

	def checkCoins(self):
		self.newCoins = self.connection.coins
		if self.newCoins != self.oldCoins:
			if self.newCoins < self.oldCoins:
				globalVars.app.say(_("コイン消費"))
			elif self.newCoins > self.oldCoins:
				c = [i for i in range(self.oldCoins + 1, self.newCoins + 1) if i % 5 == 0]
				if len(c) > 0:
					if self.hasEnoughCoins(self.oldCoins) == False and self.hasEnoughCoins(c[-1]) == True:
						globalVars.app.say(_("完走に必要なコイン%d枚が集まりました。") %(c[-1]))
					else:
						globalVars.app.say(_("コインが%d枚集まりました。") %(c[-1]))

		self.oldCoins = self.newCoins

	def play(self):
		if self.livePlayer == None:
			self.livePlayer = soundPlayer.player.player()
			self.livePlayer.setAmp(globalVars.app.config.getint("livePlay", "defaultVolume", 100))
			self.livePlayer.setHlsTimeout(globalVars.app.config.getint("livePlay", "audioDelay", 7))
			self.changeDevice(globalVars.app.config["livePlay"]["device"])
		if self.livePlayer.getStatus() != PLAYER_STATUS_PLAYING:
			if self.connection.movieInfo["movie"]["hls_url"] == None:
				simpleDialog.errorDialog(_("再生URLを取得できません。"))
				return
			setSource = self.livePlayer.setSource(self.connection.movieInfo["movie"]["hls_url"])
			if setSource == False:
				simpleDialog.errorDialog(_("再生に失敗しました。"))
				return
			self.livePlayer.play()
			globalVars.app.say(_("再生"))
		self.MainView.menu.EnableMenu("PLAY", False)
		self.MainView.menu.EnableMenu("STOP", True)
		self.MainView.menu.EnableMenu("VOLUME_UP", True)
		self.MainView.menu.EnableMenu("VOLUME_DOWN", True)
		self.MainView.menu.EnableMenu("RESET_VOLUME", True)
		self.playStatusTimer.Start(playstatusTimerInterval)

	def stop(self):
		if self.playStatusTimer.IsRunning() == True:
			self.playStatusTimer.Stop()
		if self.livePlayer.getStatus() != PLAYER_STATUS_STOPPED:
			self.livePlayer.stop()
			globalVars.app.say(_("停止"))
		self.MainView.menu.EnableMenu("STOP", False)
		self.MainView.menu.EnableMenu("PLAY", True)
		self.MainView.menu.EnableMenu("VOLUME_UP", False)
		self.MainView.menu.EnableMenu("VOLUME_DOWN", False)
		self.MainView.menu.EnableMenu("RESET_VOLUME", False)

	def volumeUp(self):
		self.livePlayer.setAmp(self.livePlayer.getConfig(PLAYER_CONFIG_AMP) + 10)
		globalVars.app.say(_("音量%d") %self.livePlayer.getConfig(PLAYER_CONFIG_AMPVOL), True)

	def volumeDown(self):
		self.livePlayer.setAmp(self.livePlayer.getConfig(PLAYER_CONFIG_AMP) - 10)
		globalVars.app.say(_("音量%d") %self.livePlayer.getConfig(PLAYER_CONFIG_AMPVOL), True)

	def resetVolume(self):
		self.livePlayer.setAmp(100)

	def changeDevice(self, deviceName = ""):
		try:
			if deviceName == "":
				result = self.livePlayer.setDevice(PLAYER_DEFAULT_SPEAKER)
			else:
				result = self.livePlayer.setDeviceByName(deviceName)
		except AttributeError:
			result = True
		if result == True:
			if deviceName == "":
				globalVars.app.config["livePlay"]["device"] = ""
			else:
				globalVars.app.config["livePlay"]["device"] = deviceName
		else:
			self.changeDevice()

	def playFx(self, filePath = ""):
		if globalVars.app.config.getboolean("fx", "syncAudioDevice", False) == True and globalVars.app.config["livePlay"]["device"] != "":
			device = globalVars.app.config["livePlay"]["device"]
		else:
			device = PLAYER_DEFAULT_SPEAKER
		soundPlayer.fxPlayer.playFx(filePath, device, globalVars.app.config.getint("fx", "fxVolume", 100, 0, 100))

	def playCommentReceivedSoundIfSkipped(self):
		if globalVars.app.config.getboolean("fx", "playcommentreceivedsound", True) == True and globalVars.app.config.getboolean("fx", "playcommentreceivedsoundifskipped", False) == True:
			self.playFx(globalVars.app.config["fx"]["commentreceivedsound"])
	def changeMenuState(self, connectionState):
		if connectionState == False:
			menuItems = {
				"CONNECT": True,
				"VIEW_HISTORY": True,
				"VIEW_FAVORITES": True,
				"DISCONNECT": False,
				"PLAY": False,
				"STOP": False,
				"VOLUME_UP": False,
				"VOLUME_DOWN": False,
				"RESET_VOLUME": False,
				"COPY_COMMENT": False,
				"VIEW_COMMENT": False,
				"REPLY2SELECTED_COMMENT": False,
				"DELETE_SELECTED_COMMENT": False,
				"SELECT_ALL_COMMENT": False,
				"REPLY2BROADCASTER": False,
				"VIEW_BROADCASTER": False,
				"OPEN_LIVE": False,
				"ADD_FAVORITES": False,
				"POST_ITEM": False,
				"ACCOUNT_MANAGER": True,
			}
		elif connectionState == True:
			menuItems = {
				"CONNECT": False,
				"VIEW_HISTORY": False,
				"VIEW_FAVORITES": False,
				"DISCONNECT": True,
				"PLAY": True,
				"REPLY2BROADCASTER": True,
				"VIEW_BROADCASTER": True,
				"OPEN_LIVE": True,
				"ADD_FAVORITES": True,
				"POST_ITEM": True,
				"ACCOUNT_MANAGER": False,
			}
		for key, value in menuItems.items():
			self.MainView.menu.EnableMenu(key, value)

	def openLiveWindow(self):
		webbrowser.open("https://twitcasting.tv/%s" %(self.connection.movieInfo["broadcaster"]["screen_id"]))

	def hasEnoughCoins(self, count):
		current = (self.elapsedTime + (1800 - (self.elapsedTime % 1800))) // 1800 - 1
		current = current * 5
		return current + count >= 35

	def refreshReplaceSettings(self):
		if hasattr(self, "connection") == False or hasattr(self.MainView, "commentList") == False or self.MainView.commentList == None:
			return
		tmplst = deepcopy(self.connection.comments)
		if len(tmplst) > self.MainView.commentList.GetItemCount():
			tmplst = tmplst[-1 * self.MainView.commentList.GetItemCount():]
		for idx in range(len(tmplst)):
			name = tmplst[idx]["from_user"]["name"]
			for i in globalVars.app.config.items("nameReplace"):
				if i[0] == tmplst[idx]["from_user"]["screen_id"]:
					name = i[1]
			self.MainView.commentList.SetItem(idx, 0, name)
			body = tmplst[idx]["message"]
			for i in globalVars.app.config.items("commentReplaceBasic"):
				body = body.replace(i[0], i[1])
			for i in globalVars.app.config.items("commentReplaceReg"):
				body = re.sub(i[0], i[1], body)
			urls = list(tmplst[idx]["urls"])
			domains = re.finditer("(https?://[^/]+/)", body)
			for url in urls:
				for domain in domains:
					if len(globalVars.app.config["commentReplaceSpecial"]["url"]) != 0:
						body = re.sub(url.group(), globalVars.app.config["commentReplaceSpecial"]["url"], body)
					if globalVars.app.config.getboolean("commentReplaceSpecial", "deleteProtcolName", False) == True:
						body = body.replace("http://", "")
						body = body.replace("https://", "")
					if globalVars.app.config.getboolean("commentReplaceSpecial", "onlyDomain", False) == True:
						body = body.replace(url.group(), domain.group())
			self.MainView.commentList.SetItem(idx, 1, body)

	def checkError(self):
		code = self.connection.errorFlag
		if code != 0:
			self.errorCheckTimer.Stop()
			if code == 1000:
				simpleDialog.errorDialog(_("アクセストークンが不正です。設定メニューのアカウントマネージャから、再度アカウントの追加を行ってください。"))
			elif code == 2000:
				simpleDialog.errorDialog(_("APIの実行回数が上限に達しました。しばらくたってから、再度実行してください。"))
			elif code == 500:
				simpleDialog.errorDialog(_("ツイキャスAPIが500エラーを返しました。しばらく待ってから、再度接続してください。"))
			elif code == 2001:
				simpleDialog.errorDialog(_("現在TCVは使用できません。開発者に連絡してください。"))
				sys.exit(-1)
			else:
				detail = {
					1001: "Validation Error",
					1002: "Invalid WebHook URL",
					2002: "Protected",
					2003: "Duplicate",
					2004: "Too Many Comments",
					2005: "Out Of Scope",
					2006: "Email Unverified",
					400: "Bad Request",
					403: "Forbidden",
					404: "Not Found",
				}
				simpleDialog.errorDialog(_("ツイキャスAPIとの通信中にエラーが発生しました。詳細：%s") %(detail[code]))
			self.disconnect()

	def canExit(self):
		return block == 0

class ItemOperation(threading.Thread):
	def __init__(self, manager):
		super().__init__(daemon=True)
		self.manager = manager
		self.running = False

	def checkItem(self):
		self.manager.newItem = self.manager.connection.item
		receivedItem = []
		for new in self.manager.newItem:
			if new["id"] not in [i["id"] for i in self.manager.oldItem]:
				receivedItem.append({"id": new["id"], "name": new["name"], "count": new["count"]})
			for old in self.manager.oldItem:
				if new["id"] == old["id"] and new["count"] > old["count"]:
					receivedItem.append({"id": new["id"], "name": new["name"], "count": new["count"] - old["count"]})
		for i in receivedItem:
			if i["name"] == "MP":
				continue
			id = i["id"]
			name = i["name"]
			count = i["count"]
			users = self.manager.connection.getItemPostedUser(id, count)
			items = []
			for i in range(count):
				items.append({
					"user": users[i],
					"item": name,
				})
			self.manager.items = items + self.manager.items
			readItemPostedUser = globalVars.app.config.getint("autoReadingOptions", "readItemPostedUser", 0)
			multiUser = False
			if len(users) > 1:
				for k in range(1, len(users) - 1):
					if users[0] != users[k]:
						multiUser = True
						break
			readReceivedItems = globalVars.app.config.getboolean("autoReadingOptions", "readReceivedItems", True)
			if readReceivedItems == True:
				if readItemPostedUser == 0:
					if count == 1:
						globalVars.app.say(_("%sをもらいました。") %name)
					else:
						globalVars.app.say(_("%(name)sを%(count)i個もらいました。") %{"name": name, "count": count})
				else:
					if readItemPostedUser == 1:
						users[0] = twitcasting.twitcasting.GetUserInfo(users[0])["user"]["screen_id"]
					elif readItemPostedUser == 2:
						users[0] = twitcasting.twitcasting.GetUserInfo(users[0])["user"]["name"]
					if multiUser == False:
						if count == 1:
							globalVars.app.say(_("%(user)sさんから%(item)sをもらいました。") %{"user": users[0], "item": name})
						else:
							globalVars.app.say(_("%(user)sさんから%(item)sを%(count)i個もらいました。") %{"user": users[0], "item": name, "count": count})
					else:
						if count == 1:
							globalVars.app.say(_("%(user)sさんなどから%(item)sをもらいました。") %{"user": users[0], "item": name})
						else:
							globalVars.app.say(_("%(user)sさんなどから%(item)sを%(count)i個もらいました。") %{"user": users[0], "item": name, "count": count})
		if globalVars.app.config.getboolean("fx", "playItemReceivedSound", True) == True and len(receivedItem) != 0:
			self.manager.playFx(globalVars.app.config["fx"]["itemReceivedSound"])
		self.manager.oldItem = self.manager.newItem

	def run(self):
		self.running = True
		while self.running:
			time.sleep(5)
			self.checkItem()