nostr

package module
v0.11.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 16, 2023 License: MIT Imports: 21 Imported by: 435

README

go-nostr

A set of useful things for Nostr Protocol implementations.

GoDoc

Generating a key
sk, _ := nostr.GenerateKey()
pk, _ := nostr.GetPublicKey(sk)
nsec, _ := nip19.EncodePrivateKey(sk)
npub, _ := nip19.EncodePublicKey(pk)

fmt.Println("sk:", sk)
fmt.Println("pk:", nostr.GetPublicKey(sk))
fmt.Println(nsec)
fmt.Println(npub)
Subscribing to a single relay
relay, err := nostr.RelayConnect(context.Background(), "wss://nostr.zebedee.cloud")
if err != nil {
	panic(err)
}

npub := "npub1422a7ws4yul24p0pf7cacn7cghqkutdnm35z075vy68ggqpqjcyswn8ekc"

var filters nostr.Filters
if _, v, err := nip19.Decode(npub); err == nil {
	pub := v.(string)
	filters = []nostr.Filter{{
		Kinds:   []int{1},
		Authors: []string{pub},
		Limit:   1,
	}}
} else {
	panic(err)
}

ctx, cancel := context.WithCancel(context.Background())
sub := relay.Subscribe(ctx, filters)

go func() {
	<-sub.EndOfStoredEvents
	// handle end of stored events (EOSE, see NIP-15)
}()

for ev := range sub.Events {
	// handle returned event.
	// channel will stay open until the ctx is cancelled (in this case, by calling cancel())
	
	fmt.Println(ev.ID)
}
Publishing to two relays
sk := nostr.GeneratePrivateKey()
pub, _ := nostr.GetPublicKey(sk)

ev := nostr.Event{
	PubKey:    pub,
	CreatedAt: time.Now(),
	Kind:      1,
	Tags:      nil,
	Content:   "Hello World!",
}

// calling Sign sets the event ID field and the event Sig field
ev.Sign(sk)

// publish the event to two relays
for _, url := range []string{"wss://nostr.zebedee.cloud", "wss://nostr-pub.wellorder.net"} {
	relay, e := nostr.RelayConnect(context.Background(), url)
	if e != nil {
		fmt.Println(e)
		continue
	}
	fmt.Println("published to ", url, relay.Publish(context.Background(), ev))
}
Example script
go run example/example.go

Documentation

Index

Examples

Constants

View Source 
const (
	KindSetMetadata            int = 0
	KindTextNote               int = 1
	KindRecommendServer        int = 2
	KindContactList            int = 3
	KindEncryptedDirectMessage int = 4
	KindDeletion               int = 5
	KindBoost                  int = 6
	KindReaction               int = 7
	KindChannelCreation        int = 40
	KindChannelMetadata        int = 41
	KindChannelMessage         int = 42
	KindChannelHideMessage     int = 43
	KindChannelMuteUser        int = 44
)

Variables

This section is empty.

Functions

func ContainsPrefixOf 

func ContainsPrefixOf(haystack []string, needle string) bool

func FilterEqual 

func FilterEqual(a Filter, b Filter) bool

func GeneratePrivateKey 

func GeneratePrivateKey() string

func GetPublicKey 

func GetPublicKey(sk string) (string, error)

func NormalizeURL 

func NormalizeURL(u string) string
Example 
fmt.Println(NormalizeURL(""))
fmt.Println(NormalizeURL("wss://x.com/y"))
fmt.Println(NormalizeURL("wss://x.com/y/"))
fmt.Println(NormalizeURL("http://x.com/y"))
fmt.Println(NormalizeURL(NormalizeURL("http://x.com/y")))
fmt.Println(NormalizeURL("wss://x.com"))
fmt.Println(NormalizeURL("wss://x.com/"))
fmt.Println(NormalizeURL(NormalizeURL(NormalizeURL("wss://x.com/"))))
fmt.Println(NormalizeURL("x.com"))
fmt.Println(NormalizeURL("x.com/"))
fmt.Println(NormalizeURL("x.com////"))
fmt.Println(NormalizeURL("x.com/?x=23"))

Output:


wss://x.com/y
wss://x.com/y
ws://x.com/y
ws://x.com/y
wss://x.com
wss://x.com
wss://x.com
wss://x.com
wss://x.com
wss://x.com
wss://x.com?x=23

func Similar 

func Similar[E constraints.Ordered](as, bs []E) bool

Types

type Connection 

type Connection struct {
	// contains filtered or unexported fields
}

func NewConnection 

func NewConnection(socket *websocket.Conn) *Connection

func (*Connection) Close 

func (c *Connection) Close() error

func (*Connection) WriteJSON 

func (c *Connection) WriteJSON(v interface{}) error

func (*Connection) WriteMessage 

func (c *Connection) WriteMessage(messageType int, data []byte) error

type Event 

type Event struct {
	ID        string
	PubKey    string
	CreatedAt time.Time
	Kind      int
	Tags      Tags
	Content   string
	Sig       string
	// contains filtered or unexported fields
}

func (Event) CheckSignature 

func (evt Event) CheckSignature() (bool, error)

CheckSignature checks if the signature is valid for the id (which is a hash of the serialized event content). returns an error if the signature itself is invalid.

func (Event) GetExtra added in v0.8.2 

func (evt Event) GetExtra(key string) any

GetExtra tries to get a value under the given key that may be present in the event object but is hidden in the basic type since it is out of the spec.

func (Event) GetExtraBoolean added in v0.8.2 

func (evt Event) GetExtraBoolean(key string) bool

GetExtraBoolean is like Event.GetExtra, but only works if the value is a boolean, otherwise returns the zero-value.

func (Event) GetExtraNumber added in v0.8.2 

func (evt Event) GetExtraNumber(key string) float64

GetExtraNumber is like Event.GetExtra, but only works if the value is a float64, otherwise returns the zero-value.

func (Event) GetExtraString added in v0.8.2 

func (evt Event) GetExtraString(key string) string

GetExtraString is like Event.GetExtra, but only works if the value is a string, otherwise returns the zero-value.

func (*Event) GetID 

func (evt *Event) GetID() string

GetID serializes and returns the event ID as a string

func (Event) MarshalJSON 

func (evt Event) MarshalJSON() ([]byte, error)

func (*Event) Serialize 

func (evt *Event) Serialize() []byte

Serialize outputs a byte array that can be hashed/signed to identify/authenticate

func (*Event) SetExtra added in v0.8.2 

func (evt *Event) SetExtra(key string, value any)

SetExtra sets an out-of-the-spec value under the given key into the event object.

func (*Event) Sign 

func (evt *Event) Sign(privateKey string) error

Sign signs an event with a given privateKey

func (*Event) UnmarshalJSON 

func (evt *Event) UnmarshalJSON(payload []byte) error

type EventMessage 

type EventMessage struct {
	Event Event
	Relay string
}

type Filter 

type Filter struct {
	IDs     []string
	Kinds   []int
	Authors []string
	Tags    TagMap
	Since   *time.Time
	Until   *time.Time
	Limit   int
}

func (Filter) MarshalJSON 

func (f Filter) MarshalJSON() ([]byte, error)

func (Filter) Matches 

func (ef Filter) Matches(event *Event) bool

func (Filter) String added in v0.8.2 

func (ef Filter) String() string

func (*Filter) UnmarshalJSON 

func (f *Filter) UnmarshalJSON(payload []byte) error

type Filters 

type Filters []Filter

func (Filters) Match 

func (eff Filters) Match(event *Event) bool

func (Filters) String added in v0.8.2 

func (eff Filters) String() string

type ProfileMetadata added in v0.9.0 

type ProfileMetadata struct {
	Name    string `json:"name,omitempty"`
	About   string `json:"about,omitempty"`
	Picture string `json:"picture,omitempty"`
	NIP05   string `json:"nip05,omitempty"`
}

func ParseMetadata added in v0.9.0 

func ParseMetadata(event Event) (*ProfileMetadata, error)

type Relay 

type Relay struct {
	URL string

	Connection *Connection

	Notices         chan string
	ConnectionError chan error
	// contains filtered or unexported fields
}

func RelayConnect added in v0.8.1 

func RelayConnect(ctx context.Context, url string) (*Relay, error)

RelayConnect returns a relay object connected to url Once successfully connected, cancelling ctx has no effect To close the connection, call r.Close()

func (*Relay) Close 

func (r *Relay) Close() error

func (*Relay) Connect 

func (r *Relay) Connect(ctx context.Context) error

Connect tries to establish a websocket connection to r.URL. If the context expires before the connection is complete, an error is returned. Once successfully connected, context expiration has no effect: call r.Close to close the connection.

func (*Relay) PrepareSubscription added in v0.8.2 

func (r *Relay) PrepareSubscription() *Subscription

func (*Relay) Publish 

func (r *Relay) Publish(ctx context.Context, event Event) Status

Publish sends an "EVENT" command to the relay r as in NIP-01 status can be: success, failed, or sent (no response from relay before ctx times out)

func (*Relay) QuerySync added in v0.9.0 

func (r *Relay) QuerySync(ctx context.Context, filter Filter) []Event

func (*Relay) String added in v0.8.2 

func (r *Relay) String() string

func (*Relay) Subscribe 

func (r *Relay) Subscribe(ctx context.Context, filters Filters) *Subscription

Subscribe sends a "REQ" command to the relay r as in NIP-01 Events are returned through the channel sub.Events the subscription is closed when context ctx is cancelled ("CLOSE" in NIP-01)

type Status 

type Status int
const (
	PublishStatusSent      Status = 0
	PublishStatusFailed    Status = -1
	PublishStatusSucceeded Status = 1
)

func (Status) String 

func (s Status) String() string

type Subscription 

type Subscription struct {
	Relay             *Relay
	Filters           Filters
	Events            chan Event
	EndOfStoredEvents chan struct{}
	// contains filtered or unexported fields
}

func (*Subscription) Fire added in v0.8.2 

func (sub *Subscription) Fire(ctx context.Context)

Fire sends the "REQ" command to the relay when ctx is cancelled, sub.Unsub() is called, closing the subscription

func (*Subscription) Sub 

func (sub *Subscription) Sub(ctx context.Context, filters Filters)

Sub sets sub.Filters and then calls sub.Fire(ctx)

func (*Subscription) Unsub 

func (sub *Subscription) Unsub()

Unsub closes the subscription, sending "CLOSE" to relay as in NIP-01 Unsub() also closes the channel sub.Events

type Tag 

type Tag []string

func (Tag) Key added in v0.8.2 

func (tag Tag) Key() string

func (Tag) Relay added in v0.8.2 

func (tag Tag) Relay() string

func (Tag) StartsWith 

func (tag Tag) StartsWith(prefix []string) bool

StartsWith checks if a tag contains a prefix. for example, 

["p", "abcdef...", "wss://relay.com"]

would match against 

["p", "abcdef..."]

or even 

["p", "abcdef...", "wss://"]

func (Tag) Value added in v0.8.2 

func (tag Tag) Value() string

type TagMap 

type TagMap map[string][]string

type Tags 

type Tags []Tag

func (Tags) AppendUnique 

func (tags Tags) AppendUnique(tag Tag) Tags

AppendUnique appends a tag if it doesn't exist yet, otherwise does nothing

func (Tags) ContainsAny 

func (tags Tags) ContainsAny(tagName string, values []string) bool

func (Tags) FilterOut 

func (tags Tags) FilterOut(tagPrefix []string) Tags

FilterOut removes all tags that match the prefix, see Tag.StartsWith

func (Tags) GetAll 

func (tags Tags) GetAll(tagPrefix []string) Tags

GetLast gets all the tags that match the prefix, see Tag.StartsWith

func (Tags) GetFirst 

func (tags Tags) GetFirst(tagPrefix []string) *Tag

GetFirst gets the first tag in tags that matches the prefix, see Tag.StartsWith

func (Tags) GetLast 

func (tags Tags) GetLast(tagPrefix []string) *Tag

GetLast gets the last tag in tags that matches the prefix, see Tag.StartsWith

func (*Tags) Scan 

func (t *Tags) Scan(src interface{}) error

Source Files

View all Source files

Directories

Path Synopsis
Package nip13 implements NIP-13 See https://github.com/nostr-protocol/nips/blob/master/13.md for details.
 Package nip13 implements NIP-13 See https://github.com/nostr-protocol/nips/blob/master/13.md for details.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.