thedesk/app/js/tl/notification.js

//通知
//取得+Streaming接続
function notf(acct_id, tlid, sys) {
	if (sys == 'direct') {
		notfColumn(acct_id, tlid, sys)
	} else {
		notfCommon(acct_id, tlid, sys)
	}
}
function notfColumn(acct_id, tlid, sys) {
	todo('Notifications Loading...')
	var native = localStorage.getItem('nativenotf')
	var at = localStorage.getItem('acct_' + acct_id + '_at')
	if (!native) {
		native = 'yes'
	}
	var domain = localStorage.getItem('domain_' + acct_id)
	var httpreq = new XMLHttpRequest()
	if (localStorage.getItem('mode_' + domain) == 'misskey') {
		var misskey = true
		var start = 'https://' + domain + '/api/i/notifications'
		httpreq.open('POST', start, true)
		httpreq.setRequestHeader('Content-Type', 'application/json')
		var body = JSON.stringify({
			i: at
		})
	} else {
		var misskey = false
		if (localStorage.getItem('exclude-' + tlid)) {
			var exc = localStorage.getItem('exclude-' + tlid)
		} else {
			var exc = ''
		}
		var start = 'https://' + domain + '/api/v1/notifications' + exc
		httpreq.open('GET', start, true)
		httpreq.setRequestHeader('Content-Type', 'application/json')
		httpreq.setRequestHeader('Authorization', 'Bearer ' + at)
		var body = ''
	}

	httpreq.responseType = 'json'
	httpreq.send(body)
	httpreq.onreadystatechange = function() {
		if (httpreq.readyState === 4) {
			var json = httpreq.response
			if (this.status !== 200) {
				setLog(start, this.status, this.response)
			}
			var max_id = httpreq.getResponseHeader('link')
			if (max_id) {
				max_id = max_id.match(/[?&]{1}max_id=([0-9]+)/)[1]
			}
			if (json[0]) {
				var templete = ''
				var lastnotf = localStorage.getItem('lastnotf_' + acct_id)
				localStorage.setItem('lastnotf_' + acct_id, json[0].id)
				Object.keys(json).forEach(function(key) {
					var obj = json[key]
					if (lastnotf == obj.id && key > 0 && native == 'yes') {
						var ct = key
						if (key > 14) {
							ct = '15+'
						}
						var os = localStorage.getItem('platform')
						var options = {
							body: ct + lang.lang_notf_new,
							icon: localStorage.getItem('prof_' + acct_id)
						}
						var n = new Notification('TheDesk:' + domain, options)
					}
					var mute = getFilterTypeByAcct(acct_id, 'notif')
					if (obj.type != 'follow') {
						if (misskey) {
							templete = templete + misskeyParse([obj], 'notf', acct_id, tlid, -1, mute)
						} else {
							templete = templete + parse([obj], 'notf', acct_id, tlid, -1, mute)
						}
					} else {
						if (misskey) {
							templete = templete + misskeyUserparse([obj], 'notf', acct_id, tlid, -1, mute)
						} else {
							templete = templete + userparse([obj.account], 'notf', acct_id, tlid, -1)
						}
					}
				})
				templete = templete + '<div class="hide notif-marker" data-maxid="' + max_id + '"></div>'
				$('#timeline_' + tlid).html(templete)
				$('#landing_' + tlid).hide()
				jQuery('time.timeago').timeago()
			}
			$('#notf-box').addClass('fetched')
			todc()
			//Markers
			var markers = localStorage.getItem('markers')
			if (markers == 'yes') {
				markers = true
			} else {
				markers = false
			}
			if (markers) {
				getMarker(tlid, 'notf', acct_id)
			}
		}
	}
	if (!misskey) {
		if (localStorage.getItem('streaming_' + acct_id)) {
			var wss = localStorage.getItem('streaming_' + acct_id)
		} else {
			var wss = 'wss://' + domain
		}
		var start = wss + '/api/v1/streaming/?stream=user&access_token=' + at
	} else {
		var start = 'wss://' + domain + '/?i=' + at
	}
}
function notfCommon(acct_id, tlid, sys) {
	todo('Notifications Loading...')
	var native = localStorage.getItem('nativenotf')
	var at = localStorage.getItem('acct_' + acct_id + '_at')
	if (!native) {
		native = 'yes'
	}
	var domain = localStorage.getItem('domain_' + acct_id)
	if (localStorage.getItem('mode_' + domain) == 'misskey') {
		var misskey = true
		var start = 'https://' + domain + '/api/i/notifications'
		var i = {
			method: 'POST',
			headers: {
				'content-type': 'application/json'
			},
			body: JSON.stringify({
				i: at
			})
		}
	} else {
		var misskey = false
		var start = 'https://' + domain + '/api/v1/notifications'
		var i = {
			method: 'GET',
			headers: {
				'content-type': 'application/json',
				Authorization: 'Bearer ' + at
			}
		}
	}
	fetch(start, i)
		.then(function(response) {
			console.log('header to get param:' + response.headers.get('link'))
			if (!response.ok) {
				response.text().then(function(text) {
					setLog(response.url, response.status, text)
				})
			}
			return response.json()
		})
		.catch(function(error) {
			todo(error)
			setLog(start, 'JSON', error)
			console.error(error)
		})
		.then(function(json) {
			if (json[0]) {
				var templete = ''
				var lastnotf = localStorage.getItem('lastnotf_' + acct_id)
				localStorage.setItem('lastnotf_' + acct_id, json[0].id)
				Object.keys(json).forEach(function(key) {
					var obj = json[key]
					if (lastnotf == obj.id && key > 0 && native == 'yes') {
						var ct = key
						if (key > 14) {
							ct = '15+'
						}
						var os = localStorage.getItem('platform')
						var options = {
							body: ct + lang.lang_notf_new,
							icon: localStorage.getItem('prof_' + acct_id)
						}
						var n = new Notification('TheDesk:' + domain, options)
					}
					var mute = getFilterTypeByAcct(acct_id, 'notif')
					if (obj.type != 'follow') {
						if (misskey) {
							templete = templete + misskeyParse([obj], 'notf', acct_id, 'notf', -1, mute)
						} else {
							templete = templete + parse([obj], 'notf', acct_id, 'notf', -1, mute)
						}
					} else {
						if (misskey) {
							templete = templete + misskeyUserparse([obj], 'notf', acct_id, 'notf', -1, mute)
						} else {
							templete = templete + userparse([obj.account], 'notf', acct_id, 'notf', -1)
						}
					}
				})
				$('div[data-notf=' + acct_id + ']').html(templete)
				$('#landing_' + tlid).hide()
				jQuery('time.timeago').timeago()
			}
			$('#notf-box').addClass('fetched')
			todc()
			notfWS(misskey, acct_id, tlid, domain, at)
		})
}
function notfWS(misskey, acct_id, tlid, domain, at) {
	if (!misskey) {
		if (localStorage.getItem('streaming_' + acct_id)) {
			var wss = localStorage.getItem('streaming_' + acct_id)
		} else {
			var wss = 'wss://' + domain
		}
		var start = wss + '/api/v1/streaming/?stream=user&access_token=' + at

		var wsid = websocketNotf.length
		websocketNotf[acct_id] = new WebSocket(start)
		websocketNotf[acct_id].onopen = function(mess) {
			console.table({
				acct_id: acct_id,
				type: 'Connect Streaming API(Notf)',
				domain: domain,
				message: [mess]
			})
			$('i[data-notf=' + acct_id + ']').removeClass('red-text')
		}
		websocketNotf[acct_id].onmessage = function(mess) {
			//console.log(["Receive Streaming API(Notf):" + acct_id + "(" + domain + ")", JSON.parse(JSON.parse(mess.data).payload)]);
			var popup = localStorage.getItem('popup')
			if (!popup) {
				popup = 0
			}
			var obj = JSON.parse(JSON.parse(mess.data).payload)
			var type = JSON.parse(mess.data).event
			if (type == 'notification') {
				var templete = ''
				localStorage.setItem('lastnotf_' + acct_id, obj.id)
				if (!$('#unread_' + tlid + ' .material-icons').hasClass('teal-text')) {
					//markers show中はダメ
					if (obj.type != 'follow') {
						templete = parse([obj], 'notf', acct_id, 'notf', popup)
					} else {
						templete = userparse([obj], 'notf', acct_id, 'notf', popup)
					}
					if (!$('div[data-notfIndv=' + acct_id + '_' + obj.id + ']').length) {
						$('div[data-notf=' + acct_id + ']').prepend(templete)
						$('div[data-const=notf_' + acct_id + ']').prepend(templete)
					}
					jQuery('time.timeago').timeago()
				}
			} else if (type == 'delete') {
				$('[toot-id=' + obj + ']').hide()
				$('[toot-id=' + obj + ']').remove()
			}
		}
		websocketNotf[acct_id].onerror = function(error) {
			console.error('WebSocket Error ' + error)
			errorct++
			console.log(errorct)
			if (errorct < 3) {
				notfWS(misskey, acct_id, tlid, domain, at)
			}
		}
		websocketNotf[acct_id].onclose = function(error) {
			console.error('WebSocket Close ' + error)
			errorct++
			console.log(errorct)
			if (errorct < 3) {
				notfWS(misskey, acct_id, tlid, domain, at)
			}
		}
	}
}
//一定のスクロールで発火
function notfmore(tlid) {
	console.log({ status: 'kicked', status: moreloading })
	var multi = localStorage.getItem('column')
	var obj = JSON.parse(multi)
	var acct_id = obj[tlid].domain
	if (!type) {
		var type = obj[tlid].type
	} else {
		var data
	}
	var sid = $('#timeline_' + tlid + ' .notif-marker')
		.last()
		.attr('data-maxid')
	var at = localStorage.getItem('acct_' + acct_id + '_at')
	var domain = localStorage.getItem('domain_' + acct_id)
	if (sid && !moreloading) {
		moreloading = true
		var httpreq = new XMLHttpRequest()
		if (localStorage.getItem('mode_' + domain) == 'misskey') {
			var misskey = true
			var start = 'https://' + domain + '/api/i/notifications'
			httpreq.open(POST, start, true)
			httpreq.setRequestHeader('Content-Type', 'application/json')
			var body = JSON.stringify({
				i: at,
				untilID: sid
			})
		} else {
			var misskey = false
			if (localStorage.getItem('exclude-' + tlid)) {
				var exc = localStorage.getItem('exclude-' + tlid) + '&max_id=' + sid
			} else {
				var exc = '?max_id=' + sid
			}
			var start = 'https://' + domain + '/api/v1/notifications' + exc
			httpreq.open('GET', start, true)
			httpreq.setRequestHeader('Content-Type', 'application/json')
			httpreq.setRequestHeader('Authorization', 'Bearer ' + at)
			var body = ''
		}

		httpreq.responseType = 'json'
		httpreq.send(body)
		httpreq.onreadystatechange = function() {
			if (httpreq.readyState === 4) {
				var json = httpreq.response
				if (this.status !== 200) {
					setLog(start, this.status, this.response)
				}
				console.log(['More notifications on ' + tlid, json])
				var max_id = httpreq.getResponseHeader('link').match(/[?&]{1}max_id=([0-9]+)/)[1]
				if (json[0]) {
					var templete = ''
					var lastnotf = localStorage.getItem('lastnotf_' + acct_id)
					localStorage.setItem('lastnotf_' + acct_id, json[0].id)
					Object.keys(json).forEach(function(key) {
						var obj = json[key]
						var mute = getFilterTypeByAcct(acct_id, 'notif')
						if (obj.type != 'follow') {
							if (misskey) {
								templete = templete + misskeyParse([obj], 'notf', acct_id, 'notf', -1, mute)
							} else {
								templete = templete + parse([obj], 'notf', acct_id, 'notf', -1, mute)
							}
						} else {
							if (misskey) {
								templete = templete + misskeyUserparse([obj], 'notf', acct_id, 'notf', -1, mute)
							} else {
								templete = templete + userparse([obj.account], 'notf', acct_id, 'notf', -1)
							}
						}
					})
					moreloading = false
					templete = templete + '<div class="hide notif-marker" data-maxid="' + max_id + '"></div>'
					$('#timeline_' + tlid).append(templete)
					$('#landing_' + tlid).hide()
					jQuery('time.timeago').timeago()
				}
				$('#notf-box').addClass('fetched')
				todc()
			}
		}
	}
}

//通知トグルボタン
function notfToggle(acct, tlid) {
	if ($('#notf-box_' + tlid).hasClass('column-hide')) {
		$('#notf-box_' + tlid).css('display', 'block')
		$('#notf-box_' + tlid).animate(
			{
				height: '400px'
			},
			{
				duration: 300,
				complete: function() {
					$('#notf-box_' + tlid).css('overflow-y', 'scroll')
					$('#notf-box_' + tlid).removeClass('column-hide')
				}
			}
		)
	} else {
		$('#notf-box_' + tlid).css('overflow-y', 'hidden')
		$('#notf-box_' + tlid).animate(
			{
				height: '0'
			},
			{
				duration: 300,
				complete: function() {
					$('#notf-box_' + tlid).addClass('column-hide')
					$('#notf-box_' + tlid).css('display', 'none')
				}
			}
		)
	}
	notfCanceler(acct)
}
function notfCanceler(acct) {
	$('.notf-reply_' + acct).text(0)
	localStorage.removeItem('notf-reply_' + acct)
	$('.notf-reply_' + acct).addClass('hide')
	$('.notf-fav_' + acct).text(0)
	localStorage.removeItem('notf-fav_' + acct)
	$('.notf-fav_' + acct).addClass('hide')
	$('.notf-bt_' + acct).text(0)
	localStorage.removeItem('notf-bt_' + acct)
	$('.notf-bt_' + acct).addClass('hide')
	$('.notf-follow_' + acct).text(0)
	localStorage.removeItem('notf-follow_' + acct)
	$('.notf-follow_' + acct).addClass('hide')
	$('.notf-icon_' + acct).removeClass('red-text')
}
function allNotfRead() {
	var multi = localStorage.getItem('multi')
	if (multi) {
		var obj = JSON.parse(multi)
		Object.keys(obj).forEach(function(key) {
			notfCanceler(key)
		})
	}
}
allNotfRead()