task-processor/internal/app/server.go

package app

import (
	"context"
	"google.golang.org/grpc"
	"task-processor/internal/appState"
	pb "task-processor/proto/taskProcessor"
)

type Server struct {
	pb.UnimplementedTaskProcessorServer
	state *appState.State
}

func newServer(app *App) *grpc.Server {
	s := grpc.NewServer()
	srv := &Server{
		state: app.state,
	}
	pb.RegisterTaskProcessorServer(s, srv)
	return s
}

func (s *Server) ProcessorStatus(_ context.Context, _ *pb.ProcessorStatusRequest) (*pb.ProcessorStatusResponse, error) {
	resp := s.state.StateResponse()
	return resp, nil
}