WIP: review

.gitignore

@@ -0,0 +1,22 @@
+Program/src/*.o
+main
+settings.json
+SpaceProjects.odt
+Program/src/incomplete_requests
+Program/src/obj
+Program/test/incomplete_requests
+Program/test/temp
+
+*.o
+*.a
+TODO
+Program/FreeRTOSv10.2.1
+Program/libcsp
+.vscode*
+*.jpg
+*.jpeg
+.gitignore
+
+give_packet_loss.sh
+Program/libcsp
+Program/__pycache__

.gitmodules

@@ -0,0 +1,3 @@
+[submodule "Program/libcsp"]
+	path = Program/libcsp
+	url = git@github.com:EvanGee/libcsp.git

Documents/mib.txt

@@ -0,0 +1,80 @@
+The MIB is known as the management information base. 
+This base holds the configuration information for users (peers or applications).
+This data is used for determining how and who we can send file or commands
+to. Files will not be sent to users that are not included in the MIB.
+
+The MIB is currently configured as key value pairs. These pairs are formatted
+in the JSON format. 
+
+Here is an example of a MIB entry:
+{
+    "cfdp_id": 1,
+    "UT_address" : 2130706433,
+    "UT_port" : 1111,
+    "type_of_network" : 1,
+    "default_transmission_mode" : 1,
+    "MTU" : 1500,
+    "one_way_light_time" : 123,
+    "total_round_trip_allowance" : 123,
+    "async_NAK_interval" : 123,
+    "async_keep_alive_interval" : 123,
+    "async_report_interval" : 123,
+    "immediate_nak_mode_enabled" : 123,
+    "prompt_transmission_interval" : 123,
+    "disposition_of_incomplete" : 123,
+    "CRC_required" : 0,
+    "keep_alive_discrepancy_limit" : 8,
+    "positive_ack_timer_expiration_limit" : 123,
+    "nak_timer_expiration_limit" : 123,
+    "transaction_inactivity_limit" : 123
+}
+
+
+Below are the meanings of the fields for the MIB
+
+- cfdp_id
+    This is the unique identifier of a peer on the network. We can start it at 1
+    and increment it from there. This is an unsigned integer (32 bit) value;
+
+- UT_address
+    This is an Underlying Transmission address. For example, in an IP stack, this
+    would be an IP4 Ip address. This value is a decimal representation of an IP
+    address. This particular one is 127.0.0.1. 
+
+- UT_port
+    This os an Underlying Transmission port. For example, in an IP stack, this
+    would be a 16 bit value -- like port 8080. combined with the UT_address, 
+    together they form a complete UT address. The one above would be equal to
+    127.0.0.1:1111. This is an unsigned integer (16 bit) value
+
+- type_of_network
+    This number represents what type of network the underlying UT address takes.
+    currently, the only acceptable values are 0 and 1. 
+    - 0: UDP
+    - 1: TCP
+    - 2: csp
+
+- default_transmission_mode:
+    not implemented
+
+- MTU
+    This number represents the 'maximum transmissible unit' -- this will also
+    take the form of a buffer in the program. This value is the maximum size 
+    packet that the application will receive. 
+
+- one_way_light_time : not implemented
+- total_round_trip_allowance : not implemented
+- async_NAK_interval : not implemented
+- async_keep_alive_interval : not implemented
+- async_report_interval : not implemented
+- immediate_nak_mode_enabled : not implemented
+- prompt_transmission_interval : not implemented
+- disposition_of_incomplete : not implemented
+- CRC_required : not implemented
+- keep_alive_discrepancy_limit : not implemented
+- positive_ack_timer_expiration_limit : not implemented
+- nak_timer_expiration_limit : not implemented
+- transaction_inactivity_limit : not implemented
+
+if you want to get in contact with me
+email me at evangiese77@gmail.com

Program/ftp_python.py

@@ -0,0 +1,59 @@
+import subprocess
+from pprint import pprint
+import os
+import datetime
+
+def change_working_dir():
+    path = os.path.abspath(__file__)
+    split = path.split("/")[0:-1]
+    split.append("src")
+    new_path = "/".join(split)
+    os.chdir(new_path)
+
+
+class logger():
+    def __init__(self, path="ftp_log/log.txt"):
+        self.log_file = self.create_ftp_log(path)
+
+    def create_ftp_log(self, path):
+        if not os.path.exists("ftp_log"):
+            os.makedirs("ftp_log")
+
+        file = open(path, "a")
+        return file
+
+    def close(self):
+        self.log_file.close()
+
+    def log(self, stuff):
+        self.log_file.writelines(str(datetime.datetime.today()) + ":" + stuff)
+
+def get_request(sat_path, file_path, block=True):
+    change_working_dir()
+
+    print("need sudo password for opening /dev/ttyUSB0")
+    cmd = ["sudo", "./main", "-i", "10", "-c", "1", "-k", "/dev/ttyUSB0", "-f", 'GET {0}|{1}'.format(sat_path, file_path)]
+
+    if block:
+        output = subprocess.run(cmd)
+        print(output)
+        return 
+
+    #subprocess.Popen(cmd)
+
+def put_request(file_path, sat_path, block=True):
+    change_working_dir()
+
+    print("need sudo password for opening /dev/ttyUSB0")
+    cmd = ["sudo", "./main", "-i", "10", "-c", "1", "-k", "/dev/ttyUSB0", "-f", 'PUT {0}|{1}'.format(file_path, sat_path)]
+
+    if block:
+        output = subprocess.run(cmd)
+        print(output)
+        return
+
+    #subprocess.Popen(cmd)
+
+
+if __name__ == "__main__":
+    print("thats not how you use this, please import either 'get_request' or 'put_request' into your program")

Program/include/app_control.h

@@ -0,0 +1,31 @@
+/*------------------------------------------------------------------------------
+This file is protected under copyright. If you want to use it,
+please include this text, that is my only stipulation.  
+
+Author: Evan Giese
+------------------------------------------------------------------------------*/
+#ifndef SSP_TASKS_H
+#define SSP_TASKS_H
+
+#include "types.h"
+
+void ssp_cleanup_client(Client *client);
+void ssp_cleanup_req(void *request);
+void ssp_cleanup_ftp(FTP *app);
+void *ssp_connectionless_server_task(void *params);
+void *ssp_connectionless_client_task(void* params);
+
+void *ssp_connection_client_task(void *params);
+void *ssp_connection_server_task(void *params);
+void *ssp_csp_connectionless_client_task(void *params);
+void *ssp_csp_connectionless_server_task(void *params);
+void *ssp_csp_connection_client_task(void *params);
+void *ssp_csp_connection_server_task(void *params);
+void ssp_client_join(Client *client);
+void *ssp_generic_client_task(void *params);
+void *ssp_generic_server_task(void *params);
+
+void reset_timeout(int *prevtime);
+void remove_request_check(Node *node, void *request, void *args);
+
+#endif

Program/include/changeNotes

@@ -0,0 +1 @@
+added PDU_NAK_METADATA directive, due to spec not containing room for missing metadata packet

Program/include/csp_server_provider.h

@@ -0,0 +1,39 @@
+/*------------------------------------------------------------------------------
+This file is protected under copyright. If you want to use it,
+please include this text, that is my only stipulation.  
+
+Author: Evan Giese
+------------------------------------------------------------------------------*/
+#ifndef CSP_SERVER_H
+#define CSP_SERVER_H
+#include "stdint.h"
+
+void csp_connectionless_client(uint8_t dest_id, uint8_t dest_port, uint8_t src_port, uint32_t packet_len,
+    int (*onSend)(int sfd, void *addr, uint32_t size_of_addr, void *onSendParams),
+    int (*onRecv)(int sfd, char *packet, uint32_t packet_len, uint32_t *buff_size, void *addr, size_t size_of_addr, void *onRecvParams) ,
+    int (*checkExit)(void *checkExitParams),
+    void (*onExit)(void *params),
+    void *params);
+
+void csp_connectionless_server(uint8_t my_port, uint32_t packet_len, uint32_t time_out,
+    int (*onRecv)(int sfd, char *packet, uint32_t packet_len,  uint32_t *buff_size, void *addr, size_t size_of_addr, void *other), 
+    int (*onTimeOut)(void *other),
+    int (*checkExit)(void *other),
+    void (*onExit)(void *other),
+    void *other);
+
+void csp_connection_server(uint8_t my_port, uint32_t packet_len, uint32_t time_out,
+    int (*onRecv)(int sfd, char *packet, uint32_t packet_len,  uint32_t *buff_size, void *addr, size_t size_of_addr, void *other), 
+    int (*onTimeOut)(void *other),
+    int (*checkExit)(void *other),
+    void (*onExit)(void *other),
+    void *other);
+
+void csp_connection_client(uint8_t dest_id, uint8_t dest_port, uint8_t my_port, uint32_t packet_len, uint32_t time_out, void*lock,
+    int (*onSend)(int sfd, void *addr, uint32_t size_of_addr, void *onSendParams),
+    int (*onRecv)(int sfd, char *packet, uint32_t packet_len, uint32_t *buff_size, void *addr, size_t size_of_addr, void *onRecvParams) ,
+    int (*checkExit)(void *checkExitParams),
+    void (*onExit)(void *params),
+    void *params);
+int csp_custom_ftp_ping(uint32_t dest_id, uint32_t port);
+#endif

Program/include/file_delivery_app.h

@@ -0,0 +1,18 @@
+/*------------------------------------------------------------------------------
+This file is protected under copyright. If you want to use it,
+please include this text, that is my only stipulation.  
+
+Author: Evan Giese
+------------------------------------------------------------------------------*/
+#ifndef FTP_APP_H
+#define FTP_APP_H
+#include "types.h"
+
+int init_ftp(uint32_t my_cfdp_address, FTP *app);
+Client *ssp_client(uint32_t cfdp_id, FTP *app);
+void create_ssp_server(FTP *app);
+int create_ssp_server_drivers(FTP *app);
+void *create_ftp_task(uint32_t cfdp_id, FTP *app);
+Client *init_client(uint32_t dest_cfdp_id, uint32_t my_cfdp_id);
+
+#endif

Program/include/filesystem_funcs.h

@@ -0,0 +1,54 @@
+/*------------------------------------------------------------------------------
+This file is protected under copyright. If you want to use it,
+please include this text, that is my only stipulation.  
+
+Author: Evan Giese
+------------------------------------------------------------------------------*/
+#ifndef FILESYSTEM_FUNCS_H
+#define FILESYSTEM_FUNCS_H
+#include "types.h"
+
+#define TEMP_FILESIZE 1000
+
+struct params {
+    int error;
+    int fd;
+};
+
+
+int get_file_size(char *source_file_name);
+
+//allocates space for a file pointer
+File *create_file(char *source_file_name, int clear_file_contents);
+void ssp_free_file(void *file);
+int add_first_offset(File *file, uint32_t file_size);
+
+int does_file_exist(char *source_file_name);
+int get_offset(File *file, void *buff, uint32_t buf_size, int offset);
+int write_offset(File *file, void *buff, uint32_t size, uint32_t offset);
+uint32_t calc_check_sum(char *data, uint32_t length);
+uint32_t check_sum_file(File *file, uint16_t stack_buffer);
+int receive_offset(File *file, uint32_t offset_start, uint32_t offset_end);
+File *create_temp_file(char *file_name, uint32_t size);
+int change_tempfile_to_actual(char *temp, char *destination_file_name, uint32_t file_size, File *file);
+int read_json(char *file_name, int (*callback)(char *key, char *value, void *params), void *params);
+
+int write_lv(int fd, LV lv);
+int read_lv(int fd, LV *lv);
+
+int read_id(int fd, uint64_t *id);
+int write_id(int fd, uint64_t id);
+
+int save_req_to_file(Request *req);
+int save_file_to_file(int fd, File *file);
+int get_file_from_file(int fd, File *file);
+int get_req_from_file(uint32_t dest_cfdp_id, uint64_t transaction_seq_num, uint32_t my_cfdp_id, Request *req);
+int delete_saved_request(Request *req);
+int read_request_from_file(int fd, Request *req);
+
+
+//new json stuff:
+int write_request_json (Request *req, char *file_name);
+int get_request_from_json (Request *req, char *file_name);
+
+#endif 

Program/include/generic_server_provider.h

@@ -0,0 +1,19 @@
+#ifndef SSP_GENERIC_PROVIDER_H
+#define SSP_GENERIC_PROVIDER_H
+#include "port.h"
+
+void csp_generic_server(
+    int (*onRecv)(int sfd, char *packet, uint32_t packet_len,  uint32_t *buff_size, void *addr, size_t size_of_addr, void *app), 
+    int (*onTimeOut)(void *app),
+    int (*checkExit)(void *app),
+    void (*onExit)(void *app),
+    void *app);
+
+void csp_generic_client(uint8_t dest_id, uint8_t dest_port, uint8_t my_port, uint32_t packet_len,
+    int (*onSend)(int sfd, void *addr, uint32_t size_of_addr, void *onSendParams),
+    int (*onRecv)(int sfd, char *packet, uint32_t packet_len, uint32_t *buff_size, void *addr, size_t size_of_addr, void *onRecvParams) ,
+    int (*checkExit)(void *checkExitParams),
+    void (*onExit)(void *params),
+    void *params);
+
+#endif