Implement restructured protobuf definition

Implement new protobuf api for frontend (web) and backend (go)

Author: nandesh-dev

internal/api/api.go

@@ -9,15 +9,15 @@ import (
 	"connectrpc.com/grpcreflect"
 	"github.com/nandesh-dev/subtle/generated/embed"
 	"github.com/nandesh-dev/subtle/generated/ent"
-	"github.com/nandesh-dev/subtle/generated/proto/web/webconnect"
+	"github.com/nandesh-dev/subtle/generated/proto/services/servicesconnect"
 	"github.com/nandesh-dev/subtle/pkgs/configuration"
 	"github.com/rs/cors"
 	"golang.org/x/net/http2"
 	"golang.org/x/net/http2/h2c"
 )
 
 type WebServiceHandler struct {
-	webconnect.UnimplementedWebServiceHandler
+	servicesconnect.UnimplementedWebServiceHandler
   ctx context.Context
 	configFile *configuration.File
 	db         *ent.Client
@@ -35,11 +35,11 @@ type APIServerOptions struct {
 func NewAPIServer(ctx context.Context, configFile *configuration.File, db *ent.Client, options APIServerOptions) *APIServer {
 	mux := http.NewServeMux()
 
-  path, handler := webconnect.NewWebServiceHandler(WebServiceHandler{configFile: configFile, db: db, ctx:ctx})
+  path, handler := servicesconnect.NewWebServiceHandler(WebServiceHandler{configFile: configFile, db: db, ctx:ctx})
 	mux.Handle(path, handler)
 
 	if options.EnableGRPCReflection {
-		path, handler = grpcreflect.NewHandlerV1Alpha(grpcreflect.NewStaticReflector(webconnect.WebServiceName))
+		path, handler = grpcreflect.NewHandlerV1Alpha(grpcreflect.NewStaticReflector(servicesconnect.WebServiceName))
 		mux.Handle(path, handler)
 	}
 

internal/api/config.go

@@ -0,0 +1,27 @@
+package api
+
+import (
+	"context"
+
+	"connectrpc.com/connect"
+	"github.com/nandesh-dev/subtle/generated/proto/messages"
+)
+
+func (h WebServiceHandler) GetConfig(ctx context.Context, req *connect.Request[messages.GetConfigRequest]) (*connect.Response[messages.GetConfigResponse], error) {
+	configString, err := h.configFile.ReadString()
+	if err != nil {
+		return nil, err
+	}
+
+	return connect.NewResponse(&messages.GetConfigResponse{
+		Config: configString,
+	}), nil
+}
+
+func (h WebServiceHandler) UpdateConfig(ctx context.Context, req *connect.Request[messages.UpdateConfigRequest]) (*connect.Response[messages.UpdateConfigResponse], error) {
+	if err := h.configFile.WriteString(req.Msg.Config); err != nil {
+		return nil, err
+	}
+
+	return connect.NewResponse(&messages.UpdateConfigResponse{}), nil
+}

internal/api/filesystem.go

@@ -0,0 +1,69 @@
+package api
+
+import (
+	"context"
+	"fmt"
+	"strconv"
+
+	"connectrpc.com/connect"
+	"github.com/nandesh-dev/subtle/generated/ent/videoschema"
+	"github.com/nandesh-dev/subtle/generated/proto/messages"
+	"github.com/nandesh-dev/subtle/pkgs/filemanager"
+)
+
+func (h WebServiceHandler) GetRootDirectoryPaths(ctx context.Context, req *connect.Request[messages.GetRootDirectoryPathsRequest]) (*connect.Response[messages.GetRootDirectoryPathsResponse], error) {
+	config, err := h.configFile.Read()
+	if err != nil {
+		return nil, fmt.Errorf("cannot read config file, err: %v", err)
+	}
+
+	paths := make([]string, 0, len(config.Job.Scanning))
+
+	for _, scaningGroup := range config.Job.Scanning {
+		paths = append(paths, scaningGroup.DirectoryPath)
+	}
+
+	return connect.NewResponse(&messages.GetRootDirectoryPathsResponse{
+		Paths: paths,
+	}), nil
+}
+
+func (h WebServiceHandler) ReadDirectory(ctx context.Context, req *connect.Request[messages.ReadDirectoryRequest]) (*connect.Response[messages.ReadDirectoryResponse], error) {
+	directory, err := filemanager.ReadDirectory(req.Msg.Path)
+	if err != nil {
+		return nil, fmt.Errorf("cannot read directory, err: %v", err)
+	}
+
+	videoFilepaths := make([]string, 0, len(directory.Videos))
+	for _, video := range directory.Videos {
+		videoFilepaths = append(videoFilepaths, video.Filepath())
+	}
+
+	return connect.NewResponse(&messages.ReadDirectoryResponse{
+		ChildrenDirectoryPaths: directory.ChildrenPaths,
+    VideoPaths: videoFilepaths,
+	}), nil
+}
+
+func (h WebServiceHandler) SearchVideo(ctx context.Context, req *connect.Request[messages.SearchVideoRequest]) (*connect.Response[messages.SearchVideoResponse], error) {
+	videoEntry, err := h.db.VideoSchema.Query().Where(videoschema.Filepath(req.Msg.Path)).Only(h.ctx)
+	if err != nil {
+		return nil, fmt.Errorf("cannot get video entry from database, err: %v", err)
+	}
+
+	subtitleEntries, err := videoEntry.QuerySubtitles().All(h.ctx)
+	if err != nil {
+		return nil, fmt.Errorf("cannot get subtitle entries from database, err: %v", err)
+	}
+
+	subtitleIds := make([]string, 0, len(subtitleEntries))
+	for _, subtitleEntry := range subtitleEntries {
+		subtitleIds = append(subtitleIds,  strconv.FormatInt(int64(subtitleEntry.ID), 10))
+	}
+
+	return connect.NewResponse(&messages.SearchVideoResponse{
+    Id: strconv.FormatInt(int64(videoEntry.ID), 10),
+    Path: videoEntry.Filepath,
+    SubtitleIds: subtitleIds,
+	}), nil
+}