From 7a6ee3f87b7ed229e271fbcbfee682582011827d Mon Sep 17 00:00:00 2001
From: Gisle Aune <dev@gisle.me>
Date: Tue, 21 Sep 2021 20:55:06 +0200
Subject: [PATCH] add device search endpoint. >_>

---
 app/api/bridges.go | 32 ++++++++++++++++++++++++++++++++
 1 file changed, 32 insertions(+)

diff --git a/app/api/bridges.go b/app/api/bridges.go
index ae9e933..889fdf7 100644
--- a/app/api/bridges.go
+++ b/app/api/bridges.go
@@ -6,6 +6,7 @@ import (
 	"git.aiterp.net/lucifer/new-server/models"
 	"github.com/gin-gonic/gin"
 	"log"
+	"time"
 )
 
 func Bridges(r gin.IRoutes) {
@@ -96,6 +97,37 @@ func Bridges(r gin.IRoutes) {
 		return bridge, nil
 	}))
 
+	r.PUT("/:id/search", handler(func(c *gin.Context) (interface{}, error) {
+		var body struct {
+			TimeoutMS int64 `json:"timeoutMs"`
+		}
+		err := parseBody(c, &body)
+		if err != nil {
+			return nil, err
+		}
+
+		if body.TimeoutMS <= 0 {
+			body.TimeoutMS = 30000
+		}
+
+		bridge, err := config.BridgeRepository().Find(ctxOf(c), intParam(c, "id"))
+		if err != nil {
+			return nil, err
+		}
+
+		driver, err := config.DriverProvider().Provide(bridge.Driver)
+		if err != nil {
+			return nil, err
+		}
+
+		devices, err := driver.SearchDevices(ctxOf(c), bridge, time.Millisecond * time.Duration(body.TimeoutMS))
+		if err != nil {
+			return nil, err
+		}
+
+		return devices, nil
+	}))
+
 	r.DELETE("/:id", handler(func(c *gin.Context) (interface{}, error) {
 		bridge, err := config.BridgeRepository().Find(ctxOf(c), intParam(c, "id"))
 		if err != nil {