#Author: <NAME> 
#Course: CS 4375 Theory of Operating Systems
#Instructor: Dr. <NAME>
#T.A: <NAME> 
#Assignment: Project 1 
#Last Modification: 10/02/2020
#Purpose: Basic shell

import os 
import sys
import re 

def shell_input(u_str): #This method checks out string 
    if '' == u_str or u_str.isspace():
        return

    if 'exit' in u_str:  #If exit is detected, then program quits 
        sys.exit(0)

    if 'cd' in u_str: #Changes directory using input
        try:
            os.chdir(u_str.split()[1])
        except Exception:
            print("cd: no such file or directory: {}".format(u_str))
        return

    if '|' in u_str: #Detects pipes from the string
        pid = os.getpid()
        rc = os.fork()

        if rc < 0:
            os.write(2, ("fork failed, returning %d\n" % rc).encode())
            sys.exit(1)

        if rc == 0:
            n_args = []
            args = u_str.split('|')
            
            for i in range(len(args)):
                n_args.append(args[i].split())

            pipe(n_args)

        else: 
            childPidCode = os.wait()
            main()
            return

    if '>' in u_str: #Redirect output
        n_args = []
        args = u_str.split('>')

        for i in range(len(args)):
            n_args.append(args[i].split())

        redirect_output(n_args)
        return

    if '<' in u_str: #Redirect input
        n_args = []
        args = u_str.split('<')

        for i in range(len(args)):
            n_args.append(args[i].split())

        redirect_input(n_args)
        return

    if '&' in u_str: #For background processes
        n_args = []
        args = u_str.split('&')

        if args[-1] == "": #Runs background process
            args.remove("")
            for i in range(len(args)):
                n_args.append(args[i].split())

            for i in range(len(n_args)):
                background_exec(n_args[i])

        else: #Runs processes normally
            for i in range(len(args)): 
                n_args.append(args[i].split())

            for i in range(len(n_args)):
                exec(n_args[i])

        return

    args = u_str.split()
    exec(args)

def redirect_input(args): #Redirects. 
    path = args[1] #Splits up input for forks and redirects
    path_str = path[0]
    program = args[0]
    program_str = program[0]

    pid = os.getpid()               # get and remember pid
    rc = os.fork() #Forks processes 

    if rc < 0:
        os.write(2, ("fork failed, returning %d\n" % rc).encode())
        sys.exit(1)

    elif rc == 0:                   # child process
        os.close(0)                 # redirect child's standard input
        file_input = os.open(path_str, os.O_RDONLY) #Reads from file to use as input
        os.set_inheritable(0, True)

        args.pop() #Removes last element (usually file name)

        for dir in re.split(":", os.environ['PATH']): # try each directory in path
            program = "%s/%s" % (dir, program_str)
            try:
                os.execve(program, args[0], os.environ) # try to exec program
            except FileNotFoundError:             # ...expected
                pass                              # ...fail quietly 

    else:                           # parent (forked ok)
        childPidCode = os.wait()

def redirect_output(args): #Redirect output
	path = args[1] #Splits up input for forks and redirects
	path_str = path[0]
	program = args[0]
	program_str = program[0]

	pid = os.getpid()               # get and remember pid
	rc = os.fork() #Forks processes

	if rc < 0:
		os.write(2, ("fork failed, returning %d\n" % rc).encode())
		sys.exit(1)

	elif rc == 0:                   # child process
		os.close(1)                 # redirect child's standard output
		file_output = os.open(path_str, os.O_CREAT | os.O_WRONLY) #Creates file to write input to
		os.set_inheritable(1, True) 

		args.pop() #Removes last element (usually file name)

		for dir in re.split(":", os.environ['PATH']): # try each directory in path
			program = "%s/%s" % (dir, program_str)
			try:
				os.execve(program, args[0], os.environ) # try to exec program
			except FileNotFoundError:             # ...expected
				pass                              # ...fail quietly 


	else:                           # parent (forked ok)
		childPidCode = os.wait() #waits until process is finished


def pipe(args): #Method for pipe instructions
    arg1, arg2 = args[0], args[1]  #Separating commands (only two)
    pipe_read, pipe_write = os.pipe() #Creates pipe

    rc = os.fork() #Creates fork

    if rc < 0: 
        os.write(2,("Fork failed, returning %d\n" % rc).encode())
        sys.exit(1)

    elif rc == 0: #Runs first command
        os.close(1) #Closes file descriptor (standard output)
        file_descriptor = os.dup(pipe_write) #Gets file descriptor from pipe_write
        os.set_inheritable(file_descriptor, True) #Sets the inheritable flag for file descriptor to use in child process

        pipe_exec(arg1) #Runs command for pipe

    elif rc > 0: #Runs second command
        os.close(0) #Closes file descriptor (standard input)
        file_descriptor = os.dup(pipe_read) #Gets file descriptor from pipe_read
        os.set_inheritable(file_descriptor, True) #Sets the inheritable flag for file descriptor to use in child process

        pipe_exec(arg2) #Runs command for pipe

    return

def pipe_exec(args): #Method to execute pipe command
    try: #Attempts direct path first
        program = args[0]
        os.execve(program, args, os.environ) # try to exec program
    except FileNotFoundError:             # ...expected
        pass

    for dir in re.split(':', os.environ['PATH']):  # try each directory in the path
        program = "%s/%s" % (dir, args[0])
        try:
            os.execve(program, args, os.environ)  # try to exec program
        except FileNotFoundError:  # ...expected
            pass  # ...fail quietly

    os.write(2, ("Could not exec %s\n" % args[0]).encode())
    sys.exit(1)  # terminate with error


def exec(args): #This method execs commands using forks. 
	pid = os.getpid()
	rc = os.fork()

	if(os.path.isfile(args[0])): #For absolute paths only. 
		if rc < 0:
			print("fork failed. Try again.")
			sys.exit(1)
		elif rc == 0:
			try:
				program = args[0]
				os.execve(program, args, os.environ) # try to exec program
			except FileNotFoundError:             # ...expected
				print("")                              # ...fail quietly
		elif rc > 0:
			childPidCode = os.wait()
			return

	for dir in re.split(":", os.environ['PATH']): #when path is not specified 
		program = "%s/%s" % (dir, args[0])

		if rc < 0:
			print("fork failed. Try again.")
			sys.exit(1)
		elif rc == 0:
			try:
				os.execve(program, args, os.environ) # try to exec program
			except FileNotFoundError:             # ...expected
				continue                              # ...fail quietly
		elif rc > 0:
			childPidCode = os.wait()
			return

	print(args[0] + " command not found.")
	sys.exit(0)

def background_exec(args): #This method executes commands in background. 
	pid = os.getpid()
	rc = os.fork()
	program = args[0]

	if rc < 0:
		print("fork failed. Try again.")
		sys.exit(1)
	elif rc == 0:
		try:
			os.execve(program, args, os.environ) # try to exec program
		except FileNotFoundError:             # ...expected
			pass
	elif rc > 0:
		return

	for dir in re.split(":", os.environ['PATH']):
		program = "%s/%s" % (dir, args[0])
		if rc < 0:
			print("fork failed. Try again.")
			sys.exit(-1)
		elif rc == 0:
			try:
				os.execve(program, args, os.environ) # try to exec program
			except FileNotFoundError:             # ...expected
				pass                              # ...fail quietly
		elif rc > 0: #Does not wait for other command to finish. 
			return

	print(args[0] + " command not found.")
	sys.exit(-1)

def os_input(): #For the input 
	prompt = "$ "
	if "PS1" in os.environ: #Sets environment variable 
		prompt = os.environ["PS1"]

	os.write(1, prompt.encode())
	u_str = os.read(0,2000).decode() #Takes user input
	return u_str

def main():
    while(1): #Everything is ran in loop
        u_str = os_input()
        #u_str = input("$ ") #For debugging purposes 
        args = u_str.splitlines()

        for i in range(len(args)): #For inputs that are multiple lines. 
            shell_input(str(args[i]))

main()
#Author: <NAME> 
#Course: CS 4375 Theory of Operating Systems
#Instructor: Dr. <NAME>
#T.A: <NAME> 
#Assignment: Project 1 
#Last Modification: 10/02/2020
#Purpose: Basic shell

import os 
import sys
import re 

def shell_input(u_str): #This method checks out string 
    if '' == u_str or u_str.isspace():
        return

    if 'exit' in u_str:  #If exit is detected, then program quits 
        sys.exit(0)

    if 'cd' in u_str: #Changes directory using input
        try:
            os.chdir(u_str.split()[1])
        except Exception:
            print("cd: no such file or directory: {}".format(u_str))
        return

    if '|' in u_str: #Detects pipes from the string
        pid = os.getpid()
        rc = os.fork()

        if rc < 0:
            os.write(2, ("fork failed, returning %d\n" % rc).encode())
            sys.exit(1)

        if rc == 0:
            n_args = []
            args = u_str.split('|')
            
            for i in range(len(args)):
                n_args.append(args[i].split())

            pipe(n_args)

        else: 
            childPidCode = os.wait()
            main()
            return

    if '>' in u_str: #Redirect output
        n_args = []
        args = u_str.split('>')

        for i in range(len(args)):
            n_args.append(args[i].split())

        redirect_output(n_args)
        return

    if '<' in u_str: #Redirect input
        n_args = []
        args = u_str.split('<')

        for i in range(len(args)):
            n_args.append(args[i].split())

        redirect_input(n_args)
        return

    if '&' in u_str: #For background processes
        n_args = []
        args = u_str.split('&')

        if args[-1] == "": #Runs background process
            args.remove("")
            for i in range(len(args)):
                n_args.append(args[i].split())

            for i in range(len(n_args)):
                background_exec(n_args[i])

        else: #Runs processes normally
            for i in range(len(args)): 
                n_args.append(args[i].split())

            for i in range(len(n_args)):
                exec(n_args[i])

        return

    args = u_str.split()
    exec(args)

def redirect_input(args): #Redirects. 
    path = args[1] #Splits up input for forks and redirects
    path_str = path[0]
    program = args[0]
    program_str = program[0]

    pid = os.getpid()               # get and remember pid
    rc = os.fork() #Forks processes 

    if rc < 0:
        os.write(2, ("fork failed, returning %d\n" % rc).encode())
        sys.exit(1)

    elif rc == 0:                   # child process
        os.close(0)                 # redirect child's standard input
        file_input = os.open(path_str, os.O_RDONLY) #Reads from file to use as input
        os.set_inheritable(0, True)

        args.pop() #Removes last element (usually file name)

        for dir in re.split(":", os.environ['PATH']): # try each directory in path
            program = "%s/%s" % (dir, program_str)
            try:
                os.execve(program, args[0], os.environ) # try to exec program
            except FileNotFoundError:             # ...expected
                pass                              # ...fail quietly 

    else:                           # parent (forked ok)
        childPidCode = os.wait()

def redirect_output(args): #Redirect output
	path = args[1] #Splits up input for forks and redirects
	path_str = path[0]
	program = args[0]
	program_str = program[0]

	pid = os.getpid()               # get and remember pid
	rc = os.fork() #Forks processes

	if rc < 0:
		os.write(2, ("fork failed, returning %d\n" % rc).encode())
		sys.exit(1)

	elif rc == 0:                   # child process
		os.close(1)                 # redirect child's standard output
		file_output = os.open(path_str, os.O_CREAT | os.O_WRONLY) #Creates file to write input to
		os.set_inheritable(1, True) 

		args.pop() #Removes last element (usually file name)

		for dir in re.split(":", os.environ['PATH']): # try each directory in path
			program = "%s/%s" % (dir, program_str)
			try:
				os.execve(program, args[0], os.environ) # try to exec program
			except FileNotFoundError:             # ...expected
				pass                              # ...fail quietly 


	else:                           # parent (forked ok)
		childPidCode = os.wait() #waits until process is finished


def pipe(args): #Method for pipe instructions
    arg1, arg2 = args[0], args[1]  #Separating commands (only two)
    pipe_read, pipe_write = os.pipe() #Creates pipe

    rc = os.fork() #Creates fork

    if rc < 0: 
        os.write(2,("Fork failed, returning %d\n" % rc).encode())
        sys.exit(1)

    elif rc == 0: #Runs first command
        os.close(1) #Closes file descriptor (standard output)
        file_descriptor = os.dup(pipe_write) #Gets file descriptor from pipe_write
        os.set_inheritable(file_descriptor, True) #Sets the inheritable flag for file descriptor to use in child process

        pipe_exec(arg1) #Runs command for pipe

    elif rc > 0: #Runs second command
        os.close(0) #Closes file descriptor (standard input)
        file_descriptor = os.dup(pipe_read) #Gets file descriptor from pipe_read
        os.set_inheritable(file_descriptor, True) #Sets the inheritable flag for file descriptor to use in child process

        pipe_exec(arg2) #Runs command for pipe

    return

def pipe_exec(args): #Method to execute pipe command
    try: #Attempts direct path first
        program = args[0]
        os.execve(program, args, os.environ) # try to exec program
    except FileNotFoundError:             # ...expected
        pass

    for dir in re.split(':', os.environ['PATH']):  # try each directory in the path
        program = "%s/%s" % (dir, args[0])
        try:
            os.execve(program, args, os.environ)  # try to exec program
        except FileNotFoundError:  # ...expected
            pass  # ...fail quietly

    os.write(2, ("Could not exec %s\n" % args[0]).encode())
    sys.exit(1)  # terminate with error


def exec(args): #This method execs commands using forks. 
	pid = os.getpid()
	rc = os.fork()

	if(os.path.isfile(args[0])): #For absolute paths only. 
		if rc < 0:
			print("fork failed. Try again.")
			sys.exit(1)
		elif rc == 0:
			try:
				program = args[0]
				os.execve(program, args, os.environ) # try to exec program
			except FileNotFoundError:             # ...expected
				print("")                              # ...fail quietly
		elif rc > 0:
			childPidCode = os.wait()
			return

	for dir in re.split(":", os.environ['PATH']): #when path is not specified 
		program = "%s/%s" % (dir, args[0])

		if rc < 0:
			print("fork failed. Try again.")
			sys.exit(1)
		elif rc == 0:
			try:
				os.execve(program, args, os.environ) # try to exec program
			except FileNotFoundError:             # ...expected
				continue                              # ...fail quietly
		elif rc > 0:
			childPidCode = os.wait()
			return

	print(args[0] + " command not found.")
	sys.exit(0)

def background_exec(args): #This method executes commands in background. 
	pid = os.getpid()
	rc = os.fork()
	program = args[0]

	if rc < 0:
		print("fork failed. Try again.")
		sys.exit(1)
	elif rc == 0:
		try:
			os.execve(program, args, os.environ) # try to exec program
		except FileNotFoundError:             # ...expected
			pass
	elif rc > 0:
		return

	for dir in re.split(":", os.environ['PATH']):
		program = "%s/%s" % (dir, args[0])
		if rc < 0:
			print("fork failed. Try again.")
			sys.exit(-1)
		elif rc == 0:
			try:
				os.execve(program, args, os.environ) # try to exec program
			except FileNotFoundError:             # ...expected
				pass                              # ...fail quietly
		elif rc > 0: #Does not wait for other command to finish. 
			return

	print(args[0] + " command not found.")
	sys.exit(-1)

def os_input(): #For the input 
	prompt = "$ "
	if "PS1" in os.environ: #Sets environment variable 
		prompt = os.environ["PS1"]

	os.write(1, prompt.encode())
	u_str = os.read(0,2000).decode() #Takes user input
	return u_str

def main():
    while(1): #Everything is ran in loop
        u_str = os_input()
        #u_str = input("$ ") #For debugging purposes 
        args = u_str.splitlines()

        for i in range(len(args)): #For inputs that are multiple lines. 
            shell_input(str(args[i]))

main()
#Author: <NAME> #Course: CS 4375 Theory of Operating Systems #Instructor: Dr. <NAME> #T.A: <NAME> #Assignment: Project 1 #Last Modification: 10/02/2020 #Purpose: Basic shell #This method checks out string #If exit is detected, then program quits #Changes directory using input #Detects pipes from the string #Redirect output #Redirect input #For background processes #Runs background process #Runs processes normally #Redirects. #Splits up input for forks and redirects # get and remember pid #Forks processes # child process # redirect child's standard input #Reads from file to use as input #Removes last element (usually file name) # try each directory in path # try to exec program # ...expected # ...fail quietly # parent (forked ok) #Redirect output #Splits up input for forks and redirects # get and remember pid #Forks processes # child process # redirect child's standard output #Creates file to write input to #Removes last element (usually file name) # try each directory in path # try to exec program # ...expected # ...fail quietly # parent (forked ok) #waits until process is finished #Method for pipe instructions #Separating commands (only two) #Creates pipe #Creates fork #Runs first command #Closes file descriptor (standard output) #Gets file descriptor from pipe_write #Sets the inheritable flag for file descriptor to use in child process #Runs command for pipe #Runs second command #Closes file descriptor (standard input) #Gets file descriptor from pipe_read #Sets the inheritable flag for file descriptor to use in child process #Runs command for pipe #Method to execute pipe command #Attempts direct path first # try to exec program # ...expected # try each directory in the path # try to exec program # ...expected # ...fail quietly # terminate with error #This method execs commands using forks. #For absolute paths only. # try to exec program # ...expected # ...fail quietly #when path is not specified # try to exec program # ...expected # ...fail quietly #This method executes commands in background. # try to exec program # ...expected # try to exec program # ...expected # ...fail quietly #Does not wait for other command to finish. #For the input #Sets environment variable #Takes user input #Everything is ran in loop #u_str = input("$ ") #For debugging purposes #For inputs that are multiple lines.