Updates

Author: djthorpe

etc/server.yaml

@@ -21,4 +21,7 @@ sqlite3:
     main: ":memory:"
   # Set trace to true to enable the ability to profile queries
   trace: true
+  # Set max number of connections that can be simultaneously opened
+  max: 100
+
 

pkg/sqlite3/sqlite3.go

@@ -13,3 +13,11 @@ const (
 	tempSchema    = "temp"
 	defaultMemory = sqlite3.DefaultMemory
 )
+
+////////////////////////////////////////////////////////////////////////////////
+// METHODS
+
+func Version() string {
+	str, _, _ := sqlite3.Version()
+	return str
+}

plugin/sqlite3/handlers.go

@@ -6,8 +6,11 @@ import (
 	"regexp"
 
 	// Modules
-	server "github.com/djthorpe/go-server"
 	router "github.com/djthorpe/go-server/pkg/httprouter"
+	sqlite3 "github.com/djthorpe/go-sqlite/pkg/sqlite3"
+
+	// Namespace imports
+	. "github.com/djthorpe/go-server"
 
 	// Some sort of hack
 	_ "gopkg.in/yaml.v3"
@@ -39,7 +42,7 @@ const (
 ///////////////////////////////////////////////////////////////////////////////
 // LIFECYCLE
 
-func (p *plugin) AddHandlers(ctx context.Context, provider server.Provider) error {
+func (p *plugin) AddHandlers(ctx context.Context, provider Provider) error {
 
 	// Add handler for ping
 	if err := provider.AddHandlerFuncEx(ctx, reRoutePing, p.ServePing); err != nil {
@@ -67,6 +70,7 @@ func (p *plugin) ServePing(w http.ResponseWriter, req *http.Request) {
 		Modules: []string{},
 		Schemas: []string{},
 	}
+	response.Version = sqlite3.Version()
 	response.Modules = append(response.Modules, conn.Modules()...)
 	response.Schemas = append(response.Schemas, conn.Schemas()...)
 

plugin/sqlite3/main.go

@@ -2,13 +2,12 @@ package main
 
 import (
 	"context"
-	"time"
 
-	// Modules
-	server "github.com/djthorpe/go-server"
+	// Packages
 	sqlite3 "github.com/djthorpe/go-sqlite/pkg/sqlite3"
 
 	// Namespace imports
+	. "github.com/djthorpe/go-server"
 	. "github.com/djthorpe/go-sqlite"
 )
 
@@ -20,18 +19,11 @@ type plugin struct {
 	errs chan error
 }
 
-///////////////////////////////////////////////////////////////////////////////
-// GLOBALS
-
-const (
-	tickerDelta = time.Second * 5
-)
-
 ///////////////////////////////////////////////////////////////////////////////
 // LIFECYCLE
 
 // Create the module
-func New(ctx context.Context, provider server.Provider) server.Plugin {
+func New(ctx context.Context, provider Provider) Plugin {
 	p := new(plugin)
 
 	// Get configuration
@@ -63,7 +55,7 @@ func Name() string {
 	return "sqlite3"
 }
 
-func (p *plugin) Run(ctx context.Context, provider server.Provider) error {
+func (p *plugin) Run(ctx context.Context, provider Provider) error {
 	// Add handlers
 	if err := p.AddHandlers(ctx, provider); err != nil {
 		return err