forked from ground/ground
Compare commits
6 Commits
7443722dd5
...
master
| Author | SHA1 | Date | |
|---|---|---|---|
| a8097c9cf7 | |||
| f9c333a1bc | |||
| ccc8a61f66 | |||
| fb6dd62a42 | |||
| e73fdddb4c | |||
| dc2781559d |
422
libs/datetime/date_functions.c
Normal file
422
libs/datetime/date_functions.c
Normal file
@@ -0,0 +1,422 @@
|
||||
#include "date_functions.h"
|
||||
#include <stdio.h>
|
||||
|
||||
GroundValue tmToGroundValue(struct tm t) {
|
||||
GroundStruct timeStruct = groundCreateStruct();
|
||||
groundAddFieldToStruct(&timeStruct, "year", groundCreateValue(INT, t.tm_year + 1900));
|
||||
groundAddFieldToStruct(&timeStruct, "month", groundCreateValue(INT, t.tm_mon + 1));
|
||||
groundAddFieldToStruct(&timeStruct, "day", groundCreateValue(INT, t.tm_mday));
|
||||
groundAddFieldToStruct(&timeStruct, "hour", groundCreateValue(INT, t.tm_hour));
|
||||
groundAddFieldToStruct(&timeStruct, "minute", groundCreateValue(INT, t.tm_min));
|
||||
groundAddFieldToStruct(&timeStruct, "second", groundCreateValue(INT, t.tm_sec));
|
||||
groundAddFieldToStruct(&timeStruct, "weekDay", groundCreateValue(INT, t.tm_wday));
|
||||
groundAddFieldToStruct(&timeStruct, "yearDay", groundCreateValue(INT, t.tm_yday + 1));
|
||||
groundAddFieldToStruct(&timeStruct, "isDaylightSavingsTime", groundCreateValue(BOOL, t.tm_isdst));
|
||||
|
||||
GroundValue value = groundCreateValue(CUSTOM, &timeStruct);
|
||||
value.type = CUSTOM;
|
||||
|
||||
return value;
|
||||
}
|
||||
|
||||
GroundValue datetime_Now(GroundScope* scope, List args) {
|
||||
time_t now = time(NULL);
|
||||
struct tm t = {0};
|
||||
|
||||
localtime_r(&now, &t);
|
||||
|
||||
// return a -datetime struct
|
||||
return tmToGroundValue(t);
|
||||
}
|
||||
|
||||
GroundValue datetime_FromEpochLocal(GroundScope* scope, List args) {
|
||||
struct tm t = {0};
|
||||
time_t ts = args.values[0].data.doubleVal;
|
||||
|
||||
localtime_r(&ts, &t);
|
||||
|
||||
return tmToGroundValue(t);
|
||||
}
|
||||
|
||||
GroundValue datetime_FromEpochUTC(GroundScope* scope, List args) {
|
||||
struct tm t = {0};
|
||||
time_t ts = args.values[0].data.doubleVal;
|
||||
|
||||
gmtime_r(&ts, &t);
|
||||
|
||||
return tmToGroundValue(t);
|
||||
}
|
||||
|
||||
GroundValue datetime_ToEpochLocal(GroundScope* scope, List args) {
|
||||
GroundObject obj = *args.values[0].data.customVal;
|
||||
|
||||
// check args
|
||||
GroundObjectField* year = groundFindField(obj, "year");
|
||||
if (year == NULL || year->value.type != INT) ERROR("Object does not have year field as int", "ValueError");
|
||||
GroundObjectField* month = groundFindField(obj, "month");
|
||||
if (month == NULL || month->value.type != INT) ERROR("Object does not have month field as int", "ValueError");
|
||||
GroundObjectField* day = groundFindField(obj, "day");
|
||||
if (day == NULL || day->value.type != INT) ERROR("Object does not have day field as int", "ValueError");
|
||||
GroundObjectField* hour = groundFindField(obj, "hour");
|
||||
if (hour == NULL || hour->value.type != INT) ERROR("Object does not have hour field as int", "ValueError");
|
||||
GroundObjectField* minute = groundFindField(obj, "minute");
|
||||
if (minute == NULL || minute->value.type != INT) ERROR("Object does not have minute field as int", "ValueError");
|
||||
GroundObjectField* second = groundFindField(obj, "second");
|
||||
if (second == NULL || second->value.type != INT) ERROR("Object does not have second field as int", "ValueError");
|
||||
GroundObjectField* weekDay = groundFindField(obj, "weekDay");
|
||||
if (weekDay == NULL || weekDay->value.type != INT) ERROR("Object does not have weekDay field as int", "ValueError");
|
||||
GroundObjectField* yearDay = groundFindField(obj, "yearDay");
|
||||
if (yearDay == NULL || yearDay->value.type != INT) ERROR("Object does not have yearDay field as int", "ValueError");
|
||||
GroundObjectField* isDaylightSavingsTime = groundFindField(obj, "isDaylightSavingsTime");
|
||||
if (isDaylightSavingsTime == NULL || isDaylightSavingsTime->value.type != BOOL) ERROR("Object does not have isDaylightSavingsTime field as bool", "ValueError");
|
||||
|
||||
// construct tm struct from our ground struct
|
||||
struct tm t = {
|
||||
.tm_sec = second->value.data.intVal,
|
||||
.tm_min = minute->value.data.intVal,
|
||||
.tm_hour = hour->value.data.intVal,
|
||||
.tm_mday = day->value.data.intVal,
|
||||
.tm_mon = month->value.data.intVal - 1,
|
||||
.tm_year = year->value.data.intVal - 1900,
|
||||
.tm_wday = 0,
|
||||
.tm_yday = 0,
|
||||
.tm_isdst = -1
|
||||
};
|
||||
|
||||
time_t ts = mktime(&t);
|
||||
return groundCreateValue(INT, (long long)ts);
|
||||
}
|
||||
|
||||
GroundValue datetime_ToEpochUTC(GroundScope* scope, List args) {
|
||||
GroundObject obj = *args.values[0].data.customVal;
|
||||
|
||||
// check args
|
||||
GroundObjectField* year = groundFindField(obj, "year");
|
||||
if (year == NULL || year->value.type != INT) ERROR("Object does not have year field as int", "ValueError");
|
||||
GroundObjectField* month = groundFindField(obj, "month");
|
||||
if (month == NULL || month->value.type != INT) ERROR("Object does not have month field as int", "ValueError");
|
||||
GroundObjectField* day = groundFindField(obj, "day");
|
||||
if (day == NULL || day->value.type != INT) ERROR("Object does not have day field as int", "ValueError");
|
||||
GroundObjectField* hour = groundFindField(obj, "hour");
|
||||
if (hour == NULL || hour->value.type != INT) ERROR("Object does not have hour field as int", "ValueError");
|
||||
GroundObjectField* minute = groundFindField(obj, "minute");
|
||||
if (minute == NULL || minute->value.type != INT) ERROR("Object does not have minute field as int", "ValueError");
|
||||
GroundObjectField* second = groundFindField(obj, "second");
|
||||
if (second == NULL || second->value.type != INT) ERROR("Object does not have second field as int", "ValueError");
|
||||
GroundObjectField* weekDay = groundFindField(obj, "weekDay");
|
||||
if (weekDay == NULL || weekDay->value.type != INT) ERROR("Object does not have weekDay field as int", "ValueError");
|
||||
GroundObjectField* yearDay = groundFindField(obj, "yearDay");
|
||||
if (yearDay == NULL || yearDay->value.type != INT) ERROR("Object does not have yearDay field as int", "ValueError");
|
||||
GroundObjectField* isDaylightSavingsTime = groundFindField(obj, "isDaylightSavingsTime");
|
||||
if (isDaylightSavingsTime == NULL || isDaylightSavingsTime->value.type != BOOL) ERROR("Object does not have isDaylightSavingsTime field as bool", "ValueError");
|
||||
|
||||
// construct tm struct from our ground struct
|
||||
struct tm t = {
|
||||
.tm_sec = second->value.data.intVal,
|
||||
.tm_min = minute->value.data.intVal,
|
||||
.tm_hour = hour->value.data.intVal,
|
||||
.tm_mday = day->value.data.intVal,
|
||||
.tm_mon = month->value.data.intVal - 1,
|
||||
.tm_year = year->value.data.intVal - 1900,
|
||||
.tm_wday = 0,
|
||||
.tm_yday = 0,
|
||||
.tm_isdst = -1
|
||||
};
|
||||
|
||||
time_t ts = timegm(&t);
|
||||
return groundCreateValue(INT, (long long)ts);
|
||||
}
|
||||
|
||||
GroundValue formatDatetimeObj(GroundObject obj, char* formatString) {
|
||||
// check args
|
||||
GroundObjectField* year = groundFindField(obj, "year");
|
||||
if (year == NULL || year->value.type != INT) ERROR("Object does not have year field as int", "ValueError");
|
||||
GroundObjectField* month = groundFindField(obj, "month");
|
||||
if (month == NULL || month->value.type != INT) ERROR("Object does not have month field as int", "ValueError");
|
||||
GroundObjectField* day = groundFindField(obj, "day");
|
||||
if (day == NULL || day->value.type != INT) ERROR("Object does not have day field as int", "ValueError");
|
||||
GroundObjectField* hour = groundFindField(obj, "hour");
|
||||
if (hour == NULL || hour->value.type != INT) ERROR("Object does not have hour field as int", "ValueError");
|
||||
GroundObjectField* minute = groundFindField(obj, "minute");
|
||||
if (minute == NULL || minute->value.type != INT) ERROR("Object does not have minute field as int", "ValueError");
|
||||
GroundObjectField* second = groundFindField(obj, "second");
|
||||
if (second == NULL || second->value.type != INT) ERROR("Object does not have second field as int", "ValueError");
|
||||
GroundObjectField* weekDay = groundFindField(obj, "weekDay");
|
||||
if (weekDay == NULL || weekDay->value.type != INT) ERROR("Object does not have weekDay field as int", "ValueError");
|
||||
GroundObjectField* yearDay = groundFindField(obj, "yearDay");
|
||||
if (yearDay == NULL || yearDay->value.type != INT) ERROR("Object does not have yearDay field as int", "ValueError");
|
||||
GroundObjectField* isDaylightSavingsTime = groundFindField(obj, "isDaylightSavingsTime");
|
||||
if (isDaylightSavingsTime == NULL || isDaylightSavingsTime->value.type != BOOL) ERROR("Object does not have isDaylightSavingsTime field as bool", "ValueError");
|
||||
|
||||
// construct tm struct from our ground struct
|
||||
struct tm t = {
|
||||
.tm_sec = second->value.data.intVal,
|
||||
.tm_min = minute->value.data.intVal,
|
||||
.tm_hour = hour->value.data.intVal,
|
||||
.tm_mday = day->value.data.intVal,
|
||||
.tm_mon = month->value.data.intVal - 1,
|
||||
.tm_year = year->value.data.intVal - 1900,
|
||||
.tm_wday = 0,
|
||||
.tm_yday = 0,
|
||||
.tm_isdst = -1
|
||||
};
|
||||
|
||||
mktime(&t); // normalise time
|
||||
|
||||
// create a buffer for the string
|
||||
char* buffer = (char*)malloc(128);
|
||||
strftime(buffer, 128, formatString, &t);
|
||||
|
||||
// return ground version of string
|
||||
return groundCreateValue(STRING, buffer);
|
||||
}
|
||||
|
||||
GroundValue datetime_Format(GroundScope* scope, List args) {
|
||||
return formatDatetimeObj(
|
||||
*args.values[0].data.customVal,
|
||||
args.values[1].data.stringVal
|
||||
);
|
||||
}
|
||||
|
||||
GroundValue datetime_FromFormatted(GroundScope* scope, List args) {
|
||||
char* timeString = args.values[0].data.stringVal;
|
||||
char* formatString = args.values[1].data.stringVal;
|
||||
|
||||
struct tm t = {0};
|
||||
t.tm_isdst = -1;
|
||||
char* result = strptime(timeString, formatString, &t);
|
||||
|
||||
if (result == NULL) {
|
||||
ERROR("Time string does not match format!", "ValueError");
|
||||
}
|
||||
|
||||
mktime(&t);
|
||||
|
||||
return tmToGroundValue(t);
|
||||
}
|
||||
|
||||
GroundValue datetime_ToISO8601UTC(GroundScope* scope, List args) {
|
||||
GroundObject obj = *args.values[0].data.customVal;
|
||||
|
||||
// check args
|
||||
GroundObjectField* year = groundFindField(obj, "year");
|
||||
if (year == NULL || year->value.type != INT) ERROR("Object does not have year field as int", "ValueError");
|
||||
GroundObjectField* month = groundFindField(obj, "month");
|
||||
if (month == NULL || month->value.type != INT) ERROR("Object does not have month field as int", "ValueError");
|
||||
GroundObjectField* day = groundFindField(obj, "day");
|
||||
if (day == NULL || day->value.type != INT) ERROR("Object does not have day field as int", "ValueError");
|
||||
GroundObjectField* hour = groundFindField(obj, "hour");
|
||||
if (hour == NULL || hour->value.type != INT) ERROR("Object does not have hour field as int", "ValueError");
|
||||
GroundObjectField* minute = groundFindField(obj, "minute");
|
||||
if (minute == NULL || minute->value.type != INT) ERROR("Object does not have minute field as int", "ValueError");
|
||||
GroundObjectField* second = groundFindField(obj, "second");
|
||||
if (second == NULL || second->value.type != INT) ERROR("Object does not have second field as int", "ValueError");
|
||||
GroundObjectField* weekDay = groundFindField(obj, "weekDay");
|
||||
if (weekDay == NULL || weekDay->value.type != INT) ERROR("Object does not have weekDay field as int", "ValueError");
|
||||
GroundObjectField* yearDay = groundFindField(obj, "yearDay");
|
||||
if (yearDay == NULL || yearDay->value.type != INT) ERROR("Object does not have yearDay field as int", "ValueError");
|
||||
GroundObjectField* isDaylightSavingsTime = groundFindField(obj, "isDaylightSavingsTime");
|
||||
if (isDaylightSavingsTime == NULL || isDaylightSavingsTime->value.type != BOOL) ERROR("Object does not have isDaylightSavingsTime field as bool", "ValueError");
|
||||
|
||||
// construct tm struct from our ground struct
|
||||
struct tm t = {
|
||||
.tm_sec = second->value.data.intVal,
|
||||
.tm_min = minute->value.data.intVal,
|
||||
.tm_hour = hour->value.data.intVal,
|
||||
.tm_mday = day->value.data.intVal,
|
||||
.tm_mon = month->value.data.intVal - 1,
|
||||
.tm_year = year->value.data.intVal - 1900,
|
||||
.tm_wday = 0,
|
||||
.tm_yday = 0,
|
||||
.tm_isdst = -1
|
||||
};
|
||||
|
||||
time_t ts = mktime(&t);
|
||||
gmtime_r(&ts, &t);
|
||||
|
||||
char* buffer = (char*)malloc(128);
|
||||
strftime(buffer, 128, "%Y-%m-%dT%H:%M:%SZ", &t);
|
||||
|
||||
return groundCreateValue(STRING, buffer);
|
||||
}
|
||||
|
||||
GroundValue datetime_ToISO8601Local(GroundScope* scope, List args) {
|
||||
GroundObject obj = *args.values[0].data.customVal;
|
||||
|
||||
// check args
|
||||
GroundObjectField* year = groundFindField(obj, "year");
|
||||
if (year == NULL || year->value.type != INT) ERROR("Object does not have year field as int", "ValueError");
|
||||
GroundObjectField* month = groundFindField(obj, "month");
|
||||
if (month == NULL || month->value.type != INT) ERROR("Object does not have month field as int", "ValueError");
|
||||
GroundObjectField* day = groundFindField(obj, "day");
|
||||
if (day == NULL || day->value.type != INT) ERROR("Object does not have day field as int", "ValueError");
|
||||
GroundObjectField* hour = groundFindField(obj, "hour");
|
||||
if (hour == NULL || hour->value.type != INT) ERROR("Object does not have hour field as int", "ValueError");
|
||||
GroundObjectField* minute = groundFindField(obj, "minute");
|
||||
if (minute == NULL || minute->value.type != INT) ERROR("Object does not have minute field as int", "ValueError");
|
||||
GroundObjectField* second = groundFindField(obj, "second");
|
||||
if (second == NULL || second->value.type != INT) ERROR("Object does not have second field as int", "ValueError");
|
||||
GroundObjectField* weekDay = groundFindField(obj, "weekDay");
|
||||
if (weekDay == NULL || weekDay->value.type != INT) ERROR("Object does not have weekDay field as int", "ValueError");
|
||||
GroundObjectField* yearDay = groundFindField(obj, "yearDay");
|
||||
if (yearDay == NULL || yearDay->value.type != INT) ERROR("Object does not have yearDay field as int", "ValueError");
|
||||
GroundObjectField* isDaylightSavingsTime = groundFindField(obj, "isDaylightSavingsTime");
|
||||
if (isDaylightSavingsTime == NULL || isDaylightSavingsTime->value.type != BOOL) ERROR("Object does not have isDaylightSavingsTime field as bool", "ValueError");
|
||||
|
||||
// construct tm struct from our ground struct
|
||||
struct tm t = {
|
||||
.tm_sec = second->value.data.intVal,
|
||||
.tm_min = minute->value.data.intVal,
|
||||
.tm_hour = hour->value.data.intVal,
|
||||
.tm_mday = day->value.data.intVal,
|
||||
.tm_mon = month->value.data.intVal - 1,
|
||||
.tm_year = year->value.data.intVal - 1900,
|
||||
.tm_wday = 0,
|
||||
.tm_yday = 0,
|
||||
.tm_isdst = -1
|
||||
};
|
||||
|
||||
time_t ts = mktime(&t);
|
||||
localtime_r(&ts, &t);
|
||||
|
||||
char* buffer = (char*)malloc(128);
|
||||
strftime(buffer, 128, "%Y-%m-%dT%H:%M:%S%z", &t);
|
||||
|
||||
return groundCreateValue(STRING, buffer);
|
||||
}
|
||||
|
||||
GroundValue datetime_Diff(GroundScope* scope, List args) {
|
||||
GroundObject obj1 = *args.values[0].data.customVal;
|
||||
GroundObject obj2 = *args.values[1].data.customVal;
|
||||
|
||||
// check first timedate object
|
||||
GroundObjectField* year = groundFindField(obj1, "year");
|
||||
if (year == NULL || year->value.type != INT) ERROR("Object 1 does not have year field as int", "ValueError");
|
||||
GroundObjectField* month = groundFindField(obj1, "month");
|
||||
if (month == NULL || month->value.type != INT) ERROR("Object 1 does not have month field as int", "ValueError");
|
||||
GroundObjectField* day = groundFindField(obj1, "day");
|
||||
if (day == NULL || day->value.type != INT) ERROR("Object 1 does not have day field as int", "ValueError");
|
||||
GroundObjectField* hour = groundFindField(obj1, "hour");
|
||||
if (hour == NULL || hour->value.type != INT) ERROR("Object 1 does not have hour field as int", "ValueError");
|
||||
GroundObjectField* minute = groundFindField(obj1, "minute");
|
||||
if (minute == NULL || minute->value.type != INT) ERROR("Object 1 does not have minute field as int", "ValueError");
|
||||
GroundObjectField* second = groundFindField(obj1, "second");
|
||||
if (second == NULL || second->value.type != INT) ERROR("Object 1 does not have second field as int", "ValueError");
|
||||
GroundObjectField* weekDay = groundFindField(obj1, "weekDay");
|
||||
if (weekDay == NULL || weekDay->value.type != INT) ERROR("Object 1 does not have weekDay field as int", "ValueError");
|
||||
GroundObjectField* yearDay = groundFindField(obj1, "yearDay");
|
||||
if (yearDay == NULL || yearDay->value.type != INT) ERROR("Object 1 does not have yearDay field as int", "ValueError");
|
||||
GroundObjectField* isDaylightSavingsTime = groundFindField(obj1, "isDaylightSavingsTime");
|
||||
if (isDaylightSavingsTime == NULL || isDaylightSavingsTime->value.type != BOOL) ERROR("Object 1 does not have isDaylightSavingsTime field as bool", "ValueError");
|
||||
|
||||
// construct tm struct from our ground struct
|
||||
struct tm t1 = {
|
||||
.tm_sec = second->value.data.intVal,
|
||||
.tm_min = minute->value.data.intVal,
|
||||
.tm_hour = hour->value.data.intVal,
|
||||
.tm_mday = day->value.data.intVal,
|
||||
.tm_mon = month->value.data.intVal - 1,
|
||||
.tm_year = year->value.data.intVal - 1900,
|
||||
.tm_wday = 0,
|
||||
.tm_yday = 0,
|
||||
.tm_isdst = -1
|
||||
};
|
||||
|
||||
|
||||
// check second timedate object
|
||||
year = groundFindField(obj2, "year");
|
||||
if (year == NULL || year->value.type != INT) ERROR("Object does not have year field as int", "ValueError");
|
||||
month = groundFindField(obj2, "month");
|
||||
if (month == NULL || month->value.type != INT) ERROR("Object does not have month field as int", "ValueError");
|
||||
day = groundFindField(obj2, "day");
|
||||
if (day == NULL || day->value.type != INT) ERROR("Object does not have day field as int", "ValueError");
|
||||
hour = groundFindField(obj2, "hour");
|
||||
if (hour == NULL || hour->value.type != INT) ERROR("Object does not have hour field as int", "ValueError");
|
||||
minute = groundFindField(obj2, "minute");
|
||||
if (minute == NULL || minute->value.type != INT) ERROR("Object does not have minute field as int", "ValueError");
|
||||
second = groundFindField(obj2, "second");
|
||||
if (second == NULL || second->value.type != INT) ERROR("Object does not have second field as int", "ValueError");
|
||||
weekDay = groundFindField(obj2, "weekDay");
|
||||
if (weekDay == NULL || weekDay->value.type != INT) ERROR("Object does not have weekDay field as int", "ValueError");
|
||||
yearDay = groundFindField(obj2, "yearDay");
|
||||
if (yearDay == NULL || yearDay->value.type != INT) ERROR("Object does not have yearDay field as int", "ValueError");
|
||||
isDaylightSavingsTime = groundFindField(obj2, "isDaylightSavingsTime");
|
||||
if (isDaylightSavingsTime == NULL || isDaylightSavingsTime->value.type != BOOL) ERROR("Object does not have isDaylightSavingsTime field as bool", "ValueError");
|
||||
|
||||
// construct tm struct from our ground struct
|
||||
struct tm t2 = {
|
||||
.tm_sec = second->value.data.intVal,
|
||||
.tm_min = minute->value.data.intVal,
|
||||
.tm_hour = hour->value.data.intVal,
|
||||
.tm_mday = day->value.data.intVal,
|
||||
.tm_mon = month->value.data.intVal - 1,
|
||||
.tm_year = year->value.data.intVal - 1900,
|
||||
.tm_wday = 0,
|
||||
.tm_yday = 0,
|
||||
.tm_isdst = -1
|
||||
};
|
||||
|
||||
|
||||
time_t ts1 = mktime(&t1);
|
||||
time_t ts2 = mktime(&t2);
|
||||
|
||||
return groundCreateValue(INT, ts2 - ts1);
|
||||
}
|
||||
|
||||
GroundValue datetime_Add(GroundScope* scope, List args) {
|
||||
GroundObject obj = *args.values[0].data.customVal;
|
||||
|
||||
long long secs = args.values[1].data.intVal;
|
||||
long long mins = args.values[2].data.intVal;
|
||||
long long hours = args.values[3].data.intVal;
|
||||
long long days = args.values[4].data.intVal;
|
||||
|
||||
// check args
|
||||
GroundObjectField* year = groundFindField(obj, "year");
|
||||
if (year == NULL || year->value.type != INT) ERROR("Object does not have year field as int", "ValueError");
|
||||
GroundObjectField* month = groundFindField(obj, "month");
|
||||
if (month == NULL || month->value.type != INT) ERROR("Object does not have month field as int", "ValueError");
|
||||
GroundObjectField* day = groundFindField(obj, "day");
|
||||
if (day == NULL || day->value.type != INT) ERROR("Object does not have day field as int", "ValueError");
|
||||
GroundObjectField* hour = groundFindField(obj, "hour");
|
||||
if (hour == NULL || hour->value.type != INT) ERROR("Object does not have hour field as int", "ValueError");
|
||||
GroundObjectField* minute = groundFindField(obj, "minute");
|
||||
if (minute == NULL || minute->value.type != INT) ERROR("Object does not have minute field as int", "ValueError");
|
||||
GroundObjectField* second = groundFindField(obj, "second");
|
||||
if (second == NULL || second->value.type != INT) ERROR("Object does not have second field as int", "ValueError");
|
||||
GroundObjectField* weekDay = groundFindField(obj, "weekDay");
|
||||
if (weekDay == NULL || weekDay->value.type != INT) ERROR("Object does not have weekDay field as int", "ValueError");
|
||||
GroundObjectField* yearDay = groundFindField(obj, "yearDay");
|
||||
if (yearDay == NULL || yearDay->value.type != INT) ERROR("Object does not have yearDay field as int", "ValueError");
|
||||
GroundObjectField* isDaylightSavingsTime = groundFindField(obj, "isDaylightSavingsTime");
|
||||
if (isDaylightSavingsTime == NULL || isDaylightSavingsTime->value.type != BOOL) ERROR("Object does not have isDaylightSavingsTime field as bool", "ValueError");
|
||||
|
||||
// construct tm struct from our ground struct
|
||||
struct tm t = {
|
||||
.tm_sec = second->value.data.intVal,
|
||||
.tm_min = minute->value.data.intVal,
|
||||
.tm_hour = hour->value.data.intVal,
|
||||
.tm_mday = day->value.data.intVal,
|
||||
.tm_mon = month->value.data.intVal - 1,
|
||||
.tm_year = year->value.data.intVal - 1900,
|
||||
.tm_wday = 0,
|
||||
.tm_yday = 0,
|
||||
.tm_isdst = -1
|
||||
};
|
||||
|
||||
time_t base = mktime(&t);
|
||||
|
||||
long long totalSeconds =
|
||||
secs +
|
||||
mins * 60 +
|
||||
hours * 3600 +
|
||||
days * 86400;
|
||||
|
||||
base += totalSeconds;
|
||||
|
||||
struct tm newT;
|
||||
localtime_r(&base, &newT);
|
||||
|
||||
return tmToGroundValue(newT);
|
||||
|
||||
}
|
||||
18
libs/datetime/date_functions.h
Normal file
18
libs/datetime/date_functions.h
Normal file
@@ -0,0 +1,18 @@
|
||||
#pragma once
|
||||
#define _XOPEN_SOURCE // to make gcc happy lol
|
||||
|
||||
#include <groundext.h>
|
||||
#include <groundvm.h>
|
||||
#include <time.h>
|
||||
|
||||
GroundValue datetime_Now(GroundScope* scope, List args);
|
||||
GroundValue datetime_Format(GroundScope* scope, List args);
|
||||
GroundValue datetime_FromFormatted(GroundScope* scope, List args);
|
||||
GroundValue datetime_ToISO8601UTC(GroundScope* scope, List args);
|
||||
GroundValue datetime_ToISO8601Local(GroundScope* scope, List args);
|
||||
GroundValue datetime_FromEpochLocal(GroundScope* scope, List args);
|
||||
GroundValue datetime_FromEpochUTC(GroundScope* scope, List args);
|
||||
GroundValue datetime_ToEpochLocal(GroundScope* scope, List args);
|
||||
GroundValue datetime_ToEpochUTC(GroundScope* scope, List args);
|
||||
GroundValue datetime_Diff(GroundScope* scope, List args);
|
||||
GroundValue datetime_Add(GroundScope* scope, List args);
|
||||
18
libs/datetime/datetime.c
Normal file
18
libs/datetime/datetime.c
Normal file
@@ -0,0 +1,18 @@
|
||||
#include "time_functions.h"
|
||||
#include "date_functions.h"
|
||||
|
||||
|
||||
void ground_init(GroundScope* scope) {
|
||||
groundAddNativeFunction(scope, "datetime_NowEpoch", datetime_NowEpoch, DOUBLE, 0);
|
||||
groundAddNativeFunction(scope, "datetime_Now", datetime_Now, CUSTOM, 0);
|
||||
groundAddNativeFunction(scope, "datetime_Format", datetime_Format, STRING, 2, CUSTOM, "datetime", STRING, "format");
|
||||
groundAddNativeFunction(scope, "datetime_FromFormatted", datetime_FromFormatted, CUSTOM, 2, STRING, "datetimeString", STRING, "format");
|
||||
groundAddNativeFunction(scope, "datetime_ToISO8601UTC", datetime_ToISO8601UTC, STRING, 1, CUSTOM, "datetime");
|
||||
groundAddNativeFunction(scope, "datetime_ToISO8601Local", datetime_ToISO8601Local, STRING, 1, CUSTOM, "datetime");
|
||||
groundAddNativeFunction(scope, "datetime_FromEpochUTC", datetime_FromEpochUTC, CUSTOM, 1, DOUBLE, "epoch");
|
||||
groundAddNativeFunction(scope, "datetime_FromEpochLocal", datetime_FromEpochLocal, CUSTOM, 1, DOUBLE, "epoch");
|
||||
groundAddNativeFunction(scope, "datetime_ToEpochUTC", datetime_ToEpochUTC, INT, 1, CUSTOM, "datetime");
|
||||
groundAddNativeFunction(scope, "datetime_ToEpochLocal", datetime_ToEpochLocal, INT, 1, CUSTOM, "datetime");
|
||||
groundAddNativeFunction(scope, "datetime_Diff", datetime_Diff, INT, 2, CUSTOM, "datetime1", CUSTOM, "datetime2");
|
||||
groundAddNativeFunction(scope, "datetime_Add", datetime_Add, CUSTOM, 5, CUSTOM, "datetime", INT, "seconds", INT, "minutes", INT, "hours", INT, "days");
|
||||
}
|
||||
12
libs/datetime/time_functions.c
Normal file
12
libs/datetime/time_functions.c
Normal file
@@ -0,0 +1,12 @@
|
||||
#include "time_functions.h"
|
||||
|
||||
GroundValue datetime_NowEpoch(GroundScope* scope, List args) {
|
||||
// grab time from system clock
|
||||
struct timespec ts;
|
||||
clock_gettime(CLOCK_REALTIME, &ts);
|
||||
|
||||
// convert it to secs and return it
|
||||
double secsSinceEpoch = (double)ts.tv_sec + (double)ts.tv_nsec / 1e9;
|
||||
|
||||
return groundCreateValue(DOUBLE, secsSinceEpoch);
|
||||
}
|
||||
5
libs/datetime/time_functions.h
Normal file
5
libs/datetime/time_functions.h
Normal file
@@ -0,0 +1,5 @@
|
||||
#pragma once
|
||||
#include <groundext.h>
|
||||
#include <time.h>
|
||||
|
||||
GroundValue datetime_NowEpoch(GroundScope* scope, List args);
|
||||
@@ -1,35 +1,23 @@
|
||||
#include <groundext.h>
|
||||
#include <curl/curl.h>
|
||||
#include <groundvm.h>
|
||||
#include <curl/curl.h>
|
||||
#include <stdio.h>
|
||||
#include <string.h>
|
||||
#include <stdlib.h>
|
||||
#include <stdbool.h>
|
||||
|
||||
bool curl_init = false;
|
||||
CURL* curlHandle = NULL;
|
||||
|
||||
GroundStruct template;
|
||||
|
||||
const char* VALID_REQUEST_TYPES[] = {
|
||||
"GET",
|
||||
"POST"
|
||||
};
|
||||
|
||||
typedef struct {
|
||||
char* data;
|
||||
size_t size;
|
||||
} ResponseBuffer;
|
||||
|
||||
typedef struct {
|
||||
CURL* handle;
|
||||
bool connected;
|
||||
char* url;
|
||||
} WebSocketConnection;
|
||||
|
||||
// Global storage for WebSocket connections (simple implementation)
|
||||
#define MAX_WS_CONNECTIONS 10
|
||||
WebSocketConnection ws_connections[MAX_WS_CONNECTIONS] = {0};
|
||||
|
||||
void curl_setup() {
|
||||
if (!curl_init) {
|
||||
curl_global_init(CURL_GLOBAL_ALL);
|
||||
curl_init = true;
|
||||
}
|
||||
}
|
||||
|
||||
// Proper write callback that accumulates data
|
||||
size_t write_callback(void* ptr, size_t size, size_t nmemb, void* userdata) {
|
||||
size_t total_size = size * nmemb;
|
||||
ResponseBuffer* buffer = (ResponseBuffer*)userdata;
|
||||
@@ -48,295 +36,117 @@ size_t write_callback(void* ptr, size_t size, size_t nmemb, void* userdata) {
|
||||
return total_size;
|
||||
}
|
||||
|
||||
// GET request
|
||||
GroundValue get_request(GroundScope* scope, List args) {
|
||||
curl_setup();
|
||||
CURL* handle = curl_easy_init();
|
||||
|
||||
if (!handle) {
|
||||
ERROR("CURL failed to init", "GenericRequestError");
|
||||
}
|
||||
|
||||
ResponseBuffer buffer = {0};
|
||||
buffer.data = malloc(1);
|
||||
buffer.data[0] = '\0';
|
||||
buffer.size = 0;
|
||||
|
||||
curl_easy_setopt(handle, CURLOPT_URL, args.values[0].data.stringVal);
|
||||
curl_easy_setopt(handle, CURLOPT_HTTPGET, 1L);
|
||||
curl_easy_setopt(handle, CURLOPT_WRITEFUNCTION, write_callback);
|
||||
curl_easy_setopt(handle, CURLOPT_WRITEDATA, &buffer);
|
||||
curl_easy_setopt(handle, CURLOPT_FOLLOWLOCATION, 1L);
|
||||
|
||||
CURLcode result = curl_easy_perform(handle);
|
||||
|
||||
if (result != CURLE_OK) {
|
||||
char buf[256];
|
||||
snprintf(buf, sizeof(buf) - 1, "Curl request failed: %s\n", curl_easy_strerror(result));
|
||||
ERROR(buf, "ActionRequestError");
|
||||
}
|
||||
|
||||
curl_easy_cleanup(handle);
|
||||
|
||||
GroundValue ret = groundCreateValue(STRING, buffer.data);
|
||||
return ret;
|
||||
}
|
||||
GroundValue ground_request(GroundScope* scope, List args) {
|
||||
|
||||
// POST request
|
||||
GroundValue post_request(GroundScope* scope, List args) {
|
||||
curl_setup();
|
||||
CURL* handle = curl_easy_init();
|
||||
|
||||
if (!handle) {
|
||||
ERROR("CURL failed to init", "GenericRequestError");
|
||||
}
|
||||
|
||||
ResponseBuffer buffer = {0};
|
||||
buffer.data = malloc(1);
|
||||
buffer.data[0] = '\0';
|
||||
buffer.size = 0;
|
||||
|
||||
curl_easy_setopt(handle, CURLOPT_URL, args.values[0].data.stringVal);
|
||||
curl_easy_setopt(handle, CURLOPT_POST, 1L);
|
||||
curl_easy_setopt(handle, CURLOPT_POSTFIELDS, args.values[1].data.stringVal);
|
||||
curl_easy_setopt(handle, CURLOPT_WRITEFUNCTION, write_callback);
|
||||
curl_easy_setopt(handle, CURLOPT_WRITEDATA, &buffer);
|
||||
curl_easy_setopt(handle, CURLOPT_FOLLOWLOCATION, 1L);
|
||||
|
||||
CURLcode result = curl_easy_perform(handle);
|
||||
|
||||
if (result != CURLE_OK) {
|
||||
free(buffer.data);
|
||||
char buf[256];
|
||||
snprintf(buf, sizeof(buf) - 1, "Curl request failed: %s\n", curl_easy_strerror(result));
|
||||
curl_easy_cleanup(handle);
|
||||
ERROR(buf, "ActionRequestError");
|
||||
}
|
||||
|
||||
curl_easy_cleanup(handle);
|
||||
|
||||
GroundValue ret = groundCreateValue(STRING, buffer.data);
|
||||
return ret;
|
||||
}
|
||||
GroundObject obj = *args.values[0].data.customVal;
|
||||
|
||||
// ============== WebSocket Functions ==============
|
||||
// check arg types
|
||||
GroundObjectField* address = groundFindField(obj, "address");
|
||||
if (address == NULL || address->value.type != STRING) {
|
||||
ERROR("Object does not have address field as string", "ValueError");
|
||||
}
|
||||
GroundObjectField* type = groundFindField(obj, "type");
|
||||
if (type == NULL || type->value.type != STRING) {
|
||||
ERROR("Object does not have type field as string", "ValueError");
|
||||
}
|
||||
GroundObjectField* userAgent = groundFindField(obj, "userAgent");
|
||||
if (userAgent == NULL || userAgent->value.type != STRING) {
|
||||
ERROR("Object does not have userAgent field as string", "ValueError");
|
||||
}
|
||||
GroundObjectField* httpHeaders = groundFindField(obj, "httpHeaders");
|
||||
if (httpHeaders == NULL || httpHeaders->value.type != LIST) {
|
||||
ERROR("Object does not have httpHeaders field as list<string>", "ValueError");
|
||||
}
|
||||
GroundObjectField* verbose = groundFindField(obj, "verbose");
|
||||
if (verbose == NULL || verbose->value.type != BOOL) {
|
||||
ERROR("Object does not have verbose field as bool", "ValueError");
|
||||
}
|
||||
|
||||
// Find an empty slot for a new WebSocket connection
|
||||
int find_ws_slot() {
|
||||
for (int i = 0; i < MAX_WS_CONNECTIONS; i++) {
|
||||
if (!ws_connections[i].connected) {
|
||||
return i;
|
||||
// check request type string
|
||||
bool requestTypeOk = false;
|
||||
for (int i = 0; i < sizeof(VALID_REQUEST_TYPES)/sizeof(VALID_REQUEST_TYPES[0]); i++) {
|
||||
if (strcmp(type->value.data.stringVal, VALID_REQUEST_TYPES[i]) == 0) {
|
||||
requestTypeOk = true;
|
||||
break;
|
||||
}
|
||||
}
|
||||
return -1;
|
||||
}
|
||||
if (!requestTypeOk)
|
||||
ERROR("Invalid request type! Choices: GET, POST", "ValueError");
|
||||
|
||||
|
||||
// WebSocket Connect - returns connection ID as INT
|
||||
GroundValue ws_connect(GroundScope* scope, List args) {
|
||||
curl_setup();
|
||||
|
||||
int slot = find_ws_slot();
|
||||
if (slot == -1) {
|
||||
ERROR("Maximum WebSocket connections reached", "OverflowError");
|
||||
}
|
||||
|
||||
CURL* handle = curl_easy_init();
|
||||
if (!handle) {
|
||||
ERROR("CURL failed to init", "GenericWSError");
|
||||
}
|
||||
|
||||
curl_easy_setopt(handle, CURLOPT_URL, args.values[0].data.stringVal);
|
||||
curl_easy_setopt(handle, CURLOPT_CONNECT_ONLY, 2L); // WebSocket mode
|
||||
curl_easy_setopt(handle, CURLOPT_TIMEOUT, 10L);
|
||||
|
||||
CURLcode result = curl_easy_perform(handle);
|
||||
|
||||
if (result != CURLE_OK) {
|
||||
char buf[256];
|
||||
snprintf(buf, sizeof(buf) - 1, "Curl WebSocket failed: %s\n", curl_easy_strerror(result));
|
||||
curl_easy_cleanup(handle);
|
||||
ERROR(buf, "ActionWSError");
|
||||
}
|
||||
|
||||
ws_connections[slot].handle = handle;
|
||||
ws_connections[slot].connected = true;
|
||||
ws_connections[slot].url = strdup(args.values[0].data.stringVal);
|
||||
|
||||
return groundCreateValue(INT, (int64_t)slot);
|
||||
}
|
||||
ResponseBuffer buffer = {0};
|
||||
|
||||
// WebSocket Send - sends a text message, returns bytes sent as INT
|
||||
GroundValue ws_send(GroundScope* scope, List args) {
|
||||
int conn_id = (int)args.values[0].data.intVal;
|
||||
if (conn_id < 0 || conn_id >= MAX_WS_CONNECTIONS || !ws_connections[conn_id].connected) {
|
||||
ERROR("Invalid WebSocket connection ID", "GenericWSError");
|
||||
}
|
||||
|
||||
CURL* handle = ws_connections[conn_id].handle;
|
||||
const char* message = args.values[1].data.stringVal;
|
||||
size_t sent;
|
||||
|
||||
CURLcode result = curl_ws_send(handle, message, strlen(message), &sent, 0, CURLWS_TEXT);
|
||||
|
||||
if (result != CURLE_OK) {
|
||||
char buf[256];
|
||||
snprintf(buf, sizeof(buf) - 1, "WebSocket send failed: %s\n", curl_easy_strerror(result));
|
||||
ERROR(buf, "ActionWSError");
|
||||
}
|
||||
|
||||
return groundCreateValue(INT, (int64_t)sent);
|
||||
}
|
||||
// set curl params
|
||||
curl_easy_setopt(curlHandle, CURLOPT_URL, address->value.data.stringVal);
|
||||
curl_easy_setopt(curlHandle, CURLOPT_WRITEFUNCTION, write_callback);
|
||||
curl_easy_setopt(curlHandle, CURLOPT_WRITEDATA, (void*)&buffer);
|
||||
curl_easy_setopt(curlHandle, CURLOPT_USERAGENT, userAgent->value.data.stringVal);
|
||||
curl_easy_setopt(curlHandle, CURLOPT_VERBOSE, verbose->value.data.boolVal);
|
||||
|
||||
// WebSocket Receive - receives a message (blocking)
|
||||
GroundValue ws_receive(GroundScope* scope, List args) {
|
||||
int conn_id = (int)args.values[0].data.intVal;
|
||||
if (conn_id < 0 || conn_id >= MAX_WS_CONNECTIONS || !ws_connections[conn_id].connected) {
|
||||
ERROR("Invalid WebSocket connection ID", "GenericWSError");
|
||||
// append headers to http request
|
||||
struct curl_slist* httpHeaderList = NULL;
|
||||
GroundValue* httpHeaderStrings = httpHeaders->value.data.listVal.values;
|
||||
for (int i = 0; i < httpHeaders->value.data.listVal.size; i++) {
|
||||
httpHeaderList = curl_slist_append(httpHeaderList, httpHeaderStrings[i].data.stringVal);
|
||||
}
|
||||
|
||||
CURL* handle = ws_connections[conn_id].handle;
|
||||
char buffer[4096];
|
||||
size_t received;
|
||||
const struct curl_ws_frame* meta;
|
||||
|
||||
CURLcode result = curl_ws_recv(handle, buffer, sizeof(buffer) - 1, &received, &meta);
|
||||
|
||||
if (result != CURLE_OK) {
|
||||
if (result == CURLE_AGAIN) {
|
||||
// No data available right now
|
||||
return groundCreateValue(STRING, "");
|
||||
}
|
||||
char buf[256];
|
||||
snprintf(buf, sizeof(buf) - 1, "WebSocket receive failed: %s\n", curl_easy_strerror(result));
|
||||
ERROR(buf, "ActionWSError");
|
||||
}
|
||||
|
||||
buffer[received] = '\0';
|
||||
|
||||
// Handle different frame types
|
||||
if (meta->flags & CURLWS_CLOSE) {
|
||||
printf("WebSocket close frame received\n");
|
||||
ws_connections[conn_id].connected = false;
|
||||
return groundCreateValue(STRING, "[CLOSED]");
|
||||
}
|
||||
|
||||
if (meta->flags & CURLWS_PING) {
|
||||
// Automatically respond to ping with pong
|
||||
curl_ws_send(handle, "", 0, &received, 0, CURLWS_PONG);
|
||||
return groundCreateValue(STRING, "[PING]");
|
||||
}
|
||||
|
||||
char* data = malloc(received + 1);
|
||||
memcpy(data, buffer, received);
|
||||
data[received] = '\0';
|
||||
|
||||
return groundCreateValue(STRING, data);
|
||||
}
|
||||
curl_easy_setopt(curlHandle, CURLOPT_HTTPHEADER, httpHeaderList);
|
||||
|
||||
// WebSocket Receive with timeout (non-blocking version)
|
||||
GroundValue ws_receive_timeout(GroundScope* scope, List args) {
|
||||
int conn_id = (int)args.values[0].data.intVal;
|
||||
long timeout_ms = (long)args.values[1].data.intVal;
|
||||
|
||||
if (conn_id < 0 || conn_id >= MAX_WS_CONNECTIONS || !ws_connections[conn_id].connected) {
|
||||
ERROR("Invalid WebSocket connection ID", "GenericWSError");
|
||||
}
|
||||
|
||||
CURL* handle = ws_connections[conn_id].handle;
|
||||
|
||||
// Set socket to non-blocking mode
|
||||
curl_easy_setopt(handle, CURLOPT_TIMEOUT_MS, timeout_ms);
|
||||
|
||||
char buffer[4096];
|
||||
size_t received;
|
||||
const struct curl_ws_frame* meta;
|
||||
|
||||
CURLcode result = curl_ws_recv(handle, buffer, sizeof(buffer) - 1, &received, &meta);
|
||||
|
||||
if (result == CURLE_AGAIN || result == CURLE_OPERATION_TIMEDOUT) {
|
||||
return groundCreateValue(STRING, "");
|
||||
}
|
||||
|
||||
if (result != CURLE_OK) {
|
||||
char buf[256];
|
||||
snprintf(buf, sizeof(buf) - 1, "WebSocket receive failed: %s\n", curl_easy_strerror(result));
|
||||
ERROR(buf, "ActionWSError");
|
||||
}
|
||||
|
||||
buffer[received] = '\0';
|
||||
|
||||
if (meta->flags & CURLWS_CLOSE) {
|
||||
ws_connections[conn_id].connected = false;
|
||||
return groundCreateValue(STRING, "[CLOSED]");
|
||||
}
|
||||
|
||||
if (meta->flags & CURLWS_PING) {
|
||||
curl_ws_send(handle, "", 0, &received, 0, CURLWS_PONG);
|
||||
return groundCreateValue(STRING, "[PING]");
|
||||
}
|
||||
|
||||
char* data = malloc(received + 1);
|
||||
memcpy(data, buffer, received);
|
||||
data[received] = '\0';
|
||||
|
||||
return groundCreateValue(STRING, data);
|
||||
}
|
||||
|
||||
// WebSocket Close - properly close a connection, returns BOOL success
|
||||
GroundValue ws_close(GroundScope* scope, List args) {
|
||||
int conn_id = (int)args.values[0].data.intVal;
|
||||
if (conn_id < 0 || conn_id >= MAX_WS_CONNECTIONS || !ws_connections[conn_id].connected) {
|
||||
ERROR("Invalid or already connected websocket", "GenericWSError");
|
||||
}
|
||||
|
||||
CURL* handle = ws_connections[conn_id].handle;
|
||||
size_t sent;
|
||||
|
||||
// Send close frame
|
||||
curl_ws_send(handle, "", 0, &sent, 0, CURLWS_CLOSE);
|
||||
|
||||
// Cleanup
|
||||
curl_easy_cleanup(handle);
|
||||
free(ws_connections[conn_id].url);
|
||||
ws_connections[conn_id].handle = NULL;
|
||||
ws_connections[conn_id].connected = false;
|
||||
ws_connections[conn_id].url = NULL;
|
||||
|
||||
return groundCreateValue(BOOL, true);
|
||||
}
|
||||
CURLcode curlStatus = curl_easy_perform(curlHandle);
|
||||
curl_slist_free_all(httpHeaderList); // dont want em' memory leaks :P - spooopy
|
||||
|
||||
// WebSocket Send Binary data, returns bytes sent as INT
|
||||
GroundValue ws_send_binary(GroundScope* scope, List args) {
|
||||
int conn_id = (int)args.values[0].data.intVal;
|
||||
if (conn_id < 0 || conn_id >= MAX_WS_CONNECTIONS || !ws_connections[conn_id].connected) {
|
||||
ERROR("Invalid WebSocket connection ID", "GenericWSError");
|
||||
// check for any curl errors
|
||||
if (curlStatus != CURLE_OK) {
|
||||
char curlErrorMsg[255] = {0};
|
||||
|
||||
snprintf(curlErrorMsg, 255, "%s\n", curl_easy_strerror(curlStatus));
|
||||
ERROR(curlErrorMsg, "CurlError");
|
||||
}
|
||||
|
||||
CURL* handle = ws_connections[conn_id].handle;
|
||||
const char* data = args.values[1].data.stringVal;
|
||||
size_t sent;
|
||||
|
||||
CURLcode result = curl_ws_send(handle, data, strlen(data), &sent, 0, CURLWS_BINARY);
|
||||
|
||||
if (result != CURLE_OK) {
|
||||
char buf[256];
|
||||
snprintf(buf, sizeof(buf) - 1, "WebSocket binary send failed: %s\n", curl_easy_strerror(result));
|
||||
ERROR(buf, "ActionWSError");
|
||||
}
|
||||
|
||||
return groundCreateValue(INT, (int64_t)sent);
|
||||
|
||||
// get the http response code
|
||||
long httpCode = 0;
|
||||
curl_easy_getinfo(curlHandle, CURLINFO_RESPONSE_CODE, &httpCode);
|
||||
|
||||
// create return value and return it
|
||||
GroundValue value = groundCreateValue(CUSTOM, &template);
|
||||
|
||||
GroundObjectField* status = groundFindField(*value.data.customVal, "statusCode");
|
||||
status->value.data.intVal = httpCode;
|
||||
|
||||
GroundObjectField* data = groundFindField(*value.data.customVal, "data");
|
||||
data->value.data.stringVal = buffer.data;
|
||||
|
||||
value.type = CUSTOM;
|
||||
|
||||
return value;
|
||||
}
|
||||
|
||||
void ground_init(GroundScope* scope) {
|
||||
// HTTP Functions
|
||||
groundAddNativeFunction(scope, "request_Get", get_request, STRING, 1, STRING, "url");
|
||||
groundAddNativeFunction(scope, "request_Post", post_request, STRING, 2, STRING, "url", STRING, "data");
|
||||
|
||||
// WebSocket Functions
|
||||
groundAddNativeFunction(scope, "ws_Connect", ws_connect, INT, 1, STRING, "url");
|
||||
groundAddNativeFunction(scope, "ws_Send", ws_send, INT, 2, INT, "conn_id", STRING, "message");
|
||||
groundAddNativeFunction(scope, "ws_Receive", ws_receive, STRING, 1, INT, "conn_id");
|
||||
groundAddNativeFunction(scope, "ws_ReceiveTimeout", ws_receive_timeout, STRING, 2, INT, "conn_id", INT, "timeout_ms");
|
||||
groundAddNativeFunction(scope, "ws_Close", ws_close, BOOL, 1, INT, "conn_id");
|
||||
groundAddNativeFunction(scope, "ws_SendBinary", ws_send_binary, INT, 2, INT, "conn_id", STRING, "data");
|
||||
}
|
||||
// init libcurl
|
||||
curl_global_init(CURL_GLOBAL_ALL);
|
||||
curlHandle = curl_easy_init();
|
||||
|
||||
groundAddValueToScope(scope, "requestInitSuccess", groundCreateValue(BOOL, curlHandle != NULL));
|
||||
if (curlHandle == NULL) {
|
||||
return;
|
||||
}
|
||||
|
||||
// create struct
|
||||
template = groundCreateStruct();
|
||||
groundAddFieldToStruct(&template, "statusCode", groundCreateValue(INT, 200));
|
||||
groundAddFieldToStruct(&template, "data", groundCreateValue(STRING, ""));
|
||||
groundAddFieldToStruct(&template, "ok", groundCreateValue(BOOL, 1));
|
||||
|
||||
// create struct that users can pass to this library
|
||||
GroundStruct requestStruct = groundCreateStruct();
|
||||
groundAddFieldToStruct(&requestStruct, "address", groundCreateValue(STRING, ""));
|
||||
groundAddFieldToStruct(&requestStruct, "type", groundCreateValue(STRING, "GET"));
|
||||
groundAddFieldToStruct(&requestStruct, "userAgent", groundCreateValue(STRING, "Ground/1.0"));
|
||||
groundAddFieldToStruct(&requestStruct, "httpHeaders", groundCreateValue(LIST, 0));
|
||||
groundAddFieldToStruct(&requestStruct, "verbose", groundCreateValue(BOOL, 0));
|
||||
|
||||
groundAddValueToScope(scope, "request", groundCreateValue(STRUCTVAL, requestStruct));
|
||||
|
||||
// create functions
|
||||
groundAddNativeFunction(scope, "request_Request", ground_request, CUSTOM, 1, CUSTOM, "requestInfo");
|
||||
}
|
||||
@@ -87,11 +87,14 @@ GroundValue copyGroundValue(const GroundValue* gv) {
|
||||
case CHAR: newGv.data.charVal = gv->data.charVal; break;
|
||||
case BOOL: newGv.data.boolVal = gv->data.boolVal; break;
|
||||
case STRING:
|
||||
/*
|
||||
if (gv->data.stringVal != NULL) {
|
||||
newGv.data.stringVal = strdup(gv->data.stringVal);
|
||||
} else {
|
||||
newGv.data.stringVal = NULL;
|
||||
}
|
||||
*/
|
||||
newGv.data.stringVal = gv->data.stringVal;
|
||||
break;
|
||||
case LIST: {
|
||||
List newList = createList();
|
||||
@@ -258,7 +261,8 @@ void printGroundValue(GroundValue* gv) {
|
||||
|
||||
void freeGroundValue(GroundValue* gv) {
|
||||
if (gv->type == STRING && gv->data.stringVal != NULL) {
|
||||
free(gv->data.stringVal);
|
||||
// leak some memory for now
|
||||
// free(gv->data.stringVal);
|
||||
gv->data.stringVal = NULL;
|
||||
}
|
||||
if (gv->type == LIST && gv->data.listVal.values != NULL) {
|
||||
|
||||
@@ -1,15 +1,27 @@
|
||||
set &x 5
|
||||
|
||||
PAUSE
|
||||
|
||||
fun !dingle -function -int &a
|
||||
|
||||
PAUSE
|
||||
|
||||
fun !capture -int -int &b
|
||||
|
||||
PAUSE
|
||||
|
||||
add $a $b &tmp
|
||||
add $tmp $x &tmp
|
||||
return $tmp
|
||||
endfun
|
||||
|
||||
return $capture
|
||||
|
||||
endfun
|
||||
|
||||
set &x 10
|
||||
call !dingle 3 &result
|
||||
|
||||
PAUSE
|
||||
|
||||
call !result 5 &y
|
||||
println $y $x
|
||||
println $y
|
||||
|
||||
@@ -1,4 +1,4 @@
|
||||
set &x "dingus"
|
||||
println $x
|
||||
PAUSE
|
||||
drop &x
|
||||
println $x
|
||||
PAUSE
|
||||
|
||||
@@ -1,4 +0,0 @@
|
||||
fun !lib_PrintHello -int
|
||||
println "Hello"
|
||||
return 0
|
||||
endfun
|
||||
@@ -1,6 +1,5 @@
|
||||
# A cool list
|
||||
setlist &favWords "hello" "there" "general"
|
||||
listappend &favWords "kenobi"
|
||||
setlist &favWords "hello" "there" "general" "kenobi"
|
||||
println $favWords
|
||||
|
||||
set &count 0
|
||||
|
||||
@@ -1,5 +0,0 @@
|
||||
[hello, there, general, hello]
|
||||
hello
|
||||
there
|
||||
general
|
||||
,WV
|
||||
11
tests/pause.grnd
Normal file
11
tests/pause.grnd
Normal file
@@ -0,0 +1,11 @@
|
||||
fun !dingle -int
|
||||
|
||||
endfun
|
||||
|
||||
set &x 5
|
||||
set &y "dingle"
|
||||
PAUSE
|
||||
println "continuing"
|
||||
println "step through here"
|
||||
println "step again"
|
||||
println "and again"
|
||||
@@ -18,7 +18,7 @@ fun !fib -int -int &n -function &fib
|
||||
endfun
|
||||
|
||||
# Main program
|
||||
println "Computing fib(20) recursively..."
|
||||
call !fib 20 $fib &answer
|
||||
println "Computing fib(30) recursively..."
|
||||
call !fib 30 $fib &answer
|
||||
println "Result:" $answer
|
||||
end
|
||||
|
||||
@@ -2,10 +2,10 @@ input &str
|
||||
getstrsize $str &size
|
||||
set &idx 0
|
||||
@loop
|
||||
getstrcharat $str $idx &char
|
||||
println $char
|
||||
add 1 $idx &idx
|
||||
equal $idx $size &cond
|
||||
if $cond %loopend
|
||||
jump %loop
|
||||
getstrcharat $str $idx &char
|
||||
println $char
|
||||
add 1 $idx &idx
|
||||
equal $idx $size &cond
|
||||
if $cond %loopend
|
||||
jump %loop
|
||||
@loopend
|
||||
|
||||
@@ -1,80 +0,0 @@
|
||||
#!/usr/bin/env bash
|
||||
|
||||
echo "" > log.txt
|
||||
for f in *.grnd; do
|
||||
[ -e "$f" ] || continue # skip if no files match
|
||||
# Files to skip over
|
||||
if [[ "$f" == "lib.grnd" ]] ||
|
||||
[[ "$f" == "string.grnd" ]] ||
|
||||
[[ "$f" == "test.grnd" ]] ||
|
||||
[[ "$f" == "to1000.grnd" ]] ||
|
||||
[[ "$f" == "uhoh.grnd" ]];
|
||||
then continue
|
||||
fi
|
||||
echo "Running $f"
|
||||
ground "$f" > log.txt
|
||||
|
||||
FILE="log.txt"
|
||||
FAILED="\033[31mFailed:\n\033[0m"
|
||||
if [[ "$f" == "closure.grnd" ]]; then
|
||||
if !(cmp -s "$FILE" <(printf "13 10\n"));
|
||||
then printf $FAILED
|
||||
exit 1
|
||||
fi
|
||||
elif [[ "$f" == "convs.grnd" ]]; then
|
||||
if !(cmp -s "$FILE" <(printf "32\n12\n3.140000\na\n97\n"));
|
||||
then printf $FAILED
|
||||
exit 1
|
||||
fi
|
||||
elif [[ "$f" == "drop.grnd" ]]; then
|
||||
if !(cmp -s "$FILE" <(printf "dingus\nGround runtime error:\n ErrorType: UnknownVariable\n ErrorInstruction: println \$x\n ErrorLine: 4\n"));
|
||||
then printf "\033[31mFailed\n\033[0m"
|
||||
exit 1
|
||||
fi
|
||||
elif [[ "$f" == "error.grnd" ]]; then
|
||||
if !(cmp -s "$FILE" <(printf "Ground runtime error:\n ErrorType: Hello\n ErrorContext: [1, 2, 3, Hi!]\n ErrorInstruction: error \"Hello\" [1, 2, 3, Hi!] 1\n ErrorLine: 2\n"));
|
||||
then printf $FAILED
|
||||
exit 1
|
||||
fi
|
||||
elif [[ "$f" == "fib.grnd" ]]; then
|
||||
if !(cmp -s "$FILE" <(printf "Fibonacci result: 7540113804746346429\n"));
|
||||
then printf $FAILED
|
||||
exit 1
|
||||
fi
|
||||
elif [[ "$f" == "function.grnd" ]]; then
|
||||
if !(cmp -s "$FILE" <(printf "dingle\n1\n2\n3\n4\n5\n6\n7\n8\n9\n10\n"));
|
||||
then printf $FAILED
|
||||
exit 1
|
||||
fi
|
||||
elif [[ "$f" == "list.grnd" ]]; then
|
||||
if !(cmp -s "$FILE" <(printf "[hello, there, general, kenobi]\nhello\nthere\ngeneral\nkenobi\n"));
|
||||
then printf $FAILED
|
||||
exit 1
|
||||
fi
|
||||
elif [[ "$f" == "recursivefib.grnd" ]]; then
|
||||
if !(cmp -s "$FILE" <(printf "Computing fib(20) recursively...\nResult: 6765\n"));
|
||||
then printf $FAILED
|
||||
exit 1
|
||||
fi
|
||||
elif [[ "$f" == "simple.grnd" ]]; then
|
||||
if !(cmp -s "$FILE" <(printf "dingus\ndinglefart\n5.840000\n464773025\n5164.120000\n"));
|
||||
then printf $FAILED
|
||||
exit 1
|
||||
fi
|
||||
elif [[ "$f" == "struct.grnd" ]]; then
|
||||
if !(cmp -s "$FILE" <(printf "53\n32\n"));
|
||||
then printf $FAILED
|
||||
exit 1
|
||||
fi
|
||||
elif [[ "$f" == "use.grnd" ]]; then
|
||||
if !(cmp -s "$FILE" <(printf "Hello\n"));
|
||||
then printf $FAILED
|
||||
exit 1
|
||||
fi
|
||||
else
|
||||
printf "\033[31mCould not find test case\n\033[0m"
|
||||
exit 1
|
||||
fi
|
||||
done
|
||||
printf "\033[32mAll tests passed!\n\033[0m"
|
||||
exit 0
|
||||
@@ -1,2 +0,0 @@
|
||||
use "lib"
|
||||
call !lib_PrintHello &tmp
|
||||
Reference in New Issue
Block a user