graphify

Jan 30, 2025

Changes in this version

+ func ContainType(t reflect.Type) reflect.Type

+ func DoubleQuote(s string) string

+ func JSONName(f reflect.StructField) string

Jan 27, 2025

Changes in this version

+ func Id(resource, key string) string

+ func Must[T any](v T, err error) T

+ func ProtoMarshal(v any, out proto.Message) error

Jan 27, 2025

Changes in this version

+ func Bytes(v any) []byte

Jan 25, 2025

Changes in this version

+ func AdminKeyFromContext(ctx context.Context) (value string, found bool)

+ func ContextWithAdminKey(parent context.Context, key string) context.Context

Jan 23, 2025

Changes in this version

+ func QueryJoin(parts ...string) string

+ func Quote(s string) string

+ type Access interface

+ AutoMigrate func(ctx context.Context, graph Graph) error

+ Collection func(ctx context.Context, elem any, callbacks ...CollectionCallback) error

+ Create func(ctx context.Context, val any) ([]string, error)

+ Delete func(ctx context.Context, item any) error

+ Fetch func(ctx context.Context, query string, bindVars map[string]any, out any) error

+ Find func(ctx context.Context, bindVars Vars, out any) error

+ List func(ctx context.Context, bindVars Vars, out any) (int64, error)

+ ListKeys func(ctx context.Context, keys []string, out any) error

+ Query func(ctx context.Context, query string, bindVars map[string]any, out any) error

+ Read func(ctx context.Context, key string, out any) error

+ Relations func(ctx context.Context, id string, bindVars Vars, direction Direction, out any) (int64, error)

+ Replace func(ctx context.Context, key string, item any) error

+ Update func(ctx context.Context, key string, item any) error

type ArangoAccess

+ func (e *ArangoAccess) Fetch(ctx context.Context, query string, bindVars map[string]any, out any) error

+ func (e *ArangoAccess) Query(ctx context.Context, query string, bindVars map[string]any, out any) error

+ type Connection interface

+ Collection func(ctx context.Context, elem any) (driver.Collection, error)

+ Database func(ctx context.Context) (driver.Database, error)

+ Reflect func(ctx context.Context, elem reflect.Type) (driver.Collection, error)

+ type FileStorage interface

+ MaxMemory func() int

+ ReadFile func(name string) (fileContent []byte, errr error)

+ StoreByHash func(file []byte) (hash string, err error)

+ StoreFile func(name string, file []byte) (err error)

type Vars

+ Filters func() string

+ Limit func() string

+ Values func() map[string]interface{}

Jan 17, 2025

Changes in this version

+ func Map[T any](size int, fn func(int) T) (result []T)

+ type Validate interface

+ Validate func() error

Jan 16, 2025

Changes in this version

+ func RegisterAdmin(ctx context.Context, access IAccess, admin *accountv1.Admin, password string) (err error)

Jan 16, 2025

Changes in this version

+ func NewDbFileStorage(access IAccess) *dbFileStorage

Jan 11, 2025

Changes in this version

type GraphqlHandler

+ func (e *GraphqlHandler) Handle(ctx context.Context, handlers ...interface{}) *handler.Handler

Jan 10, 2025

Changes in this version

+ func Convert[T any](size int, fn func(int) T) (result []T)

+ func Filter(keyValues ...interface{}) *bindVars

+ func GenerateRandomPassword() string

+ func Pure[T any](v T) (result T)

+ func ToMap(v any) (result map[string]any)

type AdminHandler

+ func (h *AdminHandler) CreateAccount(ctx context.Context, req *dashboardv1.CreateAccountRequest) (*emptypb.Empty, error)

+ func (h *AdminHandler) CreateResource(ctx context.Context, req *dashboardv1.CreateResourceRequest) (*dashboardv1.CreateResourceResponse, error)

+ func (h *AdminHandler) DeleteResource(ctx context.Context, req *dashboardv1.DeleteResourceRequest) (*emptypb.Empty, error)

+ func (h *AdminHandler) FilesDownloadHandler(w http.ResponseWriter, r *http.Request, pathParams map[string]string)

+ func (h *AdminHandler) FilesUploadHandler(w http.ResponseWriter, r *http.Request, _ map[string]string)

+ func (h *AdminHandler) GetAccount(ctx context.Context, req *emptypb.Empty) (*dashboardv1.GetAccountResponse, error)

+ func (h *AdminHandler) GetResource(ctx context.Context, req *dashboardv1.GetResourceRequest) (*dashboardv1.GetResourceResponse, error)

+ func (h *AdminHandler) GetResourceRelation(ctx context.Context, req *dashboardv1.GetResourceRelationRequest) (*dashboardv1.GetResourceRelationResponse, error)

+ func (h *AdminHandler) GetSchema(ctx context.Context, req *emptypb.Empty) (*dashboardv1.GetSchemaResponse, error)

+ func (h *AdminHandler) ListResources(ctx context.Context, req *dashboardv1.ListResourcesRequest) (*dashboardv1.ListResourcesResponse, error)

+ func (h *AdminHandler) Login(ctx context.Context, req *dashboardv1.LoginRequest) (*dashboardv1.LoginResponse, error)

+ func (h *AdminHandler) UpdateResource(ctx context.Context, req *dashboardv1.UpdateResourceRequest) (*dashboardv1.UpdateResourceResponse, error)

+ type IVars interface

+ Filters func() string

+ Limit func() string

+ Values func() map[string]interface{}

Dec 9, 2024

Changes in this version

+ func ExposeNodes(nodes ...any) exposedNodes

+ type AdminHandler struct

+ func NewAdminHandler(ctx context.Context, config AdminHandlerConfig, params AdminHandlerParams) *AdminHandler

+ func (e *AdminHandler) Handler(ctx context.Context) http.Handler

+ type AdminHandlerConfig struct

+ Secret []byte

+ type AdminHandlerParams struct

+ Access IAccess

+ Graph IGraph

+ Observer IObserver[Topic]

+ Storage IFileStorage

+ type ArangoAccess struct

+ func NewArangoAccess(conn IConnection, observer IObserver[Topic]) *ArangoAccess

+ func (e *ArangoAccess) AutoMigrate(ctx context.Context, graph IGraph) error

+ func (e *ArangoAccess) Collection(ctx context.Context, elem any, callbacks ...CollectionCallback) (err error)

+ func (e *ArangoAccess) Create(ctx context.Context, val any) ([]string, error)

+ func (e *ArangoAccess) Delete(ctx context.Context, item any) error

+ func (e *ArangoAccess) Find(ctx context.Context, bindVars Vars, out any) error

+ func (e *ArangoAccess) List(ctx context.Context, bindVars Vars, out any) (int64, error)

+ func (e *ArangoAccess) ListKeys(ctx context.Context, keys []string, out any) error

+ func (e *ArangoAccess) Read(ctx context.Context, key string, out any) error

+ func (e *ArangoAccess) Relations(ctx context.Context, id string, bindVars Vars, direction Direction, out any) (int, error)

+ func (e *ArangoAccess) Replace(ctx context.Context, key string, item any) error

+ func (e *ArangoAccess) Update(ctx context.Context, key string, item any) error

+ type CollectionCallback func(context.Context, driver.Collection)

+ type ConnectionConfig struct

+ Connection http.ConnectionConfig

+ DBName string

+ Password string

+ UserName string

+ type Empty struct

+ func (*Empty) Argument() graphql.FieldConfigArgument

+ type FilesystemStorageConfig struct

+ BasePath string

+ MaxMemory int

+ type Graph struct

+ func (g *Graph) CollectionFor(t reflect.Type) string

+ func (g *Graph) Edge(from, to, edge any)

+ func (g *Graph) Edges() []reflect.Type

+ func (g *Graph) Node(node any)

+ func (g *Graph) Nodes() []reflect.Type

+ func (g *Graph) Relation(edge reflect.Type) *Relation

+ func (g *Graph) TypeOf(collection string) reflect.Type

+ type GraphqlHandler struct

+ func NewGraphqlHandler(access IAccess, graph IGraph) *GraphqlHandler

+ func (e *GraphqlHandler) Handler(ctx context.Context, handlers ...interface{}) *handler.Handler

+ type IAccess interface

+ AutoMigrate func(ctx context.Context, graph IGraph) error

+ Collection func(ctx context.Context, elem any, callbacks ...CollectionCallback) (err error)

+ Create func(ctx context.Context, val any) ([]string, error)

+ Delete func(ctx context.Context, item any) error

+ Find func(ctx context.Context, bindVars Vars, out any) error

+ List func(ctx context.Context, bindVars Vars, out any) (int64, error)

+ ListKeys func(ctx context.Context, keys []string, out any) error

+ Read func(ctx context.Context, key string, out any) error

+ Relations func(ctx context.Context, id string, bindVars Vars, direction Direction, out any) (int, error)

+ Replace func(ctx context.Context, key string, item any) error

+ Update func(ctx context.Context, key string, item any) error

type IConnection

+ Collection func(ctx context.Context, elem any) (driver.Collection, error)

+ Database func(ctx context.Context) (driver.Database, error)

+ Reflect func(ctx context.Context, elem reflect.Type) (driver.Collection, error)

+ type IGraph interface

+ CollectionFor func(elem reflect.Type) string

+ Edge func(from, to, edge any)

+ Edges func() []reflect.Type

+ Node func(node any)

+ Nodes func() []reflect.Type

+ Relation func(edge reflect.Type) *Relation

+ TypeOf func(colection string) reflect.Type

+ type Relation struct

+ From reflect.Type

+ To reflect.Type

+ type Vars map[string]interface

May 13, 2024

Changes in this version

+ func ContextWithSecret(parent context.Context, secret []byte) context.Context

+ func SecretFromContext(ctx context.Context) (value []byte, found bool)

May 13, 2024

Changes in this version

+ func Find(ctx context.Context, bindVars map[string]interface{}, out any) error

type DatabaseConfig

+ Connection http.ConnectionConfig

+ type PaginationResult struct

+ Count int64

+ Items any

May 5, 2024

Changes in this version

+ type Mutation *graphql.Field

+ type Query *graphql.Field

+ type UnsafeHandlers bool

Apr 28, 2024

Changes in this version

+ func Replace(ctx context.Context, key string, item any) error

type Topic

+ var AdminReplacedTopic Topic = "admin_replaced"

+ var ReplacedTopic Topic = "replaced"

Apr 27, 2024

Changes in this version

+ type Pagination struct

+ Count int64

+ Items any

type Topic

+ var AdminCreatedTopic Topic = "admin_created"

+ var AdminDeletedTopic Topic = "admin_deleted"

+ var AdminUpdatedTopic Topic = "admin_updated"

Mar 23, 2024

Changes in this version

+ func Collection(ctx context.Context, elem interface{}, ...) (err error)

Mar 21, 2024

Changes in this version

+ func DevelopmentContext(parent context.Context) context.Context

+ func IsDevelopmentContext(ctx context.Context) bool

+ type Direction string

+ const DirectionAny

+ const DirectionInbound

+ const DirectionOutbound

Mar 13, 2024

Changes in this version

+ var BeastList = []Beast

+ func AdminFromContext(ctx context.Context) (admin *adminv1.Admin, found bool)

+ func ContextWithAdmin(parent context.Context, admin *adminv1.Admin) context.Context

+ func ContextWithConnection(parent context.Context, conn IConnection) context.Context

+ func ContextWithObserver(parent context.Context, observer IObserver[Topic]) context.Context

+ func ContextWithStorage(parent context.Context, storage IFileStorage) context.Context

+ func Relations(ctx context.Context, id string, out interface{}, ...) (int, error)

+ type Beast struct

+ Description string

+ ID int

+ ImageURL string

+ Name string

+ OtherNames []string

type DatabaseConfig

+ DBName string

+ Password string

+ UserName string

type IConnection

+ func ConnectionFromContext(ctx context.Context) (conn IConnection, found bool)

type IFileStorage

+ func StorageFromContext(ctx context.Context) (storage IFileStorage, found bool)

type IObserver

+ func ObserverFromContext(ctx context.Context) (observer IObserver[Topic], found bool)

Mar 2, 2024

Changes in this version

+ type ApplicationConfig struct

+ Domain string

+ Logo string

+ Name string

+ type ApplicationConfigInit struct

+ Admin adminv1.Admin

+ Config ApplicationConfig

+ Password string

type IFileStorage

+ StoreByHash func(file multipart.File) (hash string, err error)

Mar 2, 2024

Changes in this version

+ func NewFilesystemStorage(basePath string, maxMemory int64) *filesystemStorage

+ func WriteFileResponse(w http.ResponseWriter, filename, fileContentType string, fileContent []byte)

type Common

+ Storage IFileStorage

+ type IFileStorage interface

+ MaxMemory func() int64

+ ReadFile func(hash string) (fileContent []byte, errr error)

+ StoreFile func(file multipart.File, header *multipart.FileHeader) (hash string, err error)

Mar 1, 2024

Changes in this version

+ func WriteResponse(w http.ResponseWriter, status int, data []byte)

type Topic

+ func (t Topic) For(elem interface{}) Topic

Feb 28, 2024

Changes in this version

+ func CollectionFor(t reflect.Type) string

+ func ContextWithDatabaseConfig(ctx context.Context, cnf DatabaseConfig) context.Context

+ func Create(ctx context.Context, val interface{}, comm *Common) ([]string, error)

+ func Delete(ctx context.Context, item interface{}, comm *Common) error

+ func List(ctx context.Context, offset, count int, out interface{}, comm *Common) (int, error)

+ func ListKeys(ctx context.Context, keys []string, out interface{}, comm *Common) error

+ func NewConnection() *connection

+ func NewGraph(comm *Common) *graph

+ func Read(ctx context.Context, key string, out interface{}, comm *Common) error

+ func Update(ctx context.Context, key string, item interface{}, comm *Common) error

+ func WriteErrorResponse(w http.ResponseWriter, status int, err error)

+ func WriteJSONResponse(w http.ResponseWriter, status int, data interface{})

+ func WriteSuccessResponse(w http.ResponseWriter, status int)

+ type Common struct

+ Connection IConnection

+ Observer IObserver[Topic]

+ type DatabaseConfig struct

+ Name string

+ func DatabaseConfigFromContext(ctx context.Context) (*DatabaseConfig, error)

+ type Event struct

+ Payload protoreflect.ProtoMessage

+ Timestamp time.Time

+ Topic T

+ type IConnection interface

+ GetCollection func(ctx context.Context, elem reflect.Type) (driver.Collection, error)

+ GetDatabase func(ctx context.Context) (driver.Database, error)

+ type IObserver interface

+ Emit func(e *Event[T]) error

+ Subscribe func(t T, p Processor[T]) SourceID

+ Unsubscribe func(s SourceID)

+ type Observer struct

+ func NewObserver[T comparable]() *Observer[T]

+ func (o *Observer[T]) Emit(e *Event[T]) error

+ func (o *Observer[T]) Subscribe(t T, p Processor[T]) SourceID

+ func (o *Observer[T]) Unsubscribe(s SourceID)

+ type Processor func(e *Event[T]) error

+ type SourceID int64

+ type Topic string

+ var CreatedTopic Topic = "Created"

+ var DeletedTopic Topic = "Deleted"

+ var UpdatedTopic Topic = "Updated"

+ func (t Topic) With(elem interface{}) Topic