Use helper functions throughout

This commit is contained in:
adnano 2020-09-27 22:03:09 -04:00
parent 707ebf1c0c
commit 599c5bb131
2 changed files with 19 additions and 24 deletions

View File

@ -45,7 +45,7 @@ func main() {
} }
handler := &gmi.ServeMux{} handler := &gmi.ServeMux{}
handler.HandleFunc("", welcome) handler.HandleFunc("/", welcome)
handler.HandleFunc("/login", login) handler.HandleFunc("/login", login)
handler.HandleFunc("/login/password", loginPassword) handler.HandleFunc("/login/password", loginPassword)
handler.HandleFunc("/profile", profile) handler.HandleFunc("/profile", profile)
@ -69,23 +69,22 @@ func getSession(crt *x509.Certificate) (*session, bool) {
} }
func welcome(rw *gmi.ResponseWriter, req *gmi.Request) { func welcome(rw *gmi.ResponseWriter, req *gmi.Request) {
rw.WriteHeader(gmi.StatusSuccess, "text/gemini")
rw.Write([]byte("Welcome to this example.\n=> /login Login\n")) rw.Write([]byte("Welcome to this example.\n=> /login Login\n"))
} }
func login(rw *gmi.ResponseWriter, req *gmi.Request) { func login(rw *gmi.ResponseWriter, req *gmi.Request) {
if len(req.TLS.PeerCertificates) > 0 { if len(req.TLS.PeerCertificates) > 0 {
if username := req.URL.RawQuery; username == "" { if username := req.URL.RawQuery; username == "" {
rw.WriteHeader(gmi.StatusInput, "Username") gmi.Input(rw, req, "Username")
} else { } else {
fingerprint := gmi.Fingerprint(req.TLS.PeerCertificates[0]) fingerprint := gmi.Fingerprint(req.TLS.PeerCertificates[0])
sessions[fingerprint] = &session{ sessions[fingerprint] = &session{
username: username, username: username,
} }
rw.WriteHeader(gmi.StatusRedirect, "/login/password") gmi.Redirect(rw, req, "/login/password", false)
} }
} else { } else {
rw.WriteHeader(gmi.StatusCertificateRequired, "Certificate required") gmi.CertificateRequired(rw, req)
} }
} }
@ -93,23 +92,23 @@ func loginPassword(rw *gmi.ResponseWriter, req *gmi.Request) {
if len(req.TLS.PeerCertificates) > 0 { if len(req.TLS.PeerCertificates) > 0 {
session, ok := getSession(req.TLS.PeerCertificates[0]) session, ok := getSession(req.TLS.PeerCertificates[0])
if !ok { if !ok {
rw.WriteHeader(gmi.StatusCertificateNotAuthorized, "Not authorized") gmi.CertificateNotAuthorized(rw, req)
return return
} }
if password := req.URL.RawQuery; password == "" { if password := req.URL.RawQuery; password == "" {
rw.WriteHeader(gmi.StatusInput, "Password") gmi.SensitiveInput(rw, req, "Password")
} else { } else {
expected := logins[session.username].password expected := logins[session.username].password
if password == expected { if password == expected {
session.authorized = true session.authorized = true
rw.WriteHeader(gmi.StatusRedirect, "/profile") gmi.Redirect(rw, req, "/profile", false)
} else { } else {
rw.WriteHeader(gmi.StatusInput, "Wrong password. Please try again") gmi.SensitiveInput(rw, req, "Wrong password. Try again")
} }
} }
} else { } else {
rw.WriteHeader(gmi.StatusCertificateRequired, "Certificate required") gmi.CertificateRequired(rw, req)
} }
} }
@ -118,7 +117,6 @@ func logout(rw *gmi.ResponseWriter, req *gmi.Request) {
fingerprint := gmi.Fingerprint(req.TLS.PeerCertificates[0]) fingerprint := gmi.Fingerprint(req.TLS.PeerCertificates[0])
delete(sessions, fingerprint) delete(sessions, fingerprint)
} }
rw.WriteHeader(gmi.StatusSuccess, "text/gemini")
rw.Write([]byte("Successfully logged out.\n")) rw.Write([]byte("Successfully logged out.\n"))
} }
@ -126,15 +124,14 @@ func profile(rw *gmi.ResponseWriter, req *gmi.Request) {
if len(req.TLS.PeerCertificates) > 0 { if len(req.TLS.PeerCertificates) > 0 {
session, ok := getSession(req.TLS.PeerCertificates[0]) session, ok := getSession(req.TLS.PeerCertificates[0])
if !ok { if !ok {
rw.WriteHeader(gmi.StatusCertificateNotAuthorized, "Certificate not authorized") gmi.CertificateNotAuthorized(rw, req)
return return
} }
user := logins[session.username] user := logins[session.username]
profile := fmt.Sprintf("Username: %s\nAdmin: %t\n=> /logout Logout", session.username, user.admin) profile := fmt.Sprintf("Username: %s\nAdmin: %t\n=> /logout Logout", session.username, user.admin)
rw.WriteHeader(gmi.StatusSuccess, "text/gemini")
rw.Write([]byte(profile)) rw.Write([]byte(profile))
} else { } else {
rw.WriteHeader(gmi.StatusCertificateRequired, "Certificate required") gmi.CertificateRequired(rw, req)
} }
} }
@ -142,17 +139,16 @@ func admin(rw *gmi.ResponseWriter, req *gmi.Request) {
if len(req.TLS.PeerCertificates) > 0 { if len(req.TLS.PeerCertificates) > 0 {
session, ok := getSession(req.TLS.PeerCertificates[0]) session, ok := getSession(req.TLS.PeerCertificates[0])
if !ok { if !ok {
rw.WriteHeader(gmi.StatusCertificateNotAuthorized, "Certificate not authorized") gmi.CertificateNotAuthorized(rw, req)
return return
} }
user := logins[session.username] user := logins[session.username]
if !user.admin { if !user.admin {
rw.WriteHeader(gmi.StatusCertificateNotAuthorized, "Admins only!") gmi.CertificateNotAuthorized(rw, req)
return return
} }
rw.WriteHeader(gmi.StatusSuccess, "text/gemini")
rw.Write([]byte("Welcome to the admin portal.\n")) rw.Write([]byte("Welcome to the admin portal.\n"))
} else { } else {
rw.WriteHeader(gmi.StatusCertificateRequired, "Certificate required") gmi.CertificateRequired(rw, req)
} }
} }

View File

@ -145,11 +145,11 @@ func (r *ResponseWriter) SetMimetype(mimetype string) {
// SetMimetype. If no mimetype is set, a default of "text/gemini" will be used. // SetMimetype. If no mimetype is set, a default of "text/gemini" will be used.
func (r *ResponseWriter) Write(b []byte) (int, error) { func (r *ResponseWriter) Write(b []byte) (int, error) {
if !r.wroteHeader { if !r.wroteHeader {
if r.mimetype != "" { mimetype := r.mimetype
r.WriteHeader(StatusSuccess, r.mimetype) if mimetype == "" {
} else { mimetype = "text/gemini"
r.WriteHeader(StatusSuccess, "text/gemini")
} }
r.WriteHeader(StatusSuccess, mimetype)
} }
if !r.bodyAllowed { if !r.bodyAllowed {
return 0, ErrBodyNotAllowed return 0, ErrBodyNotAllowed
@ -395,8 +395,7 @@ func (fsys fsHandler) Serve(rw *ResponseWriter, req *Request) {
return return
} }
// TODO: detect mimetype // TODO: detect mimetype
mime := "text/gemini" rw.SetMimetype("text/gemini")
rw.WriteHeader(StatusSuccess, mime)
// Copy file to response writer // Copy file to response writer
io.Copy(rw, f) io.Copy(rw, f)
} }