summaryrefslogtreecommitdiff
path: root/internal/processing/stream
diff options
context:
space:
mode:
authorLibravatar Daenney <daenney@users.noreply.github.com>2025-04-26 15:34:10 +0200
committerLibravatar Daenney <daenney@users.noreply.github.com>2025-04-26 15:38:43 +0200
commitab10266bff8d3dea1655e5f98a932efa2474bdb6 (patch)
treedef81628d7a7c81b8ad0c971fb02ebc945eca75c /internal/processing/stream
parent[chore] Set up Github to be a mirror (diff)
downloadgotosocial-ab10266bff8d3dea1655e5f98a932efa2474bdb6.tar.xz
[feature] Move to code.superseriousbusiness.org
Diffstat (limited to 'internal/processing/stream')
-rw-r--r--internal/processing/stream/authorize.go8
-rw-r--r--internal/processing/stream/authorize_test.go2
-rw-r--r--internal/processing/stream/conversation.go6
-rw-r--r--internal/processing/stream/delete.go2
-rw-r--r--internal/processing/stream/filterschanged.go4
-rw-r--r--internal/processing/stream/notification.go8
-rw-r--r--internal/processing/stream/notification_test.go4
-rw-r--r--internal/processing/stream/open.go8
-rw-r--r--internal/processing/stream/statusupdate.go8
-rw-r--r--internal/processing/stream/statusupdate_test.go6
-rw-r--r--internal/processing/stream/stream.go6
-rw-r--r--internal/processing/stream/stream_test.go14
-rw-r--r--internal/processing/stream/update.go8
13 files changed, 42 insertions, 42 deletions
diff --git a/internal/processing/stream/authorize.go b/internal/processing/stream/authorize.go
index cedd21e0b..44463d5c6 100644
--- a/internal/processing/stream/authorize.go
+++ b/internal/processing/stream/authorize.go
@@ -24,10 +24,10 @@ import (
"slices"
"strings"
- apiutil "github.com/superseriousbusiness/gotosocial/internal/api/util"
- "github.com/superseriousbusiness/gotosocial/internal/db"
- "github.com/superseriousbusiness/gotosocial/internal/gtserror"
- "github.com/superseriousbusiness/gotosocial/internal/gtsmodel"
+ apiutil "code.superseriousbusiness.org/gotosocial/internal/api/util"
+ "code.superseriousbusiness.org/gotosocial/internal/db"
+ "code.superseriousbusiness.org/gotosocial/internal/gtserror"
+ "code.superseriousbusiness.org/gotosocial/internal/gtsmodel"
)
// Authorize returns an oauth2 token info in response to an access token query from the streaming API
diff --git a/internal/processing/stream/authorize_test.go b/internal/processing/stream/authorize_test.go
index cb91d5b30..ee0e528af 100644
--- a/internal/processing/stream/authorize_test.go
+++ b/internal/processing/stream/authorize_test.go
@@ -21,8 +21,8 @@ import (
"context"
"testing"
+ "code.superseriousbusiness.org/gotosocial/internal/db"
"github.com/stretchr/testify/suite"
- "github.com/superseriousbusiness/gotosocial/internal/db"
)
type AuthorizeTestSuite struct {
diff --git a/internal/processing/stream/conversation.go b/internal/processing/stream/conversation.go
index a0236c459..b5394ee17 100644
--- a/internal/processing/stream/conversation.go
+++ b/internal/processing/stream/conversation.go
@@ -21,10 +21,10 @@ import (
"context"
"encoding/json"
+ apimodel "code.superseriousbusiness.org/gotosocial/internal/api/model"
+ "code.superseriousbusiness.org/gotosocial/internal/log"
+ "code.superseriousbusiness.org/gotosocial/internal/stream"
"codeberg.org/gruf/go-byteutil"
- apimodel "github.com/superseriousbusiness/gotosocial/internal/api/model"
- "github.com/superseriousbusiness/gotosocial/internal/log"
- "github.com/superseriousbusiness/gotosocial/internal/stream"
)
// Conversation streams the given conversation to any open, appropriate streams belonging to the given account.
diff --git a/internal/processing/stream/delete.go b/internal/processing/stream/delete.go
index 1c61b98d3..fc763f910 100644
--- a/internal/processing/stream/delete.go
+++ b/internal/processing/stream/delete.go
@@ -20,7 +20,7 @@ package stream
import (
"context"
- "github.com/superseriousbusiness/gotosocial/internal/stream"
+ "code.superseriousbusiness.org/gotosocial/internal/stream"
)
// Delete streams the delete of the given statusID to *ALL* open streams.
diff --git a/internal/processing/stream/filterschanged.go b/internal/processing/stream/filterschanged.go
index b98506b9f..dff22c64b 100644
--- a/internal/processing/stream/filterschanged.go
+++ b/internal/processing/stream/filterschanged.go
@@ -20,8 +20,8 @@ package stream
import (
"context"
- "github.com/superseriousbusiness/gotosocial/internal/gtsmodel"
- "github.com/superseriousbusiness/gotosocial/internal/stream"
+ "code.superseriousbusiness.org/gotosocial/internal/gtsmodel"
+ "code.superseriousbusiness.org/gotosocial/internal/stream"
)
// FiltersChanged streams a filters changed event to any open, appropriate streams belonging to the given account.
diff --git a/internal/processing/stream/notification.go b/internal/processing/stream/notification.go
index a16da11e6..ef3acdc79 100644
--- a/internal/processing/stream/notification.go
+++ b/internal/processing/stream/notification.go
@@ -21,11 +21,11 @@ import (
"context"
"encoding/json"
+ apimodel "code.superseriousbusiness.org/gotosocial/internal/api/model"
+ "code.superseriousbusiness.org/gotosocial/internal/gtsmodel"
+ "code.superseriousbusiness.org/gotosocial/internal/log"
+ "code.superseriousbusiness.org/gotosocial/internal/stream"
"codeberg.org/gruf/go-byteutil"
- apimodel "github.com/superseriousbusiness/gotosocial/internal/api/model"
- "github.com/superseriousbusiness/gotosocial/internal/gtsmodel"
- "github.com/superseriousbusiness/gotosocial/internal/log"
- "github.com/superseriousbusiness/gotosocial/internal/stream"
)
// Notify streams the given notification to any open, appropriate streams belonging to the given account.
diff --git a/internal/processing/stream/notification_test.go b/internal/processing/stream/notification_test.go
index 2ede28079..e0874e713 100644
--- a/internal/processing/stream/notification_test.go
+++ b/internal/processing/stream/notification_test.go
@@ -23,9 +23,9 @@ import (
"encoding/json"
"testing"
+ apimodel "code.superseriousbusiness.org/gotosocial/internal/api/model"
+ "code.superseriousbusiness.org/gotosocial/internal/typeutils"
"github.com/stretchr/testify/suite"
- apimodel "github.com/superseriousbusiness/gotosocial/internal/api/model"
- "github.com/superseriousbusiness/gotosocial/internal/typeutils"
)
type NotificationTestSuite struct {
diff --git a/internal/processing/stream/open.go b/internal/processing/stream/open.go
index 2f2bbd4a3..bafa277a5 100644
--- a/internal/processing/stream/open.go
+++ b/internal/processing/stream/open.go
@@ -20,11 +20,11 @@ package stream
import (
"context"
+ "code.superseriousbusiness.org/gotosocial/internal/gtserror"
+ "code.superseriousbusiness.org/gotosocial/internal/gtsmodel"
+ "code.superseriousbusiness.org/gotosocial/internal/log"
+ "code.superseriousbusiness.org/gotosocial/internal/stream"
"codeberg.org/gruf/go-kv"
- "github.com/superseriousbusiness/gotosocial/internal/gtserror"
- "github.com/superseriousbusiness/gotosocial/internal/gtsmodel"
- "github.com/superseriousbusiness/gotosocial/internal/log"
- "github.com/superseriousbusiness/gotosocial/internal/stream"
)
// Open returns a new Stream for the given account, which will contain a channel for passing messages back to the caller.
diff --git a/internal/processing/stream/statusupdate.go b/internal/processing/stream/statusupdate.go
index bd4658873..2f1ca598b 100644
--- a/internal/processing/stream/statusupdate.go
+++ b/internal/processing/stream/statusupdate.go
@@ -21,11 +21,11 @@ import (
"context"
"encoding/json"
+ apimodel "code.superseriousbusiness.org/gotosocial/internal/api/model"
+ "code.superseriousbusiness.org/gotosocial/internal/gtsmodel"
+ "code.superseriousbusiness.org/gotosocial/internal/log"
+ "code.superseriousbusiness.org/gotosocial/internal/stream"
"codeberg.org/gruf/go-byteutil"
- apimodel "github.com/superseriousbusiness/gotosocial/internal/api/model"
- "github.com/superseriousbusiness/gotosocial/internal/gtsmodel"
- "github.com/superseriousbusiness/gotosocial/internal/log"
- "github.com/superseriousbusiness/gotosocial/internal/stream"
)
// StatusUpdate streams the given edited status to any open, appropriate streams belonging to the given account.
diff --git a/internal/processing/stream/statusupdate_test.go b/internal/processing/stream/statusupdate_test.go
index 1f0bcd142..0045cceed 100644
--- a/internal/processing/stream/statusupdate_test.go
+++ b/internal/processing/stream/statusupdate_test.go
@@ -23,10 +23,10 @@ import (
"encoding/json"
"testing"
+ statusfilter "code.superseriousbusiness.org/gotosocial/internal/filter/status"
+ "code.superseriousbusiness.org/gotosocial/internal/stream"
+ "code.superseriousbusiness.org/gotosocial/internal/typeutils"
"github.com/stretchr/testify/suite"
- statusfilter "github.com/superseriousbusiness/gotosocial/internal/filter/status"
- "github.com/superseriousbusiness/gotosocial/internal/stream"
- "github.com/superseriousbusiness/gotosocial/internal/typeutils"
)
type StatusUpdateTestSuite struct {
diff --git a/internal/processing/stream/stream.go b/internal/processing/stream/stream.go
index 0b7285b58..19a82a8a2 100644
--- a/internal/processing/stream/stream.go
+++ b/internal/processing/stream/stream.go
@@ -18,9 +18,9 @@
package stream
import (
- "github.com/superseriousbusiness/gotosocial/internal/oauth"
- "github.com/superseriousbusiness/gotosocial/internal/state"
- "github.com/superseriousbusiness/gotosocial/internal/stream"
+ "code.superseriousbusiness.org/gotosocial/internal/oauth"
+ "code.superseriousbusiness.org/gotosocial/internal/state"
+ "code.superseriousbusiness.org/gotosocial/internal/stream"
)
type Processor struct {
diff --git a/internal/processing/stream/stream_test.go b/internal/processing/stream/stream_test.go
index 3e5bad2b1..47c85af1f 100644
--- a/internal/processing/stream/stream_test.go
+++ b/internal/processing/stream/stream_test.go
@@ -18,14 +18,14 @@
package stream_test
import (
+ "code.superseriousbusiness.org/gotosocial/internal/admin"
+ "code.superseriousbusiness.org/gotosocial/internal/db"
+ "code.superseriousbusiness.org/gotosocial/internal/gtsmodel"
+ "code.superseriousbusiness.org/gotosocial/internal/oauth"
+ "code.superseriousbusiness.org/gotosocial/internal/processing/stream"
+ "code.superseriousbusiness.org/gotosocial/internal/state"
+ "code.superseriousbusiness.org/gotosocial/testrig"
"github.com/stretchr/testify/suite"
- "github.com/superseriousbusiness/gotosocial/internal/admin"
- "github.com/superseriousbusiness/gotosocial/internal/db"
- "github.com/superseriousbusiness/gotosocial/internal/gtsmodel"
- "github.com/superseriousbusiness/gotosocial/internal/oauth"
- "github.com/superseriousbusiness/gotosocial/internal/processing/stream"
- "github.com/superseriousbusiness/gotosocial/internal/state"
- "github.com/superseriousbusiness/gotosocial/testrig"
)
type StreamTestSuite struct {
diff --git a/internal/processing/stream/update.go b/internal/processing/stream/update.go
index a84763d51..f2b064c28 100644
--- a/internal/processing/stream/update.go
+++ b/internal/processing/stream/update.go
@@ -21,11 +21,11 @@ import (
"context"
"encoding/json"
+ apimodel "code.superseriousbusiness.org/gotosocial/internal/api/model"
+ "code.superseriousbusiness.org/gotosocial/internal/gtsmodel"
+ "code.superseriousbusiness.org/gotosocial/internal/log"
+ "code.superseriousbusiness.org/gotosocial/internal/stream"
"codeberg.org/gruf/go-byteutil"
- apimodel "github.com/superseriousbusiness/gotosocial/internal/api/model"
- "github.com/superseriousbusiness/gotosocial/internal/gtsmodel"
- "github.com/superseriousbusiness/gotosocial/internal/log"
- "github.com/superseriousbusiness/gotosocial/internal/stream"
)
// Update streams the given update to any open, appropriate streams belonging to the given account.