db

Oct 11, 2024

Changes in this version

type Proposal

+ RefetchedAt sql.NullTime

type ProposalRepo

+ func (r *ProposalRepo) GetFinishedShutterProposals(limit int) ([]string, error)

+ func (r *ProposalRepo) MarkProposalAsRefetched(id string) error

+ func (r *ProposalRepo) RemoveFetchedVotes(id string) error

type ProposalService

+ func (s *ProposalService) GetFinishedShutterProposals(limit int) ([]string, error)

+ func (s *ProposalService) MarkAsRefetched(id string) error

Jun 25, 2024

Changes in this version

type MessageRepo

+ func (r *MessageRepo) FindDaoUpdateSettings(limit, offset int) ([]string, error)

type MessageService

+ func (s *MessageService) FindDaoUpdateSettings(limit, offset int) ([]string, error)

Jun 13, 2024

Changes in this version

+ type Message struct

+ CreatedAt time.Time

+ DeletedAt gorm.DeletedAt

+ ID string

+ IpfsID string

+ MCI int

+ Snapshot json.RawMessage

+ Space string

+ Timestamp time.Time

+ Type MessageType

+ UpdatedAt time.Time

+ type MessageRepo struct

+ func NewMessageRepo(conn *gorm.DB) *MessageRepo

+ func (r *MessageRepo) CreateInBatches(messages []*Message) (newRows int, err error)

+ func (r *MessageRepo) FindDeleteProposals(limit, offset int) ([]string, error)

+ func (r *MessageRepo) FindLatestMCI() (int, error)

+ func (r *MessageRepo) FindSpacesWithNewVotes(after time.Time) ([]string, error)

+ func (r *MessageRepo) Upsert(m *Message) (isNew bool, err error)

+ type MessageService struct

+ func NewMessageService(repo *MessageRepo, publisher Publisher) *MessageService

+ func (s *MessageService) FindDeleteProposals(limit, offset int) ([]string, error)

+ func (s *MessageService) FindSpacesWithNewVotes(after time.Time) ([]string, error)

+ func (s *MessageService) GetLatestMCI() (int, error)

+ func (s *MessageService) Upsert(message ...*Message) error

+ type MessageType string

+ const ArchiveProposalMessage

+ const DeleteProposalMessage

+ const InvalidProposalMessage

+ const ProposalMessage

+ const SettingsMessage

+ const VoteMessage

type VoteRepo

+ func (r *VoteRepo) GetLatestVoteByProposal(proposalID string) (*Vote, error)

type VoteService

+ func (s *VoteService) GetLatestVoteByProposal(proposalID string) (*Vote, error)

Mar 1, 2024

Changes in this version

+ type PreparedVote struct

+ CreatedAt time.Time

+ ID uuid.UUID

+ Proposal string

+ TypedData string

+ Voter string

+ type PreparedVoteRepo struct

+ func NewPreparedVoteRepo(conn *gorm.DB) *PreparedVoteRepo

+ func (r *PreparedVoteRepo) Create(pv *PreparedVote) error

+ func (r *PreparedVoteRepo) Get(id uuid.UUID) (PreparedVote, error)

+ type Proposal struct

+ CreatedAt time.Time

+ DeletedAt gorm.DeletedAt

+ ID string

+ Snapshot json.RawMessage

+ SpaceID string

+ UpdatedAt time.Time

+ VoteProcessed bool

+ type ProposalRepo struct

+ func NewProposalRepo(conn *gorm.DB) *ProposalRepo

+ func (r *ProposalRepo) DeleteByID(id ...string) error

+ func (r *ProposalRepo) GetByID(id string) (*Proposal, error)

+ func (r *ProposalRepo) GetLatestProposal() (*Proposal, error)

+ func (r *ProposalRepo) GetProposalForVotes(limit int) ([]string, error)

+ func (r *ProposalRepo) GetProposalIDsForUpdate(interval time.Duration, limit int, randOrder bool) ([]string, error)

+ func (r *ProposalRepo) MarkVotesProcessed(id string) error

+ func (r *ProposalRepo) Upsert(p *Proposal) (isNew bool, err error)

+ type ProposalService struct

+ func NewProposalService(repo *ProposalRepo, publisher Publisher) *ProposalService

+ func (s *ProposalService) Delete(ids []string) error

+ func (s *ProposalService) GetLatestProposal() (*Proposal, error)

+ func (s *ProposalService) GetProposalForVotes(limit int) ([]string, error)

+ func (s *ProposalService) GetProposalIDsForUpdate(interval time.Duration, limit int, randOrder bool) ([]string, error)

+ func (s *ProposalService) MarkVotesProcessed(id string) error

+ func (s *ProposalService) Upsert(p *Proposal) error

+ type Publisher interface

+ PublishJSON func(ctx context.Context, subject string, obj any) error

+ type Space struct

+ CreatedAt time.Time

+ DeletedAt gorm.DeletedAt

+ ID string

+ Snapshot json.RawMessage

+ UpdatedAt time.Time

+ type SpaceRepo struct

+ func NewSpaceRepo(conn *gorm.DB) *SpaceRepo

+ func (r *SpaceRepo) FindUndefinedSpaceIDs(limit int) ([]string, error)

+ func (r *SpaceRepo) Upsert(s *Space) (isNew bool, err error)

+ type SpaceService struct

+ func NewSpaceService(repo *SpaceRepo, publisher Publisher) *SpaceService

+ func (s *SpaceService) GetUndefinedSpaceIDs(limit int) ([]string, error)

+ func (s *SpaceService) Upsert(space *Space) error

+ type Vote struct

+ App string

+ Choice json.RawMessage

+ CreatedAt time.Time

+ DeletedAt gorm.DeletedAt

+ ID string

+ Ipfs string

+ ProposalID string

+ Published bool

+ Reason string

+ SpaceID string

+ UpdatedAt time.Time

+ Voter string

+ Vp float64

+ VpByStrategy []float64

+ VpState string

+ type VoteRepo struct

+ func NewVoteRepo(conn *gorm.DB) *VoteRepo

+ func (r *VoteRepo) BatchCreate(data []Vote) error

+ func (r *VoteRepo) GetLatestVote(id string) (*Vote, error)

+ func (r *VoteRepo) MarkAsPublished(votes []Vote) error

+ func (r *VoteRepo) SelectForPublish(limit int) ([]Vote, error)

+ func (r *VoteRepo) Upsert(v *Vote) (isNew bool, err error)

+ type VoteService struct

+ func NewVoteService(repo *VoteRepo, publisher Publisher) *VoteService

+ func (s *VoteService) BatchCreate(votes []Vote) error

+ func (s *VoteService) GetLatestVote(id string) (*Vote, error)

+ func (s *VoteService) Publish(votes []Vote, batchSize int) error

+ func (s *VoteService) Upsert(vote *Vote) error