Add filters

Author: Vilsol

filter/processor.go

@@ -0,0 +1,15 @@
+package filter
+
+var processorInstance Processor
+
+func SetProcessor(processor Processor) {
+	processorInstance = processor
+}
+
+func GetProcessor() Processor {
+	if processorInstance == nil {
+		panic("filter processor is nil")
+	}
+
+	return processorInstance
+}

filter/types.go

@@ -0,0 +1,26 @@
+package filter
+
+import (
+	"encoding/json"
+)
+
+type Processor interface {
+	// Check if a filter exists
+	FilterExists(filter string) bool
+
+	// Create a new instance of the filter
+	CreateFilter(filter string) interface{}
+
+	// Validate structure for filter validness
+	ValidateFilter(filter ProcessedFilter) (bool, error)
+}
+
+type EncodedFilter struct {
+	Type string          `json:"type"`
+	Data json.RawMessage `json:"data"`
+}
+
+type ProcessedFilter struct {
+	Type string      `json:"type"`
+	Data interface{} `json:"data"`
+}

plugins/types.go

@@ -1,5 +1,9 @@
 package plugins
 
+import (
+	"github.com/StratoAPI/Interface/filter"
+)
+
 type Plugin interface {
 	// The name of the plugin
 	Name() string
@@ -30,16 +34,16 @@ type Storage interface {
 	Stop() error
 
 	// Retrieve resources.
-	GetResources(resource string, filters []interface{}) ([]map[string]interface{}, error)
+	GetResources(resource string, filters []filter.ProcessedFilter) ([]map[string]interface{}, error)
 
 	// Create resources.
 	CreateResources(resource string, data []map[string]interface{}) error
 
 	// Update resources.
-	UpdateResources(resource string, data []map[string]interface{}, filters []interface{}) error
+	UpdateResources(resource string, data []map[string]interface{}, filters []filter.ProcessedFilter) error
 
 	// Delete resources.
-	DeleteResources(resource string, filters []interface{}) error
+	DeleteResources(resource string, filters []filter.ProcessedFilter) error
 }
 
 type Filter interface {
@@ -53,7 +57,10 @@ type Filter interface {
 	Stop() error
 
 	// Validate structure for filter validness
-	ValidateFilter(filter interface{}) (bool, error)
+	ValidateFilter(filter filter.ProcessedFilter) (bool, error)
+
+	// Create a new instance of the filter
+	CreateFilter(filter string) interface{}
 }
 
 type Registry interface {

schema/types.go

@@ -1,12 +1,13 @@
 package schema
 
 type Processor interface {
-	// Get the store of a resource
+	// Check if a resource schema exists
 	ResourceExists(resource string) bool
 
-	// Get a list of all resources
+	// Check if the resource structure is valid
 	ResourceValid(resource string, data string) (bool, error)
 
+	// Get the schema of a resource
 	GetSchema(resource string) *Schema
 }