Committing my echo-server assignment

Author: danwoj

students/danwoj/Mailroom2.0/FILENAME

@@ -0,0 +1,31 @@
+don_fname,don_mi,don_lname,don_amt,don_date
+Malisa,Q,Sebree,41839,18 January 2015
+Janella,W,Farkas,37393,27 February 2015
+Cordell,E,Behler,45094,2 March 2015
+Dannie,R,Calderone,35988,25 April 2015
+Sue,T,Mcnellis,27176,17 May 2015
+Stacee,Y,Bushard,31461,11 June 2015
+Dorla  ,U,Perrin,10828,6 July 2015
+Nevada,I,Garmany,47613,6 December 2015
+Melba,O,Irving,24975,16 February 2016
+Damian,P,Warburton,17969,1 April 2016
+Sal,A,Hinkel,29608,11 May 2016
+Willetta,S,Cory,29991,21 July 2016
+Tennille,D,Kea,29381,23 July 2016
+Nichelle,F,Dampier,15561,29 July 2016
+Qiana,G,Pusey,48768,22 September 2016
+Shala,H,Vialpando,23891,23 October 2016
+Trina,J,Boedeker,26692,21 November 2016
+Earline,K,Bayer,11434,6 January 2017
+Mark,L,Wing,31395,17 February 2017
+Ezekiel,Z,Nusbaum,9944,17 August 2017
+Delmer,X,McAndrew,11639,28 August 2017
+Lecia,C,Lorenz,30423,9 October 2017
+Ozie,V,Avilez,49438,13 October 2017
+Marylynn,B,Griffy,13971,26 October 2017
+Daphine,N,Dillenbeck,14758,27 November 2017
+Noe,M,Kennell,17874,27 February 2015
+Florentino ,Q,McGonigal,37929,25 March 2015
+Lissette,W,Beekman,46658,7 May 2015
+Tiffanie,E,Mosser,39157,30 July 2015
+Marcelle,R,Chmura,48649,31 August 2015

students/danwoj/Mailroom2.0/don_list

@@ -0,0 +1,34 @@
+#!/usr/bin/python
+
+import sqlite3 as lite
+import sys
+
+db_con = None
+db_file = 'don_list.db'
+
+#try:
+#    db_con = lite.connect(db_file)
+
+#    cur = db_con.cursor()    
+#    cur.execute('.schema don_list')
+
+def cmd_db(sql_state):
+    db_con = lite.connect(db_file)
+    cur = db_con.cursor()
+    cur.execute(sql_state)
+    data = cur.fetchone()
+    return data
+
+#    data = cur.fetchone()
+
+#    print(data)
+
+#except lite.Error(e):
+
+#    print("Error %s:" % e.args[0])
+#    sys.exit(1)
+
+#finally:
+
+#    if db_con:
+#        db_con.close()

students/danwoj/Mailroom2.0/don_list.csv

@@ -0,0 +1,40 @@
+#!/usr/bin/env python3.6
+
+import mailroom2, pytest
+
+def test_db_query():
+    qstate = "SELECT sql FROM sqlite_master ORDER BY tbl_name, type DESC, name"
+    read_state = "SELECT * FROM don_list ORDER BY rowid DESC LIMIT 1;"
+    write_state = "INSERT INTO don_list(don_fname, don_mi, don_lname, don_amt, don_date) VALUES ('Dan', 'NMN', 'Wojciechowski', 99999, '1 April 2017');"
+    delete_state = "DELETE FROM don_list WHERE rowid = (SELECT MAX(rowid) FROM notes);"
+
+    result = mailroom2.cmd_db(qstate)
+    assert result == ('CREATE TABLE don_list(\n  "don_fname" TEXT,\n  "don_mi" TEXT,\n  "don_lname" TEXT,\n  "don_amt" TEXT,\n  "don_date" TEXT\n)',)
+
+    result = mailroom2.cmd_db(read_state)
+    assert result == ('Marcelle', 'R', 'Chmura', '48649', '31 August 2015')
+
+    result2 = mailroom2.cmd_db(write_state)
+    assert result2 == ('Dan', 'NMN', 'Wojciechowski', '99999', '1 April 2017')
+    assert result != result2
+    mailroom2(cmd_db(delete_state))
+    result2 = mailroom2(cmd_db(read_state))
+    assert result2 == result
+
+#def test_add_name():
+#    assert mailroom.add_name('Dan', 'Woj') is True
+
+#def test_add_name2(capsys):
+#    mailroom.add_name('Dan', 'Woj')
+#    out, err = capsys.readouterr()
+#    assert out == 'The name Dan Woj is not in the donor list. Adding them as a new donor.\n\n'
+
+#def test_add_value():
+
+#def test_print_letter():
+#    assert mailroom.print_letter(4, 1234) is True
+
+#def test_run_report(capfd):
+#    mailroom.run_report()
+#    out, err = capfd.readouterr()
+#    assert out == '\n######################  Donor Report ######################\n\nDonor Name         | Total Given | Num Gifts | Average Gift\n-----------------------------------------------------------\nBill Gates         | $ 700.00    | 2         | $ 350.00\nMelvin Smith       | $ 8000.00   | 3         | $ 2666.67\nDaphnie Jones      | $ 2000.00   | 2         | $ 1000.00\nChauncey Doe       | $ 400.00    | 1         | $ 400.00\nFrieda Whatever    | $ 9000.00   | 3         | $ 3000.00\n'

students/danwoj/Mailroom2.0/don_list.db

@@ -0,0 +1,5 @@
+November 12,2017
+
+Dear Dan,
+
+Thank you so much for your generous donation of $3490.10. This contribution is so important to the work our organization does and we express our deepest appreciation of your support to our important cause.

students/danwoj/Mailroom2.0/donor.db

@@ -0,0 +1,58 @@
+import socket
+import sys
+
+def client(msg, log_buffer=sys.stderr):
+    server_address = ('localhost', 20001)
+    # TODO: Replace the following line with your code which will instantiate
+    #       a TCP socket with IPv4 Addressing, call the socket you make 'sock'
+    #sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+    sock = socket.socket()
+    print('connecting to {0} port {1}'.format(*server_address), file=log_buffer)
+    # TODO: connect your socket to the server here.
+    sock.connect(server_address)
+    # you can use this variable to accumulate the entire message received back
+    # from the server
+    received_message = ''
+
+    # this try/finally block exists purely to allow us to close the socket
+    # when we are finished with it
+    try:
+        print('sending "{0}"'.format(msg), file=log_buffer)
+        # TODO: send your message to the server here.
+        sock.sendall(msg.encode('utf-8'))
+#        time.sleep(5)
+        # TODO: the server should be sending you back your message as a series
+        #       of 16-byte chunks. Accumulate the chunks you get to build the
+        #       entire reply from the server. Make sure that you have received
+        #       the entire message and then you can break the loop.
+        #
+        #       Log each chunk you receive.  Use the print statement below to
+        #       do it. This will help in debugging problems
+        chunk = ''
+        chunks = []
+        bytes_recd = 0
+        while bytes_recd < len(msg):
+            chunk = sock.recv(2048)
+            chunks.append(chunk)
+            bytes_recd = bytes_recd + len(chunk)
+
+        received_message = b''.join(chunks).decode('utf8')
+        print('received "{0}"'.format(received_message), file=log_buffer)
+    finally:
+        # TODO: after you break out of the loop receiving echoed chunks from
+        #       the server you will want to close your client socket.
+        print('closing socket', file=log_buffer)
+        sock.close()
+
+        # TODO: when all is said and done, you should return the entire reply
+        # you received from the server as the return value of this function.
+        return received_message
+
+if __name__ == '__main__':
+    if len(sys.argv) != 2:
+        usage = '\nusage: python echo_client.py "this is my message"\n'
+        print(usage, file=sys.stderr)
+        sys.exit(1)
+
+    msg = sys.argv[1]
+    client(msg)

students/danwoj/Mailroom2.0/mailroom2.py

@@ -0,0 +1,91 @@
+import socket
+import sys
+
+
+def server(log_buffer=sys.stderr):
+    # set an address for our server
+    address = ('localhost', 20001)
+    # TODO: Replace the following line with your code which will instantiate
+    #       a TCP socket with IPv4 Addressing, call the socket you make 'sock'
+    #sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM, socket.IPPROTO_TCP)
+    sock = socket.socket()
+    # TODO: You may find that if you repeatedly run the server script it fails,
+    #       claiming that the port is already used.  You can set an option on
+    #       your socket that will fix this problem. We DID NOT talk about this
+    #       in class. Find the correct option by reading the very end of the
+    #       socket library documentation:
+    #       http://docs.python.org/3/library/socket.html#example
+    #sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
+    # log that we are building a server
+    print("making a server on {0}:{1}".format(*address), file=log_buffer)
+    # TODO: bind your new sock 'sock' to the address above and begin to listen
+    #       for incoming connections
+    sock.bind(address)
+    sock.listen(5)
+    try:
+        # the outer loop controls the creation of new connection sockets. The
+        # server will handle each incoming connection one at a time.
+        while True:
+            print('waiting for a connection', file=log_buffer)
+
+            # TODO: make a new socket when a client connects, call it 'conn',
+            #       at the same time you should be able to get the address of
+            #       the client so we can report it below.  Replace the
+            #       following line with your code. It is only here to prevent
+            #       syntax errors
+#            conn, addr = ('foo', ('bar', 'baz'))
+            conn, addr = sock.accept()
+#            conn.run()
+            try:
+                print('connection - {0}:{1}'.format(*addr), file=log_buffer)
+
+                # the inner loop will receive messages sent by the client in
+                # buffers.  When a complete message has been received, the
+                # loop will exit
+                while True:
+                    # TODO: receive 16 bytes of data from the client. Store
+                    #       the data you receive as 'data'.  Replace the
+                    #       following line with your code.  It's only here as
+                    #       a placeholder to prevent an error in string
+                    #       formatting
+                    data = b''
+                    partial = conn.recv(16)
+                    data += partial
+                    print('Received: "{0}"'.format(data.decode('utf8')))
+                    
+                    # TODO: Send the data you received back to the client, log
+                    # the fact using the print statement here.  It will help in
+                    # debugging problems.
+                    conn.sendall(data)
+                    print('Sent: "{0}"'.format(data.decode('utf8')))
+                    # TODO: Check here to see whether you have received the end
+                    # of the message. If you have, then break from the `while True`
+                    # loop.
+                    # 
+                    # Figuring out whether or not you have received the end of the
+                    # message is a trick we learned in the lesson: if you don't
+                    # remember then ask your classmates or instructor for a clue.
+                    # :)
+                    if len(data) == 0:
+                        break
+            finally:
+                # TODO: When the inner loop exits, this 'finally' clause will
+                #       be hit. Use that opportunity to close the socket you
+                #       created above when a client connected.
+                print(
+                    'Echo complete, client connection closed.', file=log_buffer
+                )
+                conn.close()
+
+    except KeyboardInterrupt:
+        # TODO: Use the python KeyboardInterrupt exception as a signal to
+        #       close the server socket and exit from the server function.
+        #       Replace the call to `pass` below, which is only there to
+        #       prevent syntax problems
+        raise
+        print('quitting echo server', file=log_buffer)
+
+
+if __name__ == '__main__':
+    server()
+    sys.exit(0)