http_ns

package
v0.2.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 9, 2024 License: MIT Imports: 74 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	HTTP_UPLOAD_RATE_LIMIT_NAME  = "http/upload"
	HTTP_REQUEST_RATE_LIMIT_NAME = "http/request"

	DEFAULT_HTTP_CLIENT_TIMEOUT = 10 * time.Second

	MISSING_URL_ARG           = "missing core.URL argument"
	OPTION_DOES_NOT_EXIST_FMT = "option '%s' does not exist"

	CERT_MAGIG_LOG_SRC = "http/certmagic"
)
View Source 
const (
	CSP_HEADER_NAME          = "Content-Security-Policy"
	DEFAULT_NONCE_BYTE_COUNT = 16
)
View Source 
const (
	INOX_FILE_EXTENSION            = inoxconsts.INOXLANG_FILE_EXTENSION
	PATH_PARAMS_CTX_DATA_NAMESPACE = core.Path("/path-params/")

	FS_ROUTING_LOG_SRC = "fs-routing"
)
View Source 
const (
	DEFAULT_SELF_SIGNED_CERT_VALIDITY_DURATION = time.Hour * 24 * 180
	RELATIVE_SELF_SIGNED_CERT_FILEPATH         = "./" + inoxconsts.DEV_DIR_NAME + "/self_signed.cert"
	RELATIVE_SELF_SIGNED_CERT_KEY_FILEPATH     = "./" + inoxconsts.DEV_DIR_NAME + "/self_signed.key"
)
View Source 
const (
	HTTP_READ_PERM_MIGHT_BE_MISSING    = "http read permission might be missing"
	HTTP_WRITE_PERM_MIGHT_BE_MISSING   = "http write permission might be missing"
	HTTP_DELETE_PERM_MIGHT_BE_MISSING  = "http delete permission might be missing"
	HTTP_PROVIDE_PERM_MIGHT_BE_MISSING = "http provide permission might be missing"
)
View Source 
const (
	RESULT_INIT_STATUS_PROPNAME  = "status"
	RESULT_INIT_BODY_PROPNAME    = "body"
	RESULT_INIT_HEADERS_PROPNAME = "headers"
	RESULT_INIT_SESSION_PROPNAME = "session"
)
View Source 
const (
	//socket
	SOCKET_RLIMIT_WINDOW       = 10 * time.Second
	SOCKET_MAX_READ_REQ_COUNT  = 10
	SOCKET_MAX_WRITE_REQ_COUNT = 5

	//ip level
	SHARED_READ_BURST_WINDOW     = 10 * time.Second
	SHARED_READ_BURST_WINDOW_REQ = 60

	SHARED_WRITE_BURST_WINDOW     = 10 * time.Second
	SHARED_WRITE_BURST_WINDOW_REQ = 10
)
View Source 
const (
	DEFAULT_HTTP_SERVER_READ_HEADER_TIMEOUT = 3 * time.Second
	DEFAULT_HTTP_SERVER_READ_TIMEOUT        = DEFAULT_HTTP_SERVER_READ_HEADER_TIMEOUT + 8*time.Second
	DEFAULT_HTTP_SERVER_WRITE_TIMEOUT       = 2 * (DEFAULT_HTTP_SERVER_READ_TIMEOUT - DEFAULT_HTTP_SERVER_READ_HEADER_TIMEOUT)
	DEFAULT_HTTP_SERVER_MAX_HEADER_BYTES    = 1 << 12
	DEFAULT_HTTP_SERVER_TX_TIMEOUT          = 20 * time.Second
	SSE_STREAM_WRITE_TIMEOUT                = 500 * time.Second

	HTTP_SERVER_STARTING_WAIT_TIME        = 5 * time.Millisecond
	HTTP_SERVER_GRACEFUL_SHUTDOWN_TIMEOUT = 5 * time.Second

	NO_HANDLER_PLACEHOLDER_MESSAGE = "hello"

	HANDLING_DESC_ROUTING_PROPNAME     = "routing"
	HANDLING_DESC_DEFAULT_CSP_PROPNAME = "default-csp"
	HANDLING_DESC_CERTIFICATE_PROPNAME = "certificate"
	HANDLING_DESC_KEY_PROPNAME         = "key"

	HANDLING_DESC_DEFAULT_LIMITS_PROPNAME = "default-limits"
	HANDLING_DESC_MAX_LIMITS_PROPNAME     = "max-limits"
	HANDLING_DESC_SESSIONS_PROPNAME       = "sessions"
	SESSIONS_DESC_COLLECTION_PROPNAME     = "collection"

	HTTP_SERVER_SRC = "http/server"

	SESSION_ID_PROPNAME = "id"
)
View Source 
const (
	DEFAULT_HTTPS_PORT = "443"

	SERVER_HANDLING_ARG_NAME = "handler/handling"
)
View Source 
const (
	MIN_SESSION_ID_BYTE_COUNT      = 16
	MAX_SESSION_ID_BYTE_COUNT      = 32
	DEFAULT_SESSION_ID_BYTE_COUNT  = MIN_SESSION_ID_BYTE_COUNT
	DEFAULT_SESSION_ID_COOKIE_NAME = "session-id"

	SESSION_CTX_DATA_KEY = core.Path("/session")
)
View Source 
const (
	INITIAL_SSE_CLIENT_BUFFER_SIZE = 4096
	MAX_SSE_CLIENT_BUFFER_SIZE     = 1 << 16
)
View Source 
const (
	VIEW_UPDATE_WATCHING_TIMEOUT        = 10 * time.Millisecond
	VIEW_UPDATE_SSE_STREAM_STOP_TIMEOUT = 10 * time.Millisecond
)
View Source 
const DEFAULT_ACCEPT_HEADER = "*/*"
View Source 
const DEFAULT_EVENT_STREAM_BUFFER_SIZE = 200
View Source 
const DEFAULT_SUBSCRIPTION_CHAN_SIZE = 50
View Source 
const (
	REQUEST_ID_LOG_FIELD_NAME = "reqID"
)
View Source 
const (
	STOPPING_SUB_WAIT_TIME = time.Millisecond
)

Variables

View Source 
var (
	DEFAULT_PUSHED_BYTESTREAM_CHUNK_SIZE_RANGE = core.NewIntRange(100, 1000)
	BYTESTREAM_SSE_STREAM_STOP_TIMEOUT         = 10 * time.Millisecond
	BYTESTREAM_CHUNK_WAIT_TIMEOUT              = 2 * time.Millisecond
)
View Source 
var (
	DEFAULT_CSP, _ = NewCSPWithDirectives(nil)

	HANDLER_DISABLED_ARGS = []bool{true, true}
)
View Source 
var (
	STATUS_NAMESPACE = core.NewNamespace("status", map[string]core.Value{

		"OK": StatusCode(http.StatusOK),

		"MOVED_PERMANENTLY":  StatusCode(http.StatusMovedPermanently),
		"SEE_OTHER":          StatusCode(http.StatusSeeOther),
		"TEMPORARY_REDIRECT": StatusCode(http.StatusTemporaryRedirect),
		"PERMANENT_REDIRECT": StatusCode(http.StatusPermanentRedirect),

		"BAD_REQUEST":        StatusCode(http.StatusBadRequest),
		"UNAUTHORIZED":       StatusCode(http.StatusUnauthorized),
		"FORBIDDEN":          StatusCode(http.StatusForbidden),
		"NOT_FOUND":          StatusCode(http.StatusNotFound),
		"METHOD_NOT_ALLOWED": StatusCode(http.StatusMethodNotAllowed),
		"NOT_ACCEPTABLE":     StatusCode(http.StatusNotAcceptable),

		"INTERNAL_SERVER_ERROR":      StatusCode(http.StatusInternalServerError),
		"BAD_GATEWAY":                StatusCode(http.StatusBadGateway),
		"GATEWAY_TIMEOUT":            StatusCode(http.StatusGatewayTimeout),
		"HTTP_VERSION_NOT_SUPPORTED": StatusCode(http.StatusHTTPVersionNotSupported),
	})

	MAKE_STATUS_CODE_PARAMS      = &[]symbolic.Value{http_symbolic.STATUS_CODE_INT_VALUE}
	MAKE_STATUS_CODE_PARAM_NAMES = []string{"code"}
)
View Source 
var (
	CALLABLE_HTTP_REQUEST_PATTERN = &core.TypePattern{
		Name:             "http.req",
		Type:             reflect.TypeOf(&Request{}),
		SymbolicValue:    &http_symbolic.Request{},
		CallImpl:         createRequestPattern,
		SymbolicCallImpl: createSymbolicRequestPattern,
	}

	HTTP_REQUEST_PATTERN_PATTERN = &core.TypePattern{
		Name:          "http.req-pattern",
		Type:          reflect.TypeOf(&RequestPattern{}),
		SymbolicValue: http_symbolic.ANY_REQUEST_PATTERN,
	}
)
View Source 
var (
	ErrNotAcceptedContentType                   = errors.New("not accepted content type")
	ErrCannotMutateWriterOfFinishedResponse     = errors.New("cannot mutate writer of finished response")
	ErrCannotMutateWriterWithDetachedRespWriter = errors.New("cannot mutate writer with detached response writer")
	ErrStatusAlreadySent                        = errors.New("status already sent")
)
View Source 
var (
	SYMBOLIC_RESULT_INIT_ARG = symbolic.NewInexactObject(
		map[string]symbolic.Serializable{
			RESULT_INIT_STATUS_PROPNAME:  http_ns_symb.ANY_STATUS_CODE,
			RESULT_INIT_BODY_PROPNAME:    symbolic.AsSerializableChecked(symbolic.NewMultivalue(html_ns_symb.ANY_HTML_NODE, symbolic.ANY_STR_LIKE)),
			RESULT_INIT_HEADERS_PROPNAME: symbolic.NewInexactObject2(map[string]symbolic.Serializable{}),
			RESULT_INIT_SESSION_PROPNAME: symbolic.NewInexactObject2(map[string]symbolic.Serializable{SESSION_ID_PROPNAME: symbolic.ANY_STR_LIKE}),
		},
		map[string]struct{}{
			RESULT_INIT_STATUS_PROPNAME:  {},
			RESULT_INIT_BODY_PROPNAME:    {},
			RESULT_INIT_HEADERS_PROPNAME: {},
			RESULT_INIT_SESSION_PROPNAME: {},
		},
		nil)
	NEW_RESULT_PARAMS      = &[]symbolic.Value{SYMBOLIC_RESULT_INIT_ARG}
	NEW_RESULT_PARAM_NAMES = []string{"init"}
)
View Source 
var (
	ErrHandlerNotSharable            = errors.New("handler is not sharable")
	ErrCannotMutateInitializedServer = errors.New("cannot mutate initialized server")

	HTTP_ROUTING_SYMB_OBJ = symbolic.NewInexactObject(map[string]symbolic.Serializable{
		"static":  symbolic.ANY_ABS_DIR_PATH,
		"dynamic": symbolic.ANY_ABS_DIR_PATH,
	}, map[string]struct{}{
		"static":  {},
		"dynamic": {},
	}, nil)

	SESSIONS_CONFIG_SYMB_OBJ = symbolic.NewInexactObject2(map[string]symbolic.Serializable{
		SESSIONS_DESC_COLLECTION_PROPNAME: symb_containers.NewSetWithPattern(symbolic.ANY_PATTERN, common.NewPropertyValueUniqueness(SESSION_ID_PROPNAME)),
	})

	SYMBOLIC_HANDLING_DESC = symbolic.NewInexactObject(map[string]symbolic.Serializable{
		HANDLING_DESC_ROUTING_PROPNAME: symbolic.AsSerializableChecked(symbolic.NewMultivalue(
			symbolic.ANY_INOX_FUNC,
			symbolic.NewMapping(),
			HTTP_ROUTING_SYMB_OBJ,
		)),
		HANDLING_DESC_DEFAULT_CSP_PROPNAME:    http_ns_symb.ANY_CSP,
		HANDLING_DESC_CERTIFICATE_PROPNAME:    symbolic.ANY_STR_LIKE,
		HANDLING_DESC_KEY_PROPNAME:            symbolic.ANY_SECRET,
		HANDLING_DESC_DEFAULT_LIMITS_PROPNAME: symbolic.ANY_OBJ,
		HANDLING_DESC_MAX_LIMITS_PROPNAME:     symbolic.ANY_OBJ,
		HANDLING_DESC_SESSIONS_PROPNAME:       SESSIONS_CONFIG_SYMB_OBJ,
	}, map[string]struct{}{

		HANDLING_DESC_DEFAULT_CSP_PROPNAME:    {},
		HANDLING_DESC_CERTIFICATE_PROPNAME:    {},
		HANDLING_DESC_KEY_PROPNAME:            {},
		HANDLING_DESC_DEFAULT_LIMITS_PROPNAME: {},
		HANDLING_DESC_MAX_LIMITS_PROPNAME:     {},
		HANDLING_DESC_SESSIONS_PROPNAME:       {},
	}, nil)

	NEW_SERVER_SINGLE_PARAM_NAME = []string{"host"}
	NEW_SERVER_TWO_PARAM_NAMES   = []string{"host", "handling"}
)
View Source 
var (
	MIN_SESSION_ID_LEN   = hex.EncodedLen(MIN_SESSION_ID_BYTE_COUNT)
	MAX_SESSION_ID_LEN   = hex.EncodedLen(MAX_SESSION_ID_BYTE_COUNT)
	ErrSessionNotFound   = errors.New("session not found")
	ErrSessionIdTooLong  = errors.New("session id is too long")
	ErrSessionIdTooShort = errors.New("session id is too short")
)
View Source 
var (
	SSE_ID_HEADER    = []byte("id:")
	SSE_DATA_HEADER  = []byte("data:")
	SSE_EVENT_HEADER = []byte("event:")
	SSE_RETRY_HEADER = []byte("retry:")
)
View Source 
var (
	DEFAULT_DIRECTIVE_VALUES = map[string][]CSPDirectiveValue{
		"default-src": {{/* contains filtered or unexported fields */}},

		"frame-ancestors": {{/* contains filtered or unexported fields */}},
		"frame-src":       {{/* contains filtered or unexported fields */}},

		"script-src-elem": {{/* contains filtered or unexported fields */}},
		"connect-src":     {{/* contains filtered or unexported fields */}},

		"font-src":       {{/* contains filtered or unexported fields */}},
		"img-src":        {{/* contains filtered or unexported fields */}},
		"style-src-elem": {{/* contains filtered or unexported fields */}},
	}
)
View Source 
var (
	DEFAULT_HTTP_PROFILE_CONFIG = ClientConfig{
		SaveCookies: false,
	}
)
View Source 
var DEFAULT_HTTP_REQUEST_OPTIONS = &RequestOptions{
	Timeout:            DEFAULT_HTTP_CLIENT_TIMEOUT,
	InsecureSkipVerify: false,
}
View Source 
var (
	ErrOutOfBoundsStatusCode = errors.New("out of bounds status code")
)
View Source 
var (
	//methods allowed in handler module filenames.
	FS_ROUTING_METHODS = spec.FS_ROUTING_METHODS
)
View Source 
var (
	NEWLINE_BYTES = []byte{'\n'}
)

Functions

func DeserializeHttpRequestPattern 

func DeserializeHttpRequestPattern(ctx *core.Context, it *jsoniter.Iterator, pattern core.Pattern, try bool) (_ core.Pattern, finalErr error)

func GenerateSelfSignedCertAndKey 

func GenerateSelfSignedCertAndKey(args SelfSignedCertParams) (cert *pem.Block, key *pem.Block, err error)

func GetTLSConfig 

func GetTLSConfig(ctx *core.Context, pemEncodedCert string, pemEncodedKey string) (*tls.Config, error)

func HttpRead 

func HttpRead(ctx *core.Context, u core.URL, args ...core.Value) (result core.Value, finalErr error)

func IsMutationMethod 

func IsMutationMethod(method string) bool

func MakeHTTPProxy 

func MakeHTTPProxy(ctx *core.Context, params HTTPProxyParams) (*http.Server, error)

StartHTTPProxy starts an HTTP proxy listening on 127.0.0.1:<port>. The connection between the client and an HTTP proxy is not encrypted, https://chromium.googlesource.com/chromium/src/+/HEAD/net/docs/proxy.md#http-proxy-scheme.

func Mime_ 

func Mime_(ctx *core.Context, arg core.String) (core.Mimetype, error)

func NewGolangHttpServer 

func NewGolangHttpServer(ctx *core.Context, config GolangHttpServerConfig) (*http.Server, error)

func NewHttpNamespace 

func NewHttpNamespace() *core.Namespace

func PercentDecode 

func PercentDecode(ctx *core.Context, s core.StringLike) (core.String, error)

func PercentEncode 

func PercentEncode(ctx *core.Context, s core.StringLike) core.String

func ServeFile 

func ServeFile(ctx *core.Context, rw *ResponseWriter, r *Request, pth core.Path) error

ServeFile is a thin wrapper around serveFileNativeRequest.

Types

type API 

type API = spec.API

type ApiEndpoint 

type ApiEndpoint = spec.ApiEndpoint

type CSPDirective 

type CSPDirective struct {
	// contains filtered or unexported fields
}

type CSPDirectiveValue 

type CSPDirectiveValue struct {
	// contains filtered or unexported fields
}

type CSPHeaderValueParams 

type CSPHeaderValueParams struct {
	ScriptsNonce string //optional
}

type Client 

type Client struct {
	// contains filtered or unexported fields
}

A Client represents a high level http client, Client implements core.ProtocolClient.

func NewClient 

func NewClient(ctx *core.Context, configObject *core.Object) (*Client, error)

func NewHttpClientFromPreExistingClient 

func NewHttpClientFromPreExistingClient(client *http.Client, insecure bool) *Client

func (*Client) DoRequest 

func (c *Client) DoRequest(ctx *core.Context, req *Request) (*Response, error)

func (*Client) Equal 

func (c *Client) Equal(ctx *core.Context, other core.Value, alreadyCompared map[uintptr]uintptr, depth int) bool

func (*Client) GetGoMethod 

func (c *Client) GetGoMethod(name string) (*core.GoFunction, bool)

func (*Client) GetHostCookieObjects 

func (c *Client) GetHostCookieObjects(ctx *core.Context, h core.Host) *core.List

func (*Client) GetHostCookies 

func (c *Client) GetHostCookies(h core.Host) []*http.Cookie

func (*Client) IsMutable 

func (c *Client) IsMutable() bool

func (*Client) MakeRequest 

func (c *Client) MakeRequest(ctx *core.Context, method string, u core.URL, body io.Reader, contentType string, opts *RequestOptions) (*Request, error)

func (*Client) PrettyPrint 

func (c *Client) PrettyPrint(w *bufio.Writer, config *core.PrettyPrintConfig, depth int, parentIndentCount int)

func (*Client) Prop 

func (c *Client) Prop(ctx *core.Context, name string) core.Value

func (*Client) PropertyNames 

func (*Client) PropertyNames(ctx *core.Context) []string

func (*Client) Schemes 

func (c *Client) Schemes() []core.Scheme

func (*Client) SetProp 

func (*Client) SetProp(ctx *core.Context, name string, value core.Value) error

func (*Client) ToSymbolicValue 

func (c *Client) ToSymbolicValue(ctx *core.Context, encountered map[uintptr]symbolic.Value) (symbolic.Value, error)

type ClientConfig 

type ClientConfig struct {
	Insecure     bool
	SaveCookies  bool
	Finalization *core.Dictionary
}

type ContentSecurityPolicy 

type ContentSecurityPolicy struct {
	// contains filtered or unexported fields
}

func NewCSP 

func NewCSP(ctx *core.Context, desc *core.Object) (*ContentSecurityPolicy, error)

func NewCSPWithDirectives 

func NewCSPWithDirectives(directives []CSPDirective) (*ContentSecurityPolicy, error)

NewCSPWithDirectives creates a CSP with the default directives and a list of given directives.

func (*ContentSecurityPolicy) Directive 

func (c *ContentSecurityPolicy) Directive(directiveName string) (CSPDirective, bool)

func (*ContentSecurityPolicy) Equal 

func (c *ContentSecurityPolicy) Equal(ctx *core.Context, other core.Value, alreadyCompared map[uintptr]uintptr, depth int) bool

func (*ContentSecurityPolicy) HeaderValue 

func (c *ContentSecurityPolicy) HeaderValue(params CSPHeaderValueParams) string

func (*ContentSecurityPolicy) IsMutable 

func (*ContentSecurityPolicy) IsMutable() bool

func (*ContentSecurityPolicy) PrettyPrint 

func (csp *ContentSecurityPolicy) PrettyPrint(w *bufio.Writer, config *core.PrettyPrintConfig, depth int, parentIndentCount int)

func (*ContentSecurityPolicy) String 

func (csp *ContentSecurityPolicy) String() string

func (*ContentSecurityPolicy) ToSymbolicValue 

func (*ContentSecurityPolicy) ToSymbolicValue(ctx *core.Context, encountered map[uintptr]symbolic.Value) (symbolic.Value, error)

func (*ContentSecurityPolicy) WriteJSONRepresentation 

func (c *ContentSecurityPolicy) WriteJSONRepresentation(ctx *core.Context, w *jsoniter.Stream, config core.JSONSerializationConfig, depth int) error

func (*ContentSecurityPolicy) WriteRepresentation 

func (c *ContentSecurityPolicy) WriteRepresentation(ctx *core.Context, w io.Writer, config *core.ReprConfig, depth int) error

type GolangHttpServerConfig 

type GolangHttpServerConfig struct {
	//hostname:port or :port
	Addr    string
	Handler http.Handler

	PemEncodedCert string
	PemEncodedKey  string

	AllowSelfSignedCertCreationEvenIfExposed bool
	//if true the certificate and key files are persisted on the filesystem for later reuse.
	PersistCreatedLocalCert        bool
	SelfSignedCertValidityDuration time.Duration //defaults to DEFAULT_SELF_SIGNED_CERT_VALIDITY_DURATION

	ReadHeaderTimeout time.Duration // defaults to DEFAULT_HTTP_SERVER_READ_HEADER_TIMEOUT
	ReadTimeout       time.Duration // defaults to DEFAULT_HTTP_SERVER_READ_TIMEOUT
	WriteTimeout      time.Duration // defaults to DEFAULT_HTTP_SERVER_WRITE_TIMEOUT
	MaxHeaderBytes    int           // defaults to DEFAULT_HTTP_SERVER_MAX_HEADER_BYTES
}

type HTTPProxyParams 

type HTTPProxyParams struct {
	Port int

	//OnRequest is invoked before GetContext and before any permissions is checked to forward the request.
	//If a non nil response is returned it it sent to the client.
	OnRequest func(req *http.Request, proxyCtx *goproxy.ProxyCtx) (*http.Request, *http.Response)

	//GetContext is called to retrieve the context for the request, the context is used to check permissions.
	GetContext func(req *http.Request) *core.Context

	RemovedRequestHeaders []string

	Logger zerolog.Logger
}

type HttpsServer 

type HttpsServer struct {
	// contains filtered or unexported fields
}

HttpsServer implements the GoValue interface.

func NewFileServer 

func NewFileServer(ctx *core.Context, args ...core.Value) (*HttpsServer, error)

NewFileServer returns an HttpServer that uses Go's http.FileServer(dir) to handle requests

func NewHttpsServer 

func NewHttpsServer(ctx *core.Context, host core.Host, args ...core.Value) (*HttpsServer, error)

NewHttpsServer creates a listening HTTPS server. The server's defaultLimits are constructed by merging the default request handling limits with the default-limits in arguments. The server's maxLimits are constructed by merging the default max request handling limits with the max-limits in arguments.

func (*HttpsServer) Close 

func (serv *HttpsServer) Close(ctx *core.Context)

func (*HttpsServer) Equal 

func (s *HttpsServer) Equal(ctx *core.Context, other core.Value, alreadyCompared map[uintptr]uintptr, depth int) bool

func (*HttpsServer) GetGoMethod 

func (serv *HttpsServer) GetGoMethod(name string) (*core.GoFunction, bool)

func (*HttpsServer) ImmediatelyClose 

func (serv *HttpsServer) ImmediatelyClose(ctx *core.Context)

func (*HttpsServer) IsMutable 

func (serv *HttpsServer) IsMutable() bool

func (*HttpsServer) ListeningAddr 

func (serv *HttpsServer) ListeningAddr() core.Host

func (*HttpsServer) PrettyPrint 

func (s *HttpsServer) PrettyPrint(w *bufio.Writer, config *core.PrettyPrintConfig, depth int, parentIndentCount int)

func (*HttpsServer) Prop 

func (s *HttpsServer) Prop(ctx *core.Context, name string) core.Value

func (*HttpsServer) PropertyNames 

func (*HttpsServer) PropertyNames(ctx *core.Context) []string

func (*HttpsServer) SetProp 

func (*HttpsServer) SetProp(ctx *core.Context, name string, value core.Value) error

func (*HttpsServer) ToSymbolicValue 

func (serv *HttpsServer) ToSymbolicValue(ctx *core.Context, encountered map[uintptr]symbolic.Value) (symbolic.Value, error)

func (*HttpsServer) WaitClosed 

func (serv *HttpsServer) WaitClosed(ctx *core.Context)

type IncomingRequestInfo 

type IncomingRequestInfo struct {
	ULID     ulid.ULID
	Path     core.Path
	Hostname string
	Method   string
	//VMethod                  VMethod
	//ResourceTypeName         ModelName
	ContentType        string
	RemoteAddrAndPort  string
	Referer            string
	URL                core.URL
	UserAgent          string
	ResponseStatusCode int

	CreationTime                    time.Time
	EndTime                         time.Time //rename ?
	HandlingDurationMillis          int64
	SessionCookieStart              string
	CookieNames                     []string
	Errors                          []string
	Info                            []string
	SetCookieHeaderValueStart       string
	HeaderNames                     []string
	SeeOtherRedirectURL             string
	ResourceWaitingDurationMicrosec int64
	SentBodyBytes                   int
}

should not contain super sensitive information (full cookie, email address, ...)

func NewIncomingRequestInfo 

func NewIncomingRequestInfo(r *Request) *IncomingRequestInfo

func (IncomingRequestInfo) RemoteIpAddress 

func (reqInfo IncomingRequestInfo) RemoteIpAddress() string

type Request 

type Request struct {
	ULID       ulid.ULID
	ULIDString string

	//accessible from inox
	Method             core.String //.url.Method from the *http.Request ("GET" if empty)
	URL                core.URL    //.url.URL from the *http.Request
	Path               core.Path   //.url.Path from the *http.Request (already escaped)
	Body               *core.Reader
	Cookies            []*http.Cookie
	ParsedAcceptHeader mimeheader.AcceptHeader
	AcceptHeader       string
	ContentType        mimeheader.MimeType
	Session            *core.Object //can be nil

	//
	CreationTime      time.Time
	HeaderNames       []string
	UserAgent         string
	Hostname          string
	RemoteAddrAndPort netaddr.RemoteAddrWithPort //empty for client side requests
	RemoteIpAddr      netaddr.RemoteIpAddr       //empty for client side requests
	// contains filtered or unexported fields
}

Request is considered immutable from the viewpoint of Inox code, it should NOT be mutated.

func NewClientSideRequest 

func NewClientSideRequest(r *http.Request) (*Request, error)

func NewServerSideRequest 

func NewServerSideRequest(r *http.Request, logger zerolog.Logger, server *HttpsServer) (*Request, error)

func (*Request) AcceptAny 

func (req *Request) AcceptAny() bool

func (*Request) Equal 

func (r *Request) Equal(ctx *core.Context, other core.Value, alreadyCompared map[uintptr]uintptr, depth int) bool

func (*Request) GetGoMethod 

func (req *Request) GetGoMethod(name string) (*core.GoFunction, bool)

func (*Request) IsGetOrHead 

func (req *Request) IsGetOrHead() bool

func (*Request) IsMutable 

func (req *Request) IsMutable() bool

func (*Request) IsSharable 

func (req *Request) IsSharable(originState *core.GlobalState) (bool, string)

func (*Request) IsShared 

func (req *Request) IsShared() bool

func (*Request) PrettyPrint 

func (r *Request) PrettyPrint(w *bufio.Writer, config *core.PrettyPrintConfig, depth int, parentIndentCount int)

func (*Request) Prop 

func (req *Request) Prop(ctx *core.Context, name string) core.Value

func (*Request) PropertyNames 

func (*Request) PropertyNames(ctx *core.Context) []string

func (*Request) Request 

func (req *Request) Request() *http.Request

func (*Request) SetProp 

func (*Request) SetProp(ctx *core.Context, name string, value core.Value) error

func (*Request) Share 

func (req *Request) Share(originState *core.GlobalState)

func (*Request) SmartLock 

func (req *Request) SmartLock(state *core.GlobalState)

func (*Request) SmartUnlock 

func (req *Request) SmartUnlock(state *core.GlobalState)

func (*Request) ToSymbolicValue 

func (req *Request) ToSymbolicValue(ctx *core.Context, encountered map[uintptr]symbolic.Value) (symbolic.Value, error)

func (*Request) WriteJSONRepresentation 

func (r *Request) WriteJSONRepresentation(ctx *core.Context, w *jsoniter.Stream, config core.JSONSerializationConfig, depth int) error

func (*Request) WriteRepresentation 

func (r *Request) WriteRepresentation(ctx *core.Context, w io.Writer, config *core.ReprConfig, depth int) error

type RequestOptions 

type RequestOptions struct {
	Timeout            time.Duration
	InsecureSkipVerify bool
	Jar                http.CookieJar
}

type RequestPattern 

type RequestPattern struct {
	core.NotCallablePatternMixin
	// contains filtered or unexported fields
}

func (*RequestPattern) Equal 

func (p *RequestPattern) Equal(ctx *core.Context, other core.Value, alreadyCompared map[uintptr]uintptr, depth int) bool

func (*RequestPattern) IsMutable 

func (*RequestPattern) IsMutable() bool

func (*RequestPattern) Iterator 

func (*RequestPattern) Iterator(*core.Context, core.IteratorConfiguration) core.Iterator

func (*RequestPattern) PrettyPrint 

func (p *RequestPattern) PrettyPrint(w *bufio.Writer, config *core.PrettyPrintConfig, depth int, parentIndentCount int)

func (*RequestPattern) Random 

func (*RequestPattern) Random(ctx *core.Context, options ...core.Option) core.Value

func (*RequestPattern) StringPattern 

func (*RequestPattern) StringPattern() (core.StringPattern, bool)

func (*RequestPattern) Test 

func (p *RequestPattern) Test(ctx *core.Context, v core.Value) bool

func (*RequestPattern) ToSymbolicValue 

func (*RequestPattern) ToSymbolicValue(ctx *core.Context, encountered map[uintptr]symbolic.Value) (symbolic.Value, error)

func (*RequestPattern) WriteJSONRepresentation 

func (p *RequestPattern) WriteJSONRepresentation(ctx *core.Context, w *jsoniter.Stream, config core.JSONSerializationConfig, depth int) error

type Response 

type Response struct {
	// contains filtered or unexported fields
}

func HttpDelete 

func HttpDelete(ctx *core.Context, args ...core.Value) (*Response, error)

func HttpGet 

func HttpGet(ctx *core.Context, u core.URL, args ...core.Value) (*Response, error)

func HttpPatch 

func HttpPatch(ctx *core.Context, args ...core.Value) (*Response, error)

func HttpPost 

func HttpPost(ctx *core.Context, args ...core.Value) (*Response, error)

func (*Response) Body 

func (resp *Response) Body(ctx *core.Context) io.ReadCloser

func (*Response) ContentType 

func (resp *Response) ContentType(ctx *core.Context) (core.Mimetype, bool, error)

func (*Response) Equal 

func (r *Response) Equal(ctx *core.Context, other core.Value, alreadyCompared map[uintptr]uintptr, depth int) bool

func (*Response) GetGoMethod 

func (resp *Response) GetGoMethod(name string) (*core.GoFunction, bool)

func (*Response) IsMutable 

func (resp *Response) IsMutable() bool

func (*Response) PrettyPrint 

func (r *Response) PrettyPrint(w *bufio.Writer, config *core.PrettyPrintConfig, depth int, parentIndentCount int)

func (*Response) Prop 

func (resp *Response) Prop(ctx *core.Context, name string) core.Value

func (*Response) PropertyNames 

func (*Response) PropertyNames(ctx *core.Context) []string

func (*Response) SetProp 

func (*Response) SetProp(ctx *core.Context, name string, value core.Value) error

func (*Response) Status 

func (resp *Response) Status(ctx *core.Context) string

func (*Response) StatusCode 

func (resp *Response) StatusCode(ctx *core.Context) int

func (*Response) ToSymbolicValue 

func (resp *Response) ToSymbolicValue(ctx *core.Context, encountered map[uintptr]symbolic.Value) (symbolic.Value, error)

type ResponseWriter 

type ResponseWriter struct {
	// contains filtered or unexported fields
}

func NewResponseWriter 

func NewResponseWriter(req *Request, rw http.ResponseWriter, serverLogger zerolog.Logger) *ResponseWriter

func (*ResponseWriter) AddHeader 

func (rw *ResponseWriter) AddHeader(ctx *core.Context, k, v core.String)

func (*ResponseWriter) DetachBodyWriter 

func (rw *ResponseWriter) DetachBodyWriter() io.Writer

DetachBodyWriter writes the headers and the planned status if they have not been sent yet, then it detachs the underlying response writer and returns it. The HttpResponseWriter should not be used afterwards.

func (*ResponseWriter) DetachRespWriter 

func (rw *ResponseWriter) DetachRespWriter() http.ResponseWriter

DetachBodyWriter detachs the underlying response writer and returns it. The HttpResponseWriter should not be used afterwards.

func (*ResponseWriter) Equal 

func (rw *ResponseWriter) Equal(ctx *core.Context, other core.Value, alreadyCompared map[uintptr]uintptr, depth int) bool

func (*ResponseWriter) FinalLog 

func (rw *ResponseWriter) FinalLog()

func (*ResponseWriter) Finish 

func (rw *ResponseWriter) Finish(ctx *core.Context)

func (*ResponseWriter) GetGoMethod 

func (rw *ResponseWriter) GetGoMethod(name string) (*core.GoFunction, bool)

func (*ResponseWriter) IsMutable 

func (resp *ResponseWriter) IsMutable() bool

func (*ResponseWriter) IsStatusSent 

func (rw *ResponseWriter) IsStatusSent() bool

func (ResponseWriter) PlannedStatus 

func (rw ResponseWriter) PlannedStatus() int

func (*ResponseWriter) PrettyPrint 

func (rw *ResponseWriter) PrettyPrint(w *bufio.Writer, config *core.PrettyPrintConfig, depth int, parentIndentCount int)

func (*ResponseWriter) Prop 

func (rw *ResponseWriter) Prop(ctx *core.Context, name string) core.Value

func (*ResponseWriter) PropertyNames 

func (rw *ResponseWriter) PropertyNames(ctx *core.Context) []string

func (ResponseWriter) SentStatus 

func (rw ResponseWriter) SentStatus() int

func (*ResponseWriter) SetContentType 

func (rw *ResponseWriter) SetContentType(s string)

func (*ResponseWriter) SetCookie 

func (rw *ResponseWriter) SetCookie(ctx *core.Context, obj *core.Object) error

func (*ResponseWriter) SetProp 

func (*ResponseWriter) SetProp(ctx *core.Context, name string, value core.Value) error

func (*ResponseWriter) SetStatus 

func (rw *ResponseWriter) SetStatus(ctx *core.Context, status StatusCode)

func (*ResponseWriter) SetWriteDeadline 

func (rw *ResponseWriter) SetWriteDeadline(timeout time.Duration)

func (*ResponseWriter) ToSymbolicValue 

func (resp *ResponseWriter) ToSymbolicValue(ctx *core.Context, encountered map[uintptr]symbolic.Value) (symbolic.Value, error)

func (*ResponseWriter) WriteBinary 

func (rw *ResponseWriter) WriteBinary(ctx *core.Context, bytes *core.ByteSlice) (core.Int, error)

func (*ResponseWriter) WriteCSS 

func (rw *ResponseWriter) WriteCSS(ctx *core.Context, v core.Value) (core.Int, error)

func (*ResponseWriter) WriteError 

func (rw *ResponseWriter) WriteError(ctx *core.Context, err core.Error, code StatusCode)

func (*ResponseWriter) WriteHTML 

func (rw *ResponseWriter) WriteHTML(ctx *core.Context, v core.Value) (core.Int, error)

func (*ResponseWriter) WriteHeaders 

func (rw *ResponseWriter) WriteHeaders(ctx *core.Context, status *core.OptionalParam[StatusCode])

func (*ResponseWriter) WriteJS 

func (rw *ResponseWriter) WriteJS(ctx *core.Context, v core.Value) (core.Int, error)

func (*ResponseWriter) WriteJSON 

func (rw *ResponseWriter) WriteJSON(ctx *core.Context, v core.Serializable) (core.Int, error)

func (*ResponseWriter) WritePlainText 

func (rw *ResponseWriter) WritePlainText(ctx *core.Context, bytes *core.ByteSlice) (core.Int, error)

type Result 

type Result struct {
	// contains filtered or unexported fields
}

func NewResult 

func NewResult(ctx *core.Context, init *core.Object) *Result

func (*Result) Equal 

func (r *Result) Equal(ctx *core.Context, other core.Value, alreadyCompared map[uintptr]uintptr, depth int) bool

func (*Result) IsMutable 

func (resp *Result) IsMutable() bool

func (*Result) PrettyPrint 

func (r *Result) PrettyPrint(w *bufio.Writer, config *core.PrettyPrintConfig, depth int, parentIndentCount int)

func (*Result) ToSymbolicValue 

func (res *Result) ToSymbolicValue(ctx *core.Context, encountered map[uintptr]symbolic.Value) (symbolic.Value, error)

type SelfSignedCertParams 

type SelfSignedCertParams struct {
	Localhost        bool
	NonLocalhostIPs  bool
	ValidityDuration time.Duration //should be >= 100ms, defaults to DEFAULT_SELF_SIGNED_CERT_VALIDITY_DURATION
}

type ServerSentEvent 

type ServerSentEvent struct {
	ID      []byte
	Data    []byte
	Event   []byte
	Retry   []byte
	Comment []byte
	// contains filtered or unexported fields
}

func (*ServerSentEvent) HasContent 

func (e *ServerSentEvent) HasContent() bool

func (*ServerSentEvent) ToEvent 

func (e *ServerSentEvent) ToEvent() *core.Event

type ServerSentEventSource 

type ServerSentEventSource struct {
	core.EventSourceBase
	// contains filtered or unexported fields
}

func NewEventSource 

func NewEventSource(ctx *core.Context, resourceNameOrPattern core.Value) (*ServerSentEventSource, error)

func (*ServerSentEventSource) Close 

func (evs *ServerSentEventSource) Close()

func (*ServerSentEventSource) Equal 

func (evs *ServerSentEventSource) Equal(ctx *core.Context, other core.Value, alreadyCompared map[uintptr]uintptr, depth int) bool

func (*ServerSentEventSource) GetGoMethod 

func (evs *ServerSentEventSource) GetGoMethod(name string) (*core.GoFunction, bool)

func (*ServerSentEventSource) IsClosed 

func (evs *ServerSentEventSource) IsClosed() bool

func (*ServerSentEventSource) IsMutable 

func (*ServerSentEventSource) IsMutable() bool

func (*ServerSentEventSource) Iterator 

func (evs *ServerSentEventSource) Iterator(ctx *core.Context, config core.IteratorConfiguration) core.Iterator

func (*ServerSentEventSource) PrettyPrint 

func (evs *ServerSentEventSource) PrettyPrint(w *bufio.Writer, config *core.PrettyPrintConfig, depth int, parentIndentCount int)

func (*ServerSentEventSource) Prop 

func (evs *ServerSentEventSource) Prop(ctx *core.Context, name string) core.Value

func (*ServerSentEventSource) PropertyNames 

func (*ServerSentEventSource) PropertyNames(ctx *core.Context) []string

func (*ServerSentEventSource) SetProp 

func (*ServerSentEventSource) SetProp(ctx *core.Context, name string, value core.Value) error

func (*ServerSentEventSource) ToSymbolicValue 

func (evs *ServerSentEventSource) ToSymbolicValue(ctx *core.Context, encountered map[uintptr]symbolic.Value) (symbolic.Value, error)

type SseServer 

type SseServer struct {
	// contains filtered or unexported fields
}

func NewSseServer 

func NewSseServer() *SseServer

func (*SseServer) Close 

func (s *SseServer) Close()

Close closes all the streams.

func (*SseServer) CreateStream 

func (s *SseServer) CreateStream(id string) *multiSubscriptionSSEStream

func (*SseServer) Publish 

func (s *SseServer) Publish(streamId string, event *ServerSentEvent)

func (*SseServer) PushSubscriptionEvents 

func (s *SseServer) PushSubscriptionEvents(config eventPushConfig)

PushSubscriptionEvents writes the headers required for event streaming & push events.

func (*SseServer) RemoveStream 

func (s *SseServer) RemoveStream(id string)

type Status 

type Status struct {
	// contains filtered or unexported fields
}

func MakeStatus 

func MakeStatus(code StatusCode) (Status, error)

func ParseStatus 

func ParseStatus(str string) (Status, error)

func (Status) Code 

func (s Status) Code() StatusCode

func (Status) Equal 

func (s Status) Equal(ctx *core.Context, other core.Value, alreadyCompared map[uintptr]uintptr, depth int) bool

func (Status) FullText 

func (s Status) FullText() string

func (*Status) GetGoMethod 

func (*Status) GetGoMethod(name string) (*core.GoFunction, bool)

func (Status) IsMutable 

func (s Status) IsMutable() bool

func (Status) PrettyPrint 

func (s Status) PrettyPrint(w *bufio.Writer, config *core.PrettyPrintConfig, depth int, parentIndentCount int)

func (*Status) Prop 

func (s *Status) Prop(ctx *core.Context, name string) core.Value

func (Status) PropertyNames 

func (Status) PropertyNames(*core.Context) []string

func (Status) ReasonPhrase 

func (s Status) ReasonPhrase() string

func (Status) SetProp 

func (Status) SetProp(ctx *core.Context, name string, value core.Value) error

func (Status) ToSymbolicValue 

func (s Status) ToSymbolicValue(ctx *core.Context, encountered map[uintptr]symbolic.Value) (symbolic.Value, error)

func (Status) WriteJSONRepresentation 

func (s Status) WriteJSONRepresentation(ctx *core.Context, w *jsoniter.Stream, config core.JSONSerializationConfig, depth int) error

func (Status) WriteRepresentation 

func (Status) WriteRepresentation(ctx *core.Context, w io.Writer, config *core.ReprConfig, depth int) error

type StatusCode 

type StatusCode uint16

func MakeStatusCode 

func MakeStatusCode(_ *core.Context, n core.Int) (StatusCode, error)

func (StatusCode) Equal 

func (c StatusCode) Equal(ctx *core.Context, other core.Value, alreadyCompared map[uintptr]uintptr, depth int) bool

func (StatusCode) IsMutable 

func (c StatusCode) IsMutable() bool

func (StatusCode) PrettyPrint 

func (c StatusCode) PrettyPrint(w *bufio.Writer, config *core.PrettyPrintConfig, depth int, parentIndentCount int)

func (StatusCode) ToSymbolicValue 

func (c StatusCode) ToSymbolicValue(ctx *core.Context, encountered map[uintptr]symbolic.Value) (symbolic.Value, error)

func (StatusCode) WriteJSONRepresentation 

func (c StatusCode) WriteJSONRepresentation(ctx *core.Context, w *jsoniter.Stream, config core.JSONSerializationConfig, depth int) error

func (StatusCode) WriteRepresentation 

func (StatusCode) WriteRepresentation(ctx *core.Context, w io.Writer, config *core.ReprConfig, depth int) error

type Subscription 

type Subscription struct {
	// contains filtered or unexported fields
}

func (*Subscription) IsStopped 

func (s *Subscription) IsStopped() bool

func (*Subscription) StopAsync 

func (s *Subscription) StopAsync()

StopAsync causes the server to stop the event stream after all other events have been sent.

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.