url.go

package sdump

import (
	"context"
	"fmt"
	"time"

	"github.com/google/uuid"
	"github.com/rs/xid"
	"github.com/uptrace/bun"
)

type appError string

func (a appError) Error() string { return string(a) }

const (
	ErrURLEndpointNotFound = appError("endpoint not found")
)

type URLEndpointMetadata struct{}

type URLEndpoint struct {
	ID        uuid.UUID `bun:"type:uuid,default:uuid_generate_v4()" json:"id,omitempty"`
	Reference string    `json:"reference,omitempty"`
	IsActive  bool      `json:"is_active,omitempty"`
	UserID    uuid.UUID `json:"user_id,omitempty"`

	Metadata URLEndpointMetadata `json:"metadata,omitempty"`

	CreatedAt time.Time  `bun:",nullzero,notnull,default:current_timestamp" json:"created_at,omitempty" bson:"created_at"`
	UpdatedAt time.Time  `bun:",nullzero,notnull,default:current_timestamp" json:"updated_at,omitempty" bson:"updated_at"`
	DeletedAt *time.Time `bun:",soft_delete,nullzero" json:"-,omitempty" bson:"deleted_at"`

	bun.BaseModel `bun:"table:urls"`
}

func (u *URLEndpoint) PubChannel() string { return fmt.Sprintf("messages.%s", u.Reference) }

func NewURLEndpoint(userID uuid.UUID) *URLEndpoint {
	return &URLEndpoint{
		Reference: xid.New().String(),
		IsActive:  true,
		UserID:    userID,
	}
}

type FindURLOptions struct {
	Reference string
	ID        uuid.UUID
}

type URLRepository interface {
	Create(context.Context, *URLEndpoint) error
	Get(context.Context, *FindURLOptions) (*URLEndpoint, error)
	Latest(context.Context, uuid.UUID) (*URLEndpoint, error)
}