NetNewsWire/Frameworks/Database/StatusesTable.swift

//
//  StatusesTable.swift
//  Evergreen
//
//  Created by Brent Simmons on 5/8/16.
//  Copyright © 2016 Ranchero Software, LLC. All rights reserved.
//

import Foundation
import RSCore
import RSDatabase
import Data

// Article->ArticleStatus is a to-one relationship.
//
// CREATE TABLE if not EXISTS statuses (articleID TEXT NOT NULL PRIMARY KEY, read BOOL NOT NULL DEFAULT 0, starred BOOL NOT NULL DEFAULT 0, userDeleted BOOL NOT NULL DEFAULT 0, dateArrived DATE NOT NULL DEFAULT 0, accountInfo BLOB);

typealias StatusesCompletionBlock = ([String: ArticleStatus]) -> Void // [articleID: Status]

final class StatusesTable: DatabaseTable {

	let name = DatabaseTableName.statuses
	private let cache = StatusCache()
	private let queue: RSDatabaseQueue
	
	init(queue: RSDatabaseQueue) {
		
		self.queue = queue
	}

	// MARK: Cache

//	func cachedStatus(for articleID: String) -> ArticleStatus? {
//
//		assert(Thread.isMainThread)
//		assert(cache[articleID] != nil)
//		return cache[articleID]
//	}
//
//	func cachedStatuses(for articleIDs: Set<String>) -> Set<ArticleStatus> {
//
//		assert(Thread.isMainThread)
//
//		var statuses = Set<ArticleStatus>()
//		for articleID in articleIDs {
//			if let articleStatus = cache[articleID] {
//				statuses.insert(articleStatus)
//			}
//		}
//
//		return statuses
//	}


	// MARK: Creating/Updating

	func ensureStatusesForArticleIDs(_ articleIDs: Set<String>, _ completion: @escaping StatusesCompletionBlock) {
		
		// Adds them to the cache if not cached.
		
		assert(Thread.isMainThread)
		
		// Check cache.
		let articleIDsMissingCachedStatus = articleIDsWithNoCachedStatus(articleIDs)
		if articleIDsMissingCachedStatus.isEmpty {
			completion(statusesDictionary(articleIDs))
			return
		}
		
		// Check database.
		fetchAndCacheStatusesForArticleIDs(articleIDsMissingCachedStatus) {
			
			let articleIDsNeedingStatus = self.articleIDsWithNoCachedStatus(articleIDs)
			if !articleIDsNeedingStatus.isEmpty {
				// Create new statuses.
				self.createAndSaveStatusesForArticleIDs(articleIDsNeedingStatus)
			}
			
			completion(self.statusesDictionary(articleIDs))
		}
	}

	// MARK: Marking

	func mark(_ statuses: Set<ArticleStatus>, _ statusKey: String, _ flag: Bool) {

		// Sets flag in both memory and in database.

		var updatedStatuses = Set<ArticleStatus>()

		for status in statuses {

			if status.boolStatus(forKey: statusKey) == flag {
				continue
			}
			status.setBoolStatus(flag, forKey: statusKey)
			updatedStatuses.insert(status)
		}

		if updatedStatuses.isEmpty {
			return
		}

		queue.update { (database) in
			self.markArticleIDs(updatedStatuses.articleIDs(), statusKey, flag, database)
		}
	}

	// MARK: Fetching

	func statusWithRow(_ row: FMResultSet) -> ArticleStatus? {

		guard let articleID = row.string(forColumn: DatabaseKey.articleID) else {
			return nil
		}
		guard let dateArrived = row.date(forColumn: DatabaseKey.dateArrived) else {
			return nil
		}

		let articleStatus = ArticleStatus(articleID: articleID, dateArrived: dateArrived, row: row)
		return articleStatus
	}
}

// MARK: - Private

private extension StatusesTable {

	// MARK: Cache
	
	func articleIDsWithNoCachedStatus(_ articleIDs: Set<String>) -> Set<String> {

		assert(Thread.isMainThread)
		return Set(articleIDs.filter { cache[$0] == nil })
	}

	func statusesDictionary(_ articleIDs: Set<String>) -> [String: ArticleStatus] {
		
		assert(Thread.isMainThread)
		
		var d = [String: ArticleStatus]()
		
		for articleID in articleIDs {
			if let articleStatus = cache[articleID] {
				d[articleID] = articleStatus
			}
		}
		
		return d
	}

	func addToCache(_ statuses: Set<ArticleStatus>) {

		// Replacing any already cached statuses.
		if statuses.isEmpty {
			return
		}

		if Thread.isMainThread {
			self.cache.add(statuses)
		}
		else {
			DispatchQueue.main.async {
				self.cache.add(statuses)
			}
		}
	}

	func addIfNotCached(_ statuses: Set<ArticleStatus>) {

		if statuses.isEmpty {
			return
		}

		if Thread.isMainThread {
			self.cache.addIfNotCached(statuses)
		}
		else {
			DispatchQueue.main.async {
				self.cache.addIfNotCached(statuses)
			}
		}
	}

	// MARK: Creating

	func saveStatuses(_ statuses: Set<ArticleStatus>) {

		queue.update { (database) in
			let statusArray = statuses.map { $0.databaseDictionary()! }
			self.insertRows(statusArray, insertType: .orIgnore, in: database)
		}
	}

	func createAndSaveStatusesForArticleIDs(_ articleIDs: Set<String>) {

		assert(Thread.isMainThread)
		
		let now = Date()
		let statuses = Set(articleIDs.map { ArticleStatus(articleID: $0, dateArrived: now) })
		cache.addIfNotCached(statuses)
		
		saveStatuses(statuses)
	}

	func fetchAndCacheStatusesForArticleIDs(_ articleIDs: Set<String>, _ completion: @escaping RSVoidCompletionBlock) {
		
		queue.fetch { (database) in
			guard let resultSet = self.selectRowsWhere(key: DatabaseKey.articleID, inValues: Array(articleIDs), in: database) else {
				completion()
				return
			}
			
			let statuses = resultSet.mapToSet(self.statusWithRow)
			
			DispatchQueue.main.async {
				self.cache.addIfNotCached(statuses)
				completion()
			}
		}
	}

	// MARK: Marking

	func markArticleIDs(_ articleIDs: Set<String>, _ statusKey: String, _ flag: Bool, _ database: FMDatabase) {

		updateRowsWithValue(NSNumber(value: flag), valueKey: statusKey, whereKey: DatabaseKey.articleID, matches: Array(articleIDs), database: database)
	}
}

private final class StatusCache {

	// Serial database queue only.

	var dictionary = [String: ArticleStatus]()

	func add(_ statuses: Set<ArticleStatus>) {

		// Replaces any cached statuses.

		assert(!Thread.isMainThread)

		for status in statuses {
			self[status.articleID] = status
		}
	}

	func addIfNotCached(_ statuses: Set<ArticleStatus>) {
		
		// Does not replace already cached statuses.
		
		assert(!Thread.isMainThread)

		for status in statuses {
			let articleID = status.articleID
			if let _ = self[articleID] {
				continue
			}
			self[articleID] = status
		}
	}
	
	subscript(_ articleID: String) -> ArticleStatus? {
		get {
			assert(!Thread.isMainThread)
			return self[articleID]
		}
		set {
			assert(!Thread.isMainThread)
			self[articleID] = newValue
		}
	}
}