diff options
author | Wim <wim@42.be> | 2017-12-25 00:54:39 +0100 |
---|---|---|
committer | Wim <wim@42.be> | 2017-12-25 00:54:39 +0100 |
commit | 16f3fa6bae77f646c980f616e262ab84a12dddb7 (patch) | |
tree | c103acf984bc0e2f11c66852aeef53fb335dea5e /vendor/github.com/matterbridge/gomatrix/store.go | |
parent | 1f706673cf326625b749b42b1102a75835ff1bbb (diff) | |
download | matterbridge-msglm-16f3fa6bae77f646c980f616e262ab84a12dddb7.tar.gz matterbridge-msglm-16f3fa6bae77f646c980f616e262ab84a12dddb7.tar.bz2 matterbridge-msglm-16f3fa6bae77f646c980f616e262ab84a12dddb7.zip |
Vendor github.com/matterbridge/gomatrix
Diffstat (limited to 'vendor/github.com/matterbridge/gomatrix/store.go')
-rw-r--r-- | vendor/github.com/matterbridge/gomatrix/store.go | 65 |
1 files changed, 65 insertions, 0 deletions
diff --git a/vendor/github.com/matterbridge/gomatrix/store.go b/vendor/github.com/matterbridge/gomatrix/store.go new file mode 100644 index 00000000..6dc687e5 --- /dev/null +++ b/vendor/github.com/matterbridge/gomatrix/store.go @@ -0,0 +1,65 @@ +package gomatrix + +// Storer is an interface which must be satisfied to store client data. +// +// You can either write a struct which persists this data to disk, or you can use the +// provided "InMemoryStore" which just keeps data around in-memory which is lost on +// restarts. +type Storer interface { + SaveFilterID(userID, filterID string) + LoadFilterID(userID string) string + SaveNextBatch(userID, nextBatchToken string) + LoadNextBatch(userID string) string + SaveRoom(room *Room) + LoadRoom(roomID string) *Room +} + +// InMemoryStore implements the Storer interface. +// +// Everything is persisted in-memory as maps. It is not safe to load/save filter IDs +// or next batch tokens on any goroutine other than the syncing goroutine: the one +// which called Client.Sync(). +type InMemoryStore struct { + Filters map[string]string + NextBatch map[string]string + Rooms map[string]*Room +} + +// SaveFilterID to memory. +func (s *InMemoryStore) SaveFilterID(userID, filterID string) { + s.Filters[userID] = filterID +} + +// LoadFilterID from memory. +func (s *InMemoryStore) LoadFilterID(userID string) string { + return s.Filters[userID] +} + +// SaveNextBatch to memory. +func (s *InMemoryStore) SaveNextBatch(userID, nextBatchToken string) { + s.NextBatch[userID] = nextBatchToken +} + +// LoadNextBatch from memory. +func (s *InMemoryStore) LoadNextBatch(userID string) string { + return s.NextBatch[userID] +} + +// SaveRoom to memory. +func (s *InMemoryStore) SaveRoom(room *Room) { + s.Rooms[room.ID] = room +} + +// LoadRoom from memory. +func (s *InMemoryStore) LoadRoom(roomID string) *Room { + return s.Rooms[roomID] +} + +// NewInMemoryStore constructs a new InMemoryStore. +func NewInMemoryStore() *InMemoryStore { + return &InMemoryStore{ + Filters: make(map[string]string), + NextBatch: make(map[string]string), + Rooms: make(map[string]*Room), + } +} |