API 레퍼런스

public class Deplite(
    public val apiToken: String,
    public val baseUrl: String = DEFAULT_BASE_URL,
    okHttp: OkHttpClient = HttpClient.defaultOkHttp(),
)

@JvmStatic
@JvmOverloads
public suspend fun enroll(
    installCode: String,
    name: String,
    hostname: String? = null,
    os: String? = null,
    agentVersion: String? = null,
    baseUrl: String = DEFAULT_BASE_URL,
    okHttp: OkHttpClient = HttpClient.defaultOkHttp(),
): Enrollment

val enrollment = Deplite.enroll(
    installCode = INSTALL_CODE,
    name = "kiosk-seoul-01",
)
secureStore.save(enrollment)  // identity + privateKey

public suspend fun run(
    triggerId: String,
    params: JsonElement? = null,
    workflowName: String? = null,
    ref: String? = null,
    debug: Boolean = false,
    idempotencyKey: String? = null,
): TriggerRunResult

val job = deplite.triggers.run(
    triggerId = TRIGGER_ID,
    params = buildJsonObject {
        put("ref", "main")
        put("actor", "sehyun")
    },
    idempotencyKey = UUID.randomUUID().toString(),
)
 
Log.i("Deplite", "${job.jobId} ${job.status}")

public suspend fun upload(
    file: File,
    cleanupRule: CleanupRule = CleanupRule.Ttl(86_400),
    filename: String? = null,
    contentType: String? = null,
    bindingId: String? = null,
): FileMeta

val uploaded = deplite.files.upload(
    file = File("/tmp/app.apk"),
    cleanupRule = CleanupRule.Ttl(3600),
    contentType = "application/vnd.android.package-archive",
)
 
deplite.triggers.run(
    triggerId = TRIGGER_ID,
    params = buildJsonObject { put("apkFileId", uploaded.id) },
)

public suspend fun presignUpload(
    cleanupRule: CleanupRule,
    filename: String? = null,
    contentType: String? = null,
    bindingId: String? = null,
): PresignedUpload

public suspend fun completeUpload(fileId: String): FileMeta
public suspend fun downloadUrl(fileId: String): String
public suspend fun download(fileId: String, to: File): File
public suspend fun get(fileId: String): FileMeta
public suspend fun list(bindingId: String? = null, status: String? = null): List<FileMeta>
public suspend fun delete(fileId: String)

public class DepliteAgent(
    public val identity: AgentIdentity,
    privateKey: ByteArray,       // 정확히 32바이트
    okHttp: OkHttpClient = HttpClient.defaultOkHttp(),
)

public suspend fun heartbeat()

public suspend fun updateIdentity(
    hostname: String? = null,
    os: String? = null,
    agentVersion: String? = null,
)

public fun events(): Flow<AgentEvent>

agent.events().collect { ev ->
    when (ev) {
        is AgentEvent.Deploy -> handleDeploy(ev.payload)
        AgentEvent.SyncWorkflows -> reportWorkflows()
        AgentEvent.Revoke -> return@collect
        AgentEvent.Ping -> {}                  // keep-alive 무시
        is AgentEvent.Unknown -> Log.w("Agent", "unknown: ${ev.name}")
    }
}

public suspend fun appendLogs(jobId: String, items: List<LogItem>): Int

public suspend fun reportResult(jobId: String, result: JobResult)

try {
    val output = runWorkflow(payload)
    agent.jobs.reportResult(payload.jobId, JobResult.success(output = output))
} catch (e: Exception) {
    agent.jobs.reportResult(payload.jobId, JobResult.failed(exitCode = 1, errorMessage = e.message))
}

public suspend fun upload(jobId: String, file: File, ...): FileMeta
public suspend fun presignUpload(jobId: String, ...): PresignedUpload
public suspend fun complete(fileId: String): FileMeta
public suspend fun downloadUrl(fileId: String): String
public suspend fun download(fileId: String, to: File): File
public suspend fun get(fileId: String): FileMeta
public suspend fun delete(fileId: String)

public suspend fun report(workflows: List<WorkflowReport>): Int

public data class Enrollment(
    val identity: AgentIdentity,
    val privateKey: ByteArray,       // raw 32-byte 개인키
)

public data class AgentIdentity(
    val agentId: String,
    val organizationId: String,
    val baseUrl: String,
    val serverPublicKeyPem: String,
)

public sealed class AgentEvent {
    public data class Deploy(val payload: DeployPayload, val signature: String) : AgentEvent()
    public data object Revoke : AgentEvent()
    public data object SyncWorkflows : AgentEvent()
    public data object Ping : AgentEvent()
    public data class Unknown(val name: String, val data: String) : AgentEvent()
}

@Serializable
public data class DeployPayload(
    val jobId: String,
    val workflowName: String,
    val debug: Boolean = false,
    val ref: String? = null,
    val params: JsonElement? = null,
    val issuedAt: Long = 0,
    val nonce: String = "",
    val force: Boolean = false,
    val forceReason: String? = null,
)

@Serializable
public data class TriggerRunResult(
    val jobId: String,
    val status: String,
    val idempotent: Boolean = false,
    val timedOut: Boolean = false,
    val exitCode: Int? = null,
    val errorMessage: String? = null,
    val output: JsonElement? = null,
    val statusUrl: String? = null,
)

public sealed class CleanupRule {
    public data class Ttl(val ttlSeconds: Long) : CleanupRule()   // 60s ≤ ttl ≤ 90일
    public data object Persistent : CleanupRule()
    public data object OnJobEnd : CleanupRule()                   // Agent Files 전용
}

@Serializable
public data class FileMeta(
    val id: String,
    val bindingId: String? = null,
    val jobId: String? = null,
    val filename: String? = null,
    val contentType: String? = null,
    val size: Long? = null,
    val status: String? = null,
    val cleanupRule: String? = null,
    val expiresAt: String? = null,
    val createdAt: String? = null,
)

@Serializable
public data class PresignedUpload(
    val fileId: String,
    val uploadUrl: String,
    val uploadHeaders: Map<String, String>? = null,
    val expiresInSeconds: Int? = null,
)

public enum class LogStream { Raw, System }
public enum class LogLevel { Info, Warn, Error }
 
public data class LogItem(
    val seq: Int,
    val stream: LogStream,
    val content: String,
    val stepName: String? = null,
    val level: LogLevel? = null,
)

public enum class JobStatus { Running, Success, Failed, Timeout, Rejected }
 
public data class JobResult internal constructor(
    val status: JobStatus,
    val exitCode: Int? = null,
    val errorMessage: String? = null,
    val output: JsonElement? = null,
    val rejection: Rejection? = null,
) {
    public companion object {
        public fun running(): JobResult
        public fun success(exitCode: Int = 0, output: JsonElement? = null): JobResult
        public fun failed(exitCode: Int? = null, errorMessage: String? = null): JobResult
        public fun timeout(errorMessage: String? = null): JobResult
        public fun rejected(rejection: Rejection): JobResult
    }
}

public data class Rejection(
    val reason: String,           // 'rate_limited' | 'queue_full' | ...
    val limitType: String? = null,
    val retryAfterSeconds: Int? = null,
    val bypassedLimits: List<String> = emptyList(),
)

@Serializable
public data class WorkflowReport(
    val name: String,
    val verboseSteps: List<String> = emptyList(),
    val secretsKeys: List<String> = emptyList(),
)

public open class DepliteException(
    message: String,
    cause: Throwable? = null,
) : RuntimeException(message, cause)

public open class DepliteApiException(
    public val statusCode: Int,
    public val body: String,
) : DepliteException("Deplite API error: $statusCode")

public class DepliteAuthException(
    statusCode: Int,
    body: String,
) : DepliteApiException(statusCode, body)

try {
    deplite.triggers.run(triggerId, params = buildJsonObject {})
} catch (e: DepliteAuthException) {
    // 토큰 회수·교체 필요
} catch (e: DepliteApiException) {
    if (e.statusCode == 429 || e.statusCode >= 500) {
        // 백오프 후 재시도
    }
} catch (e: DepliteException) {
    Log.e("Deplite", e.message, e.cause)
}