Adding A type record dns adding

.drone.yml

@@ -0,0 +1,17 @@
+kind: pipeline
+type: docker
+name: syntax
+
+platform:
+  os: linux
+  arch: arm
+
+steps:
+- name: syntax
+  pull: if-not-exists
+  image: python:3.7-slim-buster
+  commands:
+  - apt update
+  - apt install -y pylint libcurl4-openssl-dev libssl-dev python-dev gcc
+  - pip3 install -r requirements.txt 
+  - pylint *.py

.gitignore

@@ -1,3 +1,6 @@
+!.drone.yml
+# IGNORE
 data/*
 *.yml
 *.conf
+*.swp

README.md

@@ -2,5 +2,6 @@
 
 Needed files:
 
-* ovh.conf as explained here : https://github.com/ovh/python-ovh
+* ovh.conf as explained here : https://github.com/ovh/python-ovh.
-* creds.yml containing nextcloud credentials for bill upload
+* creds.yml containing nextcloud credentials for bill upload.
+* data directory next to scripts.

ovh-bills.py

@@ -2,8 +2,8 @@
 
 import requests
 import ovh
-import pycurl
 import yaml
+import pycurl
 
 try:
     input = raw_input
@@ -24,7 +24,7 @@ for bill in bills:
         f.write(r.content)
         f.close()
         url += bill + ".pdf"
-        with open('/dev/null','wb') as output:
+        with open('/dev/null', 'wb') as output:
             c = pycurl.Curl()
             c.setopt(c.URL, url)
             c.setopt(c.USERPWD, '%s:%s' %(username, password))
@@ -34,7 +34,7 @@ for bill in bills:
             status = c.getinfo(c.RESPONSE_CODE)
             c.close()
             output.close()
-            if (status == 404):
+            if status == 404:
                 file = open(file_path)
                 c = pycurl.Curl()
                 c.setopt(c.URL, url)

ovh-domain.py

@@ -1,18 +1,41 @@
 #!/usr/bin/python3
 
-import requests
+import argparse
+import json
 import ovh
 import pycurl
-import argparse
+import requests
 
 try:
     input = raw_input
 except NameError:
     pass
 
-parser = argparse.ArgumentParser(description='Process arguments')
+def addCNAME(client,domain,fr,to):
-parser.add_argument('domain', metavar='method', type=str, help='Function to use')
+    result = client.get(base_url + "/record",fieldType="CNAME",subDomain=fr)
-parser.add_argument('--method', metavar='fr', type=str, help='domain to request from')
+    if not result:
+        result = client.post(base_url + "/record",fieldType="CNAME",subDomain=fr,target=to)
+        print(json.dumps(result,indent=4))
+        result = client.post(base_url+ "/refresh")
+        print("Refresh zone trigger")
+    else:
+        print("CNAME already existing")
+
+def addA(client,domain,fr,to):
+    result = client.get(base_url + "/record",fieldType="A",subDomain=fr)
+    if not result:
+        result = client.post(base_url + "/record",fieldType="A",subDomain=fr,target=to)
+        print(json.dumps(result,indent=4))
+        result = client.post(base_url+ "/refresh")
+        print("Refresh zone trigger")
+    else:
+        print("A record already existing")
+
+parser = argparse.ArgumentParser(description="Process arguments")
+parser.add_argument("domain", metavar="domain", type=str, help="Domain to request")
+parser.add_argument("--method", metavar="type", type=str, help="Function to use. Ex: addCNAME")
+parser.add_argument("--src", metavar="src", type=str, help="Source subdomain")
+parser.add_argument("--dest", metavar="dst", type=str, help="Dest IP or domain")
 args = parser.parse_args()
 
 # Instantiate. Visit https://api.ovh.com/createToken/?GET=/me
@@ -20,7 +43,13 @@ args = parser.parse_args()
 client = ovh.Client()
 
 # Grab bill list
-zone = client.get('/domain/zone/' + args.domain + '/record')
+base_url = "/domain/zone/" + args.domain
-for id in zone:
+zone = client.get(base_url + "/record")
-    entry = client.get('/domain/zone/' + args.domain + '/record/'+str(id))
+if args.method == "list":
+    for id in zone:
+        entry = client.get(base_url + "/record/"+str(id))
         print(entry)
+elif args.method == "addCNAME":
+    addCNAME(client,args.domain,args.src,args.dest)
+elif args.method == "addA":
+    addA(client,args.domain,args.src,args.dest)

ovh-mail.py

@@ -15,7 +15,7 @@ def writeRedirectionsToFile(client,domain):
         file.write(redirection['from']+','+redirection['to']+','+redirection['id']+'\n')
     file.close()
 
-def checkRedirExists(client,domain, fr,to):
+def checkRedirExists(client,domain,fr,to):
     mailbox = client.get('/email/domain/' + domain + '/redirection')
     for id in mailbox:
         redirection = client.get('/email/domain/' + domain +'/redirection/'+str(id))
@@ -33,6 +33,15 @@ def addRedirection(client,domain,fr,to):
     print(json.dumps(result,indent=4))
     return 0
 
+def delRedirection(client,domain,fr,to):
+    id_redir = checkRedirExists(client,domain,fr,to)
+    if not id_redir:
+        return False
+    else:
+        result = client.delete('/email/domain/'+ domain +'/redirection/' + str(id_redir))
+        print(json.dumps(result,indent=4))
+        return 0
+
 parser = argparse.ArgumentParser(description='Process arguments')
 parser.add_argument('method', metavar='method', type=str, help='Function to use')
 parser.add_argument('domain', metavar='domain', type=str, help='domain')
@@ -52,3 +61,5 @@ if (args.method == "write"):
 elif (args.method == "add"):
     if not (checkRedirExists(client,args.domain,args.fr,args.to)):
         addRedirection(client,args.domain,args.fr,args.to)
+elif (args.method == "del"):
+    status = delRedirection(client,args.domain,args.fr,args.to)

requirements.txt

@@ -0,0 +1,4 @@
+argparse
+pycurl
+ovh
+requests