swagger fix

gen/swagger/api.swagger.json

@@ -9,7 +9,7 @@
       "email": "varlamow.col@yahoo.com"
     }
   },
-  "host": "localhost:3010",
+  "host": "localhost:3201",
   "schemes": [
     "http",
     "https"

modules/controllers/messages/handlers.go

@@ -0,0 +1,38 @@
+package messages
+
+import (
+	"context"
+
+	"github.com/minish144/go-sms-api/gen/pb"
+	"github.com/minish144/go-sms-api/modules/modem"
+	"github.com/sirupsen/logrus"
+	"github.com/spf13/viper"
+)
+
+func Send(ctx context.Context, in *pb.Messages_SendRequest) (*pb.Messages_SendResponse, error) {
+	if err := in.Validate(); err != nil {
+		return nil, err
+	}
+
+	comport := viper.GetString("modem.comport")
+	baudrate := viper.GetInt("modem.baudrate")
+	newModem := modem.New(comport, baudrate)
+
+	if err := newModem.Send(in.Message.Phone, in.Message.Message); err != nil {
+		logrus.WithFields(
+			logrus.Fields{
+				"error": err.Error(),
+			},
+		).Errorln("failed to send sms")
+		return nil, err
+	}
+
+	logrus.WithFields(
+		logrus.Fields{
+			"phone":   in.Message.Phone,
+			"message": in.Message.Message,
+		},
+	).Infoln("sms was sent successfully")
+
+	return &pb.Messages_SendResponse{}, nil
+}

modules/server/server.go

@@ -88,7 +88,7 @@ func Run() {
 
 	mux.HandleFunc("/swagger.json", serveSwagger)
 
-	logrus.Infoln("serving gRPC-Gateway on " + httpConnectionString)
+	logrus.Infoln("serving HTTP gRPC-Gateway on " + httpConnectionString)
 	if err := http.ListenAndServe(httpConnectionString, allowCORS(mux)); err != nil {
 		logrus.WithFields(logrus.Fields{
 			"error": err.Error(),

modules/server/structs.go

@@ -4,12 +4,13 @@ import (
 	"context"
 
 	"github.com/minish144/go-sms-api/gen/pb"
+	"github.com/minish144/go-sms-api/modules/controllers/messages"
 )
 
 type ApiServiceServer struct {
 	pb.UnimplementedApiServiceServer
 }
 
 func (s *ApiServiceServer) SendMessage(ctx context.Context, in *pb.Messages_SendRequest) (*pb.Messages_SendResponse, error) {
-	return nil, nil
+	return messages.Send(ctx, in)
 }

proto/api.proto

@@ -18,7 +18,7 @@ option (grpc.gateway.protoc_gen_openapiv2.options.openapiv2_swagger) = {
             email: "varlamow.col@yahoo.com"
         };
     };
-    host: "localhost:3010",
+    host: "localhost:3201",
     schemes: [HTTP, HTTPS]
     consumes: "application/json"
     produces: "application/json"

proto/common.proto

@@ -10,5 +10,5 @@ import public "github.com/envoyproxy/protoc-gen-validate/validate/validate.proto
 
 message Message {
     string phone = 1 [(validate.rules).string = { pattern: "^\\+(?:[0-9]●?){6,14}[0-9]$" }];
-    string message = 2;
+    string message = 2 [(validate.rules).string = { ignore_empty: true, max_len: 160 }];
 }