delivery_queue_slog.go

package activitypub

import (
	"context"
	"log/slog"
)

type SlogDeliveryQueue struct {
	DeliveryQueue
}

func init() {
	ctx := context.Background()
	RegisterDeliveryQueue(ctx, "slog", NewSlogDeliveryQueue)
}

func NewSlogDeliveryQueue(ctx context.Context, uri string) (DeliveryQueue, error) {
	q := &SlogDeliveryQueue{}
	return q, nil
}

func (q *SlogDeliveryQueue) DeliverPost(ctx context.Context, opts *DeliverPostOptions) error {
	slog.Info("Deliver post", "post id", opts.Post.Id, "from", opts.From.Id, "to", opts.To)
	return nil
}