container

Documentation

Index

• Constants
• func ReleaseContainer(c *Container)
• type Container
  • func AcquireContainer() *Container
  • func NewContainer(options *options.Options) (*Container, error)
  • func (container *Container) AcquireDevice(hostNumber string) (*store.Device, error)
  • func (container *Container) ClientJID() waTypes.JID
  • func (container *Container) FindMessageByID(jid waTypes.JID, id string) *events.Message
  • func (container *Container) GetAllChats() []*events.Message
  • func (container *Container) GetChatInJID(jid waTypes.JID) []*events.Message
  • func (container *Container) GetStatusMessages() []*events.Message
  • func (container *Container) HandleHistorySync(evt *waProto.HistorySync)
  • func (container *Container) HandleMessageUpdates(evt *events.Message)
  • func (container *Container) InitializeTables()
  • func (container *Container) ParseWebMessage(chatJID waTypes.JID, webMsg *waProto.WebMessageInfo) (*events.Message, error)
  • func (container *Container) SetClientJID(jid waTypes.JID)
  • func (container *Container) UpsertMessages(jid waTypes.JID, message []*events.Message)

Constants

const CHATS_TABLE = `` /* 247-byte string literal not displayed */

const DELETE_ALL_CHATS = `DELETE FROM whatsmeow_chats WHERE our_jid = $1`

const INSERT_CHATS = `INSERT INTO whatsmeow_chats (our_jid, chat_jid, messages) VALUES ($1, $2, $3)`

const SELECT_ALL_CHATS = `SELECT messages FROM whatsmeow_chats WHERE our_jid = $1`

const SELECT_CHATS_BY_JID = `SELECT messages FROM whatsmeow_chats WHERE our_jid = $1 AND chat_jid = $2`

const UPDATE_MESSAGES_IN_CHAT = `UPDATE whatsmeow_chats SET messages = $1 WHERE our_jid = $1 AND chat_jid = $2`

const UPSERT_CHATS = `` /* 152-byte string literal not displayed */

Functions

func ReleaseContainer

func ReleaseContainer(c *Container)

Types

type Container

type Container struct {
	DB *sql.DB

	NewDevice bool
	// contains filtered or unexported fields
}

func AcquireContainer

func AcquireContainer() *Container

func NewContainer

func NewContainer(options *options.Options) (*Container, error)

func (*Container) AcquireDevice

func (container *Container) AcquireDevice(hostNumber string) (*store.Device, error)

func (*Container) ClientJID

func (container *Container) ClientJID() waTypes.JID

func (*Container) FindMessageByID

func (container *Container) FindMessageByID(jid waTypes.JID, id string) *events.Message

func (*Container) GetAllChats

func (container *Container) GetAllChats() []*events.Message

func (*Container) GetChatInJID

func (container *Container) GetChatInJID(jid waTypes.JID) []*events.Message

func (*Container) GetStatusMessages

func (container *Container) GetStatusMessages() []*events.Message

func (*Container) HandleHistorySync

func (container *Container) HandleHistorySync(evt *waProto.HistorySync)

func (*Container) HandleMessageUpdates

func (container *Container) HandleMessageUpdates(evt *events.Message)

func (*Container) InitializeTables

func (container *Container) InitializeTables()

func (*Container) ParseWebMessage

func (container *Container) ParseWebMessage(chatJID waTypes.JID, webMsg *waProto.WebMessageInfo) (*events.Message, error)

func (*Container) SetClientJID

func (container *Container) SetClientJID(jid waTypes.JID)

func (*Container) UpsertMessages

func (container *Container) UpsertMessages(jid waTypes.JID, message []*events.Message)