twdb

package

v0.2.1 Latest Latest Go to latest Published: Jan 14, 2025 License: BSD-3-Clause Imports: 17 Imported by: 0

Details

Package twdb provides tools to store a Twitter/X db-index of tweets.

This section is empty.

This section is empty.

func SchemaVersion() int

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

func Create(ctx context.Context, fname string) (*DB, error)

Create creates a new sqlite repository at fname.

func Open(fname string) (*DB, error)

Open opens the named sqlite repository.

func (db *DB) AddAccount(ctx context.Context, acc twarc.Account) error

func (db *DB) AddBskyPost(ctx context.Context, acc twarc.Account, tid twarc.ID, bsid string) error

func (db *DB) AddTweet(ctx context.Context, acc twarc.Account, tw twarc.Tweet) error

func (db *DB) AddUser(ctx context.Context, usr User) error

func (db *DB) BskyPost(ctx context.Context, acc twarc.Account, tid twarc.ID) (bid string, err error)

func (db *DB) BskyUser(ctx context.Context, id twarc.ID) (did string, err error)

func (db *DB) Close() (err error)

func (db *DB) HasAccount(ctx context.Context, acc twarc.Account) bool

func (db *DB) HasBskyPost(ctx context.Context, acc twarc.Account, tid twarc.ID) bool

func (db *DB) HasTweet(ctx context.Context, acc twarc.Account, tw twarc.Tweet) bool

func (db *DB) HasUser(ctx context.Context, id twarc.ID) bool

func (db *DB) ImportArchive(ctx context.Context, a twarc.Archive) error

func (db *DB) Threads(ctx context.Context, acc twarc.Account) iter.Seq2[twarc.Thread, error]

func (db *DB) Tweet(ctx context.Context, acc twarc.Account, tid twarc.ID) (tw twarc.Tweet, err error)

func (db *DB) Tweets(ctx context.Context, acc twarc.Account) iter.Seq2[twarc.Tweet, error]

func (db *DB) Users(ctx context.Context) iter.Seq2[User, error]

type User struct {
	ID          twarc.ID
	Handle      string
	DisplayName string
	BSID        string
}