summaryrefslogtreecommitdiff
path: root/internal/processing/streaming/streamdelete.go
diff options
context:
space:
mode:
authorLibravatar tobi <31960611+tsmethurst@users.noreply.github.com>2022-04-02 15:40:09 +0200
committerLibravatar GitHub <noreply@github.com>2022-04-02 15:40:09 +0200
commit03d7c75ebf1b81b12ec21f95eef1c07b265ff939 (patch)
tree511724f53946563a3b7ba1307d25f5bda98ac3a8 /internal/processing/streaming/streamdelete.go
parent[documentation] Add third-party packaging to documentation (#443) (diff)
downloadgotosocial-03d7c75ebf1b81b12ec21f95eef1c07b265ff939.tar.xz
[chore] Update Go version to 1.18 (#444)
* linting with new golangci-lint version * update go to 1.18 * bump versions in drone.yml * use new runtime/debug package for version info * remove Commit build flag from goreleaser * remove mock commit + version from build script * go fmt * add dummy version env flag to test container * install git in golang container for testing * only set versionString if Version is defined
Diffstat (limited to 'internal/processing/streaming/streamdelete.go')
-rw-r--r--internal/processing/streaming/streamdelete.go7
1 files changed, 6 insertions, 1 deletions
diff --git a/internal/processing/streaming/streamdelete.go b/internal/processing/streaming/streamdelete.go
index c9c099b46..3d4efb7a7 100644
--- a/internal/processing/streaming/streamdelete.go
+++ b/internal/processing/streaming/streamdelete.go
@@ -31,7 +31,12 @@ func (p *processor) StreamDelete(statusID string) error {
// get all account IDs with open streams
accountIDs := []string{}
p.streamMap.Range(func(k interface{}, _ interface{}) bool {
- accountIDs = append(accountIDs, k.(string))
+ key, ok := k.(string)
+ if !ok {
+ panic("streamMap key was not a string (account id)")
+ }
+
+ accountIDs = append(accountIDs, key)
return true
})