wireguard/celery fixes

uncloud_net/models.py

@@ -55,22 +55,16 @@ class WireGuardVPNPool(models.Model):
 
     @property
     def wireguard_config(self):
-        wireguard_config = [
-            "[Interface]\nListenPort = 51820\nPrivateKey = {self.wireguard_private_key}\n".format(
-                privatekey=self.wireguard_private_key)
-                            ]
+        wireguard_config = [ f"[Interface]\nListenPort = 51820\nPrivateKey = {self.wireguard_private_key}\n" ]
 
         peers = []
 
         for vpn in self.wireguardvpn_set.all():
             public_key = vpn.wireguard_public_key
-            peer_network = "{}/{}".format(vpn.address, self.subnetwork_mask)
+            peer_network = f"{vpn.address}/{self.subnetwork_mask}"
             owner = vpn.owner
 
-            peers.append("# Owner: {owner}\n[Peer]\nPublicKey = {public_key}\nAllowedIPs = {peer_network}\n\n".format(
-                owner=owner,
-                public_key=public_key,
-                peer_network=peer_network))
+            peers.append(f"# Owner: {owner}\n[Peer]\nPublicKey = {public_key}\nAllowedIPs = {peer_network}\n\n")
 
         wireguard_config.extend(peers)
 

uncloud_net/tasks.py

@@ -20,7 +20,12 @@ def configure_wireguard_server(wireguardvpnpool):
     server = wireguardvpnpool.vpn_server_hostname
 
     print(f"Configuring VPN server {server}")
-    cdist_configure_wireguard_server(config, server)
+    #res = cdist_configure_wireguard_server.delay(config, server)
+    res = cdist_configure_wireguard_server.apply_async((config, server), queue='cdist')
+
+    print(f"res={res}")
+    res2= res.get()
+    print(f"res2={res2}")
 
 
 @shared_task
@@ -33,5 +38,9 @@ def cdist_configure_wireguard_server(config, server):
 
     fname = f"/home/app/.cdist/type/__ungleich_wireguard/files/{server}"
 
+    print(os.uname())
     with open(fname, "w") as fd:
         fd.write(config)
+
+
+    return "All good"

uncloud_net/views.py

@@ -40,7 +40,7 @@ class WireGuardVPNViewSet(viewsets.ModelViewSet):
             public_key=serializer.validated_data['wireguard_public_key'],
             network_mask=serializer.validated_data['network_mask']
         )
-        configure_wireguard_server.apply_async((vpn.vpnpool,))
+        configure_wireguard_server(vpn.vpnpool)
         return Response(WireGuardVPNSerializer(vpn).data)