chore(style): reformatted some files
This commit is contained in:
+1
-1
@@ -28,4 +28,4 @@ fun JellyfinSyncState.toEntity(): JellyfinSyncStateEntity =
|
|||||||
lastSuccessfulSyncAt = lastSuccessfulSyncAt,
|
lastSuccessfulSyncAt = lastSuccessfulSyncAt,
|
||||||
lastError = lastError,
|
lastError = lastError,
|
||||||
syncedItemCount = syncedItemCount,
|
syncedItemCount = syncedItemCount,
|
||||||
)
|
)
|
||||||
|
|||||||
+12
-10
@@ -23,20 +23,22 @@ class JellyfinEventRepository(
|
|||||||
jellyfinItemId: String?,
|
jellyfinItemId: String?,
|
||||||
payload: String?,
|
payload: String?,
|
||||||
) {
|
) {
|
||||||
val sql = """
|
val sql =
|
||||||
|
"""
|
||||||
INSERT INTO jellyfin_events(event_id, server_id, event_type, occurred_at, jellyfin_user_id, jellyfin_item_id, payload)
|
INSERT INTO jellyfin_events(event_id, server_id, event_type, occurred_at, jellyfin_user_id, jellyfin_item_id, payload)
|
||||||
VALUES (:eventId, :serverId, :eventType, :occurredAt, :jellyfinUserId, :jellyfinItemId, cast(:payload as jsonb))
|
VALUES (:eventId, :serverId, :eventType, :occurredAt, :jellyfinUserId, :jellyfinItemId, cast(:payload as jsonb))
|
||||||
ON CONFLICT (event_id) DO NOTHING
|
ON CONFLICT (event_id) DO NOTHING
|
||||||
""".trimIndent()
|
""".trimIndent()
|
||||||
|
|
||||||
val params = MapSqlParameterSource()
|
val params =
|
||||||
.addValue("eventId", eventId)
|
MapSqlParameterSource()
|
||||||
.addValue("serverId", serverId)
|
.addValue("eventId", eventId)
|
||||||
.addValue("eventType", eventType)
|
.addValue("serverId", serverId)
|
||||||
.addValue("occurredAt", occurredAt)
|
.addValue("eventType", eventType)
|
||||||
.addValue("jellyfinUserId", jellyfinUserId)
|
.addValue("occurredAt", occurredAt)
|
||||||
.addValue("jellyfinItemId", jellyfinItemId)
|
.addValue("jellyfinUserId", jellyfinUserId)
|
||||||
.addValue("payload", payload)
|
.addValue("jellyfinItemId", jellyfinItemId)
|
||||||
|
.addValue("payload", payload)
|
||||||
|
|
||||||
jdbc.update(sql, params)
|
jdbc.update(sql, params)
|
||||||
}
|
}
|
||||||
|
|||||||
+1
-1
@@ -72,4 +72,4 @@ class JellyfinSyncStateRepository(
|
|||||||
"SELECT user_id, last_synced_at, last_successful_sync_at, last_error, synced_item_count FROM jellyfin_sync_state",
|
"SELECT user_id, last_synced_at, last_successful_sync_at, last_error, synced_item_count FROM jellyfin_sync_state",
|
||||||
rowMapper,
|
rowMapper,
|
||||||
).map { it.toDomain() }
|
).map { it.toDomain() }
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user