aboutsummaryrefslogtreecommitdiff
path: root/forged/internal/misc
diff options
context:
space:
mode:
Diffstat (limited to 'forged/internal/misc')
-rw-r--r--forged/internal/misc/misc.go13
-rw-r--r--forged/internal/misc/slices.go17
-rw-r--r--forged/internal/misc/url.go37
-rw-r--r--forged/internal/misc/usock.go23
4 files changed, 40 insertions, 50 deletions
diff --git a/forged/internal/misc/misc.go b/forged/internal/misc/misc.go
index 398020a..e9e10ab 100644
--- a/forged/internal/misc/misc.go
+++ b/forged/internal/misc/misc.go
@@ -3,16 +3,3 @@
// Package misc provides miscellaneous functions and other definitions.
package misc
-
-import "strings"
-
-// sliceContainsNewlines returns true if and only if the given slice contains
-// one or more strings that contains newlines.
-func SliceContainsNewlines(s []string) bool {
- for _, v := range s {
- if strings.Contains(v, "\n") {
- return true
- }
- }
- return false
-}
diff --git a/forged/internal/misc/slices.go b/forged/internal/misc/slices.go
new file mode 100644
index 0000000..3ad0211
--- /dev/null
+++ b/forged/internal/misc/slices.go
@@ -0,0 +1,17 @@
+// SPDX-License-Identifier: AGPL-3.0-only
+// SPDX-FileCopyrightText: Copyright (c) 2025 Runxi Yu <https://runxiyu.org>
+
+package misc
+
+import "strings"
+
+// sliceContainsNewlines returns true if and only if the given slice contains
+// one or more strings that contains newlines.
+func SliceContainsNewlines(s []string) bool {
+ for _, v := range s {
+ if strings.Contains(v, "\n") {
+ return true
+ }
+ }
+ return false
+}
diff --git a/forged/internal/misc/url.go b/forged/internal/misc/url.go
index 0f9dc04..346ff76 100644
--- a/forged/internal/misc/url.go
+++ b/forged/internal/misc/url.go
@@ -4,48 +4,11 @@
package misc
import (
- "errors"
"net/http"
"net/url"
"strings"
)
-var (
- ErrDupRefSpec = errors.New("duplicate ref spec")
- ErrNoRefSpec = errors.New("no ref spec")
-)
-
-// getParamRefTypeName looks at the query parameters in an HTTP request and
-// returns its ref name and type, if any.
-func GetParamRefTypeName(request *http.Request) (retRefType, retRefName string, err error) {
- rawQuery := request.URL.RawQuery
- queryValues, err := url.ParseQuery(rawQuery)
- if err != nil {
- return
- }
- done := false
- for _, refType := range []string{"commit", "branch", "tag"} {
- refName, ok := queryValues[refType]
- if ok {
- if done {
- err = ErrDupRefSpec
- return
- }
- done = true
- if len(refName) != 1 {
- err = ErrDupRefSpec
- return
- }
- retRefName = refName[0]
- retRefType = refType
- }
- }
- if !done {
- err = ErrNoRefSpec
- }
- return
-}
-
// ParseReqURI parses an HTTP request URL, and returns a slice of path segments
// and the query parameters. It handles %2F correctly.
func ParseReqURI(requestURI string) (segments []string, params url.Values, err error) {
diff --git a/forged/internal/misc/usock.go b/forged/internal/misc/usock.go
new file mode 100644
index 0000000..357fa43
--- /dev/null
+++ b/forged/internal/misc/usock.go
@@ -0,0 +1,23 @@
+package misc
+
+import (
+ "errors"
+ "fmt"
+ "net"
+ "syscall"
+)
+
+func ListenUnixSocket(path string) (listener net.Listener, replaced bool, err error) {
+ listener, err = net.Listen("unix", path)
+ if errors.Is(err, syscall.EADDRINUSE) {
+ replaced = true
+ if unlinkErr := syscall.Unlink(path); unlinkErr != nil {
+ return listener, false, fmt.Errorf("remove existing socket %q: %w", path, unlinkErr)
+ }
+ listener, err = net.Listen("unix", path)
+ }
+ if err != nil {
+ return listener, replaced, fmt.Errorf("listen on unix socket %q: %w", path, err)
+ }
+ return listener, replaced, nil
+}