Add config

Author: hazim1093

README.md

@@ -1,2 +1,9 @@
 # slack-operator
 Kubernetes operator for Slack
+
+# TODO: 
+ - Readme for slack app/token creation
+ - Update to operator v1.0.0
+ - CRD tests for deletion and users invite scenario
+ - Webhooks
+ - Scenario: rename to existing channel, then delete the CRD what will happen?: ID will be of the channel we want to delete so no issue?

config/operator/default-config.yaml

@@ -0,0 +1,4 @@
+slack:
+  APIToken:
+    secretName: "slack-secret"
+    key: APIToken

config/samples/slack-secret.yaml

@@ -0,0 +1,7 @@
+apiVersion: v1
+kind: Secret
+metadata:
+  name: slack-secret
+type: Opaque
+data:
+  APIToken: eG94Yi0xMjM0NTY3ODktMTIzNDU0MzIxLWFiY2RlZmdoaWprbG1ub3BxcnN0dXZ3eHl6

main.go

@@ -17,18 +17,23 @@ limitations under the License.
 package main
 
 import (
+	"context"
 	"flag"
 	"os"
 
+	v1 "k8s.io/api/core/v1"
 	"k8s.io/apimachinery/pkg/runtime"
+	"k8s.io/apimachinery/pkg/types"
 	utilruntime "k8s.io/apimachinery/pkg/util/runtime"
 	clientgoscheme "k8s.io/client-go/kubernetes/scheme"
 	_ "k8s.io/client-go/plugin/pkg/client/auth/gcp"
 	ctrl "sigs.k8s.io/controller-runtime"
+	"sigs.k8s.io/controller-runtime/pkg/client"
 	"sigs.k8s.io/controller-runtime/pkg/log/zap"
 
 	slackv1alpha1 "github.com/stakater/slack-operator/api/v1alpha1"
 	"github.com/stakater/slack-operator/controllers"
+	"github.com/stakater/slack-operator/pkg/config"
 	slack "github.com/stakater/slack-operator/pkg/slack"
 	// +kubebuilder:scaffold:imports
 )
@@ -68,11 +73,19 @@ func main() {
 		os.Exit(1)
 	}
 
+	config, err := config.GetOperatorConfig()
+	if err != nil {
+		setupLog.Error(err, "Unable to read operator config")
+		os.Exit(1)
+	}
+
+	slackAPIToken := readSlackTokenSecret(config, mgr.GetAPIReader())
+
 	if err = (&controllers.ChannelReconciler{
 		Client:       mgr.GetClient(),
 		Log:          ctrl.Log.WithName("controllers").WithName("Channel"),
 		Scheme:       mgr.GetScheme(),
-		SlackService: slack.New("", ctrl.Log.WithName("service").WithName("Slack")), //TODO: get from config
+		SlackService: slack.New(slackAPIToken, ctrl.Log.WithName("service").WithName("Slack")),
 	}).SetupWithManager(mgr); err != nil {
 		setupLog.Error(err, "unable to create controller", "controller", "Channel")
 		os.Exit(1)
@@ -92,3 +105,26 @@ func main() {
 		os.Exit(1)
 	}
 }
+
+func readSlackTokenSecret(config *config.Config, k8sReader client.Reader) string {
+	secretName := config.Slack.APIToken.SecretName
+	secretKey := config.Slack.APIToken.Key
+
+	secret := &v1.Secret{}
+	setupLog.Info(os.Getenv("OPERATOR_NAMESPACE"))
+	//TODO: get Operator namespace
+	err := k8sReader.Get(context.TODO(), types.NamespacedName{Name: secretName, Namespace: "namnplats"}, secret)
+
+	if err != nil {
+		setupLog.Error(err, "Could not read secret")
+		os.Exit(1)
+	}
+	token := string(secret.Data[secretKey])
+
+	if token == "" {
+		setupLog.Error(nil, "Could not read API token from key", "secretName", secretName, "secretKey", secretKey)
+		os.Exit(1)
+	}
+
+	return token
+}

pkg/config/config.go

@@ -0,0 +1,60 @@
+package config
+
+import (
+	"io/ioutil"
+	"os"
+
+	"gopkg.in/yaml.v2"
+	"sigs.k8s.io/controller-runtime/pkg/log/zap"
+)
+
+// Config struct for operator config yaml
+type Config struct {
+	Slack Slack `yaml:"slack"`
+}
+
+// Slack for config yaml structure
+type Slack struct {
+	APIToken APIToken `yaml:"APIToken"`
+}
+
+// APIToken for config yaml structure
+type APIToken struct {
+	SecretName string `yaml:"secretName"`
+	Key        string `yaml:"key"`
+}
+
+var log = zap.Logger(true)
+
+func readConfig(filePath string) (*Config, error) {
+	var config Config
+
+	// Read YML
+	source, err := ioutil.ReadFile(filePath)
+	if err != nil {
+		return nil, err
+	}
+
+	// Unmarshall
+	err = yaml.Unmarshal(source, &config)
+	if err != nil {
+		return nil, err
+	}
+
+	return &config, nil
+}
+
+// GetOperatorConfig returns the config object for the operator
+func GetOperatorConfig() (*Config, error) {
+	configFilePath := os.Getenv("CONFIG_FILE_PATH")
+	if len(configFilePath) == 0 {
+		configFilePath = "config/operator/default-config.yaml"
+	}
+
+	log.Info("Reading config file", "configFilePath", configFilePath)
+	config, err := readConfig(configFilePath)
+	if err != nil {
+		return nil, err
+	}
+	return config, nil
+}