fade to black

Author: graingert

bin/ldaptor-fetchschema

@@ -5,26 +5,30 @@ from ldaptor.protocols.ldap import ldapclient, ldapconnector, fetchschema
 from ldaptor import usage, config
 from twisted.internet import reactor
 
+
 def _printResults(x):
     attributeTypes, objectClasses = x
 
     something = False
     for at in attributeTypes:
-        print('attributetype', at)
+        print("attributetype", at)
         something = True
 
     if something:
         print()
 
     for oc in objectClasses:
-        print('objectclass', oc)
+        print("objectclass", oc)
+
+
+exitStatus = 0
 
-exitStatus=0
 
 def error(fail):
-    print('fail:', fail.getErrorMessage(), file=sys.stderr)
+    print("fail:", fail.getErrorMessage(), file=sys.stderr)
     global exitStatus
-    exitStatus=1
+    exitStatus = 1
+
 
 def main(cfg):
     try:
@@ -33,13 +37,13 @@ def main(cfg):
         print("{}: {}.".format(sys.argv[0], e), file=sys.stderr)
         sys.exit(1)
 
-    c = ldapconnector.LDAPClientCreator(reactor,
-                                        ldapclient.LDAPClient)
-    d= c.connectAnonymously(dn=baseDN,
-                            overrides=cfg.getServiceLocationOverrides())
+    c = ldapconnector.LDAPClientCreator(reactor, ldapclient.LDAPClient)
+    d = c.connectAnonymously(dn=baseDN, overrides=cfg.getServiceLocationOverrides())
+
     def _cbBound(client, baseDN):
-        d=fetchschema.fetch(client, baseDN)
+        d = fetchschema.fetch(client, baseDN)
         return d
+
     d.addCallback(_cbBound, baseDN)
     d.addCallback(_printResults)
     d.addErrback(error)
@@ -48,20 +52,26 @@ def main(cfg):
     reactor.run()
     sys.exit(exitStatus)
 
-class MyOptions(usage.Options, usage.Options_service_location, usage.Options_base_optional):
+
+class MyOptions(
+    usage.Options, usage.Options_service_location, usage.Options_base_optional
+):
     """LDAPtor command line schema fetching utility"""
 
+
 if __name__ == "__main__":
     from twisted.python import log
+
     log.startLogging(sys.stderr, setStdout=0)
 
     try:
         opts = MyOptions()
         opts.parseOptions()
     except usage.UsageError as ue:
-        sys.stderr.write('{}: {}\n'.format(sys.argv[0], ue))
+        sys.stderr.write("{}: {}\n".format(sys.argv[0], ue))
         sys.exit(1)
 
-    cfg = config.LDAPConfig(baseDN=opts['base'],
-                            serviceLocationOverrides=opts['service-location'])
+    cfg = config.LDAPConfig(
+        baseDN=opts["base"], serviceLocationOverrides=opts["service-location"]
+    )
     main(cfg)

bin/ldaptor-find-server

@@ -6,37 +6,45 @@ from twisted.internet.defer import DeferredList
 from twisted.internet import reactor
 from twisted.names import client, dns
 
+
 def printAnswer(answers, dn):
     for rrlist in answers:
         for rr in rrlist:
             if isinstance(rr.payload, dns.Record_SRV):
-                print('%s\tpri=%d weight=%d %s:%d' % (dn,
-                                                  rr.payload.priority,
-                                                  rr.payload.weight,
-                                                  rr.payload.target,
-                                                  rr.payload.port,
-                                                  ))
+                print(
+                    "%s\tpri=%d weight=%d %s:%d"
+                    % (
+                        dn,
+                        rr.payload.priority,
+                        rr.payload.weight,
+                        rr.payload.target,
+                        rr.payload.port,
+                    )
+                )
             else:
                 # suppress additional records
                 pass
     return answers
 
+
 exitStatus = 0
 
+
 def errback(data):
     print("ERROR:", data.getErrorMessage())
     global exitStatus
-    exitStatus=1
+    exitStatus = 1
+
 
 def main(dns):
     l = []
-    resolver = client.Resolver('/etc/resolv.conf')
+    resolver = client.Resolver("/etc/resolv.conf")
 
     for dnString in dns:
-        dn=DistinguishedName(stringValue=dnString)
-        domain=dn.getDomainName()
+        dn = DistinguishedName(stringValue=dnString)
+        domain = dn.getDomainName()
 
-        d = resolver.lookupService('_ldap._tcp.%s' % domain)
+        d = resolver.lookupService("_ldap._tcp.%s" % domain)
         l.append(d)
         d.addCallback(printAnswer, dnString)
         d.addErrback(errback)
@@ -45,9 +53,10 @@ def main(dns):
     reactor.run()
     sys.exit(exitStatus)
 
+
 if __name__ == "__main__":
     if not sys.argv[1:]:
-        print('%s: usage:' % sys.argv[0], file=sys.stderr)
-        print('  %s DN..' % sys.argv[0], file=sys.stderr)
+        print("%s: usage:" % sys.argv[0], file=sys.stderr)
+        print("  %s DN.." % sys.argv[0], file=sys.stderr)
     else:
         main(sys.argv[1:])

bin/ldaptor-getfreenumber

@@ -5,13 +5,15 @@ from ldaptor.protocols.ldap import ldapclient, ldapsyntax, ldapconnector
 from ldaptor import usage, numberalloc, config
 from twisted.internet import reactor
 
-exitStatus=0
+exitStatus = 0
+
 
 def error(fail):
     print(fail)
-    print('fail:', fail.getErrorMessage(), file=sys.stderr)
+    print("fail:", fail.getErrorMessage(), file=sys.stderr)
     global exitStatus
-    exitStatus=1
+    exitStatus = 1
+
 
 def main(cfg):
     try:
@@ -20,38 +22,41 @@ def main(cfg):
         print("{}: {}.".format(sys.argv[0], e), file=sys.stderr)
         sys.exit(1)
 
-    c = ldapconnector.LDAPClientCreator(reactor,
-                                        ldapclient.LDAPClient)
-    d= c.connectAnonymously(dn=baseDN,
-                            overrides=cfg.getServiceLocationOverrides())
+    c = ldapconnector.LDAPClientCreator(reactor, ldapclient.LDAPClient)
+    d = c.connectAnonymously(dn=baseDN, overrides=cfg.getServiceLocationOverrides())
+
     def _cbBound(client, baseDN):
-        o=ldapsyntax.LDAPEntry(client=client, dn=baseDN)
-        return numberalloc.getFreeNumber(o,
-                                         'uidNumber',
-                                         min=1000)
+        o = ldapsyntax.LDAPEntry(client=client, dn=baseDN)
+        return numberalloc.getFreeNumber(o, "uidNumber", min=1000)
+
     d.addCallback(_cbBound, baseDN)
-    d.addCallback(lambda num: sys.stdout.write('%s\n' % repr(num)))
+    d.addCallback(lambda num: sys.stdout.write("%s\n" % repr(num)))
     d.addErrback(error)
     d.addBoth(lambda x: reactor.stop())
 
     reactor.run()
     sys.exit(exitStatus)
 
-class MyOptions(usage.Options, usage.Options_service_location, usage.Options_base_optional):
+
+class MyOptions(
+    usage.Options, usage.Options_service_location, usage.Options_base_optional
+):
     """LDAPtor command line search utility"""
 
+
 if __name__ == "__main__":
     from twisted.python import log
+
     log.startLogging(sys.stderr, setStdout=0)
 
     try:
         opts = MyOptions()
         opts.parseOptions()
     except usage.UsageError as ue:
-        sys.stderr.write('{}: {}\n'.format(sys.argv[0], ue))
+        sys.stderr.write("{}: {}\n".format(sys.argv[0], ue))
         sys.exit(1)
 
     cfg = config.LDAPConfig(
-        baseDN=opts['base'],
-        serviceLocationOverrides=opts['service-location'])
+        baseDN=opts["base"], serviceLocationOverrides=opts["service-location"]
+    )
     main(cfg)