-
Quick start:
-Run app using Docker: +Run app using Docker Compose:user@user-laptop:~$ cd oktopus/deploy/compose user@user-laptop:~/oktopus/deploy/compose$ COMPOSE_PROFILES=nats,controller,mqtt,stomp,ws,adapter,frontend,portainer docker compose up -d
+Oktopus deployment in Kubernetes still is in beta phase: Instructions for Kubernetes deployment UI will open at port 3000:+
-
Device test agent (obuspa):
diff --git a/backend/services/acs/.env b/backend/services/acs/.env new file mode 100644 index 0000000..e69de29 diff --git a/backend/services/acs/.gitignore b/backend/services/acs/.gitignore new file mode 100644 index 0000000..e45d6e3 --- /dev/null +++ b/backend/services/acs/.gitignore @@ -0,0 +1 @@ +*.local \ No newline at end of file diff --git a/backend/services/acs/README.md b/backend/services/acs/README.md new file mode 100644 index 0000000..d5cb5d6 --- /dev/null +++ b/backend/services/acs/README.md @@ -0,0 +1,97 @@ +# Moses ACS [](https://travis-ci.org/lucacervasio/mosesacs) + +An ACS in Go for provisioning CPEs, suitable for test purposes or production deployment. + +## Getting started + +Install the package: + + go get oktopUSP/backend/services/acs + +Run daemon: + + mosesacs -d + +Connect to it and get a cli: + + mosesacs + +Congratulations, you've connected to the daemon via websocket. Now you can issue commands via CLI or browse the embedded webserver at http://localhost:9292/www + +## Compatibility on ARM + +Moses is built on purpose only with dependencies in pure GO. So it runs on ARM processors with no issues. We tested it on QNAP devices and Raspberry for remote control. + +## CLI commands + +### 1. `list`: list CPEs + + example: + +``` + moses@localhost:9292/> list + cpe list + CPE A54FD with OUI 006754 +``` + +### 2. `readMib SERIAL LEAF/SUBTREE`: read a specific leaf or a subtree + + example: + +``` + moses@localhost:9292/> readMib A54FD Device. + Received an Inform from [::1]:58582 (3191 bytes) with SerialNumber A54FD and EventCodes 6 CONNECTION REQUEST + InternetGatewayDevice.Time.NTPServer1 : pool.ntp.org + InternetGatewayDevice.Time.CurrentLocalTime : 2014-07-11T09:08:25 + InternetGatewayDevice.Time.LocalTimeZone : +00:00 + InternetGatewayDevice.Time.LocalTimeZoneName : Greenwich Mean Time : Dublin + InternetGatewayDevice.Time.DaylightSavingsUsed : 0 +``` + +### 3. `writeMib SERIAL LEAF VALUE`: issue a SetParameterValues and write a value into a leaf + + example: + +``` + moses@localhost:9292/> writeMib A54FD InternetGatewayDevice.Time.Enable false + Received an Inform from [::1]:58582 (3191 bytes) with SerialNumber A54FD and EventCodes 6 CONNECTION REQUEST +``` + +### 4. `GetParameterNames SERIAL LEAF/SUBTREE`: issue a GetParameterNames and get all leaves/objects at first level + + example: + +``` +moses@localhost:9292/> GetParameterNames A54FD InternetGatewayDevice. +Received an Inform from [::1]:55385 (3119 bytes) with SerialNumber A54FD and EventCodes 6 CONNECTION REQUEST +InternetGatewayDevice.LANDeviceNumberOfEntries : 0 +InternetGatewayDevice.WANDeviceNumberOfEntries : 0 +InternetGatewayDevice.DeviceInfo. : 0 +InternetGatewayDevice.ManagementServer. : 0 +InternetGatewayDevice.Time. : 0 +InternetGatewayDevice.Layer3Forwarding. : 0 +InternetGatewayDevice.LANDevice. : 0 +InternetGatewayDevice.WANDevice. : 0 +InternetGatewayDevice.X_00507F_InternetAcc. : 0 +InternetGatewayDevice.X_00507F_LAN. : 0 +InternetGatewayDevice.X_00507F_NAT. : 0 +InternetGatewayDevice.X_00507F_VLAN. : 0 +InternetGatewayDevice.X_00507F_Firewall. : 0 +InternetGatewayDevice.X_00507F_Applications. : 0 +InternetGatewayDevice.X_00507F_System. : 0 +InternetGatewayDevice.X_00507F_Status. : 0 +InternetGatewayDevice.X_00507F_Diagnostics. : 0 +``` + + + + +## Services exposed + +Moses exposes three services: + + - http://localhost:9292/acs is the endpoint for the CPEs to connect + - http://localhost:9292/www is the embedded webserver to control your CPEs + - ws://localhost:9292/ws is the websocket endpoint used by the cli to issue commands. Read about the API specification if you want to build a custom frontend which interacts with mosesacs daemon. + + diff --git a/backend/services/acs/build/Dockerfile b/backend/services/acs/build/Dockerfile new file mode 100644 index 0000000..0e8119a --- /dev/null +++ b/backend/services/acs/build/Dockerfile @@ -0,0 +1,8 @@ +FROM golang:1.22.2@sha256:450e3822c7a135e1463cd83e51c8e2eb03b86a02113c89424e6f0f8344bb4168 as builder +WORKDIR /app +COPY ../ . +RUN CGO_ENABLED=0 GOOS=linux go build -o acs cmd/acs/main.go + +FROM alpine:3.14@sha256:0f2d5c38dd7a4f4f733e688e3a6733cb5ab1ac6e3cb4603a5dd564e5bfb80eed +COPY --from=builder /app/acs / +ENTRYPOINT ["/acs"] \ No newline at end of file diff --git a/backend/services/acs/build/Makefile b/backend/services/acs/build/Makefile new file mode 100644 index 0000000..10c7fd2 --- /dev/null +++ b/backend/services/acs/build/Makefile @@ -0,0 +1,61 @@ +.PHONY: help build push start stop release remove delete run logs bash + +DOCKER_USER ?= oktopusp +DOCKER_APP ?= acs +DOCKER_TAG ?= $(shell git log --format="%h" -n 1) +CONTAINER_SHELL ?= /bin/sh + +.DEFAULT_GOAL := help + +help: + @echo "Makefile arguments:" + @echo "" + @echo "DOCKER_USER - docker user to build image" + @echo "DOCKER_APP - docker image name" + @echo "DOCKER_TAG - docker image tag" + @echo "CONTAINER_SHELL - container shell e.g:'/bin/bash'" + @echo "" + @echo "Makefile commands:" + @echo "" + @echo "build - docker image build" + @echo "push - push docker iamge to registry" + @echo "run - create and start docker container with the image" + @echo "start - start existent docker container with the image" + @echo "stop - stop docker container running the image" + @echo "remove - remove docker container running the image" + @echo "delete - delete docker image" + @echo "logs - show logs of docker container" + @echo "bash - access container shell" + @echo "release - tag image as latest and push to registry" + +build: + @docker build -t ${DOCKER_USER}/${DOCKER_APP}:${DOCKER_TAG} -f Dockerfile ../ + +run: + @docker run -d --name ${DOCKER_USER}-${DOCKER_APP} ${DOCKER_USER}/${DOCKER_APP}:${DOCKER_TAG} + +stop: + @docker stop ${DOCKER_USER}-${DOCKER_APP} + +remove: stop + @docker rm ${DOCKER_USER}-${DOCKER_APP} + +delete: + @docker rmi ${DOCKER_USER}/${DOCKER_APP}:${DOCKER_TAG} + +start: + @docker start ${DOCKER_USER}-${DOCKER_APP} + +push: + @docker push ${DOCKER_USER}/${DOCKER_APP}:${DOCKER_TAG} + +logs: + @docker logs -f ${DOCKER_USER}-${DOCKER_APP} + +bash: + @docker exec -it ${DOCKER_USER}-${DOCKER_APP} ${CONTAINER_SHELL} + +release: build + @docker push ${DOCKER_USER}/${DOCKER_APP}:${DOCKER_TAG} + @docker tag ${DOCKER_USER}/${DOCKER_APP}:${DOCKER_TAG} ${DOCKER_USER}/${DOCKER_APP}:latest + @docker push ${DOCKER_USER}/${DOCKER_APP}:latest \ No newline at end of file diff --git a/backend/services/acs/cmd/acs/main.go b/backend/services/acs/cmd/acs/main.go new file mode 100644 index 0000000..53d9379 --- /dev/null +++ b/backend/services/acs/cmd/acs/main.go @@ -0,0 +1,27 @@ +package main + +import ( + "oktopUSP/backend/services/acs/internal/bridge" + "oktopUSP/backend/services/acs/internal/config" + "oktopUSP/backend/services/acs/internal/nats" + "oktopUSP/backend/services/acs/internal/server" + "oktopUSP/backend/services/acs/internal/server/handler" +) + +func main() { + + c := config.NewConfig() + + natsActions := nats.StartNatsClient(c.Nats) + + h := handler.NewHandler(natsActions.Publish, natsActions.Subscribe) + + b := bridge.NewBridge( + natsActions.Publish, + natsActions.Subscribe, + h, + ) + b.StartBridge() + + server.Run(c.Acs, natsActions, h) +} diff --git a/backend/services/acs/go.mod b/backend/services/acs/go.mod new file mode 100644 index 0000000..f57be7f --- /dev/null +++ b/backend/services/acs/go.mod @@ -0,0 +1,20 @@ +module oktopUSP/backend/services/acs + +go 1.22.2 + +require ( + github.com/google/uuid v1.6.0 + github.com/joho/godotenv v1.5.1 + github.com/nats-io/nats.go v1.34.1 + github.com/oleiade/lane v1.0.1 + golang.org/x/net v0.24.0 +) + +require ( + github.com/klauspost/compress v1.17.2 // indirect + github.com/nats-io/nkeys v0.4.7 // indirect + github.com/nats-io/nuid v1.0.1 // indirect + golang.org/x/crypto v0.22.0 // indirect + golang.org/x/sys v0.19.0 // indirect + golang.org/x/text v0.14.0 // indirect +) diff --git a/backend/services/acs/go.sum b/backend/services/acs/go.sum new file mode 100644 index 0000000..c223b41 --- /dev/null +++ b/backend/services/acs/go.sum @@ -0,0 +1,22 @@ +github.com/google/uuid v1.6.0 h1:NIvaJDMOsjHA8n1jAhLSgzrAzy1Hgr+hNrb57e+94F0= +github.com/google/uuid v1.6.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo= +github.com/joho/godotenv v1.5.1 h1:7eLL/+HRGLY0ldzfGMeQkb7vMd0as4CfYvUVzLqw0N0= +github.com/joho/godotenv v1.5.1/go.mod h1:f4LDr5Voq0i2e/R5DDNOoa2zzDfwtkZa6DnEwAbqwq4= +github.com/klauspost/compress v1.17.2 h1:RlWWUY/Dr4fL8qk9YG7DTZ7PDgME2V4csBXA8L/ixi4= +github.com/klauspost/compress v1.17.2/go.mod h1:ntbaceVETuRiXiv4DpjP66DpAtAGkEQskQzEyD//IeE= +github.com/nats-io/nats.go v1.34.1 h1:syWey5xaNHZgicYBemv0nohUPPmaLteiBEUT6Q5+F/4= +github.com/nats-io/nats.go v1.34.1/go.mod h1:Ubdu4Nh9exXdSz0RVWRFBbRfrbSxOYd26oF0wkWclB8= +github.com/nats-io/nkeys v0.4.7 h1:RwNJbbIdYCoClSDNY7QVKZlyb/wfT6ugvFCiKy6vDvI= +github.com/nats-io/nkeys v0.4.7/go.mod h1:kqXRgRDPlGy7nGaEDMuYzmiJCIAAWDK0IMBtDmGD0nc= +github.com/nats-io/nuid v1.0.1 h1:5iA8DT8V7q8WK2EScv2padNa/rTESc1KdnPw4TC2paw= +github.com/nats-io/nuid v1.0.1/go.mod h1:19wcPz3Ph3q0Jbyiqsd0kePYG7A95tJPxeL+1OSON2c= +github.com/oleiade/lane v1.0.1 h1:hXofkn7GEOubzTwNpeL9MaNy8WxolCYb9cInAIeqShU= +github.com/oleiade/lane v1.0.1/go.mod h1:IyTkraa4maLfjq/GmHR+Dxb4kCMtEGeb+qmhlrQ5Mk4= +golang.org/x/crypto v0.22.0 h1:g1v0xeRhjcugydODzvb3mEM9SQ0HGp9s/nh3COQ/C30= +golang.org/x/crypto v0.22.0/go.mod h1:vr6Su+7cTlO45qkww3VDJlzDn0ctJvRgYbC2NvXHt+M= +golang.org/x/net v0.24.0 h1:1PcaxkF854Fu3+lvBIx5SYn9wRlBzzcnHZSiaFFAb0w= +golang.org/x/net v0.24.0/go.mod h1:2Q7sJY5mzlzWjKtYUEXSlBWCdyaioyXzRB2RtU8KVE8= +golang.org/x/sys v0.19.0 h1:q5f1RH2jigJ1MoAWp2KTp3gm5zAGFUTarQZ5U386+4o= +golang.org/x/sys v0.19.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA= +golang.org/x/text v0.14.0 h1:ScX5w1eTa3QqT8oi6+ziP7dTV1S2+ALU0bI+0zXKWiQ= +golang.org/x/text v0.14.0/go.mod h1:18ZOQIKpY8NJVqYksKHtTdi31H5itFRjB5/qKTNYzSU= diff --git a/backend/services/acs/internal/auth/auth.go b/backend/services/acs/internal/auth/auth.go new file mode 100644 index 0000000..3b20e03 --- /dev/null +++ b/backend/services/acs/internal/auth/auth.go @@ -0,0 +1,112 @@ +package auth + +import ( + "crypto/md5" + "crypto/rand" + "encoding/base64" + "fmt" + "net/http" + "net/url" + "strings" +) + +type myjar struct { + jar map[string][]*http.Cookie +} + +func (p *myjar) SetCookies(u *url.URL, cookies []*http.Cookie) { + p.jar[u.Host] = cookies +} + +func (p *myjar) Cookies(u *url.URL) []*http.Cookie { + return p.jar[u.Host] +} + +func Auth(username string, password string, uri string) (bool, error) { + client := &http.Client{} + jar := &myjar{} + jar.jar = make(map[string][]*http.Cookie) + client.Jar = jar + var req *http.Request + var resp *http.Response + var err error + req, err = http.NewRequest("GET", uri, nil) + resp, err = client.Do(req) + if err != nil { + return false, err + } + // if resp.StatusCode == 401 { + // var authorization map[string]string = DigestAuthParams(resp) + // realmHeader := authorization["realm"] + // qopHeader := authorization["qop"] + // nonceHeader := authorization["nonce"] + // opaqueHeader := authorization["opaque"] + // realm := realmHeader + // // A1 + // h := md5.New() + // A1 := fmt.Sprintf("%s:%s:%s", username, realm, password) + // io.WriteString(h, A1) + // HA1 := fmt.Sprintf("%x", h.Sum(nil)) + + // // A2 + // h = md5.New() + // A2 := fmt.Sprintf("GET:%s", "/auth") + // io.WriteString(h, A2) + // HA2 := fmt.Sprintf("%x", h.Sum(nil)) + + // // response + // cnonce := RandomKey() + // response := H(strings.Join([]string{HA1, nonceHeader, "00000001", cnonce, qopHeader, HA2}, ":")) + + // // now make header + // AuthHeader := fmt.Sprintf(`Digest username="%s", realm="%s", nonce="%s", uri="%s", cnonce="%s", nc=00000001, qop=%s, response="%s", opaque="%s", algorithm=MD5`, + // username, realmHeader, nonceHeader, "/auth", cnonce, qopHeader, response, opaqueHeader) + // req.Header.Set("Authorization", AuthHeader) + // resp, err = client.Do(req) + // } else { + // return false, fmt.Errorf("response status code should have been 401, it was %v", resp.StatusCode) + // } + return resp.StatusCode == 200, err +} + +/* +Parse Authorization header from the http.Request. Returns a map of +auth parameters or nil if the header is not a valid parsable Digest +auth header. +*/ +func DigestAuthParams(r *http.Response) map[string]string { + s := strings.SplitN(r.Header.Get("Www-Authenticate"), " ", 2) + if len(s) != 2 || s[0] != "Digest" { + return nil + } + + result := map[string]string{} + for _, kv := range strings.Split(s[1], ",") { + parts := strings.SplitN(kv, "=", 2) + if len(parts) != 2 { + continue + } + result[strings.Trim(parts[0], "\" ")] = strings.Trim(parts[1], "\" ") + } + return result +} +func RandomKey() string { + k := make([]byte, 12) + for bytes := 0; bytes < len(k); { + n, err := rand.Read(k[bytes:]) + if err != nil { + panic("rand.Read() failed") + } + bytes += n + } + return base64.StdEncoding.EncodeToString(k) +} + +/* +H function for MD5 algorithm (returns a lower-case hex MD5 digest) +*/ +func H(data string) string { + digest := md5.New() + digest.Write([]byte(data)) + return fmt.Sprintf("%x", digest.Sum(nil)) +} diff --git a/backend/services/acs/internal/bridge/bridge.go b/backend/services/acs/internal/bridge/bridge.go new file mode 100644 index 0000000..9eda542 --- /dev/null +++ b/backend/services/acs/internal/bridge/bridge.go @@ -0,0 +1,112 @@ +package bridge + +import ( + "encoding/json" + "log" + "net/http" + "oktopUSP/backend/services/acs/internal/server/handler" + "strings" + "time" + + "github.com/google/uuid" + "github.com/nats-io/nats.go" +) + +type Bridge struct { + pub func(string, []byte) error + sub func(string, func(*nats.Msg)) error + cpes map[string]handler.CPE + h *handler.Handler +} + +type msgAnswer struct { + Code int + Msg any +} + +const DEVICE_ANSWER_TIMEOUT = 5 * time.Second + +func NewBridge( + pub func(string, []byte) error, + sub func(string, func(*nats.Msg)) error, + h *handler.Handler, +) *Bridge { + return &Bridge{ + pub: pub, + sub: sub, + cpes: h.Cpes, + h: h, + } +} + +func (b *Bridge) StartBridge() { + b.sub(handler.NATS_CWMP_ADAPTER_SUBJECT_PREFIX+"*.api", func(msg *nats.Msg) { + log.Printf("Received message: %s", string(msg.Data)) + log.Printf("Subject: %s", msg.Subject) + log.Printf("Reply: %s", msg.Reply) + + device := getDeviceFromSubject(msg.Subject) + cpe, ok := b.cpes[device] + if !ok { + log.Printf("Device %s not found", device) + respondMsg(msg.Respond, http.StatusNotFound, "Device not found") + return + } + if cpe.Queue.Size() > 0 { + log.Printf("Device %s is busy", device) + respondMsg(msg.Respond, http.StatusConflict, "Device is busy") + return + } + + deviceAnswer := make(chan []byte) + defer close(deviceAnswer) + + cpe.Queue.Enqueue(handler.Request{ //TODO: pass user and password too + Id: uuid.NewString(), + CwmpMsg: msg.Data, + Callback: deviceAnswer, + }) + + err := b.h.ConnectionRequest(cpe) + if err != nil { + log.Println("Failed to do connection request", err) + cpe.Queue.Dequeue() + respondMsg(msg.Respond, http.StatusBadRequest, err.Error()) + return + } + + //req := cpe.Queue.Dequeue().(handler.Request) + //cpe.Waiting = &req + + select { + case response := <-deviceAnswer: + log.Println("Received response from device: ", string(response)) + respondMsg(msg.Respond, http.StatusOK, response) + case <-time.After(DEVICE_ANSWER_TIMEOUT): + log.Println("Device response timed out") + respondMsg(msg.Respond, http.StatusRequestTimeout, "Request timeout") + } + }) +} + +func respondMsg(respond func(data []byte) error, code int, msgData any) { + + msg, err := json.Marshal(msgAnswer{ + Code: code, + Msg: msgData, + }) + if err != nil { + log.Printf("Failed to marshal message: %q", err) + respond([]byte(err.Error())) + return + } + + respond(msg) + //log.Println("Responded with message: ", string(msg)) +} + +func getDeviceFromSubject(subject string) string { + paths := strings.Split(subject, ".") + device := paths[len(paths)-2] + return device +} diff --git a/backend/services/acs/internal/config/config.go b/backend/services/acs/internal/config/config.go new file mode 100644 index 0000000..9ad7d24 --- /dev/null +++ b/backend/services/acs/internal/config/config.go @@ -0,0 +1,111 @@ +package config + +import ( + "context" + "flag" + "log" + "os" + "strconv" + + "github.com/joho/godotenv" +) + +const LOCAL_ENV = ".env.local" + +type Nats struct { + Url string + Name string + VerifyCertificates bool + Ctx context.Context +} + +type Acs struct { + Port string + Tls bool + TlsPort bool + NoTls bool + Username string + Password string + Route string +} + +type Config struct { + Acs Acs + Nats Nats +} + +func NewConfig() *Config { + + loadEnvVariables() + log.SetFlags(log.LstdFlags | log.Lshortfile) + + natsUrl := flag.String("nats_url", lookupEnvOrString("NATS_URL", "nats://localhost:4222"), "url for nats server") + natsName := flag.String("nats_name", lookupEnvOrString("NATS_NAME", "adapter"), "name for nats client") + natsVerifyCertificates := flag.Bool("nats_verify_certificates", lookupEnvOrBool("NATS_VERIFY_CERTIFICATES", false), "verify validity of certificates from nats server") + acsPort := flag.String("acs_port", lookupEnvOrString("ACS_PORT", ":9292"), "port for acs server") + acsRoute := flag.String("acs_route", lookupEnvOrString("ACS_ROUTE", "/acs"), "route for acs server") + flHelp := flag.Bool("help", false, "Help") + + /* + App variables priority: + 1º - Flag through command line. + 2º - Env variables. + 3º - Default flag value. + */ + + flag.Parse() + + if *flHelp { + flag.Usage() + os.Exit(0) + } + + ctx := context.TODO() + + return &Config{ + Nats: Nats{ + Url: *natsUrl, + Name: *natsName, + VerifyCertificates: *natsVerifyCertificates, + Ctx: ctx, + }, + Acs: Acs{ + Port: *acsPort, + Route: *acsRoute, + }, + } +} + +func loadEnvVariables() { + err := godotenv.Load() + + if _, err := os.Stat(LOCAL_ENV); err == nil { + _ = godotenv.Overload(LOCAL_ENV) + log.Printf("Loaded variables from '%s'", LOCAL_ENV) + return + } + + if err != nil { + log.Println("Error to load environment variables:", err) + } else { + log.Println("Loaded variables from '.env'") + } +} + +func lookupEnvOrString(key string, defaultVal string) string { + if val, _ := os.LookupEnv(key); val != "" { + return val + } + return defaultVal +} + +func lookupEnvOrBool(key string, defaultVal bool) bool { + if val, _ := os.LookupEnv(key); val != "" { + v, err := strconv.ParseBool(val) + if err != nil { + log.Fatalf("LookupEnvOrBool[%s]: %v", key, err) + } + return v + } + return defaultVal +} diff --git a/backend/services/acs/internal/cwmp/cwmp.go b/backend/services/acs/internal/cwmp/cwmp.go new file mode 100644 index 0000000..a0aaa06 --- /dev/null +++ b/backend/services/acs/internal/cwmp/cwmp.go @@ -0,0 +1,542 @@ +package cwmp + +import ( + "crypto/rand" + "encoding/xml" + "fmt" + "strconv" + "strings" + "time" +) + +type SoapEnvelope struct { + XMLName xml.Name + Header SoapHeader + Body SoapBody +} + +type SoapHeader struct { + Id string `xml:"ID"` +} +type SoapBody struct { + CWMPMessage CWMPMessage `xml:",any"` +} + +type CWMPMessage struct { + XMLName xml.Name +} + +type EventStruct struct { + EventCode string + CommandKey string +} + +type ParameterValueStruct struct { + Name string + Value string +} + +type ParameterInfoStruct struct { + Name string + Writable string +} + +type SetParameterValues_ struct { + ParameterList []ParameterValueStruct `xml:"Body>SetParameterValues>ParameterList>ParameterValueStruct"` + ParameterKey string `xml:"Body>SetParameterValues>ParameterKey>string"` +} + +type GetParameterValues_ struct { + ParameterNames []string `xml:"Body>GetParameterValues>ParameterNames>string"` +} + +type GetParameterNames_ struct { + ParameterPath []string `xml:"Body>GetParameterNames>ParameterPath"` + NextLevel string `xml:"Body>GetParameterNames>NextLevel"` +} + +type GetParameterValuesResponse struct { + ParameterList []ParameterValueStruct `xml:"Body>GetParameterValuesResponse>ParameterList>ParameterValueStruct"` +} + +type GetParameterNamesResponse struct { + ParameterList []ParameterInfoStruct `xml:"Body>GetParameterNamesResponse>ParameterList>ParameterInfoStruct"` +} + +type CWMPInform struct { + DeviceId DeviceID `xml:"Body>Inform>DeviceId"` + Events []EventStruct `xml:"Body>Inform>Event>EventStruct"` + ParameterList []ParameterValueStruct `xml:"Body>Inform>ParameterList>ParameterValueStruct"` +} + +func (s *SoapEnvelope) KindOf() string { + return s.Body.CWMPMessage.XMLName.Local +} + +func (i *CWMPInform) GetEvents() string { + res := "" + for idx := range i.Events { + res += i.Events[idx].EventCode + } + + return res +} + +func (i *CWMPInform) GetConnectionRequest() string { + for idx := range i.ParameterList { + // valid condition for both tr98 and tr181 + if strings.HasSuffix(i.ParameterList[idx].Name, "Device.ManagementServer.ConnectionRequestURL") { + return i.ParameterList[idx].Value + } + } + + return "" +} + +func (i *CWMPInform) GetSoftwareVersion() string { + for idx := range i.ParameterList { + if strings.HasSuffix(i.ParameterList[idx].Name, "Device.DeviceInfo.SoftwareVersion") { + return i.ParameterList[idx].Value + } + } + + return "" +} + +func (i *CWMPInform) GetHardwareVersion() string { + for idx := range i.ParameterList { + if strings.HasSuffix(i.ParameterList[idx].Name, "Device.DeviceInfo.HardwareVersion") { + return i.ParameterList[idx].Value + } + } + + return "" +} + +func (i *CWMPInform) GetDataModelType() string { + if strings.HasPrefix(i.ParameterList[0].Name, "InternetGatewayDevice") { + return "TR098" + } else if strings.HasPrefix(i.ParameterList[0].Name, "Device") { + return "TR181" + } + + return "" +} + +type DeviceID struct { + Manufacturer string + OUI string + SerialNumber string + ProductClass string +} + +func InformResponse(mustUnderstand string) string { + mustUnderstandHeader := "" + if mustUnderstand != "" { + mustUnderstandHeader = `1 ++ +` + leaf + ` +` + + for idx := range leaves { + msg += ` +` + leaves[idx] + ` ` + + } + msg += `+ ++ +` + leaf + ` +` + value + ` +LC1309` + randToken() + ` +` + + for key, value := range data { + msg += ` ++ ` + } + + msg += `` + key + ` +` + value + ` +LC1309` + randToken() + ` +` + leaf + ` +` + strconv.Itoa(nextlevel) + ` +MSDWK +` + filetype + ` +` + url + ` +` + username + ` +` + password + ` +` + filesize + ` ++ 0 ++ + + + ` +} + +func ScheduleDownload(filetype, url, username, password, filesize string, windowslist []fmt.Stringer) string { + ret := ` +` + window.WindowStart + ` +` + window.WindowEnd + ` +` + window.WindowMode + ` +` + window.UserMessage + ` +` + window.MaxRetries + ` +MSDWK +` + filetype + ` +` + url + ` +` + username + ` +` + password + ` +` + filesize + ` ++ ` + + for _, op := range windowslist { + ret += op.String() + } + + ret += ` ++ ` +} + +type UpdateOpStruct struct { + Uuid string + Version string + Url string + Username string + Password string +} + +func (op *UpdateOpStruct) String() string { + return `` + op.Url + ` +` + op.Uuid + ` +` + op.Username + ` +` + op.Password + ` +` + op.ExecutionEnvironment + ` ++ ` +} + +type UninstallOpStruct struct { + Uuid string + Version string + ExecutionEnvironment string +} + +func (op *UninstallOpStruct) String() string { + return `` + op.Uuid + ` +` + op.Version + ` +` + op.Url + ` +` + op.Username + ` +` + op.Password + ` ++ ` +} + +func ChangeDuState(ops []fmt.Stringer) string { + ret := ` +` + op.Uuid + ` +` + op.Version + ` +` + op.ExecutionEnvironment + ` +` + + for _, op := range ops { + ret += op.String() + } + + ret += ` ++ ADB Broadband +0013C8 +VV5522 +` + serial + ` ++ +6 CONNECTION REQUEST ++ 1 +` + time.Now().Format(time.RFC3339) + ` +0 ++ +InternetGatewayDevice.ManagementServer.ConnectionRequestURL +http://104.199.175.27:7547/ConnectionRequest-` + serial + ` +InternetGatewayDevice.ManagementServer.ParameterKey ++ InternetGatewayDevice.DeviceSummary +InternetGatewayDevice:1.2[](Baseline:1,EthernetLAN:1,WiFiLAN:1,ADSLWAN:1,EthernetWAN:1,QoS:1,QoSDynamicFlow:1,Bridging:1,Time:1,IPPing:1,TraceRoute:1,DeviceAssociation:1,UDPConnReq:1),VoiceService:1.0[1](TAEndpoint:1,SIPEndpoint:1) +InternetGatewayDevice.DeviceInfo.HardwareVersion +` + serial + ` +InternetGatewayDevice.DeviceInfo.ProvisioningCode +ABCD +InternetGatewayDevice.DeviceInfo.SoftwareVersion +4.0.8.17785 +InternetGatewayDevice.DeviceInfo.SpecVersion +1.0 +InternetGatewayDevice.WANDevice.1.WANConnectionDevice.1.WANIPConnection.1.ExternalIPAddress +12.0.0.10 ++ ` + } + } + + ret += `` + key + ` +` + value + ` +` + ret += temp + ret += ` + ` + } + + fmt.Println(len(obj)) + ret += `` + o + ` +true +` + ret += temp + ret += ` 1 ++ +` + leaf + ` +` + + for idx := range leaves { + msg += ` +` + leaves[idx] + ` ` + + } + msg += `+ ++ +` + leaf + ` +` + value + ` +LC1309` + randToken() + ` +` + + for key, value := range data { + msg += ` ++ ` + } + + msg += `` + key + ` +` + value + ` +LC1309` + randToken() + ` +` + leaf + ` +` + strconv.Itoa(nextlevel) + ` +MSDWK +` + filetype + ` +` + url + ` +` + username + ` +` + password + ` +` + filesize + ` ++ 0 ++ + + + ` +} + +func ScheduleDownload(filetype, url, username, password, filesize string, windowslist []fmt.Stringer) string { + ret := ` +` + window.WindowStart + ` +` + window.WindowEnd + ` +` + window.WindowMode + ` +` + window.UserMessage + ` +` + window.MaxRetries + ` +MSDWK +` + filetype + ` +` + url + ` +` + username + ` +` + password + ` +` + filesize + ` ++ ` + + for _, op := range windowslist { + ret += op.String() + } + + ret += ` ++ ` +} + +type UpdateOpStruct struct { + Uuid string + Version string + Url string + Username string + Password string +} + +func (op *UpdateOpStruct) String() string { + return `` + op.Url + ` +` + op.Uuid + ` +` + op.Username + ` +` + op.Password + ` +` + op.ExecutionEnvironment + ` ++ ` +} + +type UninstallOpStruct struct { + Uuid string + Version string + ExecutionEnvironment string +} + +func (op *UninstallOpStruct) String() string { + return `` + op.Uuid + ` +` + op.Version + ` +` + op.Url + ` +` + op.Username + ` +` + op.Password + ` ++ ` +} + +func ChangeDuState(ops []fmt.Stringer) string { + ret := ` +` + op.Uuid + ` +` + op.Version + ` +` + op.ExecutionEnvironment + ` +` + + for _, op := range ops { + ret += op.String() + } + + ret += ` ++ ADB Broadband +0013C8 +VV5522 +` + serial + ` ++ +6 CONNECTION REQUEST ++ 1 +` + time.Now().Format(time.RFC3339) + ` +0 ++ +InternetGatewayDevice.ManagementServer.ConnectionRequestURL +http://104.199.175.27:7547/ConnectionRequest-` + serial + ` +InternetGatewayDevice.ManagementServer.ParameterKey ++ InternetGatewayDevice.DeviceSummary +InternetGatewayDevice:1.2[](Baseline:1,EthernetLAN:1,WiFiLAN:1,ADSLWAN:1,EthernetWAN:1,QoS:1,QoSDynamicFlow:1,Bridging:1,Time:1,IPPing:1,TraceRoute:1,DeviceAssociation:1,UDPConnReq:1),VoiceService:1.0[1](TAEndpoint:1,SIPEndpoint:1) +InternetGatewayDevice.DeviceInfo.HardwareVersion +` + serial + ` +InternetGatewayDevice.DeviceInfo.ProvisioningCode +ABCD +InternetGatewayDevice.DeviceInfo.SoftwareVersion +4.0.8.17785 +InternetGatewayDevice.DeviceInfo.SpecVersion +1.0 +InternetGatewayDevice.WANDevice.1.WANConnectionDevice.1.WANIPConnection.1.ExternalIPAddress +12.0.0.10 ++ ` + } + } + + ret += `` + key + ` +` + value + ` +` + ret += temp + ret += ` + ` + } + + fmt.Println(len(obj)) + ret += `` + o + ` +true +` + ret += temp + ret += ` 1 ++ +` + leaf + ` +` + + for idx := range leaves { + msg += ` +` + leaves[idx] + ` ` + + } + msg += `+ ++ +` + leaf + ` +` + value + ` +LC1309` + randToken() + ` +` + + for key, value := range data { + msg += ` ++ ` + } + + msg += `` + key + ` +` + value + ` +LC1309` + randToken() + ` +` + leaf + ` +` + strconv.Itoa(nextlevel) + ` +MSDWK +` + filetype + ` +` + url + ` +` + username + ` +` + password + ` +` + filesize + ` ++ 0 ++ + + + ` +} + +func ScheduleDownload(filetype, url, username, password, filesize string, windowslist []fmt.Stringer) string { + ret := ` +` + window.WindowStart + ` +` + window.WindowEnd + ` +` + window.WindowMode + ` +` + window.UserMessage + ` +` + window.MaxRetries + ` +MSDWK +` + filetype + ` +` + url + ` +` + username + ` +` + password + ` +` + filesize + ` ++ ` + + for _, op := range windowslist { + ret += op.String() + } + + ret += ` ++ ` +} + +type UpdateOpStruct struct { + Uuid string + Version string + Url string + Username string + Password string +} + +func (op *UpdateOpStruct) String() string { + return `` + op.Url + ` +` + op.Uuid + ` +` + op.Username + ` +` + op.Password + ` +` + op.ExecutionEnvironment + ` ++ ` +} + +type UninstallOpStruct struct { + Uuid string + Version string + ExecutionEnvironment string +} + +func (op *UninstallOpStruct) String() string { + return `` + op.Uuid + ` +` + op.Version + ` +` + op.Url + ` +` + op.Username + ` +` + op.Password + ` ++ ` +} + +func ChangeDuState(ops []fmt.Stringer) string { + ret := ` +` + op.Uuid + ` +` + op.Version + ` +` + op.ExecutionEnvironment + ` +` + + for _, op := range ops { + ret += op.String() + } + + ret += ` ++ + ` + } + } + + ret += `` + key + ` +` + value + ` +` + ret += temp + ret += ` + ` + } + + fmt.Println(len(obj)) + ret += `` + o + ` +true +` + ret += temp + ret += ` :30003" + - name: NEXT_PUBLIC_WS_ENDPOINT + value: " :30005" +``` + +```shell +kubectl apply -f $DEPLOYMENT_PATH/mqtt.yaml +kubectl apply -f $DEPLOYMENT_PATH/mqtt-adapter.yaml +kubectl apply -f $DEPLOYMENT_PATH/adapter.yaml +kubectl apply -f $DEPLOYMENT_PATH/controller.yaml +kubectl apply -f $DEPLOYMENT_PATH/socketio.yaml +kubectl apply -f $DEPLOYMENT_PATH/frontend.yaml +kubectl apply -f $DEPLOYMENT_PATH/ws.yaml +kubectl apply -f $DEPLOYMENT_PATH/ws-adapter.yaml +``` + +### Checking cluster status: + +```shell + +kubectl get pods +kubectl get svc + +``` \ No newline at end of file diff --git a/deploy/kubernetes/adapter.yaml b/deploy/kubernetes/adapter.yaml new file mode 100644 index 0000000..d2d2d23 --- /dev/null +++ b/deploy/kubernetes/adapter.yaml @@ -0,0 +1,39 @@ +apiVersion: apps/v1 +kind: Deployment +metadata: + name: adapter +spec: + replicas: 1 + selector: + matchLabels: + app: adapter + strategy: + type: Recreate # Specify the Recreate strategy + template: + metadata: + labels: + app: adapter + spec: + containers: + - name: adapter + image: oktopusp/adapter:latest + resources: + requests: + memory: 64Mi + cpu: 0.1 + limits: + memory: 128Mi + cpu: 0.2 + imagePullPolicy: IfNotPresent + env: + - name: NATS_URL + value: "nats://nats:4222" + - name: NATS_NAME + value: "adapter" + - name: NATS_VERIFY_CERTIFICATES + value: "false" + - name: MONGO_URI + value: "mongodb://oktopusp:oktopusp@mongodb-0.mongodb-svc.mongodb.svc.cluster.local:27017,mongodb-1.mongodb-svc.mongodb.svc.cluster.local:27017,mongodb-2.mongodb-svc.mongodb.svc.cluster.local:27017/adapter?replicaSet=mongodb&ssl=false" + - name: CONTROLLER_ID + value: "oktopusController" + diff --git a/deploy/kubernetes/backend.yaml b/deploy/kubernetes/backend.yaml deleted file mode 100644 index 10a45db..0000000 --- a/deploy/kubernetes/backend.yaml +++ /dev/null @@ -1,21 +0,0 @@ -apiVersion: apps/v1 -kind: Deployment -metadata: - name: backend - labels: - app: backend -spec: - replicas: 1 - selector: - matchLabels: - app: backend - template: - metadata: - labels: - app: backend - spec: - containers: - - name: backend - image: backend:latest - ports: - - containerPort: 8080 \ No newline at end of file diff --git a/deploy/kubernetes/controller.yaml b/deploy/kubernetes/controller.yaml new file mode 100644 index 0000000..450317d --- /dev/null +++ b/deploy/kubernetes/controller.yaml @@ -0,0 +1,53 @@ +apiVersion: apps/v1 +kind: Deployment +metadata: + name: controller +spec: + replicas: 1 + selector: + matchLabels: + app: controller + strategy: + type: Recreate + template: + metadata: + labels: + app: controller + spec: + containers: + - name: controller + image: oktopusp/controller:latest + resources: + # requests: + # memory: 64Mi + # cpu: 0.5 + # limits: + # memory: 256Mi + # cpu: 1 + imagePullPolicy: IfNotPresent + env: + - name: NATS_URL + value: "nats://nats:4222" + - name: NATS_NAME + value: "adapter" + - name: NATS_VERIFY_CERTIFICATES + value: "false" + - name: MONGO_URI + value: "mongodb://oktopusp:oktopusp@mongodb-0.mongodb-svc.mongodb.svc.cluster.local:27017,mongodb-1.mongodb-svc.mongodb.svc.cluster.local:27017,mongodb-2.mongodb-svc.mongodb.svc.cluster.local:27017/?replicaSet=mongodb&ssl=false" + - name: REST_API_PORT + value: "8000" +--- +apiVersion: v1 +kind: Service +metadata: + name: controller-svc +spec: + selector: + app: controller + ports: + - protocol: TCP + port: 8000 + targetPort: 8000 + nodePort: 30003 + type: NodePort + diff --git a/deploy/kubernetes/frontend.yaml b/deploy/kubernetes/frontend.yaml new file mode 100644 index 0000000..6731899 --- /dev/null +++ b/deploy/kubernetes/frontend.yaml @@ -0,0 +1,48 @@ +apiVersion: apps/v1 +kind: Deployment +metadata: + name: frontend +spec: + replicas: 1 + selector: + matchLabels: + app: frontend + strategy: + type: Recreate # Specify the Recreate strategy + template: + metadata: + labels: + app: frontend + spec: + containers: + - name: frontend + image: oktopusp/frontend:latest + resources: + requests: + memory: 64Mi + cpu: 100m + limits: + memory: 256Mi + cpu: 200m + ports: + - containerPort: 3000 + imagePullPolicy: IfNotPresent + env: + - name: NEXT_PUBLIC_REST_ENDPOINT + value: "192.168.1.130:30003" + - name: NEXT_PUBLIC_WS_ENDPOINT + value: "192.168.1.130:30005" +--- +apiVersion: v1 +kind: Service +metadata: + name: frontend-svc +spec: + selector: + app: frontend + ports: + - protocol: TCP + port: 3000 + targetPort: 3000 + nodePort: 30001 + type: NodePort diff --git a/deploy/kubernetes/haproxy-kubernetes-ingress-cm.yaml b/deploy/kubernetes/haproxy-kubernetes-ingress-cm.yaml new file mode 100644 index 0000000..c4aabd9 --- /dev/null +++ b/deploy/kubernetes/haproxy-kubernetes-ingress-cm.yaml @@ -0,0 +1,7 @@ +apiVersion: v1 +kind: ConfigMap +metadata: + name: haproxy-kubernetes-ingress + namespace: haproxy-controller +data: + syslog-server: "address:stdout, format: raw, facility:daemon" diff --git a/deploy/kubernetes/haproxy-tcp-services-cm.yaml b/deploy/kubernetes/haproxy-tcp-services-cm.yaml new file mode 100644 index 0000000..a4b8f7f --- /dev/null +++ b/deploy/kubernetes/haproxy-tcp-services-cm.yaml @@ -0,0 +1,8 @@ +apiVersion: v1 +kind: ConfigMap +metadata: + name: haproxy-tcp + namespace: default +data: + 1883: # Port where the frontend is going to listen to. + default/mqtt-svc:1883 # Kubernetes service in the format NS/ServiceName:ServicePort diff --git a/deploy/kubernetes/haproxy-tcp-services.yaml b/deploy/kubernetes/haproxy-tcp-services.yaml new file mode 100644 index 0000000..77db1d6 --- /dev/null +++ b/deploy/kubernetes/haproxy-tcp-services.yaml @@ -0,0 +1,8 @@ +controller: + service: + tcpPorts: + - name: mqtt + port: 1883 + targetPort: 1883 + extraArgs: + - --configmap-tcp-services=default/haproxy-tcp diff --git a/deploy/kubernetes/mongodb.yaml b/deploy/kubernetes/mongodb.yaml new file mode 100644 index 0000000..c8aaf12 --- /dev/null +++ b/deploy/kubernetes/mongodb.yaml @@ -0,0 +1,38 @@ +--- +apiVersion: mongodbcommunity.mongodb.com/v1 +kind: MongoDBCommunity +metadata: + name: mongodb +spec: + members: 3 + type: ReplicaSet + version: "6.0.5" + security: + authentication: + modes: ["SCRAM"] + users: + - name: oktopusp + db: admin + passwordSecretRef: # a reference to the secret that will be used to generate the user's password + name: mongo-secret + roles: + - name: clusterAdmin + db: admin + - name: userAdminAnyDatabase + db: admin + - name: readWriteAnyDatabase + db: admin + scramCredentialsSecretName: my-scram + additionalMongodConfig: + storage.wiredTiger.engineConfig.journalCompressor: zlib + +# the user credentials will be generated from this secret +# once the credentials are generated, this secret is no longer required +--- +apiVersion: v1 +kind: Secret +metadata: + name: mongo-secret +type: Opaque +stringData: + password: oktopusp diff --git a/deploy/kubernetes/mqtt-adapter.yaml b/deploy/kubernetes/mqtt-adapter.yaml new file mode 100644 index 0000000..3d7b7b5 --- /dev/null +++ b/deploy/kubernetes/mqtt-adapter.yaml @@ -0,0 +1,44 @@ +apiVersion: apps/v1 +kind: Deployment +metadata: + name: mqtt-adapter +spec: + replicas: 1 + selector: + matchLabels: + app: mqtt-adapter + template: + metadata: + labels: + app: mqtt-adapter + spec: + containers: + - name: mqtt-adapter + image: oktopusp/mqtt-adapter:latest + resources: + requests: + memory: 64Mi + cpu: 0.1 + limits: + memory: 128Mi + cpu: 0.2 + imagePullPolicy: IfNotPresent + env: + - name: NATS_URL + value: "nats:4222" + - name: NATS_NAME + value: "mqtt-adapter" + - name: NATS_VERIFY_CERTIFICATES + value: "false" + - name: MQTT_URL + value: "tcp://mqtt:1883" + - name: MQTT_CLIENT_ID + value: "mqtt-adapter" + - name: MQTT_USERNAME + value: "" + - name: MQTT_PASSWORD + value: "" + - name: MQTT_QOS + value: "1" + - name: MQTT_SERVICE_HOST + value: "mqtt" diff --git a/deploy/kubernetes/mqtt.yaml b/deploy/kubernetes/mqtt.yaml new file mode 100644 index 0000000..0d705ee --- /dev/null +++ b/deploy/kubernetes/mqtt.yaml @@ -0,0 +1,48 @@ +apiVersion: v1 +kind: Service +metadata: + name: mqtt-svc +spec: + selector: + app: mqtt + ports: + - protocol: TCP + port: 1883 + targetPort: 1883 + nodePort: 30000 + type: NodePort +--- +apiVersion: apps/v1 +kind: Deployment +metadata: + name: mqtt +spec: + replicas: 1 + selector: + matchLabels: + app: mqtt + template: + metadata: + labels: + app: mqtt + spec: + containers: + - name: mqtt + image: rogersacchelli/mqtt:latest + ports: + - containerPort: 1883 + resources: + requests: + memory: 64Mi + cpu: 100m + limits: + memory: 256Mi + cpu: 200m + imagePullPolicy: IfNotPresent + env: + - name: MQTT_PORT + value: ":1883" + - name: MQTT_TLS + value: "false" + - name: LOG_LEVEL + value: "0" # 0 - DEBUG diff --git a/deploy/kubernetes/socketio.yaml b/deploy/kubernetes/socketio.yaml new file mode 100644 index 0000000..a51c5fd --- /dev/null +++ b/deploy/kubernetes/socketio.yaml @@ -0,0 +1,35 @@ +apiVersion: apps/v1 +kind: Deployment +metadata: + name: socketio +spec: + replicas: 1 + selector: + matchLabels: + app: socketio + template: + metadata: + labels: + app: socketio + spec: + containers: + - name: socketio + image: oktopusp/socketio:latest + imagePullPolicy: IfNotPresent + env: + - name: NATS_URL + value: "nats:4222" +--- +apiVersion: v1 +kind: Service +metadata: + name: socketio-svc +spec: + selector: + app: socketio + ports: + - protocol: TCP + port: 5000 + targetPort: 5000 + nodePort: 30002 + type: NodePort diff --git a/deploy/kubernetes/ws-adapter.yaml b/deploy/kubernetes/ws-adapter.yaml new file mode 100644 index 0000000..3be4722 --- /dev/null +++ b/deploy/kubernetes/ws-adapter.yaml @@ -0,0 +1,46 @@ +apiVersion: apps/v1 +kind: Deployment +metadata: + name: ws-adapter +spec: + replicas: 1 + selector: + matchLabels: + app: ws-adapter + template: + metadata: + labels: + app: ws-adapter + spec: + containers: + - name: ws-adapter + image: oktopusp/ws-adapter:latest + resources: + #requests: + # memory: 64Mi + # cpu: 0.1 + #limits: + # memory: 256Mi + # cpu: 0.2 + imagePullPolicy: IfNotPresent + env: + - name: NATS_URL + value: "nats://nats:4222" + - name: NATS_NAME + value: "ws-adapter" + - name: NATS_VERIFY_CERTIFICATES + value: "0" # 0 - DEBUG + - name: WS_TOKEN + value: "" + - name: WS_AUTH_ENABLE + value: "false" + - name: WS_ADDR + value: "ws-svc" + - name: WS_PORT + value: ":8080" + - name: WS_ROUTE + value: "/ws/controller" + - name: WS_TLS_ENABLE + value: "false" + - name: WS_SKIP_TLS_VERIFY + value: "false" diff --git a/deploy/kubernetes/ws.yaml b/deploy/kubernetes/ws.yaml new file mode 100644 index 0000000..f53f334 --- /dev/null +++ b/deploy/kubernetes/ws.yaml @@ -0,0 +1,52 @@ +apiVersion: v1 +kind: Service +metadata: + name: ws-svc +spec: + selector: + app: ws + ports: + - protocol: TCP + port: 8080 + targetPort: 8080 + nodePort: 30005 + type: NodePort +--- +apiVersion: apps/v1 +kind: Deployment +metadata: + name: ws +spec: + replicas: 1 + selector: + matchLabels: + app: ws + template: + metadata: + labels: + app: ws + spec: + containers: + - name: ws + image: oktopusp/ws:latest + ports: + - containerPort: 8080 + resources: + requests: + memory: 64Mi + cpu: 100m + limits: + memory: 256Mi + cpu: 200m + imagePullPolicy: IfNotPresent + env: + - name: SERVER_PORT + value: ":8080" + - name: SERVER_AUTH_TOKEN + value: "" + - name: SERVER_AUTH_ENABLE + value: "false" + - name: CONTROLLER_EID + value: "oktopusController" + - name: SERVER_TLS_ENABLE + value: "false" diff --git a/frontend/.env b/frontend/.env index 32e4aa9..141984e 100644 --- a/frontend/.env +++ b/frontend/.env @@ -1,17 +1,17 @@ # ----------------------------- Local Environment ---------------------------- # -NEXT_PUBLIC_REST_ENPOINT="http://localhost:8000/api" -NEXT_PUBLIC_WS_ENPOINT="http://localhost:5000/" +NEXT_PUBLIC_REST_ENDPOINT="http://localhost:8000/api" +NEXT_PUBLIC_WS_ENDPOINT="http://localhost:5000/" # ---------------------------------------------------------------------------- # # -------------------------- Production Environment -------------------------- # -#NEXT_PUBLIC_REST_ENPOINT="https://demo.oktopus.app.br/api" -#NEXT_PUBLIC_WS_ENPOINT="https://demo.oktopus.app.br/" +#NEXT_PUBLIC_REST_ENDPOINT="https://demo.oktopus.app.br/api" +#NEXT_PUBLIC_WS_ENDPOINT="https://demo.oktopus.app.br/" # ---------------------------------------------------------------------------- # # ---------------------------- Mocked Environment ---------------------------- # -#NEXT_PUBLIC_REST_ENPOINT="https://d9962fd9-2464-4a30-9a86-a15a04b57ad0.mock.pstmn.io" +#NEXT_PUBLIC_REST_ENDPOINT="https://d9962fd9-2464-4a30-9a86-a15a04b57ad0.mock.pstmn.io" # ---------------------------------------------------------------------------- # diff --git a/frontend/build/Dockerfile b/frontend/build/Dockerfile index 5c9d862..a5d60f8 100644 --- a/frontend/build/Dockerfile +++ b/frontend/build/Dockerfile @@ -2,11 +2,11 @@ FROM node:16.20.2-alpine as builder WORKDIR /app -COPY ../ . +COPY ../ ./ RUN npm install -RUN NEXT_PUBLIC_REST_ENPOINT=REST_API_URL NEXT_PUBLIC_WS_ENPOINT=WS_URL npm run build +RUN NEXT_PUBLIC_REST_ENDPOINT=REST_API_URL NEXT_PUBLIC_WS_ENDPOINT=WS_URL npm run build RUN ls -la && echo "Listing directory contents done" @@ -26,4 +26,4 @@ RUN chmod 755 entrypoint.sh ENTRYPOINT ["/app/entrypoint.sh"] -CMD [ "npm", "run", "start" ] \ No newline at end of file +CMD [ "npm", "run", "start" ] diff --git a/frontend/build/entrypoint.sh b/frontend/build/entrypoint.sh index f4abca7..bf43c58 100644 --- a/frontend/build/entrypoint.sh +++ b/frontend/build/entrypoint.sh @@ -3,16 +3,16 @@ set -Ex function apply_path { - echo "Check that we have NEXT_PUBLIC_REST_ENPOINT vars" - test -n "$NEXT_PUBLIC_REST_ENPOINT" + echo "Check that we have NEXT_PUBLIC_REST_ENDPOINT vars" + test -n "$NEXT_PUBLIC_REST_ENDPOINT" - echo "Check that we have NEXT_PUBLIC_WS_ENPOINT vars" - test -n "$NEXT_PUBLIC_WS_ENPOINT" + echo "Check that we have NEXT_PUBLIC_WS_ENDPOINT vars" + test -n "$NEXT_PUBLIC_WS_ENDPOINT" - find /app/.next \( -type d -name .git -prune \) -o -type f -print0 | xargs -0 sed -i "s#REST_API_URL#$NEXT_PUBLIC_REST_ENPOINT#g" - find /app/.next \( -type d -name .git -prune \) -o -type f -print0 | xargs -0 sed -i "s#WS_URL#$NEXT_PUBLIC_WS_ENPOINT#g" + find /app/.next \( -type d -name .git -prune \) -o -type f -print0 | xargs -0 sed -i "s#REST_API_URL#$NEXT_PUBLIC_REST_ENDPOINT#g" + find /app/.next \( -type d -name .git -prune \) -o -type f -print0 | xargs -0 sed -i "s#WS_URL#$NEXT_PUBLIC_WS_ENDPOINT#g" } apply_path echo "Starting Nextjs" -exec "$@" \ No newline at end of file +exec "$@"