# I am the Watcher. I am your guide through this vast new twtiverse. # # Usage: # https://watcher.sour.is/api/plain/users View list of users and latest twt date. # https://watcher.sour.is/api/plain/twt View all twts. # https://watcher.sour.is/api/plain/mentions?uri=:uri View all mentions for uri. # https://watcher.sour.is/api/plain/conv/:hash View all twts for a conversation subject. # # Options: # uri Filter to show a specific users twts. # offset Start index for quey. # limit Count of items to return (going back in time). # # twt range = 1 13 # self = https://watcher.sour.is/conv/fuhaoaa
type PA[T any] interface {
\tevent.Aggregate
\t*T
}
// Create uses fn to create a new aggregate and store in db.
func Create[A any, T PA[A]](ctx context.Context, es *EventStore, streamID string, fn func(context.Context, T) error) (agg T, err error) {
\tctx, span := logz.Span(ctx)
\tdefer span.End()
\tagg = new(A)
\tagg.SetStreamID(streamID)
\tif err = es.Load(ctx, agg); err != nil {
\t\treturn
\t}
\tif err = event.NotExists(agg); err != nil {
\t\treturn
\t}
\tif err = fn(ctx, agg); err != nil {
\t\treturn
\t}
\tvar i uint64
\tif i, err = es.Save(ctx, agg); err != nil {
\t\treturn
\t}
\tspan.AddEvent(fmt.Sprint("wrote events = ", i))
\treturn
}
a, err := es.Create(ctx, r.es, streamID, func(ctx context.Context, agg *domain.SaltyUser) error {
\t\treturn agg.OnUserRegister(nick, key)
})
type PA[T any] interface {
event.Aggregate
*T
}
// Create uses fn to create a new aggregate and store in db.
func Create[A any, T PA[A]](ctx context.Context, es *EventStore, streamID string, fn func(context.Context, T) error) (agg T, err error) {
ctx, span := logz.Span(ctx)
defer span.End()
agg = new(A)
agg.SetStreamID(streamID)
if err = es.Load(ctx, agg); err != nil {
return
}
if err = event.NotExists(agg); err != nil {
return
}
if err = fn(ctx, agg); err != nil {
return
}
var i uint64
if i, err = es.Save(ctx, agg); err != nil {
return
}
span.AddEvent(fmt.Sprint("wrote events = ", i))
return
}
a, err := es.Create(ctx, r.es, streamID, func(ctx context.Context, agg *domain.SaltyUser) error {
return agg.OnUserRegister(nick, key)
})
type PA[T any] interface {
\tevent.Aggregate
\t*T
}
// Create uses fn to create a new aggregate and store in db.
func Create[A any, T PA[A]](ctx context.Context, es *EventStore, streamID string, fn func(context.Context, T) error) (agg T, err error) {
\tctx, span := logz.Span(ctx)
\tdefer span.End()
\tagg = new(A)
\tagg.SetStreamID(streamID)
\tif err = es.Load(ctx, agg); err != nil {
\t\treturn
\t}
\tif err = event.NotExists(agg); err != nil {
\t\treturn
\t}
\tif err = fn(ctx, agg); err != nil {
\t\treturn
\t}
\tvar i uint64
\tif i, err = es.Save(ctx, agg); err != nil {
\t\treturn
\t}
\tspan.AddEvent(fmt.Sprint("wrote events = ", i))
\treturn
}
a, err := es.Create(ctx, r.es, streamID, func(ctx context.Context, agg *domain.SaltyUser) error {
\t\treturn agg.OnUserRegister(nick, key)
})