Compare commits
54 Commits
v0.1.0
...
f5c1a5e8d0
Author | SHA1 | Date | |
---|---|---|---|
f5c1a5e8d0 | |||
40d1104a66 | |||
736673c33f | |||
1a2e18359c | |||
d1d3a81565 | |||
bc2302d31f | |||
1b02e3fad2 | |||
dc06a6e9aa | |||
63370ada01 | |||
5145e1cd94 | |||
28eb7e236a | |||
4a7883f886 | |||
b69a0688ef | |||
0e18c7a7db | |||
3ab9a8fe10 | |||
6dfd49a5cd | |||
5455bdb12b | |||
9eaafdc712 | |||
d127be4c93 | |||
34832e397f | |||
2c0b4878f4 | |||
f0e078c011 | |||
a8fc28af36 | |||
e4f085f762 | |||
6136f83dfc | |||
21170c9cc2 | |||
6502aa7ec1 | |||
e5bdc235b6 | |||
655992c8b2 | |||
aa7fcd6075 | |||
f9cc90a948 | |||
7f2433c30b | |||
f34efc95dd | |||
935d0a1ca4 | |||
48d4d482b2 | |||
8dae3ca21e | |||
6f02852212 | |||
4cc2110c4b | |||
04cbee097c | |||
93423ae606 | |||
41113b24a8 | |||
2247f316a3 | |||
9beedf9b2b | |||
7d6f96a185 | |||
8d47146a7c | |||
4853184ba1 | |||
50895249df | |||
6e91253908 | |||
9bb6010319 | |||
75a0af055c | |||
171a0dd250 | |||
372882a252 | |||
2d0b53a254 | |||
2447f50bac |
4
LICENSE
4
LICENSE
@ -209,7 +209,7 @@ If you develop a new program, and you want it to be of the greatest possible use
|
||||
To do so, attach the following notices to the program. It is safest to attach them to the start of each source file to most effectively state the exclusion of warranty; and each file should have at least the “copyright” line and a pointer to where the full notice is found.
|
||||
|
||||
cpolis
|
||||
Copyright (C) 2024 Jason Streifling
|
||||
Copyright (C) 2024 jason
|
||||
|
||||
This program is free software: you can redistribute it and/or modify it under the terms of the GNU General Public License as published by the Free Software Foundation, either version 3 of the License, or (at your option) any later version.
|
||||
|
||||
@ -221,7 +221,7 @@ Also add information on how to contact you by electronic and paper mail.
|
||||
|
||||
If the program does terminal interaction, make it output a short notice like this when it starts in an interactive mode:
|
||||
|
||||
cpolis Copyright (C) 2024 Jason Streifling
|
||||
cpolis Copyright (C) 2024 jason
|
||||
This program comes with ABSOLUTELY NO WARRANTY; for details type `show w'.
|
||||
This is free software, and you are welcome to redistribute it under certain conditions; type `show c' for details.
|
||||
|
||||
|
@ -1,46 +0,0 @@
|
||||
package control
|
||||
|
||||
import (
|
||||
"flag"
|
||||
"fmt"
|
||||
"path/filepath"
|
||||
)
|
||||
|
||||
type CliArgs struct {
|
||||
DBName string
|
||||
KeyFile string
|
||||
LogFile string
|
||||
PicsDir string
|
||||
WebDir string
|
||||
}
|
||||
|
||||
func HandleCliArgs() (*CliArgs, error) {
|
||||
var err error
|
||||
cliArgs := new(CliArgs)
|
||||
|
||||
keyFile := flag.String("key", "/var/www/cpolis.key", "key file")
|
||||
logFile := flag.String("log", "/var/log/cpolis.log", "log file")
|
||||
picsDir := flag.String("pics", "/var/www/cpolis/pics", "pictures directory")
|
||||
webDir := flag.String("web", "/var/www/cpolis/web", "web directory")
|
||||
flag.StringVar(&cliArgs.DBName, "db", "cpolis", "DB name")
|
||||
flag.Parse()
|
||||
|
||||
cliArgs.KeyFile, err = filepath.Abs(*keyFile)
|
||||
if err != nil {
|
||||
return nil, fmt.Errorf("error finding absolute path for KeyFile: %v", err)
|
||||
}
|
||||
cliArgs.LogFile, err = filepath.Abs(*logFile)
|
||||
if err != nil {
|
||||
return nil, fmt.Errorf("error finding absolute path for LogFile: %v", err)
|
||||
}
|
||||
cliArgs.PicsDir, err = filepath.Abs(*picsDir)
|
||||
if err != nil {
|
||||
return nil, fmt.Errorf("error finding absolute path for PicsDir: %v", err)
|
||||
}
|
||||
cliArgs.WebDir, err = filepath.Abs(*webDir)
|
||||
if err != nil {
|
||||
return nil, fmt.Errorf("error finding absolute path for WebDir: %v", err)
|
||||
}
|
||||
|
||||
return cliArgs, nil
|
||||
}
|
@ -2,8 +2,6 @@ package control
|
||||
|
||||
import (
|
||||
"fmt"
|
||||
"io"
|
||||
"os"
|
||||
"time"
|
||||
|
||||
"git.streifling.com/jason/rss"
|
||||
@ -50,82 +48,3 @@ func GetChannel(db *model.DB, title, link, description string) (*rss.Channel, er
|
||||
|
||||
return channel, nil
|
||||
}
|
||||
|
||||
func GenerateRSS(db *model.DB, title, link, desc string) (*string, error) {
|
||||
channel := &rss.Channel{
|
||||
Title: title,
|
||||
Link: link,
|
||||
Description: desc,
|
||||
Items: make([]*rss.Item, 0),
|
||||
}
|
||||
|
||||
articles, err := db.GetCertainArticles(true, false)
|
||||
if err != nil {
|
||||
return nil, fmt.Errorf("error getting published articles for RSS feed: %v", err)
|
||||
}
|
||||
|
||||
for _, article := range articles {
|
||||
tags, err := db.GetArticleTags(article.ID)
|
||||
if err != nil {
|
||||
return nil, fmt.Errorf("error getting tags for articles for RSS feed: %v", err)
|
||||
}
|
||||
tagNames := make([]string, 0)
|
||||
for _, tag := range tags {
|
||||
tagNames = append(tagNames, tag.Name)
|
||||
}
|
||||
tagNames = append(tagNames, fmt.Sprint("Orient Express ", article.IssueID))
|
||||
|
||||
user, err := db.GetUser(article.AuthorID)
|
||||
if err != nil {
|
||||
return nil, fmt.Errorf("error getting user user info for RSS feed: %v", err)
|
||||
}
|
||||
|
||||
articleTitle, err := ConvertToPlain(article.Title)
|
||||
if err != nil {
|
||||
return nil, fmt.Errorf("error converting title to plain text for RSS feed: %v", err)
|
||||
}
|
||||
|
||||
articleDescription, err := ConvertToPlain(article.Description)
|
||||
if err != nil {
|
||||
return nil, fmt.Errorf("error converting description to plain text for RSS feed: %v", err)
|
||||
}
|
||||
|
||||
articleContent, err := ConvertToHTML(article.Content)
|
||||
if err != nil {
|
||||
return nil, fmt.Errorf("error converting content to HTML for RSS feed: %v", err)
|
||||
}
|
||||
|
||||
channel.Items = append(channel.Items, &rss.Item{
|
||||
Title: articleTitle,
|
||||
Author: user.FirstName + user.LastName,
|
||||
PubDate: article.Created.Format(time.RFC1123Z),
|
||||
Description: articleDescription,
|
||||
Content: &rss.Content{Value: articleContent},
|
||||
Categories: tagNames,
|
||||
})
|
||||
}
|
||||
|
||||
feed := rss.NewFeed()
|
||||
feed.Channels = append(feed.Channels, channel)
|
||||
rss, err := feed.ToXML()
|
||||
if err != nil {
|
||||
return nil, fmt.Errorf("error converting RSS feed to XML: %v", err)
|
||||
}
|
||||
|
||||
return &rss, nil
|
||||
}
|
||||
|
||||
func SaveRSS(filename string, feed *string) error {
|
||||
file, err := os.Create(filename)
|
||||
if err != nil {
|
||||
return fmt.Errorf("error creating file for RSS feed: %v", err)
|
||||
}
|
||||
defer file.Close()
|
||||
file.Chmod(0644)
|
||||
|
||||
if _, err = io.WriteString(file, *feed); err != nil {
|
||||
return fmt.Errorf("error writing to RSS file: %v", err)
|
||||
}
|
||||
|
||||
return nil
|
||||
}
|
||||
|
61
cmd/main.go
61
cmd/main.go
@ -16,67 +16,60 @@ func init() {
|
||||
}
|
||||
|
||||
func main() {
|
||||
args, err := control.HandleCliArgs()
|
||||
if err != nil {
|
||||
log.Fatalln(err)
|
||||
}
|
||||
|
||||
logFile, err := os.OpenFile(args.LogFile, os.O_WRONLY|os.O_CREATE|os.O_APPEND, 0644)
|
||||
logFile, err := os.OpenFile("tmp/cpolis.log",
|
||||
os.O_WRONLY|os.O_CREATE|os.O_APPEND, 0644)
|
||||
if err != nil {
|
||||
log.Fatalln(err)
|
||||
}
|
||||
defer logFile.Close()
|
||||
log.SetOutput(logFile)
|
||||
// log.SetOutput(logFile)
|
||||
|
||||
db, err := model.OpenDB(args.DBName)
|
||||
db, err := model.OpenDB("cpolis")
|
||||
if err != nil {
|
||||
log.Fatalln(err)
|
||||
}
|
||||
defer db.Close()
|
||||
|
||||
key, err := control.LoadKey(args.KeyFile)
|
||||
key, err := control.LoadKey("tmp/key.gob")
|
||||
if err != nil {
|
||||
key, err = control.NewKey()
|
||||
if err != nil {
|
||||
log.Fatalln(err)
|
||||
}
|
||||
control.SaveKey(key, args.KeyFile)
|
||||
control.SaveKey(key, "tmp/key.gob")
|
||||
}
|
||||
store := control.NewCookieStore(key)
|
||||
|
||||
mux := http.NewServeMux()
|
||||
mux.Handle("/web/static/", http.StripPrefix("/web/static/",
|
||||
http.FileServer(http.Dir(args.WebDir+"/static/"))))
|
||||
mux.HandleFunc("/", view.HomePage(args, db, store))
|
||||
http.FileServer(http.Dir("web/static/"))))
|
||||
mux.HandleFunc("/", view.HomePage(db, store))
|
||||
|
||||
mux.HandleFunc("GET /create-tag/", view.CreateTag(args))
|
||||
mux.HandleFunc("GET /create-user/", view.CreateUser(args))
|
||||
mux.HandleFunc("GET /edit-user/", view.EditUser(args, db, store))
|
||||
mux.HandleFunc("GET /hub/", view.ShowHub(args, db, store))
|
||||
mux.HandleFunc("GET /logout/", view.Logout(args, store))
|
||||
mux.HandleFunc("GET /publish-issue/", view.PublishLatestIssue(args, db, store))
|
||||
mux.HandleFunc("GET /rejected-articles/", view.ShowRejectedArticles(args, db, store))
|
||||
mux.HandleFunc("GET /rss/", view.ShowRSS(args,
|
||||
mux.HandleFunc("GET /create-tag/", view.CreateTag)
|
||||
mux.HandleFunc("GET /create-user/", view.CreateUser)
|
||||
mux.HandleFunc("GET /edit-user/", view.EditUser(db, store))
|
||||
mux.HandleFunc("GET /hub/", view.ShowHub(db, store))
|
||||
mux.HandleFunc("GET /logout/", view.Logout(store))
|
||||
mux.HandleFunc("GET /rejected-articles/", view.ShowRejectedArticles(db, store))
|
||||
mux.HandleFunc("GET /rss/", view.ShowRSS(
|
||||
db,
|
||||
"Freimaurer Distrikt Niedersachsen und Sachsen-Anhalt",
|
||||
"https://distrikt-ni-st.de",
|
||||
"Freiheit, Gleichheit, Brüderlichkeit, Toleranz und Humanität",
|
||||
))
|
||||
mux.HandleFunc("GET /this-issue/", view.ShowCurrentArticles(args, db))
|
||||
mux.HandleFunc("GET /unpublished-articles/", view.ShowUnpublishedArticles(args, db))
|
||||
mux.HandleFunc("GET /write-article/", view.WriteArticle(args, db))
|
||||
mux.HandleFunc("GET /unpublished-articles/", view.ShowUnpublishedArticles(db))
|
||||
mux.HandleFunc("GET /write-article/", view.WriteArticle(db))
|
||||
|
||||
mux.HandleFunc("POST /add-tag/", view.AddTag(args, db, store))
|
||||
mux.HandleFunc("POST /add-user/", view.AddUser(args, db, store))
|
||||
mux.HandleFunc("POST /login/", view.Login(args, db, store))
|
||||
mux.HandleFunc("POST /publish-article/", view.PublishArticle(args, db, store))
|
||||
mux.HandleFunc("POST /reject-article/", view.RejectArticle(args, db, store))
|
||||
mux.HandleFunc("POST /resubmit-article/", view.ResubmitArticle(args, db, store))
|
||||
mux.HandleFunc("POST /review-rejected-article/", view.ReviewRejectedArticle(args, db, store))
|
||||
mux.HandleFunc("POST /review-unpublished-article/", view.ReviewUnpublishedArticle(args, db, store))
|
||||
mux.HandleFunc("POST /submit-article/", view.SubmitArticle(args, db, store))
|
||||
mux.HandleFunc("POST /update-user/", view.UpdateUser(args, db, store))
|
||||
mux.HandleFunc("POST /upload-image/", view.UploadImage(args))
|
||||
mux.HandleFunc("POST /add-tag/", view.AddTag(db, store))
|
||||
mux.HandleFunc("POST /add-user/", view.AddUser(db, store))
|
||||
mux.HandleFunc("POST /login/", view.Login(db, store))
|
||||
mux.HandleFunc("POST /publish-article/", view.PublishArticle(db, store))
|
||||
mux.HandleFunc("POST /reject-article/", view.RejectArticle(db, store))
|
||||
mux.HandleFunc("POST /resubmit-article/", view.ResubmitArticle(db, store))
|
||||
mux.HandleFunc("POST /review-rejected-article/", view.ReviewRejectedArticle(db, store))
|
||||
mux.HandleFunc("POST /review-unpublished-article/", view.ReviewUnpublishedArticle(db, store))
|
||||
mux.HandleFunc("POST /submit-article/", view.SubmitArticle(db, store))
|
||||
mux.HandleFunc("POST /update-user/", view.UpdateUser(db, store))
|
||||
|
||||
log.Fatalln(http.ListenAndServe(":8080", mux))
|
||||
}
|
||||
|
@ -1,10 +1,7 @@
|
||||
package model
|
||||
|
||||
import (
|
||||
"context"
|
||||
"database/sql"
|
||||
"fmt"
|
||||
"log"
|
||||
"time"
|
||||
)
|
||||
|
||||
@ -17,64 +14,26 @@ type Article struct {
|
||||
Rejected bool
|
||||
ID int64
|
||||
AuthorID int64
|
||||
IssueID int64
|
||||
}
|
||||
|
||||
func (db *DB) AddArticle(a *Article) (int64, error) {
|
||||
var id int64
|
||||
txOptions := &sql.TxOptions{Isolation: sql.LevelSerializable}
|
||||
selectQuery := "SELECT id FROM issues WHERE published = false"
|
||||
insertQuery := `
|
||||
query := `
|
||||
INSERT INTO articles
|
||||
(title, description, content, published, rejected, author_id, issue_id)
|
||||
VALUES (?, ?, ?, ?, ?, ?, ?)
|
||||
(title, description, content, published, rejected, author_id)
|
||||
VALUES (?, ?, ?, ?, ?, ?)
|
||||
`
|
||||
|
||||
for i := 0; i < TxMaxRetries; i++ {
|
||||
id, err := func() (int64, error) {
|
||||
tx, err := db.BeginTx(context.Background(), txOptions)
|
||||
if err != nil {
|
||||
return 0, fmt.Errorf("error starting transaction: %v", err)
|
||||
}
|
||||
|
||||
if err = tx.QueryRow(selectQuery).Scan(&id); err != nil {
|
||||
if rollbackErr := tx.Rollback(); rollbackErr != nil {
|
||||
log.Fatalf("transaction error: %v, rollback error: %v", err, rollbackErr)
|
||||
}
|
||||
return 0, fmt.Errorf("error getting issue ID when adding article to DB: %v", err)
|
||||
}
|
||||
|
||||
result, err := tx.Exec(insertQuery, a.Title, a.Description,
|
||||
a.Content, a.Published, a.Rejected, a.AuthorID, id)
|
||||
if err != nil {
|
||||
if rollbackErr := tx.Rollback(); rollbackErr != nil {
|
||||
log.Fatalf("transaction error: %v, rollback error: %v", err, rollbackErr)
|
||||
}
|
||||
return 0, fmt.Errorf("error inserting article into DB: %v", err)
|
||||
}
|
||||
|
||||
id, err := result.LastInsertId()
|
||||
if err != nil {
|
||||
if rollbackErr := tx.Rollback(); rollbackErr != nil {
|
||||
log.Fatalf("transaction error: %v, rollback error: %v", err, rollbackErr)
|
||||
}
|
||||
return 0, fmt.Errorf("error retrieving ID of added article: %v", err)
|
||||
}
|
||||
|
||||
if err = tx.Commit(); err != nil {
|
||||
return 0, fmt.Errorf("error committing transaction when adding article to DB: %v", err)
|
||||
}
|
||||
return id, nil
|
||||
}()
|
||||
if err == nil {
|
||||
return id, nil
|
||||
}
|
||||
|
||||
log.Println(err)
|
||||
wait(i)
|
||||
result, err := db.Exec(query, a.Title, a.Description, a.Content,
|
||||
a.Published, a.Rejected, a.AuthorID)
|
||||
if err != nil {
|
||||
return 0, fmt.Errorf("error inserting article into DB: %v", err)
|
||||
}
|
||||
id, err := result.LastInsertId()
|
||||
if err != nil {
|
||||
return 0, fmt.Errorf("error retrieving last ID: %v", err)
|
||||
}
|
||||
|
||||
return 0, fmt.Errorf("error: %v unsuccessful retries for DB operation, aborting", TxMaxRetries)
|
||||
return id, nil
|
||||
}
|
||||
|
||||
func (db *DB) GetArticle(id int64) (*Article, error) {
|
||||
@ -105,7 +64,7 @@ func (db *DB) GetArticle(id int64) (*Article, error) {
|
||||
|
||||
func (db *DB) GetCertainArticles(published, rejected bool) ([]*Article, error) {
|
||||
query := `
|
||||
SELECT id, title, created, description, content, author_id, issue_id
|
||||
SELECT id, title, created, description, content, author_id
|
||||
FROM articles
|
||||
WHERE published = ?
|
||||
AND rejected = ?
|
||||
@ -120,9 +79,8 @@ func (db *DB) GetCertainArticles(published, rejected bool) ([]*Article, error) {
|
||||
article := new(Article)
|
||||
var created []byte
|
||||
|
||||
if err = rows.Scan(&article.ID, &article.Title, &created,
|
||||
&article.Description, &article.Content, &article.AuthorID,
|
||||
&article.IssueID); err != nil {
|
||||
if err = rows.Scan(&article.ID, &article.Title, &created, &article.Description,
|
||||
&article.Content, &article.AuthorID); err != nil {
|
||||
return nil, fmt.Errorf("error scanning article row: %v", err)
|
||||
}
|
||||
|
||||
@ -137,122 +95,3 @@ func (db *DB) GetCertainArticles(published, rejected bool) ([]*Article, error) {
|
||||
|
||||
return articleList, nil
|
||||
}
|
||||
|
||||
func (db *DB) GetCurrentIssueArticles() ([]*Article, error) {
|
||||
var issueID int64
|
||||
txOptions := &sql.TxOptions{Isolation: sql.LevelSerializable}
|
||||
issueQuery := "SELECT id FROM issues WHERE published = false"
|
||||
articlesQuery := `
|
||||
SELECT id, title, created, description, content, author_id
|
||||
FROM articles
|
||||
WHERE issue_id = ? AND published = true
|
||||
`
|
||||
|
||||
for i := 0; i < TxMaxRetries; i++ {
|
||||
id, err := func() ([]*Article, error) {
|
||||
tx, err := db.BeginTx(context.Background(), txOptions)
|
||||
if err != nil {
|
||||
return nil, fmt.Errorf("error starting transaction: %v", err)
|
||||
}
|
||||
|
||||
row := tx.QueryRow(issueQuery)
|
||||
if err := row.Scan(&issueID); err != nil {
|
||||
if rollbackErr := tx.Rollback(); rollbackErr != nil {
|
||||
log.Fatalf("transaction error: %v, rollback error: %v", err, rollbackErr)
|
||||
}
|
||||
return nil, fmt.Errorf("error querying DB for unpublished issue: %v", err)
|
||||
}
|
||||
|
||||
rows, err := tx.Query(articlesQuery, issueID)
|
||||
if err != nil {
|
||||
if rollbackErr := tx.Rollback(); rollbackErr != nil {
|
||||
log.Fatalf("transaction error: %v, rollback error: %v", err, rollbackErr)
|
||||
}
|
||||
return nil, fmt.Errorf("error querying DB for articles of issue %v: %v", issueID, err)
|
||||
}
|
||||
|
||||
articleList := make([]*Article, 0)
|
||||
for rows.Next() {
|
||||
article := new(Article)
|
||||
var created []byte
|
||||
|
||||
if err = rows.Scan(&article.ID, &article.Title, &created,
|
||||
&article.Description, &article.Content, &article.AuthorID); err != nil {
|
||||
if rollbackErr := tx.Rollback(); rollbackErr != nil {
|
||||
log.Fatalf("transaction error: %v, rollback error: %v", err, rollbackErr)
|
||||
}
|
||||
return nil, fmt.Errorf("error scanning article from issue %v: %v", issueID, err)
|
||||
}
|
||||
|
||||
article.Created, err = time.Parse("2006-01-02 15:04:05", string(created))
|
||||
if err != nil {
|
||||
if rollbackErr := tx.Rollback(); rollbackErr != nil {
|
||||
log.Fatalf("transaction error: %v, rollback error: %v", err, rollbackErr)
|
||||
}
|
||||
return nil, fmt.Errorf("error parsing created: %v", err)
|
||||
}
|
||||
|
||||
articleList = append(articleList, article)
|
||||
}
|
||||
|
||||
if err = tx.Commit(); err != nil {
|
||||
return nil, fmt.Errorf("error committing transaction when getting articles of issue %v: %v", issueID, err)
|
||||
}
|
||||
|
||||
return articleList, nil
|
||||
}()
|
||||
if err == nil {
|
||||
return id, nil
|
||||
}
|
||||
|
||||
log.Println(err)
|
||||
wait(i)
|
||||
}
|
||||
|
||||
return nil, fmt.Errorf("error: %v unsuccessful retries for DB operation, aborting", TxMaxRetries)
|
||||
}
|
||||
|
||||
func (db *DB) AddArticleToCurrentIssue(id int64) error {
|
||||
var issueID int64
|
||||
txOptions := &sql.TxOptions{Isolation: sql.LevelSerializable}
|
||||
selectQuery := "SELECT id FROM issues WHERE published = false"
|
||||
updateQuery := "UPDATE articles SET issue_id = ? WHERE id = ?"
|
||||
|
||||
for i := 0; i < TxMaxRetries; i++ {
|
||||
err := func() error {
|
||||
tx, err := db.BeginTx(context.Background(), txOptions)
|
||||
if err != nil {
|
||||
return fmt.Errorf("error starting transaction: %v", err)
|
||||
}
|
||||
|
||||
if err = tx.QueryRow(selectQuery).Scan(&issueID); err != nil {
|
||||
if rollbackErr := tx.Rollback(); rollbackErr != nil {
|
||||
log.Fatalf("transaction error: %v, rollback error: %v", err, rollbackErr)
|
||||
}
|
||||
return fmt.Errorf("error scanning row: %v", err)
|
||||
}
|
||||
|
||||
_, err = db.Exec(updateQuery, issueID, id)
|
||||
if err != nil {
|
||||
if rollbackErr := tx.Rollback(); rollbackErr != nil {
|
||||
log.Fatalf("transaction error: %v, rollback error: %v", err, rollbackErr)
|
||||
}
|
||||
return fmt.Errorf("error updating issueID for article: %v", err)
|
||||
}
|
||||
|
||||
if err = tx.Commit(); err != nil {
|
||||
return fmt.Errorf("error committing transaction when getting articles of issue %v: %v", issueID, err)
|
||||
}
|
||||
|
||||
return nil
|
||||
}()
|
||||
if err == nil {
|
||||
return nil
|
||||
}
|
||||
|
||||
log.Println(err)
|
||||
wait(i)
|
||||
}
|
||||
|
||||
return fmt.Errorf("error: %v unsuccessful retries for DB operation, aborting", TxMaxRetries)
|
||||
}
|
||||
|
@ -3,11 +3,12 @@ package model
|
||||
import (
|
||||
"fmt"
|
||||
"log"
|
||||
"math"
|
||||
"math/rand/v2"
|
||||
"time"
|
||||
)
|
||||
|
||||
func (db *DB) WriteArticleTags(articleID int64, tagIDs []int64) error {
|
||||
query := "INSERT INTO articles_tags (article_id, tag_id) VALUES (?, ?)"
|
||||
|
||||
for i := 0; i < TxMaxRetries; i++ {
|
||||
err := func() error {
|
||||
tx, err := db.Begin()
|
||||
@ -16,9 +17,13 @@ func (db *DB) WriteArticleTags(articleID int64, tagIDs []int64) error {
|
||||
}
|
||||
|
||||
for _, tagID := range tagIDs {
|
||||
query := `
|
||||
INSERT INTO articles_tags (article_id, tag_id)
|
||||
VALUES (?, ?)
|
||||
`
|
||||
if _, err := tx.Exec(query, articleID, tagID); err != nil {
|
||||
if rollbackErr := tx.Rollback(); rollbackErr != nil {
|
||||
log.Fatalf("transaction error: %v, rollback error: %v", err, rollbackErr)
|
||||
log.Fatalf("error: transaction error: %v, rollback error: %v", err, rollbackErr)
|
||||
}
|
||||
return fmt.Errorf("error inserting into articles_tags: %v", err)
|
||||
}
|
||||
@ -34,7 +39,9 @@ func (db *DB) WriteArticleTags(articleID int64, tagIDs []int64) error {
|
||||
}
|
||||
|
||||
log.Println(err)
|
||||
wait(i)
|
||||
waitTime := time.Duration(math.Pow(2, float64(i))) * time.Second
|
||||
jitter := time.Duration(rand.IntN(1000)) * time.Millisecond
|
||||
time.Sleep(waitTime + jitter)
|
||||
}
|
||||
return fmt.Errorf("error: %v unsuccessful retries for DB operation, aborting", TxMaxRetries)
|
||||
}
|
||||
@ -63,45 +70,3 @@ func (db *DB) GetArticleTags(articleID int64) ([]*Tag, error) {
|
||||
|
||||
return tags, nil
|
||||
}
|
||||
|
||||
func (db *DB) UpdateArticleTags(articleID int64, tagIDs []int64) error {
|
||||
deleteQuery := "DELETE FROM articles_tags WHERE article_id = ?"
|
||||
insertQuery := "INSERT INTO articles_tags (article_id, tag_id) VALUES (?, ?)"
|
||||
|
||||
for i := 0; i < TxMaxRetries; i++ {
|
||||
err := func() error {
|
||||
tx, err := db.Begin()
|
||||
if err != nil {
|
||||
return fmt.Errorf("error starting transaction: %v", err)
|
||||
}
|
||||
|
||||
if _, err := tx.Exec(deleteQuery, articleID); err != nil {
|
||||
if rollbackErr := tx.Rollback(); rollbackErr != nil {
|
||||
log.Fatalf("transaction error: %v, rollback error: %v", err, rollbackErr)
|
||||
}
|
||||
return fmt.Errorf("error deleting entries from articles_tags before inserting new ones: %v", err)
|
||||
}
|
||||
|
||||
for _, tagID := range tagIDs {
|
||||
if _, err := tx.Exec(insertQuery, articleID, tagID); err != nil {
|
||||
if rollbackErr := tx.Rollback(); rollbackErr != nil {
|
||||
log.Fatalf("transaction error: %v, rollback error: %v", err, rollbackErr)
|
||||
}
|
||||
return fmt.Errorf("error inserting new entries into articles_tags: %v", err)
|
||||
}
|
||||
}
|
||||
|
||||
if err = tx.Commit(); err != nil {
|
||||
return fmt.Errorf("error committing transaction: %v", err)
|
||||
}
|
||||
return nil
|
||||
}()
|
||||
if err == nil {
|
||||
return nil
|
||||
}
|
||||
|
||||
log.Println(err)
|
||||
wait(i)
|
||||
}
|
||||
return fmt.Errorf("error: %v unsuccessful retries for DB operation, aborting", TxMaxRetries)
|
||||
}
|
||||
|
@ -16,14 +16,13 @@ import (
|
||||
"golang.org/x/term"
|
||||
)
|
||||
|
||||
var TxMaxRetries = 5
|
||||
var TxMaxRetries = 3
|
||||
|
||||
type (
|
||||
DB struct{ *sql.DB }
|
||||
Tx struct{ *sql.Tx }
|
||||
|
||||
DB struct{ *sql.DB }
|
||||
Tx struct{ *sql.Tx }
|
||||
Attribute struct {
|
||||
Value any
|
||||
Value interface{}
|
||||
Table string
|
||||
AttName string
|
||||
ID int64
|
||||
@ -71,15 +70,9 @@ func getCredentials() (string, string, error) {
|
||||
return user, pass, nil
|
||||
}
|
||||
|
||||
func wait(iteration int) {
|
||||
waitTime := time.Duration(math.Pow(2, float64(iteration))) * 100 * time.Millisecond
|
||||
jitter := time.Duration(rand.IntN(int(waitTime)/2)) * time.Millisecond
|
||||
time.Sleep(waitTime + jitter)
|
||||
}
|
||||
|
||||
func OpenDB(dbName string) (*DB, error) {
|
||||
var err error
|
||||
db := DB{DB: new(sql.DB)}
|
||||
db := DB{DB: &sql.DB{}}
|
||||
|
||||
cfg := mysql.NewConfig()
|
||||
cfg.DBName = dbName
|
||||
@ -115,7 +108,7 @@ func (db *DB) UpdateAttributes(a ...*Attribute) error {
|
||||
`, attribute.Table, attribute.AttName)
|
||||
if _, err := tx.Exec(query, attribute.Value, attribute.ID); err != nil {
|
||||
if rollbackErr := tx.Rollback(); rollbackErr != nil {
|
||||
log.Fatalf("transaction error: %v, rollback error: %v", err, rollbackErr)
|
||||
log.Fatalf("error: transaction error: %v, rollback error: %v", err, rollbackErr)
|
||||
}
|
||||
return fmt.Errorf("error updating %v in DB: %v", attribute.AttName, err)
|
||||
}
|
||||
@ -131,7 +124,9 @@ func (db *DB) UpdateAttributes(a ...*Attribute) error {
|
||||
}
|
||||
|
||||
log.Println(err)
|
||||
wait(i)
|
||||
waitTime := time.Duration(math.Pow(2, float64(i))) * time.Second
|
||||
jitter := time.Duration(rand.IntN(1000)) * time.Millisecond
|
||||
time.Sleep(waitTime + jitter)
|
||||
}
|
||||
return fmt.Errorf("error: %v unsuccessful retries for DB operation, aborting", TxMaxRetries)
|
||||
}
|
||||
@ -148,6 +143,31 @@ func (db *DB) CountEntries(table string) (int64, error) {
|
||||
return count, nil
|
||||
}
|
||||
|
||||
func (db *DB) StartTransaction() (*Tx, error) {
|
||||
tx := &Tx{Tx: new(sql.Tx)}
|
||||
var err error
|
||||
|
||||
tx.Tx, err = db.Begin()
|
||||
if err != nil {
|
||||
return nil, fmt.Errorf("error starting transaction: %v", err)
|
||||
}
|
||||
|
||||
return tx, nil
|
||||
}
|
||||
|
||||
func (tx *Tx) CommitTransaction() error {
|
||||
if err := tx.Commit(); err != nil {
|
||||
return fmt.Errorf("error committing transaction: %v", err)
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
func (tx *Tx) RollbackTransaction() {
|
||||
if err := tx.Rollback(); err != nil {
|
||||
log.Fatalf("error rolling back transaction: %v", err)
|
||||
}
|
||||
}
|
||||
|
||||
func (tx *Tx) UpdateAttributes(a ...*Attribute) error {
|
||||
for _, attribute := range a {
|
||||
query := fmt.Sprintf(`
|
||||
@ -157,7 +177,7 @@ func (tx *Tx) UpdateAttributes(a ...*Attribute) error {
|
||||
`, attribute.Table, attribute.AttName)
|
||||
if _, err := tx.Exec(query, attribute.Value, attribute.ID); err != nil {
|
||||
if rollbackErr := tx.Rollback(); rollbackErr != nil {
|
||||
log.Fatalf("transaction error: %v, rollback error: %v", err, rollbackErr)
|
||||
log.Fatalf("error: transaction error: %v, rollback error: %v", err, rollbackErr)
|
||||
}
|
||||
return fmt.Errorf("error updating %v in DB: %v", attribute.AttName, err)
|
||||
}
|
||||
|
@ -1,65 +0,0 @@
|
||||
package model
|
||||
|
||||
import (
|
||||
"context"
|
||||
"database/sql"
|
||||
"fmt"
|
||||
"log"
|
||||
)
|
||||
|
||||
func (db *DB) AddIssue() (int64, error) {
|
||||
query := "INSERT INTO issues (published) VALUES (?)"
|
||||
result, err := db.Exec(query, false)
|
||||
if err != nil {
|
||||
return 0, fmt.Errorf("error inserting issue into DB: %v", err)
|
||||
}
|
||||
|
||||
id, err := result.LastInsertId()
|
||||
if err != nil {
|
||||
return 0, fmt.Errorf("error getting ID of added issue: %v", err)
|
||||
}
|
||||
|
||||
return id, nil
|
||||
}
|
||||
|
||||
func (db *DB) PublishLatestIssue() error {
|
||||
txOptions := &sql.TxOptions{Isolation: sql.LevelSerializable}
|
||||
updateQuery := "UPDATE issues SET published = true WHERE published = false"
|
||||
insertQuery := "INSERT INTO issues (published) VALUES (?)"
|
||||
|
||||
for i := 0; i < TxMaxRetries; i++ {
|
||||
err := func() error {
|
||||
tx, err := db.BeginTx(context.Background(), txOptions)
|
||||
if err != nil {
|
||||
return fmt.Errorf("error starting transaction: %v", err)
|
||||
}
|
||||
|
||||
if _, err := tx.Exec(updateQuery); err != nil {
|
||||
if rollbackErr := tx.Rollback(); rollbackErr != nil {
|
||||
log.Fatalf("transaction error: %v, rollback error: %v", err, rollbackErr)
|
||||
}
|
||||
return fmt.Errorf("error publishing issue: %v", err)
|
||||
}
|
||||
|
||||
if _, err := tx.Exec(insertQuery, false); err != nil {
|
||||
if rollbackErr := tx.Rollback(); rollbackErr != nil {
|
||||
log.Fatalf("transaction error: %v, rollback error: %v", err, rollbackErr)
|
||||
}
|
||||
return fmt.Errorf("error inserting new issue into DB: %v", err)
|
||||
}
|
||||
|
||||
if err = tx.Commit(); err != nil {
|
||||
return fmt.Errorf("error committing transaction when publishing issue: %v", err)
|
||||
}
|
||||
return nil
|
||||
}()
|
||||
if err == nil {
|
||||
return nil
|
||||
}
|
||||
|
||||
log.Println(err)
|
||||
wait(i)
|
||||
}
|
||||
|
||||
return fmt.Errorf("error: %v unsuccessful retries for DB operation, aborting", TxMaxRetries)
|
||||
}
|
@ -3,15 +3,17 @@ package model
|
||||
import (
|
||||
"fmt"
|
||||
"log"
|
||||
"math"
|
||||
"math/rand/v2"
|
||||
"time"
|
||||
|
||||
"golang.org/x/crypto/bcrypt"
|
||||
)
|
||||
|
||||
const (
|
||||
Admin = iota
|
||||
Publisher
|
||||
Editor
|
||||
Author
|
||||
Writer
|
||||
)
|
||||
|
||||
type User struct {
|
||||
@ -22,26 +24,21 @@ type User struct {
|
||||
Role int
|
||||
}
|
||||
|
||||
func (db *DB) AddUser(u *User, pass string) (int64, error) {
|
||||
func (db *DB) AddUser(user *User, pass string) error {
|
||||
hashedPass, err := bcrypt.GenerateFromPassword([]byte(pass), bcrypt.DefaultCost)
|
||||
if err != nil {
|
||||
return 0, fmt.Errorf("error creating password hash: %v", err)
|
||||
return fmt.Errorf("error creating password hash: %v", err)
|
||||
}
|
||||
|
||||
query := `
|
||||
INSERT INTO users (username, password, first_name, last_name, role)
|
||||
VALUES (?, ?, ?, ?, ?)
|
||||
`
|
||||
result, err := db.Exec(query, u.UserName, string(hashedPass), u.FirstName, u.LastName, u.Role)
|
||||
if err != nil {
|
||||
return 0, fmt.Errorf("error inserting new user %v into DB: %v", u.UserName, err)
|
||||
}
|
||||
id, err := result.LastInsertId()
|
||||
if err != nil {
|
||||
return 0, fmt.Errorf("error inserting user into DB: %v", err)
|
||||
if _, err = db.Exec(query, user.UserName, string(hashedPass), user.FirstName, user.LastName, user.Role); err != nil {
|
||||
return fmt.Errorf("error inserting user into DB: %v", err)
|
||||
}
|
||||
|
||||
return id, nil
|
||||
return nil
|
||||
}
|
||||
|
||||
func (db *DB) GetID(userName string) (int64, bool) {
|
||||
@ -90,14 +87,14 @@ func (tx *Tx) ChangePassword(id int64, oldPass, newPass string) error {
|
||||
row := tx.QueryRow(getQuery, id)
|
||||
if err := row.Scan(&queriedPass); err != nil {
|
||||
if rollbackErr := tx.Rollback(); rollbackErr != nil {
|
||||
log.Fatalf("transaction error: %v, rollback error: %v", err, rollbackErr)
|
||||
log.Fatalf("error: transaction error: %v, rollback error: %v", err, rollbackErr)
|
||||
}
|
||||
return fmt.Errorf("error reading password from DB: %v", err)
|
||||
}
|
||||
|
||||
if err := bcrypt.CompareHashAndPassword([]byte(queriedPass), []byte(oldPass)); err != nil {
|
||||
if rollbackErr := tx.Rollback(); rollbackErr != nil {
|
||||
log.Fatalf("transaction error: %v, rollback error: %v", err, rollbackErr)
|
||||
log.Fatalf("error: transaction error: %v, rollback error: %v", err, rollbackErr)
|
||||
}
|
||||
return fmt.Errorf("incorrect password: %v", err)
|
||||
}
|
||||
@ -105,7 +102,7 @@ func (tx *Tx) ChangePassword(id int64, oldPass, newPass string) error {
|
||||
newHashedPass, err := bcrypt.GenerateFromPassword([]byte(newPass), bcrypt.DefaultCost)
|
||||
if err != nil {
|
||||
if rollbackErr := tx.Rollback(); rollbackErr != nil {
|
||||
log.Fatalf("transaction error: %v, rollback error: %v", err, rollbackErr)
|
||||
log.Fatalf("error: transaction error: %v, rollback error: %v", err, rollbackErr)
|
||||
}
|
||||
return fmt.Errorf("error creating password hash: %v", err)
|
||||
}
|
||||
@ -117,7 +114,7 @@ func (tx *Tx) ChangePassword(id int64, oldPass, newPass string) error {
|
||||
`
|
||||
if _, err = tx.Exec(setQuery, string(newHashedPass), id); err != nil {
|
||||
if rollbackErr := tx.Rollback(); rollbackErr != nil {
|
||||
log.Fatalf("transaction error: %v, rollback error: %v", err, rollbackErr)
|
||||
log.Fatalf("error: transaction error: %v, rollback error: %v", err, rollbackErr)
|
||||
}
|
||||
return fmt.Errorf("error updating password in DB: %v", err)
|
||||
}
|
||||
@ -135,8 +132,7 @@ func (db *DB) GetUser(id int64) (*User, error) {
|
||||
`
|
||||
|
||||
row := db.QueryRow(query, id)
|
||||
if err := row.Scan(&user.ID, &user.UserName, &user.FirstName,
|
||||
&user.LastName, &user.Role); err != nil {
|
||||
if err := row.Scan(&user.ID, &user.UserName, &user.FirstName, &user.LastName, &user.Role); err != nil {
|
||||
return nil, fmt.Errorf("error reading user information: %v", err)
|
||||
}
|
||||
|
||||
@ -165,7 +161,7 @@ func (db *DB) UpdateUserAttributes(id int64, user, first, last, oldPass, newPass
|
||||
if !passwordEmpty {
|
||||
if err = tx.ChangePassword(id, oldPass, newPass); err != nil {
|
||||
if rollbackErr := tx.Rollback(); rollbackErr != nil {
|
||||
log.Fatalf("transaction error: %v, rollback error: %v", err, rollbackErr)
|
||||
log.Fatalf("error: transaction error: %v, rollback error: %v", err, rollbackErr)
|
||||
}
|
||||
return fmt.Errorf("error changing password: %v", err)
|
||||
}
|
||||
@ -177,7 +173,7 @@ func (db *DB) UpdateUserAttributes(id int64, user, first, last, oldPass, newPass
|
||||
&Attribute{Table: "users", ID: id, AttName: "last_name", Value: last},
|
||||
); err != nil {
|
||||
if rollbackErr := tx.Rollback(); rollbackErr != nil {
|
||||
log.Fatalf("transaction error: %v, rollback error: %v", err, rollbackErr)
|
||||
log.Fatalf("error: transaction error: %v, rollback error: %v", err, rollbackErr)
|
||||
}
|
||||
return fmt.Errorf("error updating attributes in DB: %v", err)
|
||||
}
|
||||
@ -193,7 +189,9 @@ func (db *DB) UpdateUserAttributes(id int64, user, first, last, oldPass, newPass
|
||||
}
|
||||
|
||||
log.Println(err)
|
||||
wait(i)
|
||||
waitTime := time.Duration(math.Pow(2, float64(i))) * time.Second
|
||||
jitter := time.Duration(rand.IntN(1000)) * time.Millisecond
|
||||
time.Sleep(waitTime + jitter)
|
||||
}
|
||||
|
||||
return fmt.Errorf("error: %v unsuccessful retries for DB operation, aborting", TxMaxRetries)
|
||||
|
@ -1,12 +1,9 @@
|
||||
package view
|
||||
|
||||
import (
|
||||
"fmt"
|
||||
"html/template"
|
||||
"io"
|
||||
"log"
|
||||
"net/http"
|
||||
"os"
|
||||
"strconv"
|
||||
"time"
|
||||
|
||||
@ -14,21 +11,21 @@ import (
|
||||
"streifling.com/jason/cpolis/cmd/model"
|
||||
)
|
||||
|
||||
func ShowHub(c *control.CliArgs, db *model.DB, s *control.CookieStore) http.HandlerFunc {
|
||||
func ShowHub(db *model.DB, s *control.CookieStore) http.HandlerFunc {
|
||||
return func(w http.ResponseWriter, r *http.Request) {
|
||||
session, err := s.Get(r, "cookie")
|
||||
if err != nil {
|
||||
tmpl, err := template.ParseFiles(c.WebDir + "/templates/login.html")
|
||||
tmpl, err := template.ParseFiles("web/templates/login.html")
|
||||
msg := "Session nicht mehr gültig. Bitte erneut anmelden."
|
||||
template.Must(tmpl, err).ExecuteTemplate(w, "page-content", msg)
|
||||
}
|
||||
|
||||
tmpl, err := template.ParseFiles(c.WebDir + "/templates/hub.html")
|
||||
tmpl, err := template.ParseFiles("web/templates/hub.html")
|
||||
template.Must(tmpl, err).ExecuteTemplate(w, "page-content", session.Values["role"].(int))
|
||||
}
|
||||
}
|
||||
|
||||
func WriteArticle(c *control.CliArgs, db *model.DB) http.HandlerFunc {
|
||||
func WriteArticle(db *model.DB) http.HandlerFunc {
|
||||
return func(w http.ResponseWriter, r *http.Request) {
|
||||
tags, err := db.GetTagList()
|
||||
if err != nil {
|
||||
@ -37,16 +34,16 @@ func WriteArticle(c *control.CliArgs, db *model.DB) http.HandlerFunc {
|
||||
return
|
||||
}
|
||||
|
||||
tmpl, err := template.ParseFiles(c.WebDir + "/templates/editor.html")
|
||||
tmpl, err := template.ParseFiles("web/templates/editor.html")
|
||||
template.Must(tmpl, err).ExecuteTemplate(w, "page-content", tags)
|
||||
}
|
||||
}
|
||||
|
||||
func SubmitArticle(c *control.CliArgs, db *model.DB, s *control.CookieStore) http.HandlerFunc {
|
||||
func SubmitArticle(db *model.DB, s *control.CookieStore) http.HandlerFunc {
|
||||
return func(w http.ResponseWriter, r *http.Request) {
|
||||
session, err := s.Get(r, "cookie")
|
||||
if err != nil {
|
||||
tmpl, err := template.ParseFiles(c.WebDir + "/templates/login.html")
|
||||
tmpl, err := template.ParseFiles("web/templates/login.html")
|
||||
msg := "Session nicht mehr gültig. Bitte erneut anmelden."
|
||||
template.Must(tmpl, err).ExecuteTemplate(w, "page-content", msg)
|
||||
}
|
||||
@ -84,13 +81,13 @@ func SubmitArticle(c *control.CliArgs, db *model.DB, s *control.CookieStore) htt
|
||||
return
|
||||
}
|
||||
|
||||
tmpl, err := template.ParseFiles(c.WebDir + "/templates/hub.html")
|
||||
tmpl, err := template.ParseFiles("web/templates/hub.html")
|
||||
tmpl = template.Must(tmpl, err)
|
||||
tmpl.ExecuteTemplate(w, "page-content", session.Values["role"])
|
||||
}
|
||||
}
|
||||
|
||||
func ResubmitArticle(c *control.CliArgs, db *model.DB, s *control.CookieStore) http.HandlerFunc {
|
||||
func ResubmitArticle(db *model.DB, s *control.CookieStore) http.HandlerFunc {
|
||||
return func(w http.ResponseWriter, r *http.Request) {
|
||||
id, err := strconv.ParseInt(r.PostFormValue("article-id"), 10, 64)
|
||||
if err != nil {
|
||||
@ -103,7 +100,7 @@ func ResubmitArticle(c *control.CliArgs, db *model.DB, s *control.CookieStore) h
|
||||
description := r.PostFormValue("article-description")
|
||||
content := r.PostFormValue("article-content")
|
||||
|
||||
if err = db.UpdateAttributes(
|
||||
if err := db.UpdateAttributes(
|
||||
&model.Attribute{Table: "articles", ID: id, AttName: "title", Value: title},
|
||||
&model.Attribute{Table: "articles", ID: id, AttName: "description", Value: description},
|
||||
&model.Attribute{Table: "articles", ID: id, AttName: "content", Value: content},
|
||||
@ -114,37 +111,20 @@ func ResubmitArticle(c *control.CliArgs, db *model.DB, s *control.CookieStore) h
|
||||
return
|
||||
}
|
||||
|
||||
r.ParseForm()
|
||||
tags := make([]int64, 0)
|
||||
for _, tag := range r.Form["tags"] {
|
||||
tagID, err := strconv.ParseInt(tag, 10, 64)
|
||||
if err != nil {
|
||||
log.Println(err)
|
||||
http.Error(w, err.Error(), http.StatusInternalServerError)
|
||||
return
|
||||
}
|
||||
tags = append(tags, tagID)
|
||||
}
|
||||
if err = db.UpdateArticleTags(id, tags); err != nil {
|
||||
log.Println(err)
|
||||
http.Error(w, err.Error(), http.StatusInternalServerError)
|
||||
return
|
||||
}
|
||||
|
||||
session, err := s.Get(r, "cookie")
|
||||
if err != nil {
|
||||
tmpl, err := template.ParseFiles(c.WebDir + "/templates/login.html")
|
||||
tmpl, err := template.ParseFiles("web/templates/login.html")
|
||||
msg := "Session nicht mehr gültig. Bitte erneut anmelden."
|
||||
template.Must(tmpl, err).ExecuteTemplate(w, "page-content", msg)
|
||||
}
|
||||
|
||||
tmpl, err := template.ParseFiles(c.WebDir + "/templates/hub.html")
|
||||
tmpl, err := template.ParseFiles("web/templates/hub.html")
|
||||
tmpl = template.Must(tmpl, err)
|
||||
tmpl.ExecuteTemplate(w, "page-content", session.Values["role"])
|
||||
}
|
||||
}
|
||||
|
||||
func ShowUnpublishedArticles(c *control.CliArgs, db *model.DB) http.HandlerFunc {
|
||||
func ShowUnpublishedArticles(db *model.DB) http.HandlerFunc {
|
||||
return func(w http.ResponseWriter, r *http.Request) {
|
||||
unpublishedArticles, err := db.GetCertainArticles(false, false)
|
||||
if err != nil {
|
||||
@ -153,13 +133,13 @@ func ShowUnpublishedArticles(c *control.CliArgs, db *model.DB) http.HandlerFunc
|
||||
return
|
||||
}
|
||||
|
||||
tmpl, err := template.ParseFiles(c.WebDir + "/templates/unpublished-articles.html")
|
||||
tmpl, err := template.ParseFiles("web/templates/unpublished-articles.html")
|
||||
tmpl = template.Must(tmpl, err)
|
||||
tmpl.ExecuteTemplate(w, "page-content", unpublishedArticles)
|
||||
}
|
||||
}
|
||||
|
||||
func ShowRejectedArticles(c *control.CliArgs, db *model.DB, s *control.CookieStore) http.HandlerFunc {
|
||||
func ShowRejectedArticles(db *model.DB, s *control.CookieStore) http.HandlerFunc {
|
||||
return func(w http.ResponseWriter, r *http.Request) {
|
||||
type htmlData struct {
|
||||
MyIDs map[int64]bool
|
||||
@ -188,13 +168,13 @@ func ShowRejectedArticles(c *control.CliArgs, db *model.DB, s *control.CookieSto
|
||||
}
|
||||
}
|
||||
|
||||
tmpl, err := template.ParseFiles(c.WebDir + "/templates/rejected-articles.html")
|
||||
tmpl, err := template.ParseFiles("web/templates/rejected-articles.html")
|
||||
tmpl = template.Must(tmpl, err)
|
||||
tmpl.ExecuteTemplate(w, "page-content", data)
|
||||
}
|
||||
}
|
||||
|
||||
func ReviewUnpublishedArticle(c *control.CliArgs, db *model.DB, s *control.CookieStore) http.HandlerFunc {
|
||||
func ReviewUnpublishedArticle(db *model.DB, s *control.CookieStore) http.HandlerFunc {
|
||||
return func(w http.ResponseWriter, r *http.Request) {
|
||||
type htmlData struct {
|
||||
Article *model.Article
|
||||
@ -223,13 +203,13 @@ func ReviewUnpublishedArticle(c *control.CliArgs, db *model.DB, s *control.Cooki
|
||||
return
|
||||
}
|
||||
|
||||
tmpl, err := template.ParseFiles(c.WebDir + "/templates/to-be-published.html")
|
||||
tmpl, err := template.ParseFiles("web/templates/to-be-published.html")
|
||||
tmpl = template.Must(tmpl, err)
|
||||
tmpl.ExecuteTemplate(w, "page-content", data)
|
||||
}
|
||||
}
|
||||
|
||||
func ReviewRejectedArticle(c *control.CliArgs, db *model.DB, s *control.CookieStore) http.HandlerFunc {
|
||||
func ReviewRejectedArticle(db *model.DB, s *control.CookieStore) http.HandlerFunc {
|
||||
return func(w http.ResponseWriter, r *http.Request) {
|
||||
type htmlData struct {
|
||||
Selected map[int64]bool
|
||||
@ -270,13 +250,13 @@ func ReviewRejectedArticle(c *control.CliArgs, db *model.DB, s *control.CookieSt
|
||||
data.Selected[tag.ID] = true
|
||||
}
|
||||
|
||||
tmpl, err := template.ParseFiles(c.WebDir + "/templates/rework-article.html")
|
||||
tmpl, err := template.ParseFiles("web/templates/rework-article.html")
|
||||
tmpl = template.Must(tmpl, err)
|
||||
tmpl.ExecuteTemplate(w, "page-content", data)
|
||||
}
|
||||
}
|
||||
|
||||
func PublishArticle(c *control.CliArgs, db *model.DB, s *control.CookieStore) http.HandlerFunc {
|
||||
func PublishArticle(db *model.DB, s *control.CookieStore) http.HandlerFunc {
|
||||
return func(w http.ResponseWriter, r *http.Request) {
|
||||
id, err := strconv.ParseInt(r.PostFormValue("id"), 10, 64)
|
||||
if err != nil {
|
||||
@ -287,17 +267,11 @@ func PublishArticle(c *control.CliArgs, db *model.DB, s *control.CookieStore) ht
|
||||
|
||||
session, err := s.Get(r, "cookie")
|
||||
if err != nil {
|
||||
tmpl, err := template.ParseFiles(c.WebDir + "/templates/login.html")
|
||||
tmpl, err := template.ParseFiles("web/templates/login.html")
|
||||
msg := "Session nicht mehr gültig. Bitte erneut anmelden."
|
||||
template.Must(tmpl, err).ExecuteTemplate(w, "page-content", msg)
|
||||
}
|
||||
|
||||
if err = db.AddArticleToCurrentIssue(id); err != nil {
|
||||
log.Println(err)
|
||||
http.Error(w, err.Error(), http.StatusInternalServerError)
|
||||
return
|
||||
}
|
||||
|
||||
if err = db.UpdateAttributes(
|
||||
&model.Attribute{Table: "articles", ID: id, AttName: "published", Value: true},
|
||||
&model.Attribute{Table: "articles", ID: id, AttName: "rejected", Value: false},
|
||||
@ -308,30 +282,13 @@ func PublishArticle(c *control.CliArgs, db *model.DB, s *control.CookieStore) ht
|
||||
return
|
||||
}
|
||||
|
||||
feed, err := control.GenerateRSS(
|
||||
db,
|
||||
"Freimaurer Distrikt Niedersachsen und Sachsen-Anhalt",
|
||||
"https://distrikt-ni-st.de",
|
||||
"Freiheit, Gleichheit, Brüderlichkeit, Toleranz und Humanität",
|
||||
)
|
||||
if err != nil {
|
||||
log.Println(err)
|
||||
http.Error(w, err.Error(), http.StatusInternalServerError)
|
||||
return
|
||||
}
|
||||
if err = control.SaveRSS("tmp/orientexpress_alle.rss", feed); err != nil {
|
||||
log.Println(err)
|
||||
http.Error(w, err.Error(), http.StatusInternalServerError)
|
||||
return
|
||||
}
|
||||
|
||||
tmpl, err := template.ParseFiles(c.WebDir + "/templates/hub.html")
|
||||
tmpl, err := template.ParseFiles("web/templates/hub.html")
|
||||
tmpl = template.Must(tmpl, err)
|
||||
tmpl.ExecuteTemplate(w, "page-content", session.Values["role"])
|
||||
}
|
||||
}
|
||||
|
||||
func RejectArticle(c *control.CliArgs, db *model.DB, s *control.CookieStore) http.HandlerFunc {
|
||||
func RejectArticle(db *model.DB, s *control.CookieStore) http.HandlerFunc {
|
||||
return func(w http.ResponseWriter, r *http.Request) {
|
||||
id, err := strconv.ParseInt(r.PostFormValue("id"), 10, 64)
|
||||
if err != nil {
|
||||
@ -342,7 +299,7 @@ func RejectArticle(c *control.CliArgs, db *model.DB, s *control.CookieStore) htt
|
||||
|
||||
session, err := s.Get(r, "cookie")
|
||||
if err != nil {
|
||||
tmpl, err := template.ParseFiles(c.WebDir + "/templates/login.html")
|
||||
tmpl, err := template.ParseFiles("web/templates/login.html")
|
||||
msg := "Session nicht mehr gültig. Bitte erneut anmelden."
|
||||
template.Must(tmpl, err).ExecuteTemplate(w, "page-content", msg)
|
||||
}
|
||||
@ -355,52 +312,8 @@ func RejectArticle(c *control.CliArgs, db *model.DB, s *control.CookieStore) htt
|
||||
return
|
||||
}
|
||||
|
||||
tmpl, err := template.ParseFiles(c.WebDir + "/templates/hub.html")
|
||||
tmpl, err := template.ParseFiles("web/templates/hub.html")
|
||||
tmpl = template.Must(tmpl, err)
|
||||
tmpl.ExecuteTemplate(w, "page-content", session.Values["role"])
|
||||
}
|
||||
}
|
||||
|
||||
func ShowCurrentArticles(c *control.CliArgs, db *model.DB) http.HandlerFunc {
|
||||
return func(w http.ResponseWriter, r *http.Request) {
|
||||
articles, err := db.GetCurrentIssueArticles()
|
||||
if err != nil {
|
||||
log.Println(err)
|
||||
http.Error(w, err.Error(), http.StatusInternalServerError)
|
||||
return
|
||||
}
|
||||
|
||||
tmpl, err := template.ParseFiles(c.WebDir + "/templates/current-articles.html")
|
||||
template.Must(tmpl, err).ExecuteTemplate(w, "page-content", articles)
|
||||
}
|
||||
}
|
||||
|
||||
func UploadImage(c *control.CliArgs) http.HandlerFunc {
|
||||
return func(w http.ResponseWriter, r *http.Request) {
|
||||
file, header, err := r.FormFile("article-image")
|
||||
if err != nil {
|
||||
log.Println(err)
|
||||
http.Error(w, err.Error(), http.StatusInternalServerError)
|
||||
return
|
||||
}
|
||||
defer file.Close()
|
||||
|
||||
filename := fmt.Sprint(c.PicsDir, time.Now().Format("2006-01-02_15:04:05"), "-", header.Filename)
|
||||
img, err := os.Create(filename)
|
||||
if err != nil {
|
||||
log.Println(err)
|
||||
http.Error(w, err.Error(), http.StatusInternalServerError)
|
||||
return
|
||||
}
|
||||
defer img.Close()
|
||||
|
||||
if _, err = io.Copy(img, file); err != nil {
|
||||
log.Println(err)
|
||||
http.Error(w, err.Error(), http.StatusInternalServerError)
|
||||
return
|
||||
}
|
||||
|
||||
tmpl, err := template.ParseFiles(c.WebDir + "/templates/editor.html")
|
||||
template.Must(tmpl, err).ExecuteTemplate(w, "editor-images", fmt.Sprint(""))
|
||||
}
|
||||
}
|
||||
|
@ -8,25 +8,23 @@ import (
|
||||
"streifling.com/jason/cpolis/cmd/model"
|
||||
)
|
||||
|
||||
func CreateTag(c *control.CliArgs) http.HandlerFunc {
|
||||
return func(w http.ResponseWriter, r *http.Request) {
|
||||
tmpl, err := template.ParseFiles(c.WebDir + "/templates/add-tag.html")
|
||||
template.Must(tmpl, err).ExecuteTemplate(w, "page-content", nil)
|
||||
}
|
||||
func CreateTag(w http.ResponseWriter, r *http.Request) {
|
||||
tmpl, err := template.ParseFiles("web/templates/add-tag.html")
|
||||
template.Must(tmpl, err).ExecuteTemplate(w, "page-content", nil)
|
||||
}
|
||||
|
||||
func AddTag(c *control.CliArgs, db *model.DB, s *control.CookieStore) http.HandlerFunc {
|
||||
func AddTag(db *model.DB, s *control.CookieStore) http.HandlerFunc {
|
||||
return func(w http.ResponseWriter, r *http.Request) {
|
||||
db.AddTag(r.PostFormValue("tag"))
|
||||
|
||||
session, err := s.Get(r, "cookie")
|
||||
if err != nil {
|
||||
tmpl, err := template.ParseFiles(c.WebDir + "/templates/login.html")
|
||||
tmpl, err := template.ParseFiles("web/templates/login.html")
|
||||
msg := "Session nicht mehr gültig. Bitte erneut anmelden."
|
||||
template.Must(tmpl, err).ExecuteTemplate(w, "page-content", msg)
|
||||
}
|
||||
|
||||
tmpl, err := template.ParseFiles(c.WebDir + "/templates/hub.html")
|
||||
tmpl, err := template.ParseFiles("web/templates/hub.html")
|
||||
tmpl = template.Must(tmpl, err)
|
||||
tmpl.ExecuteTemplate(w, "page-content", session.Values["role"])
|
||||
}
|
||||
|
@ -1,31 +0,0 @@
|
||||
package view
|
||||
|
||||
import (
|
||||
"html/template"
|
||||
"log"
|
||||
"net/http"
|
||||
|
||||
"streifling.com/jason/cpolis/cmd/control"
|
||||
"streifling.com/jason/cpolis/cmd/model"
|
||||
)
|
||||
|
||||
func PublishLatestIssue(c *control.CliArgs, db *model.DB, s *control.CookieStore) http.HandlerFunc {
|
||||
return func(w http.ResponseWriter, r *http.Request) {
|
||||
if err := db.PublishLatestIssue(); err != nil {
|
||||
log.Println(err)
|
||||
http.Error(w, err.Error(), http.StatusInternalServerError)
|
||||
return
|
||||
}
|
||||
|
||||
session, err := s.Get(r, "cookie")
|
||||
if err != nil {
|
||||
tmpl, err := template.ParseFiles(c.WebDir + "/templates/login.html")
|
||||
msg := "Session nicht mehr gültig. Bitte erneut anmelden."
|
||||
template.Must(tmpl, err).ExecuteTemplate(w, "page-content", msg)
|
||||
}
|
||||
|
||||
tmpl, err := template.ParseFiles(c.WebDir + "/templates/hub.html")
|
||||
tmpl = template.Must(tmpl, err)
|
||||
tmpl.ExecuteTemplate(w, "page-content", session.Values["role"])
|
||||
}
|
||||
}
|
@ -1,7 +1,6 @@
|
||||
package view
|
||||
|
||||
import (
|
||||
"fmt"
|
||||
"html/template"
|
||||
"log"
|
||||
"net/http"
|
||||
@ -12,7 +11,7 @@ import (
|
||||
"streifling.com/jason/cpolis/cmd/model"
|
||||
)
|
||||
|
||||
func ShowRSS(c *control.CliArgs, db *model.DB, title, link, desc string) http.HandlerFunc {
|
||||
func ShowRSS(db *model.DB, title, link, desc string) http.HandlerFunc {
|
||||
return func(w http.ResponseWriter, r *http.Request) {
|
||||
channel := &rss.Channel{
|
||||
Title: title,
|
||||
@ -39,7 +38,6 @@ func ShowRSS(c *control.CliArgs, db *model.DB, title, link, desc string) http.Ha
|
||||
for _, tag := range tags {
|
||||
tagNames = append(tagNames, tag.Name)
|
||||
}
|
||||
tagNames = append(tagNames, fmt.Sprint("Orient Express ", article.IssueID))
|
||||
|
||||
user, err := db.GetUser(article.AuthorID)
|
||||
if err != nil {
|
||||
@ -88,7 +86,7 @@ func ShowRSS(c *control.CliArgs, db *model.DB, title, link, desc string) http.Ha
|
||||
return
|
||||
}
|
||||
|
||||
files := []string{c.WebDir + "/templates/index.html", c.WebDir + "/templates/feed.rss"}
|
||||
files := []string{"web/templates/index.html", "web/templates/feed.rss"}
|
||||
tmpl, err := template.ParseFiles(files...)
|
||||
template.Must(tmpl, err).Execute(w, rss)
|
||||
}
|
||||
|
@ -27,26 +27,26 @@ func saveSession(w http.ResponseWriter, r *http.Request, s *control.CookieStore,
|
||||
return nil
|
||||
}
|
||||
|
||||
func HomePage(c *control.CliArgs, db *model.DB, s *control.CookieStore) http.HandlerFunc {
|
||||
func HomePage(db *model.DB, s *control.CookieStore) http.HandlerFunc {
|
||||
return func(w http.ResponseWriter, r *http.Request) {
|
||||
numRows, err := db.CountEntries("users")
|
||||
if err != nil {
|
||||
log.Fatalln(err)
|
||||
}
|
||||
|
||||
files := []string{c.WebDir + "/templates/index.html"}
|
||||
files := []string{"web/templates/index.html"}
|
||||
if numRows == 0 {
|
||||
files = append(files, c.WebDir+"/templates/add-user.html")
|
||||
files = append(files, "web/templates/add-user.html")
|
||||
tmpl, err := template.ParseFiles(files...)
|
||||
template.Must(tmpl, err).Execute(w, nil)
|
||||
} else {
|
||||
session, _ := s.Get(r, "cookie")
|
||||
if auth, ok := session.Values["authenticated"].(bool); auth && ok {
|
||||
files = append(files, c.WebDir+"/templates/hub.html")
|
||||
files = append(files, "web/templates/hub.html")
|
||||
tmpl, err := template.ParseFiles(files...)
|
||||
template.Must(tmpl, err).Execute(w, session.Values["role"])
|
||||
} else {
|
||||
files = append(files, c.WebDir+"/templates/login.html")
|
||||
files = append(files, "web/templates/login.html")
|
||||
tmpl, err := template.ParseFiles(files...)
|
||||
template.Must(tmpl, err).Execute(w, nil)
|
||||
}
|
||||
@ -54,7 +54,7 @@ func HomePage(c *control.CliArgs, db *model.DB, s *control.CookieStore) http.Han
|
||||
}
|
||||
}
|
||||
|
||||
func Login(c *control.CliArgs, db *model.DB, s *control.CookieStore) http.HandlerFunc {
|
||||
func Login(db *model.DB, s *control.CookieStore) http.HandlerFunc {
|
||||
return func(w http.ResponseWriter, r *http.Request) {
|
||||
userName := r.PostFormValue("username")
|
||||
password := r.PostFormValue("password")
|
||||
@ -84,16 +84,16 @@ func Login(c *control.CliArgs, db *model.DB, s *control.CookieStore) http.Handle
|
||||
return
|
||||
}
|
||||
|
||||
tmpl, err := template.ParseFiles(c.WebDir + "/templates/hub.html")
|
||||
tmpl, err := template.ParseFiles("web/templates/hub.html")
|
||||
template.Must(tmpl, err).ExecuteTemplate(w, "page-content", user.Role)
|
||||
}
|
||||
}
|
||||
|
||||
func Logout(c *control.CliArgs, s *control.CookieStore) http.HandlerFunc {
|
||||
func Logout(s *control.CookieStore) http.HandlerFunc {
|
||||
return func(w http.ResponseWriter, r *http.Request) {
|
||||
session, err := s.Get(r, "cookie")
|
||||
if err != nil {
|
||||
tmpl, err := template.ParseFiles(c.WebDir + "/templates/login.html")
|
||||
tmpl, err := template.ParseFiles("web/templates/login.html")
|
||||
msg := "Session nicht mehr gültig. Bitte erneut anmelden."
|
||||
template.Must(tmpl, err).ExecuteTemplate(w, "page-content", msg)
|
||||
}
|
||||
@ -106,7 +106,7 @@ func Logout(c *control.CliArgs, s *control.CookieStore) http.HandlerFunc {
|
||||
return
|
||||
}
|
||||
|
||||
tmpl, err := template.ParseFiles(c.WebDir + "/templates/login.html")
|
||||
tmpl, err := template.ParseFiles("web/templates/login.html")
|
||||
template.Must(tmpl, err).ExecuteTemplate(w, "page-content", nil)
|
||||
}
|
||||
}
|
||||
|
@ -31,14 +31,12 @@ func checkUserStrings(user *model.User) (string, int, bool) {
|
||||
}
|
||||
}
|
||||
|
||||
func CreateUser(c *control.CliArgs) http.HandlerFunc {
|
||||
return func(w http.ResponseWriter, r *http.Request) {
|
||||
tmpl, err := template.ParseFiles(c.WebDir + "/templates/add-user.html")
|
||||
template.Must(tmpl, err).ExecuteTemplate(w, "page-content", nil)
|
||||
}
|
||||
func CreateUser(w http.ResponseWriter, r *http.Request) {
|
||||
tmpl, err := template.ParseFiles("web/templates/add-user.html")
|
||||
template.Must(tmpl, err).ExecuteTemplate(w, "page-content", nil)
|
||||
}
|
||||
|
||||
func AddUser(c *control.CliArgs, db *model.DB, s *control.CookieStore) http.HandlerFunc {
|
||||
func AddUser(db *model.DB, s *control.CookieStore) http.HandlerFunc {
|
||||
return func(w http.ResponseWriter, r *http.Request) {
|
||||
role, err := strconv.Atoi(r.PostFormValue("role"))
|
||||
if err != nil {
|
||||
@ -61,7 +59,7 @@ func AddUser(c *control.CliArgs, db *model.DB, s *control.CookieStore) http.Hand
|
||||
if len(htmlData.UserName) == 0 || len(htmlData.FirstName) == 0 ||
|
||||
len(htmlData.LastName) == 0 || len(pass) == 0 || len(pass2) == 0 {
|
||||
htmlData.Msg = "Alle Felder müssen ausgefüllt werden."
|
||||
tmpl, err := template.ParseFiles(c.WebDir + "/templates/add-user.html")
|
||||
tmpl, err := template.ParseFiles("web/templates/add-user.html")
|
||||
template.Must(tmpl, err).ExecuteTemplate(w, "page-content", htmlData)
|
||||
return
|
||||
}
|
||||
@ -69,7 +67,7 @@ func AddUser(c *control.CliArgs, db *model.DB, s *control.CookieStore) http.Hand
|
||||
if !ok {
|
||||
htmlData.Msg = fmt.Sprint(userString, " ist zu lang. Maximal ",
|
||||
stringLen, " Zeichen erlaubt.")
|
||||
tmpl, err := template.ParseFiles(c.WebDir + "/templates/add-user.html")
|
||||
tmpl, err := template.ParseFiles("web/templates/add-user.html")
|
||||
template.Must(tmpl, err).ExecuteTemplate(w, "page-content", htmlData)
|
||||
return
|
||||
}
|
||||
@ -77,32 +75,30 @@ func AddUser(c *control.CliArgs, db *model.DB, s *control.CookieStore) http.Hand
|
||||
if id != 0 {
|
||||
htmlData.Msg = fmt.Sprint(htmlData.UserName,
|
||||
" ist bereits vergeben. Bitte anderen Benutzernamen wählen.")
|
||||
tmpl, err := template.ParseFiles(c.WebDir + "/templates/add-user.html")
|
||||
tmpl, err := template.ParseFiles("web/templates/add-user.html")
|
||||
template.Must(tmpl, err).ExecuteTemplate(w, "page-content", htmlData)
|
||||
return
|
||||
}
|
||||
if pass != pass2 {
|
||||
htmlData.Msg = "Die Passwörter stimmen nicht überein."
|
||||
tmpl, err := template.ParseFiles(c.WebDir + "/templates/add-user.html")
|
||||
tmpl, err := template.ParseFiles("web/templates/add-user.html")
|
||||
template.Must(tmpl, err).ExecuteTemplate(w, "page-content", htmlData)
|
||||
return
|
||||
}
|
||||
|
||||
htmlData.ID, err = db.AddUser(htmlData.User, pass)
|
||||
num, err := db.CountEntries("users")
|
||||
if err != nil {
|
||||
log.Println(err)
|
||||
http.Error(w, err.Error(), http.StatusInternalServerError)
|
||||
return
|
||||
}
|
||||
|
||||
if htmlData.ID == 1 {
|
||||
htmlData.Role = model.Admin
|
||||
|
||||
if err = db.UpdateAttributes(
|
||||
&model.Attribute{Table: "users", ID: id, AttName: "role", Value: htmlData.Role},
|
||||
); err != nil {
|
||||
log.Println(err)
|
||||
http.Error(w, err.Error(), http.StatusInternalServerError)
|
||||
if num == 0 {
|
||||
if htmlData.Role != model.Admin {
|
||||
htmlData.Msg = "Der erste Benutzer muss ein Administrator sein."
|
||||
htmlData.Role = model.Admin
|
||||
tmpl, err := template.ParseFiles("web/templates/add-user.html")
|
||||
tmpl = template.Must(tmpl, err)
|
||||
tmpl.ExecuteTemplate(w, "page-content", htmlData)
|
||||
return
|
||||
}
|
||||
|
||||
@ -111,24 +107,24 @@ func AddUser(c *control.CliArgs, db *model.DB, s *control.CookieStore) http.Hand
|
||||
http.Error(w, err.Error(), http.StatusInternalServerError)
|
||||
return
|
||||
}
|
||||
|
||||
if _, err := db.AddIssue(); err != nil {
|
||||
log.Println(err)
|
||||
http.Error(w, err.Error(), http.StatusInternalServerError)
|
||||
return
|
||||
}
|
||||
}
|
||||
|
||||
tmpl, err := template.ParseFiles(c.WebDir + "/templates/hub.html")
|
||||
if err := db.AddUser(htmlData.User, pass); err != nil {
|
||||
log.Println(err)
|
||||
http.Error(w, err.Error(), http.StatusInternalServerError)
|
||||
return
|
||||
}
|
||||
|
||||
tmpl, err := template.ParseFiles("web/templates/hub.html")
|
||||
template.Must(tmpl, err).ExecuteTemplate(w, "page-content", 0)
|
||||
}
|
||||
}
|
||||
|
||||
func EditUser(c *control.CliArgs, db *model.DB, s *control.CookieStore) http.HandlerFunc {
|
||||
func EditUser(db *model.DB, s *control.CookieStore) http.HandlerFunc {
|
||||
return func(w http.ResponseWriter, r *http.Request) {
|
||||
session, err := s.Get(r, "cookie")
|
||||
if err != nil {
|
||||
tmpl, err := template.ParseFiles(c.WebDir + "/templates/login.html")
|
||||
tmpl, err := template.ParseFiles("web/templates/login.html")
|
||||
msg := "Session nicht mehr gültig. Bitte erneut anmelden."
|
||||
template.Must(tmpl, err).ExecuteTemplate(w, "page-content", msg)
|
||||
}
|
||||
@ -140,16 +136,16 @@ func EditUser(c *control.CliArgs, db *model.DB, s *control.CookieStore) http.Han
|
||||
return
|
||||
}
|
||||
|
||||
tmpl, err := template.ParseFiles(c.WebDir + "/templates/edit-user.html")
|
||||
tmpl, err := template.ParseFiles("web/templates/edit-user.html")
|
||||
template.Must(tmpl, err).ExecuteTemplate(w, "page-content", user)
|
||||
}
|
||||
}
|
||||
|
||||
func UpdateUser(c *control.CliArgs, db *model.DB, s *control.CookieStore) http.HandlerFunc {
|
||||
func UpdateUser(db *model.DB, s *control.CookieStore) http.HandlerFunc {
|
||||
return func(w http.ResponseWriter, r *http.Request) {
|
||||
session, err := s.Get(r, "cookie")
|
||||
if err != nil {
|
||||
tmpl, err := template.ParseFiles(c.WebDir + "/templates/login.html")
|
||||
tmpl, err := template.ParseFiles("web/templates/login.html")
|
||||
msg := "Session nicht mehr gültig. Bitte erneut anmelden."
|
||||
template.Must(tmpl, err).ExecuteTemplate(w, "page-content", msg)
|
||||
}
|
||||
@ -169,7 +165,7 @@ func UpdateUser(c *control.CliArgs, db *model.DB, s *control.CookieStore) http.H
|
||||
if len(userData.UserName) == 0 || len(userData.FirstName) == 0 ||
|
||||
len(userData.LastName) == 0 {
|
||||
userData.Msg = "Alle Felder mit * müssen ausgefüllt sein."
|
||||
tmpl, err := template.ParseFiles(c.WebDir + "/templates/edit-user.html")
|
||||
tmpl, err := template.ParseFiles("web/templates/edit-user.html")
|
||||
tmpl = template.Must(tmpl, err)
|
||||
tmpl.ExecuteTemplate(w, "page-content", userData.Msg)
|
||||
return
|
||||
@ -179,7 +175,7 @@ func UpdateUser(c *control.CliArgs, db *model.DB, s *control.CookieStore) http.H
|
||||
if !ok {
|
||||
userData.Msg = fmt.Sprint(userString, " ist zu lang. Maximal ",
|
||||
stringLen, " Zeichen erlaubt.")
|
||||
tmpl, err := template.ParseFiles(c.WebDir + "/templates/edit-user.html")
|
||||
tmpl, err := template.ParseFiles("web/templates/edit-user.html")
|
||||
tmpl = template.Must(tmpl, err)
|
||||
tmpl.ExecuteTemplate(w, "page-content", userData)
|
||||
return
|
||||
@ -189,7 +185,7 @@ func UpdateUser(c *control.CliArgs, db *model.DB, s *control.CookieStore) http.H
|
||||
if id != userData.ID {
|
||||
userData.Msg = "Benutzername bereits vergeben."
|
||||
userData.UserName = ""
|
||||
tmpl, err := template.ParseFiles(c.WebDir + "/templates/edit-user.html")
|
||||
tmpl, err := template.ParseFiles("web/templates/edit-user.html")
|
||||
tmpl = template.Must(tmpl, err)
|
||||
tmpl.ExecuteTemplate(w, "page-content", userData)
|
||||
return
|
||||
@ -205,11 +201,11 @@ func UpdateUser(c *control.CliArgs, db *model.DB, s *control.CookieStore) http.H
|
||||
newPass,
|
||||
newPass2); err != nil {
|
||||
userData.Msg = "Aktualisierung der Benutzerdaten fehlgeschlagen."
|
||||
tmpl, err := template.ParseFiles(c.WebDir + "/templates/edit-user.html")
|
||||
tmpl, err := template.ParseFiles("web/templates/edit-user.html")
|
||||
template.Must(tmpl, err).ExecuteTemplate(w, "page-content", userData)
|
||||
}
|
||||
|
||||
tmpl, err := template.ParseFiles(c.WebDir + "/templates/hub.html")
|
||||
tmpl, err := template.ParseFiles("web/templates/hub.html")
|
||||
tmpl = template.Must(tmpl, err)
|
||||
tmpl.ExecuteTemplate(w, "page-content", session.Values["role"].(int))
|
||||
}
|
||||
|
@ -1,10 +1,8 @@
|
||||
{{define "page-content"}}
|
||||
<h2>Neuer Benutzer</h2>
|
||||
|
||||
<form>
|
||||
<input required name="tag" placeholder="Tag" type="text" />
|
||||
<input type="submit" value="Anlegen" hx-post="/add-tag/" hx-target="#page-content" />
|
||||
</form>
|
||||
|
||||
<button hx-get="/hub/" hx-target="#page-content">Abbrechen</button>
|
||||
{{end}}
|
||||
|
@ -1,31 +1,22 @@
|
||||
{{define "page-content"}}
|
||||
<h2>Neuer Benutzer</h2>
|
||||
<form>
|
||||
<div>
|
||||
<input required name="username" placeholder="Benutzername" type="text" value="{{.UserName}}" />
|
||||
<input required name="password" placeholder="Passwort" type="password" />
|
||||
<input required name="password2" placeholder="Passwort wiederholen" type="password" />
|
||||
</div>
|
||||
<input required name="username" placeholder="Benutzername" type="text" value="{{.UserName}}" />
|
||||
<input required name="password" placeholder="Passwort" type="password" />
|
||||
<input required name="password2" placeholder="Passwort wiederholen" type="password" />
|
||||
|
||||
<div>
|
||||
<input required name="first-name" placeholder="Vorname" type="text" value="{{.FirstName}}" />
|
||||
<input required name="last-name" placeholder="Nachname" type="text" value="{{.LastName}}" />
|
||||
</div>
|
||||
<input required name="first-name" placeholder="Vorname" type="text" value="{{.FirstName}}" />
|
||||
<input required name="last-name" placeholder="Nachname" type="text" value="{{.LastName}}" />
|
||||
|
||||
<div>
|
||||
<input required id="author" name="role" type="radio" value="3" {{if eq .Role 3 }}checked{{end}} />
|
||||
<label for="author">Autor</label>
|
||||
<input required id="editor" name="role" type="radio" value="2" {{if eq .Role 2 }}checked{{end}} />
|
||||
<label for="editor">Redakteur</label>
|
||||
<input required id="publisher" name="role" type="radio" value="1" {{if eq .Role 1 }}checked{{end}} />
|
||||
<label for="publisher">Herausgeber</label>
|
||||
<input required id="admin" name="role" type="radio" value="0" {{if eq .Role 0 }}checked{{end}} />
|
||||
<label for="admin">Admin</label>
|
||||
</div>
|
||||
<input required id="writer" name="role" type="radio" value="2" {{if eq .Role 2 }}checked{{end}} />
|
||||
<label for="writer">Schreiber</label>
|
||||
<input required id="editor" name="role" type="radio" value="1" {{if eq .Role 1 }}checked{{end}} />
|
||||
<label for="editor">Redakteur</label>
|
||||
<input required id="admin" name="role" type="radio" value="0" {{if eq .Role 0 }}checked{{end}} />
|
||||
<label for="admin">Admin</label>
|
||||
|
||||
<input type="submit" value="Anlegen" hx-post="/add-user/" hx-target="#page-content" />
|
||||
</form>
|
||||
|
||||
<button hx-get="/hub/" hx-target="#page-content">Abbrechen</button>
|
||||
|
||||
<script>
|
||||
|
@ -1,13 +0,0 @@
|
||||
{{define "page-content"}}
|
||||
<div>
|
||||
{{range .}}
|
||||
<div>
|
||||
<h1>{{.Title}}</h1>
|
||||
<p>{{.Description}}</p>
|
||||
</div>
|
||||
{{end}}
|
||||
</div>
|
||||
|
||||
<button hx-get="/publish-issue/" hx-target="#page-content">Ausgabe publizieren</button>
|
||||
<button hx-get="/hub/" hx-target="#page-content">Abbrechen</button>
|
||||
{{end}}
|
@ -1,19 +1,13 @@
|
||||
{{define "page-content"}}
|
||||
<form>
|
||||
<div>
|
||||
<input name="username" type="text" value="{{.UserName}}" />
|
||||
<input name="first-name" type="text" value="{{.FirstName}}" />
|
||||
<input name="last-name" type="text" value="{{.LastName}}" />
|
||||
</div>
|
||||
<input name="username" type="text" value="{{.UserName}}" />
|
||||
<input name="first-name" type="text" value="{{.FirstName}}" />
|
||||
<input name="last-name" type="text" value="{{.LastName}}" />
|
||||
|
||||
<div>
|
||||
<input name="old-password" placeholder="Altes Passwort" type="password" />
|
||||
<input name="password" placeholder="Neues Passwort" type="password" />
|
||||
<input name="password2" placeholder="Wiederholen" type="password" />
|
||||
</div>
|
||||
<input name="old-password" placeholder="Altes Passwort" type="password" />
|
||||
<input name="password" placeholder="Neues Passwort" type="password" />
|
||||
<input name="password2" placeholder="Wiederholen" type="password" />
|
||||
|
||||
<input type="submit" value="Aktualisieren" hx-post="/update-user/" hx-target="#page-content" />
|
||||
</form>
|
||||
|
||||
<button hx-get="/hub/" hx-target="#page-content">Abbrechen</button>
|
||||
{{end}}
|
||||
|
@ -1,57 +1,13 @@
|
||||
{{define "page-content"}}
|
||||
<h2>Editor</h2>
|
||||
<form>
|
||||
<div>
|
||||
<input name="article-title" placeholder="Titel" type="text" />
|
||||
<textarea name="article-description" placeholder="Beschreibung"></textarea>
|
||||
<textarea name="article-content" placeholder="Artikel"></textarea>
|
||||
</div>
|
||||
|
||||
<div>
|
||||
{{range .}}
|
||||
<div>
|
||||
<input id="{{.Name}}" name="tags" type="checkbox" value="{{.ID}}" />
|
||||
<label for="{{.Name}}">{{.Name}}</label>
|
||||
</div>
|
||||
{{end}}
|
||||
</div>
|
||||
|
||||
<div id="editor-images">
|
||||
<input name="article-image" type="file" hx-encoding="multipart/form-data" hx-post="/upload-image/"
|
||||
hx-swap="beforeend" hx-target="#editor-images" />
|
||||
</div>
|
||||
|
||||
<input name="article-title" placeholder="Titel" type="text" />
|
||||
<textarea name="article-description" placeholder="Beschreibung"></textarea>
|
||||
<textarea name="article-content" placeholder="Artikel"></textarea>
|
||||
{{range .}}
|
||||
<input id="{{.Name}}" name="tags" type="checkbox" value="{{.ID}}" />
|
||||
<label for="{{.Name}}">{{.Name}}</label>
|
||||
{{end}}
|
||||
<input type="submit" value="Senden" hx-post="/submit-article/" hx-target="#page-content" />
|
||||
</form>
|
||||
|
||||
<button hx-get="/hub/" hx-target="#page-content">Abbrechen</button>
|
||||
|
||||
<script>
|
||||
function copyToClipboard(text) {
|
||||
event.preventDefault(); // Get-Request verhindern
|
||||
|
||||
var textarea = document.createElement("textarea");
|
||||
textarea.textContent = text;
|
||||
document.body.appendChild(textarea);
|
||||
|
||||
textarea.select();
|
||||
try {
|
||||
document.execCommand('copy');
|
||||
} catch (err) {
|
||||
console.warn('Fehler beim Kopieren', err);
|
||||
}
|
||||
|
||||
document.body.removeChild(textarea);
|
||||
}
|
||||
|
||||
</script>
|
||||
{{end}}
|
||||
|
||||
{{define "editor-images"}}
|
||||
{{if gt (len .) 0}}
|
||||
<div>
|
||||
{{.}}
|
||||
<button onclick="copyToClipboard('{{.}}')">Kopieren</button>
|
||||
</div>
|
||||
{{end}}
|
||||
{{end}}
|
||||
|
@ -1,25 +1,14 @@
|
||||
{{define "page-content"}}
|
||||
<h2>Hub</h2>
|
||||
<div>
|
||||
<button hx-get="/write-article/" hx-target="#page-content">Artikel schreiben</button>
|
||||
<button hx-get="/rejected-articles/" hx-target="#page-content">Abgelehnte Artikel</button>
|
||||
<button hx-get="/rss/" hx-target="#page-content">RSS Feed</button>
|
||||
<button hx-get="/edit-user/" hx-target="#page-content">Benutzer bearbeiten</button>
|
||||
</div>
|
||||
{{if lt . 3}}
|
||||
<div>
|
||||
<button hx-get="/unpublished-articles/" hx-target="#page-content">Unveröffentlichte Artikel</button>
|
||||
<button hx-get="/create-tag/" hx-target="#page-content">Neuer Tag</button>
|
||||
</div>
|
||||
{{end}}
|
||||
<button hx-get="/write-article/" hx-target="#page-content">Artikel schreiben</button>
|
||||
<button hx-get="/rejected-articles/" hx-target="#page-content">Abgelehnte Artikel</button>
|
||||
<button hx-get="/rss/" hx-target="#page-content">RSS Feed</button>
|
||||
<button hx-get="/edit-user/" hx-target="#page-content">Benutzer bearbeiten</button>
|
||||
{{if lt . 2}}
|
||||
<div>
|
||||
<button hx-get="/this-issue/" hx-target="#page-content">Diese Ausgabe</button>
|
||||
</div>
|
||||
<button hx-get="/unpublished-articles/" hx-target="#page-content">Unveröffentlichte Artikel</button>
|
||||
<button hx-get="/create-tag/" hx-target="#page-content">Neuer Tag</button>
|
||||
{{end}}
|
||||
{{if eq . 0}}
|
||||
<div>
|
||||
<button hx-get="/create-user/" hx-target="#page-content">Benutzer hinzufügen</button>
|
||||
</div>
|
||||
<button hx-get="/create-user/" hx-target="#page-content">Benutzer hinzufügen</button>
|
||||
{{end}}
|
||||
{{end}}
|
||||
|
@ -1,11 +1,8 @@
|
||||
{{define "page-content"}}
|
||||
<h2>Anmeldung</h2>
|
||||
<form>
|
||||
<div>
|
||||
<input name="username" placeholder="Benutzername" type="text" />
|
||||
<input name="password" placeholder="Passwort" type="password" />
|
||||
</div>
|
||||
|
||||
<input name="username" placeholder="Benutzername" type="text" />
|
||||
<input name="password" placeholder="Passwort" type="password" />
|
||||
<input type="submit" value="Anmelden" hx-post="/login/" hx-target="#page-content" />
|
||||
</form>
|
||||
{{end}}
|
||||
|
@ -1,18 +1,12 @@
|
||||
{{define "page-content"}}
|
||||
<form>
|
||||
<div>
|
||||
{{range .RejectedArticles}}
|
||||
<div>
|
||||
{{if index $.MyIDs .ID}}
|
||||
<input required id="{{.ID}}" name="id" type="radio" value="{{.ID}}" />
|
||||
<label for="{{.ID}}">{{.Title}}</label>
|
||||
{{end}}
|
||||
</div>
|
||||
{{end}}
|
||||
</div>
|
||||
|
||||
{{range .RejectedArticles}}
|
||||
{{if index $.MyIDs .ID}}
|
||||
<input required id="{{.ID}}" name="id" type="radio" value="{{.ID}}" />
|
||||
<label for="{{.ID}}">{{.Title}}</label>
|
||||
{{end}}
|
||||
{{end}}
|
||||
<input type="submit" value="Auswählen" hx-post="/review-rejected-article/" hx-target="#page-content" />
|
||||
</form>
|
||||
|
||||
<button hx-get="/hub/" hx-target="#page-content">Zurück</button>
|
||||
{{end}}
|
||||
|
@ -1,25 +1,16 @@
|
||||
{{define "page-content"}}
|
||||
<h2>Editor</h2>
|
||||
<form>
|
||||
<div>
|
||||
<input name="article-title" placeholder="Titel" type="text" value="{{.Article.Title}}" />
|
||||
<textarea name="article-description" placeholder="Beschreibung">{{.Article.Description}}</textarea>
|
||||
<textarea name="article-content" placeholder="Artikel">{{.Article.Content}}</textarea>
|
||||
<input name="article-id" type="hidden" value="{{.Article.ID}}" />
|
||||
</div>
|
||||
<input name="article-title" placeholder="Titel" type="text" value="{{.Article.Title}}" />
|
||||
<textarea name="article-description" placeholder="Beschreibung">{{.Article.Description}}</textarea>
|
||||
<textarea name="article-content" placeholder="Artikel">{{.Article.Content}}</textarea>
|
||||
<input name="article-id" type="hidden" value="{{.Article.ID}}" />
|
||||
|
||||
<div>
|
||||
{{range .Tags}}
|
||||
<div>
|
||||
<input id="tag-{{.Name}}" name="tags" type="checkbox" value="{{.ID}}" {{if index $.Selected
|
||||
.ID}}checked{{end}} />
|
||||
<label for="tag-{{.Name}}">{{.Name}}</label>
|
||||
</div>
|
||||
{{end}}
|
||||
</div>
|
||||
{{range .Tags}}
|
||||
<input id="tag-{{.Name}}" name="tags" type="checkbox" value="{{.ID}}" {{if index $.Selected .ID}}checked{{end}} />
|
||||
<label for="tag-{{.Name}}">{{.Name}}</label>
|
||||
{{end}}
|
||||
|
||||
<input type="submit" value="Senden" hx-post="/resubmit-article/" hx-target="#page-content" />
|
||||
</form>
|
||||
|
||||
<button hx-get="/hub/" hx-target="#page-content">Zurück</button>
|
||||
{{end}}
|
||||
|
@ -5,9 +5,9 @@
|
||||
{{.Article.Content}}
|
||||
|
||||
<p>
|
||||
{{range .Tags}}
|
||||
{{.Name}}
|
||||
{{end}}
|
||||
{{range .Tags}}
|
||||
{{.Name}}
|
||||
{{end}}
|
||||
</p>
|
||||
|
||||
<input name="id" type="hidden" value="{{.Article.ID}}" />
|
||||
|
@ -1,16 +1,10 @@
|
||||
{{define "page-content"}}
|
||||
<form>
|
||||
<div>
|
||||
{{range .}}
|
||||
<div>
|
||||
<input required id="{{.ID}}" name="id" type="radio" value="{{.ID}}" />
|
||||
<label for="{{.ID}}">{{.Title}}</label>
|
||||
</div>
|
||||
{{end}}
|
||||
</div>
|
||||
|
||||
{{range .}}
|
||||
<input required id="{{.ID}}" name="id" type="radio" value="{{.ID}}" />
|
||||
<label for="{{.ID}}">{{.Title}}</label>
|
||||
{{end}}
|
||||
<input type="submit" value="Auswählen" hx-post="/review-unpublished-article/" hx-target="#page-content" />
|
||||
</form>
|
||||
|
||||
<button hx-get="/hub/" hx-target="#page-content">Zurück</button>
|
||||
{{end}}
|
||||
|
Reference in New Issue
Block a user