Changeset 2261

Timestamp:

Jul 25, 2016, 1:35:51 PM (5 years ago)

Author:

jrpelegrina

Message:

Adding download time_file and is_update functions

Location:

lliurex-mirror/trunk/fuentes/n4d-lliurex-mirror.install

Files:

• etc/n4d/conf.d/MirrorManager (modified) (1 diff)
• usr/share/lliurex-mirror/conf/llx13.json (modified) (1 diff)
• usr/share/lliurex-mirror/conf/llx14.json (modified) (1 diff)
• usr/share/lliurex-mirror/conf/llx15.json (modified) (1 diff)
• usr/share/lliurex-mirror/conf/llx16.json (modified) (1 diff)
• usr/share/n4d/python-plugins/MirrorManager.py (modified) (3 diffs)

lliurex-mirror/trunk/fuentes/n4d-lliurex-mirror.install/etc/n4d/conf.d/MirrorManager

@@ -20 +20 @@
 get_available_mirrors=anonymous,*
 stopupdate=adm,admins
+is_mirror_update=anonymous,*

lliurex-mirror/trunk/fuentes/n4d-lliurex-mirror.install/usr/share/lliurex-mirror/conf/llx13.json

@@ -1 +1 @@
 {
+    "LLIUREX_ORIG":"lliurex.net/pandora"
     "URL": "lliurex.net/pandora",
     "ARCHITECTURES": [ "amd64", "i386"], 

lliurex-mirror/trunk/fuentes/n4d-lliurex-mirror.install/usr/share/lliurex-mirror/conf/llx14.json

@@ -1 +1 @@
 {
+    "LLIUREX_ORIG":"lliurex.net/platinum"       
     "URL": "lliurex.net/platinum", 
     "ARCHITECTURES": [ "amd64", "i386"], 

lliurex-mirror/trunk/fuentes/n4d-lliurex-mirror.install/usr/share/lliurex-mirror/conf/llx15.json

@@ -1 +1 @@
 {
+    "LLIUREX_ORIG":"lliurex.net/trusty"
     "URL": "lliurex.net/trusty", 
     "ARCHITECTURES": [ "amd64", "i386"], 

lliurex-mirror/trunk/fuentes/n4d-lliurex-mirror.install/usr/share/lliurex-mirror/conf/llx16.json

@@ -1 +1 @@
 {
+    "LLIUREX_ORIG":"lliurex.net/xenial"
     "URL": "lliurex.net/xenial", 
     "ARCHITECTURES": [ "amd64", "i386"], 

lliurex-mirror/trunk/fuentes/n4d-lliurex-mirror.install/usr/share/n4d/python-plugins/MirrorManager.py

@@ -16 +16 @@
 from multiprocessing import Process
 import socket
+from urllib2 import urlopen
+
+from datetime import datetime, date
 
 
@@ -172 +175 @@
                                 break
                 filelog.close()
+
+                self.download_time_file(distro)
+
                 self.set_mirror_info(distro)
 
@@ -393 +399 @@
                         return {'status':False,'msg':str(e)}
 
+
+        def download_time_file(self,distro):
+                
+                configpath = os.path.join(self.configpath,distro + ".json")
+                config = json.load(open(configpath,'r'))
+                path=config["MIRRORPATH"]
+                file="time-of-last-update"
+                dest=os.path.join(path,file)
+
+                orig_mirror=self.get_mirror_orig(distro)
+                url_mirror="http://"+os.path.join(orig_mirror['msg'],file)
+
+                return self.get_time_file(url_mirror,dest)
+
+        # def download_time_file                        
+
+                
+        def get_time_file(self,url,dest):
+                
+                try:
+                        r=urlopen(url)
+                        f=open(dest,"wb")
+                        f.write(r.read())
+                        f.close()
+                        r.close()
+                        return {'status':True,'msg':dest + 'download sucessfull.'}
+                
+                except Exception as e:
+                        return {'status':False,'msg':'Error downloading' + dest + str(e)}                       
+
+        # def get_time_file             
+
+        def is_mirror_update(self,distro):
+
+                configpath = os.path.join(self.configpath,distro + ".json")
+                config = json.load(open(configpath,'r'))
+                path=config["MIRRORPATH"]
+                file_time_name="time-of-last-update"
+                file_local_mirror=os.path.join(path,file_time_name)
+
+                
+                if os.path.isfile(file_local_mirror):
+                        url_pool="http://"+os.path.join(config["LLIUREX_ORIG"],file_time_name)
+                        file_pool=os.path.join("/tmp",file_time_name)
+
+                        exist_file_pool=self.get_time_file(url_pool,file_pool)
+                        if exist_file_pool['status']:
+                                file_local_mirror_content=open(file_miror,"r")
+                                file_local_miror_datetime=(file_local_mirror_content.readline().strip()).split("_")
+                                file_pool_content=open(file_pool,'r')
+                                file_pool_datetime=(file_pool_content.readline().strip()).split("_")
+                                file_local_mirror_content.close()
+                                file_pool_content.close()
+
+                                date_local_mirror=datetime.strptime(file_local_miror_datetime[0],"%Y/%m/%d")
+                                date_pool=datetime.strptime(file_pool_datetime[0],"%Y/%m/%d")
+
+                                if date_local_mirror==date_pool:
+                                        time_local_mirror=datetime.strptime(file_local_miror_datetime[1],"%H:%M")       
+                                        time_pool=datetime.strptime(file_pool_datetime[1],"%H:%M")
+
+                                        if time_local_mirror<time_pool:
+                                                return {'status':False,'msg':'Mirror is not update','action': 'update'}
+                                        elif :
+                                                return {'status':True,'msg':'Mirror is update','action':'nothing'}
+
+                                elif date_local_mirror<date_pool:
+                                        return {'status':False,'msg':'Mirror is not update','action': 'update'}
+                                else:
+                                        return {'status':True,'msg':'Mirror is update','action':'nothing'}      
+                        else:
+                                return {'status':False,'msg':exist_file_pool['msg'],'action':'nothing'} 
+
+                else:
+                        return {'status':False,'msg':file_local_mirror + 'dont exists.','action':'nothing'}
+
+        # def is_mirror_update