Merge pull request #1 from WyriHaximusNet/add-docker-image

Add Docker image building blocks

Author: WyriHaximus

Dockerfile

@@ -0,0 +1,6 @@
+FROM flant/shell-operator:latest-alpine3.12
+
+RUN apk add --no-cache redis
+
+ADD hooks /hooks
+ADD engine /engine

engine/add.sh

@@ -0,0 +1,42 @@
+#!/usr/bin/env bash
+
+json=$(echo "$1")
+name=$(echo "$json" | jq -r '.metadata.name')
+namespace=$(echo "$json" | jq -r '.metadata.namespace')
+kind=$(echo "$json" | jq -r '.kind')
+secret=$(echo "$json" | jq -r '.spec.secret.name')
+read=$(echo "$json" | jq -r '.spec.service.read')
+write=$(echo "$json" | jq -r '.spec.service.read')
+echo "${namespace}/${name} object is added"
+echo "${namespace}/${secret} is target secret"
+echo "${read} is read service"
+echo "${write} is write service"
+
+(kubectl get secret -n "${namespace}" "${secret}")
+if [[ "$?" == "1" ]] ; then
+  maxDatabases=$(redis-cli -u "${write}" CONFIG GET databases | grep -v databases)
+  redisServerIsKnown=$(kubectl get configmap redis-database-assignment-operator-in-use-dbs-list -o json | jq -r -c '.data.dbs' | jq -r ".\"${write}\"" | wc -l)
+  if [[ "$redisServerIsKnown" == "1" ]] ; then
+      kubectl create configmap redis-database-assignment-operator-in-use-dbs-list --from-literal=dbs=$(kubectl get configmap redis-database-assignment-operator-in-use-dbs-list -o json | jq -r '.data.dbs' | jq -r ". * {\"${write}\": {}}" | jq -c) --dry-run -o yaml | kubectl apply -f -
+      for i in $(seq 0 $maxDatabases);
+      do
+          kubectl create configmap redis-database-assignment-operator-in-use-dbs-list --from-literal=dbs=$(kubectl get configmap redis-database-assignment-operator-in-use-dbs-list -o json | jq -r '.data.dbs' | jq -r ". * {\"${write}\": {\"db${i}\": \"free\"}}" | jq -c) --dry-run -o yaml | kubectl apply -f -
+      done
+  fi
+
+  echo "Secret ${namespace}/${secret} doesn't exist"
+
+  for i in $(seq 0 $maxDatabases);
+  do
+      isDatabaseFree=$(kubectl get configmap redis-database-assignment-operator-in-use-dbs-list -o json | jq -r '.data.dbs' | jq ".[\"${write}\"].db${i}" | grep free | wc -l)
+      if [[ "$isDatabaseFree" == "1" ]] ; then
+        echo "Database ${i} is available"
+        kubectl create secret generic "${secret}" -n "${namespace}" --from-literal=database="${i}" --from-literal=read="${read}" --from-literal=write="${write}"
+        kubectl create configmap redis-database-assignment-operator-in-use-dbs-list --from-literal=dbs=$(kubectl get configmap redis-database-assignment-operator-in-use-dbs-list -o json | jq -r '.data.dbs' | jq -r ". * {\"${write}\": {\"db${i}\": \"${namespace}/${secret}\"}}" | jq -c) --dry-run -o yaml | kubectl apply -f -
+        echo "Database ${i} has now been claimed"
+        break
+      fi
+  done
+else
+  echo "Secret ${namespace}/${secret} exists, no need to do anything"
+fi

hooks/add.sh

@@ -0,0 +1,20 @@
+#!/usr/bin/env bash
+
+if [[ $1 == "--config" ]] ; then
+  cat <<EOF
+{
+  "configVersion":"v1",
+  "kubernetes":[{
+    "apiVersion": "wyrihaximus.net/v1",
+    "kind": "RedisDatabase",
+    "executeHookOnEvent":["Added"]
+  }]
+}
+EOF
+else
+  type=$(jq -r '.[0].type' ${BINDING_CONTEXT_PATH})
+  echo "Event: ${type}"
+  if [[ $type == "Event" ]] ; then
+    /engine/add.sh $(jq -r -c '.[0].object' ${BINDING_CONTEXT_PATH})
+  fi
+fi

hooks/start-up.sh

@@ -0,0 +1,25 @@
+#!/usr/bin/env bash
+
+if [[ $1 == "--config" ]] ; then
+  cat <<EOF
+{
+  "configVersion":"v1",
+  "kubernetes":[{
+    "apiVersion": "wyrihaximus.net/v1",
+    "kind": "RedisDatabase",
+    "executeHookOnEvent":["Added"]
+  }]
+}
+EOF
+else
+  type=$(jq -r '.[0].type' ${BINDING_CONTEXT_PATH})
+  echo "Event: ${type}"
+  if [[ $type == "Synchronization" ]] ; then
+    /engine/init-global-database.sh
+    count=$(jq -c '.[0].objects | .[] | .object' ${BINDING_CONTEXT_PATH} | wc -l)
+    if [[ "$count" != "0" ]] ; then
+      echo "Synchronizing existing redis databases"
+      jq -c '.[0].objects | .[] | .object' ${BINDING_CONTEXT_PATH} | tr '\n' '\0' | xargs -0 /engine/add.sh
+    fi
+  fi
+fi