dalbodeule/sh0rt.kr-pdns
1
0
Fork 0
mirror of https://github.com/dalbodeule/sh0rt.kr-pdns.git synced 2025-06-08 18:58:20 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix pdns api clients (retry 9x)

Browse Source
This commit is contained in:
dalbodeule 2024-06-07 10:14:29 +09:00
parent 85cccd391a
commit ccb02f0f50
No known key found for this signature in database
GPG Key ID: EFA860D069C9FA65
1 changed files with 35 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

42
src/main/kotlin/space/mori/dnsapi/PowerDNSAPIClient.kt
View File

@ -6,6 +6,7 @@ import okhttp3.OkHttpClient
import okhttp3.Request import okhttp3.Request
import okhttp3.RequestBody.Companion.toRequestBody import okhttp3.RequestBody.Companion.toRequestBody
import okhttp3.Response import okhttp3.Response
import okhttp3.internal.concat
import org.springframework.beans.factory.annotation.Value import org.springframework.beans.factory.annotation.Value
import org.springframework.stereotype.Service import org.springframework.stereotype.Service
@ -27,15 +28,20 @@ class PowerDNSAPIClient() {
val body = gson.toJson(mapOf( val body = gson.toJson(mapOf(
"name" to zoneName, "name" to zoneName,
"nameservers" to nameserver.split(",")) "nameservers" to nameserver.split(","))
).toRequestBody("application/json".toMediaType()) ).toRequestBody()
val request = Request.Builder() val request = Request.Builder()
.url("$apiUrl/api/v1/servers/localhost/zones") .url("$apiUrl/api/v1/servers/localhost/zones")
.addHeader("X-API-Key", apiKey) .addHeader("X-API-Key", apiKey)
.addHeader("Accept", "application/json")
.addHeader("Content-Type", "application/json")
.post(body) .post(body)
.build() .build()
val response = client.newCall(request).execute() val response = client.newCall(request).execute()
if(!response.isSuccessful) { throw RuntimeException("Unexpected code $response") } if(!response.isSuccessful) {
val error = gson.fromJson(response.body?.string(), Error::class.java)
throw RuntimeException("Unexpected code ${error.error}, ${error.errors.concat(", ")}")
}
return response return response
} }
@ -43,11 +49,16 @@ class PowerDNSAPIClient() {
val request = Request.Builder() val request = Request.Builder()
.url("$apiUrl/api/v1/servers/localhost/zones/$zoneName") .url("$apiUrl/api/v1/servers/localhost/zones/$zoneName")
.addHeader("X-API-Key", apiKey) .addHeader("X-API-Key", apiKey)
.addHeader("Accept", "application/json")
.addHeader("Content-Type", "application/json")
.delete() .delete()
.build() .build()
val response = client.newCall(request).execute() val response = client.newCall(request).execute()
if(!response.isSuccessful) { throw RuntimeException("Unexpected code $response") } if(!response.isSuccessful) {
val error = gson.fromJson(response.body?.string(), Error::class.java)
throw RuntimeException("Unexpected code ${error.error}, ${error.errors.concat(", ")}")
}
return response return response
} }
@ -60,11 +71,16 @@ class PowerDNSAPIClient() {
val request = Request.Builder() val request = Request.Builder()
.url("$apiUrl/api/v1/servers/localhost/zones/$zoneName/records") .url("$apiUrl/api/v1/servers/localhost/zones/$zoneName/records")
.addHeader("X-API-Key", apiKey) .addHeader("X-API-Key", apiKey)
.addHeader("Accept", "application/json")
.addHeader("Content-Type", "application/json")
.post(body) .post(body)
.build() .build()
val response = client.newCall(request).execute() val response = client.newCall(request).execute()
if(!response.isSuccessful) { throw RuntimeException("Unexpected code $response") } if(!response.isSuccessful) {
val error = gson.fromJson(response.body?.string(), Error::class.java)
throw RuntimeException("Unexpected code ${error.error}, ${error.errors.concat(", ")}")
}
return response return response
} }
@ -75,11 +91,16 @@ class PowerDNSAPIClient() {
val request = Request.Builder() val request = Request.Builder()
.url("$apiUrl/api/v1/servers/localhost/zones/$zoneName/records/$recordName/$recordType") .url("$apiUrl/api/v1/servers/localhost/zones/$zoneName/records/$recordName/$recordType")
.addHeader("X-API-Key", apiKey) .addHeader("X-API-Key", apiKey)
.addHeader("Accept", "application/json")
.addHeader("Content-Type", "application/json")
.put(body) .put(body)
.build() .build()
val response = client.newCall(request).execute() val response = client.newCall(request).execute()
if(!response.isSuccessful) { throw RuntimeException("Unexpected code $response") } if(!response.isSuccessful) {
val error = gson.fromJson(response.body?.string(), Error::class.java)
throw RuntimeException("Unexpected code ${error.error}, ${error.errors.concat(", ")}")
}
return response return response
} }
@ -87,11 +108,18 @@ class PowerDNSAPIClient() {
val request = Request.Builder() val request = Request.Builder()
.url("$apiUrl/api/v1/servers/localhost/zones/$zoneName/records/$recordName/$recordType") .url("$apiUrl/api/v1/servers/localhost/zones/$zoneName/records/$recordName/$recordType")
.addHeader("X-API-Key", apiKey) .addHeader("X-API-Key", apiKey)
.addHeader("Accept", "application/json")
.addHeader("Content-Type", "application/json")
.delete() .delete()
.build() .build()
val response = client.newCall(request).execute() val response = client.newCall(request).execute()
if(!response.isSuccessful) { throw RuntimeException("Unexpected code $response") } if(!response.isSuccessful) {
val error = gson.fromJson(response.body?.string(), Error::class.java)
throw RuntimeException("Unexpected code ${error.error}, ${error.errors.concat(", ")}")
}
return response return response
} }
} }
data class Error(val error: String, val errors: Array<String>)