aboutsummaryrefslogtreecommitdiff
path: root/relayapi
diff options
context:
space:
mode:
authorDevon Hudson <devonhudson@librem.one>2023-04-28 13:31:21 -0600
committerDevon Hudson <devonhudson@librem.one>2023-04-28 13:31:21 -0600
commitb00e272e6f2fbcafb44995aa7cb6b09b6ba8ddb6 (patch)
treea904332851fba50c0a839bda6dd9460ac47d2021 /relayapi
parent9e9617ff84c3310fa3db6f32cdfc0207ec546963 (diff)
Use new gmsl to use new String() API
Diffstat (limited to 'relayapi')
-rw-r--r--relayapi/internal/perform.go8
-rw-r--r--relayapi/routing/relaytxn.go2
-rw-r--r--relayapi/routing/relaytxn_test.go2
-rw-r--r--relayapi/routing/sendrelay.go2
-rw-r--r--relayapi/routing/sendrelay_test.go2
5 files changed, 8 insertions, 8 deletions
diff --git a/relayapi/internal/perform.go b/relayapi/internal/perform.go
index 45765211..79d600ab 100644
--- a/relayapi/internal/perform.go
+++ b/relayapi/internal/perform.go
@@ -101,11 +101,11 @@ func (r *RelayInternalAPI) QueryTransactions(
userID spec.UserID,
previousEntry fclient.RelayEntry,
) (api.QueryRelayTransactionsResponse, error) {
- logrus.Infof("QueryTransactions for %s", userID.Raw())
+ logrus.Infof("QueryTransactions for %s", userID.String())
if previousEntry.EntryID > 0 {
logrus.Infof("Cleaning previous entry (%v) from db for %s",
previousEntry.EntryID,
- userID.Raw(),
+ userID.String(),
)
prevReceipt := receipt.NewReceipt(previousEntry.EntryID)
err := r.db.CleanTransactions(ctx, userID, []*receipt.Receipt{&prevReceipt})
@@ -123,12 +123,12 @@ func (r *RelayInternalAPI) QueryTransactions(
response := api.QueryRelayTransactionsResponse{}
if transaction != nil && receipt != nil {
- logrus.Infof("Obtained transaction (%v) for %s", transaction.TransactionID, userID.Raw())
+ logrus.Infof("Obtained transaction (%v) for %s", transaction.TransactionID, userID.String())
response.Transaction = *transaction
response.EntryID = receipt.GetNID()
response.EntriesQueued = true
} else {
- logrus.Infof("No more entries in the queue for %s", userID.Raw())
+ logrus.Infof("No more entries in the queue for %s", userID.String())
response.EntryID = 0
response.EntriesQueued = false
}
diff --git a/relayapi/routing/relaytxn.go b/relayapi/routing/relaytxn.go
index 2fc61373..9a3ced52 100644
--- a/relayapi/routing/relaytxn.go
+++ b/relayapi/routing/relaytxn.go
@@ -34,7 +34,7 @@ func GetTransactionFromRelay(
relayAPI api.RelayInternalAPI,
userID spec.UserID,
) util.JSONResponse {
- logrus.Infof("Processing relay_txn for %s", userID.Raw())
+ logrus.Infof("Processing relay_txn for %s", userID.String())
var previousEntry fclient.RelayEntry
if err := json.Unmarshal(fedReq.Content(), &previousEntry); err != nil {
diff --git a/relayapi/routing/relaytxn_test.go b/relayapi/routing/relaytxn_test.go
index e6d2d9e5..1041d8e7 100644
--- a/relayapi/routing/relaytxn_test.go
+++ b/relayapi/routing/relaytxn_test.go
@@ -35,7 +35,7 @@ func createQuery(
prevEntry fclient.RelayEntry,
) fclient.FederationRequest {
var federationPathPrefixV1 = "/_matrix/federation/v1"
- path := federationPathPrefixV1 + "/relay_txn/" + userID.Raw()
+ path := federationPathPrefixV1 + "/relay_txn/" + userID.String()
request := fclient.NewFederationRequest("GET", userID.Domain(), "relay", path)
request.SetContent(prevEntry)
diff --git a/relayapi/routing/sendrelay.go b/relayapi/routing/sendrelay.go
index e4794dc4..6ff08e20 100644
--- a/relayapi/routing/sendrelay.go
+++ b/relayapi/routing/sendrelay.go
@@ -36,7 +36,7 @@ func SendTransactionToRelay(
txnID gomatrixserverlib.TransactionID,
userID spec.UserID,
) util.JSONResponse {
- logrus.Infof("Processing send_relay for %s", userID.Raw())
+ logrus.Infof("Processing send_relay for %s", userID.String())
var txnEvents fclient.RelayEvents
if err := json.Unmarshal(fedReq.Content(), &txnEvents); err != nil {
diff --git a/relayapi/routing/sendrelay_test.go b/relayapi/routing/sendrelay_test.go
index 05dfbe6d..cac109e1 100644
--- a/relayapi/routing/sendrelay_test.go
+++ b/relayapi/routing/sendrelay_test.go
@@ -52,7 +52,7 @@ func createFederationRequest(
content interface{},
) fclient.FederationRequest {
var federationPathPrefixV1 = "/_matrix/federation/v1"
- path := federationPathPrefixV1 + "/send_relay/" + string(txnID) + "/" + userID.Raw()
+ path := federationPathPrefixV1 + "/send_relay/" + string(txnID) + "/" + userID.String()
request := fclient.NewFederationRequest("PUT", origin, destination, path)
request.SetContent(content)