mirror of
https://github.com/hanzoai/team.git
synced 2026-09-30 01:57:35 +00:00
zeekay
8feb24ea1f
The server module named github.com/hanzoai/team/server/v8 — a path that resolves to the retired workspace's repository, not this one — while server/public still published github.com/mattermost/mattermost/server/public. Both are github.com/hanzoteam/server/... now, which is where this code actually lives. That second half is what made the binary unbootable. Upstream's public path stayed claimed by upstream, mattermost-plugin-ai imported it, and the build linked public/model twice; public/plugin's gob.Register then ran twice under one name and panicked at init, before main. Reverting the rename traded the brand for a working binary. Rebranding the plugin alongside it needs no such trade: the agents fork is github.com/hanzoteam/agents/v2 against our public module, so no module named mattermost/mattermost is in the graph at all. Measured: `go list -deps ./cmd/mattermost` names exactly one public/model, and it is ours.
157 lines
4.3 KiB
Go
157 lines
4.3 KiB
Go
// Copyright (c) 2015-present Mattermost, Inc. All Rights Reserved.
|
|
// See LICENSE.txt for license information.
|
|
|
|
package app
|
|
|
|
import (
|
|
"fmt"
|
|
"net/http"
|
|
"strconv"
|
|
"time"
|
|
|
|
"github.com/hanzoteam/server/server/public/model"
|
|
"github.com/hanzoteam/server/server/public/shared/httpservice"
|
|
"github.com/hanzoteam/server/server/public/shared/mlog"
|
|
"github.com/hanzoteam/server/server/public/shared/timezones"
|
|
"github.com/hanzoteam/server/server/v8/einterfaces"
|
|
"github.com/hanzoteam/server/server/v8/platform/services/imageproxy"
|
|
"github.com/hanzoteam/server/server/v8/platform/services/searchengine"
|
|
"github.com/hanzoteam/server/server/v8/platform/shared/templates"
|
|
)
|
|
|
|
// App is a pure functional component that does not have any fields, except Server.
|
|
// It is a request-scoped struct constructed every time a request hits the server,
|
|
// and its only purpose is to provide business logic to Server via its methods.
|
|
type App struct {
|
|
ch *Channels
|
|
}
|
|
|
|
func New(options ...AppOption) *App {
|
|
app := &App{}
|
|
|
|
for _, option := range options {
|
|
option(app)
|
|
}
|
|
|
|
return app
|
|
}
|
|
|
|
func (a *App) ServerId() string {
|
|
return a.Srv().ServerId()
|
|
}
|
|
|
|
func (s *Server) TemplatesContainer() *templates.Container {
|
|
return s.htmlTemplates
|
|
}
|
|
|
|
func (s *Server) getFirstServerRunTimestamp() (int64, *model.AppError) {
|
|
systemData, err := s.Store().System().GetByName(model.SystemFirstServerRunTimestampKey)
|
|
if err != nil {
|
|
return 0, model.NewAppError("getFirstServerRunTimestamp", "app.system.get_by_name.app_error", nil, "", http.StatusInternalServerError).Wrap(err)
|
|
}
|
|
value, err := strconv.ParseInt(systemData.Value, 10, 64)
|
|
if err != nil {
|
|
return 0, model.NewAppError("getFirstServerRunTimestamp", "app.system_install_date.parse_int.app_error", nil, "", http.StatusInternalServerError).Wrap(err)
|
|
}
|
|
return value, nil
|
|
}
|
|
|
|
func (a *App) Channels() *Channels {
|
|
return a.ch
|
|
}
|
|
func (a *App) Srv() *Server {
|
|
return a.ch.srv
|
|
}
|
|
func (a *App) Log() *mlog.Logger {
|
|
return a.ch.srv.Log()
|
|
}
|
|
|
|
func (a *App) AccountMigration() einterfaces.AccountMigrationInterface {
|
|
return a.ch.AccountMigration
|
|
}
|
|
func (a *App) Cluster() einterfaces.ClusterInterface {
|
|
return a.ch.srv.platform.Cluster()
|
|
}
|
|
func (a *App) Compliance() einterfaces.ComplianceInterface {
|
|
return a.ch.Compliance
|
|
}
|
|
func (a *App) DataRetention() einterfaces.DataRetentionInterface {
|
|
return a.ch.DataRetention
|
|
}
|
|
func (a *App) SearchEngine() *searchengine.Broker {
|
|
return a.ch.srv.platform.SearchEngine
|
|
}
|
|
func (a *App) Ldap() einterfaces.LdapInterface {
|
|
return a.ch.Ldap
|
|
}
|
|
func (a *App) LdapDiagnostic() einterfaces.LdapDiagnosticInterface {
|
|
return a.ch.srv.platform.LdapDiagnostic()
|
|
}
|
|
func (a *App) MessageExport() einterfaces.MessageExportInterface {
|
|
return a.ch.MessageExport
|
|
}
|
|
func (a *App) Metrics() einterfaces.MetricsInterface {
|
|
return a.ch.srv.GetMetrics()
|
|
}
|
|
func (a *App) Notification() einterfaces.NotificationInterface {
|
|
return a.ch.Notification
|
|
}
|
|
func (a *App) AutoTranslation() einterfaces.AutoTranslationInterface {
|
|
return a.Srv().AutoTranslation
|
|
}
|
|
func (a *App) Saml() einterfaces.SamlInterface {
|
|
return a.ch.Saml
|
|
}
|
|
func (a *App) Intune() einterfaces.IntuneInterface {
|
|
return a.ch.Intune
|
|
}
|
|
func (a *App) OutgoingOAuthConnections() einterfaces.OutgoingOAuthConnectionInterface {
|
|
return a.ch.srv.OutgoingOAuthConnection
|
|
}
|
|
func (a *App) HTTPService() httpservice.HTTPService {
|
|
return a.ch.srv.httpService
|
|
}
|
|
func (a *App) ImageProxy() *imageproxy.ImageProxy {
|
|
return a.ch.imageProxy
|
|
}
|
|
func (a *App) Timezones() *timezones.Timezones {
|
|
return a.ch.srv.timezones
|
|
}
|
|
func (a *App) License() *model.License {
|
|
return a.Srv().License()
|
|
}
|
|
|
|
func (a *App) DBHealthCheckWrite() error {
|
|
currentTime := strconv.FormatInt(time.Now().Unix(), 10)
|
|
|
|
return a.Srv().Store().System().SaveOrUpdate(&model.System{
|
|
Name: a.dbHealthCheckKey(),
|
|
Value: currentTime,
|
|
})
|
|
}
|
|
|
|
func (a *App) DBHealthCheckDelete() error {
|
|
_, err := a.Srv().Store().System().PermanentDeleteByName(a.dbHealthCheckKey())
|
|
return err
|
|
}
|
|
|
|
func (a *App) dbHealthCheckKey() string {
|
|
return fmt.Sprintf("health_check_%s", a.GetClusterId())
|
|
}
|
|
|
|
func (a *App) CheckIntegrity() <-chan model.IntegrityCheckResult {
|
|
return a.Srv().Store().CheckIntegrity()
|
|
}
|
|
|
|
func (a *App) SetChannels(ch *Channels) {
|
|
a.ch = ch
|
|
}
|
|
|
|
func (a *App) SetServer(srv *Server) {
|
|
a.ch.srv = srv
|
|
}
|
|
|
|
func (a *App) UpdateExpiredDNDStatuses() ([]*model.Status, error) {
|
|
return a.Srv().Store().Status().UpdateExpiredDNDStatuses()
|
|
}
|