diff --git a/src/main/kotlin/ltd/hlaeja/repository/NodeRepository.kt b/src/main/kotlin/ltd/hlaeja/repository/NodeRepository.kt
index e0e2835..53a3ecd 100644
--- a/src/main/kotlin/ltd/hlaeja/repository/NodeRepository.kt
+++ b/src/main/kotlin/ltd/hlaeja/repository/NodeRepository.kt
@@ -2,8 +2,13 @@ package ltd.hlaeja.repository
 
 import java.util.UUID
 import ltd.hlaeja.entity.NodeEntity
+import org.springframework.data.r2dbc.repository.Query
 import org.springframework.data.repository.kotlin.CoroutineCrudRepository
 import org.springframework.stereotype.Repository
 
 @Repository
-interface NodeRepository : CoroutineCrudRepository<NodeEntity, UUID>
+interface NodeRepository : CoroutineCrudRepository<NodeEntity, UUID> {
+
+    @Query("SELECT * FROM nodes WHERE device = :device")
+    suspend fun findByDevice(device: UUID): NodeEntity?
+}