pg

package

v0.0.0-...-7c75739 Latest Latest Go to latest Published: Jul 24, 2025 License: MIT Imports: 10 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func NewStorage(pool *pgxpool.Pool, logger zerolog.Logger) *Storage

func (s *Storage) AddProfilesToSubreddit(ctx context.Context, subreddit string, profileIDs []int64) error

func (s *Storage) CheckPresence(ctx context.Context, postIDs []string) (map[string]struct{}, error)

func (s *Storage) EnrichPosts(ctx context.Context, posts []reddit.PostAndComments) error

func (s *Storage) GetAllSubredditSettings(ctx context.Context) ([]reddit.SubredditSettings, error)

func (s *Storage) GetAllSubredditSettingsWithProfileID(
	ctx context.Context,
	profileID int64,
) ([]reddit.SubredditSettings, error)

func (s *Storage) GetPosts(ctx context.Context, postIDs []string) (posts []reddit.PostAndComments, err error)

func (s *Storage) GetPostsForEnrichment(
	ctx context.Context,
	postCreatedBefore time.Time,
	limit int,
) (postIDs []string, err error)

func (s *Storage) GetPostsForScheduling(
	ctx context.Context,
	batchSize int,
	minScore int,
) (posts []reddit.PostAndComments, err error)

func (s *Storage) GetRawPosts(ctx context.Context, postIDs []string) (posts []reddit.RawPostAndComments, err error)

func (s *Storage) GetScheduledPostIDsFromSubreddits(
	ctx context.Context,
	subreddits []string,
	days *int,
	limit *int,
) ([]string, error)

func (s *Storage) GetSubredditsForScraping(ctx context.Context) (subreddits []string, err error)

func (s *Storage) GetSubredditsSettings(
	ctx context.Context,
	subreddits []string,
) (subredditsSettings []reddit.SubredditSettings, err error)

func (s *Storage) InsertPosts(ctx context.Context, posts []reddit.Post) error

func (s *Storage) MarkPostsAsScheduled(ctx context.Context, postIDs []string) error

func (s *Storage) RemoveProfileFromAllSubredditSettings(ctx context.Context, profileID int64) error

func (s *Storage) RemoveProfilesFromSubreddit(ctx context.Context, subreddit string, profileIDs []int64) error