mrgodhani/raven-reader

import lf from 'lovefield'
import * as db from '../db'
import store from '../store'
import dayjs from 'dayjs'

export default {
  fetchFeeds () {
    return db.database.select().from(db.feedTable).exec()
  },
  fetchServicesFeeds (service) {
    return db.database.select().from(db.feedTable).where(db.feedTable.source.eq(service)).exec()
  },
  fetchServicesArticles (service) {
    return db.database
      .select()
      .from(db.articleTable)
      .innerJoin(db.feedTable, db.feedTable.uuid.eq(db.articleTable.feed_uuid))
      .where(db.feedTable.source.eq(service))
      .exec()
  },
  fetchArticles () {
    return db.database
      .select()
      .from(db.articleTable)
      .innerJoin(db.feedTable, db.feedTable.uuid.eq(db.articleTable.feed_uuid))
      .exec()
  },
  fetchArticlesByFeed (feedId) {
    return db.database
      .select()
      .from(db.articleTable)
      .where(db.articleTable.feed_uuid.eq(feedId))
      .exec()
  },
  fetchArticlesByFeedMulti (feedIds) {
    return db.database
      .select()
      .from(db.articleTable)
      .where(db.articleTable.feed_uuid.in(feedIds))
      .exec()
  },
  addFeed (data) {
    return db.database.insertOrReplace().into(db.feedTable).values(data).exec()
  },
  deleteFeed (feedId) {
    return db.database.delete().from(db.feedTable).where(db.feedTable.uuid.eq(feedId)).exec()
  },
  deleteAllSyncAccountSubscriptions (subscription) {
    return db.database.delete().from(db.feedTable).where(db.feedTable.source.eq(subscription)).exec()
  },
  deleteFeedMulti (feedIds) {
    return db.database.delete().from(db.feedTable).where(db.feedTable.uuid.in(feedIds)).exec()
  },
  updateFeedTitle (id, title, category) {
    return db.database.update(db.feedTable)
      .set(db.feedTable.title, title)
      .set(db.feedTable.category, category)
      .where(db.feedTable.uuid.eq(id))
      .exec()
  },
  updateFeedCategory (ids, category) {
    return db.database.update(db.feedTable)
      .set(db.feedTable.category, category)
      .where(db.feedTable.uuid.in(ids))
      .exec()
  },
  addArticles (data) {
    return db.database.insertOrReplace().into(db.articleTable).values(data).exec()
  },
  deleteArticles (feedId) {
    return db.database.delete().from(db.articleTable).where(db.articleTable.feed_uuid.eq(feedId)).exec()
  },
  deleteArticlesSyncAccount (subscription) {
    return db.database.delete().from(db.articleTable).where(db.articleTable.source.eq(subscription)).exec()
  },
  deleteArticlesMulti (articles) {
    return db.database.delete().from(db.articleTable).where(db.articleTable.uuid.in(articles)).exec()
  },
  fetchArticle (uuid) {
    return db.database.select()
      .from(db.articleTable)
      .innerJoin(db.feedTable, db.feedTable.uuid.eq(db.articleTable.feed_uuid))
      .where(db.articleTable.uuid.eq(uuid))
      .exec()
  },
  updateArticleCategoryFeed (feedid, category) {
    return db.database.update(db.articleTable)
      .set(db.articleTable.category, category)
      .where(db.articleTable.feed_uuid.eq(feedid))
      .exec()
  },
  updateArticleCategoryFeedMulti (feedids, category) {
    return db.database.update(db.articleTable)
      .set(db.articleTable.category, category)
      .where(db.articleTable.feed_uuid.in(feedids))
      .exec()
  },
  updateArticleCategory (uuids, category) {
    return db.database.update(db.articleTable)
      .set(db.articleTable.category, category)
      .where(db.articleTable.uuid.in(uuids))
      .exec()
  },
  addCategory (data) {
    return db.database.insertOrReplace().into(db.categoryTable).values(data).exec()
  },
  fetchCategories () {
    return db.database.select().from(db.categoryTable).exec()
  },
  fetchCategoriesBySource (source) {
    return db.database.select().from(db.categoryTable).where(db.categoryTable.source.eq(source)).exec()
  },
  updateCategory (id, category) {
    return db.database.update(db.categoryTable)
      .set(db.categoryTable.title, category)
      .where(db.categoryTable.id.eq(id))
      .exec()
  },
  deleteCategoryBySource (source) {
    return db.database.delete().from(db.categoryTable).where(db.categoryTable.source.eq(source)).exec()
  },
  deleteCategory (title) {
    return db.database.delete().from(db.categoryTable).where(db.categoryTable.title.eq(title)).exec()
  },
  deleteCategoryMulti (titles) {
    return db.database.delete().from(db.categoryTable).where(db.categoryTable.title.in(titles)).exec()
  },
  markOffline (uuid, verdict) {
    return db.database.update(db.articleTable)
      .set(db.articleTable.offline, verdict)
      .where(db.articleTable.uuid.eq(uuid))
      .exec()
  },
  markCategoryRead (title) {
    return db.database.update(db.articleTable)
      .set(db.articleTable.read, true)
      .set(db.articleTable.keep_read, dayjs().add(store.state.Setting.keepRead, 'week').valueOf())
      .where(db.articleTable.category.eq(title))
      .exec()
  },
  markRead (uuid, podcast, verdict) {
    if (podcast) {
      return db.database.update(db.articleTable)
        .set(db.articleTable.read, verdict)
        .set(db.articleTable.played, verdict)
        .set(db.articleTable.keep_read, dayjs().add(store.state.Setting.keepRead, 'week').valueOf())
        .where(db.articleTable.uuid.eq(uuid))
        .exec()
    }
    return db.database.update(db.articleTable)
      .set(db.articleTable.read, verdict)
      .set(db.articleTable.keep_read, dayjs().add(store.state.Setting.keepRead, 'week').valueOf())
      .where(db.articleTable.uuid.eq(uuid))
      .exec()
  },
  markAllunread (uuids) {
    // Non-podcast
    return db.database.update(db.articleTable)
      .set(db.articleTable.read, false)
      .set(db.articleTable.keep_read, dayjs().add(store.state.Setting.keepRead, 'week').valueOf())
      .where(db.articleTable.uuid.in(uuids))
      .exec()
  },
  markAllRead (uuids) {
    // Non-podcast
    return db.database.update(db.articleTable)
      .set(db.articleTable.read, true)
      .set(db.articleTable.keep_read, dayjs().add(store.state.Setting.keepRead, 'week').valueOf())
      .where(db.articleTable.uuid.in(uuids))
      .exec()
  },
  markBulkFavourite (uuids) {
    return db.database.update(db.articleTable)
      .set(db.articleTable.favourite, true)
      .where(db.articleTable.uuid.in(uuids))
      .exec()
  },
  markBulkUnFavourite (uuids) {
    return db.database.update(db.articleTable)
      .set(db.articleTable.favourite, false)
      .where(db.articleTable.uuid.in(uuids))
      .exec()
  },
  markFavourite (uuid, verdict) {
    return db.database.update(db.articleTable)
      .set(db.articleTable.favourite, verdict)
      .where(db.articleTable.uuid.eq(uuid))
      .exec()
  },
  removeOldReadItems (week) {
    db.database.delete()
      .from(db.articleTable)
      .where(lf.op.and(
        db.articleTable.read.eq(true),
        db.articleTable.publishUnix.lt(week)
      )).exec()
  },
  deleteAllData () {
    return new Promise((resolve, reject) => {
      db.database.delete()
        .from(db.articleTable).exec()
      db.database.delete()
        .from(db.feedTable).exec()
      db.database.delete()
        .from(db.categoryTable).exec()
      resolve(true)
    })
  },
  deleteArticleByKeepRead () {
    return db.database.delete()
      .from(db.articleTable)
      .where(lf.op.or(
        db.articleTable.keep_read.lt(dayjs().valueOf()),
        db.articleTable.keep_read.eq(dayjs().valueOf())
      ))
      .exec()
  },
  unassignFeeds (uuids) {
    return db.database.update(db.feedTable)
      .set(db.feedTable.category, null)
      .where(db.feedTable.uuid.in(uuids))
      .exec()
  },
  unassignCategoriesArticles (uuids) {
    return db.database.update(db.articleTable)
      .set(db.articleTable.category, null)
      .where(db.articleTable.uuid.in(uuids))
      .exec()
  }
}