refactor(ws_v2): broke out sinks into a dedicated ws_sinks.py module. Also broke out their tests.