eaba / hostel Goto Github PK

View Code? Open in Web Editor NEW

12.0 5.0 3.0 13.66 MB

Smart Traditional Single Rooms Hostel using Distributed Domain-Driven Design and Event-Sourcing

C# 79.23% HTML 8.30% CSS 0.62% JavaScript 0.74% Batchfile 0.06% TypeScript 6.52% TSQL 4.17% Less 0.36%

hostel

hostel's Introduction

Hostel(WIP - Will be completed in due course due to private projects)

Smart Traditional Single Rooms Hostel using Distributed Domain-Driven Design and Event-Sourcing

Domain Description

The Owner owns a Hostel with three floors(ground, first and second) and the floors with 20-23 rooms, 2-3 community toilets, 2 community bathrooms and a kitchen each!

Problem

The Owner currently is facing these problems: Water scarcity, Poor Hygienity, Noise pollution, embarrassing septic tank spillage, poor rent followup and poor or no tenant data management!

Solution

Various types of IoT sensors will be installed as follows: Sonic Sensor for Water and Septic Tank, Dirt and Smell detection for Toilets, Bathrooms and Kitchens and Noise detection Sensor installed at strategic locations!

Hostel will help this Owner monitor readings coming from the sensors and automate rent expiration notification. Birthday notification will be a bonus tool to add!

The Owner also desires to know which one of the toilets are used the most, so we will be tracking flush!

Tool-Set

Akka.NET
MassTransit
SignalR
SQL
ML.NET
Quartz.NET
Xamarin.Forms
Asp.Net Core
IdentityServer4
xca
Angular

Home Preview(https://hostel.com)

hostel's People

Contributors

Stargazers

Watchers

Forkers

lulzzz fzf003 ateeq156

hostel's Issues

Ultrasonic Sensors

https://www.hoffmann-krippner.com/5-clever-applications-for-ultrasonic-sensors/

HostelActorSystem/system/akka.persistence.journal.sql-server Instance failure

"Payload": {
    "System": "HostelActorSystem",
    "Log": "[ERROR][5/11/2019 12:20:12][Thread 0005][akka://HostelActorSystem/system/akka.persistence.journal.sql-server] 
	Instance failure.\r\nCause: [akka://HostelActorSystem/system/akka.persistence.journal.sql-server#1096997092]: 
	Akka.Actor.ActorInitializationException: Exception during creation ---> System.InvalidOperationException: 
	Instance failure.\r\n   at System.Data.ProviderBase.DbConnectionPool.TryGetConnection(DbConnection owningObject, 
	UInt32 waitForMultipleObjectsTimeout, Boolean allowCreate, Boolean onlyOneCheckConnection, DbConnectionOptions userOptions, 
	DbConnectionInternal& connection)\r\n   at System.Data.ProviderBase.DbConnectionPool.WaitForPendingOpen()\r\n   a
	t System.Data.ProviderBase.DbConnectionPool.TryGetConnection(DbConnection owningObject, 
	TaskCompletionSource`1 retry, DbConnectionOptions userOptions, DbConnectionInternal& connection)\r\n   
	at System.Data.ProviderBase.DbConnectionFactory.TryGetConnection(DbConnection owningConnection, 
	TaskCompletionSource`1 retry, DbConnectionOptions userOptions, DbConnectionInternal oldConnection, DbConnectionInternal& connection)\r\n   
	at System.Data.ProviderBase.DbConnectionInternal.TryOpenConnectionInternal(DbConnection outerConnection, 
	DbConnectionFactory connectionFactory, TaskCompletionSource`1 retry, DbConnectionOptions userOptions)\r\n--- 
	End of stack trace from previous location where exception was thrown ---\r\n   
	at Akka.Persistence.Sql.Common.Snapshot.SqlSnapshotStore.Initialize()\r\n   
	at System.Data.SqlClient.SqlConnection.TryOpen(TaskCompletionSource`1 retry)\r\n   
	at System.Data.SqlClient.SqlConnection.Open()\r\n   
	at Akka.Persistence.Sql.Common.Journal.BatchingSqlJournal`2.PreStart()\r\n   
	at Akka.Actor.ActorCell.UseThreadContext(Action action)\r\n   
	at Akka.Actor.ActorCell.Create(Exception failure)\r\n   
	--- End of inner exception stack trace ---\r\n   at Akka.Actor.ActorCell.Create(Exception failure)\r\n   
	at Akka.Actor.ActorCell.SysMsgInvokeAll(EarliestFirstSystemMessageList messages, Int32 currentState)",
    "Level": "ErrorLevel"
  }
}

What is Read Model? What is Write Model?

I kept reading about Read/Write model while I still lacked better understanding of what Read Model is?

Collection was modified; enumeration operation may not execute

Repository TranNonQuery is currently throwing this error: Collection was modified; enumeration operation may not execute

I will attempt closing this issue today

Can or Should command return result or value?

At this point, I need to be clear if Commands can return value(result) instead of me depending on a projector to notify a user on the outcome of their Command!!!

System.InvalidOperationException' occurred in System.Data.SqlClient.dll

System.InvalidOperationException' occurred in System.Data.SqlClient.dll but was not handled in user codeTimeout expired. The timeout period elapsed prior to obtaining a connection from the pool. This may have occurred because all pooled connections were in use and max pool size was reached

Owner and Tenant Actors

Two thoughts running through my mind: should I create OwnerActor and TenantActor and make them a child of HostelManagerActor and RoomActor respectively or leave it just the way it is currently?

Entity Identifier

Because of the purpose of Event Sourcing is to deterministically recreate the current state of an object by replaying the changes that happened to it, am thinking generating Identifier automatically, like NewId() or Guid.NewGuid is a bad idea!

What do you think about this?