Develop

.gitignore

@@ -25,3 +25,5 @@ node_modules
 server/api/dashboard.go
 coverage.txt
 versioninfo.json
+.DS_Store
+Icon

api/handler.go

@@ -22,6 +22,7 @@ import (
 type Handler interface {
 	http.Handler
 	RegisterHealthHandler(path string, h http.Handler)
+	RegisterMcpHandler(path string, h http.Handler)
 }
 
 type handler struct {
@@ -33,6 +34,8 @@ type handler struct {
 	index         string
 	healthPath    string
 	healthHandler http.Handler
+	mcpPath       string
+	mcpHandler    http.Handler
 }
 
 type info struct {
@@ -111,6 +114,11 @@ func (h *handler) RegisterHealthHandler(path string, handler http.Handler) {
 	h.healthHandler = handler
 }
 
+func (h *handler) RegisterMcpHandler(path string, handler http.Handler) {
+	h.mcpPath = path
+	h.mcpHandler = handler
+}
+
 func (h *handler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
 	if r.Method != "GET" && r.Method != "POST" {
 		http.Error(w, fmt.Sprintf("method %v is not allowed", r.Method), http.StatusMethodNotAllowed)
@@ -154,6 +162,8 @@ func (h *handler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
 		h.getSearchResults(w, r)
 	case strings.HasPrefix(p, h.healthPath) && h.healthHandler != nil:
 		h.healthHandler.ServeHTTP(w, r)
+	case strings.HasPrefix(p, h.mcpPath) && h.mcpHandler != nil:
+		h.mcpHandler.ServeHTTP(w, r)
 	case h.fileServer != nil:
 		if r.Method != "GET" {
 			http.Error(w, fmt.Sprintf("method %v is not allowed", r.Method), http.StatusMethodNotAllowed)

api/handler_config.go

@@ -79,7 +79,17 @@ func (h *handler) getConfigData(w http.ResponseWriter, r *http.Request, key stri
 	ext := filepath.Ext(path)
 	mt := mime.TypeByExtension(filepath.Ext(ext))
 	if mt == "" {
-		mt = "text/plain"
+		if ext == "" {
+			values, err := mime.ExtensionsByType(c.Info.Kernel().ContentType)
+			if err == nil && len(values) > 0 {
+				ext = values[0]
+				path += ext
+				mt = mime.TypeByExtension(filepath.Ext(ext))
+			}
+		}
+		if mt == "" {
+			mt = "text/plain"
+		}
 	}
 	w.Header().Set("Last-Modified", c.Info.Time.UTC().Format(http.TimeFormat))
 	w.Header().Set("Content-Type", mt)

api/handler_config_test.go

@@ -149,6 +149,7 @@ func TestHandler_Config(t *testing.T) {
 			requestUrl: "http://foo.api/api/configs/foo/data",
 			test: []try.ResponseCondition{
 				try.HasStatusCode(http.StatusOK),
+				try.HasHeader("Content-Disposition", "inline; filename=\"foo.yaml\""),
 				try.HasHeader("Last-Modified", "Wed, 27 Dec 2023 13:01:30 GMT"),
 				try.HasHeaderXor("Content-Type", "text/plain", "application/yaml"),
 				try.HasHeader("Cache-Control", "no-cache"),
@@ -173,6 +174,34 @@ func TestHandler_Config(t *testing.T) {
 			requestUrl: "http://foo.api/api/configs/foo/data",
 			test: []try.ResponseCondition{
 				try.HasStatusCode(http.StatusOK),
+				try.HasHeader("Content-Disposition", "inline; filename=\"foo.json\""),
+				try.HasHeader("Last-Modified", "Fri, 22 Dec 2023 13:01:30 GMT"),
+				try.HasHeader("Content-Type", "application/json"),
+				try.HasHeader("Etag", etag),
+				try.HasHeader("Cache-Control", "no-cache"),
+				try.HasBody(`{"foo": "bar"}`),
+			},
+		},
+		{
+			name: "config data: no extension but ContentType in Info is set",
+			app: func() *runtime.App {
+
+				return &runtime.App{Configs: map[string]*dynamic.Config{
+					"foo": {
+						Info: dynamic.ConfigInfo{
+							Url:         mustUrl("https://foo.bar/foo"),
+							Time:        mustTime("2023-12-22T13:01:30+00:00"),
+							Checksum:    checksum,
+							ContentType: "application/json",
+						},
+						Raw: data,
+					},
+				}}
+			},
+			requestUrl: "http://foo.api/api/configs/foo/data",
+			test: []try.ResponseCondition{
+				try.HasStatusCode(http.StatusOK),
+				try.HasHeader("Content-Disposition", "inline; filename=\"foo.json\""),
 				try.HasHeader("Last-Modified", "Fri, 22 Dec 2023 13:01:30 GMT"),
 				try.HasHeader("Content-Type", "application/json"),
 				try.HasHeader("Etag", etag),

cmd/mokapi/main_test.go

@@ -89,6 +89,11 @@ health:
     path: /health
     port: 8080
     log: false
+mcp:
+    server:
+        enabled: false
+        path: /mcp
+        port: 8080
 rootCaCert: ""
 rootCaKey: ""
 configs: []

config/dynamic/config_info.go

@@ -12,12 +12,13 @@ import (
 )
 
 type ConfigInfo struct {
-	Provider string
-	Url      *url.URL
-	Checksum []byte
-	Time     time.Time
-	inner    *ConfigInfo
-	Tags     []string
+	Provider    string
+	Url         *url.URL
+	Checksum    []byte
+	Time        time.Time
+	inner       *ConfigInfo
+	Tags        []string
+	ContentType string
 }
 
 func (ci *ConfigInfo) Path() string {

config/dynamic/parse.go

@@ -76,10 +76,12 @@ func parse(c *Config) (interface{}, error) {
 		var v interface{}
 		v, err = parseJson(b, result)
 		if err == nil {
+			c.Info.ContentType = "application/json"
 			return v, nil
 		}
 		v, err = parseYaml(b, result)
 		if v != nil && err == nil {
+			c.Info.ContentType = "application/yaml"
 			return v, nil
 		}
 		err = nil

config/dynamic/parse_test.go

@@ -107,6 +107,7 @@ func TestParse(t *testing.T) {
 				err := dynamic.Parse(c, &dynamictest.Reader{})
 				require.NoError(t, err)
 				require.Equal(t, "foo", c.Data.(*data).User)
+				require.Equal(t, "application/json", c.Info.ContentType)
 			},
 		},
 		{
@@ -161,6 +162,7 @@ func TestParse(t *testing.T) {
 				err := dynamic.Parse(c, &dynamictest.Reader{})
 				require.NoError(t, err)
 				require.Equal(t, "foo", c.Data.(*data).User)
+				require.Equal(t, "application/yaml", c.Info.ContentType)
 			},
 		},
 		{

config/dynamic/provider/http/http.go

@@ -198,6 +198,10 @@ func (p *Provider) readUrl(u *url.URL) (c *dynamic.Config, changed bool, err err
 		Raw: b,
 	}
 
+	if ct := res.Header.Get("Content-Type"); ct != "" {
+		c.Info.ContentType = ct
+	}
+
 	return
 }
 

config/dynamic/provider/http/http_test.go

@@ -3,9 +3,6 @@ package http
 import (
 	"context"
 	"fmt"
-	"github.com/sirupsen/logrus"
-	"github.com/sirupsen/logrus/hooks/test"
-	"github.com/stretchr/testify/require"
 	"io"
 	"mokapi/config/dynamic"
 	"mokapi/config/static"
@@ -15,6 +12,10 @@ import (
 	"net/http/httptest"
 	"testing"
 	"time"
+
+	"github.com/sirupsen/logrus"
+	"github.com/sirupsen/logrus/hooks/test"
+	"github.com/stretchr/testify/require"
 )
 
 func TestProvider_Start(t *testing.T) {
@@ -159,6 +160,28 @@ func TestProvider_Start(t *testing.T) {
 				require.Equal(t, fmt.Sprintf("request to %v failed: request has timed out", url), hook.LastEntry().Message)
 			},
 		},
+		{
+			name: "content type",
+			init: func() (static.HttpProvider, *httptest.Server) {
+				server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
+					w.Header().Set("Content-Type", "application/json")
+					w.WriteHeader(http.StatusOK)
+					_, _ = w.Write([]byte("foo: bar"))
+				}))
+
+				cfg := static.HttpProvider{
+					Urls: []string{server.URL},
+				}
+
+				return cfg, server
+			},
+			test: func(t *testing.T, url string, ch chan dynamic.ConfigEvent, hook *test.Hook, err error) {
+				require.NoError(t, err)
+				c := <-ch
+				require.Equal(t, "foo: bar", string(c.Config.Raw))
+				require.Equal(t, "application/json", c.Config.Info.ContentType)
+			},
+		},
 	}
 
 	for _, tc := range testcases {

config/static/static_config.go

@@ -19,6 +19,7 @@ type Config struct {
 	Providers        Providers         `json:"providers" yaml:"providers"`
 	Api              Api               `json:"api" yaml:"api"`
 	Health           Health            `json:"health" yaml:"health"`
+	Mcp              Mcp               `json:"mcp" yaml:"mcp"`
 	RootCaCert       tls.FileOrContent `json:"rootCaCert" yaml:"rootCaCert" name:"root-ca-cert"`
 	RootCaKey        tls.FileOrContent `json:"rootCaKey" yaml:"rootCaKey" name:"root-ca-cert"`
 	Configs          Configs           `json:"configs" yaml:"configs" explode:"config"`
@@ -44,6 +45,14 @@ func NewConfig() *Config {
 	cfg.Health.Port = 8080
 	cfg.Health.Path = "/health"
 
+	cfg.Mcp = Mcp{
+		Server: McpServer{
+			Enabled: false,
+			Port:    8080,
+			Path:    "/mcp",
+		},
+	}
+
 	cfg.Providers.File.SkipPrefix = []string{"_"}
 	cfg.Event.Store = map[string]Store{"default": {Size: 100}}
 	cfg.DataGen.OptionalProperties = "0.85"
@@ -298,3 +307,13 @@ type Health struct {
 	Port    int    `yaml:"port" json:"port"`
 	Log     bool   `yaml:"log" json:"log"`
 }
+
+type Mcp struct {
+	Server McpServer `yaml:"server" json:"server"`
+}
+
+type McpServer struct {
+	Enabled bool   `yaml:"enabled" json:"enabled"`
+	Path    string `yaml:"path" json:"path"`
+	Port    int    `yaml:"port" json:"port"`
+}

context7.json

@@ -0,0 +1,4 @@
+{
+  "url": "https://context7.com/marle3003/mokapi",
+  "public_key": "pk_aZSdHtCTd5H3Tm72PzeNI"
+}

docs/javascript-api/mokapi-http/fetchoptions.md

@@ -7,13 +7,14 @@ description: The FetchOptions object defines parameters for the fetch() function
 The `FetchOptions` object defines additional parameters for the [`fetch()`](/docs/javascript-api/mokapi-http/fetch.md) function in the `mokapi/http` module.  
 It allows you to customize request behavior such as HTTP method, headers, body, timeout, and redirect handling.
 
-| Name         | Type           | Description                                                                                                  |
-|--------------|----------------|--------------------------------------------------------------------------------------------------------------|
-| method       | string         | The HTTP method used for the request (e.g. `"GET"`, `"POST"`, `"PUT"`). Defaults to `"GET"`.                 |                                                                 |
-| body         | object         | The request body to send. Automatically serialized to JSON when `Content-Type` is set to `application/json`. |
-| headers      | object         | Key-value pairs representing HTTP headers to include with the request.                                       |
-| maxRedirects | number         | The number of redirects to follow. Default value is 5. A value of 0 (zero) prevents all redirection.         |
-| timeout      | number, string | Maximum time to wait for the request to complete. Default timeout is 60 seconds ("60s")                      |
+| Name         | Type           | Description                                                                                                                                              |
+|--------------|----------------|----------------------------------------------------------------------------------------------------------------------------------------------------------|
+| method       | string         | The HTTP method used for the request (e.g. `"GET"`, `"POST"`, `"PUT"`). Defaults to `"GET"`.                                                             |                                                                 |
+| body         | any            | The request body to send. Automatically serialized to JSON when `Content-Type` is set to `application/json`.                                             |
+| headers      | object         | Key-value pairs representing HTTP headers to include with the request.                                                                                   |
+| maxRedirects | number         | The number of redirects to follow. Default value is 5. A value of 0 (zero) prevents all redirection.                                                     |
+| timeout      | number, string | Maximum time to wait for the request to complete. Default timeout is 60 seconds ("60s")                                                                  |
+| insecure     | boolean        | If set to true, TLS certificate verification is skipped. This allows connections to servers with self-signed or invalid certificates. Default is false.  |
 
 ## Example of Accept header
 

docs/javascript-api/mokapi-kafka/produceargs.md

@@ -10,7 +10,7 @@ ProduceArgs is an object used by [produce](/docs/javascript-api/mokapi-kafka/pro
 |-----------------------------------|--------|-------------------------------------------------------------------------------------------------------------------------------------------------------------------|
 | cluster (optional)                | string | Kafka cluster name. Used when topic name is not unique.                                                                                                           |
 | topic (optional)                  | string | Kafka topic name. If not specified, message will be written to a random topic.                                                                                    |
-| messages                          | array  | An list of [Message](/docs/javascript-api/mokapi-kafka/message.md) contains Kafka messages to produce into given topic                                            |
+| messages                          | array  | A list of [Message](/docs/javascript-api/mokapi-kafka/message.md) contains Kafka messages to produce into given topic                                             |
 | partition (optional, deprecated ) | number | Kafka partition index. If not specified, the message will be written to any partition                                                                             |
 | key (optional, deprecated)        | any    | Kafka message key. If not specified, a random key will be generated based on the topic configuration.                                                             |
 | value (optional, deprecated)      | any    | Kafka message value. If not specified, a random value will be generated based on the topic configuration. Object will be encoded based on the topic configuration |

docs/javascript-api/mokapi/eventhandler/kafkaeventmessage.md

@@ -7,10 +7,10 @@ description: KafkaEventMessage is an object used by KafkaEventHandler
 KafkaMessage is an object used by [KafkaEventHandler](/docs/javascript-api/mokapi/eventhandler/kafkaeventhandler.md)
 that contains Kafka-specific message data.
 
-| Name    | Type   | Description                                                   |
-|---------|--------|---------------------------------------------------------------|
-| offset  | number | Kafka partition where the message was written to (read-only). |
-| key     | string | Kafka message key                                             |
-| value   | string | Kafka message value                                           |
-| headers | object | Kafka message headers                                         |
+| Name    | Type   | Description                                    |
+|---------|--------|------------------------------------------------|
+| offset  | number | Kafka offset of the kafka message (read-only). |
+| key     | string | Kafka message key                              |
+| value   | string | Kafka message value                            |
+| headers | object | Kafka message headers                          |
 

engine/common/host.go

@@ -116,6 +116,7 @@ type HttpClient interface {
 type HttpClientOptions struct {
 	MaxRedirects int
 	Timeout      time.Duration
+	Insecure     bool
 }
 
 type Action struct {

engine/host.go

@@ -1,6 +1,7 @@
 package engine
 
 import (
+	"crypto/tls"
 	"encoding/json"
 	"fmt"
 	"mokapi/config/dynamic"
@@ -283,8 +284,15 @@ func (sh *scriptHost) KafkaClient() common.KafkaClient {
 }
 
 func (sh *scriptHost) HttpClient(opts common.HttpClientOptions) common.HttpClient {
-	return &http.Client{
-		Timeout: opts.Timeout,
+	transport := http.DefaultTransport.(*http.Transport).Clone()
+
+	if opts.Insecure {
+		transport.TLSClientConfig = &tls.Config{InsecureSkipVerify: true}
+	}
+
+	c := &http.Client{
+		Transport: transport,
+		Timeout:   opts.Timeout,
 		CheckRedirect: func(req *http.Request, via []*http.Request) error {
 			if l := len(via); l > opts.MaxRedirects {
 				log.Warnf("Stopped after %d redirects, original URL was %s", opts.MaxRedirects, via[0].URL)
@@ -293,6 +301,8 @@ func (sh *scriptHost) HttpClient(opts common.HttpClientOptions) common.HttpClien
 			return nil
 		},
 	}
+
+	return c
 }
 
 func (sh *scriptHost) CanClose() bool {

examples/mokapi/services_http.js

@@ -377,7 +377,7 @@ export let apps = [
                     {
                         method: "get",
                         summary: "Finds Pets by status",
-                        description: "Multiple status values can be provided with comma separated strings",
+                        description: "Multiple status values **can** be provided with comma separated strings",
                         operationId: "findPetsByStatus",
                         tags: ["pet"],
                         parameters: [