From 44bc85b7307d8664aa81f3b2cdf75e0e58f2ab2a Mon Sep 17 00:00:00 2001
From: Pcosson <pcosson@comitari.fr>
Date: Fri, 5 Jul 2024 11:14:18 +0200
Subject: [PATCH] reorganisation

---
 WAPT/control  |  44 ++++++++++++
 WAPT/icon.png | Bin 0 -> 2756 bytes
 all/setup.py  |   1 +
 setup.py      | 180 ++++++++++++++++++++++++++++++++++++++++++++++++++
 smtp.ini      |   5 ++
 wapt_api.ini  |   4 ++
 6 files changed, 234 insertions(+)
 create mode 100644 WAPT/control
 create mode 100644 WAPT/icon.png
 create mode 100644 setup.py
 create mode 100644 smtp.ini
 create mode 100644 wapt_api.ini

diff --git a/WAPT/control b/WAPT/control
new file mode 100644
index 0000000..40c96b9
--- /dev/null
+++ b/WAPT/control
@@ -0,0 +1,44 @@
+package           : comi-apps-to-update-on-wapt-server
+version           : 0-16
+architecture      : all
+section           : base
+priority          : optional
+name              : json-update
+categories        : Utilities
+maintainer        : Comitari,pcosson
+description       : Package to audit the wapt-server and generate a json with applications that are not up to date
+depends           : 
+conflicts         : 
+maturity          : PROD
+locale            : all
+target_os         : all
+min_wapt_version  : 2.3
+sources           : 
+installed_size    : 
+impacted_process  : 
+description_fr    : Package pour auditer le serveur wapt et générer un json avec les applications qui ne sont pas à jour
+description_pl    : Pakiet do audytu serwera wapt i generowania pliku json z aplikacjami, które nie są aktualne
+description_de    : Paket zur Überprüfung des wapt-Servers und zur Erstellung eines json mit Anwendungen, die nicht auf dem neuesten Stand sind
+description_es    : Paquete para auditar el servidor wapt y generar un json con las aplicaciones que no están actualizadas
+description_pt    : Pacote para auditar o wapt-server e gerar um json com as aplicações que não estão atualizadas
+description_it    : Pacchetto per verificare il server wapt e generare un json con le applicazioni che non sono aggiornate
+description_nl    : Pakket om de wapt-server te controleren en een json te genereren met applicaties die niet up-to-date zijn
+description_ru    : Пакет для аудита wapt-сервера и генерации json с неактуальными приложениями
+audit_schedule    : 
+editor            : 
+keywords          : 
+licence           : opensource_free,wapt_public
+homepage          : 
+package_uuid      : 56be0e6d-4573-4d1f-ad99-1cc5d5d4c718
+valid_from        : 
+valid_until       : 
+forced_install_on : 
+changelog         : 
+min_os_version    : 
+max_os_version    : 
+icon_sha256sum    : d642b35ce6441158dc071677fb958ad01830271d373c332d64e48dec67f80834
+signer            : pcosson_key
+signer_fingerprint: a25582410cf03bad179a60c189f459a0b03821c92c0cedf209e82448a66a9b4e
+signature_date    : 2024-04-30T15:04:28.000000
+signed_attributes : package,version,architecture,section,priority,name,categories,maintainer,description,depends,conflicts,maturity,locale,target_os,min_wapt_version,sources,installed_size,impacted_process,description_fr,description_pl,description_de,description_es,description_pt,description_it,description_nl,description_ru,audit_schedule,editor,keywords,licence,homepage,package_uuid,valid_from,valid_until,forced_install_on,changelog,min_os_version,max_os_version,icon_sha256sum,signer,signer_fingerprint,signature_date,signed_attributes
+signature         : MaKQmI6kWy/jfJDWUJ7FQlwYyIU0FyH6GHi06Tj7DcPOMJgkliC2zCrQtT+d2YGs1kC6HjkPFHMm4zOhk8j4IMUESQH+X7MgYIGizCAXTbyQfxecR9MwvRyQ7flF+d7+i5KHWBYNJmHz/4ng37a6viFyqPfK8uZ5kQC/w+BWMIV+kJFDmxtSWppSVLa27nq8N4sk6r+6R8Of/bY+o1rHpTbzr76b8WK48OFtEUNJ+2NM5l68bJB1t6lgF+4R0SDpMykL+/h4t77jpS8ZCAuoOuBVGrUuvwyIuXQx15Nk7zKgIQ60ePDY8rrTe4PsT5f+BK7ow/6Oe88rUu0Zw8WQ6g==
\ No newline at end of file
diff --git a/WAPT/icon.png b/WAPT/icon.png
new file mode 100644
index 0000000000000000000000000000000000000000..1f86e211f498b95d52f6ff9a5e4e8a8d4398a367
GIT binary patch
literal 2756
zcmV;#3On_QP)<h;3K|Lk000e1NJLTq001xm001xu1^@s6R|5Hm00009a7bBm00027
z000270mdy!jQ{`u8FWQhbW?9;ba!ELWdL_~cP?peYja~^aAhuUa%Y?FJQ@H13Q<W!
zK~!jg)tPH_RMi#7fBW7f6JEYs9%4}m7|F~e3bwQ;1uU&qS@p%kN0*8iD%8@{0LcJ4
z3zL}vqPBvof)p+FRruiYfvbuns1z%rkjy0V2m%TPODI~NlVtAhhdX&pawiXhb#;H4
zS#!?0=l?tV%-;K)3;*XP-?o4R%iWyH`P~Mgv3>}3XlyT`EB3TC#2FyJya%bq3Y25i
zrOoEC%WA#}y#VBG>_&ReNvJU%(J_Flg~T1GwSsidBK%^t9Nrorzq|)&#+xW3<G&n2
zWd<SlOJ`KLUkz#_(}9OkE&vqx7-2KWAuLTtm=1IYz_c<c%HG~KfW7i-fFA=d10MhZ
zpa;t9n6U>a&e`8}@teC->v|sLX5bjgQm9|jxLsyPvN7~IAO|>vY91l)3r>$Rl8UeX
z^e%#)CowG#$U1~^SY{;!ktv{E`|m_u&&I{SjgUdeliw)bSCNOI9|1WiE2&Kzl1w}_
z_kb@v1LgO?TU38~1FI**n!2e_P<bDsCBWIBr6~6k@_yE7@dcF`h_w@812xexEE`tW
zq#-g1)t7+1s7@i|eW$(08O^@E0h|E549q;M1*Z~nFUN>w0dIheK_pCJ<hS_Mpfe^6
ziGO=7K|FwJArM9DM|DJeB0!O67w9~oFBp$I_AbuZPtY?C)w_U`pidC3T+}H5Vi^Ef
zR68_Y4D4txbT+rd)vMn22b6yxdJn$H&ytP`d0(K;8UnHhbOv*)26c2o5F5a-b~?0`
z1A~~gt)JsizZw)q?#36H?+mbdLJT#g08vzzGHY9}q&iBn{{>bEFtK9ScN~BWKskAQ
zmqXiMfOO2d$65u7IpJYM!y7@LLv<ehE$6fb09cS!2~q?MAf+zUrW7&u#J`;1Nr3%4
z@uQQiTB@s70GohG6hu~1xOFfETQ0^Ieg=yVL4E)nw>zg9&Hw<1Pb~n-QGUhjijj_e
zY#Y%qb%&%ER9p&t4{+E%*gHVXn}AOc?gDc=lCm3R3Q&b`Bk%<f<5+z(Il!`Eb%-??
zun<{J-o|bYVuqrc4}j{(cB4^2#ifX>2TYXbllBV?Il$rQa76D#SpmENl8dY63Y3XJ
zCL$%2WFLq2iaB36fKmwjk?Kz$Y|IUX<=24mD$omM7s6$r&k*!X1<@qp%dl5}CP7b0
zoAWwqiA+az39uel%~<@S>)QwL?@lLr>?6PpS_!fNr9Z;Yu}9yIrE3vc3k-FHXf9sJ
zC*XO^{yj1c(S?XLl0fz+ZR)TW>>c1R^~RMf$~xH4)VACGmz;u>Q79|p;cqI!4Zz9x
z*c?LMBdCrAJ_flTU**${5hR&-Ut~I>OF+M--gVG<^0>{e%!+&40=>1lczX>yYW~We
zoMZqNhe@>*r4$%~5G3I7QBZMilP6e;$s%HuI*M0a40-^p(FAjL*kic~k)BxE9V7)q
zdZCtp+zIqUm_)#{s->*cFUox3-ar}3<w+n;0^O2|H+2j}+1tr4|1POg3X+v%rYIu0
z1l%i~8oO3i&aCW1s#V$s#0Lc3BS5rCJO?qY(G+EG#~1F6>N;DzE<{<2XcUzb09bN@
z?#7q+v;Lh-Lf4O!?L#a@HG;^Kz(LS41ijmA@$qel%qQr6<aDM#GiTzNm3>ID%7Dxy
z5X8lgCg|Ok2rZ8ia6f#yQ+KWuPG)ATI}Jxar4U~@kQki+w2Yu<JHD#Eq*x9Ao#L*D
zhcn@Ugd`>NK_`&Z6Z&UVhTDmc071{3u1?=I4<v}!hX}eKq23q`9B}r8+--}O(3ubq
zka9-E3;6`R_94iO-3HPJXxL7~Ju$Y?6QXC?$xbwWz+Z`KDlYR*{8`63Bjfb8(449P
zSg|tT5)>aHPcROZi^$W!mngT}*;cZE5`vzY__v%xH03Se`=HNIr+K8BuYz712i}O4
zdL0WhkA8CiNo$*mU)!Nl4`8N@qG-rY3L;k_x+y-BQ*=52^hIPfYMlVN8{~ala(zcV
zksM(BDwBbOE&?+nUI%4hNCxPL_(fDxRp}&tR(XF+qYV21a|AfI5n@jGA}n?SE<{$7
zcIXZmWf2Xp=qyBQ0RQIhL|rAoy+FFdh#Fu%0ng&3;^%C=5X)Q-WFQ2=T#Uv_flQ#p
zK3VBCjpE~_F@7~V3y}ygewE3<%U?klhq4`E6RJBg*oBzYq*9%b))Q)*hLzve52J29
z!XTQ5N;}!DgZQ;dOYw~h*g1$qfP#v7h|EWLg_`KZR`)i|&E5ukTZuR8%RmR)Ny;;~
zv47siZlw2m4fqML3RlgY_(#{{D|dr&h=AuyM+o6P(u^CDK{Vw7U${3Sg}^@2((h?g
zJV2^@KdQe$V<Vcad@1N)&>{!%ueK5opvGF1EfiK{HUWr*%QM+de2k>lT0?$$kG26+
zr(&1C3-J&7Pn+T!CJA}%3t3-PUyQoac#@h=&^s@oZ+g!ez*vM03F7T}9|8J+l(q?x
zX1wVH(JT|oMBpn<9$nt9_*NF1+a%ths<c=G96=e*sq=46XbX9lp^^*q26@*$fhB=R
zHClPX{twJ8zl50a8SpGY&t!o3&D?#cb_4m4Sjq|(X8zMrzb~>1)$v%-b67C!YsWqX
z6+`3kzZa@^5b~~0Y>!MqbSY4SWsI@!ry4+-|FJ2<Wn70ps}>qOP;cbKc|Nco7M_FZ
z-%uS7+z9$8X59`7BGVkjS!##d+S*#jc7Txg<9JPU6p<Gxth_C;-Mt)@slWvoR;i;W
z?CY4(oU)1<nrr~!BKy<Yhp+rvghxU4U~m;KqZjC8(614F3SUKDD{&HkEwpc6a)6c)
zST9l#xwRDp<R*nUo<0R+2f~9CRGixcfZ9c!N;lM84p<m6kz&tg{8`5cdY{GAtATx}
z1n^b$Z2^!DSc&fx+J!iV=u532f}TGmK={htjctnuMG;*Fq=PZ02|$d7z5O`o#VAWC
z&f1jl;G*o^s04v@)cR>co2m<Fd-dCbC=B1y8bYT5-$9MFJhc6S#x{{102tc889@E}
z*e}@z0H2d?%*DwJYq#CsI<N6JU%4A(Fz{7}0a`-9%dH{2OHs*1*+a_FrkoU`HvlSM
zH31ao><8Hp?=n4U>Q<Q&C)o<vH)d+Q2b_({?>YtG1W^!f5n|oT33+~)5ZQ!DaV>vu
z0st_KUxM)qf}S@VC-a5J0=IyyBj7HxU-lVq13iFyPWv@%!gk`X6jt1nv~OYf0nlqv
z))307ws|^Y{>n6>Ryi;bv4*3@G~hmj8dPs1=zaIJ#5cF5Jkb-8Ja$$+-53;dH>Yx*
zD<7c<IE2Af6nnntIDjua6J;S#g?-~T6!b$Za{>#pKJT*lMu^HQ5bJf|Lf~^?BO)fM
zR|9>4y;wSq1>SJOkd7VdRU1Oxkhu7#aG4{|sCa--))s2hazGvjQh`bFWEw+c0WRap
z=Hj8F9+*|$A4BXy%P?yQWNkg8!jqZ5@;pw(l#utx|75;z!~P4vw6ZexF26?r0000<
KMNUMnLSTX<RPnU{

literal 0
HcmV?d00001

diff --git a/all/setup.py b/all/setup.py
index b52587f..b642ff2 100644
--- a/all/setup.py
+++ b/all/setup.py
@@ -2,6 +2,7 @@
 from setuphelpers import *
 import requests
 import json
+import smtplib
 from configparser import ConfigParser
 from waptpackage import HostCapabilities
 from waptpackage import WaptRemoteRepo
diff --git a/setup.py b/setup.py
new file mode 100644
index 0000000..b642ff2
--- /dev/null
+++ b/setup.py
@@ -0,0 +1,180 @@
+# -*- coding: utf-8 -*-
+from setuphelpers import *
+import requests
+import json
+import smtplib
+from configparser import ConfigParser
+from waptpackage import HostCapabilities
+from waptpackage import WaptRemoteRepo
+from waptpackage import PackageVersion
+
+all_package = {}
+
+dict_host_capa = {
+    "ubuntu22frx64": HostCapabilities(
+        architecture="x64",
+        language="fr",
+        os="ubuntu",
+        packages_locales=["fr", "en", "es", "de", "it"],
+        tags=["debian", "debian_based", "linux", "unix", "debian11", "ubuntu-22"],
+        os_version="11",
+    ),
+    "ubuntu20frx64": HostCapabilities(
+        architecture="x64",
+        language="fr",
+        os="ubuntu",
+        packages_locales=["fr", "en", "es", "de", "it"],
+        tags=["debian", "debian_based", "linux", "unix", "debian11", "ubuntu-20"],
+        os_version="11",
+    ),
+    "debian11frx64": HostCapabilities(
+        architecture="x64",
+        language="fr",
+        os="debian",
+        packages_locales=["fr", "en", "es", "de", "it"],
+        tags=["debian-bullseye", "debian", "debian_based", "linux", "unix", "debian11", "debian-11"],
+        os_version="11",
+    ),
+    "debian12frx64": HostCapabilities(
+        architecture="x64",
+        language="fr",
+        os="debian",
+        packages_locales=["fr", "en", "es", "de", "it"],
+        tags=["debian-bookworm", "debian", "debian_based", "linux", "unix", "debian12", "debian-12"],
+        os_version="11",
+    ),
+    "win10x64fr": HostCapabilities(
+        architecture="x64",
+        language="fr",
+        os="windows",
+        packages_locales=["fr", "en", "es", "de", "it"],
+        tags=["windows-10", "win-10", "w-10", "windows10", "win10", "w10", "windows", "win", "w"],
+        os_version="10.0.19043",
+    ),
+}
+webhook_url="https://chat.comitari.fr/hooks/64d4d02760b38508f62a5bcb/ncKSYRiLM9oNXagK5c7G3KWX2qEzET3kbFFXKnNAhtfZQEQ9"
+
+def install():
+    plugin_inifiles = glob.glob("*.ini")
+
+    for file in plugin_inifiles:
+        if not isfile(makepath(WAPT.private_dir,file.split("\\")[-1])) :
+            print(f"copie de {file} dans {WAPT.private_dir}")
+            filecopyto(file, WAPT.private_dir)
+
+def audit():
+    plugin_inifile = makepath(WAPT.private_dir, "wapt_api.ini")
+    conf_wapt = ConfigParser()
+    conf_wapt.read(plugin_inifile)
+    wapt_url = conf_wapt.get("wapt", "wapt_url")
+    wapt_user = conf_wapt.get("wapt", "wapt_username")
+    wapt_password = conf_wapt.get("wapt", "wapt_password")
+
+    app_to_update_json_path = makepath(WAPT.private_dir, "app_to_update.json")
+    if isfile(app_to_update_json_path):
+        print("suppression de l'ancienne version du fichier json")
+        remove_file(app_to_update_json_path)
+
+    store = WaptRemoteRepo(name="main", url="https://wapt.tranquil.it/wapt", timeout=4, verify_cert=False)
+    localstore = WaptRemoteRepo(name="main", url="https://srvwapt.comitari.fr/wapt", timeout=4, verify_cert=False)
+    # Download JSON data from the URL
+    online_package_list = {}
+    local_package_list = {}
+    for hc in dict_host_capa:
+        online_package_version = {}
+        for packageentry in store.packages():
+            if dict_host_capa[hc].is_matching_package(packageentry):
+                if not packageentry.package in online_package_version:
+                    online_package_version[packageentry.package] = "0"
+                if PackageVersion(online_package_version[packageentry.package]) < PackageVersion(packageentry.version):
+                    online_package_version[packageentry.package] = packageentry.version
+        online_package_list[hc] = online_package_version
+
+    for hc in dict_host_capa:
+        local_package_version = {}
+        for packageentry in localstore.packages():
+            if dict_host_capa[hc].is_matching_package(packageentry):
+                if not packageentry.package in local_package_version:
+                    local_package_version[packageentry.package] = "0"
+                if PackageVersion(local_package_version[packageentry.package]) < PackageVersion(packageentry.version):
+                    local_package_version[packageentry.package] = packageentry.version
+        local_package_list[hc] = local_package_version
+
+    list_app_to_update = []
+    for hc in dict_host_capa:
+        for app in local_package_list[hc]:
+            if "-" in app:
+                if "tis-" + app.split("-", 1)[1] in online_package_list[hc]:
+                    if PackageVersion(local_package_list[hc][app]) < PackageVersion(online_package_list[hc]["tis-" + app.split("-", 1)[1]]) and app not in list_app_to_update:
+                        print(
+                            f'{app} new version detected from {local_package_list[hc][app]} to {online_package_list[hc]["tis-"+app.split("-", 1)[1]]} for {hc}'
+                        )
+                        list_app_to_update.append(
+                            {
+                                "package": app,
+                                "old_version": local_package_list[hc][app],
+                                "new_version": online_package_list[hc]["tis-" + app.split("-", 1)[1]],
+                            }
+                        )
+    WAPT.write_audit_data_if_changed("apps_to_upgrade", "list", list_app_to_update, max_count=3)
+
+
+    if not list_app_to_update:
+        message="your repository seems up to date"
+        print(message)
+        send_to_rocket(webhook_url,message)
+        return "OK"
+    else:
+        message="you need to update some packages"
+        print(message)
+        send_to_rocket(webhook_url,message)
+        return "WARNING"
+
+
+def send_to_rocket(webhook_url, message_text, attachments=None):
+    """
+    Envoie un message à Rocket.Chat via un webhook.
+    
+    :param webhook_url: URL du webhook Rocket.Chat
+    :param message_text: Texte du message à envoyer
+    :param attachments: Liste de pièces jointes (facultatif)
+    """
+    # Construire le message
+    message = {
+        'text': message_text
+    }
+    if attachments:
+        message['attachments'] = attachments
+
+    # Envoyer la requête POST
+    response = requests.post(webhook_url, data=json.dumps(message), headers={'Content-Type': 'application/json'})
+    
+    # Vérifier la réponse
+    if response.status_code == 200:
+        print('Message envoyé avec succès.')
+    else:
+        print(f'Échec de l\'envoi du message. Statut de la réponse : {response.status_code}')
+        print(f'Erreur : {response.text}')
+
+
+def send_mail(body,subject):
+
+    smtp_inifile = makepath(WAPT.private_dir, "smtp.ini")
+    conf_wapt = ConfigParser()
+    conf_wapt.read(smtp_inifile)
+
+    from_addr = conf_wapt.get("smtp", "from_addr")
+    to_addr = conf_wapt.get("smtp", "to_addr")
+    password = conf_wapt.get("smtp", "password")
+    smtpserver = conf_wapt.get("smtp", "smtpserver")
+
+    print(from_addr)
+
+
+    message = f"Subject: {subject}\n\n{body}"
+    server = smtplib.SMTP(smtpserver, 587)
+    server.starttls()
+    server.login(from_addr, password)
+    server.sendmail(from_addr, to_addr, message)
+    server.quit()
+    return "OK"
\ No newline at end of file
diff --git a/smtp.ini b/smtp.ini
new file mode 100644
index 0000000..ccc7d1e
--- /dev/null
+++ b/smtp.ini
@@ -0,0 +1,5 @@
+[wapt]
+from_addr =
+to_addr =
+password =
+smtpserver =
\ No newline at end of file
diff --git a/wapt_api.ini b/wapt_api.ini
new file mode 100644
index 0000000..3f2be2f
--- /dev/null
+++ b/wapt_api.ini
@@ -0,0 +1,4 @@
+[wapt]
+wapt_username = xxxxx
+wapt_password = xxxxx
+wapt_url =xxxxx
\ No newline at end of file