Compare commits
3 Commits
8910fced57
...
1fdc1fc456
Author | SHA1 | Date | |
---|---|---|---|
1fdc1fc456 | |||
4eb3a9d2a7 | |||
01933df053 |
29
README.md
29
README.md
@ -10,7 +10,34 @@ These tools work with YAML descriptions of resources (E.g. files, users, contain
|
||||
|
||||
# Releases
|
||||
|
||||
v0 releases are unstable and changes may be made to interfaces and specifications.
|
||||
**v0 releases are unstable and changes may be made to interfaces and specifications.**
|
||||
|
||||
# JX Documents
|
||||
|
||||
The JX YAML specification is a simple way to describe system resources. The two main components are `configurations` and `resources`.
|
||||
|
||||
## Configurations
|
||||
|
||||
`
|
||||
configurations:
|
||||
- name: myhttpconfig
|
||||
values:
|
||||
http_user: jex
|
||||
http_password: sample
|
||||
- name: myhttptoken
|
||||
values:
|
||||
authorization_token: abcde123456789
|
||||
`
|
||||
|
||||
## Resources
|
||||
`
|
||||
resources:
|
||||
- type: http
|
||||
config: myhttptoken
|
||||
transition: read
|
||||
attributes:
|
||||
endpoint: https://myserver/v1/api
|
||||
`
|
||||
|
||||
# Testing
|
||||
|
||||
|
81
internal/config/system.go
Normal file
81
internal/config/system.go
Normal file
@ -0,0 +1,81 @@
|
||||
// Copyright 2024 Matthew Rich <matthewrich.conf@gmail.com>. All rights reserved.
|
||||
|
||||
package config
|
||||
|
||||
import (
|
||||
"context"
|
||||
"encoding/json"
|
||||
"net/url"
|
||||
"fmt"
|
||||
"decl/internal/data"
|
||||
"decl/internal/folio"
|
||||
"runtime"
|
||||
)
|
||||
|
||||
// Collects facts about the system
|
||||
|
||||
var (
|
||||
buildValues = map[string]any{
|
||||
"GOOS": runtime.GOOS,
|
||||
"GOARCH": runtime.GOARCH,
|
||||
}
|
||||
)
|
||||
|
||||
func init() {
|
||||
folio.DocumentRegistry.ConfigurationTypes.Register([]string{"system"}, func(u *url.URL) data.Configuration {
|
||||
s := NewSystem()
|
||||
return s
|
||||
})
|
||||
}
|
||||
|
||||
type System Generic[any]
|
||||
|
||||
func NewSystem() *System {
|
||||
s := make(System)
|
||||
for k, v := range buildValues {
|
||||
s[k] = v
|
||||
}
|
||||
return &s
|
||||
}
|
||||
|
||||
func (s *System) URI() string {
|
||||
return fmt.Sprintf("%s://%s", s.Type(), "")
|
||||
}
|
||||
|
||||
func (s *System) SetURI(uri string) error {
|
||||
return nil
|
||||
}
|
||||
|
||||
func (s *System) SetParsedURI(uri *url.URL) error {
|
||||
return nil
|
||||
}
|
||||
|
||||
func (s *System) Clone() data.Configuration {
|
||||
jsonSystem, _ := json.Marshal(s)
|
||||
clone := NewSystem()
|
||||
if unmarshalErr := json.Unmarshal(jsonSystem, clone); unmarshalErr != nil {
|
||||
panic(unmarshalErr)
|
||||
}
|
||||
return clone
|
||||
}
|
||||
|
||||
func (s *System) Has(key string) (ok bool) {
|
||||
_, ok = (*s)[key]
|
||||
return
|
||||
}
|
||||
|
||||
func (s *System) Type() string {
|
||||
return "system"
|
||||
}
|
||||
|
||||
func (s *System) Read(context.Context) ([]byte, error) {
|
||||
return nil, nil
|
||||
}
|
||||
|
||||
func (s *System) GetValue(name string) (result any, err error) {
|
||||
var ok bool
|
||||
if result, ok = (*s)[name]; !ok {
|
||||
err = ErrUnknownConfigurationKey
|
||||
}
|
||||
return
|
||||
}
|
20
internal/config/system_test.go
Normal file
20
internal/config/system_test.go
Normal file
@ -0,0 +1,20 @@
|
||||
// Copyright 2024 Matthew Rich <matthewrich.conf@gmail.com>. All rights reserved.
|
||||
|
||||
package config
|
||||
|
||||
import (
|
||||
"github.com/stretchr/testify/assert"
|
||||
"testing"
|
||||
)
|
||||
|
||||
func TestNewSystemConfig(t *testing.T) {
|
||||
s := NewSystem()
|
||||
assert.NotNil(t, s)
|
||||
}
|
||||
|
||||
func TestSystemConfig(t *testing.T) {
|
||||
s := NewSystem()
|
||||
assert.NotNil(t, s)
|
||||
|
||||
assert.True(t, s.Has("GOARCH"))
|
||||
}
|
@ -10,11 +10,11 @@ import (
|
||||
type ReadFilter func([]byte, int, error) (int, error)
|
||||
|
||||
type Reader struct {
|
||||
input io.Reader
|
||||
input io.ReadCloser
|
||||
filter ReadFilter
|
||||
}
|
||||
|
||||
func NewReader(reader io.Reader, filter ReadFilter) *Reader {
|
||||
func NewReader(reader io.ReadCloser, filter ReadFilter) *Reader {
|
||||
return &Reader{
|
||||
input: reader,
|
||||
filter: filter,
|
||||
@ -30,3 +30,7 @@ func (r *Reader) Read(p []byte) (n int, err error) {
|
||||
}
|
||||
return n, err
|
||||
}
|
||||
|
||||
func (r *Reader) Close() error {
|
||||
return r.input.Close()
|
||||
}
|
||||
|
@ -6,11 +6,12 @@ import (
|
||||
"github.com/stretchr/testify/assert"
|
||||
"testing"
|
||||
"strings"
|
||||
"io"
|
||||
)
|
||||
|
||||
func TestNewReader(t *testing.T) {
|
||||
buffer := make([]byte, 20)
|
||||
reader := NewReader(strings.NewReader("testdata"), func(p []byte, in int, e error) (int, error) {
|
||||
reader := NewReader(io.NopCloser(strings.NewReader("testdata")), func(p []byte, in int, e error) (int, error) {
|
||||
copy(p, []byte("foo"))
|
||||
return 3, nil
|
||||
})
|
||||
|
Loading…
Reference in New Issue
Block a user