forked from ground/ground
Compare commits
18 Commits
a0a8cb69cc
...
master
| Author | SHA1 | Date | |
|---|---|---|---|
| 5c5b0bd26f | |||
| be7db9d837 | |||
| 3bfea76f7d | |||
| a8097c9cf7 | |||
| f9c333a1bc | |||
| ccc8a61f66 | |||
| fd118369d3 | |||
| 2df8d2848d | |||
| fb6dd62a42 | |||
| c60e53a1a8 | |||
| 8f34705965 | |||
| e58eec6f08 | |||
| 7443722dd5 | |||
| e73fdddb4c | |||
| dc2781559d | |||
| 3f678e0cd7 | |||
| 76f342adf8 | |||
| 832c6c7bf9 |
1
.gitignore
vendored
1
.gitignore
vendored
@@ -3,3 +3,4 @@ build
|
|||||||
ground
|
ground
|
||||||
groundc
|
groundc
|
||||||
.idea
|
.idea
|
||||||
|
Makefile
|
||||||
|
|||||||
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 <groundext.h>
|
||||||
#include <curl/curl.h>
|
|
||||||
#include <groundvm.h>
|
#include <groundvm.h>
|
||||||
|
#include <curl/curl.h>
|
||||||
#include <stdio.h>
|
#include <stdio.h>
|
||||||
#include <string.h>
|
#include <stdbool.h>
|
||||||
#include <stdlib.h>
|
|
||||||
|
|
||||||
bool curl_init = false;
|
CURL* curlHandle = NULL;
|
||||||
|
|
||||||
|
GroundStruct template;
|
||||||
|
|
||||||
|
const char* VALID_REQUEST_TYPES[] = {
|
||||||
|
"GET",
|
||||||
|
"POST"
|
||||||
|
};
|
||||||
|
|
||||||
typedef struct {
|
typedef struct {
|
||||||
char* data;
|
char* data;
|
||||||
size_t size;
|
size_t size;
|
||||||
} ResponseBuffer;
|
} 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 write_callback(void* ptr, size_t size, size_t nmemb, void* userdata) {
|
||||||
size_t total_size = size * nmemb;
|
size_t total_size = size * nmemb;
|
||||||
ResponseBuffer* buffer = (ResponseBuffer*)userdata;
|
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;
|
return total_size;
|
||||||
}
|
}
|
||||||
|
|
||||||
// GET request
|
GroundValue ground_request(GroundScope* scope, List args) {
|
||||||
GroundValue get_request(GroundScope* scope, List args) {
|
|
||||||
curl_setup();
|
|
||||||
CURL* handle = curl_easy_init();
|
|
||||||
|
|
||||||
if (!handle) {
|
GroundObject obj = *args.values[0].data.customVal;
|
||||||
ERROR("CURL failed to init", "GenericRequestError");
|
|
||||||
|
// 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");
|
||||||
|
}
|
||||||
|
|
||||||
|
// 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;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if (!requestTypeOk)
|
||||||
|
ERROR("Invalid request type! Choices: GET, POST", "ValueError");
|
||||||
|
|
||||||
|
|
||||||
ResponseBuffer buffer = {0};
|
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);
|
// set curl params
|
||||||
curl_easy_setopt(handle, CURLOPT_HTTPGET, 1L);
|
curl_easy_setopt(curlHandle, CURLOPT_URL, address->value.data.stringVal);
|
||||||
curl_easy_setopt(handle, CURLOPT_WRITEFUNCTION, write_callback);
|
curl_easy_setopt(curlHandle, CURLOPT_WRITEFUNCTION, write_callback);
|
||||||
curl_easy_setopt(handle, CURLOPT_WRITEDATA, &buffer);
|
curl_easy_setopt(curlHandle, CURLOPT_WRITEDATA, (void*)&buffer);
|
||||||
curl_easy_setopt(handle, CURLOPT_FOLLOWLOCATION, 1L);
|
curl_easy_setopt(curlHandle, CURLOPT_USERAGENT, userAgent->value.data.stringVal);
|
||||||
|
curl_easy_setopt(curlHandle, CURLOPT_VERBOSE, verbose->value.data.boolVal);
|
||||||
|
|
||||||
CURLcode result = curl_easy_perform(handle);
|
// 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_easy_setopt(curlHandle, CURLOPT_HTTPHEADER, httpHeaderList);
|
||||||
|
|
||||||
if (result != CURLE_OK) {
|
|
||||||
char buf[256];
|
CURLcode curlStatus = curl_easy_perform(curlHandle);
|
||||||
snprintf(buf, sizeof(buf) - 1, "Curl request failed: %s\n", curl_easy_strerror(result));
|
curl_slist_free_all(httpHeaderList); // dont want em' memory leaks :P - spooopy
|
||||||
ERROR(buf, "ActionRequestError");
|
|
||||||
|
// 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_easy_cleanup(handle);
|
// get the http response code
|
||||||
|
long httpCode = 0;
|
||||||
|
curl_easy_getinfo(curlHandle, CURLINFO_RESPONSE_CODE, &httpCode);
|
||||||
|
|
||||||
GroundValue ret = groundCreateValue(STRING, buffer.data);
|
// create return value and return it
|
||||||
return ret;
|
GroundValue value = groundCreateValue(CUSTOM, &template);
|
||||||
}
|
|
||||||
|
|
||||||
// POST request
|
GroundObjectField* status = groundFindField(*value.data.customVal, "statusCode");
|
||||||
GroundValue post_request(GroundScope* scope, List args) {
|
status->value.data.intVal = httpCode;
|
||||||
curl_setup();
|
|
||||||
CURL* handle = curl_easy_init();
|
|
||||||
|
|
||||||
if (!handle) {
|
GroundObjectField* data = groundFindField(*value.data.customVal, "data");
|
||||||
ERROR("CURL failed to init", "GenericRequestError");
|
data->value.data.stringVal = buffer.data;
|
||||||
}
|
|
||||||
|
|
||||||
ResponseBuffer buffer = {0};
|
value.type = CUSTOM;
|
||||||
buffer.data = malloc(1);
|
|
||||||
buffer.data[0] = '\0';
|
|
||||||
buffer.size = 0;
|
|
||||||
|
|
||||||
curl_easy_setopt(handle, CURLOPT_URL, args.values[0].data.stringVal);
|
return value;
|
||||||
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;
|
|
||||||
}
|
|
||||||
|
|
||||||
// ============== WebSocket Functions ==============
|
|
||||||
|
|
||||||
// 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;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return -1;
|
|
||||||
}
|
|
||||||
|
|
||||||
// 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);
|
|
||||||
}
|
|
||||||
|
|
||||||
// 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);
|
|
||||||
}
|
|
||||||
|
|
||||||
// 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");
|
|
||||||
}
|
|
||||||
|
|
||||||
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);
|
|
||||||
}
|
|
||||||
|
|
||||||
// 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);
|
|
||||||
}
|
|
||||||
|
|
||||||
// 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");
|
|
||||||
}
|
|
||||||
|
|
||||||
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);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
void ground_init(GroundScope* scope) {
|
void ground_init(GroundScope* scope) {
|
||||||
// HTTP Functions
|
// init libcurl
|
||||||
groundAddNativeFunction(scope, "request_Get", get_request, STRING, 1, STRING, "url");
|
curl_global_init(CURL_GLOBAL_ALL);
|
||||||
groundAddNativeFunction(scope, "request_Post", post_request, STRING, 2, STRING, "url", STRING, "data");
|
curlHandle = curl_easy_init();
|
||||||
|
|
||||||
// WebSocket Functions
|
groundAddValueToScope(scope, "requestInitSuccess", groundCreateValue(BOOL, curlHandle != NULL));
|
||||||
groundAddNativeFunction(scope, "ws_Connect", ws_connect, INT, 1, STRING, "url");
|
if (curlHandle == NULL) {
|
||||||
groundAddNativeFunction(scope, "ws_Send", ws_send, INT, 2, INT, "conn_id", STRING, "message");
|
return;
|
||||||
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");
|
// create struct
|
||||||
groundAddNativeFunction(scope, "ws_SendBinary", ws_send_binary, INT, 2, INT, "conn_id", STRING, "data");
|
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");
|
||||||
}
|
}
|
||||||
File diff suppressed because one or more lines are too long
@@ -3,6 +3,7 @@
|
|||||||
#include "compiler.h"
|
#include "compiler.h"
|
||||||
#include "types.h"
|
#include "types.h"
|
||||||
#include "serialize.h"
|
#include "serialize.h"
|
||||||
|
#include "repl.h"
|
||||||
#include <stdio.h>
|
#include <stdio.h>
|
||||||
#include <string.h>
|
#include <string.h>
|
||||||
|
|
||||||
@@ -43,9 +44,8 @@ char* getFileContents(const char* filename) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
int main(int argc, char** argv) {
|
int main(int argc, char** argv) {
|
||||||
if (argc < 2) {
|
if (argc == 1) {
|
||||||
printf("Usage: %s <file> [-c] [--compile] [-h] [--help]\n", argv[0]);
|
exit(repl());
|
||||||
exit(1);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
bool compile = false;
|
bool compile = false;
|
||||||
@@ -71,7 +71,7 @@ int main(int argc, char** argv) {
|
|||||||
printf(" -w <output> or --writebytecode <output>: Outputs binary Ground bytecode");
|
printf(" -w <output> or --writebytecode <output>: Outputs binary Ground bytecode");
|
||||||
printf(" -b <output> or --bytecode <output>: Inputs binary Ground bytecode");
|
printf(" -b <output> or --bytecode <output>: Inputs binary Ground bytecode");
|
||||||
exit(0);
|
exit(0);
|
||||||
} else if (strcmp("--writebytecode", argv[i]) == 0 || strcmp("-w", argv[i]) == 0) {
|
} else if (strcmp("--writeBytecode", argv[i]) == 0 || strcmp("-w", argv[i]) == 0) {
|
||||||
if (compile) {
|
if (compile) {
|
||||||
printf("Cannot choose both bytecode and compilation");
|
printf("Cannot choose both bytecode and compilation");
|
||||||
exit(1);
|
exit(1);
|
||||||
|
|||||||
@@ -176,6 +176,11 @@ static GroundInstType getInstructionType(const char* inst) {
|
|||||||
if (strcmp(inst, "not") == 0) return NOT;
|
if (strcmp(inst, "not") == 0) return NOT;
|
||||||
if (strcmp(inst, "greater") == 0) return GREATER;
|
if (strcmp(inst, "greater") == 0) return GREATER;
|
||||||
if (strcmp(inst, "lesser") == 0) return LESSER;
|
if (strcmp(inst, "lesser") == 0) return LESSER;
|
||||||
|
if (strcmp(inst, "and") == 0) return AND;
|
||||||
|
if (strcmp(inst, "or") == 0) return OR;
|
||||||
|
if (strcmp(inst, "xor") == 0) return XOR;
|
||||||
|
if (strcmp(inst, "neg") == 0) return NEG;
|
||||||
|
if (strcmp(inst, "shift") == 0) return SHIFT;
|
||||||
if (strcmp(inst, "stoi") == 0) return STOI;
|
if (strcmp(inst, "stoi") == 0) return STOI;
|
||||||
if (strcmp(inst, "stod") == 0) return STOD;
|
if (strcmp(inst, "stod") == 0) return STOD;
|
||||||
if (strcmp(inst, "ctoi") == 0) return CTOI;
|
if (strcmp(inst, "ctoi") == 0) return CTOI;
|
||||||
@@ -194,6 +199,7 @@ static GroundInstType getInstructionType(const char* inst) {
|
|||||||
if (strcmp(inst, "use") == 0) return USE;
|
if (strcmp(inst, "use") == 0) return USE;
|
||||||
if (strcmp(inst, "extern") == 0) return EXTERN;
|
if (strcmp(inst, "extern") == 0) return EXTERN;
|
||||||
if (strcmp(inst, "drop") == 0) return DROP;
|
if (strcmp(inst, "drop") == 0) return DROP;
|
||||||
|
if (strcmp(inst, "license") == 0) return LICENSE;
|
||||||
if (strcmp(inst, "PAUSE") == 0) return PAUSE;
|
if (strcmp(inst, "PAUSE") == 0) return PAUSE;
|
||||||
|
|
||||||
fprintf(stderr, "Error: Unknown instruction: %s\n", inst);
|
fprintf(stderr, "Error: Unknown instruction: %s\n", inst);
|
||||||
|
|||||||
60
src/repl.c
Normal file
60
src/repl.c
Normal file
@@ -0,0 +1,60 @@
|
|||||||
|
/*
|
||||||
|
* Ground REPL (shows when ground is ran without any arguments)
|
||||||
|
* Copyright (C) 2026 DiamondNether90
|
||||||
|
*
|
||||||
|
* This program is free software: you can redistribute it and/or modify
|
||||||
|
* it under the terms of the GNU General Public License as published by
|
||||||
|
* the Free Software Foundation, either version 3 of the License, or
|
||||||
|
* (at your option) any later version.
|
||||||
|
*
|
||||||
|
* This program is distributed in the hope that it will be useful,
|
||||||
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||||
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
||||||
|
* GNU General Public License for more details.
|
||||||
|
*
|
||||||
|
* You should have received a copy of the GNU General Public License
|
||||||
|
* along with this program. If not, see <https://www.gnu.org/licenses/>.
|
||||||
|
*/
|
||||||
|
|
||||||
|
#include "interpreter.h"
|
||||||
|
#include "include/estr.h"
|
||||||
|
#include "parser.h"
|
||||||
|
#define BUFFER_SIZE 1024
|
||||||
|
|
||||||
|
int repl() {
|
||||||
|
printf("Ground REPL\n");
|
||||||
|
printf("Copyright (C) DiamondNether90 2026\n");
|
||||||
|
printf("Distributed under the GNU GPL-3.0 license; type \"license\" for more info\n");
|
||||||
|
char input[BUFFER_SIZE];
|
||||||
|
|
||||||
|
GroundVariable* variables = NULL;
|
||||||
|
GroundLabel* labels = NULL;
|
||||||
|
|
||||||
|
GroundScope scope;
|
||||||
|
scope.variables = &variables;
|
||||||
|
scope.labels = &labels;
|
||||||
|
scope.isMainScope = true;
|
||||||
|
while (true) {
|
||||||
|
Estr programString = CREATE_ESTR("");
|
||||||
|
*scope.labels = NULL;
|
||||||
|
|
||||||
|
// Get program
|
||||||
|
printf(">>> ");
|
||||||
|
while (true) {
|
||||||
|
fgets(input, BUFFER_SIZE, stdin);
|
||||||
|
if (strcmp(input, "\n") == 0) {
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
APPEND_ESTR(programString, input);
|
||||||
|
printf("...");
|
||||||
|
}
|
||||||
|
|
||||||
|
// Interpret program
|
||||||
|
GroundProgram program = createGroundProgram();
|
||||||
|
program = parseFile(programString.str);
|
||||||
|
interpretGroundProgram(&program, &scope);
|
||||||
|
freeGroundProgram(&program);
|
||||||
|
|
||||||
|
DESTROY_ESTR(programString);
|
||||||
|
}
|
||||||
|
}
|
||||||
1
src/repl.h
Normal file
1
src/repl.h
Normal file
@@ -0,0 +1 @@
|
|||||||
|
int repl();
|
||||||
31
src/types.c
31
src/types.c
@@ -87,11 +87,14 @@ GroundValue copyGroundValue(const GroundValue* gv) {
|
|||||||
case CHAR: newGv.data.charVal = gv->data.charVal; break;
|
case CHAR: newGv.data.charVal = gv->data.charVal; break;
|
||||||
case BOOL: newGv.data.boolVal = gv->data.boolVal; break;
|
case BOOL: newGv.data.boolVal = gv->data.boolVal; break;
|
||||||
case STRING:
|
case STRING:
|
||||||
|
/*
|
||||||
if (gv->data.stringVal != NULL) {
|
if (gv->data.stringVal != NULL) {
|
||||||
newGv.data.stringVal = strdup(gv->data.stringVal);
|
newGv.data.stringVal = strdup(gv->data.stringVal);
|
||||||
} else {
|
} else {
|
||||||
newGv.data.stringVal = NULL;
|
newGv.data.stringVal = NULL;
|
||||||
}
|
}
|
||||||
|
*/
|
||||||
|
newGv.data.stringVal = gv->data.stringVal;
|
||||||
break;
|
break;
|
||||||
case LIST: {
|
case LIST: {
|
||||||
List newList = createList();
|
List newList = createList();
|
||||||
@@ -258,7 +261,8 @@ void printGroundValue(GroundValue* gv) {
|
|||||||
|
|
||||||
void freeGroundValue(GroundValue* gv) {
|
void freeGroundValue(GroundValue* gv) {
|
||||||
if (gv->type == STRING && gv->data.stringVal != NULL) {
|
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;
|
gv->data.stringVal = NULL;
|
||||||
}
|
}
|
||||||
if (gv->type == LIST && gv->data.listVal.values != NULL) {
|
if (gv->type == LIST && gv->data.listVal.values != NULL) {
|
||||||
@@ -482,6 +486,21 @@ void printGroundInstruction(GroundInstruction* gi) {
|
|||||||
case LESSER:
|
case LESSER:
|
||||||
printf("lesser");
|
printf("lesser");
|
||||||
break;
|
break;
|
||||||
|
case AND:
|
||||||
|
printf("and");
|
||||||
|
break;
|
||||||
|
case OR:
|
||||||
|
printf("or");
|
||||||
|
break;
|
||||||
|
case XOR:
|
||||||
|
printf("xor");
|
||||||
|
break;
|
||||||
|
case NEG:
|
||||||
|
printf("neg");
|
||||||
|
break;
|
||||||
|
case SHIFT:
|
||||||
|
printf("shift");
|
||||||
|
break;
|
||||||
case STOI:
|
case STOI:
|
||||||
printf("stoi");
|
printf("stoi");
|
||||||
break;
|
break;
|
||||||
@@ -541,6 +560,7 @@ void printGroundInstruction(GroundInstruction* gi) {
|
|||||||
}
|
}
|
||||||
if (gi->type != CREATELABEL) printf(" ");
|
if (gi->type != CREATELABEL) printf(" ");
|
||||||
for (size_t i = 0; i < gi->args.length; i++) {
|
for (size_t i = 0; i < gi->args.length; i++) {
|
||||||
|
if (i != 0) printf(" ");
|
||||||
if (gi->args.args[i].type == VALUE && gi->args.args[i].value.value.type == STRING) {
|
if (gi->args.args[i].type == VALUE && gi->args.args[i].value.value.type == STRING) {
|
||||||
printf("\"");
|
printf("\"");
|
||||||
printGroundArg(&gi->args.args[i]);
|
printGroundArg(&gi->args.args[i]);
|
||||||
@@ -548,7 +568,6 @@ void printGroundInstruction(GroundInstruction* gi) {
|
|||||||
} else {
|
} else {
|
||||||
printGroundArg(&gi->args.args[i]);
|
printGroundArg(&gi->args.args[i]);
|
||||||
}
|
}
|
||||||
printf(" ");
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -561,12 +580,12 @@ List createList() {
|
|||||||
|
|
||||||
void appendToList(List* list, GroundValue value) {
|
void appendToList(List* list, GroundValue value) {
|
||||||
if (list == NULL) {
|
if (list == NULL) {
|
||||||
printf("Expecting a List ptr, got a null pointer instead.\nThis is likely not an error with your Ground program.\nPlease report this issue to https://chsp.au/ground/cground\n");
|
printf("Expecting a List ptr, got a null pointer instead.\nThis is likely not an error with your Ground program.\nPlease report this issue to https://chsp.au/ground/ground\n");
|
||||||
exit(EXIT_FAILURE);
|
exit(EXIT_FAILURE);
|
||||||
}
|
}
|
||||||
GroundValue* ptr = realloc(list->values, (list->size + 1) * sizeof(GroundValue));
|
GroundValue* ptr = realloc(list->values, (list->size + 1) * sizeof(GroundValue));
|
||||||
if (ptr == NULL) {
|
if (ptr == NULL) {
|
||||||
printf("There was an error allocating memory for a list.\nThis is likely not an error with your Ground program.\nPlease report this issue to https://chsp.au/ground/cground\n");
|
printf("There was an error allocating memory for a list.\nThis is likely not an error with your Ground program.\nPlease report this issue to https://chsp.au/ground/ground\n");
|
||||||
exit(EXIT_FAILURE);
|
exit(EXIT_FAILURE);
|
||||||
}
|
}
|
||||||
list->size++;
|
list->size++;
|
||||||
@@ -576,7 +595,7 @@ void appendToList(List* list, GroundValue value) {
|
|||||||
|
|
||||||
ListAccess getListAt(List* list, size_t idx) {
|
ListAccess getListAt(List* list, size_t idx) {
|
||||||
if (list == NULL) {
|
if (list == NULL) {
|
||||||
printf("Expecting a List ptr, got a null pointer instead.\nThis is likely not an error with your Ground program.\nPlease report this issue to https://chsp.au/ground/cground\n");
|
printf("Expecting a List ptr, got a null pointer instead.\nThis is likely not an error with your Ground program.\nPlease report this issue to https://chsp.au/ground/ground\n");
|
||||||
exit(EXIT_FAILURE);
|
exit(EXIT_FAILURE);
|
||||||
}
|
}
|
||||||
if (idx < list->size) {
|
if (idx < list->size) {
|
||||||
@@ -594,7 +613,7 @@ ListAccess getListAt(List* list, size_t idx) {
|
|||||||
|
|
||||||
ListAccessStatus setListAt(List* list, size_t idx, GroundValue value) {
|
ListAccessStatus setListAt(List* list, size_t idx, GroundValue value) {
|
||||||
if (list == NULL) {
|
if (list == NULL) {
|
||||||
printf("Expecting a List ptr, got a null pointer instead.\nThis is likely not an error with your Ground program.\nPlease report this issue to https://chsp.au/ground/cground\n");
|
printf("Expecting a List ptr, got a null pointer instead.\nThis is likely not an error with your Ground program.\nPlease report this issue to https://chsp.au/ground/ground\n");
|
||||||
exit(EXIT_FAILURE);
|
exit(EXIT_FAILURE);
|
||||||
}
|
}
|
||||||
if (idx < list->size) {
|
if (idx < list->size) {
|
||||||
|
|||||||
@@ -29,7 +29,7 @@ void wasm_print(const char* str);
|
|||||||
#endif
|
#endif
|
||||||
|
|
||||||
typedef enum GroundInstType {
|
typedef enum GroundInstType {
|
||||||
IF, JUMP, END, INPUT, PRINT, PRINTLN, SET, GETTYPE, EXISTS, SETLIST, SETLISTAT, GETLISTAT, GETLISTSIZE, LISTAPPEND, GETSTRSIZE, GETSTRCHARAT, ADD, SUBTRACT, MULTIPLY, DIVIDE, EQUAL, INEQUAL, NOT, GREATER, LESSER, STOI, STOD, ITOC, CTOI, TOSTRING, FUN, RETURN, ENDFUN, PUSHARG, CALL, STRUCT, ENDSTRUCT, INIT, GETFIELD, SETFIELD, USE, EXTERN, CREATELABEL, PAUSE, DROP, ERRORCMD
|
IF, JUMP, END, INPUT, PRINT, PRINTLN, SET, GETTYPE, EXISTS, SETLIST, SETLISTAT, GETLISTAT, GETLISTSIZE, LISTAPPEND, GETSTRSIZE, GETSTRCHARAT, ADD, SUBTRACT, MULTIPLY, DIVIDE, EQUAL, INEQUAL, NOT, GREATER, LESSER, AND, OR, XOR, NEG, SHIFT, STOI, STOD, ITOC, CTOI, TOSTRING, FUN, RETURN, ENDFUN, PUSHARG, CALL, STRUCT, ENDSTRUCT, INIT, GETFIELD, SETFIELD, USE, EXTERN, CREATELABEL, PAUSE, DROP, LICENSE, ERRORCMD
|
||||||
} GroundInstType;
|
} GroundInstType;
|
||||||
|
|
||||||
typedef enum GroundValueType {
|
typedef enum GroundValueType {
|
||||||
@@ -83,7 +83,7 @@ typedef struct GroundError {
|
|||||||
typedef struct GroundValue {
|
typedef struct GroundValue {
|
||||||
GroundValueType type;
|
GroundValueType type;
|
||||||
struct GroundStruct* customType;
|
struct GroundStruct* customType;
|
||||||
struct {
|
union {
|
||||||
int64_t intVal;
|
int64_t intVal;
|
||||||
double doubleVal;
|
double doubleVal;
|
||||||
char* stringVal;
|
char* stringVal;
|
||||||
|
|||||||
@@ -1,27 +1,15 @@
|
|||||||
set &x 5
|
set &x 5
|
||||||
|
|
||||||
PAUSE
|
|
||||||
|
|
||||||
fun !dingle -function -int &a
|
fun !dingle -function -int &a
|
||||||
|
|
||||||
PAUSE
|
|
||||||
|
|
||||||
fun !capture -int -int &b
|
fun !capture -int -int &b
|
||||||
|
|
||||||
PAUSE
|
|
||||||
|
|
||||||
add $a $b &tmp
|
add $a $b &tmp
|
||||||
add $tmp $x &tmp
|
add $tmp $x &tmp
|
||||||
return $tmp
|
return $tmp
|
||||||
endfun
|
endfun
|
||||||
|
|
||||||
return $capture
|
return $capture
|
||||||
|
|
||||||
endfun
|
endfun
|
||||||
|
|
||||||
|
set &x 10
|
||||||
call !dingle 3 &result
|
call !dingle 3 &result
|
||||||
|
|
||||||
PAUSE
|
|
||||||
|
|
||||||
call !result 5 &y
|
call !result 5 &y
|
||||||
println $y
|
println $y $x
|
||||||
@@ -1,4 +1,4 @@
|
|||||||
set &x "dingus"
|
set &x "dingus"
|
||||||
PAUSE
|
println $x
|
||||||
drop &x
|
drop &x
|
||||||
PAUSE
|
println $x
|
||||||
2
tests/end.grnd
Normal file
2
tests/end.grnd
Normal file
@@ -0,0 +1,2 @@
|
|||||||
|
set &x 10
|
||||||
|
end $x
|
||||||
4
tests/lib.grnd
Normal file
4
tests/lib.grnd
Normal file
@@ -0,0 +1,4 @@
|
|||||||
|
fun !lib_PrintHello -int
|
||||||
|
println "Hello"
|
||||||
|
return 0
|
||||||
|
endfun
|
||||||
@@ -1,5 +1,6 @@
|
|||||||
# A cool list
|
# A cool list
|
||||||
setlist &favWords "hello" "there" "general" "kenobi"
|
setlist &favWords "hello" "there" "general"
|
||||||
|
listappend &favWords "kenobi"
|
||||||
println $favWords
|
println $favWords
|
||||||
|
|
||||||
set &count 0
|
set &count 0
|
||||||
|
|||||||
@@ -1,11 +1,2 @@
|
|||||||
fun !dingle -int
|
|
||||||
|
|
||||||
endfun
|
|
||||||
|
|
||||||
set &x 5
|
set &x 5
|
||||||
set &y "dingle"
|
|
||||||
PAUSE
|
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
|
endfun
|
||||||
|
|
||||||
# Main program
|
# Main program
|
||||||
println "Computing fib(30) recursively..."
|
println "Computing fib(20) recursively..."
|
||||||
call !fib 30 $fib &answer
|
call !fib 20 $fib &answer
|
||||||
println "Result:" $answer
|
println "Result:" $answer
|
||||||
end
|
end
|
||||||
|
|||||||
@@ -2,10 +2,10 @@ input &str
|
|||||||
getstrsize $str &size
|
getstrsize $str &size
|
||||||
set &idx 0
|
set &idx 0
|
||||||
@loop
|
@loop
|
||||||
getstrcharat $str $idx &char
|
getstrcharat $str $idx &char
|
||||||
println $char
|
println $char
|
||||||
add 1 $idx &idx
|
add 1 $idx &idx
|
||||||
equal $idx $size &cond
|
equal $idx $size &cond
|
||||||
if $cond %loopend
|
if $cond %loopend
|
||||||
jump %loop
|
jump %loop
|
||||||
@loopend
|
@loopend
|
||||||
|
|||||||
82
tests/unit.sh
Executable file
82
tests/unit.sh
Executable file
@@ -0,0 +1,82 @@
|
|||||||
|
#!/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" ]] ||
|
||||||
|
[[ "$f" == "pause.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
|
||||||
|
rm log.txt
|
||||||
|
printf "\033[32mAll tests passed!\n\033[0m"
|
||||||
|
exit 0
|
||||||
2
tests/use.grnd
Normal file
2
tests/use.grnd
Normal file
@@ -0,0 +1,2 @@
|
|||||||
|
use "lib"
|
||||||
|
call !lib_PrintHello &tmp
|
||||||
Reference in New Issue
Block a user