73 lines
1.8 KiB
Go
73 lines
1.8 KiB
Go
|
package nostr
|
||
|
|
|
||
|
|
import (
|
||
|
|
"context"
|
||
|
|
|
||
|
|
"git.devvul.com/asara/well-goknown/config"
|
||
|
|
"github.com/fiatjaf/eventstore/postgresql"
|
||
|
|
"github.com/fiatjaf/khatru"
|
||
|
|
"github.com/fiatjaf/khatru/policies"
|
||
|
|
"github.com/jmoiron/sqlx"
|
||
|
|
)
|
||
|
|
|
||
|
|
var (
|
||
|
|
DB *sqlx.DB
|
||
|
|
RelayDb postgresql.PostgresBackend
|
||
|
|
relay *khatru.Relay
|
||
|
|
)
|
||
|
|
|
||
|
|
type nostrUser struct {
|
||
|
|
Pubkey string `db:"pubkey"`
|
||
|
|
Relays *string `db:"relays,omitempty"`
|
||
|
|
}
|
||
|
|
|
||
|
|
type nostrWellKnown struct {
|
||
|
|
Names map[string]string `json:"names"`
|
||
|
|
Relays map[string][]string `json:"relays,omitempty"`
|
||
|
|
NIP46 map[string][]string `json:"nip46,omitempty"`
|
||
|
|
}
|
||
|
|
|
||
|
|
func NewRelay(version string) *khatru.Relay {
|
||
|
|
// relay configuration
|
||
|
|
relay = khatru.NewRelay()
|
||
|
|
relay.Info.Name = config.GetConfig().RelayName
|
||
|
|
relay.Info.PubKey = config.GetConfig().RelayPubkey
|
||
|
|
relay.Info.Description = config.GetConfig().RelayDescription
|
||
|
|
relay.Info.Icon = config.GetConfig().RelayIcon
|
||
|
|
relay.Info.Contact = config.GetConfig().RelayContact
|
||
|
|
relay.Info.Version = version
|
||
|
|
relay.Info.Software = "https://git.devvul.com/asara/well-goknown"
|
||
|
|
// contact lists
|
||
|
|
relay.Info.SupportedNIPs = []int{
|
||
|
|
1, // basic protocol
|
||
|
|
2, // contact lists
|
||
|
|
4, // encrypted DMs
|
||
|
|
11, // relay info
|
||
|
|
42, // auth
|
||
|
|
70, // protected events
|
||
|
|
}
|
||
|
|
|
||
|
|
relay.OnConnect = append(relay.OnConnect, func(ctx context.Context) {
|
||
|
|
khatru.RequestAuth(ctx)
|
||
|
|
})
|
||
|
|
|
||
|
|
// storage
|
||
|
|
relay.StoreEvent = append(relay.StoreEvent, RelayDb.SaveEvent)
|
||
|
|
relay.QueryEvents = append(relay.QueryEvents, RelayDb.QueryEvents)
|
||
|
|
relay.CountEvents = append(relay.CountEvents, RelayDb.CountEvents)
|
||
|
|
relay.DeleteEvent = append(relay.DeleteEvent, RelayDb.DeleteEvent)
|
||
|
|
|
||
|
|
// apply policies
|
||
|
|
relay.RejectEvent = append(
|
||
|
|
relay.RejectEvent,
|
||
|
|
RejectUnregisteredNpubs,
|
||
|
|
policies.ValidateKind,
|
||
|
|
)
|
||
|
|
|
||
|
|
relay.RejectFilter = append(
|
||
|
|
relay.RejectFilter,
|
||
|
|
policies.RejectKind04Snoopers,
|
||
|
|
)
|
||
|
|
return relay
|
||
|
|
}
|