💾 Archived View for source.community › ckaznocha › gemini › blob › main › request.go captured on 2023-01-29 at 03:22:40. Gemini links have been rewritten to link to archived content

-=-=-=-=-=-=-

                                                         .
,-. ,-. . . ,-. ,-. ,-.    ,-. ,-. ,-,-. ,-,-. . . ,-. . |- . .
`-. | | | | |   |   |-'    |   | | | | | | | | | | | | | |  | |
`-' `-' `-^ '   `-' `-' :: `-' `-' ' ' ' ' ' ' `-^ ' ' ' `' `-|
                                                             /|
                                                            `-'

ckaznocha / gemini

git clone https://source.community/ckaznocha/gemini.git

Branches

Log

Tree

/request.go (main)

↑ /

blob

View raw contents of /request.go (main)

────╮
   1│ package gemini
   2│ 
   3│ import (
   4│ 	"bufio"
   5│ 	"crypto/x509/pkix"
   6│ 	"fmt"
   7│ 	"net/textproto"
   8│ )
   9│ 
  10│ const maxRequestLength = 1024
  11│ 
  12│ // Request is a Gemini request.
  13│ type Request struct {
  14│ 	Subject    *pkix.Name
  15│ 	URI        *URI
  16│ 	RemoteAddr string
  17│ }
  18│ 
  19│ // ReadRequest reads and parses a Gemini request from buffer. It returns an
  20│ // error if the request could not be read or was  malformed.
  21│ func ReadRequest(b *bufio.Reader) (*Request, error) {
  22│ 	u := []byte{}
  23│ 	cr := false
  24│ 
  25│ 	for {
  26│ 		b, err := b.ReadByte()
  27│ 		if err != nil {
  28│ 			return nil, fmt.Errorf("%w: %s", ErrRequestRead, err)
  29│ 		}
  30│ 
  31│ 		if b == '\r' {
  32│ 			cr = true
  33│ 
  34│ 			continue
  35│ 		}
  36│ 
  37│ 		if cr && b == '\n' {
  38│ 			break
  39│ 		}
  40│ 
  41│ 		cr = false
  42│ 
  43│ 		u = append(u, b)
  44│ 		if len(u) > maxRequestLength {
  45│ 			return nil, ErrMaxRequestLengthExceeded
  46│ 		}
  47│ 	}
  48│ 
  49│ 	uri, err := ParseRequestURI(string(textproto.TrimBytes(u)))
  50│ 	if err != nil {
  51│ 		return nil, err
  52│ 	}
  53│ 
  54│ 	return &Request{URI: uri}, nil
  55│ }
────╯

· · ·

info@source.community