Method sourceHandshake

ntrip/client.go:314–330

sourceHandshake sends the NTRIP v1 SOURCE request and streams raw RTCM data after the headers. The request uses a bare mountpoint (no leading slash) plus a STR line, matching the de-facto format produced by RTKLIB's str2str that NTRIP casters accept.

(conn net.Conn)

// slash) plus a STR line, matching the de-facto format produced by RTKLIB's
// str2str that NTRIP casters accept.
func (c *Client) sourceHandshake(conn net.Conn) error {
	mount := strings.TrimPrefix(c.config.Mountpoint, "/")
	req := fmt.Sprintf(
		"SOURCE %s %s\r\nSource-Agent: %s\r\nSTR: \r\n\r\n",
		c.config.Password, mount, c.config.UserAgent,
	)

	c.logger.Info("sending SOURCE request",
		"caster", c.config.Caster,
		"mountpoint", mount,
	)
	if _, err := conn.Write([]byte(req)); err != nil {
		return fmt.Errorf("sending SOURCE request: %w", err)
	}

	return nil
}

// postHandshake sends the NTRIP v2 (HTTP POST) server request. The caster keeps
// the connection open and ingests the request body as an RTCM stream. Some