more installers

lib/installers/net/mycelium/.heroscript

@@ -0,0 +1,11 @@
+!!hero_code.generate_installer
+    name: "mycelium"
+    classname: "MyceliumInstaller"
+    hasconfig: false
+    singleton: true
+    default: true
+    title: ""
+    templates: false
+    build: true
+    startupmanager: true
+

lib/installers/net/mycelium/mycelium_actions.v

@@ -0,0 +1,202 @@
+module mycelium
+
+import freeflowuniverse.herolib.osal
+import freeflowuniverse.herolib.ui.console
+import freeflowuniverse.herolib.core.texttools
+import freeflowuniverse.herolib.core.pathlib
+
+import freeflowuniverse.herolib.osal.systemd
+import freeflowuniverse.herolib.osal.zinit
+
+import freeflowuniverse.herolib.installers.ulist
+import freeflowuniverse.herolib.installers.lang.golang
+import freeflowuniverse.herolib.installers.lang.rust
+import freeflowuniverse.herolib.installers.lang.python
+
+import os
+
+fn startupcmd () ![]zinit.ZProcessNewArgs{
+    mut installer := get()!
+    mut res := []zinit.ZProcessNewArgs{}
+    //THIS IS EXAMPLE CODEAND NEEDS TO BE CHANGED
+    // res << zinit.ZProcessNewArgs{
+    //     name: 'mycelium'
+    //     cmd: 'mycelium server'
+    //     env: {
+    //         'HOME': '/root'
+    //     }    
+    // }
+
+    return res
+    
+}
+
+fn running() !bool {
+    mut installer := get()!
+    //THIS IS EXAMPLE CODEAND NEEDS TO BE CHANGED
+    // this checks health of mycelium
+    // curl http://localhost:3333/api/v1/s --oauth2-bearer 1234 works
+    // url:='http://127.0.0.1:${cfg.port}/api/v1'
+    // mut conn := httpconnection.new(name: 'mycelium', url: url)!
+
+    // if cfg.secret.len > 0 {
+    //     conn.default_header.add(.authorization, 'Bearer ${cfg.secret}')
+    // }
+    // conn.default_header.add(.content_type, 'application/json')
+    // console.print_debug("curl -X 'GET' '${url}'/tags --oauth2-bearer ${cfg.secret}")
+    // r := conn.get_json_dict(prefix: 'tags', debug: false) or {return false}
+    // println(r)
+    // if true{panic("ssss")}
+    // tags := r['Tags'] or { return false }
+    // console.print_debug(tags)
+    // console.print_debug('mycelium is answering.')
+    return false
+}
+
+fn start_pre()!{
+    
+}
+
+fn start_post()!{
+    
+}
+
+fn stop_pre()!{
+    
+}
+
+fn stop_post()!{
+    
+}
+
+
+//////////////////// following actions are not specific to instance of the object
+
+// checks if a certain version or above is installed
+fn installed() !bool {
+    //THIS IS EXAMPLE CODEAND NEEDS TO BE CHANGED
+    // res := os.execute('${osal.profile_path_source_and()} mycelium version')
+    // if res.exit_code != 0 {
+    //     return false
+    // }
+    // r := res.output.split_into_lines().filter(it.trim_space().len > 0)
+    // if r.len != 1 {
+    //     return error("couldn't parse mycelium version.\n${res.output}")
+    // }
+    // if texttools.version(version) == texttools.version(r[0]) {
+    //     return true
+    // }
+    return false
+}
+
+//get the Upload List of the files
+fn ulist_get() !ulist.UList {
+    //optionally build a UList which is all paths which are result of building, is then used e.g. in upload
+    return ulist.UList{}
+}
+
+//uploads to S3 server if configured
+fn upload() ! {
+    // installers.upload(
+    //     cmdname: 'mycelium'
+    //     source: '${gitpath}/target/x86_64-unknown-linux-musl/release/mycelium'
+    // )!
+
+}
+
+fn install() ! {
+    console.print_header('install mycelium')
+    //THIS IS EXAMPLE CODEAND NEEDS TO BE CHANGED
+    // mut url := ''
+    // if osal.is_linux_arm() {
+    //     url = 'https://github.com/mycelium-dev/mycelium/releases/download/v${version}/mycelium_${version}_linux_arm64.tar.gz'
+    // } else if osal.is_linux_intel() {
+    //     url = 'https://github.com/mycelium-dev/mycelium/releases/download/v${version}/mycelium_${version}_linux_amd64.tar.gz'
+    // } else if osal.is_osx_arm() {
+    //     url = 'https://github.com/mycelium-dev/mycelium/releases/download/v${version}/mycelium_${version}_darwin_arm64.tar.gz'
+    // } else if osal.is_osx_intel() {
+    //     url = 'https://github.com/mycelium-dev/mycelium/releases/download/v${version}/mycelium_${version}_darwin_amd64.tar.gz'
+    // } else {
+    //     return error('unsported platform')
+    // }
+
+    // mut dest := osal.download(
+    //     url: url
+    //     minsize_kb: 9000
+    //     expand_dir: '/tmp/mycelium'
+    // )!
+
+    // //dest.moveup_single_subdir()!
+
+    // mut binpath := dest.file_get('mycelium')!
+    // osal.cmd_add(
+    //     cmdname: 'mycelium'
+    //     source: binpath.path
+    // )!
+}
+
+fn build() ! {
+    //url := 'https://github.com/threefoldtech/mycelium'
+
+    // make sure we install base on the node
+    // if osal.platform() != .ubuntu {
+    //     return error('only support ubuntu for now')
+    // }
+    // golang.install()!
+
+    // console.print_header('build mycelium')
+
+    // gitpath := gittools.get_repo(coderoot: '/tmp/builder', url: url, reset: true, pull: true)!
+
+    // cmd := '
+    // cd ${gitpath}
+    // source ~/.cargo/env
+    // exit 1 #todo
+    // '
+    // osal.execute_stdout(cmd)!
+    //
+    // //now copy to the default bin path
+    // mut binpath := dest.file_get('...')!
+    // adds it to path
+    // osal.cmd_add(
+    //     cmdname: 'griddriver2'
+    //     source: binpath.path
+    // )!   
+
+}
+
+fn destroy() ! {
+
+    // mut systemdfactory := systemd.new()!
+    // systemdfactory.destroy("zinit")!
+
+    // osal.process_kill_recursive(name:'zinit')!
+    // osal.cmd_delete('zinit')!
+
+    // osal.package_remove('
+    //    podman
+    //    conmon
+    //    buildah
+    //    skopeo
+    //    runc
+    // ')!
+
+    // //will remove all paths where go/bin is found
+    // osal.profile_path_add_remove(paths2delete:"go/bin")!
+
+    // osal.rm("
+    //    podman
+    //    conmon
+    //    buildah
+    //    skopeo
+    //    runc
+    //    /var/lib/containers
+    //    /var/lib/podman
+    //    /var/lib/buildah
+    //    /tmp/podman
+    //    /tmp/conmon
+    // ")!
+
+
+}
+

lib/installers/net/mycelium/mycelium_factory_.v

@@ -0,0 +1,160 @@
+
+module mycelium
+
+import freeflowuniverse.herolib.core.base
+import freeflowuniverse.herolib.core.playbook
+import freeflowuniverse.herolib.ui.console
+
+import freeflowuniverse.herolib.sysadmin.startupmanager
+import freeflowuniverse.herolib.osal.zinit
+import time
+
+__global (
+    mycelium_global map[string]&MyceliumInstaller
+    mycelium_default string
+)
+
+/////////FACTORY
+
+@[params]
+pub struct ArgsGet{
+pub mut:
+    name string
+}
+
+pub fn get(args_ ArgsGet) !&MyceliumInstaller  {
+    return &MyceliumInstaller{}
+}
+
+
+
+////////////////////////////////////////////////////////////////////////////////////////////////////
+//////////////////////////# LIVE CYCLE MANAGEMENT FOR INSTALLERS ///////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////////////////////////
+
+fn startupmanager_get(cat zinit.StartupManagerType) !startupmanager.StartupManager {
+    // unknown
+    // screen
+    // zinit
+    // tmux
+    // systemd
+    match cat{
+        .zinit{
+            console.print_debug("startupmanager: zinit")
+            return startupmanager.get(cat:.zinit)!
+        }
+        .systemd{
+            console.print_debug("startupmanager: systemd")
+            return startupmanager.get(cat:.systemd)!
+        }else{
+            console.print_debug("startupmanager: auto")
+            return startupmanager.get()!
+        }
+    }
+}
+
+
+pub fn (mut self MyceliumInstaller) start() ! {
+    switch(self.name)
+    if self.running()!{
+        return
+    }
+
+    console.print_header('mycelium start')
+
+    if ! installed()!{
+        install()!
+    }
+
+    configure()!
+
+    start_pre()!
+
+    for zprocess in startupcmd()!{
+        mut sm:=startupmanager_get(zprocess.startuptype)!
+
+        console.print_debug('starting mycelium with ${zprocess.startuptype}...')
+
+        sm.new(zprocess)!
+
+        sm.start(zprocess.name)!
+    }
+
+    start_post()!
+
+    for _ in 0 .. 50 {
+        if self.running()! {
+            return
+        }
+        time.sleep(100 * time.millisecond)
+    }
+    return error('mycelium did not install properly.')
+
+}
+
+pub fn (mut self MyceliumInstaller) install_start(model InstallArgs) ! {
+    switch(self.name)
+    self.install(model)!
+    self.start()!
+}
+
+pub fn (mut self MyceliumInstaller) stop() ! {
+    switch(self.name)
+    stop_pre()!
+    for zprocess in startupcmd()!{
+        mut sm:=startupmanager_get(zprocess.startuptype)!
+        sm.stop(zprocess.name)!
+    }
+    stop_post()!
+}
+
+pub fn (mut self MyceliumInstaller) restart() ! {
+    switch(self.name)
+    self.stop()!
+    self.start()!
+}
+
+pub fn (mut self MyceliumInstaller) running() !bool {
+    switch(self.name)
+
+    //walk over the generic processes, if not running return
+    for zprocess in startupcmd()!{
+        mut sm:=startupmanager_get(zprocess.startuptype)!
+        r:=sm.running(zprocess.name)!
+        if r==false{
+            return false
+        }
+    }
+    return running()!
+}
+
+@[params]
+pub struct InstallArgs{
+pub mut:
+    reset bool
+}
+
+pub fn (mut self MyceliumInstaller) install(model InstallArgs) ! {
+    switch(self.name)
+    if model.reset || (!installed()!) {
+        install()!
+    }    
+}
+
+pub fn (mut self MyceliumInstaller) build() ! {
+    switch(self.name)
+    build()!
+}
+
+pub fn (mut self MyceliumInstaller) destroy() ! {
+    switch(self.name)
+    self.stop() or {}
+    destroy()!
+}
+
+
+
+//switch instance to be used for mycelium
+pub fn switch(name string) {
+    mycelium_default = name
+}

lib/installers/net/mycelium/mycelium_model.v

@@ -0,0 +1,30 @@
+module mycelium
+import freeflowuniverse.herolib.data.paramsparser
+import os
+
+pub const version = '0.0.0'
+const singleton = true
+const default = true
+
+
+//THIS THE THE SOURCE OF THE INFORMATION OF THIS FILE, HERE WE HAVE THE CONFIG OBJECT CONFIGURED AND MODELLED
+$[heap]
+pub struct MyceliumInstaller {
+pub mut:
+    name string = 'default'
+}
+
+
+fn obj_init(obj_ MyceliumInstaller)!MyceliumInstaller{
+    //never call get here, only thing we can do here is work on object itself
+    mut obj:=obj_
+    panic("implement")
+    return obj
+}
+
+//called before start if done
+fn configure() ! {
+    //mut installer := get()!
+}
+
+