diff --git a/cert/cert.go b/cert/cert.go new file mode 100644 index 0000000..f7d89cf --- /dev/null +++ b/cert/cert.go @@ -0,0 +1,89 @@ +package cert + +import ( + "crypto/rand" + "crypto/rsa" + "crypto/x509" + "crypto/x509/pkix" + "encoding/pem" + "math/big" + "os" + "path" + "time" +) + +type Cert struct { + Organization string + CertFile string + KeyFile string +} + +// Initialize a new ssl certificate handler with organization name +func NewCertHandler(org string) *Cert { + return &Cert{ + Organization: org, + } +} + +// generates a new self signed ssl certificate foe localhost and development use +func (c *Cert) GenerateSelfSignedCert() error { + + // do not generate certs if they exist + // _, err := os.Stat(c.CertFile) + // _, err2 := os.Stat(c.KeyFile) + // if !os.IsNotExist(err) && !os.IsNotExist(err2) { + // return nil + // } + + priv, err := rsa.GenerateKey(rand.Reader, 2048) + if err != nil { + return err + } + + serialNumber, _ := rand.Int(rand.Reader, big.NewInt(1<<62)) + + template := x509.Certificate{ + SerialNumber: serialNumber, + Subject: pkix.Name{ + CommonName: "localhost", + Organization: []string{c.Organization}, + }, + NotBefore: time.Now(), + NotAfter: time.Now().Add(365 * 24 * time.Hour), + + KeyUsage: x509.KeyUsageKeyEncipherment | x509.KeyUsageDigitalSignature, + ExtKeyUsage: []x509.ExtKeyUsage{x509.ExtKeyUsageServerAuth}, + BasicConstraintsValid: true, + DNSNames: []string{"localhost"}, + } + + certDER, err := x509.CreateCertificate(rand.Reader, &template, &template, &priv.PublicKey, priv) + if err != nil { + return err + } + + if _, err := os.Stat(path.Dir(c.CertFile)); os.IsNotExist(err) { + os.MkdirAll(path.Dir(c.CertFile), 0666) + } + + certOut, err := os.Create(c.CertFile) + if err != nil { + return err + } + defer certOut.Close() + pem.Encode(certOut, &pem.Block{Type: "CERTIFICATE", Bytes: certDER}) + + if _, err := os.Stat(path.Dir(c.KeyFile)); os.IsNotExist(err) { + os.MkdirAll(path.Dir(c.KeyFile), 0666) + } + + keyOut, err := os.Create(c.KeyFile) + if err != nil { + return err + } + defer keyOut.Close() + + pem.Encode(keyOut, &pem.Block{Type: "RSA PRIVATE KEY", Bytes: x509.MarshalPKCS1PrivateKey(priv)}) + + return nil +} diff --git a/cert/cert.pem b/cert/cert.pem new file mode 100644 index 0000000..590fa19 --- /dev/null +++ b/cert/cert.pem @@ -0,0 +1,19 @@ +-----BEGIN CERTIFICATE----- +MIIDGzCCAgOgAwIBAgIIB2N9YzgUYFAwDQYJKoZIhvcNAQELBQAwJzERMA8GA1UE +ChMIdGVjYW1pbm8xEjAQBgNVBAMTCWxvY2FsaG9zdDAeFw0yNTA0MTYxNjE2NDJa +Fw0yNjA0MTYxNjE2NDJaMCcxETAPBgNVBAoTCHRlY2FtaW5vMRIwEAYDVQQDEwls +b2NhbGhvc3QwggEiMA0GCSqGSIb3DQEBAQUAA4IBDwAwggEKAoIBAQDDFOsJDNRd +wX25lB1QGCFhvjK+yN/pZHNtjQvHOcajON+Fhm56RWKbuKR4BQdNWF/uWe/wH6kC +xrYXzuAqJIzB/trFZ14whNblxjjxSmGhkMNFFTIIIdTICcoQu3+zzXxUc4s9ni4R +uGXudFB7uSZBx5x2TWrdFzBIfAuWfQfCwMWqiDoTH09T7DxJJyuvKf4yNPyDq+oe +4WGEXCpk3VBjggqYDGknMUzreEEa8JaIuDMFhQz4J4A5QGZOHOEyaP839cDblY31 +ot5Pd6PUAs5yvmvIZUCscW7bJH2vUqDC2tJ4WjkVkykULLIDIbe4Thi4//9oKzKV +fhP2TM9t+OeVAgMBAAGjSzBJMA4GA1UdDwEB/wQEAwIFoDATBgNVHSUEDDAKBggr +BgEFBQcDATAMBgNVHRMBAf8EAjAAMBQGA1UdEQQNMAuCCWxvY2FsaG9zdDANBgkq +hkiG9w0BAQsFAAOCAQEANfjOOkU/fl7Y2pJ6V+qKv9vdBb4nEpiNOnSl8sSgZP4r +wa1ArfALCPY1Gu+XDrwqcVLii511xT4cFuegxaOdu2+5j4+WjIR9ke/AeEuyNU1X +mm/xgBOSibxqSWVHTGhLLY4jwyU3GYx+4ODNmLoQ2eNQ7NDsCDAQq+OAbR+f5486 +j8AcrjEjWI5Nh9p4DiqEA1DwNCKnpYcw8QBiawNFli3mvFSu1KSTG5UGM8vwzCOu +nk2GtBvhDODVhDuM3BjqAmT7xbIJGXdW25+FG9++Vc+36LVSJVxMeOWx4u07Ggqk +4y39spP+xOzXegFCJXu+OkxjvZ7mRGaPp1zKeaoVVQ== +-----END CERTIFICATE----- diff --git a/cert/key.pem b/cert/key.pem new file mode 100644 index 0000000..4e0cc3a --- /dev/null +++ b/cert/key.pem @@ -0,0 +1,27 @@ +-----BEGIN RSA PRIVATE KEY----- +MIIEpAIBAAKCAQEAwxTrCQzUXcF9uZQdUBghYb4yvsjf6WRzbY0LxznGozjfhYZu +ekVim7ikeAUHTVhf7lnv8B+pAsa2F87gKiSMwf7axWdeMITW5cY48UphoZDDRRUy +CCHUyAnKELt/s818VHOLPZ4uEbhl7nRQe7kmQcecdk1q3RcwSHwLln0HwsDFqog6 +Ex9PU+w8SScrryn+MjT8g6vqHuFhhFwqZN1QY4IKmAxpJzFM63hBGvCWiLgzBYUM ++CeAOUBmThzhMmj/N/XA25WN9aLeT3ej1ALOcr5ryGVArHFu2yR9r1KgwtrSeFo5 +FZMpFCyyAyG3uE4YuP//aCsylX4T9kzPbfjnlQIDAQABAoIBAAfekaahTyj8puMA +39489ifFVOW2U7X/nw2Y+Xpb0P2azAV//HfpOAbN5kopjCrC35SaKZNdq5ZllRXi +LgL1MeQBF5ElnNQtn6YDa4U5E2j0xOb5NmkpxQKDk2E+aj92EOEu2G78l24pxDVG +Zhkl/GGXheIna4hBdbZCCFoI1b9o4w1iFLsc1MJxDszRqxD5M9uZ4YMtI6rGrUtx +xAeYqSvEnMfYHRXbQlFhZF2F9suW+rsUpL264bQ7OPMNsQAtsu5Q9x1dEMuuj+NX +4Tavu78CyVGjBrBrCDJ0P/r/EyK72n8noZBto+Xzk4S3PjxWfb0HVsHYVaeq2O+I +3et0C+cCgYEA8fd9NB31KU2sjJtNWBq7Vs/6F6IPlZat6FCHFDjt0wCm9LK0gMii +l79mJyKwI3i2K3HKVDrpuplYBJ9Z7XQCQin6844Bcp0OizIHX4OYf1CSWsQbJZFm +SdrUwKyijYR9nHKmjbFa+PWFh/HD630kkkLEFt+Ti+CsdNe0+Hmfc7cCgYEAzmVS +JX9DZVZMvEUPanPrHI1vAkFTd9YSGPx088yadomF8cL6QbYXUFq+ZMq3st70S+qr +XxBXjjmDTuE8tLepZemIIM9UC6AQ+2IE/RiThLyKrhk9b/7myqWSz9cY8/SqMOsW +015U4Jc+KRS1/Tse8Y7tyzHFlthACoKX5HrxNxMCgYBuOQ1B1nu9ivKVQpGjFtpM +G4WTinGK9Q7XiwddgOlleyCSy21KVRssATZpkXWnUu+5Lqa6Y/Pg2sWrpWNztarp +tPHqTMAAE+dyJSISsoGfTXa9/iNXo7py3kqYUovh537I67lPRoFoc3+Wg915wpIM +RnnI6aPuzjQBLdn0boLiVQKBgQC/cv6y54ylmFqPnOPC1Am3r33UMrJxC3I4GR2G +9DgnUkOb0Ud/4p9XmwTWy6+ATQ2AygnyoV8F/1VMuuMrot2QOgJapNaJ/g0ikXad +KsnTq2xcN+9kTqbYPKOlBRoRWNbxj2/Z2ruSpNg1FRAG+GsomHL9M4rb9HXbCe5J +Mr1DXwKBgQDmsYhXErxHiQ0jwDgqFmcKRjm/UvEGzuJ1wMZzCBU1GNAOid25QHvI +VIsJjYT6idRNHNxFr7AoW5bpTRMsfh8nLD4VfK9k2HbiRbZmDhC03zxXpgbzRWrp +bWTuoTIidPr5pt6XFlPU9NYPfgpGJvcCSbE15UQBd4DLts+UcZZ3Zw== +-----END RSA PRIVATE KEY----- diff --git a/driver/artNet.go b/driver/artNet.go new file mode 100644 index 0000000..cec3dfd --- /dev/null +++ b/driver/artNet.go @@ -0,0 +1,29 @@ +package driver + +import "artNet/models" + +type ArtNetDriver struct { + Bus []*models.Bus +} + +// initialize new Art-Net driver +func NewDriver() *ArtNetDriver { + return &ArtNetDriver{} +} + +// adds new Art-Net interface to driver port 0 = 6454 (default art-net) +func (d *ArtNetDriver) NewInterface(ip string, port int) *models.Bus { + i := models.NewBus(ip, port) + d.Bus = append(d.Bus, i) + return i +} + +// dmxData[46] = byte(255) // Channel 1: Red +// dmxData[47] = byte(255) // Channel 2: Green +// dmxData[48] = byte(255) // Channel 3: Blue +// dmxData[49] = byte(255) // Channel 4: White +// dmxData[50] = byte(255) // Channel 5: Amber +// dmxData[51] = byte(255) // Channel 6: UV Lila +// dmxData[52] = byte(255) // Channel 7: 0-9 10-255 strobo +// dmxData[53] = byte(255) // Channel 8: 0-5 stop 6-127 static position 128-255 Motorgeschwindigkeit +// dmxData[54] = byte(255) // Channel 9: 0-50 coincitence 51 -100 two color 101-150 all color diff --git a/go.mod b/go.mod new file mode 100644 index 0000000..2b5eafa --- /dev/null +++ b/go.mod @@ -0,0 +1,43 @@ +module artNet + +go 1.23.0 + +toolchain go1.23.8 + +require ( + github.com/coder/websocket v1.8.13 + github.com/gin-gonic/gin v1.10.0 + github.com/tatsushid/go-fastping v0.0.0-20160109021039-d7bb493dee3e + github.com/tecamino/tecamino-logger v0.1.1 +) + +require ( + github.com/bytedance/sonic v1.11.6 // indirect + github.com/bytedance/sonic/loader v0.1.1 // indirect + github.com/cloudwego/base64x v0.1.4 // indirect + github.com/cloudwego/iasm v0.2.0 // indirect + github.com/gabriel-vasile/mimetype v1.4.3 // indirect + github.com/gin-contrib/sse v0.1.0 // indirect + github.com/go-playground/locales v0.14.1 // indirect + github.com/go-playground/universal-translator v0.18.1 // indirect + github.com/go-playground/validator/v10 v10.20.0 // indirect + github.com/goccy/go-json v0.10.2 // indirect + github.com/json-iterator/go v1.1.12 // indirect + github.com/klauspost/cpuid/v2 v2.2.7 // indirect + github.com/leodido/go-urn v1.4.0 // indirect + github.com/mattn/go-isatty v0.0.20 // indirect + github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd // indirect + github.com/modern-go/reflect2 v1.0.2 // indirect + github.com/pelletier/go-toml/v2 v2.2.2 // indirect + github.com/twitchyliquid64/golang-asm v0.15.1 // indirect + github.com/ugorji/go/codec v1.2.12 // indirect + go.uber.org/multierr v1.10.0 // indirect + go.uber.org/zap v1.27.0 // indirect + golang.org/x/arch v0.8.0 // indirect + golang.org/x/crypto v0.23.0 // indirect + golang.org/x/net v0.25.0 // indirect + golang.org/x/sys v0.20.0 // indirect + golang.org/x/text v0.15.0 // indirect + google.golang.org/protobuf v1.34.1 // indirect + gopkg.in/yaml.v3 v3.0.1 // indirect +) diff --git a/go.sum b/go.sum new file mode 100644 index 0000000..e586213 --- /dev/null +++ b/go.sum @@ -0,0 +1,101 @@ +github.com/bytedance/sonic v1.11.6 h1:oUp34TzMlL+OY1OUWxHqsdkgC/Zfc85zGqw9siXjrc0= +github.com/bytedance/sonic v1.11.6/go.mod h1:LysEHSvpvDySVdC2f87zGWf6CIKJcAvqab1ZaiQtds4= +github.com/bytedance/sonic/loader v0.1.1 h1:c+e5Pt1k/cy5wMveRDyk2X4B9hF4g7an8N3zCYjJFNM= +github.com/bytedance/sonic/loader v0.1.1/go.mod h1:ncP89zfokxS5LZrJxl5z0UJcsk4M4yY2JpfqGeCtNLU= +github.com/cloudwego/base64x v0.1.4 h1:jwCgWpFanWmN8xoIUHa2rtzmkd5J2plF/dnLS6Xd/0Y= +github.com/cloudwego/base64x v0.1.4/go.mod h1:0zlkT4Wn5C6NdauXdJRhSKRlJvmclQ1hhJgA0rcu/8w= +github.com/cloudwego/iasm v0.2.0 h1:1KNIy1I1H9hNNFEEH3DVnI4UujN+1zjpuk6gwHLTssg= +github.com/cloudwego/iasm v0.2.0/go.mod h1:8rXZaNYT2n95jn+zTI1sDr+IgcD2GVs0nlbbQPiEFhY= +github.com/coder/websocket v1.8.13 h1:f3QZdXy7uGVz+4uCJy2nTZyM0yTBj8yANEHhqlXZ9FE= +github.com/coder/websocket v1.8.13/go.mod h1:LNVeNrXQZfe5qhS9ALED3uA+l5pPqvwXg3CKoDBB2gs= +github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= +github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c= +github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= +github.com/gabriel-vasile/mimetype v1.4.3 h1:in2uUcidCuFcDKtdcBxlR0rJ1+fsokWf+uqxgUFjbI0= +github.com/gabriel-vasile/mimetype v1.4.3/go.mod h1:d8uq/6HKRL6CGdk+aubisF/M5GcPfT7nKyLpA0lbSSk= +github.com/gin-contrib/sse v0.1.0 h1:Y/yl/+YNO8GZSjAhjMsSuLt29uWRFHdHYUb5lYOV9qE= +github.com/gin-contrib/sse v0.1.0/go.mod h1:RHrZQHXnP2xjPF+u1gW/2HnVO7nvIa9PG3Gm+fLHvGI= +github.com/gin-gonic/gin v1.10.0 h1:nTuyha1TYqgedzytsKYqna+DfLos46nTv2ygFy86HFU= +github.com/gin-gonic/gin v1.10.0/go.mod h1:4PMNQiOhvDRa013RKVbsiNwoyezlm2rm0uX/T7kzp5Y= +github.com/go-playground/assert/v2 v2.2.0 h1:JvknZsQTYeFEAhQwI4qEt9cyV5ONwRHC+lYKSsYSR8s= +github.com/go-playground/assert/v2 v2.2.0/go.mod h1:VDjEfimB/XKnb+ZQfWdccd7VUvScMdVu0Titje2rxJ4= +github.com/go-playground/locales v0.14.1 h1:EWaQ/wswjilfKLTECiXz7Rh+3BjFhfDFKv/oXslEjJA= +github.com/go-playground/locales v0.14.1/go.mod h1:hxrqLVvrK65+Rwrd5Fc6F2O76J/NuW9t0sjnWqG1slY= +github.com/go-playground/universal-translator v0.18.1 h1:Bcnm0ZwsGyWbCzImXv+pAJnYK9S473LQFuzCbDbfSFY= +github.com/go-playground/universal-translator v0.18.1/go.mod h1:xekY+UJKNuX9WP91TpwSH2VMlDf28Uj24BCp08ZFTUY= +github.com/go-playground/validator/v10 v10.20.0 h1:K9ISHbSaI0lyB2eWMPJo+kOS/FBExVwjEviJTixqxL8= +github.com/go-playground/validator/v10 v10.20.0/go.mod h1:dbuPbCMFw/DrkbEynArYaCwl3amGuJotoKCe95atGMM= +github.com/goccy/go-json v0.10.2 h1:CrxCmQqYDkv1z7lO7Wbh2HN93uovUHgrECaO5ZrCXAU= +github.com/goccy/go-json v0.10.2/go.mod h1:6MelG93GURQebXPDq3khkgXZkazVtN9CRI+MGFi0w8I= +github.com/google/go-cmp v0.5.5 h1:Khx7svrCpmxxtHBq5j2mp/xVjsi8hQMfNLvJFAlrGgU= +github.com/google/go-cmp v0.5.5/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE= +github.com/google/gofuzz v1.0.0/go.mod h1:dBl0BpW6vV/+mYPU4Po3pmUjxk6FQPldtuIdl/M65Eg= +github.com/json-iterator/go v1.1.12 h1:PV8peI4a0ysnczrg+LtxykD8LfKY9ML6u2jnxaEnrnM= +github.com/json-iterator/go v1.1.12/go.mod h1:e30LSqwooZae/UwlEbR2852Gd8hjQvJoHmT4TnhNGBo= +github.com/klauspost/cpuid/v2 v2.0.9/go.mod h1:FInQzS24/EEf25PyTYn52gqo7WaD8xa0213Md/qVLRg= +github.com/klauspost/cpuid/v2 v2.2.7 h1:ZWSB3igEs+d0qvnxR/ZBzXVmxkgt8DdzP6m9pfuVLDM= +github.com/klauspost/cpuid/v2 v2.2.7/go.mod h1:Lcz8mBdAVJIBVzewtcLocK12l3Y+JytZYpaMropDUws= +github.com/knz/go-libedit v1.10.1/go.mod h1:MZTVkCWyz0oBc7JOWP3wNAzd002ZbM/5hgShxwh4x8M= +github.com/leodido/go-urn v1.4.0 h1:WT9HwE9SGECu3lg4d/dIA+jxlljEa1/ffXKmRjqdmIQ= +github.com/leodido/go-urn v1.4.0/go.mod h1:bvxc+MVxLKB4z00jd1z+Dvzr47oO32F/QSNjSBOlFxI= +github.com/mattn/go-isatty v0.0.20 h1:xfD0iDuEKnDkl03q4limB+vH+GxLEtL/jb4xVJSWWEY= +github.com/mattn/go-isatty v0.0.20/go.mod h1:W+V8PltTTMOvKvAeJH7IuucS94S2C6jfK/D7dTCTo3Y= +github.com/modern-go/concurrent v0.0.0-20180228061459-e0a39a4cb421/go.mod h1:6dJC0mAP4ikYIbvyc7fijjWJddQyLn8Ig3JB5CqoB9Q= +github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd h1:TRLaZ9cD/w8PVh93nsPXa1VrQ6jlwL5oN8l14QlcNfg= +github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd/go.mod h1:6dJC0mAP4ikYIbvyc7fijjWJddQyLn8Ig3JB5CqoB9Q= +github.com/modern-go/reflect2 v1.0.2 h1:xBagoLtFs94CBntxluKeaWgTMpvLxC4ur3nMaC9Gz0M= +github.com/modern-go/reflect2 v1.0.2/go.mod h1:yWuevngMOJpCy52FWWMvUC8ws7m/LJsjYzDa0/r8luk= +github.com/pelletier/go-toml/v2 v2.2.2 h1:aYUidT7k73Pcl9nb2gScu7NSrKCSHIDE89b3+6Wq+LM= +github.com/pelletier/go-toml/v2 v2.2.2/go.mod h1:1t835xjRzz80PqgE6HHgN2JOsmgYu/h4qDAS4n929Rs= +github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM= +github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4= +github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME= +github.com/stretchr/objx v0.4.0/go.mod h1:YvHI0jy2hoMjB+UWwv71VJQ9isScKT/TqJzVSSt89Yw= +github.com/stretchr/objx v0.5.0/go.mod h1:Yh+to48EsGEfYuaHDzXPcE3xhTkx73EhmCGUpEOglKo= +github.com/stretchr/objx v0.5.2/go.mod h1:FRsXN1f5AsAjCGJKqEizvkpNtU+EGNCLh3NxZ/8L+MA= +github.com/stretchr/testify v1.3.0/go.mod h1:M5WIy9Dh21IEIfnGCwXGc5bZfKNJtfHm1UVUgZn+9EI= +github.com/stretchr/testify v1.7.0/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg= +github.com/stretchr/testify v1.7.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg= +github.com/stretchr/testify v1.8.0/go.mod h1:yNjHg4UonilssWZ8iaSj1OCr/vHnekPRkoO+kdMU+MU= +github.com/stretchr/testify v1.8.1/go.mod h1:w2LPCIKwWwSfY2zedu0+kehJoqGctiVI29o6fzry7u4= +github.com/stretchr/testify v1.8.4/go.mod h1:sz/lmYIOXD/1dqDmKjjqLyZ2RngseejIcXlSw2iwfAo= +github.com/stretchr/testify v1.9.0 h1:HtqpIVDClZ4nwg75+f6Lvsy/wHu+3BoSGCbBAcpTsTg= +github.com/stretchr/testify v1.9.0/go.mod h1:r2ic/lqez/lEtzL7wO/rwa5dbSLXVDPFyf8C91i36aY= +github.com/tatsushid/go-fastping v0.0.0-20160109021039-d7bb493dee3e h1:nt2877sKfojlHCTOBXbpWjBkuWKritFaGIfgQwbQUls= +github.com/tatsushid/go-fastping v0.0.0-20160109021039-d7bb493dee3e/go.mod h1:B4+Kq1u5FlULTjFSM707Q6e/cOHFv0z/6QRoxubDIQ8= +github.com/tecamino/tecamino-logger v0.1.1 h1:bK0SEQpbjui42OsnM6JCDThaGMBoqwVj/Op6ESqDwV4= +github.com/tecamino/tecamino-logger v0.1.1/go.mod h1:sGysmiFGIdr4vLJRAI+fJgsa7EoRRuxvRrKW7GnGQkw= +github.com/twitchyliquid64/golang-asm v0.15.1 h1:SU5vSMR7hnwNxj24w34ZyCi/FmDZTkS4MhqMhdFk5YI= +github.com/twitchyliquid64/golang-asm v0.15.1/go.mod h1:a1lVb/DtPvCB8fslRZhAngC2+aY1QWCk3Cedj/Gdt08= +github.com/ugorji/go/codec v1.2.12 h1:9LC83zGrHhuUA9l16C9AHXAqEV/2wBQ4nkvumAE65EE= +github.com/ugorji/go/codec v1.2.12/go.mod h1:UNopzCgEMSXjBc6AOMqYvWC1ktqTAfzJZUZgYf6w6lg= +go.uber.org/goleak v1.3.0 h1:2K3zAYmnTNqV73imy9J1T3WC+gmCePx2hEGkimedGto= +go.uber.org/goleak v1.3.0/go.mod h1:CoHD4mav9JJNrW/WLlf7HGZPjdw8EucARQHekz1X6bE= +go.uber.org/multierr v1.10.0 h1:S0h4aNzvfcFsC3dRF1jLoaov7oRaKqRGC/pUEJ2yvPQ= +go.uber.org/multierr v1.10.0/go.mod h1:20+QtiLqy0Nd6FdQB9TLXag12DsQkrbs3htMFfDN80Y= +go.uber.org/zap v1.27.0 h1:aJMhYGrd5QSmlpLMr2MftRKl7t8J8PTZPA732ud/XR8= +go.uber.org/zap v1.27.0/go.mod h1:GB2qFLM7cTU87MWRP2mPIjqfIDnGu+VIO4V/SdhGo2E= +golang.org/x/arch v0.0.0-20210923205945-b76863e36670/go.mod h1:5om86z9Hs0C8fWVUuoMHwpExlXzs5Tkyp9hOrfG7pp8= +golang.org/x/arch v0.8.0 h1:3wRIsP3pM4yUptoR96otTUOXI367OS0+c9eeRi9doIc= +golang.org/x/arch v0.8.0/go.mod h1:FEVrYAQjsQXMVJ1nsMoVVXPZg6p2JE2mx8psSWTDQys= +golang.org/x/crypto v0.23.0 h1:dIJU/v2J8Mdglj/8rJ6UUOM3Zc9zLZxVZwwxMooUSAI= +golang.org/x/crypto v0.23.0/go.mod h1:CKFgDieR+mRhux2Lsu27y0fO304Db0wZe70UKqHu0v8= +golang.org/x/net v0.25.0 h1:d/OCCoBEUq33pjydKrGQhw7IlUPI2Oylr+8qLx49kac= +golang.org/x/net v0.25.0/go.mod h1:JkAGAh7GEvH74S6FOH42FLoXpXbE/aqXSrIQjXgsiwM= +golang.org/x/sys v0.5.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= +golang.org/x/sys v0.6.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= +golang.org/x/sys v0.20.0 h1:Od9JTbYCk261bKm4M/mw7AklTlFYIa0bIp9BgSm1S8Y= +golang.org/x/sys v0.20.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA= +golang.org/x/text v0.15.0 h1:h1V/4gjBv8v9cjcR6+AR5+/cIYK5N/WAgiv4xlsEtAk= +golang.org/x/text v0.15.0/go.mod h1:18ZOQIKpY8NJVqYksKHtTdi31H5itFRjB5/qKTNYzSU= +golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543 h1:E7g+9GITq07hpfrRu66IVDexMakfv52eLZ2CXBWiKr4= +golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0= +google.golang.org/protobuf v1.34.1 h1:9ddQBjfCyZPOHPUiPxpYESBLc+T8P3E+Vo4IbKZgFWg= +google.golang.org/protobuf v1.34.1/go.mod h1:c6P6GXX6sHbq/GpV6MGZEdwhWPcYBgnhAHhKbcUYpos= +gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405 h1:yhCVgyC4o1eVCa2tZl7eS0r+SDo693bJlVdllGtEeKM= +gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0= +gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM= +gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA= +gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM= +nullprogram.com/x/optparse v1.0.0/go.mod h1:KdyPE+Igbe0jQUrVfMqDMeJQIJZEuyV7pjYmp6pbG50= +rsc.io/pdf v0.1.1/go.mod h1:n8OzWcQ6Sp37PL01nO98y4iUCRdTGarVfzxY20ICaU4= diff --git a/main.go b/main.go new file mode 100644 index 0000000..885b614 --- /dev/null +++ b/main.go @@ -0,0 +1,73 @@ +package main + +import ( + "artNet/driver" + "artNet/server" + "fmt" + "math" + "time" +) + +func main() { + + bus := driver.NewDriver().NewInterface("2.0.0.1", 0) + d, _ := bus.AddDevice(47, 9) + + var i uint8 + + s := server.NewServer() + + s.ServeHttp(8120) + + for { + if i == math.MaxUint8 { + i = 0 + } + err := d.SetChannelValue(0, i) + if err != nil { + fmt.Println(err) + } + err = d.SetChannelValue(1, i) + if err != nil { + fmt.Println(err) + } + err = d.SetChannelValue(2, i) + if err != nil { + fmt.Println(err) + } + err = d.SetChannelValue(3, i) + if err != nil { + fmt.Println(err) + } + err = d.SetChannelValue(4, i) + if err != nil { + fmt.Println(err) + } + err = d.SetChannelValue(5, i) + if err != nil { + fmt.Println(err) + } + err = d.SetChannelValue(6, i) + if err != nil { + fmt.Println(err) + } + err = d.SetChannelValue(7, i) + if err != nil { + fmt.Println(err) + } + err = d.SetChannelValue(8, i) + if err != nil { + fmt.Println(err) + } + + if err := bus.SendData(); err != nil { + fmt.Println(12, err) + panic(err) + } + time.Sleep(100 * time.Microsecond) + i += 1 + i = 0 + + } + +} diff --git a/models/bus.go b/models/bus.go new file mode 100644 index 0000000..0a7c77e --- /dev/null +++ b/models/bus.go @@ -0,0 +1,143 @@ +package models + +import ( + "fmt" + "net" + "time" + + "github.com/tatsushid/go-fastping" +) + +// Art-Net constants +const ( + artPort = 6454 +) + +// Art-Net Interface +type Bus struct { + ip string `yaml:"ip"` + port int `yaml:"port"` + Devices []*Device `yaml:"devices"` + Data *DMX +} + +// adds new Art-Net interface to driver port 0 = 6454 (default art-net) +func NewBus(ip string, port int) *Bus { + if port == 0 { + port = artPort + } + + i := Bus{ + ip: ip, + port: port, + Data: NewDMXUniverse(), + } + return &i +} + +// adds new dmx device to interface +func (i *Bus) AddDevice(address uint, channels uint) (*Device, error) { + d := NewDevice(address, channels, i.Data) + i.Devices = append(i.Devices, d) + return d, nil +} + +// start polling dmx data in milliseconds 0 = aprox. 44Hertz +func (i *Bus) Poll(interval time.Duration) error { + if interval == 0 { + interval = 23 + } + + // Send packet over UDP + conn, err := net.DialUDP("udp", nil, &net.UDPAddr{ + IP: net.ParseIP(i.ip), + Port: i.port, + }) + + if err != nil { + return err + } + defer conn.Close() + + var errCount int + for { + go func() { + for { + if reached, _ := isUDPReachable(i.ip); !reached { + if errCount > 20 { + break + } else { + errCount += 1 + return + } + } else { + errCount = 0 + break + } + } + }() + + _, err = conn.Write(NewArtNetPackage(i.Data)) + if err != nil { + return err + } + + if errCount > 5 { + return fmt.Errorf("device not reachable") + } + time.Sleep(23 * time.Millisecond) + } +} + +// start polling dmx data in milliseconds 0 = aprox. 44Hertz +func (i *Bus) SendData() error { + // Send packet over UDP + conn, err := net.DialUDP("udp", nil, &net.UDPAddr{ + IP: net.ParseIP(i.ip), + Port: i.port, + }) + + if err != nil { + return err + } + defer conn.Close() + + errChan := make(chan error) + go func() { + if reached, _ := isUDPReachable(i.ip); !reached { + errChan <- fmt.Errorf("device not reachable") + return + } + errChan <- nil + }() + + err = <-errChan + if err != nil { + return err + } + + _, err = conn.Write(NewArtNetPackage(i.Data)) + + return err +} + +const ( + protocolICMP = 1 +) + +func isUDPReachable(ip string) (recieved bool, err error) { + p := fastping.NewPinger() + ra, err := net.ResolveIPAddr("ip4:icmp", ip) + if err != nil { + return + } + p.AddIPAddr(ra) + p.OnRecv = func(addr *net.IPAddr, rtt time.Duration) { + recieved = true + return + } + p.OnIdle = func() {} + + err = p.Run() + return +} diff --git a/models/device.go b/models/device.go new file mode 100644 index 0000000..b86c2ac --- /dev/null +++ b/models/device.go @@ -0,0 +1,25 @@ +package models + +import "fmt" + +type Device struct { + startAddress uint + length uint + channels *DMX +} + +func NewDevice(startAddress uint, channels uint, dmx *DMX) *Device { + return &Device{ + startAddress: startAddress, + length: channels, + channels: dmx, + } +} + +func (d *Device) SetChannelValue(channel uint, value uint8) error { + if d.length == channel { + return fmt.Errorf("channel out of range %d", channel) + } + d.channels.SetValue(d.startAddress+channel, value) + return nil +} diff --git a/models/dmx.go b/models/dmx.go new file mode 100644 index 0000000..d5a7ae3 --- /dev/null +++ b/models/dmx.go @@ -0,0 +1,12 @@ +package models + +type DMX []byte + +func NewDMXUniverse() *DMX { + dmx := make(DMX, 512) + return &dmx +} + +func (d *DMX) SetValue(channel uint, value uint8) { + (*d)[channel] = value +} diff --git a/models/get.go b/models/get.go new file mode 100644 index 0000000..50fbd5f --- /dev/null +++ b/models/get.go @@ -0,0 +1,5 @@ +package models + +type Get struct { + Bus uint `json:"bus"` +} diff --git a/models/jsonData.go b/models/jsonData.go new file mode 100644 index 0000000..6457c35 --- /dev/null +++ b/models/jsonData.go @@ -0,0 +1,22 @@ +package models + +type JsonData struct { + Set *[]Set `json:"set,omitempty"` +} + +func NewRequest() *JsonData { + return &JsonData{} + +} + +func (r *JsonData) AddSet(bus, address uint, value uint8) { + if r.Set == nil { + r.Set = &[]Set{} + } + + *r.Set = append(*r.Set, Set{ + Bus: bus, + Address: address, + Value: value, + }) +} diff --git a/models/package.go b/models/package.go new file mode 100644 index 0000000..151d012 --- /dev/null +++ b/models/package.go @@ -0,0 +1,29 @@ +package models + +import ( + "bytes" + "encoding/binary" +) + +// Art-Net constants +const ( + opCode = 0x5000 // OpDmx (low byte first) + protocolID = "Art-Net\x00" +) + +type Package []byte + +func NewArtNetPackage(data *DMX) Package { + // Build ArtDMX packet + packet := &bytes.Buffer{} + packet.WriteString(protocolID) // Art-Net ID + binary.Write(packet, binary.LittleEndian, uint16(opCode)) // OpCode (OpDmx) + packet.WriteByte(0x00) // Protocol Version High + packet.WriteByte(14) // Protocol Version Low (14 for Art-Net 4) + packet.WriteByte(0x00) // Sequence + packet.WriteByte(0x00) // Physical + binary.Write(packet, binary.BigEndian, uint16(0)) // Universe (net:subuni, usually 0) + binary.Write(packet, binary.BigEndian, uint16(len(*data))) // Length + packet.Write(*data) + return packet.Bytes() +} diff --git a/models/set.go b/models/set.go new file mode 100644 index 0000000..4d5b5da --- /dev/null +++ b/models/set.go @@ -0,0 +1,7 @@ +package models + +type Set struct { + Bus uint `json:"bus"` + Address uint `json:"address"` + Value uint8 `json:"value"` +} diff --git a/server/allBuses.go b/server/allBuses.go new file mode 100644 index 0000000..bcd94a3 --- /dev/null +++ b/server/allBuses.go @@ -0,0 +1,18 @@ +package server + +import ( + "github.com/gin-gonic/gin" +) + +func (s *Server) AllBuses(c *gin.Context) { + var data any + if s.Driver.Bus == nil { + data = "no buses avaiable" + } else { + data = s.Driver.Bus + } + + c.JSON(200, gin.H{ + "buses": data, + }) +} diff --git a/server/jsonRequest.go b/server/jsonRequest.go new file mode 100644 index 0000000..1160d3f --- /dev/null +++ b/server/jsonRequest.go @@ -0,0 +1,25 @@ +package server + +import ( + "net/http" + + "artNet/models" + + "github.com/gin-gonic/gin" +) + +func (s *Server) JsonRequest(c *gin.Context) { + var payload models.JsonData + + if err := c.BindJSON(&payload); err != nil { + + c.JSON(http.StatusBadRequest, gin.H{"error": err.Error()}) + return + } + + c.JSON(200, gin.H{ + "name": payload, + }) + return + +} diff --git a/server/models/response.go b/server/models/response.go new file mode 100644 index 0000000..84cef66 --- /dev/null +++ b/server/models/response.go @@ -0,0 +1,7 @@ +package models + +type Response struct { + StatusCode int `json:"statusCode"` + Message string `json:"message,omitempty"` + Data string `json:"dat,omitempty"` +} diff --git a/server/models/subscribers.go b/server/models/subscribers.go new file mode 100644 index 0000000..fd4a6fb --- /dev/null +++ b/server/models/subscribers.go @@ -0,0 +1,26 @@ +package models + +import "github.com/coder/websocket" + +type Subscribers map[*websocket.Conn]*bool + +func InitSubsrcibers() Subscribers { + return make(Subscribers) +} + +func (s *Subscribers) Connect(conn *websocket.Conn) { + b := true + (*s)[conn] = &b +} + +func (s *Subscribers) DeleteSubsrcibers(conn *websocket.Conn) { + delete(*s, conn) +} + +func (s *Subscribers) GetPointer(conn *websocket.Conn) *bool { + return (*s)[conn] +} + +func (s *Subscribers) Disconnect(conn *websocket.Conn) { + *(*s)[conn] = false +} diff --git a/server/routes.go b/server/routes.go new file mode 100644 index 0000000..a3a822f --- /dev/null +++ b/server/routes.go @@ -0,0 +1,16 @@ +package server + +import ( + "github.com/gin-gonic/gin" +) + +func (s *Server) AddRoutes() { + + s.engine.GET("/ws", s.handleWebSocket) + + s.engine.GET("/allBuses", s.AllBuses) + + s.engine.GET("/", func(c *gin.Context) { + c.String(200, "WebSocket Broadcast Server is running!") + }) +} diff --git a/server/server.go b/server/server.go new file mode 100644 index 0000000..18453d4 --- /dev/null +++ b/server/server.go @@ -0,0 +1,48 @@ +package server + +import ( + "fmt" + "sync" + + "artNet/cert" + "artNet/driver" + serverModels "artNet/server/models" + + "github.com/gin-gonic/gin" + "github.com/tecamino/tecamino-logger/logging" +) + +type Server struct { + engine *gin.Engine + sync.RWMutex + Subscribers serverModels.Subscribers + Logger *logging.Logger + Driver *driver.ArtNetDriver +} + +func NewServer() *Server { + s := Server{ + engine: gin.Default(), + Subscribers: serverModels.InitSubsrcibers(), + } + s.AddRoutes() + + s.Driver = driver.NewDriver() + + return &s +} + +func (s *Server) ServeHttp(port uint) error { + if err := s.engine.Run(fmt.Sprintf(":%d", port)); err != nil { + return fmt.Errorf("failed to run http server: %v", err) + } + return nil +} + +func (s *Server) ServeHttps(port uint, cert cert.Cert) error { + cert.GenerateSelfSignedCert() + if err := s.engine.RunTLS(fmt.Sprintf(":%d", port), cert.CertFile, cert.KeyFile); err != nil { + return fmt.Errorf("failed to run https server: %v", err) + } + return nil +} diff --git a/server/set.go b/server/set.go new file mode 100644 index 0000000..8e4e78a --- /dev/null +++ b/server/set.go @@ -0,0 +1,13 @@ +package server + +import ( + "artNet/models" + "fmt" +) + +func (s *Server) Set(get models.Get) error { + if len(s.Driver.Bus) <= int(get.Bus) { + return fmt.Errorf("no bus number '%d' found", get.Bus) + } + return nil +} diff --git a/server/webSocket.go b/server/webSocket.go new file mode 100644 index 0000000..17eca09 --- /dev/null +++ b/server/webSocket.go @@ -0,0 +1,65 @@ +package server + +import ( + "context" + "fmt" + "log" + "time" + + "artNet/models" + + "github.com/coder/websocket" + "github.com/coder/websocket/wsjson" + "github.com/gin-gonic/gin" +) + +const ( + OnCreate = "onCreate" + OnChange = "onChange" + OnDelete = "onDelete" +) + +func (s *Server) handleWebSocket(c *gin.Context) { + conn, err := websocket.Accept(c.Writer, c.Request, &websocket.AcceptOptions{ + OriginPatterns: []string{"*"}, + }) + if err != nil { + log.Println("Upgrade error:", err) + return + } + + defer conn.Close(websocket.StatusInternalError, "Internal error") + + ctx, cancel := context.WithTimeout(c.Request.Context(), 10*time.Minute) + defer cancel() + + s.Subscribers.Connect(conn) + + //Read loop + for { + var request models.JsonData + err := wsjson.Read(ctx, conn, &request) + if err != nil { + fmt.Println(s.Subscribers[conn]) + log.Println("WebSocket read error:", err) + s.Subscribers.Disconnect(conn) + fmt.Println(s.Subscribers[conn]) + break + } + + // Set + // if request.Set != nil { + // for _, set := range *request.Set { + // err = s.Unsubscribe(unsub, conn) + // if err != nil { + // fmt.Println(err) + // break + // } + // } + // } + + if err != nil { + break + } + } +}