diff --git a/app/Tasks.hs b/app/Tasks.hs
index c3360a8..0f8a12d 100644
--- a/app/Tasks.hs
+++ b/app/Tasks.hs
@@ -27,5 +27,6 @@ main = do
       checkPayments pipe (c_dbName loadedConfig)
       expireOwners pipe (c_dbName loadedConfig)
       updateLogins pipe loadedConfig
+      expireProSessions pipe (c_dbName loadedConfig)
       close pipe
     else fail "MongoDB connection failed!"
diff --git a/src/Owner.hs b/src/Owner.hs
index 2e85222..d7b1fa0 100644
--- a/src/Owner.hs
+++ b/src/Owner.hs
@@ -301,3 +301,63 @@ findExpiringOwners now =
     (select
        ["paid" =: True, "expiration" =: ["$lte" =: addUTCTime 172800 now]]
        "owners")
+
+removePro :: T.Text -> Action IO ()
+removePro o =
+  modify (select ["address" =: o] "owners") ["$set" =: ["invoices" =: False]]
+
+-- | Type for a pro session
+data ZGoProSession =
+  ZGoProSession
+    { ps_id :: Maybe ObjectId
+    , psaddress :: T.Text
+    , psexpiration :: UTCTime
+    , psclosed :: Bool
+    }
+  deriving (Eq, Show)
+
+instance Val ZGoProSession where
+  cast' (Doc d) = do
+    i <- B.lookup "_id" d
+    a <- B.lookup "address" d
+    e <- B.lookup "expiraton" d
+    p <- B.lookup "closed" d
+    Just (ZGoProSession i a e p)
+  cast' _ = Nothing
+  val (ZGoProSession i a e p) =
+    case i of
+      Just oid ->
+        Doc ["_id" =: oid, "address" =: a, "expiration" =: e, "closed" =: p]
+      Nothing -> Doc ["address" =: a, "expiration" =: e, "closed" =: p]
+
+-- | Function to get a pro session
+findProSession :: T.Text -> Action IO (Maybe Document)
+findProSession zaddy =
+  findOne (select ["address" =: zaddy, "closed" =: False] "prosessions")
+
+-- | Function to get expiring pro sessions
+findExpiringProSessions :: UTCTime -> Action IO [Document]
+findExpiringProSessions now =
+  rest =<<
+  find
+    (select ["closed" =: False, "expiration" =: ["$lte" =: now]] "prosessions")
+
+-- | Function to upsert a pro session
+upsertProSession :: ZGoProSession -> Action IO ()
+upsertProSession ps = do
+  let prosession = val ps
+  case prosession of
+    Doc d ->
+      upsert
+        (select
+           ["address" =: psaddress ps, "expiration" =: psexpiration ps]
+           "owners")
+        d
+    _ -> return ()
+
+closeProSession :: ZGoProSession -> Action IO ()
+closeProSession ps = do
+  let prosession = val ps
+  case prosession of
+    Doc d -> modify (select d "prosessions") ["$set" =: ["closed" =: True]]
+    _ -> return ()
diff --git a/src/ZGoBackend.hs b/src/ZGoBackend.hs
index 17bb653..dc4228f 100644
--- a/src/ZGoBackend.hs
+++ b/src/ZGoBackend.hs
@@ -1391,4 +1391,19 @@ expireOwners pipe db = do
          ["$set" =: ["paid" =: False]])
   return ()
 
+expireProSessions :: Pipe -> T.Text -> IO ()
+expireProSessions pipe db = do
+  now <- getCurrentTime
+  psessions <- access pipe master db $ findExpiringProSessions now
+  let pSessObj = cast' . Doc <$> psessions
+  mapM_ (sendExpiration pipe db) pSessObj
+  where
+    sendExpiration :: Pipe -> T.Text -> Maybe ZGoProSession -> IO ()
+    sendExpiration pipe db zps =
+      case zps of
+        Nothing -> return ()
+        Just z -> do
+          access pipe master db $ removePro (psaddress z)
+          access pipe master db $ closeProSession z
+
 debug = flip trace
diff --git a/stack.yaml b/stack.yaml
index 48755d1..442eff8 100644
--- a/stack.yaml
+++ b/stack.yaml
@@ -17,7 +17,7 @@
 #
 # resolver: ./custom-snapshot.yaml
 # resolver: https://example.com/snapshots/2018-01-01.yaml
-resolver: lts-20.8
+resolver: lts-20.17
   #url: https://raw.githubusercontent.com/commercialhaskell/stackage-snapshots/master/lts/19/4.yaml
 
 # User packages to be built.
diff --git a/stack.yaml.lock b/stack.yaml.lock
index f3f90bb..358549d 100644
--- a/stack.yaml.lock
+++ b/stack.yaml.lock
@@ -31,7 +31,7 @@ packages:
     hackage: crypto-rng-0.3.0.1@sha256:04f4ae75943ecad8b794950985054130f272d65a588b6b6528f56df0bfedc4dc,1565
 snapshots:
 - completed:
-    sha256: bfafe5735ccb74527d754b1f9999ded72d7c3a6c3a88529449661431ccfbd6cc
-    size: 649327
-    url: https://raw.githubusercontent.com/commercialhaskell/stackage-snapshots/master/lts/20/8.yaml
-  original: lts-20.8
+    sha256: 14ca51a9a597c32dd7804c10d079feea3d0ae40c5fbbb346cbd67b3ae49f6d01
+    size: 649598
+    url: https://raw.githubusercontent.com/commercialhaskell/stackage-snapshots/master/lts/20/17.yaml
+  original: lts-20.17
diff --git a/test/Spec.hs b/test/Spec.hs
index b549218..4527b03 100644
--- a/test/Spec.hs
+++ b/test/Spec.hs
@@ -355,6 +355,14 @@ main = do
           it "should fail with bad creds" $ \p -> do
             r <- liftIO $ access p master "zgo" (auth "user" "pwd")
             r `shouldBe` False
+        describe "ZGo Pro sessions" $ do
+          it "find in DB" $ \p -> do
+            doc <-
+              access p master "test" $
+              findProSession
+                "zs1w6nkameazc5gujm69350syl5w8tgvyaphums3pw8eytzy5ym08x7dvskmykkatmwrucmgv3er8e"
+            doc `shouldNotBe` Nothing
+          it "upsert to DB" $ const pending
         describe "Zcash prices" $ do
           it "should update" $ \p -> do
             doc <- access p master "test" $ findPrice "usd"
@@ -378,7 +386,7 @@ main = do
                             let t2 = ZGoBackend.timestamp r2
                             t2 `shouldSatisfy` (t1 <)
         describe "user is" $ do
-          it "validated" $ \p -> do
+          xit "validated" $ \p -> do
             t <-
               access p master "test" $
               findOne (select ["validated" =: False] "users")
@@ -473,7 +481,7 @@ main = do
             let s = parseZGoTxBson =<< t
             let conf = maybe 0 confirmations s
             conf `shouldSatisfy` (> 0)
-          it "payments are added to db" $ \p -> do
+          xit "payments are added to db" $ \p -> do
             _ <-
               access
                 p
@@ -770,6 +778,16 @@ startAPI config = do
   case itemTest of
     Doc iT -> access pipe master "test" (insert_ "items" iT)
     _ -> fail "Couldn't save test Item in DB"
+  let proSession1 =
+        ZGoProSession
+          Nothing
+          "zs1w6nkameazc5gujm69350syl5w8tgvyaphums3pw8eytzy5ym08x7dvskmykkatmwrucmgv3er8e"
+          myTs
+          False
+  let proSessionTest = val proSession1
+  case proSessionTest of
+    Doc pS1 -> access pipe master "test" (insert_ "prosessions" pS1)
+    _ -> fail "Couldn't save test ZGoProSession in DB"
   --let myWooToken =
         --WooToken
           --Nothing