import socket
import json #converts data to byte streams
import select
import errno
import numpy
import struct 
def byteswap(i):
    return struct.unpack("!I", struct.pack("!I", i))[0]
HEADER_LENGTH = 200
IP = "localhost"
PORT = 3015 #6341 #8089 #3015
Engine_name = "ArrayTest"
# Create a socket
# socket.AF_INET - address family, IPv4, some otehr possible are AF_INET6, AF_BLUETOOTH, AF_UNIX
# socket.SOCK_STREAM - TCP, conection-based, socket.SOCK_DGRAM - UDP, connectionless, datagrams, socket.SOCK_RAW - raw IP packets
client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
# Connect to a given ip and port
client_socket.connect((IP, PORT))
# Set connection to non-blocking state, so .recv() call won;t block, just return some exception we'll handle
client_socket.setblocking(True)
while True:
    arr = [1,2,3,4,5,6]
    send_data = byteswap(json.dumps({"test_data":arr}))
    print(send_data)
    client_socket.send(send_data.encode())

import socket 
import threading
import json
File_length = 4098 #maximum number of characters that can be passed back and forth. needs to be kept the same as labview
PORT = 3015
SERVER = socket.gethostbyname(socket.gethostname())
ADDR = (SERVER, PORT)
FORMAT = 'utf-8'
DISCONNECT_MESSAGE = "!DISCONNECT"
server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
server.bind(ADDR)
def handle_client(conn, addr):
    print(f"[NEW CONNECTION] {addr} connected.")
    Message_previous = ""
    connected = True
    while connected:
        Message = conn.recv(File_length).decode(FORMAT)
        Decoded_message = json.loads(Message)
        if Decoded_message != Message_previous:
            print(Decoded_message)
            Message_previous = Decoded_message
        String_arr = Decoded_message["Test Value Arr"]
        print(String_arr)
        print(String_arr[0])
        
def start():
    server.listen()
    print(f"[LISTENING] Server is listening on {SERVER}")
    while True:
        conn, addr = server.accept()
        thread = threading.Thread(target=handle_client, args=(conn, addr))
        thread.start()
        return threading.active_count()
        #print(f"[ACTIVE CONNECTIONS] {threading.active_count() - 1}")
print("[STARTING] server is starting...")
start()