add parser

cmd/pinned_message/main.go

@@ -1,15 +1,21 @@
 package main
 
 import (
-	"pinned_message/internal/app"
-	proto "pinned_message/proto"
 	"context"
-	"github.com/grpc-ecosystem/grpc-gateway/v2/runtime"
-	"google.golang.org/grpc"
-	"google.golang.org/grpc/credentials/insecure"
 	"log"
 	"net"
 	"net/http"
+	"pinned_message/internal/app"
+	"pinned_message/internal/config"
+	"pinned_message/internal/modules/data_parser"
+	"pinned_message/internal/modules/date_parser"
+	"pinned_message/internal/services/schedule_parser"
+	"pinned_message/internal/services/schedule_storage"
+	proto "pinned_message/proto"
+
+	"github.com/grpc-ecosystem/grpc-gateway/v2/runtime"
+	"google.golang.org/grpc"
+	"google.golang.org/grpc/credentials/insecure"
 )
 
 func main() {
@@ -21,8 +27,19 @@ func main() {
 
 	// Create a gRPC server object
 	s := grpc.NewServer()
+
+	ctx := context.Background()
+	scheduleParser := schedule_parser.NewScheduleParser(
+		data_parser.NewGoogleTableScheduleParser(),
+		date_parser.NewDateParser(),
+		*schedule_storage.NewScheduleStorage(config.GetScheduleFilepath()),
+	)
+	go func() {
+		scheduleParser.Run(ctx)
+	}()
+
 	// Attach the Greeter service to the server
-	proto.RegisterpinnedMessageServer(s, app.NewServer())
+	proto.RegisterPinnedMessageServer(s, app.NewServer())
 	// Serve gRPC server
 	log.Println("Serving gRPC on 0.0.0.0:8080")
 	go func() {
@@ -41,7 +58,7 @@ func main() {
 
 	gwmux := runtime.NewServeMux()
 	// Register Greeter
-	err = proto.RegisterpinnedMessageHandler(context.Background(), gwmux, conn)
+	err = proto.RegisterPinnedMessageHandler(context.Background(), gwmux, conn)
 	if err != nil {
 		log.Fatalln("Failed to register gateway:", err)
 	}