chore: thing for dzi

.gitignore

@@ -4,3 +4,5 @@
 **/bin
 **/rom
 **/.gitignore
+
+**/venv

2022-06-07/paxful/paxful_api.py

@@ -0,0 +1,96 @@
+import json
+import requests
+import time
+import signal
+import sys
+
+# Paxful API Base URL
+api_url = 'https://paxful.com/data/trades'
+
+# `start_date` and `end_date` are time-date strings in the format
+# 'YYY:MM:DD HH:mm:ss'. These represent the range of transactions we want to
+# collect from the API
+start_date = '2022-01-01 00:00:00'
+end_date = '2022-01-01 1:00:00'
+
+# This is the list of known (and UNIQUE) transactions
+known_txs = {}
+
+
+def main():
+    # You can use CTRL-C from the terminal in order to end the program
+    # early and the will save all the transactions it's collected thus far to disk
+    signal.signal(signal.SIGINT, write_and_exit)
+
+    # We will not store nor query for transactions past this point in time
+    needle_limit = get_unix_timestamp(end_date)
+    # The current time we're querying the Paxful API for
+    needle = get_unix_timestamp(start_date)
+
+    # This loop iterates over all points of time between the start and the end date
+    # and checks to see if there are any transactions that we don't already know about
+    # that might have occurred during this time
+    while needle < needle_limit:
+        # Build Proper URL for API Request
+        req_url = api_url + '?sincetype=date&since=' + str(needle)
+        req = requests.get(req_url)
+        txs = req.json()  # Get Array of transaction JSON objects
+        # The number of transactions received from the API. Should be ~100, doesn't have to be
+        txs_len = len(txs)
+        # This keeps track of how many new (and within-range) transactions we found
+        valid_count = 0
+
+        # For every Transaction in the ~100 transactions we received from Paxful
+        for tx in txs:
+            # get the Paxful-defined ID of the transaction. This is guaranteed (by paxful) to be unique
+            # so we can use it to keep track of unique transactions `known_txs` above
+            id = tx['id']
+
+            if id not in known_txs:
+                tx_timestamp = int(tx['date'])
+
+                # Before we get batches in 100, sometimes we can get transactions that
+                # fall outside our range. We filter those out here
+                if (tx_timestamp <= needle_limit):
+                    valid_count += 1
+                    known_txs[id] = tx
+
+        # For Debugging: Number of transactions received from Paxful and number of transactions we care about
+        print("Batch: " + str(txs_len) + ' Valid: ' + str(valid_count))
+
+        # Paxful Transactions are sorted by date, and so instead of incrementing the timestamp by a
+        # second and performing another HTTP request, we can set the needle to the timestamp of the last
+        # transaction we found. This also reduces the amount of repeated transactions we find when querying
+        # Paxful's API
+        needle = int(txs[txs_len - 1]['date'])
+
+    # Once we've found all transactions within the range, set by `start_date` and `end_date`
+    # Write to file and exit the program
+    write_and_exit(None, None)
+
+
+# Converts a date-string to a Unix timestamp, which is the format Paxful uses
+# to keep track of time
+def get_unix_timestamp(date: str):
+    return int(time.mktime(time.strptime(date, '%Y-%m-%d %H:%M:%S')))
+
+
+def write_and_exit(sig, frame):
+    # Write all found transactions to file (JSON format)
+
+    known_txs_len = len(known_txs)
+    out_file = open('tx.json', 'w')
+    print("Total In-Range Transactions: " + str(known_txs_len))
+
+    out_file.write('[')
+    for i, tx in enumerate(known_txs):
+        suffix = ',' if (i < known_txs_len - 1) else ''
+        out_file.write(json.dumps(known_txs[tx]) + suffix)
+
+    out_file.write(']')
+
+    sys.exit(0)
+
+
+if __name__ == '__main__':
+    main()