database

package
v0.6.320 Latest Latest
Warning

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

 Go to latest Published: May 10, 2026 License: AGPL-3.0, AGPL-3.0-or-later Imports: 24 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	AuthRepoName    = "/AUTH"
	PassSubName     = "PASS" // TODO pass restore functionality
	DefaultOwnerKey = "OWNER"
)
View Source 
const (
	ChatNamespace     = "/CHATS"
	MessageNamespace  = "/MESSAGES"
	NonceSubNamespace = "NONCE"
)
View Source 
const (
	LikeRepoName      = "/LIKES"
	IncrSubNamespace  = "INCR"
	LikerSubNamespace = "LIKER"
)
View Source 
const (
	MediaRepoName     = "/MEDIA"
	ImageSubNamespace = "IMAGES"
	VideoSubNamespace = "VIDEOS"
)
View Source 
const (
	BlocklistSubNamespace     = "BLOCKLIST"
	BlocklistUserSubNamespace = "USER"
	BlocklistTermSubNamespace = "TERM"
)
View Source 
const (
	TweetsNamespace = "/TWEETS"

	// ViewDedupTTL is the time window during which repeated views of the
	// same tweet by the same viewer are not counted.
	ViewDedupTTL = 30 * time.Minute
)
View Source 
const (
	UsersRepoName = "/USERS"

	DefaultWarpnetUserNetwork = "warpnet"
)
View Source 
const (
	DevicesRepoName = "/DEVICES"
)
View Source 
const (
	ErrNilNodeRepo = local_store.DBError("node repo is nil")
)

slash is required because of: invalid datastore key: NODES:/peers/keys/AASAQAISEAXNRKHMX2O3AA26JM7NGIWUPOGIITJ2UHHXGX4OWIEKPNAW6YCSK/priv

View Source 
const (
	FollowRepoName = "/FOLLOW"
)
View Source 
const (
	NotificationsRepoName = "/NOTIFICATIONS"
)
View Source 
const (
	RepliesNamespace = "/REPLY"
)
View Source 
const TimelineRepoName = "/TIMELINE"

Variables

View Source 
var (
	ErrChatNotFound    = local_store.DBError("chat not found")
	ErrMessageNotFound = local_store.DBError("message not found")
)
View Source 
var (
	ErrMediaNotFound    = local_store.DBError("media not found")
	ErrMediaRepoNotInit = local_store.DBError("media repo is not initialized")
)
View Source 
var (
	ErrTweetNotFound = local.DBError("tweet not found")
	ErrViewsNotFound = local.DBError("views not found")
)
View Source 
var (
	ErrUserNotFound      = local_store.DBError("user not found")
	ErrUserAlreadyExists = local_store.DBError("user already exists")
)
View Source 
var ErrAlreadyFollowed = local_store.DBError("already followed")
View Source 
var ErrLikesNotFound = local_store.DBError("like not found")
View Source 
var ErrNilAuthRepo = local_store.DBError("auth repo is nil")
View Source 
var ErrNilDevicesRepo = local_store.DBError("devices repo is nil")
View Source 
var ErrNotificationsNotFound = local_store.DBError("notifications not found")
View Source 
var ErrReplyNotFound = local_store.DBError("reply not found")

Functions

func NewStatsRepo added in v0.6.120 

func NewStatsRepo(db StatsStorer) ds.Datastore

Types

type AuthRepo 

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

func NewAuthRepo 

func NewAuthRepo(db AuthStorer, network string) *AuthRepo

func (*AuthRepo) Authenticate 

func (repo *AuthRepo) Authenticate(username, password string) (err error)

func (*AuthRepo) GetOwner 

func (repo *AuthRepo) GetOwner() domain.Owner

func (*AuthRepo) Logout added in v0.4.37 

func (repo *AuthRepo) Logout()

func (*AuthRepo) PrivateKey 

func (repo *AuthRepo) PrivateKey() ed25519.PrivateKey

func (*AuthRepo) SessionToken 

func (repo *AuthRepo) SessionToken() string

func (*AuthRepo) SetOwner 

func (repo *AuthRepo) SetOwner(o domain.Owner) (_ domain.Owner, err error)

type AuthStorer 

type AuthStorer interface {
	Run(username, password string) (err error)
	Set(key local_store.DatabaseKey, value []byte) error
	Get(key local_store.DatabaseKey) ([]byte, error)
	NewTxn() (local_store.WarpTransactioner, error)
	Close()
}

type Base64Image 

type Base64Image string

type BlockLevel added in v0.5.105 

type BlockLevel int
const (
	InitialBlock BlockLevel = iota + 1
	MediumBlock
	AdvancedBlock
	PermanentBlock
)

func (BlockLevel) Next added in v0.5.105 

func (b BlockLevel) Next() BlockLevel

type BlocklistTerm added in v0.5.129 

type BlocklistTerm struct {
	PeerID string
	Level  BlockLevel
}

type ChatRepo 

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

func NewChatRepo 

func NewChatRepo(db ChatStorer) *ChatRepo

func (*ChatRepo) CreateChat 

func (repo *ChatRepo) CreateChat(chatId *string, ownerId, otherUserId string) (chat domain.Chat, err error)

func (*ChatRepo) CreateMessage 

func (repo *ChatRepo) CreateMessage(msg domain.ChatMessage) (domain.ChatMessage, error)

func (*ChatRepo) DeleteChat 

func (repo *ChatRepo) DeleteChat(chatId string) error

func (*ChatRepo) DeleteMessage 

func (repo *ChatRepo) DeleteMessage(chatId, id string) error

func (*ChatRepo) GetChat 

func (repo *ChatRepo) GetChat(chatId string) (chat domain.Chat, err error)

func (*ChatRepo) GetMessage 

func (repo *ChatRepo) GetMessage(chatId, id string) (m domain.ChatMessage, err error)

func (*ChatRepo) GetUserChats 

func (repo *ChatRepo) GetUserChats(userId string, limit *uint64, cursor *string) ([]domain.Chat, string, error)

func (*ChatRepo) ListMessages 

func (repo *ChatRepo) ListMessages(chatId string, limit *uint64, cursor *string) ([]domain.ChatMessage, string, error)

type ChatStorer 

type ChatStorer interface {
	NewTxn() (local_store.WarpTransactioner, error)
}

type DevicesRepo added in v0.6.263 

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

func NewDevicesRepo added in v0.6.263 

func NewDevicesRepo(db DevicesStorer) *DevicesRepo

func (*DevicesRepo) GetDevices added in v0.6.263 

func (repo *DevicesRepo) GetDevices(ownerNodeId string) (devices []domain.Device, err error)

func (*DevicesRepo) SetDevice added in v0.6.263 

func (repo *DevicesRepo) SetDevice(ownerNodeId string, device domain.Device) error

type DevicesStorer added in v0.6.263 

type DevicesStorer interface {
	SetWithTTL(key local_store.DatabaseKey, value []byte, ttl time.Duration) error
	NewTxn() (local_store.WarpTransactioner, error)
}

type FollowRepo 

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

func NewFollowRepo 

func NewFollowRepo(db FollowerStorer) *FollowRepo

func (*FollowRepo) Follow 

func (repo *FollowRepo) Follow(fromUserId, toUserId string) error

func (*FollowRepo) GetFollowers 

func (repo *FollowRepo) GetFollowers(userId string, limit *uint64, cursor *string) ([]string, string, error)

func (*FollowRepo) GetFollowersCount 

func (repo *FollowRepo) GetFollowersCount(userId string) (uint64, error)

func (*FollowRepo) GetFollowings added in v0.5.83 

func (repo *FollowRepo) GetFollowings(userId string, limit *uint64, cursor *string) ([]string, string, error)

GetFollowings following - one who is followed (has his/her posts monitored by another user)

func (*FollowRepo) GetFollowingsCount added in v0.5.83 

func (repo *FollowRepo) GetFollowingsCount(userId string) (uint64, error)

func (*FollowRepo) IsFollower added in v0.5.83 

func (repo *FollowRepo) IsFollower(ownerId, otherUserId string) bool

func (*FollowRepo) IsFollowing added in v0.5.83 

func (repo *FollowRepo) IsFollowing(ownerId, otherUserId string) bool

func (*FollowRepo) Unfollow 

func (repo *FollowRepo) Unfollow(fromUserId, toUserId string) error

type FollowerStorer 

type FollowerStorer interface {
	NewTxn() (local_store.WarpTransactioner, error)
	Set(key local_store.DatabaseKey, value []byte) error
	Get(key local_store.DatabaseKey) ([]byte, error)
	Delete(key local_store.DatabaseKey) error
}

type ImageKey 

type ImageKey string

type LikeRepo 

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

func NewLikeRepo 

func NewLikeRepo(db LikeStorer, statsDb LikeStatsStorer) *LikeRepo

func (*LikeRepo) Like 

func (repo *LikeRepo) Like(tweetId, userId string) (likesCount uint64, err error)

func (*LikeRepo) Likers 

func (repo *LikeRepo) Likers(tweetId string, limit *uint64, cursor *string) (_ likedUserIDs, cur string, err error)

func (*LikeRepo) LikesCount 

func (repo *LikeRepo) LikesCount(tweetId string) (likesNum uint64, err error)

func (*LikeRepo) Unlike 

func (repo *LikeRepo) Unlike(tweetId, userId string) (likesCount uint64, err error)

type LikeStatsStorer added in v0.5.158 

type LikeStatsStorer interface {
	GetAggregatedStat(key ds.Key) (uint64, error)
	Increment(key ds.Key) error
	Decrement(key ds.Key) error
}

type LikeStorer 

type LikeStorer interface {
	Get(key local_store.DatabaseKey) ([]byte, error)
	NewTxn() (local_store.WarpTransactioner, error)
}

type MediaRepo 

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

func NewMediaRepo 

func NewMediaRepo(db MediaStorer) *MediaRepo

func (*MediaRepo) GetImage 

func (repo *MediaRepo) GetImage(userId, key string) (Base64Image, error)

func (*MediaRepo) SetForeignImageWithTTL 

func (repo *MediaRepo) SetForeignImageWithTTL(userId, key string, img Base64Image) error

func (*MediaRepo) SetImage 

func (repo *MediaRepo) SetImage(userId string, img Base64Image) (_ ImageKey, err error)

type MediaStorer 

type MediaStorer interface {
	Set(key local_store.DatabaseKey, value []byte) error
	Get(key local_store.DatabaseKey) ([]byte, error)
	SetWithTTL(key local_store.DatabaseKey, value []byte, ttl time.Duration) error
}

type NodeRepo 

type NodeRepo struct {
	BootstrapSelfHashHex string
	// contains filtered or unexported fields
}

func NewNodeRepo 

func NewNodeRepo(db NodeStorer) *NodeRepo

func (*NodeRepo) Batch 

func (d *NodeRepo) Batch(ctx context.Context) (datastore.Batch, error)

func (*NodeRepo) Blocklist 

func (d *NodeRepo) Blocklist(peerId string) error

func (*NodeRepo) BlocklistRemove 

func (d *NodeRepo) BlocklistRemove(peerId string) error

func (*NodeRepo) BlocklistTerm added in v0.5.129 

func (d *NodeRepo) BlocklistTerm(peerId string) (*BlocklistTerm, error)

func (*NodeRepo) Close 

func (d *NodeRepo) Close() (err error)

func (*NodeRepo) Delete 

func (d *NodeRepo) Delete(ctx context.Context, key datastore.Key) error

func (*NodeRepo) DiskUsage 

func (d *NodeRepo) DiskUsage(ctx context.Context) (uint64, error)

DiskUsage implements the PersistentDatastore interface. It returns the sum of lsm and value log files sizes in bytes.

func (*NodeRepo) Get 

func (d *NodeRepo) Get(ctx context.Context, key datastore.Key) (value []byte, err error)

func (*NodeRepo) GetExpiration 

func (d *NodeRepo) GetExpiration(ctx context.Context, key datastore.Key) (t time.Time, err error)

func (*NodeRepo) GetSize 

func (d *NodeRepo) GetSize(ctx context.Context, key datastore.Key) (_ int, err error)

func (*NodeRepo) Has 

func (d *NodeRepo) Has(ctx context.Context, key datastore.Key) (_ bool, err error)

func (*NodeRepo) IsBlocklisted 

func (d *NodeRepo) IsBlocklisted(peerId string) bool

func (*NodeRepo) Put 

func (d *NodeRepo) Put(ctx context.Context, key datastore.Key, value []byte) error

func (*NodeRepo) PutWithTTL 

func (d *NodeRepo) PutWithTTL(ctx context.Context, key datastore.Key, value []byte, ttl time.Duration) error

func (*NodeRepo) Query 

func (d *NodeRepo) Query(ctx context.Context, q datastore.Query) (datastore.Results, error)

func (*NodeRepo) SetTTL 

func (d *NodeRepo) SetTTL(ctx context.Context, key datastore.Key, ttl time.Duration) error

func (*NodeRepo) Sync 

func (d *NodeRepo) Sync(ctx context.Context, _ datastore.Key) error

type NodeStorer 

type NodeStorer interface {
	NewTxn() (local_store.WarpTransactioner, error)
	Get(key local_store.DatabaseKey) ([]byte, error)
	GetExpiration(key local_store.DatabaseKey) (uint64, error)
	GetSize(key local_store.DatabaseKey) (int64, error)
	Sync() error
	IsClosed() bool
	InnerDB() *local_store.WarpDB
	SetWithTTL(key local_store.DatabaseKey, value []byte, ttl time.Duration) error
	Set(key local_store.DatabaseKey, value []byte) error
	Delete(key local_store.DatabaseKey) error
}

type NotificationsRepo added in v0.5.30 

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

func NewNotificationsRepo added in v0.5.30 

func NewNotificationsRepo(db NotificationsStorer) *NotificationsRepo

func (*NotificationsRepo) Add added in v0.5.30 

func (repo *NotificationsRepo) Add(not domain.Notification) error

func (*NotificationsRepo) List added in v0.5.30 

func (repo *NotificationsRepo) List(userId string, limit *uint64, cursor *string) ([]domain.Notification, string, error)

type NotificationsStorer added in v0.5.30 

type NotificationsStorer interface {
	NewTxn() (local_store.WarpTransactioner, error)
}

type ReplyRepo 

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

func NewRepliesRepo 

func NewRepliesRepo(db ReplyStorer, statsDb ReplyStatsStorer) *ReplyRepo

func (*ReplyRepo) AddReply 

func (repo *ReplyRepo) AddReply(reply domain.Tweet) (domain.Tweet, error)

func (*ReplyRepo) DeleteReply 

func (repo *ReplyRepo) DeleteReply(rootID, parentID, replyID string) error

func (*ReplyRepo) GetRepliesTree 

func (repo *ReplyRepo) GetRepliesTree(rootId, parentId string, limit *uint64, cursor *string) ([]domain.ReplyNode, string, error)

func (*ReplyRepo) GetReply 

func (repo *ReplyRepo) GetReply(rootID string, replyId string) (tweet domain.Tweet, err error)

func (*ReplyRepo) RepliesCount 

func (repo *ReplyRepo) RepliesCount(tweetId string) (likesNum uint64, err error)

type ReplyStatsStorer added in v0.5.158 

type ReplyStatsStorer interface {
	GetAggregatedStat(key ds.Key) (uint64, error)
	Increment(key ds.Key) error
	Decrement(key ds.Key) error
}

type ReplyStorer 

type ReplyStorer interface {
	Set(key local_store.DatabaseKey, value []byte) error
	Get(key local_store.DatabaseKey) ([]byte, error)
	Delete(key local_store.DatabaseKey) error
	NewTxn() (local_store.WarpTransactioner, error)
}

type StatsStorer added in v0.6.120 

type StatsStorer interface {
	NewTxn() (local_store.WarpTransactioner, error)
	Get(key local_store.DatabaseKey) ([]byte, error)
	GetExpiration(key local_store.DatabaseKey) (uint64, error)
	GetSize(key local_store.DatabaseKey) (int64, error)
	Sync() error
	IsClosed() bool
	InnerDB() *local_store.WarpDB
	SetWithTTL(key local_store.DatabaseKey, value []byte, ttl time.Duration) error
	Set(key local_store.DatabaseKey, value []byte) error
	Delete(key local_store.DatabaseKey) error
}

type TimelineRepo 

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

func NewTimelineRepo 

func NewTimelineRepo(db TimelineStorer) *TimelineRepo

func (*TimelineRepo) AddTweetToTimeline 

func (repo *TimelineRepo) AddTweetToTimeline(userId string, tweet domain.Tweet) error

func (*TimelineRepo) DeleteTweetFromTimeline 

func (repo *TimelineRepo) DeleteTweetFromTimeline(userID, tweetID string) error

func (*TimelineRepo) GetTimeline 

func (repo *TimelineRepo) GetTimeline(userId string, limit *uint64, cursor *string) ([]domain.Tweet, string, error)

GetTimeline retrieves a user's timeline sorted from newest to oldest

type TimelineStorer 

type TimelineStorer interface {
	Set(key local_store.DatabaseKey, value []byte) error
	NewTxn() (local_store.WarpTransactioner, error)
	Delete(key local_store.DatabaseKey) error
}

type TweetRepo 

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

func NewTweetRepo 

func NewTweetRepo(db TweetsStorer, statsDb TweetStatsStorer) *TweetRepo

func (*TweetRepo) Blocklist added in v0.5.30 

func (repo *TweetRepo) Blocklist(tweetId string) error

func (*TweetRepo) Create 

func (repo *TweetRepo) Create(userId string, tweet domain.Tweet) (domain.Tweet, error)

Create adds a new tweet to the database

func (*TweetRepo) CreateWithTTL added in v0.3.61 

func (repo *TweetRepo) CreateWithTTL(userId string, tweet domain.Tweet, duration time.Duration) (domain.Tweet, error)

func (*TweetRepo) Delete 

func (repo *TweetRepo) Delete(userID, tweetID string) error

Delete removes a tweet by its ID

func (*TweetRepo) Get 

func (repo *TweetRepo) Get(userID, tweetID string) (tweet domain.Tweet, err error)

Get retrieves a tweet by its ID

func (*TweetRepo) GetViewsCount added in v0.5.158 

func (repo *TweetRepo) GetViewsCount(tweetId string) (uint64, error)

func (*TweetRepo) IsBlocklisted added in v0.5.30 

func (repo *TweetRepo) IsBlocklisted(tweetId string) bool

func (*TweetRepo) List 

func (repo *TweetRepo) List(userId string, limit *uint64, cursor *string) ([]domain.Tweet, string, error)

func (*TweetRepo) NewRetweet 

func (repo *TweetRepo) NewRetweet(tweet domain.Tweet) (_ domain.Tweet, err error)

func (*TweetRepo) RecordView added in v0.6.316 

func (repo *TweetRepo) RecordView(tweetId, viewerId string) (uint64, error)

RecordView increments the view counter for tweetId on behalf of viewerId. Repeated calls from the same viewerId within ViewDedupTTL are no-ops, so rapid re-views do not inflate the count. The increment is atomic via the underlying transaction and replicated through the CRDT stats store, so it is safe under concurrent calls across nodes.

func (*TweetRepo) Retweeters 

func (repo *TweetRepo) Retweeters(tweetId string, limit *uint64, cursor *string) (_ retweetersIDs, cur string, err error)

func (*TweetRepo) RetweetsCount 

func (repo *TweetRepo) RetweetsCount(tweetId string) (uint64, error)

func (*TweetRepo) TweetsCount 

func (repo *TweetRepo) TweetsCount(userId string) (uint64, error)

func (*TweetRepo) UnRetweet 

func (repo *TweetRepo) UnRetweet(retweetedByUserID, tweetId string) error

func (*TweetRepo) Update added in v0.5.134 

func (repo *TweetRepo) Update(updateTweet domain.Tweet) error

type TweetStatsStorer added in v0.5.158 

type TweetStatsStorer interface {
	GetAggregatedStat(key ds.Key) (uint64, error)
	Increment(key ds.Key) error
	Decrement(key ds.Key) error
}

type TweetsStorer 

type TweetsStorer interface {
	NewTxn() (local.WarpTransactioner, error)
	Set(key local.DatabaseKey, value []byte) error
	Get(key local.DatabaseKey) ([]byte, error)
	Delete(key local.DatabaseKey) error
	GetExpiration(key local.DatabaseKey) (uint64, error)
}

type UserRepo 

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

func NewUserRepo 

func NewUserRepo(db UserStorer) *UserRepo

func (*UserRepo) Create 

func (repo *UserRepo) Create(user domain.User) (domain.User, error)

Create adds a new user to the database

func (*UserRepo) CreateWithTTL added in v0.3.61 

func (repo *UserRepo) CreateWithTTL(user domain.User, ttl time.Duration) (domain.User, error)

func (*UserRepo) Delete 

func (repo *UserRepo) Delete(userId string) error

Delete removes a user by their ID

func (*UserRepo) Get 

func (repo *UserRepo) Get(userId string) (user domain.User, err error)

Get retrieves a user by their ID

func (*UserRepo) GetBatch 

func (repo *UserRepo) GetBatch(userIDs ...string) (users []domain.User, err error)

func (*UserRepo) GetByNodeID 

func (repo *UserRepo) GetByNodeID(nodeID string) (user domain.User, err error)

func (*UserRepo) List 

func (repo *UserRepo) List(limit *uint64, cursor *string) ([]domain.User, string, error)

func (*UserRepo) Update 

func (repo *UserRepo) Update(userId string, newUser domain.User) (domain.User, error)

func (*UserRepo) WhoToFollow added in v0.3.75 

func (repo *UserRepo) WhoToFollow(limit *uint64, cursor *string) ([]domain.User, string, error)

type UserStorer 

type UserStorer interface {
	NewTxn() (local_store.WarpTransactioner, error)
	Set(key local_store.DatabaseKey, value []byte) error
	Get(key local_store.DatabaseKey) ([]byte, error)
	Delete(key local_store.DatabaseKey) error
}

Source Files

View all Source files

Directories

Path Synopsis

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.