This commit is contained in:
sujit
2025-08-05 08:53:38 +05:45
parent b601da07d8
commit f40518c53e
5 changed files with 244 additions and 44 deletions

View File

@@ -4,38 +4,76 @@ import (
"fmt"
"net/http"
"os"
"strings"
"sync"
"github.com/oarkflow/jsonschema"
"github.com/oarkflow/mq/renderer"
)
func main() {
schemaContent, err := os.ReadFile("schema.json")
if err != nil {
fmt.Printf("Error reading schema file: %v\n", err)
return
type RequestSchemaTemplate struct {
Schema *jsonschema.Schema `json:"schema"`
Renderer *renderer.JSONSchemaRenderer `json:"template"`
}
var cache = make(map[string]*RequestSchemaTemplate)
var mu = &sync.Mutex{}
func getCachedRenderer(schemaPath, template string) (*renderer.JSONSchemaRenderer, error) {
mu.Lock()
defer mu.Unlock()
path := fmt.Sprintf("%s:%s", schemaPath, template)
if cached, exists := cache[path]; exists {
return cached.Renderer, nil
}
schemaContent, err := os.ReadFile(schemaPath)
if err != nil {
return nil, fmt.Errorf("error reading schema file: %w", err)
}
compiler := jsonschema.NewCompiler()
schema, err := compiler.Compile(schemaContent)
if err != nil {
fmt.Printf("Error compiling schema: %v\n", err)
return
return nil, fmt.Errorf("error compiling schema: %w", err)
}
templatePath := fmt.Sprintf("templates/%s.html", template)
htmlLayout, err := os.ReadFile(templatePath)
if err != nil {
return nil, fmt.Errorf("failed to load template: %w", err)
}
renderer := renderer.NewJSONSchemaRenderer(schema, string(htmlLayout))
cachedTemplate := &RequestSchemaTemplate{
Schema: schema,
Renderer: renderer,
}
cache[path] = cachedTemplate
return cachedTemplate.Renderer, nil
}
func main() {
http.Handle("/form.css", http.FileServer(http.Dir("templates")))
http.HandleFunc("/render", func(w http.ResponseWriter, r *http.Request) {
templateName := r.URL.Query().Get("template")
if templateName == "" {
templateName = "basic"
}
templatePath := fmt.Sprintf("templates/%s.html", templateName)
htmlLayout, err := os.ReadFile(templatePath)
if err != nil {
http.Error(w, fmt.Sprintf("Failed to load template: %v", err), http.StatusInternalServerError)
schemaHTML := r.URL.Query().Get("schema")
if schemaHTML == "" {
http.Error(w, "Schema parameter is required", http.StatusBadRequest)
return
}
if !strings.Contains(schemaHTML, ".json") {
schemaHTML = fmt.Sprintf("%s.json", schemaHTML)
}
renderer, err := getCachedRenderer(schemaHTML, templateName)
if err != nil {
http.Error(w, fmt.Sprintf("Failed to get cached template: %v", err), http.StatusInternalServerError)
return
}
renderer := renderer.NewJSONSchemaRenderer(schema, string(htmlLayout))
// Set template data for dynamic interpolation
templateData := map[string]interface{}{
@@ -46,9 +84,7 @@ func main() {
templateData["task_id"] = "default_task_123"
}
renderer.SetTemplateData(templateData)
renderedHTML, err := renderer.RenderFields()
renderedHTML, err := renderer.RenderFields(templateData)
if err != nil {
http.Error(w, fmt.Sprintf("Failed to render fields: %v", err), http.StatusInternalServerError)
return