summaryrefslogtreecommitdiffstats
path: root/vendor/github.com/gopackage/ddp/ddp_collection.go
diff options
context:
space:
mode:
authorWim <wim@42.be>2021-10-17 00:47:22 +0200
committerGitHub <noreply@github.com>2021-10-17 00:47:22 +0200
commit4dd8bae5c91fa4aef09d865d8fef1acd84f90925 (patch)
treeffad9b242daccaf8c86d1c1fbd59032302bd3be9 /vendor/github.com/gopackage/ddp/ddp_collection.go
parent7ae45c42e712bd0e66c101f3f714c05aa1dc2104 (diff)
downloadmatterbridge-msglm-4dd8bae5c91fa4aef09d865d8fef1acd84f90925.tar.gz
matterbridge-msglm-4dd8bae5c91fa4aef09d865d8fef1acd84f90925.tar.bz2
matterbridge-msglm-4dd8bae5c91fa4aef09d865d8fef1acd84f90925.zip
Update dependencies (#1610)
* Update dependencies * Update module to go 1.17
Diffstat (limited to 'vendor/github.com/gopackage/ddp/ddp_collection.go')
-rw-r--r--vendor/github.com/gopackage/ddp/ddp_collection.go245
1 files changed, 0 insertions, 245 deletions
diff --git a/vendor/github.com/gopackage/ddp/ddp_collection.go b/vendor/github.com/gopackage/ddp/ddp_collection.go
deleted file mode 100644
index f417e68a..00000000
--- a/vendor/github.com/gopackage/ddp/ddp_collection.go
+++ /dev/null
@@ -1,245 +0,0 @@
-package ddp
-
-// ----------------------------------------------------------------------
-// Collection
-// ----------------------------------------------------------------------
-
-type Update map[string]interface{}
-type UpdateListener interface {
- CollectionUpdate(collection, operation, id string, doc Update)
-}
-
-// Collection managed cached collection data sent from the server in a
-// livedata subscription.
-//
-// It would be great to build an entire mongo compatible local store (minimongo)
-type Collection interface {
-
- // FindOne queries objects and returns the first match.
- FindOne(id string) Update
- // FindAll returns a map of all items in the cache - this is a hack
- // until we have time to build out a real minimongo interface.
- FindAll() map[string]Update
- // AddUpdateListener adds a channel that receives update messages.
- AddUpdateListener(listener UpdateListener)
-
- // livedata updates
- added(msg Update)
- changed(msg Update)
- removed(msg Update)
- addedBefore(msg Update)
- movedBefore(msg Update)
- init() // init informs the collection that the connection to the server has begun/resumed
- reset() // reset informs the collection that the connection to the server has been lost
-}
-
-// NewMockCollection creates an empty collection that does nothing.
-func NewMockCollection() Collection {
- return &MockCache{}
-}
-
-// NewCollection creates a new collection - always KeyCache.
-func NewCollection(name string) Collection {
- return &KeyCache{name, make(map[string]Update), nil}
-}
-
-// KeyCache caches items keyed on unique ID.
-type KeyCache struct {
- // The name of the collection
- Name string
- // items contains collection items by ID
- items map[string]Update
- // listeners contains all the listeners that should be notified of collection updates.
- listeners []UpdateListener
- // TODO(badslug): do we need to protect from multiple threads
-}
-
-func (c *KeyCache) added(msg Update) {
- id, fields := parseUpdate(msg)
- if fields != nil {
- c.items[id] = fields
- c.notify("create", id, fields)
- }
-}
-
-func (c *KeyCache) changed(msg Update) {
- id, fields := parseUpdate(msg)
- if fields != nil {
- item, ok := c.items[id]
- if ok {
- for key, value := range fields {
- item[key] = value
- }
- c.items[id] = item
- c.notify("update", id, item)
- }
- }
-}
-
-func (c *KeyCache) removed(msg Update) {
- id, _ := parseUpdate(msg)
- if len(id) > 0 {
- delete(c.items, id)
- c.notify("remove", id, nil)
- }
-}
-
-func (c *KeyCache) addedBefore(msg Update) {
- // for keyed cache, ordered commands are a noop
-}
-
-func (c *KeyCache) movedBefore(msg Update) {
- // for keyed cache, ordered commands are a noop
-}
-
-// init prepares the collection for data updates (called when a new connection is
-// made or a connection/session is resumed).
-func (c *KeyCache) init() {
- // TODO start to patch up the current data with fresh server state
-}
-
-func (c *KeyCache) reset() {
- // TODO we should mark the collection but maintain it's contents and then
- // patch up the current contents with the new contents when we receive them.
- //c.items = nil
- c.notify("reset", "", nil)
-}
-
-// notify sends a Update to all UpdateListener's which should never block.
-func (c *KeyCache) notify(operation, id string, doc Update) {
- for _, listener := range c.listeners {
- listener.CollectionUpdate(c.Name, operation, id, doc)
- }
-}
-
-// FindOne returns the item with matching id.
-func (c *KeyCache) FindOne(id string) Update {
- return c.items[id]
-}
-
-// FindAll returns a dump of all items in the collection
-func (c *KeyCache) FindAll() map[string]Update {
- return c.items
-}
-
-// AddUpdateListener adds a listener for changes on a collection.
-func (c *KeyCache) AddUpdateListener(listener UpdateListener) {
- c.listeners = append(c.listeners, listener)
-}
-
-// OrderedCache caches items based on list order.
-// This is a placeholder, currently not implemented as the Meteor server
-// does not transmit ordered collections over DDP yet.
-type OrderedCache struct {
- // ranks contains ordered collection items for ordered collections
- items []interface{}
-}
-
-func (c *OrderedCache) added(msg Update) {
- // for ordered cache, key commands are a noop
-}
-
-func (c *OrderedCache) changed(msg Update) {
-
-}
-
-func (c *OrderedCache) removed(msg Update) {
-
-}
-
-func (c *OrderedCache) addedBefore(msg Update) {
-
-}
-
-func (c *OrderedCache) movedBefore(msg Update) {
-
-}
-
-func (c *OrderedCache) init() {
-
-}
-
-func (c *OrderedCache) reset() {
-
-}
-
-// FindOne returns the item with matching id.
-func (c *OrderedCache) FindOne(id string) Update {
- return nil
-}
-
-// FindAll returns a dump of all items in the collection
-func (c *OrderedCache) FindAll() map[string]Update {
- return map[string]Update{}
-}
-
-// AddUpdateListener does nothing.
-func (c *OrderedCache) AddUpdateListener(ch UpdateListener) {
-}
-
-// MockCache implements the Collection interface but does nothing with the data.
-type MockCache struct {
-}
-
-func (c *MockCache) added(msg Update) {
-
-}
-
-func (c *MockCache) changed(msg Update) {
-
-}
-
-func (c *MockCache) removed(msg Update) {
-
-}
-
-func (c *MockCache) addedBefore(msg Update) {
-
-}
-
-func (c *MockCache) movedBefore(msg Update) {
-
-}
-
-func (c *MockCache) init() {
-
-}
-
-func (c *MockCache) reset() {
-
-}
-
-// FindOne returns the item with matching id.
-func (c *MockCache) FindOne(id string) Update {
- return nil
-}
-
-// FindAll returns a dump of all items in the collection
-func (c *MockCache) FindAll() map[string]Update {
- return map[string]Update{}
-}
-
-// AddUpdateListener does nothing.
-func (c *MockCache) AddUpdateListener(ch UpdateListener) {
-}
-
-// parseUpdate returns the ID and fields from a DDP Update document.
-func parseUpdate(up Update) (ID string, Fields Update) {
- key, ok := up["id"]
- if ok {
- switch id := key.(type) {
- case string:
- updates, ok := up["fields"]
- if ok {
- switch fields := updates.(type) {
- case map[string]interface{}:
- return id, Update(fields)
- default:
- // Don't know what to do...
- }
- }
- return id, nil
- }
- }
- return "", nil
-}