Jonathan Miller
9a5720e8ad
Branch Policy Check / Verify merge target (pull_request) Has been cancelled
Universal: PR Check / Branch Policy (pull_request) Has been cancelled
PR RC Release / Build RC Release (pull_request) Has been cancelled
Universal: PR Check / Validate PR (pull_request) Has been cancelled
Branch Cleanup / Delete merged branch (pull_request) Has been cancelled
Universal: PR Check / Build RC Package (pull_request) Has been cancelled
Full namespace migration: update the Go module path and all import statements from git.mokoconsulting.tech to code.mokoconsulting.tech. Also updates all URL references in templates, workflows, configs, tests, and documentation. Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
78 lines
2.4 KiB
Go
78 lines
2.4 KiB
Go
// Copyright 2020 The Gitea Authors. All rights reserved.
|
|
// SPDX-License-Identifier: MIT
|
|
|
|
package notify
|
|
|
|
import (
|
|
"net/http"
|
|
"strings"
|
|
|
|
activities_model "code.mokoconsulting.tech/MokoConsulting/MokoGitea/models/activities"
|
|
"code.mokoconsulting.tech/MokoConsulting/MokoGitea/models/db"
|
|
api "code.mokoconsulting.tech/MokoConsulting/MokoGitea/modules/structs"
|
|
"code.mokoconsulting.tech/MokoConsulting/MokoGitea/routers/api/v1/utils"
|
|
"code.mokoconsulting.tech/MokoConsulting/MokoGitea/services/context"
|
|
)
|
|
|
|
// NewAvailable check if unread notifications exist
|
|
func NewAvailable(ctx *context.APIContext) {
|
|
// swagger:operation GET /notifications/new notification notifyNewAvailable
|
|
// ---
|
|
// summary: Check if unread notifications exist
|
|
// responses:
|
|
// "200":
|
|
// "$ref": "#/responses/NotificationCount"
|
|
|
|
total, err := db.Count[activities_model.Notification](ctx, activities_model.FindNotificationOptions{
|
|
UserID: ctx.Doer.ID,
|
|
Status: []activities_model.NotificationStatus{activities_model.NotificationStatusUnread},
|
|
})
|
|
if err != nil {
|
|
ctx.APIError(http.StatusUnprocessableEntity, err)
|
|
return
|
|
}
|
|
|
|
ctx.JSON(http.StatusOK, api.NotificationCount{New: total})
|
|
}
|
|
|
|
func getFindNotificationOptions(ctx *context.APIContext) *activities_model.FindNotificationOptions {
|
|
before, since, err := context.GetQueryBeforeSince(ctx.Base)
|
|
if err != nil {
|
|
ctx.APIError(http.StatusUnprocessableEntity, err)
|
|
return nil
|
|
}
|
|
opts := &activities_model.FindNotificationOptions{
|
|
ListOptions: utils.GetListOptions(ctx),
|
|
UserID: ctx.Doer.ID,
|
|
UpdatedBeforeUnix: before,
|
|
UpdatedAfterUnix: since,
|
|
}
|
|
if !ctx.FormBool("all") {
|
|
statuses := ctx.FormStrings("status-types")
|
|
opts.Status = statusStringsToNotificationStatuses(statuses, []string{"unread", "pinned"})
|
|
}
|
|
|
|
subjectTypes := ctx.FormStrings("subject-type")
|
|
if len(subjectTypes) != 0 {
|
|
opts.Source = subjectToSource(subjectTypes)
|
|
}
|
|
|
|
return opts
|
|
}
|
|
|
|
func subjectToSource(value []string) (result []activities_model.NotificationSource) {
|
|
for _, v := range value {
|
|
switch strings.ToLower(v) {
|
|
case "issue":
|
|
result = append(result, activities_model.NotificationSourceIssue)
|
|
case "pull":
|
|
result = append(result, activities_model.NotificationSourcePullRequest)
|
|
case "commit":
|
|
result = append(result, activities_model.NotificationSourceCommit)
|
|
case "repository":
|
|
result = append(result, activities_model.NotificationSourceRepository)
|
|
}
|
|
}
|
|
return result
|
|
}
|