apply https://github.com/42wim/matterbridge/pull/1864v1.26.0+0.1.0

1 files changed, 43 insertions, 0 deletions

diff --git a/vendor/maunium.net/go/mautrix/appservice/txnid.go b/vendor/maunium.net/go/mautrix/appservice/txnid.go
new file mode 100644
index 00000000..213703c5
--- /dev/null
+++ b/vendor/maunium.net/go/mautrix/appservice/txnid.go
@@ -0,0 +1,43 @@
+// Copyright (c) 2021 Tulir Asokan
+//
+// This Source Code Form is subject to the terms of the Mozilla Public
+// License, v. 2.0. If a copy of the MPL was not distributed with this
+// file, You can obtain one at http://mozilla.org/MPL/2.0/.
+
+package appservice
+
+import "sync"
+
+type TransactionIDCache struct {
+	array    []string
+	arrayPtr int
+	hash     map[string]struct{}
+	lock     sync.RWMutex
+}
+
+func NewTransactionIDCache(size int) *TransactionIDCache {
+	return &TransactionIDCache{
+		array: make([]string, size),
+		hash:  make(map[string]struct{}),
+	}
+}
+
+func (txnIDC *TransactionIDCache) IsProcessed(txnID string) bool {
+	txnIDC.lock.RLock()
+	_, exists := txnIDC.hash[txnID]
+	txnIDC.lock.RUnlock()
+	return exists
+}
+
+func (txnIDC *TransactionIDCache) MarkProcessed(txnID string) {
+	txnIDC.lock.Lock()
+	txnIDC.hash[txnID] = struct{}{}
+	if txnIDC.array[txnIDC.arrayPtr] != "" {
+		for i := 0; i < len(txnIDC.array)/8; i++ {
+			delete(txnIDC.hash, txnIDC.array[txnIDC.arrayPtr+i])
+			txnIDC.array[txnIDC.arrayPtr+i] = ""
+		}
+	}
+	txnIDC.array[txnIDC.arrayPtr] = txnID
+	txnIDC.lock.Unlock()
+}