package jp.juggler.subwaytooter

import android.os.SystemClock
import jp.juggler.subwaytooter.api.TootApiCallback
import jp.juggler.subwaytooter.api.TootApiClient
import jp.juggler.subwaytooter.api.TootApiResult
import jp.juggler.subwaytooter.api.TootParser
import jp.juggler.subwaytooter.api.entity.*
import jp.juggler.subwaytooter.util.ScrollPosition
import jp.juggler.util.*

class ColumnTask_Refresh(
	columnArg : Column,
	private val bSilent : Boolean,
	private val bBottom : Boolean,
	internal val posted_status_id : EntityId? = null,
	internal val refresh_after_toot : Int = - 1
) : ColumnTask(
	columnArg,
	if(bBottom) ColumnTaskType.REFRESH_BOTTOM else ColumnTaskType.REFRESH_TOP
) {
	
	companion object {
		
		internal val log = LogCategory("CT_Refresh")
	}
	
	private var filterUpdated = false
	
	override fun doInBackground() : TootApiResult? {
		ctStarted.set(true)
		
		val client = TootApiClient(context, callback = object : TootApiCallback {
			override val isApiCancelled : Boolean
				get() = isCancelled || column.is_dispose.get()
			
			override fun publishApiProgress(s : String) {
				runOnMainLooper {
					if(isCancelled) return@runOnMainLooper
					column.task_progress = s
					column.fireShowContent(reason = "refresh progress", changeList = ArrayList())
				}
			}
		})
		client.account = access_info
		try {
			
			if(! bBottom) {
				val filterList = column.loadFilter2(client)
				if(filterList != null) {
					column.keywordFilterTrees = column.encodeFilterTree(filterList)
					filterUpdated = true
				}
			}
			
			return column.type.refresh(this, client)
		} catch(ex : Throwable) {
			return TootApiResult(ex.withCaption("refresh failed."))
		} finally {
			try {
				column.updateRelation(client, list_tmp, column.who_account, parser)
			} catch(ex : Throwable) {
				log.trace(ex)
			}
			ctClosed.set(true)
			runOnMainLooperDelayed(333L) {
				if(! isCancelled) column.fireShowColumnStatus()
			}
		}
	}
	
	override fun onPostExecute(result : TootApiResult?) {
		if(column.is_dispose.get()) return
		
		if(isCancelled || result == null) {
			return
		}
		try {
			column.lastTask = null
			column.bRefreshLoading = false
			
			if(filterUpdated) {
				column.checkFiltersForListData(column.keywordFilterTrees)
			}
			
			val error = result.error
			if(error != null) {
				column.mRefreshLoadingError = error
				column.mRefreshLoadingErrorTime = SystemClock.elapsedRealtime()
				column.fireShowContent(reason = "refresh error", changeList = ArrayList())
				return
			}
			
			val list_new = column.duplicate_map.filterDuplicate(list_tmp)
			if(list_new.isEmpty()) {
				column.fireShowContent(
					reason = "refresh list_new is empty",
					changeList = ArrayList()
				)
				return
			}
			
			// 事前にスクロール位置を覚えておく
			var sp : ScrollPosition? = null
			val holder = column.viewHolder
			if(holder != null) {
				sp = holder.scrollPosition
			}
			
			
			
			if(bBottom) {
				val changeList = listOf(
					AdapterChange(
						AdapterChangeType.RangeInsert,
						column.list_data.size,
						list_new.size
					)
				)
				column.list_data.addAll(list_new)
				column.fireShowContent(reason = "refresh updated bottom", changeList = changeList)
				
				// 新着が少しだけ見えるようにスクロール位置を移動する
				if(sp != null) {
					holder?.setScrollPosition(sp, 20f)
				}
			} else {
				
				val changeList = ArrayList<AdapterChange>()
				
				if(column.list_data.isNotEmpty() && column.list_data[0] is TootGap) {
					changeList.add(AdapterChange(AdapterChangeType.RangeRemove, 0, 1))
					column.list_data.removeAt(0)
				}
				
				var doneSound = false
				for(o in list_new) {
					if(o is TootStatus) {
						o.highlightSound?.let {
							if(! doneSound) {
								doneSound = true
								App1.sound(it)
							}
						}
						o.highlightSpeech?.let {
							App1.getAppState(context)
								.addSpeech(it.name, dedupMode = DedupMode.RecentExpire)
						}
					}
				}
				
				column.replaceConversationSummary(changeList, list_new, column.list_data)
				
				val added = list_new.size // may 0
				
				// 投稿後のリフレッシュなら当該投稿の位置を探す
				var status_index = - 1
				for(i in 0 until added) {
					val o = list_new[i]
					if(o is TootStatus && o.id == posted_status_id) {
						status_index = i
						break
					}
				}
				
				changeList.add(AdapterChange(AdapterChangeType.RangeInsert, 0, added))
				column.list_data.addAll(0, list_new)
				column.fireShowContent(reason = "refresh updated head", changeList = changeList)
				
				if(status_index >= 0 && refresh_after_toot == Pref.RAT_REFRESH_SCROLL) {
					// 投稿後にその投稿にスクロールする
					if(holder != null) {
						holder.setScrollPosition(
							ScrollPosition(column.toAdapterIndex(status_index)),
							0f
						)
					} else {
						column.scroll_save = ScrollPosition(column.toAdapterIndex(status_index))
					}
				} else {
					//
					val scroll_save = column.scroll_save
					when {
						// ViewHolderがある場合は増加件数分+deltaの位置にスクロールする
						sp != null -> {
							sp.adapterIndex += added
							val delta = if(bSilent) 0f else - 20f
							holder?.setScrollPosition(sp, delta)
						}
						// ViewHolderがなくて保存中の位置がある場合、増加件数分ずらす。deltaは難しいので反映しない
						scroll_save != null -> scroll_save.adapterIndex += added
						// 保存中の位置がない場合、保存中の位置を新しく作る
						else -> column.scroll_save =
							ScrollPosition(column.toAdapterIndex(added))
					}
				}
			}
			
			column.updateMisskeyCapture()
			
		} finally {
			column.fireShowColumnStatus()
			
			if(! bBottom) {
				column.bRefreshingTop = false
				column.resumeStreaming(false)
			}
		}
	}
	
	private fun <T : TimelineItem> refreshTopMisskey(
		logCaption : String,
		requester : (first : Boolean) -> TootApiResult?,
		arrayFinder : (JsonObject) -> JsonArray?,
		listParser : (parser : TootParser, jsonArray : JsonArray) -> List<T>,
		adder : (List<T>, Boolean) -> Unit
	) : TootApiResult? {
		
		// ColumnPagingType.Defaultだけが始端を更新できる
		if(column.pagingType != ColumnPagingType.Default)
			return TootApiResult("can't refresh top.")
		
		val addToHead = true
		
		val time_start = SystemClock.elapsedRealtime()
		
		var result = requester(true)
		
		val firstResult = result
		
		var jsonObject = result?.jsonObject
		if(jsonObject != null)
			result?.data = arrayFinder(jsonObject)
		
		var array = result?.jsonArray
		if(array != null) {
			list_tmp = ArrayList()
			
			var src = listParser(parser, array)
			adder(src, addToHead)
			column.saveRangeTop(result, src)
			
			// misskeyの場合、sinceIdを指定したら未読範囲の古い方から読んでしまう
			// 最新まで読めるとは限らない
			// 先頭にギャップを置くかもしれない
			var willAddGap = false
			while(true) {
				// 頭の方を読む時は隙間を減らすため、フィルタの有無に関係なく繰り返しを行う
				
				if(isCancelled) {
					log.d("$logCaption: cancelled.")
					break
				}
				
				if(src.isEmpty()) {
					// 直前のデータが0個なら終了とみなす
					log.d("$logCaption: previous size == 0.")
					break
				}
				
				if((list_tmp?.size ?: 0) >= Column.LOOP_READ_ENOUGH) {
					// 既に十分読んだなら止める
					log.d("$logCaption: read enough. make gap.")
					willAddGap = true
					break
				}
				
				if(SystemClock.elapsedRealtime() - time_start > Column.LOOP_TIMEOUT) {
					log.d("$logCaption: timeout.")
					willAddGap = true
					break
				}
				
				result = requester(false)
				
				jsonObject = result?.jsonObject
				if(jsonObject != null)
					result?.data = arrayFinder(jsonObject)
				
				array = result?.jsonArray
				if(array == null) {
					log.d("$logCaption: error or cancelled.")
					willAddGap = true
					break
				}
				
				src = listParser(parser, array)
				adder(src, addToHead)
				column.saveRangeTop(result = result, list = src)
			}
			
			// MisskeyはsinceIdを指定するとID昇順のデータが得られるので、ID降順に並べ直す
			list_tmp?.sortByDescending { it.getOrderId() }
			
			if(! isCancelled
				&& list_tmp?.isNotEmpty() == true
				&& (willAddGap || Pref.bpForceGap(context))
			) {
				addOne(list_tmp, TootGap.mayNull(null, column.idRecent), head = addToHead)
			}
		}
		return firstResult
	}
	
	private fun <T : TimelineItem> refreshBottomMisskey(
		logCaption : String,
		requester : (first : Boolean) -> TootApiResult?,
		arrayFinder : (JsonObject) -> JsonArray?,
		listParser : (parser : TootParser, jsonArray : JsonArray) -> List<T>,
		adder : (List<T>, Boolean) -> Unit,
		repeatReading : Boolean = false,
	) : TootApiResult? {
		
		when(column.pagingType) {
			ColumnPagingType.None ->
				return TootApiResult(context.getString(R.string.end_of_list))
			
			ColumnPagingType.Cursor ->
				if(column.idOld == null)
					return TootApiResult(context.getString(R.string.end_of_list))
			
			else -> {
			}
		}
		
		val time_start = SystemClock.elapsedRealtime()
		val addToHead = false
		
		var result = requester(true)
		val firstResult = result
		
		fun saveRange(src : List<T>) : Boolean = when(column.pagingType) {
			ColumnPagingType.Offset -> {
				column.offsetNext += src.size
				true
			}
			
			else -> // ColumnPagingType.Default
				column.saveRangeBottom(result, src)
					.also {
						if(! it) log.d("$logCaption: saveRangeBottom returns false. no more unread contents.")
					}
		}
		
		var jsonObject = result?.jsonObject
		if(jsonObject != null) {
			if(column.pagingType == ColumnPagingType.Cursor) {
				column.idOld = EntityId.mayNull(jsonObject.string("next"))
			}
			result?.data = arrayFinder(jsonObject)
		}
		
		var array = result?.jsonArray
		if(array != null) {
			list_tmp = ArrayList()
			
			var src = listParser(parser, array)
			adder(src, addToHead)
			var hasMoreRange = saveRange(src)
			
			while(hasMoreRange && repeatReading) {
				if(isCancelled) {
					log.d("$logCaption: cancelled.")
					break
				}
				
				// bottomの場合、フィルタなしなら繰り返さない
				if(! column.isFilterEnabled) {
					log.d("$logCaption: isFilterEnabled is false.")
					break
				}
				
				// max_id だけを指定した場合、必ずlimit個のデータが帰ってくるとは限らない
				// 直前のデータが0個なら終了とみなすしかなさそう
				if(src.isEmpty()) {
					log.d("$logCaption: previous size == 0.")
					break
				}
				
				if(column.idOld == null) {
					log.d("$logCaption: idOld is null.")
					break
				}
				
				// 十分読んだらそれで終了
				if((list_tmp?.size ?: 0) >= Column.LOOP_READ_ENOUGH) {
					log.d("$logCaption: read enough data.")
					break
				}
				
				if(SystemClock.elapsedRealtime() - time_start > Column.LOOP_TIMEOUT) {
					// タイムアウト
					log.d("$logCaption: loop timeout.")
					break
				}
				
				result = requester(false)
				
				jsonObject = result?.jsonObject
				if(jsonObject != null) {
					if(column.pagingType == ColumnPagingType.Cursor) {
						column.idOld = EntityId.mayNull(jsonObject.string("next"))
					}
					result?.data = arrayFinder(jsonObject)
				}
				
				array = result?.jsonArray
				if(array == null) {
					log.d("$logCaption:  error or cancelled.")
					break
				}
				
				src = listParser(parser, array)
				adder(src, addToHead)
				hasMoreRange = saveRange(src)
			}
		}
		return firstResult
	}
	
	private fun <T : TimelineItem> refreshTopMastodon(
		logCaption : String,
		requester : (first : Boolean, gapIdNewer : EntityId?, gapIdOlder : EntityId?) -> TootApiResult?,
		arrayFinder : (JsonObject) -> JsonArray?,
		listParser : (parser : TootParser, jsonArray : JsonArray) -> List<T>,
		adder : (List<T>, Boolean) -> Unit
	) : TootApiResult? {
		
		// 上端の差分更新に対応できるのは ColumnPagingType.Default だけ
		if(column.pagingType != ColumnPagingType.Default)
			return TootApiResult("can't refresh top.")
		
		val time_start = SystemClock.elapsedRealtime()
		val addToHead = false
		
		var result = requester(true, null, null)
		val firstResult = result
		
		var jsonObject = result?.jsonObject
		if(jsonObject != null) result?.data = arrayFinder(jsonObject)
		
		var array = result?.jsonArray
		if(array != null) {
			val last_since_id = column.idRecent
			list_tmp = ArrayList()
			
			var src = listParser(parser, array)
			adder(src, addToHead)
			column.saveRangeTop(result, src)
			// TLは (新しいデータ)(ギャップ)(古いデータ) となるので、レンジを保存するのはここだけで良い
			// 続く読み込みはギャップを埋めるものなのでレンジを保存してはいけない
			
			// 頭の方を読む時は隙間を減らすため、フィルタの有無に関係なく繰り返しを行う
			var willAddGap = false
			var max_id : EntityId? = null
			while(true) {
				if(isCancelled) {
					log.d("$logCaption: cancelled.")
					break
				}
				
				if(src.isEmpty()) {
					// max_id だけを指定した場合、必ずlimit個のデータが帰ってくるとは限らない
					// 直前のデータが0個なら終了とみなすしかなさそう
					log.d("$logCaption: previous size == 0.")
					break
				}
				
				// 直前に読んだ範囲のmaxIdを調べる
				max_id = column.parseRange(result, src).first
				if(max_id == null) {
					log.d("$logCaption: max_id is null.")
					break
				}
				
				if((list_tmp?.size ?: 0) >= Column.LOOP_READ_ENOUGH) {
					log.d("$logCaption: read enough. make gap.")
					willAddGap = true
					break
				}
				
				if(SystemClock.elapsedRealtime() - time_start > Column.LOOP_TIMEOUT) {
					// タイムアウト
					log.d("$logCaption: timeout. make gap.")
					willAddGap = true
					break
				}
				
				result = requester(false, max_id, last_since_id)
				
				jsonObject = result?.jsonObject
				if(jsonObject != null) result?.data = arrayFinder(jsonObject)
				
				array = result?.jsonArray
				
				if(array == null) {
					// エラー
					log.d("$logCaption: error or cancelled. make gap.")
					willAddGap = true
					break
				}
				
				src = listParser(parser, array)
				adder(src, addToHead)
				
				// 今読んだのはギャップなので範囲を保存してはいけない
			}
			
			if(! isCancelled
				&& list_tmp?.isNotEmpty() == true
				&& (willAddGap || Pref.bpForceGap(context))
			) {
				addOne(list_tmp, TootGap.mayNull(max_id, last_since_id), head = addToHead)
			}
		}
		return firstResult
	}
	
	private fun <T : TimelineItem> refreshTopMastodonMinId(
		logCaption : String,
		requester : (first : Boolean, gapIdNewer : EntityId?, gapIdOlder : EntityId?) -> TootApiResult?,
		arrayFinder : (JsonObject) -> JsonArray?,
		listParser : (parser : TootParser, jsonArray : JsonArray) -> List<T>,
		adder : (List<T>, Boolean) -> Unit
	) : TootApiResult? {
		list_tmp = ArrayList()
		
		// 上端の差分更新に対応できるのは ColumnPagingType.Default だけ
		if(column.pagingType != ColumnPagingType.Default)
			return TootApiResult("can't refresh top.")
		
		val last_since_id = column.idRecent
		val addToHead = true
		
		val time_start = SystemClock.elapsedRealtime()
		
		var result = requester(true, null, null)
		
		val firstResult = result
		
		var jsonObject = result?.jsonObject
		if(jsonObject != null) {
			result?.data = arrayFinder(jsonObject)
		}
		
		var array = result?.jsonArray
		if(array != null) {
			
			var src = listParser(parser, array)
			adder(src, addToHead)
			
			var willAddGap = false
			var max_id : EntityId? = null
			while(true) {
				column.saveRangeTop(result, src)
				
				if(isCancelled) {
					log.d("$logCaption: cancelled.")
					break
				}
				
				// max_id だけを指定した場合、必ずlimit個のデータが帰ってくるとは限らない
				// 直前のデータが0個なら終了とみなすしかなさそう
				if(src.isEmpty()) {
					log.d("$logCaption: previous size == 0.")
					break
				}
				
				// 直前に読んだ範囲のmaxIdを調べる
				max_id = column.parseRange(result, src).first
				if(max_id == null) {
					log.d("$logCaption: max_id is null.")
					break
				}
				
				if(SystemClock.elapsedRealtime() - time_start > Column.LOOP_TIMEOUT) {
					log.d("$logCaption: timeout. make gap.")
					// タイムアウト
					// 隙間ができるかもしれない。後ほど手動で試してもらうしかない
					willAddGap = true
					break
				}
				
				result = requester(false, null, null)
				
				jsonObject = result?.jsonObject
				if(jsonObject != null)
					result?.data = arrayFinder(jsonObject)
				
				array = result?.jsonArray
				
				if(array == null) {
					log.d("$logCaption: error or cancelled. make gap.")
					// エラー
					// 隙間ができるかもしれない。後ほど手動で試してもらうしかない
					willAddGap = true
					break
				}
				
				src = listParser(parser, array)
				adder(src, addToHead)
				
			}
			
			if(! isCancelled
				&& list_tmp?.isNotEmpty() == true
				&& (willAddGap || Pref.bpForceGap(context))
			) {
				addOne(list_tmp, TootGap.mayNull(max_id, last_since_id), head = addToHead)
			}
		}
		return firstResult
	}
	
	private fun <T : TimelineItem> refreshBottomMastodon(
		logCaption : String,
		requester : (first : Boolean, gapIdNewer : EntityId?, gapIdOlder : EntityId?) -> TootApiResult?,
		arrayFinder : (JsonObject) -> JsonArray?,
		listParser : (parser : TootParser, jsonArray : JsonArray) -> List<T>,
		adder : (List<T>, Boolean) -> Unit,
		repeatReading : Boolean = false
	) : TootApiResult? {
		
		@Suppress("NON_EXHAUSTIVE_WHEN")
		when(column.pagingType) {
			ColumnPagingType.None ->
				return TootApiResult(context.getString(R.string.end_of_list))
			
			ColumnPagingType.Cursor ->
				if(column.idOld == null)
					return TootApiResult(context.getString(R.string.end_of_list))
		}
		
		val time_start = SystemClock.elapsedRealtime()
		val addToHead = false
		
		var result = requester(true, null, null)
		val firstResult = result
		
		var jsonObject = result?.jsonObject
		if(jsonObject != null) {
			if(column.pagingType == ColumnPagingType.Cursor) {
				column.idOld = EntityId.mayNull(jsonObject.string("next"))
			}
			result?.data = arrayFinder(jsonObject)
		}
		
		var array = result?.jsonArray
		if(array != null) {
			list_tmp = ArrayList()
			var src = listParser(parser, array)
			adder(src, addToHead)
			
			while(repeatReading) {
				
				// returns false if no more result
				fun saveResultRange(src : List<T>) = when(column.pagingType) {
					ColumnPagingType.Offset -> {
						column.offsetNext += src.size
						true
					}
					
					else -> // ColumnPagingType.Default
						column.saveRangeBottom(result, src)
				}
				
				if(! saveResultRange(src)) {
					log.d("$logCaption: saveRangeBottom returns false. no more items.")
					break
				}
				
				if(isCancelled) {
					log.d("$logCaption: cancelled.")
					break
				}
				
				if(! column.isFilterEnabled) {
					// bottomの場合、フィルタなしなら繰り返さない
					log.d("$logCaption: isFiltered is false.")
					break
				}
				
				if(src.isEmpty()) {
					// max_id だけを指定した場合、必ずlimit個のデータが帰ってくるとは限らない
					// 直前のデータが0個なら終了とみなすしかなさそう
					log.d("$logCaption: previous size == 0.")
					break
				}
				
				if(column.idOld == null) {
					log.d("$logCaption: idOld is null.")
					break
				}
				
				if((list_tmp?.size ?: 0) >= Column.LOOP_READ_ENOUGH) {
					// 十分読んだらそれで終了
					log.d("$logCaption: read enough data.")
					break
				}
				
				if(SystemClock.elapsedRealtime() - time_start > Column.LOOP_TIMEOUT) {
					// タイムアウト
					log.d("$logCaption: loop timeout.")
					break
				}
				
				result = requester(false, null, null)
				
				jsonObject = result?.jsonObject
				if(jsonObject != null)
					result?.data = arrayFinder(jsonObject)
				
				array = result?.jsonArray
				if(array == null) {
					log.d("$logCaption: error or cancelled.")
					break
				}
				
				src = listParser(parser, array)
				adder(src, addToHead)
			}
		}
		return firstResult
	}
	
	private fun defaultRequesterMisskey(
		client : TootApiClient,
		path_base : String,
		params : JsonObject,
		first : Boolean
	) =
		client.request(
			path_base,
			params.apply {
				if(! bBottom) {
					if(first) {
						
						addRangeMisskey(bBottom)
					} else {
						putMisskeySince(column.idRecent)
					}
				} else {
					if(first) {
						
						when(column.pagingType) {
							ColumnPagingType.Default -> addRangeMisskey(bBottom)
							ColumnPagingType.Offset -> put("offset", column.offsetNext)
							ColumnPagingType.Cursor -> put("cursor", column.idOld)
							
							ColumnPagingType.None -> {
							}
						}
					} else {
						when(column.pagingType) {
							ColumnPagingType.Default -> putMisskeyUntil(column.idOld)
							ColumnPagingType.Offset -> put("offset", column.offsetNext)
							ColumnPagingType.Cursor -> put("cursor", column.idOld)
							
							ColumnPagingType.None -> {
							}
						}
					}
				}
			}.toPostRequestBuilder()
		)
	
	private fun defaultRequesterMastodon(
		client : TootApiClient,
		path_base : String,
		delimiter : Char,
		@Suppress("UNUSED_PARAMETER") first : Boolean,
		useMinId : Boolean,
		gapIdNewer : EntityId?,
		gapIdOlder : EntityId?
	) =
		client.request(
			when {
				// profile directory 用
				column.pagingType == ColumnPagingType.Offset ->
					"$path_base${delimiter}offset=${column.offsetNext}"
				
				useMinId ->
					column.addRangeMin(path_base)
				
				gapIdNewer != null ->
					"$path_base${delimiter}max_id=$gapIdNewer&since_id=$gapIdOlder"
				
				else ->
					column.addRange(bBottom = bBottom, path_base, delimiter = delimiter)
			}
		)
	
	internal fun getStatusList(
		client : TootApiClient,
		path_base : String?,
		useMinId : Boolean = false,
		misskeyParams : JsonObject? = null,
		listParser : (parser : TootParser, jsonArray : JsonArray) -> List<TootStatus> =
			defaultStatusListParser
	) : TootApiResult? {
		
		path_base ?: return null // cancelled.
		
		val logCaption = "getStatusList"
		val adder : (List<TootStatus>, Boolean) -> Unit =
			{ src, head -> addWithFilterStatus(list_tmp, src, head = head) }
		
		return if(isMisskey) {
			
			val params = misskeyParams ?: column.makeMisskeyTimelineParameter(parser)
			
			val requester : (Boolean) -> TootApiResult? =
				{ defaultRequesterMisskey(client, path_base, params, it) }
			
			when {
				bBottom -> refreshBottomMisskey(
					logCaption,
					requester = requester,
					arrayFinder = nullArrayFinder,
					listParser = listParser,
					adder = adder,
					repeatReading = true
				)
				else -> refreshTopMisskey(
					logCaption,
					requester = requester,
					arrayFinder = nullArrayFinder,
					listParser = listParser,
					adder = adder
				)
			}
			
		} else {
			
			val delimiter = if(- 1 != path_base.indexOf('?')) '&' else '?'
			
			val requester : (first : Boolean, gapIdNewer : EntityId?, gapIdOlder : EntityId?) -> TootApiResult? =
				{ first, gapIdNewer, gapIdOlder ->
					defaultRequesterMastodon(
						client,
						path_base,
						delimiter,
						first,
						useMinId = useMinId,
						gapIdNewer,
						gapIdOlder,
					)
				}
			
			when {
				bBottom -> refreshBottomMastodon(
					logCaption,
					requester = requester,
					arrayFinder = nullArrayFinder,
					listParser = listParser,
					adder = adder,
					repeatReading = true
				)
				useMinId -> refreshTopMastodonMinId(
					logCaption,
					requester = requester,
					arrayFinder = nullArrayFinder,
					listParser = listParser,
					adder
				)
				else -> refreshTopMastodon(
					logCaption,
					requester = requester,
					arrayFinder = nullArrayFinder,
					listParser = listParser,
					adder
				)
			}
		}
	}
	
	internal fun getNotificationList(
		client : TootApiClient,
		fromAcct : String? = null,
		useMinId : Boolean = false
	) : TootApiResult? {
		
		val logCaption = "getNotificationList"
		
		val listParser : (parser : TootParser, jsonArray : JsonArray) -> List<TootNotification> =
			defaultNotificationListParser
		
		val adder : (List<TootNotification>, Boolean) -> Unit =
			{ src, head -> addWithFilterNotification(list_tmp, src, head = head) }
		
		// Misskeyの通知TLはfromAcctに対応していない
		val path_base = column.makeNotificationUrl(client, fromAcct)
		
		return if(isMisskey) {
			
			val params =
				column.makeMisskeyBaseParameter(parser).addMisskeyNotificationFilter(column)
			
			val requester : (Boolean) -> TootApiResult? =
				{ defaultRequesterMisskey(client, path_base, params, it) }
			
			when {
				bBottom -> refreshBottomMisskey(
					logCaption,
					requester = requester,
					arrayFinder = nullArrayFinder,
					listParser = listParser,
					adder = adder,
					repeatReading = true
				)
				else -> refreshTopMisskey(
					logCaption,
					requester = requester,
					arrayFinder = nullArrayFinder,
					listParser = listParser,
					adder = adder
				)
			}
		} else {
			
			val delimiter = if(- 1 != path_base.indexOf('?')) '&' else '?'
			
			val requester : (first : Boolean, gapIdNewer : EntityId?, gapIdOlder : EntityId?) -> TootApiResult? =
				{ first, gapIdNewer, gapIdOlder ->
					defaultRequesterMastodon(
						client,
						path_base,
						delimiter,
						first,
						useMinId = useMinId,
						gapIdNewer,
						gapIdOlder,
					)
				}
			
			when {
				bBottom -> refreshBottomMastodon(
					logCaption,
					requester = requester,
					arrayFinder = nullArrayFinder,
					listParser = listParser,
					adder = adder,
					repeatReading = true
				)
				useMinId -> refreshTopMastodonMinId(
					logCaption,
					requester = requester,
					arrayFinder = nullArrayFinder,
					listParser = listParser,
					adder = adder
				)
				else -> refreshTopMastodon(
					logCaption,
					requester = requester,
					arrayFinder = nullArrayFinder,
					listParser = listParser,
					adder = adder
				)
			}
		}
	}
	
	internal fun getAccountList(
		client : TootApiClient,
		path_base : String,
		misskeyParams : JsonObject? = null,
		arrayFinder : (JsonObject) -> JsonArray? =
			nullArrayFinder,
		listParser : (parser : TootParser, jsonArray : JsonArray) -> List<TootAccountRef> =
			defaultAccountListParser
	) : TootApiResult? {
		
		val logCaption = "getAccountList"
		val adder : (List<TootAccountRef>, Boolean) -> Unit =
			{ src, head -> addAll(list_tmp, src, head = head) }
		
		return if(isMisskey) {
			val params = misskeyParams ?: column.makeMisskeyBaseParameter(parser)
			val requester : (Boolean) -> TootApiResult? =
				{ defaultRequesterMisskey(client, path_base, params, it) }
			when {
				bBottom -> refreshBottomMisskey(
					logCaption,
					requester = requester,
					arrayFinder = arrayFinder,
					listParser = listParser,
					adder = adder
				)
				else -> refreshTopMisskey(
					logCaption,
					requester = requester,
					arrayFinder = arrayFinder,
					listParser = listParser,
					adder = adder
				)
			}
		} else {
			val delimiter = if(- 1 != path_base.indexOf('?')) '&' else '?'
			val requester : (first : Boolean, gapIdNewer : EntityId?, gapIdOlder : EntityId?) -> TootApiResult? =
				{ first, gapIdNewer, gapIdOlder ->
					defaultRequesterMastodon(
						client,
						path_base,
						delimiter,
						first,
						useMinId = false,
						gapIdNewer,
						gapIdOlder,
					)
				}
			
			when {
				bBottom -> refreshBottomMastodon(
					logCaption,
					requester = requester,
					arrayFinder = arrayFinder,
					listParser = listParser,
					adder = adder
				)
				else -> refreshTopMastodon(
					logCaption,
					requester = requester,
					arrayFinder = arrayFinder,
					listParser = listParser,
					adder = adder
				)
			}
		}
	}
	
	internal fun getDomainList(
		client : TootApiClient,
		path_base : String
	) : TootApiResult? {
		
		val logCaption = "getDomainList"
		
		val adder : (List<TimelineItem>, Boolean) -> Unit =
			{ src, head -> addAll(list_tmp, src, head = head) }
		
		val listParser = defaultDomainBlockListParser
		
		return if(isMisskey) {
			TootApiResult("misskey support is not yet implemented.")
		} else {
			// ページングIDはサーバ側の内部IDで、Linkヘッダ以外には露出しない。
			val delimiter = if(- 1 != path_base.indexOf('?')) '&' else '?'
			val requester : (first : Boolean, gapIdNewer : EntityId?, gapIdOlder : EntityId?) -> TootApiResult? =
				{ first, gapIdNewer, gapIdOlder ->
					defaultRequesterMastodon(
						client,
						path_base,
						delimiter,
						first,
						useMinId = false,
						gapIdNewer,
						gapIdOlder,
					)
				}
			
			when {
				bBottom -> refreshBottomMastodon(
					logCaption,
					requester = requester,
					arrayFinder = nullArrayFinder,
					listParser = listParser,
					adder = adder
				)
				else -> refreshTopMastodon(
					logCaption,
					requester = requester,
					arrayFinder = nullArrayFinder,
					listParser = listParser,
					adder = adder
				)
			}
		}
	}
	
	// リスト一覧にはページネーションがない
	//			fun getListList(client : TootApiClient, path_base : String) : TootApiResult? {
	//
	//				if(isMisskey) return TootApiResult("misskey support is not yet implemented.")
	//
	//				return TootApiResult("Mastodon's /api/v1/lists has no pagination.")
	//			}
	
	internal fun getReportList(
		client : TootApiClient,
		path_base : String
	) : TootApiResult? {
		
		val logCaption = "getReportList"
		val adder : (List<TootReport>, Boolean) -> Unit =
			{ src, head -> addAll(list_tmp, src, head = head) }
		
		val listParser : (parser : TootParser, jsonArray : JsonArray) -> List<TootReport> =
			{ _, jsonArray -> parseList(::TootReport, jsonArray) }
		
		return if(isMisskey) {
			TootApiResult("Misskey has no API to list reports from you.")
		} else {
			// ページングIDはサーバ側の内部IDで、Linkヘッダ以外には露出しない。
			val delimiter = if(- 1 != path_base.indexOf('?')) '&' else '?'
			val requester : (first : Boolean, gapIdNewer : EntityId?, gapIdOlder : EntityId?) -> TootApiResult? =
				{ first, gapIdNewer, gapIdOlder ->
					defaultRequesterMastodon(
						client,
						path_base,
						delimiter,
						first,
						useMinId = false,
						gapIdNewer,
						gapIdOlder,
					)
				}
			
			when {
				bBottom -> refreshBottomMastodon(
					logCaption,
					requester = requester,
					arrayFinder = nullArrayFinder,
					listParser = listParser,
					adder = adder
				)
				else -> refreshTopMastodon(
					logCaption,
					requester = requester,
					arrayFinder = nullArrayFinder,
					listParser = listParser,
					adder = adder
				)
			}
		}
	}
	
	internal fun getConversationSummaryList(
		client : TootApiClient,
		path_base : String,
		//	aroundMin : Boolean = false,
		misskeyParams : JsonObject? = null,
	) : TootApiResult? {
		val logCaption = "getConversationSummaryList"
		
		val listParser : (parser : TootParser, jsonArray : JsonArray) -> List<TootConversationSummary> =
			defaultConversationSummaryListParser
		
		val adder : (List<TootConversationSummary>, Boolean) -> Unit =
			{ src, head -> addWithFilterConversationSummary(list_tmp, src, head = head) }
		
		return if(isMisskey) {
			
			val params = misskeyParams ?: column.makeMisskeyTimelineParameter(parser)
			
			val requester : (Boolean) -> TootApiResult? =
				{ defaultRequesterMisskey(client, path_base, params, it) }
			
			when {
				bBottom -> refreshBottomMisskey(
					logCaption,
					requester = requester,
					arrayFinder = nullArrayFinder,
					listParser = listParser,
					adder = adder,
					repeatReading = true
				)
				else -> refreshTopMisskey(
					logCaption,
					requester = requester,
					arrayFinder = nullArrayFinder,
					listParser = listParser,
					adder = adder
				)
			}
		} else {
			val delimiter = if(- 1 != path_base.indexOf('?')) '&' else '?'
			val requester : (first : Boolean, gapIdNewer : EntityId?, gapIdOlder : EntityId?) -> TootApiResult? =
				{ first, gapIdNewer, gapIdOlder ->
					defaultRequesterMastodon(
						client,
						path_base,
						delimiter,
						first,
						useMinId = false,
						gapIdNewer,
						gapIdOlder,
					)
				}
			
			when {
				bBottom -> refreshBottomMastodon(
					logCaption,
					requester = requester,
					arrayFinder = nullArrayFinder,
					listParser = listParser,
					adder = adder,
					repeatReading = true
				)
				else -> refreshTopMastodon(
					logCaption,
					requester = requester,
					arrayFinder = nullArrayFinder,
					listParser = listParser,
					adder
				)
			}
		}
	}
	
	internal fun getScheduledStatuses(client : TootApiClient) : TootApiResult? {
		val result = client.request(column.addRange(bBottom, Column.PATH_SCHEDULED_STATUSES))
		val src = parseList(::TootScheduled, parser, result?.jsonArray)
		list_tmp = addAll(list_tmp, src)
		column.saveRange(bBottom, ! bBottom, result, src)
		return result
	}
	
	fun getMSP(client : TootApiClient) : TootApiResult? {
		if(! bBottom) return TootApiResult("head of list.")
		
		val q = column.search_query.trim()
		val old = column.idOld?.toString()
		if(q.isEmpty() || old == null) {
			list_tmp = ArrayList()
			return TootApiResult(context.getString(R.string.end_of_list))
		}
		
		return client.searchMsp(q, old)?.also { result ->
			val jsonArray = result.jsonArray
			if(jsonArray != null) {
				// max_id の更新
				column.idOld = EntityId.mayNull(
					TootApiClient.getMspMaxId(
						jsonArray,
						column.idOld?.toString()
					)
				)
				// リストデータの用意
				parser.serviceType = ServiceType.MSP
				list_tmp = addWithFilterStatus(list_tmp, parser.statusList(jsonArray))
			}
		}
	}
	
	fun getTootSearch(client : TootApiClient) : TootApiResult? {
		if(! bBottom) return TootApiResult("head of list.")
		
		val q = column.search_query.trim { it <= ' ' }
		val old = column.idOld?.toString()?.toLong()
		if(q.isEmpty() || old == null) {
			list_tmp = ArrayList()
			return TootApiResult(context.getString(R.string.end_of_list))
		}
		
		return client.searchTootsearch(q, old)?.also { result ->
			val jsonObject = result.jsonObject
			if(jsonObject != null) {
				// max_id の更新
				column.idOld = EntityId.mayNull(
					TootApiClient.getTootsearchMaxId(
						jsonObject,
						old
					)?.toString()
				)
				// リストデータの用意
				val search_result = TootStatus.parseListTootsearch(parser, jsonObject)
				list_tmp = addWithFilterStatus(list_tmp, search_result)
			}
		}
	}
}