fix: improve local Pulsar connectivity checks

Taskfile.yml

@@ -108,7 +108,7 @@ tasks:
   emu:
     desc: Create a virtual serial port pair (ttyS0 ↔ ttyS1) with socat
     cmds:
-      - socat PTY,link=ttyS0 PTY,link=ttyS1
+      - socat PTY,link=/tmp/ttyS0 PTY,link=/tmp/ttyS1
     silent: false
 
   deps:

cmd/test.go

@@ -16,11 +16,14 @@ limitations under the License.
 package cmd
 
 import (
+	"net"
+	"net/url"
+	"time"
+
 	"github.com/spf13/cobra"
 	"go.uber.org/zap"
 	"it2000.com.cn/tele-recv/serial"
 	"it2000.com.cn/tele-recv/storage"
-	"it2000.com.cn/tele-recv/transport"
 )
 
 // testCmd represents the test command
@@ -56,13 +59,23 @@ func test() {
 		store.Close()
 	}
 
-	// Test Pulsar
+	// Test the Pulsar endpoint without constructing a producer. The legacy Pulsar
-	sender, err := transport.NewPulsarSender(pulsarUrl, topic, name)
+	// client used by the service is not compatible with newer Go runtimes on macOS.
+	endpoint, err := url.Parse(pulsarUrl)
 	if err != nil {
-		logger.Warn("pulsar connection failed (expected if no broker)", zap.Error(err))
+		logger.Warn("pulsar URL is invalid", zap.Error(err))
 	} else {
-		logger.Info("pulsar ok")
+		address := endpoint.Host
-		sender.Close()
+		if endpoint.Port() == "" {
+			address = net.JoinHostPort(endpoint.Hostname(), "6650")
+		}
+		conn, err := net.DialTimeout("tcp", address, 3*time.Second)
+		if err != nil {
+			logger.Warn("pulsar connection failed (expected if no broker)", zap.Error(err))
+		} else {
+			conn.Close()
+			logger.Info("pulsar endpoint ok")
+		}
 	}
 }
 

telegram.yaml

@@ -6,17 +6,15 @@ serial:
   #stopbits: 1
   lograw: true
 
-
 sqlite:
   file: telegram.db
   init: true
 
-
 socket:
   address: 127.0.0.1:6000
 
 pulsar:
-  url: pulsar://yzjc.gzzn.dev:6650
+  url: pulsar://localhost:6650
   topic: telegram-raw
   name: serial-reader