mirror of
https://github.com/hanzoai/forge.git
synced 2026-10-30 15:00:39 +00:00
zeekayandHanzo Dev
aa87442fdd
Source files keep their SPDX-License-Identifier and Hanzo copyright line; the Gitea, Gogs and LFS Test Server copyrights they used to repeat now live once in NOTICE, alongside LICENSE. The header lint accepts any copyright line above the SPDX line, so it no longer demands an upstream one. Co-authored-by: Hanzo Dev <[email protected]>
139 lines
4.1 KiB
Go
139 lines
4.1 KiB
Go
// Copyright 2026 Hanzo AI, Inc. All rights reserved.
|
|
// SPDX-License-Identifier: MIT
|
|
|
|
package webhook
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
"net/http"
|
|
|
|
webhook_model "github.com/hanzoai/git/models/webhook"
|
|
"github.com/hanzoai/git/modules/json"
|
|
"github.com/hanzoai/git/modules/log"
|
|
api "github.com/hanzoai/git/modules/structs"
|
|
webhook_module "github.com/hanzoai/git/modules/webhook"
|
|
)
|
|
|
|
type (
|
|
// PackagistPayload represents
|
|
PackagistPayload struct {
|
|
PackagistRepository struct {
|
|
URL string `json:"url"`
|
|
} `json:"repository"`
|
|
}
|
|
|
|
// PackagistMeta contains the metadata for the webhook
|
|
PackagistMeta struct {
|
|
Username string `json:"username"`
|
|
APIToken string `json:"api_token"`
|
|
PackageURL string `json:"package_url"`
|
|
}
|
|
)
|
|
|
|
// GetPackagistHook returns packagist metadata
|
|
func GetPackagistHook(w *webhook_model.Webhook) *PackagistMeta {
|
|
s := &PackagistMeta{}
|
|
if err := json.Unmarshal([]byte(w.Meta), s); err != nil {
|
|
log.Error("webhook.GetPackagistHook(%d): %v", w.ID, err)
|
|
}
|
|
return s
|
|
}
|
|
|
|
type packagistConvertor struct {
|
|
PackageURL string
|
|
}
|
|
|
|
// Create implements PayloadConvertor Create method
|
|
func (pc packagistConvertor) Create(_ *api.CreatePayload) (PackagistPayload, error) {
|
|
return PackagistPayload{}, nil
|
|
}
|
|
|
|
// Delete implements PayloadConvertor Delete method
|
|
func (pc packagistConvertor) Delete(_ *api.DeletePayload) (PackagistPayload, error) {
|
|
return PackagistPayload{}, nil
|
|
}
|
|
|
|
// Fork implements PayloadConvertor Fork method
|
|
func (pc packagistConvertor) Fork(_ *api.ForkPayload) (PackagistPayload, error) {
|
|
return PackagistPayload{}, nil
|
|
}
|
|
|
|
// Push implements PayloadConvertor Push method
|
|
// https://packagist.org/about
|
|
func (pc packagistConvertor) Push(_ *api.PushPayload) (PackagistPayload, error) {
|
|
return PackagistPayload{
|
|
PackagistRepository: struct {
|
|
URL string `json:"url"`
|
|
}{
|
|
URL: pc.PackageURL,
|
|
},
|
|
}, nil
|
|
}
|
|
|
|
// Issue implements PayloadConvertor Issue method
|
|
func (pc packagistConvertor) Issue(_ *api.IssuePayload) (PackagistPayload, error) {
|
|
return PackagistPayload{}, nil
|
|
}
|
|
|
|
// IssueComment implements PayloadConvertor IssueComment method
|
|
func (pc packagistConvertor) IssueComment(_ *api.IssueCommentPayload) (PackagistPayload, error) {
|
|
return PackagistPayload{}, nil
|
|
}
|
|
|
|
// PullRequest implements PayloadConvertor PullRequest method
|
|
func (pc packagistConvertor) PullRequest(_ *api.PullRequestPayload) (PackagistPayload, error) {
|
|
return PackagistPayload{}, nil
|
|
}
|
|
|
|
// Review implements PayloadConvertor Review method
|
|
func (pc packagistConvertor) Review(_ *api.PullRequestPayload, _ webhook_module.HookEventType) (PackagistPayload, error) {
|
|
return PackagistPayload{}, nil
|
|
}
|
|
|
|
// Repository implements PayloadConvertor Repository method
|
|
func (pc packagistConvertor) Repository(_ *api.RepositoryPayload) (PackagistPayload, error) {
|
|
return PackagistPayload{}, nil
|
|
}
|
|
|
|
// Wiki implements PayloadConvertor Wiki method
|
|
func (pc packagistConvertor) Wiki(_ *api.WikiPayload) (PackagistPayload, error) {
|
|
return PackagistPayload{}, nil
|
|
}
|
|
|
|
// Release implements PayloadConvertor Release method
|
|
func (pc packagistConvertor) Release(_ *api.ReleasePayload) (PackagistPayload, error) {
|
|
return PackagistPayload{}, nil
|
|
}
|
|
|
|
func (pc packagistConvertor) Package(_ *api.PackagePayload) (PackagistPayload, error) {
|
|
return PackagistPayload{}, nil
|
|
}
|
|
|
|
func (pc packagistConvertor) Status(_ *api.CommitStatusPayload) (PackagistPayload, error) {
|
|
return PackagistPayload{}, nil
|
|
}
|
|
|
|
func (pc packagistConvertor) WorkflowRun(_ *api.WorkflowRunPayload) (PackagistPayload, error) {
|
|
return PackagistPayload{}, nil
|
|
}
|
|
|
|
func (pc packagistConvertor) WorkflowJob(_ *api.WorkflowJobPayload) (PackagistPayload, error) {
|
|
return PackagistPayload{}, nil
|
|
}
|
|
|
|
func newPackagistRequest(_ context.Context, w *webhook_model.Webhook, t *webhook_model.HookTask) (*http.Request, []byte, error) {
|
|
meta := &PackagistMeta{}
|
|
if err := json.Unmarshal([]byte(w.Meta), meta); err != nil {
|
|
return nil, nil, fmt.Errorf("newpackagistRequest meta json: %w", err)
|
|
}
|
|
var pc payloadConvertor[PackagistPayload] = packagistConvertor{
|
|
PackageURL: meta.PackageURL,
|
|
}
|
|
return newJSONRequest(pc, w, t, true)
|
|
}
|
|
|
|
func init() {
|
|
RegisterWebhookRequester(webhook_module.PACKAGIST, newPackagistRequest)
|
|
}
|