def handler()

in authz.py [0:0]

• 12 lines of code
• 2 McCabe index (conditional complexity)

    def handler(self, payload):
        #LOGGER.debug(f'PAYLOAD: {payload}')

        # If a (re)write has been signaled, then wait for a bit before
        # writing more files. This prevents rewriting on EVERY change.
        # Given that a heartbeat occurs every 5 seconds (as of this
        # comment), we'll get an opportunity to check/write.
        if time.time() > self.write_signal + self.delay:
            self.write_files()

        # What kind of packet/payload arrived from PUBSUB ?

        if 'stillalive' in payload:
            self.verbose2('HEARTBEAT:', payload)
        elif 'commit' in payload:
            self.handle_commit(payload['commit'])
        elif 'dn' in payload:
            # LDAP has changed, but we don't need the details. It would
            # be incredibly difficult to map changes against what LDAP
            # records are needed by the authz files. So, just rebuild the
            # files, regardless.
            LOGGER.info(f'LDAP CHANGE: {payload["dn"]}')
            self.write_needed()
        else:
            # unknown payload. (???)
            pass