database

package

v1.0.0 Latest Latest Go to latest Published: Mar 7, 2026 License: Apache-2.0 Imports: 7 Imported by: 0

Details

View Source

const (
	StateInit = iota
	StateDecrypting
	StateReady
	StateError
)

This section is empty.

This section is empty.

type Config interface {
	GetWorkDir() string
	GetPlatform() string
	GetVersion() int
	GetWebhook() *conf.Webhook
}

type Service struct {
	State    int
	StateMsg string
	// contains filtered or unexported fields
}

func NewService(conf Config) *Service

func (s *Service) Close()

Close closes the database connection

func (s *Service) GetChatRooms(key string, limit, offset int) (*wechatdb.GetChatRoomsResp, error)

func (s *Service) GetContacts(key string, limit, offset int) (*wechatdb.GetContactsResp, error)

func (s *Service) GetDB() *wechatdb.DB

func (s *Service) GetMedia(_type string, key string) (*model.Media, error)

func (s *Service) GetMessages(start, end time.Time, talker string, sender string, keyword string, limit, offset int) ([]*model.Message, error)

func (s *Service) GetSessions(key string, limit, offset int) (*wechatdb.GetSessionsResp, error)

GetSession retrieves session information

func (s *Service) SetDecrypting()

func (s *Service) SetError(msg string)

func (s *Service) SetInit()

func (s *Service) SetReady()

func (s *Service) Start() error

func (s *Service) Stop() error