projet.py

import os,sys,time
import lexer as ssp 

#  **** fonction pour excuter*****


def executerCommandeSimple(processus, entreeProcessus=0, sortieProcessus=1, sortiePrec = None, premierFils = False):
	(rfd,wfd)=os.pipe() # derscrtiteur de lecture et dectiture de pipe

	pid=os.fork() # 
	if(pid==0): # le fils s'ocuupe de l'excution de la commande

		commande=processus._cmd.getCommand()
		argCommande=processus._cmd.getArgs()
		redirEntree=filtrerRedirectionsEntree(processus)
		
		if redirEntree:
			#print(redirEntree._filespec)
			re_re_fd=os.open(redirEntree._filespec, os.O_RDONLY)
			os.dup2(re_re_fd, 0)
			# os.close(re_re_fd)
		elif entreeProcessus != 0 and sortiePrec:
			os.close(sortiePrec)
			afficherErreur("je vais fermer sortieProcessus")
			# os.close(sortiePrec)
			afficherErreur("lire depuis " + str(entreeProcessus) + " au lieu de 0 pour " + commande)
			os.dup2(entreeProcessus, 0)
			#os.close(entreeProcessus)

		re_wr_fd=None
		redirSortie=filtrerRedirectionsSortie(processus) # redirection de la sortie gerer par le pere
		
		## redirection entre *************
		if redirSortie:
			
			if redirSortie.isAppend():
				re_wr_fd=os.open(redirSortie._filespec, os.O_WRONLY | os.O_APPEND | os.O_CREAT )
			else:
				re_wr_fd=os.open(redirSortie._filespec, os.O_WRONLY| os.O_CREAT | os.O_TRUNC)


			os.dup2(re_wr_fd,1)

			# fin ***********************************

			
		elif sortieProcessus != 1:
			os.close(entreeProcessus)

			afficherErreur('ecrire dans ' + str(sortieProcessus) + ' au lieu de 1 pour ' + processus._cmd.getCommand())
			os.close(1)
			os.dup2(sortieProcessus,1)
			

		redirErreur=filtrerRedirectionsErreur(processus)# redirection d'erreur gerer par le fils 
		re_Er_fd=None
		if redirErreur: 
			if redirErreur.isAppend():
				re_Er_fd=os.open(redirErreur._filespec, os.O_WRONLY | os.O_APPEND | os.O_CREAT)
			else:
				re_Er_fd=os.open(redirErreur._filespec, os.O_WRONLY| os.O_CREAT | os.O_TRUNC)
			
			os.dup2(re_Er_fd,2)	

		argCommande=[commande]+ argCommande # pour tt les fonction exec le 1er argCommande doit etre la commande lui meme

		try: # essaye cette commande 
			os.execv("/bin/"+commande,argCommande)
		except OSError as e:
			if e.errno==2: # si il y a une erreur 
				try:
					afficherErreur( commande +" va executer")
					os.execv("/usr/bin/"+commande,argCommande) # esaye l'autre commande 
				except OSError as e:
					afficherErreur(e.strerror)
					if e.errno==2:
						try:
							afficherErreur( commande +" va executer 3")

							os.execv("./"+commande, argCommande)
						except OSError as e:
							afficherErreur("commande echoue")
							afficherErreur(e.strerror)
		sys.exit(-1)
				
			
	else: # pere 
		pass
		

					

def log(msg): # pour voir les erreur sur le code
	log_fd=os.open("log.txt", os.O_CREAT | os.O_WRONLY | os.O_APPEND )
	os.write(log_fd,bytearray(msg + '\n',"utf-8"))
	os.close(log_fd)

def afficherErreur(msg):
	os.write(2, bytearray(msg+'\n',"utf-8"))


def filtrerRedirectionsEntree(processus):
	return  next((re for re in processus._redirs._redirs if re.__class__.__name__ == "INREDIR"), None)

def filtrerRedirectionsSortie(processus):
	return  next((re for re in processus._redirs._redirs if re.__class__.__name__ == "OUTREDIR"), None)

def filtrerRedirectionsErreur(processus):
	return  next((re for re in processus._redirs._redirs if re.__class__.__name__ == "ERRREDIR"), None)


if __name__ =='__main__':
	pl = ssp.get_parser().parse("ps -aux | sort -k1n | wc -c ")
	#pl = ssp.get_parser().parse("ls -al | sort -k1 | tr ‘A-Z’ ‘a-z’")
	#pl=ssp.get_parser().parse("ps -aux | sort -k1n   | tr 'a-z' 'A-Z' | tee toto.txt | wc -c")



	tubesEnchainement = []
	for i in range(len(pl)):
		tubesEnchainement.append(os.pipe())



	# afficherErreur(str(pl) + ' ' + str(len(pl)))
	for i in range(len(pl)):
		p = pl[i]

		if(len(pl) == 1):
			executerCommandeSimple(p, entreeProcessus =0, sortieProcessus= 1)

		elif i == 0:
			executerCommandeSimple(p, 0, tubesEnchainement[i][1], premierFils = True)
		elif i == len(pl)-1:
			executerCommandeSimple(p, tubesEnchainement[i-1][0], sortieProcessus=1, sortiePrec=tubesEnchainement[i-1][1])
		else:
			executerCommandeSimple(p, tubesEnchainement[i-1][0], tubesEnchainement[i][1], tubesEnchainement[i-1][1])


	afficherErreur("avant fermeture fils")
	for i in range(len(pl)):
		(p,es) = os.waitpid(-1,os.WNOHANG)

	afficherErreur("fin du programe")