418 lines
12 KiB
JavaScript
418 lines
12 KiB
JavaScript
//通知
|
|
//取得+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')
|
|
//Pleromaにはmoveというtypeがあるらしい。何が互換APIじゃ
|
|
if (obj.type != 'follow' && obj.type != 'move') {
|
|
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')
|
|
//Pleromaにはmoveというtypeがあるらしい。何が互換APIじゃ
|
|
if (obj.type != 'follow' && obj.type != 'move') {
|
|
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], type, 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()
|