add restrictions for changing table and entrance

src/models/app/index.ts

@@ -5,6 +5,8 @@ import { Config } from './types'
 
 export const initAppFx = createEffect<Config, unknown>()
 
+export const showErrorFx = createEffect<string, unknown>()
+
 export const AppGate = createGate()
 
-export const Route = createGate<{name: string}>()
+export const Route = createGate<{ name: string }>()

src/models/app/init.ts

@@ -2,7 +2,7 @@ import { initializeApp } from 'firebase'
 import { forward } from 'effector'
 
 import {
-  initAppFx, AppGate, Route
+  initAppFx, showErrorFx, AppGate, Route
 } from './'
 
 import { fetchUsersFx } from '../users'
@@ -34,6 +34,10 @@ initAppFx.use(async ({
   })
 })
 
+showErrorFx.use((text) => {
+  alert(text)
+})
+
 initAppFx({
   appId,
   projectId,

src/models/auth/init.ts

@@ -1,4 +1,4 @@
-import { forward, sample, guard } from 'effector'
+import { forward, sample, guard, merge } from 'effector'
 import { auth } from 'firebase'
 
 import {
@@ -19,12 +19,20 @@ import {
 
 import {
   addUserFx,
-  updateUsersTableFx,
   deleteUserFx,
-  $firebaseUsers,
-  $usersByEmail
+  $usersByEmail,
+  $usersCount
 } from '../users'
 
+import {
+  $tableCapacity,
+  $tablesCount
+} from '../tables'
+
+import {
+  showErrorFx
+} from '../app'
+
 import { User } from './types'
 
 const gProvider = new auth.GoogleAuthProvider()
@@ -80,14 +88,33 @@ $signInForm
   [fieldName]: value
 }))
 
-forward({
-  from: gSignIn,
-  to: manageGmailProviderFx
+const $canUserEnter = sample({
+  source: {
+    count: $tablesCount,
+    capacity: $tableCapacity
+  },
+  clock: $usersCount,
+  fn: ({ count, capacity }, usersCount) => count * capacity > usersCount
 })
 
-forward({
-  from: signIn,
-  to: manageEmailProviderFx
+const $cantUserEnter = $canUserEnter.map((can) => !can)
+
+guard({
+  source: gSignIn,
+  filter: $canUserEnter,
+  target: manageGmailProviderFx
+})
+
+guard({
+  source: signIn,
+  filter: $canUserEnter,
+  target: manageEmailProviderFx
+})
+
+guard({
+  source: merge([signIn, gSignIn]).map(() => 'Theater is full! Try to login later.'),
+  filter: $cantUserEnter,
+  target: showErrorFx
 })
 
 forward({
@@ -100,17 +127,19 @@ forward({
   to: signUpViaEmailFx
 })
 
+const foundPrevLogInUser = sample({
+  source: $usersByEmail,
+  clock: [
+    manageGmailProviderFx.doneData,
+    signUpViaEmailFx.doneData,
+    manageEmailProviderFx.doneData
+  ],
+  fn: (users, user) => users[user.email]
+})
+
 sample({
   source: guard({
-    source: sample({
-      source: $usersByEmail,
-      clock: [
-        manageGmailProviderFx.doneData,
-        signUpViaEmailFx.doneData,
-        manageEmailProviderFx.doneData
-      ],
-      fn: (users, user) => users[user.email]
-    }),
+    source: foundPrevLogInUser,
     filter: Boolean
   }),
   fn: (user) => user.id!,

src/models/tables/index.ts

@@ -2,6 +2,8 @@ import {createStore, createEvent} from 'effector'
 
 export const updateCurrentIDandStage = createEvent<{ ID: string, stage: number }>()
 
+export const updateStage = updateCurrentIDandStage.map(({ stage }) => stage)
+
 export const $currentConnectID = createStore<string>('first-table')
 
 export const $tableIDs = createStore<string[]>([
@@ -26,4 +28,8 @@ export const $tableIDs = createStore<string[]>([
   'right-bottom-table'
 ])
 
+export const $tablesCount = $tableIDs.map((ids) => ids.length)
+
+export const $tableCapacity = createStore(6)
+
 export const $stage = createStore(2)

src/models/tables/init.ts

@@ -1,15 +1,17 @@
-import {forward, sample} from 'effector'
+import {forward, sample, guard} from 'effector'
 
 import {
   updateCurrentIDandStage,
+  updateStage,
   $currentConnectID,
   $tableIDs,
-  $stage
-} from './index'
+  $stage,
+  $tableCapacity
+} from './'
 
 import {
   $tableUsers
-} from '../users/index'
+} from '../users'
 
 sample({
   source: {
@@ -37,7 +39,12 @@ forward({
   to: $currentConnectID
 })
 
-forward({
-  from: updateCurrentIDandStage.map(({stage}) => stage),
-  to: $stage
+guard({
+  source: updateStage,
+  filter: sample({
+    source: $tableCapacity,
+    clock: updateStage,
+    fn: (capacity, stage) => stage <= capacity
+  }),
+  target: $stage
 })

src/models/users/index.ts

@@ -39,4 +39,8 @@ export const $tableUsers = $firebaseUsers.map((fUsers) => {
       [tableID]: [fUsers[id]]
     }
   }, {})
-})
+})
+
+export const $usersCount = $firebaseUsers.map((fUsers) =>
+  Object.keys(fUsers).length
+)

src/models/users/init.ts

@@ -9,7 +9,9 @@ import {
   fetchUsersFx,
   deleteUserFx,
   updateUsersTableFx,
-  $firebaseUsers
+  $firebaseUsers,
+  $usersByEmail,
+  $tableUsers
 } from './'
 
 import {
@@ -20,9 +22,14 @@ import {
 } from '../auth'
 
 import {
-  $currentConnectID
+  $currentConnectID,
+  $tableCapacity
 } from '../tables'
 
+import {
+  showErrorFx
+} from '../app'
+
 const usersRef = database().ref('users/');
 usersRef.on('value', (snapshot) => updateUsers(snapshot.val() === null ? {} : snapshot.val()))
 
@@ -65,16 +72,40 @@ sample({
   target: addUserFx
 })
 
-sample({
-  source: $user,
+forward({
+  from: addUserFx.doneData,
+  to: fetchUsersFx
+})
+
+const userChangeTable = sample({
+  source: {
+    user: $user,
+    usersByEmail: $usersByEmail,
+    tableUsers: $tableUsers,
+    tableCapacity: $tableCapacity
+  },
   clock: changeUserTable,
-  fn: ({id}, tableID) => ({
-    id, tableID
+  fn: ({user, usersByEmail, tableUsers, tableCapacity}, tableID) => {
+    const id = usersByEmail[user.email!].id!
+    const canBeUpdated = tableUsers[tableID] === undefined || tableUsers[tableID].length < tableCapacity
+    return {id, tableID, canBeUpdated}
+  }
+})
+
+forward({
+  from: userChangeTable.filterMap(({ id, tableID, canBeUpdated }) => {
+    if (canBeUpdated) {
+      return { id, tableID }
+    }
   }),
-  target: updateUsersTableFx
+  to: updateUsersTableFx
 })
 
 forward({
-  from: addUserFx.doneData,
-  to: fetchUsersFx
+  from: userChangeTable.filterMap(({ canBeUpdated }) => {
+    if (!canBeUpdated) {
+      return 'Table is full. You shall not pass!'
+    }
+  }),
+  to: showErrorFx
 })