Method Start

modules/proxy/server.go:31–66

(ctx context.Context)

}

func (s *proxyServer) Start(ctx context.Context) error {
	ca, err := generateCA()
	if err != nil {
		return fmt.Errorf("proxy: generate CA: %w", err)
	}
	s.ca = ca

	ln, err := net.Listen("tcp", s.addr)
	if err != nil {
		return fmt.Errorf("proxy: listen %s: %w", s.addr, err)
	}
	s.listener = ln

	go func() {
		for {
			conn, err := ln.Accept()
			if err != nil {
				select {
				case <-ctx.Done():
					return
				default:
					slog.Error("proxy: accept error", "err", err)
					continue
				}
			}
			go s.handleConn(ctx, conn)
		}
	}()

	go func() {
		<-ctx.Done()
		ln.Close()
	}()

	return nil
}

func (s *proxyServer) Stop() error {
	if s.listener != nil {