From 578a270932eaf9112f90a0034c23da2149729ec5 Mon Sep 17 00:00:00 2001
From: Jan Eitzinger <jan@moebiusband.org>
Date: Thu, 9 Nov 2023 06:19:53 +0100
Subject: [PATCH] Start to port API

---
 pkg/archive/s3Backend.go | 65 +++++++++++++++++++++++++++++++++++++++-
 1 file changed, 64 insertions(+), 1 deletion(-)

diff --git a/pkg/archive/s3Backend.go b/pkg/archive/s3Backend.go
index e204074..26471b0 100644
--- a/pkg/archive/s3Backend.go
+++ b/pkg/archive/s3Backend.go
@@ -4,10 +4,73 @@
 // license that can be found in the LICENSE file.
 package archive
 
+import (
+	"encoding/json"
+
+	"github.com/ClusterCockpit/cc-backend/pkg/log"
+	"github.com/ClusterCockpit/cc-backend/pkg/schema"
+	"github.com/minio/minio-go/v7"
+	"github.com/minio/minio-go/v7/pkg/credentials"
+)
+
 type S3ArchiveConfig struct {
-	Path string `json:"filePath"`
+	Endpoint        string `json:"endpoint"`
+	AccessKeyID     string `json:"accessKeyID"`
+	SecretAccessKey string `json:"secretAccessKey"`
+	UseSSL          bool   `json:"useSSL"`
 }
 
 type S3Archive struct {
 	path string
 }
+
+func (s3a *S3Archive) Init(rawConfig json.RawMessage) (uint64, error) {
+	var config S3ArchiveConfig
+	if err := json.Unmarshal(rawConfig, &config); err != nil {
+		log.Warnf("Init() > Unmarshal error: %#v", err)
+		return 0, err
+	}
+
+	client, err := minio.New(config.Endpoint, &minio.Options{
+		Creds:  credentials.NewStaticV4(config.AccessKeyID, config.SecretAccessKey, ""),
+		Secure: config.UseSSL,
+	})
+	if err != nil {
+		log.Fatalln(err)
+	}
+
+	return 0, err
+}
+
+func (s3a *S3Archive) Info() {
+}
+
+func (s3a *S3Archive) Exists(job *schema.Job) bool {
+}
+
+func (s3a *S3Archive) LoadJobMeta(job *schema.Job) (*schema.JobMeta, error) {
+}
+
+func (s3a *S3Archive) LoadJobData(job *schema.Job) (schema.JobData, error) {
+}
+
+func (s3a *S3Archive) LoadClusterCfg(name string) (*schema.Cluster, error) {
+}
+
+func (s3a *S3Archive) StoreJobMeta(jobMeta *schema.JobMeta) error
+
+func (s3a *S3Archive) ImportJob(jobMeta *schema.JobMeta, jobData *schema.JobData) error
+
+func (s3a *S3Archive) GetClusters() []string
+
+func (s3a *S3Archive) CleanUp(jobs []*schema.Job)
+
+func (s3a *S3Archive) Move(jobs []*schema.Job, path string)
+
+func (s3a *S3Archive) Clean(before int64, after int64)
+
+func (s3a *S3Archive) Compress(jobs []*schema.Job)
+
+func (s3a *S3Archive) CompressLast(starttime int64) int64
+
+func (s3a *S3Archive) Iter(loadMetricData bool) <-chan JobContainer