|
|
| version 1.72, 2001/05/08 06:00:34 | version 1.92, 2001/07/09 16:13:17 |
|---|---|
| Line 4 | Line 4 |
| Copyright (c) 2001 ArtLebedev Group (http://www.artlebedev.com) | Copyright (c) 2001 ArtLebedev Group (http://www.artlebedev.com) |
| Author: Alexander Petrosyan <paf@design.ru> (http://design.ru/paf) | Author: Alexander Petrosyan <paf@design.ru> (http://design.ru/paf) |
| $Id$ | |
| */ | */ |
| static const char *RCSId="$Id$"; | |
| #include "pa_config_includes.h" | #include "pa_config_includes.h" |
| Line 43 public: // Methoded | Line 42 public: // Methoded |
| static void _set(Request& r, const String& method_name, MethodParams *params) { | static void _set(Request& r, const String& method_name, MethodParams *params) { |
| Pool& pool=r.pool(); | Pool& pool=r.pool(); |
| // data is last parameter | // data is last parameter |
| Value& vdata=params->get_junction(params->size()-1, "body must be code"); | Value& vdata=params->as_junction(params->size()-1, "body must be code"); |
| Temp_lang temp_lang(r, String::UL_PASS_APPENDED); | Temp_lang temp_lang(r, String::UL_PASS_APPENDED); |
| const String& data=r.process(vdata).as_string(); | const String& data=r.process(vdata).as_string(); |
| Line 85 static void _set(Request& r, const Strin | Line 84 static void _set(Request& r, const Strin |
| static void _load(Request& r, const String& method_name, MethodParams *params) { | static void _load(Request& r, const String& method_name, MethodParams *params) { |
| Pool& pool=r.pool(); | Pool& pool=r.pool(); |
| // filename is last parameter | // filename is last parameter |
| Value& vfilename=params->get_no_junction(params->size()-1, | Value& vfilename=params->as_no_junction(params->size()-1, |
| "file name must not be code"); | "file name must not be code"); |
| // loading text | // loading text |
| Line 131 static void _load(Request& r, const Stri | Line 130 static void _load(Request& r, const Stri |
| static_cast<VTable *>(r.self)->set_table(table); | static_cast<VTable *>(r.self)->set_table(table); |
| } | } |
| static Table *fill_month_days(Request& r, | |
| const String& method_name, MethodParams *params, bool rus){ | |
| Pool& pool=r.pool(); | |
| Table *result=new(pool) Table(pool, &method_name, 0/*&columns*/); | |
| int year=params->as_int(1, r); | |
| int month=max(1, min(params->as_int(2, r), 12)) -1; | |
| tm tmIn={0, 0, 0, 1, month, year-1900}; | |
| time_t t=mktime(&tmIn); | |
| if(t<0) | |
| PTHROW(0, 0, | |
| &method_name, | |
| "invalid date"); | |
| tm *tmOut=localtime(&t); | |
| int weekDay1=tmOut->tm_wday; | |
| if(rus) | |
| weekDay1=weekDay1?weekDay1-1:6; //sunday last | |
| int monthDays=getMonthDays(year, month); | |
| for(int _day=1-weekDay1; _day<=monthDays;) { | |
| Array& row=*new(pool) Array(pool, 7); | |
| for(int wday=0; wday<7; wday++, _day++) { | |
| String *cell; | |
| if(_day>=1 && _day<=monthDays) { | |
| char *buf=(char *)malloc(2+1); | |
| sprintf(buf, "%02d", _day); | |
| cell=new(pool) String(pool, buf); | |
| } else | |
| cell=new(pool) String(pool); | |
| row+=cell; | |
| } | |
| *result+=&row; | |
| } | |
| return result; | |
| } | |
| static Table *fill_week_days(Request& r, | |
| const String& method_name, MethodParams *params, bool rus){ | |
| Pool& pool=r.pool(); | |
| Array& columns=*new(pool) Array(pool, 4); | |
| columns+=new(pool) String(pool, "year"); | |
| columns+=new(pool) String(pool, "month"); | |
| columns+=new(pool) String(pool, "day"); | |
| columns+=new(pool) String(pool, "weekday"); | |
| Table *result=new(pool) Table(pool, &method_name, &columns); | |
| int year=params->as_int(1, r); | |
| int month=max(1, min(params->as_int(2, r), 12)) -1; | |
| int day=params->as_int(3, r); | |
| tm tmIn={0, 0, 18, day, month, year-1900}; | |
| time_t t=mktime(&tmIn); | |
| if(t<0) | |
| PTHROW(0, 0, | |
| &method_name, | |
| "invalid date"); | |
| tm *tmOut=localtime(&t); | |
| int baseWeekDay=tmOut->tm_wday; | |
| if(rus) | |
| baseWeekDay=baseWeekDay?baseWeekDay-1:6; //sunday last | |
| t-=baseWeekDay*SECS_PER_DAY; | |
| for(int curWeekDay=0; curWeekDay<7; curWeekDay++, t+=SECS_PER_DAY) { | |
| tm *tmOut=localtime(&t); | |
| Array& row=*new(pool) Array(pool, 4); | |
| {char *buf=(char *)malloc(4+1); sprintf(buf, "%04d", 1900+tmOut->tm_year); row+=new(pool) String(pool, buf);} | |
| {char *buf=(char *)malloc(2+1); sprintf(buf, "%02d", 1+tmOut->tm_mon); row+=new(pool) String(pool, buf);} | |
| {char *buf=(char *)malloc(2+1); sprintf(buf, "%02d", tmOut->tm_mday); row+=new(pool) String(pool, buf);} | |
| {char *buf=(char *)malloc(2+1); sprintf(buf, "%02d", tmOut->tm_wday); row+=new(pool) String(pool, buf);} | |
| *result+=&row; | |
| } | |
| return result; | |
| } | |
| static void _calendar(Request& r, const String& method_name, MethodParams *params) { | |
| Pool& pool=r.pool(); | |
| const String& what=params->as_string(0, "format must be strig"); | |
| bool rus=false; | |
| if(what=="rus") | |
| rus=true; | |
| else if(what=="eng") | |
| rus=false; | |
| else | |
| PTHROW(0, 0, | |
| &what, | |
| "must be rus|eng"); | |
| Table *result=0; | |
| if(params->size()==1+2) | |
| result=fill_month_days(r, method_name, params, rus); | |
| else // 1+3 | |
| result=fill_week_days(r, method_name, params, rus); | |
| // replace any previous table value | |
| static_cast<VTable *>(r.self)->set_table(*result); | |
| } | |
| static void _save(Request& r, const String& method_name, MethodParams *params) { | static void _save(Request& r, const String& method_name, MethodParams *params) { |
| Pool& pool=r.pool(); | Pool& pool=r.pool(); |
| Value& vtable_name=params->get_no_junction(params->size()-1, | Value& vtable_name=params->as_no_junction(params->size()-1, |
| "file name must not be code"); | "file name must not be code"); |
| Table& table=static_cast<VTable *>(r.self)->table(); | Table& table=static_cast<VTable *>(r.self)->table(); |
| Line 193 static void _line(Request& r, const Stri | Line 299 static void _line(Request& r, const Stri |
| static void _offset(Request& r, const String& method_name, MethodParams *params) { | static void _offset(Request& r, const String& method_name, MethodParams *params) { |
| Pool& pool=r.pool(); | Pool& pool=r.pool(); |
| Table& table=static_cast<VTable *>(r.self)->table(); | Table& table=static_cast<VTable *>(r.self)->table(); |
| if(params->size()) | if(params->size()) { |
| table.shift((int)r.process(params->get(0)).as_double()); | Value& offset_expr=params->as_junction(0, "offset must be expression"); |
| else { | table.shift(r.process(offset_expr).as_int()); |
| } else { | |
| Value& value=*new(pool) VInt(pool, table.current()); | Value& value=*new(pool) VInt(pool, table.current()); |
| r.write_no_lang(value); | r.write_no_lang(value); |
| } | } |
| } | } |
| static void _menu(Request& r, const String& method_name, MethodParams *params) { | static void _menu(Request& r, const String& method_name, MethodParams *params) { |
| Value& body_code=params->get_junction(0, "body must be code"); | Value& body_code=params->as_junction(0, "body must be code"); |
| Value *delim_code=params->size()==2?¶ms->get(1):0; | Value *delim_code=params->size()==2?¶ms->get(1):0; |
| Line 226 static void _menu(Request& r, const Stri | Line 333 static void _menu(Request& r, const Stri |
| } | } |
| static void _empty(Request& r, const String& method_name, MethodParams *params) { | static void _empty(Request& r, const String& method_name, MethodParams *params) { |
| Pool& pool=r.pool(); | |
| Table& table=static_cast<VTable *>(r.self)->table(); | Table& table=static_cast<VTable *>(r.self)->table(); |
| if(table.size()==0) | |
| r.write_pass_lang(r.process(params->get(0))); | r.write_no_lang(*new(pool) VBool(pool, table.size()==0)); |
| else if(params->size()>1) | |
| r.write_pass_lang(r.process(params->get(1))); | |
| } | } |
| /// used by table: _record / store_column_item_to_hash | /// used by table: _record / store_column_item_to_hash |
| Line 242 struct Record_info { | Line 348 struct Record_info { |
| static void store_column_item_to_hash(Array::Item *item, void *info) { | static void store_column_item_to_hash(Array::Item *item, void *info) { |
| Record_info& ri=*static_cast<Record_info *>(info); | Record_info& ri=*static_cast<Record_info *>(info); |
| String& column_name=*static_cast<String *>(item); | String& column_name=*static_cast<String *>(item); |
| const String *column_item=ri.table->item(column_name); | |
| Value *value; | Value *value; |
| if(column_item) | if(const String *column_item=ri.table->item(column_name)) |
| value=new(*ri.pool) VString(*column_item); | value=new(*ri.pool) VString(*column_item); |
| else | else |
| value=new(*ri.pool) VUnknown(*ri.pool); | value=new(*ri.pool) VVoid(*ri.pool); |
| ri.hash->put(column_name, value); | ri.hash->put(column_name, value); |
| } | } |
| static void _record(Request& r, const String& method_name, MethodParams *params) { | static void _record(Request& r, const String& method_name, MethodParams *) { |
| Table& table=static_cast<VTable *>(r.self)->table(); | Table& table=static_cast<VTable *>(r.self)->table(); |
| if(const Array *columns=table.columns()) { | if(const Array *columns=table.columns()) { |
| Pool& pool=r.pool(); | Pool& pool=r.pool(); |
| Value& value=*new(pool) VHash(pool); | Value& result=*new(pool) VHash(pool); |
| Record_info record_info={&pool, &table, value.get_hash()}; | Record_info record_info={&pool, &table, result.get_hash()}; |
| columns->for_each(store_column_item_to_hash, &record_info); | columns->for_each(store_column_item_to_hash, &record_info); |
| result.set_name(method_name); | |
| r.write_no_lang(result); | |
| } | |
| } | |
| /// used by table: _hash / table_row_to_hash | |
| struct Row_info { | |
| Table *table; | |
| int key_field; | |
| Array *value_fields; | |
| Hash *hash; | |
| }; | |
| static void table_row_to_hash(Array::Item *value, void *info) { | |
| Array& row=*static_cast<Array *>(value); | |
| Row_info& ri=*static_cast<Row_info *>(info); | |
| Pool& pool=ri.table->pool(); | |
| if(ri.key_field<row.size()) { | |
| VHash& result=*new(pool) VHash(pool); | |
| Hash& hash=*result.get_hash(); | |
| for(int i=0; i<ri.value_fields->size(); i++) { | |
| int value_field=ri.value_fields->get_int(i); | |
| if(value_field<row.size()) | |
| hash.put( | |
| *ri.table->columns()->get_string(value_field), | |
| new(pool) VString(*row.get_string(value_field))); | |
| } | |
| r.write_no_lang(value); | ri.hash->put(*row.get_string(ri.key_field), &result); |
| } | } |
| } | } |
| static void _hash(Request& r, const String& method_name, MethodParams *params) { | |
| Table& table=static_cast<VTable *>(r.self)->table(); | |
| if(const Array *columns=table.columns()) | |
| if(columns->size()>1) { | |
| Pool& pool=r.pool(); | |
| const String& key_field_name=params->as_no_junction(0, | |
| "key field name must not be code").as_string(); | |
| int key_field=table.column_name2index(key_field_name, true); | |
| int value_fields_count=params->size()-1; | |
| bool value_fields_by_params=value_fields_count!=0; | |
| if(!value_fields_by_params) | |
| value_fields_count=columns->size()-1; // all columns except key | |
| Array value_fields(pool, value_fields_count); | |
| if(value_fields_by_params) { | |
| for(int i=1; i<params->size(); i++) { | |
| const String& value_field_name=params->as_no_junction(i, | |
| "value field name must not be code").as_string(); | |
| value_fields+=table.column_name2index(value_field_name, true); | |
| } | |
| } else { // by all columns except key | |
| for(int i=0; i<columns->size(); i++) | |
| if(i!=key_field) | |
| value_fields+=i; | |
| } | |
| struct Seq_item { | // integers: key_field & value_fields |
| Value& result=*new(pool) VHash(pool); | |
| Row_info row_info={&table, key_field, &value_fields, result.get_hash()}; | |
| table.for_each(table_row_to_hash, &row_info); | |
| result.set_name(method_name); | |
| r.write_no_lang(result); | |
| } | |
| } | |
| /// used by table: _sort / sort_cmp_string|sort_cmp_double | |
| struct Table_seq_item { | |
| Array *row; | Array *row; |
| union { | union { |
| char *c_str; | char *c_str; |
| Line 271 struct Seq_item { | Line 438 struct Seq_item { |
| }; | }; |
| static int sort_cmp_string(const void *a, const void *b) { | static int sort_cmp_string(const void *a, const void *b) { |
| return strcmp( | return strcmp( |
| static_cast<const Seq_item *>(a)->value.c_str, | static_cast<const Table_seq_item *>(a)->value.c_str, |
| static_cast<const Seq_item *>(b)->value.c_str | static_cast<const Table_seq_item *>(b)->value.c_str |
| ); | ); |
| } | } |
| static int sort_cmp_double(const void *a, const void *b) { | static int sort_cmp_double(const void *a, const void *b) { |
| double va=static_cast<const Seq_item *>(a)->value.d; | double va=static_cast<const Table_seq_item *>(a)->value.d; |
| double vb=static_cast<const Seq_item *>(b)->value.d; | double vb=static_cast<const Table_seq_item *>(b)->value.d; |
| if(va<vb) | if(va<vb) |
| return -1; | return -1; |
| else if(va>vb) | else if(va>vb) |
| Line 286 static int sort_cmp_double(const void *a | Line 453 static int sort_cmp_double(const void *a |
| return 0; | return 0; |
| } | } |
| static void _sort(Request& r, const String& method_name, MethodParams *params) { | static void _sort(Request& r, const String& method_name, MethodParams *params) { |
| Value& key_maker=params->get_junction(0, "key-maker must be code"); | Value& key_maker=params->as_junction(0, "key-maker must be code"); |
| bool reverse=params->size()==2/*..[asc|desc]*/? | bool reverse=params->size()==2/*..[asc|desc]*/? |
| reverse=params->get_no_junction(1, "order must not be code").as_string()=="desc": | reverse=params->as_no_junction(1, "order must not be code").as_string()=="desc": |
| false; | false; |
| Table& table=static_cast<VTable *>(r.self)->table(); | Table& table=static_cast<VTable *>(r.self)->table(); |
| Line 298 static void _sort(Request& r, const Stri | Line 465 static void _sort(Request& r, const Stri |
| if(!table.size()) | if(!table.size()) |
| return; | return; |
| Seq_item *seq=(Seq_item *)malloc(sizeof(Seq_item)*table.size()); | Table_seq_item *seq=(Table_seq_item *)malloc(sizeof(Table_seq_item)*table.size()); |
| int i; | int i; |
| // calculate key values | // calculate key values |
| Line 317 static void _sort(Request& r, const Stri | Line 484 static void _sort(Request& r, const Stri |
| seq[i].value.d=value.as_double(); | seq[i].value.d=value.as_double(); |
| } | } |
| // sort keys | // sort keys |
| _qsort(seq, table.size(), sizeof(Seq_item), | _qsort(seq, table.size(), sizeof(Table_seq_item), |
| key_values_are_strings?sort_cmp_string:sort_cmp_double); | key_values_are_strings?sort_cmp_string:sort_cmp_double); |
| // reorder table as they require in 'seq' | // reorder table as they require in 'seq' |
| Line 334 static void _locate(Request& r, const St | Line 501 static void _locate(Request& r, const St |
| VTable& vtable=*static_cast<VTable *>(r.self); | VTable& vtable=*static_cast<VTable *>(r.self); |
| Table& table=vtable.table(); | Table& table=vtable.table(); |
| Value& result=*new(pool) VBool(pool, table.locate( | Value& result=*new(pool) VBool(pool, table.locate( |
| params->get(0).as_string(), | params->get(0).as_string(), |
| params->get(1).as_string())); | params->get(1).as_string())); |
| result.set_name(method_name); | result.set_name(method_name); |
| r.write_no_lang(result); | r.write_no_lang(result); |
| Line 364 static void _append(Request& r, const St | Line 531 static void _append(Request& r, const St |
| Pool& pool=r.pool(); | Pool& pool=r.pool(); |
| // data is last parameter | // data is last parameter |
| const String& string= | const String& string= |
| r.process(params->get_junction(0, "body must be code")).as_string(); | r.process(params->as_junction(0, "body must be code")).as_string(); |
| // parse cells | // parse cells |
| Array& row=*new(pool) Array(pool); | Array& row=*new(pool) Array(pool); |
| Line 380 static void _append(Request& r, const St | Line 547 static void _append(Request& r, const St |
| static void _join(Request& r, const String& method_name, MethodParams *params) { | static void _join(Request& r, const String& method_name, MethodParams *params) { |
| Pool& pool=r.pool(); | Pool& pool=r.pool(); |
| Table *maybe_src=params->get_no_junction(0, "table ref must not be code").get_table(); | Table *maybe_src=params->as_no_junction(0, "table ref must not be code").get_table(); |
| if(!maybe_src) | if(!maybe_src) |
| PTHROW(0, 0, | PTHROW(0, 0, |
| &method_name, | &method_name, |
| "source is not a table"); | "source is not a table"); |
| Table& src=*maybe_src; | Table& src=*maybe_src; |
| Table& dest=static_cast<VTable *>(r.self)->table(); | Table& dest=static_cast<VTable *>(r.self)->table(); |
| if(&src == &dest) | if(&src == &dest) |
| PTHROW(0, 0, | PTHROW(0, 0, |
| &method_name, | &method_name, |
| "source and destination are same table"); | "source and destination are same table"); |
| if(const Array *dest_columns=dest.columns()) { // dest is named | if(const Array *dest_columns=dest.columns()) { // dest is named |
| Line 413 static void _sql(Request& r, const Strin | Line 580 static void _sql(Request& r, const Strin |
| Pool& pool=r.pool(); | Pool& pool=r.pool(); |
| if(!r.connection) | if(!r.connection) |
| PTHROW(0, 0, | PTHROW(0, 0, |
| &method_name, | &method_name, |
| "without connect"); | "without connect"); |
| Value& statement=params->get_junction(0, "statement must be code"); | Value& statement=params->as_junction(0, "statement must be code"); |
| ulong limit=0; | ulong limit=0; |
| if(params->size()>1) { | if(params->size()>1) { |
| Value& limit_code=params->get_junction(1, "limit must be expression"); | Value& limit_code=params->as_junction(1, "limit must be expression"); |
| limit=(uint)r.process(limit_code).as_double(); | limit=(uint)r.process(limit_code).as_double(); |
| } | } |
| ulong offset=0; | ulong offset=0; |
| if(params->size()>2) { | if(params->size()>2) { |
| Value& offset_code=params->get_junction(2, "offset must be expression"); | Value& offset_code=params->as_junction(2, "offset must be expression"); |
| offset=(ulong)r.process(offset_code).as_double(); | offset=(ulong)r.process(offset_code).as_double(); |
| } | } |
| Line 440 static void _sql(Request& r, const Strin | Line 607 static void _sql(Request& r, const Strin |
| bool need_rethrow=false; Exception rethrow_me; | bool need_rethrow=false; Exception rethrow_me; |
| PTRY { | PTRY { |
| r.connection->query( | r.connection->query( |
| statement_cstr, offset, limit, | statement_cstr, offset, limit, |
| &sql_column_count, &sql_columns, | &sql_column_count, &sql_columns, |
| &sql_row_count, &sql_rows); | &sql_row_count, &sql_rows); |
| } | } |
| PCATCH(e) { // connect/process problem | PCATCH(e) { // query problem |
| rethrow_me=e; need_rethrow=true; | rethrow_me=e; need_rethrow=true; |
| } | } |
| PEND_CATCH | PEND_CATCH |
| if(need_rethrow) | if(need_rethrow) |
| PTHROW(rethrow_me.type(), rethrow_me.code(), | PTHROW(rethrow_me.type(), rethrow_me.code(), |
| &statement_string, // setting more specific source [were url] | &statement_string, // setting more specific source [were url] |
| rethrow_me.comment()); | rethrow_me.comment()); |
| Line 457 static void _sql(Request& r, const Strin | Line 624 static void _sql(Request& r, const Strin |
| for(unsigned int i=0; i<sql_column_count; i++) { | for(unsigned int i=0; i<sql_column_count; i++) { |
| String& table_column=*new(pool) String(pool); | String& table_column=*new(pool) String(pool); |
| table_column.APPEND_TAINTED( | table_column.APPEND_TAINTED( |
| (const char *)sql_columns[i].ptr, sql_columns[i].size, | (const char *)sql_columns[i].ptr, sql_columns[i].size, |
| statement_cstr, 0); | statement_cstr, 0); |
| table_columns+=&table_column; | table_columns+=&table_column; |
| } | } |
| Table& table=*new(pool) Table(pool, &method_name, &table_columns); | Table& table=*new(pool) Table(pool, &method_name, &table_columns); |
| { | for(unsigned long row=0; row<sql_row_count; row++) { |
| for(unsigned long r=0; r<sql_row_count; r++) { | SQL_Driver::Cell *sql_cells=sql_rows[row]; |
| SQL_Driver::Cell *sql_cells=sql_rows[r]; | Array& table_row=*new(pool) Array(pool); |
| Array& table_row=*new(pool) Array(pool); | |
| for(unsigned int i=0; i<sql_column_count; i++) { | |
| for(unsigned int i=0; i<sql_column_count; i++) { | String& table_cell=*new(pool) String(pool); |
| String& table_cell=*new(pool) String(pool); | if(sql_cells[i].size) |
| table_cell.APPEND_TAINTED( | table_cell.APPEND_TAINTED( |
| (const char *)sql_cells[i].ptr, sql_cells[i].size, | (const char *)sql_cells[i].ptr, sql_cells[i].size, |
| statement_cstr, r); | statement_cstr, row); |
| table_row+=&table_cell; | table_row+=&table_cell; |
| } | |
| table+=&table_row; | |
| } | } |
| table+=&table_row; | |
| } | } |
| // replace any previous table value | // replace any previous table value |
| Line 487 static void _sql(Request& r, const Strin | Line 653 static void _sql(Request& r, const Strin |
| static void _dir(Request& r, const String& method_name, MethodParams *params) { | static void _dir(Request& r, const String& method_name, MethodParams *params) { |
| Pool& pool=r.pool(); | Pool& pool=r.pool(); |
| Value& relative_path=params->get_no_junction(0, "path must not be code"); | Value& relative_path=params->as_no_junction(0, "path must not be code"); |
| const String *regexp; | const String *regexp; |
| pcre *regexp_code; | pcre *regexp_code; |
| int ovecsize; | int ovecsize; |
| int *ovector; | int *ovector; |
| if(params->size()>1) { | if(params->size()>1) { |
| regexp=¶ms->get_no_junction(1, "regexp must not be code").as_string(); | regexp=¶ms->as_no_junction(1, "regexp must not be code").as_string(); |
| const char *pattern=regexp->cstr(String::UL_AS_IS); | const char *pattern=regexp->cstr(String::UL_AS_IS); |
| const char *errptr; | const char *errptr; |
| int erroffset; | int erroffset; |
| regexp_code=pcre_compile(pattern, PCRE_EXTRA | PCRE_DOTALL, | regexp_code=pcre_compile(pattern, PCRE_EXTRA | PCRE_DOTALL, |
| &errptr, &erroffset, | &errptr, &erroffset, |
| r.pcre_tables); | r.pcre_tables); |
| if(!regexp_code) | if(!regexp_code) |
| PTHROW(0, 0, | PTHROW(0, 0, |
| ®exp->mid(erroffset, regexp->size()), | ®exp->mid(erroffset, regexp->size()), |
| "regular expression syntax error - %s", errptr); | "regular expression syntax error - %s", errptr); |
| ovector=(int *)malloc(sizeof(int)*(ovecsize=(1/*match*/)*3)); | ovector=(int *)malloc(sizeof(int)*(ovecsize=(1/*match*/)*3)); |
| Line 524 static void _dir(Request& r, const Strin | Line 690 static void _dir(Request& r, const Strin |
| size_t file_name_size=strlen(ffblk.ff_name); | size_t file_name_size=strlen(ffblk.ff_name); |
| bool suits=true; | bool suits=true; |
| if(regexp_code) { | if(regexp_code) { |
| int exec_result=pcre_exec(regexp_code, 0, | int exec_result=pcre_exec(regexp_code, 0, |
| ffblk.ff_name, file_name_size, 0, | ffblk.ff_name, file_name_size, 0, |
| 0, ovector, ovecsize); | 0, ovector, ovecsize); |
| if(exec_result==PCRE_ERROR_NOMATCH) | if(exec_result==PCRE_ERROR_NOMATCH) |
| suits=false; | suits=false; |
| else if(exec_result<0) { | else if(exec_result<0) { |
| (*pcre_free)(regexp_code); | (*pcre_free)(regexp_code); |
| PTHROW(0, 0, | PTHROW(0, 0, |
| regexp, | regexp, |
| "regular expression execute (%d)", | "regular expression execute (%d)", |
| exec_result); | exec_result); |
| } | } |
| Line 543 static void _dir(Request& r, const Strin | Line 709 static void _dir(Request& r, const Strin |
| char *file_name_cstr=(char *)r.malloc(file_name_size); | char *file_name_cstr=(char *)r.malloc(file_name_size); |
| memcpy(file_name_cstr, ffblk.ff_name, file_name_size); | memcpy(file_name_cstr, ffblk.ff_name, file_name_size); |
| String &file_name=*new(pool) String(pool); | String &file_name=*new(pool) String(pool); |
| file_name.APPEND(file_name_cstr, file_name_size, String::UL_FILE_NAME, | file_name.APPEND(file_name_cstr, file_name_size, String::UL_FILE_NAME, |
| method_name.origin().file, method_name.origin().line); | method_name.origin().file, method_name.origin().line); |
| Array& row=*new(pool) Array(pool); | Array& row=*new(pool) Array(pool); |
| Line 559 static void _dir(Request& r, const Strin | Line 725 static void _dir(Request& r, const Strin |
| static_cast<VTable *>(r.self)->set_table(table); | static_cast<VTable *>(r.self)->set_table(table); |
| } | } |
| static void _columns(Request& r, const String& method_name, MethodParams *) { | |
| Pool& pool=r.pool(); | |
| Array& result_columns=*new(pool) Array(pool); | |
| result_columns+=new(pool) String(pool, "column"); | |
| Table& result_table=*new(pool) Table(pool, &method_name, &result_columns); | |
| Table& source_table=static_cast<VTable *>(r.self)->table(); | |
| if(const Array *source_columns=source_table.columns()) { | |
| int size=source_columns->quick_size(); | |
| for(int i=0; i<size; i++) { | |
| Array& result_row=*new(pool) Array(pool); | |
| result_row+=source_columns->quick_get(i); | |
| result_table+=&result_row; | |
| } | |
| } | |
| VTable& result=*new(pool) VTable(pool, &result_table); | |
| result.set_name(method_name); | |
| r.write_no_lang(result); | |
| } | |
| // constructor | // constructor |
| MTable::MTable(Pool& apool) : Methoded(apool) { | MTable::MTable(Pool& apool) : Methoded(apool) { |
| Line 572 MTable::MTable(Pool& apool) : Methoded(a | Line 760 MTable::MTable(Pool& apool) : Methoded(a |
| // ^table:load[nameless;file] | // ^table:load[nameless;file] |
| add_native_method("load", Method::CT_DYNAMIC, _load, 1, 2); | add_native_method("load", Method::CT_DYNAMIC, _load, 1, 2); |
| // ^table:calendar[month|montheng;year;month] | |
| // ^table:calendar[week|weekeng;year;month;day] | |
| add_native_method("calendar", Method::CT_DYNAMIC, _calendar, 3, 4); | |
| // ^table.save[file] | // ^table.save[file] |
| // ^table.save[nameless;file] | // ^table.save[nameless;file] |
| add_native_method("save", Method::CT_DYNAMIC, _save, 1, 2); | add_native_method("save", Method::CT_DYNAMIC, _save, 1, 2); |
| Line 590 MTable::MTable(Pool& apool) : Methoded(a | Line 782 MTable::MTable(Pool& apool) : Methoded(a |
| // ^table.menu{code}[delim] | // ^table.menu{code}[delim] |
| add_native_method("menu", Method::CT_DYNAMIC, _menu, 1, 2); | add_native_method("menu", Method::CT_DYNAMIC, _menu, 1, 2); |
| // ^table.empty{code-when-empty} | // ^table.empty[] |
| // ^table.empty{code-when-empty}{code-when-not} | add_native_method("empty", Method::CT_DYNAMIC, _empty, 0, 0); |
| add_native_method("empty", Method::CT_DYNAMIC, _empty, 1, 2); | |
| // ^table.record[] | // ^table.record[] |
| add_native_method("record", Method::CT_DYNAMIC, _record, 0, 0); | add_native_method("record", Method::CT_DYNAMIC, _record, 0, 0); |
| // ^table:hash[key field name] | |
| // ^table:hash[key field name][value field name;...] | |
| add_native_method("hash", Method::CT_DYNAMIC, _hash, 1, 1000); | |
| // ^table.sort{string-key-maker} ^table.sort{string-key-maker}[asc|desc] | // ^table.sort{string-key-maker} ^table.sort{string-key-maker}[asc|desc] |
| // ^table.sort(numeric-key-maker) ^table.sort(numeric-key-maker)[asc|desc] | // ^table.sort(numeric-key-maker) ^table.sort(numeric-key-maker)[asc|desc] |
| add_native_method("sort", Method::CT_DYNAMIC, _sort, 1, 2); | add_native_method("sort", Method::CT_DYNAMIC, _sort, 1, 2); |
| Line 620 MTable::MTable(Pool& apool) : Methoded(a | Line 815 MTable::MTable(Pool& apool) : Methoded(a |
| // ^table:dir[path] | // ^table:dir[path] |
| // ^table:dir[path][regexp] | // ^table:dir[path][regexp] |
| add_native_method("dir", Method::CT_DYNAMIC, _dir, 1, 2); | add_native_method("dir", Method::CT_DYNAMIC, _dir, 1, 2); |
| // ^table:columns[] | |
| add_native_method("columns", Method::CT_DYNAMIC, _columns, 0, 0); | |
| } | } |
| // global variable | // global variable |