From 707f49b83fac46c77cb10acb5ce370aa7d148eb2 Mon Sep 17 00:00:00 2001
From: kodumbeats <brandon.leckemby@gmail.com>
Date: Thu, 17 Jun 2021 17:58:35 -0400
Subject: [PATCH] Set up database worker

---
 app/init.php             |  9 +++++++++
 app/workers/database.php |  6 +++++-
 docker-compose.yml       | 29 +++++++++++++++++++++++++++++
 3 files changed, 43 insertions(+), 1 deletion(-)

diff --git a/app/init.php b/app/init.php
index f79ef3270..d62e50af3 100644
--- a/app/init.php
+++ b/app/init.php
@@ -64,7 +64,12 @@ const APP_SOCIAL_DISCORD = 'https://appwrite.io/discord';
 const APP_SOCIAL_DISCORD_CHANNEL = '564160730845151244';
 const APP_SOCIAL_DEV = 'https://dev.to/appwrite';
 const APP_SOCIAL_STACKSHARE = 'https://stackshare.io/appwrite'; 
+// Creation Types
+const CREATE_TYPE_ATTRIBUTE = 'newAttribute';
+const CREATE_TYPE_INDEX = 'newIndex';
 // Deletion Types
+const DELETE_TYPE_ATTRIBUTE = 'attribute';
+const DELETE_TYPE_INDEX = 'index';
 const DELETE_TYPE_DOCUMENT = 'document';
 const DELETE_TYPE_EXECUTIONS = 'executions';
 const DELETE_TYPE_AUDIT = 'audit';
@@ -375,6 +380,10 @@ App::setResource('deletes', function($register) {
     return new Event(Event::DELETE_QUEUE_NAME, Event::DELETE_CLASS_NAME);
 }, ['register']);
 
+App::setResource('database', function($register) {
+    return new Event(Event::DATABASE_QUEUE_NAME, Event::DATABASE_CLASS_NAME);
+}, ['register']);
+
 // Test Mock
 App::setResource('clients', function($request, $console, $project) {
     $console->setAttribute('platforms', [ // Allways allow current host
diff --git a/app/workers/database.php b/app/workers/database.php
index 6294f228b..c7426195d 100644
--- a/app/workers/database.php
+++ b/app/workers/database.php
@@ -19,7 +19,7 @@ require_once __DIR__.'/../init.php';
 Console::title('Database V1 Worker');
 Console::success(APP_NAME.' database worker v1 has started'."\n");
 
-class DeletesV1 extends Worker
+class DatabaseV1 extends Worker
 {
     public $args = [];
 
@@ -29,6 +29,10 @@ class DeletesV1 extends Worker
 
     public function run(): void
     {
+        $collections = Config::getParam('collections2');
+
+        var_dump($collections);
+
     }
 
     public function shutdown(): void
diff --git a/docker-compose.yml b/docker-compose.yml
index be056b8a6..8fc1bff54 100644
--- a/docker-compose.yml
+++ b/docker-compose.yml
@@ -240,6 +240,35 @@ services:
       - _APP_DB_USER
       - _APP_DB_PASS
 
+  appwrite-worker-database:
+    entrypoint: worker-database
+    container_name: appwrite-worker-database
+    build:
+      context: .
+    networks:
+      - appwrite
+    volumes: 
+      - appwrite-uploads:/storage/uploads:rw
+      - appwrite-cache:/storage/cache:rw
+      - appwrite-functions:/storage/functions:rw
+      - appwrite-certificates:/storage/certificates:rw
+      - ./app:/usr/src/code/app
+      - ./src:/usr/src/code/src
+    depends_on:
+      - redis
+      - mariadb
+    environment:
+      - _APP_ENV
+      - _APP_REDIS_HOST
+      - _APP_REDIS_PORT
+      - _APP_REDIS_USER
+      - _APP_REDIS_PASS
+      - _APP_DB_HOST
+      - _APP_DB_PORT
+      - _APP_DB_SCHEMA
+      - _APP_DB_USER
+      - _APP_DB_PASS
+
   appwrite-worker-certificates:
     entrypoint: worker-certificates
     container_name: appwrite-worker-certificates