285 lines
11 KiB
Go
285 lines
11 KiB
Go
/*
|
|
* Amsterdam Web Communities System
|
|
* Copyright (c) 2025 Erbosoft Metaverse Design Solutions, All Rights Reserved
|
|
*
|
|
* This Source Code Form is subject to the terms of the Mozilla Public
|
|
* License, v. 2.0. If a copy of the MPL was not distributed with this
|
|
* file, You can obtain one at https://mozilla.org/MPL/2.0/.
|
|
*
|
|
* SPDX-License-Identifier: MPL-2.0
|
|
*/
|
|
|
|
// Package main contains the high-level Amsterdam logic.
|
|
package main
|
|
|
|
// Directive generating the Tailwind CSS file.
|
|
//go:generate tailwindcss -i ui/styles.css -o ui/static/css/tailwind.css
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
"net/http"
|
|
"os"
|
|
"os/signal"
|
|
"syscall"
|
|
"time"
|
|
|
|
"git.erbosoft.com/amy/amsterdam/config"
|
|
"git.erbosoft.com/amy/amsterdam/database"
|
|
"git.erbosoft.com/amy/amsterdam/email"
|
|
"git.erbosoft.com/amy/amsterdam/htmlcheck"
|
|
"git.erbosoft.com/amy/amsterdam/ui"
|
|
"git.erbosoft.com/amy/amsterdam/util"
|
|
"github.com/labstack/echo/v4"
|
|
"github.com/labstack/echo/v4/middleware"
|
|
log "github.com/sirupsen/logrus"
|
|
)
|
|
|
|
// GetAndPost is used to have functions that respond to both GET and POST on a URI.
|
|
var GetAndPost = []string{http.MethodGet, http.MethodPost}
|
|
|
|
// setupEcho creates, configures, and returns a new Echo instance.
|
|
func setupEcho() *echo.Echo {
|
|
e := echo.New()
|
|
e.HideBanner = true
|
|
e.Logger = &EchoLogrusAdapter{}
|
|
e.Renderer = &ui.TemplateRenderer{}
|
|
e.HTTPErrorHandler = AmErrorHandler
|
|
if !config.CommandLine.DebugPanic {
|
|
e.Use(middleware.RecoverWithConfig(middleware.RecoverConfig{
|
|
LogErrorFunc: LogrusPanicLogging,
|
|
}))
|
|
} else {
|
|
log.Warn("WARNING: --debug-panic in effect - DO NOT use this in production!")
|
|
}
|
|
e.Use(LogrusMiddleware)
|
|
|
|
// set up the rate limiter from the configuration
|
|
rateLimiter := AmSetupRateLimiter()
|
|
|
|
// This is the set of all middleware functions used by the UI, as opposed to other things.
|
|
uiset := []echo.MiddlewareFunc{ui.SessionStoreInjector, ui.ContextCreator, rateLimiter, ui.IPBanTest, ui.CookieLoginTest}
|
|
|
|
e.RouteNotFound("/*", ui.AmWrap(AmNotFoundHandler), uiset...)
|
|
fs, err := config.AmOpenExternalContentPath()
|
|
if err != nil {
|
|
panic(err)
|
|
}
|
|
if fs != nil {
|
|
e.StaticFS("/ext", fs)
|
|
e.GET("/fext/*", ui.AmWrap(ui.AmStaticFramePage(fs, "/fext/")), uiset...)
|
|
}
|
|
e.Match(GetAndPost, "/TODO/*", ui.AmWrap(NotImplPage), uiset...)
|
|
e.GET("/img/*", ui.AmServeImage)
|
|
e.GET("/images/*", ui.AmServeImage)
|
|
if config.GlobalConfig.Rendering.VeniceCompatibleImageURLs {
|
|
e.GET("/venice/imagedata/:id", ui.AmServeVeniceCompatibleImage)
|
|
}
|
|
e.GET("/static/*", ui.AmStaticFileHandler())
|
|
e.GET("/go/:postlink", ui.AmWrap(JumpToShortcut), uiset...)
|
|
|
|
e.GET("/", ui.AmWrap(TopPage), uiset...)
|
|
e.GET("/about", ui.AmWrap(AboutPage), uiset...)
|
|
e.GET("/policy", ui.AmWrap(PolicyPage), uiset...)
|
|
e.GET("/login", ui.AmWrap(LoginForm), uiset...)
|
|
e.POST("/login", ui.AmWrap(Login), uiset...)
|
|
e.GET("/logout", ui.AmWrap(Logout), uiset...)
|
|
e.GET("/newacct", ui.AmWrap(NewAccountUserAgreement), uiset...)
|
|
e.GET("/newacct2", ui.AmWrap(NewAccountForm), uiset...)
|
|
e.POST("/newacct2", ui.AmWrap(NewAccount), uiset...)
|
|
e.GET("/verify", ui.AmWrap(VerifyEmailForm), uiset...)
|
|
e.POST("/verify", ui.AmWrap(VerifyEMail), uiset...)
|
|
e.GET("/passrecovery/:uid/:auth", ui.AmWrap(PasswordRecovery), uiset...)
|
|
e.GET("/profile", ui.AmWrap(EditProfileForm), uiset...)
|
|
e.POST("/profile", ui.AmWrap(EditProfile), uiset...)
|
|
e.GET("/profile_photo", ui.AmWrap(ProfilePhotoForm), uiset...)
|
|
e.POST("/profile_photo", ui.AmWrap(ProfilePhoto), uiset...)
|
|
e.GET("/find", ui.AmWrap(FindPage), uiset...)
|
|
e.POST("/find", ui.AmWrap(Find), uiset...)
|
|
e.GET("/user/:uname", ui.AmWrap(ShowProfile), uiset...)
|
|
e.POST("/quick_email", ui.AmWrap(QuickEMail), uiset...)
|
|
e.GET("/hotlist", ui.AmWrap(Hotlist), uiset...)
|
|
e.GET("/sideboxes", ui.AmWrap(ManageSideboxes), uiset...)
|
|
e.POST("/sideboxes", ui.AmWrap(AddSidebox), uiset...)
|
|
e.GET("/create_comm", ui.AmWrap(CreateCommunityForm), uiset...)
|
|
e.POST("/create_comm", ui.AmWrap(CreateCommunity), uiset...)
|
|
e.GET("/manage_comm", ui.AmWrap(ManageCommunities), uiset...)
|
|
e.POST("/attachment_upload", ui.AmWrap(AttachmentUpload), uiset...)
|
|
e.GET("/attachment/:post", ui.AmWrap(AttachmentSend), uiset...)
|
|
e.POST("/__invite_send", ui.AmWrap(InviteSend), uiset...)
|
|
sysGroup := e.Group("/sysadmin", uiset...)
|
|
sysGroup.GET("", ui.AmWrap(SysAdminMenu))
|
|
sysGroup.GET("/globals", ui.AmWrap(GlobalPropertiesForm))
|
|
sysGroup.POST("/globals", ui.AmWrap(GlobalPropertiesSet))
|
|
sysGroup.Match(GetAndPost, "/users", ui.AmWrap(UserManagementSearch))
|
|
sysGroup.GET("/users/:uname", ui.AmWrap(UserManagementForm))
|
|
sysGroup.POST("/users/:uname", ui.AmWrap(UserManagementSave))
|
|
sysGroup.GET("/users/:uname/photo", ui.AmWrap(AdminUserPhotoForm))
|
|
sysGroup.POST("/users/:uname/photo", ui.AmWrap(AdminUserPhoto))
|
|
sysGroup.GET("/ipban", ui.AmWrap(IPBanList))
|
|
sysGroup.GET("/ipban/add", ui.AmWrap(AddIPBanForm))
|
|
sysGroup.POST("/ipban/add", ui.AmWrap(AddIPBan))
|
|
sysGroup.Match(GetAndPost, "/audit", ui.AmWrap(SystemAudit))
|
|
sysGroup.Match(GetAndPost, "/import", ui.AmWrap(UserImport))
|
|
sysGroup.GET("/sysstat", ui.AmWrap(SysStats))
|
|
|
|
// community group
|
|
uiset2 := make([]echo.MiddlewareFunc, len(uiset), len(uiset)+1)
|
|
copy(uiset2, uiset)
|
|
commGroup := e.Group("/comm/:cid", append(uiset2, ui.SetCommunity)...)
|
|
fn := ui.AmWrap(ShowCommunity)
|
|
commGroup.GET("", fn)
|
|
commGroup.GET("/profile", fn)
|
|
commGroup.GET("/join", ui.AmWrap(JoinCommunity))
|
|
commGroup.POST("/join", ui.AmWrap(JoinCommunityWithKey))
|
|
commGroup.GET("/unjoin", ui.AmWrap(UnjoinCommunity("prof")))
|
|
commGroup.GET("/unj", ui.AmWrap(UnjoinCommunity("manage")))
|
|
commGroup.POST("/unjoin", ui.AmWrap(UnjoinCommunityConfirm))
|
|
commGroup.GET("/members", ui.AmWrap(MemberList))
|
|
commGroup.POST("/members", ui.AmWrap(MemberSearch))
|
|
commGroup.GET("/members/export", ui.AmWrap(ExportCommunityMembers))
|
|
commGroup.GET("/invite", ui.AmWrap(InviteToCommunity))
|
|
commGroup.GET("/find", ui.AmWrap(FindPostsPageCommunity))
|
|
commGroup.POST("/find", ui.AmWrap(FindPostsCommunity))
|
|
adminGroup := commGroup.Group("/admin")
|
|
adminGroup.GET("", ui.AmWrap(CommunityAdminMenu))
|
|
adminGroup.GET("/profile", ui.AmWrap(CommunityProfileForm))
|
|
adminGroup.POST("/profile", ui.AmWrap(EditCommunityProfile))
|
|
adminGroup.GET("/logo", ui.AmWrap(CommunityLogoForm))
|
|
adminGroup.POST("/logo", ui.AmWrap(EditCommunityLogo))
|
|
adminGroup.Match(GetAndPost, "/audit", ui.AmWrap(CommunityAudit))
|
|
adminGroup.GET("/category", ui.AmWrap(CommunityCategory))
|
|
adminGroup.Match(GetAndPost, "/members", ui.AmWrap(CommunityMembers))
|
|
adminGroup.GET("/massmail", ui.AmWrap(CommunityEmailForm))
|
|
adminGroup.POST("/massmail", ui.AmWrap(CommunityEmail))
|
|
adminGroup.GET("/delete", ui.AmWrap(DeleteCommunity))
|
|
|
|
// conference group
|
|
commGroup.GET("/create_conf", ui.AmWrap(CreateConferenceForm))
|
|
commGroup.POST("/create_conf", ui.AmWrap(CreateConference))
|
|
commGroup.GET("/manage_conf", ui.AmWrap(ManageConferenceList), ui.ValidateConference)
|
|
commGroup.GET("/manage_conf/del/:confid", ui.AmWrap(ManageDeleteConference), ui.ValidateConference, ui.SetConference)
|
|
commGroup.GET("/conf", ui.AmWrap(Conferences), ui.ValidateConference)
|
|
|
|
confGroup := commGroup.Group("/conf/:confid", ui.ValidateConference, ui.SetConference)
|
|
confGroup.GET("", ui.AmWrap(Topics))
|
|
confGroup.GET("/new_topic", ui.AmWrap(NewTopicForm))
|
|
confGroup.POST("/new_topic", ui.AmWrap(NewTopic))
|
|
confGroup.GET("/find", ui.AmWrap(FindPostsPageConference))
|
|
confGroup.POST("/find", ui.AmWrap(FindPostsConference))
|
|
confGroup.GET("/manage", ui.AmWrap(ConfManage))
|
|
confGroup.POST("/pseud", ui.AmWrap(SetPseud))
|
|
confGroup.GET("/fixseen", ui.AmWrap(ConfFixseen))
|
|
confGroup.GET("/edit", ui.AmWrap(EditConferenceForm))
|
|
confGroup.POST("/edit", ui.AmWrap(EditConference))
|
|
confGroup.GET("/aliases", ui.AmWrap(ConferenceAliasForm))
|
|
confGroup.POST("/aliases", ui.AmWrap(ConferenceAliasAdd))
|
|
confGroup.Match(GetAndPost, "/members", ui.AmWrap(ConferenceMembers))
|
|
confGroup.GET("/custom", ui.AmWrap(ConfCustomForm))
|
|
confGroup.POST("/custom", ui.AmWrap(ConfCustom))
|
|
confGroup.GET("/activity", ui.AmWrap(ConfReports))
|
|
confGroup.GET("/email", ui.AmWrap(ConferenceEmailForm))
|
|
confGroup.POST("/email", ui.AmWrap(ConferenceEmail))
|
|
confGroup.GET("/export", ui.AmWrap(ConferenceExportForm))
|
|
confGroup.POST("/export", ui.AmWrap(ConferenceExport))
|
|
confGroup.Match(GetAndPost, "/import", ui.AmWrap(ConferenceImport))
|
|
confGroup.GET("/delete", ui.AmWrap(DeleteConference))
|
|
confGroup.GET("/hotlist", ui.AmWrap(AddToHotlist))
|
|
confGroup.GET("/invite", ui.AmWrap(InviteToConference))
|
|
confGroup.GET("/r/:topic", ui.AmWrap(ReadPosts), ui.SetTopic)
|
|
confGroup.POST("/r/:topic", ui.AmWrap(PostInTopic), ui.SetTopic)
|
|
|
|
opsGroup := confGroup.Group("/op/:topic", ui.SetTopic)
|
|
opsGroup.GET("/find", ui.AmWrap(FindPostsPageTopic))
|
|
opsGroup.POST("/find", ui.AmWrap(FindPostsTopic))
|
|
opsGroup.GET("/hide", ui.AmWrap(HideTopic))
|
|
opsGroup.GET("/freeze", ui.AmWrap(FreezeTopic))
|
|
opsGroup.GET("/archive", ui.AmWrap(ArchiveTopic))
|
|
opsGroup.GET("/stick", ui.AmWrap(StickTopic))
|
|
opsGroup.GET("/delete", ui.AmWrap(DeleteTopic))
|
|
opsGroup.GET("/hide/:msg", ui.AmWrap(HideMessage))
|
|
opsGroup.GET("/scribble/:msg", ui.AmWrap(ScribbleMessage))
|
|
opsGroup.GET("/nuke/:msg", ui.AmWrap(NukeMessage))
|
|
opsGroup.GET("/prune/:msg", ui.AmWrap(PruneMessageAttachment))
|
|
opsGroup.GET("/publish/:msg", ui.AmWrap(PublishMessage))
|
|
opsGroup.GET("/move/:msg", ui.AmWrap(MoveMessageForm))
|
|
opsGroup.POST("/move/:msg", ui.AmWrap(MoveMessage))
|
|
opsGroup.GET("/manage", ui.AmWrap(TopicManage))
|
|
opsGroup.GET("/subscribe", ui.AmWrap(TopicSetSubscribe))
|
|
opsGroup.GET("/invite", ui.AmWrap(InviteToTopic))
|
|
opsGroup.GET("/rmbozo/:uid", ui.AmWrap(TopicRemoveBozo))
|
|
|
|
return e
|
|
}
|
|
|
|
// ampool is the worker pool for one-shot background tasks.
|
|
var ampool *util.WorkerPool
|
|
|
|
// SystemStartTime records the time since the system was started.
|
|
var SystemStartTime time.Time
|
|
|
|
// main is Ye Olde Main Function.
|
|
func main() {
|
|
SystemStartTime = time.Now()
|
|
// Configure the system.
|
|
config.SetupConfig()
|
|
closer := SetupLogging()
|
|
defer closer()
|
|
closer, err := database.SetupDb()
|
|
if err != nil {
|
|
panic(fmt.Sprintf("Database open failure: %v", err))
|
|
}
|
|
defer closer()
|
|
closer = email.SetupMailSender()
|
|
defer closer()
|
|
htmlcheck.SetupDicts()
|
|
closer = ui.SetupUILayer()
|
|
defer closer()
|
|
|
|
// Determine my IP address and the admin user.
|
|
myIP, err := util.MyIPAddress()
|
|
if err != nil {
|
|
panic(err)
|
|
}
|
|
|
|
// Set up to trap SIGINT/SIGTERM and shut down gracefully
|
|
ctx, stop := signal.NotifyContext(context.Background(), os.Interrupt, syscall.SIGTERM)
|
|
defer stop()
|
|
|
|
// Set up ampool.
|
|
ampool = util.AmNewPool(ctx, config.GlobalConfig.Tuning.WorkerTasks, config.GlobalConfig.Tuning.Queues.WorkerTasks)
|
|
go func() {
|
|
<-ctx.Done()
|
|
ampool.Shutdown()
|
|
}()
|
|
|
|
// Set up Echo.
|
|
e := setupEcho()
|
|
|
|
// Audit the startup
|
|
database.AmStoreAudit(database.AmNewAudit(database.AuditStartup, 0, myIP.String(),
|
|
fmt.Sprintf("version=%s", config.AMSTERDAM_VERSION)))
|
|
defer func() {
|
|
// Audit the shutdown
|
|
database.AmStoreAudit(database.AmNewAudit(database.AuditShutdown, 0, myIP.String()))
|
|
}()
|
|
|
|
stime := time.Since(SystemStartTime)
|
|
log.Infof("Amsterdam %s startup sequence completed in %v", config.AMSTERDAM_VERSION, stime)
|
|
|
|
// Start server
|
|
go func() {
|
|
if err := e.Start(config.GlobalComputedConfig.Listen); err != nil && err != http.ErrServerClosed {
|
|
e.Logger.Fatalf("shutting down the server: %v", err)
|
|
}
|
|
}()
|
|
|
|
// Wait for the interrupt signal and then gracefully shut the server down.
|
|
<-ctx.Done()
|
|
ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
|
|
defer cancel()
|
|
if err := e.Shutdown(ctx); err != nil {
|
|
e.Logger.Fatal(err)
|
|
}
|
|
}
|