chiark / gitweb /
make-secnet-sites: Rework with new `inpub' class
[secnet.git] / make-secnet-sites
index 1caf53dc3dfd919f5bd65cb59ebb787e6b99f968..0bdb6943bb93fa8e33b5d29a97e6c4ad226ba636 100755 (executable)
@@ -254,6 +254,7 @@ def parse_args():
        global debug_level
        global output_version
        global pubkeys_dir
+       global pubkeys_install
 
        ap = argparse.ArgumentParser(description='process secnet sites files')
        ap.add_argument('--userv', '-u', action='store_true',
@@ -261,6 +262,8 @@ def parse_args():
        ap.add_argument('--conf-key-prefix', action=ActionNoYes,
                        default=True,
                 help='prefix conf file key names derived from sites data')
+       ap.add_argument('--pubkeys-install', action='store_true',
+                       help='install public keys in public key directory')
        ap.add_argument('--pubkeys-dir',  nargs=1,
                        help='public key directory',
                        default=['/var/lib/secnet/pubkeys'])
@@ -279,6 +282,7 @@ def parse_args():
        key_prefix = av.conf_key_prefix
        output_version = av.output_version[0]
        pubkeys_dir = av.pubkeys_dir[0]
+       pubkeys_install = av.pubkeys_install
        if service:
                if len(av.arg)!=4:
                        print("Wrong number of arguments")
@@ -418,16 +422,22 @@ class address (basetype):
        def __str__(self):
                return '"%s"; port %d'%(self.adr,self.port)
 
-class pubkey (basetype):
+class inpub (basetype):
+       def forsites(self,version,xcopy,fs):
+               return self.forpub(version,fs)
+
+class pubkey (inpub):
        "Some kind of publie key"
        def __init__(self,w):
                self.a=w[1].name('algname')
                self.d=w[2].base91();
        def __str__(self):
                return 'make-public("%s","%s")'%(self.a,self.d)
-       def forsites(self,version,xcopy,fs):
+       def forpub(self,version,fs):
                if version < 2: return []
                return ['pub', self.a, self.d]
+       def okforonlykey(self,version,fs):
+               return len(self.forpub(version,fs)) != 0
 
 class rsakey (pubkey):
        "An RSA public key"
@@ -447,10 +457,11 @@ class rsakey (pubkey):
                return 'rsa-public("%s","%s")'%(self.e,self.n)
                # this specialisation means we can generate files
                # compatible with old secnet executables
-       def forsites(self,version,xcopy,fs):
+       def forpub(self,version,fs):
                if version < 2:
+                       if fs.pkg != '00000000': return []
                        return ['pubkey', str(self.l), self.e, self.n]
-               return pubkey.forsites(self,version,xcopy,fs)
+               return pubkey.forpub(self,version,fs)
 
 class rsakey_newfmt(rsakey):
        "An old-style RSA public key in new-style sites format"
@@ -469,13 +480,33 @@ class rsakey_newfmt(rsakey):
                        complain('rsa1 key in new format has bad base91')
                #print(repr(w_inner), file=sys.stderr)
                rsakey.__init__(self,w_inner)
+
+class pubkey_group(inpub):
+       "Public key group introducer"
+       # appears in the site's list of keys mixed in with the keys
+       def __init__(self,w,fallback):
+               self.i=w[1].hexid(4,'pkg-id')
+               self.fallback=fallback
+       def forpub(self,version,fs):
+               fs.pkg=self.i
+               if version < 2: return []
+               return ['pkgf' if self.fallback else 'pkg', self.i]
+       def okforonlykey(self,version,fs):
+               self.forpub(version,fs)
+               return False
+       
 def somepubkey(w):
+       #print(repr(w), file=sys.stderr)
        if w[0]=='pubkey':
                return rsakey(w)
        elif w[0]=='pub' and w[1]=='rsa1':
                return rsakey_newfmt(w)
        elif w[0]=='pub':
                return pubkey(w)
+       elif w[0]=='pkg':
+               return pubkey_group(w,False)
+       elif w[0]=='pkgf':
+               return pubkey_group(w,True)
        else:
                assert(False)
 
@@ -491,6 +522,9 @@ keywords={
  'renegotiate-time':(num,"Time after key setup to begin renegotiation (ms)"),
  'restrict-nets':(networks,"Allowable networks"),
  'networks':(networks,"Claimed networks"),
+ 'serial':(serial,"public key set serial"),
+ 'pkg':(listof(somepubkey),"start of public key group",'pub'),
+ 'pkgf':(listof(somepubkey),"start of fallback public key group",'pub'),
  'pub':(listof(somepubkey),"new style public site key"),
  'pubkey':(listof(somepubkey),"RSA public site key",'pub'),
  'peer':(single_ipaddr,"Tunnel peer IP address"),
@@ -612,6 +646,9 @@ class sitelevel(level):
         'address':sp,
         'networks':None,
         'peer':None,
+         'serial':None,
+        'pkg':None,
+        'pkgf':None,
         'pub':None,
         'pubkey':None,
         'mobile':sp,
@@ -622,7 +659,6 @@ class sitelevel(level):
         'networks':"Networks claimed by the site",
         'hash':"hash function",
         'peer':"Gateway address of the site",
-        'pub':"public key of the site",
        }
        def mangle_name(self):
                return self.name.replace('/',',')
@@ -638,7 +674,42 @@ class sitelevel(level):
                self.indent(w,ind+2)
                w.write("name \"%s\";\n"%(np,))
                self.indent(w,ind+2)
-               w.write("key %s;\n"%str(self.properties["pub"].list[0]))
+
+               if pubkeys_install:
+                       pa=self.pubkeys_path()
+                       pw=open(pa+'~tmp','w')
+                       if 'serial' in self.properties:
+                               pw.write('serial %s\n' %
+                                        self.properties['serial'])
+               else:
+                       outk = []
+
+               fs=FilterState()
+               for k in self.properties["pub"].list:
+                       debugrepr('pubkeys ', k)
+                       if pubkeys_install:
+                               wout=k.forpub(output_version,fs)
+                               pw.write(' '.join(wout))
+                               pw.write('\n')
+                       else:
+                               if k.okforonlykey(output_version,fs):
+                                       outk.append(k)
+
+               if pubkeys_install:
+                       pw.close()
+                       os.rename(pa+'~tmp',pa+'~update')
+                       w.write("peer-keys \"%s\";\n"%pa);
+               else:
+                       if len(outk) == 0:
+                               complain("site with no public key");
+                       elif len(outk) != 1:
+                               debugrepr('outk ', outk)
+                               complain(
+ "site with multiple public keys, without --pubkeys-install (maybe --output-version=1 would help"
+                               )
+                       else:
+                               w.write("key %s;\n"%str(k))
+
                self.output_props(w,ind+2)
                self.indent(w,ind+2)
                w.write("link netlink {\n");
@@ -693,7 +764,7 @@ class FilterState:
        def reset(self):
                # called when we enter a new node,
                # in particular, at the start of each site
-               pass
+               self.pkg = '00000000'
 
 def pline(il,filterstate,allow_include=False):
        "Process a configuration file line"