Merge pull request #14 from a-company-jp/invoke-endpoint

Invoke Endpointの追加

main.go

@@ -40,5 +40,9 @@ func main() {
 			return
 		}
 	}
+
+	invokeHandler := handler.NewInvokeHandler(fs)
+	e.POST("/invoke", invokeHandler.Handle)
+
 	e.Run(fmt.Sprintf(":%d", port))
 }

pkg/handler/invoke.go

@@ -0,0 +1,44 @@
+package handler
+
+import (
+	"cloud.google.com/go/firestore"
+	"fmt"
+	"github.com/gin-gonic/gin"
+	"log/slog"
+	"time"
+)
+
+type CallInvoke struct {
+	fs *firestore.Client
+}
+
+func NewInvokeHandler(
+	fs *firestore.Client,
+) *CallInvoke {
+	return &CallInvoke{
+		fs: fs,
+	}
+}
+
+func (h *CallInvoke) Handle(c *gin.Context) {
+	// get time
+	timeVal := fmt.Sprintf("%2d:%2d", time.Now().Hour(), 0)
+	res := h.fs.Collection("users").Where("call_time", "==", timeVal).Documents(c)
+	if res == nil {
+		c.JSON(400, gin.H{"error": "no data"})
+		return
+	}
+	for {
+		doc, err := res.Next()
+		if err != nil {
+			break
+		}
+		userdata := doc.Data()
+		slog.Info("invoke call on user", slog.Any("data", userdata))
+
+		// vonage callを発火
+	}
+	c.JSON(200, gin.H{
+		"message": "success",
+	})
+}

pkg/model/user.go

@@ -3,8 +3,8 @@ package model
 import "time"
 
 type User struct {
+	Target
 	LINEID  string    `firestore:"line_id"`
-	Target  Target    `firestore:"target"`
 	AddDate time.Time `firestore:"add_date"`
 }