mirror of
https://github.com/fnproject/fn.git
synced 2022-10-28 21:29:17 +03:00
d56a49b321
Largely a removal job, however many tests, particularly system level ones relied on Routes. These have been migrated to use Fns. * Add 410 response to swagger * No app names in log tags * Adding constraint in GetCall for FnID * Adding test to check FnID is required on call * Add fn_id to call selector * Fix text in docker mem warning * Correct buildConfig func name * Test fix up * Removing CPU setting from Agent test CPU setting has been deprecated, but the code base is still riddled with it. This just removes it from this layer. Really we need to remove it from Call. * Remove fn id check on calls * Reintroduce fn id required on call * Adding fnID to calls for execute test * Correct setting of app id in middleware * Removes root middlewares ability to redirect fun invocations * Add over sized test check * Removing call fn id check
141 lines
3.3 KiB
Go
141 lines
3.3 KiB
Go
package datastoreutil
|
|
|
|
import (
|
|
"context"
|
|
"time"
|
|
|
|
"github.com/fnproject/fn/api/models"
|
|
)
|
|
|
|
// NewValidator returns a models.Datastore which validates certain arguments before delegating to ds.
|
|
func NewValidator(ds models.Datastore) models.Datastore {
|
|
return &validator{ds}
|
|
}
|
|
|
|
type validator struct {
|
|
models.Datastore
|
|
}
|
|
|
|
func (v *validator) GetAppID(ctx context.Context, appName string) (string, error) {
|
|
if appName == "" {
|
|
return "", models.ErrAppsMissingName
|
|
}
|
|
return v.Datastore.GetAppID(ctx, appName)
|
|
}
|
|
|
|
func (v *validator) GetAppByID(ctx context.Context, appID string) (*models.App, error) {
|
|
if appID == "" {
|
|
return nil, models.ErrAppsMissingID
|
|
}
|
|
|
|
return v.Datastore.GetAppByID(ctx, appID)
|
|
}
|
|
|
|
// app and app.Name will never be nil/empty.
|
|
func (v *validator) InsertApp(ctx context.Context, app *models.App) (*models.App, error) {
|
|
if app == nil {
|
|
return nil, models.ErrDatastoreEmptyApp
|
|
}
|
|
if app.ID != "" {
|
|
return nil, models.ErrAppIDProvided
|
|
}
|
|
if err := app.Validate(); err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return v.Datastore.InsertApp(ctx, app)
|
|
}
|
|
|
|
// app and app.Name will never be nil/empty.
|
|
func (v *validator) UpdateApp(ctx context.Context, app *models.App) (*models.App, error) {
|
|
if app == nil {
|
|
return nil, models.ErrDatastoreEmptyApp
|
|
}
|
|
if app.ID == "" {
|
|
return nil, models.ErrAppsMissingID
|
|
}
|
|
|
|
return v.Datastore.UpdateApp(ctx, app)
|
|
}
|
|
|
|
// name will never be empty.
|
|
func (v *validator) RemoveApp(ctx context.Context, appID string) error {
|
|
if appID == "" {
|
|
return models.ErrAppsMissingID
|
|
}
|
|
|
|
return v.Datastore.RemoveApp(ctx, appID)
|
|
}
|
|
|
|
func (v *validator) InsertTrigger(ctx context.Context, t *models.Trigger) (*models.Trigger, error) {
|
|
|
|
if t.ID != "" {
|
|
return nil, models.ErrTriggerIDProvided
|
|
}
|
|
|
|
if !time.Time(t.CreatedAt).IsZero() {
|
|
return nil, models.ErrCreatedAtProvided
|
|
}
|
|
if !time.Time(t.UpdatedAt).IsZero() {
|
|
return nil, models.ErrUpdatedAtProvided
|
|
}
|
|
|
|
return v.Datastore.InsertTrigger(ctx, t)
|
|
}
|
|
|
|
func (v *validator) GetTriggers(ctx context.Context, filter *models.TriggerFilter) (*models.TriggerList, error) {
|
|
|
|
if filter.AppID == "" {
|
|
return nil, models.ErrTriggerMissingAppID
|
|
}
|
|
|
|
return v.Datastore.GetTriggers(ctx, filter)
|
|
}
|
|
func (v *validator) RemoveTrigger(ctx context.Context, triggerID string) error {
|
|
if triggerID == "" {
|
|
return models.ErrMissingID
|
|
}
|
|
|
|
return v.Datastore.RemoveTrigger(ctx, triggerID)
|
|
}
|
|
|
|
func (v *validator) InsertFn(ctx context.Context, fn *models.Fn) (*models.Fn, error) {
|
|
if fn == nil {
|
|
return nil, models.ErrDatastoreEmptyFn
|
|
}
|
|
if fn.ID != "" {
|
|
return nil, models.ErrFnsIDProvided
|
|
}
|
|
if fn.AppID == "" {
|
|
return nil, models.ErrFnsMissingAppID
|
|
}
|
|
if fn.Name == "" {
|
|
return nil, models.ErrFnsMissingName
|
|
}
|
|
return v.Datastore.InsertFn(ctx, fn)
|
|
}
|
|
|
|
func (v *validator) GetFnByID(ctx context.Context, fnID string) (*models.Fn, error) {
|
|
if fnID == "" {
|
|
return nil, models.ErrDatastoreEmptyFnID
|
|
}
|
|
|
|
return v.Datastore.GetFnByID(ctx, fnID)
|
|
}
|
|
|
|
func (v *validator) GetFns(ctx context.Context, filter *models.FnFilter) (*models.FnList, error) {
|
|
|
|
if filter.AppID == "" {
|
|
return nil, models.ErrFnsMissingAppID
|
|
}
|
|
|
|
return v.Datastore.GetFns(ctx, filter)
|
|
}
|
|
|
|
func (v *validator) RemoveFn(ctx context.Context, fnID string) error {
|
|
if fnID == "" {
|
|
return models.ErrDatastoreEmptyFnID
|
|
}
|
|
return v.Datastore.RemoveFn(ctx, fnID)
|
|
}
|