main.go

package main

import (
	"fmt"
	"regexp"
)

// Message структура для хранения пути и сообщения
type Message struct {
	Path    string
	Content []byte
}

// Route структура для хранения паттернов и каналов для обработки сообщений
type Route struct {
	Pattern *regexp.Regexp
	Channel chan Message
}

// Router структура для хранения маршрутов
type Router struct {
	routes []Route
}

// NewRouter создает новый экземпляр Router
func NewRouter() *Router {
	return &Router{}
}

// Register для регистрации канала с паттерном
func (r *Router) Register(pattern string, channel chan Message) {
	regex := regexp.MustCompile(pattern)
	r.routes = append(r.routes, Route{Pattern: regex, Channel: channel})
}

// Push принимает путь и сообщение и обрабатывает его
func (r *Router) Push(path string, message []byte) {
	for _, route := range r.routes {
		if route.Pattern.MatchString(path) {
			// Отправляем путь и сообщение в канал
			route.Channel <- Message{Path: path, Content: message}
		}
	}
}

// Start запускает обработчики сообщений в отдельных горутинах
func (r *Router) Start() {
	for _, route := range r.routes {
		go func(ch chan Message) {
			for msg := range ch {
				fmt.Printf("Received - Path: %s, Message: %s\n", msg.Path, string(msg.Content))
			}
		}(route.Channel)
	}
}

func main() {
	router := NewRouter()

	// Создание каналов
	homeChannel := make(chan Message)
	aboutChannel := make(chan Message)
	usersChannel := make(chan Message)

	// Регистрация каналов на паттерны
	router.Register("^/$", homeChannel)
	router.Register("^/about$", aboutChannel)
	router.Register("^/users/.*$", usersChannel)

	// Запуск горутин для обработки сообщений
	router.Start()

	fmt.Println("Starting server on :8080...")

	// Имитация вызовов метода Push
	router.Push("/", []byte("Request to Home"))
	router.Push("/about", []byte("Request to About"))
	router.Push("/users/123", []byte("Request to Users"))
	router.Push("/nonexistent", []byte("Request to Nonexistent URL"))

	// Закрытие каналов для предотвращения утечки памяти
	close(homeChannel)
	close(aboutChannel)
	close(usersChannel)

	// wait ctrl^c
	fmt.Scanln()
}