diff --git a/server/src/main/kotlin/suwayomi/tachidesk/graphql/queries/SourceQuery.kt b/server/src/main/kotlin/suwayomi/tachidesk/graphql/queries/SourceQuery.kt
index 533883af..b1513072 100644
--- a/server/src/main/kotlin/suwayomi/tachidesk/graphql/queries/SourceQuery.kt
+++ b/server/src/main/kotlin/suwayomi/tachidesk/graphql/queries/SourceQuery.kt
@@ -9,10 +9,32 @@ package suwayomi.tachidesk.graphql.queries
 
 import com.expediagroup.graphql.server.extensions.getValueFromDataLoader
 import graphql.schema.DataFetchingEnvironment
+import org.jetbrains.exposed.sql.Column
+import org.jetbrains.exposed.sql.Op
+import org.jetbrains.exposed.sql.SortOrder
+import org.jetbrains.exposed.sql.SqlExpressionBuilder.greater
+import org.jetbrains.exposed.sql.SqlExpressionBuilder.less
+import org.jetbrains.exposed.sql.andWhere
 import org.jetbrains.exposed.sql.selectAll
 import org.jetbrains.exposed.sql.transactions.transaction
+import suwayomi.tachidesk.graphql.queries.filter.BooleanFilter
+import suwayomi.tachidesk.graphql.queries.filter.Filter
+import suwayomi.tachidesk.graphql.queries.filter.HasGetOp
+import suwayomi.tachidesk.graphql.queries.filter.LongFilter
+import suwayomi.tachidesk.graphql.queries.filter.OpAnd
+import suwayomi.tachidesk.graphql.queries.filter.StringFilter
+import suwayomi.tachidesk.graphql.queries.filter.andFilterWithCompare
+import suwayomi.tachidesk.graphql.queries.filter.andFilterWithCompareEntity
+import suwayomi.tachidesk.graphql.queries.filter.andFilterWithCompareString
+import suwayomi.tachidesk.graphql.queries.filter.applyOps
+import suwayomi.tachidesk.graphql.server.primitives.Cursor
+import suwayomi.tachidesk.graphql.server.primitives.OrderBy
+import suwayomi.tachidesk.graphql.server.primitives.PageInfo
+import suwayomi.tachidesk.graphql.server.primitives.QueryResults
+import suwayomi.tachidesk.graphql.server.primitives.greaterNotUnique
+import suwayomi.tachidesk.graphql.server.primitives.lessNotUnique
+import suwayomi.tachidesk.graphql.server.primitives.maybeSwap
 import suwayomi.tachidesk.graphql.types.SourceNodeList
-import suwayomi.tachidesk.graphql.types.SourceNodeList.Companion.toNodeList
 import suwayomi.tachidesk.graphql.types.SourceType
 import suwayomi.tachidesk.manga.model.table.SourceTable
 import java.util.concurrent.CompletableFuture
@@ -35,11 +57,157 @@ class SourceQuery {
         return dataFetchingEnvironment.getValueFromDataLoader<Long, SourceType?>("SourceDataLoader", id)
     }
 
-    fun sources(): SourceNodeList {
-        val results = transaction {
-            SourceTable.selectAll().toList().mapNotNull { SourceType(it) }
+    enum class SourceOrderBy(override val column: Column<out Comparable<*>>) : OrderBy<SourceType> {
+        ID(SourceTable.id),
+        NAME(SourceTable.name),
+        LANG(SourceTable.lang);
+
+        override fun greater(cursor: Cursor): Op<Boolean> {
+            return when (this) {
+                ID -> SourceTable.id greater cursor.value.toLong()
+                NAME -> greaterNotUnique(SourceTable.name, SourceTable.id, cursor, String::toString)
+                LANG -> greaterNotUnique(SourceTable.lang, SourceTable.id, cursor, String::toString)
+            }
         }
 
-        return results.toNodeList()
+        override fun less(cursor: Cursor): Op<Boolean> {
+            return when (this) {
+                ID -> SourceTable.id less cursor.value.toLong()
+                NAME -> lessNotUnique(SourceTable.name, SourceTable.id, cursor, String::toString)
+                LANG -> lessNotUnique(SourceTable.lang, SourceTable.id, cursor, String::toString)
+            }
+        }
+
+        override fun asCursor(type: SourceType): Cursor {
+            val value = when (this) {
+                ID -> type.id.toString()
+                NAME -> type.id.toString() + "-" + type.name
+                LANG -> type.id.toString() + "-" + type.lang
+            }
+            return Cursor(value)
+        }
+    }
+
+    data class SourceCondition(
+        val id: Long? = null,
+        val name: String? = null,
+        val lang: String? = null,
+        val isNsfw: Boolean? = null
+    ) : HasGetOp {
+        override fun getOp(): Op<Boolean>? {
+            val opAnd = OpAnd()
+            opAnd.eq(id, SourceTable.id)
+            opAnd.eq(name, SourceTable.name)
+            opAnd.eq(lang, SourceTable.lang)
+            opAnd.eq(isNsfw, SourceTable.isNsfw)
+
+            return opAnd.op
+        }
+    }
+
+    data class SourceFilter(
+        val id: LongFilter? = null,
+        val name: StringFilter? = null,
+        val lang: StringFilter? = null,
+        val isNsfw: BooleanFilter? = null,
+        override val and: List<SourceFilter>? = null,
+        override val or: List<SourceFilter>? = null,
+        override val not: SourceFilter? = null
+    ) : Filter<SourceFilter> {
+        override fun getOpList(): List<Op<Boolean>> {
+            return listOfNotNull(
+                andFilterWithCompareEntity(SourceTable.id, id),
+                andFilterWithCompareString(SourceTable.name, name),
+                andFilterWithCompareString(SourceTable.lang, lang),
+                andFilterWithCompare(SourceTable.isNsfw, isNsfw)
+            )
+        }
+    }
+
+    fun sources(
+        condition: SourceCondition? = null,
+        filter: SourceFilter? = null,
+        orderBy: SourceOrderBy? = null,
+        orderByType: SortOrder? = null,
+        before: Cursor? = null,
+        after: Cursor? = null,
+        first: Int? = null,
+        last: Int? = null,
+        offset: Int? = null
+    ): SourceNodeList {
+        val (queryResults, resultsAsType) = transaction {
+            val res = SourceTable.selectAll()
+
+            res.applyOps(condition, filter)
+
+            if (orderBy != null || (last != null || before != null)) {
+                val orderByColumn = orderBy?.column ?: SourceTable.id
+                val orderType = orderByType.maybeSwap(last ?: before)
+
+                if (orderBy == SourceOrderBy.ID || orderBy == null) {
+                    res.orderBy(orderByColumn to orderType)
+                } else {
+                    res.orderBy(
+                        orderByColumn to orderType,
+                        SourceTable.id to SortOrder.ASC
+                    )
+                }
+            }
+
+            val total = res.count()
+            val firstResult = res.firstOrNull()?.get(SourceTable.id)?.value
+            val lastResult = res.lastOrNull()?.get(SourceTable.id)?.value
+
+            if (after != null) {
+                res.andWhere {
+                    (orderBy ?: SourceOrderBy.ID).greater(after)
+                }
+            } else if (before != null) {
+                res.andWhere {
+                    (orderBy ?: SourceOrderBy.ID).less(before)
+                }
+            }
+
+            if (first != null) {
+                res.limit(first, offset?.toLong() ?: 0)
+            } else if (last != null) {
+                res.limit(last)
+            }
+
+            QueryResults(total, firstResult, lastResult, res.toList()).let {
+                it to it.results.mapNotNull { SourceType(it) }
+            }
+        }
+
+        val getAsCursor: (SourceType) -> Cursor = (orderBy ?: SourceOrderBy.ID)::asCursor
+
+        return SourceNodeList(
+            resultsAsType,
+            if (resultsAsType.isEmpty()) {
+                emptyList()
+            } else {
+                listOfNotNull(
+                    resultsAsType.firstOrNull()?.let {
+                        SourceNodeList.SourceEdge(
+                            getAsCursor(it),
+                            it
+                        )
+                    },
+                    resultsAsType.lastOrNull()?.let {
+                        SourceNodeList.SourceEdge(
+                            getAsCursor(it),
+                            it
+                        )
+                    }
+                )
+            },
+            pageInfo = PageInfo(
+                hasNextPage = queryResults.lastKey != resultsAsType.lastOrNull()?.id,
+                hasPreviousPage = queryResults.firstKey != resultsAsType.firstOrNull()?.id,
+                startCursor = resultsAsType.firstOrNull()?.let { getAsCursor(it) },
+                endCursor = resultsAsType.lastOrNull()?.let { getAsCursor(it) }
+            ),
+            totalCount = queryResults.total.toInt()
+        )
     }
 }
diff --git a/server/src/main/kotlin/suwayomi/tachidesk/graphql/server/primitives/OrderBy.kt b/server/src/main/kotlin/suwayomi/tachidesk/graphql/server/primitives/OrderBy.kt
index 5b3e5f0c..4cf89215 100644
--- a/server/src/main/kotlin/suwayomi/tachidesk/graphql/server/primitives/OrderBy.kt
+++ b/server/src/main/kotlin/suwayomi/tachidesk/graphql/server/primitives/OrderBy.kt
@@ -36,13 +36,34 @@ fun SortOrder?.maybeSwap(value: Any?): SortOrder {
     }
 }
 
+@JvmName("greaterNotUniqueIntKey")
 fun <T : Comparable<T>> greaterNotUnique(
     column: Column<T>,
     idColumn: Column<EntityID<Int>>,
     cursor: Cursor,
     toValue: (String) -> T
 ): Op<Boolean> {
-    val id = cursor.value.substringBefore('-').toInt()
+    return greaterNotUniqueImpl(column, idColumn, cursor, String::toInt, toValue)
+}
+
+@JvmName("greaterNotUniqueLongKey")
+fun <T : Comparable<T>> greaterNotUnique(
+    column: Column<T>,
+    idColumn: Column<EntityID<Long>>,
+    cursor: Cursor,
+    toValue: (String) -> T
+): Op<Boolean> {
+    return greaterNotUniqueImpl(column, idColumn, cursor, String::toLong, toValue)
+}
+
+private fun <K : Comparable<K>, V : Comparable<V>> greaterNotUniqueImpl(
+    column: Column<V>,
+    idColumn: Column<EntityID<K>>,
+    cursor: Cursor,
+    toKey: (String) -> K,
+    toValue: (String) -> V
+): Op<Boolean> {
+    val id = toKey(cursor.value.substringBefore('-'))
     val value = toValue(cursor.value.substringAfter('-'))
     return (column greater value) or ((column eq value) and (idColumn greater id))
 }
@@ -59,13 +80,34 @@ fun <T : Comparable<T>> greaterNotUnique(
     return (column greater value) or ((column eq value) and (idColumn greater id))
 }
 
+@JvmName("lessNotUniqueIntKey")
 fun <T : Comparable<T>> lessNotUnique(
     column: Column<T>,
     idColumn: Column<EntityID<Int>>,
     cursor: Cursor,
     toValue: (String) -> T
 ): Op<Boolean> {
-    val id = cursor.value.substringBefore('-').toInt()
+    return lessNotUniqueImpl(column, idColumn, cursor, String::toInt, toValue)
+}
+
+@JvmName("lessNotUniqueLongKey")
+fun <T : Comparable<T>> lessNotUnique(
+    column: Column<T>,
+    idColumn: Column<EntityID<Long>>,
+    cursor: Cursor,
+    toValue: (String) -> T
+): Op<Boolean> {
+    return lessNotUniqueImpl(column, idColumn, cursor, String::toLong, toValue)
+}
+
+private fun <K : Comparable<K>, V : Comparable<V>> lessNotUniqueImpl(
+    column: Column<V>,
+    idColumn: Column<EntityID<K>>,
+    cursor: Cursor,
+    toKey: (String) -> K,
+    toValue: (String) -> V
+): Op<Boolean> {
+    val id = toKey(cursor.value.substringBefore('-'))
     val value = toValue(cursor.value.substringAfter('-'))
     return (column less value) or ((column eq value) and (idColumn less id))
 }