webhookqueue

package main

import (
	"context"
	"fmt"
	"net/url"

	"github.com/faustbrian/go-queue/core"
	"github.com/faustbrian/go-queue/job"
	webhook "github.com/faustbrian/go-webhook"
	"github.com/faustbrian/go-webhook/adapters/queue"
)

func main() {
	queue := &fixtureQueue{}
	adapter, _ := webhookqueue.New(webhookqueue.Config{Queue: queue, MaxMessageBytes: 4096})
	endpoint, _ := url.Parse("https://receiver.example/hooks")
	_ = adapter.Enqueue(context.Background(), webhook.DeliveryRequest{
		Endpoint: endpoint, Body: []byte(`{"order":123}`),
		EventID: "event-123", IdempotencyKey: "event-123",
	})
	delivery, _ := webhook.UnmarshalDeliveryRequest(queue.message.Bytes(), 4096)
	fmt.Println(delivery.EventID, string(delivery.Body))
}

type fixtureQueue struct {
	message core.QueuedMessage
}

func (q *fixtureQueue) Queue(message core.QueuedMessage, _ ...job.AllowOption) error {
	q.message = message
	return nil
}

Output:
event-123 {"order":123}