dkforest

commit 5a29609510ceb14186a1a2e4bba119e362f852e2
parent 3210ffc4ec6d5228b760e8a34a3d951617e8c891
Author: n0tr1v <n0tr1v@protonmail.com>
Date:   Sun, 24 Dec 2023 00:46:16 -0500

move code

Diffstat:
M
pkg/web/handlers/poker.go
 | 
60
++++++++++++++++++++++++++++++------------------------------

1 file changed, 30 insertions(+), 30 deletions(-)
diff --git a/pkg/web/handlers/poker.go b/pkg/web/handlers/poker.go
@@ -410,36 +410,6 @@ func PokerLogsHandler(c echo.Context) error {
 	return nil
 }
 
-var BreakLoopErr = errors.New("break Loop")
-var ContinueLoopErr = errors.New("continue Loop")
-
-func loop[T any](quit <-chan struct{}, sub *pubsub.Sub[T], clb func(topic string, payload T) error) {
-Loop:
-	for {
-		select {
-		case <-quit:
-			break Loop
-		default:
-		}
-
-		topic, payload, err := sub.ReceiveTimeout2(1*time.Second, quit)
-		if err != nil {
-			if errors.Is(err, pubsub.ErrCancelled) {
-				break Loop
-			}
-			continue
-		}
-
-		if err := clb(topic, payload); err != nil {
-			if errors.Is(err, BreakLoopErr) {
-				break Loop
-			} else if errors.Is(err, ContinueLoopErr) {
-				continue Loop
-			}
-		}
-	}
-}
-
 func PokerBetHandler(c echo.Context) error {
 	roomID := poker.RoomID(c.Param("roomID"))
 	authUser := c.Get("authUser").(*database.User)
@@ -563,6 +533,36 @@ func PokerBetHandler(c echo.Context) error {
 	return nil
 }
 
+var BreakLoopErr = errors.New("break Loop")
+var ContinueLoopErr = errors.New("continue Loop")
+
+func loop[T any](quit <-chan struct{}, sub *pubsub.Sub[T], clb func(topic string, payload T) error) {
+Loop:
+	for {
+		select {
+		case <-quit:
+			break Loop
+		default:
+		}
+
+		topic, payload, err := sub.ReceiveTimeout2(1*time.Second, quit)
+		if err != nil {
+			if errors.Is(err, pubsub.ErrCancelled) {
+				break Loop
+			}
+			continue
+		}
+
+		if err := clb(topic, payload); err != nil {
+			if errors.Is(err, BreakLoopErr) {
+				break Loop
+			} else if errors.Is(err, ContinueLoopErr) {
+				continue Loop
+			}
+		}
+	}
+}
+
 func PokerDealHandler(c echo.Context) error {
 	roomID := poker.RoomID(c.Param("roomID"))
 	authUser := c.Get("authUser").(*database.User)