mirror of
https://github.com/InsanusMokrassar/SauceNaoAPI.git
synced 2024-11-16 20:03:46 +00:00
Compare commits
123 Commits
Author | SHA1 | Date | |
---|---|---|---|
a61211e24a | |||
caa2fb9b58 | |||
915cb09e37 | |||
930523f69a | |||
773415f579 | |||
21803cb321 | |||
c6643dbdbc | |||
58beceebf1 | |||
0acf4a88f4 | |||
ed48b3e4aa | |||
1ed123596c | |||
76a0dbdf27 | |||
33775f3304 | |||
f7ca2bda89 | |||
9efade9daf | |||
e4d1ff7fa9 | |||
e0b5f5d410 | |||
adec37b9e5 | |||
8e042c6399 | |||
0564ed1d75 | |||
f9d98ec7d7 | |||
67519da545 | |||
6028ec7774 | |||
e29cad7bae | |||
473a5a735a | |||
0229697dd3 | |||
47161eb4ff | |||
e6024b223c | |||
5f8e410531 | |||
7727d2400e | |||
eec32de472 | |||
ae9a7baf50 | |||
bcc36dbfb7 | |||
cf8ec46513 | |||
9c25b08296 | |||
962d079f46 | |||
a84f31f888 | |||
14006652ee | |||
29aa1271a6 | |||
d2edd43a09 | |||
c31793ab38 | |||
d19bb48384 | |||
b21c3f1ac9 | |||
5ddc13eca0 | |||
8b180850da | |||
e65a171e65 | |||
31f32a7069 | |||
5b299fb1c1 | |||
5038fb4240 | |||
96f520700f | |||
2a4296ff7d | |||
2f34ab7ad1 | |||
798c4097ed | |||
c1df04fd09 | |||
8cc0426dc5 | |||
9cc929adf6 | |||
85567956ed | |||
db154f4202 | |||
bfdbee356a | |||
62580f6649 | |||
0b79f27b38 | |||
8543917da7 | |||
be858d3e60 | |||
90e090ca78 | |||
66414ff8df | |||
d0c143dcd6 | |||
3ee0d0de7d | |||
d04ee03043 | |||
e173bd71e0 | |||
11aac1b581 | |||
4319c41e44 | |||
dfd1ba807f | |||
e926a5422d | |||
d631d63490 | |||
60ae527dd0 | |||
05b8d7738f | |||
b5ceff32bd | |||
64109735f8 | |||
d4f902aefd | |||
2de15a54a1 | |||
036deeb318 | |||
4cc0223fbc | |||
be292102aa | |||
9d473857be | |||
6ff3f76295 | |||
0ed1a8702b | |||
c800a81a41 | |||
62ceae0066 | |||
8619d020f6 | |||
affa06905e | |||
cbe76b3d95 | |||
9f4feeccfc | |||
037074cef6 | |||
dfe29296ab | |||
ce1d185eff | |||
a78611a27c | |||
cba4b2ccdb | |||
6aabcca9d2 | |||
503c4226d7 | |||
d82bff2563 | |||
8391e20dce | |||
67244683dd | |||
948dede0c8 | |||
6f171c5f6d | |||
6d85ccfffa | |||
bce508a8c2 | |||
224f0a6cc0 | |||
61937ed209 | |||
8e861020d8 | |||
c231b956b4 | |||
c14df69ae1 | |||
f55744a038 | |||
f27c493771 | |||
7bc1e822fc | |||
eb9456a233 | |||
8c8a02054d | |||
f52eb2ad6e | |||
4fcdb6f728 | |||
18cdf4ffbe | |||
33d143ea12 | |||
e0215dcf8f | |||
ca4348b5f6 | |||
249cbba1f7 |
29
.github/workflows/build_and_publish.yml
vendored
Normal file
29
.github/workflows/build_and_publish.yml
vendored
Normal file
@ -0,0 +1,29 @@
|
||||
name: Publish package to GitHub Packages
|
||||
on: [push]
|
||||
jobs:
|
||||
publishing:
|
||||
runs-on: ubuntu-latest
|
||||
steps:
|
||||
- uses: actions/checkout@v2
|
||||
- uses: actions/setup-java@v1
|
||||
with:
|
||||
java-version: 11
|
||||
- name: Rewrite version
|
||||
run: |
|
||||
branch="`echo "${{ github.ref }}" | grep -o "[^/]*$"`"
|
||||
cat gradle.properties | sed -e "s/^library_version=\([0-9\.]*\)/library_version=\1-branch_$branch-build${{ github.run_number }}/" > gradle.properties.tmp
|
||||
rm gradle.properties
|
||||
mv gradle.properties.tmp gradle.properties
|
||||
- name: Build
|
||||
run: ./gradlew build
|
||||
- name: Publish to Gitea
|
||||
continue-on-error: true
|
||||
run: ./gradlew publishAllPublicationsToGiteaRepository
|
||||
env:
|
||||
GITEA_TOKEN: ${{ secrets.GITEA_TOKEN }}
|
||||
- name: Publish
|
||||
run: ./gradlew publishAllPublicationsToGithubPackagesRepository --no-parallel
|
||||
continue-on-error: true
|
||||
env:
|
||||
GITHUBPACKAGES_USER: ${{ github.actor }}
|
||||
GITHUBPACKAGES_PASSWORD: ${{ secrets.GITHUB_TOKEN }}
|
1
.gitignore
vendored
1
.gitignore
vendored
@ -8,3 +8,4 @@ settings.xml
|
||||
.gradle/
|
||||
build/
|
||||
out/
|
||||
kotlin-js-store/
|
||||
|
217
CHANGELOG.md
217
CHANGELOG.md
@ -1,5 +1,182 @@
|
||||
# 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
|
||||
|
||||
* Versions updates:
|
||||
* `Kotlin`: `1.6.10` -> `1.6.21`
|
||||
* `Serialization`: `1.3.2` -> `1.3.3`
|
||||
* `Klock`: `2.6.3` -> `2.7.0`
|
||||
* `Ktor`: `1.6.8` -> `2.0.1`
|
||||
|
||||
## 0.10.1
|
||||
|
||||
* Versions updates:
|
||||
* `Klock`: `2.6.2` -> `2.6.3`
|
||||
* `Ktor`: `1.6.7` -> `1.6.8`
|
||||
|
||||
## 0.10.0
|
||||
|
||||
Migration onto libs versions toml
|
||||
|
||||
## 0.9.1
|
||||
|
||||
* Versions updates:
|
||||
* `Kotlin`: `1.5.30` -> `1.5.31`
|
||||
* `Klock`: `2.4.0` -> `2.4.2`
|
||||
* `Coroutines`: `1.5.1` -> `1.5.2`
|
||||
* Add several extensions to `ResultData`: `authors`, `froms`, `charactersList`, `titles`, `urls`
|
||||
|
||||
## 0.9.0
|
||||
|
||||
* Versions updates:
|
||||
* `Kotlin`: `1.5.10` -> `1.5.30`
|
||||
* `Klock`: `2.1.2` -> `2.4.0`
|
||||
* `Ktor`: `1.5.4` -> `1.6.3`
|
||||
* `Serialization`: `1.2.1` -> `1.2.2`
|
||||
* `Coroutines`: `1.5.0` -> `1.5.1`
|
||||
|
||||
## 0.8.2
|
||||
|
||||
* Versions updates:
|
||||
* `Kotlin`: `1.4.32` -> `1.5.10`
|
||||
* `Klock`: `2.0.7` -> `2.1.2`
|
||||
* `Ktor`: `1.5.3` -> `1.5.4`
|
||||
* `Serialization`: `1.1.0` -> `1.2.1`
|
||||
* `Coroutines`: `1.4.3` -> `1.5.0`
|
||||
|
||||
## 0.8.1
|
||||
|
||||
* Versions updates:
|
||||
* `Kotlin`: `1.4.31` -> `1.4.32`
|
||||
* `Klock`: `2.0.6` -> `2.0.7`
|
||||
* `Ktor`: `1.5.2` -> `1.5.3`
|
||||
|
||||
## 0.8.0
|
||||
|
||||
* Versions updates:
|
||||
* `Kotlin`: `1.4.21` -> `1.4.31`
|
||||
* `Klock`: `2.0.4` -> `2.0.6`
|
||||
* `Ktor`: `1.5.1` -> `1.5.2`
|
||||
* `Kotlin Serialisation`: `1.0.1` -> `1.1.0`
|
||||
* `Kotlin Coroutines`: `1.4.2` -> `1.4.3`
|
||||
|
||||
## 0.7.2
|
||||
|
||||
* Versions updates:
|
||||
* `Klock`: `2.0.2` -> `2.0.4`
|
||||
* `Ktor`: `1.5.0` -> `1.5.1`
|
||||
|
||||
## 0.7.1
|
||||
|
||||
* Versions updates:
|
||||
* `Kotlin`: `1.4.20` -> `1.4.21`
|
||||
* `Klock`: `2.0.0` -> `2.0.2`
|
||||
* `Ktor`: `1.4.3` -> `1.5.0`
|
||||
|
||||
## 0.7.0
|
||||
|
||||
**BREAKING CHANGES: PACKAGE HAS BEEN CHANGED FROM `com.insanusmokrassar` to `dev.inmo`**
|
||||
|
||||
Migration:
|
||||
|
||||
* Packages in the whole project were changed `com.insanusmokrassar.SauceNaoAPI` -> `dev.inmo.saucenaoapi`
|
||||
* Change implementation in your gradle files: `implementation "com.insanusmokrassar:SauceNaoAPI:*"` ->
|
||||
`implementation "dev.inmo:saucenaoapi:*"`
|
||||
|
||||
## 0.6.2
|
||||
|
||||
* Versions updates:
|
||||
* `Kotlin`: `1.4.10` -> `1.4.20`
|
||||
* `Kotlin Serialisation`: `1.0.0-RC2` -> `1.0.1`
|
||||
* `Kotlin Coroutines`: `1.3.9` -> `1.4.2`
|
||||
* `Klock`: `1.12.1` -> `2.0.0`
|
||||
* `Ktor`: `1.4.1` -> `1.4.3`
|
||||
|
||||
## 0.6.1
|
||||
|
||||
* Versions updates:
|
||||
* `Kotlin`: `1.4.0` -> `1.4.10`
|
||||
* `Kotlin Serialisation`: `1.0.0-RC` -> `1.0.0-RC2`
|
||||
* `Klock`: `1.12.0` -> `1.12.1`
|
||||
* `Ktor`: `1.4.0` -> `1.4.1`
|
||||
|
||||
## 0.6.0
|
||||
|
||||
**MAIN PACKAGE WAS CHANGED: `com.github.insanusmokrassar` -> `com.insanusmokrassar`**
|
||||
@ -12,31 +189,11 @@
|
||||
* `Klock`: `1.11.14` -> `1.12.0`
|
||||
* `Ktor`: `1.3.2` -> `1.4.0`
|
||||
|
||||
### 0.6.1
|
||||
|
||||
* Versions updates:
|
||||
* `Kotlin`: `1.4.0` -> `1.4.10`
|
||||
* `Kotlin Serialisation`: `1.0.0-RC` -> `1.0.0-RC2`
|
||||
* `Klock`: `1.12.0` -> `1.12.1`
|
||||
* `Ktor`: `1.4.0` -> `1.4.1`
|
||||
|
||||
## 0.5.0
|
||||
|
||||
* Versions updates
|
||||
|
||||
## 0.4.0
|
||||
|
||||
* Update libraries versions
|
||||
* Kotlin `1.3.31` -> `1.3.50`
|
||||
* Coroutines `1.2.1` -> `1.3.2`
|
||||
* Serialization `0.11.0` -> `0.13.0`
|
||||
* Joda Time `2.10.1` -> `2.10.4`
|
||||
* Ktor `1.1.4` -> `1.2.5`
|
||||
* Now `SauceNaoAPI` is `Closeable`
|
||||
* Now `SauceNaoAPI` working with synchronous queue
|
||||
* `SauceNaoAPI` now will wait for some time when one of limits will be achieved
|
||||
|
||||
### 0.4.4
|
||||
## 0.4.4
|
||||
|
||||
* Uploading of file
|
||||
* Updates of versions
|
||||
@ -44,15 +201,15 @@
|
||||
* `SauceNaoAPI` instances now can return `limitsState` object, which will contains `LimitsState` with currently known
|
||||
state of limits
|
||||
|
||||
### 0.4.3
|
||||
## 0.4.3
|
||||
|
||||
Hotfix for serializer of `SauceNaoAnswer`
|
||||
|
||||
### 0.4.2
|
||||
## 0.4.2
|
||||
|
||||
Hotfix for autostop for some time when there is no remaining quotas for requests
|
||||
|
||||
### 0.4.1 Managers experiments and row format in answer
|
||||
## 0.4.1 Managers experiments and row format in answer
|
||||
|
||||
* Add `TimeManager` - it will manage work with requests times
|
||||
* Add `RequestQuotaMagager` - it will manage quota for requests and call suspend
|
||||
@ -61,6 +218,18 @@ if they will be over
|
||||
* Now `SauceNaoAnswer` have field `row` which contains `JsonObject` with
|
||||
all original answer fields
|
||||
|
||||
## 0.4.0
|
||||
|
||||
* Update libraries versions
|
||||
* Kotlin `1.3.31` -> `1.3.50`
|
||||
* Coroutines `1.2.1` -> `1.3.2`
|
||||
* Serialization `0.11.0` -> `0.13.0`
|
||||
* Joda Time `2.10.1` -> `2.10.4`
|
||||
* Ktor `1.1.4` -> `1.2.5`
|
||||
* Now `SauceNaoAPI` is `Closeable`
|
||||
* Now `SauceNaoAPI` working with synchronous queue
|
||||
* `SauceNaoAPI` now will wait for some time when one of limits will be achieved
|
||||
|
||||
## 0.3.0
|
||||
|
||||
* Now `results` field of `SauceNaoAnswer` is optional and is empty list by default
|
||||
|
@ -1,6 +1,7 @@
|
||||
# SauceNaoAPI
|
||||
|
||||
[![Download](https://api.bintray.com/packages/insanusmokrassar/InsanusMokrassar/SauceNaoAPI-mpp/images/download.svg)](https://bintray.com/insanusmokrassar/InsanusMokrassar/SauceNaoAPI-mpp/_latestVersion)
|
||||
[![Maven Central](https://maven-badges.herokuapp.com/maven-central/dev.inmo/saucenaoapi/badge.svg)](https://maven-badges.herokuapp.com/maven-central/dev.inmo/saucenaoapi)
|
||||
|
||||
|
||||
It is wrapper for [SauceNAO](https://saucenao.com/) API. For now, library is
|
||||
in preview state. It can be fully used, but some of info can be unavailable from
|
||||
@ -11,7 +12,7 @@ wrapper classes, but now you can access them via `SauceNaoAnswer#row` field.
|
||||
### Gradle
|
||||
|
||||
```groovy
|
||||
implementation "com.insanusmokrassar:SauceNaoAPI:$saucenaoapi_version"
|
||||
implementation "dev.inmo:saucenaoapi:$saucenaoapi_version"
|
||||
```
|
||||
|
||||
## Requester
|
||||
|
55
build.gradle
55
build.gradle
@ -1,42 +1,46 @@
|
||||
buildscript {
|
||||
repositories {
|
||||
mavenLocal()
|
||||
jcenter()
|
||||
mavenCentral()
|
||||
}
|
||||
|
||||
dependencies {
|
||||
classpath "org.jetbrains.kotlin:kotlin-gradle-plugin:$kotlin_version"
|
||||
classpath "org.jetbrains.kotlin:kotlin-serialization:$kotlin_version"
|
||||
classpath "com.jfrog.bintray.gradle:gradle-bintray-plugin:$gradle_bintray_plugin_version"
|
||||
classpath "com.github.breadmoirai:github-release:$gradle_github_release_plugin_version"
|
||||
classpath libs.buildscript.kt.gradle
|
||||
classpath libs.buildscript.kt.serialization
|
||||
classpath libs.buildscript.gh.release
|
||||
}
|
||||
}
|
||||
|
||||
plugins {
|
||||
id "org.jetbrains.kotlin.multiplatform" version "$kotlin_version"
|
||||
id "org.jetbrains.kotlin.plugin.serialization" version "$kotlin_version"
|
||||
alias(libs.plugins.multiplatform)
|
||||
alias(libs.plugins.serialization)
|
||||
}
|
||||
|
||||
project.version = "0.6.1"
|
||||
project.group = "com.insanusmokrassar"
|
||||
project.version = "$library_version"
|
||||
project.group = "dev.inmo"
|
||||
|
||||
apply from: "publish.gradle"
|
||||
apply from: "github_release.gradle"
|
||||
|
||||
repositories {
|
||||
mavenLocal()
|
||||
jcenter()
|
||||
mavenCentral()
|
||||
maven { url "https://kotlin.bintray.com/kotlinx" }
|
||||
}
|
||||
|
||||
kotlin {
|
||||
jvm()
|
||||
js(BOTH) {
|
||||
jvm {
|
||||
compilations.main {
|
||||
kotlinOptions {
|
||||
jvmTarget = "1.8"
|
||||
}
|
||||
}
|
||||
}
|
||||
js(IR) {
|
||||
browser()
|
||||
nodejs()
|
||||
}
|
||||
linuxX64()
|
||||
mingwX64()
|
||||
|
||||
|
||||
sourceSets {
|
||||
@ -44,10 +48,13 @@ kotlin {
|
||||
dependencies {
|
||||
implementation kotlin('stdlib')
|
||||
|
||||
api "org.jetbrains.kotlinx:kotlinx-coroutines-core:$kotlin_coroutines_version"
|
||||
api "org.jetbrains.kotlinx:kotlinx-serialization-json:$kotlin_serialisation_runtime_version"
|
||||
api "com.soywiz.korlibs.klock:klock:$klock_version"
|
||||
api "io.ktor:ktor-client-core:$ktor_version"
|
||||
api libs.kt.coroutines
|
||||
api libs.kt.serialization
|
||||
api libs.klock
|
||||
api libs.ktor.client
|
||||
api libs.microutils.common
|
||||
api libs.microutils.ktor.common
|
||||
api libs.microutils.mimetypes
|
||||
}
|
||||
}
|
||||
commonTest {
|
||||
@ -56,21 +63,21 @@ kotlin {
|
||||
implementation kotlin('test-annotations-common')
|
||||
}
|
||||
}
|
||||
jvmMain {
|
||||
dependencies {
|
||||
implementation kotlin('stdlib')
|
||||
}
|
||||
}
|
||||
jvmTest {
|
||||
dependencies {
|
||||
implementation kotlin('test-junit')
|
||||
implementation "io.ktor:ktor-client-okhttp:$ktor_version"
|
||||
implementation libs.ktor.client.okhttp
|
||||
}
|
||||
}
|
||||
jsMain {
|
||||
jsTest {
|
||||
dependencies {
|
||||
implementation kotlin('test-js')
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
java {
|
||||
sourceCompatibility = JavaVersion.VERSION_1_8
|
||||
targetCompatibility = JavaVersion.VERSION_1_8
|
||||
}
|
||||
|
@ -2,7 +2,8 @@ private String getCurrentVersionChangelog() {
|
||||
OutputStream changelogDataOS = new ByteArrayOutputStream()
|
||||
exec {
|
||||
standardOutput = changelogDataOS
|
||||
commandLine './changelog_info_retriever', "$library_version", 'CHANGELOG.md'
|
||||
commandLine 'chmod', "+x", './changelog_parser.sh'
|
||||
commandLine './changelog_parser.sh', "$library_version", 'CHANGELOG.md'
|
||||
}
|
||||
|
||||
return changelogDataOS.toString().trim()
|
||||
@ -18,9 +19,9 @@ if (new File(projectDir, "secret.gradle").exists()) {
|
||||
owner "InsanusMokrassar"
|
||||
repo "${rootProject.name}"
|
||||
|
||||
tagName "$library_version"
|
||||
releaseName "$library_version"
|
||||
targetCommitish "$library_version"
|
||||
tagName "v${project.version}"
|
||||
releaseName "${project.version}"
|
||||
targetCommitish "${project.version}"
|
||||
|
||||
body getCurrentVersionChangelog()
|
||||
}
|
||||
|
@ -1,9 +1,3 @@
|
||||
kotlin.code.style=official
|
||||
kotlin_version=1.4.10
|
||||
kotlin_coroutines_version=1.3.9
|
||||
kotlin_serialisation_runtime_version=1.0.0-RC2
|
||||
klock_version=1.12.1
|
||||
ktor_version=1.4.1
|
||||
|
||||
gradle_github_release_plugin_version=2.2.12
|
||||
gradle_bintray_plugin_version=1.8.5
|
||||
library_version=0.17.2
|
||||
|
36
gradle/libs.versions.toml
Normal file
36
gradle/libs.versions.toml
Normal file
@ -0,0 +1,36 @@
|
||||
[versions]
|
||||
|
||||
kt = "1.8.22"
|
||||
kt-serialization = "1.5.1"
|
||||
kt-coroutines = "1.7.3"
|
||||
|
||||
klock = "4.0.3"
|
||||
ktor = "2.3.4"
|
||||
|
||||
microutils = "0.19.9"
|
||||
|
||||
gh-release = "2.4.1"
|
||||
|
||||
[libraries]
|
||||
|
||||
kt-stdlib = { module = "org.jetbrains.kotlin:kotlin-stdlib", version.ref = "kt" }
|
||||
kt-serialization = { module = "org.jetbrains.kotlinx:kotlinx-serialization-json", version.ref = "kt-serialization" }
|
||||
kt-coroutines = { module = "org.jetbrains.kotlinx:kotlinx-coroutines-core", version.ref = "kt-coroutines" }
|
||||
|
||||
klock = { module = "com.soywiz.korlibs.klock:klock", version.ref = "klock" }
|
||||
|
||||
ktor-client = { module = "io.ktor:ktor-client-core", 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-serialization = { module = "org.jetbrains.kotlin:kotlin-serialization", version.ref = "kt" }
|
||||
buildscript-gh-release = { module = "com.github.breadmoirai:github-release", version.ref = "gh-release" }
|
||||
|
||||
[plugins]
|
||||
|
||||
multiplatform = { id = "org.jetbrains.kotlin.multiplatform", version.ref = "kt" }
|
||||
serialization = { id = "org.jetbrains.kotlin.plugin.serialization", version.ref = "kt" }
|
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
|
||||
zipStoreBase=GRADLE_USER_HOME
|
||||
zipStorePath=wrapper/dists
|
||||
distributionUrl=https\://services.gradle.org/distributions/gradle-6.6.1-bin.zip
|
||||
distributionUrl=https\://services.gradle.org/distributions/gradle-7.6.1-bin.zip
|
||||
|
@ -1,53 +0,0 @@
|
||||
apply plugin: 'maven-publish'
|
||||
|
||||
task javadocsJar(type: Jar) {
|
||||
classifier = 'javadoc'
|
||||
}
|
||||
|
||||
afterEvaluate {
|
||||
project.publishing.publications.all {
|
||||
// rename artifacts
|
||||
groupId "${project.group}"
|
||||
if (it.name.contains('kotlinMultiplatform')) {
|
||||
artifactId = "${project.name}"
|
||||
} else {
|
||||
artifactId = "${project.name}-$name"
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
publishing {
|
||||
publications.all {
|
||||
artifact javadocsJar
|
||||
|
||||
pom {
|
||||
description = "SauceNao API library"
|
||||
name = "SauceNao API"
|
||||
url = "https://insanusmokrassar.github.io/${project.name}"
|
||||
|
||||
scm {
|
||||
developerConnection = "scm:git:[fetch=]https://github.com/insanusmokrassar/${project.name}.git[push=]https://github.com/insanusmokrassar/${project.name}.git"
|
||||
url = "https://github.com/insanusmokrassar/${project.name}.git"
|
||||
}
|
||||
|
||||
developers {
|
||||
|
||||
developer {
|
||||
id = "InsanusMokrassar"
|
||||
name = "Ovsyannikov Alexey"
|
||||
email = "ovsyannikov.alexey95@gmail.com"
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
licenses {
|
||||
|
||||
license {
|
||||
name = "Apache Software License 2.0"
|
||||
url = "https://github.com/InsanusMokrassar/TelegramBotAPI/blob/master/LICENSE"
|
||||
}
|
||||
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
@ -1 +0,0 @@
|
||||
{"bintrayConfig":{"repo":"InsanusMokrassar","packageName":"${project.name}-mpp","packageVcs":"https://github.com/InsanusMokrassar/${project.name}"},"licenses":[{"id":"Apache-2.0","title":"Apache Software License 2.0","url":"https://github.com/InsanusMokrassar/TelegramBotAPI/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"}]},"type":"Multiplatform"}
|
134
publish.gradle
134
publish.gradle
@ -1,55 +1,99 @@
|
||||
apply plugin: 'com.jfrog.bintray'
|
||||
apply plugin: 'maven-publish'
|
||||
|
||||
apply from: "maven.publish.gradle"
|
||||
task javadocsJar(type: Jar) {
|
||||
classifier = 'javadoc'
|
||||
}
|
||||
|
||||
bintray {
|
||||
user = project.hasProperty('BINTRAY_USER') ? project.property('BINTRAY_USER') : System.getenv('BINTRAY_USER')
|
||||
key = project.hasProperty('BINTRAY_KEY') ? project.property('BINTRAY_KEY') : System.getenv('BINTRAY_KEY')
|
||||
filesSpec {
|
||||
from "${buildDir}/publications/"
|
||||
eachFile {
|
||||
String directorySubname = it.getFile().parentFile.name
|
||||
if (it.getName() == "module.json") {
|
||||
if (directorySubname == "kotlinMultiplatform") {
|
||||
it.setPath("${project.name}/${project.version}/${project.name}-${project.version}.module")
|
||||
} else {
|
||||
it.setPath("${project.name}-${directorySubname}/${project.version}/${project.name}-${directorySubname}-${project.version}.module")
|
||||
}
|
||||
} else {
|
||||
if (directorySubname == "kotlinMultiplatform" && it.getName() == "pom-default.xml") {
|
||||
it.setPath("${project.name}/${project.version}/${project.name}-${project.version}.pom")
|
||||
} else {
|
||||
it.exclude()
|
||||
}
|
||||
publishing {
|
||||
publications.all {
|
||||
artifact javadocsJar
|
||||
|
||||
pom {
|
||||
description = "SauceNao API library"
|
||||
name = "SauceNao API"
|
||||
url = "https://insanusmokrassar.github.io/${project.name}"
|
||||
|
||||
scm {
|
||||
developerConnection = "scm:git:[fetch=]https://github.com/insanusmokrassar/${project.name}.git[push=]https://github.com/insanusmokrassar/${project.name}.git"
|
||||
url = "https://github.com/insanusmokrassar/${project.name}.git"
|
||||
}
|
||||
|
||||
developers {
|
||||
|
||||
developer {
|
||||
id = "InsanusMokrassar"
|
||||
name = "Ovsyannikov Alexey"
|
||||
email = "ovsyannikov.alexey95@gmail.com"
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
licenses {
|
||||
|
||||
license {
|
||||
name = "Apache Software License 2.0"
|
||||
url = "https://github.com/InsanusMokrassar/SauceNaoAPI/blob/master/LICENSE"
|
||||
}
|
||||
|
||||
}
|
||||
}
|
||||
into "${project.group}".replace(".", "/")
|
||||
}
|
||||
pkg {
|
||||
repo = "InsanusMokrassar"
|
||||
name = "${project.name}-mpp"
|
||||
vcsUrl = "https://github.com/InsanusMokrassar/${project.name}"
|
||||
licenses = ["Apache-2.0"]
|
||||
version {
|
||||
name = "${project.version}"
|
||||
released = new Date()
|
||||
vcsTag = "${project.version}"
|
||||
gpg {
|
||||
sign = true
|
||||
passphrase = project.hasProperty('signing.gnupg.passphrase') ? project.property('signing.gnupg.passphrase') : System.getenv('signing.gnupg.passphrase')
|
||||
repositories {
|
||||
if ((project.hasProperty('GITHUBPACKAGES_USER') || System.getenv('GITHUBPACKAGES_USER') != null) && (project.hasProperty('GITHUBPACKAGES_PASSWORD') || System.getenv('GITHUBPACKAGES_PASSWORD') != null)) {
|
||||
maven {
|
||||
name = "GithubPackages"
|
||||
url = uri("https://maven.pkg.github.com/InsanusMokrassar/SauceNaoAPI")
|
||||
|
||||
credentials {
|
||||
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')
|
||||
}
|
||||
|
||||
}
|
||||
}
|
||||
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)) {
|
||||
maven {
|
||||
name = "sonatype"
|
||||
url = uri("https://oss.sonatype.org/service/local/staging/deploy/maven2/")
|
||||
|
||||
credentials {
|
||||
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')
|
||||
}
|
||||
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
bintrayUpload.doFirst {
|
||||
publications = publishing.publications.collect {
|
||||
if (it.name.contains('kotlinMultiplatform')) {
|
||||
null
|
||||
} else {
|
||||
it.name
|
||||
|
||||
if (project.hasProperty("signing.gnupg.keyName")) {
|
||||
apply plugin: 'signing'
|
||||
|
||||
signing {
|
||||
useGpgCmd()
|
||||
|
||||
sign publishing.publications
|
||||
}
|
||||
|
||||
task signAll {
|
||||
tasks.withType(Sign).forEach {
|
||||
dependsOn(it)
|
||||
}
|
||||
} - null
|
||||
}
|
||||
}
|
||||
|
||||
bintrayUpload.dependsOn publishToMavenLocal
|
1
publish.kpsb
Normal file
1
publish.kpsb
Normal file
@ -0,0 +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"}}}
|
@ -1 +1,3 @@
|
||||
rootProject.name = 'SauceNaoAPI'
|
||||
rootProject.name = 'saucenaoapi'
|
||||
|
||||
enableFeaturePreview("VERSION_CATALOGS")
|
||||
|
@ -1,17 +0,0 @@
|
||||
package com.insanusmokrassar.SauceNaoAPI
|
||||
|
||||
sealed class OutputType {
|
||||
abstract val typeCode: Int
|
||||
}
|
||||
|
||||
object HtmlOutputType : OutputType() {
|
||||
override val typeCode: Int = 0
|
||||
}
|
||||
|
||||
object XmlOutputType : OutputType() {
|
||||
override val typeCode: Int = 1
|
||||
}
|
||||
|
||||
object JsonOutputType : OutputType() {
|
||||
override val typeCode: Int = 2
|
||||
}
|
@ -1,215 +0,0 @@
|
||||
package com.insanusmokrassar.SauceNaoAPI
|
||||
|
||||
import com.insanusmokrassar.SauceNaoAPI.exceptions.TooManyRequestsException
|
||||
import com.insanusmokrassar.SauceNaoAPI.exceptions.sauceNaoAPIException
|
||||
import com.insanusmokrassar.SauceNaoAPI.models.*
|
||||
import com.insanusmokrassar.SauceNaoAPI.utils.*
|
||||
import io.ktor.client.HttpClient
|
||||
import io.ktor.client.features.ClientRequestException
|
||||
import io.ktor.client.request.*
|
||||
import io.ktor.client.request.forms.MultiPartFormDataContent
|
||||
import io.ktor.client.request.forms.formData
|
||||
import io.ktor.client.statement.HttpResponse
|
||||
import io.ktor.client.statement.readText
|
||||
import io.ktor.http.*
|
||||
import io.ktor.utils.io.core.Input
|
||||
import kotlinx.coroutines.*
|
||||
import kotlinx.coroutines.channels.Channel
|
||||
import kotlinx.serialization.json.Json
|
||||
import kotlin.coroutines.*
|
||||
|
||||
private const val API_TOKEN_FIELD = "api_key"
|
||||
private const val OUTPUT_TYPE_FIELD = "output_type"
|
||||
private const val URL_FIELD = "url"
|
||||
private const val FILE_FIELD = "file"
|
||||
private const val FILENAME_FIELD = "filename"
|
||||
private const val DB_FIELD = "db"
|
||||
private const val DBMASK_FIELD = "dbmask"
|
||||
private const val DBMASKI_FIELD = "dbmaski"
|
||||
private const val RESULTS_COUNT_FIELD = "numres"
|
||||
private const val MINIMAL_SIMILARITY_FIELD = "minsim"
|
||||
|
||||
private const val SEARCH_URL = "https://saucenao.com/search.php"
|
||||
|
||||
val defaultSauceNaoParser = Json {
|
||||
allowSpecialFloatingPointValues = true
|
||||
allowStructuredMapKeys = true
|
||||
ignoreUnknownKeys = true
|
||||
useArrayPolymorphism = true
|
||||
}
|
||||
|
||||
data class SauceNaoAPI(
|
||||
private val apiToken: String? = null,
|
||||
private val outputType: OutputType = JsonOutputType,
|
||||
private val client: HttpClient = HttpClient(),
|
||||
private val searchUrl: String = SEARCH_URL,
|
||||
private val scope: CoroutineScope = CoroutineScope(Dispatchers.Default),
|
||||
private val parser: Json = defaultSauceNaoParser
|
||||
) : SauceCloseable {
|
||||
private val requestsChannel = Channel<Pair<Continuation<SauceNaoAnswer>, HttpRequestBuilder>>(Channel.UNLIMITED)
|
||||
private val timeManager = TimeManager(scope)
|
||||
private val quotaManager = RequestQuotaManager(scope)
|
||||
|
||||
val limitsState: LimitsState
|
||||
get() = quotaManager.limitsState
|
||||
|
||||
private val requestsJob = scope.launch {
|
||||
for ((callback, requestBuilder) in requestsChannel) {
|
||||
quotaManager.getQuota()
|
||||
launch {
|
||||
try {
|
||||
val answer = makeRequest(requestBuilder)
|
||||
callback.resume(answer)
|
||||
|
||||
quotaManager.updateQuota(answer.header, timeManager)
|
||||
} catch (e: TooManyRequestsException) {
|
||||
quotaManager.happenTooManyRequests(timeManager, e)
|
||||
requestsChannel.send(callback to requestBuilder)
|
||||
} catch (e: Exception) {
|
||||
try {
|
||||
callback.resumeWithException(e)
|
||||
} catch (e: IllegalStateException) { // may happen when already resumed and api was closed
|
||||
// do nothing
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
suspend fun request(
|
||||
url: String,
|
||||
resultsCount: Int? = null,
|
||||
minSimilarity: Float? = null
|
||||
): SauceNaoAnswer? = makeRequest(
|
||||
url.asSauceRequestSubject,
|
||||
resultsCount = resultsCount,
|
||||
minSimilarity = minSimilarity
|
||||
)
|
||||
|
||||
suspend fun request(
|
||||
mediaInput: Input,
|
||||
mimeType: ContentType,
|
||||
resultsCount: Int? = null,
|
||||
minSimilarity: Float? = null
|
||||
): SauceNaoAnswer? = makeRequest(
|
||||
mediaInput.asSauceRequestSubject(mimeType),
|
||||
resultsCount = resultsCount,
|
||||
minSimilarity = minSimilarity
|
||||
)
|
||||
|
||||
suspend fun requestByDb(
|
||||
url: String,
|
||||
db: Int,
|
||||
resultsCount: Int? = null,
|
||||
minSimilarity: Float? = null
|
||||
): SauceNaoAnswer? = makeRequest(
|
||||
url.asSauceRequestSubject,
|
||||
db = db,
|
||||
resultsCount = resultsCount,
|
||||
minSimilarity = minSimilarity
|
||||
)
|
||||
|
||||
suspend fun requestByMask(
|
||||
url: String,
|
||||
dbmask: Int,
|
||||
resultsCount: Int? = null,
|
||||
minSimilarity: Float? = null
|
||||
): SauceNaoAnswer? = makeRequest(
|
||||
url.asSauceRequestSubject,
|
||||
dbmask = dbmask,
|
||||
resultsCount = resultsCount,
|
||||
minSimilarity = minSimilarity
|
||||
)
|
||||
|
||||
suspend fun requestByMaskI(
|
||||
url: String,
|
||||
dbmaski: Int,
|
||||
resultsCount: Int? = null,
|
||||
minSimilarity: Float? = null
|
||||
): SauceNaoAnswer? = makeRequest(
|
||||
url.asSauceRequestSubject,
|
||||
dbmaski = dbmaski,
|
||||
resultsCount = resultsCount,
|
||||
minSimilarity = minSimilarity
|
||||
)
|
||||
|
||||
private suspend fun makeRequest(
|
||||
builder: HttpRequestBuilder
|
||||
): SauceNaoAnswer {
|
||||
return try {
|
||||
val call = client.request<HttpResponse>(builder)
|
||||
val answerText = call.readText()
|
||||
timeManager.addTimeAndClear()
|
||||
parser.decodeFromString(
|
||||
SauceNaoAnswerSerializer,
|
||||
answerText
|
||||
)
|
||||
} catch (e: ClientRequestException) {
|
||||
throw e.sauceNaoAPIException()
|
||||
}
|
||||
}
|
||||
|
||||
private suspend fun makeRequest(
|
||||
request: SauceRequestSubject,
|
||||
db: Int? = null,
|
||||
dbmask: Int? = null,
|
||||
dbmaski: Int? = null,
|
||||
resultsCount: Int? = null,
|
||||
minSimilarity: Float? = null
|
||||
): SauceNaoAnswer? {
|
||||
return suspendCoroutine<SauceNaoAnswer> {
|
||||
requestsChannel.offer(
|
||||
it to HttpRequestBuilder().apply {
|
||||
url(searchUrl)
|
||||
|
||||
apiToken ?.also { parameter(API_TOKEN_FIELD, it) }
|
||||
parameter(OUTPUT_TYPE_FIELD, outputType.typeCode)
|
||||
db ?.also { parameter(DB_FIELD, it) }
|
||||
dbmask ?.also { parameter(DBMASK_FIELD, it) }
|
||||
dbmaski ?.also { parameter(DBMASKI_FIELD, it) }
|
||||
resultsCount ?.also { parameter(RESULTS_COUNT_FIELD, it) }
|
||||
minSimilarity ?.also { parameter(MINIMAL_SIMILARITY_FIELD, it) }
|
||||
|
||||
when (request) {
|
||||
is UrlSauceRequestSubject -> {
|
||||
parameter(URL_FIELD, request.url)
|
||||
}
|
||||
is InputRequestSubject -> {
|
||||
val mimeType = request.mimeType
|
||||
|
||||
method = HttpMethod.Post
|
||||
body = MultiPartFormDataContent(formData {
|
||||
appendInput(
|
||||
FILE_FIELD,
|
||||
Headers.build {
|
||||
append(HttpHeaders.ContentType, mimeType.toString())
|
||||
|
||||
val fakeFilename = "filename=file" + when (mimeType) {
|
||||
ContentType.Image.GIF -> ".gif"
|
||||
ContentType.Image.JPEG -> ".jpeg"
|
||||
ContentType.Image.PNG -> ".png"
|
||||
ContentType.Image.SVG -> ".svg"
|
||||
else -> throw IllegalArgumentException(
|
||||
"Currently supported formats for uploading in sauce: gif, jpeg, png, svg"
|
||||
)
|
||||
}
|
||||
append(HttpHeaders.ContentDisposition, "filename=$fakeFilename")
|
||||
},
|
||||
block = request::input
|
||||
)
|
||||
})
|
||||
}
|
||||
}
|
||||
}
|
||||
)
|
||||
}
|
||||
}
|
||||
|
||||
override fun close() {
|
||||
requestsChannel.close()
|
||||
client.close()
|
||||
requestsJob.cancel()
|
||||
timeManager.close()
|
||||
quotaManager.close()
|
||||
}
|
||||
}
|
@ -1,23 +0,0 @@
|
||||
package com.insanusmokrassar.SauceNaoAPI.additional
|
||||
|
||||
import com.insanusmokrassar.SauceNaoAPI.additional.header.ResultMetaInfo
|
||||
import com.insanusmokrassar.SauceNaoAPI.additional.header.adapted
|
||||
import com.insanusmokrassar.SauceNaoAPI.additional.results.AdaptedResult
|
||||
import com.insanusmokrassar.SauceNaoAPI.additional.results.adapted
|
||||
import com.insanusmokrassar.SauceNaoAPI.models.SauceNaoAnswer
|
||||
|
||||
val SauceNaoAnswer.adapted: AdaptedAnswer
|
||||
get() = header.adapted.let { resultMetainfo ->
|
||||
val adaptedResults = results.map {
|
||||
it.adapted(resultMetainfo)
|
||||
}
|
||||
AdaptedAnswer(
|
||||
resultMetainfo,
|
||||
adaptedResults
|
||||
)
|
||||
}
|
||||
|
||||
data class AdaptedAnswer(
|
||||
val resultMetaInfo: ResultMetaInfo,
|
||||
val results: List<AdaptedResult>
|
||||
)
|
@ -1,9 +0,0 @@
|
||||
package com.insanusmokrassar.SauceNaoAPI.additional.results
|
||||
|
||||
import com.insanusmokrassar.SauceNaoAPI.additional.header.IndexInfo
|
||||
|
||||
data class ResultHeader(
|
||||
val similarity: Float,
|
||||
val thumbnail: String,
|
||||
val index: IndexInfo
|
||||
)
|
@ -1,18 +0,0 @@
|
||||
package com.insanusmokrassar.SauceNaoAPI.utils
|
||||
|
||||
import com.insanusmokrassar.SauceNaoAPI.additional.LONG_TIME_RECALCULATING_MILLIS
|
||||
import com.insanusmokrassar.SauceNaoAPI.additional.SHORT_TIME_RECALCULATING_MILLIS
|
||||
import com.insanusmokrassar.SauceNaoAPI.models.Header
|
||||
import com.soywiz.klock.DateTime
|
||||
|
||||
internal suspend fun calculateSleepTime(
|
||||
header: Header,
|
||||
mostOldestInShortPeriodGetter: suspend () -> DateTime?,
|
||||
mostOldestInLongPeriodGetter: suspend () -> DateTime?
|
||||
): DateTime? {
|
||||
return when {
|
||||
header.longRemaining < 1 -> mostOldestInLongPeriodGetter() ?.plus(LONG_TIME_RECALCULATING_MILLIS)
|
||||
header.shortRemaining < 1 -> mostOldestInShortPeriodGetter() ?.plus(SHORT_TIME_RECALCULATING_MILLIS)
|
||||
else -> null
|
||||
}
|
||||
}
|
17
src/commonMain/kotlin/dev/inmo/saucenaoapi/OutputType.kt
Normal file
17
src/commonMain/kotlin/dev/inmo/saucenaoapi/OutputType.kt
Normal file
@ -0,0 +1,17 @@
|
||||
package dev.inmo.saucenaoapi
|
||||
|
||||
sealed class OutputType {
|
||||
abstract val typeCode: Int
|
||||
}
|
||||
|
||||
object HtmlOutputType : dev.inmo.saucenaoapi.OutputType() {
|
||||
override val typeCode: Int = 0
|
||||
}
|
||||
|
||||
object XmlOutputType : dev.inmo.saucenaoapi.OutputType() {
|
||||
override val typeCode: Int = 1
|
||||
}
|
||||
|
||||
object JsonOutputType : dev.inmo.saucenaoapi.OutputType() {
|
||||
override val typeCode: Int = 2
|
||||
}
|
366
src/commonMain/kotlin/dev/inmo/saucenaoapi/SauceNaoAPI.kt
Normal file
366
src/commonMain/kotlin/dev/inmo/saucenaoapi/SauceNaoAPI.kt
Normal file
@ -0,0 +1,366 @@
|
||||
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.sauceNaoAPIException
|
||||
import dev.inmo.saucenaoapi.models.*
|
||||
import dev.inmo.saucenaoapi.utils.*
|
||||
import io.ktor.client.HttpClient
|
||||
import io.ktor.client.plugins.ClientRequestException
|
||||
import io.ktor.client.request.*
|
||||
import io.ktor.client.request.forms.MultiPartFormDataContent
|
||||
import io.ktor.client.request.forms.formData
|
||||
import io.ktor.client.statement.bodyAsText
|
||||
import io.ktor.http.*
|
||||
import io.ktor.utils.io.core.Input
|
||||
import kotlinx.coroutines.*
|
||||
import kotlinx.coroutines.channels.Channel
|
||||
import kotlinx.serialization.json.Json
|
||||
|
||||
private const val API_TOKEN_FIELD = "api_key"
|
||||
private const val OUTPUT_TYPE_FIELD = "output_type"
|
||||
private const val URL_FIELD = "url"
|
||||
private const val FILE_FIELD = "file"
|
||||
private const val FILENAME_FIELD = "filename"
|
||||
private const val DB_FIELD = "db"
|
||||
private const val DBS_FIELD = "dbs[]"
|
||||
private const val DBMASK_FIELD = "dbmask"
|
||||
private const val DBMASKI_FIELD = "dbmaski"
|
||||
private const val RESULTS_COUNT_FIELD = "numres"
|
||||
private const val MINIMAL_SIMILARITY_FIELD = "minsim"
|
||||
|
||||
private const val SEARCH_URL = "https://saucenao.com/search.php"
|
||||
|
||||
val defaultSauceNaoParser = Json {
|
||||
allowSpecialFloatingPointValues = true
|
||||
allowStructuredMapKeys = true
|
||||
ignoreUnknownKeys = true
|
||||
useArrayPolymorphism = true
|
||||
}
|
||||
|
||||
data class SauceNaoAPI(
|
||||
private val apiToken: String? = null,
|
||||
private val client: HttpClient = HttpClient(),
|
||||
private val searchUrl: String = SEARCH_URL,
|
||||
private val scope: CoroutineScope = CoroutineScope(Dispatchers.Default),
|
||||
private val parser: Json = defaultSauceNaoParser
|
||||
) : SauceCloseable {
|
||||
private val requestsChannel = Channel<Pair<CompletableDeferred<SauceNaoAnswer>, HttpRequestBuilder>>(Channel.UNLIMITED)
|
||||
private val subscope = CoroutineScope(scope.coroutineContext + SupervisorJob(scope.coroutineContext.job)).also {
|
||||
it.coroutineContext.job.invokeOnCompletion {
|
||||
requestsChannel.close(it)
|
||||
}
|
||||
}
|
||||
private val timeManager = TimeManager(subscope)
|
||||
private val quotaManager = RequestQuotaManager(subscope)
|
||||
|
||||
val limitsState: LimitsState by quotaManager::limitsState
|
||||
val longQuotaFlow by quotaManager::longQuotaFlow
|
||||
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 {
|
||||
for ((callback, requestBuilder) in requestsChannel) {
|
||||
quotaManager.getQuota()
|
||||
launch {
|
||||
try {
|
||||
val answer = makeRequest(requestBuilder)
|
||||
callback.complete(answer)
|
||||
|
||||
quotaManager.updateQuota(answer.header, timeManager)
|
||||
} catch (e: TooManyRequestsException) {
|
||||
quotaManager.happenTooManyRequests(timeManager, e)
|
||||
requestsChannel.send(callback to requestBuilder)
|
||||
} catch (e: Exception) {
|
||||
try {
|
||||
callback.completeExceptionally(e)
|
||||
} catch (e: IllegalStateException) { // may happen when already resumed and api was closed
|
||||
// do nothing
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
suspend fun request(
|
||||
url: String,
|
||||
resultsCount: Int? = null,
|
||||
minSimilarity: Float? = null
|
||||
): SauceNaoAnswer = makeRequest(
|
||||
url.asSauceRequestSubject,
|
||||
resultsCount = resultsCount,
|
||||
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(
|
||||
mediaInput: Input,
|
||||
mimeType: ContentType,
|
||||
resultsCount: Int? = null,
|
||||
minSimilarity: Float? = null
|
||||
): SauceNaoAnswer = makeRequest(
|
||||
mediaInput.asSauceRequestSubject(mimeType),
|
||||
resultsCount = resultsCount,
|
||||
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(
|
||||
file: MPPFile,
|
||||
resultsCount: Int? = null,
|
||||
minSimilarity: Float? = null
|
||||
): SauceNaoAnswer = request(
|
||||
file.input(),
|
||||
file.contentType,
|
||||
resultsCount,
|
||||
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(
|
||||
url: String,
|
||||
db: Int,
|
||||
resultsCount: Int? = null,
|
||||
minSimilarity: Float? = null
|
||||
): SauceNaoAnswer = requestByDBs(
|
||||
url,
|
||||
db,
|
||||
null,
|
||||
resultsCount,
|
||||
minSimilarity
|
||||
)
|
||||
|
||||
@Deprecated("Renamed", ReplaceWith("requestByMasks(url, dbmask, null, resultsCount, minSimilarity)"))
|
||||
suspend fun request(
|
||||
url: String,
|
||||
dbmask: Int,
|
||||
resultsCount: Int? = null,
|
||||
minSimilarity: Float? = null
|
||||
): SauceNaoAnswer = requestByMasks(
|
||||
url,
|
||||
dbmask,
|
||||
null,
|
||||
resultsCount,
|
||||
minSimilarity
|
||||
)
|
||||
|
||||
@Deprecated("Renamed", ReplaceWith("requestByMasks(url, null, dbmaski, resultsCount, minSimilarity)"))
|
||||
suspend fun requestByMaskI(
|
||||
url: String,
|
||||
dbmaski: Int,
|
||||
resultsCount: Int? = null,
|
||||
minSimilarity: Float? = null
|
||||
): SauceNaoAnswer = requestByMasks(
|
||||
url,
|
||||
null,
|
||||
dbmaski,
|
||||
resultsCount,
|
||||
minSimilarity
|
||||
)
|
||||
|
||||
private suspend fun makeRequest(
|
||||
builder: HttpRequestBuilder
|
||||
): SauceNaoAnswer {
|
||||
return try {
|
||||
val call = client.request(builder)
|
||||
val answerText = call.bodyAsText()
|
||||
timeManager.addTimeAndClear()
|
||||
parser.decodeFromString(
|
||||
SauceNaoAnswerSerializer,
|
||||
answerText
|
||||
)
|
||||
} catch (e: ClientRequestException) {
|
||||
throw e.sauceNaoAPIException()
|
||||
}
|
||||
}
|
||||
|
||||
private suspend fun makeRequest(
|
||||
request: SauceRequestSubject,
|
||||
db: Int? = null,
|
||||
dbs: Array<Int>? = null,
|
||||
dbmask: Int? = null,
|
||||
dbmaski: Int? = null,
|
||||
resultsCount: Int? = null,
|
||||
minSimilarity: Float? = null
|
||||
): SauceNaoAnswer {
|
||||
val deferred = CompletableDeferred<SauceNaoAnswer>()
|
||||
|
||||
requestsChannel.trySend(
|
||||
deferred to HttpRequestBuilder().apply {
|
||||
url(searchUrl)
|
||||
|
||||
apiToken ?.also { parameter(API_TOKEN_FIELD, it) }
|
||||
parameter(OUTPUT_TYPE_FIELD, JsonOutputType.typeCode)
|
||||
db ?.also { parameter(DB_FIELD, it) }
|
||||
dbs ?.forEach { parameter(DBS_FIELD, it) }
|
||||
dbmask ?.also { parameter(DBMASK_FIELD, it) }
|
||||
dbmaski ?.also { parameter(DBMASKI_FIELD, it) }
|
||||
resultsCount ?.also { parameter(RESULTS_COUNT_FIELD, it) }
|
||||
minSimilarity ?.also { parameter(MINIMAL_SIMILARITY_FIELD, it) }
|
||||
|
||||
when (request) {
|
||||
is UrlSauceRequestSubject -> {
|
||||
parameter(URL_FIELD, request.url)
|
||||
}
|
||||
is InputRequestSubject -> {
|
||||
val mimeType = request.mimeType
|
||||
|
||||
method = HttpMethod.Post
|
||||
setBody(
|
||||
MultiPartFormDataContent(
|
||||
formData {
|
||||
appendInput(
|
||||
FILE_FIELD,
|
||||
Headers.build {
|
||||
append(HttpHeaders.ContentType, mimeType.toString())
|
||||
|
||||
val fakeFilename = "filename=file" + when (mimeType) {
|
||||
ContentType.Image.GIF -> ".gif"
|
||||
ContentType.Image.JPEG -> ".jpeg"
|
||||
ContentType.Image.PNG -> ".png"
|
||||
ContentType.Image.SVG -> ".svg"
|
||||
else -> throw IllegalArgumentException(
|
||||
"Currently supported formats for uploading in sauce: gif, jpeg, png, svg"
|
||||
)
|
||||
}
|
||||
append(HttpHeaders.ContentDisposition, "filename=$fakeFilename")
|
||||
},
|
||||
block = request::input
|
||||
)
|
||||
}
|
||||
)
|
||||
)
|
||||
}
|
||||
}
|
||||
}
|
||||
)
|
||||
|
||||
return deferred.await()
|
||||
}
|
||||
|
||||
override fun close() {
|
||||
subscope.cancel()
|
||||
}
|
||||
}
|
@ -1,4 +1,4 @@
|
||||
package com.insanusmokrassar.SauceNaoAPI
|
||||
package dev.inmo.saucenaoapi
|
||||
|
||||
import io.ktor.http.ContentType
|
||||
import io.ktor.utils.io.core.Input
|
@ -0,0 +1,23 @@
|
||||
package dev.inmo.saucenaoapi.additional
|
||||
|
||||
import dev.inmo.saucenaoapi.additional.header.ResultMetaInfo
|
||||
import dev.inmo.saucenaoapi.additional.header.adapted
|
||||
import dev.inmo.saucenaoapi.additional.results.AdaptedResult
|
||||
import dev.inmo.saucenaoapi.additional.results.adapted
|
||||
import dev.inmo.saucenaoapi.models.SauceNaoAnswer
|
||||
|
||||
val SauceNaoAnswer.adapted: AdaptedAnswer
|
||||
get() = header.adapted.let { resultMetainfo ->
|
||||
val adaptedResults = results.map {
|
||||
it.adapted(resultMetainfo)
|
||||
}
|
||||
AdaptedAnswer(
|
||||
resultMetainfo,
|
||||
adaptedResults
|
||||
)
|
||||
}
|
||||
|
||||
data class AdaptedAnswer(
|
||||
val resultMetaInfo: ResultMetaInfo,
|
||||
val results: List<AdaptedResult>
|
||||
)
|
@ -1,6 +1,6 @@
|
||||
package com.insanusmokrassar.SauceNaoAPI.additional
|
||||
package dev.inmo.saucenaoapi.additional
|
||||
|
||||
import com.soywiz.klock.TimeSpan
|
||||
import korlibs.time.TimeSpan
|
||||
|
||||
typealias AccountType = Int
|
||||
const val defaultAccountType: AccountType = 1 // "basic"
|
@ -1,7 +1,7 @@
|
||||
package com.insanusmokrassar.SauceNaoAPI.additional.header
|
||||
package dev.inmo.saucenaoapi.additional.header
|
||||
|
||||
import com.insanusmokrassar.SauceNaoAPI.additional.*
|
||||
import com.insanusmokrassar.SauceNaoAPI.models.Header
|
||||
import dev.inmo.saucenaoapi.additional.*
|
||||
import dev.inmo.saucenaoapi.models.Header
|
||||
|
||||
val Header.shortLimitStatus: LimitStatus
|
||||
get() = LimitStatus(
|
||||
@ -29,15 +29,27 @@ val Header.accountInfo
|
||||
data class LimitStatus(
|
||||
val remain: 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(
|
||||
val short: 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(
|
||||
val accountType: AccountType = defaultAccountType,
|
||||
val userId: UserId? = null,
|
||||
val limits: Limits = Limits()
|
||||
)
|
||||
) : Comparable<AccountInfo> {
|
||||
override fun compareTo(other: AccountInfo): Int = limits.compareTo(other.limits)
|
||||
}
|
@ -1,6 +1,6 @@
|
||||
package com.insanusmokrassar.SauceNaoAPI.additional.header
|
||||
package dev.inmo.saucenaoapi.additional.header
|
||||
|
||||
import com.insanusmokrassar.SauceNaoAPI.models.Header
|
||||
import dev.inmo.saucenaoapi.models.Header
|
||||
|
||||
data class IndexInfo(
|
||||
val id: Int,
|
@ -1,6 +1,6 @@
|
||||
package com.insanusmokrassar.SauceNaoAPI.additional.header
|
||||
package dev.inmo.saucenaoapi.additional.header
|
||||
|
||||
import com.insanusmokrassar.SauceNaoAPI.models.Header
|
||||
import dev.inmo.saucenaoapi.models.Header
|
||||
|
||||
val Header.queryPreview
|
||||
get() = QueryResultPreview(
|
@ -1,6 +1,6 @@
|
||||
package com.insanusmokrassar.SauceNaoAPI.additional.header
|
||||
package dev.inmo.saucenaoapi.additional.header
|
||||
|
||||
import com.insanusmokrassar.SauceNaoAPI.models.Header
|
||||
import dev.inmo.saucenaoapi.models.Header
|
||||
|
||||
data class ResultMetaInfo(
|
||||
val accountInfo: AccountInfo = AccountInfo(),
|
@ -1,9 +1,9 @@
|
||||
package com.insanusmokrassar.SauceNaoAPI.additional.results
|
||||
package dev.inmo.saucenaoapi.additional.results
|
||||
|
||||
import com.insanusmokrassar.SauceNaoAPI.additional.header.IndexInfo
|
||||
import com.insanusmokrassar.SauceNaoAPI.additional.header.ResultMetaInfo
|
||||
import com.insanusmokrassar.SauceNaoAPI.models.Result
|
||||
import com.insanusmokrassar.SauceNaoAPI.models.ResultData
|
||||
import dev.inmo.saucenaoapi.additional.header.IndexInfo
|
||||
import dev.inmo.saucenaoapi.additional.header.ResultMetaInfo
|
||||
import dev.inmo.saucenaoapi.models.Result
|
||||
import dev.inmo.saucenaoapi.models.ResultData
|
||||
|
||||
fun Result.adapted(
|
||||
resultMetaInfo: ResultMetaInfo
|
@ -0,0 +1,9 @@
|
||||
package dev.inmo.saucenaoapi.additional.results
|
||||
|
||||
import dev.inmo.saucenaoapi.additional.header.IndexInfo
|
||||
|
||||
data class ResultHeader(
|
||||
val similarity: Float,
|
||||
val thumbnail: String,
|
||||
val index: IndexInfo
|
||||
)
|
@ -1,26 +1,25 @@
|
||||
package com.insanusmokrassar.SauceNaoAPI.exceptions
|
||||
package dev.inmo.saucenaoapi.exceptions
|
||||
|
||||
import com.insanusmokrassar.SauceNaoAPI.additional.LONG_TIME_RECALCULATING_MILLIS
|
||||
import com.insanusmokrassar.SauceNaoAPI.additional.SHORT_TIME_RECALCULATING_MILLIS
|
||||
import com.soywiz.klock.TimeSpan
|
||||
import io.ktor.client.features.ClientRequestException
|
||||
import io.ktor.client.statement.readText
|
||||
import korlibs.time.TimeSpan
|
||||
import dev.inmo.saucenaoapi.additional.LONG_TIME_RECALCULATING_MILLIS
|
||||
import dev.inmo.saucenaoapi.additional.SHORT_TIME_RECALCULATING_MILLIS
|
||||
import io.ktor.client.plugins.ClientRequestException
|
||||
import io.ktor.client.statement.bodyAsText
|
||||
import io.ktor.http.HttpStatusCode.Companion.TooManyRequests
|
||||
import io.ktor.utils.io.errors.IOException
|
||||
|
||||
internal suspend fun ClientRequestException.sauceNaoAPIException(): Exception {
|
||||
val response = response ?: return this
|
||||
return when (response.status) {
|
||||
TooManyRequests -> {
|
||||
val answerContent = response.readText()
|
||||
when {
|
||||
answerContent.contains("daily limit") -> TooManyRequestsLongException(answerContent)
|
||||
else -> TooManyRequestsShortException(answerContent)
|
||||
}
|
||||
return when (response.status) {
|
||||
TooManyRequests -> {
|
||||
val answerContent = response.bodyAsText()
|
||||
when {
|
||||
answerContent.contains("daily limit") -> TooManyRequestsLongException(answerContent)
|
||||
else -> TooManyRequestsShortException(answerContent)
|
||||
}
|
||||
else -> this
|
||||
}
|
||||
else -> this
|
||||
}
|
||||
}
|
||||
|
||||
sealed class TooManyRequestsException(message: String, cause: Throwable? = null) : IOException(message, cause) {
|
||||
abstract val answerContent: String
|
@ -1,6 +1,6 @@
|
||||
package com.insanusmokrassar.SauceNaoAPI.models
|
||||
package dev.inmo.saucenaoapi.models
|
||||
|
||||
import com.insanusmokrassar.SauceNaoAPI.defaultSauceNaoParser
|
||||
import dev.inmo.saucenaoapi.defaultSauceNaoParser
|
||||
import kotlinx.serialization.*
|
||||
import kotlinx.serialization.builtins.serializer
|
||||
import kotlinx.serialization.descriptors.SerialDescriptor
|
@ -1,4 +1,4 @@
|
||||
package com.insanusmokrassar.SauceNaoAPI.models
|
||||
package dev.inmo.saucenaoapi.models
|
||||
|
||||
import kotlinx.serialization.Serializable
|
||||
|
@ -1,4 +1,4 @@
|
||||
package com.insanusmokrassar.SauceNaoAPI.models
|
||||
package dev.inmo.saucenaoapi.models
|
||||
|
||||
import kotlinx.serialization.Serializable
|
||||
|
||||
@ -8,4 +8,6 @@ data class LimitsState(
|
||||
val maxLongQuota: Int,
|
||||
val knownShortQuota: Int,
|
||||
val knownLongQuota: Int
|
||||
)
|
||||
) : Comparable<LimitsState> {
|
||||
override fun compareTo(other: LimitsState): Int = knownShortQuota.compareTo(other.knownShortQuota)
|
||||
}
|
@ -1,4 +1,4 @@
|
||||
package com.insanusmokrassar.SauceNaoAPI.models
|
||||
package dev.inmo.saucenaoapi.models
|
||||
|
||||
import kotlinx.serialization.Serializable
|
||||
|
@ -1,6 +1,6 @@
|
||||
package com.insanusmokrassar.SauceNaoAPI.models
|
||||
package dev.inmo.saucenaoapi.models
|
||||
|
||||
import com.insanusmokrassar.SauceNaoAPI.utils.CommonMultivariantStringSerializer
|
||||
import dev.inmo.saucenaoapi.utils.CommonMultivariantStringSerializer
|
||||
import kotlinx.serialization.SerialName
|
||||
import kotlinx.serialization.Serializable
|
||||
|
||||
@ -159,3 +159,18 @@ data class ResultData(
|
||||
@SerialName("ext_urls")
|
||||
val extUrls: List<String> = emptyList()
|
||||
)
|
||||
|
||||
val ResultData.froms: List<String>
|
||||
get() = material ?.split(", ") ?: emptyList()
|
||||
|
||||
val ResultData.authors: List<String>
|
||||
get() = (creator ?.split(", ") ?: emptyList()) + (memberName ?.split(", ") ?: emptyList())
|
||||
|
||||
val ResultData.charactersList: List<String>
|
||||
get() = characters ?.split(", ") ?: emptyList()
|
||||
|
||||
val ResultData.titles: List<String>
|
||||
get() = title ?.split(", ") ?: emptyList()
|
||||
|
||||
val ResultData.urls: List<String>
|
||||
get() = extUrls + (url ?.split(", ") ?: emptyList())
|
@ -1,4 +1,4 @@
|
||||
package com.insanusmokrassar.SauceNaoAPI.models
|
||||
package dev.inmo.saucenaoapi.models
|
||||
|
||||
import kotlinx.serialization.SerialName
|
||||
import kotlinx.serialization.Serializable
|
@ -1,6 +1,6 @@
|
||||
package com.insanusmokrassar.SauceNaoAPI.models
|
||||
package dev.inmo.saucenaoapi.models
|
||||
|
||||
import com.insanusmokrassar.SauceNaoAPI.defaultSauceNaoParser
|
||||
import dev.inmo.saucenaoapi.defaultSauceNaoParser
|
||||
import kotlinx.serialization.*
|
||||
import kotlinx.serialization.builtins.ListSerializer
|
||||
import kotlinx.serialization.encoding.Decoder
|
@ -1,17 +1,13 @@
|
||||
package com.insanusmokrassar.SauceNaoAPI.utils
|
||||
package dev.inmo.saucenaoapi.utils
|
||||
|
||||
import kotlinx.serialization.KSerializer
|
||||
import kotlinx.serialization.Serializer
|
||||
import kotlinx.serialization.builtins.ListSerializer
|
||||
import kotlinx.serialization.builtins.serializer
|
||||
import kotlinx.serialization.encoding.Decoder
|
||||
import kotlinx.serialization.json.*
|
||||
|
||||
|
||||
@Serializer(String::class)
|
||||
object CommonMultivariantStringSerializer : KSerializer<String> by String.serializer() {
|
||||
private val stringArraySerializer = ListSerializer(String.serializer())
|
||||
|
||||
override fun deserialize(decoder: Decoder): String {
|
||||
return when (val parsed = JsonElement.serializer().deserialize(decoder)) {
|
||||
is JsonPrimitive -> parsed.content
|
26
src/commonMain/kotlin/dev/inmo/saucenaoapi/utils/MPPFile.kt
Normal file
26
src/commonMain/kotlin/dev/inmo/saucenaoapi/utils/MPPFile.kt
Normal file
@ -0,0 +1,26 @@
|
||||
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.utils.io.core.Input
|
||||
|
||||
@Deprecated(
|
||||
"MPPFile from microutils is preferable since 0.16.0",
|
||||
ReplaceWith("MPPFile", "dev.inmo.micro_utils.common.MPPFile")
|
||||
)
|
||||
typealias MPPFile = MPPFile
|
||||
|
||||
@Deprecated(
|
||||
"input() from microutils is preferable since 0.16.0",
|
||||
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,26 +1,47 @@
|
||||
package com.insanusmokrassar.SauceNaoAPI.utils
|
||||
package dev.inmo.saucenaoapi.utils
|
||||
|
||||
import com.insanusmokrassar.SauceNaoAPI.additional.LONG_TIME_RECALCULATING_MILLIS
|
||||
import com.insanusmokrassar.SauceNaoAPI.additional.SHORT_TIME_RECALCULATING_MILLIS
|
||||
import com.insanusmokrassar.SauceNaoAPI.exceptions.TooManyRequestsException
|
||||
import com.insanusmokrassar.SauceNaoAPI.exceptions.TooManyRequestsLongException
|
||||
import com.insanusmokrassar.SauceNaoAPI.models.Header
|
||||
import com.insanusmokrassar.SauceNaoAPI.models.LimitsState
|
||||
import com.soywiz.klock.DateTime
|
||||
import korlibs.time.DateTime
|
||||
import dev.inmo.saucenaoapi.additional.LONG_TIME_RECALCULATING_MILLIS
|
||||
import dev.inmo.saucenaoapi.additional.SHORT_TIME_RECALCULATING_MILLIS
|
||||
import dev.inmo.saucenaoapi.exceptions.TooManyRequestsException
|
||||
import dev.inmo.saucenaoapi.exceptions.TooManyRequestsLongException
|
||||
import dev.inmo.saucenaoapi.models.Header
|
||||
import dev.inmo.saucenaoapi.models.LimitsState
|
||||
import kotlinx.coroutines.*
|
||||
import kotlinx.coroutines.channels.Channel
|
||||
import kotlin.coroutines.suspendCoroutine
|
||||
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.min
|
||||
|
||||
internal class RequestQuotaManager (
|
||||
scope: CoroutineScope
|
||||
) : SauceCloseable {
|
||||
private var longQuota = 1
|
||||
private var shortQuota = 1
|
||||
private var longMaxQuota = 1
|
||||
private var shortMaxQuota = 1
|
||||
) {
|
||||
private val _longQuotaFlow = MutableStateFlow(1)
|
||||
private val _shortQuotaFlow = MutableStateFlow(1)
|
||||
private val _longMaxQuotaFlow = MutableStateFlow(1)
|
||||
private val _shortMaxQuotaFlow = MutableStateFlow(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
|
||||
get() = LimitsState(
|
||||
shortMaxQuota,
|
||||
@ -35,6 +56,10 @@ internal class RequestQuotaManager (
|
||||
for (callback in quotaActions) {
|
||||
callback()
|
||||
}
|
||||
}.also {
|
||||
it.invokeOnCompletion {
|
||||
quotaActions.close(it)
|
||||
}
|
||||
}
|
||||
|
||||
private suspend fun updateQuota(
|
||||
@ -83,21 +108,16 @@ internal class RequestQuotaManager (
|
||||
)
|
||||
|
||||
suspend fun getQuota() {
|
||||
return suspendCoroutine {
|
||||
lateinit var callback: suspend () -> Unit
|
||||
callback = suspend {
|
||||
if (longQuota > 0 && shortQuota > 0) {
|
||||
it.resumeWith(Result.success(Unit))
|
||||
} else {
|
||||
quotaActions.send(callback)
|
||||
}
|
||||
val job = Job()
|
||||
lateinit var callback: suspend () -> Unit
|
||||
callback = suspend {
|
||||
if (longQuota > 0 && shortQuota > 0) {
|
||||
job.complete()
|
||||
} else {
|
||||
quotaActions.send(callback)
|
||||
}
|
||||
quotaActions.offer(callback)
|
||||
}
|
||||
}
|
||||
|
||||
override fun close() {
|
||||
quotaJob.cancel()
|
||||
quotaActions.close()
|
||||
quotaActions.trySend(callback)
|
||||
return job.join()
|
||||
}
|
||||
}
|
@ -1,4 +1,4 @@
|
||||
package com.insanusmokrassar.SauceNaoAPI.utils
|
||||
package dev.inmo.saucenaoapi.utils
|
||||
|
||||
import kotlinx.coroutines.supervisorScope
|
||||
|
||||
@ -6,12 +6,13 @@ interface SauceCloseable {
|
||||
fun close()
|
||||
}
|
||||
|
||||
fun <T> SauceCloseable.use(block: (SauceCloseable) -> T): T = try {
|
||||
inline fun <T> SauceCloseable.use(block: (SauceCloseable) -> T): T = try {
|
||||
block(this)
|
||||
} finally {
|
||||
close()
|
||||
}
|
||||
|
||||
@Deprecated("Useless")
|
||||
suspend fun <T> SauceCloseable.useSafe(block: suspend (SauceCloseable) -> T): T = try {
|
||||
supervisorScope {
|
||||
block(this@useSafe)
|
@ -1,13 +1,10 @@
|
||||
package com.insanusmokrassar.SauceNaoAPI.utils
|
||||
package dev.inmo.saucenaoapi.utils
|
||||
|
||||
import com.insanusmokrassar.SauceNaoAPI.additional.LONG_TIME_RECALCULATING_MILLIS
|
||||
import com.insanusmokrassar.SauceNaoAPI.additional.SHORT_TIME_RECALCULATING_MILLIS
|
||||
import com.soywiz.klock.DateTime
|
||||
import kotlinx.coroutines.CoroutineScope
|
||||
import korlibs.time.DateTime
|
||||
import dev.inmo.saucenaoapi.additional.LONG_TIME_RECALCULATING_MILLIS
|
||||
import dev.inmo.saucenaoapi.additional.SHORT_TIME_RECALCULATING_MILLIS
|
||||
import kotlinx.coroutines.*
|
||||
import kotlinx.coroutines.channels.Channel
|
||||
import kotlinx.coroutines.launch
|
||||
import kotlin.coroutines.Continuation
|
||||
import kotlin.coroutines.suspendCoroutine
|
||||
|
||||
private fun MutableList<DateTime>.clearTooOldTimes(relatedTo: DateTime = DateTime.now()) {
|
||||
val limitValue = relatedTo - LONG_TIME_RECALCULATING_MILLIS
|
||||
@ -38,16 +35,16 @@ private data class TimeManagerTimeAdder(
|
||||
}
|
||||
|
||||
private data class TimeManagerMostOldestInLongGetter(
|
||||
private val continuation: Continuation<DateTime?>
|
||||
private val deferred: CompletableDeferred<DateTime?>
|
||||
) : TimeManagerAction {
|
||||
override suspend fun makeChangeWith(times: MutableList<DateTime>) {
|
||||
times.clearTooOldTimes()
|
||||
continuation.resumeWith(Result.success(times.minOrNull()))
|
||||
deferred.complete(times.minOrNull())
|
||||
}
|
||||
}
|
||||
|
||||
private data class TimeManagerMostOldestInShortGetter(
|
||||
private val continuation: Continuation<DateTime?>
|
||||
private val deferred: CompletableDeferred<DateTime?>
|
||||
) : TimeManagerAction {
|
||||
override suspend fun makeChangeWith(times: MutableList<DateTime>) {
|
||||
times.clearTooOldTimes()
|
||||
@ -56,19 +53,17 @@ private data class TimeManagerMostOldestInShortGetter(
|
||||
|
||||
val limitTime = now - SHORT_TIME_RECALCULATING_MILLIS
|
||||
|
||||
continuation.resumeWith(
|
||||
Result.success(
|
||||
times.asSequence().filter {
|
||||
limitTime < it
|
||||
}.minOrNull()
|
||||
)
|
||||
deferred.complete(
|
||||
times.asSequence().filter {
|
||||
limitTime < it
|
||||
}.minOrNull()
|
||||
)
|
||||
}
|
||||
}
|
||||
|
||||
internal class TimeManager(
|
||||
scope: CoroutineScope
|
||||
) : SauceCloseable {
|
||||
) {
|
||||
private val actionsChannel = Channel<TimeManagerAction>(Channel.UNLIMITED)
|
||||
|
||||
private val timeUpdateJob = scope.launch {
|
||||
@ -76,6 +71,10 @@ internal class TimeManager(
|
||||
for (action in actionsChannel) {
|
||||
action(times)
|
||||
}
|
||||
}.also {
|
||||
it.invokeOnCompletion {
|
||||
actionsChannel.close(it)
|
||||
}
|
||||
}
|
||||
|
||||
suspend fun addTimeAndClear() {
|
||||
@ -83,21 +82,20 @@ internal class TimeManager(
|
||||
}
|
||||
|
||||
suspend fun getMostOldestInLongPeriod(): DateTime? {
|
||||
return suspendCoroutine {
|
||||
actionsChannel.offer(
|
||||
TimeManagerMostOldestInLongGetter(it)
|
||||
)
|
||||
val deferred = CompletableDeferred<DateTime?>()
|
||||
return if (actionsChannel.trySend(TimeManagerMostOldestInLongGetter(deferred)).isSuccess) {
|
||||
deferred.await()
|
||||
} else {
|
||||
null
|
||||
}
|
||||
}
|
||||
|
||||
suspend fun getMostOldestInShortPeriod(): DateTime? {
|
||||
return suspendCoroutine {
|
||||
actionsChannel.offer(TimeManagerMostOldestInShortGetter(it))
|
||||
val deferred = CompletableDeferred<DateTime?>()
|
||||
return if (actionsChannel.trySend(TimeManagerMostOldestInShortGetter(deferred)).isSuccess) {
|
||||
deferred.await()
|
||||
} else {
|
||||
null
|
||||
}
|
||||
}
|
||||
|
||||
override fun close() {
|
||||
actionsChannel.close()
|
||||
timeUpdateJob.cancel()
|
||||
}
|
||||
}
|
@ -1,30 +1,27 @@
|
||||
import com.insanusmokrassar.SauceNaoAPI.SauceNaoAPI
|
||||
import com.insanusmokrassar.SauceNaoAPI.utils.useSafe
|
||||
import io.ktor.http.ContentType
|
||||
import io.ktor.utils.io.streams.asInput
|
||||
import dev.inmo.saucenaoapi.SauceNaoAPI
|
||||
import io.ktor.client.HttpClient
|
||||
import kotlinx.coroutines.*
|
||||
import java.io.File
|
||||
import java.nio.file.Files
|
||||
|
||||
suspend fun main(vararg args: String) {
|
||||
val (key, requestSubject) = args
|
||||
|
||||
val scope = CoroutineScope(Dispatchers.Default)
|
||||
|
||||
val api = SauceNaoAPI(key, scope = scope)
|
||||
api.useSafe { _ ->
|
||||
println(
|
||||
when {
|
||||
requestSubject.startsWith("/") -> File(requestSubject).let {
|
||||
api.request(
|
||||
it.inputStream().asInput(),
|
||||
ContentType.parse(Files.probeContentType(it.toPath()))
|
||||
)
|
||||
}
|
||||
else -> api.request(requestSubject)
|
||||
}
|
||||
)
|
||||
val client = HttpClient()
|
||||
val scope = CoroutineScope(Dispatchers.IO).also {
|
||||
it.coroutineContext.job.invokeOnCompletion {
|
||||
client.close()
|
||||
}
|
||||
}
|
||||
|
||||
val api = SauceNaoAPI(key, client, scope = scope)
|
||||
println(
|
||||
when {
|
||||
requestSubject.startsWith("/") -> File(requestSubject).let {
|
||||
api.request(it)
|
||||
}
|
||||
else -> api.request(requestSubject)
|
||||
}
|
||||
)
|
||||
|
||||
scope.cancel()
|
||||
}
|
||||
|
Loading…
Reference in New Issue
Block a user