119 lines
3.1 KiB
Swift
119 lines
3.1 KiB
Swift
//
|
|
// JellyfinClientController.swift
|
|
// Jel
|
|
//
|
|
// Created by zerocool on 12/12/23.
|
|
//
|
|
|
|
import Foundation
|
|
import Get
|
|
import JellyfinKit
|
|
import Pulse
|
|
|
|
struct AuthHeaders: Codable {
|
|
var Client: String
|
|
var Device: String
|
|
var DeviceId: String
|
|
var Version: String
|
|
var Token: String
|
|
}
|
|
|
|
enum JellyfinClientError: Error {
|
|
case badResponseCode
|
|
}
|
|
|
|
extension AuthHeaders {
|
|
func format() -> String {
|
|
return "MediaBrowser Client=\(self.Client), Device=\(self.Device), DeviceId=\(self.DeviceId), Version=\(self.Version), Token=\(self.Token)"
|
|
}
|
|
}
|
|
|
|
class JellyfinClientController: ObservableObject {
|
|
private var api: APIClient
|
|
|
|
private var authHeaders: AuthHeaders
|
|
private var authState: AuthStateController
|
|
|
|
init(authHeaders: AuthHeaders, serverUrl: URL? = nil, authState: AuthStateController = AuthStateController.shared) {
|
|
self.authHeaders = authHeaders
|
|
self.authState = authState
|
|
|
|
self.api = APIClient(baseURL: serverUrl)
|
|
self.setUrl(url: serverUrl)
|
|
|
|
self.setToken(token: self.authState.authToken ?? "")
|
|
}
|
|
|
|
func setToken(token: String) {
|
|
self.authHeaders.Token = token
|
|
self.setUrl(url: self.authState.serverUrl)
|
|
}
|
|
|
|
func setUrl(url: URL?) {
|
|
if url == nil {
|
|
return
|
|
}
|
|
|
|
self.api = APIClient(baseURL: url, {
|
|
$0.sessionConfiguration.httpAdditionalHeaders = ["Authorization": self.authHeaders.format()]
|
|
|
|
let decoder = JSONDecoder()
|
|
decoder.dateDecodingStrategy = .iso8601withFractionalSeconds
|
|
$0.decoder = decoder
|
|
|
|
$0.sessionDelegate = Pulse.URLSessionProxyDelegate()
|
|
})
|
|
}
|
|
|
|
func getUrl() -> URL? {
|
|
return self.api.configuration.baseURL
|
|
}
|
|
|
|
@discardableResult func send<T>(
|
|
_ request: Request<T>,
|
|
delegate: URLSessionDataDelegate? = nil,
|
|
configure: ((inout URLRequest) throws -> Void)? = nil
|
|
) async throws -> Response<T> where T : Decodable {
|
|
return try await self.api.send(request, delegate: delegate, configure: configure)
|
|
}
|
|
|
|
@discardableResult func send(
|
|
_ request: Request<Void>,
|
|
delegate: URLSessionDataDelegate? = nil,
|
|
configure: ((inout URLRequest) throws -> Void)? = nil
|
|
) async throws -> Response<Void> {
|
|
return try await self.api.send(request, delegate: delegate, configure: configure)
|
|
}
|
|
|
|
}
|
|
|
|
extension JellyfinClientController {
|
|
func getPublicServerInfo() async -> PublicSystemInfo? {
|
|
let request = Paths.getPublicSystemInfo
|
|
do {
|
|
let res = try await api.send(request)
|
|
if res.statusCode != 200 {
|
|
throw JellyfinClientError.badResponseCode
|
|
}
|
|
|
|
return res.value
|
|
} catch {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func signIn(username: String, pw: String) async throws {
|
|
let request = Paths.authenticateUserByName(AuthenticateUserByName(pw: pw, username: username))
|
|
let res = try await self.api.send(request)
|
|
DispatchQueue.main.async {
|
|
self.authState.loggedIn = true
|
|
self.authState.authToken = res.value.accessToken
|
|
self.authState.userId = res.value.user?.id
|
|
self.authState.save()
|
|
|
|
self.setToken(token: self.authState.authToken ?? "")
|
|
}
|
|
}
|
|
}
|
|
|