pyanaf/spv_java2.py

'''Created Sep 20, 2021 Levi'''
# coding: utf-8
import subprocess as sp
import json
import configparser
import pprint
from json.decoder import JSONDecodeError
from time import sleep
from multiprocessing.pool import ThreadPool
from threading import Event

import psutil
import telegram
from declarations import (count_down, pretty_exc)

# In "C:\Program Files\Java\jre1.8.0_333\lib\security\java.security" file comment the
# jdk.tls.disabledAlgorithms=SSLv3, TLSv1, TLSv1.1, RC4, DES, MD5withRSA, \
#     DH keySize < 1024, EC keySize < 224, 3DES_EDE_CBC, anon, NULL, \
#     include jdk.disabled.namedCurves
# lines
event = Event()
config = configparser.ConfigParser()
config.read('bot')
bot = telegram.Bot(token=config['AUTH']['token2'])

proc_name = 'javaw.exe'
days = '"30"'
url = f'"https://webserviced.anaf.ro/SPVWS2/rest/listaMesaje?zile={days}"'
pin = '"61103989"'
java_executable = '"C:\Program Files\Java\jre1.8.0_301\bin\javaw.exe" -jar'
jar_package = 'ApelSPV-1.0-SNAPSHOT.jar'

def kill_proc(name, timeout, pool_=None):
    # print('waiting')
    # event.wait()
    while timeout >= 0:
        # print(timeout, '' * 3, end='\r')
        sleep(1)
        timeout -= 1
    if pool_:
        pool_.close()
    for proc in psutil.process_iter():
        # check whether the process name matches
        if proc.name() == name:
            proc.kill()

def run_proc1():
    proc_1 = sp.run(f'{java_executable} {jar_package} {url} {pin}',
                    shell=True, capture_output=True, text=True)
    # print(event.is_set())
    # event.set()
    # print(event.is_set())
    return proc_1.stdout


if __name__ == '__main__':
    # run_proc1()
    messages = []
    while True:
        try:
            pool = ThreadPool(processes=1)
            async_result = pool.apply_async(run_proc1)
            kill_proc(proc_name, 10, pool_=pool)
            return_val = async_result.get()
            print(return_val)
            return_val = json.loads(return_val)
            for message in return_val['mesaje']:
                # print(message)
                if message['tip'] != 'RECIPISA':
                    messages.append(message)
            pprint.pprint(messages, indent=4)
            # print(return_val['titlu'])
            # print('last message type', return_val['mesaje'][0]['tip'])
            # if return_val['mesaje'][0]['tip'] != 'RECIPISA':
            #     bot.send_message(chat_id=config['AUTH']['chatid'], text=return_val['mesaje'][0]['detalii'])
            break
            count_down(1800, d_type='h', up_down='down')
        except JSONDecodeError as exc_:
            pretty_exc(exc_)
            print(return_val[:7])
            count_down(10, d_type='h', up_down='down')