[streaming] Refactored db state connectors and added their license