Method handleSGCollect

rest/admin_api.go:1661–1710

()

}

func (h *handler) handleSGCollect() error {
	body, err := h.readBody()
	if err != nil {
		return err
	}

	var params SGCollectOptions
	if err = base.JSONUnmarshal(body, &params); err != nil {
		return base.HTTPErrorf(http.StatusBadRequest, "Unable to parse request body: %v", err)
	}

	if multiError := params.Validate(); multiError != nil {
		return base.HTTPErrorf(http.StatusBadRequest, "Invalid options used for sgcollect_info: %v", multiError)
	}

	addr, err := h.server.getServerAddr(adminServer)
	if err != nil {
		return base.HTTPErrorf(http.StatusInternalServerError, "Error getting admin server address: %v", err)
	}
	if h.server.Config.API.HTTPS.TLSCertPath != "" {
		addr = "https://" + addr
	} else {
		addr = "http://" + addr
	}
	params.adminURL = addr

	zipFilename := SGCollectFilename()

	logFilePath := h.server.Config.Logging.LogFilePath

	ctx := base.CorrelationIDLogCtx(context.WithoutCancel(h.ctx()), fmt.Sprintf("SGCollect-%03d", h.serialNumber))

	if err := h.server.SGCollect.Start(ctx, logFilePath, zipFilename, params); err != nil {
		return base.HTTPErrorf(http.StatusInternalServerError, "Error running sgcollect_info: %v", err)
	}

	h.writeRawJSONStatus(http.StatusOK, []byte(`{"status":"started"}`))

	auditFields := base.AuditFields{
		"output_dir":   params.OutputDirectory,
		"upload_host":  params.UploadHost,
		"customer":     params.Customer,
		"ticket":       params.Ticket,
		"keep_zip":     params.KeepZip,
		"zip_filename": zipFilename,
	}
	base.Audit(h.ctx(), base.AuditIDSyncGatewayCollectInfoStart, auditFields)

	return nil
}

// ////// USERS & ROLES: