diff --git a/.gitignore b/.gitignore
index af3fefe..84c5097 100644
--- a/.gitignore
+++ b/.gitignore
@@ -4,9 +4,6 @@
 # PY VENV
 venv/
 
-# Tokens and Passwwords
-essentials/secrets\.py
-
 *.log
 
 # export
@@ -16,4 +13,6 @@ export/*.txt
 *.pyc
 
 #backup
-backup/
\ No newline at end of file
+backup/
+
+node_modules/
\ No newline at end of file
diff --git a/cogs/help.py b/cogs/help.py
index c368dd8..2e3c6b8 100644
--- a/cogs/help.py
+++ b/cogs/help.py
@@ -47,7 +47,7 @@ def get_help_embed(self, page, pre):
         title = f' Pollmaster Help - React with an emoji to learn more about a topic!'
         embed = discord.Embed(title='', description='', colour=SETTINGS.color)
         embed.set_author(name=title, icon_url=SETTINGS.author_icon)
-        embed.set_footer(text='Use reactions to navigate the help. This message will self-destruct in 5 minutes.')
+        embed.set_footer(text='Use reactions to navigate the help. This message will self-destruct in 5 minutes…')
 
         if page == '🏠':
             # POLL CREATION SHORT
diff --git a/cogs/poll_controls.py b/cogs/poll_controls.py
index a0b18e1..283fd9e 100644
--- a/cogs/poll_controls.py
+++ b/cogs/poll_controls.py
@@ -4,6 +4,8 @@
 import random
 import shlex
 import time
+import os
+import requests
 from string import ascii_lowercase
 
 import discord
@@ -15,7 +17,7 @@
 from essentials.multi_server import get_server_pre, ask_for_server, ask_for_channel
 from essentials.settings import SETTINGS
 from models.poll import Poll
-from utils.misc import CustomFormatter
+from utils.misc import CustomFormatter, proceed_to_party
 from utils.paginator import embed_list_paginated
 from utils.poll_name_generator import generate_word
 
@@ -40,6 +42,8 @@ def cog_unload(self):
     # noinspection PyCallingNonCallable
     @tasks.loop(seconds=30)
     async def close_activate_polls(self):
+        if not proceed_to_party():
+            return
         if hasattr(self.bot, 'db') and hasattr(self.bot.db, 'polls'):
             utc_now = datetime.datetime.utcnow().replace(tzinfo=pytz.utc)
 
@@ -111,11 +115,15 @@ async def close_activate_polls(self):
 
     @close_activate_polls.before_loop
     async def before_close_activate_polls(self):
+        if not proceed_to_party():
+            return
         # print('close task waiting...')
         await self.bot.wait_until_ready()
 
     @tasks.loop(seconds=5)
     async def refresh_queue(self):
+        if not proceed_to_party():
+            return
         remove_list = []
         for pid, t in self.bot.refresh_blocked.items():
             if t - time.time() < 0:
@@ -135,6 +143,8 @@ async def refresh_queue(self):
 
     @refresh_queue.before_loop
     async def before_refresh_queue(self):
+        if not proceed_to_party():
+            return
         # print('refresh task waiting...')
         await self.bot.wait_until_ready()
 
@@ -193,6 +203,8 @@ async def say_embed(self, ctx, say_text='', title='Pollmaster', footer_text=None
 
     @commands.command()
     async def activate(self, ctx, *, short=None):
+        if not proceed_to_party():
+            return
         """Activate a prepared poll. Parameter: <label>"""
         server = await ask_for_server(self.bot, ctx.message, short)
         if not server:
@@ -230,6 +242,8 @@ async def activate(self, ctx, *, short=None):
 
     @commands.command()
     async def delete(self, ctx, *, short=None):
+        if not proceed_to_party():
+            return
         """Delete a poll. Parameter: <label>"""
         server = await ask_for_server(self.bot, ctx.message, short)
         if not server:
@@ -269,6 +283,8 @@ async def delete(self, ctx, *, short=None):
 
     @commands.command()
     async def close(self, ctx, *, short=None):
+        if not proceed_to_party():
+            return
         """Close a poll. Parameter: <label>"""
         server = await ask_for_server(self.bot, ctx.message, short)
         if not server:
@@ -303,6 +319,8 @@ async def close(self, ctx, *, short=None):
 
     @commands.command()
     async def copy(self, ctx, *, short=None):
+        if not proceed_to_party():
+            return
         """Copy a poll. Parameter: <label>"""
         server = await ask_for_server(self.bot, ctx.message, short)
         if not server:
@@ -328,6 +346,8 @@ async def copy(self, ctx, *, short=None):
 
     @commands.command()
     async def export(self, ctx, *, short=None):
+        if not proceed_to_party():
+            return
         """Export a poll. Parameter: <label>"""
         server = await ask_for_server(self.bot, ctx.message, short)
         if not server:
@@ -370,6 +390,8 @@ async def export(self, ctx, *, short=None):
 
     @commands.command()
     async def show(self, ctx, short='open', start=0):
+        if not proceed_to_party():
+            return
         """Show a list of open polls or show a specific poll.
         Parameters: "open" (default), "closed", "prepared" or <label>"""
 
@@ -419,6 +441,8 @@ def item_fct(i, item):
 
     @commands.command()
     async def draw(self, ctx, short=None, opt=None):
+        if not proceed_to_party():
+            return
         server = await ask_for_server(self.bot, ctx.message, short)
         if not server:
             return
@@ -480,6 +504,8 @@ async def draw(self, ctx, short=None, opt=None):
 
     @commands.command()
     async def cmd(self, ctx, *, cmd=None):
+        if not proceed_to_party():
+            return
         """The old, command style way paired with the wizard."""
         # await self.say_embed(ctx, say_text='This command is temporarily disabled.')
 
@@ -572,6 +598,8 @@ async def route(poll):
 
     @commands.command()
     async def quick(self, ctx, *, cmd=None):
+        if not proceed_to_party():
+            return
         """Create a quick poll with just a question and some options. Parameters: <Question> (optional)"""
         server = await ask_for_server(self.bot, ctx.message)
         if not server:
@@ -594,6 +622,8 @@ async def route(poll):
 
     @commands.command()
     async def prepare(self, ctx, *, cmd=None):
+        if not proceed_to_party():
+            return
         """Prepare a poll to use later. Parameters: <Question> (optional)"""
         server = await ask_for_server(self.bot, ctx.message)
         if not server:
@@ -618,6 +648,8 @@ async def route(poll):
 
     @commands.command()
     async def advanced(self, ctx, *, cmd=None):
+        if not proceed_to_party():
+            return
         """Poll with more options. Parameters: <Question> (optional)"""
         server = await ask_for_server(self.bot, ctx.message)
         if not server:
@@ -641,6 +673,8 @@ async def route(poll):
 
     @commands.command()
     async def new(self, ctx, *, cmd=None):
+        if not proceed_to_party():
+            return
         """Start the poll wizard to create a new poll step by step. Parameters: <Question> (optional)"""
         server = await ask_for_server(self.bot, ctx.message)
         if not server:
@@ -703,6 +737,8 @@ async def wizard(self, ctx, route, server):
 
     @commands.Cog.listener()
     async def on_raw_reaction_remove(self, data):
+        if not proceed_to_party():
+            return
         # get emoji symbol
         emoji = data.emoji
         if not emoji:
@@ -768,7 +804,10 @@ async def on_raw_reaction_remove(self, data):
 
     @commands.Cog.listener()
     async def on_raw_reaction_add(self, data):
-        # dont look at bot's own reactions
+        if not proceed_to_party():
+            return
+
+        # don't look at bot's own reactions
         user_id = data.user_id
         if user_id == self.bot.user.id:
             return
@@ -825,10 +864,11 @@ async def on_raw_reaction_add(self, data):
             return
 
         p = await Poll.load_from_db(self.bot, server.id, label)
+
         if not isinstance(p, Poll):
             return
-        # member = server.get_member(user_id)
         user = member = data.member
+
         # export
         if emoji.name == '📎':
             self.ignore_next_removed_reaction[str(message.id) + str(emoji)] = user_id
@@ -974,13 +1014,28 @@ async def on_raw_reaction_add(self, data):
             return
         else:
             # Assume: User wants to vote with reaction
+            tri = await get_token_rule_info(user_id, data.guild_id)
+            print(f"Token rule info result", tri)
+            if "success" in tri:
+                print("Success")
+                print(f"Role(s) added", tri["success"]["added"])
+                print(f"Role(s) removed", tri["success"]["removed"])
+            elif "error" in tri:
+                await message.remove_reaction(emoji, data.member)
+                await data.member.send(tri["error"])
+                return
+
+            print(f"Original roles: {data.member.roles}")
+            # This refreshes the user/member with their roles that were updated after /get-token-rule-info call
+            user = member = await data.member.guild.fetch_member(user_id)
+            print(f"New roles: {member.roles}")
+
             # no rights, terminate function
             if not p.has_required_role(member):
                 await message.remove_reaction(emoji, user)
                 await member.send(f'You are not allowed to vote in this poll. Only users with '
                                   f'at least one of these roles can vote:\n{", ".join(p.roles)}')
                 return
-
             # check if we need to remove reactions (this will trigger on_reaction_remove)
             if not isinstance(channel, discord.DMChannel) and (p.anonymous or p.hide_count):
                 # immediately remove reaction and to be safe, remove all reactions
@@ -1001,6 +1056,23 @@ async def on_raw_reaction_add(self, data):
             await p.vote(member, emoji.name, message)
 
 
+async def get_token_rule_info(user_id, guild_id):
+    try:
+        data = requests.post(os.environ.get('PM_STARRY_BACKEND') + "/token-rule-info",
+                         data={'discordUserId': user_id, 'guildId': guild_id})
+        data.raise_for_status()
+    except requests.exceptions.HTTPError as errh:
+        print("Http Error:", errh)
+    except requests.exceptions.ConnectionError as errc:
+        print("Error Connecting:", errc)
+    except requests.exceptions.Timeout as errt:
+        print("Timeout Error:", errt)
+    except requests.exceptions.RequestException as err:
+        print("Other error", err)
+
+    content = data.json()
+    return content
+
 def setup(bot):
     global logger
     logger = logging.getLogger('discord')
diff --git a/essentials/secrets.py b/essentials/secrets.py
new file mode 100644
index 0000000..92a9b2a
--- /dev/null
+++ b/essentials/secrets.py
@@ -0,0 +1,10 @@
+import os
+
+class Secrets:
+    def __init__(self):
+        self.dbl_token = ''  # DBL token (only needed for public bot)
+        self.mongo_db = os.environ.get('PM_DB')
+        self.bot_token = os.environ.get('PM_BOT_TOKEN')
+        self.mode = 'development' # or production
+
+SECRETS = Secrets()
\ No newline at end of file
diff --git a/index.js b/index.js
new file mode 100644
index 0000000..3507e1b
--- /dev/null
+++ b/index.js
@@ -0,0 +1,15 @@
+const express = require('express')
+const app = express()
+const port = 3000
+
+app.get('/health-hack', (req, res) => {
+  res.sendStatus(200)
+})
+
+app.post('/health-hack', (req, res) => {
+  res.sendStatus(200)
+})
+
+app.listen(port, () => {
+  console.log(`Health hack listening on port ${port}`)
+})
diff --git a/launcher.py b/launcher.py
index f6671f3..1a320c2 100644
--- a/launcher.py
+++ b/launcher.py
@@ -11,6 +11,7 @@
 from bot import ClusterBot
 from essentials.multi_server import get_pre
 from essentials.settings import SETTINGS
+from utils.misc import proceed_to_party
 
 TOKEN = SETTINGS.bot_token
 
@@ -45,6 +46,7 @@ def __init__(self, loop):
         self.init = time.perf_counter()
 
     def get_shard_count(self):
+        print(f"Settings.mode is {SETTINGS.mode}")
         if SETTINGS.mode == "development":
             return 1
         data = requests.get('https://discordapp.com/api/v7/gateway/bot', headers={
@@ -81,8 +83,11 @@ def task_complete(self, task):
 
     async def startup(self):
         shards = list(range(self.get_shard_count()))
-        size = [shards[x:x + 4] for x in range(0, len(shards), 4)]
+        print(f"Shards: {shards}")
+        # size = [shards[x:x + 4] for x in range(0, len(shards), 4)]
+        size = [shards[x:x + 1] for x in range(0, len(shards), 1)]
         log.info(f"Preparing {len(size)} clusters")
+        print(f"Preparing {len(size)} clusters")
         for shard_ids in size:
             self.cluster_queue.append(Cluster(self, next(NAMES), shard_ids, len(shards)))
 
@@ -126,7 +131,7 @@ async def start_cluster(self):
         if self.cluster_queue:
             cluster = self.cluster_queue.pop(0)
             log.info(f"Starting Cluster#{cluster.name}")
-            await cluster.start()
+            await cluster.start(force=True)
             log.info("Done!")
             self.clusters.append(cluster)
             await self.start_cluster()
@@ -193,6 +198,10 @@ def stop(self, sign=signal.SIGINT):
             pass
 
 
+
+
 if __name__ == "__main__":
+    print("in main")
     loop = asyncio.get_event_loop()
-    Launcher(loop).start()
+    launcher = Launcher(loop)
+    launcher.start()
diff --git a/models/poll.py b/models/poll.py
index 7cb01a2..ef412fb 100644
--- a/models/poll.py
+++ b/models/poll.py
@@ -43,7 +43,6 @@ def __init__(self, bot, ctx=None, server=None, channel=None, load=False):
 
         self.bot = bot
         self.cursor_pos = 0
-
         self.vote_counts = {}
         self.vote_counts_weighted = {}
         self.full_votes = []
diff --git a/package.json b/package.json
new file mode 100644
index 0000000..2379344
--- /dev/null
+++ b/package.json
@@ -0,0 +1,22 @@
+{
+  "name": "pollmaster-health-check",
+  "version": "1.0.0",
+  "description": "Just returns 200 for Render",
+  "main": "index.js",
+  "scripts": {
+    "test": "echo \"Error: no test specified\" && exit 1"
+  },
+  "repository": {
+    "type": "git",
+    "url": "git+https://github.com/starryzone/pollmaster.git"
+  },
+  "author": "Mike Purvis",
+  "license": "MIT",
+  "bugs": {
+    "url": "https://github.com/starryzone/pollmaster/issues"
+  },
+  "homepage": "https://github.com/starryzone/pollmaster#readme",
+  "dependencies": {
+    "express": "^4.17.3"
+  }
+}
diff --git a/pollmaster.py b/pollmaster.py
index 2b6ad16..f84a706 100644
--- a/pollmaster.py
+++ b/pollmaster.py
@@ -13,6 +13,7 @@
 
 from essentials.multi_server import get_pre
 from essentials.settings import SETTINGS
+from utils.misc import proceed_to_party
 
 bot_config = {
     'command_prefix': get_pre,
@@ -56,6 +57,8 @@
 
 @bot.event
 async def on_message(message):
+    if not proceed_to_party():
+        return
     # allow case insensitive prefix
     prefix = await get_pre(bot, message)
     if type(prefix) == tuple:
@@ -74,6 +77,8 @@ async def on_message(message):
 
 @bot.event
 async def on_ready():
+    if not proceed_to_party():
+        return
     bot.owner = await bot.fetch_user(SETTINGS.owner_id)
 
     mongo = AsyncIOMotorClient(SETTINGS.mongo_db)
@@ -109,7 +114,8 @@ async def on_ready():
 
 @bot.event
 async def on_command_error(ctx, e):
-
+    if not proceed_to_party():
+        return
     if hasattr(ctx.cog, 'qualified_name') and ctx.cog.qualified_name == "Admin":
         # Admin cog handles the errors locally
         return
@@ -153,6 +159,8 @@ async def on_command_error(ctx, e):
 
 @bot.event
 async def on_guild_join(server):
+    if not proceed_to_party():
+        return
     result = await bot.db.config.find_one({'_id': str(server.id)})
     if result is None:
         await bot.db.config.update_one(
diff --git a/requirements.txt b/requirements.txt
index 57c52af..ef8605a 100644
--- a/requirements.txt
+++ b/requirements.txt
@@ -1,20 +1,21 @@
-aiohttp==3.7.2
-async-timeout==3.0.1
+aiohttp
+async-timeout
 asyncpg==0.21.0
 attrs==20.2.0
 certifi==2020.6.20
 chardet==3.0.4
 cycler==0.10.0
 dateparser==0.7.4
-dblpy==0.3.4
+dblpy
 discord.py==1.5.1
 idna==2.10
 idna-ssl==1.1.0
 kiwisolver==1.3.0
 matplotlib==3.2.1
 motor==2.3.0
-multidict==5.0.0
-numpy==1.19.2
+multidict
+numpy
+psutil
 pymongo==3.11.0
 pyparsing==2.4.7
 python-dateutil==2.8.1
diff --git a/start.sh b/start.sh
new file mode 100755
index 0000000..b583846
--- /dev/null
+++ b/start.sh
@@ -0,0 +1,4 @@
+#!/bin/bash
+#ps -ef | grep "python launcher.py" | grep -v grep | awk '{print $2}' | xargs kill -9
+node index.js &
+python ipc.py &
diff --git a/utils/misc.py b/utils/misc.py
index 26f9ba1..0ff6a12 100644
--- a/utils/misc.py
+++ b/utils/misc.py
@@ -1,4 +1,7 @@
 import argparse
+import os
+import time
+import psutil
 
 import pytz
 import datetime as dt
@@ -50,4 +53,27 @@ def possible_timezones(tz_offset, common_only=True):
         if desired_delta == non_dst_offset[0]:
             results.append(tz_name)
 
-    return results
\ No newline at end of file
+    return results
+
+
+def proceed_to_party():
+    current_pid = os.getpid()
+    launcher_pids = {}
+    for proc in psutil.process_iter():
+        try:
+            if "python" in proc.name():
+                flist = proc.open_files()
+                if flist:
+                    for nt in flist:
+                        if "launcher" in nt.path.lower() and proc.pid != current_pid:
+                            # proc.kill()
+                            launcher_pids[proc.pid] = proc.create_time()
+        except (psutil.NoSuchProcess, psutil.AccessDenied, psutil.ZombieProcess):
+            pass
+    if not current_pid in launcher_pids:
+        launcher_pids[current_pid] = time.time()
+    most_recent_pid = max(launcher_pids, key=launcher_pids.get)
+    if most_recent_pid == current_pid:
+        return True
+    else:
+        return False