async fn open_portal_for_subscribe( db: &LaminarDB, s: &SubscribeStatement, ) -> PgWireResult<SubscriptionPortal>