project: added jsonrpc support, added ability to send a message to yourself, users by their id and all users.

project: changed the structure of the project

project: removed browser client, added CLI client

Dockerfile: changed the path to the server binary file, removed the file index.html from the second build

Makefile: added build and launch of the client part

README.md: changed information about starting the client part, added technologies used in project & version v1.1.0

Author: Lapp

.gitignore

@@ -1 +1,2 @@
 .idea
+build/.bin

Dockerfile

@@ -4,14 +4,13 @@ COPY ./ /github.com/Lapp-coder/websocket-chat
 WORKDIR /github.com/Lapp-coder/websocket-chat
 
 RUN go mod download
-RUN go build -o ./build/bin/chat ./...
+RUN go build -o ./build/.bin/chat ./cmd/app/server/main.go
 
 FROM alpine:latest
 
 WORKDIR /opt/
 
-COPY --from=builder /github.com/Lapp-coder/websocket-chat/build/bin/chat .
-COPY --from=builder /github.com/Lapp-coder/websocket-chat/index.html .
+COPY --from=builder /github.com/Lapp-coder/websocket-chat/build/.bin/chat .
 
 EXPOSE 8080
 

Makefile

@@ -1,11 +1,17 @@
 .PHONY:
 .SILENT:
 
-build:
-	go build -o ./main ./...
+build-server:
+	go build -o ./build/.bin/server ./cmd/app/server/main.go
 
-run: build
-	./main
+run-server: build-server
+	./build/.bin/server
+
+build-client:
+	go build -o ./build/.bin/client ./cmd/app/client/main.go
+
+run-client: build-client
+	./build/.bin/client
 
 docker-build:
 	docker build -t websocket-chat .

README.md

@@ -1,10 +1,18 @@
-# Чат на вебсокетах
-[![Release](https://img.shields.io/badge/release-v1.0.1-blue)](https://github.com/Lapp-coder/go-pocket-sdk/releases)
+# Чат
+[![Release](https://img.shields.io/badge/release-v1.1.0-blue)](https://github.com/Lapp-coder/go-pocket-sdk/releases)
+
+### При создании этого приложения были использованны следующие технологии:
+* Go 1.16.6
+* Протокол Websocket
+* Протокол JSON-RPC
+* Docker
+* Git
+* Makefile
 
 ### Для запуска сервера используйте следующую команду
 ```make docker-build && docker run --name=chat -e CHAT_HOST=<host> -e CHAT_PORT=<port> -p <port>>:<port> --rm websocket-chat```
 
 ### Для запуска сервера с конфигурацией по умолчанию
 ```make docker-run```
 
-#### P.S: Клиентом можно воспользоваться перейдя на корневую страницу сайта.
+#### P.S: Для запуска клиента используйте команду ```make run-client```

cmd/app/client/main.go

@@ -0,0 +1,84 @@
+package main
+
+import (
+	"bufio"
+	"fmt"
+	"github.com/Lapp-coder/websocket-chat/pkg/jrpc"
+	"github.com/gorilla/websocket"
+	"github.com/sirupsen/logrus"
+	"net/rpc"
+	"net/rpc/jsonrpc"
+	"os"
+	"strings"
+)
+
+const (
+	url = "ws://localhost:8080/chat"
+)
+
+func main() {
+	ws, _, err := websocket.DefaultDialer.Dial(url, nil)
+	if err != nil {
+		logrus.Fatal(err)
+	}
+	defer ws.Close()
+
+	_, msg, err := ws.ReadMessage()
+	if err != nil {
+		logrus.Fatal(err)
+	}
+
+	id := string(msg)
+
+	client := jsonrpc.NewClient(ws.UnderlyingConn())
+	defer client.Close()
+
+	go getUnreadMessages(id, client)
+
+	fmt.Println(
+		`
+			 Введите id того пользоваетеля, которому хотите отправить сообщение. ( чтобы узнать свой id, введите команду /getmyid )
+			 Вы также можете отправить сообщение сразу нескольким пользователям, просто укажите их id через запятую.
+			 Для отправки сообщения всем пользователем введите *.
+			 Для отправки сообщения самому себе введите echo.
+
+			 Для того, чтобы отправить сообщение, выберете получателя (по принципу выше) и через %$4^b введите ваше сообщение.
+			 Пример: echo %$4^b Hello, World!
+	`)
+
+	scanner := bufio.NewScanner(os.Stdin)
+	for {
+		scanner.Scan()
+		text := scanner.Text()
+
+		switch text {
+		case "/getmyid":
+			fmt.Println("Ваш id:", id)
+		default:
+			sending := strings.Split(text, " %$4^b ")
+			if len(sending) == 0 {
+				logrus.Error("Неккоректный формат входных данных")
+				continue
+			}
+
+			args := jrpc.SendMessageArgs{ID: id, Ids: sending[0], Message: sending[1]}
+			if err = client.Call("Handler.SendMessage", args, nil); err != nil {
+				logrus.Fatal(err)
+			}
+		}
+	}
+}
+
+func getUnreadMessages(id string, client *rpc.Client) {
+	for {
+		args := jrpc.GetMessagesArgs{ID: id}
+		var result *[]string
+		if err := client.Call("Handler.GetMessages", args, &result); err != nil {
+			logrus.Fatal(err)
+		} else if len(*result) != 0 {
+			for _, msg := range *result {
+				logrus.Println(msg)
+			}
+		}
+	}
+}

main.go renamed to cmd/app/server/main.go

@@ -2,19 +2,20 @@ package main
 
 import (
 	"context"
+	"github.com/Lapp-coder/websocket-chat/internal/app/server"
 	"github.com/sirupsen/logrus"
-	"html/template"
+	"net/rpc"
 	"os"
 	"os/signal"
 	"syscall"
 )
 
 func main() {
-	indexTemplate = template.Must(template.ParseFiles("index.html"))
-	hub := newHub()
-	handler := newHandler(hub)
-	handler.initRoutes()
-	go hub.listen()
+	hub := server.NewHub()
+	handler := server.NewHandler(hub)
+	rpc.Register(handler)
+	handler.InitRoutes()
+	go hub.Listen()
 
 	host := os.Getenv("CHAT_HOST")
 	port := os.Getenv("CHAT_PORT")
@@ -23,9 +24,9 @@ func main() {
 	}
 
 	// Запуск сервера в go-рутине для его плавной остановки
-	srv := newServer(host + ":" + port)
+	srv := server.NewServer(host + ":" + port)
 	go func() {
-		if err := srv.start(); err != nil {
+		if err := srv.Start(); err != nil {
 			logrus.Errorf("failed to start server: %s", err.Error())
 		}
 	}()
@@ -40,7 +41,7 @@ func main() {
 	logrus.Info("server shutdown")
 
 	// Плавная остановка сервера
-	if err := srv.shutdown(context.Background()); err != nil {
+	if err := srv.Shutdown(context.Background()); err != nil {
 		logrus.Errorf("failed to graceful shutdown server: %s", err.Error())
 	}
 }