(un)subscribe(ack) codec implementation + mini refactor