allow custom sub publish path

main.go

@@ -9,6 +9,7 @@ import (
 	"net/http"
 	"raycat/internal/pkg/tinypool"
 	"strconv"
+	"strings"
 
 	"github.com/ServiceWeaver/weaver"
 )
@@ -36,14 +37,22 @@ type app struct {
 
 // serve serves HTTP traffic.
 func serve(ctx context.Context, app *app) error {
-	http.HandleFunc("/x", subShareHandlerApp(app))
+	config := app.configure.Get()
+	subPublishPath, err := config.GetSubPublishPath(ctx)
+	if err != nil {
+		app.Logger(ctx).Warn("failed to get sub publish path,will use /subscribe as default", "err", err)
+		subPublishPath = "/subscribe"
+	}
+	if !strings.HasPrefix(subPublishPath, "/") {
+		subPublishPath = "/" + subPublishPath
+	}
+	http.HandleFunc(subPublishPath, subShareHandlerApp(app))
 	app.Logger(ctx).Info("Listening on...", "address", app.lis)
 	return http.Serve(app.lis, nil)
 }
 
 func subShareHandlerApp(app *app) func(w http.ResponseWriter, _ *http.Request) {
 	return func(w http.ResponseWriter, r *http.Request) {
-
 		w.Header().Set("Access-Control-Allow-Origin", "*")
 		w.Header().Set("Access-Control-Allow-Methods", "POST, GET, OPTIONS, PUT, DELETE")
 		w.Header().Set("Access-Control-Allow-Headers", "Accept, Content-Type, Content-Length, Accept-Encoding, X-CSRF-Token, Authorization,profile-web-page-url,profile-update-interval")

sub_configure.go

@@ -7,14 +7,16 @@ import (
 )
 
 var (
-	noResponseOptionConfiguredError = errors.New("no response option configured")
+	responseOptionNotConfiguredError = errors.New("no response option configured")
+	subPublishPathNotConfiguredError = errors.New("sub publish path not configured")
 )
 
 var _ subConfigureProvider = (*subConfigure)(nil)
 
 type subConfigureProvider interface {
 	GetSubFilePaths(ctx context.Context, privateSubToken string) ([]string, error)
 	GetUrlSubs(ctx context.Context, privateSubToken string) ([]string, int, error)
+	GetSubPublishPath(ctx context.Context) (string, error)
 	GetResponseOption(ctx context.Context) (*responseOption, error)
 }
 
@@ -27,6 +29,7 @@ type subConfig struct {
 	PrivateUrlSubs            []string `toml:"private_url_subs"`
 
 	PrivateSubToken string          `toml:"private_sub_token"`
+	SubPublishPath  string          `toml:"sub_publish_path,omitempty"`
 	ResponseOption  *responseOption `toml:"response_option,omitempty"`
 }
 
@@ -60,10 +63,17 @@ func (s *subConfigure) GetUrlSubs(ctx context.Context, privateSubToken string) (
 	return append(config.PrivateUrlSubs, config.PublicUrlSubs...), config.UrlSubFetchTimeoutSeconds, nil
 }
 
+func (s *subConfigure) GetSubPublishPath(ctx context.Context) (string, error) {
+	if s.Config().SubPublishPath == "" {
+		return "", subPublishPathNotConfiguredError
+	}
+	return s.Config().SubPublishPath, nil
+}
+
 func (s *subConfigure) GetResponseOption(ctx context.Context) (*responseOption, error) {
 	config := s.Config()
 	if config.ResponseOption == nil {
-		return nil, noResponseOptionConfiguredError
+		return nil, responseOptionNotConfiguredError
 	}
 	return config.ResponseOption, nil
 }

weaver.toml

@@ -33,6 +33,7 @@ private_url_subs = [
     "url4"
 ]
 private_sub_token = "gopher"
+sub_publish_path = "/subscibe"
 ["raycat/subConfigureProvider".response_option]
 update_interval_hours = 8
 profile_web_page = "https://x.com"