<commit_before>package hey

import "time"

// Manager represents storage methods
type Manager interface {
	// threads
	NewThread(*Thread) error
	GetThread(threadID string) (*Thread, error)
	UpdateThread(*Thread) error
	DeleteThread(threadID string) error

	// thread sources
	AddSource(dstThread, sourceThread string) error
	GetSources(threadID string, offset, limit uint32) ([]Thread, error)
	GetRefers(sourceThreadID string, offset, limit uint32) ([]Thread, error)
	RemoveSource(dstThread, sourceThread string) error

	// user subscriptions
	Observe(userID, threadID string) error
	Ignore(userID, threadID string) error
	Observers(threadID string, offset, limit uint32) ([]User, error)
	Observes(userID string, offset, limit uint32) ([]Thread, error)
	MarkAsDelivered(userID string, threadID string, times ...time.Time) error

	// threadline
	RecentActivityByLastTS(threadID string, limit uint32, lastts time.Time) ([]Event, error)
	RecentActivity(threadID string, limit, offset uint32) ([]Event, error)

	// events
	NewEvent(*Event) error
	GetEvent(id string) (*Event, error)
	GetEvents(ids ...string) ([]Event, error)
	UpdateEvent(ev *Event) error
	DeleteEvent(eventID string) error
}<commit_msg>hide sources methods<commit_after>package hey

import "time"

// Manager represents storage methods
type Manager interface {
	// threads
	NewThread(*Thread) error
	GetThread(threadID string) (*Thread, error)
	UpdateThread(*Thread) error
	DeleteThread(threadID string) error

	// thread sources
	//AddSource(dstThread, sourceThread string) error
	//GetSources(threadID string, offset, limit uint32) ([]Thread, error)
	//GetRefers(sourceThreadID string, offset, limit uint32) ([]Thread, error)
	//RemoveSource(dstThread, sourceThread string) error

	// user subscriptions
	Observe(userID, threadID string) error
	Ignore(userID, threadID string) error
	Observers(threadID string, offset, limit uint32) ([]User, error)
	Observes(userID string, offset, limit uint32) ([]Thread, error)
	MarkAsDelivered(userID string, threadID string, times ...time.Time) error

	// threadline
	RecentActivityByLastTS(threadID string, limit uint32, lastts time.Time) ([]Event, error)
	RecentActivity(userID, threadID string, limit uint32) ([]Event, error)
	Activity(threadID string, offset, limit uint32) ([]Event, error)

	// events
	NewEvent(*Event) error
	GetEvent(id string) (*Event, error)
	GetEvents(ids ...string) ([]Event, error)
	UpdateEvent(ev *Event) error
	DeleteEvent(eventID string) error

	// related data
	SetRelatedData(*RelatedData) error
	GetRelatedDatas(userID string, events ...Event) ([]EventObserver, error)

	// users
	NewUser(*User) error
	GetUser(userID string) (*User, error)
}
{'fraction_non_alphanumeric': 0.11488250652741515, 'fraction_numerical': 0.00969787392763894, 'mean_word_length': 5.859335038363171, 'pattern_counts': {'":': 0, '<': 3, '<?xml version=': 0, '>': 3, 'https://': 0, 'lorem ipsum': 0, 'www.': 0, 'xml': 0}, 'pii_count': 0, 'substrings_counts': 0, 'word_list_counts': {'cursed_substrings.json': 0, 'profanity_word_list.json': 0, 'sexual_word_list.json': 0, 'zh_pornsignals.json': 0}}
{'dir': 'git-commits-cleaned', 'id': '7001085', 'n_tokens_mistral': 839, 'n_tokens_neox': 807, 'n_words': 248}