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 6x)

Browse Source
This commit is contained in:
dalbodeule 2024-06-07 01:24:22 +09:00
parent a41d8ae23c
commit 006fb129f3
No known key found for this signature in database
GPG Key ID: EFA860D069C9FA65
1 changed files with 21 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -5,6 +5,7 @@ import okhttp3.MediaType.Companion.toMediaType
import okhttp3.OkHttpClient import okhttp3.OkHttpClient
import okhttp3.Request import okhttp3.Request
import okhttp3.RequestBody.Companion.toRequestBody import okhttp3.RequestBody.Companion.toRequestBody
import okhttp3.Response
import org.springframework.beans.factory.annotation.Value import org.springframework.beans.factory.annotation.Value
import org.springframework.stereotype.Service import org.springframework.stereotype.Service
@ -22,33 +23,35 @@ class PowerDNSAPIClient() {
private val gson = Gson() private val gson = Gson()
private val client = OkHttpClient() private val client = OkHttpClient()
fun createZone(zoneName: String): Boolean { fun createZone(zoneName: String): Response {
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; charset=utf-8".toMediaType()) ).toRequestBody("application/json; charset=utf-8".toMediaType())
val request = Request.Builder() val request = Request.Builder()
.url("$apiUrl/api/v1/servers/localhost/zones") .url("$apiUrl/api/v1/servers/localhost/zones")
.addHeader("Authorization", "Bearer $apiKey") .addHeader("X-API-Key", apiKey)
.post(body) .post(body)
.build() .build()
val response = client.newCall(request).execute() val response = client.newCall(request).execute()
return response.isSuccessful if(!response.isSuccessful) { throw RuntimeException("Unexpected code $response") }
return response
} }
fun deleteZone(zoneName: String): Boolean { fun deleteZone(zoneName: String): Response {
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("Authorization", "Bearer $apiKey") .addHeader("X-API-Key", apiKey)
.delete() .delete()
.build() .build()
val response = client.newCall(request).execute() val response = client.newCall(request).execute()
return response.isSuccessful if(!response.isSuccessful) { throw RuntimeException("Unexpected code $response") }
return response
} }
fun createRecord(zoneName: String, recordName: String, recordType: String, recordContent: String): Boolean { fun createRecord(zoneName: String, recordName: String, recordType: String, recordContent: String): Response {
val body = gson.toJson(mapOf( val body = gson.toJson(mapOf(
"name" to recordName, "name" to recordName,
"type" to recordType, "type" to recordType,
@ -56,36 +59,39 @@ class PowerDNSAPIClient() {
)).toRequestBody("application/json; charset=utf-8".toMediaType()) )).toRequestBody("application/json; charset=utf-8".toMediaType())
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("Authorization", "Bearer $apiKey") .addHeader("X-API-Key", apiKey)
.post(body) .post(body)
.build() .build()
val response = client.newCall(request).execute() val response = client.newCall(request).execute()
return response.isSuccessful if(!response.isSuccessful) { throw RuntimeException("Unexpected code $response") }
return response
} }
fun updateRecord(zoneName: String, recordName: String, recordType: String, recordContent: String): Boolean { fun updateRecord(zoneName: String, recordName: String, recordType: String, recordContent: String): Response {
val body = gson.toJson(mapOf( val body = gson.toJson(mapOf(
"content" to recordContent "content" to recordContent
)).toRequestBody("application/json; charset=utf-8".toMediaType()) )).toRequestBody("application/json; charset=utf-8".toMediaType())
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("Authorization", "Bearer $apiKey") .addHeader("X-API-Key", apiKey)
.put(body) .put(body)
.build() .build()
val response = client.newCall(request).execute() val response = client.newCall(request).execute()
return response.isSuccessful if(!response.isSuccessful) { throw RuntimeException("Unexpected code $response") }
return response
} }
fun deleteRecord(zoneName: String, recordName: String, recordType: String): Boolean { fun deleteRecord(zoneName: String, recordName: String, recordType: String): Response {
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("Authorization", "Bearer $apiKey") .addHeader("X-API-Key", apiKey)
.delete() .delete()
.build() .build()
val response = client.newCall(request).execute() val response = client.newCall(request).execute()
return response.isSuccessful if(!response.isSuccessful) { throw RuntimeException("Unexpected code $response") }
return response
} }
} }