summaryrefslogtreecommitdiffstats
path: root/integrations/eventsource_test.go
diff options
context:
space:
mode:
authorKyle D <kdumontnu@gmail.com>2022-09-02 15:18:23 -0400
committerGitHub <noreply@github.com>2022-09-02 15:18:23 -0400
commitc8ded77680db7344c8dc1ccee76bce0b4e02e103 (patch)
treebc63678ef62dc71ce68b29eeaf019c45cdb12034 /integrations/eventsource_test.go
parent5710ff343c9f16119ddbff06044e5d61388baa22 (diff)
downloadgitea-c8ded77680db7344c8dc1ccee76bce0b4e02e103.tar.gz
gitea-c8ded77680db7344c8dc1ccee76bce0b4e02e103.zip
Kd/ci playwright go test (#20123)
* Add initial playwright config * Simplify Makefile * Simplify Makefile * Use correct config files * Update playwright settings * Fix package-lock file * Don't use test logger for e2e tests * fix frontend lint * Allow passing TEST_LOGGER variable * Init postgres database * use standard gitea env variables * Update playwright * update drone * Move empty env var to commands * Cleanup * Move integrations to subfolder * tests integrations to tests integraton * Run e2e tests with go test * Fix linting * install CI deps * Add files to ESlint * Fix drone typo * Don't log to console in CI * Use go test http server * Add build step before tests * Move shared init function to common package * fix drone * Clean up tests * Fix linting * Better mocking for page + version string * Cleanup test generation * Remove dependency on gitea binary * Fix linting * add initial support for running specific tests * Add ACCEPT_VISUAL variable * don't require git-lfs * Add initial documentation * Review feedback * Add logged in session test * Attempt fixing drone race * Cleanup and bump version * Bump deps * Review feedback * simplify installation * Fix ci * Update install docs
Diffstat (limited to 'integrations/eventsource_test.go')
-rw-r--r--integrations/eventsource_test.go82
1 files changed, 0 insertions, 82 deletions
diff --git a/integrations/eventsource_test.go b/integrations/eventsource_test.go
deleted file mode 100644
index 4bb607cde4..0000000000
--- a/integrations/eventsource_test.go
+++ /dev/null
@@ -1,82 +0,0 @@
-// Copyright 2020 The Gitea Authors. All rights reserved.
-// Use of this source code is governed by a MIT-style
-// license that can be found in the LICENSE file.
-
-package integrations
-
-import (
- "fmt"
- "net/http"
- "testing"
- "time"
-
- activities_model "code.gitea.io/gitea/models/activities"
- repo_model "code.gitea.io/gitea/models/repo"
- "code.gitea.io/gitea/models/unittest"
- user_model "code.gitea.io/gitea/models/user"
- "code.gitea.io/gitea/modules/eventsource"
- api "code.gitea.io/gitea/modules/structs"
-
- "github.com/stretchr/testify/assert"
-)
-
-func TestEventSourceManagerRun(t *testing.T) {
- defer prepareTestEnv(t)()
- manager := eventsource.GetManager()
-
- eventChan := manager.Register(2)
- defer func() {
- manager.Unregister(2, eventChan)
- // ensure the eventChan is closed
- for {
- _, ok := <-eventChan
- if !ok {
- break
- }
- }
- }()
- expectNotificationCountEvent := func(count int64) func() bool {
- return func() bool {
- select {
- case event, ok := <-eventChan:
- if !ok {
- return false
- }
- data, ok := event.Data.(activities_model.UserIDCount)
- if !ok {
- return false
- }
- return event.Name == "notification-count" && data.Count == count
- default:
- return false
- }
- }
- }
-
- user2 := unittest.AssertExistsAndLoadBean(t, &user_model.User{ID: 2})
- repo1 := unittest.AssertExistsAndLoadBean(t, &repo_model.Repository{ID: 1})
- thread5 := unittest.AssertExistsAndLoadBean(t, &activities_model.Notification{ID: 5})
- assert.NoError(t, thread5.LoadAttributes())
- session := loginUser(t, user2.Name)
- token := getTokenForLoggedInUser(t, session)
-
- var apiNL []api.NotificationThread
-
- // -- mark notifications as read --
- req := NewRequest(t, "GET", fmt.Sprintf("/api/v1/notifications?status-types=unread&token=%s", token))
- resp := session.MakeRequest(t, req, http.StatusOK)
-
- DecodeJSON(t, resp, &apiNL)
- assert.Len(t, apiNL, 2)
-
- lastReadAt := "2000-01-01T00%3A50%3A01%2B00%3A00" // 946687801 <- only Notification 4 is in this filter ...
- req = NewRequest(t, "PUT", fmt.Sprintf("/api/v1/repos/%s/%s/notifications?last_read_at=%s&token=%s", user2.Name, repo1.Name, lastReadAt, token))
- session.MakeRequest(t, req, http.StatusResetContent)
-
- req = NewRequest(t, "GET", fmt.Sprintf("/api/v1/notifications?token=%s&status-types=unread", token))
- resp = session.MakeRequest(t, req, http.StatusOK)
- DecodeJSON(t, resp, &apiNL)
- assert.Len(t, apiNL, 1)
-
- assert.Eventually(t, expectNotificationCountEvent(1), 30*time.Second, 1*time.Second)
-}