a/OpenWeather-gRPC-API
1
0
Fork 0
mirror of https://codeberg.org/andyscott/OpenWeather-gRPC-API.git synced 2024-12-21 12:13:09 -05:00
Code Issues Projects Releases Packages Wiki Activity

Added some basic documentation

Browse source
This commit is contained in:
Andrew Scott 2022-07-26 19:42:25 -04:00
parent ba7e27dfea
commit 87a9143248
Signed by: a
GPG key ID: 3EB62D0BBB8DB381
3 changed files with 8 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
server/current.go
View file

@ -10,6 +10,8 @@ import (
pb "codeberg.org/andcscott/OpenWeatherMap-gRPC-API/proto" pb "codeberg.org/andcscott/OpenWeatherMap-gRPC-API/proto"
) )
// Receives a gRPC request for the current forecast
// Returns a SendCurrent message containing the forecast in JSON
func (s *Server) Current(ctx context.Context, in *pb.RequestCurrent) (*pb.SendCurrent, error) { func (s *Server) Current(ctx context.Context, in *pb.RequestCurrent) (*pb.SendCurrent, error) {
log.Println("'Current' function called...") log.Println("'Current' function called...")

2
server/extended.go
View file

@ -11,6 +11,8 @@ import (
pb "codeberg.org/andcscott/OpenWeatherMap-gRPC-API/proto" pb "codeberg.org/andcscott/OpenWeatherMap-gRPC-API/proto"
) )
// Receives a gRPC request for an extended forecast
// Returns a SendExtended message with the forecast in JSON
func (s *Server) Extended(ctx context.Context, in *pb.RequestExtended) (*pb.SendExtended, error) { func (s *Server) Extended(ctx context.Context, in *pb.RequestExtended) (*pb.SendExtended, error) {
log.Println("'Extended' function called...") log.Println("'Extended' function called...")

4
server/main.go
View file

@ -18,13 +18,16 @@ type Server struct {
func main() { func main() {
// Load .env file
err := godotenv.Load() err := godotenv.Load()
if err != nil { if err != nil {
log.Fatalln(err) log.Fatalln(err)
} }
// Read PORT from .env
port, _ := strconv.Atoi(os.Getenv("PORT")) port, _ := strconv.Atoi(os.Getenv("PORT"))
// Start server
lis, err := net.Listen("tcp", fmt.Sprintf(":%d", port)) lis, err := net.Listen("tcp", fmt.Sprintf(":%d", port))
if err != nil { if err != nil {
log.Fatalf("Error starting server: %v\n", err) log.Fatalf("Error starting server: %v\n", err)
@ -32,6 +35,7 @@ func main() {
log.Printf("Listening on port %d...\n", port) log.Printf("Listening on port %d...\n", port)
} }
// Initialize gRPC server
s := grpc.NewServer() s := grpc.NewServer()
pb.RegisterWeatherServiceServer(s, &Server{}) pb.RegisterWeatherServiceServer(s, &Server{})
if err = s.Serve(lis); err != nil { if err = s.Serve(lis); err != nil {