pds

package
v0.0.0-...-efe2ce5 Latest Latest
Warning

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

 Go to latest Published: Apr 25, 2024 License: Apache-2.0, MIT Imports: 39 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ErrInvalidUsernameOrPassword = fmt.Errorf("invalid username or password")
View Source 
var ErrNoSuchUser = fmt.Errorf("no such user")

Functions

This section is empty.

Types

type FeedGenerator 

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

func NewFeedGenerator 

func NewFeedGenerator(db *gorm.DB, ix *indexer.Indexer, readRecord ReadRecordFunc) (*FeedGenerator, error)

func (*FeedGenerator) GetActorProfile 

func (fg *FeedGenerator) GetActorProfile(ctx context.Context, actor string) (*models.ActorInfo, error)

func (*FeedGenerator) GetActorProfileByID 

func (fg *FeedGenerator) GetActorProfileByID(ctx context.Context, actor uint) (*models.ActorInfo, error)

func (*FeedGenerator) GetAuthorFeed 

func (fg *FeedGenerator) GetAuthorFeed(ctx context.Context, user *User, before string, limit int) ([]*bsky.FeedDefs_FeedViewPost, error)

func (*FeedGenerator) GetFollows 

func (fg *FeedGenerator) GetFollows(ctx context.Context, user string, limit int, before string) ([]*FollowInfo, error)

func (*FeedGenerator) GetPostThread 

func (fg *FeedGenerator) GetPostThread(ctx context.Context, uri string, depth int) (*ThreadPost, error)

func (*FeedGenerator) GetTimeline 

func (fg *FeedGenerator) GetTimeline(ctx context.Context, user *User, algo string, before string, limit int) ([]*bsky.FeedDefs_FeedViewPost, error)

func (*FeedGenerator) GetVotes 

func (fg *FeedGenerator) GetVotes(ctx context.Context, uri string, pcid cid.Cid, limit int, before string) ([]*HydratedVote, error)

type FollowInfo 

type FollowInfo struct {
	Follower  *bsky.ActorDefs_ProfileViewBasic
	Subject   *bsky.ActorDefs_ProfileViewBasic
	CreatedAt string
	IndexedAt string
}

type HealthStatus 

type HealthStatus struct {
	Status  string `json:"status"`
	Message string `json:"msg,omitempty"`
}

type HydratedVote 

type HydratedVote struct {
	Actor     *bsky.ActorDefs_ProfileViewBasic
	Direction string
	IndexedAt time.Time
	CreatedAt string
}

type Peering 

type Peering struct {
	gorm.Model
	Host     string
	Did      string
	Approved bool
}

type ReadRecordFunc 

type ReadRecordFunc func(context.Context, models.Uid, cid.Cid) (lexutil.CBOR, error)

type RefreshToken 

type RefreshToken struct {
	gorm.Model
	Token string
}

type Server 

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

func NewServer 

func NewServer(db *gorm.DB, cs *carstore.CarStore, serkey *did.PrivKey, handleSuffix, serviceUrl string, didr plc.PLCClient, jwtkey []byte) (*Server, error)

func (*Server) EventsHandler 

func (s *Server) EventsHandler(c echo.Context) error

func (*Server) HandleComAtprotoAdminDisableAccountInvites 

func (s *Server) HandleComAtprotoAdminDisableAccountInvites(c echo.Context) error

func (*Server) HandleComAtprotoAdminDisableInviteCodes 

func (s *Server) HandleComAtprotoAdminDisableInviteCodes(c echo.Context) error

func (*Server) HandleComAtprotoAdminEnableAccountInvites 

func (s *Server) HandleComAtprotoAdminEnableAccountInvites(c echo.Context) error

func (*Server) HandleComAtprotoAdminGetAccountInfo 

func (s *Server) HandleComAtprotoAdminGetAccountInfo(c echo.Context) error

func (*Server) HandleComAtprotoAdminGetInviteCodes 

func (s *Server) HandleComAtprotoAdminGetInviteCodes(c echo.Context) error

func (*Server) HandleComAtprotoAdminGetSubjectStatus 

func (s *Server) HandleComAtprotoAdminGetSubjectStatus(c echo.Context) error

func (*Server) HandleComAtprotoAdminSendEmail 

func (s *Server) HandleComAtprotoAdminSendEmail(c echo.Context) error

func (*Server) HandleComAtprotoAdminUpdateAccountEmail 

func (s *Server) HandleComAtprotoAdminUpdateAccountEmail(c echo.Context) error

func (*Server) HandleComAtprotoAdminUpdateAccountHandle 

func (s *Server) HandleComAtprotoAdminUpdateAccountHandle(c echo.Context) error

func (*Server) HandleComAtprotoAdminUpdateSubjectStatus 

func (s *Server) HandleComAtprotoAdminUpdateSubjectStatus(c echo.Context) error

func (*Server) HandleComAtprotoIdentityResolveHandle 

func (s *Server) HandleComAtprotoIdentityResolveHandle(c echo.Context) error

func (*Server) HandleComAtprotoIdentityUpdateHandle 

func (s *Server) HandleComAtprotoIdentityUpdateHandle(c echo.Context) error

func (*Server) HandleComAtprotoLabelQueryLabels 

func (s *Server) HandleComAtprotoLabelQueryLabels(c echo.Context) error

func (*Server) HandleComAtprotoModerationCreateReport 

func (s *Server) HandleComAtprotoModerationCreateReport(c echo.Context) error

func (*Server) HandleComAtprotoRepoApplyWrites 

func (s *Server) HandleComAtprotoRepoApplyWrites(c echo.Context) error

func (*Server) HandleComAtprotoRepoCreateRecord 

func (s *Server) HandleComAtprotoRepoCreateRecord(c echo.Context) error

func (*Server) HandleComAtprotoRepoDeleteRecord 

func (s *Server) HandleComAtprotoRepoDeleteRecord(c echo.Context) error

func (*Server) HandleComAtprotoRepoDescribeRepo 

func (s *Server) HandleComAtprotoRepoDescribeRepo(c echo.Context) error

func (*Server) HandleComAtprotoRepoGetRecord 

func (s *Server) HandleComAtprotoRepoGetRecord(c echo.Context) error

func (*Server) HandleComAtprotoRepoListRecords 

func (s *Server) HandleComAtprotoRepoListRecords(c echo.Context) error

func (*Server) HandleComAtprotoRepoPutRecord 

func (s *Server) HandleComAtprotoRepoPutRecord(c echo.Context) error

func (*Server) HandleComAtprotoRepoUploadBlob 

func (s *Server) HandleComAtprotoRepoUploadBlob(c echo.Context) error

func (*Server) HandleComAtprotoServerConfirmEmail 

func (s *Server) HandleComAtprotoServerConfirmEmail(c echo.Context) error

func (*Server) HandleComAtprotoServerCreateAccount 

func (s *Server) HandleComAtprotoServerCreateAccount(c echo.Context) error

func (*Server) HandleComAtprotoServerCreateAppPassword 

func (s *Server) HandleComAtprotoServerCreateAppPassword(c echo.Context) error

func (*Server) HandleComAtprotoServerCreateInviteCode 

func (s *Server) HandleComAtprotoServerCreateInviteCode(c echo.Context) error

func (*Server) HandleComAtprotoServerCreateInviteCodes 

func (s *Server) HandleComAtprotoServerCreateInviteCodes(c echo.Context) error

func (*Server) HandleComAtprotoServerCreateSession 

func (s *Server) HandleComAtprotoServerCreateSession(c echo.Context) error

func (*Server) HandleComAtprotoServerDeleteAccount 

func (s *Server) HandleComAtprotoServerDeleteAccount(c echo.Context) error

func (*Server) HandleComAtprotoServerDeleteSession 

func (s *Server) HandleComAtprotoServerDeleteSession(c echo.Context) error

func (*Server) HandleComAtprotoServerDescribeServer 

func (s *Server) HandleComAtprotoServerDescribeServer(c echo.Context) error

func (*Server) HandleComAtprotoServerGetAccountInviteCodes 

func (s *Server) HandleComAtprotoServerGetAccountInviteCodes(c echo.Context) error

func (*Server) HandleComAtprotoServerGetSession 

func (s *Server) HandleComAtprotoServerGetSession(c echo.Context) error

func (*Server) HandleComAtprotoServerListAppPasswords 

func (s *Server) HandleComAtprotoServerListAppPasswords(c echo.Context) error

func (*Server) HandleComAtprotoServerRefreshSession 

func (s *Server) HandleComAtprotoServerRefreshSession(c echo.Context) error

func (*Server) HandleComAtprotoServerRequestAccountDelete 

func (s *Server) HandleComAtprotoServerRequestAccountDelete(c echo.Context) error

func (*Server) HandleComAtprotoServerRequestEmailConfirmation 

func (s *Server) HandleComAtprotoServerRequestEmailConfirmation(c echo.Context) error

func (*Server) HandleComAtprotoServerRequestEmailUpdate 

func (s *Server) HandleComAtprotoServerRequestEmailUpdate(c echo.Context) error

func (*Server) HandleComAtprotoServerRequestPasswordReset 

func (s *Server) HandleComAtprotoServerRequestPasswordReset(c echo.Context) error

func (*Server) HandleComAtprotoServerReserveSigningKey 

func (s *Server) HandleComAtprotoServerReserveSigningKey(c echo.Context) error

func (*Server) HandleComAtprotoServerResetPassword 

func (s *Server) HandleComAtprotoServerResetPassword(c echo.Context) error

func (*Server) HandleComAtprotoServerRevokeAppPassword 

func (s *Server) HandleComAtprotoServerRevokeAppPassword(c echo.Context) error

func (*Server) HandleComAtprotoServerUpdateEmail 

func (s *Server) HandleComAtprotoServerUpdateEmail(c echo.Context) error

func (*Server) HandleComAtprotoSyncGetBlob 

func (s *Server) HandleComAtprotoSyncGetBlob(c echo.Context) error

func (*Server) HandleComAtprotoSyncGetBlocks 

func (s *Server) HandleComAtprotoSyncGetBlocks(c echo.Context) error

func (*Server) HandleComAtprotoSyncGetCheckout 

func (s *Server) HandleComAtprotoSyncGetCheckout(c echo.Context) error

func (*Server) HandleComAtprotoSyncGetHead 

func (s *Server) HandleComAtprotoSyncGetHead(c echo.Context) error

func (*Server) HandleComAtprotoSyncGetLatestCommit 

func (s *Server) HandleComAtprotoSyncGetLatestCommit(c echo.Context) error

func (*Server) HandleComAtprotoSyncGetRecord 

func (s *Server) HandleComAtprotoSyncGetRecord(c echo.Context) error

func (*Server) HandleComAtprotoSyncGetRepo 

func (s *Server) HandleComAtprotoSyncGetRepo(c echo.Context) error

func (*Server) HandleComAtprotoSyncListBlobs 

func (s *Server) HandleComAtprotoSyncListBlobs(c echo.Context) error

func (*Server) HandleComAtprotoSyncListRepos 

func (s *Server) HandleComAtprotoSyncListRepos(c echo.Context) error

func (*Server) HandleComAtprotoSyncNotifyOfUpdate 

func (s *Server) HandleComAtprotoSyncNotifyOfUpdate(c echo.Context) error

func (*Server) HandleComAtprotoSyncRequestCrawl 

func (s *Server) HandleComAtprotoSyncRequestCrawl(c echo.Context) error

func (*Server) HandleComAtprotoTempFetchLabels 

func (s *Server) HandleComAtprotoTempFetchLabels(c echo.Context) error

func (*Server) HandleHealthCheck 

func (s *Server) HandleHealthCheck(c echo.Context) error

func (*Server) HandleResolveDid 

func (s *Server) HandleResolveDid(c echo.Context) error

func (*Server) RegisterHandlersComAtproto 

func (s *Server) RegisterHandlersComAtproto(e *echo.Echo) error

func (*Server) Repoman 

func (s *Server) Repoman() *repomgr.RepoManager

func (*Server) RunAPI 

func (s *Server) RunAPI(addr string) error

func (*Server) RunAPIWithListener 

func (s *Server) RunAPIWithListener(listen net.Listener) error

func (*Server) Shutdown 

func (s *Server) Shutdown(ctx context.Context) error

func (*Server) UpdateUserHandle 

func (s *Server) UpdateUserHandle(ctx context.Context, u *User, handle string) error

type ThreadPost 

type ThreadPost struct {
	Post   *bsky.FeedDefs_FeedViewPost
	PostID uint

	ParentUri string
	Parent    *ThreadPost
}

type User 

type User struct {
	ID          models.Uid `gorm:"primarykey"`
	CreatedAt   time.Time
	UpdatedAt   time.Time
	DeletedAt   gorm.DeletedAt `gorm:"index"`
	Handle      string         `gorm:"uniqueIndex"`
	Password    string
	RecoveryKey string
	Email       string
	Did         string `gorm:"uniqueIndex"`
	PDS         uint
}

Source Files

View all Source files

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.