Compare commits
2 commits
2581c2d04a
...
7ccd1a9eff
| Author | SHA1 | Date | |
|---|---|---|---|
| 7ccd1a9eff | |||
| b2ad1654d1 |
10 changed files with 493 additions and 0 deletions
48
client/index.html
Normal file
48
client/index.html
Normal file
|
|
@ -0,0 +1,48 @@
|
||||||
|
<!DOCTYPE html>
|
||||||
|
<html>
|
||||||
|
<head>
|
||||||
|
<link rel="stylesheet" type="text/css" href="style.css">
|
||||||
|
</head>
|
||||||
|
<body>
|
||||||
|
<h1 class="title fontXL textCenter backgroundLightGreen colorWhite">Collin and Lucy's Wedding</h1>
|
||||||
|
<div class="contents fontM">
|
||||||
|
<div>
|
||||||
|
<h2 class="textLeft fontL colorLightGreen">When?</h2>
|
||||||
|
<p>Saturday 16th of May 2026.</p>
|
||||||
|
|
||||||
|
<br/>
|
||||||
|
|
||||||
|
<h3 class="colorLightGreen fontM">Agenda</h3>
|
||||||
|
<ul>
|
||||||
|
<li>14:30 - Guests arrive</li>
|
||||||
|
<li>15:00 - Ceremony</li>
|
||||||
|
<li>15:30 - Reception</li>
|
||||||
|
<li>18:30 - Dinner</li>
|
||||||
|
</ul>
|
||||||
|
|
||||||
|
<br/>
|
||||||
|
|
||||||
|
<h2 class="textLeft colorLightGreen fontL">Where?</h2>
|
||||||
|
<a href="https://www.broekerhuis.nl/">
|
||||||
|
<p>
|
||||||
|
Het Broeker Huis <br/>
|
||||||
|
Leeteinde 16 <br/>
|
||||||
|
1151AK Broek in Waterland
|
||||||
|
</p>
|
||||||
|
</a>
|
||||||
|
<br/>
|
||||||
|
<iframe width="425" height="350" src="https://www.openstreetmap.org/export/embed.html?bbox=4.991877973079682%2C52.436195297048144%2C4.994031786918641%2C52.43801523045145&layer=mapnik&marker=52.43710609072568%2C4.992956221103668" style="border: 1px solid black"></iframe><br/>
|
||||||
|
<a href="https://www.openstreetmap.org/node/2869212621"><h5 class="fontS">View</h5></a>
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
<div class="rsvpButton textCenter backgroundLightGreen hidden">
|
||||||
|
<p class="colorBlack">
|
||||||
|
R <br/>
|
||||||
|
S <br/>
|
||||||
|
V <br/>
|
||||||
|
P <br/>
|
||||||
|
</p>
|
||||||
|
</div>
|
||||||
|
<script src="rsvp.js"></script>
|
||||||
|
</body>
|
||||||
|
</html>
|
||||||
30
client/rsvp.js
Normal file
30
client/rsvp.js
Normal file
|
|
@ -0,0 +1,30 @@
|
||||||
|
const COOKIE_NAME = 'hasRsvped'
|
||||||
|
|
||||||
|
function hasRsvped() {
|
||||||
|
const cookies = Object.fromEntries(
|
||||||
|
document.cookie
|
||||||
|
.split(';')
|
||||||
|
.map(x => x.trim().split('='))
|
||||||
|
)
|
||||||
|
|
||||||
|
return cookies[COOKIE_NAME] === 'true'
|
||||||
|
}
|
||||||
|
|
||||||
|
function persistRsvp(hasRsvped = true) {
|
||||||
|
document.cookie = `${COOKIE_NAME}=${String(hasRsvped)}; path=/`
|
||||||
|
console.log(document.cookie);
|
||||||
|
}
|
||||||
|
|
||||||
|
function rsvpButtonClicked() {
|
||||||
|
console.log('here')
|
||||||
|
persistRsvp(true)
|
||||||
|
}
|
||||||
|
|
||||||
|
window.onload = function () {
|
||||||
|
if (!hasRsvped()) {
|
||||||
|
const rsvpButton = document.querySelector('.rsvpButton')
|
||||||
|
rsvpButton.classList.remove('hidden')
|
||||||
|
|
||||||
|
rsvpButton.onclick = rsvpButtonClicked
|
||||||
|
}
|
||||||
|
}
|
||||||
119
client/style.css
Normal file
119
client/style.css
Normal file
|
|
@ -0,0 +1,119 @@
|
||||||
|
/* reset annoying shit */
|
||||||
|
* {
|
||||||
|
padding: 0;
|
||||||
|
margin: 0;
|
||||||
|
}
|
||||||
|
|
||||||
|
a {
|
||||||
|
text-decoration: underline;
|
||||||
|
}
|
||||||
|
|
||||||
|
a:visited {
|
||||||
|
color: inherit;
|
||||||
|
}
|
||||||
|
|
||||||
|
ul {
|
||||||
|
list-style: none;
|
||||||
|
}
|
||||||
|
|
||||||
|
html {
|
||||||
|
height: 100%;
|
||||||
|
width: 100%;
|
||||||
|
}
|
||||||
|
|
||||||
|
body {
|
||||||
|
height: auto;
|
||||||
|
min-height: 100%;
|
||||||
|
width: auto;
|
||||||
|
display: block;
|
||||||
|
}
|
||||||
|
|
||||||
|
/* #region reusable */
|
||||||
|
.hidden {
|
||||||
|
visibility: hidden;
|
||||||
|
}
|
||||||
|
|
||||||
|
.textLeft {
|
||||||
|
text-align: left;
|
||||||
|
}
|
||||||
|
|
||||||
|
.textCenter {
|
||||||
|
text-align: center;
|
||||||
|
}
|
||||||
|
|
||||||
|
.textRight {
|
||||||
|
text-align: right;
|
||||||
|
}
|
||||||
|
|
||||||
|
.colorWhite {
|
||||||
|
color: #ffffff;
|
||||||
|
}
|
||||||
|
|
||||||
|
.colorBlack {
|
||||||
|
color: #000000;
|
||||||
|
}
|
||||||
|
|
||||||
|
.colorLightGreen {
|
||||||
|
color: #8cad87;
|
||||||
|
}
|
||||||
|
|
||||||
|
.backgroundWhite {
|
||||||
|
background-color: #ffffff;
|
||||||
|
}
|
||||||
|
|
||||||
|
.backgroundBlack {
|
||||||
|
background-color: #000000;
|
||||||
|
}
|
||||||
|
|
||||||
|
.backgroundLightGreen {
|
||||||
|
background-color: #8cad87;
|
||||||
|
}
|
||||||
|
|
||||||
|
.fontXL {
|
||||||
|
font-size: 10vmin;
|
||||||
|
}
|
||||||
|
|
||||||
|
.fontL {
|
||||||
|
font-size: 7.5vmin;
|
||||||
|
}
|
||||||
|
|
||||||
|
.fontM {
|
||||||
|
font-size: 5vmin;
|
||||||
|
}
|
||||||
|
|
||||||
|
.fontS {
|
||||||
|
font-size: 2.5vmin;
|
||||||
|
}
|
||||||
|
|
||||||
|
.fontXS {
|
||||||
|
font-size: 1vmin;
|
||||||
|
}
|
||||||
|
/* #endregion */
|
||||||
|
|
||||||
|
.title {
|
||||||
|
padding-left: 100px;
|
||||||
|
padding-right: 100px;
|
||||||
|
padding-top: 50px;
|
||||||
|
padding-bottom: 50px;
|
||||||
|
}
|
||||||
|
|
||||||
|
/* #region contents */
|
||||||
|
.contents {
|
||||||
|
height: auto;
|
||||||
|
padding: 50px;
|
||||||
|
}
|
||||||
|
/* #endregion
|
||||||
|
|
||||||
|
/* #region rsvp */
|
||||||
|
.rsvpButton {
|
||||||
|
position: fixed;
|
||||||
|
height: 100px;
|
||||||
|
width: 18px;
|
||||||
|
top: 25px;
|
||||||
|
right: 0px;
|
||||||
|
padding: 16px;
|
||||||
|
border-radius: 16px 0px 0px 16px;
|
||||||
|
mix-blend-mode: color-dodge;
|
||||||
|
cursor: pointer;
|
||||||
|
}
|
||||||
|
/* #endregion */
|
||||||
28
server/database.go
Normal file
28
server/database.go
Normal file
|
|
@ -0,0 +1,28 @@
|
||||||
|
package main
|
||||||
|
|
||||||
|
import (
|
||||||
|
"database/sql"
|
||||||
|
"fmt"
|
||||||
|
"log"
|
||||||
|
)
|
||||||
|
|
||||||
|
func SetupDatabase() *sql.DB {
|
||||||
|
db, err := sql.Open("sqlite3", "./db.sqlite")
|
||||||
|
|
||||||
|
if err != nil {
|
||||||
|
log.Fatal("failed to open database")
|
||||||
|
}
|
||||||
|
|
||||||
|
var version string
|
||||||
|
err = db.QueryRow("SELECT SQLITE_VERSION()").Scan(&version)
|
||||||
|
|
||||||
|
if err != nil {
|
||||||
|
log.Fatal("failed to query database")
|
||||||
|
}
|
||||||
|
|
||||||
|
fmt.Println(version)
|
||||||
|
|
||||||
|
SetupRsvpsTable(db)
|
||||||
|
|
||||||
|
return db
|
||||||
|
}
|
||||||
9
server/go.mod
Normal file
9
server/go.mod
Normal file
|
|
@ -0,0 +1,9 @@
|
||||||
|
module collinenlucy.nl
|
||||||
|
|
||||||
|
go 1.24.4
|
||||||
|
|
||||||
|
require (
|
||||||
|
github.com/AnthonyHewins/gotfy v0.0.10 // indirect
|
||||||
|
github.com/goccy/go-json v0.10.2 // indirect
|
||||||
|
github.com/mattn/go-sqlite3 v1.14.28 // indirect
|
||||||
|
)
|
||||||
6
server/go.sum
Normal file
6
server/go.sum
Normal file
|
|
@ -0,0 +1,6 @@
|
||||||
|
github.com/AnthonyHewins/gotfy v0.0.10 h1:23ZjRVG7wuGuqn7CQq/bOrkXa3gg2XyYrrD3RYEmvE8=
|
||||||
|
github.com/AnthonyHewins/gotfy v0.0.10/go.mod h1:q2orErDDpl9/gZ5L4oJhejb7TaP/eBdtkzjWDruNRlg=
|
||||||
|
github.com/goccy/go-json v0.10.2 h1:CrxCmQqYDkv1z7lO7Wbh2HN93uovUHgrECaO5ZrCXAU=
|
||||||
|
github.com/goccy/go-json v0.10.2/go.mod h1:6MelG93GURQebXPDq3khkgXZkazVtN9CRI+MGFi0w8I=
|
||||||
|
github.com/mattn/go-sqlite3 v1.14.28 h1:ThEiQrnbtumT+QMknw63Befp/ce/nUPgBPMlRFEum7A=
|
||||||
|
github.com/mattn/go-sqlite3 v1.14.28/go.mod h1:Uh1q+B4BYcTPb+yiD3kU8Ct7aC0hY9fxUwlHK0RXw+Y=
|
||||||
43
server/http.go
Normal file
43
server/http.go
Normal file
|
|
@ -0,0 +1,43 @@
|
||||||
|
package main
|
||||||
|
|
||||||
|
import (
|
||||||
|
"database/sql"
|
||||||
|
"fmt"
|
||||||
|
"net/http"
|
||||||
|
"time"
|
||||||
|
)
|
||||||
|
|
||||||
|
type Handler struct {
|
||||||
|
db *sql.DB
|
||||||
|
}
|
||||||
|
|
||||||
|
func (h *Handler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
|
||||||
|
fmt.Printf("%s - [%s] (%s) %s\n", time.Now().Format(time.RFC3339), r.RemoteAddr, r.Method, r.URL)
|
||||||
|
|
||||||
|
switch true {
|
||||||
|
case r.Method == "GET" && r.URL.Path == "/":
|
||||||
|
rsvps, err := GetRsvps(h.db)
|
||||||
|
if err != nil {
|
||||||
|
w.WriteHeader(http.StatusInternalServerError)
|
||||||
|
fmt.Fprintf(w, "%s", err.Error())
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
w.WriteHeader(http.StatusOK)
|
||||||
|
fmt.Fprintf(w, "%#v", rsvps)
|
||||||
|
case r.Method == "POST" && r.URL.Path == "/":
|
||||||
|
r := Rsvp{
|
||||||
|
id: -1,
|
||||||
|
attending: true,
|
||||||
|
partySize: 2,
|
||||||
|
partyMembers: []Member{
|
||||||
|
{name: "test", dietaryPreferences: "no meat", child: false},
|
||||||
|
{name: "; DROP TABLE rsvps", dietaryPreferences: "", child: true},
|
||||||
|
},
|
||||||
|
}
|
||||||
|
r.CreateRsvp(h.db)
|
||||||
|
w.WriteHeader(http.StatusAccepted)
|
||||||
|
default:
|
||||||
|
w.WriteHeader(http.StatusNotFound)
|
||||||
|
}
|
||||||
|
}
|
||||||
14
server/main.go
Normal file
14
server/main.go
Normal file
|
|
@ -0,0 +1,14 @@
|
||||||
|
package main
|
||||||
|
|
||||||
|
import (
|
||||||
|
"net/http"
|
||||||
|
|
||||||
|
_ "github.com/mattn/go-sqlite3"
|
||||||
|
)
|
||||||
|
|
||||||
|
func main() {
|
||||||
|
SetupNtfyClient()
|
||||||
|
db := SetupDatabase()
|
||||||
|
hnd := &Handler{db}
|
||||||
|
http.ListenAndServe(":8000", hnd)
|
||||||
|
}
|
||||||
67
server/ntfy.go
Normal file
67
server/ntfy.go
Normal file
|
|
@ -0,0 +1,67 @@
|
||||||
|
package main
|
||||||
|
|
||||||
|
import (
|
||||||
|
"context"
|
||||||
|
"fmt"
|
||||||
|
"log"
|
||||||
|
"net/http"
|
||||||
|
"net/url"
|
||||||
|
"os"
|
||||||
|
"strings"
|
||||||
|
|
||||||
|
"github.com/AnthonyHewins/gotfy"
|
||||||
|
)
|
||||||
|
|
||||||
|
var client *gotfy.Publisher
|
||||||
|
|
||||||
|
type authdTransport struct {
|
||||||
|
underlyingTransport http.RoundTripper
|
||||||
|
}
|
||||||
|
|
||||||
|
func (t *authdTransport) RoundTrip(req *http.Request) (*http.Response, error) {
|
||||||
|
var ntfyToken string
|
||||||
|
env := os.Environ()
|
||||||
|
for _, keyVal := range env {
|
||||||
|
keyValArr := strings.Split(keyVal, "=")
|
||||||
|
if keyValArr[0] == "NTFY_TOKEN" {
|
||||||
|
ntfyToken = keyValArr[1]
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
req.Header.Add("Authorization", "Bearer "+ntfyToken)
|
||||||
|
return t.underlyingTransport.RoundTrip(req)
|
||||||
|
}
|
||||||
|
|
||||||
|
func SetupNtfyClient() {
|
||||||
|
server, err := url.Parse("https://home.collinduncan.com/ntfy")
|
||||||
|
|
||||||
|
if err != nil {
|
||||||
|
log.Fatal(err)
|
||||||
|
}
|
||||||
|
|
||||||
|
authdHttpClient := &http.Client{Transport: &authdTransport{underlyingTransport: http.DefaultTransport}}
|
||||||
|
|
||||||
|
tp, err := gotfy.NewPublisher(server, authdHttpClient)
|
||||||
|
|
||||||
|
if err != nil {
|
||||||
|
log.Fatal(err)
|
||||||
|
}
|
||||||
|
|
||||||
|
client = tp
|
||||||
|
resp, err := client.SendMessage(context.Background(), &gotfy.Message{
|
||||||
|
Topic: "collinenlucy_nl",
|
||||||
|
Message: "Collin RSVP'd",
|
||||||
|
Title: "New RSVP",
|
||||||
|
Tags: []string{},
|
||||||
|
Priority: gotfy.Default,
|
||||||
|
})
|
||||||
|
|
||||||
|
if err != nil {
|
||||||
|
log.Fatal(err)
|
||||||
|
}
|
||||||
|
|
||||||
|
fmt.Printf("%s\n", resp.ID)
|
||||||
|
}
|
||||||
|
|
||||||
|
func SendRsvpNotification() {
|
||||||
|
}
|
||||||
129
server/rsvp.go
Normal file
129
server/rsvp.go
Normal file
|
|
@ -0,0 +1,129 @@
|
||||||
|
package main
|
||||||
|
|
||||||
|
import (
|
||||||
|
"database/sql"
|
||||||
|
"fmt"
|
||||||
|
"log"
|
||||||
|
"net/url"
|
||||||
|
"strings"
|
||||||
|
)
|
||||||
|
|
||||||
|
type Member struct {
|
||||||
|
name string
|
||||||
|
dietaryPreferences string
|
||||||
|
child bool
|
||||||
|
}
|
||||||
|
|
||||||
|
func (m *Member) serialize() string {
|
||||||
|
builder := new(strings.Builder)
|
||||||
|
fmt.Fprintf(builder, "%s,%s,%t,", url.QueryEscape(m.name), url.QueryEscape(m.dietaryPreferences), m.child)
|
||||||
|
return builder.String()
|
||||||
|
}
|
||||||
|
|
||||||
|
func deserializeMembers(serializedData string) ([]Member, error) {
|
||||||
|
members := make([]Member, 0)
|
||||||
|
keyVals := strings.Split(serializedData, ",")
|
||||||
|
for i := 0; i < len(keyVals)-1; i += 3 {
|
||||||
|
name, err := url.QueryUnescape(keyVals[i])
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
dietaryPreferences, err := url.QueryUnescape(keyVals[i+1])
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
child := keyVals[i+2] == "true"
|
||||||
|
|
||||||
|
members = append(members, Member{
|
||||||
|
name: name,
|
||||||
|
dietaryPreferences: dietaryPreferences,
|
||||||
|
child: child,
|
||||||
|
})
|
||||||
|
}
|
||||||
|
return members, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
type Rsvp struct {
|
||||||
|
id int64
|
||||||
|
attending bool
|
||||||
|
partySize int64
|
||||||
|
partyMembers []Member
|
||||||
|
}
|
||||||
|
|
||||||
|
func SetupRsvpsTable(db *sql.DB) {
|
||||||
|
_, err := db.Exec(`CREATE TABLE IF NOT EXISTS rsvps (
|
||||||
|
id INTEGER PRIMARY KEY AUTOINCREMENT,
|
||||||
|
attending BOOLEAN NOT NULL,
|
||||||
|
partySize INTEGER NOT NULL,
|
||||||
|
partyMembers BLOB NOT NULL
|
||||||
|
);`)
|
||||||
|
|
||||||
|
if err != nil {
|
||||||
|
log.Fatalf("failed to create rsvp table: %s", err.Error())
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func GetRsvps(db *sql.DB) ([]Rsvp, error) {
|
||||||
|
rows, err := db.Query("SELECT * FROM rsvps ORDER BY id desc")
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
|
||||||
|
defer rows.Close()
|
||||||
|
|
||||||
|
rsvps := make([]Rsvp, 0)
|
||||||
|
|
||||||
|
for rows.Next() {
|
||||||
|
var id int64
|
||||||
|
var attending bool
|
||||||
|
var partySize int64
|
||||||
|
var rawPartyMembers string
|
||||||
|
|
||||||
|
err = rows.Scan(&id, &attending, &partySize, &rawPartyMembers)
|
||||||
|
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
|
||||||
|
members, err := deserializeMembers(rawPartyMembers)
|
||||||
|
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
|
||||||
|
rsvps = append(rsvps, Rsvp{
|
||||||
|
id: id,
|
||||||
|
attending: attending,
|
||||||
|
partySize: partySize,
|
||||||
|
partyMembers: members,
|
||||||
|
})
|
||||||
|
}
|
||||||
|
|
||||||
|
return rsvps, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func (rsvp *Rsvp) CreateRsvp(db *sql.DB) (int64, error) {
|
||||||
|
partyMembersBuilder := new(strings.Builder)
|
||||||
|
for _, m := range rsvp.partyMembers {
|
||||||
|
partyMembersBuilder.WriteString(m.serialize())
|
||||||
|
}
|
||||||
|
fmt.Printf("%s\n", partyMembersBuilder.String())
|
||||||
|
result, err := db.Exec(
|
||||||
|
"INSERT INTO rsvps (attending, partySize, partyMembers) VALUES (?, ?, ?);",
|
||||||
|
rsvp.attending,
|
||||||
|
rsvp.partySize,
|
||||||
|
partyMembersBuilder.String(),
|
||||||
|
)
|
||||||
|
|
||||||
|
if err != nil {
|
||||||
|
return -1, err
|
||||||
|
}
|
||||||
|
|
||||||
|
id, err := result.LastInsertId()
|
||||||
|
|
||||||
|
if err != nil {
|
||||||
|
return -1, err
|
||||||
|
}
|
||||||
|
|
||||||
|
return id, nil
|
||||||
|
}
|
||||||
Loading…
Add table
Reference in a new issue