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