mirror of
https://github.com/InsanusMokrassar/SauceNaoAPI.git
synced 2024-11-16 20:03:46 +00:00
Compare commits
No commits in common. "master" and "0.11.0" have entirely different histories.
7
.github/workflows/build_and_publish.yml
vendored
7
.github/workflows/build_and_publish.yml
vendored
@ -16,13 +16,8 @@ jobs:
|
|||||||
mv gradle.properties.tmp gradle.properties
|
mv gradle.properties.tmp gradle.properties
|
||||||
- name: Build
|
- name: Build
|
||||||
run: ./gradlew build
|
run: ./gradlew build
|
||||||
- name: Publish to Gitea
|
|
||||||
continue-on-error: true
|
|
||||||
run: ./gradlew publishAllPublicationsToGiteaRepository
|
|
||||||
env:
|
|
||||||
GITEA_TOKEN: ${{ secrets.GITEA_TOKEN }}
|
|
||||||
- name: Publish
|
- name: Publish
|
||||||
run: ./gradlew publishAllPublicationsToGithubPackagesRepository --no-parallel
|
run: ./gradlew publishAllPublicationsToGithubPackagesRepository --no-parallel -x signJsPublication -x signJvmPublication -x signKotlinMultiplatformPublication
|
||||||
continue-on-error: true
|
continue-on-error: true
|
||||||
env:
|
env:
|
||||||
GITHUBPACKAGES_USER: ${{ github.actor }}
|
GITHUBPACKAGES_USER: ${{ github.actor }}
|
||||||
|
1
.gitignore
vendored
1
.gitignore
vendored
@ -8,4 +8,3 @@ settings.xml
|
|||||||
.gradle/
|
.gradle/
|
||||||
build/
|
build/
|
||||||
out/
|
out/
|
||||||
kotlin-js-store/
|
|
||||||
|
77
CHANGELOG.md
77
CHANGELOG.md
@ -1,82 +1,5 @@
|
|||||||
# SauceNaoAPI Changelog
|
# SauceNaoAPI Changelog
|
||||||
|
|
||||||
## 0.17.2
|
|
||||||
|
|
||||||
* Versions:
|
|
||||||
* `Coroutines`: `1.7.3`
|
|
||||||
* `Ktor`: `2.3.4`
|
|
||||||
* `MicroUtils`: `0.19.9`
|
|
||||||
|
|
||||||
## 0.17.1
|
|
||||||
|
|
||||||
* Versions:
|
|
||||||
* `Coroutines`: `1.7.2`
|
|
||||||
* `Ktor`: `2.3.2`
|
|
||||||
* `MicroUtils`: `0.19.7`
|
|
||||||
|
|
||||||
## 0.17.0
|
|
||||||
|
|
||||||
* Versions:
|
|
||||||
* `Kotlin`: `1.8.22`
|
|
||||||
* `Serialization`: `1.5.1`
|
|
||||||
* `Ktor`: `2.3.1`
|
|
||||||
* `MicroUtils`: `0.19.2`
|
|
||||||
* `Klock`: `4.0.3`
|
|
||||||
|
|
||||||
## 0.16.0
|
|
||||||
|
|
||||||
Add `MicroUtils` as used micro utils
|
|
||||||
|
|
||||||
* Versions:
|
|
||||||
* `Kotlin`: `1.8.21`
|
|
||||||
* `Ktor`: `2.3.0`
|
|
||||||
|
|
||||||
## 0.15.1
|
|
||||||
|
|
||||||
* Versions:
|
|
||||||
* `Ktor`: `2.2.4`
|
|
||||||
|
|
||||||
## 0.15.0
|
|
||||||
|
|
||||||
* Versions:
|
|
||||||
* `Kotlin`: `1.8.10`
|
|
||||||
* `Serialization`: `1.5.0`
|
|
||||||
* `Ktor`: `2.2.3`
|
|
||||||
|
|
||||||
## 0.14.0
|
|
||||||
|
|
||||||
* `LimitStatus` is `Comparable<LimitStatus>` since this update
|
|
||||||
* `Limits` is `Comparable<Limits>` since this update
|
|
||||||
* Main API has been changed
|
|
||||||
|
|
||||||
## 0.13.0
|
|
||||||
|
|
||||||
* Versions:
|
|
||||||
* `Kotlin`: `1.7.20` -> `1.7.22`
|
|
||||||
* `Serialization`: `1.4.0` -> `1.4.1`
|
|
||||||
* `Klock`: `3.2.0` -> `3.4.0`
|
|
||||||
* `Ktor`: `2.1.2` -> `2.2.1`
|
|
||||||
* Now it is possible to subscribe onto API limits changes
|
|
||||||
|
|
||||||
## 0.12.2
|
|
||||||
|
|
||||||
* Versions:
|
|
||||||
* `Kotlin`: `1.7.10` -> `1.7.20`
|
|
||||||
* `Serialization`: `1.4.0-RC` -> `1.4.0`
|
|
||||||
* `Klock`: `3.0.0` -> `3.2.0`
|
|
||||||
* `Ktor`: `2.1.0` -> `2.1.2`
|
|
||||||
|
|
||||||
## 0.12.1
|
|
||||||
|
|
||||||
* Versions:
|
|
||||||
* `Ktor`: `2.0.3` -> `2.1.0`
|
|
||||||
|
|
||||||
## 0.11.1
|
|
||||||
|
|
||||||
* Versions updates:
|
|
||||||
* `Ktor`: `2.0.1` -> `2.0.3`
|
|
||||||
* `Coroutines`: `1.6.1` -> `1.6.4`
|
|
||||||
|
|
||||||
## 0.11.0
|
## 0.11.0
|
||||||
|
|
||||||
* Versions updates:
|
* Versions updates:
|
||||||
|
18
build.gradle
18
build.gradle
@ -28,19 +28,11 @@ repositories {
|
|||||||
}
|
}
|
||||||
|
|
||||||
kotlin {
|
kotlin {
|
||||||
jvm {
|
jvm()
|
||||||
compilations.main {
|
|
||||||
kotlinOptions {
|
|
||||||
jvmTarget = "1.8"
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
js(IR) {
|
js(IR) {
|
||||||
browser()
|
browser()
|
||||||
nodejs()
|
nodejs()
|
||||||
}
|
}
|
||||||
linuxX64()
|
|
||||||
mingwX64()
|
|
||||||
|
|
||||||
|
|
||||||
sourceSets {
|
sourceSets {
|
||||||
@ -52,9 +44,6 @@ kotlin {
|
|||||||
api libs.kt.serialization
|
api libs.kt.serialization
|
||||||
api libs.klock
|
api libs.klock
|
||||||
api libs.ktor.client
|
api libs.ktor.client
|
||||||
api libs.microutils.common
|
|
||||||
api libs.microutils.ktor.common
|
|
||||||
api libs.microutils.mimetypes
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
commonTest {
|
commonTest {
|
||||||
@ -76,8 +65,3 @@ kotlin {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
java {
|
|
||||||
sourceCompatibility = JavaVersion.VERSION_1_8
|
|
||||||
targetCompatibility = JavaVersion.VERSION_1_8
|
|
||||||
}
|
|
||||||
|
@ -19,7 +19,7 @@ if (new File(projectDir, "secret.gradle").exists()) {
|
|||||||
owner "InsanusMokrassar"
|
owner "InsanusMokrassar"
|
||||||
repo "${rootProject.name}"
|
repo "${rootProject.name}"
|
||||||
|
|
||||||
tagName "v${project.version}"
|
tagName "${project.version}"
|
||||||
releaseName "${project.version}"
|
releaseName "${project.version}"
|
||||||
targetCommitish "${project.version}"
|
targetCommitish "${project.version}"
|
||||||
|
|
||||||
|
@ -1,3 +1,3 @@
|
|||||||
kotlin.code.style=official
|
kotlin.code.style=official
|
||||||
|
|
||||||
library_version=0.17.2
|
library_version=0.11.0
|
||||||
|
@ -1,15 +1,13 @@
|
|||||||
[versions]
|
[versions]
|
||||||
|
|
||||||
kt = "1.8.22"
|
kt = "1.6.21"
|
||||||
kt-serialization = "1.5.1"
|
kt-serialization = "1.3.3"
|
||||||
kt-coroutines = "1.7.3"
|
kt-coroutines = "1.6.1"
|
||||||
|
|
||||||
klock = "4.0.3"
|
klock = "2.7.0"
|
||||||
ktor = "2.3.4"
|
ktor = "2.0.1"
|
||||||
|
|
||||||
microutils = "0.19.9"
|
gh-release = "2.3.7"
|
||||||
|
|
||||||
gh-release = "2.4.1"
|
|
||||||
|
|
||||||
[libraries]
|
[libraries]
|
||||||
|
|
||||||
@ -22,10 +20,6 @@ klock = { module = "com.soywiz.korlibs.klock:klock", version.ref = "klock" }
|
|||||||
ktor-client = { module = "io.ktor:ktor-client-core", version.ref = "ktor" }
|
ktor-client = { module = "io.ktor:ktor-client-core", version.ref = "ktor" }
|
||||||
ktor-client-okhttp = { module = "io.ktor:ktor-client-okhttp", version.ref = "ktor" }
|
ktor-client-okhttp = { module = "io.ktor:ktor-client-okhttp", version.ref = "ktor" }
|
||||||
|
|
||||||
microutils-common = { module = "dev.inmo:micro_utils.common", version.ref = "microutils" }
|
|
||||||
microutils-ktor-common = { module = "dev.inmo:micro_utils.ktor.common", version.ref = "microutils" }
|
|
||||||
microutils-mimetypes = { module = "dev.inmo:micro_utils.mime_types", version.ref = "microutils" }
|
|
||||||
|
|
||||||
buildscript-kt-gradle = { module = "org.jetbrains.kotlin:kotlin-gradle-plugin", version.ref = "kt" }
|
buildscript-kt-gradle = { module = "org.jetbrains.kotlin:kotlin-gradle-plugin", version.ref = "kt" }
|
||||||
buildscript-kt-serialization = { module = "org.jetbrains.kotlin:kotlin-serialization", version.ref = "kt" }
|
buildscript-kt-serialization = { module = "org.jetbrains.kotlin:kotlin-serialization", version.ref = "kt" }
|
||||||
buildscript-gh-release = { module = "com.github.breadmoirai:github-release", version.ref = "gh-release" }
|
buildscript-gh-release = { module = "com.github.breadmoirai:github-release", version.ref = "gh-release" }
|
||||||
|
2
gradle/wrapper/gradle-wrapper.properties
vendored
2
gradle/wrapper/gradle-wrapper.properties
vendored
@ -3,4 +3,4 @@ distributionBase=GRADLE_USER_HOME
|
|||||||
distributionPath=wrapper/dists
|
distributionPath=wrapper/dists
|
||||||
zipStoreBase=GRADLE_USER_HOME
|
zipStoreBase=GRADLE_USER_HOME
|
||||||
zipStorePath=wrapper/dists
|
zipStorePath=wrapper/dists
|
||||||
distributionUrl=https\://services.gradle.org/distributions/gradle-7.6.1-bin.zip
|
distributionUrl=https\://services.gradle.org/distributions/gradle-7.4.2-bin.zip
|
||||||
|
2058
kotlin-js-store/yarn.lock
Normal file
2058
kotlin-js-store/yarn.lock
Normal file
File diff suppressed because it is too large
Load Diff
@ -42,40 +42,20 @@ publishing {
|
|||||||
maven {
|
maven {
|
||||||
name = "GithubPackages"
|
name = "GithubPackages"
|
||||||
url = uri("https://maven.pkg.github.com/InsanusMokrassar/SauceNaoAPI")
|
url = uri("https://maven.pkg.github.com/InsanusMokrassar/SauceNaoAPI")
|
||||||
|
|
||||||
credentials {
|
credentials {
|
||||||
username = project.hasProperty('GITHUBPACKAGES_USER') ? project.property('GITHUBPACKAGES_USER') : System.getenv('GITHUBPACKAGES_USER')
|
username = project.hasProperty('GITHUBPACKAGES_USER') ? project.property('GITHUBPACKAGES_USER') : System.getenv('GITHUBPACKAGES_USER')
|
||||||
password = project.hasProperty('GITHUBPACKAGES_PASSWORD') ? project.property('GITHUBPACKAGES_PASSWORD') : System.getenv('GITHUBPACKAGES_PASSWORD')
|
password = project.hasProperty('GITHUBPACKAGES_PASSWORD') ? project.property('GITHUBPACKAGES_PASSWORD') : System.getenv('GITHUBPACKAGES_PASSWORD')
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
|
||||||
}
|
|
||||||
if (project.hasProperty('GITEA_TOKEN') || System.getenv('GITEA_TOKEN') != null) {
|
|
||||||
maven {
|
|
||||||
name = "Gitea"
|
|
||||||
url = uri("https://git.inmo.dev/api/packages/InsanusMokrassar/maven")
|
|
||||||
|
|
||||||
credentials(HttpHeaderCredentials) {
|
|
||||||
name = "Authorization"
|
|
||||||
value = project.hasProperty('GITEA_TOKEN') ? project.property('GITEA_TOKEN') : System.getenv('GITEA_TOKEN')
|
|
||||||
}
|
|
||||||
|
|
||||||
authentication {
|
|
||||||
header(HttpHeaderAuthentication)
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
if ((project.hasProperty('SONATYPE_USER') || System.getenv('SONATYPE_USER') != null) && (project.hasProperty('SONATYPE_PASSWORD') || System.getenv('SONATYPE_PASSWORD') != null)) {
|
if ((project.hasProperty('SONATYPE_USER') || System.getenv('SONATYPE_USER') != null) && (project.hasProperty('SONATYPE_PASSWORD') || System.getenv('SONATYPE_PASSWORD') != null)) {
|
||||||
maven {
|
maven {
|
||||||
name = "sonatype"
|
name = "sonatype"
|
||||||
url = uri("https://oss.sonatype.org/service/local/staging/deploy/maven2/")
|
url = uri("https://oss.sonatype.org/service/local/staging/deploy/maven2/")
|
||||||
|
|
||||||
credentials {
|
credentials {
|
||||||
username = project.hasProperty('SONATYPE_USER') ? project.property('SONATYPE_USER') : System.getenv('SONATYPE_USER')
|
username = project.hasProperty('SONATYPE_USER') ? project.property('SONATYPE_USER') : System.getenv('SONATYPE_USER')
|
||||||
password = project.hasProperty('SONATYPE_PASSWORD') ? project.property('SONATYPE_PASSWORD') : System.getenv('SONATYPE_PASSWORD')
|
password = project.hasProperty('SONATYPE_PASSWORD') ? project.property('SONATYPE_PASSWORD') : System.getenv('SONATYPE_PASSWORD')
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -1 +1 @@
|
|||||||
{"licenses":[{"id":"Apache-2.0","title":"Apache Software License 2.0","url":"https://github.com/InsanusMokrassar/SauceNaoAPI/blob/master/LICENSE"}],"mavenConfig":{"name":"SauceNao API","description":"SauceNao API library","url":"https://insanusmokrassar.github.io/${project.name}","vcsUrl":"https://github.com/insanusmokrassar/${project.name}.git","developers":[{"id":"InsanusMokrassar","name":"Ovsyannikov Alexey","eMail":"ovsyannikov.alexey95@gmail.com"}],"repositories":[{"name":"GithubPackages","url":"https://maven.pkg.github.com/InsanusMokrassar/SauceNaoAPI"},{"name":"Gitea","url":"https://git.inmo.dev/api/packages/InsanusMokrassar/maven","credsType":{"type":"dev.inmo.kmppscriptbuilder.core.models.MavenPublishingRepository.CredentialsType.HttpHeaderCredentials","headerName":"Authorization","headerValueProperty":"GITEA_TOKEN"}},{"name":"sonatype","url":"https://oss.sonatype.org/service/local/staging/deploy/maven2/"}],"gpgSigning":{"type":"dev.inmo.kmppscriptbuilder.core.models.GpgSigning.Optional"}}}
|
{"licenses":[{"id":"Apache-2.0","title":"Apache Software License 2.0","url":"https://github.com/InsanusMokrassar/SauceNaoAPI/blob/master/LICENSE"}],"mavenConfig":{"name":"SauceNao API","description":"SauceNao API library","url":"https://insanusmokrassar.github.io/${project.name}","vcsUrl":"https://github.com/insanusmokrassar/${project.name}.git","developers":[{"id":"InsanusMokrassar","name":"Ovsyannikov Alexey","eMail":"ovsyannikov.alexey95@gmail.com"}],"repositories":[{"name":"GithubPackages","url":"https://maven.pkg.github.com/InsanusMokrassar/SauceNaoAPI"},{"name":"sonatype","url":"https://oss.sonatype.org/service/local/staging/deploy/maven2/"}],"gpgSigning":{"type":"dev.inmo.kmppscriptbuilder.core.models.GpgSigning.Optional"}}}
|
@ -1,7 +1,5 @@
|
|||||||
package dev.inmo.saucenaoapi
|
package dev.inmo.saucenaoapi
|
||||||
|
|
||||||
import dev.inmo.micro_utils.common.MPPFile
|
|
||||||
import dev.inmo.micro_utils.ktor.common.input
|
|
||||||
import dev.inmo.saucenaoapi.exceptions.TooManyRequestsException
|
import dev.inmo.saucenaoapi.exceptions.TooManyRequestsException
|
||||||
import dev.inmo.saucenaoapi.exceptions.sauceNaoAPIException
|
import dev.inmo.saucenaoapi.exceptions.sauceNaoAPIException
|
||||||
import dev.inmo.saucenaoapi.models.*
|
import dev.inmo.saucenaoapi.models.*
|
||||||
@ -24,7 +22,6 @@ private const val URL_FIELD = "url"
|
|||||||
private const val FILE_FIELD = "file"
|
private const val FILE_FIELD = "file"
|
||||||
private const val FILENAME_FIELD = "filename"
|
private const val FILENAME_FIELD = "filename"
|
||||||
private const val DB_FIELD = "db"
|
private const val DB_FIELD = "db"
|
||||||
private const val DBS_FIELD = "dbs[]"
|
|
||||||
private const val DBMASK_FIELD = "dbmask"
|
private const val DBMASK_FIELD = "dbmask"
|
||||||
private const val DBMASKI_FIELD = "dbmaski"
|
private const val DBMASKI_FIELD = "dbmaski"
|
||||||
private const val RESULTS_COUNT_FIELD = "numres"
|
private const val RESULTS_COUNT_FIELD = "numres"
|
||||||
@ -55,12 +52,8 @@ data class SauceNaoAPI(
|
|||||||
private val timeManager = TimeManager(subscope)
|
private val timeManager = TimeManager(subscope)
|
||||||
private val quotaManager = RequestQuotaManager(subscope)
|
private val quotaManager = RequestQuotaManager(subscope)
|
||||||
|
|
||||||
val limitsState: LimitsState by quotaManager::limitsState
|
val limitsState: LimitsState
|
||||||
val longQuotaFlow by quotaManager::longQuotaFlow
|
get() = quotaManager.limitsState
|
||||||
val shortQuotaFlow by quotaManager::shortQuotaFlow
|
|
||||||
val longMaxQuotaFlow by quotaManager::longMaxQuotaFlow
|
|
||||||
val shortMaxQuotaFlow by quotaManager::shortMaxQuotaFlow
|
|
||||||
val limitsStateFlow by quotaManager::limitsStateFlow
|
|
||||||
|
|
||||||
private val requestsJob = subscope.launch {
|
private val requestsJob = subscope.launch {
|
||||||
for ((callback, requestBuilder) in requestsChannel) {
|
for ((callback, requestBuilder) in requestsChannel) {
|
||||||
@ -95,45 +88,6 @@ data class SauceNaoAPI(
|
|||||||
minSimilarity = minSimilarity
|
minSimilarity = minSimilarity
|
||||||
)
|
)
|
||||||
|
|
||||||
/**
|
|
||||||
* @param db search a specific index number or all without needing to generate a bitmask.
|
|
||||||
* @param dbs search one or more specific index number, set more than once to search multiple.
|
|
||||||
*/
|
|
||||||
suspend fun requestByDBs(
|
|
||||||
url: String,
|
|
||||||
db: Int? = null,
|
|
||||||
dbs: Array<Int>? = null,
|
|
||||||
resultsCount: Int? = null,
|
|
||||||
minSimilarity: Float? = null
|
|
||||||
): SauceNaoAnswer = makeRequest(
|
|
||||||
url.asSauceRequestSubject,
|
|
||||||
db = db,
|
|
||||||
dbs = dbs,
|
|
||||||
resultsCount = resultsCount,
|
|
||||||
minSimilarity = minSimilarity
|
|
||||||
)
|
|
||||||
|
|
||||||
/**
|
|
||||||
* @param mask Mask for selecting specific indexes to ENABLE. dbmask=8191 will search all of the first 14 indexes. If intending to search all databases, the db=999 option is more appropriate.
|
|
||||||
* @param excludedMask Mask for selecting specific indexes to DISABLE. dbmaski=8191 would search only indexes higher than the first 14. This is ideal when attempting to disable only certain indexes, while allowing future indexes to be included by default.
|
|
||||||
*
|
|
||||||
* Bitmask Note: Index numbers start with 0. Even though pixiv is labeled as index 5, it would be controlled with the 6th bit position, which has a decimal value of 32 when set.
|
|
||||||
* db=<index num or 999 for all>
|
|
||||||
*/
|
|
||||||
suspend fun requestByMasks(
|
|
||||||
url: String,
|
|
||||||
mask: Int?,
|
|
||||||
excludedMask: Int? = null,
|
|
||||||
resultsCount: Int? = null,
|
|
||||||
minSimilarity: Float? = null
|
|
||||||
): SauceNaoAnswer = makeRequest(
|
|
||||||
url.asSauceRequestSubject,
|
|
||||||
dbmask = mask,
|
|
||||||
dbmaski = excludedMask,
|
|
||||||
resultsCount = resultsCount,
|
|
||||||
minSimilarity = minSimilarity
|
|
||||||
)
|
|
||||||
|
|
||||||
suspend fun request(
|
suspend fun request(
|
||||||
mediaInput: Input,
|
mediaInput: Input,
|
||||||
mimeType: ContentType,
|
mimeType: ContentType,
|
||||||
@ -145,139 +99,51 @@ data class SauceNaoAPI(
|
|||||||
minSimilarity = minSimilarity
|
minSimilarity = minSimilarity
|
||||||
)
|
)
|
||||||
|
|
||||||
/**
|
|
||||||
* @param db search a specific index number or all without needing to generate a bitmask.
|
|
||||||
* @param dbs search one or more specific index number, set more than once to search multiple.
|
|
||||||
*/
|
|
||||||
suspend fun requestByDBs(
|
|
||||||
mediaInput: Input,
|
|
||||||
mimeType: ContentType,
|
|
||||||
db: Int? = null,
|
|
||||||
dbs: Array<Int>? = null,
|
|
||||||
resultsCount: Int? = null,
|
|
||||||
minSimilarity: Float? = null
|
|
||||||
): SauceNaoAnswer = makeRequest(
|
|
||||||
mediaInput.asSauceRequestSubject(mimeType),
|
|
||||||
db = db,
|
|
||||||
dbs = dbs,
|
|
||||||
resultsCount = resultsCount,
|
|
||||||
minSimilarity = minSimilarity
|
|
||||||
)
|
|
||||||
|
|
||||||
/**
|
|
||||||
* @param mask Mask for selecting specific indexes to ENABLE. dbmask=8191 will search all of the first 14 indexes. If intending to search all databases, the db=999 option is more appropriate.
|
|
||||||
* @param excludedMask Mask for selecting specific indexes to DISABLE. dbmaski=8191 would search only indexes higher than the first 14. This is ideal when attempting to disable only certain indexes, while allowing future indexes to be included by default.
|
|
||||||
*
|
|
||||||
* Bitmask Note: Index numbers start with 0. Even though pixiv is labeled as index 5, it would be controlled with the 6th bit position, which has a decimal value of 32 when set.
|
|
||||||
* db=<index num or 999 for all>
|
|
||||||
*/
|
|
||||||
suspend fun requestByMasks(
|
|
||||||
mediaInput: Input,
|
|
||||||
mimeType: ContentType,
|
|
||||||
mask: Int?,
|
|
||||||
excludedMask: Int? = null,
|
|
||||||
resultsCount: Int? = null,
|
|
||||||
minSimilarity: Float? = null
|
|
||||||
): SauceNaoAnswer = makeRequest(
|
|
||||||
mediaInput.asSauceRequestSubject(mimeType),
|
|
||||||
dbmask = mask,
|
|
||||||
dbmaski = excludedMask,
|
|
||||||
resultsCount = resultsCount,
|
|
||||||
minSimilarity = minSimilarity
|
|
||||||
)
|
|
||||||
|
|
||||||
suspend fun request(
|
suspend fun request(
|
||||||
file: MPPFile,
|
file: MPPFile,
|
||||||
resultsCount: Int? = null,
|
resultsCount: Int? = null,
|
||||||
minSimilarity: Float? = null
|
minSimilarity: Float? = null
|
||||||
): SauceNaoAnswer = request(
|
): SauceNaoAnswer = request(
|
||||||
file.input(),
|
file.input,
|
||||||
file.contentType,
|
file.contentType,
|
||||||
resultsCount,
|
resultsCount = resultsCount,
|
||||||
minSimilarity
|
minSimilarity = minSimilarity
|
||||||
)
|
)
|
||||||
|
|
||||||
/**
|
|
||||||
* @param db search a specific index number or all without needing to generate a bitmask.
|
|
||||||
* @param dbs search one or more specific index number, set more than once to search multiple.
|
|
||||||
*/
|
|
||||||
suspend fun requestByDBs(
|
|
||||||
file: MPPFile,
|
|
||||||
db: Int? = null,
|
|
||||||
dbs: Array<Int>? = null,
|
|
||||||
resultsCount: Int? = null,
|
|
||||||
minSimilarity: Float? = null
|
|
||||||
): SauceNaoAnswer = requestByDBs(
|
|
||||||
file.input(),
|
|
||||||
file.contentType,
|
|
||||||
db,
|
|
||||||
dbs,
|
|
||||||
resultsCount,
|
|
||||||
minSimilarity
|
|
||||||
)
|
|
||||||
|
|
||||||
/**
|
|
||||||
* @param mask Mask for selecting specific indexes to ENABLE. dbmask=8191 will search all of the first 14 indexes. If intending to search all databases, the db=999 option is more appropriate.
|
|
||||||
* @param excludedMask Mask for selecting specific indexes to DISABLE. dbmaski=8191 would search only indexes higher than the first 14. This is ideal when attempting to disable only certain indexes, while allowing future indexes to be included by default.
|
|
||||||
*
|
|
||||||
* Bitmask Note: Index numbers start with 0. Even though pixiv is labeled as index 5, it would be controlled with the 6th bit position, which has a decimal value of 32 when set.
|
|
||||||
* db=<index num or 999 for all>
|
|
||||||
*/
|
|
||||||
suspend fun requestByMasks(
|
|
||||||
file: MPPFile,
|
|
||||||
mask: Int?,
|
|
||||||
excludedMask: Int? = null,
|
|
||||||
resultsCount: Int? = null,
|
|
||||||
minSimilarity: Float? = null
|
|
||||||
): SauceNaoAnswer = requestByMasks(
|
|
||||||
file.input(),
|
|
||||||
file.contentType,
|
|
||||||
mask,
|
|
||||||
excludedMask,
|
|
||||||
resultsCount,
|
|
||||||
minSimilarity
|
|
||||||
)
|
|
||||||
|
|
||||||
@Deprecated("Renamed", ReplaceWith("requestByDBs(url, db, null, resultsCount, minSimilarity)"))
|
|
||||||
suspend fun requestByDb(
|
suspend fun requestByDb(
|
||||||
url: String,
|
url: String,
|
||||||
db: Int,
|
db: Int,
|
||||||
resultsCount: Int? = null,
|
resultsCount: Int? = null,
|
||||||
minSimilarity: Float? = null
|
minSimilarity: Float? = null
|
||||||
): SauceNaoAnswer = requestByDBs(
|
): SauceNaoAnswer = makeRequest(
|
||||||
url,
|
url.asSauceRequestSubject,
|
||||||
db,
|
db = db,
|
||||||
null,
|
resultsCount = resultsCount,
|
||||||
resultsCount,
|
minSimilarity = minSimilarity
|
||||||
minSimilarity
|
|
||||||
)
|
)
|
||||||
|
|
||||||
@Deprecated("Renamed", ReplaceWith("requestByMasks(url, dbmask, null, resultsCount, minSimilarity)"))
|
suspend fun requestByMask(
|
||||||
suspend fun request(
|
|
||||||
url: String,
|
url: String,
|
||||||
dbmask: Int,
|
dbmask: Int,
|
||||||
resultsCount: Int? = null,
|
resultsCount: Int? = null,
|
||||||
minSimilarity: Float? = null
|
minSimilarity: Float? = null
|
||||||
): SauceNaoAnswer = requestByMasks(
|
): SauceNaoAnswer = makeRequest(
|
||||||
url,
|
url.asSauceRequestSubject,
|
||||||
dbmask,
|
dbmask = dbmask,
|
||||||
null,
|
resultsCount = resultsCount,
|
||||||
resultsCount,
|
minSimilarity = minSimilarity
|
||||||
minSimilarity
|
|
||||||
)
|
)
|
||||||
|
|
||||||
@Deprecated("Renamed", ReplaceWith("requestByMasks(url, null, dbmaski, resultsCount, minSimilarity)"))
|
|
||||||
suspend fun requestByMaskI(
|
suspend fun requestByMaskI(
|
||||||
url: String,
|
url: String,
|
||||||
dbmaski: Int,
|
dbmaski: Int,
|
||||||
resultsCount: Int? = null,
|
resultsCount: Int? = null,
|
||||||
minSimilarity: Float? = null
|
minSimilarity: Float? = null
|
||||||
): SauceNaoAnswer = requestByMasks(
|
): SauceNaoAnswer = makeRequest(
|
||||||
url,
|
url.asSauceRequestSubject,
|
||||||
null,
|
dbmaski = dbmaski,
|
||||||
dbmaski,
|
resultsCount = resultsCount,
|
||||||
resultsCount,
|
minSimilarity = minSimilarity
|
||||||
minSimilarity
|
|
||||||
)
|
)
|
||||||
|
|
||||||
private suspend fun makeRequest(
|
private suspend fun makeRequest(
|
||||||
@ -299,7 +165,6 @@ data class SauceNaoAPI(
|
|||||||
private suspend fun makeRequest(
|
private suspend fun makeRequest(
|
||||||
request: SauceRequestSubject,
|
request: SauceRequestSubject,
|
||||||
db: Int? = null,
|
db: Int? = null,
|
||||||
dbs: Array<Int>? = null,
|
|
||||||
dbmask: Int? = null,
|
dbmask: Int? = null,
|
||||||
dbmaski: Int? = null,
|
dbmaski: Int? = null,
|
||||||
resultsCount: Int? = null,
|
resultsCount: Int? = null,
|
||||||
@ -314,7 +179,6 @@ data class SauceNaoAPI(
|
|||||||
apiToken ?.also { parameter(API_TOKEN_FIELD, it) }
|
apiToken ?.also { parameter(API_TOKEN_FIELD, it) }
|
||||||
parameter(OUTPUT_TYPE_FIELD, JsonOutputType.typeCode)
|
parameter(OUTPUT_TYPE_FIELD, JsonOutputType.typeCode)
|
||||||
db ?.also { parameter(DB_FIELD, it) }
|
db ?.also { parameter(DB_FIELD, it) }
|
||||||
dbs ?.forEach { parameter(DBS_FIELD, it) }
|
|
||||||
dbmask ?.also { parameter(DBMASK_FIELD, it) }
|
dbmask ?.also { parameter(DBMASK_FIELD, it) }
|
||||||
dbmaski ?.also { parameter(DBMASKI_FIELD, it) }
|
dbmaski ?.also { parameter(DBMASKI_FIELD, it) }
|
||||||
resultsCount ?.also { parameter(RESULTS_COUNT_FIELD, it) }
|
resultsCount ?.also { parameter(RESULTS_COUNT_FIELD, it) }
|
||||||
|
@ -1,6 +1,6 @@
|
|||||||
package dev.inmo.saucenaoapi.additional
|
package dev.inmo.saucenaoapi.additional
|
||||||
|
|
||||||
import korlibs.time.TimeSpan
|
import com.soywiz.klock.TimeSpan
|
||||||
|
|
||||||
typealias AccountType = Int
|
typealias AccountType = Int
|
||||||
const val defaultAccountType: AccountType = 1 // "basic"
|
const val defaultAccountType: AccountType = 1 // "basic"
|
||||||
|
@ -29,27 +29,15 @@ val Header.accountInfo
|
|||||||
data class LimitStatus(
|
data class LimitStatus(
|
||||||
val remain: Int = Int.MAX_VALUE,
|
val remain: Int = Int.MAX_VALUE,
|
||||||
val limit: Int = Int.MAX_VALUE
|
val limit: Int = Int.MAX_VALUE
|
||||||
) : Comparable<LimitStatus> {
|
)
|
||||||
override fun compareTo(other: LimitStatus): Int = when {
|
|
||||||
limit == other.limit && remain == other.remain -> 0
|
|
||||||
else -> remain.compareTo(other.remain)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
data class Limits(
|
data class Limits(
|
||||||
val short: LimitStatus = LimitStatus(),
|
val short: LimitStatus = LimitStatus(),
|
||||||
val long: LimitStatus = LimitStatus()
|
val long: LimitStatus = LimitStatus()
|
||||||
) : Comparable<Limits> {
|
)
|
||||||
override fun compareTo(other: Limits): Int = when {
|
|
||||||
long == other.long && short == other.short -> 0
|
|
||||||
else -> short.remain.compareTo(other.short.remain)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
data class AccountInfo(
|
data class AccountInfo(
|
||||||
val accountType: AccountType = defaultAccountType,
|
val accountType: AccountType = defaultAccountType,
|
||||||
val userId: UserId? = null,
|
val userId: UserId? = null,
|
||||||
val limits: Limits = Limits()
|
val limits: Limits = Limits()
|
||||||
) : Comparable<AccountInfo> {
|
)
|
||||||
override fun compareTo(other: AccountInfo): Int = limits.compareTo(other.limits)
|
|
||||||
}
|
|
||||||
|
@ -1,6 +1,6 @@
|
|||||||
package dev.inmo.saucenaoapi.exceptions
|
package dev.inmo.saucenaoapi.exceptions
|
||||||
|
|
||||||
import korlibs.time.TimeSpan
|
import com.soywiz.klock.TimeSpan
|
||||||
import dev.inmo.saucenaoapi.additional.LONG_TIME_RECALCULATING_MILLIS
|
import dev.inmo.saucenaoapi.additional.LONG_TIME_RECALCULATING_MILLIS
|
||||||
import dev.inmo.saucenaoapi.additional.SHORT_TIME_RECALCULATING_MILLIS
|
import dev.inmo.saucenaoapi.additional.SHORT_TIME_RECALCULATING_MILLIS
|
||||||
import io.ktor.client.plugins.ClientRequestException
|
import io.ktor.client.plugins.ClientRequestException
|
||||||
|
@ -8,6 +8,4 @@ data class LimitsState(
|
|||||||
val maxLongQuota: Int,
|
val maxLongQuota: Int,
|
||||||
val knownShortQuota: Int,
|
val knownShortQuota: Int,
|
||||||
val knownLongQuota: Int
|
val knownLongQuota: Int
|
||||||
) : Comparable<LimitsState> {
|
)
|
||||||
override fun compareTo(other: LimitsState): Int = knownShortQuota.compareTo(other.knownShortQuota)
|
|
||||||
}
|
|
||||||
|
@ -1,26 +1,9 @@
|
|||||||
package dev.inmo.saucenaoapi.utils
|
package dev.inmo.saucenaoapi.utils
|
||||||
|
|
||||||
import dev.inmo.micro_utils.common.MPPFile
|
|
||||||
import dev.inmo.micro_utils.common.filename
|
|
||||||
import dev.inmo.micro_utils.ktor.common.input
|
|
||||||
import dev.inmo.micro_utils.mime_types.KnownMimeTypes
|
|
||||||
import dev.inmo.micro_utils.mime_types.getMimeType
|
|
||||||
import io.ktor.http.ContentType
|
import io.ktor.http.ContentType
|
||||||
import io.ktor.utils.io.core.Input
|
import io.ktor.utils.io.core.Input
|
||||||
|
|
||||||
@Deprecated(
|
expect class MPPFile
|
||||||
"MPPFile from microutils is preferable since 0.16.0",
|
|
||||||
ReplaceWith("MPPFile", "dev.inmo.micro_utils.common.MPPFile")
|
|
||||||
)
|
|
||||||
typealias MPPFile = MPPFile
|
|
||||||
|
|
||||||
@Deprecated(
|
expect val MPPFile.input: Input
|
||||||
"input() from microutils is preferable since 0.16.0",
|
expect val MPPFile.contentType: ContentType
|
||||||
ReplaceWith("this.input()", "dev.inmo.micro_utils.ktor.common.input")
|
|
||||||
)
|
|
||||||
val MPPFile.input: Input
|
|
||||||
get() = input()
|
|
||||||
val MPPFile.contentType: ContentType
|
|
||||||
get() = ContentType.parse(
|
|
||||||
getMimeType(stringWithExtension = filename.extension) ?.raw ?: KnownMimeTypes.Any.raw
|
|
||||||
)
|
|
||||||
|
@ -1,6 +1,6 @@
|
|||||||
package dev.inmo.saucenaoapi.utils
|
package dev.inmo.saucenaoapi.utils
|
||||||
|
|
||||||
import korlibs.time.DateTime
|
import com.soywiz.klock.DateTime
|
||||||
import dev.inmo.saucenaoapi.additional.LONG_TIME_RECALCULATING_MILLIS
|
import dev.inmo.saucenaoapi.additional.LONG_TIME_RECALCULATING_MILLIS
|
||||||
import dev.inmo.saucenaoapi.additional.SHORT_TIME_RECALCULATING_MILLIS
|
import dev.inmo.saucenaoapi.additional.SHORT_TIME_RECALCULATING_MILLIS
|
||||||
import dev.inmo.saucenaoapi.exceptions.TooManyRequestsException
|
import dev.inmo.saucenaoapi.exceptions.TooManyRequestsException
|
||||||
@ -9,39 +9,17 @@ import dev.inmo.saucenaoapi.models.Header
|
|||||||
import dev.inmo.saucenaoapi.models.LimitsState
|
import dev.inmo.saucenaoapi.models.LimitsState
|
||||||
import kotlinx.coroutines.*
|
import kotlinx.coroutines.*
|
||||||
import kotlinx.coroutines.channels.Channel
|
import kotlinx.coroutines.channels.Channel
|
||||||
import kotlinx.coroutines.flow.MutableStateFlow
|
|
||||||
import kotlinx.coroutines.flow.asStateFlow
|
|
||||||
import kotlinx.coroutines.flow.map
|
|
||||||
import kotlinx.coroutines.flow.merge
|
|
||||||
import kotlin.math.max
|
import kotlin.math.max
|
||||||
import kotlin.math.min
|
import kotlin.math.min
|
||||||
|
|
||||||
internal class RequestQuotaManager (
|
internal class RequestQuotaManager (
|
||||||
scope: CoroutineScope
|
scope: CoroutineScope
|
||||||
) {
|
) {
|
||||||
private val _longQuotaFlow = MutableStateFlow(1)
|
private var longQuota = 1
|
||||||
private val _shortQuotaFlow = MutableStateFlow(1)
|
private var shortQuota = 1
|
||||||
private val _longMaxQuotaFlow = MutableStateFlow(1)
|
private var longMaxQuota = 1
|
||||||
private val _shortMaxQuotaFlow = MutableStateFlow(1)
|
private var shortMaxQuota = 1
|
||||||
private var longQuota by _longQuotaFlow::value
|
|
||||||
private var shortQuota by _shortQuotaFlow::value
|
|
||||||
private var longMaxQuota by _longMaxQuotaFlow::value
|
|
||||||
private var shortMaxQuota by _shortMaxQuotaFlow::value
|
|
||||||
|
|
||||||
val longQuotaFlow = _longQuotaFlow.asStateFlow()
|
|
||||||
val shortQuotaFlow = _shortQuotaFlow.asStateFlow()
|
|
||||||
val longMaxQuotaFlow = _longMaxQuotaFlow.asStateFlow()
|
|
||||||
val shortMaxQuotaFlow = _shortMaxQuotaFlow.asStateFlow()
|
|
||||||
val limitsStateFlow = merge(
|
|
||||||
longQuotaFlow, shortQuotaFlow, longMaxQuotaFlow, shortMaxQuotaFlow
|
|
||||||
).map { _ ->
|
|
||||||
LimitsState(
|
|
||||||
shortMaxQuota,
|
|
||||||
longMaxQuota,
|
|
||||||
shortQuota,
|
|
||||||
longQuota
|
|
||||||
)
|
|
||||||
}
|
|
||||||
val limitsState: LimitsState
|
val limitsState: LimitsState
|
||||||
get() = LimitsState(
|
get() = LimitsState(
|
||||||
shortMaxQuota,
|
shortMaxQuota,
|
||||||
|
@ -1,6 +1,6 @@
|
|||||||
package dev.inmo.saucenaoapi.utils
|
package dev.inmo.saucenaoapi.utils
|
||||||
|
|
||||||
import korlibs.time.DateTime
|
import com.soywiz.klock.DateTime
|
||||||
import dev.inmo.saucenaoapi.additional.LONG_TIME_RECALCULATING_MILLIS
|
import dev.inmo.saucenaoapi.additional.LONG_TIME_RECALCULATING_MILLIS
|
||||||
import dev.inmo.saucenaoapi.additional.SHORT_TIME_RECALCULATING_MILLIS
|
import dev.inmo.saucenaoapi.additional.SHORT_TIME_RECALCULATING_MILLIS
|
||||||
import kotlinx.coroutines.*
|
import kotlinx.coroutines.*
|
||||||
|
@ -0,0 +1,18 @@
|
|||||||
|
package dev.inmo.saucenaoapi.utils
|
||||||
|
|
||||||
|
import io.ktor.http.ContentType
|
||||||
|
import io.ktor.utils.io.core.ByteReadPacket
|
||||||
|
import io.ktor.utils.io.core.Input
|
||||||
|
import org.khronos.webgl.Int8Array
|
||||||
|
import org.w3c.files.File
|
||||||
|
import org.w3c.files.FileReaderSync
|
||||||
|
|
||||||
|
actual typealias MPPFile = File
|
||||||
|
|
||||||
|
actual val MPPFile.input: Input
|
||||||
|
get() {
|
||||||
|
val reader = FileReaderSync()
|
||||||
|
return ByteReadPacket(Int8Array(reader.readAsArrayBuffer(this)) as ByteArray)
|
||||||
|
}
|
||||||
|
actual val MPPFile.contentType: ContentType
|
||||||
|
get() = ContentType.parse(type)
|
@ -0,0 +1,14 @@
|
|||||||
|
package dev.inmo.saucenaoapi.utils
|
||||||
|
|
||||||
|
import io.ktor.http.ContentType
|
||||||
|
import io.ktor.utils.io.core.Input
|
||||||
|
import io.ktor.utils.io.streams.asInput
|
||||||
|
import java.io.File
|
||||||
|
import java.nio.file.Files
|
||||||
|
|
||||||
|
actual typealias MPPFile = File
|
||||||
|
|
||||||
|
actual val MPPFile.input: Input
|
||||||
|
get() = inputStream().asInput()
|
||||||
|
actual val MPPFile.contentType: ContentType
|
||||||
|
get() = ContentType.parse(Files.probeContentType(toPath()))
|
Loading…
Reference in New Issue
Block a user