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 <socials@rodneyosodo.com>

NOISSUE - Proof of Concept For Wasm Orchestrator

Signed-off-by: JeffMboya <jangina.mboya@gmail.com>

Signed-off-by: Rodney Osodo <socials@rodneyosodo.com>

NOISSUE - Add architecture diagram

Signed-off-by: Rodney Osodo <socials@rodneyosodo.com>

Call subscribe after service has started to subscribe to wildcard topic

PROP- 25 - Implement Manager Service

Signed-off-by: Rodney Osodo <socials@rodneyosodo.com>

* chore: remove unused files Signed-off-by: Rodney Osodo <socials@rodneyosodo.com> * fix: add ci for lint and build check Signed-off-by: Rodney Osodo <socials@rodneyosodo.com> * chore: add apache license Signed-off-by: Rodney Osodo <socials@rodneyosodo.com> --------- Signed-off-by: Rodney Osodo <socials@rodneyosodo.com>

Signed-off-by: Rodney Osodo <socials@rodneyosodo.com>

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

Signed-off-by: JeffMboya <jangina.mboya@gmail.com>

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 <socials@rodneyosodo.com>

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 <jangina.mboya@gmail.com>

Add docs

a5949f2

Signed-off-by: JeffMboya <jangina.mboya@gmail.com>

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

619f118

feat: add magistrala stack

b8fcafc

Signed-off-by: Rodney Osodo <socials@rodneyosodo.com>

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 <socials@rodneyosodo.com>

fix: add mqtt client

1954269

Signed-off-by: Rodney Osodo <socials@rodneyosodo.com>

remove previous scheduler implementation

88fa945

Signed-off-by: Rodney Osodo <socials@rodneyosodo.com>

fix: remove oauth URLs

b2f6b48

Signed-off-by: Rodney Osodo <socials@rodneyosodo.com>

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 <socials@rodneyosodo.com>

fix: add ci for lint and build check

61cc6c7

Signed-off-by: Rodney Osodo <socials@rodneyosodo.com>

chore: add apache license

8f789c9

Signed-off-by: Rodney Osodo <socials@rodneyosodo.com>

refactor: initialize mqtt client once

723a1e1

Signed-off-by: Rodney Osodo <socials@rodneyosodo.com>

docs: change from supermq to magistrala

c00f5c4

Signed-off-by: Rodney Osodo <socials@rodneyosodo.com>

fix: cli logging

300de6f

Signed-off-by: Rodney Osodo <socials@rodneyosodo.com>

Restructure service.go

9afc108

Signed-off-by: JeffMboya <jangina.mboya@gmail.com>

Fix errors.go

d8e8738

Signed-off-by: JeffMboya <jangina.mboya@gmail.com>

replace the fmt.Printf statements with proper logging.

8fe4134

Signed-off-by: JeffMboya <jangina.mboya@gmail.com>

Fix linter

c6aa347

Signed-off-by: JeffMboya <jangina.mboya@gmail.com>

Remove repository package

fc8bf0a

Signed-off-by: JeffMboya <jangina.mboya@gmail.com>

Remove pointers

2039018

Signed-off-by: JeffMboya <jangina.mboya@gmail.com>

Remove pointers in api

b996405

Signed-off-by: JeffMboya <jangina.mboya@gmail.com>

JeffMboya added 2 commits December 11, 2024 17:54

Fix duplicate logging

4c2edf4

Signed-off-by: JeffMboya <jangina.mboya@gmail.com>

fix duplicate logging

d1ba45b

Signed-off-by: JeffMboya <jangina.mboya@gmail.com>

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 <jangina.mboya@gmail.com>

Fix handleStop/Start command

f5b957c

Signed-off-by: JeffMboya <jangina.mboya@gmail.com>

Fix handleStop/Start command

513ff20

Signed-off-by: JeffMboya <jangina.mboya@gmail.com>

defer WASM file parsing to start command

b0ce326

Signed-off-by: JeffMboya <jangina.mboya@gmail.com>

Update LWT payload

2ccb23b

Signed-off-by: JeffMboya <jangina.mboya@gmail.com>

Update LWT payload

e6929cc

Signed-off-by: JeffMboya <jangina.mboya@gmail.com>

Publish LWT on set-up

acf904a

Signed-off-by: JeffMboya <jangina.mboya@gmail.com>

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 <jangina.mboya@gmail.com>

Fix CI

eb64d6b

Signed-off-by: JeffMboya <jangina.mboya@gmail.com>

Fix CI

a1930aa

Signed-off-by: JeffMboya <jangina.mboya@gmail.com>

Fix CI

2afc240

Signed-off-by: JeffMboya <jangina.mboya@gmail.com>

Fix CI

600baba

Signed-off-by: JeffMboya <jangina.mboya@gmail.com>

Implement a single runtime for every app

7d17553

Signed-off-by: JeffMboya <jangina.mboya@gmail.com>

Remove wasm.go

8bdd7ef

Signed-off-by: JeffMboya <jangina.mboya@gmail.com>

Move runtime methods to runtime.go

d746352

Signed-off-by: JeffMboya <jangina.mboya@gmail.com>

Rename worker.go to proplet.go

1c0be00

Signed-off-by: JeffMboya <jangina.mboya@gmail.com>

Consolidate chunk handling

6b89357

Signed-off-by: JeffMboya <jangina.mboya@gmail.com>

Fix CI

dfdd11c

Signed-off-by: JeffMboya <jangina.mboya@gmail.com>

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 <jangina.mboya@gmail.com>

add method to repare WASM binary

2d5b766

Signed-off-by: JeffMboya <jangina.mboya@gmail.com>

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 <jangina.mboya@gmail.com>

Reduce timout time

2ca4de9

Signed-off-by: JeffMboya <jangina.mboya@gmail.com>

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