|
| 1 | +#include "SupabaseESP32.h" |
| 2 | + |
| 3 | +// #if ESP32 |
| 4 | +HTTPClient http; |
| 5 | +// #endif |
| 6 | + |
| 7 | +String supabase_url; |
| 8 | +String supabase_key; |
| 9 | +String supabase_bearer; |
| 10 | +String supabase_table; |
| 11 | + |
| 12 | +SUPABASE::SUPABASE(String url, String key, String tableName) |
| 13 | +{ |
| 14 | + supabase_table = tableName; |
| 15 | + supabase_url = url + "/" + supabase_table; |
| 16 | + supabase_key = key; |
| 17 | + supabase_bearer = "Bearer " + key; |
| 18 | +} |
| 19 | + |
| 20 | +SUPABASE::~SUPABASE() {} |
| 21 | + |
| 22 | +void SUPABASE::begin() |
| 23 | +{ |
| 24 | + Serial.println(supabase_url); |
| 25 | + http.begin(supabase_url.c_str()); |
| 26 | + http.addHeader("apikey", supabase_key); |
| 27 | + http.addHeader("Authorization", supabase_bearer); |
| 28 | + http.addHeader("Content-Type", "application/json"); |
| 29 | + http.addHeader("Prefer", "return=representation"); |
| 30 | +} |
| 31 | + |
| 32 | +int SUPABASE::update(int rowId, String column, double value) |
| 33 | +{ |
| 34 | + String url = supabase_url + "?id=eq." + String(rowId); |
| 35 | + http.begin(url.c_str()); |
| 36 | + http.addHeader("apikey", supabase_key); |
| 37 | + http.addHeader("Authorization", supabase_bearer); |
| 38 | + http.addHeader("Content-Type", "application/json"); |
| 39 | + http.addHeader("Prefer", "return=minimal"); |
| 40 | + String supabase_data = "{\"" + column + "\":" + String(value) + "}"; |
| 41 | + int httpResponseCode = http.PATCH(supabase_data); |
| 42 | + http.end(); |
| 43 | + return httpResponseCode; |
| 44 | +} |
| 45 | + |
| 46 | +int SUPABASE::insert(String column, double value) |
| 47 | +{ |
| 48 | + http.begin(supabase_url.c_str()); |
| 49 | + http.addHeader("apikey", supabase_key); |
| 50 | + http.addHeader("Authorization", supabase_bearer); |
| 51 | + http.addHeader("Content-Type", "application/json"); |
| 52 | + http.addHeader("Prefer", "return=minimal"); |
| 53 | + String supabase_data = "{\"" + column + "\":" + String(value) + "}"; |
| 54 | + int httpResponseCode = http.POST(supabase_data); |
| 55 | + http.end(); |
| 56 | + return httpResponseCode; |
| 57 | +} |
| 58 | + |
| 59 | + |
| 60 | +String SUPABASE::read() |
| 61 | +{ |
| 62 | + String url = supabase_url + "?select=*"; |
| 63 | + http.begin(url.c_str()); |
| 64 | + http.addHeader("apikey", supabase_key); |
| 65 | + int httpResponseCode = http.GET(); |
| 66 | + String payload = http.getString(); |
| 67 | + |
| 68 | + Serial.println("DATA READ!"); |
| 69 | + Serial.print("HTTP GET: "); |
| 70 | + Serial.println(httpResponseCode); |
| 71 | + Serial.print("HTTP Payload: "); |
| 72 | + Serial.println(payload); |
| 73 | + |
| 74 | + http.end(); |
| 75 | + return payload; |
| 76 | +} |
0 commit comments