Correction version

.gitignore

@@ -0,0 +1 @@
+oc.json

Makefile

@@ -0,0 +1,17 @@
+ifndef OC_VERSION
+$(error OC_VERSION is not set)
+endif
+
+PUBLISH_REPO := "na/oc-version"
+PUBLISH_TOKEN := "61bcebe3a6ffa67ae88adeb49825d94d212889eb"
+PUBLISH_BRANCH := $(shell git rev-parse --abbrev-ref HEAD)
+
+.PHONY: publish
+publish:
+	@echo Publication de : ${OC_VERSION}
+	@(cd publish && \
+	PUBLISH_REPO=${PUBLISH_REPO} \
+	PUBLISH_TOKEN=${PUBLISH_TOKEN} \
+        PUBLISH_BRANCH=${PUBLISH_BRANCH} \
+	go run main.go ${OC_VERSION})
+

latest.yml

@@ -1,3 +1,3 @@
 ---
 
-version: 0.0.1
+version: 0.1.0

oc_0.1.0.yml

@@ -12,13 +12,26 @@ tools:
     version: v3.16.0
 
 opencloud:
-  - name: opencloud-0.1.0
-    repository: https://harbor.dtf/dev
+  - oci:
+      url: oci://harbor.dtf/dev
     charts:
       - name: oc-mongo
         version: 0.1.0
+        helm_opts: --insecure-skip-tls-verify
+        helm_filevalues:
+        - values.yml
       - name: oc-catalog
         version: 0.1.0
+        helm_opts: --insecure-skip-tls-verify
+        helm_filevalues:
+        - values.yml
       - name: oc-shared
         version: 0.1.0
+        helm_opts: --insecure-skip-tls-verify
+        helm_filevalues:
+        - values.yml
       - name: oc-workspace
+        version: 0.1.0
+        helm_opts: --insecure-skip-tls-verify
+        helm_filevalues:
+        - values.yml

publish/.gitignore

@@ -0,0 +1,3 @@
+go.sum
+*_
+.coverage.*

publish/go.mod

@@ -0,0 +1,3 @@
+module oc-publish
+
+go 1.22.2

publish/main.go

@@ -0,0 +1,87 @@
+package main
+
+import (
+	"fmt"
+	"os"
+	"io"
+	"encoding/base64"
+	"oc-publish/releases"
+	"oc-publish/occonst"
+)
+
+func main() {
+
+	version := os.Args[1]
+
+	fmt.Printf(" >> oc-publish :\n")
+
+	fmt.Printf(" <<   Url : %s/%s\n", occonst.PUBLISH_URL, occonst.PUBLISH_REPO)
+
+	fmt.Printf(" <<   version : %s %s\n", version, occonst.PUBLISH_BRANCH)
+
+	vversion := fmt.Sprintf("v%s", version)
+	existe, _ := releases.CheckRelease(vversion)
+
+    if existe == false {
+        err := releases.CreateRelease(vversion, occonst.PUBLISH_BRANCH)
+        if err != nil {
+            fmt.Println(err)
+            os.Exit(1)
+        }
+    }
+
+    idRelease, _ := releases.GetReleaseId(vversion)
+    if  existe == true {
+        fmt.Println(fmt.Sprintf(" <<   Release existante : %d ", idRelease))
+    } else {
+        fmt.Println(fmt.Sprintf(" <<   Release crée : %d ", idRelease))
+    }
+
+	assetname := "oc.json"
+	ficversion := fmt.Sprintf("../oc_%s.yml", version)
+	ficjson := fmt.Sprintf("../%s", assetname)
+	err := createJsonFile(ficversion, ficjson)
+    if err != nil {
+        fmt.Println(err)
+        os.Exit(1)
+    }
+
+    idAsset, _ := releases.GetAssetId(idRelease, assetname)
+    if idAsset == 0 {
+        fmt.Println(fmt.Sprintf(" <<   Ajout Asset : %s", assetname))
+        err := releases.CreateAsset(idRelease, ficjson, assetname)
+        if err != nil {
+            fmt.Println(err)
+            os.Exit(1)
+        }    
+    } else {
+        fmt.Println(fmt.Sprintf(" <<   Mise à jour : %s (idAsset=%d) ", assetname, idAsset))
+        err := releases.UpdateAsset(idRelease, idAsset, ficjson, assetname)
+        if err != nil {
+            fmt.Println(err)
+            os.Exit(1)
+        }    
+    }
+
+}
+
+
+func createJsonFile(ficversion string, jsonfile string) error {
+    fout, _ := os.Create(jsonfile)
+	defer fout.Close()
+
+    fin, err := os.Open(ficversion)
+    if err != nil {
+        return err
+    }
+    defer fin.Close()
+    byteValue, err := io.ReadAll(fin)
+
+	// data := "abc123!?$*&()'-=@~"
+	data64 := base64.StdEncoding.EncodeToString(byteValue)
+
+    content := fmt.Sprintf(`{"value": "%s"}`, data64)
+    fout.Write([]byte(content))
+    fout.Write([]byte("\n"))
+	return nil
+}

publish/occonst/variables.go

@@ -0,0 +1,18 @@
+package occonst
+
+import (
+	"os"
+)
+
+var PUBLISH_URL = getenv("PUBLISH_URL", "https://cloud.o-forge.io")
+var PUBLISH_REPO = getenv("PUBLISH_REPO", "core/oc-version")
+var PUBLISH_TOKEN = getenv("PUBLISH_TOKEN", "")
+var PUBLISH_BRANCH = getenv("PUBLISH_BRANCH", "main")
+
+func getenv(key string, defaut string) string {
+	value := os.Getenv(key)
+	if len(value) == 0 {
+		return defaut
+	}
+	return value
+}

publish/releases/assets.go

@@ -0,0 +1,145 @@
+package releases
+
+import (
+    "fmt"
+    "os"
+    "path/filepath"
+    "mime/multipart"
+    "io"
+    "io/ioutil"
+    "encoding/json"
+    "net/http"
+    "bytes"
+
+    "oc-publish/occonst"
+)
+
+type assetStruct struct {
+    Name string `json:"name"`
+    Id int `json:"id"`
+}
+
+func GetAssetId(idRelease int, name string) (int, error) {
+    url := fmt.Sprintf("%s/api/v1/repos/%s/releases/%d/assets",
+                        occonst.PUBLISH_URL,
+                        occonst.PUBLISH_REPO,
+                        idRelease)
+
+    res, err := http.Get(url)
+    if err != nil {
+        return -1, err
+    }
+    body, err := io.ReadAll(res.Body)
+    if err != nil {
+        return -2, err
+    }
+
+    var data []assetStruct
+
+    err = json.Unmarshal(body, &data)
+    if err != nil {
+        return -3, err
+    }
+
+    for _, ele := range data {
+        if ele.Name == name {
+            return ele.Id, nil
+        }
+    }
+    return 0, nil
+}
+
+// curl -X 'POST' \
+//   'https://cloud.o-forge.io/api/v1/repos/core/oc-deploy/releases/2/assets?name=zzzz' \
+//   -H 'accept: application/json' \
+//   -H 'Content-Type: multipart/form-data' \
+//   -F 'attachment=oc-deploy'
+func CreateAsset(idRelease int, filename string, name string) (error) {
+    url := fmt.Sprintf("%s/api/v1/repos/%s/releases/%d/assets?name=%s&token=%s",
+                        occonst.PUBLISH_URL,
+                        occonst.PUBLISH_REPO,
+                        idRelease,
+                        name,
+                        occonst.PUBLISH_TOKEN)
+
+    err := uploadFile(url, "attachment", filename)
+
+    return err 
+}
+
+func UpdateAsset(idRelease int, idAsset int, filename string, name string) (error) {
+
+  url := fmt.Sprintf("%s/api/v1/repos/%s/releases/%d/assets/%d?token=%s",
+            occonst.PUBLISH_URL,
+            occonst.PUBLISH_REPO,
+            idRelease,
+            idAsset,
+            occonst.PUBLISH_TOKEN)
+
+    // Create client
+    client := &http.Client{}
+
+    // Create request
+    req, err := http.NewRequest("DELETE", url, nil)
+    if err != nil {
+        return err
+    }
+
+    // Fetch Request
+    resp, err := client.Do(req)
+    if err != nil {
+        return err
+    }
+    defer resp.Body.Close()
+
+    // Read Response Body
+    respBody, err := ioutil.ReadAll(resp.Body)
+    if err != nil {
+        return err
+    }
+    fmt.Println(string(respBody))
+
+  return CreateAsset(idRelease, filename, name)
+}
+
+func uploadFile(url string, paramName string, filePath string) error {
+    file, err := os.Open(filePath)
+    if err != nil {
+      return err
+    }
+    defer file.Close()
+
+    body := &bytes.Buffer{}
+    writer := multipart.NewWriter(body)
+    part, err := writer.CreateFormFile(paramName, filepath.Base(filePath))
+    if err != nil {
+      return err
+    }
+    _, err = io.Copy(part, file)
+  
+    err = writer.Close()
+    if err != nil {
+      return err
+    }
+  
+    request, err := http.NewRequest("POST", url, body)
+    request.Header.Add("Content-Type", writer.FormDataContentType())
+    request.Header.Add("accept", "application/json")
+    client := &http.Client{}
+    response, err := client.Do(request)
+
+    if err != nil {
+      fmt.Println(109, err)
+      return err
+    }
+    defer response.Body.Close()
+  
+    if response.StatusCode > 400 {
+        return fmt.Errorf(response.Status)
+  }
+
+    _, err1 := io.ReadAll(response.Body)
+
+    // Handle the server response...
+    return err1
+  }

publish/releases/release.go

@@ -0,0 +1,126 @@
+package releases
+
+import (
+	"fmt"
+	"io"
+	"io/ioutil"
+    "strings"
+    "encoding/json"
+    "net/http"
+
+	"oc-publish/occonst"
+)
+
+type checkStruct struct {
+    Name string `json:"name"`
+    Id int `json:"id"`
+}
+
+func CheckRelease(version string) (bool, error) {
+	url := fmt.Sprintf("%s/api/v1/repos/%s/releases",
+						occonst.PUBLISH_URL,
+						occonst.PUBLISH_REPO)
+
+    res, err := http.Get(url)
+    if err != nil {
+        return false, err
+    }
+    body, err := io.ReadAll(res.Body)
+    if err != nil {
+        return false, err
+    }
+
+	var data []checkStruct
+    err = json.Unmarshal(body, &data)
+    if err != nil {
+        return false, err
+    }
+
+    for _, ele := range data {
+        if ele.Name == version {
+            return true, nil
+        }
+    }
+	// return data.Name != "", nil
+    return false, nil
+}
+
+func GetReleaseId(version string) (int, error) {
+	url := fmt.Sprintf("%s/api/v1/repos/%s/releases/tags/%s",
+						occonst.PUBLISH_URL,
+						occonst.PUBLISH_REPO,
+						version)
+
+    res, err := http.Get(url)
+    if err != nil {
+        return 0, err
+    }
+    body, err := io.ReadAll(res.Body)
+    if err != nil {
+        return 0, err
+    }
+
+	var data checkStruct
+    err = json.Unmarshal(body, &data)
+    if err != nil {
+        return 0, err
+    }
+
+	return data.Id, nil
+}
+
+// curl -X 'POST' \
+//   'https://cloud.o-forge.io/api/v1/repos/na/oc-version/releases?token=sss' \
+//   -H 'accept: application/json' \
+//   -H 'Content-Type: application/json' \
+//   -d '{
+//   "body": "string",
+//   "draft": true,
+//   "name": "string",
+//   "prerelease": true,
+//   "tag_name": "string",
+//   "target_commitish": "string"
+// }'
+func CreateRelease(version string, branch string) (error) {
+	url := fmt.Sprintf("%s/api/v1/repos/%s/releases?token=%s",
+						occonst.PUBLISH_URL,
+						occonst.PUBLISH_REPO,
+						occonst.PUBLISH_TOKEN)
+
+    releasebytes, err := ioutil.ReadFile("release.txt")
+    releasetxt := string(releasebytes)
+    releasetxt = strings.Replace(releasetxt, "\n", "\\n", -1)
+    releasetxt = fmt.Sprintf(releasetxt, version, occonst.PUBLISH_URL, occonst.PUBLISH_REPO, version)
+
+    body := fmt.Sprintf(`{
+    "body": "%s",
+    "draft": false,
+    "name": "%s",
+    "prerelease": false,
+    "tag_name": "%s",
+    "target_commitish": "%s"
+}`, releasetxt, version, version, branch)
+
+    request, err := http.NewRequest("POST", url, strings.NewReader(body))
+    if err != nil {
+        return err
+    }
+    request.Header.Add("accept", "application/json")
+    request.Header.Add("Content-Type", "application/json")
+
+    client := &http.Client{}
+    response, err := client.Do(request)
+    if err != nil {
+        return err
+    }
+    defer response.Body.Close()
+
+    _, err1 := io.ReadAll(response.Body)
+    // cnt, err1 := io.ReadAll(response.Body)
+    // fmt.Println(string(cnt))
+
+    if err1 != nil {
+        return err1
+    }
+    return nil
+}