NOISSUE - Enhance Proplet #35

JeffMboya · 2024-12-11T13:36:36Z

What type of PR is this?

This is an optimization

What does this do?

Eliminates duplicate error logging
Integrates the mqtt package from the pkg/mqtt directory in the Proplet implementation
Parses the WasmFile during the start command, rather than at the initial startup of the Proplet
Replaces a shared runtime with a single runtime per task/app

Which issue(s) does this PR fix/relate to?

No issue

Have you included tests for your changes?

No

Did you document any new/modified features?

No

Notes

Signed-off-by: Rodney Osodo <[email protected]>

NOISSUE - Proof of Concept For Wasm Orchestrator

Signed-off-by: JeffMboya <[email protected]>

Signed-off-by: Rodney Osodo <[email protected]>

NOISSUE - Add architecture diagram

Signed-off-by: Rodney Osodo <[email protected]>

Call subscribe after service has started to subscribe to wildcard topic

PROP- 25 - Implement Manager Service

Signed-off-by: Rodney Osodo <[email protected]>

* chore: remove unused files Signed-off-by: Rodney Osodo <[email protected]> * fix: add ci for lint and build check Signed-off-by: Rodney Osodo <[email protected]> * chore: add apache license Signed-off-by: Rodney Osodo <[email protected]> --------- Signed-off-by: Rodney Osodo <[email protected]>

Signed-off-by: Rodney Osodo <[email protected]>

Signed-off-by: JeffMboya <[email protected]> Add requests, responses, transport,endpoint and service files Signed-off-by: JeffMboya <[email protected]> Remove proplet.go Signed-off-by: JeffMboya <[email protected]> Rename endpoints Signed-off-by: JeffMboya <[email protected]> Rename endpoints Signed-off-by: JeffMboya <[email protected]> Rename endpoints Signed-off-by: JeffMboya <[email protected]> Rename endpoints Signed-off-by: JeffMboya <[email protected]> Add mqtt client; remove http client Signed-off-by: JeffMboya <[email protected]> Add config.json Signed-off-by: JeffMboya <[email protected]> Update dependencies Signed-off-by: JeffMboya <[email protected]> Add errors Signed-off-by: JeffMboya <[email protected]> Rename from worker to proplet Signed-off-by: JeffMboya <[email protected]> Use WazeroRuntime Signed-off-by: JeffMboya <[email protected]> Add /create and /alive topics Signed-off-by: JeffMboya <[email protected]> Refactor mqtt.go Signed-off-by: JeffMboya <[email protected]> Fix service.go Signed-off-by: JeffMboya <[email protected]> Add different start and stop topics Signed-off-by: JeffMboya <[email protected]> Update README Signed-off-by: JeffMboya <[email protected]> Update README Signed-off-by: JeffMboya <[email protected]> Pre-configure registry during Proplet deployment; allow for registry update Signed-off-by: JeffMboya <[email protected]> Update topic Signed-off-by: JeffMboya <[email protected]> Remove duplicate methods Signed-off-by: JeffMboya <[email protected]> Update README Signed-off-by: JeffMboya <[email protected]> move README to docs repo Signed-off-by: JeffMboya <[email protected]> move main.go to proplet/main.go Signed-off-by: JeffMboya <[email protected]> rename initializeProplet to newService Signed-off-by: JeffMboya <[email protected]> Enable manual upload of wasm files Signed-off-by: JeffMboya <[email protected]> Remove duplicate config validation Signed-off-by: JeffMboya <[email protected]> Remove duplicate config validation; add slogger Signed-off-by: JeffMboya <[email protected]> Fix service.go Signed-off-by: JeffMboya <[email protected]> Rename token to password Signed-off-by: JeffMboya <[email protected]> Move payloads to the top Signed-off-by: JeffMboya <[email protected]> Move ptopics to the top; use substitution Signed-off-by: JeffMboya <[email protected]> Replace variable times with consts Signed-off-by: JeffMboya <[email protected]> Use ticker instead of time.Sleep Signed-off-by: JeffMboya <[email protected]> Move responses and request to api folder Signed-off-by: JeffMboya <[email protected]> Move config and m qtt to repository folder Signed-off-by: JeffMboya <[email protected]> Move config.json to repository folder Signed-off-by: JeffMboya <[email protected]> Move runtime.go to service.go Signed-off-by: JeffMboya <[email protected]> Restructure service.go Signed-off-by: JeffMboya <[email protected]> Add architecture diagram Signed-off-by: JeffMboya <[email protected]> Add docs Signed-off-by: JeffMboya <[email protected]> feat(manager): implement basic crud for worker and task feat: add magistrala stack Signed-off-by: Rodney Osodo <[email protected]> refactor: rename worker to proplet Signed-off-by: Rodney Osodo <[email protected]> fix: add mqtt client Signed-off-by: Rodney Osodo <[email protected]> remove previous scheduler implementation Signed-off-by: Rodney Osodo <[email protected]> fix: remove oauth URLs Signed-off-by: Rodney Osodo <[email protected]> refactor(manager): combine mqtt handlers to service Call subscribe after service has started to subscribe to wildcard topic first commit Signed-off-by: JeffMboya <[email protected]> Add requests, responses, transport,endpoint and service files Signed-off-by: JeffMboya <[email protected]> Remove proplet.go Signed-off-by: JeffMboya <[email protected]> Rename endpoints Signed-off-by: JeffMboya <[email protected]> Rename endpoints Signed-off-by: JeffMboya <[email protected]> Rename endpoints Signed-off-by: JeffMboya <[email protected]> Rename endpoints Signed-off-by: JeffMboya <[email protected]> Add mqtt client; remove http client Signed-off-by: JeffMboya <[email protected]> Add config.json Signed-off-by: JeffMboya <[email protected]> Update dependencies Signed-off-by: JeffMboya <[email protected]> Add errors Signed-off-by: JeffMboya <[email protected]> Rename from worker to proplet Signed-off-by: JeffMboya <[email protected]> Use WazeroRuntime Signed-off-by: JeffMboya <[email protected]> Add /create and /alive topics Signed-off-by: JeffMboya <[email protected]> Refactor mqtt.go Signed-off-by: JeffMboya <[email protected]> Fix service.go Signed-off-by: JeffMboya <[email protected]> Add different start and stop topics Signed-off-by: JeffMboya <[email protected]> Update README Signed-off-by: JeffMboya <[email protected]> Update README Signed-off-by: JeffMboya <[email protected]> Pre-configure registry during Proplet deployment; allow for registry update Signed-off-by: JeffMboya <[email protected]> Update topic Signed-off-by: JeffMboya <[email protected]> Remove duplicate methods Signed-off-by: JeffMboya <[email protected]> Update README Signed-off-by: JeffMboya <[email protected]> move README to docs repo Signed-off-by: JeffMboya <[email protected]> move main.go to proplet/main.go Signed-off-by: JeffMboya <[email protected]> rename initializeProplet to newService Signed-off-by: JeffMboya <[email protected]> Enable manual upload of wasm files Signed-off-by: JeffMboya <[email protected]> Remove duplicate config validation Signed-off-by: JeffMboya <[email protected]> Remove duplicate config validation; add slogger Signed-off-by: JeffMboya <[email protected]> Fix service.go Signed-off-by: JeffMboya <[email protected]> Rename token to password Signed-off-by: JeffMboya <[email protected]> Move payloads to the top Signed-off-by: JeffMboya <[email protected]> Move ptopics to the top; use substitution Signed-off-by: JeffMboya <[email protected]> Replace variable times with consts Signed-off-by: JeffMboya <[email protected]> Use ticker instead of time.Sleep Signed-off-by: JeffMboya <[email protected]> Move responses and request to api folder Signed-off-by: JeffMboya <[email protected]> Move config and m qtt to repository folder Signed-off-by: JeffMboya <[email protected]> Move config.json to repository folder Signed-off-by: JeffMboya <[email protected]> Move runtime.go to service.go Signed-off-by: JeffMboya <[email protected]> Restructure service.go Signed-off-by: JeffMboya <[email protected]>

Signed-off-by: JeffMboya <[email protected]>

drasko and others added 30 commits August 7, 2024 15:18

Initial commit

bfd01d8

WIP(orchestrator): Add basic task orchestrator for wasm

73083a1

Signed-off-by: Rodney Osodo <[email protected]>

Merge pull request absmach#1 from absmach/poc

b466381

NOISSUE - Proof of Concept For Wasm Orchestrator

Update README.md

3006f1a

Add architecture diagram

22e351e

Signed-off-by: JeffMboya <[email protected]>

Add docs

a5949f2

Signed-off-by: JeffMboya <[email protected]>

feat(manager): implement basic crud for worker and task

619f118

feat: add magistrala stack

b8fcafc

Signed-off-by: Rodney Osodo <[email protected]>

Merge pull request absmach#23 from JeffMboya/update-docs

a64a13a

NOISSUE - Add architecture diagram

refactor: rename worker to proplet

9453854

Signed-off-by: Rodney Osodo <[email protected]>

fix: add mqtt client

1954269

Signed-off-by: Rodney Osodo <[email protected]>

remove previous scheduler implementation

88fa945

Signed-off-by: Rodney Osodo <[email protected]>

fix: remove oauth URLs

b2f6b48

Signed-off-by: Rodney Osodo <[email protected]>

refactor(manager): combine mqtt handlers to service

a7d1d13

Call subscribe after service has started to subscribe to wildcard topic

Merge pull request absmach#29 from absmach/manager

fecb4c1

PROP- 25 - Implement Manager Service

chore: remove unused files

734c369

Signed-off-by: Rodney Osodo <[email protected]>

fix: add ci for lint and build check

61cc6c7

Signed-off-by: Rodney Osodo <[email protected]>

chore: add apache license

8f789c9

Signed-off-by: Rodney Osodo <[email protected]>

refactor: initialize mqtt client once

723a1e1

Signed-off-by: Rodney Osodo <[email protected]>

docs: change from supermq to magistrala

c00f5c4

Signed-off-by: Rodney Osodo <[email protected]>

fix: cli logging

300de6f

Signed-off-by: Rodney Osodo <[email protected]>

Restructure service.go

9afc108

Signed-off-by: JeffMboya <[email protected]>

Fix errors.go

d8e8738

Signed-off-by: JeffMboya <[email protected]>

replace the fmt.Printf statements with proper logging.

8fe4134

Signed-off-by: JeffMboya <[email protected]>

Fix linter

c6aa347

Signed-off-by: JeffMboya <[email protected]>

Remove repository package

fc8bf0a

Signed-off-by: JeffMboya <[email protected]>

Remove pointers

2039018

Signed-off-by: JeffMboya <[email protected]>

Remove pointers in api

b996405

Signed-off-by: JeffMboya <[email protected]>

JeffMboya added 2 commits December 11, 2024 17:54

Fix duplicate logging

4c2edf4

Signed-off-by: JeffMboya <[email protected]>

fix duplicate logging

d1ba45b

Signed-off-by: JeffMboya <[email protected]>

JeffMboya force-pushed the duplicate-logs branch from 6b19242 to 1dee293 Compare December 11, 2024 14:54

JeffMboya added 7 commits December 12, 2024 15:45

Use pkg/mqtt package in proplet implementation

43d9385

Signed-off-by: JeffMboya <[email protected]>

Fix handleStop/Start command

f5b957c

Signed-off-by: JeffMboya <[email protected]>

Fix handleStop/Start command

513ff20

Signed-off-by: JeffMboya <[email protected]>

defer WASM file parsing to start command

b0ce326

Signed-off-by: JeffMboya <[email protected]>

Update LWT payload

2ccb23b

Signed-off-by: JeffMboya <[email protected]>

Update LWT payload

e6929cc

Signed-off-by: JeffMboya <[email protected]>

Publish LWT on set-up

acf904a

Signed-off-by: JeffMboya <[email protected]>

JeffMboya changed the title ~~NOISSUE - Fix duplicate logging~~ NOISSUE - Enhance Proplet Dec 15, 2024

JeffMboya added 11 commits December 15, 2024 10:37

Fix CI

b31d359

Signed-off-by: JeffMboya <[email protected]>

Fix CI

eb64d6b

Signed-off-by: JeffMboya <[email protected]>

Fix CI

a1930aa

Signed-off-by: JeffMboya <[email protected]>

Fix CI

2afc240

Signed-off-by: JeffMboya <[email protected]>

Fix CI

600baba

Signed-off-by: JeffMboya <[email protected]>

Implement a single runtime for every app

7d17553

Signed-off-by: JeffMboya <[email protected]>

Remove wasm.go

8bdd7ef

Signed-off-by: JeffMboya <[email protected]>

Move runtime methods to runtime.go

d746352

Signed-off-by: JeffMboya <[email protected]>

Rename worker.go to proplet.go

1c0be00

Signed-off-by: JeffMboya <[email protected]>

Consolidate chunk handling

6b89357

Signed-off-by: JeffMboya <[email protected]>

Fix CI

dfdd11c

Signed-off-by: JeffMboya <[email protected]>

JeffMboya self-assigned this Dec 15, 2024

JeffMboya added 2 commits December 15, 2024 21:47

Enable dynamic WASM fucntion name

b25970b

Signed-off-by: JeffMboya <[email protected]>

add method to repare WASM binary

2d5b766

Signed-off-by: JeffMboya <[email protected]>

JeffMboya marked this pull request as ready for review December 15, 2024 19:04

JeffMboya added 2 commits December 15, 2024 23:23

Unify app deployment

1cf4e0b

Signed-off-by: JeffMboya <[email protected]>

Reduce timout time

2ca4de9

Signed-off-by: JeffMboya <[email protected]>

JeffMboya closed this Dec 15, 2024

JeffMboya force-pushed the duplicate-logs branch from 5b899b4 to 2ca4de9 Compare December 15, 2024 21:02

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

NOISSUE - Enhance Proplet #35

NOISSUE - Enhance Proplet #35

JeffMboya commented Dec 11, 2024 •

edited

Loading

NOISSUE - Enhance Proplet #35

NOISSUE - Enhance Proplet #35

Conversation

JeffMboya commented Dec 11, 2024 • edited Loading

What type of PR is this?

What does this do?

Which issue(s) does this PR fix/relate to?

Have you included tests for your changes?

Did you document any new/modified features?

Notes

JeffMboya commented Dec 11, 2024 •

edited

Loading