Something went wrong. Try again.
cloudflare-native port of the tangled knot server
Something went wrong. Try again.
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107package hook
import ( "bufio" "context" "encoding/json" "fmt" "net/http" "os" "strings"
"github.com/urfave/cli/v3")
type HookResponse struct { Messages []string `json:"messages"`}
// The hook command is nested like so://// knot hook --[flags] [hook]func Command() *cli.Command { return &cli.Command{ Name: "hook", Usage: "run git hooks", Flags: []cli.Flag{ &cli.StringFlag{ Name: "git-dir", Usage: "base directory for git repos", }, &cli.StringFlag{ Name: "user-did", Usage: "git user's did", }, &cli.StringFlag{ Name: "user-handle", Usage: "git user's handle", }, &cli.StringFlag{ Name: "internal-api", Usage: "endpoint for the internal API", Value: "http://localhost:5444", }, &cli.StringSliceFlag{ Name: "push-option", Usage: "any push option from git", }, }, Commands: []*cli.Command{ { Name: "post-receive", Usage: "sends a post-receive hook to the knot (waits for stdin)", Action: postReceive, }, }, }}
func postReceive(ctx context.Context, cmd *cli.Command) error { gitDir := cmd.String("git-dir") userDid := cmd.String("user-did") userHandle := cmd.String("user-handle") endpoint := cmd.String("internal-api") pushOptions := cmd.StringSlice("push-option")
payloadReader := bufio.NewReader(os.Stdin) payload, _ := payloadReader.ReadString('\n')
client := &http.Client{}
req, err := http.NewRequest("POST", "http://"+endpoint+"/hooks/post-receive", strings.NewReader(payload)) if err != nil { return fmt.Errorf("failed to create request: %w", err) }
req.Header.Set("Content-Type", "text/plain; charset=utf-8") req.Header.Set("X-Git-Dir", gitDir) req.Header.Set("X-Git-User-Did", userDid) req.Header.Set("X-Git-User-Handle", userHandle) if pushOptions != nil { for _, option := range pushOptions { req.Header.Add("X-Git-Push-Option", option) } }
resp, err := client.Do(req) if err != nil { return fmt.Errorf("failed to execute request: %w", err) } defer resp.Body.Close()
if resp.StatusCode != http.StatusOK { return fmt.Errorf("unexpected status code: %d", resp.StatusCode) }
var data HookResponse if err := json.NewDecoder(resp.Body).Decode(&data); err != nil { return fmt.Errorf("failed to decode response: %w", err) }
for _, message := range data.Messages { fmt.Println(message) }
return nil}